reflex-platform/dart-core-sdk
0
Fork 0
Code Pull Requests Projects Releases Wiki Activity
Files
1c1f8cc1387aefec260a7cedb7563ab88a491b46
dart-core-sdk/lib/org.pbgrpc.dart
ci core model 1c1f8cc138 Release 1.10.6
2025-05-19 13:38:48 +00:00

556 lines
34 KiB
Dart
Raw Blame History

//
// Generated code. Do not modify.
// source: org.proto
//
// @dart = 3.3
// ignore_for_file: annotate_overrides, camel_case_types, comment_references
// ignore_for_file: constant_identifier_names, library_prefixes
// ignore_for_file: non_constant_identifier_names, prefer_final_fields
// ignore_for_file: unnecessary_import, unnecessary_this, unused_import
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 $43;
export 'org.pb.dart';
@$pb.GrpcServiceName('api.OrganisationService')
class OrganisationServiceClient extends $grpc.Client {
static final _$get = $grpc.ClientMethod<$43.GetOrganisationRequest, $43.GetOrganisationResult>(
'/api.OrganisationService/Get',
($43.GetOrganisationRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.GetOrganisationResult.fromBuffer(value));
static final _$create = $grpc.ClientMethod<$43.CreateOrganisationRequest, $43.CreateOrganisationResult>(
'/api.OrganisationService/Create',
($43.CreateOrganisationRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.CreateOrganisationResult.fromBuffer(value));
static final _$setModules = $grpc.ClientMethod<$43.SetModulesOrganisationRequest, $43.SetModulesOrganisationResult>(
'/api.OrganisationService/SetModules',
($43.SetModulesOrganisationRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.SetModulesOrganisationResult.fromBuffer(value));
static final _$update = $grpc.ClientMethod<$43.UpdateOrganisationRequest, $43.UpdateOrganisationResult>(
'/api.OrganisationService/Update',
($43.UpdateOrganisationRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.UpdateOrganisationResult.fromBuffer(value));
static final _$delete = $grpc.ClientMethod<$43.DeleteOrganisationRequest, $43.DeleteOrganisationResult>(
'/api.OrganisationService/Delete',
($43.DeleteOrganisationRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.DeleteOrganisationResult.fromBuffer(value));
static final _$list = $grpc.ClientMethod<$43.ListOrganisationRequest, $43.ListOrganisationResult>(
'/api.OrganisationService/List',
($43.ListOrganisationRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.ListOrganisationResult.fromBuffer(value));
static final _$updateStatus = $grpc.ClientMethod<$43.UpdateOrganisationStatusRequest, $43.UpdateOrganisationStatusResult>(
'/api.OrganisationService/UpdateStatus',
($43.UpdateOrganisationStatusRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.UpdateOrganisationStatusResult.fromBuffer(value));
static final _$startStreamingJobs = $grpc.ClientMethod<$43.StartStreamingJobsRequest, $43.StartStreamingJobsResult>(
'/api.OrganisationService/StartStreamingJobs',
($43.StartStreamingJobsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.StartStreamingJobsResult.fromBuffer(value));
static final _$stopStreamingJobs = $grpc.ClientMethod<$43.StopStreamingJobsRequest, $43.StopStreamingJobsResult>(
'/api.OrganisationService/StopStreamingJobs',
($43.StopStreamingJobsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.StopStreamingJobsResult.fromBuffer(value));
static final _$checkStreamingStatus = $grpc.ClientMethod<$43.CheckStreamingStatusRequest, $43.CheckStreamingStatusResult>(
'/api.OrganisationService/CheckStreamingStatus',
($43.CheckStreamingStatusRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.CheckStreamingStatusResult.fromBuffer(value));
static final _$stopAllStreamingJobs = $grpc.ClientMethod<$43.StopAllStreamingJobsRequest, $43.StopAllStreamingJobsResult>(
'/api.OrganisationService/StopAllStreamingJobs',
($43.StopAllStreamingJobsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.StopAllStreamingJobsResult.fromBuffer(value));
static final _$restartAllStreamingJobs = $grpc.ClientMethod<$43.RestartAllStreamingJobsRequest, $43.RestartAllStreamingJobsResult>(
'/api.OrganisationService/RestartAllStreamingJobs',
($43.RestartAllStreamingJobsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.RestartAllStreamingJobsResult.fromBuffer(value));
static final _$startAllStreamingJobs = $grpc.ClientMethod<$43.StartAllStreamingJobsRequest, $43.StartAllStreamingJobsResult>(
'/api.OrganisationService/StartAllStreamingJobs',
($43.StartAllStreamingJobsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.StartAllStreamingJobsResult.fromBuffer(value));
static final _$forceStopAllStreamingJobs = $grpc.ClientMethod<$43.ForceStopAllStreamingJobsRequest, $43.ForceStopAllStreamingJobsResult>(
'/api.OrganisationService/ForceStopAllStreamingJobs',
($43.ForceStopAllStreamingJobsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.ForceStopAllStreamingJobsResult.fromBuffer(value));
static final _$startStreamingMetricsJob = $grpc.ClientMethod<$43.StartStreamingMetricsJobRequest, $43.StartStreamingMetricsJobResult>(
'/api.OrganisationService/StartStreamingMetricsJob',
($43.StartStreamingMetricsJobRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.StartStreamingMetricsJobResult.fromBuffer(value));
static final _$stopStreamingMetricsJob = $grpc.ClientMethod<$43.StopStreamingMetricsJobRequest, $43.StopStreamingMetricsJobResult>(
'/api.OrganisationService/StopStreamingMetricsJob',
($43.StopStreamingMetricsJobRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.StopStreamingMetricsJobResult.fromBuffer(value));
static final _$startIndividualStreamingJob = $grpc.ClientMethod<$43.StartIndividualStreamingJobRequest, $43.StartIndividualStreamingJobResult>(
'/api.OrganisationService/StartIndividualStreamingJob',
($43.StartIndividualStreamingJobRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.StartIndividualStreamingJobResult.fromBuffer(value));
static final _$stopIndividualStreamingJob = $grpc.ClientMethod<$43.StopIndividualStreamingJobRequest, $43.StopIndividualStreamingJobResult>(
'/api.OrganisationService/StopIndividualStreamingJob',
($43.StopIndividualStreamingJobRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.StopIndividualStreamingJobResult.fromBuffer(value));
static final _$provisionGitOrg = $grpc.ClientMethod<$43.ProvisionGitOrgRequest, $43.ProvisionGitOrgResult>(
'/api.OrganisationService/ProvisionGitOrg',
($43.ProvisionGitOrgRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.ProvisionGitOrgResult.fromBuffer(value));
static final _$deprovisionGitOrg = $grpc.ClientMethod<$43.DeprovisionGitOrgRequest, $43.DeprovisionGitOrgResult>(
'/api.OrganisationService/DeprovisionGitOrg',
($43.DeprovisionGitOrgRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.DeprovisionGitOrgResult.fromBuffer(value));
static final _$createPulsar = $grpc.ClientMethod<$43.CreatePulsarRequest, $43.CreatePulsarResult>(
'/api.OrganisationService/CreatePulsar',
($43.CreatePulsarRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.CreatePulsarResult.fromBuffer(value));
static final _$createPulsarSubscriptions = $grpc.ClientMethod<$43.CreatePulsarSubscriptionsRequest, $43.CreatePulsarSubscriptionsResult>(
'/api.OrganisationService/CreatePulsarSubscriptions',
($43.CreatePulsarSubscriptionsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.CreatePulsarSubscriptionsResult.fromBuffer(value));
static final _$deletePulsar = $grpc.ClientMethod<$43.DeletePulsarRequest, $43.DeletePulsarResult>(
'/api.OrganisationService/DeletePulsar',
($43.DeletePulsarRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.DeletePulsarResult.fromBuffer(value));
static final _$createPulsarMissPartitions = $grpc.ClientMethod<$43.CreatePulsarMissPartitionsRequest, $43.CreatePulsarMissPartitionsResult>(
'/api.OrganisationService/CreatePulsarMissPartitions',
($43.CreatePulsarMissPartitionsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.CreatePulsarMissPartitionsResult.fromBuffer(value));
static final _$createAllPulsarMissPartitions = $grpc.ClientMethod<$43.CreateAllPulsarMissPartitionsRequest, $43.CreateAllPulsarMissPartitionsResult>(
'/api.OrganisationService/CreateAllPulsarMissPartitions',
($43.CreateAllPulsarMissPartitionsRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.CreateAllPulsarMissPartitionsResult.fromBuffer(value));
static final _$deleteOrganisationInDB = $grpc.ClientMethod<$43.DeleteOrganisationInDBRequest, $43.DeleteOrganisationInDBResult>(
'/api.OrganisationService/DeleteOrganisationInDB',
($43.DeleteOrganisationInDBRequest value) => value.writeToBuffer(),
($core.List<$core.int> value) => $43.DeleteOrganisationInDBResult.fromBuffer(value));
OrganisationServiceClient(super.channel, {super.options, super.interceptors});
$grpc.ResponseFuture<$43.GetOrganisationResult> get($43.GetOrganisationRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$get, request, options: options);
}
$grpc.ResponseFuture<$43.CreateOrganisationResult> create($43.CreateOrganisationRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$create, request, options: options);
}
$grpc.ResponseFuture<$43.SetModulesOrganisationResult> setModules($43.SetModulesOrganisationRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$setModules, request, options: options);
}
$grpc.ResponseFuture<$43.UpdateOrganisationResult> update($43.UpdateOrganisationRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$update, request, options: options);
}
$grpc.ResponseFuture<$43.DeleteOrganisationResult> delete($43.DeleteOrganisationRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$delete, request, options: options);
}
$grpc.ResponseFuture<$43.ListOrganisationResult> list($43.ListOrganisationRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$list, request, options: options);
}
$grpc.ResponseFuture<$43.UpdateOrganisationStatusResult> updateStatus($43.UpdateOrganisationStatusRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$updateStatus, request, options: options);
}
$grpc.ResponseFuture<$43.StartStreamingJobsResult> startStreamingJobs($43.StartStreamingJobsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$startStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$43.StopStreamingJobsResult> stopStreamingJobs($43.StopStreamingJobsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$stopStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$43.CheckStreamingStatusResult> checkStreamingStatus($43.CheckStreamingStatusRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$checkStreamingStatus, request, options: options);
}
$grpc.ResponseFuture<$43.StopAllStreamingJobsResult> stopAllStreamingJobs($43.StopAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$stopAllStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$43.RestartAllStreamingJobsResult> restartAllStreamingJobs($43.RestartAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$restartAllStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$43.StartAllStreamingJobsResult> startAllStreamingJobs($43.StartAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$startAllStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$43.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs($43.ForceStopAllStreamingJobsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$forceStopAllStreamingJobs, request, options: options);
}
$grpc.ResponseFuture<$43.StartStreamingMetricsJobResult> startStreamingMetricsJob($43.StartStreamingMetricsJobRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$startStreamingMetricsJob, request, options: options);
}
$grpc.ResponseFuture<$43.StopStreamingMetricsJobResult> stopStreamingMetricsJob($43.StopStreamingMetricsJobRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$stopStreamingMetricsJob, request, options: options);
}
$grpc.ResponseFuture<$43.StartIndividualStreamingJobResult> startIndividualStreamingJob($43.StartIndividualStreamingJobRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$startIndividualStreamingJob, request, options: options);
}
$grpc.ResponseFuture<$43.StopIndividualStreamingJobResult> stopIndividualStreamingJob($43.StopIndividualStreamingJobRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$stopIndividualStreamingJob, request, options: options);
}
$grpc.ResponseFuture<$43.ProvisionGitOrgResult> provisionGitOrg($43.ProvisionGitOrgRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$provisionGitOrg, request, options: options);
}
$grpc.ResponseFuture<$43.DeprovisionGitOrgResult> deprovisionGitOrg($43.DeprovisionGitOrgRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$deprovisionGitOrg, request, options: options);
}
$grpc.ResponseFuture<$43.CreatePulsarResult> createPulsar($43.CreatePulsarRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$createPulsar, request, options: options);
}
$grpc.ResponseFuture<$43.CreatePulsarSubscriptionsResult> createPulsarSubscriptions($43.CreatePulsarSubscriptionsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$createPulsarSubscriptions, request, options: options);
}
$grpc.ResponseFuture<$43.DeletePulsarResult> deletePulsar($43.DeletePulsarRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$deletePulsar, request, options: options);
}
$grpc.ResponseFuture<$43.CreatePulsarMissPartitionsResult> createPulsarMissPartitions($43.CreatePulsarMissPartitionsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$createPulsarMissPartitions, request, options: options);
}
$grpc.ResponseFuture<$43.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions($43.CreateAllPulsarMissPartitionsRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$createAllPulsarMissPartitions, request, options: options);
}
$grpc.ResponseFuture<$43.DeleteOrganisationInDBResult> deleteOrganisationInDB($43.DeleteOrganisationInDBRequest request, {$grpc.CallOptions? options}) {
return $createUnaryCall(_$deleteOrganisationInDB, request, options: options);
}
}
@$pb.GrpcServiceName('api.OrganisationService')
abstract class OrganisationServiceBase extends $grpc.Service {
$core.String get $name => 'api.OrganisationService';
OrganisationServiceBase() {
$addMethod($grpc.ServiceMethod<$43.GetOrganisationRequest, $43.GetOrganisationResult>(
'Get',
get_Pre,
false,
false,
($core.List<$core.int> value) => $43.GetOrganisationRequest.fromBuffer(value),
($43.GetOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.CreateOrganisationRequest, $43.CreateOrganisationResult>(
'Create',
create_Pre,
false,
false,
($core.List<$core.int> value) => $43.CreateOrganisationRequest.fromBuffer(value),
($43.CreateOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.SetModulesOrganisationRequest, $43.SetModulesOrganisationResult>(
'SetModules',
setModules_Pre,
false,
false,
($core.List<$core.int> value) => $43.SetModulesOrganisationRequest.fromBuffer(value),
($43.SetModulesOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.UpdateOrganisationRequest, $43.UpdateOrganisationResult>(
'Update',
update_Pre,
false,
false,
($core.List<$core.int> value) => $43.UpdateOrganisationRequest.fromBuffer(value),
($43.UpdateOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.DeleteOrganisationRequest, $43.DeleteOrganisationResult>(
'Delete',
delete_Pre,
false,
false,
($core.List<$core.int> value) => $43.DeleteOrganisationRequest.fromBuffer(value),
($43.DeleteOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.ListOrganisationRequest, $43.ListOrganisationResult>(
'List',
list_Pre,
false,
false,
($core.List<$core.int> value) => $43.ListOrganisationRequest.fromBuffer(value),
($43.ListOrganisationResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.UpdateOrganisationStatusRequest, $43.UpdateOrganisationStatusResult>(
'UpdateStatus',
updateStatus_Pre,
false,
false,
($core.List<$core.int> value) => $43.UpdateOrganisationStatusRequest.fromBuffer(value),
($43.UpdateOrganisationStatusResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.StartStreamingJobsRequest, $43.StartStreamingJobsResult>(
'StartStreamingJobs',
startStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $43.StartStreamingJobsRequest.fromBuffer(value),
($43.StartStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.StopStreamingJobsRequest, $43.StopStreamingJobsResult>(
'StopStreamingJobs',
stopStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $43.StopStreamingJobsRequest.fromBuffer(value),
($43.StopStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.CheckStreamingStatusRequest, $43.CheckStreamingStatusResult>(
'CheckStreamingStatus',
checkStreamingStatus_Pre,
false,
false,
($core.List<$core.int> value) => $43.CheckStreamingStatusRequest.fromBuffer(value),
($43.CheckStreamingStatusResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.StopAllStreamingJobsRequest, $43.StopAllStreamingJobsResult>(
'StopAllStreamingJobs',
stopAllStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $43.StopAllStreamingJobsRequest.fromBuffer(value),
($43.StopAllStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.RestartAllStreamingJobsRequest, $43.RestartAllStreamingJobsResult>(
'RestartAllStreamingJobs',
restartAllStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $43.RestartAllStreamingJobsRequest.fromBuffer(value),
($43.RestartAllStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.StartAllStreamingJobsRequest, $43.StartAllStreamingJobsResult>(
'StartAllStreamingJobs',
startAllStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $43.StartAllStreamingJobsRequest.fromBuffer(value),
($43.StartAllStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.ForceStopAllStreamingJobsRequest, $43.ForceStopAllStreamingJobsResult>(
'ForceStopAllStreamingJobs',
forceStopAllStreamingJobs_Pre,
false,
false,
($core.List<$core.int> value) => $43.ForceStopAllStreamingJobsRequest.fromBuffer(value),
($43.ForceStopAllStreamingJobsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.StartStreamingMetricsJobRequest, $43.StartStreamingMetricsJobResult>(
'StartStreamingMetricsJob',
startStreamingMetricsJob_Pre,
false,
false,
($core.List<$core.int> value) => $43.StartStreamingMetricsJobRequest.fromBuffer(value),
($43.StartStreamingMetricsJobResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.StopStreamingMetricsJobRequest, $43.StopStreamingMetricsJobResult>(
'StopStreamingMetricsJob',
stopStreamingMetricsJob_Pre,
false,
false,
($core.List<$core.int> value) => $43.StopStreamingMetricsJobRequest.fromBuffer(value),
($43.StopStreamingMetricsJobResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.StartIndividualStreamingJobRequest, $43.StartIndividualStreamingJobResult>(
'StartIndividualStreamingJob',
startIndividualStreamingJob_Pre,
false,
false,
($core.List<$core.int> value) => $43.StartIndividualStreamingJobRequest.fromBuffer(value),
($43.StartIndividualStreamingJobResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.StopIndividualStreamingJobRequest, $43.StopIndividualStreamingJobResult>(
'StopIndividualStreamingJob',
stopIndividualStreamingJob_Pre,
false,
false,
($core.List<$core.int> value) => $43.StopIndividualStreamingJobRequest.fromBuffer(value),
($43.StopIndividualStreamingJobResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.ProvisionGitOrgRequest, $43.ProvisionGitOrgResult>(
'ProvisionGitOrg',
provisionGitOrg_Pre,
false,
false,
($core.List<$core.int> value) => $43.ProvisionGitOrgRequest.fromBuffer(value),
($43.ProvisionGitOrgResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.DeprovisionGitOrgRequest, $43.DeprovisionGitOrgResult>(
'DeprovisionGitOrg',
deprovisionGitOrg_Pre,
false,
false,
($core.List<$core.int> value) => $43.DeprovisionGitOrgRequest.fromBuffer(value),
($43.DeprovisionGitOrgResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.CreatePulsarRequest, $43.CreatePulsarResult>(
'CreatePulsar',
createPulsar_Pre,
false,
false,
($core.List<$core.int> value) => $43.CreatePulsarRequest.fromBuffer(value),
($43.CreatePulsarResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.CreatePulsarSubscriptionsRequest, $43.CreatePulsarSubscriptionsResult>(
'CreatePulsarSubscriptions',
createPulsarSubscriptions_Pre,
false,
false,
($core.List<$core.int> value) => $43.CreatePulsarSubscriptionsRequest.fromBuffer(value),
($43.CreatePulsarSubscriptionsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.DeletePulsarRequest, $43.DeletePulsarResult>(
'DeletePulsar',
deletePulsar_Pre,
false,
false,
($core.List<$core.int> value) => $43.DeletePulsarRequest.fromBuffer(value),
($43.DeletePulsarResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.CreatePulsarMissPartitionsRequest, $43.CreatePulsarMissPartitionsResult>(
'CreatePulsarMissPartitions',
createPulsarMissPartitions_Pre,
false,
false,
($core.List<$core.int> value) => $43.CreatePulsarMissPartitionsRequest.fromBuffer(value),
($43.CreatePulsarMissPartitionsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.CreateAllPulsarMissPartitionsRequest, $43.CreateAllPulsarMissPartitionsResult>(
'CreateAllPulsarMissPartitions',
createAllPulsarMissPartitions_Pre,
false,
false,
($core.List<$core.int> value) => $43.CreateAllPulsarMissPartitionsRequest.fromBuffer(value),
($43.CreateAllPulsarMissPartitionsResult value) => value.writeToBuffer()));
$addMethod($grpc.ServiceMethod<$43.DeleteOrganisationInDBRequest, $43.DeleteOrganisationInDBResult>(
'DeleteOrganisationInDB',
deleteOrganisationInDB_Pre,
false,
false,
($core.List<$core.int> value) => $43.DeleteOrganisationInDBRequest.fromBuffer(value),
($43.DeleteOrganisationInDBResult value) => value.writeToBuffer()));
}
$async.Future<$43.GetOrganisationResult> get_Pre($grpc.ServiceCall $call, $async.Future<$43.GetOrganisationRequest> $request) async {
return get($call, await $request);
}
$async.Future<$43.CreateOrganisationResult> create_Pre($grpc.ServiceCall $call, $async.Future<$43.CreateOrganisationRequest> $request) async {
return create($call, await $request);
}
$async.Future<$43.SetModulesOrganisationResult> setModules_Pre($grpc.ServiceCall $call, $async.Future<$43.SetModulesOrganisationRequest> $request) async {
return setModules($call, await $request);
}
$async.Future<$43.UpdateOrganisationResult> update_Pre($grpc.ServiceCall $call, $async.Future<$43.UpdateOrganisationRequest> $request) async {
return update($call, await $request);
}
$async.Future<$43.DeleteOrganisationResult> delete_Pre($grpc.ServiceCall $call, $async.Future<$43.DeleteOrganisationRequest> $request) async {
return delete($call, await $request);
}
$async.Future<$43.ListOrganisationResult> list_Pre($grpc.ServiceCall $call, $async.Future<$43.ListOrganisationRequest> $request) async {
return list($call, await $request);
}
$async.Future<$43.UpdateOrganisationStatusResult> updateStatus_Pre($grpc.ServiceCall $call, $async.Future<$43.UpdateOrganisationStatusRequest> $request) async {
return updateStatus($call, await $request);
}
$async.Future<$43.StartStreamingJobsResult> startStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$43.StartStreamingJobsRequest> $request) async {
return startStreamingJobs($call, await $request);
}
$async.Future<$43.StopStreamingJobsResult> stopStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$43.StopStreamingJobsRequest> $request) async {
return stopStreamingJobs($call, await $request);
}
$async.Future<$43.CheckStreamingStatusResult> checkStreamingStatus_Pre($grpc.ServiceCall $call, $async.Future<$43.CheckStreamingStatusRequest> $request) async {
return checkStreamingStatus($call, await $request);
}
$async.Future<$43.StopAllStreamingJobsResult> stopAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$43.StopAllStreamingJobsRequest> $request) async {
return stopAllStreamingJobs($call, await $request);
}
$async.Future<$43.RestartAllStreamingJobsResult> restartAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$43.RestartAllStreamingJobsRequest> $request) async {
return restartAllStreamingJobs($call, await $request);
}
$async.Future<$43.StartAllStreamingJobsResult> startAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$43.StartAllStreamingJobsRequest> $request) async {
return startAllStreamingJobs($call, await $request);
}
$async.Future<$43.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs_Pre($grpc.ServiceCall $call, $async.Future<$43.ForceStopAllStreamingJobsRequest> $request) async {
return forceStopAllStreamingJobs($call, await $request);
}
$async.Future<$43.StartStreamingMetricsJobResult> startStreamingMetricsJob_Pre($grpc.ServiceCall $call, $async.Future<$43.StartStreamingMetricsJobRequest> $request) async {
return startStreamingMetricsJob($call, await $request);
}
$async.Future<$43.StopStreamingMetricsJobResult> stopStreamingMetricsJob_Pre($grpc.ServiceCall $call, $async.Future<$43.StopStreamingMetricsJobRequest> $request) async {
return stopStreamingMetricsJob($call, await $request);
}
$async.Future<$43.StartIndividualStreamingJobResult> startIndividualStreamingJob_Pre($grpc.ServiceCall $call, $async.Future<$43.StartIndividualStreamingJobRequest> $request) async {
return startIndividualStreamingJob($call, await $request);
}
$async.Future<$43.StopIndividualStreamingJobResult> stopIndividualStreamingJob_Pre($grpc.ServiceCall $call, $async.Future<$43.StopIndividualStreamingJobRequest> $request) async {
return stopIndividualStreamingJob($call, await $request);
}
$async.Future<$43.ProvisionGitOrgResult> provisionGitOrg_Pre($grpc.ServiceCall $call, $async.Future<$43.ProvisionGitOrgRequest> $request) async {
return provisionGitOrg($call, await $request);
}
$async.Future<$43.DeprovisionGitOrgResult> deprovisionGitOrg_Pre($grpc.ServiceCall $call, $async.Future<$43.DeprovisionGitOrgRequest> $request) async {
return deprovisionGitOrg($call, await $request);
}
$async.Future<$43.CreatePulsarResult> createPulsar_Pre($grpc.ServiceCall $call, $async.Future<$43.CreatePulsarRequest> $request) async {
return createPulsar($call, await $request);
}
$async.Future<$43.CreatePulsarSubscriptionsResult> createPulsarSubscriptions_Pre($grpc.ServiceCall $call, $async.Future<$43.CreatePulsarSubscriptionsRequest> $request) async {
return createPulsarSubscriptions($call, await $request);
}
$async.Future<$43.DeletePulsarResult> deletePulsar_Pre($grpc.ServiceCall $call, $async.Future<$43.DeletePulsarRequest> $request) async {
return deletePulsar($call, await $request);
}
$async.Future<$43.CreatePulsarMissPartitionsResult> createPulsarMissPartitions_Pre($grpc.ServiceCall $call, $async.Future<$43.CreatePulsarMissPartitionsRequest> $request) async {
return createPulsarMissPartitions($call, await $request);
}
$async.Future<$43.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions_Pre($grpc.ServiceCall $call, $async.Future<$43.CreateAllPulsarMissPartitionsRequest> $request) async {
return createAllPulsarMissPartitions($call, await $request);
}
$async.Future<$43.DeleteOrganisationInDBResult> deleteOrganisationInDB_Pre($grpc.ServiceCall $call, $async.Future<$43.DeleteOrganisationInDBRequest> $request) async {
return deleteOrganisationInDB($call, await $request);
}
$async.Future<$43.GetOrganisationResult> get($grpc.ServiceCall call, $43.GetOrganisationRequest request);
$async.Future<$43.CreateOrganisationResult> create($grpc.ServiceCall call, $43.CreateOrganisationRequest request);
$async.Future<$43.SetModulesOrganisationResult> setModules($grpc.ServiceCall call, $43.SetModulesOrganisationRequest request);
$async.Future<$43.UpdateOrganisationResult> update($grpc.ServiceCall call, $43.UpdateOrganisationRequest request);
$async.Future<$43.DeleteOrganisationResult> delete($grpc.ServiceCall call, $43.DeleteOrganisationRequest request);
$async.Future<$43.ListOrganisationResult> list($grpc.ServiceCall call, $43.ListOrganisationRequest request);
$async.Future<$43.UpdateOrganisationStatusResult> updateStatus($grpc.ServiceCall call, $43.UpdateOrganisationStatusRequest request);
$async.Future<$43.StartStreamingJobsResult> startStreamingJobs($grpc.ServiceCall call, $43.StartStreamingJobsRequest request);
$async.Future<$43.StopStreamingJobsResult> stopStreamingJobs($grpc.ServiceCall call, $43.StopStreamingJobsRequest request);
$async.Future<$43.CheckStreamingStatusResult> checkStreamingStatus($grpc.ServiceCall call, $43.CheckStreamingStatusRequest request);
$async.Future<$43.StopAllStreamingJobsResult> stopAllStreamingJobs($grpc.ServiceCall call, $43.StopAllStreamingJobsRequest request);
$async.Future<$43.RestartAllStreamingJobsResult> restartAllStreamingJobs($grpc.ServiceCall call, $43.RestartAllStreamingJobsRequest request);
$async.Future<$43.StartAllStreamingJobsResult> startAllStreamingJobs($grpc.ServiceCall call, $43.StartAllStreamingJobsRequest request);
$async.Future<$43.ForceStopAllStreamingJobsResult> forceStopAllStreamingJobs($grpc.ServiceCall call, $43.ForceStopAllStreamingJobsRequest request);
$async.Future<$43.StartStreamingMetricsJobResult> startStreamingMetricsJob($grpc.ServiceCall call, $43.StartStreamingMetricsJobRequest request);
$async.Future<$43.StopStreamingMetricsJobResult> stopStreamingMetricsJob($grpc.ServiceCall call, $43.StopStreamingMetricsJobRequest request);
$async.Future<$43.StartIndividualStreamingJobResult> startIndividualStreamingJob($grpc.ServiceCall call, $43.StartIndividualStreamingJobRequest request);
$async.Future<$43.StopIndividualStreamingJobResult> stopIndividualStreamingJob($grpc.ServiceCall call, $43.StopIndividualStreamingJobRequest request);
$async.Future<$43.ProvisionGitOrgResult> provisionGitOrg($grpc.ServiceCall call, $43.ProvisionGitOrgRequest request);
$async.Future<$43.DeprovisionGitOrgResult> deprovisionGitOrg($grpc.ServiceCall call, $43.DeprovisionGitOrgRequest request);
$async.Future<$43.CreatePulsarResult> createPulsar($grpc.ServiceCall call, $43.CreatePulsarRequest request);
$async.Future<$43.CreatePulsarSubscriptionsResult> createPulsarSubscriptions($grpc.ServiceCall call, $43.CreatePulsarSubscriptionsRequest request);
$async.Future<$43.DeletePulsarResult> deletePulsar($grpc.ServiceCall call, $43.DeletePulsarRequest request);
$async.Future<$43.CreatePulsarMissPartitionsResult> createPulsarMissPartitions($grpc.ServiceCall call, $43.CreatePulsarMissPartitionsRequest request);
$async.Future<$43.CreateAllPulsarMissPartitionsResult> createAllPulsarMissPartitions($grpc.ServiceCall call, $43.CreateAllPulsarMissPartitionsRequest request);
$async.Future<$43.DeleteOrganisationInDBResult> deleteOrganisationInDB($grpc.ServiceCall call, $43.DeleteOrganisationInDBRequest request);
}
View Git Blame Copy Permalink