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