Versions in this module Expand all Collapse all v1 v1.8.0-rc.2 May 29, 2024 v1.8.0-rc.1 May 29, 2024 v1.8.0-rc.0 May 6, 2024 v1.7.19 Jun 26, 2024 Changes in this version + var File_github_com_containerd_containerd_api_runtime_task_v3_shim_proto protoreflect.FileDescriptor + var Task_ServiceDesc = grpc.ServiceDesc + func RegisterTTRPCTaskService(srv *ttrpc.Server, svc TTRPCTaskService) + func RegisterTaskServer(s grpc.ServiceRegistrar, srv TaskServer) + type CheckpointTaskRequest struct + ID string + Options *anypb.Any + Path string + func (*CheckpointTaskRequest) Descriptor() ([]byte, []int) + func (*CheckpointTaskRequest) ProtoMessage() + func (x *CheckpointTaskRequest) GetID() string + func (x *CheckpointTaskRequest) GetOptions() *anypb.Any + func (x *CheckpointTaskRequest) GetPath() string + func (x *CheckpointTaskRequest) ProtoReflect() protoreflect.Message + func (x *CheckpointTaskRequest) Reset() + func (x *CheckpointTaskRequest) String() string + type CloseIORequest struct + ExecID string + ID string + Stdin bool + func (*CloseIORequest) Descriptor() ([]byte, []int) + func (*CloseIORequest) ProtoMessage() + func (x *CloseIORequest) GetExecID() string + func (x *CloseIORequest) GetID() string + func (x *CloseIORequest) GetStdin() bool + func (x *CloseIORequest) ProtoReflect() protoreflect.Message + func (x *CloseIORequest) Reset() + func (x *CloseIORequest) String() string + type ConnectRequest struct + ID string + func (*ConnectRequest) Descriptor() ([]byte, []int) + func (*ConnectRequest) ProtoMessage() + func (x *ConnectRequest) GetID() string + func (x *ConnectRequest) ProtoReflect() protoreflect.Message + func (x *ConnectRequest) Reset() + func (x *ConnectRequest) String() string + type ConnectResponse struct + ShimPid uint32 + TaskPid uint32 + Version string + func (*ConnectResponse) Descriptor() ([]byte, []int) + func (*ConnectResponse) ProtoMessage() + func (x *ConnectResponse) GetShimPid() uint32 + func (x *ConnectResponse) GetTaskPid() uint32 + func (x *ConnectResponse) GetVersion() string + func (x *ConnectResponse) ProtoReflect() protoreflect.Message + func (x *ConnectResponse) Reset() + func (x *ConnectResponse) String() string + type CreateTaskRequest struct + Bundle string + Checkpoint string + ID string + Options *anypb.Any + ParentCheckpoint string + Rootfs []*types.Mount + Stderr string + Stdin string + Stdout string + Terminal bool + func (*CreateTaskRequest) Descriptor() ([]byte, []int) + func (*CreateTaskRequest) ProtoMessage() + func (x *CreateTaskRequest) GetBundle() string + func (x *CreateTaskRequest) GetCheckpoint() string + func (x *CreateTaskRequest) GetID() string + func (x *CreateTaskRequest) GetOptions() *anypb.Any + func (x *CreateTaskRequest) GetParentCheckpoint() string + func (x *CreateTaskRequest) GetRootfs() []*types.Mount + func (x *CreateTaskRequest) GetStderr() string + func (x *CreateTaskRequest) GetStdin() string + func (x *CreateTaskRequest) GetStdout() string + func (x *CreateTaskRequest) GetTerminal() bool + func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message + func (x *CreateTaskRequest) Reset() + func (x *CreateTaskRequest) String() string + type CreateTaskResponse struct + Pid uint32 + func (*CreateTaskResponse) Descriptor() ([]byte, []int) + func (*CreateTaskResponse) ProtoMessage() + func (x *CreateTaskResponse) GetPid() uint32 + func (x *CreateTaskResponse) ProtoReflect() protoreflect.Message + func (x *CreateTaskResponse) Reset() + func (x *CreateTaskResponse) String() string + type DeleteRequest struct + ExecID string + ID string + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (x *DeleteRequest) GetExecID() string + func (x *DeleteRequest) GetID() string + func (x *DeleteRequest) ProtoReflect() protoreflect.Message + func (x *DeleteRequest) Reset() + func (x *DeleteRequest) String() string + type DeleteResponse struct + ExitStatus uint32 + ExitedAt *timestamppb.Timestamp + Pid uint32 + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (x *DeleteResponse) GetExitStatus() uint32 + func (x *DeleteResponse) GetExitedAt() *timestamppb.Timestamp + func (x *DeleteResponse) GetPid() uint32 + func (x *DeleteResponse) ProtoReflect() protoreflect.Message + func (x *DeleteResponse) Reset() + func (x *DeleteResponse) String() string + type ExecProcessRequest struct + ExecID string + ID string + Spec *anypb.Any + Stderr string + Stdin string + Stdout string + Terminal bool + func (*ExecProcessRequest) Descriptor() ([]byte, []int) + func (*ExecProcessRequest) ProtoMessage() + func (x *ExecProcessRequest) GetExecID() string + func (x *ExecProcessRequest) GetID() string + func (x *ExecProcessRequest) GetSpec() *anypb.Any + func (x *ExecProcessRequest) GetStderr() string + func (x *ExecProcessRequest) GetStdin() string + func (x *ExecProcessRequest) GetStdout() string + func (x *ExecProcessRequest) GetTerminal() bool + func (x *ExecProcessRequest) ProtoReflect() protoreflect.Message + func (x *ExecProcessRequest) Reset() + func (x *ExecProcessRequest) String() string + type ExecProcessResponse struct + func (*ExecProcessResponse) Descriptor() ([]byte, []int) + func (*ExecProcessResponse) ProtoMessage() + func (x *ExecProcessResponse) ProtoReflect() protoreflect.Message + func (x *ExecProcessResponse) Reset() + func (x *ExecProcessResponse) String() string + type KillRequest struct + All bool + ExecID string + ID string + Signal uint32 + func (*KillRequest) Descriptor() ([]byte, []int) + func (*KillRequest) ProtoMessage() + func (x *KillRequest) GetAll() bool + func (x *KillRequest) GetExecID() string + func (x *KillRequest) GetID() string + func (x *KillRequest) GetSignal() uint32 + func (x *KillRequest) ProtoReflect() protoreflect.Message + func (x *KillRequest) Reset() + func (x *KillRequest) String() string + type PauseRequest struct + ID string + func (*PauseRequest) Descriptor() ([]byte, []int) + func (*PauseRequest) ProtoMessage() + func (x *PauseRequest) GetID() string + func (x *PauseRequest) ProtoReflect() protoreflect.Message + func (x *PauseRequest) Reset() + func (x *PauseRequest) String() string + type PidsRequest struct + ID string + func (*PidsRequest) Descriptor() ([]byte, []int) + func (*PidsRequest) ProtoMessage() + func (x *PidsRequest) GetID() string + func (x *PidsRequest) ProtoReflect() protoreflect.Message + func (x *PidsRequest) Reset() + func (x *PidsRequest) String() string + type PidsResponse struct + Processes []*task.ProcessInfo + func (*PidsResponse) Descriptor() ([]byte, []int) + func (*PidsResponse) ProtoMessage() + func (x *PidsResponse) GetProcesses() []*task.ProcessInfo + func (x *PidsResponse) ProtoReflect() protoreflect.Message + func (x *PidsResponse) Reset() + func (x *PidsResponse) String() string + type ResizePtyRequest struct + ExecID string + Height uint32 + ID string + Width uint32 + func (*ResizePtyRequest) Descriptor() ([]byte, []int) + func (*ResizePtyRequest) ProtoMessage() + func (x *ResizePtyRequest) GetExecID() string + func (x *ResizePtyRequest) GetHeight() uint32 + func (x *ResizePtyRequest) GetID() string + func (x *ResizePtyRequest) GetWidth() uint32 + func (x *ResizePtyRequest) ProtoReflect() protoreflect.Message + func (x *ResizePtyRequest) Reset() + func (x *ResizePtyRequest) String() string + type ResumeRequest struct + ID string + func (*ResumeRequest) Descriptor() ([]byte, []int) + func (*ResumeRequest) ProtoMessage() + func (x *ResumeRequest) GetID() string + func (x *ResumeRequest) ProtoReflect() protoreflect.Message + func (x *ResumeRequest) Reset() + func (x *ResumeRequest) String() string + type ShutdownRequest struct + ID string + Now bool + func (*ShutdownRequest) Descriptor() ([]byte, []int) + func (*ShutdownRequest) ProtoMessage() + func (x *ShutdownRequest) GetID() string + func (x *ShutdownRequest) GetNow() bool + func (x *ShutdownRequest) ProtoReflect() protoreflect.Message + func (x *ShutdownRequest) Reset() + func (x *ShutdownRequest) String() string + type StartRequest struct + ExecID string + ID string + func (*StartRequest) Descriptor() ([]byte, []int) + func (*StartRequest) ProtoMessage() + func (x *StartRequest) GetExecID() string + func (x *StartRequest) GetID() string + func (x *StartRequest) ProtoReflect() protoreflect.Message + func (x *StartRequest) Reset() + func (x *StartRequest) String() string + type StartResponse struct + Pid uint32 + func (*StartResponse) Descriptor() ([]byte, []int) + func (*StartResponse) ProtoMessage() + func (x *StartResponse) GetPid() uint32 + func (x *StartResponse) ProtoReflect() protoreflect.Message + func (x *StartResponse) Reset() + func (x *StartResponse) String() string + type StateRequest struct + ExecID string + ID string + func (*StateRequest) Descriptor() ([]byte, []int) + func (*StateRequest) ProtoMessage() + func (x *StateRequest) GetExecID() string + func (x *StateRequest) GetID() string + func (x *StateRequest) ProtoReflect() protoreflect.Message + func (x *StateRequest) Reset() + func (x *StateRequest) String() string + type StateResponse struct + Bundle string + ExecID string + ExitStatus uint32 + ExitedAt *timestamppb.Timestamp + ID string + Pid uint32 + Status task.Status + Stderr string + Stdin string + Stdout string + Terminal bool + func (*StateResponse) Descriptor() ([]byte, []int) + func (*StateResponse) ProtoMessage() + func (x *StateResponse) GetBundle() string + func (x *StateResponse) GetExecID() string + func (x *StateResponse) GetExitStatus() uint32 + func (x *StateResponse) GetExitedAt() *timestamppb.Timestamp + func (x *StateResponse) GetID() string + func (x *StateResponse) GetPid() uint32 + func (x *StateResponse) GetStatus() task.Status + func (x *StateResponse) GetStderr() string + func (x *StateResponse) GetStdin() string + func (x *StateResponse) GetStdout() string + func (x *StateResponse) GetTerminal() bool + func (x *StateResponse) ProtoReflect() protoreflect.Message + func (x *StateResponse) Reset() + func (x *StateResponse) String() string + type StatsRequest struct + ID string + func (*StatsRequest) Descriptor() ([]byte, []int) + func (*StatsRequest) ProtoMessage() + func (x *StatsRequest) GetID() string + func (x *StatsRequest) ProtoReflect() protoreflect.Message + func (x *StatsRequest) Reset() + func (x *StatsRequest) String() string + type StatsResponse struct + Stats *anypb.Any + func (*StatsResponse) Descriptor() ([]byte, []int) + func (*StatsResponse) ProtoMessage() + func (x *StatsResponse) GetStats() *anypb.Any + func (x *StatsResponse) ProtoReflect() protoreflect.Message + func (x *StatsResponse) Reset() + func (x *StatsResponse) String() string + type TTRPCTaskService interface + Checkpoint func(context.Context, *CheckpointTaskRequest) (*emptypb.Empty, error) + CloseIO func(context.Context, *CloseIORequest) (*emptypb.Empty, error) + Connect func(context.Context, *ConnectRequest) (*ConnectResponse, error) + Create func(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error) + Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error) + Exec func(context.Context, *ExecProcessRequest) (*emptypb.Empty, error) + Kill func(context.Context, *KillRequest) (*emptypb.Empty, error) + Pause func(context.Context, *PauseRequest) (*emptypb.Empty, error) + Pids func(context.Context, *PidsRequest) (*PidsResponse, error) + ResizePty func(context.Context, *ResizePtyRequest) (*emptypb.Empty, error) + Resume func(context.Context, *ResumeRequest) (*emptypb.Empty, error) + Shutdown func(context.Context, *ShutdownRequest) (*emptypb.Empty, error) + Start func(context.Context, *StartRequest) (*StartResponse, error) + State func(context.Context, *StateRequest) (*StateResponse, error) + Stats func(context.Context, *StatsRequest) (*StatsResponse, error) + Update func(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error) + Wait func(context.Context, *WaitRequest) (*WaitResponse, error) + func NewTTRPCTaskClient(client *ttrpc.Client) TTRPCTaskService + type TaskClient interface + Checkpoint func(ctx context.Context, in *CheckpointTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + CloseIO func(ctx context.Context, in *CloseIORequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Connect func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error) + Create func(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + Exec func(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Kill func(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Pause func(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Pids func(ctx context.Context, in *PidsRequest, opts ...grpc.CallOption) (*PidsResponse, error) + ResizePty func(ctx context.Context, in *ResizePtyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Resume func(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Shutdown func(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Start func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) + State func(ctx context.Context, in *StateRequest, opts ...grpc.CallOption) (*StateResponse, error) + Stats func(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error) + Update func(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) + Wait func(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error) + func NewTaskClient(cc grpc.ClientConnInterface) TaskClient + type TaskServer interface + Checkpoint func(context.Context, *CheckpointTaskRequest) (*emptypb.Empty, error) + CloseIO func(context.Context, *CloseIORequest) (*emptypb.Empty, error) + Connect func(context.Context, *ConnectRequest) (*ConnectResponse, error) + Create func(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error) + Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error) + Exec func(context.Context, *ExecProcessRequest) (*emptypb.Empty, error) + Kill func(context.Context, *KillRequest) (*emptypb.Empty, error) + Pause func(context.Context, *PauseRequest) (*emptypb.Empty, error) + Pids func(context.Context, *PidsRequest) (*PidsResponse, error) + ResizePty func(context.Context, *ResizePtyRequest) (*emptypb.Empty, error) + Resume func(context.Context, *ResumeRequest) (*emptypb.Empty, error) + Shutdown func(context.Context, *ShutdownRequest) (*emptypb.Empty, error) + Start func(context.Context, *StartRequest) (*StartResponse, error) + State func(context.Context, *StateRequest) (*StateResponse, error) + Stats func(context.Context, *StatsRequest) (*StatsResponse, error) + Update func(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error) + Wait func(context.Context, *WaitRequest) (*WaitResponse, error) + type UnimplementedTaskServer struct + func (UnimplementedTaskServer) Checkpoint(context.Context, *CheckpointTaskRequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) CloseIO(context.Context, *CloseIORequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error) + func (UnimplementedTaskServer) Create(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error) + func (UnimplementedTaskServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) + func (UnimplementedTaskServer) Exec(context.Context, *ExecProcessRequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) Kill(context.Context, *KillRequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) Pause(context.Context, *PauseRequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) Pids(context.Context, *PidsRequest) (*PidsResponse, error) + func (UnimplementedTaskServer) ResizePty(context.Context, *ResizePtyRequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) Resume(context.Context, *ResumeRequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) Shutdown(context.Context, *ShutdownRequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) Start(context.Context, *StartRequest) (*StartResponse, error) + func (UnimplementedTaskServer) State(context.Context, *StateRequest) (*StateResponse, error) + func (UnimplementedTaskServer) Stats(context.Context, *StatsRequest) (*StatsResponse, error) + func (UnimplementedTaskServer) Update(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error) + func (UnimplementedTaskServer) Wait(context.Context, *WaitRequest) (*WaitResponse, error) + type UnsafeTaskServer interface + type UpdateTaskRequest struct + Annotations map[string]string + ID string + Resources *anypb.Any + func (*UpdateTaskRequest) Descriptor() ([]byte, []int) + func (*UpdateTaskRequest) ProtoMessage() + func (x *UpdateTaskRequest) GetAnnotations() map[string]string + func (x *UpdateTaskRequest) GetID() string + func (x *UpdateTaskRequest) GetResources() *anypb.Any + func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message + func (x *UpdateTaskRequest) Reset() + func (x *UpdateTaskRequest) String() string + type WaitRequest struct + ExecID string + ID string + func (*WaitRequest) Descriptor() ([]byte, []int) + func (*WaitRequest) ProtoMessage() + func (x *WaitRequest) GetExecID() string + func (x *WaitRequest) GetID() string + func (x *WaitRequest) ProtoReflect() protoreflect.Message + func (x *WaitRequest) Reset() + func (x *WaitRequest) String() string + type WaitResponse struct + ExitStatus uint32 + ExitedAt *timestamppb.Timestamp + func (*WaitResponse) Descriptor() ([]byte, []int) + func (*WaitResponse) ProtoMessage() + func (x *WaitResponse) GetExitStatus() uint32 + func (x *WaitResponse) GetExitedAt() *timestamppb.Timestamp + func (x *WaitResponse) ProtoReflect() protoreflect.Message + func (x *WaitResponse) Reset() + func (x *WaitResponse) String() string Other modules containing this package github.com/containerd/containerd github.com/containerd/containerd/v2