You've already forked dart-core-sdk
Latest generation
This commit is contained in:
ci core model
@@ -15,224 +15,220 @@ import 'dart:core' as $core;
|
||||
import 'package:grpc/service_api.dart' as $grpc;
|
||||
import 'package:protobuf/protobuf.dart' as $pb;
|
||||
|
||||
import 'org.pb.dart' as $14;
|
||||
import 'org.pb.dart' as $46;
|
||||
|
||||
export 'org.pb.dart';
|
||||
|
||||
@$pb.GrpcServiceName('api.OrganisationService')
|
||||
class OrganisationServiceClient extends $grpc.Client {
|
||||
static final _$get = $grpc.ClientMethod<$14.GetOrganisationRequest, $14.GetOrganisationResult>(
|
||||
static final _$get = $grpc.ClientMethod<$46.GetOrganisationRequest, $46.GetOrganisationResult>(
|
||||
'/api.OrganisationService/Get',
|
||||
($14.GetOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.GetOrganisationResult.fromBuffer(value));
|
||||
static final _$create = $grpc.ClientMethod<$14.CreateOrganisationRequest, $14.CreateOrganisationResult>(
|
||||
($46.GetOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.GetOrganisationResult.fromBuffer(value));
|
||||
static final _$create = $grpc.ClientMethod<$46.CreateOrganisationRequest, $46.CreateOrganisationResult>(
|
||||
'/api.OrganisationService/Create',
|
||||
($14.CreateOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.CreateOrganisationResult.fromBuffer(value));
|
||||
static final _$setModules = $grpc.ClientMethod<$14.SetModulesOrganisationRequest, $14.SetModulesOrganisationResult>(
|
||||
($46.CreateOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.CreateOrganisationResult.fromBuffer(value));
|
||||
static final _$setModules = $grpc.ClientMethod<$46.SetModulesOrganisationRequest, $46.SetModulesOrganisationResult>(
|
||||
'/api.OrganisationService/SetModules',
|
||||
($14.SetModulesOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.SetModulesOrganisationResult.fromBuffer(value));
|
||||
static final _$update = $grpc.ClientMethod<$14.UpdateOrganisationRequest, $14.UpdateOrganisationResult>(
|
||||
($46.SetModulesOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.SetModulesOrganisationResult.fromBuffer(value));
|
||||
static final _$update = $grpc.ClientMethod<$46.UpdateOrganisationRequest, $46.UpdateOrganisationResult>(
|
||||
'/api.OrganisationService/Update',
|
||||
($14.UpdateOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.UpdateOrganisationResult.fromBuffer(value));
|
||||
static final _$delete = $grpc.ClientMethod<$14.DeleteOrganisationRequest, $14.DeleteOrganisationResult>(
|
||||
($46.UpdateOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.UpdateOrganisationResult.fromBuffer(value));
|
||||
static final _$delete = $grpc.ClientMethod<$46.DeleteOrganisationRequest, $46.DeleteOrganisationResult>(
|
||||
'/api.OrganisationService/Delete',
|
||||
($14.DeleteOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.DeleteOrganisationResult.fromBuffer(value));
|
||||
static final _$list = $grpc.ClientMethod<$14.ListOrganisationRequest, $14.ListOrganisationResult>(
|
||||
($46.DeleteOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.DeleteOrganisationResult.fromBuffer(value));
|
||||
static final _$list = $grpc.ClientMethod<$46.ListOrganisationRequest, $46.ListOrganisationResult>(
|
||||
'/api.OrganisationService/List',
|
||||
($14.ListOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.ListOrganisationResult.fromBuffer(value));
|
||||
static final _$updateStatus = $grpc.ClientMethod<$14.UpdateOrganisationStatusRequest, $14.UpdateOrganisationStatusResult>(
|
||||
($46.ListOrganisationRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.ListOrganisationResult.fromBuffer(value));
|
||||
static final _$updateStatus = $grpc.ClientMethod<$46.UpdateOrganisationStatusRequest, $46.UpdateOrganisationStatusResult>(
|
||||
'/api.OrganisationService/UpdateStatus',
|
||||
($14.UpdateOrganisationStatusRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.UpdateOrganisationStatusResult.fromBuffer(value));
|
||||
static final _$startStreamingJobs = $grpc.ClientMethod<$14.StartStreamingJobsRequest, $14.StartStreamingJobsResult>(
|
||||
($46.UpdateOrganisationStatusRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.UpdateOrganisationStatusResult.fromBuffer(value));
|
||||
static final _$startStreamingJobs = $grpc.ClientMethod<$46.StartStreamingJobsRequest, $46.StartStreamingJobsResult>(
|
||||
'/api.OrganisationService/StartStreamingJobs',
|
||||
($14.StartStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.StartStreamingJobsResult.fromBuffer(value));
|
||||
static final _$stopStreamingJobs = $grpc.ClientMethod<$14.StopStreamingJobsRequest, $14.StopStreamingJobsResult>(
|
||||
($46.StartStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.StartStreamingJobsResult.fromBuffer(value));
|
||||
static final _$stopStreamingJobs = $grpc.ClientMethod<$46.StopStreamingJobsRequest, $46.StopStreamingJobsResult>(
|
||||
'/api.OrganisationService/StopStreamingJobs',
|
||||
($14.StopStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.StopStreamingJobsResult.fromBuffer(value));
|
||||
static final _$checkStreamingStatus = $grpc.ClientMethod<$14.CheckStreamingStatusRequest, $14.CheckStreamingStatusResult>(
|
||||
($46.StopStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.StopStreamingJobsResult.fromBuffer(value));
|
||||
static final _$checkStreamingStatus = $grpc.ClientMethod<$46.CheckStreamingStatusRequest, $46.CheckStreamingStatusResult>(
|
||||
'/api.OrganisationService/CheckStreamingStatus',
|
||||
($14.CheckStreamingStatusRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.CheckStreamingStatusResult.fromBuffer(value));
|
||||
static final _$stopAllStreamingJobs = $grpc.ClientMethod<$14.StopAllStreamingJobsRequest, $14.StopAllStreamingJobsResult>(
|
||||
($46.CheckStreamingStatusRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.CheckStreamingStatusResult.fromBuffer(value));
|
||||
static final _$stopAllStreamingJobs = $grpc.ClientMethod<$46.StopAllStreamingJobsRequest, $46.StopAllStreamingJobsResult>(
|
||||
'/api.OrganisationService/StopAllStreamingJobs',
|
||||
($14.StopAllStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.StopAllStreamingJobsResult.fromBuffer(value));
|
||||
static final _$restartAllStreamingJobs = $grpc.ClientMethod<$14.RestartAllStreamingJobsRequest, $14.RestartAllStreamingJobsResult>(
|
||||
($46.StopAllStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.StopAllStreamingJobsResult.fromBuffer(value));
|
||||
static final _$restartAllStreamingJobs = $grpc.ClientMethod<$46.RestartAllStreamingJobsRequest, $46.RestartAllStreamingJobsResult>(
|
||||
'/api.OrganisationService/RestartAllStreamingJobs',
|
||||
($14.RestartAllStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.RestartAllStreamingJobsResult.fromBuffer(value));
|
||||
static final _$startAllStreamingJobs = $grpc.ClientMethod<$14.StartAllStreamingJobsRequest, $14.StartAllStreamingJobsResult>(
|
||||
($46.RestartAllStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.RestartAllStreamingJobsResult.fromBuffer(value));
|
||||
static final _$startAllStreamingJobs = $grpc.ClientMethod<$46.StartAllStreamingJobsRequest, $46.StartAllStreamingJobsResult>(
|
||||
'/api.OrganisationService/StartAllStreamingJobs',
|
||||
($14.StartAllStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.StartAllStreamingJobsResult.fromBuffer(value));
|
||||
static final _$forceStopAllStreamingJobs = $grpc.ClientMethod<$14.ForceStopAllStreamingJobsRequest, $14.ForceStopAllStreamingJobsResult>(
|
||||
($46.StartAllStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.StartAllStreamingJobsResult.fromBuffer(value));
|
||||
static final _$forceStopAllStreamingJobs = $grpc.ClientMethod<$46.ForceStopAllStreamingJobsRequest, $46.ForceStopAllStreamingJobsResult>(
|
||||
'/api.OrganisationService/ForceStopAllStreamingJobs',
|
||||
($14.ForceStopAllStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.ForceStopAllStreamingJobsResult.fromBuffer(value));
|
||||
static final _$startStreamingMetricsJob = $grpc.ClientMethod<$14.StartStreamingMetricsJobRequest, $14.StartStreamingMetricsJobResult>(
|
||||
($46.ForceStopAllStreamingJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.ForceStopAllStreamingJobsResult.fromBuffer(value));
|
||||
static final _$startStreamingMetricsJob = $grpc.ClientMethod<$46.StartStreamingMetricsJobRequest, $46.StartStreamingMetricsJobResult>(
|
||||
'/api.OrganisationService/StartStreamingMetricsJob',
|
||||
($14.StartStreamingMetricsJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.StartStreamingMetricsJobResult.fromBuffer(value));
|
||||
static final _$stopStreamingMetricsJob = $grpc.ClientMethod<$14.StopStreamingMetricsJobRequest, $14.StopStreamingMetricsJobResult>(
|
||||
($46.StartStreamingMetricsJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.StartStreamingMetricsJobResult.fromBuffer(value));
|
||||
static final _$stopStreamingMetricsJob = $grpc.ClientMethod<$46.StopStreamingMetricsJobRequest, $46.StopStreamingMetricsJobResult>(
|
||||
'/api.OrganisationService/StopStreamingMetricsJob',
|
||||
($14.StopStreamingMetricsJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.StopStreamingMetricsJobResult.fromBuffer(value));
|
||||
static final _$startIndividualStreamingJob = $grpc.ClientMethod<$14.StartIndividualStreamingJobRequest, $14.StartIndividualStreamingJobResult>(
|
||||
($46.StopStreamingMetricsJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.StopStreamingMetricsJobResult.fromBuffer(value));
|
||||
static final _$startIndividualStreamingJob = $grpc.ClientMethod<$46.StartIndividualStreamingJobRequest, $46.StartIndividualStreamingJobResult>(
|
||||
'/api.OrganisationService/StartIndividualStreamingJob',
|
||||
($14.StartIndividualStreamingJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.StartIndividualStreamingJobResult.fromBuffer(value));
|
||||
static final _$stopIndividualStreamingJob = $grpc.ClientMethod<$14.StopIndividualStreamingJobRequest, $14.StopIndividualStreamingJobResult>(
|
||||
($46.StartIndividualStreamingJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.StartIndividualStreamingJobResult.fromBuffer(value));
|
||||
static final _$stopIndividualStreamingJob = $grpc.ClientMethod<$46.StopIndividualStreamingJobRequest, $46.StopIndividualStreamingJobResult>(
|
||||
'/api.OrganisationService/StopIndividualStreamingJob',
|
||||
($14.StopIndividualStreamingJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.StopIndividualStreamingJobResult.fromBuffer(value));
|
||||
static final _$provisionGitOrg = $grpc.ClientMethod<$14.ProvisionGitOrgRequest, $14.ProvisionGitOrgResult>(
|
||||
($46.StopIndividualStreamingJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.StopIndividualStreamingJobResult.fromBuffer(value));
|
||||
static final _$provisionGitOrg = $grpc.ClientMethod<$46.ProvisionGitOrgRequest, $46.ProvisionGitOrgResult>(
|
||||
'/api.OrganisationService/ProvisionGitOrg',
|
||||
($14.ProvisionGitOrgRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.ProvisionGitOrgResult.fromBuffer(value));
|
||||
static final _$deprovisionGitOrg = $grpc.ClientMethod<$14.DeprovisionGitOrgRequest, $14.DeprovisionGitOrgResult>(
|
||||
($46.ProvisionGitOrgRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.ProvisionGitOrgResult.fromBuffer(value));
|
||||
static final _$deprovisionGitOrg = $grpc.ClientMethod<$46.DeprovisionGitOrgRequest, $46.DeprovisionGitOrgResult>(
|
||||
'/api.OrganisationService/DeprovisionGitOrg',
|
||||
($14.DeprovisionGitOrgRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.DeprovisionGitOrgResult.fromBuffer(value));
|
||||
static final _$createPulsar = $grpc.ClientMethod<$14.CreatePulsarRequest, $14.CreatePulsarResult>(
|
||||
($46.DeprovisionGitOrgRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.DeprovisionGitOrgResult.fromBuffer(value));
|
||||
static final _$createPulsar = $grpc.ClientMethod<$46.CreatePulsarRequest, $46.CreatePulsarResult>(
|
||||
'/api.OrganisationService/CreatePulsar',
|
||||
($14.CreatePulsarRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.CreatePulsarResult.fromBuffer(value));
|
||||
static final _$createPulsarSubscriptions = $grpc.ClientMethod<$14.CreatePulsarSubscriptionsRequest, $14.CreatePulsarSubscriptionsResult>(
|
||||
($46.CreatePulsarRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.CreatePulsarResult.fromBuffer(value));
|
||||
static final _$createPulsarSubscriptions = $grpc.ClientMethod<$46.CreatePulsarSubscriptionsRequest, $46.CreatePulsarSubscriptionsResult>(
|
||||
'/api.OrganisationService/CreatePulsarSubscriptions',
|
||||
($14.CreatePulsarSubscriptionsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.CreatePulsarSubscriptionsResult.fromBuffer(value));
|
||||
static final _$deletePulsar = $grpc.ClientMethod<$14.DeletePulsarRequest, $14.DeletePulsarResult>(
|
||||
($46.CreatePulsarSubscriptionsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.CreatePulsarSubscriptionsResult.fromBuffer(value));
|
||||
static final _$deletePulsar = $grpc.ClientMethod<$46.DeletePulsarRequest, $46.DeletePulsarResult>(
|
||||
'/api.OrganisationService/DeletePulsar',
|
||||
($14.DeletePulsarRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.DeletePulsarResult.fromBuffer(value));
|
||||
static final _$createPulsarMissPartitions = $grpc.ClientMethod<$14.CreatePulsarMissPartitionsRequest, $14.CreatePulsarMissPartitionsResult>(
|
||||
($46.DeletePulsarRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.DeletePulsarResult.fromBuffer(value));
|
||||
static final _$createPulsarMissPartitions = $grpc.ClientMethod<$46.CreatePulsarMissPartitionsRequest, $46.CreatePulsarMissPartitionsResult>(
|
||||
'/api.OrganisationService/CreatePulsarMissPartitions',
|
||||
($14.CreatePulsarMissPartitionsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.CreatePulsarMissPartitionsResult.fromBuffer(value));
|
||||
static final _$createAllPulsarMissPartitions = $grpc.ClientMethod<$14.CreateAllPulsarMissPartitionsRequest, $14.CreateAllPulsarMissPartitionsResult>(
|
||||
($46.CreatePulsarMissPartitionsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.CreatePulsarMissPartitionsResult.fromBuffer(value));
|
||||
static final _$createAllPulsarMissPartitions = $grpc.ClientMethod<$46.CreateAllPulsarMissPartitionsRequest, $46.CreateAllPulsarMissPartitionsResult>(
|
||||
'/api.OrganisationService/CreateAllPulsarMissPartitions',
|
||||
($14.CreateAllPulsarMissPartitionsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.CreateAllPulsarMissPartitionsResult.fromBuffer(value));
|
||||
static final _$deleteOrganisationInDB = $grpc.ClientMethod<$14.DeleteOrganisationInDBRequest, $14.DeleteOrganisationInDBResult>(
|
||||
($46.CreateAllPulsarMissPartitionsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.CreateAllPulsarMissPartitionsResult.fromBuffer(value));
|
||||
static final _$deleteOrganisationInDB = $grpc.ClientMethod<$46.DeleteOrganisationInDBRequest, $46.DeleteOrganisationInDBResult>(
|
||||
'/api.OrganisationService/DeleteOrganisationInDB',
|
||||
($14.DeleteOrganisationInDBRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $14.DeleteOrganisationInDBResult.fromBuffer(value));
|
||||
($46.DeleteOrganisationInDBRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $46.DeleteOrganisationInDBResult.fromBuffer(value));
|
||||
|
||||
OrganisationServiceClient($grpc.ClientChannel channel,
|
||||
{$grpc.CallOptions? options,
|
||||
$core.Iterable<$grpc.ClientInterceptor>? interceptors})
|
||||
: super(channel, options: options,
|
||||
interceptors: interceptors);
|
||||
OrganisationServiceClient(super.channel, {super.options, super.interceptors});
|
||||
|
||||
$grpc.ResponseFuture<$14.GetOrganisationResult> get($14.GetOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.GetOrganisationResult> get($46.GetOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$get, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.CreateOrganisationResult> create($14.CreateOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.CreateOrganisationResult> create($46.CreateOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$create, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.SetModulesOrganisationResult> setModules($14.SetModulesOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.SetModulesOrganisationResult> setModules($46.SetModulesOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$setModules, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.UpdateOrganisationResult> update($14.UpdateOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.UpdateOrganisationResult> update($46.UpdateOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$update, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.DeleteOrganisationResult> delete($14.DeleteOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.DeleteOrganisationResult> delete($46.DeleteOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$delete, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.ListOrganisationResult> list($14.ListOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.ListOrganisationResult> list($46.ListOrganisationRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$list, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.UpdateOrganisationStatusResult> updateStatus($14.UpdateOrganisationStatusRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.UpdateOrganisationStatusResult> updateStatus($46.UpdateOrganisationStatusRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$updateStatus, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.StartStreamingJobsResult> startStreamingJobs($14.StartStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.StartStreamingJobsResult> startStreamingJobs($46.StartStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$startStreamingJobs, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.StopStreamingJobsResult> stopStreamingJobs($14.StopStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.StopStreamingJobsResult> stopStreamingJobs($46.StopStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$stopStreamingJobs, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.CheckStreamingStatusResult> checkStreamingStatus($14.CheckStreamingStatusRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.CheckStreamingStatusResult> checkStreamingStatus($46.CheckStreamingStatusRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$checkStreamingStatus, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.StopAllStreamingJobsResult> stopAllStreamingJobs($14.StopAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.StopAllStreamingJobsResult> stopAllStreamingJobs($46.StopAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$stopAllStreamingJobs, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.RestartAllStreamingJobsResult> restartAllStreamingJobs($14.RestartAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.RestartAllStreamingJobsResult> restartAllStreamingJobs($46.RestartAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$restartAllStreamingJobs, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.StartAllStreamingJobsResult> startAllStreamingJobs($14.StartAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.StartAllStreamingJobsResult> startAllStreamingJobs($46.StartAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$startAllStreamingJobs, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs($14.ForceStopAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs($46.ForceStopAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$forceStopAllStreamingJobs, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.StartStreamingMetricsJobResult> startStreamingMetricsJob($14.StartStreamingMetricsJobRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.StartStreamingMetricsJobResult> startStreamingMetricsJob($46.StartStreamingMetricsJobRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$startStreamingMetricsJob, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.StopStreamingMetricsJobResult> stopStreamingMetricsJob($14.StopStreamingMetricsJobRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.StopStreamingMetricsJobResult> stopStreamingMetricsJob($46.StopStreamingMetricsJobRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$stopStreamingMetricsJob, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.StartIndividualStreamingJobResult> startIndividualStreamingJob($14.StartIndividualStreamingJobRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.StartIndividualStreamingJobResult> startIndividualStreamingJob($46.StartIndividualStreamingJobRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$startIndividualStreamingJob, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.StopIndividualStreamingJobResult> stopIndividualStreamingJob($14.StopIndividualStreamingJobRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.StopIndividualStreamingJobResult> stopIndividualStreamingJob($46.StopIndividualStreamingJobRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$stopIndividualStreamingJob, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.ProvisionGitOrgResult> provisionGitOrg($14.ProvisionGitOrgRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.ProvisionGitOrgResult> provisionGitOrg($46.ProvisionGitOrgRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$provisionGitOrg, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.DeprovisionGitOrgResult> deprovisionGitOrg($14.DeprovisionGitOrgRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.DeprovisionGitOrgResult> deprovisionGitOrg($46.DeprovisionGitOrgRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$deprovisionGitOrg, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.CreatePulsarResult> createPulsar($14.CreatePulsarRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.CreatePulsarResult> createPulsar($46.CreatePulsarRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$createPulsar, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.CreatePulsarSubscriptionsResult> createPulsarSubscriptions($14.CreatePulsarSubscriptionsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.CreatePulsarSubscriptionsResult> createPulsarSubscriptions($46.CreatePulsarSubscriptionsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$createPulsarSubscriptions, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.DeletePulsarResult> deletePulsar($14.DeletePulsarRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.DeletePulsarResult> deletePulsar($46.DeletePulsarRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$deletePulsar, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.CreatePulsarMissPartitionsResult> createPulsarMissPartitions($14.CreatePulsarMissPartitionsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.CreatePulsarMissPartitionsResult> createPulsarMissPartitions($46.CreatePulsarMissPartitionsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$createPulsarMissPartitions, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions($14.CreateAllPulsarMissPartitionsRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions($46.CreateAllPulsarMissPartitionsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$createAllPulsarMissPartitions, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$14.DeleteOrganisationInDBResult> deleteOrganisationInDB($14.DeleteOrganisationInDBRequest request, {$grpc.CallOptions? options}) {
|
||||
$grpc.ResponseFuture<$46.DeleteOrganisationInDBResult> deleteOrganisationInDB($46.DeleteOrganisationInDBRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$deleteOrganisationInDB, request, options: options);
|
||||
}
|
||||
}
|
||||
@@ -242,318 +238,318 @@ abstract class OrganisationServiceBase extends $grpc.Service {
|
||||
$core.String get $name => 'api.OrganisationService';
|
||||
|
||||
OrganisationServiceBase() {
|
||||
$addMethod($grpc.ServiceMethod<$14.GetOrganisationRequest, $14.GetOrganisationResult>(
|
||||
$addMethod($grpc.ServiceMethod<$46.GetOrganisationRequest, $46.GetOrganisationResult>(
|
||||
'Get',
|
||||
get_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.GetOrganisationRequest.fromBuffer(value),
|
||||
($14.GetOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.CreateOrganisationRequest, $14.CreateOrganisationResult>(
|
||||
($core.List<$core.int> value) => $46.GetOrganisationRequest.fromBuffer(value),
|
||||
($46.GetOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.CreateOrganisationRequest, $46.CreateOrganisationResult>(
|
||||
'Create',
|
||||
create_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.CreateOrganisationRequest.fromBuffer(value),
|
||||
($14.CreateOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.SetModulesOrganisationRequest, $14.SetModulesOrganisationResult>(
|
||||
($core.List<$core.int> value) => $46.CreateOrganisationRequest.fromBuffer(value),
|
||||
($46.CreateOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.SetModulesOrganisationRequest, $46.SetModulesOrganisationResult>(
|
||||
'SetModules',
|
||||
setModules_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.SetModulesOrganisationRequest.fromBuffer(value),
|
||||
($14.SetModulesOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.UpdateOrganisationRequest, $14.UpdateOrganisationResult>(
|
||||
($core.List<$core.int> value) => $46.SetModulesOrganisationRequest.fromBuffer(value),
|
||||
($46.SetModulesOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.UpdateOrganisationRequest, $46.UpdateOrganisationResult>(
|
||||
'Update',
|
||||
update_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.UpdateOrganisationRequest.fromBuffer(value),
|
||||
($14.UpdateOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.DeleteOrganisationRequest, $14.DeleteOrganisationResult>(
|
||||
($core.List<$core.int> value) => $46.UpdateOrganisationRequest.fromBuffer(value),
|
||||
($46.UpdateOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.DeleteOrganisationRequest, $46.DeleteOrganisationResult>(
|
||||
'Delete',
|
||||
delete_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.DeleteOrganisationRequest.fromBuffer(value),
|
||||
($14.DeleteOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.ListOrganisationRequest, $14.ListOrganisationResult>(
|
||||
($core.List<$core.int> value) => $46.DeleteOrganisationRequest.fromBuffer(value),
|
||||
($46.DeleteOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.ListOrganisationRequest, $46.ListOrganisationResult>(
|
||||
'List',
|
||||
list_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.ListOrganisationRequest.fromBuffer(value),
|
||||
($14.ListOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.UpdateOrganisationStatusRequest, $14.UpdateOrganisationStatusResult>(
|
||||
($core.List<$core.int> value) => $46.ListOrganisationRequest.fromBuffer(value),
|
||||
($46.ListOrganisationResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.UpdateOrganisationStatusRequest, $46.UpdateOrganisationStatusResult>(
|
||||
'UpdateStatus',
|
||||
updateStatus_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.UpdateOrganisationStatusRequest.fromBuffer(value),
|
||||
($14.UpdateOrganisationStatusResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.StartStreamingJobsRequest, $14.StartStreamingJobsResult>(
|
||||
($core.List<$core.int> value) => $46.UpdateOrganisationStatusRequest.fromBuffer(value),
|
||||
($46.UpdateOrganisationStatusResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.StartStreamingJobsRequest, $46.StartStreamingJobsResult>(
|
||||
'StartStreamingJobs',
|
||||
startStreamingJobs_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.StartStreamingJobsRequest.fromBuffer(value),
|
||||
($14.StartStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.StopStreamingJobsRequest, $14.StopStreamingJobsResult>(
|
||||
($core.List<$core.int> value) => $46.StartStreamingJobsRequest.fromBuffer(value),
|
||||
($46.StartStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.StopStreamingJobsRequest, $46.StopStreamingJobsResult>(
|
||||
'StopStreamingJobs',
|
||||
stopStreamingJobs_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.StopStreamingJobsRequest.fromBuffer(value),
|
||||
($14.StopStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.CheckStreamingStatusRequest, $14.CheckStreamingStatusResult>(
|
||||
($core.List<$core.int> value) => $46.StopStreamingJobsRequest.fromBuffer(value),
|
||||
($46.StopStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.CheckStreamingStatusRequest, $46.CheckStreamingStatusResult>(
|
||||
'CheckStreamingStatus',
|
||||
checkStreamingStatus_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.CheckStreamingStatusRequest.fromBuffer(value),
|
||||
($14.CheckStreamingStatusResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.StopAllStreamingJobsRequest, $14.StopAllStreamingJobsResult>(
|
||||
($core.List<$core.int> value) => $46.CheckStreamingStatusRequest.fromBuffer(value),
|
||||
($46.CheckStreamingStatusResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.StopAllStreamingJobsRequest, $46.StopAllStreamingJobsResult>(
|
||||
'StopAllStreamingJobs',
|
||||
stopAllStreamingJobs_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.StopAllStreamingJobsRequest.fromBuffer(value),
|
||||
($14.StopAllStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.RestartAllStreamingJobsRequest, $14.RestartAllStreamingJobsResult>(
|
||||
($core.List<$core.int> value) => $46.StopAllStreamingJobsRequest.fromBuffer(value),
|
||||
($46.StopAllStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.RestartAllStreamingJobsRequest, $46.RestartAllStreamingJobsResult>(
|
||||
'RestartAllStreamingJobs',
|
||||
restartAllStreamingJobs_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.RestartAllStreamingJobsRequest.fromBuffer(value),
|
||||
($14.RestartAllStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.StartAllStreamingJobsRequest, $14.StartAllStreamingJobsResult>(
|
||||
($core.List<$core.int> value) => $46.RestartAllStreamingJobsRequest.fromBuffer(value),
|
||||
($46.RestartAllStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.StartAllStreamingJobsRequest, $46.StartAllStreamingJobsResult>(
|
||||
'StartAllStreamingJobs',
|
||||
startAllStreamingJobs_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.StartAllStreamingJobsRequest.fromBuffer(value),
|
||||
($14.StartAllStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.ForceStopAllStreamingJobsRequest, $14.ForceStopAllStreamingJobsResult>(
|
||||
($core.List<$core.int> value) => $46.StartAllStreamingJobsRequest.fromBuffer(value),
|
||||
($46.StartAllStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.ForceStopAllStreamingJobsRequest, $46.ForceStopAllStreamingJobsResult>(
|
||||
'ForceStopAllStreamingJobs',
|
||||
forceStopAllStreamingJobs_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.ForceStopAllStreamingJobsRequest.fromBuffer(value),
|
||||
($14.ForceStopAllStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.StartStreamingMetricsJobRequest, $14.StartStreamingMetricsJobResult>(
|
||||
($core.List<$core.int> value) => $46.ForceStopAllStreamingJobsRequest.fromBuffer(value),
|
||||
($46.ForceStopAllStreamingJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.StartStreamingMetricsJobRequest, $46.StartStreamingMetricsJobResult>(
|
||||
'StartStreamingMetricsJob',
|
||||
startStreamingMetricsJob_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.StartStreamingMetricsJobRequest.fromBuffer(value),
|
||||
($14.StartStreamingMetricsJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.StopStreamingMetricsJobRequest, $14.StopStreamingMetricsJobResult>(
|
||||
($core.List<$core.int> value) => $46.StartStreamingMetricsJobRequest.fromBuffer(value),
|
||||
($46.StartStreamingMetricsJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.StopStreamingMetricsJobRequest, $46.StopStreamingMetricsJobResult>(
|
||||
'StopStreamingMetricsJob',
|
||||
stopStreamingMetricsJob_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.StopStreamingMetricsJobRequest.fromBuffer(value),
|
||||
($14.StopStreamingMetricsJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.StartIndividualStreamingJobRequest, $14.StartIndividualStreamingJobResult>(
|
||||
($core.List<$core.int> value) => $46.StopStreamingMetricsJobRequest.fromBuffer(value),
|
||||
($46.StopStreamingMetricsJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.StartIndividualStreamingJobRequest, $46.StartIndividualStreamingJobResult>(
|
||||
'StartIndividualStreamingJob',
|
||||
startIndividualStreamingJob_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.StartIndividualStreamingJobRequest.fromBuffer(value),
|
||||
($14.StartIndividualStreamingJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.StopIndividualStreamingJobRequest, $14.StopIndividualStreamingJobResult>(
|
||||
($core.List<$core.int> value) => $46.StartIndividualStreamingJobRequest.fromBuffer(value),
|
||||
($46.StartIndividualStreamingJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.StopIndividualStreamingJobRequest, $46.StopIndividualStreamingJobResult>(
|
||||
'StopIndividualStreamingJob',
|
||||
stopIndividualStreamingJob_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.StopIndividualStreamingJobRequest.fromBuffer(value),
|
||||
($14.StopIndividualStreamingJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.ProvisionGitOrgRequest, $14.ProvisionGitOrgResult>(
|
||||
($core.List<$core.int> value) => $46.StopIndividualStreamingJobRequest.fromBuffer(value),
|
||||
($46.StopIndividualStreamingJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.ProvisionGitOrgRequest, $46.ProvisionGitOrgResult>(
|
||||
'ProvisionGitOrg',
|
||||
provisionGitOrg_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.ProvisionGitOrgRequest.fromBuffer(value),
|
||||
($14.ProvisionGitOrgResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.DeprovisionGitOrgRequest, $14.DeprovisionGitOrgResult>(
|
||||
($core.List<$core.int> value) => $46.ProvisionGitOrgRequest.fromBuffer(value),
|
||||
($46.ProvisionGitOrgResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.DeprovisionGitOrgRequest, $46.DeprovisionGitOrgResult>(
|
||||
'DeprovisionGitOrg',
|
||||
deprovisionGitOrg_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.DeprovisionGitOrgRequest.fromBuffer(value),
|
||||
($14.DeprovisionGitOrgResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.CreatePulsarRequest, $14.CreatePulsarResult>(
|
||||
($core.List<$core.int> value) => $46.DeprovisionGitOrgRequest.fromBuffer(value),
|
||||
($46.DeprovisionGitOrgResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.CreatePulsarRequest, $46.CreatePulsarResult>(
|
||||
'CreatePulsar',
|
||||
createPulsar_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.CreatePulsarRequest.fromBuffer(value),
|
||||
($14.CreatePulsarResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.CreatePulsarSubscriptionsRequest, $14.CreatePulsarSubscriptionsResult>(
|
||||
($core.List<$core.int> value) => $46.CreatePulsarRequest.fromBuffer(value),
|
||||
($46.CreatePulsarResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.CreatePulsarSubscriptionsRequest, $46.CreatePulsarSubscriptionsResult>(
|
||||
'CreatePulsarSubscriptions',
|
||||
createPulsarSubscriptions_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.CreatePulsarSubscriptionsRequest.fromBuffer(value),
|
||||
($14.CreatePulsarSubscriptionsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.DeletePulsarRequest, $14.DeletePulsarResult>(
|
||||
($core.List<$core.int> value) => $46.CreatePulsarSubscriptionsRequest.fromBuffer(value),
|
||||
($46.CreatePulsarSubscriptionsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.DeletePulsarRequest, $46.DeletePulsarResult>(
|
||||
'DeletePulsar',
|
||||
deletePulsar_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.DeletePulsarRequest.fromBuffer(value),
|
||||
($14.DeletePulsarResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.CreatePulsarMissPartitionsRequest, $14.CreatePulsarMissPartitionsResult>(
|
||||
($core.List<$core.int> value) => $46.DeletePulsarRequest.fromBuffer(value),
|
||||
($46.DeletePulsarResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.CreatePulsarMissPartitionsRequest, $46.CreatePulsarMissPartitionsResult>(
|
||||
'CreatePulsarMissPartitions',
|
||||
createPulsarMissPartitions_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.CreatePulsarMissPartitionsRequest.fromBuffer(value),
|
||||
($14.CreatePulsarMissPartitionsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.CreateAllPulsarMissPartitionsRequest, $14.CreateAllPulsarMissPartitionsResult>(
|
||||
($core.List<$core.int> value) => $46.CreatePulsarMissPartitionsRequest.fromBuffer(value),
|
||||
($46.CreatePulsarMissPartitionsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.CreateAllPulsarMissPartitionsRequest, $46.CreateAllPulsarMissPartitionsResult>(
|
||||
'CreateAllPulsarMissPartitions',
|
||||
createAllPulsarMissPartitions_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.CreateAllPulsarMissPartitionsRequest.fromBuffer(value),
|
||||
($14.CreateAllPulsarMissPartitionsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$14.DeleteOrganisationInDBRequest, $14.DeleteOrganisationInDBResult>(
|
||||
($core.List<$core.int> value) => $46.CreateAllPulsarMissPartitionsRequest.fromBuffer(value),
|
||||
($46.CreateAllPulsarMissPartitionsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$46.DeleteOrganisationInDBRequest, $46.DeleteOrganisationInDBResult>(
|
||||
'DeleteOrganisationInDB',
|
||||
deleteOrganisationInDB_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $14.DeleteOrganisationInDBRequest.fromBuffer(value),
|
||||
($14.DeleteOrganisationInDBResult value) => value.writeToBuffer()));
|
||||
($core.List<$core.int> value) => $46.DeleteOrganisationInDBRequest.fromBuffer(value),
|
||||
($46.DeleteOrganisationInDBResult value) => value.writeToBuffer()));
|
||||
}
|
||||
|
||||
$async.Future<$14.GetOrganisationResult> get_Pre($grpc.ServiceCall $call, $async.Future<$14.GetOrganisationRequest> $request) async {
|
||||
$async.Future<$46.GetOrganisationResult> get_Pre($grpc.ServiceCall $call, $async.Future<$46.GetOrganisationRequest> $request) async {
|
||||
return get($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.CreateOrganisationResult> create_Pre($grpc.ServiceCall $call, $async.Future<$14.CreateOrganisationRequest> $request) async {
|
||||
$async.Future<$46.CreateOrganisationResult> create_Pre($grpc.ServiceCall $call, $async.Future<$46.CreateOrganisationRequest> $request) async {
|
||||
return create($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.SetModulesOrganisationResult> setModules_Pre($grpc.ServiceCall $call, $async.Future<$14.SetModulesOrganisationRequest> $request) async {
|
||||
$async.Future<$46.SetModulesOrganisationResult> setModules_Pre($grpc.ServiceCall $call, $async.Future<$46.SetModulesOrganisationRequest> $request) async {
|
||||
return setModules($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.UpdateOrganisationResult> update_Pre($grpc.ServiceCall $call, $async.Future<$14.UpdateOrganisationRequest> $request) async {
|
||||
$async.Future<$46.UpdateOrganisationResult> update_Pre($grpc.ServiceCall $call, $async.Future<$46.UpdateOrganisationRequest> $request) async {
|
||||
return update($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.DeleteOrganisationResult> delete_Pre($grpc.ServiceCall $call, $async.Future<$14.DeleteOrganisationRequest> $request) async {
|
||||
$async.Future<$46.DeleteOrganisationResult> delete_Pre($grpc.ServiceCall $call, $async.Future<$46.DeleteOrganisationRequest> $request) async {
|
||||
return delete($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.ListOrganisationResult> list_Pre($grpc.ServiceCall $call, $async.Future<$14.ListOrganisationRequest> $request) async {
|
||||
$async.Future<$46.ListOrganisationResult> list_Pre($grpc.ServiceCall $call, $async.Future<$46.ListOrganisationRequest> $request) async {
|
||||
return list($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.UpdateOrganisationStatusResult> updateStatus_Pre($grpc.ServiceCall $call, $async.Future<$14.UpdateOrganisationStatusRequest> $request) async {
|
||||
$async.Future<$46.UpdateOrganisationStatusResult> updateStatus_Pre($grpc.ServiceCall $call, $async.Future<$46.UpdateOrganisationStatusRequest> $request) async {
|
||||
return updateStatus($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.StartStreamingJobsResult> startStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$14.StartStreamingJobsRequest> $request) async {
|
||||
$async.Future<$46.StartStreamingJobsResult> startStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$46.StartStreamingJobsRequest> $request) async {
|
||||
return startStreamingJobs($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.StopStreamingJobsResult> stopStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$14.StopStreamingJobsRequest> $request) async {
|
||||
$async.Future<$46.StopStreamingJobsResult> stopStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$46.StopStreamingJobsRequest> $request) async {
|
||||
return stopStreamingJobs($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.CheckStreamingStatusResult> checkStreamingStatus_Pre($grpc.ServiceCall $call, $async.Future<$14.CheckStreamingStatusRequest> $request) async {
|
||||
$async.Future<$46.CheckStreamingStatusResult> checkStreamingStatus_Pre($grpc.ServiceCall $call, $async.Future<$46.CheckStreamingStatusRequest> $request) async {
|
||||
return checkStreamingStatus($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.StopAllStreamingJobsResult> stopAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$14.StopAllStreamingJobsRequest> $request) async {
|
||||
$async.Future<$46.StopAllStreamingJobsResult> stopAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$46.StopAllStreamingJobsRequest> $request) async {
|
||||
return stopAllStreamingJobs($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.RestartAllStreamingJobsResult> restartAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$14.RestartAllStreamingJobsRequest> $request) async {
|
||||
$async.Future<$46.RestartAllStreamingJobsResult> restartAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$46.RestartAllStreamingJobsRequest> $request) async {
|
||||
return restartAllStreamingJobs($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.StartAllStreamingJobsResult> startAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$14.StartAllStreamingJobsRequest> $request) async {
|
||||
$async.Future<$46.StartAllStreamingJobsResult> startAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$46.StartAllStreamingJobsRequest> $request) async {
|
||||
return startAllStreamingJobs($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$14.ForceStopAllStreamingJobsRequest> $request) async {
|
||||
$async.Future<$46.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$46.ForceStopAllStreamingJobsRequest> $request) async {
|
||||
return forceStopAllStreamingJobs($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.StartStreamingMetricsJobResult> startStreamingMetricsJob_Pre($grpc.ServiceCall $call, $async.Future<$14.StartStreamingMetricsJobRequest> $request) async {
|
||||
$async.Future<$46.StartStreamingMetricsJobResult> startStreamingMetricsJob_Pre($grpc.ServiceCall $call, $async.Future<$46.StartStreamingMetricsJobRequest> $request) async {
|
||||
return startStreamingMetricsJob($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.StopStreamingMetricsJobResult> stopStreamingMetricsJob_Pre($grpc.ServiceCall $call, $async.Future<$14.StopStreamingMetricsJobRequest> $request) async {
|
||||
$async.Future<$46.StopStreamingMetricsJobResult> stopStreamingMetricsJob_Pre($grpc.ServiceCall $call, $async.Future<$46.StopStreamingMetricsJobRequest> $request) async {
|
||||
return stopStreamingMetricsJob($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.StartIndividualStreamingJobResult> startIndividualStreamingJob_Pre($grpc.ServiceCall $call, $async.Future<$14.StartIndividualStreamingJobRequest> $request) async {
|
||||
$async.Future<$46.StartIndividualStreamingJobResult> startIndividualStreamingJob_Pre($grpc.ServiceCall $call, $async.Future<$46.StartIndividualStreamingJobRequest> $request) async {
|
||||
return startIndividualStreamingJob($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.StopIndividualStreamingJobResult> stopIndividualStreamingJob_Pre($grpc.ServiceCall $call, $async.Future<$14.StopIndividualStreamingJobRequest> $request) async {
|
||||
$async.Future<$46.StopIndividualStreamingJobResult> stopIndividualStreamingJob_Pre($grpc.ServiceCall $call, $async.Future<$46.StopIndividualStreamingJobRequest> $request) async {
|
||||
return stopIndividualStreamingJob($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.ProvisionGitOrgResult> provisionGitOrg_Pre($grpc.ServiceCall $call, $async.Future<$14.ProvisionGitOrgRequest> $request) async {
|
||||
$async.Future<$46.ProvisionGitOrgResult> provisionGitOrg_Pre($grpc.ServiceCall $call, $async.Future<$46.ProvisionGitOrgRequest> $request) async {
|
||||
return provisionGitOrg($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.DeprovisionGitOrgResult> deprovisionGitOrg_Pre($grpc.ServiceCall $call, $async.Future<$14.DeprovisionGitOrgRequest> $request) async {
|
||||
$async.Future<$46.DeprovisionGitOrgResult> deprovisionGitOrg_Pre($grpc.ServiceCall $call, $async.Future<$46.DeprovisionGitOrgRequest> $request) async {
|
||||
return deprovisionGitOrg($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.CreatePulsarResult> createPulsar_Pre($grpc.ServiceCall $call, $async.Future<$14.CreatePulsarRequest> $request) async {
|
||||
$async.Future<$46.CreatePulsarResult> createPulsar_Pre($grpc.ServiceCall $call, $async.Future<$46.CreatePulsarRequest> $request) async {
|
||||
return createPulsar($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.CreatePulsarSubscriptionsResult> createPulsarSubscriptions_Pre($grpc.ServiceCall $call, $async.Future<$14.CreatePulsarSubscriptionsRequest> $request) async {
|
||||
$async.Future<$46.CreatePulsarSubscriptionsResult> createPulsarSubscriptions_Pre($grpc.ServiceCall $call, $async.Future<$46.CreatePulsarSubscriptionsRequest> $request) async {
|
||||
return createPulsarSubscriptions($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.DeletePulsarResult> deletePulsar_Pre($grpc.ServiceCall $call, $async.Future<$14.DeletePulsarRequest> $request) async {
|
||||
$async.Future<$46.DeletePulsarResult> deletePulsar_Pre($grpc.ServiceCall $call, $async.Future<$46.DeletePulsarRequest> $request) async {
|
||||
return deletePulsar($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.CreatePulsarMissPartitionsResult> createPulsarMissPartitions_Pre($grpc.ServiceCall $call, $async.Future<$14.CreatePulsarMissPartitionsRequest> $request) async {
|
||||
$async.Future<$46.CreatePulsarMissPartitionsResult> createPulsarMissPartitions_Pre($grpc.ServiceCall $call, $async.Future<$46.CreatePulsarMissPartitionsRequest> $request) async {
|
||||
return createPulsarMissPartitions($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions_Pre($grpc.ServiceCall $call, $async.Future<$14.CreateAllPulsarMissPartitionsRequest> $request) async {
|
||||
$async.Future<$46.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions_Pre($grpc.ServiceCall $call, $async.Future<$46.CreateAllPulsarMissPartitionsRequest> $request) async {
|
||||
return createAllPulsarMissPartitions($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.DeleteOrganisationInDBResult> deleteOrganisationInDB_Pre($grpc.ServiceCall $call, $async.Future<$14.DeleteOrganisationInDBRequest> $request) async {
|
||||
$async.Future<$46.DeleteOrganisationInDBResult> deleteOrganisationInDB_Pre($grpc.ServiceCall $call, $async.Future<$46.DeleteOrganisationInDBRequest> $request) async {
|
||||
return deleteOrganisationInDB($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$14.GetOrganisationResult> get($grpc.ServiceCall call, $14.GetOrganisationRequest request);
|
||||
$async.Future<$14.CreateOrganisationResult> create($grpc.ServiceCall call, $14.CreateOrganisationRequest request);
|
||||
$async.Future<$14.SetModulesOrganisationResult> setModules($grpc.ServiceCall call, $14.SetModulesOrganisationRequest request);
|
||||
$async.Future<$14.UpdateOrganisationResult> update($grpc.ServiceCall call, $14.UpdateOrganisationRequest request);
|
||||
$async.Future<$14.DeleteOrganisationResult> delete($grpc.ServiceCall call, $14.DeleteOrganisationRequest request);
|
||||
$async.Future<$14.ListOrganisationResult> list($grpc.ServiceCall call, $14.ListOrganisationRequest request);
|
||||
$async.Future<$14.UpdateOrganisationStatusResult> updateStatus($grpc.ServiceCall call, $14.UpdateOrganisationStatusRequest request);
|
||||
$async.Future<$14.StartStreamingJobsResult> startStreamingJobs($grpc.ServiceCall call, $14.StartStreamingJobsRequest request);
|
||||
$async.Future<$14.StopStreamingJobsResult> stopStreamingJobs($grpc.ServiceCall call, $14.StopStreamingJobsRequest request);
|
||||
$async.Future<$14.CheckStreamingStatusResult> checkStreamingStatus($grpc.ServiceCall call, $14.CheckStreamingStatusRequest request);
|
||||
$async.Future<$14.StopAllStreamingJobsResult> stopAllStreamingJobs($grpc.ServiceCall call, $14.StopAllStreamingJobsRequest request);
|
||||
$async.Future<$14.RestartAllStreamingJobsResult> restartAllStreamingJobs($grpc.ServiceCall call, $14.RestartAllStreamingJobsRequest request);
|
||||
$async.Future<$14.StartAllStreamingJobsResult> startAllStreamingJobs($grpc.ServiceCall call, $14.StartAllStreamingJobsRequest request);
|
||||
$async.Future<$14.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs($grpc.ServiceCall call, $14.ForceStopAllStreamingJobsRequest request);
|
||||
$async.Future<$14.StartStreamingMetricsJobResult> startStreamingMetricsJob($grpc.ServiceCall call, $14.StartStreamingMetricsJobRequest request);
|
||||
$async.Future<$14.StopStreamingMetricsJobResult> stopStreamingMetricsJob($grpc.ServiceCall call, $14.StopStreamingMetricsJobRequest request);
|
||||
$async.Future<$14.StartIndividualStreamingJobResult> startIndividualStreamingJob($grpc.ServiceCall call, $14.StartIndividualStreamingJobRequest request);
|
||||
$async.Future<$14.StopIndividualStreamingJobResult> stopIndividualStreamingJob($grpc.ServiceCall call, $14.StopIndividualStreamingJobRequest request);
|
||||
$async.Future<$14.ProvisionGitOrgResult> provisionGitOrg($grpc.ServiceCall call, $14.ProvisionGitOrgRequest request);
|
||||
$async.Future<$14.DeprovisionGitOrgResult> deprovisionGitOrg($grpc.ServiceCall call, $14.DeprovisionGitOrgRequest request);
|
||||
$async.Future<$14.CreatePulsarResult> createPulsar($grpc.ServiceCall call, $14.CreatePulsarRequest request);
|
||||
$async.Future<$14.CreatePulsarSubscriptionsResult> createPulsarSubscriptions($grpc.ServiceCall call, $14.CreatePulsarSubscriptionsRequest request);
|
||||
$async.Future<$14.DeletePulsarResult> deletePulsar($grpc.ServiceCall call, $14.DeletePulsarRequest request);
|
||||
$async.Future<$14.CreatePulsarMissPartitionsResult> createPulsarMissPartitions($grpc.ServiceCall call, $14.CreatePulsarMissPartitionsRequest request);
|
||||
$async.Future<$14.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions($grpc.ServiceCall call, $14.CreateAllPulsarMissPartitionsRequest request);
|
||||
$async.Future<$14.DeleteOrganisationInDBResult> deleteOrganisationInDB($grpc.ServiceCall call, $14.DeleteOrganisationInDBRequest request);
|
||||
$async.Future<$46.GetOrganisationResult> get($grpc.ServiceCall call, $46.GetOrganisationRequest request);
|
||||
$async.Future<$46.CreateOrganisationResult> create($grpc.ServiceCall call, $46.CreateOrganisationRequest request);
|
||||
$async.Future<$46.SetModulesOrganisationResult> setModules($grpc.ServiceCall call, $46.SetModulesOrganisationRequest request);
|
||||
$async.Future<$46.UpdateOrganisationResult> update($grpc.ServiceCall call, $46.UpdateOrganisationRequest request);
|
||||
$async.Future<$46.DeleteOrganisationResult> delete($grpc.ServiceCall call, $46.DeleteOrganisationRequest request);
|
||||
$async.Future<$46.ListOrganisationResult> list($grpc.ServiceCall call, $46.ListOrganisationRequest request);
|
||||
$async.Future<$46.UpdateOrganisationStatusResult> updateStatus($grpc.ServiceCall call, $46.UpdateOrganisationStatusRequest request);
|
||||
$async.Future<$46.StartStreamingJobsResult> startStreamingJobs($grpc.ServiceCall call, $46.StartStreamingJobsRequest request);
|
||||
$async.Future<$46.StopStreamingJobsResult> stopStreamingJobs($grpc.ServiceCall call, $46.StopStreamingJobsRequest request);
|
||||
$async.Future<$46.CheckStreamingStatusResult> checkStreamingStatus($grpc.ServiceCall call, $46.CheckStreamingStatusRequest request);
|
||||
$async.Future<$46.StopAllStreamingJobsResult> stopAllStreamingJobs($grpc.ServiceCall call, $46.StopAllStreamingJobsRequest request);
|
||||
$async.Future<$46.RestartAllStreamingJobsResult> restartAllStreamingJobs($grpc.ServiceCall call, $46.RestartAllStreamingJobsRequest request);
|
||||
$async.Future<$46.StartAllStreamingJobsResult> startAllStreamingJobs($grpc.ServiceCall call, $46.StartAllStreamingJobsRequest request);
|
||||
$async.Future<$46.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs($grpc.ServiceCall call, $46.ForceStopAllStreamingJobsRequest request);
|
||||
$async.Future<$46.StartStreamingMetricsJobResult> startStreamingMetricsJob($grpc.ServiceCall call, $46.StartStreamingMetricsJobRequest request);
|
||||
$async.Future<$46.StopStreamingMetricsJobResult> stopStreamingMetricsJob($grpc.ServiceCall call, $46.StopStreamingMetricsJobRequest request);
|
||||
$async.Future<$46.StartIndividualStreamingJobResult> startIndividualStreamingJob($grpc.ServiceCall call, $46.StartIndividualStreamingJobRequest request);
|
||||
$async.Future<$46.StopIndividualStreamingJobResult> stopIndividualStreamingJob($grpc.ServiceCall call, $46.StopIndividualStreamingJobRequest request);
|
||||
$async.Future<$46.ProvisionGitOrgResult> provisionGitOrg($grpc.ServiceCall call, $46.ProvisionGitOrgRequest request);
|
||||
$async.Future<$46.DeprovisionGitOrgResult> deprovisionGitOrg($grpc.ServiceCall call, $46.DeprovisionGitOrgRequest request);
|
||||
$async.Future<$46.CreatePulsarResult> createPulsar($grpc.ServiceCall call, $46.CreatePulsarRequest request);
|
||||
$async.Future<$46.CreatePulsarSubscriptionsResult> createPulsarSubscriptions($grpc.ServiceCall call, $46.CreatePulsarSubscriptionsRequest request);
|
||||
$async.Future<$46.DeletePulsarResult> deletePulsar($grpc.ServiceCall call, $46.DeletePulsarRequest request);
|
||||
$async.Future<$46.CreatePulsarMissPartitionsResult> createPulsarMissPartitions($grpc.ServiceCall call, $46.CreatePulsarMissPartitionsRequest request);
|
||||
$async.Future<$46.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions($grpc.ServiceCall call, $46.CreateAllPulsarMissPartitionsRequest request);
|
||||
$async.Future<$46.DeleteOrganisationInDBResult> deleteOrganisationInDB($grpc.ServiceCall call, $46.DeleteOrganisationInDBRequest request);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user