Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterRuntimeProviderServiceServer(s grpc.ServiceRegistrar, srv RuntimeProviderServiceServer)
- type ControlSessionRequest
- func (*ControlSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ControlSessionRequest) GetAction() string
- func (x *ControlSessionRequest) GetPayload() []byte
- func (x *ControlSessionRequest) GetSessionId() string
- func (*ControlSessionRequest) ProtoMessage()
- func (x *ControlSessionRequest) ProtoReflect() protoreflect.Message
- func (x *ControlSessionRequest) Reset()
- func (x *ControlSessionRequest) String() string
- type ControlSessionResponse
- func (*ControlSessionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ControlSessionResponse) GetHealthy() bool
- func (x *ControlSessionResponse) GetMessage() string
- func (*ControlSessionResponse) ProtoMessage()
- func (x *ControlSessionResponse) ProtoReflect() protoreflect.Message
- func (x *ControlSessionResponse) Reset()
- func (x *ControlSessionResponse) String() string
- type DescribeRequest
- type NetworkAuditDestination
- func (*NetworkAuditDestination) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkAuditDestination) GetKind() string
- func (x *NetworkAuditDestination) GetValue() string
- func (*NetworkAuditDestination) ProtoMessage()
- func (x *NetworkAuditDestination) ProtoReflect() protoreflect.Message
- func (x *NetworkAuditDestination) Reset()
- func (x *NetworkAuditDestination) String() string
- type NetworkAuditProviderEvidence
- func (*NetworkAuditProviderEvidence) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkAuditProviderEvidence) GetContractId() string
- func (x *NetworkAuditProviderEvidence) GetContractVersion() string
- func (x *NetworkAuditProviderEvidence) GetDescriptorDigest() string
- func (x *NetworkAuditProviderEvidence) GetPluginName() string
- func (x *NetworkAuditProviderEvidence) GetPluginVersion() string
- func (x *NetworkAuditProviderEvidence) GetProviderId() string
- func (*NetworkAuditProviderEvidence) ProtoMessage()
- func (x *NetworkAuditProviderEvidence) ProtoReflect() protoreflect.Message
- func (x *NetworkAuditProviderEvidence) Reset()
- func (x *NetworkAuditProviderEvidence) String() string
- type NetworkAuditRecord
- func (*NetworkAuditRecord) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkAuditRecord) GetDestination() *NetworkAuditDestination
- func (x *NetworkAuditRecord) GetFinishedAtUnixNano() int64
- func (x *NetworkAuditRecord) GetLabels() map[string]string
- func (x *NetworkAuditRecord) GetLeaseId() string
- func (x *NetworkAuditRecord) GetObservedAtUnixNano() int64
- func (x *NetworkAuditRecord) GetProtocolVersion() string
- func (x *NetworkAuditRecord) GetProvider() *NetworkAuditProviderEvidence
- func (x *NetworkAuditRecord) GetRecordId() string
- func (x *NetworkAuditRecord) GetResourceUsage() *NetworkAuditResourceUsage
- func (x *NetworkAuditRecord) GetStartedAtUnixNano() int64
- func (x *NetworkAuditRecord) GetTaskId() string
- func (x *NetworkAuditRecord) GetWorkerId() string
- func (*NetworkAuditRecord) ProtoMessage()
- func (x *NetworkAuditRecord) ProtoReflect() protoreflect.Message
- func (x *NetworkAuditRecord) Reset()
- func (x *NetworkAuditRecord) String() string
- type NetworkAuditResourceUsage
- func (*NetworkAuditResourceUsage) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkAuditResourceUsage) GetCpuMillis() int64
- func (x *NetworkAuditResourceUsage) GetGpuMillis() int64
- func (x *NetworkAuditResourceUsage) GetLimitHit() string
- func (x *NetworkAuditResourceUsage) GetMaxMemoryBytes() int64
- func (x *NetworkAuditResourceUsage) GetNetworkRxBytes() int64
- func (x *NetworkAuditResourceUsage) GetNetworkTxBytes() int64
- func (x *NetworkAuditResourceUsage) GetOutputBytes() int64
- func (x *NetworkAuditResourceUsage) GetWorkspaceBytes() int64
- func (*NetworkAuditResourceUsage) ProtoMessage()
- func (x *NetworkAuditResourceUsage) ProtoReflect() protoreflect.Message
- func (x *NetworkAuditResourceUsage) Reset()
- func (x *NetworkAuditResourceUsage) String() string
- type NetworkAuditValidationIssue
- func (*NetworkAuditValidationIssue) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkAuditValidationIssue) GetCode() string
- func (x *NetworkAuditValidationIssue) GetField() string
- func (x *NetworkAuditValidationIssue) GetMessage() string
- func (*NetworkAuditValidationIssue) ProtoMessage()
- func (x *NetworkAuditValidationIssue) ProtoReflect() protoreflect.Message
- func (x *NetworkAuditValidationIssue) Reset()
- func (x *NetworkAuditValidationIssue) String() string
- type ProviderCapabilities
- func (*ProviderCapabilities) Descriptor() ([]byte, []int)deprecated
- func (x *ProviderCapabilities) GetExecutorProviders() []string
- func (x *ProviderCapabilities) GetProviderId() string
- func (x *ProviderCapabilities) GetRuntimeProfiles() []string
- func (x *ProviderCapabilities) GetWorkloadKinds() []string
- func (*ProviderCapabilities) ProtoMessage()
- func (x *ProviderCapabilities) ProtoReflect() protoreflect.Message
- func (x *ProviderCapabilities) Reset()
- func (x *ProviderCapabilities) String() string
- type RunEvent
- func (*RunEvent) Descriptor() ([]byte, []int)deprecated
- func (x *RunEvent) GetEvent() isRunEvent_Event
- func (x *RunEvent) GetStderr() []byte
- func (x *RunEvent) GetStdout() []byte
- func (x *RunEvent) GetTerminal() *RunResult
- func (*RunEvent) ProtoMessage()
- func (x *RunEvent) ProtoReflect() protoreflect.Message
- func (x *RunEvent) Reset()
- func (x *RunEvent) String() string
- type RunEvent_Stderr
- type RunEvent_Stdout
- type RunEvent_Terminal
- type RunRequest
- func (*RunRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RunRequest) GetEnv() map[string]string
- func (x *RunRequest) GetExecutorProvider() string
- func (x *RunRequest) GetInput() []byte
- func (x *RunRequest) GetLeaseId() string
- func (x *RunRequest) GetTaskId() string
- func (*RunRequest) ProtoMessage()
- func (x *RunRequest) ProtoReflect() protoreflect.Message
- func (x *RunRequest) Reset()
- func (x *RunRequest) String() string
- type RunResult
- func (*RunResult) Descriptor() ([]byte, []int)deprecated
- func (x *RunResult) GetArtifactHash() string
- func (x *RunResult) GetArtifacts() []string
- func (x *RunResult) GetExitCode() int32
- func (*RunResult) ProtoMessage()
- func (x *RunResult) ProtoReflect() protoreflect.Message
- func (x *RunResult) Reset()
- func (x *RunResult) String() string
- type RuntimeProviderServiceClient
- type RuntimeProviderServiceServer
- type RuntimeProviderService_RunClient
- type RuntimeProviderService_RunServer
- type RuntimeProviderService_SessionEventsClient
- type RuntimeProviderService_SessionEventsServer
- type SessionEvent
- func (*SessionEvent) Descriptor() ([]byte, []int)deprecated
- func (x *SessionEvent) GetEventType() string
- func (x *SessionEvent) GetEvidence() []byte
- func (x *SessionEvent) GetTsUnixNanos() int64
- func (*SessionEvent) ProtoMessage()
- func (x *SessionEvent) ProtoReflect() protoreflect.Message
- func (x *SessionEvent) Reset()
- func (x *SessionEvent) String() string
- type SessionHandle
- type StartSessionRequest
- func (*StartSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartSessionRequest) GetEnv() map[string]string
- func (x *StartSessionRequest) GetExecutorProvider() string
- func (x *StartSessionRequest) GetInput() []byte
- func (x *StartSessionRequest) GetLeaseId() string
- func (x *StartSessionRequest) GetTaskId() string
- func (*StartSessionRequest) ProtoMessage()
- func (x *StartSessionRequest) ProtoReflect() protoreflect.Message
- func (x *StartSessionRequest) Reset()
- func (x *StartSessionRequest) String() string
- type UnimplementedRuntimeProviderServiceServer
- func (UnimplementedRuntimeProviderServiceServer) ControlSession(context.Context, *ControlSessionRequest) (*ControlSessionResponse, error)
- func (UnimplementedRuntimeProviderServiceServer) Describe(context.Context, *DescribeRequest) (*ProviderCapabilities, error)
- func (UnimplementedRuntimeProviderServiceServer) Run(*RunRequest, grpc.ServerStreamingServer[RunEvent]) error
- func (UnimplementedRuntimeProviderServiceServer) SessionEvents(*SessionHandle, grpc.ServerStreamingServer[SessionEvent]) error
- func (UnimplementedRuntimeProviderServiceServer) StartSession(context.Context, *StartSessionRequest) (*SessionHandle, error)
- type UnsafeRuntimeProviderServiceServer
Constants ¶
const ( RuntimeProviderService_Describe_FullMethodName = "/workflow_plugin_compute_core.protocol.v1.RuntimeProviderService/Describe" RuntimeProviderService_Run_FullMethodName = "/workflow_plugin_compute_core.protocol.v1.RuntimeProviderService/Run" RuntimeProviderService_StartSession_FullMethodName = "/workflow_plugin_compute_core.protocol.v1.RuntimeProviderService/StartSession" RuntimeProviderService_SessionEvents_FullMethodName = "/workflow_plugin_compute_core.protocol.v1.RuntimeProviderService/SessionEvents" RuntimeProviderService_ControlSession_FullMethodName = "/workflow_plugin_compute_core.protocol.v1.RuntimeProviderService/ControlSession" )
Variables ¶
var File_workflow_plugin_compute_core_protocol_v1_network_audit_proto protoreflect.FileDescriptor
var File_workflow_plugin_compute_core_protocol_v1_runtime_provider_proto protoreflect.FileDescriptor
var RuntimeProviderService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "workflow_plugin_compute_core.protocol.v1.RuntimeProviderService", HandlerType: (*RuntimeProviderServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Describe", Handler: _RuntimeProviderService_Describe_Handler, }, { MethodName: "StartSession", Handler: _RuntimeProviderService_StartSession_Handler, }, { MethodName: "ControlSession", Handler: _RuntimeProviderService_ControlSession_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Run", Handler: _RuntimeProviderService_Run_Handler, ServerStreams: true, }, { StreamName: "SessionEvents", Handler: _RuntimeProviderService_SessionEvents_Handler, ServerStreams: true, }, }, Metadata: "workflow_plugin_compute_core/protocol/v1/runtime_provider.proto", }
RuntimeProviderService_ServiceDesc is the grpc.ServiceDesc for RuntimeProviderService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRuntimeProviderServiceServer ¶ added in v0.7.1
func RegisterRuntimeProviderServiceServer(s grpc.ServiceRegistrar, srv RuntimeProviderServiceServer)
Types ¶
type ControlSessionRequest ¶ added in v0.7.1
type ControlSessionRequest struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
// contains filtered or unexported fields
}
ControlSessionRequest sends a control action to a running session. action examples: health, renew, stop, mutate.
func (*ControlSessionRequest) Descriptor
deprecated
added in
v0.7.1
func (*ControlSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use ControlSessionRequest.ProtoReflect.Descriptor instead.
func (*ControlSessionRequest) GetAction ¶ added in v0.7.1
func (x *ControlSessionRequest) GetAction() string
func (*ControlSessionRequest) GetPayload ¶ added in v0.7.1
func (x *ControlSessionRequest) GetPayload() []byte
func (*ControlSessionRequest) GetSessionId ¶ added in v0.7.1
func (x *ControlSessionRequest) GetSessionId() string
func (*ControlSessionRequest) ProtoMessage ¶ added in v0.7.1
func (*ControlSessionRequest) ProtoMessage()
func (*ControlSessionRequest) ProtoReflect ¶ added in v0.7.1
func (x *ControlSessionRequest) ProtoReflect() protoreflect.Message
func (*ControlSessionRequest) Reset ¶ added in v0.7.1
func (x *ControlSessionRequest) Reset()
func (*ControlSessionRequest) String ¶ added in v0.7.1
func (x *ControlSessionRequest) String() string
type ControlSessionResponse ¶ added in v0.7.1
type ControlSessionResponse struct {
Healthy bool `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
ControlSessionResponse is the reply to a ControlSessionRequest.
func (*ControlSessionResponse) Descriptor
deprecated
added in
v0.7.1
func (*ControlSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ControlSessionResponse.ProtoReflect.Descriptor instead.
func (*ControlSessionResponse) GetHealthy ¶ added in v0.7.1
func (x *ControlSessionResponse) GetHealthy() bool
func (*ControlSessionResponse) GetMessage ¶ added in v0.7.1
func (x *ControlSessionResponse) GetMessage() string
func (*ControlSessionResponse) ProtoMessage ¶ added in v0.7.1
func (*ControlSessionResponse) ProtoMessage()
func (*ControlSessionResponse) ProtoReflect ¶ added in v0.7.1
func (x *ControlSessionResponse) ProtoReflect() protoreflect.Message
func (*ControlSessionResponse) Reset ¶ added in v0.7.1
func (x *ControlSessionResponse) Reset()
func (*ControlSessionResponse) String ¶ added in v0.7.1
func (x *ControlSessionResponse) String() string
type DescribeRequest ¶ added in v0.7.1
type DescribeRequest struct {
// contains filtered or unexported fields
}
DescribeRequest asks the provider to describe its capabilities.
func (*DescribeRequest) Descriptor
deprecated
added in
v0.7.1
func (*DescribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use DescribeRequest.ProtoReflect.Descriptor instead.
func (*DescribeRequest) ProtoMessage ¶ added in v0.7.1
func (*DescribeRequest) ProtoMessage()
func (*DescribeRequest) ProtoReflect ¶ added in v0.7.1
func (x *DescribeRequest) ProtoReflect() protoreflect.Message
func (*DescribeRequest) Reset ¶ added in v0.7.1
func (x *DescribeRequest) Reset()
func (*DescribeRequest) String ¶ added in v0.7.1
func (x *DescribeRequest) String() string
type NetworkAuditDestination ¶
type NetworkAuditDestination struct {
Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*NetworkAuditDestination) Descriptor
deprecated
func (*NetworkAuditDestination) Descriptor() ([]byte, []int)
Deprecated: Use NetworkAuditDestination.ProtoReflect.Descriptor instead.
func (*NetworkAuditDestination) GetKind ¶
func (x *NetworkAuditDestination) GetKind() string
func (*NetworkAuditDestination) GetValue ¶
func (x *NetworkAuditDestination) GetValue() string
func (*NetworkAuditDestination) ProtoMessage ¶
func (*NetworkAuditDestination) ProtoMessage()
func (*NetworkAuditDestination) ProtoReflect ¶
func (x *NetworkAuditDestination) ProtoReflect() protoreflect.Message
func (*NetworkAuditDestination) Reset ¶
func (x *NetworkAuditDestination) Reset()
func (*NetworkAuditDestination) String ¶
func (x *NetworkAuditDestination) String() string
type NetworkAuditProviderEvidence ¶
type NetworkAuditProviderEvidence struct {
ProviderId string `protobuf:"bytes,1,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
PluginName string `protobuf:"bytes,2,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"`
PluginVersion string `protobuf:"bytes,3,opt,name=plugin_version,json=pluginVersion,proto3" json:"plugin_version,omitempty"`
ContractId string `protobuf:"bytes,4,opt,name=contract_id,json=contractId,proto3" json:"contract_id,omitempty"`
ContractVersion string `protobuf:"bytes,5,opt,name=contract_version,json=contractVersion,proto3" json:"contract_version,omitempty"`
DescriptorDigest string `protobuf:"bytes,6,opt,name=descriptor_digest,json=descriptorDigest,proto3" json:"descriptor_digest,omitempty"`
// contains filtered or unexported fields
}
func (*NetworkAuditProviderEvidence) Descriptor
deprecated
func (*NetworkAuditProviderEvidence) Descriptor() ([]byte, []int)
Deprecated: Use NetworkAuditProviderEvidence.ProtoReflect.Descriptor instead.
func (*NetworkAuditProviderEvidence) GetContractId ¶
func (x *NetworkAuditProviderEvidence) GetContractId() string
func (*NetworkAuditProviderEvidence) GetContractVersion ¶
func (x *NetworkAuditProviderEvidence) GetContractVersion() string
func (*NetworkAuditProviderEvidence) GetDescriptorDigest ¶
func (x *NetworkAuditProviderEvidence) GetDescriptorDigest() string
func (*NetworkAuditProviderEvidence) GetPluginName ¶
func (x *NetworkAuditProviderEvidence) GetPluginName() string
func (*NetworkAuditProviderEvidence) GetPluginVersion ¶
func (x *NetworkAuditProviderEvidence) GetPluginVersion() string
func (*NetworkAuditProviderEvidence) GetProviderId ¶
func (x *NetworkAuditProviderEvidence) GetProviderId() string
func (*NetworkAuditProviderEvidence) ProtoMessage ¶
func (*NetworkAuditProviderEvidence) ProtoMessage()
func (*NetworkAuditProviderEvidence) ProtoReflect ¶
func (x *NetworkAuditProviderEvidence) ProtoReflect() protoreflect.Message
func (*NetworkAuditProviderEvidence) Reset ¶
func (x *NetworkAuditProviderEvidence) Reset()
func (*NetworkAuditProviderEvidence) String ¶
func (x *NetworkAuditProviderEvidence) String() string
type NetworkAuditRecord ¶
type NetworkAuditRecord struct {
ProtocolVersion string `protobuf:"bytes,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
RecordId string `protobuf:"bytes,2,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
TaskId string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
LeaseId string `protobuf:"bytes,4,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
WorkerId string `protobuf:"bytes,5,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
Provider *NetworkAuditProviderEvidence `protobuf:"bytes,6,opt,name=provider,proto3" json:"provider,omitempty"`
Destination *NetworkAuditDestination `protobuf:"bytes,7,opt,name=destination,proto3" json:"destination,omitempty"`
ResourceUsage *NetworkAuditResourceUsage `protobuf:"bytes,8,opt,name=resource_usage,json=resourceUsage,proto3" json:"resource_usage,omitempty"`
Labels map[string]string `` /* 139-byte string literal not displayed */
StartedAtUnixNano int64 `protobuf:"varint,10,opt,name=started_at_unix_nano,json=startedAtUnixNano,proto3" json:"started_at_unix_nano,omitempty"`
FinishedAtUnixNano int64 `protobuf:"varint,11,opt,name=finished_at_unix_nano,json=finishedAtUnixNano,proto3" json:"finished_at_unix_nano,omitempty"`
ObservedAtUnixNano int64 `protobuf:"varint,12,opt,name=observed_at_unix_nano,json=observedAtUnixNano,proto3" json:"observed_at_unix_nano,omitempty"`
// contains filtered or unexported fields
}
func (*NetworkAuditRecord) Descriptor
deprecated
func (*NetworkAuditRecord) Descriptor() ([]byte, []int)
Deprecated: Use NetworkAuditRecord.ProtoReflect.Descriptor instead.
func (*NetworkAuditRecord) GetDestination ¶
func (x *NetworkAuditRecord) GetDestination() *NetworkAuditDestination
func (*NetworkAuditRecord) GetFinishedAtUnixNano ¶
func (x *NetworkAuditRecord) GetFinishedAtUnixNano() int64
func (*NetworkAuditRecord) GetLabels ¶
func (x *NetworkAuditRecord) GetLabels() map[string]string
func (*NetworkAuditRecord) GetLeaseId ¶
func (x *NetworkAuditRecord) GetLeaseId() string
func (*NetworkAuditRecord) GetObservedAtUnixNano ¶
func (x *NetworkAuditRecord) GetObservedAtUnixNano() int64
func (*NetworkAuditRecord) GetProtocolVersion ¶
func (x *NetworkAuditRecord) GetProtocolVersion() string
func (*NetworkAuditRecord) GetProvider ¶
func (x *NetworkAuditRecord) GetProvider() *NetworkAuditProviderEvidence
func (*NetworkAuditRecord) GetRecordId ¶
func (x *NetworkAuditRecord) GetRecordId() string
func (*NetworkAuditRecord) GetResourceUsage ¶
func (x *NetworkAuditRecord) GetResourceUsage() *NetworkAuditResourceUsage
func (*NetworkAuditRecord) GetStartedAtUnixNano ¶
func (x *NetworkAuditRecord) GetStartedAtUnixNano() int64
func (*NetworkAuditRecord) GetTaskId ¶
func (x *NetworkAuditRecord) GetTaskId() string
func (*NetworkAuditRecord) GetWorkerId ¶
func (x *NetworkAuditRecord) GetWorkerId() string
func (*NetworkAuditRecord) ProtoMessage ¶
func (*NetworkAuditRecord) ProtoMessage()
func (*NetworkAuditRecord) ProtoReflect ¶
func (x *NetworkAuditRecord) ProtoReflect() protoreflect.Message
func (*NetworkAuditRecord) Reset ¶
func (x *NetworkAuditRecord) Reset()
func (*NetworkAuditRecord) String ¶
func (x *NetworkAuditRecord) String() string
type NetworkAuditResourceUsage ¶
type NetworkAuditResourceUsage struct {
CpuMillis int64 `protobuf:"varint,1,opt,name=cpu_millis,json=cpuMillis,proto3" json:"cpu_millis,omitempty"`
GpuMillis int64 `protobuf:"varint,2,opt,name=gpu_millis,json=gpuMillis,proto3" json:"gpu_millis,omitempty"`
MaxMemoryBytes int64 `protobuf:"varint,3,opt,name=max_memory_bytes,json=maxMemoryBytes,proto3" json:"max_memory_bytes,omitempty"`
NetworkRxBytes int64 `protobuf:"varint,4,opt,name=network_rx_bytes,json=networkRxBytes,proto3" json:"network_rx_bytes,omitempty"`
NetworkTxBytes int64 `protobuf:"varint,5,opt,name=network_tx_bytes,json=networkTxBytes,proto3" json:"network_tx_bytes,omitempty"`
WorkspaceBytes int64 `protobuf:"varint,6,opt,name=workspace_bytes,json=workspaceBytes,proto3" json:"workspace_bytes,omitempty"`
OutputBytes int64 `protobuf:"varint,7,opt,name=output_bytes,json=outputBytes,proto3" json:"output_bytes,omitempty"`
LimitHit string `protobuf:"bytes,8,opt,name=limit_hit,json=limitHit,proto3" json:"limit_hit,omitempty"`
// contains filtered or unexported fields
}
func (*NetworkAuditResourceUsage) Descriptor
deprecated
func (*NetworkAuditResourceUsage) Descriptor() ([]byte, []int)
Deprecated: Use NetworkAuditResourceUsage.ProtoReflect.Descriptor instead.
func (*NetworkAuditResourceUsage) GetCpuMillis ¶
func (x *NetworkAuditResourceUsage) GetCpuMillis() int64
func (*NetworkAuditResourceUsage) GetGpuMillis ¶
func (x *NetworkAuditResourceUsage) GetGpuMillis() int64
func (*NetworkAuditResourceUsage) GetLimitHit ¶
func (x *NetworkAuditResourceUsage) GetLimitHit() string
func (*NetworkAuditResourceUsage) GetMaxMemoryBytes ¶
func (x *NetworkAuditResourceUsage) GetMaxMemoryBytes() int64
func (*NetworkAuditResourceUsage) GetNetworkRxBytes ¶
func (x *NetworkAuditResourceUsage) GetNetworkRxBytes() int64
func (*NetworkAuditResourceUsage) GetNetworkTxBytes ¶
func (x *NetworkAuditResourceUsage) GetNetworkTxBytes() int64
func (*NetworkAuditResourceUsage) GetOutputBytes ¶
func (x *NetworkAuditResourceUsage) GetOutputBytes() int64
func (*NetworkAuditResourceUsage) GetWorkspaceBytes ¶
func (x *NetworkAuditResourceUsage) GetWorkspaceBytes() int64
func (*NetworkAuditResourceUsage) ProtoMessage ¶
func (*NetworkAuditResourceUsage) ProtoMessage()
func (*NetworkAuditResourceUsage) ProtoReflect ¶
func (x *NetworkAuditResourceUsage) ProtoReflect() protoreflect.Message
func (*NetworkAuditResourceUsage) Reset ¶
func (x *NetworkAuditResourceUsage) Reset()
func (*NetworkAuditResourceUsage) String ¶
func (x *NetworkAuditResourceUsage) String() string
type NetworkAuditValidationIssue ¶
type NetworkAuditValidationIssue struct {
Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
Field string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*NetworkAuditValidationIssue) Descriptor
deprecated
func (*NetworkAuditValidationIssue) Descriptor() ([]byte, []int)
Deprecated: Use NetworkAuditValidationIssue.ProtoReflect.Descriptor instead.
func (*NetworkAuditValidationIssue) GetCode ¶
func (x *NetworkAuditValidationIssue) GetCode() string
func (*NetworkAuditValidationIssue) GetField ¶
func (x *NetworkAuditValidationIssue) GetField() string
func (*NetworkAuditValidationIssue) GetMessage ¶
func (x *NetworkAuditValidationIssue) GetMessage() string
func (*NetworkAuditValidationIssue) ProtoMessage ¶
func (*NetworkAuditValidationIssue) ProtoMessage()
func (*NetworkAuditValidationIssue) ProtoReflect ¶
func (x *NetworkAuditValidationIssue) ProtoReflect() protoreflect.Message
func (*NetworkAuditValidationIssue) Reset ¶
func (x *NetworkAuditValidationIssue) Reset()
func (*NetworkAuditValidationIssue) String ¶
func (x *NetworkAuditValidationIssue) String() string
type ProviderCapabilities ¶ added in v0.7.1
type ProviderCapabilities struct {
ProviderId string `protobuf:"bytes,1,opt,name=provider_id,json=providerId,proto3" json:"provider_id,omitempty"`
WorkloadKinds []string `protobuf:"bytes,2,rep,name=workload_kinds,json=workloadKinds,proto3" json:"workload_kinds,omitempty"`
ExecutorProviders []string `protobuf:"bytes,3,rep,name=executor_providers,json=executorProviders,proto3" json:"executor_providers,omitempty"`
RuntimeProfiles []string `protobuf:"bytes,4,rep,name=runtime_profiles,json=runtimeProfiles,proto3" json:"runtime_profiles,omitempty"`
// contains filtered or unexported fields
}
ProviderCapabilities describes what a RuntimeProvider can handle.
func (*ProviderCapabilities) Descriptor
deprecated
added in
v0.7.1
func (*ProviderCapabilities) Descriptor() ([]byte, []int)
Deprecated: Use ProviderCapabilities.ProtoReflect.Descriptor instead.
func (*ProviderCapabilities) GetExecutorProviders ¶ added in v0.7.1
func (x *ProviderCapabilities) GetExecutorProviders() []string
func (*ProviderCapabilities) GetProviderId ¶ added in v0.7.1
func (x *ProviderCapabilities) GetProviderId() string
func (*ProviderCapabilities) GetRuntimeProfiles ¶ added in v0.7.1
func (x *ProviderCapabilities) GetRuntimeProfiles() []string
func (*ProviderCapabilities) GetWorkloadKinds ¶ added in v0.7.1
func (x *ProviderCapabilities) GetWorkloadKinds() []string
func (*ProviderCapabilities) ProtoMessage ¶ added in v0.7.1
func (*ProviderCapabilities) ProtoMessage()
func (*ProviderCapabilities) ProtoReflect ¶ added in v0.7.1
func (x *ProviderCapabilities) ProtoReflect() protoreflect.Message
func (*ProviderCapabilities) Reset ¶ added in v0.7.1
func (x *ProviderCapabilities) Reset()
func (*ProviderCapabilities) String ¶ added in v0.7.1
func (x *ProviderCapabilities) String() string
type RunEvent ¶ added in v0.7.1
type RunEvent struct {
// Types that are valid to be assigned to Event:
//
// *RunEvent_Stdout
// *RunEvent_Stderr
// *RunEvent_Terminal
Event isRunEvent_Event `protobuf_oneof:"event"`
// contains filtered or unexported fields
}
RunEvent is a streaming chunk emitted during RunRequest execution.
func (*RunEvent) Descriptor
deprecated
added in
v0.7.1
func (*RunEvent) GetTerminal ¶ added in v0.7.1
func (*RunEvent) ProtoMessage ¶ added in v0.7.1
func (*RunEvent) ProtoMessage()
func (*RunEvent) ProtoReflect ¶ added in v0.7.1
func (x *RunEvent) ProtoReflect() protoreflect.Message
type RunEvent_Stderr ¶ added in v0.7.1
type RunEvent_Stderr struct {
Stderr []byte `protobuf:"bytes,2,opt,name=stderr,proto3,oneof"`
}
type RunEvent_Stdout ¶ added in v0.7.1
type RunEvent_Stdout struct {
Stdout []byte `protobuf:"bytes,1,opt,name=stdout,proto3,oneof"`
}
type RunEvent_Terminal ¶ added in v0.7.1
type RunEvent_Terminal struct {
Terminal *RunResult `protobuf:"bytes,3,opt,name=terminal,proto3,oneof"`
}
type RunRequest ¶ added in v0.7.1
type RunRequest struct {
ExecutorProvider string `protobuf:"bytes,1,opt,name=executor_provider,json=executorProvider,proto3" json:"executor_provider,omitempty"`
Input []byte `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
Env map[string]string `` /* 133-byte string literal not displayed */
TaskId string `protobuf:"bytes,4,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
LeaseId string `protobuf:"bytes,5,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
// contains filtered or unexported fields
}
RunRequest initiates a one-shot workload execution. env values may be unresolved secret:// refs — the provider resolves them.
func (*RunRequest) Descriptor
deprecated
added in
v0.7.1
func (*RunRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.
func (*RunRequest) GetEnv ¶ added in v0.7.1
func (x *RunRequest) GetEnv() map[string]string
func (*RunRequest) GetExecutorProvider ¶ added in v0.7.1
func (x *RunRequest) GetExecutorProvider() string
func (*RunRequest) GetInput ¶ added in v0.7.1
func (x *RunRequest) GetInput() []byte
func (*RunRequest) GetLeaseId ¶ added in v0.7.1
func (x *RunRequest) GetLeaseId() string
func (*RunRequest) GetTaskId ¶ added in v0.7.1
func (x *RunRequest) GetTaskId() string
func (*RunRequest) ProtoMessage ¶ added in v0.7.1
func (*RunRequest) ProtoMessage()
func (*RunRequest) ProtoReflect ¶ added in v0.7.1
func (x *RunRequest) ProtoReflect() protoreflect.Message
func (*RunRequest) Reset ¶ added in v0.7.1
func (x *RunRequest) Reset()
func (*RunRequest) String ¶ added in v0.7.1
func (x *RunRequest) String() string
type RunResult ¶ added in v0.7.1
type RunResult struct {
ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
ArtifactHash string `protobuf:"bytes,2,opt,name=artifact_hash,json=artifactHash,proto3" json:"artifact_hash,omitempty"`
Artifacts []string `protobuf:"bytes,3,rep,name=artifacts,proto3" json:"artifacts,omitempty"`
// contains filtered or unexported fields
}
RunResult is the terminal outcome of a RunRequest.
func (*RunResult) Descriptor
deprecated
added in
v0.7.1
func (*RunResult) GetArtifactHash ¶ added in v0.7.1
func (*RunResult) GetArtifacts ¶ added in v0.7.1
func (*RunResult) GetExitCode ¶ added in v0.7.1
func (*RunResult) ProtoMessage ¶ added in v0.7.1
func (*RunResult) ProtoMessage()
func (*RunResult) ProtoReflect ¶ added in v0.7.1
func (x *RunResult) ProtoReflect() protoreflect.Message
type RuntimeProviderServiceClient ¶ added in v0.7.1
type RuntimeProviderServiceClient interface {
Describe(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*ProviderCapabilities, error)
Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[RunEvent], error)
StartSession(ctx context.Context, in *StartSessionRequest, opts ...grpc.CallOption) (*SessionHandle, error)
SessionEvents(ctx context.Context, in *SessionHandle, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SessionEvent], error)
ControlSession(ctx context.Context, in *ControlSessionRequest, opts ...grpc.CallOption) (*ControlSessionResponse, error)
}
RuntimeProviderServiceClient is the client API for RuntimeProviderService 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.
RuntimeProviderService is the gRPC interface that all compute runtime providers must implement.
func NewRuntimeProviderServiceClient ¶ added in v0.7.1
func NewRuntimeProviderServiceClient(cc grpc.ClientConnInterface) RuntimeProviderServiceClient
type RuntimeProviderServiceServer ¶ added in v0.7.1
type RuntimeProviderServiceServer interface {
Describe(context.Context, *DescribeRequest) (*ProviderCapabilities, error)
Run(*RunRequest, grpc.ServerStreamingServer[RunEvent]) error
StartSession(context.Context, *StartSessionRequest) (*SessionHandle, error)
SessionEvents(*SessionHandle, grpc.ServerStreamingServer[SessionEvent]) error
ControlSession(context.Context, *ControlSessionRequest) (*ControlSessionResponse, error)
// contains filtered or unexported methods
}
RuntimeProviderServiceServer is the server API for RuntimeProviderService service. All implementations must embed UnimplementedRuntimeProviderServiceServer for forward compatibility.
RuntimeProviderService is the gRPC interface that all compute runtime providers must implement.
type RuntimeProviderService_RunClient ¶ added in v0.7.1
type RuntimeProviderService_RunClient = grpc.ServerStreamingClient[RunEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RuntimeProviderService_RunServer ¶ added in v0.7.1
type RuntimeProviderService_RunServer = grpc.ServerStreamingServer[RunEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RuntimeProviderService_SessionEventsClient ¶ added in v0.7.1
type RuntimeProviderService_SessionEventsClient = grpc.ServerStreamingClient[SessionEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RuntimeProviderService_SessionEventsServer ¶ added in v0.7.1
type RuntimeProviderService_SessionEventsServer = grpc.ServerStreamingServer[SessionEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SessionEvent ¶ added in v0.7.1
type SessionEvent struct {
EventType string `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
Evidence []byte `protobuf:"bytes,2,opt,name=evidence,proto3" json:"evidence,omitempty"`
TsUnixNanos int64 `protobuf:"varint,3,opt,name=ts_unix_nanos,json=tsUnixNanos,proto3" json:"ts_unix_nanos,omitempty"`
// contains filtered or unexported fields
}
SessionEvent is an event emitted by a running session. evidence is unsigned — the host signs it later.
func (*SessionEvent) Descriptor
deprecated
added in
v0.7.1
func (*SessionEvent) Descriptor() ([]byte, []int)
Deprecated: Use SessionEvent.ProtoReflect.Descriptor instead.
func (*SessionEvent) GetEventType ¶ added in v0.7.1
func (x *SessionEvent) GetEventType() string
func (*SessionEvent) GetEvidence ¶ added in v0.7.1
func (x *SessionEvent) GetEvidence() []byte
func (*SessionEvent) GetTsUnixNanos ¶ added in v0.7.1
func (x *SessionEvent) GetTsUnixNanos() int64
func (*SessionEvent) ProtoMessage ¶ added in v0.7.1
func (*SessionEvent) ProtoMessage()
func (*SessionEvent) ProtoReflect ¶ added in v0.7.1
func (x *SessionEvent) ProtoReflect() protoreflect.Message
func (*SessionEvent) Reset ¶ added in v0.7.1
func (x *SessionEvent) Reset()
func (*SessionEvent) String ¶ added in v0.7.1
func (x *SessionEvent) String() string
type SessionHandle ¶ added in v0.7.1
type SessionHandle struct {
SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
// contains filtered or unexported fields
}
SessionHandle identifies a running session.
func (*SessionHandle) Descriptor
deprecated
added in
v0.7.1
func (*SessionHandle) Descriptor() ([]byte, []int)
Deprecated: Use SessionHandle.ProtoReflect.Descriptor instead.
func (*SessionHandle) GetSessionId ¶ added in v0.7.1
func (x *SessionHandle) GetSessionId() string
func (*SessionHandle) ProtoMessage ¶ added in v0.7.1
func (*SessionHandle) ProtoMessage()
func (*SessionHandle) ProtoReflect ¶ added in v0.7.1
func (x *SessionHandle) ProtoReflect() protoreflect.Message
func (*SessionHandle) Reset ¶ added in v0.7.1
func (x *SessionHandle) Reset()
func (*SessionHandle) String ¶ added in v0.7.1
func (x *SessionHandle) String() string
type StartSessionRequest ¶ added in v0.7.1
type StartSessionRequest struct {
ExecutorProvider string `protobuf:"bytes,1,opt,name=executor_provider,json=executorProvider,proto3" json:"executor_provider,omitempty"`
Input []byte `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
Env map[string]string `` /* 133-byte string literal not displayed */
TaskId string `protobuf:"bytes,4,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
LeaseId string `protobuf:"bytes,5,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
// contains filtered or unexported fields
}
StartSessionRequest initiates a long-lived session. env values may be unresolved secret:// refs — the provider resolves them.
func (*StartSessionRequest) Descriptor
deprecated
added in
v0.7.1
func (*StartSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartSessionRequest.ProtoReflect.Descriptor instead.
func (*StartSessionRequest) GetEnv ¶ added in v0.7.1
func (x *StartSessionRequest) GetEnv() map[string]string
func (*StartSessionRequest) GetExecutorProvider ¶ added in v0.7.1
func (x *StartSessionRequest) GetExecutorProvider() string
func (*StartSessionRequest) GetInput ¶ added in v0.7.1
func (x *StartSessionRequest) GetInput() []byte
func (*StartSessionRequest) GetLeaseId ¶ added in v0.7.1
func (x *StartSessionRequest) GetLeaseId() string
func (*StartSessionRequest) GetTaskId ¶ added in v0.7.1
func (x *StartSessionRequest) GetTaskId() string
func (*StartSessionRequest) ProtoMessage ¶ added in v0.7.1
func (*StartSessionRequest) ProtoMessage()
func (*StartSessionRequest) ProtoReflect ¶ added in v0.7.1
func (x *StartSessionRequest) ProtoReflect() protoreflect.Message
func (*StartSessionRequest) Reset ¶ added in v0.7.1
func (x *StartSessionRequest) Reset()
func (*StartSessionRequest) String ¶ added in v0.7.1
func (x *StartSessionRequest) String() string
type UnimplementedRuntimeProviderServiceServer ¶ added in v0.7.1
type UnimplementedRuntimeProviderServiceServer struct{}
UnimplementedRuntimeProviderServiceServer 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 (UnimplementedRuntimeProviderServiceServer) ControlSession ¶ added in v0.7.1
func (UnimplementedRuntimeProviderServiceServer) ControlSession(context.Context, *ControlSessionRequest) (*ControlSessionResponse, error)
func (UnimplementedRuntimeProviderServiceServer) Describe ¶ added in v0.7.1
func (UnimplementedRuntimeProviderServiceServer) Describe(context.Context, *DescribeRequest) (*ProviderCapabilities, error)
func (UnimplementedRuntimeProviderServiceServer) SessionEvents ¶ added in v0.7.1
func (UnimplementedRuntimeProviderServiceServer) SessionEvents(*SessionHandle, grpc.ServerStreamingServer[SessionEvent]) error
func (UnimplementedRuntimeProviderServiceServer) StartSession ¶ added in v0.7.1
func (UnimplementedRuntimeProviderServiceServer) StartSession(context.Context, *StartSessionRequest) (*SessionHandle, error)
type UnsafeRuntimeProviderServiceServer ¶ added in v0.7.1
type UnsafeRuntimeProviderServiceServer interface {
// contains filtered or unexported methods
}
UnsafeRuntimeProviderServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuntimeProviderServiceServer will result in compilation errors.