Compare commits
No commits in common. "c46dc58ac381db5f300b30dc5d743268ede306e0" and "9fea05df763d10ff973c015b50d4e79871802147" have entirely different histories.
c46dc58ac3
...
9fea05df76
5 changed files with 6 additions and 1056 deletions
|
|
@ -82,12 +82,10 @@ class SubmitRequest extends $pb.GeneratedMessage {
|
|||
factory SubmitRequest({
|
||||
$core.List<$core.int>? flowYaml,
|
||||
$core.Iterable<$core.MapEntry<$core.String, $2.Payload>>? inputs,
|
||||
$core.bool? detach,
|
||||
}) {
|
||||
final result = create();
|
||||
if (flowYaml != null) result.flowYaml = flowYaml;
|
||||
if (inputs != null) result.inputs.addEntries(inputs);
|
||||
if (detach != null) result.detach = detach;
|
||||
return result;
|
||||
}
|
||||
|
||||
|
|
@ -113,7 +111,6 @@ class SubmitRequest extends $pb.GeneratedMessage {
|
|||
valueCreator: $2.Payload.create,
|
||||
valueDefaultOrMaker: $2.Payload.getDefault,
|
||||
packageName: const $pb.PackageName('chain.v1'))
|
||||
..aOB(3, _omitFieldNames ? '' : 'detach')
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
|
|
@ -148,20 +145,6 @@ class SubmitRequest extends $pb.GeneratedMessage {
|
|||
/// Named input values for the flow.
|
||||
@$pb.TagNumber(2)
|
||||
$pb.PbMap<$core.String, $2.Payload> get inputs => $_getMap(1);
|
||||
|
||||
/// When true (added 1.1), Submit returns immediately with the
|
||||
/// invocation id and the flow keeps running in the background. Poll
|
||||
/// GetInvocationStatus / fetch GetInvocationResult, or follow it live
|
||||
/// via SubmitStream. Only detached invocations are retained; unary
|
||||
/// detach=false is unchanged (synchronous, stateless).
|
||||
@$pb.TagNumber(3)
|
||||
$core.bool get detach => $_getBF(2);
|
||||
@$pb.TagNumber(3)
|
||||
set detach($core.bool value) => $_setBool(2, value);
|
||||
@$pb.TagNumber(3)
|
||||
$core.bool hasDetach() => $_has(2);
|
||||
@$pb.TagNumber(3)
|
||||
void clearDetach() => $_clearField(3);
|
||||
}
|
||||
|
||||
class SubmitResponse extends $pb.GeneratedMessage {
|
||||
|
|
@ -234,608 +217,6 @@ class SubmitResponse extends $pb.GeneratedMessage {
|
|||
$pb.PbMap<$core.String, $2.Payload> get outputs => $_getMap(1);
|
||||
}
|
||||
|
||||
enum SubmitStreamEvent_Event {
|
||||
stepStarted,
|
||||
stepFinished,
|
||||
moduleEvent,
|
||||
finalResult,
|
||||
error,
|
||||
notSet
|
||||
}
|
||||
|
||||
/// One event in a SubmitStream (added 1.1). Exactly one field is set.
|
||||
class SubmitStreamEvent extends $pb.GeneratedMessage {
|
||||
factory SubmitStreamEvent({
|
||||
StepStarted? stepStarted,
|
||||
StepFinished? stepFinished,
|
||||
ModuleEvent? moduleEvent,
|
||||
SubmitResponse? finalResult,
|
||||
StreamError? error,
|
||||
}) {
|
||||
final result = create();
|
||||
if (stepStarted != null) result.stepStarted = stepStarted;
|
||||
if (stepFinished != null) result.stepFinished = stepFinished;
|
||||
if (moduleEvent != null) result.moduleEvent = moduleEvent;
|
||||
if (finalResult != null) result.finalResult = finalResult;
|
||||
if (error != null) result.error = error;
|
||||
return result;
|
||||
}
|
||||
|
||||
SubmitStreamEvent._();
|
||||
|
||||
factory SubmitStreamEvent.fromBuffer($core.List<$core.int> data,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromBuffer(data, registry);
|
||||
factory SubmitStreamEvent.fromJson($core.String json,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromJson(json, registry);
|
||||
|
||||
static const $core.Map<$core.int, SubmitStreamEvent_Event>
|
||||
_SubmitStreamEvent_EventByTag = {
|
||||
1: SubmitStreamEvent_Event.stepStarted,
|
||||
2: SubmitStreamEvent_Event.stepFinished,
|
||||
3: SubmitStreamEvent_Event.moduleEvent,
|
||||
4: SubmitStreamEvent_Event.finalResult,
|
||||
5: SubmitStreamEvent_Event.error,
|
||||
0: SubmitStreamEvent_Event.notSet
|
||||
};
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
||||
_omitMessageNames ? '' : 'SubmitStreamEvent',
|
||||
package: const $pb.PackageName(_omitMessageNames ? '' : 'chain.v1'),
|
||||
createEmptyInstance: create)
|
||||
..oo(0, [1, 2, 3, 4, 5])
|
||||
..aOM<StepStarted>(1, _omitFieldNames ? '' : 'stepStarted',
|
||||
subBuilder: StepStarted.create)
|
||||
..aOM<StepFinished>(2, _omitFieldNames ? '' : 'stepFinished',
|
||||
subBuilder: StepFinished.create)
|
||||
..aOM<ModuleEvent>(3, _omitFieldNames ? '' : 'moduleEvent',
|
||||
subBuilder: ModuleEvent.create)
|
||||
..aOM<SubmitResponse>(4, _omitFieldNames ? '' : 'finalResult',
|
||||
subBuilder: SubmitResponse.create)
|
||||
..aOM<StreamError>(5, _omitFieldNames ? '' : 'error',
|
||||
subBuilder: StreamError.create)
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
SubmitStreamEvent clone() => deepCopy();
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
SubmitStreamEvent copyWith(void Function(SubmitStreamEvent) updates) =>
|
||||
super.copyWith((message) => updates(message as SubmitStreamEvent))
|
||||
as SubmitStreamEvent;
|
||||
|
||||
@$core.override
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static SubmitStreamEvent create() => SubmitStreamEvent._();
|
||||
@$core.override
|
||||
SubmitStreamEvent createEmptyInstance() => create();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static SubmitStreamEvent getDefault() => _defaultInstance ??=
|
||||
$pb.GeneratedMessage.$_defaultFor<SubmitStreamEvent>(create);
|
||||
static SubmitStreamEvent? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
@$pb.TagNumber(2)
|
||||
@$pb.TagNumber(3)
|
||||
@$pb.TagNumber(4)
|
||||
@$pb.TagNumber(5)
|
||||
SubmitStreamEvent_Event whichEvent() =>
|
||||
_SubmitStreamEvent_EventByTag[$_whichOneof(0)]!;
|
||||
@$pb.TagNumber(1)
|
||||
@$pb.TagNumber(2)
|
||||
@$pb.TagNumber(3)
|
||||
@$pb.TagNumber(4)
|
||||
@$pb.TagNumber(5)
|
||||
void clearEvent() => $_clearField($_whichOneof(0));
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
StepStarted get stepStarted => $_getN(0);
|
||||
@$pb.TagNumber(1)
|
||||
set stepStarted(StepStarted value) => $_setField(1, value);
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasStepStarted() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearStepStarted() => $_clearField(1);
|
||||
@$pb.TagNumber(1)
|
||||
StepStarted ensureStepStarted() => $_ensure(0);
|
||||
|
||||
@$pb.TagNumber(2)
|
||||
StepFinished get stepFinished => $_getN(1);
|
||||
@$pb.TagNumber(2)
|
||||
set stepFinished(StepFinished value) => $_setField(2, value);
|
||||
@$pb.TagNumber(2)
|
||||
$core.bool hasStepFinished() => $_has(1);
|
||||
@$pb.TagNumber(2)
|
||||
void clearStepFinished() => $_clearField(2);
|
||||
@$pb.TagNumber(2)
|
||||
StepFinished ensureStepFinished() => $_ensure(1);
|
||||
|
||||
@$pb.TagNumber(3)
|
||||
ModuleEvent get moduleEvent => $_getN(2);
|
||||
@$pb.TagNumber(3)
|
||||
set moduleEvent(ModuleEvent value) => $_setField(3, value);
|
||||
@$pb.TagNumber(3)
|
||||
$core.bool hasModuleEvent() => $_has(2);
|
||||
@$pb.TagNumber(3)
|
||||
void clearModuleEvent() => $_clearField(3);
|
||||
@$pb.TagNumber(3)
|
||||
ModuleEvent ensureModuleEvent() => $_ensure(2);
|
||||
|
||||
/// Terminal success — identical to the unary SubmitResponse.
|
||||
@$pb.TagNumber(4)
|
||||
SubmitResponse get finalResult => $_getN(3);
|
||||
@$pb.TagNumber(4)
|
||||
set finalResult(SubmitResponse value) => $_setField(4, value);
|
||||
@$pb.TagNumber(4)
|
||||
$core.bool hasFinalResult() => $_has(3);
|
||||
@$pb.TagNumber(4)
|
||||
void clearFinalResult() => $_clearField(4);
|
||||
@$pb.TagNumber(4)
|
||||
SubmitResponse ensureFinalResult() => $_ensure(3);
|
||||
|
||||
/// Terminal failure — the flow (or a step) errored.
|
||||
@$pb.TagNumber(5)
|
||||
StreamError get error => $_getN(4);
|
||||
@$pb.TagNumber(5)
|
||||
set error(StreamError value) => $_setField(5, value);
|
||||
@$pb.TagNumber(5)
|
||||
$core.bool hasError() => $_has(4);
|
||||
@$pb.TagNumber(5)
|
||||
void clearError() => $_clearField(5);
|
||||
@$pb.TagNumber(5)
|
||||
StreamError ensureError() => $_ensure(4);
|
||||
}
|
||||
|
||||
class StepStarted extends $pb.GeneratedMessage {
|
||||
factory StepStarted({
|
||||
$core.String? step,
|
||||
$core.String? capability,
|
||||
}) {
|
||||
final result = create();
|
||||
if (step != null) result.step = step;
|
||||
if (capability != null) result.capability = capability;
|
||||
return result;
|
||||
}
|
||||
|
||||
StepStarted._();
|
||||
|
||||
factory StepStarted.fromBuffer($core.List<$core.int> data,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromBuffer(data, registry);
|
||||
factory StepStarted.fromJson($core.String json,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromJson(json, registry);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
||||
_omitMessageNames ? '' : 'StepStarted',
|
||||
package: const $pb.PackageName(_omitMessageNames ? '' : 'chain.v1'),
|
||||
createEmptyInstance: create)
|
||||
..aOS(1, _omitFieldNames ? '' : 'step')
|
||||
..aOS(2, _omitFieldNames ? '' : 'capability')
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
StepStarted clone() => deepCopy();
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
StepStarted copyWith(void Function(StepStarted) updates) =>
|
||||
super.copyWith((message) => updates(message as StepStarted))
|
||||
as StepStarted;
|
||||
|
||||
@$core.override
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StepStarted create() => StepStarted._();
|
||||
@$core.override
|
||||
StepStarted createEmptyInstance() => create();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StepStarted getDefault() => _defaultInstance ??=
|
||||
$pb.GeneratedMessage.$_defaultFor<StepStarted>(create);
|
||||
static StepStarted? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
$core.String get step => $_getSZ(0);
|
||||
@$pb.TagNumber(1)
|
||||
set step($core.String value) => $_setString(0, value);
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasStep() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearStep() => $_clearField(1);
|
||||
|
||||
/// Capability the step resolved to, e.g. "text.extract".
|
||||
@$pb.TagNumber(2)
|
||||
$core.String get capability => $_getSZ(1);
|
||||
@$pb.TagNumber(2)
|
||||
set capability($core.String value) => $_setString(1, value);
|
||||
@$pb.TagNumber(2)
|
||||
$core.bool hasCapability() => $_has(1);
|
||||
@$pb.TagNumber(2)
|
||||
void clearCapability() => $_clearField(2);
|
||||
}
|
||||
|
||||
class StepFinished extends $pb.GeneratedMessage {
|
||||
factory StepFinished({
|
||||
$core.String? step,
|
||||
$core.bool? ok,
|
||||
$fixnum.Int64? durationMs,
|
||||
}) {
|
||||
final result = create();
|
||||
if (step != null) result.step = step;
|
||||
if (ok != null) result.ok = ok;
|
||||
if (durationMs != null) result.durationMs = durationMs;
|
||||
return result;
|
||||
}
|
||||
|
||||
StepFinished._();
|
||||
|
||||
factory StepFinished.fromBuffer($core.List<$core.int> data,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromBuffer(data, registry);
|
||||
factory StepFinished.fromJson($core.String json,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromJson(json, registry);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
||||
_omitMessageNames ? '' : 'StepFinished',
|
||||
package: const $pb.PackageName(_omitMessageNames ? '' : 'chain.v1'),
|
||||
createEmptyInstance: create)
|
||||
..aOS(1, _omitFieldNames ? '' : 'step')
|
||||
..aOB(2, _omitFieldNames ? '' : 'ok')
|
||||
..aInt64(3, _omitFieldNames ? '' : 'durationMs')
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
StepFinished clone() => deepCopy();
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
StepFinished copyWith(void Function(StepFinished) updates) =>
|
||||
super.copyWith((message) => updates(message as StepFinished))
|
||||
as StepFinished;
|
||||
|
||||
@$core.override
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StepFinished create() => StepFinished._();
|
||||
@$core.override
|
||||
StepFinished createEmptyInstance() => create();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StepFinished getDefault() => _defaultInstance ??=
|
||||
$pb.GeneratedMessage.$_defaultFor<StepFinished>(create);
|
||||
static StepFinished? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
$core.String get step => $_getSZ(0);
|
||||
@$pb.TagNumber(1)
|
||||
set step($core.String value) => $_setString(0, value);
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasStep() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearStep() => $_clearField(1);
|
||||
|
||||
@$pb.TagNumber(2)
|
||||
$core.bool get ok => $_getBF(1);
|
||||
@$pb.TagNumber(2)
|
||||
set ok($core.bool value) => $_setBool(1, value);
|
||||
@$pb.TagNumber(2)
|
||||
$core.bool hasOk() => $_has(1);
|
||||
@$pb.TagNumber(2)
|
||||
void clearOk() => $_clearField(2);
|
||||
|
||||
@$pb.TagNumber(3)
|
||||
$fixnum.Int64 get durationMs => $_getI64(2);
|
||||
@$pb.TagNumber(3)
|
||||
set durationMs($fixnum.Int64 value) => $_setInt64(2, value);
|
||||
@$pb.TagNumber(3)
|
||||
$core.bool hasDurationMs() => $_has(2);
|
||||
@$pb.TagNumber(3)
|
||||
void clearDurationMs() => $_clearField(3);
|
||||
}
|
||||
|
||||
/// An ephemeral event a module emitted via host.emit-event (WIT 1.1).
|
||||
/// Never written to the audit log.
|
||||
class ModuleEvent extends $pb.GeneratedMessage {
|
||||
factory ModuleEvent({
|
||||
$core.String? step,
|
||||
$core.String? name,
|
||||
$2.Payload? payload,
|
||||
}) {
|
||||
final result = create();
|
||||
if (step != null) result.step = step;
|
||||
if (name != null) result.name = name;
|
||||
if (payload != null) result.payload = payload;
|
||||
return result;
|
||||
}
|
||||
|
||||
ModuleEvent._();
|
||||
|
||||
factory ModuleEvent.fromBuffer($core.List<$core.int> data,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromBuffer(data, registry);
|
||||
factory ModuleEvent.fromJson($core.String json,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromJson(json, registry);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
||||
_omitMessageNames ? '' : 'ModuleEvent',
|
||||
package: const $pb.PackageName(_omitMessageNames ? '' : 'chain.v1'),
|
||||
createEmptyInstance: create)
|
||||
..aOS(1, _omitFieldNames ? '' : 'step')
|
||||
..aOS(2, _omitFieldNames ? '' : 'name')
|
||||
..aOM<$2.Payload>(3, _omitFieldNames ? '' : 'payload',
|
||||
subBuilder: $2.Payload.create)
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
ModuleEvent clone() => deepCopy();
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
ModuleEvent copyWith(void Function(ModuleEvent) updates) =>
|
||||
super.copyWith((message) => updates(message as ModuleEvent))
|
||||
as ModuleEvent;
|
||||
|
||||
@$core.override
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static ModuleEvent create() => ModuleEvent._();
|
||||
@$core.override
|
||||
ModuleEvent createEmptyInstance() => create();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static ModuleEvent getDefault() => _defaultInstance ??=
|
||||
$pb.GeneratedMessage.$_defaultFor<ModuleEvent>(create);
|
||||
static ModuleEvent? _defaultInstance;
|
||||
|
||||
/// The step whose module emitted this.
|
||||
@$pb.TagNumber(1)
|
||||
$core.String get step => $_getSZ(0);
|
||||
@$pb.TagNumber(1)
|
||||
set step($core.String value) => $_setString(0, value);
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasStep() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearStep() => $_clearField(1);
|
||||
|
||||
/// Module-defined label, e.g. "progress" / "token".
|
||||
@$pb.TagNumber(2)
|
||||
$core.String get name => $_getSZ(1);
|
||||
@$pb.TagNumber(2)
|
||||
set name($core.String value) => $_setString(1, value);
|
||||
@$pb.TagNumber(2)
|
||||
$core.bool hasName() => $_has(1);
|
||||
@$pb.TagNumber(2)
|
||||
void clearName() => $_clearField(2);
|
||||
|
||||
/// Event body.
|
||||
@$pb.TagNumber(3)
|
||||
$2.Payload get payload => $_getN(2);
|
||||
@$pb.TagNumber(3)
|
||||
set payload($2.Payload value) => $_setField(3, value);
|
||||
@$pb.TagNumber(3)
|
||||
$core.bool hasPayload() => $_has(2);
|
||||
@$pb.TagNumber(3)
|
||||
void clearPayload() => $_clearField(3);
|
||||
@$pb.TagNumber(3)
|
||||
$2.Payload ensurePayload() => $_ensure(2);
|
||||
}
|
||||
|
||||
class StreamError extends $pb.GeneratedMessage {
|
||||
factory StreamError({
|
||||
$core.String? message,
|
||||
}) {
|
||||
final result = create();
|
||||
if (message != null) result.message = message;
|
||||
return result;
|
||||
}
|
||||
|
||||
StreamError._();
|
||||
|
||||
factory StreamError.fromBuffer($core.List<$core.int> data,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromBuffer(data, registry);
|
||||
factory StreamError.fromJson($core.String json,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromJson(json, registry);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
||||
_omitMessageNames ? '' : 'StreamError',
|
||||
package: const $pb.PackageName(_omitMessageNames ? '' : 'chain.v1'),
|
||||
createEmptyInstance: create)
|
||||
..aOS(1, _omitFieldNames ? '' : 'message')
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
StreamError clone() => deepCopy();
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
StreamError copyWith(void Function(StreamError) updates) =>
|
||||
super.copyWith((message) => updates(message as StreamError))
|
||||
as StreamError;
|
||||
|
||||
@$core.override
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StreamError create() => StreamError._();
|
||||
@$core.override
|
||||
StreamError createEmptyInstance() => create();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static StreamError getDefault() => _defaultInstance ??=
|
||||
$pb.GeneratedMessage.$_defaultFor<StreamError>(create);
|
||||
static StreamError? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
$core.String get message => $_getSZ(0);
|
||||
@$pb.TagNumber(1)
|
||||
set message($core.String value) => $_setString(0, value);
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasMessage() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearMessage() => $_clearField(1);
|
||||
}
|
||||
|
||||
/// Lifecycle of a detached invocation (added 1.1).
|
||||
class InvocationStatus extends $pb.GeneratedMessage {
|
||||
factory InvocationStatus({
|
||||
InvocationStatus_Phase? phase,
|
||||
$core.String? currentStep,
|
||||
$core.String? startedAt,
|
||||
$core.String? finishedAt,
|
||||
$core.String? error,
|
||||
}) {
|
||||
final result = create();
|
||||
if (phase != null) result.phase = phase;
|
||||
if (currentStep != null) result.currentStep = currentStep;
|
||||
if (startedAt != null) result.startedAt = startedAt;
|
||||
if (finishedAt != null) result.finishedAt = finishedAt;
|
||||
if (error != null) result.error = error;
|
||||
return result;
|
||||
}
|
||||
|
||||
InvocationStatus._();
|
||||
|
||||
factory InvocationStatus.fromBuffer($core.List<$core.int> data,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromBuffer(data, registry);
|
||||
factory InvocationStatus.fromJson($core.String json,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromJson(json, registry);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
||||
_omitMessageNames ? '' : 'InvocationStatus',
|
||||
package: const $pb.PackageName(_omitMessageNames ? '' : 'chain.v1'),
|
||||
createEmptyInstance: create)
|
||||
..aE<InvocationStatus_Phase>(1, _omitFieldNames ? '' : 'phase',
|
||||
enumValues: InvocationStatus_Phase.values)
|
||||
..aOS(2, _omitFieldNames ? '' : 'currentStep')
|
||||
..aOS(3, _omitFieldNames ? '' : 'startedAt')
|
||||
..aOS(4, _omitFieldNames ? '' : 'finishedAt')
|
||||
..aOS(5, _omitFieldNames ? '' : 'error')
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
InvocationStatus clone() => deepCopy();
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
InvocationStatus copyWith(void Function(InvocationStatus) updates) =>
|
||||
super.copyWith((message) => updates(message as InvocationStatus))
|
||||
as InvocationStatus;
|
||||
|
||||
@$core.override
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static InvocationStatus create() => InvocationStatus._();
|
||||
@$core.override
|
||||
InvocationStatus createEmptyInstance() => create();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static InvocationStatus getDefault() => _defaultInstance ??=
|
||||
$pb.GeneratedMessage.$_defaultFor<InvocationStatus>(create);
|
||||
static InvocationStatus? _defaultInstance;
|
||||
|
||||
@$pb.TagNumber(1)
|
||||
InvocationStatus_Phase get phase => $_getN(0);
|
||||
@$pb.TagNumber(1)
|
||||
set phase(InvocationStatus_Phase value) => $_setField(1, value);
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasPhase() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearPhase() => $_clearField(1);
|
||||
|
||||
/// Step currently executing (RUNNING), empty otherwise.
|
||||
@$pb.TagNumber(2)
|
||||
$core.String get currentStep => $_getSZ(1);
|
||||
@$pb.TagNumber(2)
|
||||
set currentStep($core.String value) => $_setString(1, value);
|
||||
@$pb.TagNumber(2)
|
||||
$core.bool hasCurrentStep() => $_has(1);
|
||||
@$pb.TagNumber(2)
|
||||
void clearCurrentStep() => $_clearField(2);
|
||||
|
||||
/// RFC 3339 timestamps; finished_at empty until the flow ends.
|
||||
@$pb.TagNumber(3)
|
||||
$core.String get startedAt => $_getSZ(2);
|
||||
@$pb.TagNumber(3)
|
||||
set startedAt($core.String value) => $_setString(2, value);
|
||||
@$pb.TagNumber(3)
|
||||
$core.bool hasStartedAt() => $_has(2);
|
||||
@$pb.TagNumber(3)
|
||||
void clearStartedAt() => $_clearField(3);
|
||||
|
||||
@$pb.TagNumber(4)
|
||||
$core.String get finishedAt => $_getSZ(3);
|
||||
@$pb.TagNumber(4)
|
||||
set finishedAt($core.String value) => $_setString(3, value);
|
||||
@$pb.TagNumber(4)
|
||||
$core.bool hasFinishedAt() => $_has(3);
|
||||
@$pb.TagNumber(4)
|
||||
void clearFinishedAt() => $_clearField(4);
|
||||
|
||||
/// Error message when phase == FAILED, empty otherwise.
|
||||
@$pb.TagNumber(5)
|
||||
$core.String get error => $_getSZ(4);
|
||||
@$pb.TagNumber(5)
|
||||
set error($core.String value) => $_setString(4, value);
|
||||
@$pb.TagNumber(5)
|
||||
$core.bool hasError() => $_has(4);
|
||||
@$pb.TagNumber(5)
|
||||
void clearError() => $_clearField(5);
|
||||
}
|
||||
|
||||
class CancelInvocationResponse extends $pb.GeneratedMessage {
|
||||
factory CancelInvocationResponse({
|
||||
$core.bool? cancelled,
|
||||
}) {
|
||||
final result = create();
|
||||
if (cancelled != null) result.cancelled = cancelled;
|
||||
return result;
|
||||
}
|
||||
|
||||
CancelInvocationResponse._();
|
||||
|
||||
factory CancelInvocationResponse.fromBuffer($core.List<$core.int> data,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromBuffer(data, registry);
|
||||
factory CancelInvocationResponse.fromJson($core.String json,
|
||||
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
||||
create()..mergeFromJson(json, registry);
|
||||
|
||||
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
||||
_omitMessageNames ? '' : 'CancelInvocationResponse',
|
||||
package: const $pb.PackageName(_omitMessageNames ? '' : 'chain.v1'),
|
||||
createEmptyInstance: create)
|
||||
..aOB(1, _omitFieldNames ? '' : 'cancelled')
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
CancelInvocationResponse clone() => deepCopy();
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
CancelInvocationResponse copyWith(
|
||||
void Function(CancelInvocationResponse) updates) =>
|
||||
super.copyWith((message) => updates(message as CancelInvocationResponse))
|
||||
as CancelInvocationResponse;
|
||||
|
||||
@$core.override
|
||||
$pb.BuilderInfo get info_ => _i;
|
||||
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static CancelInvocationResponse create() => CancelInvocationResponse._();
|
||||
@$core.override
|
||||
CancelInvocationResponse createEmptyInstance() => create();
|
||||
@$core.pragma('dart2js:noInline')
|
||||
static CancelInvocationResponse getDefault() => _defaultInstance ??=
|
||||
$pb.GeneratedMessage.$_defaultFor<CancelInvocationResponse>(create);
|
||||
static CancelInvocationResponse? _defaultInstance;
|
||||
|
||||
/// True if a running invocation was signalled to cancel; false if it
|
||||
/// was already finished or unknown.
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool get cancelled => $_getBF(0);
|
||||
@$pb.TagNumber(1)
|
||||
set cancelled($core.bool value) => $_setBool(0, value);
|
||||
@$pb.TagNumber(1)
|
||||
$core.bool hasCancelled() => $_has(0);
|
||||
@$pb.TagNumber(1)
|
||||
void clearCancelled() => $_clearField(1);
|
||||
}
|
||||
|
||||
class ModuleList extends $pb.GeneratedMessage {
|
||||
factory ModuleList({
|
||||
$core.Iterable<ModuleSummary>? modules,
|
||||
|
|
@ -4607,7 +3988,6 @@ class StoreEntry extends $pb.GeneratedMessage {
|
|||
$core.String? kind,
|
||||
$core.String? provider,
|
||||
$core.String? sourceKind,
|
||||
$core.String? source,
|
||||
}) {
|
||||
final result = create();
|
||||
if (name != null) result.name = name;
|
||||
|
|
@ -4633,7 +4013,6 @@ class StoreEntry extends $pb.GeneratedMessage {
|
|||
if (kind != null) result.kind = kind;
|
||||
if (provider != null) result.provider = provider;
|
||||
if (sourceKind != null) result.sourceKind = sourceKind;
|
||||
if (source != null) result.source = source;
|
||||
return result;
|
||||
}
|
||||
|
||||
|
|
@ -4671,7 +4050,6 @@ class StoreEntry extends $pb.GeneratedMessage {
|
|||
..aOS(19, _omitFieldNames ? '' : 'kind')
|
||||
..aOS(20, _omitFieldNames ? '' : 'provider')
|
||||
..aOS(21, _omitFieldNames ? '' : 'sourceKind')
|
||||
..aOS(22, _omitFieldNames ? '' : 'source')
|
||||
..hasRequiredFields = false;
|
||||
|
||||
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
||||
|
|
@ -4893,19 +4271,6 @@ class StoreEntry extends $pb.GeneratedMessage {
|
|||
$core.bool hasSourceKind() => $_has(20);
|
||||
@$pb.TagNumber(21)
|
||||
void clearSourceKind() => $_clearField(21);
|
||||
|
||||
/// Name of the store this entry was loaded from: "bundled" for the
|
||||
/// built-in seed, otherwise the operator-added store's name. Distinct
|
||||
/// from source_kind (the transport) — this is the ORIGIN store. Studio
|
||||
/// groups modules by it and shows a "from <store>" label.
|
||||
@$pb.TagNumber(22)
|
||||
$core.String get source => $_getSZ(21);
|
||||
@$pb.TagNumber(22)
|
||||
set source($core.String value) => $_setString(21, value);
|
||||
@$pb.TagNumber(22)
|
||||
$core.bool hasSource() => $_has(21);
|
||||
@$pb.TagNumber(22)
|
||||
void clearSource() => $_clearField(22);
|
||||
}
|
||||
|
||||
class ChannelStatusResponse extends $pb.GeneratedMessage {
|
||||
|
|
|
|||
|
|
@ -14,38 +14,6 @@ import 'dart:core' as $core;
|
|||
|
||||
import 'package:protobuf/protobuf.dart' as $pb;
|
||||
|
||||
class InvocationStatus_Phase extends $pb.ProtobufEnum {
|
||||
static const InvocationStatus_Phase PHASE_UNKNOWN =
|
||||
InvocationStatus_Phase._(0, _omitEnumNames ? '' : 'PHASE_UNKNOWN');
|
||||
static const InvocationStatus_Phase PENDING =
|
||||
InvocationStatus_Phase._(1, _omitEnumNames ? '' : 'PENDING');
|
||||
static const InvocationStatus_Phase RUNNING =
|
||||
InvocationStatus_Phase._(2, _omitEnumNames ? '' : 'RUNNING');
|
||||
static const InvocationStatus_Phase SUCCEEDED =
|
||||
InvocationStatus_Phase._(3, _omitEnumNames ? '' : 'SUCCEEDED');
|
||||
static const InvocationStatus_Phase FAILED =
|
||||
InvocationStatus_Phase._(4, _omitEnumNames ? '' : 'FAILED');
|
||||
static const InvocationStatus_Phase CANCELLED =
|
||||
InvocationStatus_Phase._(5, _omitEnumNames ? '' : 'CANCELLED');
|
||||
|
||||
static const $core.List<InvocationStatus_Phase> values =
|
||||
<InvocationStatus_Phase>[
|
||||
PHASE_UNKNOWN,
|
||||
PENDING,
|
||||
RUNNING,
|
||||
SUCCEEDED,
|
||||
FAILED,
|
||||
CANCELLED,
|
||||
];
|
||||
|
||||
static final $core.List<InvocationStatus_Phase?> _byValue =
|
||||
$pb.ProtobufEnum.$_initByValueList(values, 5);
|
||||
static InvocationStatus_Phase? valueOf($core.int value) =>
|
||||
value < 0 || value >= _byValue.length ? null : _byValue[value];
|
||||
|
||||
const InvocationStatus_Phase._(super.value, super.name);
|
||||
}
|
||||
|
||||
class HealthStatus_State extends $pb.ProtobufEnum {
|
||||
static const HealthStatus_State UNKNOWN =
|
||||
HealthStatus_State._(0, _omitEnumNames ? '' : 'UNKNOWN');
|
||||
|
|
|
|||
|
|
@ -17,7 +17,6 @@ import 'package:grpc/service_api.dart' as $grpc;
|
|||
import 'package:protobuf/protobuf.dart' as $pb;
|
||||
import 'package:protobuf/well_known_types/google/protobuf/empty.pb.dart' as $1;
|
||||
|
||||
import 'common.pb.dart' as $2;
|
||||
import 'hub.pb.dart' as $0;
|
||||
|
||||
export 'hub.pb.dart';
|
||||
|
|
@ -43,20 +42,6 @@ class HubClient extends $grpc.Client {
|
|||
return $createUnaryCall(_$submit, request, options: options);
|
||||
}
|
||||
|
||||
/// Submit a flow and follow its execution live (added 1.1). Same
|
||||
/// request as unary Submit; the response is a stream of step markers,
|
||||
/// ephemeral module events (host.emit-event), and finally the result
|
||||
/// or an error. Works over native gRPC and gRPC-Web (server
|
||||
/// streaming). Unary Submit is unchanged for clients that don't care.
|
||||
$grpc.ResponseStream<$0.SubmitStreamEvent> submitStream(
|
||||
$0.SubmitRequest request, {
|
||||
$grpc.CallOptions? options,
|
||||
}) {
|
||||
return $createStreamingCall(
|
||||
_$submitStream, $async.Stream.fromIterable([request]),
|
||||
options: options);
|
||||
}
|
||||
|
||||
/// List modules known to this hub.
|
||||
$grpc.ResponseFuture<$0.ModuleList> listModules(
|
||||
$1.Empty request, {
|
||||
|
|
@ -65,31 +50,6 @@ class HubClient extends $grpc.Client {
|
|||
return $createUnaryCall(_$listModules, request, options: options);
|
||||
}
|
||||
|
||||
/// Detached-invocation lifecycle (added 1.1). Only invocations
|
||||
/// submitted with detach=true are tracked; results are retained under
|
||||
/// hard operator limits (size/count/TTL) and NOT persisted across a
|
||||
/// hub restart.
|
||||
$grpc.ResponseFuture<$0.InvocationStatus> getInvocationStatus(
|
||||
$2.InvocationId request, {
|
||||
$grpc.CallOptions? options,
|
||||
}) {
|
||||
return $createUnaryCall(_$getInvocationStatus, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$0.SubmitResponse> getInvocationResult(
|
||||
$2.InvocationId request, {
|
||||
$grpc.CallOptions? options,
|
||||
}) {
|
||||
return $createUnaryCall(_$getInvocationResult, request, options: options);
|
||||
}
|
||||
|
||||
$grpc.ResponseFuture<$0.CancelInvocationResponse> cancelInvocation(
|
||||
$2.InvocationId request, {
|
||||
$grpc.CallOptions? options,
|
||||
}) {
|
||||
return $createUnaryCall(_$cancelInvocation, request, options: options);
|
||||
}
|
||||
|
||||
/// Liveness / readiness probe.
|
||||
$grpc.ResponseFuture<$0.HealthStatus> health(
|
||||
$1.Empty request, {
|
||||
|
|
@ -105,30 +65,10 @@ class HubClient extends $grpc.Client {
|
|||
'/chain.v1.Hub/Submit',
|
||||
($0.SubmitRequest value) => value.writeToBuffer(),
|
||||
$0.SubmitResponse.fromBuffer);
|
||||
static final _$submitStream =
|
||||
$grpc.ClientMethod<$0.SubmitRequest, $0.SubmitStreamEvent>(
|
||||
'/chain.v1.Hub/SubmitStream',
|
||||
($0.SubmitRequest value) => value.writeToBuffer(),
|
||||
$0.SubmitStreamEvent.fromBuffer);
|
||||
static final _$listModules = $grpc.ClientMethod<$1.Empty, $0.ModuleList>(
|
||||
'/chain.v1.Hub/ListModules',
|
||||
($1.Empty value) => value.writeToBuffer(),
|
||||
$0.ModuleList.fromBuffer);
|
||||
static final _$getInvocationStatus =
|
||||
$grpc.ClientMethod<$2.InvocationId, $0.InvocationStatus>(
|
||||
'/chain.v1.Hub/GetInvocationStatus',
|
||||
($2.InvocationId value) => value.writeToBuffer(),
|
||||
$0.InvocationStatus.fromBuffer);
|
||||
static final _$getInvocationResult =
|
||||
$grpc.ClientMethod<$2.InvocationId, $0.SubmitResponse>(
|
||||
'/chain.v1.Hub/GetInvocationResult',
|
||||
($2.InvocationId value) => value.writeToBuffer(),
|
||||
$0.SubmitResponse.fromBuffer);
|
||||
static final _$cancelInvocation =
|
||||
$grpc.ClientMethod<$2.InvocationId, $0.CancelInvocationResponse>(
|
||||
'/chain.v1.Hub/CancelInvocation',
|
||||
($2.InvocationId value) => value.writeToBuffer(),
|
||||
$0.CancelInvocationResponse.fromBuffer);
|
||||
static final _$health = $grpc.ClientMethod<$1.Empty, $0.HealthStatus>(
|
||||
'/chain.v1.Hub/Health',
|
||||
($1.Empty value) => value.writeToBuffer(),
|
||||
|
|
@ -147,13 +87,6 @@ abstract class HubServiceBase extends $grpc.Service {
|
|||
false,
|
||||
($core.List<$core.int> value) => $0.SubmitRequest.fromBuffer(value),
|
||||
($0.SubmitResponse value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$0.SubmitRequest, $0.SubmitStreamEvent>(
|
||||
'SubmitStream',
|
||||
submitStream_Pre,
|
||||
false,
|
||||
true,
|
||||
($core.List<$core.int> value) => $0.SubmitRequest.fromBuffer(value),
|
||||
($0.SubmitStreamEvent value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$1.Empty, $0.ModuleList>(
|
||||
'ListModules',
|
||||
listModules_Pre,
|
||||
|
|
@ -161,28 +94,6 @@ abstract class HubServiceBase extends $grpc.Service {
|
|||
false,
|
||||
($core.List<$core.int> value) => $1.Empty.fromBuffer(value),
|
||||
($0.ModuleList value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$2.InvocationId, $0.InvocationStatus>(
|
||||
'GetInvocationStatus',
|
||||
getInvocationStatus_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $2.InvocationId.fromBuffer(value),
|
||||
($0.InvocationStatus value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$2.InvocationId, $0.SubmitResponse>(
|
||||
'GetInvocationResult',
|
||||
getInvocationResult_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $2.InvocationId.fromBuffer(value),
|
||||
($0.SubmitResponse value) => value.writeToBuffer()));
|
||||
$addMethod(
|
||||
$grpc.ServiceMethod<$2.InvocationId, $0.CancelInvocationResponse>(
|
||||
'CancelInvocation',
|
||||
cancelInvocation_Pre,
|
||||
false,
|
||||
false,
|
||||
($core.List<$core.int> value) => $2.InvocationId.fromBuffer(value),
|
||||
($0.CancelInvocationResponse value) => value.writeToBuffer()));
|
||||
$addMethod($grpc.ServiceMethod<$1.Empty, $0.HealthStatus>(
|
||||
'Health',
|
||||
health_Pre,
|
||||
|
|
@ -200,14 +111,6 @@ abstract class HubServiceBase extends $grpc.Service {
|
|||
$async.Future<$0.SubmitResponse> submit(
|
||||
$grpc.ServiceCall call, $0.SubmitRequest request);
|
||||
|
||||
$async.Stream<$0.SubmitStreamEvent> submitStream_Pre($grpc.ServiceCall $call,
|
||||
$async.Future<$0.SubmitRequest> $request) async* {
|
||||
yield* submitStream($call, await $request);
|
||||
}
|
||||
|
||||
$async.Stream<$0.SubmitStreamEvent> submitStream(
|
||||
$grpc.ServiceCall call, $0.SubmitRequest request);
|
||||
|
||||
$async.Future<$0.ModuleList> listModules_Pre(
|
||||
$grpc.ServiceCall $call, $async.Future<$1.Empty> $request) async {
|
||||
return listModules($call, await $request);
|
||||
|
|
@ -216,30 +119,6 @@ abstract class HubServiceBase extends $grpc.Service {
|
|||
$async.Future<$0.ModuleList> listModules(
|
||||
$grpc.ServiceCall call, $1.Empty request);
|
||||
|
||||
$async.Future<$0.InvocationStatus> getInvocationStatus_Pre(
|
||||
$grpc.ServiceCall $call, $async.Future<$2.InvocationId> $request) async {
|
||||
return getInvocationStatus($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$0.InvocationStatus> getInvocationStatus(
|
||||
$grpc.ServiceCall call, $2.InvocationId request);
|
||||
|
||||
$async.Future<$0.SubmitResponse> getInvocationResult_Pre(
|
||||
$grpc.ServiceCall $call, $async.Future<$2.InvocationId> $request) async {
|
||||
return getInvocationResult($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$0.SubmitResponse> getInvocationResult(
|
||||
$grpc.ServiceCall call, $2.InvocationId request);
|
||||
|
||||
$async.Future<$0.CancelInvocationResponse> cancelInvocation_Pre(
|
||||
$grpc.ServiceCall $call, $async.Future<$2.InvocationId> $request) async {
|
||||
return cancelInvocation($call, await $request);
|
||||
}
|
||||
|
||||
$async.Future<$0.CancelInvocationResponse> cancelInvocation(
|
||||
$grpc.ServiceCall call, $2.InvocationId request);
|
||||
|
||||
$async.Future<$0.HealthStatus> health_Pre(
|
||||
$grpc.ServiceCall $call, $async.Future<$1.Empty> $request) async {
|
||||
return health($call, await $request);
|
||||
|
|
|
|||
|
|
@ -41,7 +41,6 @@ const SubmitRequest$json = {
|
|||
'6': '.chain.v1.SubmitRequest.InputsEntry',
|
||||
'10': 'inputs'
|
||||
},
|
||||
{'1': 'detach', '3': 3, '4': 1, '5': 8, '10': 'detach'},
|
||||
],
|
||||
'3': [SubmitRequest_InputsEntry$json],
|
||||
};
|
||||
|
|
@ -66,9 +65,9 @@ const SubmitRequest_InputsEntry$json = {
|
|||
/// Descriptor for `SubmitRequest`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List submitRequestDescriptor = $convert.base64Decode(
|
||||
'Cg1TdWJtaXRSZXF1ZXN0EhsKCWZsb3dfeWFtbBgBIAEoDFIIZmxvd1lhbWwSOwoGaW5wdXRzGA'
|
||||
'IgAygLMiMuY2hhaW4udjEuU3VibWl0UmVxdWVzdC5JbnB1dHNFbnRyeVIGaW5wdXRzEhYKBmRl'
|
||||
'dGFjaBgDIAEoCFIGZGV0YWNoGkwKC0lucHV0c0VudHJ5EhAKA2tleRgBIAEoCVIDa2V5EicKBX'
|
||||
'ZhbHVlGAIgASgLMhEuY2hhaW4udjEuUGF5bG9hZFIFdmFsdWU6AjgB');
|
||||
'IgAygLMiMuY2hhaW4udjEuU3VibWl0UmVxdWVzdC5JbnB1dHNFbnRyeVIGaW5wdXRzGkwKC0lu'
|
||||
'cHV0c0VudHJ5EhAKA2tleRgBIAEoCVIDa2V5EicKBXZhbHVlGAIgASgLMhEuY2hhaW4udjEuUG'
|
||||
'F5bG9hZFIFdmFsdWU6AjgB');
|
||||
|
||||
@$core.Deprecated('Use submitResponseDescriptor instead')
|
||||
const SubmitResponse$json = {
|
||||
|
|
@ -118,189 +117,6 @@ final $typed_data.Uint8List submitResponseDescriptor = $convert.base64Decode(
|
|||
'dFJlc3BvbnNlLk91dHB1dHNFbnRyeVIHb3V0cHV0cxpNCgxPdXRwdXRzRW50cnkSEAoDa2V5GA'
|
||||
'EgASgJUgNrZXkSJwoFdmFsdWUYAiABKAsyES5jaGFpbi52MS5QYXlsb2FkUgV2YWx1ZToCOAE=');
|
||||
|
||||
@$core.Deprecated('Use submitStreamEventDescriptor instead')
|
||||
const SubmitStreamEvent$json = {
|
||||
'1': 'SubmitStreamEvent',
|
||||
'2': [
|
||||
{
|
||||
'1': 'step_started',
|
||||
'3': 1,
|
||||
'4': 1,
|
||||
'5': 11,
|
||||
'6': '.chain.v1.StepStarted',
|
||||
'9': 0,
|
||||
'10': 'stepStarted'
|
||||
},
|
||||
{
|
||||
'1': 'step_finished',
|
||||
'3': 2,
|
||||
'4': 1,
|
||||
'5': 11,
|
||||
'6': '.chain.v1.StepFinished',
|
||||
'9': 0,
|
||||
'10': 'stepFinished'
|
||||
},
|
||||
{
|
||||
'1': 'module_event',
|
||||
'3': 3,
|
||||
'4': 1,
|
||||
'5': 11,
|
||||
'6': '.chain.v1.ModuleEvent',
|
||||
'9': 0,
|
||||
'10': 'moduleEvent'
|
||||
},
|
||||
{
|
||||
'1': 'final_result',
|
||||
'3': 4,
|
||||
'4': 1,
|
||||
'5': 11,
|
||||
'6': '.chain.v1.SubmitResponse',
|
||||
'9': 0,
|
||||
'10': 'finalResult'
|
||||
},
|
||||
{
|
||||
'1': 'error',
|
||||
'3': 5,
|
||||
'4': 1,
|
||||
'5': 11,
|
||||
'6': '.chain.v1.StreamError',
|
||||
'9': 0,
|
||||
'10': 'error'
|
||||
},
|
||||
],
|
||||
'8': [
|
||||
{'1': 'event'},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `SubmitStreamEvent`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List submitStreamEventDescriptor = $convert.base64Decode(
|
||||
'ChFTdWJtaXRTdHJlYW1FdmVudBI6CgxzdGVwX3N0YXJ0ZWQYASABKAsyFS5jaGFpbi52MS5TdG'
|
||||
'VwU3RhcnRlZEgAUgtzdGVwU3RhcnRlZBI9Cg1zdGVwX2ZpbmlzaGVkGAIgASgLMhYuY2hhaW4u'
|
||||
'djEuU3RlcEZpbmlzaGVkSABSDHN0ZXBGaW5pc2hlZBI6Cgxtb2R1bGVfZXZlbnQYAyABKAsyFS'
|
||||
'5jaGFpbi52MS5Nb2R1bGVFdmVudEgAUgttb2R1bGVFdmVudBI9CgxmaW5hbF9yZXN1bHQYBCAB'
|
||||
'KAsyGC5jaGFpbi52MS5TdWJtaXRSZXNwb25zZUgAUgtmaW5hbFJlc3VsdBItCgVlcnJvchgFIA'
|
||||
'EoCzIVLmNoYWluLnYxLlN0cmVhbUVycm9ySABSBWVycm9yQgcKBWV2ZW50');
|
||||
|
||||
@$core.Deprecated('Use stepStartedDescriptor instead')
|
||||
const StepStarted$json = {
|
||||
'1': 'StepStarted',
|
||||
'2': [
|
||||
{'1': 'step', '3': 1, '4': 1, '5': 9, '10': 'step'},
|
||||
{'1': 'capability', '3': 2, '4': 1, '5': 9, '10': 'capability'},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `StepStarted`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List stepStartedDescriptor = $convert.base64Decode(
|
||||
'CgtTdGVwU3RhcnRlZBISCgRzdGVwGAEgASgJUgRzdGVwEh4KCmNhcGFiaWxpdHkYAiABKAlSCm'
|
||||
'NhcGFiaWxpdHk=');
|
||||
|
||||
@$core.Deprecated('Use stepFinishedDescriptor instead')
|
||||
const StepFinished$json = {
|
||||
'1': 'StepFinished',
|
||||
'2': [
|
||||
{'1': 'step', '3': 1, '4': 1, '5': 9, '10': 'step'},
|
||||
{'1': 'ok', '3': 2, '4': 1, '5': 8, '10': 'ok'},
|
||||
{'1': 'duration_ms', '3': 3, '4': 1, '5': 3, '10': 'durationMs'},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `StepFinished`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List stepFinishedDescriptor = $convert.base64Decode(
|
||||
'CgxTdGVwRmluaXNoZWQSEgoEc3RlcBgBIAEoCVIEc3RlcBIOCgJvaxgCIAEoCFICb2sSHwoLZH'
|
||||
'VyYXRpb25fbXMYAyABKANSCmR1cmF0aW9uTXM=');
|
||||
|
||||
@$core.Deprecated('Use moduleEventDescriptor instead')
|
||||
const ModuleEvent$json = {
|
||||
'1': 'ModuleEvent',
|
||||
'2': [
|
||||
{'1': 'step', '3': 1, '4': 1, '5': 9, '10': 'step'},
|
||||
{'1': 'name', '3': 2, '4': 1, '5': 9, '10': 'name'},
|
||||
{
|
||||
'1': 'payload',
|
||||
'3': 3,
|
||||
'4': 1,
|
||||
'5': 11,
|
||||
'6': '.chain.v1.Payload',
|
||||
'10': 'payload'
|
||||
},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `ModuleEvent`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List moduleEventDescriptor = $convert.base64Decode(
|
||||
'CgtNb2R1bGVFdmVudBISCgRzdGVwGAEgASgJUgRzdGVwEhIKBG5hbWUYAiABKAlSBG5hbWUSKw'
|
||||
'oHcGF5bG9hZBgDIAEoCzIRLmNoYWluLnYxLlBheWxvYWRSB3BheWxvYWQ=');
|
||||
|
||||
@$core.Deprecated('Use streamErrorDescriptor instead')
|
||||
const StreamError$json = {
|
||||
'1': 'StreamError',
|
||||
'2': [
|
||||
{'1': 'message', '3': 1, '4': 1, '5': 9, '10': 'message'},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `StreamError`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List streamErrorDescriptor = $convert
|
||||
.base64Decode('CgtTdHJlYW1FcnJvchIYCgdtZXNzYWdlGAEgASgJUgdtZXNzYWdl');
|
||||
|
||||
@$core.Deprecated('Use invocationStatusDescriptor instead')
|
||||
const InvocationStatus$json = {
|
||||
'1': 'InvocationStatus',
|
||||
'2': [
|
||||
{
|
||||
'1': 'phase',
|
||||
'3': 1,
|
||||
'4': 1,
|
||||
'5': 14,
|
||||
'6': '.chain.v1.InvocationStatus.Phase',
|
||||
'10': 'phase'
|
||||
},
|
||||
{'1': 'current_step', '3': 2, '4': 1, '5': 9, '10': 'currentStep'},
|
||||
{'1': 'started_at', '3': 3, '4': 1, '5': 9, '10': 'startedAt'},
|
||||
{'1': 'finished_at', '3': 4, '4': 1, '5': 9, '10': 'finishedAt'},
|
||||
{'1': 'error', '3': 5, '4': 1, '5': 9, '10': 'error'},
|
||||
],
|
||||
'4': [InvocationStatus_Phase$json],
|
||||
};
|
||||
|
||||
@$core.Deprecated('Use invocationStatusDescriptor instead')
|
||||
const InvocationStatus_Phase$json = {
|
||||
'1': 'Phase',
|
||||
'2': [
|
||||
{'1': 'PHASE_UNKNOWN', '2': 0},
|
||||
{'1': 'PENDING', '2': 1},
|
||||
{'1': 'RUNNING', '2': 2},
|
||||
{'1': 'SUCCEEDED', '2': 3},
|
||||
{'1': 'FAILED', '2': 4},
|
||||
{'1': 'CANCELLED', '2': 5},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `InvocationStatus`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List invocationStatusDescriptor = $convert.base64Decode(
|
||||
'ChBJbnZvY2F0aW9uU3RhdHVzEjYKBXBoYXNlGAEgASgOMiAuY2hhaW4udjEuSW52b2NhdGlvbl'
|
||||
'N0YXR1cy5QaGFzZVIFcGhhc2USIQoMY3VycmVudF9zdGVwGAIgASgJUgtjdXJyZW50U3RlcBId'
|
||||
'CgpzdGFydGVkX2F0GAMgASgJUglzdGFydGVkQXQSHwoLZmluaXNoZWRfYXQYBCABKAlSCmZpbm'
|
||||
'lzaGVkQXQSFAoFZXJyb3IYBSABKAlSBWVycm9yIl4KBVBoYXNlEhEKDVBIQVNFX1VOS05PV04Q'
|
||||
'ABILCgdQRU5ESU5HEAESCwoHUlVOTklORxACEg0KCVNVQ0NFRURFRBADEgoKBkZBSUxFRBAEEg'
|
||||
'0KCUNBTkNFTExFRBAF');
|
||||
|
||||
@$core.Deprecated('Use cancelInvocationResponseDescriptor instead')
|
||||
const CancelInvocationResponse$json = {
|
||||
'1': 'CancelInvocationResponse',
|
||||
'2': [
|
||||
{'1': 'cancelled', '3': 1, '4': 1, '5': 8, '10': 'cancelled'},
|
||||
],
|
||||
};
|
||||
|
||||
/// Descriptor for `CancelInvocationResponse`. Decode as a `google.protobuf.DescriptorProto`.
|
||||
final $typed_data.Uint8List cancelInvocationResponseDescriptor =
|
||||
$convert.base64Decode(
|
||||
'ChhDYW5jZWxJbnZvY2F0aW9uUmVzcG9uc2USHAoJY2FuY2VsbGVkGAEgASgIUgljYW5jZWxsZW'
|
||||
'Q=');
|
||||
|
||||
@$core.Deprecated('Use moduleListDescriptor instead')
|
||||
const ModuleList$json = {
|
||||
'1': 'ModuleList',
|
||||
|
|
@ -1261,7 +1077,6 @@ const StoreEntry$json = {
|
|||
{'1': 'kind', '3': 19, '4': 1, '5': 9, '10': 'kind'},
|
||||
{'1': 'provider', '3': 20, '4': 1, '5': 9, '10': 'provider'},
|
||||
{'1': 'source_kind', '3': 21, '4': 1, '5': 9, '10': 'sourceKind'},
|
||||
{'1': 'source', '3': 22, '4': 1, '5': 9, '10': 'source'},
|
||||
],
|
||||
};
|
||||
|
||||
|
|
@ -1279,7 +1094,7 @@ final $typed_data.Uint8List storeEntryDescriptor = $convert.base64Decode(
|
|||
'9uX3VybBgQIAEoCVIHaWNvblVybBInCg9zY3JlZW5zaG90X3VybHMYESADKAlSDnNjcmVlbnNo'
|
||||
'b3RVcmxzEhkKCGRvY3NfdXJsGBIgASgJUgdkb2NzVXJsEhIKBGtpbmQYEyABKAlSBGtpbmQSGg'
|
||||
'oIcHJvdmlkZXIYFCABKAlSCHByb3ZpZGVyEh8KC3NvdXJjZV9raW5kGBUgASgJUgpzb3VyY2VL'
|
||||
'aW5kEhYKBnNvdXJjZRgWIAEoCVIGc291cmNl');
|
||||
'aW5k');
|
||||
|
||||
@$core.Deprecated('Use channelStatusResponseDescriptor instead')
|
||||
const ChannelStatusResponse$json = {
|
||||
|
|
|
|||
|
|
@ -86,11 +86,6 @@ typedef StoreSearchResponse = pb.StoreSearchResponse;
|
|||
typedef InstallModuleResponse = pb.InstallModuleResponse;
|
||||
typedef Payload = pb_common.Payload;
|
||||
typedef SubmitResponse = pb.SubmitResponse;
|
||||
// Live-stream (T2) + detached-invocation (T3) wire types, re-exported
|
||||
// so consumers of [HubClient.submitStreaming] don't import the
|
||||
// generated package directly.
|
||||
typedef SubmitStreamEvent = pb.SubmitStreamEvent;
|
||||
typedef InvocationStatus = pb.InvocationStatus;
|
||||
|
||||
/// Typed client for the F∆I Hub gRPC surface. Construct once,
|
||||
/// reuse for the process lifetime, call [close] on shutdown.
|
||||
|
|
@ -784,80 +779,8 @@ class HubClient {
|
|||
Map<String, Uint8List> fileInputs = const {},
|
||||
Map<String, Object?> jsonInputs = const {},
|
||||
Map<String, String> fileMimeTypes = const {},
|
||||
bool detach = false,
|
||||
}) async {
|
||||
return _hub.submit(_buildSubmitRequest(
|
||||
flowYaml: flowYaml,
|
||||
textInputs: textInputs,
|
||||
fileInputs: fileInputs,
|
||||
jsonInputs: jsonInputs,
|
||||
fileMimeTypes: fileMimeTypes,
|
||||
detach: detach,
|
||||
));
|
||||
}
|
||||
|
||||
/// Submit a flow and follow its execution live (server streaming).
|
||||
///
|
||||
/// Yields [pb.SubmitStreamEvent]s in order: `stepStarted` /
|
||||
/// `stepFinished` markers, `moduleEvent`s (a module's ephemeral
|
||||
/// `host.emit-event`s), and finally either `finalResult` (== the
|
||||
/// unary [submit] response) or `error`. Works over native gRPC and,
|
||||
/// on web targets, gRPC-Web. Same inputs as [submit].
|
||||
///
|
||||
/// ```dart
|
||||
/// await for (final ev in hub.submitStreaming(flowYaml: yaml)) {
|
||||
/// if (ev.hasModuleEvent()) print('${ev.moduleEvent.name}');
|
||||
/// if (ev.hasFinalResult()) print(ev.finalResult.outputs);
|
||||
/// }
|
||||
/// ```
|
||||
Stream<SubmitStreamEvent> submitStreaming({
|
||||
required String flowYaml,
|
||||
Map<String, String> textInputs = const {},
|
||||
Map<String, Uint8List> fileInputs = const {},
|
||||
Map<String, Object?> jsonInputs = const {},
|
||||
Map<String, String> fileMimeTypes = const {},
|
||||
}) {
|
||||
return _hub.submitStream(_buildSubmitRequest(
|
||||
flowYaml: flowYaml,
|
||||
textInputs: textInputs,
|
||||
fileInputs: fileInputs,
|
||||
jsonInputs: jsonInputs,
|
||||
fileMimeTypes: fileMimeTypes,
|
||||
));
|
||||
}
|
||||
|
||||
/// Status of a detached invocation (T3). Throws a [GrpcError] with
|
||||
/// code `notFound` for an unknown id.
|
||||
Future<InvocationStatus> getInvocationStatus(String invocationId) {
|
||||
return _hub.getInvocationStatus(pb_common.InvocationId()..value = invocationId);
|
||||
}
|
||||
|
||||
/// Retained result of a succeeded detached invocation (T3). Throws
|
||||
/// `failedPrecondition` if it is still running / failed, `notFound`
|
||||
/// if unknown or already evicted.
|
||||
Future<SubmitResponse> getInvocationResult(String invocationId) {
|
||||
return _hub.getInvocationResult(pb_common.InvocationId()..value = invocationId);
|
||||
}
|
||||
|
||||
/// Cancel a running detached invocation (T3). Returns true if it was
|
||||
/// running and got signalled, false if already finished or unknown.
|
||||
Future<bool> cancelInvocation(String invocationId) async {
|
||||
final r =
|
||||
await _hub.cancelInvocation(pb_common.InvocationId()..value = invocationId);
|
||||
return r.cancelled;
|
||||
}
|
||||
|
||||
pb.SubmitRequest _buildSubmitRequest({
|
||||
required String flowYaml,
|
||||
required Map<String, String> textInputs,
|
||||
required Map<String, Uint8List> fileInputs,
|
||||
required Map<String, Object?> jsonInputs,
|
||||
required Map<String, String> fileMimeTypes,
|
||||
bool detach = false,
|
||||
}) {
|
||||
final req = pb.SubmitRequest()
|
||||
..flowYaml = utf8.encode(flowYaml)
|
||||
..detach = detach;
|
||||
final req = pb.SubmitRequest()..flowYaml = utf8.encode(flowYaml);
|
||||
for (final entry in textInputs.entries) {
|
||||
req.inputs[entry.key] = pb_common.Payload()..text = entry.value;
|
||||
}
|
||||
|
|
@ -878,7 +801,7 @@ class HubClient {
|
|||
}
|
||||
req.inputs[entry.key] = pb_common.Payload()..json = _structFromMap(value);
|
||||
}
|
||||
return req;
|
||||
return _hub.submit(req);
|
||||
}
|
||||
|
||||
/// Closes the gRPC channel. Idempotent.
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue