reflex-platform/dart-core-sdk
0
Fork 0
Code Pull Requests Projects Releases Wiki Activity
Files
develop
dart-core-sdk/lib/org.pbgrpc.dart
ci core model a4f7d23d92 Latest generation
2025-07-29 08:44:59 +00:00

488 lines
26 KiB
Dart
Raw Permalink Blame History

// This is a generated file - do not edit.
//
// Generated from org.proto.
// @dart = 3.3
// ignore_for_file: annotate_overrides, camel_case_types, comment_references
// ignore_for_file: constant_identifier_names
// ignore_for_file: curly_braces_in_flow_control_structures
// ignore_for_file: deprecated_member_use_from_same_package, library_prefixes
// ignore_for_file: non_constant_identifier_names
import 'dart:async' as $async;
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 $0;
export 'org.pb.dart';
@$pb.GrpcServiceName('api.OrganisationService')
class OrganisationServiceClient extends $grpc.Client {
/// The hostname for this service.
static const $core.String defaultHost = '';
/// OAuth scopes needed for the client.
static const $core.List<$core.String> oauthScopes = [
'',
];
OrganisationServiceClient(super.channel, {super.options, super.interceptors});
$grpc.ResponseFuture<$0.GetOrganisationResult> get($0.GetOrganisationRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$get, request, options: options);
}
$grpc.ResponseFuture<$0.CreateOrganisationResult> create($0.CreateOrganisationRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$create, request, options: options);
}
$grpc.ResponseFuture<$0.SetModulesOrganisationResult> setModules($0.SetModulesOrganisationRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$setModules, request, options: options);
}
$grpc.ResponseFuture<$0.UpdateOrganisationResult> update($0.UpdateOrganisationRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$update, request, options: options);
}
$grpc.ResponseFuture<$0.DeleteOrganisationResult> delete($0.DeleteOrganisationRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$delete, request, options: options);
}
$grpc.ResponseFuture<$0.ListOrganisationResult> list($0.ListOrganisationRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$list, request, options: options);
}
$grpc.ResponseFuture<$0.UpdateOrganisationStatusResult> updateStatus($0.UpdateOrganisationStatusRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$updateStatus, request, options: options);
}
$grpc.ResponseFuture<$0.StartStreamingJobsResult> startStreamingJobs($0.StartStreamingJobsRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$startStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$0.StopStreamingJobsResult> stopStreamingJobs($0.StopStreamingJobsRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$stopStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$0.CheckStreamingStatusResult> checkStreamingStatus($0.CheckStreamingStatusRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$checkStreamingStatus, request, options: options);
}
$grpc.ResponseFuture<$0.StopAllStreamingJobsResult> stopAllStreamingJobs($0.StopAllStreamingJobsRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$stopAllStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$0.RestartAllStreamingJobsResult> restartAllStreamingJobs($0.RestartAllStreamingJobsRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$restartAllStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$0.StartAllStreamingJobsResult> startAllStreamingJobs($0.StartAllStreamingJobsRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$startAllStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$0.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs($0.ForceStopAllStreamingJobsRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$forceStopAllStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$0.StartStreamingMetricsJobResult> startStreamingMetricsJob($0.StartStreamingMetricsJobRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$startStreamingMetricsJob, request, options: options);
}
$grpc.ResponseFuture<$0.StopStreamingMetricsJobResult> stopStreamingMetricsJob($0.StopStreamingMetricsJobRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$stopStreamingMetricsJob, request, options: options);
}
$grpc.ResponseFuture<$0.StartIndividualStreamingJobResult> startIndividualStreamingJob($0.StartIndividualStreamingJobRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$startIndividualStreamingJob, request, options: options);
}
$grpc.ResponseFuture<$0.StopIndividualStreamingJobResult> stopIndividualStreamingJob($0.StopIndividualStreamingJobRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$stopIndividualStreamingJob, request, options: options);
}
$grpc.ResponseFuture<$0.ProvisionGitOrgResult> provisionGitOrg($0.ProvisionGitOrgRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$provisionGitOrg, request, options: options);
}
$grpc.ResponseFuture<$0.DeprovisionGitOrgResult> deprovisionGitOrg($0.DeprovisionGitOrgRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$deprovisionGitOrg, request, options: options);
}
$grpc.ResponseFuture<$0.DeleteOrganisationInDBResult> deleteOrganisationInDB($0.DeleteOrganisationInDBRequest request, {$grpc.CallOptions? options,}) {
return $createUnaryCall(_$deleteOrganisationInDB, request, options: options);
}
// method descriptors
static final _$get = $grpc.ClientMethod<$0.GetOrganisationRequest, $0.GetOrganisationResult>(
'/api.OrganisationService/Get',
($0.GetOrganisationRequest value) => value.writeToBuffer(),
$0.GetOrganisationResult.fromBuffer);
static final _$create = $grpc.ClientMethod<$0.CreateOrganisationRequest, $0.CreateOrganisationResult>(
'/api.OrganisationService/Create',
($0.CreateOrganisationRequest value) => value.writeToBuffer(),
$0.CreateOrganisationResult.fromBuffer);
static final _$setModules = $grpc.ClientMethod<$0.SetModulesOrganisationRequest, $0.SetModulesOrganisationResult>(
'/api.OrganisationService/SetModules',
($0.SetModulesOrganisationRequest value) => value.writeToBuffer(),
$0.SetModulesOrganisationResult.fromBuffer);
static final _$update = $grpc.ClientMethod<$0.UpdateOrganisationRequest, $0.UpdateOrganisationResult>(
'/api.OrganisationService/Update',
($0.UpdateOrganisationRequest value) => value.writeToBuffer(),
$0.UpdateOrganisationResult.fromBuffer);
static final _$delete = $grpc.ClientMethod<$0.DeleteOrganisationRequest, $0.DeleteOrganisationResult>(
'/api.OrganisationService/Delete',
($0.DeleteOrganisationRequest value) => value.writeToBuffer(),
$0.DeleteOrganisationResult.fromBuffer);
static final _$list = $grpc.ClientMethod<$0.ListOrganisationRequest, $0.ListOrganisationResult>(
'/api.OrganisationService/List',
($0.ListOrganisationRequest value) => value.writeToBuffer(),
$0.ListOrganisationResult.fromBuffer);
static final _$updateStatus = $grpc.ClientMethod<$0.UpdateOrganisationStatusRequest, $0.UpdateOrganisationStatusResult>(
'/api.OrganisationService/UpdateStatus',
($0.UpdateOrganisationStatusRequest value) => value.writeToBuffer(),
$0.UpdateOrganisationStatusResult.fromBuffer);
static final _$startStreamingJobs = $grpc.ClientMethod<$0.StartStreamingJobsRequest, $0.StartStreamingJobsResult>(
'/api.OrganisationService/StartStreamingJobs',
($0.StartStreamingJobsRequest value) => value.writeToBuffer(),
$0.StartStreamingJobsResult.fromBuffer);
static final _$stopStreamingJobs = $grpc.ClientMethod<$0.StopStreamingJobsRequest, $0.StopStreamingJobsResult>(
'/api.OrganisationService/StopStreamingJobs',
($0.StopStreamingJobsRequest value) => value.writeToBuffer(),
$0.StopStreamingJobsResult.fromBuffer);
static final _$checkStreamingStatus = $grpc.ClientMethod<$0.CheckStreamingStatusRequest, $0.CheckStreamingStatusResult>(
'/api.OrganisationService/CheckStreamingStatus',
($0.CheckStreamingStatusRequest value) => value.writeToBuffer(),
$0.CheckStreamingStatusResult.fromBuffer);
static final _$stopAllStreamingJobs = $grpc.ClientMethod<$0.StopAllStreamingJobsRequest, $0.StopAllStreamingJobsResult>(
'/api.OrganisationService/StopAllStreamingJobs',
($0.StopAllStreamingJobsRequest value) => value.writeToBuffer(),
$0.StopAllStreamingJobsResult.fromBuffer);
static final _$restartAllStreamingJobs = $grpc.ClientMethod<$0.RestartAllStreamingJobsRequest, $0.RestartAllStreamingJobsResult>(
'/api.OrganisationService/RestartAllStreamingJobs',
($0.RestartAllStreamingJobsRequest value) => value.writeToBuffer(),
$0.RestartAllStreamingJobsResult.fromBuffer);
static final _$startAllStreamingJobs = $grpc.ClientMethod<$0.StartAllStreamingJobsRequest, $0.StartAllStreamingJobsResult>(
'/api.OrganisationService/StartAllStreamingJobs',
($0.StartAllStreamingJobsRequest value) => value.writeToBuffer(),
$0.StartAllStreamingJobsResult.fromBuffer);
static final _$forceStopAllStreamingJobs = $grpc.ClientMethod<$0.ForceStopAllStreamingJobsRequest, $0.ForceStopAllStreamingJobsResult>(
'/api.OrganisationService/ForceStopAllStreamingJobs',
($0.ForceStopAllStreamingJobsRequest value) => value.writeToBuffer(),
$0.ForceStopAllStreamingJobsResult.fromBuffer);
static final _$startStreamingMetricsJob = $grpc.ClientMethod<$0.StartStreamingMetricsJobRequest, $0.StartStreamingMetricsJobResult>(
'/api.OrganisationService/StartStreamingMetricsJob',
($0.StartStreamingMetricsJobRequest value) => value.writeToBuffer(),
$0.StartStreamingMetricsJobResult.fromBuffer);
static final _$stopStreamingMetricsJob = $grpc.ClientMethod<$0.StopStreamingMetricsJobRequest, $0.StopStreamingMetricsJobResult>(
'/api.OrganisationService/StopStreamingMetricsJob',
($0.StopStreamingMetricsJobRequest value) => value.writeToBuffer(),
$0.StopStreamingMetricsJobResult.fromBuffer);
static final _$startIndividualStreamingJob = $grpc.ClientMethod<$0.StartIndividualStreamingJobRequest, $0.StartIndividualStreamingJobResult>(
'/api.OrganisationService/StartIndividualStreamingJob',
($0.StartIndividualStreamingJobRequest value) => value.writeToBuffer(),
$0.StartIndividualStreamingJobResult.fromBuffer);
static final _$stopIndividualStreamingJob = $grpc.ClientMethod<$0.StopIndividualStreamingJobRequest, $0.StopIndividualStreamingJobResult>(
'/api.OrganisationService/StopIndividualStreamingJob',
($0.StopIndividualStreamingJobRequest value) => value.writeToBuffer(),
$0.StopIndividualStreamingJobResult.fromBuffer);
static final _$provisionGitOrg = $grpc.ClientMethod<$0.ProvisionGitOrgRequest, $0.ProvisionGitOrgResult>(
'/api.OrganisationService/ProvisionGitOrg',
($0.ProvisionGitOrgRequest value) => value.writeToBuffer(),
$0.ProvisionGitOrgResult.fromBuffer);
static final _$deprovisionGitOrg = $grpc.ClientMethod<$0.DeprovisionGitOrgRequest, $0.DeprovisionGitOrgResult>(
'/api.OrganisationService/DeprovisionGitOrg',
($0.DeprovisionGitOrgRequest value) => value.writeToBuffer(),
$0.DeprovisionGitOrgResult.fromBuffer);
static final _$deleteOrganisationInDB = $grpc.ClientMethod<$0.DeleteOrganisationInDBRequest, $0.DeleteOrganisationInDBResult>(
'/api.OrganisationService/DeleteOrganisationInDB',
($0.DeleteOrganisationInDBRequest value) => value.writeToBuffer(),
$0.DeleteOrganisationInDBResult.fromBuffer);
}
@$pb.GrpcServiceName('api.OrganisationService')
abstract class OrganisationServiceBase extends $grpc.Service {
$core.String get $name => 'api.OrganisationService';
OrganisationServiceBase() {
$addMethod($grpc.ServiceMethod<$0.GetOrganisationRequest, $0.GetOrganisationResult>(
'Get',
get_Pre,
false,
false,
($core.List<$core.int> value) => $0.GetOrganisationRequest.fromBuffer(value),
($0.GetOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.CreateOrganisationRequest, $0.CreateOrganisationResult>(
'Create',
create_Pre,
false,
false,
($core.List<$core.int> value) => $0.CreateOrganisationRequest.fromBuffer(value),
($0.CreateOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.SetModulesOrganisationRequest, $0.SetModulesOrganisationResult>(
'SetModules',
setModules_Pre,
false,
false,
($core.List<$core.int> value) => $0.SetModulesOrganisationRequest.fromBuffer(value),
($0.SetModulesOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.UpdateOrganisationRequest, $0.UpdateOrganisationResult>(
'Update',
update_Pre,
false,
false,
($core.List<$core.int> value) => $0.UpdateOrganisationRequest.fromBuffer(value),
($0.UpdateOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.DeleteOrganisationRequest, $0.DeleteOrganisationResult>(
'Delete',
delete_Pre,
false,
false,
($core.List<$core.int> value) => $0.DeleteOrganisationRequest.fromBuffer(value),
($0.DeleteOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.ListOrganisationRequest, $0.ListOrganisationResult>(
'List',
list_Pre,
false,
false,
($core.List<$core.int> value) => $0.ListOrganisationRequest.fromBuffer(value),
($0.ListOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.UpdateOrganisationStatusRequest, $0.UpdateOrganisationStatusResult>(
'UpdateStatus',
updateStatus_Pre,
false,
false,
($core.List<$core.int> value) => $0.UpdateOrganisationStatusRequest.fromBuffer(value),
($0.UpdateOrganisationStatusResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.StartStreamingJobsRequest, $0.StartStreamingJobsResult>(
'StartStreamingJobs',
startStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $0.StartStreamingJobsRequest.fromBuffer(value),
($0.StartStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.StopStreamingJobsRequest, $0.StopStreamingJobsResult>(
'StopStreamingJobs',
stopStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $0.StopStreamingJobsRequest.fromBuffer(value),
($0.StopStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.CheckStreamingStatusRequest, $0.CheckStreamingStatusResult>(
'CheckStreamingStatus',
checkStreamingStatus_Pre,
false,
false,
($core.List<$core.int> value) => $0.CheckStreamingStatusRequest.fromBuffer(value),
($0.CheckStreamingStatusResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.StopAllStreamingJobsRequest, $0.StopAllStreamingJobsResult>(
'StopAllStreamingJobs',
stopAllStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $0.StopAllStreamingJobsRequest.fromBuffer(value),
($0.StopAllStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.RestartAllStreamingJobsRequest, $0.RestartAllStreamingJobsResult>(
'RestartAllStreamingJobs',
restartAllStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $0.RestartAllStreamingJobsRequest.fromBuffer(value),
($0.RestartAllStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.StartAllStreamingJobsRequest, $0.StartAllStreamingJobsResult>(
'StartAllStreamingJobs',
startAllStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $0.StartAllStreamingJobsRequest.fromBuffer(value),
($0.StartAllStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.ForceStopAllStreamingJobsRequest, $0.ForceStopAllStreamingJobsResult>(
'ForceStopAllStreamingJobs',
forceStopAllStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $0.ForceStopAllStreamingJobsRequest.fromBuffer(value),
($0.ForceStopAllStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.StartStreamingMetricsJobRequest, $0.StartStreamingMetricsJobResult>(
'StartStreamingMetricsJob',
startStreamingMetricsJob_Pre,
false,
false,
($core.List<$core.int> value) => $0.StartStreamingMetricsJobRequest.fromBuffer(value),
($0.StartStreamingMetricsJobResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.StopStreamingMetricsJobRequest, $0.StopStreamingMetricsJobResult>(
'StopStreamingMetricsJob',
stopStreamingMetricsJob_Pre,
false,
false,
($core.List<$core.int> value) => $0.StopStreamingMetricsJobRequest.fromBuffer(value),
($0.StopStreamingMetricsJobResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.StartIndividualStreamingJobRequest, $0.StartIndividualStreamingJobResult>(
'StartIndividualStreamingJob',
startIndividualStreamingJob_Pre,
false,
false,
($core.List<$core.int> value) => $0.StartIndividualStreamingJobRequest.fromBuffer(value),
($0.StartIndividualStreamingJobResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.StopIndividualStreamingJobRequest, $0.StopIndividualStreamingJobResult>(
'StopIndividualStreamingJob',
stopIndividualStreamingJob_Pre,
false,
false,
($core.List<$core.int> value) => $0.StopIndividualStreamingJobRequest.fromBuffer(value),
($0.StopIndividualStreamingJobResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.ProvisionGitOrgRequest, $0.ProvisionGitOrgResult>(
'ProvisionGitOrg',
provisionGitOrg_Pre,
false,
false,
($core.List<$core.int> value) => $0.ProvisionGitOrgRequest.fromBuffer(value),
($0.ProvisionGitOrgResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.DeprovisionGitOrgRequest, $0.DeprovisionGitOrgResult>(
'DeprovisionGitOrg',
deprovisionGitOrg_Pre,
false,
false,
($core.List<$core.int> value) => $0.DeprovisionGitOrgRequest.fromBuffer(value),
($0.DeprovisionGitOrgResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$0.DeleteOrganisationInDBRequest, $0.DeleteOrganisationInDBResult>(
'DeleteOrganisationInDB',
deleteOrganisationInDB_Pre,
false,
false,
($core.List<$core.int> value) => $0.DeleteOrganisationInDBRequest.fromBuffer(value),
($0.DeleteOrganisationInDBResult value) => value.writeToBuffer()));
}
$async.Future<$0.GetOrganisationResult> get_Pre($grpc.ServiceCall $call, $async.Future<$0.GetOrganisationRequest> $request) async {
return get($call, await $request);
}
$async.Future<$0.GetOrganisationResult> get($grpc.ServiceCall call, $0.GetOrganisationRequest request);
$async.Future<$0.CreateOrganisationResult> create_Pre($grpc.ServiceCall $call, $async.Future<$0.CreateOrganisationRequest> $request) async {
return create($call, await $request);
}
$async.Future<$0.CreateOrganisationResult> create($grpc.ServiceCall call, $0.CreateOrganisationRequest request);
$async.Future<$0.SetModulesOrganisationResult> setModules_Pre($grpc.ServiceCall $call, $async.Future<$0.SetModulesOrganisationRequest> $request) async {
return setModules($call, await $request);
}
$async.Future<$0.SetModulesOrganisationResult> setModules($grpc.ServiceCall call, $0.SetModulesOrganisationRequest request);
$async.Future<$0.UpdateOrganisationResult> update_Pre($grpc.ServiceCall $call, $async.Future<$0.UpdateOrganisationRequest> $request) async {
return update($call, await $request);
}
$async.Future<$0.UpdateOrganisationResult> update($grpc.ServiceCall call, $0.UpdateOrganisationRequest request);
$async.Future<$0.DeleteOrganisationResult> delete_Pre($grpc.ServiceCall $call, $async.Future<$0.DeleteOrganisationRequest> $request) async {
return delete($call, await $request);
}
$async.Future<$0.DeleteOrganisationResult> delete($grpc.ServiceCall call, $0.DeleteOrganisationRequest request);
$async.Future<$0.ListOrganisationResult> list_Pre($grpc.ServiceCall $call, $async.Future<$0.ListOrganisationRequest> $request) async {
return list($call, await $request);
}
$async.Future<$0.ListOrganisationResult> list($grpc.ServiceCall call, $0.ListOrganisationRequest request);
$async.Future<$0.UpdateOrganisationStatusResult> updateStatus_Pre($grpc.ServiceCall $call, $async.Future<$0.UpdateOrganisationStatusRequest> $request) async {
return updateStatus($call, await $request);
}
$async.Future<$0.UpdateOrganisationStatusResult> updateStatus($grpc.ServiceCall call, $0.UpdateOrganisationStatusRequest request);
$async.Future<$0.StartStreamingJobsResult> startStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$0.StartStreamingJobsRequest> $request) async {
return startStreamingJobs($call, await $request);
}
$async.Future<$0.StartStreamingJobsResult> startStreamingJobs($grpc.ServiceCall call, $0.StartStreamingJobsRequest request);
$async.Future<$0.StopStreamingJobsResult> stopStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$0.StopStreamingJobsRequest> $request) async {
return stopStreamingJobs($call, await $request);
}
$async.Future<$0.StopStreamingJobsResult> stopStreamingJobs($grpc.ServiceCall call, $0.StopStreamingJobsRequest request);
$async.Future<$0.CheckStreamingStatusResult> checkStreamingStatus_Pre($grpc.ServiceCall $call, $async.Future<$0.CheckStreamingStatusRequest> $request) async {
return checkStreamingStatus($call, await $request);
}
$async.Future<$0.CheckStreamingStatusResult> checkStreamingStatus($grpc.ServiceCall call, $0.CheckStreamingStatusRequest request);
$async.Future<$0.StopAllStreamingJobsResult> stopAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$0.StopAllStreamingJobsRequest> $request) async {
return stopAllStreamingJobs($call, await $request);
}
$async.Future<$0.StopAllStreamingJobsResult> stopAllStreamingJobs($grpc.ServiceCall call, $0.StopAllStreamingJobsRequest request);
$async.Future<$0.RestartAllStreamingJobsResult> restartAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$0.RestartAllStreamingJobsRequest> $request) async {
return restartAllStreamingJobs($call, await $request);
}
$async.Future<$0.RestartAllStreamingJobsResult> restartAllStreamingJobs($grpc.ServiceCall call, $0.RestartAllStreamingJobsRequest request);
$async.Future<$0.StartAllStreamingJobsResult> startAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$0.StartAllStreamingJobsRequest> $request) async {
return startAllStreamingJobs($call, await $request);
}
$async.Future<$0.StartAllStreamingJobsResult> startAllStreamingJobs($grpc.ServiceCall call, $0.StartAllStreamingJobsRequest request);
$async.Future<$0.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$0.ForceStopAllStreamingJobsRequest> $request) async {
return forceStopAllStreamingJobs($call, await $request);
}
$async.Future<$0.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs($grpc.ServiceCall call, $0.ForceStopAllStreamingJobsRequest request);
$async.Future<$0.StartStreamingMetricsJobResult> startStreamingMetricsJob_Pre($grpc.ServiceCall $call, $async.Future<$0.StartStreamingMetricsJobRequest> $request) async {
return startStreamingMetricsJob($call, await $request);
}
$async.Future<$0.StartStreamingMetricsJobResult> startStreamingMetricsJob($grpc.ServiceCall call, $0.StartStreamingMetricsJobRequest request);
$async.Future<$0.StopStreamingMetricsJobResult> stopStreamingMetricsJob_Pre($grpc.ServiceCall $call, $async.Future<$0.StopStreamingMetricsJobRequest> $request) async {
return stopStreamingMetricsJob($call, await $request);
}
$async.Future<$0.StopStreamingMetricsJobResult> stopStreamingMetricsJob($grpc.ServiceCall call, $0.StopStreamingMetricsJobRequest request);
$async.Future<$0.StartIndividualStreamingJobResult> startIndividualStreamingJob_Pre($grpc.ServiceCall $call, $async.Future<$0.StartIndividualStreamingJobRequest> $request) async {
return startIndividualStreamingJob($call, await $request);
}
$async.Future<$0.StartIndividualStreamingJobResult> startIndividualStreamingJob($grpc.ServiceCall call, $0.StartIndividualStreamingJobRequest request);
$async.Future<$0.StopIndividualStreamingJobResult> stopIndividualStreamingJob_Pre($grpc.ServiceCall $call, $async.Future<$0.StopIndividualStreamingJobRequest> $request) async {
return stopIndividualStreamingJob($call, await $request);
}
$async.Future<$0.StopIndividualStreamingJobResult> stopIndividualStreamingJob($grpc.ServiceCall call, $0.StopIndividualStreamingJobRequest request);
$async.Future<$0.ProvisionGitOrgResult> provisionGitOrg_Pre($grpc.ServiceCall $call, $async.Future<$0.ProvisionGitOrgRequest> $request) async {
return provisionGitOrg($call, await $request);
}
$async.Future<$0.ProvisionGitOrgResult> provisionGitOrg($grpc.ServiceCall call, $0.ProvisionGitOrgRequest request);
$async.Future<$0.DeprovisionGitOrgResult> deprovisionGitOrg_Pre($grpc.ServiceCall $call, $async.Future<$0.DeprovisionGitOrgRequest> $request) async {
return deprovisionGitOrg($call, await $request);
}
$async.Future<$0.DeprovisionGitOrgResult> deprovisionGitOrg($grpc.ServiceCall call, $0.DeprovisionGitOrgRequest request);
$async.Future<$0.DeleteOrganisationInDBResult> deleteOrganisationInDB_Pre($grpc.ServiceCall $call, $async.Future<$0.DeleteOrganisationInDBRequest> $request) async {
return deleteOrganisationInDB($call, await $request);
}
$async.Future<$0.DeleteOrganisationInDBResult> deleteOrganisationInDB($grpc.ServiceCall call, $0.DeleteOrganisationInDBRequest request);
}
View Git Blame Copy Permalink