controlv1

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 2, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package controlv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	ControlService_Pack_FullMethodName                 = "/agentpaas.control.v1.ControlService/Pack"
	ControlService_Run_FullMethodName                  = "/agentpaas.control.v1.ControlService/Run"
	ControlService_Stop_FullMethodName                 = "/agentpaas.control.v1.ControlService/Stop"
	ControlService_Logs_FullMethodName                 = "/agentpaas.control.v1.ControlService/Logs"
	ControlService_PolicyApply_FullMethodName          = "/agentpaas.control.v1.ControlService/PolicyApply"
	ControlService_SecretSet_FullMethodName            = "/agentpaas.control.v1.ControlService/SecretSet"
	ControlService_SecretGrant_FullMethodName          = "/agentpaas.control.v1.ControlService/SecretGrant"
	ControlService_SecretRevoke_FullMethodName         = "/agentpaas.control.v1.ControlService/SecretRevoke"
	ControlService_AuditQuery_FullMethodName           = "/agentpaas.control.v1.ControlService/AuditQuery"
	ControlService_AuditExport_FullMethodName          = "/agentpaas.control.v1.ControlService/AuditExport"
	ControlService_Doctor_FullMethodName               = "/agentpaas.control.v1.ControlService/Doctor"
	ControlService_ValidateAgentProject_FullMethodName = "/agentpaas.control.v1.ControlService/ValidateAgentProject"
	ControlService_SummarizeRun_FullMethodName         = "/agentpaas.control.v1.ControlService/SummarizeRun"
	ControlService_ExplainFailure_FullMethodName       = "/agentpaas.control.v1.ControlService/ExplainFailure"
	ControlService_ExplainPolicyDenial_FullMethodName  = "/agentpaas.control.v1.ControlService/ExplainPolicyDenial"
	ControlService_RecommendPolicyPatch_FullMethodName = "/agentpaas.control.v1.ControlService/RecommendPolicyPatch"
	ControlService_GetRunTimeline_FullMethodName       = "/agentpaas.control.v1.ControlService/GetRunTimeline"
	ControlService_NextAction_FullMethodName           = "/agentpaas.control.v1.ControlService/NextAction"
	ControlService_CronAdd_FullMethodName              = "/agentpaas.control.v1.ControlService/CronAdd"
	ControlService_CronList_FullMethodName             = "/agentpaas.control.v1.ControlService/CronList"
	ControlService_CronRemove_FullMethodName           = "/agentpaas.control.v1.ControlService/CronRemove"
)

Variables

View Source
var (
	LogLevel_name = map[int32]string{
		0: "LOG_LEVEL_UNSPECIFIED",
		1: "LOG_LEVEL_DEBUG",
		2: "LOG_LEVEL_INFO",
		3: "LOG_LEVEL_WARN",
		4: "LOG_LEVEL_ERROR",
	}
	LogLevel_value = map[string]int32{
		"LOG_LEVEL_UNSPECIFIED": 0,
		"LOG_LEVEL_DEBUG":       1,
		"LOG_LEVEL_INFO":        2,
		"LOG_LEVEL_WARN":        3,
		"LOG_LEVEL_ERROR":       4,
	}
)

Enum value maps for LogLevel.

View Source
var (
	EventType_name = map[int32]string{
		0:  "EVENT_TYPE_UNSPECIFIED",
		1:  "EVENT_TYPE_INVOKE",
		2:  "EVENT_TYPE_CANCEL",
		3:  "EVENT_TYPE_POLICY_APPLY",
		4:  "EVENT_TYPE_POLICY_DENIAL",
		5:  "EVENT_TYPE_SECRET_SET",
		6:  "EVENT_TYPE_SECRET_GRANT",
		7:  "EVENT_TYPE_SECRET_REVOKE",
		8:  "EVENT_TYPE_PACK",
		9:  "EVENT_TYPE_RUN",
		10: "EVENT_TYPE_STOP",
	}
	EventType_value = map[string]int32{
		"EVENT_TYPE_UNSPECIFIED":   0,
		"EVENT_TYPE_INVOKE":        1,
		"EVENT_TYPE_CANCEL":        2,
		"EVENT_TYPE_POLICY_APPLY":  3,
		"EVENT_TYPE_POLICY_DENIAL": 4,
		"EVENT_TYPE_SECRET_SET":    5,
		"EVENT_TYPE_SECRET_GRANT":  6,
		"EVENT_TYPE_SECRET_REVOKE": 7,
		"EVENT_TYPE_PACK":          8,
		"EVENT_TYPE_RUN":           9,
		"EVENT_TYPE_STOP":          10,
	}
)

Enum value maps for EventType.

View Source
var (
	SecretType_name = map[int32]string{
		0: "SECRET_TYPE_UNSPECIFIED",
		1: "SECRET_TYPE_ENV",
		2: "SECRET_TYPE_FILE",
		3: "SECRET_TYPE_INLINE",
	}
	SecretType_value = map[string]int32{
		"SECRET_TYPE_UNSPECIFIED": 0,
		"SECRET_TYPE_ENV":         1,
		"SECRET_TYPE_FILE":        2,
		"SECRET_TYPE_INLINE":      3,
	}
)

Enum value maps for SecretType.

View Source
var ControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "agentpaas.control.v1.ControlService",
	HandlerType: (*ControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Pack",
			Handler:    _ControlService_Pack_Handler,
		},
		{
			MethodName: "Run",
			Handler:    _ControlService_Run_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _ControlService_Stop_Handler,
		},
		{
			MethodName: "PolicyApply",
			Handler:    _ControlService_PolicyApply_Handler,
		},
		{
			MethodName: "SecretSet",
			Handler:    _ControlService_SecretSet_Handler,
		},
		{
			MethodName: "SecretGrant",
			Handler:    _ControlService_SecretGrant_Handler,
		},
		{
			MethodName: "SecretRevoke",
			Handler:    _ControlService_SecretRevoke_Handler,
		},
		{
			MethodName: "AuditQuery",
			Handler:    _ControlService_AuditQuery_Handler,
		},
		{
			MethodName: "AuditExport",
			Handler:    _ControlService_AuditExport_Handler,
		},
		{
			MethodName: "Doctor",
			Handler:    _ControlService_Doctor_Handler,
		},
		{
			MethodName: "ValidateAgentProject",
			Handler:    _ControlService_ValidateAgentProject_Handler,
		},
		{
			MethodName: "SummarizeRun",
			Handler:    _ControlService_SummarizeRun_Handler,
		},
		{
			MethodName: "ExplainFailure",
			Handler:    _ControlService_ExplainFailure_Handler,
		},
		{
			MethodName: "ExplainPolicyDenial",
			Handler:    _ControlService_ExplainPolicyDenial_Handler,
		},
		{
			MethodName: "RecommendPolicyPatch",
			Handler:    _ControlService_RecommendPolicyPatch_Handler,
		},
		{
			MethodName: "GetRunTimeline",
			Handler:    _ControlService_GetRunTimeline_Handler,
		},
		{
			MethodName: "NextAction",
			Handler:    _ControlService_NextAction_Handler,
		},
		{
			MethodName: "CronAdd",
			Handler:    _ControlService_CronAdd_Handler,
		},
		{
			MethodName: "CronList",
			Handler:    _ControlService_CronList_Handler,
		},
		{
			MethodName: "CronRemove",
			Handler:    _ControlService_CronRemove_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Logs",
			Handler:       _ControlService_Logs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "control/v1/control.proto",
}

ControlService_ServiceDesc is the grpc.ServiceDesc for ControlService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_control_v1_control_proto protoreflect.FileDescriptor

Functions

func RegisterControlServiceHandler

func RegisterControlServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterControlServiceHandler registers the http handlers for service ControlService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterControlServiceHandlerClient

func RegisterControlServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ControlServiceClient) error

RegisterControlServiceHandlerClient registers the http handlers for service ControlService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ControlServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ControlServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ControlServiceClient" to call the correct interceptors. This client ignores the HTTP middlewares.

func RegisterControlServiceHandlerFromEndpoint

func RegisterControlServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterControlServiceHandlerFromEndpoint is same as RegisterControlServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterControlServiceHandlerServer

func RegisterControlServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ControlServiceServer) error

RegisterControlServiceHandlerServer registers the http handlers for service ControlService to "mux". UnaryRPC :call ControlServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterControlServiceHandlerFromEndpoint instead. GRPC interceptors will not work for this type of registration. To use interceptors, you must use the "runtime.WithMiddlewares" option in the "runtime.NewServeMux" call.

func RegisterControlServiceServer

func RegisterControlServiceServer(s grpc.ServiceRegistrar, srv ControlServiceServer)

Types

type AuditChainVerification

type AuditChainVerification struct {
	Verified         bool                    `protobuf:"varint,1,opt,name=verified,proto3" json:"verified,omitempty"`
	AuditRecordCount int64                   `protobuf:"varint,2,opt,name=audit_record_count,json=auditRecordCount,proto3" json:"audit_record_count,omitempty"`
	AuditHeadSeq     int64                   `protobuf:"varint,3,opt,name=audit_head_seq,json=auditHeadSeq,proto3" json:"audit_head_seq,omitempty"`
	CheckpointCount  int32                   `protobuf:"varint,4,opt,name=checkpoint_count,json=checkpointCount,proto3" json:"checkpoint_count,omitempty"`
	Issues           []*AuditCheckpointIssue `protobuf:"bytes,5,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditChainVerification) Descriptor deprecated

func (*AuditChainVerification) Descriptor() ([]byte, []int)

Deprecated: Use AuditChainVerification.ProtoReflect.Descriptor instead.

func (*AuditChainVerification) GetAuditHeadSeq

func (x *AuditChainVerification) GetAuditHeadSeq() int64

func (*AuditChainVerification) GetAuditRecordCount

func (x *AuditChainVerification) GetAuditRecordCount() int64

func (*AuditChainVerification) GetCheckpointCount

func (x *AuditChainVerification) GetCheckpointCount() int32

func (*AuditChainVerification) GetIssues

func (x *AuditChainVerification) GetIssues() []*AuditCheckpointIssue

func (*AuditChainVerification) GetVerified

func (x *AuditChainVerification) GetVerified() bool

func (*AuditChainVerification) ProtoMessage

func (*AuditChainVerification) ProtoMessage()

func (*AuditChainVerification) ProtoReflect

func (x *AuditChainVerification) ProtoReflect() protoreflect.Message

func (*AuditChainVerification) Reset

func (x *AuditChainVerification) Reset()

func (*AuditChainVerification) String

func (x *AuditChainVerification) String() string

type AuditCheckpointIssue

type AuditCheckpointIssue struct {
	Type    string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Seq     int64  `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	Line    int32  `protobuf:"varint,4,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditCheckpointIssue) Descriptor deprecated

func (*AuditCheckpointIssue) Descriptor() ([]byte, []int)

Deprecated: Use AuditCheckpointIssue.ProtoReflect.Descriptor instead.

func (*AuditCheckpointIssue) GetLine

func (x *AuditCheckpointIssue) GetLine() int32

func (*AuditCheckpointIssue) GetMessage

func (x *AuditCheckpointIssue) GetMessage() string

func (*AuditCheckpointIssue) GetSeq

func (x *AuditCheckpointIssue) GetSeq() int64

func (*AuditCheckpointIssue) GetType

func (x *AuditCheckpointIssue) GetType() string

func (*AuditCheckpointIssue) ProtoMessage

func (*AuditCheckpointIssue) ProtoMessage()

func (*AuditCheckpointIssue) ProtoReflect

func (x *AuditCheckpointIssue) ProtoReflect() protoreflect.Message

func (*AuditCheckpointIssue) Reset

func (x *AuditCheckpointIssue) Reset()

func (*AuditCheckpointIssue) String

func (x *AuditCheckpointIssue) String() string

type AuditEntry

type AuditEntry struct {
	EventId   string                 `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	EventType EventType              `protobuf:"varint,2,opt,name=event_type,json=eventType,proto3,enum=agentpaas.control.v1.EventType" json:"event_type,omitempty"`
	AgentName string                 `protobuf:"bytes,3,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	RunId     string                 `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Payload   []byte                 `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditEntry) Descriptor deprecated

func (*AuditEntry) Descriptor() ([]byte, []int)

Deprecated: Use AuditEntry.ProtoReflect.Descriptor instead.

func (*AuditEntry) GetAgentName

func (x *AuditEntry) GetAgentName() string

func (*AuditEntry) GetEventId

func (x *AuditEntry) GetEventId() string

func (*AuditEntry) GetEventType

func (x *AuditEntry) GetEventType() EventType

func (*AuditEntry) GetPayload

func (x *AuditEntry) GetPayload() []byte

func (*AuditEntry) GetRunId

func (x *AuditEntry) GetRunId() string

func (*AuditEntry) GetTimestamp

func (x *AuditEntry) GetTimestamp() *timestamppb.Timestamp

func (*AuditEntry) ProtoMessage

func (*AuditEntry) ProtoMessage()

func (*AuditEntry) ProtoReflect

func (x *AuditEntry) ProtoReflect() protoreflect.Message

func (*AuditEntry) Reset

func (x *AuditEntry) Reset()

func (*AuditEntry) String

func (x *AuditEntry) String() string

type AuditExportRequest

type AuditExportRequest struct {

	// Time range to export.
	TimeRange *TimeRange `protobuf:"bytes,1,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	// Output format (e.g. "json", "csv", "ndjson").
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	// Whether to include event payloads.
	IncludePayloads bool `protobuf:"varint,3,opt,name=include_payloads,json=includePayloads,proto3" json:"include_payloads,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditExportRequest) Descriptor deprecated

func (*AuditExportRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuditExportRequest.ProtoReflect.Descriptor instead.

func (*AuditExportRequest) GetFormat

func (x *AuditExportRequest) GetFormat() string

func (*AuditExportRequest) GetIncludePayloads

func (x *AuditExportRequest) GetIncludePayloads() bool

func (*AuditExportRequest) GetTimeRange

func (x *AuditExportRequest) GetTimeRange() *TimeRange

func (*AuditExportRequest) ProtoMessage

func (*AuditExportRequest) ProtoMessage()

func (*AuditExportRequest) ProtoReflect

func (x *AuditExportRequest) ProtoReflect() protoreflect.Message

func (*AuditExportRequest) Reset

func (x *AuditExportRequest) Reset()

func (*AuditExportRequest) String

func (x *AuditExportRequest) String() string

type AuditExportResponse

type AuditExportResponse struct {

	// Exported audit data in the requested format.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Number of entries exported.
	EntryCount int32 `protobuf:"varint,2,opt,name=entry_count,json=entryCount,proto3" json:"entry_count,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditExportResponse) Descriptor deprecated

func (*AuditExportResponse) Descriptor() ([]byte, []int)

Deprecated: Use AuditExportResponse.ProtoReflect.Descriptor instead.

func (*AuditExportResponse) GetData

func (x *AuditExportResponse) GetData() []byte

func (*AuditExportResponse) GetEntryCount

func (x *AuditExportResponse) GetEntryCount() int32

func (*AuditExportResponse) ProtoMessage

func (*AuditExportResponse) ProtoMessage()

func (*AuditExportResponse) ProtoReflect

func (x *AuditExportResponse) ProtoReflect() protoreflect.Message

func (*AuditExportResponse) Reset

func (x *AuditExportResponse) Reset()

func (*AuditExportResponse) String

func (x *AuditExportResponse) String() string

type AuditQueryRequest

type AuditQueryRequest struct {

	// Optional: filter by agent name.
	AgentName string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	// Optional: filter by run ID.
	RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Optional: filter by event type.
	EventType EventType `protobuf:"varint,3,opt,name=event_type,json=eventType,proto3,enum=agentpaas.control.v1.EventType" json:"event_type,omitempty"`
	// Optional: time range filter.
	TimeRange *TimeRange `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	// Maximum number of results.
	PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Pagination token.
	PageToken string `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditQueryRequest) Descriptor deprecated

func (*AuditQueryRequest) Descriptor() ([]byte, []int)

Deprecated: Use AuditQueryRequest.ProtoReflect.Descriptor instead.

func (*AuditQueryRequest) GetAgentName

func (x *AuditQueryRequest) GetAgentName() string

func (*AuditQueryRequest) GetEventType

func (x *AuditQueryRequest) GetEventType() EventType

func (*AuditQueryRequest) GetPageSize

func (x *AuditQueryRequest) GetPageSize() int32

func (*AuditQueryRequest) GetPageToken

func (x *AuditQueryRequest) GetPageToken() string

func (*AuditQueryRequest) GetRunId

func (x *AuditQueryRequest) GetRunId() string

func (*AuditQueryRequest) GetTimeRange

func (x *AuditQueryRequest) GetTimeRange() *TimeRange

func (*AuditQueryRequest) ProtoMessage

func (*AuditQueryRequest) ProtoMessage()

func (*AuditQueryRequest) ProtoReflect

func (x *AuditQueryRequest) ProtoReflect() protoreflect.Message

func (*AuditQueryRequest) Reset

func (x *AuditQueryRequest) Reset()

func (*AuditQueryRequest) String

func (x *AuditQueryRequest) String() string

type AuditQueryResponse

type AuditQueryResponse struct {
	Entries           []*AuditEntry           `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	NextPageToken     string                  `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	TotalCount        int32                   `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	ChainVerification *AuditChainVerification `protobuf:"bytes,4,opt,name=chain_verification,json=chainVerification,proto3" json:"chain_verification,omitempty"`
	// contains filtered or unexported fields
}

func (*AuditQueryResponse) Descriptor deprecated

func (*AuditQueryResponse) Descriptor() ([]byte, []int)

Deprecated: Use AuditQueryResponse.ProtoReflect.Descriptor instead.

func (*AuditQueryResponse) GetChainVerification

func (x *AuditQueryResponse) GetChainVerification() *AuditChainVerification

func (*AuditQueryResponse) GetEntries

func (x *AuditQueryResponse) GetEntries() []*AuditEntry

func (*AuditQueryResponse) GetNextPageToken

func (x *AuditQueryResponse) GetNextPageToken() string

func (*AuditQueryResponse) GetTotalCount

func (x *AuditQueryResponse) GetTotalCount() int32

func (*AuditQueryResponse) ProtoMessage

func (*AuditQueryResponse) ProtoMessage()

func (*AuditQueryResponse) ProtoReflect

func (x *AuditQueryResponse) ProtoReflect() protoreflect.Message

func (*AuditQueryResponse) Reset

func (x *AuditQueryResponse) Reset()

func (*AuditQueryResponse) String

func (x *AuditQueryResponse) String() string

type BudgetConfig

type BudgetConfig struct {

	// Maximum token budget for the run.
	MaxTokens int64 `protobuf:"varint,1,opt,name=max_tokens,json=maxTokens,proto3" json:"max_tokens,omitempty"`
	// Maximum cost in USD.
	MaxCostUsd float64 `protobuf:"fixed64,2,opt,name=max_cost_usd,json=maxCostUsd,proto3" json:"max_cost_usd,omitempty"`
	// Maximum wall-clock time in milliseconds.
	MaxWallClockMs int64 `protobuf:"varint,3,opt,name=max_wall_clock_ms,json=maxWallClockMs,proto3" json:"max_wall_clock_ms,omitempty"`
	// Maximum iteration count.
	MaxIterations int32 `protobuf:"varint,4,opt,name=max_iterations,json=maxIterations,proto3" json:"max_iterations,omitempty"`
	// contains filtered or unexported fields
}

func (*BudgetConfig) Descriptor deprecated

func (*BudgetConfig) Descriptor() ([]byte, []int)

Deprecated: Use BudgetConfig.ProtoReflect.Descriptor instead.

func (*BudgetConfig) GetMaxCostUsd

func (x *BudgetConfig) GetMaxCostUsd() float64

func (*BudgetConfig) GetMaxIterations

func (x *BudgetConfig) GetMaxIterations() int32

func (*BudgetConfig) GetMaxTokens

func (x *BudgetConfig) GetMaxTokens() int64

func (*BudgetConfig) GetMaxWallClockMs

func (x *BudgetConfig) GetMaxWallClockMs() int64

func (*BudgetConfig) ProtoMessage

func (*BudgetConfig) ProtoMessage()

func (*BudgetConfig) ProtoReflect

func (x *BudgetConfig) ProtoReflect() protoreflect.Message

func (*BudgetConfig) Reset

func (x *BudgetConfig) Reset()

func (*BudgetConfig) String

func (x *BudgetConfig) String() string

type CheckResult

type CheckResult struct {

	// Name of the health check (e.g. "buf_connectivity", "docker_daemon").
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Check status: "ok", "warning", "error".
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// Human-readable description of the check result.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Suggested remediation if the check failed.
	FixHint string `protobuf:"bytes,4,opt,name=fix_hint,json=fixHint,proto3" json:"fix_hint,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckResult) Descriptor deprecated

func (*CheckResult) Descriptor() ([]byte, []int)

Deprecated: Use CheckResult.ProtoReflect.Descriptor instead.

func (*CheckResult) GetFixHint

func (x *CheckResult) GetFixHint() string

func (*CheckResult) GetMessage

func (x *CheckResult) GetMessage() string

func (*CheckResult) GetName

func (x *CheckResult) GetName() string

func (*CheckResult) GetStatus

func (x *CheckResult) GetStatus() string

func (*CheckResult) ProtoMessage

func (*CheckResult) ProtoMessage()

func (*CheckResult) ProtoReflect

func (x *CheckResult) ProtoReflect() protoreflect.Message

func (*CheckResult) Reset

func (x *CheckResult) Reset()

func (*CheckResult) String

func (x *CheckResult) String() string

type ConfirmationRequirement

type ConfirmationRequirement struct {
	RequiresConfirmation bool   `protobuf:"varint,1,opt,name=requires_confirmation,json=requiresConfirmation,proto3" json:"requires_confirmation,omitempty"`
	ConfirmationId       string `protobuf:"bytes,2,opt,name=confirmation_id,json=confirmationId,proto3" json:"confirmation_id,omitempty"`
	// "low", "medium", or "high".
	RiskLevel            string         `protobuf:"bytes,3,opt,name=risk_level,json=riskLevel,proto3" json:"risk_level,omitempty"`
	Rationale            string         `protobuf:"bytes,4,opt,name=rationale,proto3" json:"rationale,omitempty"`
	AffectedDestinations []string       `protobuf:"bytes,5,rep,name=affected_destinations,json=affectedDestinations,proto3" json:"affected_destinations,omitempty"`
	CredentialIds        []string       `protobuf:"bytes,6,rep,name=credential_ids,json=credentialIds,proto3" json:"credential_ids,omitempty"`
	EvidenceRefs         []*EvidenceRef `protobuf:"bytes,7,rep,name=evidence_refs,json=evidenceRefs,proto3" json:"evidence_refs,omitempty"`
	// contains filtered or unexported fields
}

ConfirmationRequirement encodes the trust-boundary confirmation protocol.

func (*ConfirmationRequirement) Descriptor deprecated

func (*ConfirmationRequirement) Descriptor() ([]byte, []int)

Deprecated: Use ConfirmationRequirement.ProtoReflect.Descriptor instead.

func (*ConfirmationRequirement) GetAffectedDestinations

func (x *ConfirmationRequirement) GetAffectedDestinations() []string

func (*ConfirmationRequirement) GetConfirmationId

func (x *ConfirmationRequirement) GetConfirmationId() string

func (*ConfirmationRequirement) GetCredentialIds

func (x *ConfirmationRequirement) GetCredentialIds() []string

func (*ConfirmationRequirement) GetEvidenceRefs

func (x *ConfirmationRequirement) GetEvidenceRefs() []*EvidenceRef

func (*ConfirmationRequirement) GetRationale

func (x *ConfirmationRequirement) GetRationale() string

func (*ConfirmationRequirement) GetRequiresConfirmation

func (x *ConfirmationRequirement) GetRequiresConfirmation() bool

func (*ConfirmationRequirement) GetRiskLevel

func (x *ConfirmationRequirement) GetRiskLevel() string

func (*ConfirmationRequirement) ProtoMessage

func (*ConfirmationRequirement) ProtoMessage()

func (*ConfirmationRequirement) ProtoReflect

func (x *ConfirmationRequirement) ProtoReflect() protoreflect.Message

func (*ConfirmationRequirement) Reset

func (x *ConfirmationRequirement) Reset()

func (*ConfirmationRequirement) String

func (x *ConfirmationRequirement) String() string

type ControlServiceClient

type ControlServiceClient interface {
	// Pack builds an agent image from a project directory.
	Pack(ctx context.Context, in *PackRequest, opts ...grpc.CallOption) (*PackResponse, error)
	// Run starts a new agent run with the given budget and payload.
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
	// Stop terminates a running agent run.
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	// Logs returns a stream of log entries, optionally following in real-time.
	Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[LogEntry], error)
	// PolicyApply applies or validates an OPA/Rego policy.
	PolicyApply(ctx context.Context, in *PolicyApplyRequest, opts ...grpc.CallOption) (*PolicyApplyResponse, error)
	// SecretSet creates or updates a secret.
	SecretSet(ctx context.Context, in *SecretSetRequest, opts ...grpc.CallOption) (*SecretSetResponse, error)
	// SecretGrant grants a secret to a specific run.
	SecretGrant(ctx context.Context, in *SecretGrantRequest, opts ...grpc.CallOption) (*SecretGrantResponse, error)
	// SecretRevoke revokes a secret from a specific run.
	SecretRevoke(ctx context.Context, in *SecretRevokeRequest, opts ...grpc.CallOption) (*SecretRevokeResponse, error)
	// AuditQuery queries audit log entries with filters and pagination.
	AuditQuery(ctx context.Context, in *AuditQueryRequest, opts ...grpc.CallOption) (*AuditQueryResponse, error)
	// AuditExport exports audit log entries in a specified format.
	AuditExport(ctx context.Context, in *AuditExportRequest, opts ...grpc.CallOption) (*AuditExportResponse, error)
	// Doctor runs system diagnostics and returns health check results.
	Doctor(ctx context.Context, in *DoctorRequest, opts ...grpc.CallOption) (*DoctorResponse, error)
	// ValidateAgentProject validates an agent project directory structure and
	// configuration.
	ValidateAgentProject(ctx context.Context, in *ValidateAgentProjectRequest, opts ...grpc.CallOption) (*ValidateAgentProjectResponse, error)
	// SummarizeRun generates a natural-language summary of a completed run.
	SummarizeRun(ctx context.Context, in *SummarizeRunRequest, opts ...grpc.CallOption) (*SummarizeRunResponse, error)
	// ExplainFailure analyzes a failed run and returns root cause and suggested
	// fixes.
	ExplainFailure(ctx context.Context, in *ExplainFailureRequest, opts ...grpc.CallOption) (*ExplainFailureResponse, error)
	// ExplainPolicyDenial explains why a specific destination was denied by
	// policy.
	ExplainPolicyDenial(ctx context.Context, in *ExplainPolicyDenialRequest, opts ...grpc.CallOption) (*ExplainPolicyDenialResponse, error)
	// RecommendPolicyPatch suggests a policy patch based on a desired behavior
	// description.
	RecommendPolicyPatch(ctx context.Context, in *RecommendPolicyPatchRequest, opts ...grpc.CallOption) (*RecommendPolicyPatchResponse, error)
	// GetRunTimeline returns a chronological timeline of events for a run.
	GetRunTimeline(ctx context.Context, in *GetRunTimelineRequest, opts ...grpc.CallOption) (*GetRunTimelineResponse, error)
	// NextAction recommends the next action based on the current context.
	NextAction(ctx context.Context, in *NextActionRequest, opts ...grpc.CallOption) (*NextActionResponse, error)
	// CronAdd creates a new cron schedule that auto-invokes an agent.
	CronAdd(ctx context.Context, in *CronAddRequest, opts ...grpc.CallOption) (*CronAddResponse, error)
	// CronList lists all cron schedules.
	CronList(ctx context.Context, in *CronListRequest, opts ...grpc.CallOption) (*CronListResponse, error)
	// CronRemove removes a cron schedule.
	CronRemove(ctx context.Context, in *CronRemoveRequest, opts ...grpc.CallOption) (*CronRemoveResponse, error)
}

ControlServiceClient is the client API for ControlService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

ControlService provides operational control over agent lifecycle, policy, secrets, audit logs, and diagnostic/introspection capabilities.

type ControlServiceServer

type ControlServiceServer interface {
	// Pack builds an agent image from a project directory.
	Pack(context.Context, *PackRequest) (*PackResponse, error)
	// Run starts a new agent run with the given budget and payload.
	Run(context.Context, *RunRequest) (*RunResponse, error)
	// Stop terminates a running agent run.
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	// Logs returns a stream of log entries, optionally following in real-time.
	Logs(*LogsRequest, grpc.ServerStreamingServer[LogEntry]) error
	// PolicyApply applies or validates an OPA/Rego policy.
	PolicyApply(context.Context, *PolicyApplyRequest) (*PolicyApplyResponse, error)
	// SecretSet creates or updates a secret.
	SecretSet(context.Context, *SecretSetRequest) (*SecretSetResponse, error)
	// SecretGrant grants a secret to a specific run.
	SecretGrant(context.Context, *SecretGrantRequest) (*SecretGrantResponse, error)
	// SecretRevoke revokes a secret from a specific run.
	SecretRevoke(context.Context, *SecretRevokeRequest) (*SecretRevokeResponse, error)
	// AuditQuery queries audit log entries with filters and pagination.
	AuditQuery(context.Context, *AuditQueryRequest) (*AuditQueryResponse, error)
	// AuditExport exports audit log entries in a specified format.
	AuditExport(context.Context, *AuditExportRequest) (*AuditExportResponse, error)
	// Doctor runs system diagnostics and returns health check results.
	Doctor(context.Context, *DoctorRequest) (*DoctorResponse, error)
	// ValidateAgentProject validates an agent project directory structure and
	// configuration.
	ValidateAgentProject(context.Context, *ValidateAgentProjectRequest) (*ValidateAgentProjectResponse, error)
	// SummarizeRun generates a natural-language summary of a completed run.
	SummarizeRun(context.Context, *SummarizeRunRequest) (*SummarizeRunResponse, error)
	// ExplainFailure analyzes a failed run and returns root cause and suggested
	// fixes.
	ExplainFailure(context.Context, *ExplainFailureRequest) (*ExplainFailureResponse, error)
	// ExplainPolicyDenial explains why a specific destination was denied by
	// policy.
	ExplainPolicyDenial(context.Context, *ExplainPolicyDenialRequest) (*ExplainPolicyDenialResponse, error)
	// RecommendPolicyPatch suggests a policy patch based on a desired behavior
	// description.
	RecommendPolicyPatch(context.Context, *RecommendPolicyPatchRequest) (*RecommendPolicyPatchResponse, error)
	// GetRunTimeline returns a chronological timeline of events for a run.
	GetRunTimeline(context.Context, *GetRunTimelineRequest) (*GetRunTimelineResponse, error)
	// NextAction recommends the next action based on the current context.
	NextAction(context.Context, *NextActionRequest) (*NextActionResponse, error)
	// CronAdd creates a new cron schedule that auto-invokes an agent.
	CronAdd(context.Context, *CronAddRequest) (*CronAddResponse, error)
	// CronList lists all cron schedules.
	CronList(context.Context, *CronListRequest) (*CronListResponse, error)
	// CronRemove removes a cron schedule.
	CronRemove(context.Context, *CronRemoveRequest) (*CronRemoveResponse, error)
	// contains filtered or unexported methods
}

ControlServiceServer is the server API for ControlService service. All implementations must embed UnimplementedControlServiceServer for forward compatibility.

ControlService provides operational control over agent lifecycle, policy, secrets, audit logs, and diagnostic/introspection capabilities.

type ControlService_LogsClient

type ControlService_LogsClient = grpc.ServerStreamingClient[LogEntry]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ControlService_LogsServer

type ControlService_LogsServer = grpc.ServerStreamingServer[LogEntry]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type CronAddRequest

type CronAddRequest struct {
	AgentName         string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	Expr              string `protobuf:"bytes,2,opt,name=expr,proto3" json:"expr,omitempty"`
	AgentVersion      string `protobuf:"bytes,3,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	Timezone          string `protobuf:"bytes,4,opt,name=timezone,proto3" json:"timezone,omitempty"`
	MissedRunPolicy   string `protobuf:"bytes,5,opt,name=missed_run_policy,json=missedRunPolicy,proto3" json:"missed_run_policy,omitempty"`
	ConcurrencyPolicy string `protobuf:"bytes,6,opt,name=concurrency_policy,json=concurrencyPolicy,proto3" json:"concurrency_policy,omitempty"`
	// contains filtered or unexported fields
}

CronAddRequest creates a new cron schedule.

func (*CronAddRequest) Descriptor deprecated

func (*CronAddRequest) Descriptor() ([]byte, []int)

Deprecated: Use CronAddRequest.ProtoReflect.Descriptor instead.

func (*CronAddRequest) GetAgentName

func (x *CronAddRequest) GetAgentName() string

func (*CronAddRequest) GetAgentVersion

func (x *CronAddRequest) GetAgentVersion() string

func (*CronAddRequest) GetConcurrencyPolicy

func (x *CronAddRequest) GetConcurrencyPolicy() string

func (*CronAddRequest) GetExpr

func (x *CronAddRequest) GetExpr() string

func (*CronAddRequest) GetMissedRunPolicy

func (x *CronAddRequest) GetMissedRunPolicy() string

func (*CronAddRequest) GetTimezone

func (x *CronAddRequest) GetTimezone() string

func (*CronAddRequest) ProtoMessage

func (*CronAddRequest) ProtoMessage()

func (*CronAddRequest) ProtoReflect

func (x *CronAddRequest) ProtoReflect() protoreflect.Message

func (*CronAddRequest) Reset

func (x *CronAddRequest) Reset()

func (*CronAddRequest) String

func (x *CronAddRequest) String() string

type CronAddResponse

type CronAddResponse struct {
	Schedule *CronScheduleInfo `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// contains filtered or unexported fields
}

CronAddResponse returns the created schedule.

func (*CronAddResponse) Descriptor deprecated

func (*CronAddResponse) Descriptor() ([]byte, []int)

Deprecated: Use CronAddResponse.ProtoReflect.Descriptor instead.

func (*CronAddResponse) GetSchedule

func (x *CronAddResponse) GetSchedule() *CronScheduleInfo

func (*CronAddResponse) ProtoMessage

func (*CronAddResponse) ProtoMessage()

func (*CronAddResponse) ProtoReflect

func (x *CronAddResponse) ProtoReflect() protoreflect.Message

func (*CronAddResponse) Reset

func (x *CronAddResponse) Reset()

func (*CronAddResponse) String

func (x *CronAddResponse) String() string

type CronListRequest

type CronListRequest struct {
	// contains filtered or unexported fields
}

CronListRequest lists cron schedules.

func (*CronListRequest) Descriptor deprecated

func (*CronListRequest) Descriptor() ([]byte, []int)

Deprecated: Use CronListRequest.ProtoReflect.Descriptor instead.

func (*CronListRequest) ProtoMessage

func (*CronListRequest) ProtoMessage()

func (*CronListRequest) ProtoReflect

func (x *CronListRequest) ProtoReflect() protoreflect.Message

func (*CronListRequest) Reset

func (x *CronListRequest) Reset()

func (*CronListRequest) String

func (x *CronListRequest) String() string

type CronListResponse

type CronListResponse struct {
	Schedules []*CronScheduleInfo `protobuf:"bytes,1,rep,name=schedules,proto3" json:"schedules,omitempty"`
	// contains filtered or unexported fields
}

CronListResponse returns all schedules.

func (*CronListResponse) Descriptor deprecated

func (*CronListResponse) Descriptor() ([]byte, []int)

Deprecated: Use CronListResponse.ProtoReflect.Descriptor instead.

func (*CronListResponse) GetSchedules

func (x *CronListResponse) GetSchedules() []*CronScheduleInfo

func (*CronListResponse) ProtoMessage

func (*CronListResponse) ProtoMessage()

func (*CronListResponse) ProtoReflect

func (x *CronListResponse) ProtoReflect() protoreflect.Message

func (*CronListResponse) Reset

func (x *CronListResponse) Reset()

func (*CronListResponse) String

func (x *CronListResponse) String() string

type CronRemoveRequest

type CronRemoveRequest struct {
	ScheduleId string `protobuf:"bytes,1,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// contains filtered or unexported fields
}

CronRemoveRequest removes a cron schedule.

func (*CronRemoveRequest) Descriptor deprecated

func (*CronRemoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use CronRemoveRequest.ProtoReflect.Descriptor instead.

func (*CronRemoveRequest) GetScheduleId

func (x *CronRemoveRequest) GetScheduleId() string

func (*CronRemoveRequest) ProtoMessage

func (*CronRemoveRequest) ProtoMessage()

func (*CronRemoveRequest) ProtoReflect

func (x *CronRemoveRequest) ProtoReflect() protoreflect.Message

func (*CronRemoveRequest) Reset

func (x *CronRemoveRequest) Reset()

func (*CronRemoveRequest) String

func (x *CronRemoveRequest) String() string

type CronRemoveResponse

type CronRemoveResponse struct {
	Removed bool `protobuf:"varint,1,opt,name=removed,proto3" json:"removed,omitempty"`
	// contains filtered or unexported fields
}

CronRemoveResponse confirms removal.

func (*CronRemoveResponse) Descriptor deprecated

func (*CronRemoveResponse) Descriptor() ([]byte, []int)

Deprecated: Use CronRemoveResponse.ProtoReflect.Descriptor instead.

func (*CronRemoveResponse) GetRemoved

func (x *CronRemoveResponse) GetRemoved() bool

func (*CronRemoveResponse) ProtoMessage

func (*CronRemoveResponse) ProtoMessage()

func (*CronRemoveResponse) ProtoReflect

func (x *CronRemoveResponse) ProtoReflect() protoreflect.Message

func (*CronRemoveResponse) Reset

func (x *CronRemoveResponse) Reset()

func (*CronRemoveResponse) String

func (x *CronRemoveResponse) String() string

type CronScheduleInfo

type CronScheduleInfo struct {
	ScheduleId        string `protobuf:"bytes,1,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	Expr              string `protobuf:"bytes,2,opt,name=expr,proto3" json:"expr,omitempty"`
	AgentName         string `protobuf:"bytes,3,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	AgentVersion      string `protobuf:"bytes,4,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	Timezone          string `protobuf:"bytes,5,opt,name=timezone,proto3" json:"timezone,omitempty"`
	MissedRunPolicy   string `protobuf:"bytes,6,opt,name=missed_run_policy,json=missedRunPolicy,proto3" json:"missed_run_policy,omitempty"`
	ConcurrencyPolicy string `protobuf:"bytes,7,opt,name=concurrency_policy,json=concurrencyPolicy,proto3" json:"concurrency_policy,omitempty"`
	// contains filtered or unexported fields
}

CronScheduleInfo represents a cron trigger schedule.

func (*CronScheduleInfo) Descriptor deprecated

func (*CronScheduleInfo) Descriptor() ([]byte, []int)

Deprecated: Use CronScheduleInfo.ProtoReflect.Descriptor instead.

func (*CronScheduleInfo) GetAgentName

func (x *CronScheduleInfo) GetAgentName() string

func (*CronScheduleInfo) GetAgentVersion

func (x *CronScheduleInfo) GetAgentVersion() string

func (*CronScheduleInfo) GetConcurrencyPolicy

func (x *CronScheduleInfo) GetConcurrencyPolicy() string

func (*CronScheduleInfo) GetExpr

func (x *CronScheduleInfo) GetExpr() string

func (*CronScheduleInfo) GetMissedRunPolicy

func (x *CronScheduleInfo) GetMissedRunPolicy() string

func (*CronScheduleInfo) GetScheduleId

func (x *CronScheduleInfo) GetScheduleId() string

func (*CronScheduleInfo) GetTimezone

func (x *CronScheduleInfo) GetTimezone() string

func (*CronScheduleInfo) ProtoMessage

func (*CronScheduleInfo) ProtoMessage()

func (*CronScheduleInfo) ProtoReflect

func (x *CronScheduleInfo) ProtoReflect() protoreflect.Message

func (*CronScheduleInfo) Reset

func (x *CronScheduleInfo) Reset()

func (*CronScheduleInfo) String

func (x *CronScheduleInfo) String() string

type DoctorRequest

type DoctorRequest struct {
	// contains filtered or unexported fields
}

func (*DoctorRequest) Descriptor deprecated

func (*DoctorRequest) Descriptor() ([]byte, []int)

Deprecated: Use DoctorRequest.ProtoReflect.Descriptor instead.

func (*DoctorRequest) ProtoMessage

func (*DoctorRequest) ProtoMessage()

func (*DoctorRequest) ProtoReflect

func (x *DoctorRequest) ProtoReflect() protoreflect.Message

func (*DoctorRequest) Reset

func (x *DoctorRequest) Reset()

func (*DoctorRequest) String

func (x *DoctorRequest) String() string

type DoctorResponse

type DoctorResponse struct {
	Checks []*CheckResult `protobuf:"bytes,1,rep,name=checks,proto3" json:"checks,omitempty"`
	// Overall system health status.
	OverallStatus string `protobuf:"bytes,2,opt,name=overall_status,json=overallStatus,proto3" json:"overall_status,omitempty"`
	// contains filtered or unexported fields
}

func (*DoctorResponse) Descriptor deprecated

func (*DoctorResponse) Descriptor() ([]byte, []int)

Deprecated: Use DoctorResponse.ProtoReflect.Descriptor instead.

func (*DoctorResponse) GetChecks

func (x *DoctorResponse) GetChecks() []*CheckResult

func (*DoctorResponse) GetOverallStatus

func (x *DoctorResponse) GetOverallStatus() string

func (*DoctorResponse) ProtoMessage

func (*DoctorResponse) ProtoMessage()

func (*DoctorResponse) ProtoReflect

func (x *DoctorResponse) ProtoReflect() protoreflect.Message

func (*DoctorResponse) Reset

func (x *DoctorResponse) Reset()

func (*DoctorResponse) String

func (x *DoctorResponse) String() string

type EventType

type EventType int32

EventType represents the category of an audit event.

const (
	EventType_EVENT_TYPE_UNSPECIFIED   EventType = 0
	EventType_EVENT_TYPE_INVOKE        EventType = 1
	EventType_EVENT_TYPE_CANCEL        EventType = 2
	EventType_EVENT_TYPE_POLICY_APPLY  EventType = 3
	EventType_EVENT_TYPE_POLICY_DENIAL EventType = 4
	EventType_EVENT_TYPE_SECRET_SET    EventType = 5
	EventType_EVENT_TYPE_SECRET_GRANT  EventType = 6
	EventType_EVENT_TYPE_SECRET_REVOKE EventType = 7
	EventType_EVENT_TYPE_PACK          EventType = 8
	EventType_EVENT_TYPE_RUN           EventType = 9
	EventType_EVENT_TYPE_STOP          EventType = 10
)

func (EventType) Descriptor

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated

func (EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String

func (x EventType) String() string

func (EventType) Type

type EvidenceRef

type EvidenceRef struct {

	// Kind of evidence: "audit_seq", "run_id", "policy_rule", "span", "log",
	// "redacted_excerpt", "verification".
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Opaque identifier for the evidence.
	Ref string `protobuf:"bytes,2,opt,name=ref,proto3" json:"ref,omitempty"`
	// Optional redacted human-readable detail.
	Detail string `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"`
	// contains filtered or unexported fields
}

EvidenceRef points to an auditable artifact that supports a diagnosis.

func (*EvidenceRef) Descriptor deprecated

func (*EvidenceRef) Descriptor() ([]byte, []int)

Deprecated: Use EvidenceRef.ProtoReflect.Descriptor instead.

func (*EvidenceRef) GetDetail

func (x *EvidenceRef) GetDetail() string

func (*EvidenceRef) GetRef

func (x *EvidenceRef) GetRef() string

func (*EvidenceRef) GetType

func (x *EvidenceRef) GetType() string

func (*EvidenceRef) ProtoMessage

func (*EvidenceRef) ProtoMessage()

func (*EvidenceRef) ProtoReflect

func (x *EvidenceRef) ProtoReflect() protoreflect.Message

func (*EvidenceRef) Reset

func (x *EvidenceRef) Reset()

func (*EvidenceRef) String

func (x *EvidenceRef) String() string

type ExplainFailureRequest

type ExplainFailureRequest struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainFailureRequest) Descriptor deprecated

func (*ExplainFailureRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExplainFailureRequest.ProtoReflect.Descriptor instead.

func (*ExplainFailureRequest) GetRunId

func (x *ExplainFailureRequest) GetRunId() string

func (*ExplainFailureRequest) ProtoMessage

func (*ExplainFailureRequest) ProtoMessage()

func (*ExplainFailureRequest) ProtoReflect

func (x *ExplainFailureRequest) ProtoReflect() protoreflect.Message

func (*ExplainFailureRequest) Reset

func (x *ExplainFailureRequest) Reset()

func (*ExplainFailureRequest) String

func (x *ExplainFailureRequest) String() string

type ExplainFailureResponse

type ExplainFailureResponse struct {

	// Identified root cause of the failure.
	RootCause string `protobuf:"bytes,1,opt,name=root_cause,json=rootCause,proto3" json:"root_cause,omitempty"`
	// Factors that contributed to the failure.
	ContributingFactors []string `protobuf:"bytes,2,rep,name=contributing_factors,json=contributingFactors,proto3" json:"contributing_factors,omitempty"`
	// Suggested code or config changes to fix the issue.
	SuggestedFixes []string `protobuf:"bytes,3,rep,name=suggested_fixes,json=suggestedFixes,proto3" json:"suggested_fixes,omitempty"`
	// --- Block 11 operator contract fields ---
	SchemaVersion string `protobuf:"bytes,10,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// Stable error category classifying the failure.
	ErrorCategory    string             `protobuf:"bytes,11,opt,name=error_category,json=errorCategory,proto3" json:"error_category,omitempty"`
	RedactedExcerpts []*RedactedExcerpt `protobuf:"bytes,12,rep,name=redacted_excerpts,json=redactedExcerpts,proto3" json:"redacted_excerpts,omitempty"`
	EvidenceRefs     []*EvidenceRef     `protobuf:"bytes,13,rep,name=evidence_refs,json=evidenceRefs,proto3" json:"evidence_refs,omitempty"`
	// Recommended next action from the fixed enum.
	NextAction string `protobuf:"bytes,14,opt,name=next_action,json=nextAction,proto3" json:"next_action,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainFailureResponse) Descriptor deprecated

func (*ExplainFailureResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExplainFailureResponse.ProtoReflect.Descriptor instead.

func (*ExplainFailureResponse) GetContributingFactors

func (x *ExplainFailureResponse) GetContributingFactors() []string

func (*ExplainFailureResponse) GetErrorCategory

func (x *ExplainFailureResponse) GetErrorCategory() string

func (*ExplainFailureResponse) GetEvidenceRefs

func (x *ExplainFailureResponse) GetEvidenceRefs() []*EvidenceRef

func (*ExplainFailureResponse) GetNextAction

func (x *ExplainFailureResponse) GetNextAction() string

func (*ExplainFailureResponse) GetRedactedExcerpts

func (x *ExplainFailureResponse) GetRedactedExcerpts() []*RedactedExcerpt

func (*ExplainFailureResponse) GetRootCause

func (x *ExplainFailureResponse) GetRootCause() string

func (*ExplainFailureResponse) GetSchemaVersion

func (x *ExplainFailureResponse) GetSchemaVersion() string

func (*ExplainFailureResponse) GetSuggestedFixes

func (x *ExplainFailureResponse) GetSuggestedFixes() []string

func (*ExplainFailureResponse) ProtoMessage

func (*ExplainFailureResponse) ProtoMessage()

func (*ExplainFailureResponse) ProtoReflect

func (x *ExplainFailureResponse) ProtoReflect() protoreflect.Message

func (*ExplainFailureResponse) Reset

func (x *ExplainFailureResponse) Reset()

func (*ExplainFailureResponse) String

func (x *ExplainFailureResponse) String() string

type ExplainPolicyDenialRequest

type ExplainPolicyDenialRequest struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Optional: specific destination that was denied.
	DeniedDestination string `protobuf:"bytes,2,opt,name=denied_destination,json=deniedDestination,proto3" json:"denied_destination,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainPolicyDenialRequest) Descriptor deprecated

func (*ExplainPolicyDenialRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExplainPolicyDenialRequest.ProtoReflect.Descriptor instead.

func (*ExplainPolicyDenialRequest) GetDeniedDestination

func (x *ExplainPolicyDenialRequest) GetDeniedDestination() string

func (*ExplainPolicyDenialRequest) GetRunId

func (x *ExplainPolicyDenialRequest) GetRunId() string

func (*ExplainPolicyDenialRequest) ProtoMessage

func (*ExplainPolicyDenialRequest) ProtoMessage()

func (*ExplainPolicyDenialRequest) ProtoReflect

func (*ExplainPolicyDenialRequest) Reset

func (x *ExplainPolicyDenialRequest) Reset()

func (*ExplainPolicyDenialRequest) String

func (x *ExplainPolicyDenialRequest) String() string

type ExplainPolicyDenialResponse

type ExplainPolicyDenialResponse struct {

	// The destination that was denied.
	DeniedDestination string `protobuf:"bytes,1,opt,name=denied_destination,json=deniedDestination,proto3" json:"denied_destination,omitempty"`
	// The OPA/Rego rule that produced the denial.
	MatchingRule string `protobuf:"bytes,2,opt,name=matching_rule,json=matchingRule,proto3" json:"matching_rule,omitempty"`
	// Human-readable explanation of why the denial occurred.
	Explanation string `protobuf:"bytes,3,opt,name=explanation,proto3" json:"explanation,omitempty"`
	// --- Block 11 operator contract fields ---
	SchemaVersion string `protobuf:"bytes,10,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// Run that was denied (empty for pre-run checks).
	RunId string `protobuf:"bytes,11,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// What the agent tried to do.
	DeniedAction string `protobuf:"bytes,12,opt,name=denied_action,json=deniedAction,proto3" json:"denied_action,omitempty"`
	// Policy rule id that blocked the action (e.g. "egress[0]").
	BlockingRuleId string `protobuf:"bytes,13,opt,name=blocking_rule_id,json=blockingRuleId,proto3" json:"blocking_rule_id,omitempty"`
	// SHA-256 digest of the compiled policy at denial time.
	PolicyDigest string         `protobuf:"bytes,14,opt,name=policy_digest,json=policyDigest,proto3" json:"policy_digest,omitempty"`
	Rationale    string         `protobuf:"bytes,15,opt,name=rationale,proto3" json:"rationale,omitempty"`
	EvidenceRefs []*EvidenceRef `protobuf:"bytes,16,rep,name=evidence_refs,json=evidenceRefs,proto3" json:"evidence_refs,omitempty"`
	// Always "review_policy_patch".
	NextAction string `protobuf:"bytes,17,opt,name=next_action,json=nextAction,proto3" json:"next_action,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainPolicyDenialResponse) Descriptor deprecated

func (*ExplainPolicyDenialResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExplainPolicyDenialResponse.ProtoReflect.Descriptor instead.

func (*ExplainPolicyDenialResponse) GetBlockingRuleId

func (x *ExplainPolicyDenialResponse) GetBlockingRuleId() string

func (*ExplainPolicyDenialResponse) GetDeniedAction

func (x *ExplainPolicyDenialResponse) GetDeniedAction() string

func (*ExplainPolicyDenialResponse) GetDeniedDestination

func (x *ExplainPolicyDenialResponse) GetDeniedDestination() string

func (*ExplainPolicyDenialResponse) GetEvidenceRefs

func (x *ExplainPolicyDenialResponse) GetEvidenceRefs() []*EvidenceRef

func (*ExplainPolicyDenialResponse) GetExplanation

func (x *ExplainPolicyDenialResponse) GetExplanation() string

func (*ExplainPolicyDenialResponse) GetMatchingRule

func (x *ExplainPolicyDenialResponse) GetMatchingRule() string

func (*ExplainPolicyDenialResponse) GetNextAction

func (x *ExplainPolicyDenialResponse) GetNextAction() string

func (*ExplainPolicyDenialResponse) GetPolicyDigest

func (x *ExplainPolicyDenialResponse) GetPolicyDigest() string

func (*ExplainPolicyDenialResponse) GetRationale

func (x *ExplainPolicyDenialResponse) GetRationale() string

func (*ExplainPolicyDenialResponse) GetRunId

func (x *ExplainPolicyDenialResponse) GetRunId() string

func (*ExplainPolicyDenialResponse) GetSchemaVersion

func (x *ExplainPolicyDenialResponse) GetSchemaVersion() string

func (*ExplainPolicyDenialResponse) ProtoMessage

func (*ExplainPolicyDenialResponse) ProtoMessage()

func (*ExplainPolicyDenialResponse) ProtoReflect

func (*ExplainPolicyDenialResponse) Reset

func (x *ExplainPolicyDenialResponse) Reset()

func (*ExplainPolicyDenialResponse) String

func (x *ExplainPolicyDenialResponse) String() string

type GetRunTimelineRequest

type GetRunTimelineRequest struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRunTimelineRequest) Descriptor deprecated

func (*GetRunTimelineRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRunTimelineRequest.ProtoReflect.Descriptor instead.

func (*GetRunTimelineRequest) GetRunId

func (x *GetRunTimelineRequest) GetRunId() string

func (*GetRunTimelineRequest) ProtoMessage

func (*GetRunTimelineRequest) ProtoMessage()

func (*GetRunTimelineRequest) ProtoReflect

func (x *GetRunTimelineRequest) ProtoReflect() protoreflect.Message

func (*GetRunTimelineRequest) Reset

func (x *GetRunTimelineRequest) Reset()

func (*GetRunTimelineRequest) String

func (x *GetRunTimelineRequest) String() string

type GetRunTimelineResponse

type GetRunTimelineResponse struct {
	Events []*TimelineEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// --- Block 11 operator contract fields ---
	SchemaVersion string `protobuf:"bytes,10,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	RunId         string `protobuf:"bytes,11,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRunTimelineResponse) Descriptor deprecated

func (*GetRunTimelineResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRunTimelineResponse.ProtoReflect.Descriptor instead.

func (*GetRunTimelineResponse) GetEvents

func (x *GetRunTimelineResponse) GetEvents() []*TimelineEvent

func (*GetRunTimelineResponse) GetRunId

func (x *GetRunTimelineResponse) GetRunId() string

func (*GetRunTimelineResponse) GetSchemaVersion

func (x *GetRunTimelineResponse) GetSchemaVersion() string

func (*GetRunTimelineResponse) ProtoMessage

func (*GetRunTimelineResponse) ProtoMessage()

func (*GetRunTimelineResponse) ProtoReflect

func (x *GetRunTimelineResponse) ProtoReflect() protoreflect.Message

func (*GetRunTimelineResponse) Reset

func (x *GetRunTimelineResponse) Reset()

func (*GetRunTimelineResponse) String

func (x *GetRunTimelineResponse) String() string

type KeyEvent

type KeyEvent struct {
	Timestamp   *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Description string                 `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	EventType   string                 `protobuf:"bytes,3,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyEvent) Descriptor deprecated

func (*KeyEvent) Descriptor() ([]byte, []int)

Deprecated: Use KeyEvent.ProtoReflect.Descriptor instead.

func (*KeyEvent) GetDescription

func (x *KeyEvent) GetDescription() string

func (*KeyEvent) GetEventType

func (x *KeyEvent) GetEventType() string

func (*KeyEvent) GetTimestamp

func (x *KeyEvent) GetTimestamp() *timestamppb.Timestamp

func (*KeyEvent) ProtoMessage

func (*KeyEvent) ProtoMessage()

func (*KeyEvent) ProtoReflect

func (x *KeyEvent) ProtoReflect() protoreflect.Message

func (*KeyEvent) Reset

func (x *KeyEvent) Reset()

func (*KeyEvent) String

func (x *KeyEvent) String() string

type LogEntry

type LogEntry struct {

	// Timestamp of the log entry.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Run ID the entry belongs to.
	RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Severity level.
	Level string `protobuf:"bytes,3,opt,name=level,proto3" json:"level,omitempty"`
	// Log message body.
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// Structured fields (key-value pairs).
	Fields map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated

func (*LogEntry) Descriptor() ([]byte, []int)

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetFields

func (x *LogEntry) GetFields() map[string]string

func (*LogEntry) GetLevel

func (x *LogEntry) GetLevel() string

func (*LogEntry) GetMessage

func (x *LogEntry) GetMessage() string

func (*LogEntry) GetRunId

func (x *LogEntry) GetRunId() string

func (*LogEntry) GetTimestamp

func (x *LogEntry) GetTimestamp() *timestamppb.Timestamp

func (*LogEntry) ProtoMessage

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect

func (x *LogEntry) ProtoReflect() protoreflect.Message

func (*LogEntry) Reset

func (x *LogEntry) Reset()

func (*LogEntry) String

func (x *LogEntry) String() string

type LogLevel

type LogLevel int32

LogLevel represents the severity of a log entry.

const (
	LogLevel_LOG_LEVEL_UNSPECIFIED LogLevel = 0
	LogLevel_LOG_LEVEL_DEBUG       LogLevel = 1
	LogLevel_LOG_LEVEL_INFO        LogLevel = 2
	LogLevel_LOG_LEVEL_WARN        LogLevel = 3
	LogLevel_LOG_LEVEL_ERROR       LogLevel = 4
)

func (LogLevel) Descriptor

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated

func (LogLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String

func (x LogLevel) String() string

func (LogLevel) Type

type LogsRequest

type LogsRequest struct {

	// Optional: filter by run ID.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Optional: minimum log level to include.
	MinLevel LogLevel `protobuf:"varint,2,opt,name=min_level,json=minLevel,proto3,enum=agentpaas.control.v1.LogLevel" json:"min_level,omitempty"`
	// Optional: follow the log stream in real-time.
	Follow bool `protobuf:"varint,3,opt,name=follow,proto3" json:"follow,omitempty"`
	// Maximum number of historical entries to return.
	Tail int32 `protobuf:"varint,4,opt,name=tail,proto3" json:"tail,omitempty"`
	// contains filtered or unexported fields
}

func (*LogsRequest) Descriptor deprecated

func (*LogsRequest) Descriptor() ([]byte, []int)

Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.

func (*LogsRequest) GetFollow

func (x *LogsRequest) GetFollow() bool

func (*LogsRequest) GetMinLevel

func (x *LogsRequest) GetMinLevel() LogLevel

func (*LogsRequest) GetRunId

func (x *LogsRequest) GetRunId() string

func (*LogsRequest) GetTail

func (x *LogsRequest) GetTail() int32

func (*LogsRequest) ProtoMessage

func (*LogsRequest) ProtoMessage()

func (*LogsRequest) ProtoReflect

func (x *LogsRequest) ProtoReflect() protoreflect.Message

func (*LogsRequest) Reset

func (x *LogsRequest) Reset()

func (*LogsRequest) String

func (x *LogsRequest) String() string

type NextActionRequest

type NextActionRequest struct {

	// Current context describing the system state.
	Context string `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

func (*NextActionRequest) Descriptor deprecated

func (*NextActionRequest) Descriptor() ([]byte, []int)

Deprecated: Use NextActionRequest.ProtoReflect.Descriptor instead.

func (*NextActionRequest) GetContext

func (x *NextActionRequest) GetContext() string

func (*NextActionRequest) ProtoMessage

func (*NextActionRequest) ProtoMessage()

func (*NextActionRequest) ProtoReflect

func (x *NextActionRequest) ProtoReflect() protoreflect.Message

func (*NextActionRequest) Reset

func (x *NextActionRequest) Reset()

func (*NextActionRequest) String

func (x *NextActionRequest) String() string

type NextActionResponse

type NextActionResponse struct {

	// Recommended action type (e.g. "invoke", "stop", "policy_apply", "pack").
	Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	// Target resource for the action.
	Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// Parameters to pass with the action.
	Params map[string]string `` /* 139-byte string literal not displayed */
	// LLM reasoning behind the recommendation.
	Reasoning string `protobuf:"bytes,4,opt,name=reasoning,proto3" json:"reasoning,omitempty"`
	// --- Block 11 operator contract fields ---
	SchemaVersion string `protobuf:"bytes,10,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	RunId         string `protobuf:"bytes,11,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Next action from the fixed enum.
	NextAction   string                   `protobuf:"bytes,12,opt,name=next_action,json=nextAction,proto3" json:"next_action,omitempty"`
	Rationale    string                   `protobuf:"bytes,13,opt,name=rationale,proto3" json:"rationale,omitempty"`
	EvidenceRefs []*EvidenceRef           `protobuf:"bytes,14,rep,name=evidence_refs,json=evidenceRefs,proto3" json:"evidence_refs,omitempty"`
	Confirmation *ConfirmationRequirement `protobuf:"bytes,15,opt,name=confirmation,proto3" json:"confirmation,omitempty"`
	// contains filtered or unexported fields
}

func (*NextActionResponse) Descriptor deprecated

func (*NextActionResponse) Descriptor() ([]byte, []int)

Deprecated: Use NextActionResponse.ProtoReflect.Descriptor instead.

func (*NextActionResponse) GetAction

func (x *NextActionResponse) GetAction() string

func (*NextActionResponse) GetConfirmation

func (x *NextActionResponse) GetConfirmation() *ConfirmationRequirement

func (*NextActionResponse) GetEvidenceRefs

func (x *NextActionResponse) GetEvidenceRefs() []*EvidenceRef

func (*NextActionResponse) GetNextAction

func (x *NextActionResponse) GetNextAction() string

func (*NextActionResponse) GetParams

func (x *NextActionResponse) GetParams() map[string]string

func (*NextActionResponse) GetRationale

func (x *NextActionResponse) GetRationale() string

func (*NextActionResponse) GetReasoning

func (x *NextActionResponse) GetReasoning() string

func (*NextActionResponse) GetRunId

func (x *NextActionResponse) GetRunId() string

func (*NextActionResponse) GetSchemaVersion

func (x *NextActionResponse) GetSchemaVersion() string

func (*NextActionResponse) GetTarget

func (x *NextActionResponse) GetTarget() string

func (*NextActionResponse) ProtoMessage

func (*NextActionResponse) ProtoMessage()

func (*NextActionResponse) ProtoReflect

func (x *NextActionResponse) ProtoReflect() protoreflect.Message

func (*NextActionResponse) Reset

func (x *NextActionResponse) Reset()

func (*NextActionResponse) String

func (x *NextActionResponse) String() string

type OperatorIssue

type OperatorIssue struct {

	// Stable error category from the versioned enum.
	Category string `protobuf:"bytes,1,opt,name=category,proto3" json:"category,omitempty"`
	// Human-readable description of the issue.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Evidence refs supporting this issue.
	EvidenceRefs []*EvidenceRef `protobuf:"bytes,3,rep,name=evidence_refs,json=evidenceRefs,proto3" json:"evidence_refs,omitempty"`
	// Recommended next action from the fixed enum.
	NextAction string `protobuf:"bytes,4,opt,name=next_action,json=nextAction,proto3" json:"next_action,omitempty"`
	// contains filtered or unexported fields
}

OperatorIssue is a single readiness problem found during project validation.

func (*OperatorIssue) Descriptor deprecated

func (*OperatorIssue) Descriptor() ([]byte, []int)

Deprecated: Use OperatorIssue.ProtoReflect.Descriptor instead.

func (*OperatorIssue) GetCategory

func (x *OperatorIssue) GetCategory() string

func (*OperatorIssue) GetEvidenceRefs

func (x *OperatorIssue) GetEvidenceRefs() []*EvidenceRef

func (*OperatorIssue) GetMessage

func (x *OperatorIssue) GetMessage() string

func (*OperatorIssue) GetNextAction

func (x *OperatorIssue) GetNextAction() string

func (*OperatorIssue) ProtoMessage

func (*OperatorIssue) ProtoMessage()

func (*OperatorIssue) ProtoReflect

func (x *OperatorIssue) ProtoReflect() protoreflect.Message

func (*OperatorIssue) Reset

func (x *OperatorIssue) Reset()

func (*OperatorIssue) String

func (x *OperatorIssue) String() string

type PackRequest

type PackRequest struct {

	// Path to the agent project directory.
	AgentProjectPath string `protobuf:"bytes,1,opt,name=agent_project_path,json=agentProjectPath,proto3" json:"agent_project_path,omitempty"`
	// Name of the agent to pack.
	AgentName string `protobuf:"bytes,2,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	// Version string for the agent image.
	AgentVersion string `protobuf:"bytes,3,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	// Override base image (optional).
	BaseImage string `protobuf:"bytes,4,opt,name=base_image,json=baseImage,proto3" json:"base_image,omitempty"`
	// contains filtered or unexported fields
}

func (*PackRequest) Descriptor deprecated

func (*PackRequest) Descriptor() ([]byte, []int)

Deprecated: Use PackRequest.ProtoReflect.Descriptor instead.

func (*PackRequest) GetAgentName

func (x *PackRequest) GetAgentName() string

func (*PackRequest) GetAgentProjectPath

func (x *PackRequest) GetAgentProjectPath() string

func (*PackRequest) GetAgentVersion

func (x *PackRequest) GetAgentVersion() string

func (*PackRequest) GetBaseImage

func (x *PackRequest) GetBaseImage() string

func (*PackRequest) ProtoMessage

func (*PackRequest) ProtoMessage()

func (*PackRequest) ProtoReflect

func (x *PackRequest) ProtoReflect() protoreflect.Message

func (*PackRequest) Reset

func (x *PackRequest) Reset()

func (*PackRequest) String

func (x *PackRequest) String() string

type PackResponse

type PackResponse struct {

	// Digest of the built agent image.
	ImageDigest string `protobuf:"bytes,1,opt,name=image_digest,json=imageDigest,proto3" json:"image_digest,omitempty"`
	// Human-readable build log excerpt.
	BuildLog string `protobuf:"bytes,2,opt,name=build_log,json=buildLog,proto3" json:"build_log,omitempty"`
	// contains filtered or unexported fields
}

func (*PackResponse) Descriptor deprecated

func (*PackResponse) Descriptor() ([]byte, []int)

Deprecated: Use PackResponse.ProtoReflect.Descriptor instead.

func (*PackResponse) GetBuildLog

func (x *PackResponse) GetBuildLog() string

func (*PackResponse) GetImageDigest

func (x *PackResponse) GetImageDigest() string

func (*PackResponse) ProtoMessage

func (*PackResponse) ProtoMessage()

func (*PackResponse) ProtoReflect

func (x *PackResponse) ProtoReflect() protoreflect.Message

func (*PackResponse) Reset

func (x *PackResponse) Reset()

func (*PackResponse) String

func (x *PackResponse) String() string

type PolicyApplyRequest

type PolicyApplyRequest struct {

	// OPA/Rego policy YAML content.
	PolicyYaml string `protobuf:"bytes,1,opt,name=policy_yaml,json=policyYaml,proto3" json:"policy_yaml,omitempty"`
	// When true, validate without applying.
	DryRun bool `protobuf:"varint,2,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

func (*PolicyApplyRequest) Descriptor deprecated

func (*PolicyApplyRequest) Descriptor() ([]byte, []int)

Deprecated: Use PolicyApplyRequest.ProtoReflect.Descriptor instead.

func (*PolicyApplyRequest) GetDryRun

func (x *PolicyApplyRequest) GetDryRun() bool

func (*PolicyApplyRequest) GetPolicyYaml

func (x *PolicyApplyRequest) GetPolicyYaml() string

func (*PolicyApplyRequest) ProtoMessage

func (*PolicyApplyRequest) ProtoMessage()

func (*PolicyApplyRequest) ProtoReflect

func (x *PolicyApplyRequest) ProtoReflect() protoreflect.Message

func (*PolicyApplyRequest) Reset

func (x *PolicyApplyRequest) Reset()

func (*PolicyApplyRequest) String

func (x *PolicyApplyRequest) String() string

type PolicyApplyResponse

type PolicyApplyResponse struct {

	// Digest of the applied policy.
	PolicyDigest string `protobuf:"bytes,1,opt,name=policy_digest,json=policyDigest,proto3" json:"policy_digest,omitempty"`
	// Number of rules applied.
	RulesApplied int32 `protobuf:"varint,2,opt,name=rules_applied,json=rulesApplied,proto3" json:"rules_applied,omitempty"`
	// Any validation warnings.
	Warnings []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*PolicyApplyResponse) Descriptor deprecated

func (*PolicyApplyResponse) Descriptor() ([]byte, []int)

Deprecated: Use PolicyApplyResponse.ProtoReflect.Descriptor instead.

func (*PolicyApplyResponse) GetPolicyDigest

func (x *PolicyApplyResponse) GetPolicyDigest() string

func (*PolicyApplyResponse) GetRulesApplied

func (x *PolicyApplyResponse) GetRulesApplied() int32

func (*PolicyApplyResponse) GetWarnings

func (x *PolicyApplyResponse) GetWarnings() []string

func (*PolicyApplyResponse) ProtoMessage

func (*PolicyApplyResponse) ProtoMessage()

func (*PolicyApplyResponse) ProtoReflect

func (x *PolicyApplyResponse) ProtoReflect() protoreflect.Message

func (*PolicyApplyResponse) Reset

func (x *PolicyApplyResponse) Reset()

func (*PolicyApplyResponse) String

func (x *PolicyApplyResponse) String() string

type ProjectValidation

type ProjectValidation struct {

	// Name of the validation check.
	Check string `protobuf:"bytes,1,opt,name=check,proto3" json:"check,omitempty"`
	// Whether the check passed.
	Passed bool `protobuf:"varint,2,opt,name=passed,proto3" json:"passed,omitempty"`
	// Human-readable details.
	Details string `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectValidation) Descriptor deprecated

func (*ProjectValidation) Descriptor() ([]byte, []int)

Deprecated: Use ProjectValidation.ProtoReflect.Descriptor instead.

func (*ProjectValidation) GetCheck

func (x *ProjectValidation) GetCheck() string

func (*ProjectValidation) GetDetails

func (x *ProjectValidation) GetDetails() string

func (*ProjectValidation) GetPassed

func (x *ProjectValidation) GetPassed() bool

func (*ProjectValidation) ProtoMessage

func (*ProjectValidation) ProtoMessage()

func (*ProjectValidation) ProtoReflect

func (x *ProjectValidation) ProtoReflect() protoreflect.Message

func (*ProjectValidation) Reset

func (x *ProjectValidation) Reset()

func (*ProjectValidation) String

func (x *ProjectValidation) String() string

type RecommendPolicyPatchRequest

type RecommendPolicyPatchRequest struct {

	// Description of the desired behavior the policy should allow.
	DesiredBehavior string `protobuf:"bytes,1,opt,name=desired_behavior,json=desiredBehavior,proto3" json:"desired_behavior,omitempty"`
	// contains filtered or unexported fields
}

func (*RecommendPolicyPatchRequest) Descriptor deprecated

func (*RecommendPolicyPatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use RecommendPolicyPatchRequest.ProtoReflect.Descriptor instead.

func (*RecommendPolicyPatchRequest) GetDesiredBehavior

func (x *RecommendPolicyPatchRequest) GetDesiredBehavior() string

func (*RecommendPolicyPatchRequest) ProtoMessage

func (*RecommendPolicyPatchRequest) ProtoMessage()

func (*RecommendPolicyPatchRequest) ProtoReflect

func (*RecommendPolicyPatchRequest) Reset

func (x *RecommendPolicyPatchRequest) Reset()

func (*RecommendPolicyPatchRequest) String

func (x *RecommendPolicyPatchRequest) String() string

type RecommendPolicyPatchResponse

type RecommendPolicyPatchResponse struct {

	// Suggested OPA/Rego policy patch in YAML.
	PatchYaml string `protobuf:"bytes,1,opt,name=patch_yaml,json=patchYaml,proto3" json:"patch_yaml,omitempty"`
	// Explanation of what the patch does.
	Explanation string `protobuf:"bytes,2,opt,name=explanation,proto3" json:"explanation,omitempty"`
	// Risk assessment: "low", "medium", "high".
	RiskAssessment string `protobuf:"bytes,3,opt,name=risk_assessment,json=riskAssessment,proto3" json:"risk_assessment,omitempty"`
	// --- Block 11 operator contract fields ---
	SchemaVersion string `protobuf:"bytes,10,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// Proposed patch (YAML snippet or unified diff).
	ProposedPatch string `protobuf:"bytes,11,opt,name=proposed_patch,json=proposedPatch,proto3" json:"proposed_patch,omitempty"`
	// "low", "medium", or "high".
	RiskLevel            string                   `protobuf:"bytes,12,opt,name=risk_level,json=riskLevel,proto3" json:"risk_level,omitempty"`
	Rationale            string                   `protobuf:"bytes,13,opt,name=rationale,proto3" json:"rationale,omitempty"`
	AffectedDestinations []string                 `protobuf:"bytes,14,rep,name=affected_destinations,json=affectedDestinations,proto3" json:"affected_destinations,omitempty"`
	CredentialIds        []string                 `protobuf:"bytes,15,rep,name=credential_ids,json=credentialIds,proto3" json:"credential_ids,omitempty"`
	EvidenceRefs         []*EvidenceRef           `protobuf:"bytes,16,rep,name=evidence_refs,json=evidenceRefs,proto3" json:"evidence_refs,omitempty"`
	Confirmation         *ConfirmationRequirement `protobuf:"bytes,17,opt,name=confirmation,proto3" json:"confirmation,omitempty"`
	// Always "review_policy_patch".
	NextAction string `protobuf:"bytes,18,opt,name=next_action,json=nextAction,proto3" json:"next_action,omitempty"`
	// contains filtered or unexported fields
}

func (*RecommendPolicyPatchResponse) Descriptor deprecated

func (*RecommendPolicyPatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use RecommendPolicyPatchResponse.ProtoReflect.Descriptor instead.

func (*RecommendPolicyPatchResponse) GetAffectedDestinations

func (x *RecommendPolicyPatchResponse) GetAffectedDestinations() []string

func (*RecommendPolicyPatchResponse) GetConfirmation

func (*RecommendPolicyPatchResponse) GetCredentialIds

func (x *RecommendPolicyPatchResponse) GetCredentialIds() []string

func (*RecommendPolicyPatchResponse) GetEvidenceRefs

func (x *RecommendPolicyPatchResponse) GetEvidenceRefs() []*EvidenceRef

func (*RecommendPolicyPatchResponse) GetExplanation

func (x *RecommendPolicyPatchResponse) GetExplanation() string

func (*RecommendPolicyPatchResponse) GetNextAction

func (x *RecommendPolicyPatchResponse) GetNextAction() string

func (*RecommendPolicyPatchResponse) GetPatchYaml

func (x *RecommendPolicyPatchResponse) GetPatchYaml() string

func (*RecommendPolicyPatchResponse) GetProposedPatch

func (x *RecommendPolicyPatchResponse) GetProposedPatch() string

func (*RecommendPolicyPatchResponse) GetRationale

func (x *RecommendPolicyPatchResponse) GetRationale() string

func (*RecommendPolicyPatchResponse) GetRiskAssessment

func (x *RecommendPolicyPatchResponse) GetRiskAssessment() string

func (*RecommendPolicyPatchResponse) GetRiskLevel

func (x *RecommendPolicyPatchResponse) GetRiskLevel() string

func (*RecommendPolicyPatchResponse) GetSchemaVersion

func (x *RecommendPolicyPatchResponse) GetSchemaVersion() string

func (*RecommendPolicyPatchResponse) ProtoMessage

func (*RecommendPolicyPatchResponse) ProtoMessage()

func (*RecommendPolicyPatchResponse) ProtoReflect

func (*RecommendPolicyPatchResponse) Reset

func (x *RecommendPolicyPatchResponse) Reset()

func (*RecommendPolicyPatchResponse) String

type RedactedExcerpt

type RedactedExcerpt struct {
	Source    string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	StartLine int32  `protobuf:"varint,2,opt,name=start_line,json=startLine,proto3" json:"start_line,omitempty"`
	EndLine   int32  `protobuf:"varint,3,opt,name=end_line,json=endLine,proto3" json:"end_line,omitempty"`
	// Redacted content (secrets stripped).
	Content string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

RedactedExcerpt is a sanitized snippet of source/log/trace data.

func (*RedactedExcerpt) Descriptor deprecated

func (*RedactedExcerpt) Descriptor() ([]byte, []int)

Deprecated: Use RedactedExcerpt.ProtoReflect.Descriptor instead.

func (*RedactedExcerpt) GetContent

func (x *RedactedExcerpt) GetContent() string

func (*RedactedExcerpt) GetEndLine

func (x *RedactedExcerpt) GetEndLine() int32

func (*RedactedExcerpt) GetSource

func (x *RedactedExcerpt) GetSource() string

func (*RedactedExcerpt) GetStartLine

func (x *RedactedExcerpt) GetStartLine() int32

func (*RedactedExcerpt) ProtoMessage

func (*RedactedExcerpt) ProtoMessage()

func (*RedactedExcerpt) ProtoReflect

func (x *RedactedExcerpt) ProtoReflect() protoreflect.Message

func (*RedactedExcerpt) Reset

func (x *RedactedExcerpt) Reset()

func (*RedactedExcerpt) String

func (x *RedactedExcerpt) String() string

type RunRequest

type RunRequest struct {

	// Name of the agent to run.
	AgentName string `protobuf:"bytes,1,opt,name=agent_name,json=agentName,proto3" json:"agent_name,omitempty"`
	// Version of the agent to run.
	AgentVersion string `protobuf:"bytes,2,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	// Trigger payload passed to the agent.
	TriggerPayload []byte `protobuf:"bytes,3,opt,name=trigger_payload,json=triggerPayload,proto3" json:"trigger_payload,omitempty"`
	// Budget configuration (optional).
	Budget *BudgetConfig `protobuf:"bytes,4,opt,name=budget,proto3" json:"budget,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated

func (*RunRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetAgentName

func (x *RunRequest) GetAgentName() string

func (*RunRequest) GetAgentVersion

func (x *RunRequest) GetAgentVersion() string

func (*RunRequest) GetBudget

func (x *RunRequest) GetBudget() *BudgetConfig

func (*RunRequest) GetTriggerPayload

func (x *RunRequest) GetTriggerPayload() []byte

func (*RunRequest) ProtoMessage

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect

func (x *RunRequest) ProtoReflect() protoreflect.Message

func (*RunRequest) Reset

func (x *RunRequest) Reset()

func (*RunRequest) String

func (x *RunRequest) String() string

type RunResponse

type RunResponse struct {

	// Unique identifier for the started run.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunResponse) Descriptor deprecated

func (*RunResponse) Descriptor() ([]byte, []int)

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) GetRunId

func (x *RunResponse) GetRunId() string

func (*RunResponse) ProtoMessage

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect

func (x *RunResponse) ProtoReflect() protoreflect.Message

func (*RunResponse) Reset

func (x *RunResponse) Reset()

func (*RunResponse) String

func (x *RunResponse) String() string

type SecretGrantRequest

type SecretGrantRequest struct {

	// Run ID to grant the secret to.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Name of the secret to grant.
	SecretName string `protobuf:"bytes,2,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretGrantRequest) Descriptor deprecated

func (*SecretGrantRequest) Descriptor() ([]byte, []int)

Deprecated: Use SecretGrantRequest.ProtoReflect.Descriptor instead.

func (*SecretGrantRequest) GetRunId

func (x *SecretGrantRequest) GetRunId() string

func (*SecretGrantRequest) GetSecretName

func (x *SecretGrantRequest) GetSecretName() string

func (*SecretGrantRequest) ProtoMessage

func (*SecretGrantRequest) ProtoMessage()

func (*SecretGrantRequest) ProtoReflect

func (x *SecretGrantRequest) ProtoReflect() protoreflect.Message

func (*SecretGrantRequest) Reset

func (x *SecretGrantRequest) Reset()

func (*SecretGrantRequest) String

func (x *SecretGrantRequest) String() string

type SecretGrantResponse

type SecretGrantResponse struct {

	// Whether the grant succeeded.
	Acknowledged bool `protobuf:"varint,1,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretGrantResponse) Descriptor deprecated

func (*SecretGrantResponse) Descriptor() ([]byte, []int)

Deprecated: Use SecretGrantResponse.ProtoReflect.Descriptor instead.

func (*SecretGrantResponse) GetAcknowledged

func (x *SecretGrantResponse) GetAcknowledged() bool

func (*SecretGrantResponse) ProtoMessage

func (*SecretGrantResponse) ProtoMessage()

func (*SecretGrantResponse) ProtoReflect

func (x *SecretGrantResponse) ProtoReflect() protoreflect.Message

func (*SecretGrantResponse) Reset

func (x *SecretGrantResponse) Reset()

func (*SecretGrantResponse) String

func (x *SecretGrantResponse) String() string

type SecretRevokeRequest

type SecretRevokeRequest struct {

	// Run ID to revoke the secret from.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Name of the secret to revoke.
	SecretName string `protobuf:"bytes,2,opt,name=secret_name,json=secretName,proto3" json:"secret_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretRevokeRequest) Descriptor deprecated

func (*SecretRevokeRequest) Descriptor() ([]byte, []int)

Deprecated: Use SecretRevokeRequest.ProtoReflect.Descriptor instead.

func (*SecretRevokeRequest) GetRunId

func (x *SecretRevokeRequest) GetRunId() string

func (*SecretRevokeRequest) GetSecretName

func (x *SecretRevokeRequest) GetSecretName() string

func (*SecretRevokeRequest) ProtoMessage

func (*SecretRevokeRequest) ProtoMessage()

func (*SecretRevokeRequest) ProtoReflect

func (x *SecretRevokeRequest) ProtoReflect() protoreflect.Message

func (*SecretRevokeRequest) Reset

func (x *SecretRevokeRequest) Reset()

func (*SecretRevokeRequest) String

func (x *SecretRevokeRequest) String() string

type SecretRevokeResponse

type SecretRevokeResponse struct {

	// Whether the revocation succeeded.
	Acknowledged bool `protobuf:"varint,1,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretRevokeResponse) Descriptor deprecated

func (*SecretRevokeResponse) Descriptor() ([]byte, []int)

Deprecated: Use SecretRevokeResponse.ProtoReflect.Descriptor instead.

func (*SecretRevokeResponse) GetAcknowledged

func (x *SecretRevokeResponse) GetAcknowledged() bool

func (*SecretRevokeResponse) ProtoMessage

func (*SecretRevokeResponse) ProtoMessage()

func (*SecretRevokeResponse) ProtoReflect

func (x *SecretRevokeResponse) ProtoReflect() protoreflect.Message

func (*SecretRevokeResponse) Reset

func (x *SecretRevokeResponse) Reset()

func (*SecretRevokeResponse) String

func (x *SecretRevokeResponse) String() string

type SecretSetRequest

type SecretSetRequest struct {

	// Name of the secret.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Scope of the secret (e.g. agent name or global).
	Scope string `protobuf:"bytes,2,opt,name=scope,proto3" json:"scope,omitempty"`
	// How the secret is injected.
	Type SecretType `protobuf:"varint,3,opt,name=type,proto3,enum=agentpaas.control.v1.SecretType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretSetRequest) Descriptor deprecated

func (*SecretSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use SecretSetRequest.ProtoReflect.Descriptor instead.

func (*SecretSetRequest) GetName

func (x *SecretSetRequest) GetName() string

func (*SecretSetRequest) GetScope

func (x *SecretSetRequest) GetScope() string

func (*SecretSetRequest) GetType

func (x *SecretSetRequest) GetType() SecretType

func (*SecretSetRequest) ProtoMessage

func (*SecretSetRequest) ProtoMessage()

func (*SecretSetRequest) ProtoReflect

func (x *SecretSetRequest) ProtoReflect() protoreflect.Message

func (*SecretSetRequest) Reset

func (x *SecretSetRequest) Reset()

func (*SecretSetRequest) String

func (x *SecretSetRequest) String() string

type SecretSetResponse

type SecretSetResponse struct {

	// Whether the secret was created or updated.
	Created bool `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*SecretSetResponse) Descriptor deprecated

func (*SecretSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use SecretSetResponse.ProtoReflect.Descriptor instead.

func (*SecretSetResponse) GetCreated

func (x *SecretSetResponse) GetCreated() bool

func (*SecretSetResponse) ProtoMessage

func (*SecretSetResponse) ProtoMessage()

func (*SecretSetResponse) ProtoReflect

func (x *SecretSetResponse) ProtoReflect() protoreflect.Message

func (*SecretSetResponse) Reset

func (x *SecretSetResponse) Reset()

func (*SecretSetResponse) String

func (x *SecretSetResponse) String() string

type SecretType

type SecretType int32

SecretType represents how a secret is injected.

const (
	SecretType_SECRET_TYPE_UNSPECIFIED SecretType = 0
	SecretType_SECRET_TYPE_ENV         SecretType = 1
	SecretType_SECRET_TYPE_FILE        SecretType = 2
	SecretType_SECRET_TYPE_INLINE      SecretType = 3
)

func (SecretType) Descriptor

func (SecretType) Descriptor() protoreflect.EnumDescriptor

func (SecretType) Enum

func (x SecretType) Enum() *SecretType

func (SecretType) EnumDescriptor deprecated

func (SecretType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SecretType.Descriptor instead.

func (SecretType) Number

func (x SecretType) Number() protoreflect.EnumNumber

func (SecretType) String

func (x SecretType) String() string

func (SecretType) Type

type StopRequest

type StopRequest struct {

	// ID of the run to stop.
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Reason for stopping (optional).
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// Force immediate termination without graceful shutdown.
	Force bool `protobuf:"varint,3,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*StopRequest) Descriptor deprecated

func (*StopRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) GetForce

func (x *StopRequest) GetForce() bool

func (*StopRequest) GetReason

func (x *StopRequest) GetReason() string

func (*StopRequest) GetRunId

func (x *StopRequest) GetRunId() string

func (*StopRequest) ProtoMessage

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect

func (x *StopRequest) ProtoReflect() protoreflect.Message

func (*StopRequest) Reset

func (x *StopRequest) Reset()

func (*StopRequest) String

func (x *StopRequest) String() string

type StopResponse

type StopResponse struct {

	// Whether the stop was acknowledged.
	Acknowledged bool `protobuf:"varint,1,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	// contains filtered or unexported fields
}

func (*StopResponse) Descriptor deprecated

func (*StopResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) GetAcknowledged

func (x *StopResponse) GetAcknowledged() bool

func (*StopResponse) ProtoMessage

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect

func (x *StopResponse) ProtoReflect() protoreflect.Message

func (*StopResponse) Reset

func (x *StopResponse) Reset()

func (*StopResponse) String

func (x *StopResponse) String() string

type SummarizeRunRequest

type SummarizeRunRequest struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SummarizeRunRequest) Descriptor deprecated

func (*SummarizeRunRequest) Descriptor() ([]byte, []int)

Deprecated: Use SummarizeRunRequest.ProtoReflect.Descriptor instead.

func (*SummarizeRunRequest) GetRunId

func (x *SummarizeRunRequest) GetRunId() string

func (*SummarizeRunRequest) ProtoMessage

func (*SummarizeRunRequest) ProtoMessage()

func (*SummarizeRunRequest) ProtoReflect

func (x *SummarizeRunRequest) ProtoReflect() protoreflect.Message

func (*SummarizeRunRequest) Reset

func (x *SummarizeRunRequest) Reset()

func (*SummarizeRunRequest) String

func (x *SummarizeRunRequest) String() string

type SummarizeRunResponse

type SummarizeRunResponse struct {

	// Natural-language summary of the run.
	Summary string `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	// Key events extracted from the run.
	KeyEvents []*KeyEvent `protobuf:"bytes,2,rep,name=key_events,json=keyEvents,proto3" json:"key_events,omitempty"`
	// Budget consumed during the run.
	BudgetUsed string `protobuf:"bytes,3,opt,name=budget_used,json=budgetUsed,proto3" json:"budget_used,omitempty"`
	// --- Block 11 operator contract fields ---
	SchemaVersion string `protobuf:"bytes,10,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// Run status: "completed", "failed", "running", "stopped".
	Status        string                 `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	ExitCode      int32                  `protobuf:"varint,12,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	StartedAt     *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt    *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	DurationMs    int64                  `protobuf:"varint,15,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	Invocations   int32                  `protobuf:"varint,16,opt,name=invocations,proto3" json:"invocations,omitempty"`
	PolicyDenials int32                  `protobuf:"varint,17,opt,name=policy_denials,json=policyDenials,proto3" json:"policy_denials,omitempty"`
	// Stable error category (set when status is "failed").
	ErrorCategory string         `protobuf:"bytes,18,opt,name=error_category,json=errorCategory,proto3" json:"error_category,omitempty"`
	EvidenceRefs  []*EvidenceRef `protobuf:"bytes,19,rep,name=evidence_refs,json=evidenceRefs,proto3" json:"evidence_refs,omitempty"`
	// contains filtered or unexported fields
}

func (*SummarizeRunResponse) Descriptor deprecated

func (*SummarizeRunResponse) Descriptor() ([]byte, []int)

Deprecated: Use SummarizeRunResponse.ProtoReflect.Descriptor instead.

func (*SummarizeRunResponse) GetBudgetUsed

func (x *SummarizeRunResponse) GetBudgetUsed() string

func (*SummarizeRunResponse) GetDurationMs

func (x *SummarizeRunResponse) GetDurationMs() int64

func (*SummarizeRunResponse) GetErrorCategory

func (x *SummarizeRunResponse) GetErrorCategory() string

func (*SummarizeRunResponse) GetEvidenceRefs

func (x *SummarizeRunResponse) GetEvidenceRefs() []*EvidenceRef

func (*SummarizeRunResponse) GetExitCode

func (x *SummarizeRunResponse) GetExitCode() int32

func (*SummarizeRunResponse) GetFinishedAt

func (x *SummarizeRunResponse) GetFinishedAt() *timestamppb.Timestamp

func (*SummarizeRunResponse) GetInvocations

func (x *SummarizeRunResponse) GetInvocations() int32

func (*SummarizeRunResponse) GetKeyEvents

func (x *SummarizeRunResponse) GetKeyEvents() []*KeyEvent

func (*SummarizeRunResponse) GetPolicyDenials

func (x *SummarizeRunResponse) GetPolicyDenials() int32

func (*SummarizeRunResponse) GetSchemaVersion

func (x *SummarizeRunResponse) GetSchemaVersion() string

func (*SummarizeRunResponse) GetStartedAt

func (x *SummarizeRunResponse) GetStartedAt() *timestamppb.Timestamp

func (*SummarizeRunResponse) GetStatus

func (x *SummarizeRunResponse) GetStatus() string

func (*SummarizeRunResponse) GetSummary

func (x *SummarizeRunResponse) GetSummary() string

func (*SummarizeRunResponse) ProtoMessage

func (*SummarizeRunResponse) ProtoMessage()

func (*SummarizeRunResponse) ProtoReflect

func (x *SummarizeRunResponse) ProtoReflect() protoreflect.Message

func (*SummarizeRunResponse) Reset

func (x *SummarizeRunResponse) Reset()

func (*SummarizeRunResponse) String

func (x *SummarizeRunResponse) String() string

type TimeRange

type TimeRange struct {
	Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeRange) Descriptor deprecated

func (*TimeRange) Descriptor() ([]byte, []int)

Deprecated: Use TimeRange.ProtoReflect.Descriptor instead.

func (*TimeRange) GetEnd

func (x *TimeRange) GetEnd() *timestamppb.Timestamp

func (*TimeRange) GetStart

func (x *TimeRange) GetStart() *timestamppb.Timestamp

func (*TimeRange) ProtoMessage

func (*TimeRange) ProtoMessage()

func (*TimeRange) ProtoReflect

func (x *TimeRange) ProtoReflect() protoreflect.Message

func (*TimeRange) Reset

func (x *TimeRange) Reset()

func (*TimeRange) String

func (x *TimeRange) String() string

type TimelineEvent

type TimelineEvent struct {

	// When the event occurred.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Event type identifier.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Human-readable description.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Arbitrary structured data associated with the event.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*TimelineEvent) Descriptor deprecated

func (*TimelineEvent) Descriptor() ([]byte, []int)

Deprecated: Use TimelineEvent.ProtoReflect.Descriptor instead.

func (*TimelineEvent) GetData

func (x *TimelineEvent) GetData() []byte

func (*TimelineEvent) GetDescription

func (x *TimelineEvent) GetDescription() string

func (*TimelineEvent) GetTimestamp

func (x *TimelineEvent) GetTimestamp() *timestamppb.Timestamp

func (*TimelineEvent) GetType

func (x *TimelineEvent) GetType() string

func (*TimelineEvent) ProtoMessage

func (*TimelineEvent) ProtoMessage()

func (*TimelineEvent) ProtoReflect

func (x *TimelineEvent) ProtoReflect() protoreflect.Message

func (*TimelineEvent) Reset

func (x *TimelineEvent) Reset()

func (*TimelineEvent) String

func (x *TimelineEvent) String() string

type UnimplementedControlServiceServer

type UnimplementedControlServiceServer struct{}

UnimplementedControlServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedControlServiceServer) AuditExport

func (UnimplementedControlServiceServer) AuditQuery

func (UnimplementedControlServiceServer) CronAdd

func (UnimplementedControlServiceServer) CronList

func (UnimplementedControlServiceServer) CronRemove

func (UnimplementedControlServiceServer) Doctor

func (UnimplementedControlServiceServer) ExplainFailure

func (UnimplementedControlServiceServer) ExplainPolicyDenial

func (UnimplementedControlServiceServer) GetRunTimeline

func (UnimplementedControlServiceServer) Logs

func (UnimplementedControlServiceServer) NextAction

func (UnimplementedControlServiceServer) Pack

func (UnimplementedControlServiceServer) PolicyApply

func (UnimplementedControlServiceServer) Run

func (UnimplementedControlServiceServer) SecretGrant

func (UnimplementedControlServiceServer) SecretRevoke

func (UnimplementedControlServiceServer) SecretSet

func (UnimplementedControlServiceServer) Stop

func (UnimplementedControlServiceServer) SummarizeRun

type UnsafeControlServiceServer

type UnsafeControlServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeControlServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlServiceServer will result in compilation errors.

type ValidateAgentProjectRequest

type ValidateAgentProjectRequest struct {

	// Path to the agent project directory.
	ProjectPath string `protobuf:"bytes,1,opt,name=project_path,json=projectPath,proto3" json:"project_path,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateAgentProjectRequest) Descriptor deprecated

func (*ValidateAgentProjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateAgentProjectRequest.ProtoReflect.Descriptor instead.

func (*ValidateAgentProjectRequest) GetProjectPath

func (x *ValidateAgentProjectRequest) GetProjectPath() string

func (*ValidateAgentProjectRequest) ProtoMessage

func (*ValidateAgentProjectRequest) ProtoMessage()

func (*ValidateAgentProjectRequest) ProtoReflect

func (*ValidateAgentProjectRequest) Reset

func (x *ValidateAgentProjectRequest) Reset()

func (*ValidateAgentProjectRequest) String

func (x *ValidateAgentProjectRequest) String() string

type ValidateAgentProjectResponse

type ValidateAgentProjectResponse struct {
	Validations []*ProjectValidation `protobuf:"bytes,1,rep,name=validations,proto3" json:"validations,omitempty"`
	// Overall pass/fail.
	Valid bool `protobuf:"varint,2,opt,name=valid,proto3" json:"valid,omitempty"`
	// Summary message.
	Summary string `protobuf:"bytes,3,opt,name=summary,proto3" json:"summary,omitempty"`
	// --- Block 11 operator contract fields ---
	// Operator schema version (e.g. "1.0.0").
	SchemaVersion string `protobuf:"bytes,10,opt,name=schema_version,json=schemaVersion,proto3" json:"schema_version,omitempty"`
	// Whether the project is ready to pack/run (same as valid, but named for
	// the operator schema).
	Ready bool `protobuf:"varint,11,opt,name=ready,proto3" json:"ready,omitempty"`
	// Absolute path of the validated project.
	ProjectDir string `protobuf:"bytes,12,opt,name=project_dir,json=projectDir,proto3" json:"project_dir,omitempty"`
	// Detected agent runtime ("python", "langgraph", etc.).
	Runtime string `protobuf:"bytes,13,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// Readiness issues with error categories and next actions.
	Issues []*OperatorIssue `protobuf:"bytes,14,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateAgentProjectResponse) Descriptor deprecated

func (*ValidateAgentProjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateAgentProjectResponse.ProtoReflect.Descriptor instead.

func (*ValidateAgentProjectResponse) GetIssues

func (x *ValidateAgentProjectResponse) GetIssues() []*OperatorIssue

func (*ValidateAgentProjectResponse) GetProjectDir

func (x *ValidateAgentProjectResponse) GetProjectDir() string

func (*ValidateAgentProjectResponse) GetReady

func (x *ValidateAgentProjectResponse) GetReady() bool

func (*ValidateAgentProjectResponse) GetRuntime

func (x *ValidateAgentProjectResponse) GetRuntime() string

func (*ValidateAgentProjectResponse) GetSchemaVersion

func (x *ValidateAgentProjectResponse) GetSchemaVersion() string

func (*ValidateAgentProjectResponse) GetSummary

func (x *ValidateAgentProjectResponse) GetSummary() string

func (*ValidateAgentProjectResponse) GetValid

func (x *ValidateAgentProjectResponse) GetValid() bool

func (*ValidateAgentProjectResponse) GetValidations

func (x *ValidateAgentProjectResponse) GetValidations() []*ProjectValidation

func (*ValidateAgentProjectResponse) ProtoMessage

func (*ValidateAgentProjectResponse) ProtoMessage()

func (*ValidateAgentProjectResponse) ProtoReflect

func (*ValidateAgentProjectResponse) Reset

func (x *ValidateAgentProjectResponse) Reset()

func (*ValidateAgentProjectResponse) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL