agentpb

type AgentMessage struct {

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

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

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

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
	Op isAgentRequest_Op `protobuf_oneof:"op"`
	// contains filtered or unexported fields
}

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

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

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

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

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

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

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

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

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

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

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
	Result isAgentResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

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

type AgentResponse_Empty struct {
	// Start, Stop, Remove, EnsureVolume, 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_InspectByName struct {
	InspectByName *InspectByNameResponse `protobuf:"bytes,3,opt,name=inspect_by_name,json=inspectByName,proto3,oneof"`
}

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

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

type AgentServiceClient interface {
	// Enroll exchanges a one-time join token (internal/store.NodeJoinToken,
	// TASKS.md 3.1) 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)
}

type AgentServiceServer interface {
	// Enroll exchanges a one-time join token (internal/store.NodeJoinToken,
	// TASKS.md 3.1) 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
}

type AgentService_SessionClient = grpc.BidiStreamingClient[AgentMessage, ControlMessage]

type AgentService_SessionServer = grpc.BidiStreamingServer[AgentMessage, ControlMessage]

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
}

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
}

type ControlMessage struct {
	Request *AgentRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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
}

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
}

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

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
}

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

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
}

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

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

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

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

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
}

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
}

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
}

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
}

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

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
}

type UnimplementedAgentServiceServer struct{}

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

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
}

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
}

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