Latest generation

org.client.ts

@@ -1,4 +1,4 @@
-// @generated by protobuf-ts 2.10.0 with parameter use_proto_field_name
+// @generated by protobuf-ts 2.11.0 with parameter use_proto_field_name
 // @generated from protobuf file "org.proto" (package "api", syntax proto3)
 // tslint:disable
 import type { RpcTransport } from "@protobuf-ts/runtime-rpc";
@@ -64,107 +64,107 @@ import type { RpcOptions } from "@protobuf-ts/runtime-rpc";
  */
 export interface IOrganisationServiceClient {
     /**
-     * @generated from protobuf rpc: Get(api.GetOrganisationRequest) returns (api.GetOrganisationResult);
+     * @generated from protobuf rpc: Get
      */
     get(input: GetOrganisationRequest, options?: RpcOptions): UnaryCall<GetOrganisationRequest, GetOrganisationResult>;
     /**
-     * @generated from protobuf rpc: Create(api.CreateOrganisationRequest) returns (api.CreateOrganisationResult);
+     * @generated from protobuf rpc: Create
      */
     create(input: CreateOrganisationRequest, options?: RpcOptions): UnaryCall<CreateOrganisationRequest, CreateOrganisationResult>;
     /**
-     * @generated from protobuf rpc: SetModules(api.SetModulesOrganisationRequest) returns (api.SetModulesOrganisationResult);
+     * @generated from protobuf rpc: SetModules
      */
     setModules(input: SetModulesOrganisationRequest, options?: RpcOptions): UnaryCall<SetModulesOrganisationRequest, SetModulesOrganisationResult>;
     /**
-     * @generated from protobuf rpc: Update(api.UpdateOrganisationRequest) returns (api.UpdateOrganisationResult);
+     * @generated from protobuf rpc: Update
      */
     update(input: UpdateOrganisationRequest, options?: RpcOptions): UnaryCall<UpdateOrganisationRequest, UpdateOrganisationResult>;
     /**
-     * @generated from protobuf rpc: Delete(api.DeleteOrganisationRequest) returns (api.DeleteOrganisationResult);
+     * @generated from protobuf rpc: Delete
      */
     delete(input: DeleteOrganisationRequest, options?: RpcOptions): UnaryCall<DeleteOrganisationRequest, DeleteOrganisationResult>;
     /**
-     * @generated from protobuf rpc: List(api.ListOrganisationRequest) returns (api.ListOrganisationResult);
+     * @generated from protobuf rpc: List
      */
     list(input: ListOrganisationRequest, options?: RpcOptions): UnaryCall<ListOrganisationRequest, ListOrganisationResult>;
     /**
-     * @generated from protobuf rpc: UpdateStatus(api.UpdateOrganisationStatusRequest) returns (api.UpdateOrganisationStatusResult);
+     * @generated from protobuf rpc: UpdateStatus
      */
     updateStatus(input: UpdateOrganisationStatusRequest, options?: RpcOptions): UnaryCall<UpdateOrganisationStatusRequest, UpdateOrganisationStatusResult>;
     /**
-     * @generated from protobuf rpc: StartStreamingJobs(api.StartStreamingJobsRequest) returns (api.StartStreamingJobsResult);
+     * @generated from protobuf rpc: StartStreamingJobs
      */
     startStreamingJobs(input: StartStreamingJobsRequest, options?: RpcOptions): UnaryCall<StartStreamingJobsRequest, StartStreamingJobsResult>;
     /**
-     * @generated from protobuf rpc: StopStreamingJobs(api.StopStreamingJobsRequest) returns (api.StopStreamingJobsResult);
+     * @generated from protobuf rpc: StopStreamingJobs
      */
     stopStreamingJobs(input: StopStreamingJobsRequest, options?: RpcOptions): UnaryCall<StopStreamingJobsRequest, StopStreamingJobsResult>;
     /**
-     * @generated from protobuf rpc: CheckStreamingStatus(api.CheckStreamingStatusRequest) returns (api.CheckStreamingStatusResult);
+     * @generated from protobuf rpc: CheckStreamingStatus
      */
     checkStreamingStatus(input: CheckStreamingStatusRequest, options?: RpcOptions): UnaryCall<CheckStreamingStatusRequest, CheckStreamingStatusResult>;
     /**
-     * @generated from protobuf rpc: StopAllStreamingJobs(api.StopAllStreamingJobsRequest) returns (api.StopAllStreamingJobsResult);
+     * @generated from protobuf rpc: StopAllStreamingJobs
      */
     stopAllStreamingJobs(input: StopAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<StopAllStreamingJobsRequest, StopAllStreamingJobsResult>;
     /**
-     * @generated from protobuf rpc: RestartAllStreamingJobs(api.RestartAllStreamingJobsRequest) returns (api.RestartAllStreamingJobsResult);
+     * @generated from protobuf rpc: RestartAllStreamingJobs
      */
     restartAllStreamingJobs(input: RestartAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<RestartAllStreamingJobsRequest, RestartAllStreamingJobsResult>;
     /**
-     * @generated from protobuf rpc: StartAllStreamingJobs(api.StartAllStreamingJobsRequest) returns (api.StartAllStreamingJobsResult);
+     * @generated from protobuf rpc: StartAllStreamingJobs
      */
     startAllStreamingJobs(input: StartAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<StartAllStreamingJobsRequest, StartAllStreamingJobsResult>;
     /**
-     * @generated from protobuf rpc: ForceStopAllStreamingJobs(api.ForceStopAllStreamingJobsRequest) returns (api.ForceStopAllStreamingJobsResult);
+     * @generated from protobuf rpc: ForceStopAllStreamingJobs
      */
     forceStopAllStreamingJobs(input: ForceStopAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<ForceStopAllStreamingJobsRequest, ForceStopAllStreamingJobsResult>;
     /**
-     * @generated from protobuf rpc: StartStreamingMetricsJob(api.StartStreamingMetricsJobRequest) returns (api.StartStreamingMetricsJobResult);
+     * @generated from protobuf rpc: StartStreamingMetricsJob
      */
     startStreamingMetricsJob(input: StartStreamingMetricsJobRequest, options?: RpcOptions): UnaryCall<StartStreamingMetricsJobRequest, StartStreamingMetricsJobResult>;
     /**
-     * @generated from protobuf rpc: StopStreamingMetricsJob(api.StopStreamingMetricsJobRequest) returns (api.StopStreamingMetricsJobResult);
+     * @generated from protobuf rpc: StopStreamingMetricsJob
      */
     stopStreamingMetricsJob(input: StopStreamingMetricsJobRequest, options?: RpcOptions): UnaryCall<StopStreamingMetricsJobRequest, StopStreamingMetricsJobResult>;
     /**
-     * @generated from protobuf rpc: StartIndividualStreamingJob(api.StartIndividualStreamingJobRequest) returns (api.StartIndividualStreamingJobResult);
+     * @generated from protobuf rpc: StartIndividualStreamingJob
      */
     startIndividualStreamingJob(input: StartIndividualStreamingJobRequest, options?: RpcOptions): UnaryCall<StartIndividualStreamingJobRequest, StartIndividualStreamingJobResult>;
     /**
-     * @generated from protobuf rpc: StopIndividualStreamingJob(api.StopIndividualStreamingJobRequest) returns (api.StopIndividualStreamingJobResult);
+     * @generated from protobuf rpc: StopIndividualStreamingJob
      */
     stopIndividualStreamingJob(input: StopIndividualStreamingJobRequest, options?: RpcOptions): UnaryCall<StopIndividualStreamingJobRequest, StopIndividualStreamingJobResult>;
     /**
-     * @generated from protobuf rpc: ProvisionGitOrg(api.ProvisionGitOrgRequest) returns (api.ProvisionGitOrgResult);
+     * @generated from protobuf rpc: ProvisionGitOrg
      */
     provisionGitOrg(input: ProvisionGitOrgRequest, options?: RpcOptions): UnaryCall<ProvisionGitOrgRequest, ProvisionGitOrgResult>;
     /**
-     * @generated from protobuf rpc: DeprovisionGitOrg(api.DeprovisionGitOrgRequest) returns (api.DeprovisionGitOrgResult);
+     * @generated from protobuf rpc: DeprovisionGitOrg
      */
     deprovisionGitOrg(input: DeprovisionGitOrgRequest, options?: RpcOptions): UnaryCall<DeprovisionGitOrgRequest, DeprovisionGitOrgResult>;
     /**
-     * @generated from protobuf rpc: CreatePulsar(api.CreatePulsarRequest) returns (api.CreatePulsarResult);
+     * @generated from protobuf rpc: CreatePulsar
      */
     createPulsar(input: CreatePulsarRequest, options?: RpcOptions): UnaryCall<CreatePulsarRequest, CreatePulsarResult>;
     /**
-     * @generated from protobuf rpc: CreatePulsarSubscriptions(api.CreatePulsarSubscriptionsRequest) returns (api.CreatePulsarSubscriptionsResult);
+     * @generated from protobuf rpc: CreatePulsarSubscriptions
      */
     createPulsarSubscriptions(input: CreatePulsarSubscriptionsRequest, options?: RpcOptions): UnaryCall<CreatePulsarSubscriptionsRequest, CreatePulsarSubscriptionsResult>;
     /**
-     * @generated from protobuf rpc: DeletePulsar(api.DeletePulsarRequest) returns (api.DeletePulsarResult);
+     * @generated from protobuf rpc: DeletePulsar
      */
     deletePulsar(input: DeletePulsarRequest, options?: RpcOptions): UnaryCall<DeletePulsarRequest, DeletePulsarResult>;
     /**
-     * @generated from protobuf rpc: CreatePulsarMissPartitions(api.CreatePulsarMissPartitionsRequest) returns (api.CreatePulsarMissPartitionsResult);
+     * @generated from protobuf rpc: CreatePulsarMissPartitions
      */
     createPulsarMissPartitions(input: CreatePulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall<CreatePulsarMissPartitionsRequest, CreatePulsarMissPartitionsResult>;
     /**
-     * @generated from protobuf rpc: CreateAllPulsarMissPartitions(api.CreateAllPulsarMissPartitionsRequest) returns (api.CreateAllPulsarMissPartitionsResult);
+     * @generated from protobuf rpc: CreateAllPulsarMissPartitions
      */
     createAllPulsarMissPartitions(input: CreateAllPulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall<CreateAllPulsarMissPartitionsRequest, CreateAllPulsarMissPartitionsResult>;
     /**
-     * @generated from protobuf rpc: DeleteOrganisationInDB(api.DeleteOrganisationInDBRequest) returns (api.DeleteOrganisationInDBResult);
+     * @generated from protobuf rpc: DeleteOrganisationInDB
      */
     deleteOrganisationInDB(input: DeleteOrganisationInDBRequest, options?: RpcOptions): UnaryCall<DeleteOrganisationInDBRequest, DeleteOrganisationInDBResult>;
 }
@@ -178,182 +178,182 @@ export class OrganisationServiceClient implements IOrganisationServiceClient, Se
     constructor(private readonly _transport: RpcTransport) {
     }
     /**
-     * @generated from protobuf rpc: Get(api.GetOrganisationRequest) returns (api.GetOrganisationResult);
+     * @generated from protobuf rpc: Get
      */
     get(input: GetOrganisationRequest, options?: RpcOptions): UnaryCall<GetOrganisationRequest, GetOrganisationResult> {
         const method = this.methods[0], opt = this._transport.mergeOptions(options);
         return stackIntercept<GetOrganisationRequest, GetOrganisationResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: Create(api.CreateOrganisationRequest) returns (api.CreateOrganisationResult);
+     * @generated from protobuf rpc: Create
      */
     create(input: CreateOrganisationRequest, options?: RpcOptions): UnaryCall<CreateOrganisationRequest, CreateOrganisationResult> {
         const method = this.methods[1], opt = this._transport.mergeOptions(options);
         return stackIntercept<CreateOrganisationRequest, CreateOrganisationResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: SetModules(api.SetModulesOrganisationRequest) returns (api.SetModulesOrganisationResult);
+     * @generated from protobuf rpc: SetModules
      */
     setModules(input: SetModulesOrganisationRequest, options?: RpcOptions): UnaryCall<SetModulesOrganisationRequest, SetModulesOrganisationResult> {
         const method = this.methods[2], opt = this._transport.mergeOptions(options);
         return stackIntercept<SetModulesOrganisationRequest, SetModulesOrganisationResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: Update(api.UpdateOrganisationRequest) returns (api.UpdateOrganisationResult);
+     * @generated from protobuf rpc: Update
      */
     update(input: UpdateOrganisationRequest, options?: RpcOptions): UnaryCall<UpdateOrganisationRequest, UpdateOrganisationResult> {
         const method = this.methods[3], opt = this._transport.mergeOptions(options);
         return stackIntercept<UpdateOrganisationRequest, UpdateOrganisationResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: Delete(api.DeleteOrganisationRequest) returns (api.DeleteOrganisationResult);
+     * @generated from protobuf rpc: Delete
      */
     delete(input: DeleteOrganisationRequest, options?: RpcOptions): UnaryCall<DeleteOrganisationRequest, DeleteOrganisationResult> {
         const method = this.methods[4], opt = this._transport.mergeOptions(options);
         return stackIntercept<DeleteOrganisationRequest, DeleteOrganisationResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: List(api.ListOrganisationRequest) returns (api.ListOrganisationResult);
+     * @generated from protobuf rpc: List
      */
     list(input: ListOrganisationRequest, options?: RpcOptions): UnaryCall<ListOrganisationRequest, ListOrganisationResult> {
         const method = this.methods[5], opt = this._transport.mergeOptions(options);
         return stackIntercept<ListOrganisationRequest, ListOrganisationResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: UpdateStatus(api.UpdateOrganisationStatusRequest) returns (api.UpdateOrganisationStatusResult);
+     * @generated from protobuf rpc: UpdateStatus
      */
     updateStatus(input: UpdateOrganisationStatusRequest, options?: RpcOptions): UnaryCall<UpdateOrganisationStatusRequest, UpdateOrganisationStatusResult> {
         const method = this.methods[6], opt = this._transport.mergeOptions(options);
         return stackIntercept<UpdateOrganisationStatusRequest, UpdateOrganisationStatusResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: StartStreamingJobs(api.StartStreamingJobsRequest) returns (api.StartStreamingJobsResult);
+     * @generated from protobuf rpc: StartStreamingJobs
      */
     startStreamingJobs(input: StartStreamingJobsRequest, options?: RpcOptions): UnaryCall<StartStreamingJobsRequest, StartStreamingJobsResult> {
         const method = this.methods[7], opt = this._transport.mergeOptions(options);
         return stackIntercept<StartStreamingJobsRequest, StartStreamingJobsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: StopStreamingJobs(api.StopStreamingJobsRequest) returns (api.StopStreamingJobsResult);
+     * @generated from protobuf rpc: StopStreamingJobs
      */
     stopStreamingJobs(input: StopStreamingJobsRequest, options?: RpcOptions): UnaryCall<StopStreamingJobsRequest, StopStreamingJobsResult> {
         const method = this.methods[8], opt = this._transport.mergeOptions(options);
         return stackIntercept<StopStreamingJobsRequest, StopStreamingJobsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: CheckStreamingStatus(api.CheckStreamingStatusRequest) returns (api.CheckStreamingStatusResult);
+     * @generated from protobuf rpc: CheckStreamingStatus
      */
     checkStreamingStatus(input: CheckStreamingStatusRequest, options?: RpcOptions): UnaryCall<CheckStreamingStatusRequest, CheckStreamingStatusResult> {
         const method = this.methods[9], opt = this._transport.mergeOptions(options);
         return stackIntercept<CheckStreamingStatusRequest, CheckStreamingStatusResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: StopAllStreamingJobs(api.StopAllStreamingJobsRequest) returns (api.StopAllStreamingJobsResult);
+     * @generated from protobuf rpc: StopAllStreamingJobs
      */
     stopAllStreamingJobs(input: StopAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<StopAllStreamingJobsRequest, StopAllStreamingJobsResult> {
         const method = this.methods[10], opt = this._transport.mergeOptions(options);
         return stackIntercept<StopAllStreamingJobsRequest, StopAllStreamingJobsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: RestartAllStreamingJobs(api.RestartAllStreamingJobsRequest) returns (api.RestartAllStreamingJobsResult);
+     * @generated from protobuf rpc: RestartAllStreamingJobs
      */
     restartAllStreamingJobs(input: RestartAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<RestartAllStreamingJobsRequest, RestartAllStreamingJobsResult> {
         const method = this.methods[11], opt = this._transport.mergeOptions(options);
         return stackIntercept<RestartAllStreamingJobsRequest, RestartAllStreamingJobsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: StartAllStreamingJobs(api.StartAllStreamingJobsRequest) returns (api.StartAllStreamingJobsResult);
+     * @generated from protobuf rpc: StartAllStreamingJobs
      */
     startAllStreamingJobs(input: StartAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<StartAllStreamingJobsRequest, StartAllStreamingJobsResult> {
         const method = this.methods[12], opt = this._transport.mergeOptions(options);
         return stackIntercept<StartAllStreamingJobsRequest, StartAllStreamingJobsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: ForceStopAllStreamingJobs(api.ForceStopAllStreamingJobsRequest) returns (api.ForceStopAllStreamingJobsResult);
+     * @generated from protobuf rpc: ForceStopAllStreamingJobs
      */
     forceStopAllStreamingJobs(input: ForceStopAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<ForceStopAllStreamingJobsRequest, ForceStopAllStreamingJobsResult> {
         const method = this.methods[13], opt = this._transport.mergeOptions(options);
         return stackIntercept<ForceStopAllStreamingJobsRequest, ForceStopAllStreamingJobsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: StartStreamingMetricsJob(api.StartStreamingMetricsJobRequest) returns (api.StartStreamingMetricsJobResult);
+     * @generated from protobuf rpc: StartStreamingMetricsJob
      */
     startStreamingMetricsJob(input: StartStreamingMetricsJobRequest, options?: RpcOptions): UnaryCall<StartStreamingMetricsJobRequest, StartStreamingMetricsJobResult> {
         const method = this.methods[14], opt = this._transport.mergeOptions(options);
         return stackIntercept<StartStreamingMetricsJobRequest, StartStreamingMetricsJobResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: StopStreamingMetricsJob(api.StopStreamingMetricsJobRequest) returns (api.StopStreamingMetricsJobResult);
+     * @generated from protobuf rpc: StopStreamingMetricsJob
      */
     stopStreamingMetricsJob(input: StopStreamingMetricsJobRequest, options?: RpcOptions): UnaryCall<StopStreamingMetricsJobRequest, StopStreamingMetricsJobResult> {
         const method = this.methods[15], opt = this._transport.mergeOptions(options);
         return stackIntercept<StopStreamingMetricsJobRequest, StopStreamingMetricsJobResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: StartIndividualStreamingJob(api.StartIndividualStreamingJobRequest) returns (api.StartIndividualStreamingJobResult);
+     * @generated from protobuf rpc: StartIndividualStreamingJob
      */
     startIndividualStreamingJob(input: StartIndividualStreamingJobRequest, options?: RpcOptions): UnaryCall<StartIndividualStreamingJobRequest, StartIndividualStreamingJobResult> {
         const method = this.methods[16], opt = this._transport.mergeOptions(options);
         return stackIntercept<StartIndividualStreamingJobRequest, StartIndividualStreamingJobResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: StopIndividualStreamingJob(api.StopIndividualStreamingJobRequest) returns (api.StopIndividualStreamingJobResult);
+     * @generated from protobuf rpc: StopIndividualStreamingJob
      */
     stopIndividualStreamingJob(input: StopIndividualStreamingJobRequest, options?: RpcOptions): UnaryCall<StopIndividualStreamingJobRequest, StopIndividualStreamingJobResult> {
         const method = this.methods[17], opt = this._transport.mergeOptions(options);
         return stackIntercept<StopIndividualStreamingJobRequest, StopIndividualStreamingJobResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: ProvisionGitOrg(api.ProvisionGitOrgRequest) returns (api.ProvisionGitOrgResult);
+     * @generated from protobuf rpc: ProvisionGitOrg
      */
     provisionGitOrg(input: ProvisionGitOrgRequest, options?: RpcOptions): UnaryCall<ProvisionGitOrgRequest, ProvisionGitOrgResult> {
         const method = this.methods[18], opt = this._transport.mergeOptions(options);
         return stackIntercept<ProvisionGitOrgRequest, ProvisionGitOrgResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: DeprovisionGitOrg(api.DeprovisionGitOrgRequest) returns (api.DeprovisionGitOrgResult);
+     * @generated from protobuf rpc: DeprovisionGitOrg
      */
     deprovisionGitOrg(input: DeprovisionGitOrgRequest, options?: RpcOptions): UnaryCall<DeprovisionGitOrgRequest, DeprovisionGitOrgResult> {
         const method = this.methods[19], opt = this._transport.mergeOptions(options);
         return stackIntercept<DeprovisionGitOrgRequest, DeprovisionGitOrgResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: CreatePulsar(api.CreatePulsarRequest) returns (api.CreatePulsarResult);
+     * @generated from protobuf rpc: CreatePulsar
      */
     createPulsar(input: CreatePulsarRequest, options?: RpcOptions): UnaryCall<CreatePulsarRequest, CreatePulsarResult> {
         const method = this.methods[20], opt = this._transport.mergeOptions(options);
         return stackIntercept<CreatePulsarRequest, CreatePulsarResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: CreatePulsarSubscriptions(api.CreatePulsarSubscriptionsRequest) returns (api.CreatePulsarSubscriptionsResult);
+     * @generated from protobuf rpc: CreatePulsarSubscriptions
      */
     createPulsarSubscriptions(input: CreatePulsarSubscriptionsRequest, options?: RpcOptions): UnaryCall<CreatePulsarSubscriptionsRequest, CreatePulsarSubscriptionsResult> {
         const method = this.methods[21], opt = this._transport.mergeOptions(options);
         return stackIntercept<CreatePulsarSubscriptionsRequest, CreatePulsarSubscriptionsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: DeletePulsar(api.DeletePulsarRequest) returns (api.DeletePulsarResult);
+     * @generated from protobuf rpc: DeletePulsar
      */
     deletePulsar(input: DeletePulsarRequest, options?: RpcOptions): UnaryCall<DeletePulsarRequest, DeletePulsarResult> {
         const method = this.methods[22], opt = this._transport.mergeOptions(options);
         return stackIntercept<DeletePulsarRequest, DeletePulsarResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: CreatePulsarMissPartitions(api.CreatePulsarMissPartitionsRequest) returns (api.CreatePulsarMissPartitionsResult);
+     * @generated from protobuf rpc: CreatePulsarMissPartitions
      */
     createPulsarMissPartitions(input: CreatePulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall<CreatePulsarMissPartitionsRequest, CreatePulsarMissPartitionsResult> {
         const method = this.methods[23], opt = this._transport.mergeOptions(options);
         return stackIntercept<CreatePulsarMissPartitionsRequest, CreatePulsarMissPartitionsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: CreateAllPulsarMissPartitions(api.CreateAllPulsarMissPartitionsRequest) returns (api.CreateAllPulsarMissPartitionsResult);
+     * @generated from protobuf rpc: CreateAllPulsarMissPartitions
      */
     createAllPulsarMissPartitions(input: CreateAllPulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall<CreateAllPulsarMissPartitionsRequest, CreateAllPulsarMissPartitionsResult> {
         const method = this.methods[24], opt = this._transport.mergeOptions(options);
         return stackIntercept<CreateAllPulsarMissPartitionsRequest, CreateAllPulsarMissPartitionsResult>("unary", this._transport, method, opt, input);
     }
     /**
-     * @generated from protobuf rpc: DeleteOrganisationInDB(api.DeleteOrganisationInDBRequest) returns (api.DeleteOrganisationInDBResult);
+     * @generated from protobuf rpc: DeleteOrganisationInDB
      */
     deleteOrganisationInDB(input: DeleteOrganisationInDBRequest, options?: RpcOptions): UnaryCall<DeleteOrganisationInDBRequest, DeleteOrganisationInDBResult> {
         const method = this.methods[25], opt = this._transport.mergeOptions(options);