proto

package
v0.2026187.2153 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Provider_Invoke_FullMethodName       = "/charlyplugin.Provider/Invoke"
	Provider_InvokeStream_FullMethodName = "/charlyplugin.Provider/InvokeStream"
)
View Source 
const (
	ExecutorService_Venue_FullMethodName          = "/charlyplugin.ExecutorService/Venue"
	ExecutorService_RunSystem_FullMethodName      = "/charlyplugin.ExecutorService/RunSystem"
	ExecutorService_RunUser_FullMethodName        = "/charlyplugin.ExecutorService/RunUser"
	ExecutorService_PutFile_FullMethodName        = "/charlyplugin.ExecutorService/PutFile"
	ExecutorService_RunCapture_FullMethodName     = "/charlyplugin.ExecutorService/RunCapture"
	ExecutorService_GetFile_FullMethodName        = "/charlyplugin.ExecutorService/GetFile"
	ExecutorService_RunHostStep_FullMethodName    = "/charlyplugin.ExecutorService/RunHostStep"
	ExecutorService_InvokeProvider_FullMethodName = "/charlyplugin.ExecutorService/InvokeProvider"
	ExecutorService_HostBuild_FullMethodName      = "/charlyplugin.ExecutorService/HostBuild"
	ExecutorService_HostArbiter_FullMethodName    = "/charlyplugin.ExecutorService/HostArbiter"
)
View Source 
const (
	CheckContextService_HTTPDo_FullMethodName                  = "/charlyplugin.CheckContextService/HTTPDo"
	CheckContextService_AddBackground_FullMethodName           = "/charlyplugin.CheckContextService/AddBackground"
	CheckContextService_ResolveEndpoint_FullMethodName         = "/charlyplugin.CheckContextService/ResolveEndpoint"
	CheckContextService_ResolveGraphicsEndpoint_FullMethodName = "/charlyplugin.CheckContextService/ResolveGraphicsEndpoint"
)
View Source 
const (
	PluginMeta_Describe_FullMethodName = "/charlyplugin.PluginMeta/Describe"
)

Variables

View Source 
var CheckContextService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "charlyplugin.CheckContextService",
	HandlerType: (*CheckContextServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HTTPDo",
			Handler:    _CheckContextService_HTTPDo_Handler,
		},
		{
			MethodName: "AddBackground",
			Handler:    _CheckContextService_AddBackground_Handler,
		},
		{
			MethodName: "ResolveEndpoint",
			Handler:    _CheckContextService_ResolveEndpoint_Handler,
		},
		{
			MethodName: "ResolveGraphicsEndpoint",
			Handler:    _CheckContextService_ResolveGraphicsEndpoint_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugin.proto",
}

CheckContextService_ServiceDesc is the grpc.ServiceDesc for CheckContextService 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 ExecutorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "charlyplugin.ExecutorService",
	HandlerType: (*ExecutorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Venue",
			Handler:    _ExecutorService_Venue_Handler,
		},
		{
			MethodName: "RunSystem",
			Handler:    _ExecutorService_RunSystem_Handler,
		},
		{
			MethodName: "RunUser",
			Handler:    _ExecutorService_RunUser_Handler,
		},
		{
			MethodName: "PutFile",
			Handler:    _ExecutorService_PutFile_Handler,
		},
		{
			MethodName: "RunCapture",
			Handler:    _ExecutorService_RunCapture_Handler,
		},
		{
			MethodName: "GetFile",
			Handler:    _ExecutorService_GetFile_Handler,
		},
		{
			MethodName: "RunHostStep",
			Handler:    _ExecutorService_RunHostStep_Handler,
		},
		{
			MethodName: "InvokeProvider",
			Handler:    _ExecutorService_InvokeProvider_Handler,
		},
		{
			MethodName: "HostBuild",
			Handler:    _ExecutorService_HostBuild_Handler,
		},
		{
			MethodName: "HostArbiter",
			Handler:    _ExecutorService_HostArbiter_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugin.proto",
}

ExecutorService_ServiceDesc is the grpc.ServiceDesc for ExecutorService 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_plugin_proto protoreflect.FileDescriptor
View Source 
var PluginMeta_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "charlyplugin.PluginMeta",
	HandlerType: (*PluginMetaServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Describe",
			Handler:    _PluginMeta_Describe_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugin.proto",
}

PluginMeta_ServiceDesc is the grpc.ServiceDesc for PluginMeta 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 Provider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "charlyplugin.Provider",
	HandlerType: (*ProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Invoke",
			Handler:    _Provider_Invoke_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "InvokeStream",
			Handler:       _Provider_InvokeStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "plugin.proto",
}

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

Functions

func RegisterCheckContextServiceServer 

func RegisterCheckContextServiceServer(s grpc.ServiceRegistrar, srv CheckContextServiceServer)

func RegisterExecutorServiceServer 

func RegisterExecutorServiceServer(s grpc.ServiceRegistrar, srv ExecutorServiceServer)

func RegisterPluginMetaServer 

func RegisterPluginMetaServer(s grpc.ServiceRegistrar, srv PluginMetaServer)

func RegisterProviderServer 

func RegisterProviderServer(s grpc.ServiceRegistrar, srv ProviderServer)

Types

type AddBackgroundRequest 

type AddBackgroundRequest struct {
	Pid int32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*AddBackgroundRequest) Descriptor deprecated 

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

Deprecated: Use AddBackgroundRequest.ProtoReflect.Descriptor instead.

func (*AddBackgroundRequest) GetPid 

func (x *AddBackgroundRequest) GetPid() int32

func (*AddBackgroundRequest) ProtoMessage 

func (*AddBackgroundRequest) ProtoMessage()

func (*AddBackgroundRequest) ProtoReflect 

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

func (*AddBackgroundRequest) Reset 

func (x *AddBackgroundRequest) Reset()

func (*AddBackgroundRequest) String 

func (x *AddBackgroundRequest) String() string

type Capabilities 

type Capabilities struct {
	Calver          string                `protobuf:"bytes,1,opt,name=calver,proto3" json:"calver,omitempty"`                                           // the plugin's CalVer (CalVer is the version authority)
	ProtocolVersion uint32                `protobuf:"varint,2,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"` // thin secondary gate; never duplicates CalVer
	Provided        []*ProvidedCapability `protobuf:"bytes,3,rep,name=provided,proto3" json:"provided,omitempty"`                                       // the unit's capabilities + the def validating each input
	SchemaCue       string                `protobuf:"bytes,4,opt,name=schema_cue,json=schemaCue,proto3" json:"schema_cue,omitempty"`                    // the unit's package-less, SELF-CONTAINED .cue source text
	// contains filtered or unexported fields
}

func (*Capabilities) Descriptor deprecated 

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

Deprecated: Use Capabilities.ProtoReflect.Descriptor instead.

func (*Capabilities) GetCalver 

func (x *Capabilities) GetCalver() string

func (*Capabilities) GetProtocolVersion 

func (x *Capabilities) GetProtocolVersion() uint32

func (*Capabilities) GetProvided 

func (x *Capabilities) GetProvided() []*ProvidedCapability

func (*Capabilities) GetSchemaCue 

func (x *Capabilities) GetSchemaCue() string

func (*Capabilities) ProtoMessage 

func (*Capabilities) ProtoMessage()

func (*Capabilities) ProtoReflect 

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

func (*Capabilities) Reset 

func (x *Capabilities) Reset()

func (*Capabilities) String 

func (x *Capabilities) String() string

type CaptureReply 

type CaptureReply struct {
	Stdout   string `protobuf:"bytes,1,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr   string `protobuf:"bytes,2,opt,name=stderr,proto3" json:"stderr,omitempty"`
	ExitCode int32  `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Error    string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CaptureReply) Descriptor deprecated 

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

Deprecated: Use CaptureReply.ProtoReflect.Descriptor instead.

func (*CaptureReply) GetError 

func (x *CaptureReply) GetError() string

func (*CaptureReply) GetExitCode 

func (x *CaptureReply) GetExitCode() int32

func (*CaptureReply) GetStderr 

func (x *CaptureReply) GetStderr() string

func (*CaptureReply) GetStdout 

func (x *CaptureReply) GetStdout() string

func (*CaptureReply) ProtoMessage 

func (*CaptureReply) ProtoMessage()

func (*CaptureReply) ProtoReflect 

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

func (*CaptureReply) Reset 

func (x *CaptureReply) Reset()

func (*CaptureReply) String 

func (x *CaptureReply) String() string

type CheckContextServiceClient 

type CheckContextServiceClient interface {
	HTTPDo(ctx context.Context, in *HTTPDoRequest, opts ...grpc.CallOption) (*HTTPDoReply, error)
	AddBackground(ctx context.Context, in *AddBackgroundRequest, opts ...grpc.CallOption) (*Empty, error)
	// ResolveEndpoint: resolve the check target's venue (container / VM / ssh / local) and
	// return a host-reachable address for an in-venue TCP port — opening (and host-side
	// tracking, for post-Invoke teardown) any ssh -L forward a VM/ssh venue needs. Class-
	// generic: ANY endpoint check verb (cdp/vnc/spice/…) declares its port and dials the addr.
	ResolveEndpoint(ctx context.Context, in *ResolveEndpointRequest, opts ...grpc.CallOption) (*ResolveEndpointReply, error)
	// ResolveGraphicsEndpoint: resolve a VM's <graphics type='<kind>'> listener (kind = "vnc"
	// | "spice") to a dialable endpoint — the host owns the go-libvirt resolution, any
	// qemu+ssh:// tunnel (tracked for post-Invoke teardown), the socket->TCP bridge a TCP-only
	// client needs, and the credential-store password. Class-generic: parameterized by kind,
	// shared by the vnc + spice verbs (never a per-verb RPC).
	ResolveGraphicsEndpoint(ctx context.Context, in *ResolveGraphicsEndpointRequest, opts ...grpc.CallOption) (*ResolveGraphicsEndpointReply, error)
}

CheckContextServiceClient is the client API for CheckContextService 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.

func NewCheckContextServiceClient 

func NewCheckContextServiceClient(cc grpc.ClientConnInterface) CheckContextServiceClient

type CheckContextServiceServer 

type CheckContextServiceServer interface {
	HTTPDo(context.Context, *HTTPDoRequest) (*HTTPDoReply, error)
	AddBackground(context.Context, *AddBackgroundRequest) (*Empty, error)
	// ResolveEndpoint: resolve the check target's venue (container / VM / ssh / local) and
	// return a host-reachable address for an in-venue TCP port — opening (and host-side
	// tracking, for post-Invoke teardown) any ssh -L forward a VM/ssh venue needs. Class-
	// generic: ANY endpoint check verb (cdp/vnc/spice/…) declares its port and dials the addr.
	ResolveEndpoint(context.Context, *ResolveEndpointRequest) (*ResolveEndpointReply, error)
	// ResolveGraphicsEndpoint: resolve a VM's <graphics type='<kind>'> listener (kind = "vnc"
	// | "spice") to a dialable endpoint — the host owns the go-libvirt resolution, any
	// qemu+ssh:// tunnel (tracked for post-Invoke teardown), the socket->TCP bridge a TCP-only
	// client needs, and the credential-store password. Class-generic: parameterized by kind,
	// shared by the vnc + spice verbs (never a per-verb RPC).
	ResolveGraphicsEndpoint(context.Context, *ResolveGraphicsEndpointRequest) (*ResolveGraphicsEndpointReply, error)
	// contains filtered or unexported methods
}

CheckContextServiceServer is the server API for CheckContextService service. All implementations must embed UnimplementedCheckContextServiceServer for forward compatibility

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type ExecutorServiceClient 

type ExecutorServiceClient interface {
	Venue(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*VenueReply, error)
	RunSystem(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunReply, error)
	RunUser(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunReply, error)
	PutFile(ctx context.Context, in *PutFileRequest, opts ...grpc.CallOption) (*PutFileReply, error)
	RunCapture(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*CaptureReply, error)
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileReply, error)
	RunHostStep(ctx context.Context, in *HostStepRequest, opts ...grpc.CallOption) (*HostStepReply, error)
	InvokeProvider(ctx context.Context, in *InvokeProviderRequest, opts ...grpc.CallOption) (*InvokeReply, error)
	HostBuild(ctx context.Context, in *HostBuildRequest, opts ...grpc.CallOption) (*HostBuildReply, error)
	HostArbiter(ctx context.Context, in *HostArbiterRequest, opts ...grpc.CallOption) (*HostArbiterReply, error)
}

ExecutorServiceClient is the client API for ExecutorService 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.

func NewExecutorServiceClient 

func NewExecutorServiceClient(cc grpc.ClientConnInterface) ExecutorServiceClient

type ExecutorServiceServer 

type ExecutorServiceServer interface {
	Venue(context.Context, *Empty) (*VenueReply, error)
	RunSystem(context.Context, *RunRequest) (*RunReply, error)
	RunUser(context.Context, *RunRequest) (*RunReply, error)
	PutFile(context.Context, *PutFileRequest) (*PutFileReply, error)
	RunCapture(context.Context, *RunRequest) (*CaptureReply, error)
	GetFile(context.Context, *GetFileRequest) (*GetFileReply, error)
	RunHostStep(context.Context, *HostStepRequest) (*HostStepReply, error)
	InvokeProvider(context.Context, *InvokeProviderRequest) (*InvokeReply, error)
	HostBuild(context.Context, *HostBuildRequest) (*HostBuildReply, error)
	HostArbiter(context.Context, *HostArbiterRequest) (*HostArbiterReply, error)
	// contains filtered or unexported methods
}

ExecutorServiceServer is the server API for ExecutorService service. All implementations must embed UnimplementedExecutorServiceServer for forward compatibility

type Frame 

type Frame struct {
	ResultJson []byte `protobuf:"bytes,1,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	// contains filtered or unexported fields
}

func (*Frame) Descriptor deprecated 

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

Deprecated: Use Frame.ProtoReflect.Descriptor instead.

func (*Frame) GetResultJson 

func (x *Frame) GetResultJson() []byte

func (*Frame) ProtoMessage 

func (*Frame) ProtoMessage()

func (*Frame) ProtoReflect 

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

func (*Frame) Reset 

func (x *Frame) Reset()

func (*Frame) String 

func (x *Frame) String() string

type GetFileReply 

type GetFileReply struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileReply) Descriptor deprecated 

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

Deprecated: Use GetFileReply.ProtoReflect.Descriptor instead.

func (*GetFileReply) GetContent 

func (x *GetFileReply) GetContent() []byte

func (*GetFileReply) GetError 

func (x *GetFileReply) GetError() string

func (*GetFileReply) ProtoMessage 

func (*GetFileReply) ProtoMessage()

func (*GetFileReply) ProtoReflect 

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

func (*GetFileReply) Reset 

func (x *GetFileReply) Reset()

func (*GetFileReply) String 

func (x *GetFileReply) String() string

type GetFileRequest 

type GetFileRequest struct {
	Path     string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	AsRoot   bool   `protobuf:"varint,2,opt,name=as_root,json=asRoot,proto3" json:"as_root,omitempty"`
	OptsJson []byte `protobuf:"bytes,3,opt,name=opts_json,json=optsJson,proto3" json:"opts_json,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFileRequest) Descriptor deprecated 

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

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetAsRoot 

func (x *GetFileRequest) GetAsRoot() bool

func (*GetFileRequest) GetOptsJson 

func (x *GetFileRequest) GetOptsJson() []byte

func (*GetFileRequest) GetPath 

func (x *GetFileRequest) GetPath() string

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect 

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

func (*GetFileRequest) Reset 

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String 

func (x *GetFileRequest) String() string

type HTTPDoReply 

type HTTPDoReply struct {
	Status     int32  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Body       []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	HeaderBlob string `protobuf:"bytes,3,opt,name=header_blob,json=headerBlob,proto3" json:"header_blob,omitempty"` // pre-formatted "Key: value\n" blob (multi-value preserved), matcher-ready
	Error      string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

HTTPDoReply: status + body + response headers, or a transport-level error (the RPC itself succeeds — a failed request rides the error field, like RunReply/CaptureReply).

func (*HTTPDoReply) Descriptor deprecated 

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

Deprecated: Use HTTPDoReply.ProtoReflect.Descriptor instead.

func (*HTTPDoReply) GetBody 

func (x *HTTPDoReply) GetBody() []byte

func (*HTTPDoReply) GetError 

func (x *HTTPDoReply) GetError() string

func (*HTTPDoReply) GetHeaderBlob 

func (x *HTTPDoReply) GetHeaderBlob() string

func (*HTTPDoReply) GetStatus 

func (x *HTTPDoReply) GetStatus() int32

func (*HTTPDoReply) ProtoMessage 

func (*HTTPDoReply) ProtoMessage()

func (*HTTPDoReply) ProtoReflect 

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

func (*HTTPDoReply) Reset 

func (x *HTTPDoReply) Reset()

func (*HTTPDoReply) String 

func (x *HTTPDoReply) String() string

type HTTPDoRequest 

type HTTPDoRequest struct {
	Method            string            `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url               string            `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Body              []byte            `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Headers           map[string]string `` /* 141-byte string literal not displayed */
	Timeout           string            `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	AllowInsecure     bool              `protobuf:"varint,6,opt,name=allow_insecure,json=allowInsecure,proto3" json:"allow_insecure,omitempty"`
	NoFollowRedirects bool              `protobuf:"varint,7,opt,name=no_follow_redirects,json=noFollowRedirects,proto3" json:"no_follow_redirects,omitempty"`
	CaPem             []byte            `protobuf:"bytes,8,opt,name=ca_pem,json=caPem,proto3" json:"ca_pem,omitempty"`
	// contains filtered or unexported fields
}

HTTPDoRequest carries the FULL request + per-request policy the host needs to build the client (httpClientFor) host-side: ca_pem is the resolved CA PEM bytes (the candy reads its authored ca_file host-side and ships the bytes), timeout is a Go duration string ("" = base).

func (*HTTPDoRequest) Descriptor deprecated 

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

Deprecated: Use HTTPDoRequest.ProtoReflect.Descriptor instead.

func (*HTTPDoRequest) GetAllowInsecure 

func (x *HTTPDoRequest) GetAllowInsecure() bool

func (*HTTPDoRequest) GetBody 

func (x *HTTPDoRequest) GetBody() []byte

func (*HTTPDoRequest) GetCaPem 

func (x *HTTPDoRequest) GetCaPem() []byte

func (*HTTPDoRequest) GetHeaders 

func (x *HTTPDoRequest) GetHeaders() map[string]string

func (*HTTPDoRequest) GetMethod 

func (x *HTTPDoRequest) GetMethod() string

func (*HTTPDoRequest) GetNoFollowRedirects 

func (x *HTTPDoRequest) GetNoFollowRedirects() bool

func (*HTTPDoRequest) GetTimeout 

func (x *HTTPDoRequest) GetTimeout() string

func (*HTTPDoRequest) GetUrl 

func (x *HTTPDoRequest) GetUrl() string

func (*HTTPDoRequest) ProtoMessage 

func (*HTTPDoRequest) ProtoMessage()

func (*HTTPDoRequest) ProtoReflect 

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

func (*HTTPDoRequest) Reset 

func (x *HTTPDoRequest) Reset()

func (*HTTPDoRequest) String 

func (x *HTTPDoRequest) String() string

type HostArbiterReply 

type HostArbiterReply struct {
	ResultJson []byte `protobuf:"bytes,1,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	Error      string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*HostArbiterReply) Descriptor deprecated 

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

Deprecated: Use HostArbiterReply.ProtoReflect.Descriptor instead.

func (*HostArbiterReply) GetError 

func (x *HostArbiterReply) GetError() string

func (*HostArbiterReply) GetResultJson 

func (x *HostArbiterReply) GetResultJson() []byte

func (*HostArbiterReply) ProtoMessage 

func (*HostArbiterReply) ProtoMessage()

func (*HostArbiterReply) ProtoReflect 

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

func (*HostArbiterReply) Reset 

func (x *HostArbiterReply) Reset()

func (*HostArbiterReply) String 

func (x *HostArbiterReply) String() string

type HostArbiterRequest 

type HostArbiterRequest struct {
	Action     string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`
	ParamsJson []byte `protobuf:"bytes,2,opt,name=params_json,json=paramsJson,proto3" json:"params_json,omitempty"`
	// contains filtered or unexported fields
}

C9 resource-arbiter reverse channel (ExecutorService.HostArbiter). action names one of the 7 arbiter host-seams (spec.ArbiterSeam*); params_json is the seam's spec request; result_json is the seam's spec reply. error = an infra failure of the RPC handler itself (a seam OP failure rides the reply's own error field, like RunReply/HostBuildReply).

func (*HostArbiterRequest) Descriptor deprecated 

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

Deprecated: Use HostArbiterRequest.ProtoReflect.Descriptor instead.

func (*HostArbiterRequest) GetAction 

func (x *HostArbiterRequest) GetAction() string

func (*HostArbiterRequest) GetParamsJson 

func (x *HostArbiterRequest) GetParamsJson() []byte

func (*HostArbiterRequest) ProtoMessage 

func (*HostArbiterRequest) ProtoMessage()

func (*HostArbiterRequest) ProtoReflect 

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

func (*HostArbiterRequest) Reset 

func (x *HostArbiterRequest) Reset()

func (*HostArbiterRequest) String 

func (x *HostArbiterRequest) String() string

type HostBuildReply 

type HostBuildReply struct {
	ResultJson []byte `protobuf:"bytes,1,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	Error      string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*HostBuildReply) Descriptor deprecated 

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

Deprecated: Use HostBuildReply.ProtoReflect.Descriptor instead.

func (*HostBuildReply) GetError 

func (x *HostBuildReply) GetError() string

func (*HostBuildReply) GetResultJson 

func (x *HostBuildReply) GetResultJson() []byte

func (*HostBuildReply) ProtoMessage 

func (*HostBuildReply) ProtoMessage()

func (*HostBuildReply) ProtoReflect 

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

func (*HostBuildReply) Reset 

func (x *HostBuildReply) Reset()

func (*HostBuildReply) String 

func (x *HostBuildReply) String() string

type HostBuildRequest 

type HostBuildRequest struct {
	Kind     string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	SpecJson []byte `protobuf:"bytes,2,opt,name=spec_json,json=specJson,proto3" json:"spec_json,omitempty"`
	// contains filtered or unexported fields
}

HostBuildRequest names a registered host-builder `kind` (e.g. "plugin-binary", and — added by M13/M14 — "kustomize"/"image") + an opaque `spec_json` it interprets (F10). HostBuildReply carries the builder's opaque result (e.g. an artifact path/handle JSON) or an error.

func (*HostBuildRequest) Descriptor deprecated 

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

Deprecated: Use HostBuildRequest.ProtoReflect.Descriptor instead.

func (*HostBuildRequest) GetKind 

func (x *HostBuildRequest) GetKind() string

func (*HostBuildRequest) GetSpecJson 

func (x *HostBuildRequest) GetSpecJson() []byte

func (*HostBuildRequest) ProtoMessage 

func (*HostBuildRequest) ProtoMessage()

func (*HostBuildRequest) ProtoReflect 

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

func (*HostBuildRequest) Reset 

func (x *HostBuildRequest) Reset()

func (*HostBuildRequest) String 

func (x *HostBuildRequest) String() string

type HostStepReply 

type HostStepReply struct {
	ReverseOpsJson []byte `protobuf:"bytes,1,opt,name=reverse_ops_json,json=reverseOpsJson,proto3" json:"reverse_ops_json,omitempty"`
	Error          string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*HostStepReply) Descriptor deprecated 

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

Deprecated: Use HostStepReply.ProtoReflect.Descriptor instead.

func (*HostStepReply) GetError 

func (x *HostStepReply) GetError() string

func (*HostStepReply) GetReverseOpsJson 

func (x *HostStepReply) GetReverseOpsJson() []byte

func (*HostStepReply) ProtoMessage 

func (*HostStepReply) ProtoMessage()

func (*HostStepReply) ProtoReflect 

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

func (*HostStepReply) Reset 

func (x *HostStepReply) Reset()

func (*HostStepReply) String 

func (x *HostStepReply) String() string

type HostStepRequest 

type HostStepRequest struct {
	StepJson []byte `protobuf:"bytes,1,opt,name=step_json,json=stepJson,proto3" json:"step_json,omitempty"`
	OptsJson []byte `protobuf:"bytes,2,opt,name=opts_json,json=optsJson,proto3" json:"opts_json,omitempty"`
	// contains filtered or unexported fields
}

step_json = ONE spec.InstallStepView (a HOST-ENGINE step kind — Builder, LocalPkgInstall, SystemPackages, an act-verb Op, or ExternalPlugin — projected by stepToView); opts_json = EmitOpts. reverse_ops_json = the step's recorded []spec.ReverseOp (the plugin folds them into its DeployReply for record-and-replay teardown). error = a host-engine/apply FAILURE on the venue (the RPC itself succeeds — the failure rides the reply field, like RunReply/CaptureReply).

func (*HostStepRequest) Descriptor deprecated 

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

Deprecated: Use HostStepRequest.ProtoReflect.Descriptor instead.

func (*HostStepRequest) GetOptsJson 

func (x *HostStepRequest) GetOptsJson() []byte

func (*HostStepRequest) GetStepJson 

func (x *HostStepRequest) GetStepJson() []byte

func (*HostStepRequest) ProtoMessage 

func (*HostStepRequest) ProtoMessage()

func (*HostStepRequest) ProtoReflect 

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

func (*HostStepRequest) Reset 

func (x *HostStepRequest) Reset()

func (*HostStepRequest) String 

func (x *HostStepRequest) String() string

type InvokeProviderRequest 

type InvokeProviderRequest struct {
	Class      string `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`
	Reserved   string `protobuf:"bytes,2,opt,name=reserved,proto3" json:"reserved,omitempty"`
	Op         string `protobuf:"bytes,3,opt,name=op,proto3" json:"op,omitempty"`
	ParamsJson []byte `protobuf:"bytes,4,opt,name=params_json,json=paramsJson,proto3" json:"params_json,omitempty"`
	EnvJson    []byte `protobuf:"bytes,5,opt,name=env_json,json=envJson,proto3" json:"env_json,omitempty"`
	// contains filtered or unexported fields
}

InvokeProviderRequest mirrors InvokeRequest minus the broker id (the host already holds the reverse context): dispatch op `op` on provider (class, reserved) with params/env (F10).

func (*InvokeProviderRequest) Descriptor deprecated 

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

Deprecated: Use InvokeProviderRequest.ProtoReflect.Descriptor instead.

func (*InvokeProviderRequest) GetClass 

func (x *InvokeProviderRequest) GetClass() string

func (*InvokeProviderRequest) GetEnvJson 

func (x *InvokeProviderRequest) GetEnvJson() []byte

func (*InvokeProviderRequest) GetOp 

func (x *InvokeProviderRequest) GetOp() string

func (*InvokeProviderRequest) GetParamsJson 

func (x *InvokeProviderRequest) GetParamsJson() []byte

func (*InvokeProviderRequest) GetReserved 

func (x *InvokeProviderRequest) GetReserved() string

func (*InvokeProviderRequest) ProtoMessage 

func (*InvokeProviderRequest) ProtoMessage()

func (*InvokeProviderRequest) ProtoReflect 

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

func (*InvokeProviderRequest) Reset 

func (x *InvokeProviderRequest) Reset()

func (*InvokeProviderRequest) String 

func (x *InvokeProviderRequest) String() string

type InvokeReply 

type InvokeReply struct {
	ResultJson []byte `protobuf:"bytes,1,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeReply) Descriptor deprecated 

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

Deprecated: Use InvokeReply.ProtoReflect.Descriptor instead.

func (*InvokeReply) GetResultJson 

func (x *InvokeReply) GetResultJson() []byte

func (*InvokeReply) ProtoMessage 

func (*InvokeReply) ProtoMessage()

func (*InvokeReply) ProtoReflect 

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

func (*InvokeReply) Reset 

func (x *InvokeReply) Reset()

func (*InvokeReply) String 

func (x *InvokeReply) String() string

type InvokeRequest 

type InvokeRequest struct {
	Reserved         string `protobuf:"bytes,1,opt,name=reserved,proto3" json:"reserved,omitempty"`                                            // the reserved word, e.g. "exampleprobe","cdp","local"
	Op               string `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`                                                        // operation selector for the word's class
	ParamsJson       []byte `protobuf:"bytes,3,opt,name=params_json,json=paramsJson,proto3" json:"params_json,omitempty"`                      // the CUE-generated params (Op for verbs/steps; entity for kinds)
	EnvJson          []byte `protobuf:"bytes,4,opt,name=env_json,json=envJson,proto3" json:"env_json,omitempty"`                               // snapshotCheckEnv / venue descriptor (serializable invocation ctx)
	Class            string `protobuf:"bytes,5,opt,name=class,proto3" json:"class,omitempty"`                                                  // the ProviderClass ("verb"/"kind"/...) — words aren't unique across classes
	ExecutorBrokerId uint32 `protobuf:"varint,6,opt,name=executor_broker_id,json=executorBrokerId,proto3" json:"executor_broker_id,omitempty"` // E3b: the go-plugin broker id the host serves ExecutorService on for a deploy/step/builder op; 0 = none (verb/kind ops need no executor)
	// contains filtered or unexported fields
}

func (*InvokeRequest) Descriptor deprecated 

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

Deprecated: Use InvokeRequest.ProtoReflect.Descriptor instead.

func (*InvokeRequest) GetClass 

func (x *InvokeRequest) GetClass() string

func (*InvokeRequest) GetEnvJson 

func (x *InvokeRequest) GetEnvJson() []byte

func (*InvokeRequest) GetExecutorBrokerId 

func (x *InvokeRequest) GetExecutorBrokerId() uint32

func (*InvokeRequest) GetOp 

func (x *InvokeRequest) GetOp() string

func (*InvokeRequest) GetParamsJson 

func (x *InvokeRequest) GetParamsJson() []byte

func (*InvokeRequest) GetReserved 

func (x *InvokeRequest) GetReserved() string

func (*InvokeRequest) ProtoMessage 

func (*InvokeRequest) ProtoMessage()

func (*InvokeRequest) ProtoReflect 

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

func (*InvokeRequest) Reset 

func (x *InvokeRequest) Reset()

func (*InvokeRequest) String 

func (x *InvokeRequest) String() string

type PluginMetaClient 

type PluginMetaClient interface {
	Describe(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Capabilities, error)
}

PluginMetaClient is the client API for PluginMeta 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.

func NewPluginMetaClient 

func NewPluginMetaClient(cc grpc.ClientConnInterface) PluginMetaClient

type PluginMetaServer 

type PluginMetaServer interface {
	Describe(context.Context, *Empty) (*Capabilities, error)
	// contains filtered or unexported methods
}

PluginMetaServer is the server API for PluginMeta service. All implementations must embed UnimplementedPluginMetaServer for forward compatibility

type ProvidedCapability 

type ProvidedCapability struct {
	Class        string        `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"`                                   // "verb" / "kind" / "deploy" / "step" / "builder"
	Word         string        `protobuf:"bytes,2,opt,name=word,proto3" json:"word,omitempty"`                                     // the reserved word, e.g. "externalprobe"
	InputDef     string        `protobuf:"bytes,3,opt,name=input_def,json=inputDef,proto3" json:"input_def,omitempty"`             // the CUE def for this word's plugin_input, e.g. "#ExternalprobeInput"
	StepContract *StepContract `protobuf:"bytes,4,opt,name=step_contract,json=stepContract,proto3" json:"step_contract,omitempty"` // set ONLY for class="step" (F3): the plugin-declared install-step contract
	Structural   bool          `protobuf:"varint,5,opt,name=structural,proto3" json:"structural,omitempty"`                        // set ONLY for class="kind" (F5): the kind decodes a STRUCTURAL entity (a spec.Deploy member tree -> uf.Bundle) rather than a FLAT body (-> uf.PluginKinds)
	Lifecycle    bool          `protobuf:"varint,6,opt,name=lifecycle,proto3" json:"lifecycle,omitempty"`                          // set ONLY for class="deploy" (F6): the substrate brings its OWN host-side venue lifecycle (PrepareVenue/Start/Stop/...) served over the lifecycle Ops; the host registers a wire-backed substrateLifecycle for it
	Preresolve   bool          `protobuf:"varint,7,opt,name=preresolve,proto3" json:"preresolve,omitempty"`                        // set ONLY for class="deploy" (F6): the substrate declares a host-side PRERESOLVE step (OpPreresolve) the host runs before apply, shipping the opaque result in DeployVenue.Substrate
	Validates    bool          `protobuf:"varint,8,opt,name=validates,proto3" json:"validates,omitempty"`                          // set ONLY for class="kind" (F7/C8): the kind serves a deep OpValidate check (returns Diagnostics) BEYOND the static CUE input-def gate; the host dispatches OpValidate at load
	Phase        string        `protobuf:"bytes,9,opt,name=phase,proto3" json:"phase,omitempty"`                                   // F9: the plugin lifecycle PHASE (sdk.Phase*; "" => runtime default) — the ordered point at which the kernel loads/invokes the plugin; "bootstrap" runs BEFORE config validation/migration
	Primary      string        `protobuf:"bytes,10,opt,name=primary,proto3" json:"primary,omitempty"`                              // set ONLY for class="verb": the input field the scalar sugar shorthand targets (`file: /x` -> plugin_input: {<primary>: "/x"}); "" => map input only
	// contains filtered or unexported fields
}

ProvidedCapability — one served capability plus the CUE def that validates its plugin_input. The schema travels with the plugin over Describe (the same channel for in-proc builtin and out-of-proc external — zero distinction), so the host validates authored plugin_input against `base ++ served` without ever reading a candy's schema/ dir. `input_def` is explicit (no Title-case naming convention).

func (*ProvidedCapability) Descriptor deprecated 

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

Deprecated: Use ProvidedCapability.ProtoReflect.Descriptor instead.

func (*ProvidedCapability) GetClass 

func (x *ProvidedCapability) GetClass() string

func (*ProvidedCapability) GetInputDef 

func (x *ProvidedCapability) GetInputDef() string

func (*ProvidedCapability) GetLifecycle 

func (x *ProvidedCapability) GetLifecycle() bool

func (*ProvidedCapability) GetPhase 

func (x *ProvidedCapability) GetPhase() string

func (*ProvidedCapability) GetPreresolve 

func (x *ProvidedCapability) GetPreresolve() bool

func (*ProvidedCapability) GetPrimary added in v0.2026187.747 

func (x *ProvidedCapability) GetPrimary() string

func (*ProvidedCapability) GetStepContract 

func (x *ProvidedCapability) GetStepContract() *StepContract

func (*ProvidedCapability) GetStructural 

func (x *ProvidedCapability) GetStructural() bool

func (*ProvidedCapability) GetValidates 

func (x *ProvidedCapability) GetValidates() bool

func (*ProvidedCapability) GetWord 

func (x *ProvidedCapability) GetWord() string

func (*ProvidedCapability) ProtoMessage 

func (*ProvidedCapability) ProtoMessage()

func (*ProvidedCapability) ProtoReflect 

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

func (*ProvidedCapability) Reset 

func (x *ProvidedCapability) Reset()

func (*ProvidedCapability) String 

func (x *ProvidedCapability) String() string

type ProviderClient 

type ProviderClient interface {
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeReply, error)
	InvokeStream(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (Provider_InvokeStreamClient, error)
}

ProviderClient is the client API for Provider 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.

func NewProviderClient 

func NewProviderClient(cc grpc.ClientConnInterface) ProviderClient

type ProviderServer 

type ProviderServer interface {
	Invoke(context.Context, *InvokeRequest) (*InvokeReply, error)
	InvokeStream(*InvokeRequest, Provider_InvokeStreamServer) error
	// contains filtered or unexported methods
}

ProviderServer is the server API for Provider service. All implementations must embed UnimplementedProviderServer for forward compatibility

type Provider_InvokeStreamClient 

type Provider_InvokeStreamClient interface {
	Recv() (*Frame, error)
	grpc.ClientStream
}

type Provider_InvokeStreamServer 

type Provider_InvokeStreamServer interface {
	Send(*Frame) error
	grpc.ServerStream
}

type PutFileReply 

type PutFileReply struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileReply) Descriptor deprecated 

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

Deprecated: Use PutFileReply.ProtoReflect.Descriptor instead.

func (*PutFileReply) GetError 

func (x *PutFileReply) GetError() string

func (*PutFileReply) ProtoMessage 

func (*PutFileReply) ProtoMessage()

func (*PutFileReply) ProtoReflect 

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

func (*PutFileReply) Reset 

func (x *PutFileReply) Reset()

func (*PutFileReply) String 

func (x *PutFileReply) String() string

type PutFileRequest 

type PutFileRequest struct {
	Path      string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Content   []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	Mode      uint32 `protobuf:"varint,3,opt,name=mode,proto3" json:"mode,omitempty"`
	OwnerRoot bool   `protobuf:"varint,4,opt,name=owner_root,json=ownerRoot,proto3" json:"owner_root,omitempty"`
	OptsJson  []byte `protobuf:"bytes,5,opt,name=opts_json,json=optsJson,proto3" json:"opts_json,omitempty"`
	// contains filtered or unexported fields
}

func (*PutFileRequest) Descriptor deprecated 

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

Deprecated: Use PutFileRequest.ProtoReflect.Descriptor instead.

func (*PutFileRequest) GetContent 

func (x *PutFileRequest) GetContent() []byte

func (*PutFileRequest) GetMode 

func (x *PutFileRequest) GetMode() uint32

func (*PutFileRequest) GetOptsJson 

func (x *PutFileRequest) GetOptsJson() []byte

func (*PutFileRequest) GetOwnerRoot 

func (x *PutFileRequest) GetOwnerRoot() bool

func (*PutFileRequest) GetPath 

func (x *PutFileRequest) GetPath() string

func (*PutFileRequest) ProtoMessage 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) ProtoReflect 

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

func (*PutFileRequest) Reset 

func (x *PutFileRequest) Reset()

func (*PutFileRequest) String 

func (x *PutFileRequest) String() string

type ResolveEndpointReply added in v0.2026187.2110 

type ResolveEndpointReply struct {
	Addr  string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ResolveEndpointReply: the host-reachable "host:port" addr, or a resolution error.

func (*ResolveEndpointReply) Descriptor deprecated added in v0.2026187.2110 

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

Deprecated: Use ResolveEndpointReply.ProtoReflect.Descriptor instead.

func (*ResolveEndpointReply) GetAddr added in v0.2026187.2110 

func (x *ResolveEndpointReply) GetAddr() string

func (*ResolveEndpointReply) GetError added in v0.2026187.2110 

func (x *ResolveEndpointReply) GetError() string

func (*ResolveEndpointReply) ProtoMessage added in v0.2026187.2110 

func (*ResolveEndpointReply) ProtoMessage()

func (*ResolveEndpointReply) ProtoReflect added in v0.2026187.2110 

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

func (*ResolveEndpointReply) Reset added in v0.2026187.2110 

func (x *ResolveEndpointReply) Reset()

func (*ResolveEndpointReply) String added in v0.2026187.2110 

func (x *ResolveEndpointReply) String() string

type ResolveEndpointRequest added in v0.2026187.2110 

type ResolveEndpointRequest struct {
	Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

ResolveEndpointRequest: the in-venue TCP port to resolve to a host-reachable address.

func (*ResolveEndpointRequest) Descriptor deprecated added in v0.2026187.2110 

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

Deprecated: Use ResolveEndpointRequest.ProtoReflect.Descriptor instead.

func (*ResolveEndpointRequest) GetPort added in v0.2026187.2110 

func (x *ResolveEndpointRequest) GetPort() int32

func (*ResolveEndpointRequest) ProtoMessage added in v0.2026187.2110 

func (*ResolveEndpointRequest) ProtoMessage()

func (*ResolveEndpointRequest) ProtoReflect added in v0.2026187.2110 

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

func (*ResolveEndpointRequest) Reset added in v0.2026187.2110 

func (x *ResolveEndpointRequest) Reset()

func (*ResolveEndpointRequest) String added in v0.2026187.2110 

func (x *ResolveEndpointRequest) String() string

type ResolveGraphicsEndpointReply added in v0.2026187.2153 

type ResolveGraphicsEndpointReply struct {
	Addr        string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Socket      string `protobuf:"bytes,2,opt,name=socket,proto3" json:"socket,omitempty"`
	Password    string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Skip        bool   `protobuf:"varint,4,opt,name=skip,proto3" json:"skip,omitempty"`
	SkipMessage string `protobuf:"bytes,5,opt,name=skip_message,json=skipMessage,proto3" json:"skip_message,omitempty"`
	Error       string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ResolveGraphicsEndpointReply: the dialable endpoint. Exactly one of addr / socket is set; password is the resolved ticket (empty = no auth). skip=true with skip_message signals a deployment with no graphics device of that kind (an N/A skip, not a failure).

func (*ResolveGraphicsEndpointReply) Descriptor deprecated added in v0.2026187.2153 

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

Deprecated: Use ResolveGraphicsEndpointReply.ProtoReflect.Descriptor instead.

func (*ResolveGraphicsEndpointReply) GetAddr added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointReply) GetAddr() string

func (*ResolveGraphicsEndpointReply) GetError added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointReply) GetError() string

func (*ResolveGraphicsEndpointReply) GetPassword added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointReply) GetPassword() string

func (*ResolveGraphicsEndpointReply) GetSkip added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointReply) GetSkip() bool

func (*ResolveGraphicsEndpointReply) GetSkipMessage added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointReply) GetSkipMessage() string

func (*ResolveGraphicsEndpointReply) GetSocket added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointReply) GetSocket() string

func (*ResolveGraphicsEndpointReply) ProtoMessage added in v0.2026187.2153 

func (*ResolveGraphicsEndpointReply) ProtoMessage()

func (*ResolveGraphicsEndpointReply) ProtoReflect added in v0.2026187.2153 

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

func (*ResolveGraphicsEndpointReply) Reset added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointReply) Reset()

func (*ResolveGraphicsEndpointReply) String added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointReply) String() string

type ResolveGraphicsEndpointRequest added in v0.2026187.2153 

type ResolveGraphicsEndpointRequest struct {
	Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

ResolveGraphicsEndpointRequest: the graphics kind to resolve ("vnc" | "spice").

func (*ResolveGraphicsEndpointRequest) Descriptor deprecated added in v0.2026187.2153 

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

Deprecated: Use ResolveGraphicsEndpointRequest.ProtoReflect.Descriptor instead.

func (*ResolveGraphicsEndpointRequest) GetKind added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointRequest) GetKind() string

func (*ResolveGraphicsEndpointRequest) ProtoMessage added in v0.2026187.2153 

func (*ResolveGraphicsEndpointRequest) ProtoMessage()

func (*ResolveGraphicsEndpointRequest) ProtoReflect added in v0.2026187.2153 

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

func (*ResolveGraphicsEndpointRequest) Reset added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointRequest) Reset()

func (*ResolveGraphicsEndpointRequest) String added in v0.2026187.2153 

func (x *ResolveGraphicsEndpointRequest) String() string

type RunReply 

type RunReply struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RunReply) Descriptor deprecated 

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

Deprecated: Use RunReply.ProtoReflect.Descriptor instead.

func (*RunReply) GetError 

func (x *RunReply) GetError() string

func (*RunReply) ProtoMessage 

func (*RunReply) ProtoMessage()

func (*RunReply) ProtoReflect 

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

func (*RunReply) Reset 

func (x *RunReply) Reset()

func (*RunReply) String 

func (x *RunReply) String() string

type RunRequest 

type RunRequest struct {
	Script   string `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
	OptsJson []byte `protobuf:"bytes,2,opt,name=opts_json,json=optsJson,proto3" json:"opts_json,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated 

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetOptsJson 

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

func (*RunRequest) GetScript 

func (x *RunRequest) GetScript() string

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 StepContract 

type StepContract struct {
	Scope string `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`  // "system" | "user" | "user-profile"
	Venue int32  `protobuf:"varint,2,opt,name=venue,proto3" json:"venue,omitempty"` // Venue enum: 0=host-native, 1=container-builder, 2=skip
	Gate  string `protobuf:"bytes,3,opt,name=gate,proto3" json:"gate,omitempty"`    // "" | "allow-repo-changes" | "allow-root-tasks" | "with-services"
	Emits bool   `protobuf:"varint,4,opt,name=emits,proto3" json:"emits,omitempty"` // F-STEP-EMIT: the step produces a build-context Containerfile FRAGMENT (Invoke(OpEmit)); the pod-overlay OCITarget bakes it. false => deploy-only step (no build fragment; OCITarget skips it, like apk on an image build)
	// contains filtered or unexported fields
}

StepContract — a class="step" plugin's DECLARED install-step contract (F3): where the step's effect lands (scope) + where its commands execute (venue) + the opt-in gate it needs. This is what makes an external step kind a first-class IR step whose privilege / gating the host applies WITHOUT a compiled-in case (the open default arm). Reverse is NOT declared — an external step's teardown ops are DYNAMIC, recorded from its OpExecute reply (the same record-and-replay as ExternalPluginStep). Empty/absent for non-step capabilities.

func (*StepContract) Descriptor deprecated 

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

Deprecated: Use StepContract.ProtoReflect.Descriptor instead.

func (*StepContract) GetEmits 

func (x *StepContract) GetEmits() bool

func (*StepContract) GetGate 

func (x *StepContract) GetGate() string

func (*StepContract) GetScope 

func (x *StepContract) GetScope() string

func (*StepContract) GetVenue 

func (x *StepContract) GetVenue() int32

func (*StepContract) ProtoMessage 

func (*StepContract) ProtoMessage()

func (*StepContract) ProtoReflect 

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

func (*StepContract) Reset 

func (x *StepContract) Reset()

func (*StepContract) String 

func (x *StepContract) String() string

type UnimplementedCheckContextServiceServer 

type UnimplementedCheckContextServiceServer struct {
}

UnimplementedCheckContextServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCheckContextServiceServer) AddBackground 

func (UnimplementedCheckContextServiceServer) AddBackground(context.Context, *AddBackgroundRequest) (*Empty, error)

func (UnimplementedCheckContextServiceServer) HTTPDo 

func (UnimplementedCheckContextServiceServer) HTTPDo(context.Context, *HTTPDoRequest) (*HTTPDoReply, error)

func (UnimplementedCheckContextServiceServer) ResolveEndpoint added in v0.2026187.2110 

func (UnimplementedCheckContextServiceServer) ResolveEndpoint(context.Context, *ResolveEndpointRequest) (*ResolveEndpointReply, error)

func (UnimplementedCheckContextServiceServer) ResolveGraphicsEndpoint added in v0.2026187.2153 

func (UnimplementedCheckContextServiceServer) ResolveGraphicsEndpoint(context.Context, *ResolveGraphicsEndpointRequest) (*ResolveGraphicsEndpointReply, error)

type UnimplementedExecutorServiceServer 

type UnimplementedExecutorServiceServer struct {
}

UnimplementedExecutorServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutorServiceServer) GetFile 

func (UnimplementedExecutorServiceServer) GetFile(context.Context, *GetFileRequest) (*GetFileReply, error)

func (UnimplementedExecutorServiceServer) HostArbiter 

func (UnimplementedExecutorServiceServer) HostArbiter(context.Context, *HostArbiterRequest) (*HostArbiterReply, error)

func (UnimplementedExecutorServiceServer) HostBuild 

func (UnimplementedExecutorServiceServer) HostBuild(context.Context, *HostBuildRequest) (*HostBuildReply, error)

func (UnimplementedExecutorServiceServer) InvokeProvider 

func (UnimplementedExecutorServiceServer) InvokeProvider(context.Context, *InvokeProviderRequest) (*InvokeReply, error)

func (UnimplementedExecutorServiceServer) PutFile 

func (UnimplementedExecutorServiceServer) PutFile(context.Context, *PutFileRequest) (*PutFileReply, error)

func (UnimplementedExecutorServiceServer) RunCapture 

func (UnimplementedExecutorServiceServer) RunCapture(context.Context, *RunRequest) (*CaptureReply, error)

func (UnimplementedExecutorServiceServer) RunHostStep 

func (UnimplementedExecutorServiceServer) RunHostStep(context.Context, *HostStepRequest) (*HostStepReply, error)

func (UnimplementedExecutorServiceServer) RunSystem 

func (UnimplementedExecutorServiceServer) RunSystem(context.Context, *RunRequest) (*RunReply, error)

func (UnimplementedExecutorServiceServer) RunUser 

func (UnimplementedExecutorServiceServer) RunUser(context.Context, *RunRequest) (*RunReply, error)

func (UnimplementedExecutorServiceServer) Venue 

func (UnimplementedExecutorServiceServer) Venue(context.Context, *Empty) (*VenueReply, error)

type UnimplementedPluginMetaServer 

type UnimplementedPluginMetaServer struct {
}

UnimplementedPluginMetaServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginMetaServer) Describe 

func (UnimplementedPluginMetaServer) Describe(context.Context, *Empty) (*Capabilities, error)

type UnimplementedProviderServer 

type UnimplementedProviderServer struct {
}

UnimplementedProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedProviderServer) Invoke 

func (UnimplementedProviderServer) Invoke(context.Context, *InvokeRequest) (*InvokeReply, error)

func (UnimplementedProviderServer) InvokeStream 

func (UnimplementedProviderServer) InvokeStream(*InvokeRequest, Provider_InvokeStreamServer) error

type UnsafeCheckContextServiceServer 

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

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

type UnsafeExecutorServiceServer 

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

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

type UnsafePluginMetaServer 

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

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

type UnsafeProviderServer 

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

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

type VenueReply 

type VenueReply struct {
	Venue string `protobuf:"bytes,1,opt,name=venue,proto3" json:"venue,omitempty"`
	// contains filtered or unexported fields
}

func (*VenueReply) Descriptor deprecated 

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

Deprecated: Use VenueReply.ProtoReflect.Descriptor instead.

func (*VenueReply) GetVenue 

func (x *VenueReply) GetVenue() string

func (*VenueReply) ProtoMessage 

func (*VenueReply) ProtoMessage()

func (*VenueReply) ProtoReflect 

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

func (*VenueReply) Reset 

func (x *VenueReply) Reset()

func (*VenueReply) String 

func (x *VenueReply) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.