You've already forked dart-core-sdk
Latest generation
This commit is contained in:
ci core model
@@ -1,3 +1,3 @@
|
||||
# CHANGELOG
|
||||
|
||||
Lib version: 1.10.0-SNAPSHOT-250319084500
|
||||
Lib version: 1.10.0-SNAPSHOT-250320100517
|
||||
|
||||
292
lib/org.pb.dart
292
lib/org.pb.dart
@@ -1798,298 +1798,6 @@ class StopStreamingMetricsJobResult extends $pb.GeneratedMessage {
|
||||
static StopStreamingMetricsJobResult? _defaultInstance;
|
||||
}
|
||||
|
||||
class StartStreamingWatchdogJobRequest extends $pb.GeneratedMessage {
|
||||
factory StartStreamingWatchdogJobRequest({
|
||||
$core.String? orgID,
|
||||
}) {
|
||||
final $result = create();
|
||||
if (orgID != null) {
|
||||
$result.orgID = orgID;
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
StartStreamingWatchdogJobRequest._() : super();
|
||||
factory StartStreamingWatchdogJobRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StartStreamingWatchdogJobRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StartStreamingWatchdogJobRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..aOS(1, _omitFieldNames ? '' : 'OrgID', protoName: 'OrgID')
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartStreamingWatchdogJobRequest clone() => StartStreamingWatchdogJobRequest()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartStreamingWatchdogJobRequest copyWith(void Function(StartStreamingWatchdogJobRequest) updates) => super.copyWith((message) => updates(message as StartStreamingWatchdogJobRequest)) as StartStreamingWatchdogJobRequest;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartStreamingWatchdogJobRequest create() => StartStreamingWatchdogJobRequest._();
|
||||
StartStreamingWatchdogJobRequest createEmptyInstance() => create();
|
||||
static $pb.PbList<StartStreamingWatchdogJobRequest> createRepeated() => $pb.PbList<StartStreamingWatchdogJobRequest>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartStreamingWatchdogJobRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StartStreamingWatchdogJobRequest>(create);
|
||||
static StartStreamingWatchdogJobRequest? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
$core.String get orgID => $_getSZ(0);
|
||||
@$pb.TagNumber(1)
|
||||
set orgID($core.String v) { $_setString(0, v); }
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasOrgID() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearOrgID() => clearField(1);
|
||||
}
|
||||
|
||||
class StartStreamingWatchdogJobResult extends $pb.GeneratedMessage {
|
||||
factory StartStreamingWatchdogJobResult() => create();
|
||||
StartStreamingWatchdogJobResult._() : super();
|
||||
factory StartStreamingWatchdogJobResult.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StartStreamingWatchdogJobResult.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StartStreamingWatchdogJobResult', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartStreamingWatchdogJobResult clone() => StartStreamingWatchdogJobResult()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartStreamingWatchdogJobResult copyWith(void Function(StartStreamingWatchdogJobResult) updates) => super.copyWith((message) => updates(message as StartStreamingWatchdogJobResult)) as StartStreamingWatchdogJobResult;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartStreamingWatchdogJobResult create() => StartStreamingWatchdogJobResult._();
|
||||
StartStreamingWatchdogJobResult createEmptyInstance() => create();
|
||||
static $pb.PbList<StartStreamingWatchdogJobResult> createRepeated() => $pb.PbList<StartStreamingWatchdogJobResult>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartStreamingWatchdogJobResult getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StartStreamingWatchdogJobResult>(create);
|
||||
static StartStreamingWatchdogJobResult? _defaultInstance;
|
||||
}
|
||||
|
||||
class StopStreamingWatchdogJobRequest extends $pb.GeneratedMessage {
|
||||
factory StopStreamingWatchdogJobRequest({
|
||||
$core.String? orgID,
|
||||
}) {
|
||||
final $result = create();
|
||||
if (orgID != null) {
|
||||
$result.orgID = orgID;
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
StopStreamingWatchdogJobRequest._() : super();
|
||||
factory StopStreamingWatchdogJobRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StopStreamingWatchdogJobRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StopStreamingWatchdogJobRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..aOS(1, _omitFieldNames ? '' : 'OrgID', protoName: 'OrgID')
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StopStreamingWatchdogJobRequest clone() => StopStreamingWatchdogJobRequest()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StopStreamingWatchdogJobRequest copyWith(void Function(StopStreamingWatchdogJobRequest) updates) => super.copyWith((message) => updates(message as StopStreamingWatchdogJobRequest)) as StopStreamingWatchdogJobRequest;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StopStreamingWatchdogJobRequest create() => StopStreamingWatchdogJobRequest._();
|
||||
StopStreamingWatchdogJobRequest createEmptyInstance() => create();
|
||||
static $pb.PbList<StopStreamingWatchdogJobRequest> createRepeated() => $pb.PbList<StopStreamingWatchdogJobRequest>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StopStreamingWatchdogJobRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StopStreamingWatchdogJobRequest>(create);
|
||||
static StopStreamingWatchdogJobRequest? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
$core.String get orgID => $_getSZ(0);
|
||||
@$pb.TagNumber(1)
|
||||
set orgID($core.String v) { $_setString(0, v); }
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasOrgID() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearOrgID() => clearField(1);
|
||||
}
|
||||
|
||||
class StopStreamingWatchdogJobResult extends $pb.GeneratedMessage {
|
||||
factory StopStreamingWatchdogJobResult() => create();
|
||||
StopStreamingWatchdogJobResult._() : super();
|
||||
factory StopStreamingWatchdogJobResult.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StopStreamingWatchdogJobResult.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StopStreamingWatchdogJobResult', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StopStreamingWatchdogJobResult clone() => StopStreamingWatchdogJobResult()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StopStreamingWatchdogJobResult copyWith(void Function(StopStreamingWatchdogJobResult) updates) => super.copyWith((message) => updates(message as StopStreamingWatchdogJobResult)) as StopStreamingWatchdogJobResult;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StopStreamingWatchdogJobResult create() => StopStreamingWatchdogJobResult._();
|
||||
StopStreamingWatchdogJobResult createEmptyInstance() => create();
|
||||
static $pb.PbList<StopStreamingWatchdogJobResult> createRepeated() => $pb.PbList<StopStreamingWatchdogJobResult>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StopStreamingWatchdogJobResult getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StopStreamingWatchdogJobResult>(create);
|
||||
static StopStreamingWatchdogJobResult? _defaultInstance;
|
||||
}
|
||||
|
||||
class StartAllStreamingWatchdogJobsRequest extends $pb.GeneratedMessage {
|
||||
factory StartAllStreamingWatchdogJobsRequest() => create();
|
||||
StartAllStreamingWatchdogJobsRequest._() : super();
|
||||
factory StartAllStreamingWatchdogJobsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StartAllStreamingWatchdogJobsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StartAllStreamingWatchdogJobsRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartAllStreamingWatchdogJobsRequest clone() => StartAllStreamingWatchdogJobsRequest()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartAllStreamingWatchdogJobsRequest copyWith(void Function(StartAllStreamingWatchdogJobsRequest) updates) => super.copyWith((message) => updates(message as StartAllStreamingWatchdogJobsRequest)) as StartAllStreamingWatchdogJobsRequest;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartAllStreamingWatchdogJobsRequest create() => StartAllStreamingWatchdogJobsRequest._();
|
||||
StartAllStreamingWatchdogJobsRequest createEmptyInstance() => create();
|
||||
static $pb.PbList<StartAllStreamingWatchdogJobsRequest> createRepeated() => $pb.PbList<StartAllStreamingWatchdogJobsRequest>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartAllStreamingWatchdogJobsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StartAllStreamingWatchdogJobsRequest>(create);
|
||||
static StartAllStreamingWatchdogJobsRequest? _defaultInstance;
|
||||
}
|
||||
|
||||
class StartAllStreamingWatchdogJobsResult extends $pb.GeneratedMessage {
|
||||
factory StartAllStreamingWatchdogJobsResult() => create();
|
||||
StartAllStreamingWatchdogJobsResult._() : super();
|
||||
factory StartAllStreamingWatchdogJobsResult.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StartAllStreamingWatchdogJobsResult.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StartAllStreamingWatchdogJobsResult', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartAllStreamingWatchdogJobsResult clone() => StartAllStreamingWatchdogJobsResult()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartAllStreamingWatchdogJobsResult copyWith(void Function(StartAllStreamingWatchdogJobsResult) updates) => super.copyWith((message) => updates(message as StartAllStreamingWatchdogJobsResult)) as StartAllStreamingWatchdogJobsResult;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartAllStreamingWatchdogJobsResult create() => StartAllStreamingWatchdogJobsResult._();
|
||||
StartAllStreamingWatchdogJobsResult createEmptyInstance() => create();
|
||||
static $pb.PbList<StartAllStreamingWatchdogJobsResult> createRepeated() => $pb.PbList<StartAllStreamingWatchdogJobsResult>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartAllStreamingWatchdogJobsResult getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StartAllStreamingWatchdogJobsResult>(create);
|
||||
static StartAllStreamingWatchdogJobsResult? _defaultInstance;
|
||||
}
|
||||
|
||||
class StopAllStreamingWatchdogJobsRequest extends $pb.GeneratedMessage {
|
||||
factory StopAllStreamingWatchdogJobsRequest() => create();
|
||||
StopAllStreamingWatchdogJobsRequest._() : super();
|
||||
factory StopAllStreamingWatchdogJobsRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StopAllStreamingWatchdogJobsRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StopAllStreamingWatchdogJobsRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StopAllStreamingWatchdogJobsRequest clone() => StopAllStreamingWatchdogJobsRequest()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StopAllStreamingWatchdogJobsRequest copyWith(void Function(StopAllStreamingWatchdogJobsRequest) updates) => super.copyWith((message) => updates(message as StopAllStreamingWatchdogJobsRequest)) as StopAllStreamingWatchdogJobsRequest;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StopAllStreamingWatchdogJobsRequest create() => StopAllStreamingWatchdogJobsRequest._();
|
||||
StopAllStreamingWatchdogJobsRequest createEmptyInstance() => create();
|
||||
static $pb.PbList<StopAllStreamingWatchdogJobsRequest> createRepeated() => $pb.PbList<StopAllStreamingWatchdogJobsRequest>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StopAllStreamingWatchdogJobsRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StopAllStreamingWatchdogJobsRequest>(create);
|
||||
static StopAllStreamingWatchdogJobsRequest? _defaultInstance;
|
||||
}
|
||||
|
||||
class StopAllStreamingWatchdogJobsResult extends $pb.GeneratedMessage {
|
||||
factory StopAllStreamingWatchdogJobsResult() => create();
|
||||
StopAllStreamingWatchdogJobsResult._() : super();
|
||||
factory StopAllStreamingWatchdogJobsResult.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StopAllStreamingWatchdogJobsResult.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StopAllStreamingWatchdogJobsResult', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StopAllStreamingWatchdogJobsResult clone() => StopAllStreamingWatchdogJobsResult()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StopAllStreamingWatchdogJobsResult copyWith(void Function(StopAllStreamingWatchdogJobsResult) updates) => super.copyWith((message) => updates(message as StopAllStreamingWatchdogJobsResult)) as StopAllStreamingWatchdogJobsResult;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StopAllStreamingWatchdogJobsResult create() => StopAllStreamingWatchdogJobsResult._();
|
||||
StopAllStreamingWatchdogJobsResult createEmptyInstance() => create();
|
||||
static $pb.PbList<StopAllStreamingWatchdogJobsResult> createRepeated() => $pb.PbList<StopAllStreamingWatchdogJobsResult>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StopAllStreamingWatchdogJobsResult getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StopAllStreamingWatchdogJobsResult>(create);
|
||||
static StopAllStreamingWatchdogJobsResult? _defaultInstance;
|
||||
}
|
||||
|
||||
class CheckStreamingStatusRequest extends $pb.GeneratedMessage {
|
||||
factory CheckStreamingStatusRequest({
|
||||
$core.String? orgID,
|
||||
|
||||
@@ -85,22 +85,6 @@ class OrganisationServiceClient extends $grpc.Client {
|
||||
'/api.OrganisationService/StopStreamingMetricsJob',
|
||||
($11.StopStreamingMetricsJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $11.StopStreamingMetricsJobResult.fromBuffer(value));
|
||||
static final _$startStreamingWatchdogJob = $grpc.ClientMethod<$11.StartStreamingWatchdogJobRequest, $11.StartStreamingWatchdogJobResult>(
|
||||
'/api.OrganisationService/StartStreamingWatchdogJob',
|
||||
($11.StartStreamingWatchdogJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $11.StartStreamingWatchdogJobResult.fromBuffer(value));
|
||||
static final _$stopStreamingWatchdogJob = $grpc.ClientMethod<$11.StopStreamingWatchdogJobRequest, $11.StopStreamingWatchdogJobResult>(
|
||||
'/api.OrganisationService/StopStreamingWatchdogJob',
|
||||
($11.StopStreamingWatchdogJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $11.StopStreamingWatchdogJobResult.fromBuffer(value));
|
||||
static final _$startAllStreamingWatchdogJobs = $grpc.ClientMethod<$11.StartAllStreamingWatchdogJobsRequest, $11.StartAllStreamingWatchdogJobsResult>(
|
||||
'/api.OrganisationService/StartAllStreamingWatchdogJobs',
|
||||
($11.StartAllStreamingWatchdogJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $11.StartAllStreamingWatchdogJobsResult.fromBuffer(value));
|
||||
static final _$stopAllStreamingWatchdogJobs = $grpc.ClientMethod<$11.StopAllStreamingWatchdogJobsRequest, $11.StopAllStreamingWatchdogJobsResult>(
|
||||
'/api.OrganisationService/StopAllStreamingWatchdogJobs',
|
||||
($11.StopAllStreamingWatchdogJobsRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $11.StopAllStreamingWatchdogJobsResult.fromBuffer(value));
|
||||
static final _$startIndividualStreamingJob = $grpc.ClientMethod<$11.StartIndividualStreamingJobRequest, $11.StartIndividualStreamingJobResult>(
|
||||
'/api.OrganisationService/StartIndividualStreamingJob',
|
||||
($11.StartIndividualStreamingJobRequest value) => value.writeToBuffer(),
|
||||
@@ -212,22 +196,6 @@ class OrganisationServiceClient extends $grpc.Client {
|
||||
return $createUnaryCall(_$stopStreamingMetricsJob, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$11.StartStreamingWatchdogJobResult> startStreamingWatchdogJob($11.StartStreamingWatchdogJobRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$startStreamingWatchdogJob, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$11.StopStreamingWatchdogJobResult> stopStreamingWatchdogJob($11.StopStreamingWatchdogJobRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$stopStreamingWatchdogJob, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$11.StartAllStreamingWatchdogJobsResult> startAllStreamingWatchdogJobs($11.StartAllStreamingWatchdogJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$startAllStreamingWatchdogJobs, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$11.StopAllStreamingWatchdogJobsResult> stopAllStreamingWatchdogJobs($11.StopAllStreamingWatchdogJobsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$stopAllStreamingWatchdogJobs, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$11.StartIndividualStreamingJobResult> startIndividualStreamingJob($11.StartIndividualStreamingJobRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$startIndividualStreamingJob, request, options: options);
|
||||
}
|
||||
@@ -386,34 +354,6 @@ abstract class OrganisationServiceBase extends $grpc.Service {
|
||||
false,
|
||||
($core.List<$core.int> value) => $11.StopStreamingMetricsJobRequest.fromBuffer(value),
|
||||
($11.StopStreamingMetricsJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$11.StartStreamingWatchdogJobRequest, $11.StartStreamingWatchdogJobResult>(
|
||||
'StartStreamingWatchdogJob',
|
||||
startStreamingWatchdogJob_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $11.StartStreamingWatchdogJobRequest.fromBuffer(value),
|
||||
($11.StartStreamingWatchdogJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$11.StopStreamingWatchdogJobRequest, $11.StopStreamingWatchdogJobResult>(
|
||||
'StopStreamingWatchdogJob',
|
||||
stopStreamingWatchdogJob_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $11.StopStreamingWatchdogJobRequest.fromBuffer(value),
|
||||
($11.StopStreamingWatchdogJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$11.StartAllStreamingWatchdogJobsRequest, $11.StartAllStreamingWatchdogJobsResult>(
|
||||
'StartAllStreamingWatchdogJobs',
|
||||
startAllStreamingWatchdogJobs_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $11.StartAllStreamingWatchdogJobsRequest.fromBuffer(value),
|
||||
($11.StartAllStreamingWatchdogJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$11.StopAllStreamingWatchdogJobsRequest, $11.StopAllStreamingWatchdogJobsResult>(
|
||||
'StopAllStreamingWatchdogJobs',
|
||||
stopAllStreamingWatchdogJobs_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $11.StopAllStreamingWatchdogJobsRequest.fromBuffer(value),
|
||||
($11.StopAllStreamingWatchdogJobsResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$11.StartIndividualStreamingJobRequest, $11.StartIndividualStreamingJobResult>(
|
||||
'StartIndividualStreamingJob',
|
||||
startIndividualStreamingJob_Pre,
|
||||
@@ -550,22 +490,6 @@ abstract class OrganisationServiceBase extends $grpc.Service {
|
||||
return stopStreamingMetricsJob(call, await request);
|
||||
}
|
||||
|
||||
$async.Future<$11.StartStreamingWatchdogJobResult> startStreamingWatchdogJob_Pre($grpc.ServiceCall call, $async.Future<$11.StartStreamingWatchdogJobRequest> request) async {
|
||||
return startStreamingWatchdogJob(call, await request);
|
||||
}
|
||||
|
||||
$async.Future<$11.StopStreamingWatchdogJobResult> stopStreamingWatchdogJob_Pre($grpc.ServiceCall call, $async.Future<$11.StopStreamingWatchdogJobRequest> request) async {
|
||||
return stopStreamingWatchdogJob(call, await request);
|
||||
}
|
||||
|
||||
$async.Future<$11.StartAllStreamingWatchdogJobsResult> startAllStreamingWatchdogJobs_Pre($grpc.ServiceCall call, $async.Future<$11.StartAllStreamingWatchdogJobsRequest> request) async {
|
||||
return startAllStreamingWatchdogJobs(call, await request);
|
||||
}
|
||||
|
||||
$async.Future<$11.StopAllStreamingWatchdogJobsResult> stopAllStreamingWatchdogJobs_Pre($grpc.ServiceCall call, $async.Future<$11.StopAllStreamingWatchdogJobsRequest> request) async {
|
||||
return stopAllStreamingWatchdogJobs(call, await request);
|
||||
}
|
||||
|
||||
$async.Future<$11.StartIndividualStreamingJobResult> startIndividualStreamingJob_Pre($grpc.ServiceCall call, $async.Future<$11.StartIndividualStreamingJobRequest> request) async {
|
||||
return startIndividualStreamingJob(call, await request);
|
||||
}
|
||||
@@ -622,10 +546,6 @@ abstract class OrganisationServiceBase extends $grpc.Service {
|
||||
$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.StartStreamingWatchdogJobResult> startStreamingWatchdogJob($grpc.ServiceCall call, $11.StartStreamingWatchdogJobRequest request);
|
||||
$async.Future<$11.StopStreamingWatchdogJobResult> stopStreamingWatchdogJob($grpc.ServiceCall call, $11.StopStreamingWatchdogJobRequest request);
|
||||
$async.Future<$11.StartAllStreamingWatchdogJobsResult> startAllStreamingWatchdogJobs($grpc.ServiceCall call, $11.StartAllStreamingWatchdogJobsRequest request);
|
||||
$async.Future<$11.StopAllStreamingWatchdogJobsResult> stopAllStreamingWatchdogJobs($grpc.ServiceCall call, $11.StopAllStreamingWatchdogJobsRequest 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);
|
||||
|
||||
@@ -484,86 +484,6 @@ const StopStreamingMetricsJobResult$json = {
|
||||
final $typed_data.Uint8List stopStreamingMetricsJobResultDescriptor = $convert.base64Decode(
|
||||
'Ch1TdG9wU3RyZWFtaW5nTWV0cmljc0pvYlJlc3VsdA==');
|
||||
|
||||
@$core.Deprecated('Use startStreamingWatchdogJobRequestDescriptor instead')
|
||||
const StartStreamingWatchdogJobRequest$json = {
|
||||
'1': 'StartStreamingWatchdogJobRequest',
|
||||
'2': [
|
||||
{'1': 'OrgID', '3': 1, '4': 1, '5': 9, '8': {}, '10': 'OrgID'},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `StartStreamingWatchdogJobRequest`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List startStreamingWatchdogJobRequestDescriptor = $convert.base64Decode(
|
||||
'CiBTdGFydFN0cmVhbWluZ1dhdGNoZG9nSm9iUmVxdWVzdBIdCgVPcmdJRBgBIAEoCUIH+kIEcg'
|
||||
'IQAVIFT3JnSUQ=');
|
||||
|
||||
@$core.Deprecated('Use startStreamingWatchdogJobResultDescriptor instead')
|
||||
const StartStreamingWatchdogJobResult$json = {
|
||||
'1': 'StartStreamingWatchdogJobResult',
|
||||
};
|
||||
|
||||
/// Descriptor for `StartStreamingWatchdogJobResult`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List startStreamingWatchdogJobResultDescriptor = $convert.base64Decode(
|
||||
'Ch9TdGFydFN0cmVhbWluZ1dhdGNoZG9nSm9iUmVzdWx0');
|
||||
|
||||
@$core.Deprecated('Use stopStreamingWatchdogJobRequestDescriptor instead')
|
||||
const StopStreamingWatchdogJobRequest$json = {
|
||||
'1': 'StopStreamingWatchdogJobRequest',
|
||||
'2': [
|
||||
{'1': 'OrgID', '3': 1, '4': 1, '5': 9, '8': {}, '10': 'OrgID'},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `StopStreamingWatchdogJobRequest`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List stopStreamingWatchdogJobRequestDescriptor = $convert.base64Decode(
|
||||
'Ch9TdG9wU3RyZWFtaW5nV2F0Y2hkb2dKb2JSZXF1ZXN0Eh0KBU9yZ0lEGAEgASgJQgf6QgRyAh'
|
||||
'ABUgVPcmdJRA==');
|
||||
|
||||
@$core.Deprecated('Use stopStreamingWatchdogJobResultDescriptor instead')
|
||||
const StopStreamingWatchdogJobResult$json = {
|
||||
'1': 'StopStreamingWatchdogJobResult',
|
||||
};
|
||||
|
||||
/// Descriptor for `StopStreamingWatchdogJobResult`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List stopStreamingWatchdogJobResultDescriptor = $convert.base64Decode(
|
||||
'Ch5TdG9wU3RyZWFtaW5nV2F0Y2hkb2dKb2JSZXN1bHQ=');
|
||||
|
||||
@$core.Deprecated('Use startAllStreamingWatchdogJobsRequestDescriptor instead')
|
||||
const StartAllStreamingWatchdogJobsRequest$json = {
|
||||
'1': 'StartAllStreamingWatchdogJobsRequest',
|
||||
};
|
||||
|
||||
/// Descriptor for `StartAllStreamingWatchdogJobsRequest`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List startAllStreamingWatchdogJobsRequestDescriptor = $convert.base64Decode(
|
||||
'CiRTdGFydEFsbFN0cmVhbWluZ1dhdGNoZG9nSm9ic1JlcXVlc3Q=');
|
||||
|
||||
@$core.Deprecated('Use startAllStreamingWatchdogJobsResultDescriptor instead')
|
||||
const StartAllStreamingWatchdogJobsResult$json = {
|
||||
'1': 'StartAllStreamingWatchdogJobsResult',
|
||||
};
|
||||
|
||||
/// Descriptor for `StartAllStreamingWatchdogJobsResult`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List startAllStreamingWatchdogJobsResultDescriptor = $convert.base64Decode(
|
||||
'CiNTdGFydEFsbFN0cmVhbWluZ1dhdGNoZG9nSm9ic1Jlc3VsdA==');
|
||||
|
||||
@$core.Deprecated('Use stopAllStreamingWatchdogJobsRequestDescriptor instead')
|
||||
const StopAllStreamingWatchdogJobsRequest$json = {
|
||||
'1': 'StopAllStreamingWatchdogJobsRequest',
|
||||
};
|
||||
|
||||
/// Descriptor for `StopAllStreamingWatchdogJobsRequest`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List stopAllStreamingWatchdogJobsRequestDescriptor = $convert.base64Decode(
|
||||
'CiNTdG9wQWxsU3RyZWFtaW5nV2F0Y2hkb2dKb2JzUmVxdWVzdA==');
|
||||
|
||||
@$core.Deprecated('Use stopAllStreamingWatchdogJobsResultDescriptor instead')
|
||||
const StopAllStreamingWatchdogJobsResult$json = {
|
||||
'1': 'StopAllStreamingWatchdogJobsResult',
|
||||
};
|
||||
|
||||
/// Descriptor for `StopAllStreamingWatchdogJobsResult`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List stopAllStreamingWatchdogJobsResultDescriptor = $convert.base64Decode(
|
||||
'CiJTdG9wQWxsU3RyZWFtaW5nV2F0Y2hkb2dKb2JzUmVzdWx0');
|
||||
|
||||
@$core.Deprecated('Use checkStreamingStatusRequestDescriptor instead')
|
||||
const CheckStreamingStatusRequest$json = {
|
||||
'1': 'CheckStreamingStatusRequest',
|
||||
|
||||
157
lib/proj.pb.dart
157
lib/proj.pb.dart
@@ -18,7 +18,6 @@ import 'module.pb.dart' as $7;
|
||||
import 'org.pb.dart' as $11;
|
||||
import 'proj.pbenum.dart';
|
||||
import 'shared.pb.dart' as $29;
|
||||
import 'shared.pbenum.dart' as $29;
|
||||
import 'user.pb.dart' as $3;
|
||||
|
||||
export 'proj.pbenum.dart';
|
||||
@@ -1658,162 +1657,6 @@ class DeleteProjectInDBResult extends $pb.GeneratedMessage {
|
||||
static DeleteProjectInDBResult? _defaultInstance;
|
||||
}
|
||||
|
||||
class StartRecoverDataStreamingJobRequest extends $pb.GeneratedMessage {
|
||||
factory StartRecoverDataStreamingJobRequest({
|
||||
$core.String? projectID,
|
||||
$29.ModelDataSetEnum? entity,
|
||||
$29.RecoverType? recoveryType,
|
||||
$core.int? partitionStart,
|
||||
$core.int? partitionEnd,
|
||||
}) {
|
||||
final $result = create();
|
||||
if (projectID != null) {
|
||||
$result.projectID = projectID;
|
||||
}
|
||||
if (entity != null) {
|
||||
$result.entity = entity;
|
||||
}
|
||||
if (recoveryType != null) {
|
||||
$result.recoveryType = recoveryType;
|
||||
}
|
||||
if (partitionStart != null) {
|
||||
$result.partitionStart = partitionStart;
|
||||
}
|
||||
if (partitionEnd != null) {
|
||||
$result.partitionEnd = partitionEnd;
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
StartRecoverDataStreamingJobRequest._() : super();
|
||||
factory StartRecoverDataStreamingJobRequest.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StartRecoverDataStreamingJobRequest.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StartRecoverDataStreamingJobRequest', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..aOS(1, _omitFieldNames ? '' : 'ProjectID', protoName: 'ProjectID')
|
||||
..e<$29.ModelDataSetEnum>(2, _omitFieldNames ? '' : 'Entity', $pb.PbFieldType.OE, protoName: 'Entity', defaultOrMaker: $29.ModelDataSetEnum.ACTOR, valueOf: $29.ModelDataSetEnum.valueOf, enumValues: $29.ModelDataSetEnum.values)
|
||||
..e<$29.RecoverType>(3, _omitFieldNames ? '' : 'RecoveryType', $pb.PbFieldType.OE, protoName: 'RecoveryType', defaultOrMaker: $29.RecoverType.RECOVER_OPENSEARCH, valueOf: $29.RecoverType.valueOf, enumValues: $29.RecoverType.values)
|
||||
..a<$core.int>(4, _omitFieldNames ? '' : 'PartitionStart', $pb.PbFieldType.O3, protoName: 'PartitionStart')
|
||||
..a<$core.int>(5, _omitFieldNames ? '' : 'PartitionEnd', $pb.PbFieldType.O3, protoName: 'PartitionEnd')
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartRecoverDataStreamingJobRequest clone() => StartRecoverDataStreamingJobRequest()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartRecoverDataStreamingJobRequest copyWith(void Function(StartRecoverDataStreamingJobRequest) updates) => super.copyWith((message) => updates(message as StartRecoverDataStreamingJobRequest)) as StartRecoverDataStreamingJobRequest;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartRecoverDataStreamingJobRequest create() => StartRecoverDataStreamingJobRequest._();
|
||||
StartRecoverDataStreamingJobRequest createEmptyInstance() => create();
|
||||
static $pb.PbList<StartRecoverDataStreamingJobRequest> createRepeated() => $pb.PbList<StartRecoverDataStreamingJobRequest>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartRecoverDataStreamingJobRequest getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StartRecoverDataStreamingJobRequest>(create);
|
||||
static StartRecoverDataStreamingJobRequest? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
$core.String get projectID => $_getSZ(0);
|
||||
@$pb.TagNumber(1)
|
||||
set projectID($core.String v) { $_setString(0, v); }
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasProjectID() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearProjectID() => clearField(1);
|
||||
|
||||
@$pb.TagNumber(2)
|
||||
$29.ModelDataSetEnum get entity => $_getN(1);
|
||||
@$pb.TagNumber(2)
|
||||
set entity($29.ModelDataSetEnum v) { setField(2, v); }
|
||||
@$pb.TagNumber(2)
|
||||
$core.bool hasEntity() => $_has(1);
|
||||
@$pb.TagNumber(2)
|
||||
void clearEntity() => clearField(2);
|
||||
|
||||
@$pb.TagNumber(3)
|
||||
$29.RecoverType get recoveryType => $_getN(2);
|
||||
@$pb.TagNumber(3)
|
||||
set recoveryType($29.RecoverType v) { setField(3, v); }
|
||||
@$pb.TagNumber(3)
|
||||
$core.bool hasRecoveryType() => $_has(2);
|
||||
@$pb.TagNumber(3)
|
||||
void clearRecoveryType() => clearField(3);
|
||||
|
||||
@$pb.TagNumber(4)
|
||||
$core.int get partitionStart => $_getIZ(3);
|
||||
@$pb.TagNumber(4)
|
||||
set partitionStart($core.int v) { $_setSignedInt32(3, v); }
|
||||
@$pb.TagNumber(4)
|
||||
$core.bool hasPartitionStart() => $_has(3);
|
||||
@$pb.TagNumber(4)
|
||||
void clearPartitionStart() => clearField(4);
|
||||
|
||||
@$pb.TagNumber(5)
|
||||
$core.int get partitionEnd => $_getIZ(4);
|
||||
@$pb.TagNumber(5)
|
||||
set partitionEnd($core.int v) { $_setSignedInt32(4, v); }
|
||||
@$pb.TagNumber(5)
|
||||
$core.bool hasPartitionEnd() => $_has(4);
|
||||
@$pb.TagNumber(5)
|
||||
void clearPartitionEnd() => clearField(5);
|
||||
}
|
||||
|
||||
class StartRecoverDataStreamingJobResult extends $pb.GeneratedMessage {
|
||||
factory StartRecoverDataStreamingJobResult({
|
||||
$core.String? iD,
|
||||
}) {
|
||||
final $result = create();
|
||||
if (iD != null) {
|
||||
$result.iD = iD;
|
||||
}
|
||||
return $result;
|
||||
}
|
||||
StartRecoverDataStreamingJobResult._() : super();
|
||||
factory StartRecoverDataStreamingJobResult.fromBuffer($core.List<$core.int> i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromBuffer(i, r);
|
||||
factory StartRecoverDataStreamingJobResult.fromJson($core.String i, [$pb.ExtensionRegistry r = $pb.ExtensionRegistry.EMPTY]) => create()..mergeFromJson(i, r);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(_omitMessageNames ? '' : 'StartRecoverDataStreamingJobResult', package: const $pb.PackageName(_omitMessageNames ? '' : 'api'), createEmptyInstance: create)
|
||||
..aOS(1, _omitFieldNames ? '' : 'ID', protoName: 'ID')
|
||||
..hasRequiredFields = false
|
||||
;
|
||||
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.deepCopy] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartRecoverDataStreamingJobResult clone() => StartRecoverDataStreamingJobResult()..mergeFromMessage(this);
|
||||
@$core.Deprecated(
|
||||
'Using this can add significant overhead to your binary. '
|
||||
'Use [GeneratedMessageGenericExtensions.rebuild] instead. '
|
||||
'Will be removed in next major version')
|
||||
StartRecoverDataStreamingJobResult copyWith(void Function(StartRecoverDataStreamingJobResult) updates) => super.copyWith((message) => updates(message as StartRecoverDataStreamingJobResult)) as StartRecoverDataStreamingJobResult;
|
||||
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartRecoverDataStreamingJobResult create() => StartRecoverDataStreamingJobResult._();
|
||||
StartRecoverDataStreamingJobResult createEmptyInstance() => create();
|
||||
static $pb.PbList<StartRecoverDataStreamingJobResult> createRepeated() => $pb.PbList<StartRecoverDataStreamingJobResult>();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StartRecoverDataStreamingJobResult getDefault() => _defaultInstance ??= $pb.GeneratedMessage.$_defaultFor<StartRecoverDataStreamingJobResult>(create);
|
||||
static StartRecoverDataStreamingJobResult? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
$core.String get iD => $_getSZ(0);
|
||||
@$pb.TagNumber(1)
|
||||
set iD($core.String v) { $_setString(0, v); }
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasID() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearID() => clearField(1);
|
||||
}
|
||||
|
||||
class IDName extends $pb.GeneratedMessage {
|
||||
factory IDName({
|
||||
$core.String? iD,
|
||||
|
||||
@@ -85,10 +85,6 @@ class ProjectServiceClient extends $grpc.Client {
|
||||
'/api.ProjectService/OptimizeClickhouse',
|
||||
($12.OptimizeClickhouseRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $12.OptimizeClickhouseResult.fromBuffer(value));
|
||||
static final _$startRecoverDataStreamingJob = $grpc.ClientMethod<$12.StartRecoverDataStreamingJobRequest, $12.StartRecoverDataStreamingJobResult>(
|
||||
'/api.ProjectService/StartRecoverDataStreamingJob',
|
||||
($12.StartRecoverDataStreamingJobRequest value) => value.writeToBuffer(),
|
||||
($core.List<$core.int> value) => $12.StartRecoverDataStreamingJobResult.fromBuffer(value));
|
||||
static final _$cleanDeletedProjects = $grpc.ClientMethod<$12.CleanDeletedProjectsRequest, $12.CleanDeletedProjectsResult>(
|
||||
'/api.ProjectService/CleanDeletedProjects',
|
||||
($12.CleanDeletedProjectsRequest value) => value.writeToBuffer(),
|
||||
@@ -164,10 +160,6 @@ class ProjectServiceClient extends $grpc.Client {
|
||||
return $createUnaryCall(_$optimizeClickhouse, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$12.StartRecoverDataStreamingJobResult> startRecoverDataStreamingJob($12.StartRecoverDataStreamingJobRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$startRecoverDataStreamingJob, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$12.CleanDeletedProjectsResult> cleanDeletedProjects($12.CleanDeletedProjectsRequest request, {$grpc.CallOptions? options}) {
|
||||
return $createUnaryCall(_$cleanDeletedProjects, request, options: options);
|
||||
}
|
||||
@@ -290,13 +282,6 @@ abstract class ProjectServiceBase extends $grpc.Service {
|
||||
false,
|
||||
($core.List<$core.int> value) => $12.OptimizeClickhouseRequest.fromBuffer(value),
|
||||
($12.OptimizeClickhouseResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$12.StartRecoverDataStreamingJobRequest, $12.StartRecoverDataStreamingJobResult>(
|
||||
'StartRecoverDataStreamingJob',
|
||||
startRecoverDataStreamingJob_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $12.StartRecoverDataStreamingJobRequest.fromBuffer(value),
|
||||
($12.StartRecoverDataStreamingJobResult value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$12.CleanDeletedProjectsRequest, $12.CleanDeletedProjectsResult>(
|
||||
'CleanDeletedProjects',
|
||||
cleanDeletedProjects_Pre,
|
||||
@@ -370,10 +355,6 @@ abstract class ProjectServiceBase extends $grpc.Service {
|
||||
return optimizeClickhouse(call, await request);
|
||||
}
|
||||
|
||||
$async.Future<$12.StartRecoverDataStreamingJobResult> startRecoverDataStreamingJob_Pre($grpc.ServiceCall call, $async.Future<$12.StartRecoverDataStreamingJobRequest> request) async {
|
||||
return startRecoverDataStreamingJob(call, await request);
|
||||
}
|
||||
|
||||
$async.Future<$12.CleanDeletedProjectsResult> cleanDeletedProjects_Pre($grpc.ServiceCall call, $async.Future<$12.CleanDeletedProjectsRequest> request) async {
|
||||
return cleanDeletedProjects(call, await request);
|
||||
}
|
||||
@@ -394,6 +375,5 @@ abstract class ProjectServiceBase extends $grpc.Service {
|
||||
$async.Future<$12.DeleteProjectInDBResult> deleteProjectInDB($grpc.ServiceCall call, $12.DeleteProjectInDBRequest request);
|
||||
$async.Future<$12.DeleteCassandraResult> deleteCassandra($grpc.ServiceCall call, $12.DeleteCassandraRequest request);
|
||||
$async.Future<$12.OptimizeClickhouseResult> optimizeClickhouse($grpc.ServiceCall call, $12.OptimizeClickhouseRequest request);
|
||||
$async.Future<$12.StartRecoverDataStreamingJobResult> startRecoverDataStreamingJob($grpc.ServiceCall call, $12.StartRecoverDataStreamingJobRequest request);
|
||||
$async.Future<$12.CleanDeletedProjectsResult> cleanDeletedProjects($grpc.ServiceCall call, $12.CleanDeletedProjectsRequest request);
|
||||
}
|
||||
|
||||
@@ -442,40 +442,6 @@ const DeleteProjectInDBResult$json = {
|
||||
final $typed_data.Uint8List deleteProjectInDBResultDescriptor = $convert.base64Decode(
|
||||
'ChdEZWxldGVQcm9qZWN0SW5EQlJlc3VsdA==');
|
||||
|
||||
@$core.Deprecated('Use startRecoverDataStreamingJobRequestDescriptor instead')
|
||||
const StartRecoverDataStreamingJobRequest$json = {
|
||||
'1': 'StartRecoverDataStreamingJobRequest',
|
||||
'2': [
|
||||
{'1': 'ProjectID', '3': 1, '4': 1, '5': 9, '8': {}, '10': 'ProjectID'},
|
||||
{'1': 'Entity', '3': 2, '4': 1, '5': 14, '6': '.api.ModelDataSetEnum', '10': 'Entity'},
|
||||
{'1': 'RecoveryType', '3': 3, '4': 1, '5': 14, '6': '.api.RecoverType', '10': 'RecoveryType'},
|
||||
{'1': 'PartitionStart', '3': 4, '4': 1, '5': 5, '10': 'PartitionStart'},
|
||||
{'1': 'PartitionEnd', '3': 5, '4': 1, '5': 5, '10': 'PartitionEnd'},
|
||||
],
|
||||
'7': {},
|
||||
};
|
||||
|
||||
/// Descriptor for `StartRecoverDataStreamingJobRequest`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List startRecoverDataStreamingJobRequestDescriptor = $convert.base64Decode(
|
||||
'CiNTdGFydFJlY292ZXJEYXRhU3RyZWFtaW5nSm9iUmVxdWVzdBIlCglQcm9qZWN0SUQYASABKA'
|
||||
'lCB/pCBHICEAFSCVByb2plY3RJRBItCgZFbnRpdHkYAiABKA4yFS5hcGkuTW9kZWxEYXRhU2V0'
|
||||
'RW51bVIGRW50aXR5EjQKDFJlY292ZXJ5VHlwZRgDIAEoDjIQLmFwaS5SZWNvdmVyVHlwZVIMUm'
|
||||
'Vjb3ZlcnlUeXBlEiYKDlBhcnRpdGlvblN0YXJ0GAQgASgFUg5QYXJ0aXRpb25TdGFydBIiCgxQ'
|
||||
'YXJ0aXRpb25FbmQYBSABKAVSDFBhcnRpdGlvbkVuZDoakkEXChXSAQlQcm9qZWN0SUTSAQZFbn'
|
||||
'RpdHk=');
|
||||
|
||||
@$core.Deprecated('Use startRecoverDataStreamingJobResultDescriptor instead')
|
||||
const StartRecoverDataStreamingJobResult$json = {
|
||||
'1': 'StartRecoverDataStreamingJobResult',
|
||||
'2': [
|
||||
{'1': 'ID', '3': 1, '4': 1, '5': 9, '10': 'ID'},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `StartRecoverDataStreamingJobResult`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List startRecoverDataStreamingJobResultDescriptor = $convert.base64Decode(
|
||||
'CiJTdGFydFJlY292ZXJEYXRhU3RyZWFtaW5nSm9iUmVzdWx0Eg4KAklEGAEgASgJUgJJRA==');
|
||||
|
||||
@$core.Deprecated('Use iDNameDescriptor instead')
|
||||
const IDName$json = {
|
||||
'1': 'IDName',
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
name: dart_core_sdk
|
||||
description: dart libs from core model proto files
|
||||
version: 1.10.0-SNAPSHOT-250319084500
|
||||
version: 1.10.0-SNAPSHOT-250320100517
|
||||
homepage: ''
|
||||
publish_to: ''
|
||||
repository: ''
|
||||
|
||||
Reference in New Issue
Block a user