agentpb

package
v0.2.0-beta.2 Latest Latest
Warning

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

Go to latest
Published: Sep 18, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AgentService_Enroll_FullMethodName  = "/levelrail.agent.v1.AgentService/Enroll"
	AgentService_Session_FullMethodName = "/levelrail.agent.v1.AgentService/Session"
)

Variables

View Source
var (
	BuildKind_name = map[int32]string{
		0: "BUILD_KIND_UNSPECIFIED",
		1: "BUILD_KIND_DOCKERFILE",
		2: "BUILD_KIND_RAILPACK",
	}
	BuildKind_value = map[string]int32{
		"BUILD_KIND_UNSPECIFIED": 0,
		"BUILD_KIND_DOCKERFILE":  1,
		"BUILD_KIND_RAILPACK":    2,
	}
)

Enum value maps for BuildKind.

View Source
var AgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "levelrail.agent.v1.AgentService",
	HandlerType: (*AgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Enroll",
			Handler:    _AgentService_Enroll_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Session",
			Handler:       _AgentService_Session_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/agent/v1/agent.proto",
}

AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService 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_proto_agent_v1_agent_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServiceServer

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

Types

type AgentMessage

type AgentMessage struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*AgentMessage_Response
	//	*AgentMessage_Event
	//	*AgentMessage_ExecOutput
	//	*AgentMessage_ExecCredit
	//	*AgentMessage_BuildOutput
	//	*AgentMessage_BuildCredit
	Payload isAgentMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

AgentMessage is one frame the agent sends up the Session stream: a reply to an outstanding AgentRequest, an unprompted streamed Docker event, or one frame of an in-flight exec's output or stdin flow control.

func (*AgentMessage) Descriptor deprecated

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

Deprecated: Use AgentMessage.ProtoReflect.Descriptor instead.

func (*AgentMessage) GetBuildCredit

func (x *AgentMessage) GetBuildCredit() *BuildCredit

func (*AgentMessage) GetBuildOutput

func (x *AgentMessage) GetBuildOutput() *BuildOutput

func (*AgentMessage) GetEvent

func (x *AgentMessage) GetEvent() *ProxiedEvent

func (*AgentMessage) GetExecCredit

func (x *AgentMessage) GetExecCredit() *ExecCredit

func (*AgentMessage) GetExecOutput

func (x *AgentMessage) GetExecOutput() *ExecOutput

func (*AgentMessage) GetPayload

func (x *AgentMessage) GetPayload() isAgentMessage_Payload

func (*AgentMessage) GetResponse

func (x *AgentMessage) GetResponse() *AgentResponse

func (*AgentMessage) ProtoMessage

func (*AgentMessage) ProtoMessage()

func (*AgentMessage) ProtoReflect

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

func (*AgentMessage) Reset

func (x *AgentMessage) Reset()

func (*AgentMessage) String

func (x *AgentMessage) String() string

type AgentMessage_BuildCredit

type AgentMessage_BuildCredit struct {
	// BuildCredit here refunds the control plane's build-context window:
	// the agent has consumed that many BuildInput frames.
	BuildCredit *BuildCredit `protobuf:"bytes,6,opt,name=build_credit,json=buildCredit,proto3,oneof"`
}

type AgentMessage_BuildOutput

type AgentMessage_BuildOutput struct {
	BuildOutput *BuildOutput `protobuf:"bytes,5,opt,name=build_output,json=buildOutput,proto3,oneof"`
}

type AgentMessage_Event

type AgentMessage_Event struct {
	Event *ProxiedEvent `protobuf:"bytes,2,opt,name=event,proto3,oneof"`
}

type AgentMessage_ExecCredit

type AgentMessage_ExecCredit struct {
	// ExecCredit here refunds the control plane's stdin window: the
	// agent has consumed that many ExecInput frames.
	ExecCredit *ExecCredit `protobuf:"bytes,4,opt,name=exec_credit,json=execCredit,proto3,oneof"`
}

type AgentMessage_ExecOutput

type AgentMessage_ExecOutput struct {
	ExecOutput *ExecOutput `protobuf:"bytes,3,opt,name=exec_output,json=execOutput,proto3,oneof"`
}

type AgentMessage_Response

type AgentMessage_Response struct {
	Response *AgentResponse `protobuf:"bytes,1,opt,name=response,proto3,oneof"`
}

type AgentRequest

type AgentRequest struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are valid to be assigned to Op:
	//
	//	*AgentRequest_InspectByName
	//	*AgentRequest_Create
	//	*AgentRequest_Start
	//	*AgentRequest_Stop
	//	*AgentRequest_Remove
	//	*AgentRequest_ListImages
	//	*AgentRequest_ListByPrefix
	//	*AgentRequest_EnsureVolume
	//	*AgentRequest_WatchEvents
	//	*AgentRequest_UpdateResources
	//	*AgentRequest_EnsureNetwork
	//	*AgentRequest_RemoveNetwork
	//	*AgentRequest_ListNetworksByPrefix
	//	*AgentRequest_Exec
	//	*AgentRequest_Build
	Op isAgentRequest_Op `protobuf_oneof:"op"`
	// contains filtered or unexported fields
}

AgentRequest is one control-plane-issued operation, tagged with request_id so out-of-order AgentResponse frames on the same stream still resolve to the right caller (internal/agent's multiplexer owns matching these).

func (*AgentRequest) Descriptor deprecated

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

Deprecated: Use AgentRequest.ProtoReflect.Descriptor instead.

func (*AgentRequest) GetBuild

func (x *AgentRequest) GetBuild() *BuildRequest

func (*AgentRequest) GetCreate

func (x *AgentRequest) GetCreate() *CreateRequest

func (*AgentRequest) GetEnsureNetwork

func (x *AgentRequest) GetEnsureNetwork() *EnsureNetworkRequest

func (*AgentRequest) GetEnsureVolume

func (x *AgentRequest) GetEnsureVolume() *EnsureVolumeRequest

func (*AgentRequest) GetExec

func (x *AgentRequest) GetExec() *ExecRequest

func (*AgentRequest) GetInspectByName

func (x *AgentRequest) GetInspectByName() *InspectByNameRequest

func (*AgentRequest) GetListByPrefix

func (x *AgentRequest) GetListByPrefix() *ListByPrefixRequest

func (*AgentRequest) GetListImages

func (x *AgentRequest) GetListImages() *ListImagesRequest

func (*AgentRequest) GetListNetworksByPrefix

func (x *AgentRequest) GetListNetworksByPrefix() *ListNetworksByPrefixRequest

func (*AgentRequest) GetOp

func (x *AgentRequest) GetOp() isAgentRequest_Op

func (*AgentRequest) GetRemove

func (x *AgentRequest) GetRemove() *RemoveRequest

func (*AgentRequest) GetRemoveNetwork

func (x *AgentRequest) GetRemoveNetwork() *RemoveNetworkRequest

func (*AgentRequest) GetRequestId

func (x *AgentRequest) GetRequestId() string

func (*AgentRequest) GetStart

func (x *AgentRequest) GetStart() *StartRequest

func (*AgentRequest) GetStop

func (x *AgentRequest) GetStop() *StopRequest

func (*AgentRequest) GetUpdateResources

func (x *AgentRequest) GetUpdateResources() *UpdateResourcesRequest

func (*AgentRequest) GetWatchEvents

func (x *AgentRequest) GetWatchEvents() *WatchEventsRequest

func (*AgentRequest) ProtoMessage

func (*AgentRequest) ProtoMessage()

func (*AgentRequest) ProtoReflect

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

func (*AgentRequest) Reset

func (x *AgentRequest) Reset()

func (*AgentRequest) String

func (x *AgentRequest) String() string

type AgentRequest_Build

type AgentRequest_Build struct {
	Build *BuildRequest `protobuf:"bytes,16,opt,name=build,proto3,oneof"`
}

type AgentRequest_Create

type AgentRequest_Create struct {
	Create *CreateRequest `protobuf:"bytes,3,opt,name=create,proto3,oneof"`
}

type AgentRequest_EnsureNetwork

type AgentRequest_EnsureNetwork struct {
	EnsureNetwork *EnsureNetworkRequest `protobuf:"bytes,12,opt,name=ensure_network,json=ensureNetwork,proto3,oneof"`
}

type AgentRequest_EnsureVolume

type AgentRequest_EnsureVolume struct {
	EnsureVolume *EnsureVolumeRequest `protobuf:"bytes,9,opt,name=ensure_volume,json=ensureVolume,proto3,oneof"`
}

type AgentRequest_Exec

type AgentRequest_Exec struct {
	Exec *ExecRequest `protobuf:"bytes,15,opt,name=exec,proto3,oneof"`
}

type AgentRequest_InspectByName

type AgentRequest_InspectByName struct {
	InspectByName *InspectByNameRequest `protobuf:"bytes,2,opt,name=inspect_by_name,json=inspectByName,proto3,oneof"`
}

type AgentRequest_ListByPrefix

type AgentRequest_ListByPrefix struct {
	ListByPrefix *ListByPrefixRequest `protobuf:"bytes,8,opt,name=list_by_prefix,json=listByPrefix,proto3,oneof"`
}

type AgentRequest_ListImages

type AgentRequest_ListImages struct {
	ListImages *ListImagesRequest `protobuf:"bytes,7,opt,name=list_images,json=listImages,proto3,oneof"`
}

type AgentRequest_ListNetworksByPrefix

type AgentRequest_ListNetworksByPrefix struct {
	ListNetworksByPrefix *ListNetworksByPrefixRequest `protobuf:"bytes,14,opt,name=list_networks_by_prefix,json=listNetworksByPrefix,proto3,oneof"`
}

type AgentRequest_Remove

type AgentRequest_Remove struct {
	Remove *RemoveRequest `protobuf:"bytes,6,opt,name=remove,proto3,oneof"`
}

type AgentRequest_RemoveNetwork

type AgentRequest_RemoveNetwork struct {
	RemoveNetwork *RemoveNetworkRequest `protobuf:"bytes,13,opt,name=remove_network,json=removeNetwork,proto3,oneof"`
}

type AgentRequest_Start

type AgentRequest_Start struct {
	Start *StartRequest `protobuf:"bytes,4,opt,name=start,proto3,oneof"`
}

type AgentRequest_Stop

type AgentRequest_Stop struct {
	Stop *StopRequest `protobuf:"bytes,5,opt,name=stop,proto3,oneof"`
}

type AgentRequest_UpdateResources

type AgentRequest_UpdateResources struct {
	UpdateResources *UpdateResourcesRequest `protobuf:"bytes,11,opt,name=update_resources,json=updateResources,proto3,oneof"`
}

type AgentRequest_WatchEvents

type AgentRequest_WatchEvents struct {
	WatchEvents *WatchEventsRequest `protobuf:"bytes,10,opt,name=watch_events,json=watchEvents,proto3,oneof"`
}

type AgentResponse

type AgentResponse struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Error is set (and every field below unset) when the underlying
	// internal/docker.Runtime call itself returned an error: the
	// multiplexer surfaces this as a real Go error to the caller, never
	// silently treated as a zero-value success.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// Types that are valid to be assigned to Result:
	//
	//	*AgentResponse_InspectByName
	//	*AgentResponse_Create
	//	*AgentResponse_ListImages
	//	*AgentResponse_ListByPrefix
	//	*AgentResponse_Empty
	//	*AgentResponse_EnsureNetwork
	//	*AgentResponse_ListNetworksByPrefix
	Result isAgentResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

AgentResponse is the agent's answer to exactly one AgentRequest, carrying the same request_id.

func (*AgentResponse) Descriptor deprecated

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

Deprecated: Use AgentResponse.ProtoReflect.Descriptor instead.

func (*AgentResponse) GetCreate

func (x *AgentResponse) GetCreate() *CreateResponse

func (*AgentResponse) GetEmpty

func (x *AgentResponse) GetEmpty() *Empty

func (*AgentResponse) GetEnsureNetwork

func (x *AgentResponse) GetEnsureNetwork() *EnsureNetworkResponse

func (*AgentResponse) GetError

func (x *AgentResponse) GetError() string

func (*AgentResponse) GetInspectByName

func (x *AgentResponse) GetInspectByName() *InspectByNameResponse

func (*AgentResponse) GetListByPrefix

func (x *AgentResponse) GetListByPrefix() *ListByPrefixResponse

func (*AgentResponse) GetListImages

func (x *AgentResponse) GetListImages() *ListImagesResponse

func (*AgentResponse) GetListNetworksByPrefix

func (x *AgentResponse) GetListNetworksByPrefix() *ListNetworksByPrefixResponse

func (*AgentResponse) GetRequestId

func (x *AgentResponse) GetRequestId() string

func (*AgentResponse) GetResult

func (x *AgentResponse) GetResult() isAgentResponse_Result

func (*AgentResponse) ProtoMessage

func (*AgentResponse) ProtoMessage()

func (*AgentResponse) ProtoReflect

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

func (*AgentResponse) Reset

func (x *AgentResponse) Reset()

func (*AgentResponse) String

func (x *AgentResponse) String() string

type AgentResponse_Create

type AgentResponse_Create struct {
	Create *CreateResponse `protobuf:"bytes,4,opt,name=create,proto3,oneof"`
}

type AgentResponse_Empty

type AgentResponse_Empty struct {
	// Start, Stop, Remove, EnsureVolume, RemoveNetwork, and the
	// WatchEvents acknowledgment all return nothing but success/Error
	// above, so none of them needs its own response message.
	Empty *Empty `protobuf:"bytes,7,opt,name=empty,proto3,oneof"`
}

type AgentResponse_EnsureNetwork

type AgentResponse_EnsureNetwork struct {
	EnsureNetwork *EnsureNetworkResponse `protobuf:"bytes,8,opt,name=ensure_network,json=ensureNetwork,proto3,oneof"`
}

type AgentResponse_InspectByName

type AgentResponse_InspectByName struct {
	InspectByName *InspectByNameResponse `protobuf:"bytes,3,opt,name=inspect_by_name,json=inspectByName,proto3,oneof"`
}

type AgentResponse_ListByPrefix

type AgentResponse_ListByPrefix struct {
	ListByPrefix *ListByPrefixResponse `protobuf:"bytes,6,opt,name=list_by_prefix,json=listByPrefix,proto3,oneof"`
}

type AgentResponse_ListImages

type AgentResponse_ListImages struct {
	ListImages *ListImagesResponse `protobuf:"bytes,5,opt,name=list_images,json=listImages,proto3,oneof"`
}

type AgentResponse_ListNetworksByPrefix

type AgentResponse_ListNetworksByPrefix struct {
	ListNetworksByPrefix *ListNetworksByPrefixResponse `protobuf:"bytes,9,opt,name=list_networks_by_prefix,json=listNetworksByPrefix,proto3,oneof"`
}

type AgentServiceClient

type AgentServiceClient interface {
	// Enroll exchanges a one-time join token (internal/store.NodeJoinToken)
	// for a signed client certificate, over a connection
	// that does not yet present a client cert (the token itself is the
	// credential for this one call). Called once per node, before Session
	// is ever called.
	Enroll(ctx context.Context, in *EnrollRequest, opts ...grpc.CallOption) (*EnrollResponse, error)
	// Session is the agent's one persistent connection, opened only after
	// Enroll (using the certificate Enroll returned for mTLS). The agent
	// never initiates a logical request on this stream, only responds to
	// AgentRequest messages arriving from the control plane, plus sending
	// ProxiedEvent messages unprompted (the streaming Docker-event
	// relay ADR 003 calls out: "the agent streams Docker events up to
	// the control plane rather than the control plane polling down").
	Session(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AgentMessage, ControlMessage], error)
}

AgentServiceClient is the client API for AgentService 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.

type AgentServiceServer

type AgentServiceServer interface {
	// Enroll exchanges a one-time join token (internal/store.NodeJoinToken)
	// for a signed client certificate, over a connection
	// that does not yet present a client cert (the token itself is the
	// credential for this one call). Called once per node, before Session
	// is ever called.
	Enroll(context.Context, *EnrollRequest) (*EnrollResponse, error)
	// Session is the agent's one persistent connection, opened only after
	// Enroll (using the certificate Enroll returned for mTLS). The agent
	// never initiates a logical request on this stream, only responds to
	// AgentRequest messages arriving from the control plane, plus sending
	// ProxiedEvent messages unprompted (the streaming Docker-event
	// relay ADR 003 calls out: "the agent streams Docker events up to
	// the control plane rather than the control plane polling down").
	Session(grpc.BidiStreamingServer[AgentMessage, ControlMessage]) error
	// contains filtered or unexported methods
}

AgentServiceServer is the server API for AgentService service. All implementations must embed UnimplementedAgentServiceServer for forward compatibility.

type AgentService_SessionClient

type AgentService_SessionClient = grpc.BidiStreamingClient[AgentMessage, ControlMessage]

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

type AgentService_SessionServer

type AgentService_SessionServer = grpc.BidiStreamingServer[AgentMessage, ControlMessage]

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

type BuildCache

type BuildCache struct {
	RegistryRef      string `protobuf:"bytes,1,opt,name=registry_ref,json=registryRef,proto3" json:"registry_ref,omitempty"`
	RegistryInsecure bool   `protobuf:"varint,2,opt,name=registry_insecure,json=registryInsecure,proto3" json:"registry_insecure,omitempty"`
	// contains filtered or unexported fields
}

BuildCache carries only internal/build.CacheConfig's registry backend. Its local-directory backend is deliberately not sent: that path names a directory on the control plane's own disk, which this node does not have, while a registry ref is shared by construction.

func (*BuildCache) Descriptor deprecated

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

Deprecated: Use BuildCache.ProtoReflect.Descriptor instead.

func (*BuildCache) GetRegistryInsecure

func (x *BuildCache) GetRegistryInsecure() bool

func (*BuildCache) GetRegistryRef

func (x *BuildCache) GetRegistryRef() string

func (*BuildCache) ProtoMessage

func (*BuildCache) ProtoMessage()

func (*BuildCache) ProtoReflect

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

func (*BuildCache) Reset

func (x *BuildCache) Reset()

func (*BuildCache) String

func (x *BuildCache) String() string

type BuildCancel

type BuildCancel struct {
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

BuildCancel ends an in-flight build early, when the control plane's caller gave up before it finished.

func (*BuildCancel) Descriptor deprecated

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

Deprecated: Use BuildCancel.ProtoReflect.Descriptor instead.

func (*BuildCancel) GetBuildId

func (x *BuildCancel) GetBuildId() string

func (*BuildCancel) ProtoMessage

func (*BuildCancel) ProtoMessage()

func (*BuildCancel) ProtoReflect

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

func (*BuildCancel) Reset

func (x *BuildCancel) Reset()

func (*BuildCancel) String

func (x *BuildCancel) String() string

type BuildCredit

type BuildCredit struct {
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	Frames  uint32 `protobuf:"varint,2,opt,name=frames,proto3" json:"frames,omitempty"`
	// contains filtered or unexported fields
}

BuildCredit refunds flow-control window for one build, in frames, the same windowing ExecCredit documents for exec.

func (*BuildCredit) Descriptor deprecated

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

Deprecated: Use BuildCredit.ProtoReflect.Descriptor instead.

func (*BuildCredit) GetBuildId

func (x *BuildCredit) GetBuildId() string

func (*BuildCredit) GetFrames

func (x *BuildCredit) GetFrames() uint32

func (*BuildCredit) ProtoMessage

func (*BuildCredit) ProtoMessage()

func (*BuildCredit) ProtoReflect

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

func (*BuildCredit) Reset

func (x *BuildCredit) Reset()

func (*BuildCredit) String

func (x *BuildCredit) String() string

type BuildDone

type BuildDone struct {
	DurationMs       int64             `protobuf:"varint,1,opt,name=duration_ms,json=durationMs,proto3" json:"duration_ms,omitempty"`
	ExporterResponse map[string]string `` /* 183-byte string literal not displayed */
	// contains filtered or unexported fields
}

BuildDone carries what internal/build.Result holds beyond the tag the control plane already knows.

func (*BuildDone) Descriptor deprecated

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

Deprecated: Use BuildDone.ProtoReflect.Descriptor instead.

func (*BuildDone) GetDurationMs

func (x *BuildDone) GetDurationMs() int64

func (*BuildDone) GetExporterResponse

func (x *BuildDone) GetExporterResponse() map[string]string

func (*BuildDone) ProtoMessage

func (*BuildDone) ProtoMessage()

func (*BuildDone) ProtoReflect

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

func (*BuildDone) Reset

func (x *BuildDone) Reset()

func (*BuildDone) String

func (x *BuildDone) String() string

type BuildFailure

type BuildFailure struct {
	Message             string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	UnsupportedProvider bool   `protobuf:"varint,2,opt,name=unsupported_provider,json=unsupportedProvider,proto3" json:"unsupported_provider,omitempty"`
	Provider            string `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`
	// contains filtered or unexported fields
}

BuildFailure is the error that ended a build. unsupported_provider is set when the failure was internal/build.UnsupportedProviderError, so the control plane can rebuild that typed error rather than a flat string: internal/deploy branches on it with errors.As.

func (*BuildFailure) Descriptor deprecated

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

Deprecated: Use BuildFailure.ProtoReflect.Descriptor instead.

func (*BuildFailure) GetMessage

func (x *BuildFailure) GetMessage() string

func (*BuildFailure) GetProvider

func (x *BuildFailure) GetProvider() string

func (*BuildFailure) GetUnsupportedProvider

func (x *BuildFailure) GetUnsupportedProvider() bool

func (*BuildFailure) ProtoMessage

func (*BuildFailure) ProtoMessage()

func (*BuildFailure) ProtoReflect

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

func (*BuildFailure) Reset

func (x *BuildFailure) Reset()

func (*BuildFailure) String

func (x *BuildFailure) String() string

type BuildInput

type BuildInput struct {
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	Chunk   []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Eof     bool   `protobuf:"varint,3,opt,name=eof,proto3" json:"eof,omitempty"`
	Error   string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

BuildInput is one build-context frame for the in-flight build whose request_id is build_id, carrying a tar stream of the context directory. Exactly one of chunk, eof, or error is meaningful per frame, the same contract ExecInput follows.

func (*BuildInput) Descriptor deprecated

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

Deprecated: Use BuildInput.ProtoReflect.Descriptor instead.

func (*BuildInput) GetBuildId

func (x *BuildInput) GetBuildId() string

func (*BuildInput) GetChunk

func (x *BuildInput) GetChunk() []byte

func (*BuildInput) GetEof

func (x *BuildInput) GetEof() bool

func (*BuildInput) GetError

func (x *BuildInput) GetError() string

func (*BuildInput) ProtoMessage

func (*BuildInput) ProtoMessage()

func (*BuildInput) ProtoReflect

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

func (*BuildInput) Reset

func (x *BuildInput) Reset()

func (*BuildInput) String

func (x *BuildInput) String() string

type BuildKind

type BuildKind int32
const (
	BuildKind_BUILD_KIND_UNSPECIFIED BuildKind = 0
	BuildKind_BUILD_KIND_DOCKERFILE  BuildKind = 1
	BuildKind_BUILD_KIND_RAILPACK    BuildKind = 2
)

func (BuildKind) Descriptor

func (BuildKind) Descriptor() protoreflect.EnumDescriptor

func (BuildKind) Enum

func (x BuildKind) Enum() *BuildKind

func (BuildKind) EnumDescriptor deprecated

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

Deprecated: Use BuildKind.Descriptor instead.

func (BuildKind) Number

func (x BuildKind) Number() protoreflect.EnumNumber

func (BuildKind) String

func (x BuildKind) String() string

func (BuildKind) Type

type BuildOutput

type BuildOutput struct {
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Types that are valid to be assigned to Frame:
	//
	//	*BuildOutput_Progress
	//	*BuildOutput_ImageChunk
	//	*BuildOutput_Done
	//	*BuildOutput_Failure
	Frame isBuildOutput_Frame `protobuf_oneof:"frame"`
	// contains filtered or unexported fields
}

BuildOutput is one frame of an in-flight build: a progress update, a chunk of the resulting image tar, or that stream's terminal frame. Exactly one terminal frame (done or failure) is ever sent per build.

func (*BuildOutput) Descriptor deprecated

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

Deprecated: Use BuildOutput.ProtoReflect.Descriptor instead.

func (*BuildOutput) GetBuildId

func (x *BuildOutput) GetBuildId() string

func (*BuildOutput) GetDone

func (x *BuildOutput) GetDone() *BuildDone

func (*BuildOutput) GetFailure

func (x *BuildOutput) GetFailure() *BuildFailure

func (*BuildOutput) GetFrame

func (x *BuildOutput) GetFrame() isBuildOutput_Frame

func (*BuildOutput) GetImageChunk

func (x *BuildOutput) GetImageChunk() []byte

func (*BuildOutput) GetProgress

func (x *BuildOutput) GetProgress() *BuildProgress

func (*BuildOutput) ProtoMessage

func (*BuildOutput) ProtoMessage()

func (*BuildOutput) ProtoReflect

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

func (*BuildOutput) Reset

func (x *BuildOutput) Reset()

func (*BuildOutput) String

func (x *BuildOutput) String() string

type BuildOutput_Done

type BuildOutput_Done struct {
	Done *BuildDone `protobuf:"bytes,4,opt,name=done,proto3,oneof"`
}

type BuildOutput_Failure

type BuildOutput_Failure struct {
	Failure *BuildFailure `protobuf:"bytes,5,opt,name=failure,proto3,oneof"`
}

type BuildOutput_ImageChunk

type BuildOutput_ImageChunk struct {
	ImageChunk []byte `protobuf:"bytes,3,opt,name=image_chunk,json=imageChunk,proto3,oneof"`
}

type BuildOutput_Progress

type BuildOutput_Progress struct {
	Progress *BuildProgress `protobuf:"bytes,2,opt,name=progress,proto3,oneof"`
}

type BuildProgress

type BuildProgress struct {
	Step      string `protobuf:"bytes,1,opt,name=step,proto3" json:"step,omitempty"`
	Cached    bool   `protobuf:"varint,2,opt,name=cached,proto3" json:"cached,omitempty"`
	Completed bool   `protobuf:"varint,3,opt,name=completed,proto3" json:"completed,omitempty"`
	Error     string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	Log       string `protobuf:"bytes,5,opt,name=log,proto3" json:"log,omitempty"`
	Stream    string `protobuf:"bytes,6,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

BuildProgress mirrors internal/build.ProgressEvent field for field, so a remote build's log lines reach the control plane's existing SSE stream in the same shape a local build's do.

func (*BuildProgress) Descriptor deprecated

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

Deprecated: Use BuildProgress.ProtoReflect.Descriptor instead.

func (*BuildProgress) GetCached

func (x *BuildProgress) GetCached() bool

func (*BuildProgress) GetCompleted

func (x *BuildProgress) GetCompleted() bool

func (*BuildProgress) GetError

func (x *BuildProgress) GetError() string

func (*BuildProgress) GetLog

func (x *BuildProgress) GetLog() string

func (*BuildProgress) GetStep

func (x *BuildProgress) GetStep() string

func (*BuildProgress) GetStream

func (x *BuildProgress) GetStream() string

func (*BuildProgress) ProtoMessage

func (*BuildProgress) ProtoMessage()

func (*BuildProgress) ProtoReflect

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

func (*BuildProgress) Reset

func (x *BuildProgress) Reset()

func (*BuildProgress) String

func (x *BuildProgress) String() string

type BuildRequest

type BuildRequest struct {
	Kind BuildKind `protobuf:"varint,1,opt,name=kind,proto3,enum=levelrail.agent.v1.BuildKind" json:"kind,omitempty"`
	// Tag is the image reference the built image is exported under.
	Tag string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// DockerfilePath is relative to the build context root, since the
	// control plane's own absolute paths mean nothing on this node. Empty
	// means the context root's own Dockerfile.
	DockerfilePath string            `protobuf:"bytes,3,opt,name=dockerfile_path,json=dockerfilePath,proto3" json:"dockerfile_path,omitempty"`
	Target         string            `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	BuildArgs      map[string]string `` /* 162-byte string literal not displayed */
	NoCache        bool              `protobuf:"varint,6,opt,name=no_cache,json=noCache,proto3" json:"no_cache,omitempty"`
	Cache          *BuildCache       `protobuf:"bytes,7,opt,name=cache,proto3" json:"cache,omitempty"`
	// contains filtered or unexported fields
}

BuildRequest dispatches one image build to this node's own BuildKit instance, so build CPU lands on a dedicated build node instead of the control plane. The control plane streams the build context up as BuildInput frames tagged with this request's request_id, the agent streams progress and the resulting docker-save image tar back as BuildOutput frames under the same ID, and the AgentResponse for this request is only the acknowledgment that the agent accepted the build.

func (*BuildRequest) Descriptor deprecated

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

Deprecated: Use BuildRequest.ProtoReflect.Descriptor instead.

func (*BuildRequest) GetBuildArgs

func (x *BuildRequest) GetBuildArgs() map[string]string

func (*BuildRequest) GetCache

func (x *BuildRequest) GetCache() *BuildCache

func (*BuildRequest) GetDockerfilePath

func (x *BuildRequest) GetDockerfilePath() string

func (*BuildRequest) GetKind

func (x *BuildRequest) GetKind() BuildKind

func (*BuildRequest) GetNoCache

func (x *BuildRequest) GetNoCache() bool

func (*BuildRequest) GetTag

func (x *BuildRequest) GetTag() string

func (*BuildRequest) GetTarget

func (x *BuildRequest) GetTarget() string

func (*BuildRequest) ProtoMessage

func (*BuildRequest) ProtoMessage()

func (*BuildRequest) ProtoReflect

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

func (*BuildRequest) Reset

func (x *BuildRequest) Reset()

func (*BuildRequest) String

func (x *BuildRequest) String() string

type ContainerSpec

type ContainerSpec struct {
	Name      string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image     string            `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Ports     []*PortBinding    `protobuf:"bytes,3,rep,name=ports,proto3" json:"ports,omitempty"`
	Env       map[string]string ``                                                                        /* 133-byte string literal not displayed */
	Resources *Resources        `protobuf:"bytes,5,opt,name=resources,proto3" json:"resources,omitempty"` // unset means internal/docker.ContainerSpec.Resources == nil
	Volumes   []*VolumeMount    `protobuf:"bytes,6,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// DNS mirrors internal/docker.ContainerSpec.DNS. Empty means Docker's
	// own embedded resolver, unchanged from before this field existed.
	Dns []string `protobuf:"bytes,7,rep,name=dns,proto3" json:"dns,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerSpec) Descriptor deprecated

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

Deprecated: Use ContainerSpec.ProtoReflect.Descriptor instead.

func (*ContainerSpec) GetDns

func (x *ContainerSpec) GetDns() []string

func (*ContainerSpec) GetEnv

func (x *ContainerSpec) GetEnv() map[string]string

func (*ContainerSpec) GetImage

func (x *ContainerSpec) GetImage() string

func (*ContainerSpec) GetName

func (x *ContainerSpec) GetName() string

func (*ContainerSpec) GetPorts

func (x *ContainerSpec) GetPorts() []*PortBinding

func (*ContainerSpec) GetResources

func (x *ContainerSpec) GetResources() *Resources

func (*ContainerSpec) GetVolumes

func (x *ContainerSpec) GetVolumes() []*VolumeMount

func (*ContainerSpec) ProtoMessage

func (*ContainerSpec) ProtoMessage()

func (*ContainerSpec) ProtoReflect

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

func (*ContainerSpec) Reset

func (x *ContainerSpec) Reset()

func (*ContainerSpec) String

func (x *ContainerSpec) String() string

type ContainerState

type ContainerState struct {
	Id      string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Image   string         `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`
	Running bool           `protobuf:"varint,4,opt,name=running,proto3" json:"running,omitempty"`
	Ports   []*PortBinding `protobuf:"bytes,5,rep,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerState) Descriptor deprecated

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

Deprecated: Use ContainerState.ProtoReflect.Descriptor instead.

func (*ContainerState) GetId

func (x *ContainerState) GetId() string

func (*ContainerState) GetImage

func (x *ContainerState) GetImage() string

func (*ContainerState) GetName

func (x *ContainerState) GetName() string

func (*ContainerState) GetPorts

func (x *ContainerState) GetPorts() []*PortBinding

func (*ContainerState) GetRunning

func (x *ContainerState) GetRunning() bool

func (*ContainerState) ProtoMessage

func (*ContainerState) ProtoMessage()

func (*ContainerState) ProtoReflect

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

func (*ContainerState) Reset

func (x *ContainerState) Reset()

func (*ContainerState) String

func (x *ContainerState) String() string

type ControlMessage

type ControlMessage struct {

	// Types that are valid to be assigned to Payload:
	//
	//	*ControlMessage_Request
	//	*ControlMessage_ExecInput
	//	*ControlMessage_ExecCancel
	//	*ControlMessage_ExecCredit
	//	*ControlMessage_BuildInput
	//	*ControlMessage_BuildCancel
	//	*ControlMessage_BuildCredit
	//	*ControlMessage_ExecResize
	Payload isControlMessage_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

ControlMessage is one frame the control plane sends down the Session stream: a request, or one frame of an in-flight exec's stdin, cancellation, or output flow control.

func (*ControlMessage) Descriptor deprecated

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

Deprecated: Use ControlMessage.ProtoReflect.Descriptor instead.

func (*ControlMessage) GetBuildCancel

func (x *ControlMessage) GetBuildCancel() *BuildCancel

func (*ControlMessage) GetBuildCredit

func (x *ControlMessage) GetBuildCredit() *BuildCredit

func (*ControlMessage) GetBuildInput

func (x *ControlMessage) GetBuildInput() *BuildInput

func (*ControlMessage) GetExecCancel

func (x *ControlMessage) GetExecCancel() *ExecCancel

func (*ControlMessage) GetExecCredit

func (x *ControlMessage) GetExecCredit() *ExecCredit

func (*ControlMessage) GetExecInput

func (x *ControlMessage) GetExecInput() *ExecInput

func (*ControlMessage) GetExecResize

func (x *ControlMessage) GetExecResize() *ExecResize

func (*ControlMessage) GetPayload

func (x *ControlMessage) GetPayload() isControlMessage_Payload

func (*ControlMessage) GetRequest

func (x *ControlMessage) GetRequest() *AgentRequest

func (*ControlMessage) ProtoMessage

func (*ControlMessage) ProtoMessage()

func (*ControlMessage) ProtoReflect

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

func (*ControlMessage) Reset

func (x *ControlMessage) Reset()

func (*ControlMessage) String

func (x *ControlMessage) String() string

type ControlMessage_BuildCancel

type ControlMessage_BuildCancel struct {
	BuildCancel *BuildCancel `protobuf:"bytes,6,opt,name=build_cancel,json=buildCancel,proto3,oneof"`
}

type ControlMessage_BuildCredit

type ControlMessage_BuildCredit struct {
	// BuildCredit here refunds the agent's output window: the control
	// plane has consumed that many BuildOutput frames.
	BuildCredit *BuildCredit `protobuf:"bytes,7,opt,name=build_credit,json=buildCredit,proto3,oneof"`
}

type ControlMessage_BuildInput

type ControlMessage_BuildInput struct {
	BuildInput *BuildInput `protobuf:"bytes,5,opt,name=build_input,json=buildInput,proto3,oneof"`
}

type ControlMessage_ExecCancel

type ControlMessage_ExecCancel struct {
	ExecCancel *ExecCancel `protobuf:"bytes,3,opt,name=exec_cancel,json=execCancel,proto3,oneof"`
}

type ControlMessage_ExecCredit

type ControlMessage_ExecCredit struct {
	// ExecCredit here refunds the agent's output window: the control
	// plane has consumed that many ExecOutput frames.
	ExecCredit *ExecCredit `protobuf:"bytes,4,opt,name=exec_credit,json=execCredit,proto3,oneof"`
}

type ControlMessage_ExecInput

type ControlMessage_ExecInput struct {
	ExecInput *ExecInput `protobuf:"bytes,2,opt,name=exec_input,json=execInput,proto3,oneof"`
}

type ControlMessage_ExecResize

type ControlMessage_ExecResize struct {
	ExecResize *ExecResize `protobuf:"bytes,8,opt,name=exec_resize,json=execResize,proto3,oneof"`
}

type ControlMessage_Request

type ControlMessage_Request struct {
	Request *AgentRequest `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type CreateRequest

type CreateRequest struct {
	Spec *ContainerSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetSpec

func (x *CreateRequest) GetSpec() *ContainerSpec

func (*CreateRequest) ProtoMessage

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect

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

func (*CreateRequest) Reset

func (x *CreateRequest) Reset()

func (*CreateRequest) String

func (x *CreateRequest) String() string

type CreateResponse

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

func (*CreateResponse) Descriptor deprecated

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetId

func (x *CreateResponse) GetId() string

func (*CreateResponse) ProtoMessage

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect

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

func (*CreateResponse) Reset

func (x *CreateResponse) Reset()

func (*CreateResponse) String

func (x *CreateResponse) String() string

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 EnrollRequest

type EnrollRequest struct {
	JoinToken string `protobuf:"bytes,1,opt,name=join_token,json=joinToken,proto3" json:"join_token,omitempty"`
	// NodeName is what the enrolling node wants to be called
	// (store.Node.Name); the control plane still enforces uniqueness
	// (store.ErrNodeNameTaken) the same way it would for any other
	// SaveNode caller.
	NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EnrollRequest) Descriptor deprecated

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

Deprecated: Use EnrollRequest.ProtoReflect.Descriptor instead.

func (*EnrollRequest) GetJoinToken

func (x *EnrollRequest) GetJoinToken() string

func (*EnrollRequest) GetNodeName

func (x *EnrollRequest) GetNodeName() string

func (*EnrollRequest) ProtoMessage

func (*EnrollRequest) ProtoMessage()

func (*EnrollRequest) ProtoReflect

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

func (*EnrollRequest) Reset

func (x *EnrollRequest) Reset()

func (*EnrollRequest) String

func (x *EnrollRequest) String() string

type EnrollResponse

type EnrollResponse struct {

	// NodeID is the store.Node.ID the control plane assigned; the agent
	// persists this alongside its certificate so subsequent Session
	// reconnects can identify themselves before the mTLS handshake even
	// completes (the cert's own CommonName already encodes it too, this
	// is the same value spelled out for the agent's own local bookkeeping).
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// ClientCertPEM/ClientKeyPEM are this node's new mTLS identity.
	// ClientKeyPEM never leaves this one response: it isn't persisted by
	// the control plane, isn't logged, and isn't retrievable again,
	// matching every other "shown once" credential in this codebase
	// (API tokens, node join tokens themselves).
	ClientCertPem []byte `protobuf:"bytes,2,opt,name=client_cert_pem,json=clientCertPem,proto3" json:"client_cert_pem,omitempty"`
	ClientKeyPem  []byte `protobuf:"bytes,3,opt,name=client_key_pem,json=clientKeyPem,proto3" json:"client_key_pem,omitempty"`
	// CACertPEM is the control plane's own CA certificate, so the agent
	// can verify the control plane's TLS server certificate on every
	// future connection without trusting the system root store (this is
	// a private, self-issued PKI for exactly this one relationship, not a
	// publicly-trusted certificate).
	CaCertPem []byte `protobuf:"bytes,4,opt,name=ca_cert_pem,json=caCertPem,proto3" json:"ca_cert_pem,omitempty"`
	// contains filtered or unexported fields
}

func (*EnrollResponse) Descriptor deprecated

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

Deprecated: Use EnrollResponse.ProtoReflect.Descriptor instead.

func (*EnrollResponse) GetCaCertPem

func (x *EnrollResponse) GetCaCertPem() []byte

func (*EnrollResponse) GetClientCertPem

func (x *EnrollResponse) GetClientCertPem() []byte

func (*EnrollResponse) GetClientKeyPem

func (x *EnrollResponse) GetClientKeyPem() []byte

func (*EnrollResponse) GetNodeId

func (x *EnrollResponse) GetNodeId() string

func (*EnrollResponse) ProtoMessage

func (*EnrollResponse) ProtoMessage()

func (*EnrollResponse) ProtoReflect

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

func (*EnrollResponse) Reset

func (x *EnrollResponse) Reset()

func (*EnrollResponse) String

func (x *EnrollResponse) String() string

type EnsureNetworkRequest

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

func (*EnsureNetworkRequest) Descriptor deprecated

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

Deprecated: Use EnsureNetworkRequest.ProtoReflect.Descriptor instead.

func (*EnsureNetworkRequest) GetName

func (x *EnsureNetworkRequest) GetName() string

func (*EnsureNetworkRequest) ProtoMessage

func (*EnsureNetworkRequest) ProtoMessage()

func (*EnsureNetworkRequest) ProtoReflect

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

func (*EnsureNetworkRequest) Reset

func (x *EnsureNetworkRequest) Reset()

func (*EnsureNetworkRequest) String

func (x *EnsureNetworkRequest) String() string

type EnsureNetworkResponse

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

func (*EnsureNetworkResponse) Descriptor deprecated

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

Deprecated: Use EnsureNetworkResponse.ProtoReflect.Descriptor instead.

func (*EnsureNetworkResponse) GetId

func (x *EnsureNetworkResponse) GetId() string

func (*EnsureNetworkResponse) ProtoMessage

func (*EnsureNetworkResponse) ProtoMessage()

func (*EnsureNetworkResponse) ProtoReflect

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

func (*EnsureNetworkResponse) Reset

func (x *EnsureNetworkResponse) Reset()

func (*EnsureNetworkResponse) String

func (x *EnsureNetworkResponse) String() string

type EnsureVolumeRequest

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

func (*EnsureVolumeRequest) Descriptor deprecated

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

Deprecated: Use EnsureVolumeRequest.ProtoReflect.Descriptor instead.

func (*EnsureVolumeRequest) GetName

func (x *EnsureVolumeRequest) GetName() string

func (*EnsureVolumeRequest) ProtoMessage

func (*EnsureVolumeRequest) ProtoMessage()

func (*EnsureVolumeRequest) ProtoReflect

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

func (*EnsureVolumeRequest) Reset

func (x *EnsureVolumeRequest) Reset()

func (*EnsureVolumeRequest) String

func (x *EnsureVolumeRequest) String() string

type ExecCancel

type ExecCancel struct {
	ExecId string `protobuf:"bytes,1,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// contains filtered or unexported fields
}

ExecCancel ends an in-flight exec early, when the control plane's caller closed the stream before the command finished. The agent stops reading and closes its local exec, so the remote process does not outlive the caller that asked for it.

func (*ExecCancel) Descriptor deprecated

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

Deprecated: Use ExecCancel.ProtoReflect.Descriptor instead.

func (*ExecCancel) GetExecId

func (x *ExecCancel) GetExecId() string

func (*ExecCancel) ProtoMessage

func (*ExecCancel) ProtoMessage()

func (*ExecCancel) ProtoReflect

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

func (*ExecCancel) Reset

func (x *ExecCancel) Reset()

func (*ExecCancel) String

func (x *ExecCancel) String() string

type ExecCredit

type ExecCredit struct {
	ExecId string `protobuf:"bytes,1,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Frames uint32 `protobuf:"varint,2,opt,name=frames,proto3" json:"frames,omitempty"`
	// contains filtered or unexported fields
}

ExecCredit refunds flow-control window for one exec, in frames. Both exec directions are windowed: a sender may have at most a fixed number of unacknowledged data frames outstanding, and the receiver credits frames back as it consumes them. Without this, one slow exec consumer would either stall every other logical call sharing the Session stream or force unbounded buffering of a multi-gigabyte dump.

func (*ExecCredit) Descriptor deprecated

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

Deprecated: Use ExecCredit.ProtoReflect.Descriptor instead.

func (*ExecCredit) GetExecId

func (x *ExecCredit) GetExecId() string

func (*ExecCredit) GetFrames

func (x *ExecCredit) GetFrames() uint32

func (*ExecCredit) ProtoMessage

func (*ExecCredit) ProtoMessage()

func (*ExecCredit) ProtoReflect

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

func (*ExecCredit) Reset

func (x *ExecCredit) Reset()

func (*ExecCredit) String

func (x *ExecCredit) String() string

type ExecExit

type ExecExit struct {
	Cmd       []string `protobuf:"bytes,1,rep,name=cmd,proto3" json:"cmd,omitempty"`
	Container string   `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	ExitCode  int32    `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Stderr    string   `protobuf:"bytes,4,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecExit) Descriptor deprecated

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

Deprecated: Use ExecExit.ProtoReflect.Descriptor instead.

func (*ExecExit) GetCmd

func (x *ExecExit) GetCmd() []string

func (*ExecExit) GetContainer

func (x *ExecExit) GetContainer() string

func (*ExecExit) GetExitCode

func (x *ExecExit) GetExitCode() int32

func (*ExecExit) GetStderr

func (x *ExecExit) GetStderr() string

func (*ExecExit) ProtoMessage

func (*ExecExit) ProtoMessage()

func (*ExecExit) ProtoReflect

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

func (*ExecExit) Reset

func (x *ExecExit) Reset()

func (*ExecExit) String

func (x *ExecExit) String() string

type ExecFailure

type ExecFailure struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// Exit is set when the failure was the command's own non-zero exit
	// (internal/docker.ExecExitError), so the control plane can rebuild
	// that typed error rather than a flat string: internal/api's exec
	// endpoint branches on it with errors.As to report a real exit code.
	Exit *ExecExit `protobuf:"bytes,2,opt,name=exit,proto3" json:"exit,omitempty"`
	// contains filtered or unexported fields
}

ExecFailure is the error that ended an exec's output stream, mirroring the trailing error docker.Runtime.Exec's own io.ReadCloser returns.

func (*ExecFailure) Descriptor deprecated

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

Deprecated: Use ExecFailure.ProtoReflect.Descriptor instead.

func (*ExecFailure) GetExit

func (x *ExecFailure) GetExit() *ExecExit

func (*ExecFailure) GetMessage

func (x *ExecFailure) GetMessage() string

func (*ExecFailure) ProtoMessage

func (*ExecFailure) ProtoMessage()

func (*ExecFailure) ProtoReflect

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

func (*ExecFailure) Reset

func (x *ExecFailure) Reset()

func (*ExecFailure) String

func (x *ExecFailure) String() string

type ExecInput

type ExecInput struct {
	ExecId string `protobuf:"bytes,1,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Chunk  []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Eof    bool   `protobuf:"varint,3,opt,name=eof,proto3" json:"eof,omitempty"`
	Error  string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ExecInput is one stdin frame for the in-flight exec whose request_id is exec_id. Exactly one of chunk, eof, or error is meaningful per frame: eof ends stdin the way closing a pipe's write half does, error carries a failure reading the control plane's own source reader so the exec fails loudly instead of seeing a silently truncated stdin.

func (*ExecInput) Descriptor deprecated

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

Deprecated: Use ExecInput.ProtoReflect.Descriptor instead.

func (*ExecInput) GetChunk

func (x *ExecInput) GetChunk() []byte

func (*ExecInput) GetEof

func (x *ExecInput) GetEof() bool

func (*ExecInput) GetError

func (x *ExecInput) GetError() string

func (*ExecInput) GetExecId

func (x *ExecInput) GetExecId() string

func (*ExecInput) ProtoMessage

func (*ExecInput) ProtoMessage()

func (*ExecInput) ProtoReflect

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

func (*ExecInput) Reset

func (x *ExecInput) Reset()

func (*ExecInput) String

func (x *ExecInput) String() string

type ExecOutput

type ExecOutput struct {
	ExecId  string       `protobuf:"bytes,1,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Chunk   []byte       `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Eof     bool         `protobuf:"varint,3,opt,name=eof,proto3" json:"eof,omitempty"`
	Failure *ExecFailure `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

ExecOutput is one stdout frame for an in-flight exec, or that stream's terminal frame. A data frame sets chunk; the terminal frame sets either eof (the command's output ended cleanly) or failure. Exactly one terminal frame is ever sent per exec.

func (*ExecOutput) Descriptor deprecated

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

Deprecated: Use ExecOutput.ProtoReflect.Descriptor instead.

func (*ExecOutput) GetChunk

func (x *ExecOutput) GetChunk() []byte

func (*ExecOutput) GetEof

func (x *ExecOutput) GetEof() bool

func (*ExecOutput) GetExecId

func (x *ExecOutput) GetExecId() string

func (*ExecOutput) GetFailure

func (x *ExecOutput) GetFailure() *ExecFailure

func (*ExecOutput) ProtoMessage

func (*ExecOutput) ProtoMessage()

func (*ExecOutput) ProtoReflect

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

func (*ExecOutput) Reset

func (x *ExecOutput) Reset()

func (*ExecOutput) String

func (x *ExecOutput) String() string

type ExecRequest

type ExecRequest struct {
	ContainerId string   `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Cmd         []string `protobuf:"bytes,2,rep,name=cmd,proto3" json:"cmd,omitempty"`
	// AttachStdin selects docker.Runtime.ExecWithInput over Exec: the
	// control plane then streams ExecInput frames for the same exec_id.
	AttachStdin bool `protobuf:"varint,3,opt,name=attach_stdin,json=attachStdin,proto3" json:"attach_stdin,omitempty"`
	// Tty selects docker.TTYRuntime.ExecTTY instead: the command runs on
	// a real PTY, its output frames carry stdout and stderr already
	// merged the way a terminal merges them, and the control plane may
	// send ExecResize frames for the same exec_id. Implies attach_stdin.
	Tty bool `protobuf:"varint,4,opt,name=tty,proto3" json:"tty,omitempty"`
	// TtySize is the PTY's initial size, meaningful only when tty is set.
	TtySize *ExecTTYSize `protobuf:"bytes,5,opt,name=tty_size,json=ttySize,proto3" json:"tty_size,omitempty"`
	// Env is extra environment for the exec'd process, on top of whatever
	// the container itself was created with. A terminal needs TERM here.
	Env []string `protobuf:"bytes,6,rep,name=env,proto3" json:"env,omitempty"`
	// contains filtered or unexported fields
}

ExecRequest runs cmd inside an already-running container and streams its stdout back as ExecOutput frames tagged with this request's own request_id. The AgentResponse for this request is only an acknowledgment that the exec attached (or the error that stopped it from attaching); output arrives afterwards, frame by frame, exactly as docker.Runtime.Exec's returned io.ReadCloser produces it locally.

func (*ExecRequest) Descriptor deprecated

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

Deprecated: Use ExecRequest.ProtoReflect.Descriptor instead.

func (*ExecRequest) GetAttachStdin

func (x *ExecRequest) GetAttachStdin() bool

func (*ExecRequest) GetCmd

func (x *ExecRequest) GetCmd() []string

func (*ExecRequest) GetContainerId

func (x *ExecRequest) GetContainerId() string

func (*ExecRequest) GetEnv

func (x *ExecRequest) GetEnv() []string

func (*ExecRequest) GetTty

func (x *ExecRequest) GetTty() bool

func (*ExecRequest) GetTtySize

func (x *ExecRequest) GetTtySize() *ExecTTYSize

func (*ExecRequest) ProtoMessage

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) ProtoReflect

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

func (*ExecRequest) Reset

func (x *ExecRequest) Reset()

func (*ExecRequest) String

func (x *ExecRequest) String() string

type ExecResize

type ExecResize struct {
	ExecId string `protobuf:"bytes,1,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Rows   uint32 `protobuf:"varint,2,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols   uint32 `protobuf:"varint,3,opt,name=cols,proto3" json:"cols,omitempty"`
	// contains filtered or unexported fields
}

ExecResize tells the agent that a TTY exec's terminal changed size, so the process inside sees a SIGWINCH and redraws. Ignored for an exec that did not ask for a PTY.

func (*ExecResize) Descriptor deprecated

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

Deprecated: Use ExecResize.ProtoReflect.Descriptor instead.

func (*ExecResize) GetCols

func (x *ExecResize) GetCols() uint32

func (*ExecResize) GetExecId

func (x *ExecResize) GetExecId() string

func (*ExecResize) GetRows

func (x *ExecResize) GetRows() uint32

func (*ExecResize) ProtoMessage

func (*ExecResize) ProtoMessage()

func (*ExecResize) ProtoReflect

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

func (*ExecResize) Reset

func (x *ExecResize) Reset()

func (*ExecResize) String

func (x *ExecResize) String() string

type ExecTTYSize

type ExecTTYSize struct {
	Rows uint32 `protobuf:"varint,1,opt,name=rows,proto3" json:"rows,omitempty"`
	Cols uint32 `protobuf:"varint,2,opt,name=cols,proto3" json:"cols,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecTTYSize) Descriptor deprecated

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

Deprecated: Use ExecTTYSize.ProtoReflect.Descriptor instead.

func (*ExecTTYSize) GetCols

func (x *ExecTTYSize) GetCols() uint32

func (*ExecTTYSize) GetRows

func (x *ExecTTYSize) GetRows() uint32

func (*ExecTTYSize) ProtoMessage

func (*ExecTTYSize) ProtoMessage()

func (*ExecTTYSize) ProtoReflect

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

func (*ExecTTYSize) Reset

func (x *ExecTTYSize) Reset()

func (*ExecTTYSize) String

func (x *ExecTTYSize) String() string

type ImageInfo

type ImageInfo struct {
	Tag       string                 `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ImageInfo) Descriptor deprecated

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

Deprecated: Use ImageInfo.ProtoReflect.Descriptor instead.

func (*ImageInfo) GetCreatedAt

func (x *ImageInfo) GetCreatedAt() *timestamppb.Timestamp

func (*ImageInfo) GetTag

func (x *ImageInfo) GetTag() string

func (*ImageInfo) ProtoMessage

func (*ImageInfo) ProtoMessage()

func (*ImageInfo) ProtoReflect

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

func (*ImageInfo) Reset

func (x *ImageInfo) Reset()

func (*ImageInfo) String

func (x *ImageInfo) String() string

type InspectByNameRequest

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

func (*InspectByNameRequest) Descriptor deprecated

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

Deprecated: Use InspectByNameRequest.ProtoReflect.Descriptor instead.

func (*InspectByNameRequest) GetName

func (x *InspectByNameRequest) GetName() string

func (*InspectByNameRequest) ProtoMessage

func (*InspectByNameRequest) ProtoMessage()

func (*InspectByNameRequest) ProtoReflect

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

func (*InspectByNameRequest) Reset

func (x *InspectByNameRequest) Reset()

func (*InspectByNameRequest) String

func (x *InspectByNameRequest) String() string

type InspectByNameResponse

type InspectByNameResponse struct {

	// Found is false when internal/docker.Runtime.InspectByName's own
	// (nil, nil) "not found, not an error" contract applies: state below
	// is then unset, not a zero-valued ContainerState pretending to be a
	// real one.
	Found bool            `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
	State *ContainerState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*InspectByNameResponse) Descriptor deprecated

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

Deprecated: Use InspectByNameResponse.ProtoReflect.Descriptor instead.

func (*InspectByNameResponse) GetFound

func (x *InspectByNameResponse) GetFound() bool

func (*InspectByNameResponse) GetState

func (x *InspectByNameResponse) GetState() *ContainerState

func (*InspectByNameResponse) ProtoMessage

func (*InspectByNameResponse) ProtoMessage()

func (*InspectByNameResponse) ProtoReflect

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

func (*InspectByNameResponse) Reset

func (x *InspectByNameResponse) Reset()

func (*InspectByNameResponse) String

func (x *InspectByNameResponse) String() string

type ListByPrefixRequest

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

func (*ListByPrefixRequest) Descriptor deprecated

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

Deprecated: Use ListByPrefixRequest.ProtoReflect.Descriptor instead.

func (*ListByPrefixRequest) GetPrefix

func (x *ListByPrefixRequest) GetPrefix() string

func (*ListByPrefixRequest) ProtoMessage

func (*ListByPrefixRequest) ProtoMessage()

func (*ListByPrefixRequest) ProtoReflect

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

func (*ListByPrefixRequest) Reset

func (x *ListByPrefixRequest) Reset()

func (*ListByPrefixRequest) String

func (x *ListByPrefixRequest) String() string

type ListByPrefixResponse

type ListByPrefixResponse struct {
	Containers []*ContainerState `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListByPrefixResponse) Descriptor deprecated

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

Deprecated: Use ListByPrefixResponse.ProtoReflect.Descriptor instead.

func (*ListByPrefixResponse) GetContainers

func (x *ListByPrefixResponse) GetContainers() []*ContainerState

func (*ListByPrefixResponse) ProtoMessage

func (*ListByPrefixResponse) ProtoMessage()

func (*ListByPrefixResponse) ProtoReflect

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

func (*ListByPrefixResponse) Reset

func (x *ListByPrefixResponse) Reset()

func (*ListByPrefixResponse) String

func (x *ListByPrefixResponse) String() string

type ListImagesRequest

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

func (*ListImagesRequest) Descriptor deprecated

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

Deprecated: Use ListImagesRequest.ProtoReflect.Descriptor instead.

func (*ListImagesRequest) GetRepo

func (x *ListImagesRequest) GetRepo() string

func (*ListImagesRequest) ProtoMessage

func (*ListImagesRequest) ProtoMessage()

func (*ListImagesRequest) ProtoReflect

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

func (*ListImagesRequest) Reset

func (x *ListImagesRequest) Reset()

func (*ListImagesRequest) String

func (x *ListImagesRequest) String() string

type ListImagesResponse

type ListImagesResponse struct {
	Images []*ImageInfo `protobuf:"bytes,1,rep,name=images,proto3" json:"images,omitempty"`
	// contains filtered or unexported fields
}

func (*ListImagesResponse) Descriptor deprecated

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

Deprecated: Use ListImagesResponse.ProtoReflect.Descriptor instead.

func (*ListImagesResponse) GetImages

func (x *ListImagesResponse) GetImages() []*ImageInfo

func (*ListImagesResponse) ProtoMessage

func (*ListImagesResponse) ProtoMessage()

func (*ListImagesResponse) ProtoReflect

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

func (*ListImagesResponse) Reset

func (x *ListImagesResponse) Reset()

func (*ListImagesResponse) String

func (x *ListImagesResponse) String() string

type ListNetworksByPrefixRequest

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

func (*ListNetworksByPrefixRequest) Descriptor deprecated

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

Deprecated: Use ListNetworksByPrefixRequest.ProtoReflect.Descriptor instead.

func (*ListNetworksByPrefixRequest) GetPrefix

func (x *ListNetworksByPrefixRequest) GetPrefix() string

func (*ListNetworksByPrefixRequest) ProtoMessage

func (*ListNetworksByPrefixRequest) ProtoMessage()

func (*ListNetworksByPrefixRequest) ProtoReflect

func (*ListNetworksByPrefixRequest) Reset

func (x *ListNetworksByPrefixRequest) Reset()

func (*ListNetworksByPrefixRequest) String

func (x *ListNetworksByPrefixRequest) String() string

type ListNetworksByPrefixResponse

type ListNetworksByPrefixResponse struct {
	Networks []*NetworkInfo `protobuf:"bytes,1,rep,name=networks,proto3" json:"networks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNetworksByPrefixResponse) Descriptor deprecated

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

Deprecated: Use ListNetworksByPrefixResponse.ProtoReflect.Descriptor instead.

func (*ListNetworksByPrefixResponse) GetNetworks

func (x *ListNetworksByPrefixResponse) GetNetworks() []*NetworkInfo

func (*ListNetworksByPrefixResponse) ProtoMessage

func (*ListNetworksByPrefixResponse) ProtoMessage()

func (*ListNetworksByPrefixResponse) ProtoReflect

func (*ListNetworksByPrefixResponse) Reset

func (x *ListNetworksByPrefixResponse) Reset()

func (*ListNetworksByPrefixResponse) String

type NetworkInfo

type NetworkInfo struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

NetworkInfo mirrors internal/docker.NetworkInfo.

func (*NetworkInfo) Descriptor deprecated

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

Deprecated: Use NetworkInfo.ProtoReflect.Descriptor instead.

func (*NetworkInfo) GetId

func (x *NetworkInfo) GetId() string

func (*NetworkInfo) GetName

func (x *NetworkInfo) GetName() string

func (*NetworkInfo) ProtoMessage

func (*NetworkInfo) ProtoMessage()

func (*NetworkInfo) ProtoReflect

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

func (*NetworkInfo) Reset

func (x *NetworkInfo) Reset()

func (*NetworkInfo) String

func (x *NetworkInfo) String() string

type PortBinding

type PortBinding struct {
	ContainerPort int32  `protobuf:"varint,1,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
	HostPort      int32  `protobuf:"varint,2,opt,name=host_port,json=hostPort,proto3" json:"host_port,omitempty"`
	Protocol      string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

func (*PortBinding) Descriptor deprecated

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

Deprecated: Use PortBinding.ProtoReflect.Descriptor instead.

func (*PortBinding) GetContainerPort

func (x *PortBinding) GetContainerPort() int32

func (*PortBinding) GetHostPort

func (x *PortBinding) GetHostPort() int32

func (*PortBinding) GetProtocol

func (x *PortBinding) GetProtocol() string

func (*PortBinding) ProtoMessage

func (*PortBinding) ProtoMessage()

func (*PortBinding) ProtoReflect

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

func (*PortBinding) Reset

func (x *PortBinding) Reset()

func (*PortBinding) String

func (x *PortBinding) String() string

type ProxiedEvent

type ProxiedEvent struct {
	WatchId       string                 `protobuf:"bytes,1,opt,name=watch_id,json=watchId,proto3" json:"watch_id,omitempty"`
	Action        string                 `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"` // internal/docker.EventAction: "start" | "die" | "stop"
	ContainerName string                 `protobuf:"bytes,3,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	Time          *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

ProxiedEvent mirrors internal/docker.Event, relayed unprompted as it happens on the agent's own local WatchEvents stream (ADR 003's event-push design), scoped to the one watch_events call currently active (a fresh watch_id per WatchEventsRequest, so a control plane that starts and stops watching doesn't get events crossed between watches).

func (*ProxiedEvent) Descriptor deprecated

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

Deprecated: Use ProxiedEvent.ProtoReflect.Descriptor instead.

func (*ProxiedEvent) GetAction

func (x *ProxiedEvent) GetAction() string

func (*ProxiedEvent) GetContainerName

func (x *ProxiedEvent) GetContainerName() string

func (*ProxiedEvent) GetTime

func (x *ProxiedEvent) GetTime() *timestamppb.Timestamp

func (*ProxiedEvent) GetWatchId

func (x *ProxiedEvent) GetWatchId() string

func (*ProxiedEvent) ProtoMessage

func (*ProxiedEvent) ProtoMessage()

func (*ProxiedEvent) ProtoReflect

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

func (*ProxiedEvent) Reset

func (x *ProxiedEvent) Reset()

func (*ProxiedEvent) String

func (x *ProxiedEvent) String() string

type RemoveNetworkRequest

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

func (*RemoveNetworkRequest) Descriptor deprecated

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

Deprecated: Use RemoveNetworkRequest.ProtoReflect.Descriptor instead.

func (*RemoveNetworkRequest) GetName

func (x *RemoveNetworkRequest) GetName() string

func (*RemoveNetworkRequest) ProtoMessage

func (*RemoveNetworkRequest) ProtoMessage()

func (*RemoveNetworkRequest) ProtoReflect

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

func (*RemoveNetworkRequest) Reset

func (x *RemoveNetworkRequest) Reset()

func (*RemoveNetworkRequest) String

func (x *RemoveNetworkRequest) String() string

type RemoveRequest

type RemoveRequest struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Force bool   `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRequest) Descriptor deprecated

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetForce

func (x *RemoveRequest) GetForce() bool

func (*RemoveRequest) GetId

func (x *RemoveRequest) GetId() string

func (*RemoveRequest) ProtoMessage

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect

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

func (*RemoveRequest) Reset

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String

func (x *RemoveRequest) String() string

type Resources

type Resources struct {
	MemoryBytes     int64  `protobuf:"varint,1,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	NanoCpus        int64  `protobuf:"varint,2,opt,name=nano_cpus,json=nanoCpus,proto3" json:"nano_cpus,omitempty"`
	SwapMemoryBytes int64  `protobuf:"varint,3,opt,name=swap_memory_bytes,json=swapMemoryBytes,proto3" json:"swap_memory_bytes,omitempty"`
	CpusetCpus      string `protobuf:"bytes,4,opt,name=cpuset_cpus,json=cpusetCpus,proto3" json:"cpuset_cpus,omitempty"`
	// contains filtered or unexported fields
}

func (*Resources) Descriptor deprecated

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetCpusetCpus

func (x *Resources) GetCpusetCpus() string

func (*Resources) GetMemoryBytes

func (x *Resources) GetMemoryBytes() int64

func (*Resources) GetNanoCpus

func (x *Resources) GetNanoCpus() int64

func (*Resources) GetSwapMemoryBytes

func (x *Resources) GetSwapMemoryBytes() int64

func (*Resources) ProtoMessage

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect

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

func (*Resources) Reset

func (x *Resources) Reset()

func (*Resources) String

func (x *Resources) String() string

type StartRequest

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

func (*StartRequest) Descriptor deprecated

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

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) GetId

func (x *StartRequest) GetId() string

func (*StartRequest) ProtoMessage

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect

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

func (*StartRequest) Reset

func (x *StartRequest) Reset()

func (*StartRequest) String

func (x *StartRequest) String() string

type StopRequest

type StopRequest struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TimeoutMs int64  `protobuf:"varint,2,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"` // internal/docker.Runtime.Stop's time.Duration, in milliseconds; negative means wait indefinitely
	// contains filtered or unexported fields
}

func (*StopRequest) Descriptor deprecated

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

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) GetId

func (x *StopRequest) GetId() string

func (*StopRequest) GetTimeoutMs

func (x *StopRequest) GetTimeoutMs() int64

func (*StopRequest) ProtoMessage

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect

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

func (*StopRequest) Reset

func (x *StopRequest) Reset()

func (*StopRequest) String

func (x *StopRequest) String() string

type UnimplementedAgentServiceServer

type UnimplementedAgentServiceServer struct{}

UnimplementedAgentServiceServer 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 (UnimplementedAgentServiceServer) Enroll

func (UnimplementedAgentServiceServer) Session

type UnsafeAgentServiceServer

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

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

type UpdateResourcesRequest

type UpdateResourcesRequest struct {
	Id        string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Resources *Resources `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

UpdateResourcesRequest applies new memory/CPU/swap/cpuset limits to an already-running container in place, via the Engine API's own ContainerUpdate call, without recreating it.

func (*UpdateResourcesRequest) Descriptor deprecated

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

Deprecated: Use UpdateResourcesRequest.ProtoReflect.Descriptor instead.

func (*UpdateResourcesRequest) GetId

func (x *UpdateResourcesRequest) GetId() string

func (*UpdateResourcesRequest) GetResources

func (x *UpdateResourcesRequest) GetResources() *Resources

func (*UpdateResourcesRequest) ProtoMessage

func (*UpdateResourcesRequest) ProtoMessage()

func (*UpdateResourcesRequest) ProtoReflect

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

func (*UpdateResourcesRequest) Reset

func (x *UpdateResourcesRequest) Reset()

func (*UpdateResourcesRequest) String

func (x *UpdateResourcesRequest) String() string

type VolumeMount

type VolumeMount struct {
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ContainerPath string `protobuf:"bytes,2,opt,name=container_path,json=containerPath,proto3" json:"container_path,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMount) Descriptor deprecated

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

Deprecated: Use VolumeMount.ProtoReflect.Descriptor instead.

func (*VolumeMount) GetContainerPath

func (x *VolumeMount) GetContainerPath() string

func (*VolumeMount) GetName

func (x *VolumeMount) GetName() string

func (*VolumeMount) ProtoMessage

func (*VolumeMount) ProtoMessage()

func (*VolumeMount) ProtoReflect

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

func (*VolumeMount) Reset

func (x *VolumeMount) Reset()

func (*VolumeMount) String

func (x *VolumeMount) String() string

type WatchEventsRequest

type WatchEventsRequest struct {
	WatchId string `protobuf:"bytes,1,opt,name=watch_id,json=watchId,proto3" json:"watch_id,omitempty"`
	// contains filtered or unexported fields
}

WatchEventsRequest starts (or, sent a second time with the same watch_id, is meaningless and rejected: one watch per Session, matching internal/docker.Runtime.Events' own "until ctx is cancelled" single-stream contract) the agent's relay of its local Docker event stream as ProxiedEvent frames on the same physical Session stream. There is no corresponding "stop watching" request: the watch runs for the Session's own lifetime, ending only when the stream itself closes, the same lifetime Events(ctx) already ties to ctx cancellation.

func (*WatchEventsRequest) Descriptor deprecated

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

Deprecated: Use WatchEventsRequest.ProtoReflect.Descriptor instead.

func (*WatchEventsRequest) GetWatchId

func (x *WatchEventsRequest) GetWatchId() string

func (*WatchEventsRequest) ProtoMessage

func (*WatchEventsRequest) ProtoMessage()

func (*WatchEventsRequest) ProtoReflect

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

func (*WatchEventsRequest) Reset

func (x *WatchEventsRequest) Reset()

func (*WatchEventsRequest) String

func (x *WatchEventsRequest) String() string

Jump to

Keyboard shortcuts

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