diff --git a/docs/evidence/saas-dispatcher-implementation.md b/docs/evidence/saas-dispatcher-implementation.md index 5f177c4..34ae0f6 100644 --- a/docs/evidence/saas-dispatcher-implementation.md +++ b/docs/evidence/saas-dispatcher-implementation.md @@ -121,6 +121,7 @@ - Agent 旧静态制品入口：现行命令从未提供 `StaticArtifactRaw/Expected`，旧激活分支及只服务于旧 `static-cell-artifact-v0.2` Schema 的手写解析器无法证明 Asterisk 实际加载。结构测试先复现残留，再移除旧 RPC 参数、解析器与专属测试；保留当前隔离 Mock 的 `LoadedSIP` revision 回报及 Dispatcher SIP 版本准入校验。此变更不等于真实 Agent/Asterisk 已加载或管理平台已审批，历史 Schema/来源事实另行辨析。 - Agent 旧 spool 准入边界：隔离测试先复现现行 Agent 对同一恢复根目录中旧 `.uploads`、`.upload-locks` 与逐执行 `state.json` 均会照常启动；现于创建会话和媒体状态前只读检查这些遗留标记，发现时明确拒绝启动并保留原文件。测试核实没有写新会话、没有修改标记；仅对配置的恢复根目录生效，不替代现存数据的人工核查或处置。 - Agent 旧 spool 代码：旧执行状态、实时事件、上传尝试、失败事实及上传锁只由旧模块彼此调用，没有现行命令或录音恢复调用；删除专属实现与测试。录音恢复仍复用的原子写、目录同步、文件名校验等小函数移至 `internal/agent/file_state.go`，通过现行录音重试/未知结果测试确认恢复能力保持。删除源码不删除任何磁盘 spool；旧文件在当前恢复根目录触发上述拒绝启动，不能视作已经补传或处置。 +- Agent Proto 旧消息：先用描述符结构测试复现 `ConfigReference` 等废弃定义仍可被发现，再按当前八个服务方法及现行 Go 引用追踪字段依赖；删除无调用者的 26 个旧消息和 3 个旧枚举，不改现行请求/响应的字段号。使用本地 Buf 重新生成 Go 类型，核对七项来源/hash；现行录音客户端、获批执行、控制及会话测试保持通过。固定 `agent.v1` 仍是有效的内部协议值；这不构成真实 Agent/Asterisk 或外部 SaaS 验收。 ## 验收台账 diff --git a/gen/agent/agent.pb.go b/gen/agent/agent.pb.go index 729e1f7..9de7c68 100644 --- a/gen/agent/agent.pb.go +++ b/gen/agent/agent.pb.go @@ -363,67 +363,6 @@ func (ActiveCallPolicy) EnumDescriptor() ([]byte, []int) { return file_agent_agent_proto_rawDescGZIP(), []int{5} } -type ExecutionState int32 - -const ( - ExecutionState_EXECUTION_STATE_UNSPECIFIED ExecutionState = 0 - ExecutionState_EXECUTION_STATE_PREPARED ExecutionState = 1 - ExecutionState_EXECUTION_STATE_PERMIT_GRANTED ExecutionState = 2 - ExecutionState_EXECUTION_STATE_DISPATCHING ExecutionState = 3 - ExecutionState_EXECUTION_STATE_OBSERVED ExecutionState = 4 - ExecutionState_EXECUTION_STATE_UNKNOWN ExecutionState = 5 - ExecutionState_EXECUTION_STATE_TERMINAL ExecutionState = 6 -) - -// Enum value maps for ExecutionState. -var ( - ExecutionState_name = map[int32]string{ - 0: "EXECUTION_STATE_UNSPECIFIED", - 1: "EXECUTION_STATE_PREPARED", - 2: "EXECUTION_STATE_PERMIT_GRANTED", - 3: "EXECUTION_STATE_DISPATCHING", - 4: "EXECUTION_STATE_OBSERVED", - 5: "EXECUTION_STATE_UNKNOWN", - 6: "EXECUTION_STATE_TERMINAL", - } - ExecutionState_value = map[string]int32{ - "EXECUTION_STATE_UNSPECIFIED": 0, - "EXECUTION_STATE_PREPARED": 1, - "EXECUTION_STATE_PERMIT_GRANTED": 2, - "EXECUTION_STATE_DISPATCHING": 3, - "EXECUTION_STATE_OBSERVED": 4, - "EXECUTION_STATE_UNKNOWN": 5, - "EXECUTION_STATE_TERMINAL": 6, - } -) - -func (x ExecutionState) Enum() *ExecutionState { - p := new(ExecutionState) - *p = x - return p -} - -func (x ExecutionState) String() string { - return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) -} - -func (ExecutionState) Descriptor() protoreflect.EnumDescriptor { - return file_agent_agent_proto_enumTypes[6].Descriptor() -} - -func (ExecutionState) Type() protoreflect.EnumType { - return &file_agent_agent_proto_enumTypes[6] -} - -func (x ExecutionState) Number() protoreflect.EnumNumber { - return protoreflect.EnumNumber(x) -} - -// Deprecated: Use ExecutionState.Descriptor instead. -func (ExecutionState) EnumDescriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{6} -} - type AssetKind int32 const ( @@ -457,11 +396,11 @@ func (x AssetKind) String() string { } func (AssetKind) Descriptor() protoreflect.EnumDescriptor { - return file_agent_agent_proto_enumTypes[7].Descriptor() + return file_agent_agent_proto_enumTypes[6].Descriptor() } func (AssetKind) Type() protoreflect.EnumType { - return &file_agent_agent_proto_enumTypes[7] + return &file_agent_agent_proto_enumTypes[6] } func (x AssetKind) Number() protoreflect.EnumNumber { @@ -470,123 +409,7 @@ func (x AssetKind) Number() protoreflect.EnumNumber { // Deprecated: Use AssetKind.Descriptor instead. func (AssetKind) EnumDescriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{7} -} - -type UploadState int32 - -const ( - UploadState_UPLOAD_STATE_UNSPECIFIED UploadState = 0 - UploadState_UPLOAD_STATE_REQUESTED UploadState = 1 - UploadState_UPLOAD_STATE_COMPLETED UploadState = 3 - UploadState_UPLOAD_STATE_FAILED UploadState = 4 -) - -// Enum value maps for UploadState. -var ( - UploadState_name = map[int32]string{ - 0: "UPLOAD_STATE_UNSPECIFIED", - 1: "UPLOAD_STATE_REQUESTED", - 3: "UPLOAD_STATE_COMPLETED", - 4: "UPLOAD_STATE_FAILED", - } - UploadState_value = map[string]int32{ - "UPLOAD_STATE_UNSPECIFIED": 0, - "UPLOAD_STATE_REQUESTED": 1, - "UPLOAD_STATE_COMPLETED": 3, - "UPLOAD_STATE_FAILED": 4, - } -) - -func (x UploadState) Enum() *UploadState { - p := new(UploadState) - *p = x - return p -} - -func (x UploadState) String() string { - return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) -} - -func (UploadState) Descriptor() protoreflect.EnumDescriptor { - return file_agent_agent_proto_enumTypes[8].Descriptor() -} - -func (UploadState) Type() protoreflect.EnumType { - return &file_agent_agent_proto_enumTypes[8] -} - -func (x UploadState) Number() protoreflect.EnumNumber { - return protoreflect.EnumNumber(x) -} - -// Deprecated: Use UploadState.Descriptor instead. -func (UploadState) EnumDescriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{8} -} - -type FactKind int32 - -const ( - FactKind_FACT_KIND_UNSPECIFIED FactKind = 0 - FactKind_FACT_KIND_EXECUTION_ACCEPTED FactKind = 1 - FactKind_FACT_KIND_CALL_STATUS FactKind = 2 - FactKind_FACT_KIND_CALL_FINISHED FactKind = 3 - FactKind_FACT_KIND_TRANSCRIPT_UPDATED FactKind = 4 - FactKind_FACT_KIND_TRANSCRIPT_FAILED FactKind = 5 - FactKind_FACT_KIND_CONTACT_OPT_OUT FactKind = 6 - FactKind_FACT_KIND_RECORDING_PROGRESS FactKind = 7 -) - -// Enum value maps for FactKind. -var ( - FactKind_name = map[int32]string{ - 0: "FACT_KIND_UNSPECIFIED", - 1: "FACT_KIND_EXECUTION_ACCEPTED", - 2: "FACT_KIND_CALL_STATUS", - 3: "FACT_KIND_CALL_FINISHED", - 4: "FACT_KIND_TRANSCRIPT_UPDATED", - 5: "FACT_KIND_TRANSCRIPT_FAILED", - 6: "FACT_KIND_CONTACT_OPT_OUT", - 7: "FACT_KIND_RECORDING_PROGRESS", - } - FactKind_value = map[string]int32{ - "FACT_KIND_UNSPECIFIED": 0, - "FACT_KIND_EXECUTION_ACCEPTED": 1, - "FACT_KIND_CALL_STATUS": 2, - "FACT_KIND_CALL_FINISHED": 3, - "FACT_KIND_TRANSCRIPT_UPDATED": 4, - "FACT_KIND_TRANSCRIPT_FAILED": 5, - "FACT_KIND_CONTACT_OPT_OUT": 6, - "FACT_KIND_RECORDING_PROGRESS": 7, - } -) - -func (x FactKind) Enum() *FactKind { - p := new(FactKind) - *p = x - return p -} - -func (x FactKind) String() string { - return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) -} - -func (FactKind) Descriptor() protoreflect.EnumDescriptor { - return file_agent_agent_proto_enumTypes[9].Descriptor() -} - -func (FactKind) Type() protoreflect.EnumType { - return &file_agent_agent_proto_enumTypes[9] -} - -func (x FactKind) Number() protoreflect.EnumNumber { - return protoreflect.EnumNumber(x) -} - -// Deprecated: Use FactKind.Descriptor instead. -func (FactKind) EnumDescriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{9} + return file_agent_agent_proto_rawDescGZIP(), []int{6} } type RequestMeta struct { @@ -1257,10 +1080,9 @@ func (x *ResourceSample) GetMissingReason() string { return "" } -// Project-local v0.1 status convention: exactly one kind="sip" entry identifies -// the SIP artifact loaded by the Agent/Asterisk; state="applied" means that exact -// artifact is active. revision and config_sha256 must match the approved artifact. -// Missing, duplicate, or mismatched SIP entries are unknown and fail closed. +// Optional status metadata is not an admission grant. The Dispatcher checks +// GetLoadedSIP revisions separately; a Mock status cannot prove Asterisk loaded +// the approved configuration. type AppliedConfig struct { state protoimpl.MessageState `protogen:"open.v1"` Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"` @@ -1545,258 +1367,6 @@ func (x *Session) GetSessionCredential() []byte { return nil } -type ConfigReference struct { - state protoimpl.MessageState `protogen:"open.v1"` - Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"` - Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` - Sha256 string `protobuf:"bytes,3,opt,name=sha256,proto3" json:"sha256,omitempty"` - Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ConfigReference) Reset() { - *x = ConfigReference{} - mi := &file_agent_agent_proto_msgTypes[10] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ConfigReference) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ConfigReference) ProtoMessage() {} - -func (x *ConfigReference) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[10] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ConfigReference.ProtoReflect.Descriptor instead. -func (*ConfigReference) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{10} -} - -func (x *ConfigReference) GetKind() string { - if x != nil { - return x.Kind - } - return "" -} - -func (x *ConfigReference) GetVersion() string { - if x != nil { - return x.Version - } - return "" -} - -func (x *ConfigReference) GetSha256() string { - if x != nil { - return x.Sha256 - } - return "" -} - -func (x *ConfigReference) GetSource() string { - if x != nil { - return x.Source - } - return "" -} - -type UploadPolicy struct { - state protoimpl.MessageState `protogen:"open.v1"` - Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"` - MaxAssetBytes int64 `protobuf:"varint,2,opt,name=max_asset_bytes,json=maxAssetBytes,proto3" json:"max_asset_bytes,omitempty"` - AllowedHosts []string `protobuf:"bytes,4,rep,name=allowed_hosts,json=allowedHosts,proto3" json:"allowed_hosts,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *UploadPolicy) Reset() { - *x = UploadPolicy{} - mi := &file_agent_agent_proto_msgTypes[11] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *UploadPolicy) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*UploadPolicy) ProtoMessage() {} - -func (x *UploadPolicy) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[11] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use UploadPolicy.ProtoReflect.Descriptor instead. -func (*UploadPolicy) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{11} -} - -func (x *UploadPolicy) GetEnabled() bool { - if x != nil { - return x.Enabled - } - return false -} - -func (x *UploadPolicy) GetMaxAssetBytes() int64 { - if x != nil { - return x.MaxAssetBytes - } - return 0 -} - -func (x *UploadPolicy) GetAllowedHosts() []string { - if x != nil { - return x.AllowedHosts - } - return nil -} - -type ExecutionBinding struct { - state protoimpl.MessageState `protogen:"open.v1"` - TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"` - TenantKey string `protobuf:"bytes,2,opt,name=tenant_key,json=tenantKey,proto3" json:"tenant_key,omitempty"` - ExecutionId string `protobuf:"bytes,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"` - TaskId string `protobuf:"bytes,4,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` - TaskItemId string `protobuf:"bytes,5,opt,name=task_item_id,json=taskItemId,proto3" json:"task_item_id,omitempty"` - TaskRevision int64 `protobuf:"varint,6,opt,name=task_revision,json=taskRevision,proto3" json:"task_revision,omitempty"` - CallId string `protobuf:"bytes,7,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"` - AttemptId string `protobuf:"bytes,8,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"` - AgentVersionId string `protobuf:"bytes,9,opt,name=agent_version_id,json=agentVersionId,proto3" json:"agent_version_id,omitempty"` - RoutePolicyId string `protobuf:"bytes,10,opt,name=route_policy_id,json=routePolicyId,proto3" json:"route_policy_id,omitempty"` - CallerProfileId string `protobuf:"bytes,11,opt,name=caller_profile_id,json=callerProfileId,proto3" json:"caller_profile_id,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ExecutionBinding) Reset() { - *x = ExecutionBinding{} - mi := &file_agent_agent_proto_msgTypes[12] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ExecutionBinding) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ExecutionBinding) ProtoMessage() {} - -func (x *ExecutionBinding) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[12] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ExecutionBinding.ProtoReflect.Descriptor instead. -func (*ExecutionBinding) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{12} -} - -func (x *ExecutionBinding) GetTenantId() string { - if x != nil { - return x.TenantId - } - return "" -} - -func (x *ExecutionBinding) GetTenantKey() string { - if x != nil { - return x.TenantKey - } - return "" -} - -func (x *ExecutionBinding) GetExecutionId() string { - if x != nil { - return x.ExecutionId - } - return "" -} - -func (x *ExecutionBinding) GetTaskId() string { - if x != nil { - return x.TaskId - } - return "" -} - -func (x *ExecutionBinding) GetTaskItemId() string { - if x != nil { - return x.TaskItemId - } - return "" -} - -func (x *ExecutionBinding) GetTaskRevision() int64 { - if x != nil { - return x.TaskRevision - } - return 0 -} - -func (x *ExecutionBinding) GetCallId() string { - if x != nil { - return x.CallId - } - return "" -} - -func (x *ExecutionBinding) GetAttemptId() string { - if x != nil { - return x.AttemptId - } - return "" -} - -func (x *ExecutionBinding) GetAgentVersionId() string { - if x != nil { - return x.AgentVersionId - } - return "" -} - -func (x *ExecutionBinding) GetRoutePolicyId() string { - if x != nil { - return x.RoutePolicyId - } - return "" -} - -func (x *ExecutionBinding) GetCallerProfileId() string { - if x != nil { - return x.CallerProfileId - } - return "" -} - type AssetDescriptor struct { state protoimpl.MessageState `protogen:"open.v1"` Kind AssetKind `protobuf:"varint,1,opt,name=kind,proto3,enum=agent.AssetKind" json:"kind,omitempty"` @@ -1815,7 +1385,7 @@ type AssetDescriptor struct { func (x *AssetDescriptor) Reset() { *x = AssetDescriptor{} - mi := &file_agent_agent_proto_msgTypes[13] + mi := &file_agent_agent_proto_msgTypes[10] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1827,7 +1397,7 @@ func (x *AssetDescriptor) String() string { func (*AssetDescriptor) ProtoMessage() {} func (x *AssetDescriptor) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[13] + mi := &file_agent_agent_proto_msgTypes[10] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1840,7 +1410,7 @@ func (x *AssetDescriptor) ProtoReflect() protoreflect.Message { // Deprecated: Use AssetDescriptor.ProtoReflect.Descriptor instead. func (*AssetDescriptor) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{13} + return file_agent_agent_proto_rawDescGZIP(), []int{10} } func (x *AssetDescriptor) GetKind() AssetKind { @@ -1923,7 +1493,7 @@ type Header struct { func (x *Header) Reset() { *x = Header{} - mi := &file_agent_agent_proto_msgTypes[14] + mi := &file_agent_agent_proto_msgTypes[11] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1935,7 +1505,7 @@ func (x *Header) String() string { func (*Header) ProtoMessage() {} func (x *Header) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[14] + mi := &file_agent_agent_proto_msgTypes[11] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -1948,7 +1518,7 @@ func (x *Header) ProtoReflect() protoreflect.Message { // Deprecated: Use Header.ProtoReflect.Descriptor instead. func (*Header) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{14} + return file_agent_agent_proto_rawDescGZIP(), []int{11} } func (x *Header) GetName() string { @@ -1975,7 +1545,7 @@ type GetAgentStatusRequest struct { func (x *GetAgentStatusRequest) Reset() { *x = GetAgentStatusRequest{} - mi := &file_agent_agent_proto_msgTypes[15] + mi := &file_agent_agent_proto_msgTypes[12] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -1987,7 +1557,7 @@ func (x *GetAgentStatusRequest) String() string { func (*GetAgentStatusRequest) ProtoMessage() {} func (x *GetAgentStatusRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[15] + mi := &file_agent_agent_proto_msgTypes[12] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2000,7 +1570,7 @@ func (x *GetAgentStatusRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use GetAgentStatusRequest.ProtoReflect.Descriptor instead. func (*GetAgentStatusRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{15} + return file_agent_agent_proto_rawDescGZIP(), []int{12} } func (x *GetAgentStatusRequest) GetMeta() *RequestMeta { @@ -2028,7 +1598,7 @@ type GetAgentStatusResponse struct { func (x *GetAgentStatusResponse) Reset() { *x = GetAgentStatusResponse{} - mi := &file_agent_agent_proto_msgTypes[16] + mi := &file_agent_agent_proto_msgTypes[13] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2040,7 +1610,7 @@ func (x *GetAgentStatusResponse) String() string { func (*GetAgentStatusResponse) ProtoMessage() {} func (x *GetAgentStatusResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[16] + mi := &file_agent_agent_proto_msgTypes[13] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2053,7 +1623,7 @@ func (x *GetAgentStatusResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use GetAgentStatusResponse.ProtoReflect.Descriptor instead. func (*GetAgentStatusResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{16} + return file_agent_agent_proto_rawDescGZIP(), []int{13} } func (x *GetAgentStatusResponse) GetMeta() *ResponseMeta { @@ -2090,7 +1660,7 @@ type ActivateAgentRequest struct { func (x *ActivateAgentRequest) Reset() { *x = ActivateAgentRequest{} - mi := &file_agent_agent_proto_msgTypes[17] + mi := &file_agent_agent_proto_msgTypes[14] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2102,7 +1672,7 @@ func (x *ActivateAgentRequest) String() string { func (*ActivateAgentRequest) ProtoMessage() {} func (x *ActivateAgentRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[17] + mi := &file_agent_agent_proto_msgTypes[14] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2115,7 +1685,7 @@ func (x *ActivateAgentRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ActivateAgentRequest.ProtoReflect.Descriptor instead. func (*ActivateAgentRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{17} + return file_agent_agent_proto_rawDescGZIP(), []int{14} } func (x *ActivateAgentRequest) GetMeta() *RequestMeta { @@ -2165,7 +1735,7 @@ type ActivateAgentResponse struct { func (x *ActivateAgentResponse) Reset() { *x = ActivateAgentResponse{} - mi := &file_agent_agent_proto_msgTypes[18] + mi := &file_agent_agent_proto_msgTypes[15] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2177,7 +1747,7 @@ func (x *ActivateAgentResponse) String() string { func (*ActivateAgentResponse) ProtoMessage() {} func (x *ActivateAgentResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[18] + mi := &file_agent_agent_proto_msgTypes[15] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2190,7 +1760,7 @@ func (x *ActivateAgentResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use ActivateAgentResponse.ProtoReflect.Descriptor instead. func (*ActivateAgentResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{18} + return file_agent_agent_proto_rawDescGZIP(), []int{15} } func (x *ActivateAgentResponse) GetMeta() *ResponseMeta { @@ -2221,610 +1791,6 @@ func (x *ActivateAgentResponse) GetFailure() *Failure { return nil } -type GetBootstrapRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - AgentId string `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"` - CellId string `protobuf:"bytes,3,opt,name=cell_id,json=cellId,proto3" json:"cell_id,omitempty"` - BootId string `protobuf:"bytes,4,opt,name=boot_id,json=bootId,proto3" json:"boot_id,omitempty"` - SessionGeneration uint64 `protobuf:"varint,5,opt,name=session_generation,json=sessionGeneration,proto3" json:"session_generation,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *GetBootstrapRequest) Reset() { - *x = GetBootstrapRequest{} - mi := &file_agent_agent_proto_msgTypes[19] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *GetBootstrapRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*GetBootstrapRequest) ProtoMessage() {} - -func (x *GetBootstrapRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[19] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use GetBootstrapRequest.ProtoReflect.Descriptor instead. -func (*GetBootstrapRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{19} -} - -func (x *GetBootstrapRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *GetBootstrapRequest) GetAgentId() string { - if x != nil { - return x.AgentId - } - return "" -} - -func (x *GetBootstrapRequest) GetCellId() string { - if x != nil { - return x.CellId - } - return "" -} - -func (x *GetBootstrapRequest) GetBootId() string { - if x != nil { - return x.BootId - } - return "" -} - -func (x *GetBootstrapRequest) GetSessionGeneration() uint64 { - if x != nil { - return x.SessionGeneration - } - return 0 -} - -type GetBootstrapResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *ResponseMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - State ActivationState `protobuf:"varint,2,opt,name=state,proto3,enum=agent.ActivationState" json:"state,omitempty"` - RuntimeConfigs []*ConfigReference `protobuf:"bytes,3,rep,name=runtime_configs,json=runtimeConfigs,proto3" json:"runtime_configs,omitempty"` - UploadPolicy *UploadPolicy `protobuf:"bytes,4,opt,name=upload_policy,json=uploadPolicy,proto3" json:"upload_policy,omitempty"` - Failure *Failure `protobuf:"bytes,5,opt,name=failure,proto3" json:"failure,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *GetBootstrapResponse) Reset() { - *x = GetBootstrapResponse{} - mi := &file_agent_agent_proto_msgTypes[20] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *GetBootstrapResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*GetBootstrapResponse) ProtoMessage() {} - -func (x *GetBootstrapResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[20] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use GetBootstrapResponse.ProtoReflect.Descriptor instead. -func (*GetBootstrapResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{20} -} - -func (x *GetBootstrapResponse) GetMeta() *ResponseMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *GetBootstrapResponse) GetState() ActivationState { - if x != nil { - return x.State - } - return ActivationState_ACTIVATION_STATE_UNSPECIFIED -} - -func (x *GetBootstrapResponse) GetRuntimeConfigs() []*ConfigReference { - if x != nil { - return x.RuntimeConfigs - } - return nil -} - -func (x *GetBootstrapResponse) GetUploadPolicy() *UploadPolicy { - if x != nil { - return x.UploadPolicy - } - return nil -} - -func (x *GetBootstrapResponse) GetFailure() *Failure { - if x != nil { - return x.Failure - } - return nil -} - -type SetAdmissionStateRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Target *AgentBinding `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` - State AdmissionState `protobuf:"varint,3,opt,name=state,proto3,enum=agent.AdmissionState" json:"state,omitempty"` - BarrierId string `protobuf:"bytes,4,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"` - ExpectedAdmissionGeneration uint64 `protobuf:"varint,5,opt,name=expected_admission_generation,json=expectedAdmissionGeneration,proto3" json:"expected_admission_generation,omitempty"` - Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *SetAdmissionStateRequest) Reset() { - *x = SetAdmissionStateRequest{} - mi := &file_agent_agent_proto_msgTypes[21] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *SetAdmissionStateRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*SetAdmissionStateRequest) ProtoMessage() {} - -func (x *SetAdmissionStateRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[21] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use SetAdmissionStateRequest.ProtoReflect.Descriptor instead. -func (*SetAdmissionStateRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{21} -} - -func (x *SetAdmissionStateRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *SetAdmissionStateRequest) GetTarget() *AgentBinding { - if x != nil { - return x.Target - } - return nil -} - -func (x *SetAdmissionStateRequest) GetState() AdmissionState { - if x != nil { - return x.State - } - return AdmissionState_ADMISSION_STATE_UNSPECIFIED -} - -func (x *SetAdmissionStateRequest) GetBarrierId() string { - if x != nil { - return x.BarrierId - } - return "" -} - -func (x *SetAdmissionStateRequest) GetExpectedAdmissionGeneration() uint64 { - if x != nil { - return x.ExpectedAdmissionGeneration - } - return 0 -} - -func (x *SetAdmissionStateRequest) GetReason() string { - if x != nil { - return x.Reason - } - return "" -} - -type SetAdmissionStateResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Receipt *OperationReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"` - AppliedAdmissionGeneration uint64 `protobuf:"varint,2,opt,name=applied_admission_generation,json=appliedAdmissionGeneration,proto3" json:"applied_admission_generation,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *SetAdmissionStateResponse) Reset() { - *x = SetAdmissionStateResponse{} - mi := &file_agent_agent_proto_msgTypes[22] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *SetAdmissionStateResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*SetAdmissionStateResponse) ProtoMessage() {} - -func (x *SetAdmissionStateResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[22] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use SetAdmissionStateResponse.ProtoReflect.Descriptor instead. -func (*SetAdmissionStateResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{22} -} - -func (x *SetAdmissionStateResponse) GetReceipt() *OperationReceipt { - if x != nil { - return x.Receipt - } - return nil -} - -func (x *SetAdmissionStateResponse) GetAppliedAdmissionGeneration() uint64 { - if x != nil { - return x.AppliedAdmissionGeneration - } - return 0 -} - -type ExecuteRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Binding *ExecutionBinding `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"` - CallExecuteJson []byte `protobuf:"bytes,3,opt,name=call_execute_json,json=callExecuteJson,proto3" json:"call_execute_json,omitempty"` - ConfigSha256 string `protobuf:"bytes,4,opt,name=config_sha256,json=configSha256,proto3" json:"config_sha256,omitempty"` - AdmissionGeneration uint64 `protobuf:"varint,5,opt,name=admission_generation,json=admissionGeneration,proto3" json:"admission_generation,omitempty"` - ResourceReservationId string `protobuf:"bytes,6,opt,name=resource_reservation_id,json=resourceReservationId,proto3" json:"resource_reservation_id,omitempty"` - PermitId string `protobuf:"bytes,7,opt,name=permit_id,json=permitId,proto3" json:"permit_id,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ExecuteRequest) Reset() { - *x = ExecuteRequest{} - mi := &file_agent_agent_proto_msgTypes[23] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ExecuteRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ExecuteRequest) ProtoMessage() {} - -func (x *ExecuteRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[23] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead. -func (*ExecuteRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{23} -} - -func (x *ExecuteRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *ExecuteRequest) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -func (x *ExecuteRequest) GetCallExecuteJson() []byte { - if x != nil { - return x.CallExecuteJson - } - return nil -} - -func (x *ExecuteRequest) GetConfigSha256() string { - if x != nil { - return x.ConfigSha256 - } - return "" -} - -func (x *ExecuteRequest) GetAdmissionGeneration() uint64 { - if x != nil { - return x.AdmissionGeneration - } - return 0 -} - -func (x *ExecuteRequest) GetResourceReservationId() string { - if x != nil { - return x.ResourceReservationId - } - return "" -} - -func (x *ExecuteRequest) GetPermitId() string { - if x != nil { - return x.PermitId - } - return "" -} - -type ExecuteResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Receipt *OperationReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"` - State ExecutionState `protobuf:"varint,2,opt,name=state,proto3,enum=agent.ExecutionState" json:"state,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ExecuteResponse) Reset() { - *x = ExecuteResponse{} - mi := &file_agent_agent_proto_msgTypes[24] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ExecuteResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ExecuteResponse) ProtoMessage() {} - -func (x *ExecuteResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[24] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead. -func (*ExecuteResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{24} -} - -func (x *ExecuteResponse) GetReceipt() *OperationReceipt { - if x != nil { - return x.Receipt - } - return nil -} - -func (x *ExecuteResponse) GetState() ExecutionState { - if x != nil { - return x.State - } - return ExecutionState_EXECUTION_STATE_UNSPECIFIED -} - -// Versioned project-local D→Agent execution contract. Only the Dispatcher -// evaluates the task/line schedule, allowlist, route and effective duration. -// The Agent checks the authorized deadline and transport/session identity; it -// never selects another trunk or recalculates outbound business policy. -type ExecuteAuthorizedRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - SchemaVersion string `protobuf:"bytes,1,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"` // agent-authorized-origination.v0.1 - Meta *RequestMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` - Binding *ExecutionBinding `protobuf:"bytes,3,opt,name=binding,proto3" json:"binding,omitempty"` - SelectedTrunkId string `protobuf:"bytes,4,opt,name=selected_trunk_id,json=selectedTrunkId,proto3" json:"selected_trunk_id,omitempty"` - CallerId string `protobuf:"bytes,5,opt,name=caller_id,json=callerId,proto3" json:"caller_id,omitempty"` - Callee string `protobuf:"bytes,6,opt,name=callee,proto3" json:"callee,omitempty"` - RingTimeoutMs int64 `protobuf:"varint,7,opt,name=ring_timeout_ms,json=ringTimeoutMs,proto3" json:"ring_timeout_ms,omitempty"` - MaxCallDurationMs int64 `protobuf:"varint,8,opt,name=max_call_duration_ms,json=maxCallDurationMs,proto3" json:"max_call_duration_ms,omitempty"` - DialBeforeUnixMs int64 `protobuf:"varint,9,opt,name=dial_before_unix_ms,json=dialBeforeUnixMs,proto3" json:"dial_before_unix_ms,omitempty"` // Exclusive D-issued deadline. - BoundSnapshotSha256 string `protobuf:"bytes,10,opt,name=bound_snapshot_sha256,json=boundSnapshotSha256,proto3" json:"bound_snapshot_sha256,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ExecuteAuthorizedRequest) Reset() { - *x = ExecuteAuthorizedRequest{} - mi := &file_agent_agent_proto_msgTypes[25] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ExecuteAuthorizedRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ExecuteAuthorizedRequest) ProtoMessage() {} - -func (x *ExecuteAuthorizedRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[25] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ExecuteAuthorizedRequest.ProtoReflect.Descriptor instead. -func (*ExecuteAuthorizedRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{25} -} - -func (x *ExecuteAuthorizedRequest) GetSchemaVersion() string { - if x != nil { - return x.SchemaVersion - } - return "" -} - -func (x *ExecuteAuthorizedRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *ExecuteAuthorizedRequest) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -func (x *ExecuteAuthorizedRequest) GetSelectedTrunkId() string { - if x != nil { - return x.SelectedTrunkId - } - return "" -} - -func (x *ExecuteAuthorizedRequest) GetCallerId() string { - if x != nil { - return x.CallerId - } - return "" -} - -func (x *ExecuteAuthorizedRequest) GetCallee() string { - if x != nil { - return x.Callee - } - return "" -} - -func (x *ExecuteAuthorizedRequest) GetRingTimeoutMs() int64 { - if x != nil { - return x.RingTimeoutMs - } - return 0 -} - -func (x *ExecuteAuthorizedRequest) GetMaxCallDurationMs() int64 { - if x != nil { - return x.MaxCallDurationMs - } - return 0 -} - -func (x *ExecuteAuthorizedRequest) GetDialBeforeUnixMs() int64 { - if x != nil { - return x.DialBeforeUnixMs - } - return 0 -} - -func (x *ExecuteAuthorizedRequest) GetBoundSnapshotSha256() string { - if x != nil { - return x.BoundSnapshotSha256 - } - return "" -} - -type ExecuteAuthorizedResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Receipt *OperationReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"` - State ExecutionState `protobuf:"varint,2,opt,name=state,proto3,enum=agent.ExecutionState" json:"state,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ExecuteAuthorizedResponse) Reset() { - *x = ExecuteAuthorizedResponse{} - mi := &file_agent_agent_proto_msgTypes[26] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ExecuteAuthorizedResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ExecuteAuthorizedResponse) ProtoMessage() {} - -func (x *ExecuteAuthorizedResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[26] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ExecuteAuthorizedResponse.ProtoReflect.Descriptor instead. -func (*ExecuteAuthorizedResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{26} -} - -func (x *ExecuteAuthorizedResponse) GetReceipt() *OperationReceipt { - if x != nil { - return x.Receipt - } - return nil -} - -func (x *ExecuteAuthorizedResponse) GetState() ExecutionState { - if x != nil { - return x.State - } - return ExecutionState_EXECUTION_STATE_UNSPECIFIED -} - // Exact, immutable task/provider bytes and SIP revision accompany each // authorized execution. Provider bytes may contain credentials: never log // or persist this request body. The Agent checks session, binding and @@ -2854,7 +1820,7 @@ type ExecuteApprovedRequest struct { func (x *ExecuteApprovedRequest) Reset() { *x = ExecuteApprovedRequest{} - mi := &file_agent_agent_proto_msgTypes[27] + mi := &file_agent_agent_proto_msgTypes[16] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -2866,7 +1832,7 @@ func (x *ExecuteApprovedRequest) String() string { func (*ExecuteApprovedRequest) ProtoMessage() {} func (x *ExecuteApprovedRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[27] + mi := &file_agent_agent_proto_msgTypes[16] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -2879,7 +1845,7 @@ func (x *ExecuteApprovedRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ExecuteApprovedRequest.ProtoReflect.Descriptor instead. func (*ExecuteApprovedRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{27} + return file_agent_agent_proto_rawDescGZIP(), []int{16} } func (x *ExecuteApprovedRequest) GetMeta() *RequestMeta { @@ -3011,7 +1977,7 @@ type ExecuteApprovedResponse struct { func (x *ExecuteApprovedResponse) Reset() { *x = ExecuteApprovedResponse{} - mi := &file_agent_agent_proto_msgTypes[28] + mi := &file_agent_agent_proto_msgTypes[17] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3023,7 +1989,7 @@ func (x *ExecuteApprovedResponse) String() string { func (*ExecuteApprovedResponse) ProtoMessage() {} func (x *ExecuteApprovedResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[28] + mi := &file_agent_agent_proto_msgTypes[17] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3036,7 +2002,7 @@ func (x *ExecuteApprovedResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use ExecuteApprovedResponse.ProtoReflect.Descriptor instead. func (*ExecuteApprovedResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{28} + return file_agent_agent_proto_rawDescGZIP(), []int{17} } func (x *ExecuteApprovedResponse) GetCallId() string { @@ -3062,7 +2028,7 @@ type GetLoadedSIPRequest struct { func (x *GetLoadedSIPRequest) Reset() { *x = GetLoadedSIPRequest{} - mi := &file_agent_agent_proto_msgTypes[29] + mi := &file_agent_agent_proto_msgTypes[18] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3074,7 +2040,7 @@ func (x *GetLoadedSIPRequest) String() string { func (*GetLoadedSIPRequest) ProtoMessage() {} func (x *GetLoadedSIPRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[29] + mi := &file_agent_agent_proto_msgTypes[18] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3087,7 +2053,7 @@ func (x *GetLoadedSIPRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use GetLoadedSIPRequest.ProtoReflect.Descriptor instead. func (*GetLoadedSIPRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{29} + return file_agent_agent_proto_rawDescGZIP(), []int{18} } func (x *GetLoadedSIPRequest) GetMeta() *RequestMeta { @@ -3106,7 +2072,7 @@ type GetLoadedSIPResponse struct { func (x *GetLoadedSIPResponse) Reset() { *x = GetLoadedSIPResponse{} - mi := &file_agent_agent_proto_msgTypes[30] + mi := &file_agent_agent_proto_msgTypes[19] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3118,7 +2084,7 @@ func (x *GetLoadedSIPResponse) String() string { func (*GetLoadedSIPResponse) ProtoMessage() {} func (x *GetLoadedSIPResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[30] + mi := &file_agent_agent_proto_msgTypes[19] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3131,7 +2097,7 @@ func (x *GetLoadedSIPResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use GetLoadedSIPResponse.ProtoReflect.Descriptor instead. func (*GetLoadedSIPResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{30} + return file_agent_agent_proto_rawDescGZIP(), []int{19} } func (x *GetLoadedSIPResponse) GetTrunkRevision() map[string]int64 { @@ -3141,386 +2107,6 @@ func (x *GetLoadedSIPResponse) GetTrunkRevision() map[string]int64 { return nil } -type GetExecutionPermitRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Binding *ExecutionBinding `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"` - ResourceReservationId string `protobuf:"bytes,3,opt,name=resource_reservation_id,json=resourceReservationId,proto3" json:"resource_reservation_id,omitempty"` - ExpectedTaskRevision int64 `protobuf:"varint,4,opt,name=expected_task_revision,json=expectedTaskRevision,proto3" json:"expected_task_revision,omitempty"` - AdmissionGeneration uint64 `protobuf:"varint,5,opt,name=admission_generation,json=admissionGeneration,proto3" json:"admission_generation,omitempty"` - ConfigSha256 string `protobuf:"bytes,6,opt,name=config_sha256,json=configSha256,proto3" json:"config_sha256,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *GetExecutionPermitRequest) Reset() { - *x = GetExecutionPermitRequest{} - mi := &file_agent_agent_proto_msgTypes[31] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *GetExecutionPermitRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*GetExecutionPermitRequest) ProtoMessage() {} - -func (x *GetExecutionPermitRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[31] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use GetExecutionPermitRequest.ProtoReflect.Descriptor instead. -func (*GetExecutionPermitRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{31} -} - -func (x *GetExecutionPermitRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *GetExecutionPermitRequest) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -func (x *GetExecutionPermitRequest) GetResourceReservationId() string { - if x != nil { - return x.ResourceReservationId - } - return "" -} - -func (x *GetExecutionPermitRequest) GetExpectedTaskRevision() int64 { - if x != nil { - return x.ExpectedTaskRevision - } - return 0 -} - -func (x *GetExecutionPermitRequest) GetAdmissionGeneration() uint64 { - if x != nil { - return x.AdmissionGeneration - } - return 0 -} - -func (x *GetExecutionPermitRequest) GetConfigSha256() string { - if x != nil { - return x.ConfigSha256 - } - return "" -} - -type ExecutionPermit struct { - state protoimpl.MessageState `protogen:"open.v1"` - PermitId string `protobuf:"bytes,1,opt,name=permit_id,json=permitId,proto3" json:"permit_id,omitempty"` - ResourceReservationId string `protobuf:"bytes,2,opt,name=resource_reservation_id,json=resourceReservationId,proto3" json:"resource_reservation_id,omitempty"` - IssuedAtUnixMs int64 `protobuf:"varint,3,opt,name=issued_at_unix_ms,json=issuedAtUnixMs,proto3" json:"issued_at_unix_ms,omitempty"` - ExpiresAtUnixMs int64 `protobuf:"varint,4,opt,name=expires_at_unix_ms,json=expiresAtUnixMs,proto3" json:"expires_at_unix_ms,omitempty"` - DispatcherEpoch string `protobuf:"bytes,5,opt,name=dispatcher_epoch,json=dispatcherEpoch,proto3" json:"dispatcher_epoch,omitempty"` - SessionGeneration uint64 `protobuf:"varint,6,opt,name=session_generation,json=sessionGeneration,proto3" json:"session_generation,omitempty"` - FencingToken string `protobuf:"bytes,7,opt,name=fencing_token,json=fencingToken,proto3" json:"fencing_token,omitempty"` - ConfigSha256 string `protobuf:"bytes,8,opt,name=config_sha256,json=configSha256,proto3" json:"config_sha256,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ExecutionPermit) Reset() { - *x = ExecutionPermit{} - mi := &file_agent_agent_proto_msgTypes[32] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ExecutionPermit) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ExecutionPermit) ProtoMessage() {} - -func (x *ExecutionPermit) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[32] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ExecutionPermit.ProtoReflect.Descriptor instead. -func (*ExecutionPermit) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{32} -} - -func (x *ExecutionPermit) GetPermitId() string { - if x != nil { - return x.PermitId - } - return "" -} - -func (x *ExecutionPermit) GetResourceReservationId() string { - if x != nil { - return x.ResourceReservationId - } - return "" -} - -func (x *ExecutionPermit) GetIssuedAtUnixMs() int64 { - if x != nil { - return x.IssuedAtUnixMs - } - return 0 -} - -func (x *ExecutionPermit) GetExpiresAtUnixMs() int64 { - if x != nil { - return x.ExpiresAtUnixMs - } - return 0 -} - -func (x *ExecutionPermit) GetDispatcherEpoch() string { - if x != nil { - return x.DispatcherEpoch - } - return "" -} - -func (x *ExecutionPermit) GetSessionGeneration() uint64 { - if x != nil { - return x.SessionGeneration - } - return 0 -} - -func (x *ExecutionPermit) GetFencingToken() string { - if x != nil { - return x.FencingToken - } - return "" -} - -func (x *ExecutionPermit) GetConfigSha256() string { - if x != nil { - return x.ConfigSha256 - } - return "" -} - -type GetExecutionPermitResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Receipt *OperationReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"` - Permit *ExecutionPermit `protobuf:"bytes,2,opt,name=permit,proto3" json:"permit,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *GetExecutionPermitResponse) Reset() { - *x = GetExecutionPermitResponse{} - mi := &file_agent_agent_proto_msgTypes[33] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *GetExecutionPermitResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*GetExecutionPermitResponse) ProtoMessage() {} - -func (x *GetExecutionPermitResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[33] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use GetExecutionPermitResponse.ProtoReflect.Descriptor instead. -func (*GetExecutionPermitResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{33} -} - -func (x *GetExecutionPermitResponse) GetReceipt() *OperationReceipt { - if x != nil { - return x.Receipt - } - return nil -} - -func (x *GetExecutionPermitResponse) GetPermit() *ExecutionPermit { - if x != nil { - return x.Permit - } - return nil -} - -type ApplyTaskControlRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Binding *ExecutionBinding `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"` - Action ControlAction `protobuf:"varint,3,opt,name=action,proto3,enum=agent.ControlAction" json:"action,omitempty"` - ActiveCallPolicy ActiveCallPolicy `protobuf:"varint,4,opt,name=active_call_policy,json=activeCallPolicy,proto3,enum=agent.ActiveCallPolicy" json:"active_call_policy,omitempty"` - ExpectedTaskRevision int64 `protobuf:"varint,5,opt,name=expected_task_revision,json=expectedTaskRevision,proto3" json:"expected_task_revision,omitempty"` - Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ApplyTaskControlRequest) Reset() { - *x = ApplyTaskControlRequest{} - mi := &file_agent_agent_proto_msgTypes[34] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ApplyTaskControlRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ApplyTaskControlRequest) ProtoMessage() {} - -func (x *ApplyTaskControlRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[34] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ApplyTaskControlRequest.ProtoReflect.Descriptor instead. -func (*ApplyTaskControlRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{34} -} - -func (x *ApplyTaskControlRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *ApplyTaskControlRequest) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -func (x *ApplyTaskControlRequest) GetAction() ControlAction { - if x != nil { - return x.Action - } - return ControlAction_CONTROL_ACTION_UNSPECIFIED -} - -func (x *ApplyTaskControlRequest) GetActiveCallPolicy() ActiveCallPolicy { - if x != nil { - return x.ActiveCallPolicy - } - return ActiveCallPolicy_ACTIVE_CALL_POLICY_UNSPECIFIED -} - -func (x *ApplyTaskControlRequest) GetExpectedTaskRevision() int64 { - if x != nil { - return x.ExpectedTaskRevision - } - return 0 -} - -func (x *ApplyTaskControlRequest) GetReason() string { - if x != nil { - return x.Reason - } - return "" -} - -type ApplyTaskControlResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Receipt *OperationReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"` - AppliedTaskRevision int64 `protobuf:"varint,2,opt,name=applied_task_revision,json=appliedTaskRevision,proto3" json:"applied_task_revision,omitempty"` - State ExecutionState `protobuf:"varint,3,opt,name=state,proto3,enum=agent.ExecutionState" json:"state,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ApplyTaskControlResponse) Reset() { - *x = ApplyTaskControlResponse{} - mi := &file_agent_agent_proto_msgTypes[35] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ApplyTaskControlResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ApplyTaskControlResponse) ProtoMessage() {} - -func (x *ApplyTaskControlResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[35] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ApplyTaskControlResponse.ProtoReflect.Descriptor instead. -func (*ApplyTaskControlResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{35} -} - -func (x *ApplyTaskControlResponse) GetReceipt() *OperationReceipt { - if x != nil { - return x.Receipt - } - return nil -} - -func (x *ApplyTaskControlResponse) GetAppliedTaskRevision() int64 { - if x != nil { - return x.AppliedTaskRevision - } - return 0 -} - -func (x *ApplyTaskControlResponse) GetState() ExecutionState { - if x != nil { - return x.State - } - return ExecutionState_EXECUTION_STATE_UNSPECIFIED -} - // Current task-level control has no external command ID, revision CAS or // execution binding. The authenticated session must match dispatcher_id. type ApplyApprovedTaskControlRequest struct { @@ -3537,7 +2123,7 @@ type ApplyApprovedTaskControlRequest struct { func (x *ApplyApprovedTaskControlRequest) Reset() { *x = ApplyApprovedTaskControlRequest{} - mi := &file_agent_agent_proto_msgTypes[36] + mi := &file_agent_agent_proto_msgTypes[20] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3549,7 +2135,7 @@ func (x *ApplyApprovedTaskControlRequest) String() string { func (*ApplyApprovedTaskControlRequest) ProtoMessage() {} func (x *ApplyApprovedTaskControlRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[36] + mi := &file_agent_agent_proto_msgTypes[20] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3562,7 +2148,7 @@ func (x *ApplyApprovedTaskControlRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ApplyApprovedTaskControlRequest.ProtoReflect.Descriptor instead. func (*ApplyApprovedTaskControlRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{36} + return file_agent_agent_proto_rawDescGZIP(), []int{20} } func (x *ApplyApprovedTaskControlRequest) GetMeta() *RequestMeta { @@ -3616,7 +2202,7 @@ type ApplyApprovedTaskControlResponse struct { func (x *ApplyApprovedTaskControlResponse) Reset() { *x = ApplyApprovedTaskControlResponse{} - mi := &file_agent_agent_proto_msgTypes[37] + mi := &file_agent_agent_proto_msgTypes[21] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -3628,7 +2214,7 @@ func (x *ApplyApprovedTaskControlResponse) String() string { func (*ApplyApprovedTaskControlResponse) ProtoMessage() {} func (x *ApplyApprovedTaskControlResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[37] + mi := &file_agent_agent_proto_msgTypes[21] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -3641,7 +2227,7 @@ func (x *ApplyApprovedTaskControlResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use ApplyApprovedTaskControlResponse.ProtoReflect.Descriptor instead. func (*ApplyApprovedTaskControlResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{37} + return file_agent_agent_proto_rawDescGZIP(), []int{21} } func (x *ApplyApprovedTaskControlResponse) GetAccepted() bool { @@ -3651,482 +2237,6 @@ func (x *ApplyApprovedTaskControlResponse) GetAccepted() bool { return false } -type QueryExecutionRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Binding *ExecutionBinding `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *QueryExecutionRequest) Reset() { - *x = QueryExecutionRequest{} - mi := &file_agent_agent_proto_msgTypes[38] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *QueryExecutionRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*QueryExecutionRequest) ProtoMessage() {} - -func (x *QueryExecutionRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[38] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use QueryExecutionRequest.ProtoReflect.Descriptor instead. -func (*QueryExecutionRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{38} -} - -func (x *QueryExecutionRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *QueryExecutionRequest) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -type ExecutionSnapshot struct { - state protoimpl.MessageState `protogen:"open.v1"` - Binding *ExecutionBinding `protobuf:"bytes,1,opt,name=binding,proto3" json:"binding,omitempty"` - State ExecutionState `protobuf:"varint,2,opt,name=state,proto3,enum=agent.ExecutionState" json:"state,omitempty"` - CallState string `protobuf:"bytes,3,opt,name=call_state,json=callState,proto3" json:"call_state,omitempty"` - AttemptId string `protobuf:"bytes,4,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"` - ReasonCode string `protobuf:"bytes,5,opt,name=reason_code,json=reasonCode,proto3" json:"reason_code,omitempty"` - ObservedAtUnixMs int64 `protobuf:"varint,6,opt,name=observed_at_unix_ms,json=observedAtUnixMs,proto3" json:"observed_at_unix_ms,omitempty"` - Unknown bool `protobuf:"varint,7,opt,name=unknown,proto3" json:"unknown,omitempty"` - Assets []*AssetDescriptor `protobuf:"bytes,8,rep,name=assets,proto3" json:"assets,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ExecutionSnapshot) Reset() { - *x = ExecutionSnapshot{} - mi := &file_agent_agent_proto_msgTypes[39] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ExecutionSnapshot) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ExecutionSnapshot) ProtoMessage() {} - -func (x *ExecutionSnapshot) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[39] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ExecutionSnapshot.ProtoReflect.Descriptor instead. -func (*ExecutionSnapshot) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{39} -} - -func (x *ExecutionSnapshot) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -func (x *ExecutionSnapshot) GetState() ExecutionState { - if x != nil { - return x.State - } - return ExecutionState_EXECUTION_STATE_UNSPECIFIED -} - -func (x *ExecutionSnapshot) GetCallState() string { - if x != nil { - return x.CallState - } - return "" -} - -func (x *ExecutionSnapshot) GetAttemptId() string { - if x != nil { - return x.AttemptId - } - return "" -} - -func (x *ExecutionSnapshot) GetReasonCode() string { - if x != nil { - return x.ReasonCode - } - return "" -} - -func (x *ExecutionSnapshot) GetObservedAtUnixMs() int64 { - if x != nil { - return x.ObservedAtUnixMs - } - return 0 -} - -func (x *ExecutionSnapshot) GetUnknown() bool { - if x != nil { - return x.Unknown - } - return false -} - -func (x *ExecutionSnapshot) GetAssets() []*AssetDescriptor { - if x != nil { - return x.Assets - } - return nil -} - -type QueryExecutionResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *ResponseMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Snapshot *ExecutionSnapshot `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"` - Failure *Failure `protobuf:"bytes,3,opt,name=failure,proto3" json:"failure,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *QueryExecutionResponse) Reset() { - *x = QueryExecutionResponse{} - mi := &file_agent_agent_proto_msgTypes[40] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *QueryExecutionResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*QueryExecutionResponse) ProtoMessage() {} - -func (x *QueryExecutionResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[40] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use QueryExecutionResponse.ProtoReflect.Descriptor instead. -func (*QueryExecutionResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{40} -} - -func (x *QueryExecutionResponse) GetMeta() *ResponseMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *QueryExecutionResponse) GetSnapshot() *ExecutionSnapshot { - if x != nil { - return x.Snapshot - } - return nil -} - -func (x *QueryExecutionResponse) GetFailure() *Failure { - if x != nil { - return x.Failure - } - return nil -} - -type ExecutionFact struct { - state protoimpl.MessageState `protogen:"open.v1"` - FactId string `protobuf:"bytes,1,opt,name=fact_id,json=factId,proto3" json:"fact_id,omitempty"` - ContentSha256 string `protobuf:"bytes,2,opt,name=content_sha256,json=contentSha256,proto3" json:"content_sha256,omitempty"` - Binding *ExecutionBinding `protobuf:"bytes,3,opt,name=binding,proto3" json:"binding,omitempty"` - Kind FactKind `protobuf:"varint,4,opt,name=kind,proto3,enum=agent.FactKind" json:"kind,omitempty"` - ObservedAtUnixMs int64 `protobuf:"varint,5,opt,name=observed_at_unix_ms,json=observedAtUnixMs,proto3" json:"observed_at_unix_ms,omitempty"` - SourceBootId string `protobuf:"bytes,6,opt,name=source_boot_id,json=sourceBootId,proto3" json:"source_boot_id,omitempty"` - SourceSequence uint64 `protobuf:"varint,7,opt,name=source_sequence,json=sourceSequence,proto3" json:"source_sequence,omitempty"` - PayloadJson []byte `protobuf:"bytes,8,opt,name=payload_json,json=payloadJson,proto3" json:"payload_json,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ExecutionFact) Reset() { - *x = ExecutionFact{} - mi := &file_agent_agent_proto_msgTypes[41] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ExecutionFact) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ExecutionFact) ProtoMessage() {} - -func (x *ExecutionFact) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[41] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ExecutionFact.ProtoReflect.Descriptor instead. -func (*ExecutionFact) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{41} -} - -func (x *ExecutionFact) GetFactId() string { - if x != nil { - return x.FactId - } - return "" -} - -func (x *ExecutionFact) GetContentSha256() string { - if x != nil { - return x.ContentSha256 - } - return "" -} - -func (x *ExecutionFact) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -func (x *ExecutionFact) GetKind() FactKind { - if x != nil { - return x.Kind - } - return FactKind_FACT_KIND_UNSPECIFIED -} - -func (x *ExecutionFact) GetObservedAtUnixMs() int64 { - if x != nil { - return x.ObservedAtUnixMs - } - return 0 -} - -func (x *ExecutionFact) GetSourceBootId() string { - if x != nil { - return x.SourceBootId - } - return "" -} - -func (x *ExecutionFact) GetSourceSequence() uint64 { - if x != nil { - return x.SourceSequence - } - return 0 -} - -func (x *ExecutionFact) GetPayloadJson() []byte { - if x != nil { - return x.PayloadJson - } - return nil -} - -type ReportExecutionEventRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Fact *ExecutionFact `protobuf:"bytes,2,opt,name=fact,proto3" json:"fact,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ReportExecutionEventRequest) Reset() { - *x = ReportExecutionEventRequest{} - mi := &file_agent_agent_proto_msgTypes[42] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ReportExecutionEventRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ReportExecutionEventRequest) ProtoMessage() {} - -func (x *ReportExecutionEventRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[42] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ReportExecutionEventRequest.ProtoReflect.Descriptor instead. -func (*ReportExecutionEventRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{42} -} - -func (x *ReportExecutionEventRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *ReportExecutionEventRequest) GetFact() *ExecutionFact { - if x != nil { - return x.Fact - } - return nil -} - -type ReportExecutionEventResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Receipt *OperationReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *ReportExecutionEventResponse) Reset() { - *x = ReportExecutionEventResponse{} - mi := &file_agent_agent_proto_msgTypes[43] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *ReportExecutionEventResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*ReportExecutionEventResponse) ProtoMessage() {} - -func (x *ReportExecutionEventResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[43] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use ReportExecutionEventResponse.ProtoReflect.Descriptor instead. -func (*ReportExecutionEventResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{43} -} - -func (x *ReportExecutionEventResponse) GetReceipt() *OperationReceipt { - if x != nil { - return x.Receipt - } - return nil -} - -type RequestUploadRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Binding *ExecutionBinding `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"` - Asset *AssetDescriptor `protobuf:"bytes,3,opt,name=asset,proto3" json:"asset,omitempty"` - UploadId string `protobuf:"bytes,4,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *RequestUploadRequest) Reset() { - *x = RequestUploadRequest{} - mi := &file_agent_agent_proto_msgTypes[44] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *RequestUploadRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*RequestUploadRequest) ProtoMessage() {} - -func (x *RequestUploadRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[44] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use RequestUploadRequest.ProtoReflect.Descriptor instead. -func (*RequestUploadRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{44} -} - -func (x *RequestUploadRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *RequestUploadRequest) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -func (x *RequestUploadRequest) GetAsset() *AssetDescriptor { - if x != nil { - return x.Asset - } - return nil -} - -func (x *RequestUploadRequest) GetUploadId() string { - if x != nil { - return x.UploadId - } - return "" -} - type UploadGrant struct { state protoimpl.MessageState `protogen:"open.v1"` UploadId string `protobuf:"bytes,1,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"` @@ -4143,7 +2253,7 @@ type UploadGrant struct { func (x *UploadGrant) Reset() { *x = UploadGrant{} - mi := &file_agent_agent_proto_msgTypes[45] + mi := &file_agent_agent_proto_msgTypes[22] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4155,7 +2265,7 @@ func (x *UploadGrant) String() string { func (*UploadGrant) ProtoMessage() {} func (x *UploadGrant) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[45] + mi := &file_agent_agent_proto_msgTypes[22] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4168,7 +2278,7 @@ func (x *UploadGrant) ProtoReflect() protoreflect.Message { // Deprecated: Use UploadGrant.ProtoReflect.Descriptor instead. func (*UploadGrant) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{45} + return file_agent_agent_proto_rawDescGZIP(), []int{22} } func (x *UploadGrant) GetUploadId() string { @@ -4227,202 +2337,6 @@ func (x *UploadGrant) GetBucket() string { return "" } -type RequestUploadResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Receipt *OperationReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"` - Grant *UploadGrant `protobuf:"bytes,2,opt,name=grant,proto3" json:"grant,omitempty"` - State UploadState `protobuf:"varint,3,opt,name=state,proto3,enum=agent.UploadState" json:"state,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *RequestUploadResponse) Reset() { - *x = RequestUploadResponse{} - mi := &file_agent_agent_proto_msgTypes[46] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *RequestUploadResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*RequestUploadResponse) ProtoMessage() {} - -func (x *RequestUploadResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[46] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use RequestUploadResponse.ProtoReflect.Descriptor instead. -func (*RequestUploadResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{46} -} - -func (x *RequestUploadResponse) GetReceipt() *OperationReceipt { - if x != nil { - return x.Receipt - } - return nil -} - -func (x *RequestUploadResponse) GetGrant() *UploadGrant { - if x != nil { - return x.Grant - } - return nil -} - -func (x *RequestUploadResponse) GetState() UploadState { - if x != nil { - return x.State - } - return UploadState_UPLOAD_STATE_UNSPECIFIED -} - -type CompleteUploadRequest struct { - state protoimpl.MessageState `protogen:"open.v1"` - Meta *RequestMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` - Binding *ExecutionBinding `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"` - Asset *AssetDescriptor `protobuf:"bytes,3,opt,name=asset,proto3" json:"asset,omitempty"` - UploadId string `protobuf:"bytes,4,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"` - UploadedSizeBytes int64 `protobuf:"varint,5,opt,name=uploaded_size_bytes,json=uploadedSizeBytes,proto3" json:"uploaded_size_bytes,omitempty"` - UploadedChecksumSha256 string `protobuf:"bytes,6,opt,name=uploaded_checksum_sha256,json=uploadedChecksumSha256,proto3" json:"uploaded_checksum_sha256,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *CompleteUploadRequest) Reset() { - *x = CompleteUploadRequest{} - mi := &file_agent_agent_proto_msgTypes[47] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *CompleteUploadRequest) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*CompleteUploadRequest) ProtoMessage() {} - -func (x *CompleteUploadRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[47] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use CompleteUploadRequest.ProtoReflect.Descriptor instead. -func (*CompleteUploadRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{47} -} - -func (x *CompleteUploadRequest) GetMeta() *RequestMeta { - if x != nil { - return x.Meta - } - return nil -} - -func (x *CompleteUploadRequest) GetBinding() *ExecutionBinding { - if x != nil { - return x.Binding - } - return nil -} - -func (x *CompleteUploadRequest) GetAsset() *AssetDescriptor { - if x != nil { - return x.Asset - } - return nil -} - -func (x *CompleteUploadRequest) GetUploadId() string { - if x != nil { - return x.UploadId - } - return "" -} - -func (x *CompleteUploadRequest) GetUploadedSizeBytes() int64 { - if x != nil { - return x.UploadedSizeBytes - } - return 0 -} - -func (x *CompleteUploadRequest) GetUploadedChecksumSha256() string { - if x != nil { - return x.UploadedChecksumSha256 - } - return "" -} - -type CompleteUploadResponse struct { - state protoimpl.MessageState `protogen:"open.v1"` - Receipt *OperationReceipt `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"` - State UploadState `protobuf:"varint,2,opt,name=state,proto3,enum=agent.UploadState" json:"state,omitempty"` - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache -} - -func (x *CompleteUploadResponse) Reset() { - *x = CompleteUploadResponse{} - mi := &file_agent_agent_proto_msgTypes[48] - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - ms.StoreMessageInfo(mi) -} - -func (x *CompleteUploadResponse) String() string { - return protoimpl.X.MessageStringOf(x) -} - -func (*CompleteUploadResponse) ProtoMessage() {} - -func (x *CompleteUploadResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[48] - if x != nil { - ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) - if ms.LoadMessageInfo() == nil { - ms.StoreMessageInfo(mi) - } - return ms - } - return mi.MessageOf(x) -} - -// Deprecated: Use CompleteUploadResponse.ProtoReflect.Descriptor instead. -func (*CompleteUploadResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{48} -} - -func (x *CompleteUploadResponse) GetReceipt() *OperationReceipt { - if x != nil { - return x.Receipt - } - return nil -} - -func (x *CompleteUploadResponse) GetState() UploadState { - if x != nil { - return x.State - } - return UploadState_UPLOAD_STATE_UNSPECIFIED -} - // These facts refer only to the Dispatcher-approved execution identified by // source_event_id; no audio bytes or temporary credential is persisted in MQ. type RequestRecordingUploadRequest struct { @@ -4439,7 +2353,7 @@ type RequestRecordingUploadRequest struct { func (x *RequestRecordingUploadRequest) Reset() { *x = RequestRecordingUploadRequest{} - mi := &file_agent_agent_proto_msgTypes[49] + mi := &file_agent_agent_proto_msgTypes[23] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4451,7 +2365,7 @@ func (x *RequestRecordingUploadRequest) String() string { func (*RequestRecordingUploadRequest) ProtoMessage() {} func (x *RequestRecordingUploadRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[49] + mi := &file_agent_agent_proto_msgTypes[23] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4464,7 +2378,7 @@ func (x *RequestRecordingUploadRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use RequestRecordingUploadRequest.ProtoReflect.Descriptor instead. func (*RequestRecordingUploadRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{49} + return file_agent_agent_proto_rawDescGZIP(), []int{23} } func (x *RequestRecordingUploadRequest) GetMeta() *RequestMeta { @@ -4518,7 +2432,7 @@ type RequestRecordingUploadResponse struct { func (x *RequestRecordingUploadResponse) Reset() { *x = RequestRecordingUploadResponse{} - mi := &file_agent_agent_proto_msgTypes[50] + mi := &file_agent_agent_proto_msgTypes[24] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4530,7 +2444,7 @@ func (x *RequestRecordingUploadResponse) String() string { func (*RequestRecordingUploadResponse) ProtoMessage() {} func (x *RequestRecordingUploadResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[50] + mi := &file_agent_agent_proto_msgTypes[24] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4543,7 +2457,7 @@ func (x *RequestRecordingUploadResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use RequestRecordingUploadResponse.ProtoReflect.Descriptor instead. func (*RequestRecordingUploadResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{50} + return file_agent_agent_proto_rawDescGZIP(), []int{24} } func (x *RequestRecordingUploadResponse) GetGrant() *UploadGrant { @@ -4565,7 +2479,7 @@ type ReportCallEndedRequest struct { func (x *ReportCallEndedRequest) Reset() { *x = ReportCallEndedRequest{} - mi := &file_agent_agent_proto_msgTypes[51] + mi := &file_agent_agent_proto_msgTypes[25] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4577,7 +2491,7 @@ func (x *ReportCallEndedRequest) String() string { func (*ReportCallEndedRequest) ProtoMessage() {} func (x *ReportCallEndedRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[51] + mi := &file_agent_agent_proto_msgTypes[25] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4590,7 +2504,7 @@ func (x *ReportCallEndedRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ReportCallEndedRequest.ProtoReflect.Descriptor instead. func (*ReportCallEndedRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{51} + return file_agent_agent_proto_rawDescGZIP(), []int{25} } func (x *ReportCallEndedRequest) GetMeta() *RequestMeta { @@ -4630,7 +2544,7 @@ type ReportCallEndedResponse struct { func (x *ReportCallEndedResponse) Reset() { *x = ReportCallEndedResponse{} - mi := &file_agent_agent_proto_msgTypes[52] + mi := &file_agent_agent_proto_msgTypes[26] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4642,7 +2556,7 @@ func (x *ReportCallEndedResponse) String() string { func (*ReportCallEndedResponse) ProtoMessage() {} func (x *ReportCallEndedResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[52] + mi := &file_agent_agent_proto_msgTypes[26] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4655,7 +2569,7 @@ func (x *ReportCallEndedResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use ReportCallEndedResponse.ProtoReflect.Descriptor instead. func (*ReportCallEndedResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{52} + return file_agent_agent_proto_rawDescGZIP(), []int{26} } func (x *ReportCallEndedResponse) GetReceipt() *OperationReceipt { @@ -4678,7 +2592,7 @@ type UploadObservation struct { func (x *UploadObservation) Reset() { *x = UploadObservation{} - mi := &file_agent_agent_proto_msgTypes[53] + mi := &file_agent_agent_proto_msgTypes[27] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4690,7 +2604,7 @@ func (x *UploadObservation) String() string { func (*UploadObservation) ProtoMessage() {} func (x *UploadObservation) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[53] + mi := &file_agent_agent_proto_msgTypes[27] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4703,7 +2617,7 @@ func (x *UploadObservation) ProtoReflect() protoreflect.Message { // Deprecated: Use UploadObservation.ProtoReflect.Descriptor instead. func (*UploadObservation) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{53} + return file_agent_agent_proto_rawDescGZIP(), []int{27} } func (x *UploadObservation) GetUploadId() string { @@ -4755,7 +2669,7 @@ type ReportCallResultRequest struct { func (x *ReportCallResultRequest) Reset() { *x = ReportCallResultRequest{} - mi := &file_agent_agent_proto_msgTypes[54] + mi := &file_agent_agent_proto_msgTypes[28] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4767,7 +2681,7 @@ func (x *ReportCallResultRequest) String() string { func (*ReportCallResultRequest) ProtoMessage() {} func (x *ReportCallResultRequest) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[54] + mi := &file_agent_agent_proto_msgTypes[28] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4780,7 +2694,7 @@ func (x *ReportCallResultRequest) ProtoReflect() protoreflect.Message { // Deprecated: Use ReportCallResultRequest.ProtoReflect.Descriptor instead. func (*ReportCallResultRequest) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{54} + return file_agent_agent_proto_rawDescGZIP(), []int{28} } func (x *ReportCallResultRequest) GetMeta() *RequestMeta { @@ -4834,7 +2748,7 @@ type ReportCallResultResponse struct { func (x *ReportCallResultResponse) Reset() { *x = ReportCallResultResponse{} - mi := &file_agent_agent_proto_msgTypes[55] + mi := &file_agent_agent_proto_msgTypes[29] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -4846,7 +2760,7 @@ func (x *ReportCallResultResponse) String() string { func (*ReportCallResultResponse) ProtoMessage() {} func (x *ReportCallResultResponse) ProtoReflect() protoreflect.Message { - mi := &file_agent_agent_proto_msgTypes[55] + mi := &file_agent_agent_proto_msgTypes[29] if x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -4859,7 +2773,7 @@ func (x *ReportCallResultResponse) ProtoReflect() protoreflect.Message { // Deprecated: Use ReportCallResultResponse.ProtoReflect.Descriptor instead. func (*ReportCallResultResponse) Descriptor() ([]byte, []int) { - return file_agent_agent_proto_rawDescGZIP(), []int{55} + return file_agent_agent_proto_rawDescGZIP(), []int{29} } func (x *ReportCallResultResponse) GetReceipt() *OperationReceipt { @@ -4965,32 +2879,7 @@ const file_agent_agent_proto_rawDesc = "" + "\x10dispatcher_epoch\x18\x01 \x01(\tR\x0fdispatcherEpoch\x12-\n" + "\x12session_generation\x18\x02 \x01(\x04R\x11sessionGeneration\x12+\n" + "\x12expires_at_unix_ms\x18\x03 \x01(\x03R\x0fexpiresAtUnixMs\x12-\n" + - "\x12session_credential\x18\x04 \x01(\fR\x11sessionCredential\"o\n" + - "\x0fConfigReference\x12\x12\n" + - "\x04kind\x18\x01 \x01(\tR\x04kind\x12\x18\n" + - "\aversion\x18\x02 \x01(\tR\aversion\x12\x16\n" + - "\x06sha256\x18\x03 \x01(\tR\x06sha256\x12\x16\n" + - "\x06source\x18\x04 \x01(\tR\x06source\"\x8d\x01\n" + - "\fUploadPolicy\x12\x18\n" + - "\aenabled\x18\x01 \x01(\bR\aenabled\x12&\n" + - "\x0fmax_asset_bytes\x18\x02 \x01(\x03R\rmaxAssetBytes\x12#\n" + - "\rallowed_hosts\x18\x04 \x03(\tR\fallowedHostsJ\x04\b\x03\x10\x04R\x10min_retention_ms\"\x87\x03\n" + - "\x10ExecutionBinding\x12\x1b\n" + - "\ttenant_id\x18\x01 \x01(\tR\btenantId\x12\x1d\n" + - "\n" + - "tenant_key\x18\x02 \x01(\tR\ttenantKey\x12!\n" + - "\fexecution_id\x18\x03 \x01(\tR\vexecutionId\x12\x17\n" + - "\atask_id\x18\x04 \x01(\tR\x06taskId\x12 \n" + - "\ftask_item_id\x18\x05 \x01(\tR\n" + - "taskItemId\x12#\n" + - "\rtask_revision\x18\x06 \x01(\x03R\ftaskRevision\x12\x17\n" + - "\acall_id\x18\a \x01(\tR\x06callId\x12\x1d\n" + - "\n" + - "attempt_id\x18\b \x01(\tR\tattemptId\x12(\n" + - "\x10agent_version_id\x18\t \x01(\tR\x0eagentVersionId\x12&\n" + - "\x0froute_policy_id\x18\n" + - " \x01(\tR\rroutePolicyId\x12*\n" + - "\x11caller_profile_id\x18\v \x01(\tR\x0fcallerProfileId\"\xd1\x02\n" + + "\x12session_credential\x18\x04 \x01(\fR\x11sessionCredential\"\xd1\x02\n" + "\x0fAssetDescriptor\x12$\n" + "\x04kind\x18\x01 \x01(\x0e2\x10.agent.AssetKindR\x04kind\x12\x19\n" + "\basset_id\x18\x02 \x01(\tR\aassetId\x12\x17\n" + @@ -5025,56 +2914,7 @@ const file_agent_agent_proto_rawDesc = "" + "\x04meta\x18\x01 \x01(\v2\x13.agent.ResponseMetaR\x04meta\x12,\n" + "\x05state\x18\x02 \x01(\x0e2\x16.agent.ActivationStateR\x05state\x12(\n" + "\asession\x18\x03 \x01(\v2\x0e.agent.SessionR\asession\x12(\n" + - "\afailure\x18\x04 \x01(\v2\x0e.agent.FailureR\afailure\"\xb9\x01\n" + - "\x13GetBootstrapRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x12\x19\n" + - "\bagent_id\x18\x02 \x01(\tR\aagentId\x12\x17\n" + - "\acell_id\x18\x03 \x01(\tR\x06cellId\x12\x17\n" + - "\aboot_id\x18\x04 \x01(\tR\x06bootId\x12-\n" + - "\x12session_generation\x18\x05 \x01(\x04R\x11sessionGeneration\"\x92\x02\n" + - "\x14GetBootstrapResponse\x12'\n" + - "\x04meta\x18\x01 \x01(\v2\x13.agent.ResponseMetaR\x04meta\x12,\n" + - "\x05state\x18\x02 \x01(\x0e2\x16.agent.ActivationStateR\x05state\x12?\n" + - "\x0fruntime_configs\x18\x03 \x03(\v2\x16.agent.ConfigReferenceR\x0eruntimeConfigs\x128\n" + - "\rupload_policy\x18\x04 \x01(\v2\x13.agent.UploadPolicyR\fuploadPolicy\x12(\n" + - "\afailure\x18\x05 \x01(\v2\x0e.agent.FailureR\afailure\"\x97\x02\n" + - "\x18SetAdmissionStateRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x12+\n" + - "\x06target\x18\x02 \x01(\v2\x13.agent.AgentBindingR\x06target\x12+\n" + - "\x05state\x18\x03 \x01(\x0e2\x15.agent.AdmissionStateR\x05state\x12\x1d\n" + - "\n" + - "barrier_id\x18\x04 \x01(\tR\tbarrierId\x12B\n" + - "\x1dexpected_admission_generation\x18\x05 \x01(\x04R\x1bexpectedAdmissionGeneration\x12\x16\n" + - "\x06reason\x18\x06 \x01(\tR\x06reason\"\x90\x01\n" + - "\x19SetAdmissionStateResponse\x121\n" + - "\areceipt\x18\x01 \x01(\v2\x17.agent.OperationReceiptR\areceipt\x12@\n" + - "\x1capplied_admission_generation\x18\x02 \x01(\x04R\x1aappliedAdmissionGeneration\"\xc4\x02\n" + - "\x0eExecuteRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x121\n" + - "\abinding\x18\x02 \x01(\v2\x17.agent.ExecutionBindingR\abinding\x12*\n" + - "\x11call_execute_json\x18\x03 \x01(\fR\x0fcallExecuteJson\x12#\n" + - "\rconfig_sha256\x18\x04 \x01(\tR\fconfigSha256\x121\n" + - "\x14admission_generation\x18\x05 \x01(\x04R\x13admissionGeneration\x126\n" + - "\x17resource_reservation_id\x18\x06 \x01(\tR\x15resourceReservationId\x12\x1b\n" + - "\tpermit_id\x18\a \x01(\tR\bpermitId\"q\n" + - "\x0fExecuteResponse\x121\n" + - "\areceipt\x18\x01 \x01(\v2\x17.agent.OperationReceiptR\areceipt\x12+\n" + - "\x05state\x18\x02 \x01(\x0e2\x15.agent.ExecutionStateR\x05state\"\xb9\x03\n" + - "\x18ExecuteAuthorizedRequest\x12%\n" + - "\x0eschema_version\x18\x01 \x01(\tR\rschemaVersion\x12&\n" + - "\x04meta\x18\x02 \x01(\v2\x12.agent.RequestMetaR\x04meta\x121\n" + - "\abinding\x18\x03 \x01(\v2\x17.agent.ExecutionBindingR\abinding\x12*\n" + - "\x11selected_trunk_id\x18\x04 \x01(\tR\x0fselectedTrunkId\x12\x1b\n" + - "\tcaller_id\x18\x05 \x01(\tR\bcallerId\x12\x16\n" + - "\x06callee\x18\x06 \x01(\tR\x06callee\x12&\n" + - "\x0fring_timeout_ms\x18\a \x01(\x03R\rringTimeoutMs\x12/\n" + - "\x14max_call_duration_ms\x18\b \x01(\x03R\x11maxCallDurationMs\x12-\n" + - "\x13dial_before_unix_ms\x18\t \x01(\x03R\x10dialBeforeUnixMs\x122\n" + - "\x15bound_snapshot_sha256\x18\n" + - " \x01(\tR\x13boundSnapshotSha256\"{\n" + - "\x19ExecuteAuthorizedResponse\x121\n" + - "\areceipt\x18\x01 \x01(\v2\x17.agent.OperationReceiptR\areceipt\x12+\n" + - "\x05state\x18\x02 \x01(\x0e2\x15.agent.ExecutionStateR\x05state\"\x85\x05\n" + + "\afailure\x18\x04 \x01(\v2\x0e.agent.FailureR\afailure\"\x85\x05\n" + "\x16ExecuteApprovedRequest\x12&\n" + "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x12#\n" + "\rdispatcher_id\x18\x02 \x01(\tR\fdispatcherId\x12\x1b\n" + @@ -5103,37 +2943,7 @@ const file_agent_agent_proto_rawDesc = "" + "\x0etrunk_revision\x18\x01 \x03(\v2..agent.GetLoadedSIPResponse.TrunkRevisionEntryR\rtrunkRevision\x1a@\n" + "\x12TrunkRevisionEntry\x12\x10\n" + "\x03key\x18\x01 \x01(\tR\x03key\x12\x14\n" + - "\x05value\x18\x02 \x01(\x03R\x05value:\x028\x01\"\xbc\x02\n" + - "\x19GetExecutionPermitRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x121\n" + - "\abinding\x18\x02 \x01(\v2\x17.agent.ExecutionBindingR\abinding\x126\n" + - "\x17resource_reservation_id\x18\x03 \x01(\tR\x15resourceReservationId\x124\n" + - "\x16expected_task_revision\x18\x04 \x01(\x03R\x14expectedTaskRevision\x121\n" + - "\x14admission_generation\x18\x05 \x01(\x04R\x13admissionGeneration\x12#\n" + - "\rconfig_sha256\x18\x06 \x01(\tR\fconfigSha256\"\xe2\x02\n" + - "\x0fExecutionPermit\x12\x1b\n" + - "\tpermit_id\x18\x01 \x01(\tR\bpermitId\x126\n" + - "\x17resource_reservation_id\x18\x02 \x01(\tR\x15resourceReservationId\x12)\n" + - "\x11issued_at_unix_ms\x18\x03 \x01(\x03R\x0eissuedAtUnixMs\x12+\n" + - "\x12expires_at_unix_ms\x18\x04 \x01(\x03R\x0fexpiresAtUnixMs\x12)\n" + - "\x10dispatcher_epoch\x18\x05 \x01(\tR\x0fdispatcherEpoch\x12-\n" + - "\x12session_generation\x18\x06 \x01(\x04R\x11sessionGeneration\x12#\n" + - "\rfencing_token\x18\a \x01(\tR\ffencingToken\x12#\n" + - "\rconfig_sha256\x18\b \x01(\tR\fconfigSha256\"\x7f\n" + - "\x1aGetExecutionPermitResponse\x121\n" + - "\areceipt\x18\x01 \x01(\v2\x17.agent.OperationReceiptR\areceipt\x12.\n" + - "\x06permit\x18\x02 \x01(\v2\x16.agent.ExecutionPermitR\x06permit\"\xb7\x02\n" + - "\x17ApplyTaskControlRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x121\n" + - "\abinding\x18\x02 \x01(\v2\x17.agent.ExecutionBindingR\abinding\x12,\n" + - "\x06action\x18\x03 \x01(\x0e2\x14.agent.ControlActionR\x06action\x12E\n" + - "\x12active_call_policy\x18\x04 \x01(\x0e2\x17.agent.ActiveCallPolicyR\x10activeCallPolicy\x124\n" + - "\x16expected_task_revision\x18\x05 \x01(\x03R\x14expectedTaskRevision\x12\x16\n" + - "\x06reason\x18\x06 \x01(\tR\x06reason\"\xae\x01\n" + - "\x18ApplyTaskControlResponse\x121\n" + - "\areceipt\x18\x01 \x01(\v2\x17.agent.OperationReceiptR\areceipt\x122\n" + - "\x15applied_task_revision\x18\x02 \x01(\x03R\x13appliedTaskRevision\x12+\n" + - "\x05state\x18\x03 \x01(\x0e2\x15.agent.ExecutionStateR\x05state\"\x99\x02\n" + + "\x05value\x18\x02 \x01(\x03R\x05value:\x028\x01\"\x99\x02\n" + "\x1fApplyApprovedTaskControlRequest\x12&\n" + "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x12#\n" + "\rdispatcher_id\x18\x02 \x01(\tR\fdispatcherId\x12\x1b\n" + @@ -5142,45 +2952,7 @@ const file_agent_agent_proto_rawDesc = "" + "\x06action\x18\x05 \x01(\x0e2\x14.agent.ControlActionR\x06action\x12E\n" + "\x12active_call_policy\x18\x06 \x01(\x0e2\x17.agent.ActiveCallPolicyR\x10activeCallPolicy\">\n" + " ApplyApprovedTaskControlResponse\x12\x1a\n" + - "\baccepted\x18\x01 \x01(\bR\baccepted\"r\n" + - "\x15QueryExecutionRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x121\n" + - "\abinding\x18\x02 \x01(\v2\x17.agent.ExecutionBindingR\abinding\"\xcb\x02\n" + - "\x11ExecutionSnapshot\x121\n" + - "\abinding\x18\x01 \x01(\v2\x17.agent.ExecutionBindingR\abinding\x12+\n" + - "\x05state\x18\x02 \x01(\x0e2\x15.agent.ExecutionStateR\x05state\x12\x1d\n" + - "\n" + - "call_state\x18\x03 \x01(\tR\tcallState\x12\x1d\n" + - "\n" + - "attempt_id\x18\x04 \x01(\tR\tattemptId\x12\x1f\n" + - "\vreason_code\x18\x05 \x01(\tR\n" + - "reasonCode\x12-\n" + - "\x13observed_at_unix_ms\x18\x06 \x01(\x03R\x10observedAtUnixMs\x12\x18\n" + - "\aunknown\x18\a \x01(\bR\aunknown\x12.\n" + - "\x06assets\x18\b \x03(\v2\x16.agent.AssetDescriptorR\x06assets\"\xa1\x01\n" + - "\x16QueryExecutionResponse\x12'\n" + - "\x04meta\x18\x01 \x01(\v2\x13.agent.ResponseMetaR\x04meta\x124\n" + - "\bsnapshot\x18\x02 \x01(\v2\x18.agent.ExecutionSnapshotR\bsnapshot\x12(\n" + - "\afailure\x18\x03 \x01(\v2\x0e.agent.FailureR\afailure\"\xc8\x02\n" + - "\rExecutionFact\x12\x17\n" + - "\afact_id\x18\x01 \x01(\tR\x06factId\x12%\n" + - "\x0econtent_sha256\x18\x02 \x01(\tR\rcontentSha256\x121\n" + - "\abinding\x18\x03 \x01(\v2\x17.agent.ExecutionBindingR\abinding\x12#\n" + - "\x04kind\x18\x04 \x01(\x0e2\x0f.agent.FactKindR\x04kind\x12-\n" + - "\x13observed_at_unix_ms\x18\x05 \x01(\x03R\x10observedAtUnixMs\x12$\n" + - "\x0esource_boot_id\x18\x06 \x01(\tR\fsourceBootId\x12'\n" + - "\x0fsource_sequence\x18\a \x01(\x04R\x0esourceSequence\x12!\n" + - "\fpayload_json\x18\b \x01(\fR\vpayloadJson\"o\n" + - "\x1bReportExecutionEventRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x12(\n" + - "\x04fact\x18\x02 \x01(\v2\x14.agent.ExecutionFactR\x04fact\"Q\n" + - "\x1cReportExecutionEventResponse\x121\n" + - "\areceipt\x18\x01 \x01(\v2\x17.agent.OperationReceiptR\areceipt\"\xbc\x01\n" + - "\x14RequestUploadRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x121\n" + - "\abinding\x18\x02 \x01(\v2\x17.agent.ExecutionBindingR\abinding\x12,\n" + - "\x05asset\x18\x03 \x01(\v2\x16.agent.AssetDescriptorR\x05asset\x12\x1b\n" + - "\tupload_id\x18\x04 \x01(\tR\buploadId\"\xad\x02\n" + + "\baccepted\x18\x01 \x01(\bR\baccepted\"\xad\x02\n" + "\vUploadGrant\x12\x1b\n" + "\tupload_id\x18\x01 \x01(\tR\buploadId\x12\x1d\n" + "\n" + @@ -5191,21 +2963,7 @@ const file_agent_agent_proto_rawDesc = "" + "object_key\x18\x05 \x01(\tR\tobjectKey\x128\n" + "\x18required_checksum_sha256\x18\x06 \x01(\tR\x16requiredChecksumSha256\x12\x1b\n" + "\tmax_bytes\x18\a \x01(\x03R\bmaxBytes\x12\x16\n" + - "\x06bucket\x18\b \x01(\tR\x06bucket\"\x9e\x01\n" + - "\x15RequestUploadResponse\x121\n" + - "\areceipt\x18\x01 \x01(\v2\x17.agent.OperationReceiptR\areceipt\x12(\n" + - "\x05grant\x18\x02 \x01(\v2\x12.agent.UploadGrantR\x05grant\x12(\n" + - "\x05state\x18\x03 \x01(\x0e2\x12.agent.UploadStateR\x05state\"\xa7\x02\n" + - "\x15CompleteUploadRequest\x12&\n" + - "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x121\n" + - "\abinding\x18\x02 \x01(\v2\x17.agent.ExecutionBindingR\abinding\x12,\n" + - "\x05asset\x18\x03 \x01(\v2\x16.agent.AssetDescriptorR\x05asset\x12\x1b\n" + - "\tupload_id\x18\x04 \x01(\tR\buploadId\x12.\n" + - "\x13uploaded_size_bytes\x18\x05 \x01(\x03R\x11uploadedSizeBytes\x128\n" + - "\x18uploaded_checksum_sha256\x18\x06 \x01(\tR\x16uploadedChecksumSha256\"\x83\x01\n" + - "\x16CompleteUploadResponse\x121\n" + - "\areceipt\x18\x01 \x01(\v2\x17.agent.OperationReceiptR\areceipt\x12(\n" + - "\x05state\x18\x02 \x01(\x0e2\x12.agent.UploadStateR\x05stateJ\x04\b\x03\x10\x04R\x06oss_id\"\xfc\x01\n" + + "\x06bucket\x18\b \x01(\tR\x06bucket\"\xfc\x01\n" + "\x1dRequestRecordingUploadRequest\x12&\n" + "\x04meta\x18\x01 \x01(\v2\x12.agent.RequestMetaR\x04meta\x12#\n" + "\rdispatcher_id\x18\x02 \x01(\tR\fdispatcherId\x12\x1b\n" + @@ -5279,33 +3037,11 @@ const file_agent_agent_proto_rawDesc = "" + "\x10ActiveCallPolicy\x12\"\n" + "\x1eACTIVE_CALL_POLICY_UNSPECIFIED\x10\x00\x12\x1c\n" + "\x18ACTIVE_CALL_POLICY_DRAIN\x10\x01\x12\x1d\n" + - "\x19ACTIVE_CALL_POLICY_HANGUP\x10\x02*\xed\x01\n" + - "\x0eExecutionState\x12\x1f\n" + - "\x1bEXECUTION_STATE_UNSPECIFIED\x10\x00\x12\x1c\n" + - "\x18EXECUTION_STATE_PREPARED\x10\x01\x12\"\n" + - "\x1eEXECUTION_STATE_PERMIT_GRANTED\x10\x02\x12\x1f\n" + - "\x1bEXECUTION_STATE_DISPATCHING\x10\x03\x12\x1c\n" + - "\x18EXECUTION_STATE_OBSERVED\x10\x04\x12\x1b\n" + - "\x17EXECUTION_STATE_UNKNOWN\x10\x05\x12\x1c\n" + - "\x18EXECUTION_STATE_TERMINAL\x10\x06*\\\n" + + "\x19ACTIVE_CALL_POLICY_HANGUP\x10\x02*\\\n" + "\tAssetKind\x12\x1a\n" + "\x16ASSET_KIND_UNSPECIFIED\x10\x00\x12\x18\n" + "\x14ASSET_KIND_RECORDING\x10\x01\x12\x19\n" + - "\x15ASSET_KIND_TRANSCRIPT\x10\x02*\xb6\x01\n" + - "\vUploadState\x12\x1c\n" + - "\x18UPLOAD_STATE_UNSPECIFIED\x10\x00\x12\x1a\n" + - "\x16UPLOAD_STATE_REQUESTED\x10\x01\x12\x1a\n" + - "\x16UPLOAD_STATE_COMPLETED\x10\x03\x12\x17\n" + - "\x13UPLOAD_STATE_FAILED\x10\x04\"\x04\b\x02\x10\x02\"\x04\b\x05\x10\x05*\x16UPLOAD_STATE_UPLOADING*\x14UPLOAD_STATE_EXPIRED*\x83\x02\n" + - "\bFactKind\x12\x19\n" + - "\x15FACT_KIND_UNSPECIFIED\x10\x00\x12 \n" + - "\x1cFACT_KIND_EXECUTION_ACCEPTED\x10\x01\x12\x19\n" + - "\x15FACT_KIND_CALL_STATUS\x10\x02\x12\x1b\n" + - "\x17FACT_KIND_CALL_FINISHED\x10\x03\x12 \n" + - "\x1cFACT_KIND_TRANSCRIPT_UPDATED\x10\x04\x12\x1f\n" + - "\x1bFACT_KIND_TRANSCRIPT_FAILED\x10\x05\x12\x1d\n" + - "\x19FACT_KIND_CONTACT_OPT_OUT\x10\x06\x12 \n" + - "\x1cFACT_KIND_RECORDING_PROGRESS\x10\a2\xc6\x05\n" + + "\x15ASSET_KIND_TRANSCRIPT\x10\x022\xc6\x05\n" + "\x13AgentControlService\x12M\n" + "\x0eGetAgentStatus\x12\x1c.agent.GetAgentStatusRequest\x1a\x1d.agent.GetAgentStatusResponse\x12J\n" + "\rActivateAgent\x12\x1b.agent.ActivateAgentRequest\x1a\x1c.agent.ActivateAgentResponse\x12P\n" + @@ -5328,8 +3064,8 @@ func file_agent_agent_proto_rawDescGZIP() []byte { return file_agent_agent_proto_rawDescData } -var file_agent_agent_proto_enumTypes = make([]protoimpl.EnumInfo, 10) -var file_agent_agent_proto_msgTypes = make([]protoimpl.MessageInfo, 57) +var file_agent_agent_proto_enumTypes = make([]protoimpl.EnumInfo, 7) +var file_agent_agent_proto_msgTypes = make([]protoimpl.MessageInfo, 31) var file_agent_agent_proto_goTypes = []any{ (ResultCode)(0), // 0: agent.ResultCode (FailureCode)(0), // 1: agent.FailureCode @@ -5337,177 +3073,96 @@ var file_agent_agent_proto_goTypes = []any{ (AdmissionState)(0), // 3: agent.AdmissionState (ControlAction)(0), // 4: agent.ControlAction (ActiveCallPolicy)(0), // 5: agent.ActiveCallPolicy - (ExecutionState)(0), // 6: agent.ExecutionState - (AssetKind)(0), // 7: agent.AssetKind - (UploadState)(0), // 8: agent.UploadState - (FactKind)(0), // 9: agent.FactKind - (*RequestMeta)(nil), // 10: agent.RequestMeta - (*ResponseMeta)(nil), // 11: agent.ResponseMeta - (*Failure)(nil), // 12: agent.Failure - (*OperationReceipt)(nil), // 13: agent.OperationReceipt - (*AgentBinding)(nil), // 14: agent.AgentBinding - (*Capability)(nil), // 15: agent.Capability - (*ResourceSample)(nil), // 16: agent.ResourceSample - (*AppliedConfig)(nil), // 17: agent.AppliedConfig - (*AgentStatus)(nil), // 18: agent.AgentStatus - (*Session)(nil), // 19: agent.Session - (*ConfigReference)(nil), // 20: agent.ConfigReference - (*UploadPolicy)(nil), // 21: agent.UploadPolicy - (*ExecutionBinding)(nil), // 22: agent.ExecutionBinding - (*AssetDescriptor)(nil), // 23: agent.AssetDescriptor - (*Header)(nil), // 24: agent.Header - (*GetAgentStatusRequest)(nil), // 25: agent.GetAgentStatusRequest - (*GetAgentStatusResponse)(nil), // 26: agent.GetAgentStatusResponse - (*ActivateAgentRequest)(nil), // 27: agent.ActivateAgentRequest - (*ActivateAgentResponse)(nil), // 28: agent.ActivateAgentResponse - (*GetBootstrapRequest)(nil), // 29: agent.GetBootstrapRequest - (*GetBootstrapResponse)(nil), // 30: agent.GetBootstrapResponse - (*SetAdmissionStateRequest)(nil), // 31: agent.SetAdmissionStateRequest - (*SetAdmissionStateResponse)(nil), // 32: agent.SetAdmissionStateResponse - (*ExecuteRequest)(nil), // 33: agent.ExecuteRequest - (*ExecuteResponse)(nil), // 34: agent.ExecuteResponse - (*ExecuteAuthorizedRequest)(nil), // 35: agent.ExecuteAuthorizedRequest - (*ExecuteAuthorizedResponse)(nil), // 36: agent.ExecuteAuthorizedResponse - (*ExecuteApprovedRequest)(nil), // 37: agent.ExecuteApprovedRequest - (*ExecuteApprovedResponse)(nil), // 38: agent.ExecuteApprovedResponse - (*GetLoadedSIPRequest)(nil), // 39: agent.GetLoadedSIPRequest - (*GetLoadedSIPResponse)(nil), // 40: agent.GetLoadedSIPResponse - (*GetExecutionPermitRequest)(nil), // 41: agent.GetExecutionPermitRequest - (*ExecutionPermit)(nil), // 42: agent.ExecutionPermit - (*GetExecutionPermitResponse)(nil), // 43: agent.GetExecutionPermitResponse - (*ApplyTaskControlRequest)(nil), // 44: agent.ApplyTaskControlRequest - (*ApplyTaskControlResponse)(nil), // 45: agent.ApplyTaskControlResponse - (*ApplyApprovedTaskControlRequest)(nil), // 46: agent.ApplyApprovedTaskControlRequest - (*ApplyApprovedTaskControlResponse)(nil), // 47: agent.ApplyApprovedTaskControlResponse - (*QueryExecutionRequest)(nil), // 48: agent.QueryExecutionRequest - (*ExecutionSnapshot)(nil), // 49: agent.ExecutionSnapshot - (*QueryExecutionResponse)(nil), // 50: agent.QueryExecutionResponse - (*ExecutionFact)(nil), // 51: agent.ExecutionFact - (*ReportExecutionEventRequest)(nil), // 52: agent.ReportExecutionEventRequest - (*ReportExecutionEventResponse)(nil), // 53: agent.ReportExecutionEventResponse - (*RequestUploadRequest)(nil), // 54: agent.RequestUploadRequest - (*UploadGrant)(nil), // 55: agent.UploadGrant - (*RequestUploadResponse)(nil), // 56: agent.RequestUploadResponse - (*CompleteUploadRequest)(nil), // 57: agent.CompleteUploadRequest - (*CompleteUploadResponse)(nil), // 58: agent.CompleteUploadResponse - (*RequestRecordingUploadRequest)(nil), // 59: agent.RequestRecordingUploadRequest - (*RequestRecordingUploadResponse)(nil), // 60: agent.RequestRecordingUploadResponse - (*ReportCallEndedRequest)(nil), // 61: agent.ReportCallEndedRequest - (*ReportCallEndedResponse)(nil), // 62: agent.ReportCallEndedResponse - (*UploadObservation)(nil), // 63: agent.UploadObservation - (*ReportCallResultRequest)(nil), // 64: agent.ReportCallResultRequest - (*ReportCallResultResponse)(nil), // 65: agent.ReportCallResultResponse - nil, // 66: agent.GetLoadedSIPResponse.TrunkRevisionEntry + (AssetKind)(0), // 6: agent.AssetKind + (*RequestMeta)(nil), // 7: agent.RequestMeta + (*ResponseMeta)(nil), // 8: agent.ResponseMeta + (*Failure)(nil), // 9: agent.Failure + (*OperationReceipt)(nil), // 10: agent.OperationReceipt + (*AgentBinding)(nil), // 11: agent.AgentBinding + (*Capability)(nil), // 12: agent.Capability + (*ResourceSample)(nil), // 13: agent.ResourceSample + (*AppliedConfig)(nil), // 14: agent.AppliedConfig + (*AgentStatus)(nil), // 15: agent.AgentStatus + (*Session)(nil), // 16: agent.Session + (*AssetDescriptor)(nil), // 17: agent.AssetDescriptor + (*Header)(nil), // 18: agent.Header + (*GetAgentStatusRequest)(nil), // 19: agent.GetAgentStatusRequest + (*GetAgentStatusResponse)(nil), // 20: agent.GetAgentStatusResponse + (*ActivateAgentRequest)(nil), // 21: agent.ActivateAgentRequest + (*ActivateAgentResponse)(nil), // 22: agent.ActivateAgentResponse + (*ExecuteApprovedRequest)(nil), // 23: agent.ExecuteApprovedRequest + (*ExecuteApprovedResponse)(nil), // 24: agent.ExecuteApprovedResponse + (*GetLoadedSIPRequest)(nil), // 25: agent.GetLoadedSIPRequest + (*GetLoadedSIPResponse)(nil), // 26: agent.GetLoadedSIPResponse + (*ApplyApprovedTaskControlRequest)(nil), // 27: agent.ApplyApprovedTaskControlRequest + (*ApplyApprovedTaskControlResponse)(nil), // 28: agent.ApplyApprovedTaskControlResponse + (*UploadGrant)(nil), // 29: agent.UploadGrant + (*RequestRecordingUploadRequest)(nil), // 30: agent.RequestRecordingUploadRequest + (*RequestRecordingUploadResponse)(nil), // 31: agent.RequestRecordingUploadResponse + (*ReportCallEndedRequest)(nil), // 32: agent.ReportCallEndedRequest + (*ReportCallEndedResponse)(nil), // 33: agent.ReportCallEndedResponse + (*UploadObservation)(nil), // 34: agent.UploadObservation + (*ReportCallResultRequest)(nil), // 35: agent.ReportCallResultRequest + (*ReportCallResultResponse)(nil), // 36: agent.ReportCallResultResponse + nil, // 37: agent.GetLoadedSIPResponse.TrunkRevisionEntry } var file_agent_agent_proto_depIdxs = []int32{ 1, // 0: agent.Failure.code:type_name -> agent.FailureCode - 11, // 1: agent.OperationReceipt.meta:type_name -> agent.ResponseMeta + 8, // 1: agent.OperationReceipt.meta:type_name -> agent.ResponseMeta 0, // 2: agent.OperationReceipt.result:type_name -> agent.ResultCode - 12, // 3: agent.OperationReceipt.failure:type_name -> agent.Failure + 9, // 3: agent.OperationReceipt.failure:type_name -> agent.Failure 3, // 4: agent.AgentStatus.admission_state:type_name -> agent.AdmissionState - 15, // 5: agent.AgentStatus.capabilities:type_name -> agent.Capability - 16, // 6: agent.AgentStatus.resources:type_name -> agent.ResourceSample - 17, // 7: agent.AgentStatus.applied_configs:type_name -> agent.AppliedConfig - 7, // 8: agent.AssetDescriptor.kind:type_name -> agent.AssetKind - 10, // 9: agent.GetAgentStatusRequest.meta:type_name -> agent.RequestMeta - 14, // 10: agent.GetAgentStatusRequest.target:type_name -> agent.AgentBinding - 11, // 11: agent.GetAgentStatusResponse.meta:type_name -> agent.ResponseMeta - 18, // 12: agent.GetAgentStatusResponse.status:type_name -> agent.AgentStatus - 12, // 13: agent.GetAgentStatusResponse.failure:type_name -> agent.Failure - 10, // 14: agent.ActivateAgentRequest.meta:type_name -> agent.RequestMeta - 14, // 15: agent.ActivateAgentRequest.binding:type_name -> agent.AgentBinding - 11, // 16: agent.ActivateAgentResponse.meta:type_name -> agent.ResponseMeta + 12, // 5: agent.AgentStatus.capabilities:type_name -> agent.Capability + 13, // 6: agent.AgentStatus.resources:type_name -> agent.ResourceSample + 14, // 7: agent.AgentStatus.applied_configs:type_name -> agent.AppliedConfig + 6, // 8: agent.AssetDescriptor.kind:type_name -> agent.AssetKind + 7, // 9: agent.GetAgentStatusRequest.meta:type_name -> agent.RequestMeta + 11, // 10: agent.GetAgentStatusRequest.target:type_name -> agent.AgentBinding + 8, // 11: agent.GetAgentStatusResponse.meta:type_name -> agent.ResponseMeta + 15, // 12: agent.GetAgentStatusResponse.status:type_name -> agent.AgentStatus + 9, // 13: agent.GetAgentStatusResponse.failure:type_name -> agent.Failure + 7, // 14: agent.ActivateAgentRequest.meta:type_name -> agent.RequestMeta + 11, // 15: agent.ActivateAgentRequest.binding:type_name -> agent.AgentBinding + 8, // 16: agent.ActivateAgentResponse.meta:type_name -> agent.ResponseMeta 2, // 17: agent.ActivateAgentResponse.state:type_name -> agent.ActivationState - 19, // 18: agent.ActivateAgentResponse.session:type_name -> agent.Session - 12, // 19: agent.ActivateAgentResponse.failure:type_name -> agent.Failure - 10, // 20: agent.GetBootstrapRequest.meta:type_name -> agent.RequestMeta - 11, // 21: agent.GetBootstrapResponse.meta:type_name -> agent.ResponseMeta - 2, // 22: agent.GetBootstrapResponse.state:type_name -> agent.ActivationState - 20, // 23: agent.GetBootstrapResponse.runtime_configs:type_name -> agent.ConfigReference - 21, // 24: agent.GetBootstrapResponse.upload_policy:type_name -> agent.UploadPolicy - 12, // 25: agent.GetBootstrapResponse.failure:type_name -> agent.Failure - 10, // 26: agent.SetAdmissionStateRequest.meta:type_name -> agent.RequestMeta - 14, // 27: agent.SetAdmissionStateRequest.target:type_name -> agent.AgentBinding - 3, // 28: agent.SetAdmissionStateRequest.state:type_name -> agent.AdmissionState - 13, // 29: agent.SetAdmissionStateResponse.receipt:type_name -> agent.OperationReceipt - 10, // 30: agent.ExecuteRequest.meta:type_name -> agent.RequestMeta - 22, // 31: agent.ExecuteRequest.binding:type_name -> agent.ExecutionBinding - 13, // 32: agent.ExecuteResponse.receipt:type_name -> agent.OperationReceipt - 6, // 33: agent.ExecuteResponse.state:type_name -> agent.ExecutionState - 10, // 34: agent.ExecuteAuthorizedRequest.meta:type_name -> agent.RequestMeta - 22, // 35: agent.ExecuteAuthorizedRequest.binding:type_name -> agent.ExecutionBinding - 13, // 36: agent.ExecuteAuthorizedResponse.receipt:type_name -> agent.OperationReceipt - 6, // 37: agent.ExecuteAuthorizedResponse.state:type_name -> agent.ExecutionState - 10, // 38: agent.ExecuteApprovedRequest.meta:type_name -> agent.RequestMeta - 10, // 39: agent.GetLoadedSIPRequest.meta:type_name -> agent.RequestMeta - 66, // 40: agent.GetLoadedSIPResponse.trunk_revision:type_name -> agent.GetLoadedSIPResponse.TrunkRevisionEntry - 10, // 41: agent.GetExecutionPermitRequest.meta:type_name -> agent.RequestMeta - 22, // 42: agent.GetExecutionPermitRequest.binding:type_name -> agent.ExecutionBinding - 13, // 43: agent.GetExecutionPermitResponse.receipt:type_name -> agent.OperationReceipt - 42, // 44: agent.GetExecutionPermitResponse.permit:type_name -> agent.ExecutionPermit - 10, // 45: agent.ApplyTaskControlRequest.meta:type_name -> agent.RequestMeta - 22, // 46: agent.ApplyTaskControlRequest.binding:type_name -> agent.ExecutionBinding - 4, // 47: agent.ApplyTaskControlRequest.action:type_name -> agent.ControlAction - 5, // 48: agent.ApplyTaskControlRequest.active_call_policy:type_name -> agent.ActiveCallPolicy - 13, // 49: agent.ApplyTaskControlResponse.receipt:type_name -> agent.OperationReceipt - 6, // 50: agent.ApplyTaskControlResponse.state:type_name -> agent.ExecutionState - 10, // 51: agent.ApplyApprovedTaskControlRequest.meta:type_name -> agent.RequestMeta - 4, // 52: agent.ApplyApprovedTaskControlRequest.action:type_name -> agent.ControlAction - 5, // 53: agent.ApplyApprovedTaskControlRequest.active_call_policy:type_name -> agent.ActiveCallPolicy - 10, // 54: agent.QueryExecutionRequest.meta:type_name -> agent.RequestMeta - 22, // 55: agent.QueryExecutionRequest.binding:type_name -> agent.ExecutionBinding - 22, // 56: agent.ExecutionSnapshot.binding:type_name -> agent.ExecutionBinding - 6, // 57: agent.ExecutionSnapshot.state:type_name -> agent.ExecutionState - 23, // 58: agent.ExecutionSnapshot.assets:type_name -> agent.AssetDescriptor - 11, // 59: agent.QueryExecutionResponse.meta:type_name -> agent.ResponseMeta - 49, // 60: agent.QueryExecutionResponse.snapshot:type_name -> agent.ExecutionSnapshot - 12, // 61: agent.QueryExecutionResponse.failure:type_name -> agent.Failure - 22, // 62: agent.ExecutionFact.binding:type_name -> agent.ExecutionBinding - 9, // 63: agent.ExecutionFact.kind:type_name -> agent.FactKind - 10, // 64: agent.ReportExecutionEventRequest.meta:type_name -> agent.RequestMeta - 51, // 65: agent.ReportExecutionEventRequest.fact:type_name -> agent.ExecutionFact - 13, // 66: agent.ReportExecutionEventResponse.receipt:type_name -> agent.OperationReceipt - 10, // 67: agent.RequestUploadRequest.meta:type_name -> agent.RequestMeta - 22, // 68: agent.RequestUploadRequest.binding:type_name -> agent.ExecutionBinding - 23, // 69: agent.RequestUploadRequest.asset:type_name -> agent.AssetDescriptor - 24, // 70: agent.UploadGrant.headers:type_name -> agent.Header - 13, // 71: agent.RequestUploadResponse.receipt:type_name -> agent.OperationReceipt - 55, // 72: agent.RequestUploadResponse.grant:type_name -> agent.UploadGrant - 8, // 73: agent.RequestUploadResponse.state:type_name -> agent.UploadState - 10, // 74: agent.CompleteUploadRequest.meta:type_name -> agent.RequestMeta - 22, // 75: agent.CompleteUploadRequest.binding:type_name -> agent.ExecutionBinding - 23, // 76: agent.CompleteUploadRequest.asset:type_name -> agent.AssetDescriptor - 13, // 77: agent.CompleteUploadResponse.receipt:type_name -> agent.OperationReceipt - 8, // 78: agent.CompleteUploadResponse.state:type_name -> agent.UploadState - 10, // 79: agent.RequestRecordingUploadRequest.meta:type_name -> agent.RequestMeta - 23, // 80: agent.RequestRecordingUploadRequest.asset:type_name -> agent.AssetDescriptor - 55, // 81: agent.RequestRecordingUploadResponse.grant:type_name -> agent.UploadGrant - 10, // 82: agent.ReportCallEndedRequest.meta:type_name -> agent.RequestMeta - 13, // 83: agent.ReportCallEndedResponse.receipt:type_name -> agent.OperationReceipt - 10, // 84: agent.ReportCallResultRequest.meta:type_name -> agent.RequestMeta - 63, // 85: agent.ReportCallResultRequest.upload:type_name -> agent.UploadObservation - 13, // 86: agent.ReportCallResultResponse.receipt:type_name -> agent.OperationReceipt - 25, // 87: agent.AgentControlService.GetAgentStatus:input_type -> agent.GetAgentStatusRequest - 27, // 88: agent.AgentControlService.ActivateAgent:input_type -> agent.ActivateAgentRequest - 37, // 89: agent.AgentControlService.ExecuteApproved:input_type -> agent.ExecuteApprovedRequest - 46, // 90: agent.AgentControlService.ApplyApprovedTaskControl:input_type -> agent.ApplyApprovedTaskControlRequest - 39, // 91: agent.AgentControlService.GetLoadedSIP:input_type -> agent.GetLoadedSIPRequest - 59, // 92: agent.AgentControlService.RequestRecordingUpload:input_type -> agent.RequestRecordingUploadRequest - 61, // 93: agent.AgentControlService.ReportCallEnded:input_type -> agent.ReportCallEndedRequest - 64, // 94: agent.AgentControlService.ReportCallResult:input_type -> agent.ReportCallResultRequest - 26, // 95: agent.AgentControlService.GetAgentStatus:output_type -> agent.GetAgentStatusResponse - 28, // 96: agent.AgentControlService.ActivateAgent:output_type -> agent.ActivateAgentResponse - 38, // 97: agent.AgentControlService.ExecuteApproved:output_type -> agent.ExecuteApprovedResponse - 47, // 98: agent.AgentControlService.ApplyApprovedTaskControl:output_type -> agent.ApplyApprovedTaskControlResponse - 40, // 99: agent.AgentControlService.GetLoadedSIP:output_type -> agent.GetLoadedSIPResponse - 60, // 100: agent.AgentControlService.RequestRecordingUpload:output_type -> agent.RequestRecordingUploadResponse - 62, // 101: agent.AgentControlService.ReportCallEnded:output_type -> agent.ReportCallEndedResponse - 65, // 102: agent.AgentControlService.ReportCallResult:output_type -> agent.ReportCallResultResponse - 95, // [95:103] is the sub-list for method output_type - 87, // [87:95] is the sub-list for method input_type - 87, // [87:87] is the sub-list for extension type_name - 87, // [87:87] is the sub-list for extension extendee - 0, // [0:87] is the sub-list for field type_name + 16, // 18: agent.ActivateAgentResponse.session:type_name -> agent.Session + 9, // 19: agent.ActivateAgentResponse.failure:type_name -> agent.Failure + 7, // 20: agent.ExecuteApprovedRequest.meta:type_name -> agent.RequestMeta + 7, // 21: agent.GetLoadedSIPRequest.meta:type_name -> agent.RequestMeta + 37, // 22: agent.GetLoadedSIPResponse.trunk_revision:type_name -> agent.GetLoadedSIPResponse.TrunkRevisionEntry + 7, // 23: agent.ApplyApprovedTaskControlRequest.meta:type_name -> agent.RequestMeta + 4, // 24: agent.ApplyApprovedTaskControlRequest.action:type_name -> agent.ControlAction + 5, // 25: agent.ApplyApprovedTaskControlRequest.active_call_policy:type_name -> agent.ActiveCallPolicy + 18, // 26: agent.UploadGrant.headers:type_name -> agent.Header + 7, // 27: agent.RequestRecordingUploadRequest.meta:type_name -> agent.RequestMeta + 17, // 28: agent.RequestRecordingUploadRequest.asset:type_name -> agent.AssetDescriptor + 29, // 29: agent.RequestRecordingUploadResponse.grant:type_name -> agent.UploadGrant + 7, // 30: agent.ReportCallEndedRequest.meta:type_name -> agent.RequestMeta + 10, // 31: agent.ReportCallEndedResponse.receipt:type_name -> agent.OperationReceipt + 7, // 32: agent.ReportCallResultRequest.meta:type_name -> agent.RequestMeta + 34, // 33: agent.ReportCallResultRequest.upload:type_name -> agent.UploadObservation + 10, // 34: agent.ReportCallResultResponse.receipt:type_name -> agent.OperationReceipt + 19, // 35: agent.AgentControlService.GetAgentStatus:input_type -> agent.GetAgentStatusRequest + 21, // 36: agent.AgentControlService.ActivateAgent:input_type -> agent.ActivateAgentRequest + 23, // 37: agent.AgentControlService.ExecuteApproved:input_type -> agent.ExecuteApprovedRequest + 27, // 38: agent.AgentControlService.ApplyApprovedTaskControl:input_type -> agent.ApplyApprovedTaskControlRequest + 25, // 39: agent.AgentControlService.GetLoadedSIP:input_type -> agent.GetLoadedSIPRequest + 30, // 40: agent.AgentControlService.RequestRecordingUpload:input_type -> agent.RequestRecordingUploadRequest + 32, // 41: agent.AgentControlService.ReportCallEnded:input_type -> agent.ReportCallEndedRequest + 35, // 42: agent.AgentControlService.ReportCallResult:input_type -> agent.ReportCallResultRequest + 20, // 43: agent.AgentControlService.GetAgentStatus:output_type -> agent.GetAgentStatusResponse + 22, // 44: agent.AgentControlService.ActivateAgent:output_type -> agent.ActivateAgentResponse + 24, // 45: agent.AgentControlService.ExecuteApproved:output_type -> agent.ExecuteApprovedResponse + 28, // 46: agent.AgentControlService.ApplyApprovedTaskControl:output_type -> agent.ApplyApprovedTaskControlResponse + 26, // 47: agent.AgentControlService.GetLoadedSIP:output_type -> agent.GetLoadedSIPResponse + 31, // 48: agent.AgentControlService.RequestRecordingUpload:output_type -> agent.RequestRecordingUploadResponse + 33, // 49: agent.AgentControlService.ReportCallEnded:output_type -> agent.ReportCallEndedResponse + 36, // 50: agent.AgentControlService.ReportCallResult:output_type -> agent.ReportCallResultResponse + 43, // [43:51] is the sub-list for method output_type + 35, // [35:43] is the sub-list for method input_type + 35, // [35:35] is the sub-list for extension type_name + 35, // [35:35] is the sub-list for extension extendee + 0, // [0:35] is the sub-list for field type_name } func init() { file_agent_agent_proto_init() } @@ -5520,8 +3175,8 @@ func file_agent_agent_proto_init() { File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_agent_agent_proto_rawDesc), len(file_agent_agent_proto_rawDesc)), - NumEnums: 10, - NumMessages: 57, + NumEnums: 7, + NumMessages: 31, NumExtensions: 0, NumServices: 1, }, diff --git a/internal/rpc/service_test.go b/internal/rpc/service_test.go index 0cbda69..ac32d07 100644 --- a/internal/rpc/service_test.go +++ b/internal/rpc/service_test.go @@ -5,6 +5,7 @@ import ( "testing" agentpb "git.ipao.vip/rogee/go-sip/gen/agent" + "google.golang.org/protobuf/reflect/protoreflect" ) func TestAgentControlServiceOnlyExposesApprovedMethods(t *testing.T) { @@ -22,6 +23,29 @@ func TestAgentControlServiceOnlyExposesApprovedMethods(t *testing.T) { } } +func TestAgentProtoOmitsRetiredBusinessPayloads(t *testing.T) { + file := agentpb.File_agent_agent_proto + for _, name := range []string{ + "ConfigReference", "UploadPolicy", "ExecutionBinding", + "GetBootstrapRequest", "GetBootstrapResponse", "SetAdmissionStateRequest", "SetAdmissionStateResponse", + "ExecuteRequest", "ExecuteResponse", "ExecuteAuthorizedRequest", "ExecuteAuthorizedResponse", + "GetExecutionPermitRequest", "ExecutionPermit", "GetExecutionPermitResponse", + "ApplyTaskControlRequest", "ApplyTaskControlResponse", + "QueryExecutionRequest", "ExecutionSnapshot", "QueryExecutionResponse", + "ExecutionFact", "ReportExecutionEventRequest", "ReportExecutionEventResponse", + "RequestUploadRequest", "RequestUploadResponse", "CompleteUploadRequest", "CompleteUploadResponse", + } { + if file.Messages().ByName(protoreflect.Name(name)) != nil { + t.Fatalf("retired Agent Proto message %s is still declared", name) + } + } + for _, name := range []string{"ExecutionState", "UploadState", "FactKind"} { + if file.Enums().ByName(protoreflect.Name(name)) != nil { + t.Fatalf("retired Agent Proto enum %s is still declared", name) + } + } +} + func TestAgentServerUsesLoadedSIPInsteadOfRetiredStaticArtifact(t *testing.T) { options := reflect.TypeOf(ServerOptions{}) for _, name := range []string{"StaticArtifactRaw", "StaticArtifactExpected"} { diff --git a/proto/agent/agent.proto b/proto/agent/agent.proto index 8fa5558..edf25cd 100644 --- a/proto/agent/agent.proto +++ b/proto/agent/agent.proto @@ -71,42 +71,12 @@ enum ActiveCallPolicy { ACTIVE_CALL_POLICY_HANGUP = 2; } -enum ExecutionState { - EXECUTION_STATE_UNSPECIFIED = 0; - EXECUTION_STATE_PREPARED = 1; - EXECUTION_STATE_PERMIT_GRANTED = 2; - EXECUTION_STATE_DISPATCHING = 3; - EXECUTION_STATE_OBSERVED = 4; - EXECUTION_STATE_UNKNOWN = 5; - EXECUTION_STATE_TERMINAL = 6; -} - enum AssetKind { ASSET_KIND_UNSPECIFIED = 0; ASSET_KIND_RECORDING = 1; ASSET_KIND_TRANSCRIPT = 2; } -enum UploadState { - UPLOAD_STATE_UNSPECIFIED = 0; - UPLOAD_STATE_REQUESTED = 1; - UPLOAD_STATE_COMPLETED = 3; - UPLOAD_STATE_FAILED = 4; - reserved 2, 5; - reserved "UPLOAD_STATE_UPLOADING", "UPLOAD_STATE_EXPIRED"; -} - -enum FactKind { - FACT_KIND_UNSPECIFIED = 0; - FACT_KIND_EXECUTION_ACCEPTED = 1; - FACT_KIND_CALL_STATUS = 2; - FACT_KIND_CALL_FINISHED = 3; - FACT_KIND_TRANSCRIPT_UPDATED = 4; - FACT_KIND_TRANSCRIPT_FAILED = 5; - FACT_KIND_CONTACT_OPT_OUT = 6; - FACT_KIND_RECORDING_PROGRESS = 7; -} - message RequestMeta { string protocol_version = 1; string request_id = 2; @@ -180,10 +150,9 @@ message ResourceSample { string missing_reason = 11; } -// Project-local v0.1 status convention: exactly one kind="sip" entry identifies -// the SIP artifact loaded by the Agent/Asterisk; state="applied" means that exact -// artifact is active. revision and config_sha256 must match the approved artifact. -// Missing, duplicate, or mismatched SIP entries are unknown and fail closed. +// Optional status metadata is not an admission grant. The Dispatcher checks +// GetLoadedSIP revisions separately; a Mock status cannot prove Asterisk loaded +// the approved configuration. message AppliedConfig { string kind = 1; string revision = 2; @@ -215,35 +184,6 @@ message Session { bytes session_credential = 4; } -message ConfigReference { - string kind = 1; - string version = 2; - string sha256 = 3; - string source = 4; -} - -message UploadPolicy { - bool enabled = 1; - int64 max_asset_bytes = 2; - repeated string allowed_hosts = 4; - reserved 3; - reserved "min_retention_ms"; -} - -message ExecutionBinding { - string tenant_id = 1; - string tenant_key = 2; - string execution_id = 3; - string task_id = 4; - string task_item_id = 5; - int64 task_revision = 6; - string call_id = 7; - string attempt_id = 8; - string agent_version_id = 9; - string route_policy_id = 10; - string caller_profile_id = 11; -} - message AssetDescriptor { AssetKind kind = 1; string asset_id = 2; @@ -288,73 +228,6 @@ message ActivateAgentResponse { Failure failure = 4; } -message GetBootstrapRequest { - RequestMeta meta = 1; - string agent_id = 2; - string cell_id = 3; - string boot_id = 4; - uint64 session_generation = 5; -} - -message GetBootstrapResponse { - ResponseMeta meta = 1; - ActivationState state = 2; - repeated ConfigReference runtime_configs = 3; - UploadPolicy upload_policy = 4; - Failure failure = 5; -} - -message SetAdmissionStateRequest { - RequestMeta meta = 1; - AgentBinding target = 2; - AdmissionState state = 3; - string barrier_id = 4; - uint64 expected_admission_generation = 5; - string reason = 6; -} - -message SetAdmissionStateResponse { - OperationReceipt receipt = 1; - uint64 applied_admission_generation = 2; -} - -message ExecuteRequest { - RequestMeta meta = 1; - ExecutionBinding binding = 2; - bytes call_execute_json = 3; - string config_sha256 = 4; - uint64 admission_generation = 5; - string resource_reservation_id = 6; - string permit_id = 7; -} - -message ExecuteResponse { - OperationReceipt receipt = 1; - ExecutionState state = 2; -} - -// Versioned project-local D→Agent execution contract. Only the Dispatcher -// evaluates the task/line schedule, allowlist, route and effective duration. -// The Agent checks the authorized deadline and transport/session identity; it -// never selects another trunk or recalculates outbound business policy. -message ExecuteAuthorizedRequest { - string schema_version = 1; // agent-authorized-origination.v0.1 - RequestMeta meta = 2; - ExecutionBinding binding = 3; - string selected_trunk_id = 4; - string caller_id = 5; - string callee = 6; - int64 ring_timeout_ms = 7; - int64 max_call_duration_ms = 8; - int64 dial_before_unix_ms = 9; // Exclusive D-issued deadline. - string bound_snapshot_sha256 = 10; -} - -message ExecuteAuthorizedResponse { - OperationReceipt receipt = 1; - ExecutionState state = 2; -} - // Exact, immutable task/provider bytes and SIP revision accompany each // authorized execution. Provider bytes may contain credentials: never log // or persist this request body. The Agent checks session, binding and @@ -392,46 +265,6 @@ message GetLoadedSIPResponse { map trunk_revision = 1; } -message GetExecutionPermitRequest { - RequestMeta meta = 1; - ExecutionBinding binding = 2; - string resource_reservation_id = 3; - int64 expected_task_revision = 4; - uint64 admission_generation = 5; - string config_sha256 = 6; -} - -message ExecutionPermit { - string permit_id = 1; - string resource_reservation_id = 2; - int64 issued_at_unix_ms = 3; - int64 expires_at_unix_ms = 4; - string dispatcher_epoch = 5; - uint64 session_generation = 6; - string fencing_token = 7; - string config_sha256 = 8; -} - -message GetExecutionPermitResponse { - OperationReceipt receipt = 1; - ExecutionPermit permit = 2; -} - -message ApplyTaskControlRequest { - RequestMeta meta = 1; - ExecutionBinding binding = 2; - ControlAction action = 3; - ActiveCallPolicy active_call_policy = 4; - int64 expected_task_revision = 5; - string reason = 6; -} - -message ApplyTaskControlResponse { - OperationReceipt receipt = 1; - int64 applied_task_revision = 2; - ExecutionState state = 3; -} - // Current task-level control has no external command ID, revision CAS or // execution binding. The authenticated session must match dispatcher_id. message ApplyApprovedTaskControlRequest { @@ -447,55 +280,6 @@ message ApplyApprovedTaskControlResponse { bool accepted = 1; } -message QueryExecutionRequest { - RequestMeta meta = 1; - ExecutionBinding binding = 2; -} - -message ExecutionSnapshot { - ExecutionBinding binding = 1; - ExecutionState state = 2; - string call_state = 3; - string attempt_id = 4; - string reason_code = 5; - int64 observed_at_unix_ms = 6; - bool unknown = 7; - repeated AssetDescriptor assets = 8; -} - -message QueryExecutionResponse { - ResponseMeta meta = 1; - ExecutionSnapshot snapshot = 2; - Failure failure = 3; -} - -message ExecutionFact { - string fact_id = 1; - string content_sha256 = 2; - ExecutionBinding binding = 3; - FactKind kind = 4; - int64 observed_at_unix_ms = 5; - string source_boot_id = 6; - uint64 source_sequence = 7; - bytes payload_json = 8; -} - -message ReportExecutionEventRequest { - RequestMeta meta = 1; - ExecutionFact fact = 2; -} - -message ReportExecutionEventResponse { - OperationReceipt receipt = 1; -} - -message RequestUploadRequest { - RequestMeta meta = 1; - ExecutionBinding binding = 2; - AssetDescriptor asset = 3; - string upload_id = 4; -} - message UploadGrant { string upload_id = 1; string target_url = 2; @@ -507,28 +291,6 @@ message UploadGrant { string bucket = 8; } -message RequestUploadResponse { - OperationReceipt receipt = 1; - UploadGrant grant = 2; - UploadState state = 3; -} - -message CompleteUploadRequest { - RequestMeta meta = 1; - ExecutionBinding binding = 2; - AssetDescriptor asset = 3; - string upload_id = 4; - int64 uploaded_size_bytes = 5; - string uploaded_checksum_sha256 = 6; -} - -message CompleteUploadResponse { - OperationReceipt receipt = 1; - UploadState state = 2; - reserved 3; - reserved "oss_id"; -} - // These facts refer only to the Dispatcher-approved execution identified by // source_event_id; no audio bytes or temporary credential is persisted in MQ. message RequestRecordingUploadRequest { diff --git a/proto/manifest.json b/proto/manifest.json index 6efbb5a..6acfa2c 100644 --- a/proto/manifest.json +++ b/proto/manifest.json @@ -34,13 +34,13 @@ }, { "path": "proto/agent/agent.proto", - "bytes": 14375, - "sha256": "f9a721c8d2bc560ed07ec6deedd7ebc080b248069d2e657f7a906405e1cb1e4f" + "bytes": 8626, + "sha256": "9a76ca785c6466b9d5eb217a9c28cda80bb738f308210df66ad6818c2e74805c" }, { "path": "gen/agent/agent.pb.go", - "bytes": 183338, - "sha256": "a5b86b1f8e9a8866bb99bb67747a82107064985c730aee70c33fa9b6c0e23341" + "bytes": 104492, + "sha256": "e1deb02528c51837cdc0c66c4344b4e09704e7db096de8b3fe527654f98e4647" }, { "path": "gen/agent/agent_grpc.pb.go",