You've already forked npm-core-sdk
363 lines
25 KiB
TypeScript
363 lines
25 KiB
TypeScript
// @generated by protobuf-ts 2.10.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";
|
|
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);
|
|
}
|
|
}
|