pb

package
v0.8.1 Latest Latest
Warning

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

Go to latest
Published: Jun 30, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
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

View Source
var File_workflow_plugin_compute_core_protocol_v1_network_audit_proto protoreflect.FileDescriptor
View Source
var File_workflow_plugin_compute_core_protocol_v1_runtime_provider_proto protoreflect.FileDescriptor
View Source
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 (*NetworkAuditProviderEvidence) Reset

func (x *NetworkAuditProviderEvidence) Reset()

func (*NetworkAuditProviderEvidence) 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 (*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 (*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 (*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) Descriptor() ([]byte, []int)

Deprecated: Use RunEvent.ProtoReflect.Descriptor instead.

func (*RunEvent) GetEvent added in v0.7.1

func (x *RunEvent) GetEvent() isRunEvent_Event

func (*RunEvent) GetStderr added in v0.7.1

func (x *RunEvent) GetStderr() []byte

func (*RunEvent) GetStdout added in v0.7.1

func (x *RunEvent) GetStdout() []byte

func (*RunEvent) GetTerminal added in v0.7.1

func (x *RunEvent) GetTerminal() *RunResult

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

func (*RunEvent) Reset added in v0.7.1

func (x *RunEvent) Reset()

func (*RunEvent) String added in v0.7.1

func (x *RunEvent) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RunResult.ProtoReflect.Descriptor instead.

func (*RunResult) GetArtifactHash added in v0.7.1

func (x *RunResult) GetArtifactHash() string

func (*RunResult) GetArtifacts added in v0.7.1

func (x *RunResult) GetArtifacts() []string

func (*RunResult) GetExitCode added in v0.7.1

func (x *RunResult) GetExitCode() int32

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

func (*RunResult) Reset added in v0.7.1

func (x *RunResult) Reset()

func (*RunResult) String added in v0.7.1

func (x *RunResult) String() string

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) Describe added in v0.7.1

func (UnimplementedRuntimeProviderServiceServer) Run added in v0.7.1

func (UnimplementedRuntimeProviderServiceServer) SessionEvents added in v0.7.1

func (UnimplementedRuntimeProviderServiceServer) StartSession added in v0.7.1

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.

Jump to

Keyboard shortcuts

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