toki
6f36449daa
- Add edge connector module (edge.go, edge_registry.go, edge_server.go) - Add edge server tests (edge_server_test.go, edge_test.go) - Update control.proto with edge-related messages and RPCs - Generate proto files for Go, Dart - Update control-plane Dockerfile and configuration - Add client-side proto bindings - Update roadmap and milestones for control-plane-edge-wire-baseline - Add agent-task documentation for edge connector and local smoke tests - Update docker-compose.yml for edge support
624 lines
23 KiB
Dart
624 lines
23 KiB
Dart
// This is a generated file - do not edit.
|
|
//
|
|
// Generated from proto/iop/control.proto.
|
|
|
|
// @dart = 3.3
|
|
|
|
// ignore_for_file: annotate_overrides, camel_case_types, comment_references
|
|
// ignore_for_file: constant_identifier_names
|
|
// ignore_for_file: curly_braces_in_flow_control_structures
|
|
// ignore_for_file: deprecated_member_use_from_same_package, library_prefixes
|
|
// ignore_for_file: non_constant_identifier_names, prefer_relative_imports
|
|
|
|
import 'dart:core' as $core;
|
|
|
|
import 'package:fixnum/fixnum.dart' as $fixnum;
|
|
import 'package:protobuf/protobuf.dart' as $pb;
|
|
|
|
export 'package:protobuf/protobuf.dart' show GeneratedMessageGenericExtensions;
|
|
|
|
/// PolicyRule is a placeholder for future edge-level routing/resource constraints.
|
|
class PolicyRule extends $pb.GeneratedMessage {
|
|
factory PolicyRule({
|
|
$core.String? name,
|
|
$core.String? expression,
|
|
$core.Iterable<$core.MapEntry<$core.String, $core.String>>? params,
|
|
}) {
|
|
final result = create();
|
|
if (name != null) result.name = name;
|
|
if (expression != null) result.expression = expression;
|
|
if (params != null) result.params.addEntries(params);
|
|
return result;
|
|
}
|
|
|
|
PolicyRule._();
|
|
|
|
factory PolicyRule.fromBuffer($core.List<$core.int> data,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromBuffer(data, registry);
|
|
factory PolicyRule.fromJson($core.String json,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromJson(json, registry);
|
|
|
|
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
|
_omitMessageNames ? '' : 'PolicyRule',
|
|
package: const $pb.PackageName(_omitMessageNames ? '' : 'iop'),
|
|
createEmptyInstance: create)
|
|
..aOS(1, _omitFieldNames ? '' : 'name')
|
|
..aOS(2, _omitFieldNames ? '' : 'expression')
|
|
..m<$core.String, $core.String>(3, _omitFieldNames ? '' : 'params',
|
|
entryClassName: 'PolicyRule.ParamsEntry',
|
|
keyFieldType: $pb.PbFieldType.OS,
|
|
valueFieldType: $pb.PbFieldType.OS,
|
|
packageName: const $pb.PackageName('iop'))
|
|
..hasRequiredFields = false;
|
|
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
PolicyRule clone() => deepCopy();
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
PolicyRule copyWith(void Function(PolicyRule) updates) =>
|
|
super.copyWith((message) => updates(message as PolicyRule)) as PolicyRule;
|
|
|
|
@$core.override
|
|
$pb.BuilderInfo get info_ => _i;
|
|
|
|
@$core.pragma('dart2js:noInline')
|
|
static PolicyRule create() => PolicyRule._();
|
|
@$core.override
|
|
PolicyRule createEmptyInstance() => create();
|
|
@$core.pragma('dart2js:noInline')
|
|
static PolicyRule getDefault() => _defaultInstance ??=
|
|
$pb.GeneratedMessage.$_defaultFor<PolicyRule>(create);
|
|
static PolicyRule? _defaultInstance;
|
|
|
|
@$pb.TagNumber(1)
|
|
$core.String get name => $_getSZ(0);
|
|
@$pb.TagNumber(1)
|
|
set name($core.String value) => $_setString(0, value);
|
|
@$pb.TagNumber(1)
|
|
$core.bool hasName() => $_has(0);
|
|
@$pb.TagNumber(1)
|
|
void clearName() => $_clearField(1);
|
|
|
|
@$pb.TagNumber(2)
|
|
$core.String get expression => $_getSZ(1);
|
|
@$pb.TagNumber(2)
|
|
set expression($core.String value) => $_setString(1, value);
|
|
@$pb.TagNumber(2)
|
|
$core.bool hasExpression() => $_has(1);
|
|
@$pb.TagNumber(2)
|
|
void clearExpression() => $_clearField(2);
|
|
|
|
@$pb.TagNumber(3)
|
|
$pb.PbMap<$core.String, $core.String> get params => $_getMap(2);
|
|
}
|
|
|
|
/// ScheduleRequest is a legacy placeholder for future Control Plane orchestration.
|
|
/// It must not be treated as an active contract for direct Node scheduling.
|
|
class ScheduleRequest extends $pb.GeneratedMessage {
|
|
factory ScheduleRequest({
|
|
$core.String? jobId,
|
|
$core.String? target,
|
|
$core.Iterable<PolicyRule>? policies,
|
|
$core.Iterable<$core.MapEntry<$core.String, $core.String>>? metadata,
|
|
}) {
|
|
final result = create();
|
|
if (jobId != null) result.jobId = jobId;
|
|
if (target != null) result.target = target;
|
|
if (policies != null) result.policies.addAll(policies);
|
|
if (metadata != null) result.metadata.addEntries(metadata);
|
|
return result;
|
|
}
|
|
|
|
ScheduleRequest._();
|
|
|
|
factory ScheduleRequest.fromBuffer($core.List<$core.int> data,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromBuffer(data, registry);
|
|
factory ScheduleRequest.fromJson($core.String json,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromJson(json, registry);
|
|
|
|
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
|
_omitMessageNames ? '' : 'ScheduleRequest',
|
|
package: const $pb.PackageName(_omitMessageNames ? '' : 'iop'),
|
|
createEmptyInstance: create)
|
|
..aOS(1, _omitFieldNames ? '' : 'jobId')
|
|
..aOS(2, _omitFieldNames ? '' : 'target')
|
|
..pPM<PolicyRule>(3, _omitFieldNames ? '' : 'policies',
|
|
subBuilder: PolicyRule.create)
|
|
..m<$core.String, $core.String>(4, _omitFieldNames ? '' : 'metadata',
|
|
entryClassName: 'ScheduleRequest.MetadataEntry',
|
|
keyFieldType: $pb.PbFieldType.OS,
|
|
valueFieldType: $pb.PbFieldType.OS,
|
|
packageName: const $pb.PackageName('iop'))
|
|
..hasRequiredFields = false;
|
|
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
ScheduleRequest clone() => deepCopy();
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
ScheduleRequest copyWith(void Function(ScheduleRequest) updates) =>
|
|
super.copyWith((message) => updates(message as ScheduleRequest))
|
|
as ScheduleRequest;
|
|
|
|
@$core.override
|
|
$pb.BuilderInfo get info_ => _i;
|
|
|
|
@$core.pragma('dart2js:noInline')
|
|
static ScheduleRequest create() => ScheduleRequest._();
|
|
@$core.override
|
|
ScheduleRequest createEmptyInstance() => create();
|
|
@$core.pragma('dart2js:noInline')
|
|
static ScheduleRequest getDefault() => _defaultInstance ??=
|
|
$pb.GeneratedMessage.$_defaultFor<ScheduleRequest>(create);
|
|
static ScheduleRequest? _defaultInstance;
|
|
|
|
@$pb.TagNumber(1)
|
|
$core.String get jobId => $_getSZ(0);
|
|
@$pb.TagNumber(1)
|
|
set jobId($core.String value) => $_setString(0, value);
|
|
@$pb.TagNumber(1)
|
|
$core.bool hasJobId() => $_has(0);
|
|
@$pb.TagNumber(1)
|
|
void clearJobId() => $_clearField(1);
|
|
|
|
@$pb.TagNumber(2)
|
|
$core.String get target => $_getSZ(1);
|
|
@$pb.TagNumber(2)
|
|
set target($core.String value) => $_setString(1, value);
|
|
@$pb.TagNumber(2)
|
|
$core.bool hasTarget() => $_has(1);
|
|
@$pb.TagNumber(2)
|
|
void clearTarget() => $_clearField(2);
|
|
|
|
@$pb.TagNumber(3)
|
|
$pb.PbList<PolicyRule> get policies => $_getList(2);
|
|
|
|
@$pb.TagNumber(4)
|
|
$pb.PbMap<$core.String, $core.String> get metadata => $_getMap(3);
|
|
}
|
|
|
|
/// ScheduleResponse is a legacy placeholder. Future scheduling should be
|
|
/// reworked around Edge-owned runtime state instead of bypassing Edge.
|
|
class ScheduleResponse extends $pb.GeneratedMessage {
|
|
factory ScheduleResponse({
|
|
$core.String? nodeId,
|
|
$core.String? address,
|
|
$core.String? token,
|
|
}) {
|
|
final result = create();
|
|
if (nodeId != null) result.nodeId = nodeId;
|
|
if (address != null) result.address = address;
|
|
if (token != null) result.token = token;
|
|
return result;
|
|
}
|
|
|
|
ScheduleResponse._();
|
|
|
|
factory ScheduleResponse.fromBuffer($core.List<$core.int> data,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromBuffer(data, registry);
|
|
factory ScheduleResponse.fromJson($core.String json,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromJson(json, registry);
|
|
|
|
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
|
_omitMessageNames ? '' : 'ScheduleResponse',
|
|
package: const $pb.PackageName(_omitMessageNames ? '' : 'iop'),
|
|
createEmptyInstance: create)
|
|
..aOS(1, _omitFieldNames ? '' : 'nodeId')
|
|
..aOS(2, _omitFieldNames ? '' : 'address')
|
|
..aOS(3, _omitFieldNames ? '' : 'token')
|
|
..hasRequiredFields = false;
|
|
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
ScheduleResponse clone() => deepCopy();
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
ScheduleResponse copyWith(void Function(ScheduleResponse) updates) =>
|
|
super.copyWith((message) => updates(message as ScheduleResponse))
|
|
as ScheduleResponse;
|
|
|
|
@$core.override
|
|
$pb.BuilderInfo get info_ => _i;
|
|
|
|
@$core.pragma('dart2js:noInline')
|
|
static ScheduleResponse create() => ScheduleResponse._();
|
|
@$core.override
|
|
ScheduleResponse createEmptyInstance() => create();
|
|
@$core.pragma('dart2js:noInline')
|
|
static ScheduleResponse getDefault() => _defaultInstance ??=
|
|
$pb.GeneratedMessage.$_defaultFor<ScheduleResponse>(create);
|
|
static ScheduleResponse? _defaultInstance;
|
|
|
|
@$pb.TagNumber(1)
|
|
$core.String get nodeId => $_getSZ(0);
|
|
@$pb.TagNumber(1)
|
|
set nodeId($core.String value) => $_setString(0, value);
|
|
@$pb.TagNumber(1)
|
|
$core.bool hasNodeId() => $_has(0);
|
|
@$pb.TagNumber(1)
|
|
void clearNodeId() => $_clearField(1);
|
|
|
|
@$pb.TagNumber(2)
|
|
$core.String get address => $_getSZ(1);
|
|
@$pb.TagNumber(2)
|
|
set address($core.String value) => $_setString(1, value);
|
|
@$pb.TagNumber(2)
|
|
$core.bool hasAddress() => $_has(1);
|
|
@$pb.TagNumber(2)
|
|
void clearAddress() => $_clearField(2);
|
|
|
|
@$pb.TagNumber(3)
|
|
$core.String get token => $_getSZ(2);
|
|
@$pb.TagNumber(3)
|
|
set token($core.String value) => $_setString(2, value);
|
|
@$pb.TagNumber(3)
|
|
$core.bool hasToken() => $_has(2);
|
|
@$pb.TagNumber(3)
|
|
void clearToken() => $_clearField(3);
|
|
}
|
|
|
|
class ClientHelloRequest extends $pb.GeneratedMessage {
|
|
factory ClientHelloRequest({
|
|
$core.String? clientId,
|
|
$core.String? clientVersion,
|
|
}) {
|
|
final result = create();
|
|
if (clientId != null) result.clientId = clientId;
|
|
if (clientVersion != null) result.clientVersion = clientVersion;
|
|
return result;
|
|
}
|
|
|
|
ClientHelloRequest._();
|
|
|
|
factory ClientHelloRequest.fromBuffer($core.List<$core.int> data,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromBuffer(data, registry);
|
|
factory ClientHelloRequest.fromJson($core.String json,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromJson(json, registry);
|
|
|
|
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
|
_omitMessageNames ? '' : 'ClientHelloRequest',
|
|
package: const $pb.PackageName(_omitMessageNames ? '' : 'iop'),
|
|
createEmptyInstance: create)
|
|
..aOS(1, _omitFieldNames ? '' : 'clientId')
|
|
..aOS(2, _omitFieldNames ? '' : 'clientVersion')
|
|
..hasRequiredFields = false;
|
|
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
ClientHelloRequest clone() => deepCopy();
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
ClientHelloRequest copyWith(void Function(ClientHelloRequest) updates) =>
|
|
super.copyWith((message) => updates(message as ClientHelloRequest))
|
|
as ClientHelloRequest;
|
|
|
|
@$core.override
|
|
$pb.BuilderInfo get info_ => _i;
|
|
|
|
@$core.pragma('dart2js:noInline')
|
|
static ClientHelloRequest create() => ClientHelloRequest._();
|
|
@$core.override
|
|
ClientHelloRequest createEmptyInstance() => create();
|
|
@$core.pragma('dart2js:noInline')
|
|
static ClientHelloRequest getDefault() => _defaultInstance ??=
|
|
$pb.GeneratedMessage.$_defaultFor<ClientHelloRequest>(create);
|
|
static ClientHelloRequest? _defaultInstance;
|
|
|
|
@$pb.TagNumber(1)
|
|
$core.String get clientId => $_getSZ(0);
|
|
@$pb.TagNumber(1)
|
|
set clientId($core.String value) => $_setString(0, value);
|
|
@$pb.TagNumber(1)
|
|
$core.bool hasClientId() => $_has(0);
|
|
@$pb.TagNumber(1)
|
|
void clearClientId() => $_clearField(1);
|
|
|
|
@$pb.TagNumber(2)
|
|
$core.String get clientVersion => $_getSZ(1);
|
|
@$pb.TagNumber(2)
|
|
set clientVersion($core.String value) => $_setString(1, value);
|
|
@$pb.TagNumber(2)
|
|
$core.bool hasClientVersion() => $_has(1);
|
|
@$pb.TagNumber(2)
|
|
void clearClientVersion() => $_clearField(2);
|
|
}
|
|
|
|
class ClientHelloResponse extends $pb.GeneratedMessage {
|
|
factory ClientHelloResponse({
|
|
$core.bool? ready,
|
|
$core.String? protocol,
|
|
$fixnum.Int64? serverTimeUnixNano,
|
|
$core.String? message,
|
|
}) {
|
|
final result = create();
|
|
if (ready != null) result.ready = ready;
|
|
if (protocol != null) result.protocol = protocol;
|
|
if (serverTimeUnixNano != null)
|
|
result.serverTimeUnixNano = serverTimeUnixNano;
|
|
if (message != null) result.message = message;
|
|
return result;
|
|
}
|
|
|
|
ClientHelloResponse._();
|
|
|
|
factory ClientHelloResponse.fromBuffer($core.List<$core.int> data,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromBuffer(data, registry);
|
|
factory ClientHelloResponse.fromJson($core.String json,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromJson(json, registry);
|
|
|
|
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
|
_omitMessageNames ? '' : 'ClientHelloResponse',
|
|
package: const $pb.PackageName(_omitMessageNames ? '' : 'iop'),
|
|
createEmptyInstance: create)
|
|
..aOB(1, _omitFieldNames ? '' : 'ready')
|
|
..aOS(2, _omitFieldNames ? '' : 'protocol')
|
|
..aInt64(3, _omitFieldNames ? '' : 'serverTimeUnixNano')
|
|
..aOS(4, _omitFieldNames ? '' : 'message')
|
|
..hasRequiredFields = false;
|
|
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
ClientHelloResponse clone() => deepCopy();
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
ClientHelloResponse copyWith(void Function(ClientHelloResponse) updates) =>
|
|
super.copyWith((message) => updates(message as ClientHelloResponse))
|
|
as ClientHelloResponse;
|
|
|
|
@$core.override
|
|
$pb.BuilderInfo get info_ => _i;
|
|
|
|
@$core.pragma('dart2js:noInline')
|
|
static ClientHelloResponse create() => ClientHelloResponse._();
|
|
@$core.override
|
|
ClientHelloResponse createEmptyInstance() => create();
|
|
@$core.pragma('dart2js:noInline')
|
|
static ClientHelloResponse getDefault() => _defaultInstance ??=
|
|
$pb.GeneratedMessage.$_defaultFor<ClientHelloResponse>(create);
|
|
static ClientHelloResponse? _defaultInstance;
|
|
|
|
@$pb.TagNumber(1)
|
|
$core.bool get ready => $_getBF(0);
|
|
@$pb.TagNumber(1)
|
|
set ready($core.bool value) => $_setBool(0, value);
|
|
@$pb.TagNumber(1)
|
|
$core.bool hasReady() => $_has(0);
|
|
@$pb.TagNumber(1)
|
|
void clearReady() => $_clearField(1);
|
|
|
|
@$pb.TagNumber(2)
|
|
$core.String get protocol => $_getSZ(1);
|
|
@$pb.TagNumber(2)
|
|
set protocol($core.String value) => $_setString(1, value);
|
|
@$pb.TagNumber(2)
|
|
$core.bool hasProtocol() => $_has(1);
|
|
@$pb.TagNumber(2)
|
|
void clearProtocol() => $_clearField(2);
|
|
|
|
@$pb.TagNumber(3)
|
|
$fixnum.Int64 get serverTimeUnixNano => $_getI64(2);
|
|
@$pb.TagNumber(3)
|
|
set serverTimeUnixNano($fixnum.Int64 value) => $_setInt64(2, value);
|
|
@$pb.TagNumber(3)
|
|
$core.bool hasServerTimeUnixNano() => $_has(2);
|
|
@$pb.TagNumber(3)
|
|
void clearServerTimeUnixNano() => $_clearField(3);
|
|
|
|
@$pb.TagNumber(4)
|
|
$core.String get message => $_getSZ(3);
|
|
@$pb.TagNumber(4)
|
|
set message($core.String value) => $_setString(3, value);
|
|
@$pb.TagNumber(4)
|
|
$core.bool hasMessage() => $_has(3);
|
|
@$pb.TagNumber(4)
|
|
void clearMessage() => $_clearField(4);
|
|
}
|
|
|
|
/// EdgeHelloRequest is sent by Edge to Control Plane immediately after a
|
|
/// Control Plane-Edge wire connection is established. It describes the Edge
|
|
/// itself and must not become a direct Node registration or scheduling contract.
|
|
class EdgeHelloRequest extends $pb.GeneratedMessage {
|
|
factory EdgeHelloRequest({
|
|
$core.String? edgeId,
|
|
$core.String? edgeName,
|
|
$core.String? version,
|
|
$core.Iterable<$core.String>? capabilities,
|
|
$core.Iterable<$core.MapEntry<$core.String, $core.String>>? metadata,
|
|
}) {
|
|
final result = create();
|
|
if (edgeId != null) result.edgeId = edgeId;
|
|
if (edgeName != null) result.edgeName = edgeName;
|
|
if (version != null) result.version = version;
|
|
if (capabilities != null) result.capabilities.addAll(capabilities);
|
|
if (metadata != null) result.metadata.addEntries(metadata);
|
|
return result;
|
|
}
|
|
|
|
EdgeHelloRequest._();
|
|
|
|
factory EdgeHelloRequest.fromBuffer($core.List<$core.int> data,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromBuffer(data, registry);
|
|
factory EdgeHelloRequest.fromJson($core.String json,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromJson(json, registry);
|
|
|
|
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
|
_omitMessageNames ? '' : 'EdgeHelloRequest',
|
|
package: const $pb.PackageName(_omitMessageNames ? '' : 'iop'),
|
|
createEmptyInstance: create)
|
|
..aOS(1, _omitFieldNames ? '' : 'edgeId')
|
|
..aOS(2, _omitFieldNames ? '' : 'edgeName')
|
|
..aOS(3, _omitFieldNames ? '' : 'version')
|
|
..pPS(4, _omitFieldNames ? '' : 'capabilities')
|
|
..m<$core.String, $core.String>(5, _omitFieldNames ? '' : 'metadata',
|
|
entryClassName: 'EdgeHelloRequest.MetadataEntry',
|
|
keyFieldType: $pb.PbFieldType.OS,
|
|
valueFieldType: $pb.PbFieldType.OS,
|
|
packageName: const $pb.PackageName('iop'))
|
|
..hasRequiredFields = false;
|
|
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
EdgeHelloRequest clone() => deepCopy();
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
EdgeHelloRequest copyWith(void Function(EdgeHelloRequest) updates) =>
|
|
super.copyWith((message) => updates(message as EdgeHelloRequest))
|
|
as EdgeHelloRequest;
|
|
|
|
@$core.override
|
|
$pb.BuilderInfo get info_ => _i;
|
|
|
|
@$core.pragma('dart2js:noInline')
|
|
static EdgeHelloRequest create() => EdgeHelloRequest._();
|
|
@$core.override
|
|
EdgeHelloRequest createEmptyInstance() => create();
|
|
@$core.pragma('dart2js:noInline')
|
|
static EdgeHelloRequest getDefault() => _defaultInstance ??=
|
|
$pb.GeneratedMessage.$_defaultFor<EdgeHelloRequest>(create);
|
|
static EdgeHelloRequest? _defaultInstance;
|
|
|
|
@$pb.TagNumber(1)
|
|
$core.String get edgeId => $_getSZ(0);
|
|
@$pb.TagNumber(1)
|
|
set edgeId($core.String value) => $_setString(0, value);
|
|
@$pb.TagNumber(1)
|
|
$core.bool hasEdgeId() => $_has(0);
|
|
@$pb.TagNumber(1)
|
|
void clearEdgeId() => $_clearField(1);
|
|
|
|
@$pb.TagNumber(2)
|
|
$core.String get edgeName => $_getSZ(1);
|
|
@$pb.TagNumber(2)
|
|
set edgeName($core.String value) => $_setString(1, value);
|
|
@$pb.TagNumber(2)
|
|
$core.bool hasEdgeName() => $_has(1);
|
|
@$pb.TagNumber(2)
|
|
void clearEdgeName() => $_clearField(2);
|
|
|
|
@$pb.TagNumber(3)
|
|
$core.String get version => $_getSZ(2);
|
|
@$pb.TagNumber(3)
|
|
set version($core.String value) => $_setString(2, value);
|
|
@$pb.TagNumber(3)
|
|
$core.bool hasVersion() => $_has(2);
|
|
@$pb.TagNumber(3)
|
|
void clearVersion() => $_clearField(3);
|
|
|
|
@$pb.TagNumber(4)
|
|
$pb.PbList<$core.String> get capabilities => $_getList(3);
|
|
|
|
@$pb.TagNumber(5)
|
|
$pb.PbMap<$core.String, $core.String> get metadata => $_getMap(4);
|
|
}
|
|
|
|
/// EdgeHelloResponse acknowledges Edge enrollment on the Control Plane-Edge
|
|
/// wire. Rejection details stay at the Edge boundary rather than exposing Node
|
|
/// scheduling decisions.
|
|
class EdgeHelloResponse extends $pb.GeneratedMessage {
|
|
factory EdgeHelloResponse({
|
|
$core.bool? accepted,
|
|
$core.String? protocol,
|
|
$fixnum.Int64? serverTimeUnixNano,
|
|
$core.String? message,
|
|
$core.String? reason,
|
|
}) {
|
|
final result = create();
|
|
if (accepted != null) result.accepted = accepted;
|
|
if (protocol != null) result.protocol = protocol;
|
|
if (serverTimeUnixNano != null)
|
|
result.serverTimeUnixNano = serverTimeUnixNano;
|
|
if (message != null) result.message = message;
|
|
if (reason != null) result.reason = reason;
|
|
return result;
|
|
}
|
|
|
|
EdgeHelloResponse._();
|
|
|
|
factory EdgeHelloResponse.fromBuffer($core.List<$core.int> data,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromBuffer(data, registry);
|
|
factory EdgeHelloResponse.fromJson($core.String json,
|
|
[$pb.ExtensionRegistry registry = $pb.ExtensionRegistry.EMPTY]) =>
|
|
create()..mergeFromJson(json, registry);
|
|
|
|
static final $pb.BuilderInfo _i = $pb.BuilderInfo(
|
|
_omitMessageNames ? '' : 'EdgeHelloResponse',
|
|
package: const $pb.PackageName(_omitMessageNames ? '' : 'iop'),
|
|
createEmptyInstance: create)
|
|
..aOB(1, _omitFieldNames ? '' : 'accepted')
|
|
..aOS(2, _omitFieldNames ? '' : 'protocol')
|
|
..aInt64(3, _omitFieldNames ? '' : 'serverTimeUnixNano')
|
|
..aOS(4, _omitFieldNames ? '' : 'message')
|
|
..aOS(5, _omitFieldNames ? '' : 'reason')
|
|
..hasRequiredFields = false;
|
|
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
EdgeHelloResponse clone() => deepCopy();
|
|
@$core.Deprecated('See https://github.com/google/protobuf.dart/issues/998.')
|
|
EdgeHelloResponse copyWith(void Function(EdgeHelloResponse) updates) =>
|
|
super.copyWith((message) => updates(message as EdgeHelloResponse))
|
|
as EdgeHelloResponse;
|
|
|
|
@$core.override
|
|
$pb.BuilderInfo get info_ => _i;
|
|
|
|
@$core.pragma('dart2js:noInline')
|
|
static EdgeHelloResponse create() => EdgeHelloResponse._();
|
|
@$core.override
|
|
EdgeHelloResponse createEmptyInstance() => create();
|
|
@$core.pragma('dart2js:noInline')
|
|
static EdgeHelloResponse getDefault() => _defaultInstance ??=
|
|
$pb.GeneratedMessage.$_defaultFor<EdgeHelloResponse>(create);
|
|
static EdgeHelloResponse? _defaultInstance;
|
|
|
|
@$pb.TagNumber(1)
|
|
$core.bool get accepted => $_getBF(0);
|
|
@$pb.TagNumber(1)
|
|
set accepted($core.bool value) => $_setBool(0, value);
|
|
@$pb.TagNumber(1)
|
|
$core.bool hasAccepted() => $_has(0);
|
|
@$pb.TagNumber(1)
|
|
void clearAccepted() => $_clearField(1);
|
|
|
|
@$pb.TagNumber(2)
|
|
$core.String get protocol => $_getSZ(1);
|
|
@$pb.TagNumber(2)
|
|
set protocol($core.String value) => $_setString(1, value);
|
|
@$pb.TagNumber(2)
|
|
$core.bool hasProtocol() => $_has(1);
|
|
@$pb.TagNumber(2)
|
|
void clearProtocol() => $_clearField(2);
|
|
|
|
@$pb.TagNumber(3)
|
|
$fixnum.Int64 get serverTimeUnixNano => $_getI64(2);
|
|
@$pb.TagNumber(3)
|
|
set serverTimeUnixNano($fixnum.Int64 value) => $_setInt64(2, value);
|
|
@$pb.TagNumber(3)
|
|
$core.bool hasServerTimeUnixNano() => $_has(2);
|
|
@$pb.TagNumber(3)
|
|
void clearServerTimeUnixNano() => $_clearField(3);
|
|
|
|
@$pb.TagNumber(4)
|
|
$core.String get message => $_getSZ(3);
|
|
@$pb.TagNumber(4)
|
|
set message($core.String value) => $_setString(3, value);
|
|
@$pb.TagNumber(4)
|
|
$core.bool hasMessage() => $_has(3);
|
|
@$pb.TagNumber(4)
|
|
void clearMessage() => $_clearField(4);
|
|
|
|
@$pb.TagNumber(5)
|
|
$core.String get reason => $_getSZ(4);
|
|
@$pb.TagNumber(5)
|
|
set reason($core.String value) => $_setString(4, value);
|
|
@$pb.TagNumber(5)
|
|
$core.bool hasReason() => $_has(4);
|
|
@$pb.TagNumber(5)
|
|
void clearReason() => $_clearField(5);
|
|
}
|
|
|
|
const $core.bool _omitFieldNames =
|
|
$core.bool.fromEnvironment('protobuf.omit_field_names');
|
|
const $core.bool _omitMessageNames =
|
|
$core.bool.fromEnvironment('protobuf.omit_message_names');
|