Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)
- type AgentMessage
- func (*AgentMessage) Descriptor() ([]byte, []int)deprecated
- func (x *AgentMessage) GetBuildCredit() *BuildCredit
- func (x *AgentMessage) GetBuildOutput() *BuildOutput
- func (x *AgentMessage) GetEvent() *ProxiedEvent
- func (x *AgentMessage) GetExecCredit() *ExecCredit
- func (x *AgentMessage) GetExecOutput() *ExecOutput
- func (x *AgentMessage) GetPayload() isAgentMessage_Payload
- func (x *AgentMessage) GetResponse() *AgentResponse
- func (*AgentMessage) ProtoMessage()
- func (x *AgentMessage) ProtoReflect() protoreflect.Message
- func (x *AgentMessage) Reset()
- func (x *AgentMessage) String() string
- type AgentMessage_BuildCredit
- type AgentMessage_BuildOutput
- type AgentMessage_Event
- type AgentMessage_ExecCredit
- type AgentMessage_ExecOutput
- type AgentMessage_Response
- type AgentRequest
- func (*AgentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AgentRequest) GetBuild() *BuildRequest
- func (x *AgentRequest) GetCreate() *CreateRequest
- func (x *AgentRequest) GetEnsureNetwork() *EnsureNetworkRequest
- func (x *AgentRequest) GetEnsureVolume() *EnsureVolumeRequest
- func (x *AgentRequest) GetExec() *ExecRequest
- func (x *AgentRequest) GetInspectByName() *InspectByNameRequest
- func (x *AgentRequest) GetListByPrefix() *ListByPrefixRequest
- func (x *AgentRequest) GetListImages() *ListImagesRequest
- func (x *AgentRequest) GetListNetworksByPrefix() *ListNetworksByPrefixRequest
- func (x *AgentRequest) GetOp() isAgentRequest_Op
- func (x *AgentRequest) GetRemove() *RemoveRequest
- func (x *AgentRequest) GetRemoveNetwork() *RemoveNetworkRequest
- func (x *AgentRequest) GetRequestId() string
- func (x *AgentRequest) GetStart() *StartRequest
- func (x *AgentRequest) GetStop() *StopRequest
- func (x *AgentRequest) GetUpdateResources() *UpdateResourcesRequest
- func (x *AgentRequest) GetWatchEvents() *WatchEventsRequest
- func (*AgentRequest) ProtoMessage()
- func (x *AgentRequest) ProtoReflect() protoreflect.Message
- func (x *AgentRequest) Reset()
- func (x *AgentRequest) String() string
- type AgentRequest_Build
- type AgentRequest_Create
- type AgentRequest_EnsureNetwork
- type AgentRequest_EnsureVolume
- type AgentRequest_Exec
- type AgentRequest_InspectByName
- type AgentRequest_ListByPrefix
- type AgentRequest_ListImages
- type AgentRequest_ListNetworksByPrefix
- type AgentRequest_Remove
- type AgentRequest_RemoveNetwork
- type AgentRequest_Start
- type AgentRequest_Stop
- type AgentRequest_UpdateResources
- type AgentRequest_WatchEvents
- type AgentResponse
- func (*AgentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AgentResponse) GetCreate() *CreateResponse
- func (x *AgentResponse) GetEmpty() *Empty
- func (x *AgentResponse) GetEnsureNetwork() *EnsureNetworkResponse
- func (x *AgentResponse) GetError() string
- func (x *AgentResponse) GetInspectByName() *InspectByNameResponse
- func (x *AgentResponse) GetListByPrefix() *ListByPrefixResponse
- func (x *AgentResponse) GetListImages() *ListImagesResponse
- func (x *AgentResponse) GetListNetworksByPrefix() *ListNetworksByPrefixResponse
- func (x *AgentResponse) GetRequestId() string
- func (x *AgentResponse) GetResult() isAgentResponse_Result
- func (*AgentResponse) ProtoMessage()
- func (x *AgentResponse) ProtoReflect() protoreflect.Message
- func (x *AgentResponse) Reset()
- func (x *AgentResponse) String() string
- type AgentResponse_Create
- type AgentResponse_Empty
- type AgentResponse_EnsureNetwork
- type AgentResponse_InspectByName
- type AgentResponse_ListByPrefix
- type AgentResponse_ListImages
- type AgentResponse_ListNetworksByPrefix
- type AgentServiceClient
- type AgentServiceServer
- type AgentService_SessionClient
- type AgentService_SessionServer
- type BuildCache
- func (*BuildCache) Descriptor() ([]byte, []int)deprecated
- func (x *BuildCache) GetRegistryInsecure() bool
- func (x *BuildCache) GetRegistryRef() string
- func (*BuildCache) ProtoMessage()
- func (x *BuildCache) ProtoReflect() protoreflect.Message
- func (x *BuildCache) Reset()
- func (x *BuildCache) String() string
- type BuildCancel
- type BuildCredit
- func (*BuildCredit) Descriptor() ([]byte, []int)deprecated
- func (x *BuildCredit) GetBuildId() string
- func (x *BuildCredit) GetFrames() uint32
- func (*BuildCredit) ProtoMessage()
- func (x *BuildCredit) ProtoReflect() protoreflect.Message
- func (x *BuildCredit) Reset()
- func (x *BuildCredit) String() string
- type BuildDone
- func (*BuildDone) Descriptor() ([]byte, []int)deprecated
- func (x *BuildDone) GetDurationMs() int64
- func (x *BuildDone) GetExporterResponse() map[string]string
- func (*BuildDone) ProtoMessage()
- func (x *BuildDone) ProtoReflect() protoreflect.Message
- func (x *BuildDone) Reset()
- func (x *BuildDone) String() string
- type BuildFailure
- func (*BuildFailure) Descriptor() ([]byte, []int)deprecated
- func (x *BuildFailure) GetMessage() string
- func (x *BuildFailure) GetProvider() string
- func (x *BuildFailure) GetUnsupportedProvider() bool
- func (*BuildFailure) ProtoMessage()
- func (x *BuildFailure) ProtoReflect() protoreflect.Message
- func (x *BuildFailure) Reset()
- func (x *BuildFailure) String() string
- type BuildInput
- func (*BuildInput) Descriptor() ([]byte, []int)deprecated
- func (x *BuildInput) GetBuildId() string
- func (x *BuildInput) GetChunk() []byte
- func (x *BuildInput) GetEof() bool
- func (x *BuildInput) GetError() string
- func (*BuildInput) ProtoMessage()
- func (x *BuildInput) ProtoReflect() protoreflect.Message
- func (x *BuildInput) Reset()
- func (x *BuildInput) String() string
- type BuildKind
- type BuildOutput
- func (*BuildOutput) Descriptor() ([]byte, []int)deprecated
- func (x *BuildOutput) GetBuildId() string
- func (x *BuildOutput) GetDone() *BuildDone
- func (x *BuildOutput) GetFailure() *BuildFailure
- func (x *BuildOutput) GetFrame() isBuildOutput_Frame
- func (x *BuildOutput) GetImageChunk() []byte
- func (x *BuildOutput) GetProgress() *BuildProgress
- func (*BuildOutput) ProtoMessage()
- func (x *BuildOutput) ProtoReflect() protoreflect.Message
- func (x *BuildOutput) Reset()
- func (x *BuildOutput) String() string
- type BuildOutput_Done
- type BuildOutput_Failure
- type BuildOutput_ImageChunk
- type BuildOutput_Progress
- type BuildProgress
- func (*BuildProgress) Descriptor() ([]byte, []int)deprecated
- func (x *BuildProgress) GetCached() bool
- func (x *BuildProgress) GetCompleted() bool
- func (x *BuildProgress) GetError() string
- func (x *BuildProgress) GetLog() string
- func (x *BuildProgress) GetStep() string
- func (x *BuildProgress) GetStream() string
- func (*BuildProgress) ProtoMessage()
- func (x *BuildProgress) ProtoReflect() protoreflect.Message
- func (x *BuildProgress) Reset()
- func (x *BuildProgress) String() string
- type BuildRequest
- func (*BuildRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BuildRequest) GetBuildArgs() map[string]string
- func (x *BuildRequest) GetCache() *BuildCache
- func (x *BuildRequest) GetDockerfilePath() string
- func (x *BuildRequest) GetKind() BuildKind
- func (x *BuildRequest) GetNoCache() bool
- func (x *BuildRequest) GetTag() string
- func (x *BuildRequest) GetTarget() string
- func (*BuildRequest) ProtoMessage()
- func (x *BuildRequest) ProtoReflect() protoreflect.Message
- func (x *BuildRequest) Reset()
- func (x *BuildRequest) String() string
- type ContainerSpec
- func (*ContainerSpec) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerSpec) GetDns() []string
- func (x *ContainerSpec) GetEnv() map[string]string
- func (x *ContainerSpec) GetImage() string
- func (x *ContainerSpec) GetName() string
- func (x *ContainerSpec) GetPorts() []*PortBinding
- func (x *ContainerSpec) GetResources() *Resources
- func (x *ContainerSpec) GetVolumes() []*VolumeMount
- func (*ContainerSpec) ProtoMessage()
- func (x *ContainerSpec) ProtoReflect() protoreflect.Message
- func (x *ContainerSpec) Reset()
- func (x *ContainerSpec) String() string
- type ContainerState
- func (*ContainerState) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerState) GetId() string
- func (x *ContainerState) GetImage() string
- func (x *ContainerState) GetName() string
- func (x *ContainerState) GetPorts() []*PortBinding
- func (x *ContainerState) GetRunning() bool
- func (*ContainerState) ProtoMessage()
- func (x *ContainerState) ProtoReflect() protoreflect.Message
- func (x *ContainerState) Reset()
- func (x *ContainerState) String() string
- type ControlMessage
- func (*ControlMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ControlMessage) GetBuildCancel() *BuildCancel
- func (x *ControlMessage) GetBuildCredit() *BuildCredit
- func (x *ControlMessage) GetBuildInput() *BuildInput
- func (x *ControlMessage) GetExecCancel() *ExecCancel
- func (x *ControlMessage) GetExecCredit() *ExecCredit
- func (x *ControlMessage) GetExecInput() *ExecInput
- func (x *ControlMessage) GetExecResize() *ExecResize
- func (x *ControlMessage) GetPayload() isControlMessage_Payload
- func (x *ControlMessage) GetRequest() *AgentRequest
- func (*ControlMessage) ProtoMessage()
- func (x *ControlMessage) ProtoReflect() protoreflect.Message
- func (x *ControlMessage) Reset()
- func (x *ControlMessage) String() string
- type ControlMessage_BuildCancel
- type ControlMessage_BuildCredit
- type ControlMessage_BuildInput
- type ControlMessage_ExecCancel
- type ControlMessage_ExecCredit
- type ControlMessage_ExecInput
- type ControlMessage_ExecResize
- type ControlMessage_Request
- type CreateRequest
- type CreateResponse
- type Empty
- type EnrollRequest
- func (*EnrollRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnrollRequest) GetJoinToken() string
- func (x *EnrollRequest) GetNodeName() string
- func (*EnrollRequest) ProtoMessage()
- func (x *EnrollRequest) ProtoReflect() protoreflect.Message
- func (x *EnrollRequest) Reset()
- func (x *EnrollRequest) String() string
- type EnrollResponse
- func (*EnrollResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EnrollResponse) GetCaCertPem() []byte
- func (x *EnrollResponse) GetClientCertPem() []byte
- func (x *EnrollResponse) GetClientKeyPem() []byte
- func (x *EnrollResponse) GetNodeId() string
- func (*EnrollResponse) ProtoMessage()
- func (x *EnrollResponse) ProtoReflect() protoreflect.Message
- func (x *EnrollResponse) Reset()
- func (x *EnrollResponse) String() string
- type EnsureNetworkRequest
- func (*EnsureNetworkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnsureNetworkRequest) GetName() string
- func (*EnsureNetworkRequest) ProtoMessage()
- func (x *EnsureNetworkRequest) ProtoReflect() protoreflect.Message
- func (x *EnsureNetworkRequest) Reset()
- func (x *EnsureNetworkRequest) String() string
- type EnsureNetworkResponse
- func (*EnsureNetworkResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EnsureNetworkResponse) GetId() string
- func (*EnsureNetworkResponse) ProtoMessage()
- func (x *EnsureNetworkResponse) ProtoReflect() protoreflect.Message
- func (x *EnsureNetworkResponse) Reset()
- func (x *EnsureNetworkResponse) String() string
- type EnsureVolumeRequest
- func (*EnsureVolumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnsureVolumeRequest) GetName() string
- func (*EnsureVolumeRequest) ProtoMessage()
- func (x *EnsureVolumeRequest) ProtoReflect() protoreflect.Message
- func (x *EnsureVolumeRequest) Reset()
- func (x *EnsureVolumeRequest) String() string
- type ExecCancel
- type ExecCredit
- type ExecExit
- func (*ExecExit) Descriptor() ([]byte, []int)deprecated
- func (x *ExecExit) GetCmd() []string
- func (x *ExecExit) GetContainer() string
- func (x *ExecExit) GetExitCode() int32
- func (x *ExecExit) GetStderr() string
- func (*ExecExit) ProtoMessage()
- func (x *ExecExit) ProtoReflect() protoreflect.Message
- func (x *ExecExit) Reset()
- func (x *ExecExit) String() string
- type ExecFailure
- func (*ExecFailure) Descriptor() ([]byte, []int)deprecated
- func (x *ExecFailure) GetExit() *ExecExit
- func (x *ExecFailure) GetMessage() string
- func (*ExecFailure) ProtoMessage()
- func (x *ExecFailure) ProtoReflect() protoreflect.Message
- func (x *ExecFailure) Reset()
- func (x *ExecFailure) String() string
- type ExecInput
- func (*ExecInput) Descriptor() ([]byte, []int)deprecated
- func (x *ExecInput) GetChunk() []byte
- func (x *ExecInput) GetEof() bool
- func (x *ExecInput) GetError() string
- func (x *ExecInput) GetExecId() string
- func (*ExecInput) ProtoMessage()
- func (x *ExecInput) ProtoReflect() protoreflect.Message
- func (x *ExecInput) Reset()
- func (x *ExecInput) String() string
- type ExecOutput
- func (*ExecOutput) Descriptor() ([]byte, []int)deprecated
- func (x *ExecOutput) GetChunk() []byte
- func (x *ExecOutput) GetEof() bool
- func (x *ExecOutput) GetExecId() string
- func (x *ExecOutput) GetFailure() *ExecFailure
- func (*ExecOutput) ProtoMessage()
- func (x *ExecOutput) ProtoReflect() protoreflect.Message
- func (x *ExecOutput) Reset()
- func (x *ExecOutput) String() string
- type ExecRequest
- func (*ExecRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExecRequest) GetAttachStdin() bool
- func (x *ExecRequest) GetCmd() []string
- func (x *ExecRequest) GetContainerId() string
- func (x *ExecRequest) GetEnv() []string
- func (x *ExecRequest) GetTty() bool
- func (x *ExecRequest) GetTtySize() *ExecTTYSize
- func (*ExecRequest) ProtoMessage()
- func (x *ExecRequest) ProtoReflect() protoreflect.Message
- func (x *ExecRequest) Reset()
- func (x *ExecRequest) String() string
- type ExecResize
- func (*ExecResize) Descriptor() ([]byte, []int)deprecated
- func (x *ExecResize) GetCols() uint32
- func (x *ExecResize) GetExecId() string
- func (x *ExecResize) GetRows() uint32
- func (*ExecResize) ProtoMessage()
- func (x *ExecResize) ProtoReflect() protoreflect.Message
- func (x *ExecResize) Reset()
- func (x *ExecResize) String() string
- type ExecTTYSize
- type ImageInfo
- func (*ImageInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ImageInfo) GetCreatedAt() *timestamppb.Timestamp
- func (x *ImageInfo) GetTag() string
- func (*ImageInfo) ProtoMessage()
- func (x *ImageInfo) ProtoReflect() protoreflect.Message
- func (x *ImageInfo) Reset()
- func (x *ImageInfo) String() string
- type InspectByNameRequest
- func (*InspectByNameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InspectByNameRequest) GetName() string
- func (*InspectByNameRequest) ProtoMessage()
- func (x *InspectByNameRequest) ProtoReflect() protoreflect.Message
- func (x *InspectByNameRequest) Reset()
- func (x *InspectByNameRequest) String() string
- type InspectByNameResponse
- func (*InspectByNameResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InspectByNameResponse) GetFound() bool
- func (x *InspectByNameResponse) GetState() *ContainerState
- func (*InspectByNameResponse) ProtoMessage()
- func (x *InspectByNameResponse) ProtoReflect() protoreflect.Message
- func (x *InspectByNameResponse) Reset()
- func (x *InspectByNameResponse) String() string
- type ListByPrefixRequest
- func (*ListByPrefixRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListByPrefixRequest) GetPrefix() string
- func (*ListByPrefixRequest) ProtoMessage()
- func (x *ListByPrefixRequest) ProtoReflect() protoreflect.Message
- func (x *ListByPrefixRequest) Reset()
- func (x *ListByPrefixRequest) String() string
- type ListByPrefixResponse
- func (*ListByPrefixResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListByPrefixResponse) GetContainers() []*ContainerState
- func (*ListByPrefixResponse) ProtoMessage()
- func (x *ListByPrefixResponse) ProtoReflect() protoreflect.Message
- func (x *ListByPrefixResponse) Reset()
- func (x *ListByPrefixResponse) String() string
- type ListImagesRequest
- type ListImagesResponse
- func (*ListImagesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListImagesResponse) GetImages() []*ImageInfo
- func (*ListImagesResponse) ProtoMessage()
- func (x *ListImagesResponse) ProtoReflect() protoreflect.Message
- func (x *ListImagesResponse) Reset()
- func (x *ListImagesResponse) String() string
- type ListNetworksByPrefixRequest
- func (*ListNetworksByPrefixRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListNetworksByPrefixRequest) GetPrefix() string
- func (*ListNetworksByPrefixRequest) ProtoMessage()
- func (x *ListNetworksByPrefixRequest) ProtoReflect() protoreflect.Message
- func (x *ListNetworksByPrefixRequest) Reset()
- func (x *ListNetworksByPrefixRequest) String() string
- type ListNetworksByPrefixResponse
- func (*ListNetworksByPrefixResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListNetworksByPrefixResponse) GetNetworks() []*NetworkInfo
- func (*ListNetworksByPrefixResponse) ProtoMessage()
- func (x *ListNetworksByPrefixResponse) ProtoReflect() protoreflect.Message
- func (x *ListNetworksByPrefixResponse) Reset()
- func (x *ListNetworksByPrefixResponse) String() string
- type NetworkInfo
- type PortBinding
- func (*PortBinding) Descriptor() ([]byte, []int)deprecated
- func (x *PortBinding) GetContainerPort() int32
- func (x *PortBinding) GetHostPort() int32
- func (x *PortBinding) GetProtocol() string
- func (*PortBinding) ProtoMessage()
- func (x *PortBinding) ProtoReflect() protoreflect.Message
- func (x *PortBinding) Reset()
- func (x *PortBinding) String() string
- type ProxiedEvent
- func (*ProxiedEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ProxiedEvent) GetAction() string
- func (x *ProxiedEvent) GetContainerName() string
- func (x *ProxiedEvent) GetTime() *timestamppb.Timestamp
- func (x *ProxiedEvent) GetWatchId() string
- func (*ProxiedEvent) ProtoMessage()
- func (x *ProxiedEvent) ProtoReflect() protoreflect.Message
- func (x *ProxiedEvent) Reset()
- func (x *ProxiedEvent) String() string
- type RemoveNetworkRequest
- func (*RemoveNetworkRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveNetworkRequest) GetName() string
- func (*RemoveNetworkRequest) ProtoMessage()
- func (x *RemoveNetworkRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveNetworkRequest) Reset()
- func (x *RemoveNetworkRequest) String() string
- type RemoveRequest
- func (*RemoveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveRequest) GetForce() bool
- func (x *RemoveRequest) GetId() string
- func (*RemoveRequest) ProtoMessage()
- func (x *RemoveRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveRequest) Reset()
- func (x *RemoveRequest) String() string
- type Resources
- func (*Resources) Descriptor() ([]byte, []int)deprecated
- func (x *Resources) GetCpusetCpus() string
- func (x *Resources) GetMemoryBytes() int64
- func (x *Resources) GetNanoCpus() int64
- func (x *Resources) GetSwapMemoryBytes() int64
- func (*Resources) ProtoMessage()
- func (x *Resources) ProtoReflect() protoreflect.Message
- func (x *Resources) Reset()
- func (x *Resources) String() string
- type StartRequest
- type StopRequest
- type UnimplementedAgentServiceServer
- type UnsafeAgentServiceServer
- type UpdateResourcesRequest
- func (*UpdateResourcesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateResourcesRequest) GetId() string
- func (x *UpdateResourcesRequest) GetResources() *Resources
- func (*UpdateResourcesRequest) ProtoMessage()
- func (x *UpdateResourcesRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateResourcesRequest) Reset()
- func (x *UpdateResourcesRequest) String() string
- type VolumeMount
- func (*VolumeMount) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeMount) GetContainerPath() string
- func (x *VolumeMount) GetName() string
- func (*VolumeMount) ProtoMessage()
- func (x *VolumeMount) ProtoReflect() protoreflect.Message
- func (x *VolumeMount) Reset()
- func (x *VolumeMount) String() string
- type WatchEventsRequest
- func (*WatchEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchEventsRequest) GetWatchId() string
- func (*WatchEventsRequest) ProtoMessage()
- func (x *WatchEventsRequest) ProtoReflect() protoreflect.Message
- func (x *WatchEventsRequest) Reset()
- func (x *WatchEventsRequest) String() string
Constants ¶
const ( AgentService_Enroll_FullMethodName = "/levelrail.agent.v1.AgentService/Enroll" AgentService_Session_FullMethodName = "/levelrail.agent.v1.AgentService/Session" )
Variables ¶
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.
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)
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.
func NewAgentServiceClient ¶
func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient
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) GetDurationMs ¶
func (*BuildDone) GetExporterResponse ¶
func (*BuildDone) ProtoMessage ¶
func (*BuildDone) ProtoMessage()
func (*BuildDone) ProtoReflect ¶
func (x *BuildDone) ProtoReflect() protoreflect.Message
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
func (BuildKind) Descriptor ¶
func (BuildKind) Descriptor() protoreflect.EnumDescriptor
func (BuildKind) EnumDescriptor
deprecated
func (BuildKind) Number ¶
func (x BuildKind) Number() protoreflect.EnumNumber
func (BuildKind) Type ¶
func (BuildKind) Type() protoreflect.EnumType
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) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
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) GetContainer ¶
func (*ExecExit) GetExitCode ¶
func (*ExecExit) ProtoMessage ¶
func (*ExecExit) ProtoMessage()
func (*ExecExit) ProtoReflect ¶
func (x *ExecExit) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*ExecInput) ProtoMessage()
func (*ExecInput) ProtoReflect ¶
func (x *ExecInput) ProtoReflect() protoreflect.Message
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) GetCreatedAt ¶
func (x *ImageInfo) GetCreatedAt() *timestamppb.Timestamp
func (*ImageInfo) ProtoMessage ¶
func (*ImageInfo) ProtoMessage()
func (*ImageInfo) ProtoReflect ¶
func (x *ImageInfo) ProtoReflect() protoreflect.Message
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 (x *ListNetworksByPrefixRequest) ProtoReflect() protoreflect.Message
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 (x *ListNetworksByPrefixResponse) ProtoReflect() protoreflect.Message
func (*ListNetworksByPrefixResponse) Reset ¶
func (x *ListNetworksByPrefixResponse) Reset()
func (*ListNetworksByPrefixResponse) String ¶
func (x *ListNetworksByPrefixResponse) String() 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) GetCpusetCpus ¶
func (*Resources) GetMemoryBytes ¶
func (*Resources) GetNanoCpus ¶
func (*Resources) GetSwapMemoryBytes ¶
func (*Resources) ProtoMessage ¶
func (*Resources) ProtoMessage()
func (*Resources) ProtoReflect ¶
func (x *Resources) ProtoReflect() protoreflect.Message
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) Enroll(context.Context, *EnrollRequest) (*EnrollResponse, error)
func (UnimplementedAgentServiceServer) Session ¶
func (UnimplementedAgentServiceServer) Session(grpc.BidiStreamingServer[AgentMessage, ControlMessage]) error
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