// @generated by protobuf-ts 2.9.6
// @generated from protobuf file "org.proto" (package "api", syntax proto3)
// tslint:disable
import type { RpcTransport } from "@protobuf-ts/runtime-rpc";
import type { ServiceInfo } from "@protobuf-ts/runtime-rpc";
import { OrganisationService } from "./org";
import type { DeleteOrganisationInDBResult } from "./org";
import type { DeleteOrganisationInDBRequest } from "./org";
import type { CreateAllPulsarMissPartitionsResult } from "./org";
import type { CreateAllPulsarMissPartitionsRequest } from "./org";
import type { CreatePulsarMissPartitionsResult } from "./org";
import type { CreatePulsarMissPartitionsRequest } from "./org";
import type { DeletePulsarResult } from "./org";
import type { DeletePulsarRequest } from "./org";
import type { CreatePulsarSubscriptionsResult } from "./org";
import type { CreatePulsarSubscriptionsRequest } from "./org";
import type { CreatePulsarResult } from "./org";
import type { CreatePulsarRequest } from "./org";
import type { DeprovisionGitOrgResult } from "./org";
import type { DeprovisionGitOrgRequest } from "./org";
import type { ProvisionGitOrgResult } from "./org";
import type { ProvisionGitOrgRequest } from "./org";
import type { StopIndividualStreamingJobResult } from "./org";
import type { StopIndividualStreamingJobRequest } from "./org";
import type { StartIndividualStreamingJobResult } from "./org";
import type { StartIndividualStreamingJobRequest } from "./org";
import type { StopStreamingMetricsJobResult } from "./org";
import type { StopStreamingMetricsJobRequest } from "./org";
import type { StartStreamingMetricsJobResult } from "./org";
import type { StartStreamingMetricsJobRequest } from "./org";
import type { ForceStopAllStreamingJobsResult } from "./org";
import type { ForceStopAllStreamingJobsRequest } from "./org";
import type { StartAllStreamingJobsResult } from "./org";
import type { StartAllStreamingJobsRequest } from "./org";
import type { RestartAllStreamingJobsResult } from "./org";
import type { RestartAllStreamingJobsRequest } from "./org";
import type { StopAllStreamingJobsResult } from "./org";
import type { StopAllStreamingJobsRequest } from "./org";
import type { CheckStreamingStatusResult } from "./org";
import type { CheckStreamingStatusRequest } from "./org";
import type { StopStreamingJobsResult } from "./org";
import type { StopStreamingJobsRequest } from "./org";
import type { StartStreamingJobsResult } from "./org";
import type { StartStreamingJobsRequest } from "./org";
import type { UpdateOrganisationStatusResult } from "./org";
import type { UpdateOrganisationStatusRequest } from "./org";
import type { ListOrganisationResult } from "./org";
import type { ListOrganisationRequest } from "./org";
import type { DeleteOrganisationResult } from "./org";
import type { DeleteOrganisationRequest } from "./org";
import type { UpdateOrganisationResult } from "./org";
import type { UpdateOrganisationRequest } from "./org";
import type { SetModulesOrganisationResult } from "./org";
import type { SetModulesOrganisationRequest } from "./org";
import type { CreateOrganisationResult } from "./org";
import type { CreateOrganisationRequest } from "./org";
import { stackIntercept } from "@protobuf-ts/runtime-rpc";
import type { GetOrganisationResult } from "./org";
import type { GetOrganisationRequest } from "./org";
import type { UnaryCall } from "@protobuf-ts/runtime-rpc";
import type { RpcOptions } from "@protobuf-ts/runtime-rpc";
/**
 * @generated from protobuf service api.OrganisationService
 */
export interface IOrganisationServiceClient {
    /**
     * @generated from protobuf rpc: Get(api.GetOrganisationRequest) returns (api.GetOrganisationResult);
     */
    get(input: GetOrganisationRequest, options?: RpcOptions): UnaryCall<GetOrganisationRequest, GetOrganisationResult>;
    /**
     * @generated from protobuf rpc: Create(api.CreateOrganisationRequest) returns (api.CreateOrganisationResult);
     */
    create(input: CreateOrganisationRequest, options?: RpcOptions): UnaryCall<CreateOrganisationRequest, CreateOrganisationResult>;
    /**
     * @generated from protobuf rpc: SetModules(api.SetModulesOrganisationRequest) returns (api.SetModulesOrganisationResult);
     */
    setModules(input: SetModulesOrganisationRequest, options?: RpcOptions): UnaryCall<SetModulesOrganisationRequest, SetModulesOrganisationResult>;
    /**
     * @generated from protobuf rpc: Update(api.UpdateOrganisationRequest) returns (api.UpdateOrganisationResult);
     */
    update(input: UpdateOrganisationRequest, options?: RpcOptions): UnaryCall<UpdateOrganisationRequest, UpdateOrganisationResult>;
    /**
     * @generated from protobuf rpc: Delete(api.DeleteOrganisationRequest) returns (api.DeleteOrganisationResult);
     */
    delete(input: DeleteOrganisationRequest, options?: RpcOptions): UnaryCall<DeleteOrganisationRequest, DeleteOrganisationResult>;
    /**
     * @generated from protobuf rpc: List(api.ListOrganisationRequest) returns (api.ListOrganisationResult);
     */
    list(input: ListOrganisationRequest, options?: RpcOptions): UnaryCall<ListOrganisationRequest, ListOrganisationResult>;
    /**
     * @generated from protobuf rpc: UpdateStatus(api.UpdateOrganisationStatusRequest) returns (api.UpdateOrganisationStatusResult);
     */
    updateStatus(input: UpdateOrganisationStatusRequest, options?: RpcOptions): UnaryCall<UpdateOrganisationStatusRequest, UpdateOrganisationStatusResult>;
    /**
     * @generated from protobuf rpc: StartStreamingJobs(api.StartStreamingJobsRequest) returns (api.StartStreamingJobsResult);
     */
    startStreamingJobs(input: StartStreamingJobsRequest, options?: RpcOptions): UnaryCall<StartStreamingJobsRequest, StartStreamingJobsResult>;
    /**
     * @generated from protobuf rpc: StopStreamingJobs(api.StopStreamingJobsRequest) returns (api.StopStreamingJobsResult);
     */
    stopStreamingJobs(input: StopStreamingJobsRequest, options?: RpcOptions): UnaryCall<StopStreamingJobsRequest, StopStreamingJobsResult>;
    /**
     * @generated from protobuf rpc: CheckStreamingStatus(api.CheckStreamingStatusRequest) returns (api.CheckStreamingStatusResult);
     */
    checkStreamingStatus(input: CheckStreamingStatusRequest, options?: RpcOptions): UnaryCall<CheckStreamingStatusRequest, CheckStreamingStatusResult>;
    /**
     * @generated from protobuf rpc: StopAllStreamingJobs(api.StopAllStreamingJobsRequest) returns (api.StopAllStreamingJobsResult);
     */
    stopAllStreamingJobs(input: StopAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<StopAllStreamingJobsRequest, StopAllStreamingJobsResult>;
    /**
     * @generated from protobuf rpc: RestartAllStreamingJobs(api.RestartAllStreamingJobsRequest) returns (api.RestartAllStreamingJobsResult);
     */
    restartAllStreamingJobs(input: RestartAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<RestartAllStreamingJobsRequest, RestartAllStreamingJobsResult>;
    /**
     * @generated from protobuf rpc: StartAllStreamingJobs(api.StartAllStreamingJobsRequest) returns (api.StartAllStreamingJobsResult);
     */
    startAllStreamingJobs(input: StartAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<StartAllStreamingJobsRequest, StartAllStreamingJobsResult>;
    /**
     * @generated from protobuf rpc: ForceStopAllStreamingJobs(api.ForceStopAllStreamingJobsRequest) returns (api.ForceStopAllStreamingJobsResult);
     */
    forceStopAllStreamingJobs(input: ForceStopAllStreamingJobsRequest, options?: RpcOptions): UnaryCall<ForceStopAllStreamingJobsRequest, ForceStopAllStreamingJobsResult>;
    /**
     * @generated from protobuf rpc: StartStreamingMetricsJob(api.StartStreamingMetricsJobRequest) returns (api.StartStreamingMetricsJobResult);
     */
    startStreamingMetricsJob(input: StartStreamingMetricsJobRequest, options?: RpcOptions): UnaryCall<StartStreamingMetricsJobRequest, StartStreamingMetricsJobResult>;
    /**
     * @generated from protobuf rpc: StopStreamingMetricsJob(api.StopStreamingMetricsJobRequest) returns (api.StopStreamingMetricsJobResult);
     */
    stopStreamingMetricsJob(input: StopStreamingMetricsJobRequest, options?: RpcOptions): UnaryCall<StopStreamingMetricsJobRequest, StopStreamingMetricsJobResult>;
    /**
     * @generated from protobuf rpc: StartIndividualStreamingJob(api.StartIndividualStreamingJobRequest) returns (api.StartIndividualStreamingJobResult);
     */
    startIndividualStreamingJob(input: StartIndividualStreamingJobRequest, options?: RpcOptions): UnaryCall<StartIndividualStreamingJobRequest, StartIndividualStreamingJobResult>;
    /**
     * @generated from protobuf rpc: StopIndividualStreamingJob(api.StopIndividualStreamingJobRequest) returns (api.StopIndividualStreamingJobResult);
     */
    stopIndividualStreamingJob(input: StopIndividualStreamingJobRequest, options?: RpcOptions): UnaryCall<StopIndividualStreamingJobRequest, StopIndividualStreamingJobResult>;
    /**
     * @generated from protobuf rpc: ProvisionGitOrg(api.ProvisionGitOrgRequest) returns (api.ProvisionGitOrgResult);
     */
    provisionGitOrg(input: ProvisionGitOrgRequest, options?: RpcOptions): UnaryCall<ProvisionGitOrgRequest, ProvisionGitOrgResult>;
    /**
     * @generated from protobuf rpc: DeprovisionGitOrg(api.DeprovisionGitOrgRequest) returns (api.DeprovisionGitOrgResult);
     */
    deprovisionGitOrg(input: DeprovisionGitOrgRequest, options?: RpcOptions): UnaryCall<DeprovisionGitOrgRequest, DeprovisionGitOrgResult>;
    /**
     * @generated from protobuf rpc: CreatePulsar(api.CreatePulsarRequest) returns (api.CreatePulsarResult);
     */
    createPulsar(input: CreatePulsarRequest, options?: RpcOptions): UnaryCall<CreatePulsarRequest, CreatePulsarResult>;
    /**
     * @generated from protobuf rpc: CreatePulsarSubscriptions(api.CreatePulsarSubscriptionsRequest) returns (api.CreatePulsarSubscriptionsResult);
     */
    createPulsarSubscriptions(input: CreatePulsarSubscriptionsRequest, options?: RpcOptions): UnaryCall<CreatePulsarSubscriptionsRequest, CreatePulsarSubscriptionsResult>;
    /**
     * @generated from protobuf rpc: DeletePulsar(api.DeletePulsarRequest) returns (api.DeletePulsarResult);
     */
    deletePulsar(input: DeletePulsarRequest, options?: RpcOptions): UnaryCall<DeletePulsarRequest, DeletePulsarResult>;
    /**
     * @generated from protobuf rpc: CreatePulsarMissPartitions(api.CreatePulsarMissPartitionsRequest) returns (api.CreatePulsarMissPartitionsResult);
     */
    createPulsarMissPartitions(input: CreatePulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall<CreatePulsarMissPartitionsRequest, CreatePulsarMissPartitionsResult>;
    /**
     * @generated from protobuf rpc: CreateAllPulsarMissPartitions(api.CreateAllPulsarMissPartitionsRequest) returns (api.CreateAllPulsarMissPartitionsResult);
     */
    createAllPulsarMissPartitions(input: CreateAllPulsarMissPartitionsRequest, options?: RpcOptions): UnaryCall<CreateAllPulsarMissPartitionsRequest, CreateAllPulsarMissPartitionsResult>;
    /**
     * @generated from protobuf rpc: DeleteOrganisationInDB(api.DeleteOrganisationInDBRequest) returns (api.DeleteOrganisationInDBResult);
     */
    deleteOrganisationInDB(input: DeleteOrganisationInDBRequest, options?: RpcOptions): UnaryCall<DeleteOrganisationInDBRequest, DeleteOrganisationInDBResult>;
}
/**
 * @generated from protobuf service api.OrganisationService
 */
export class OrganisationServiceClient implements IOrganisationServiceClient, ServiceInfo {
    typeName = OrganisationService.typeName;
    methods = OrganisationService.methods;
    options = OrganisationService.options;
    constructor(private readonly _transport: RpcTransport) {
    }
    /**
     * @generated from protobuf rpc: Get(api.GetOrganisationRequest) returns (api.GetOrganisationResult);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    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);
     */
    deleteOrganisationInDB(input: DeleteOrganisationInDBRequest, options?: RpcOptions): UnaryCall<DeleteOrganisationInDBRequest, DeleteOrganisationInDBResult> {
        const method = this.methods[25], opt = this._transport.mergeOptions(options);
        return stackIntercept<DeleteOrganisationInDBRequest, DeleteOrganisationInDBResult>("unary", this._transport, method, opt, input);
    }
}