Versions in this module Expand all Collapse all v1 v1.1.0 Apr 24, 2018 Changes in this version + var ErrIntOverflowTasks = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTasks = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterTasksServer(s *grpc.Server, srv TasksServer) + type CheckpointTaskRequest struct + ContainerID string + Options *google_protobuf1.Any + ParentCheckpoint github_com_opencontainers_go_digest.Digest + func (*CheckpointTaskRequest) Descriptor() ([]byte, []int) + func (*CheckpointTaskRequest) ProtoMessage() + func (m *CheckpointTaskRequest) Marshal() (dAtA []byte, err error) + func (m *CheckpointTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CheckpointTaskRequest) Reset() + func (m *CheckpointTaskRequest) Size() (n int) + func (m *CheckpointTaskRequest) Unmarshal(dAtA []byte) error + func (this *CheckpointTaskRequest) String() string + type CheckpointTaskResponse struct + Descriptors []*containerd_types2.Descriptor + func (*CheckpointTaskResponse) Descriptor() ([]byte, []int) + func (*CheckpointTaskResponse) ProtoMessage() + func (m *CheckpointTaskResponse) Marshal() (dAtA []byte, err error) + func (m *CheckpointTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CheckpointTaskResponse) Reset() + func (m *CheckpointTaskResponse) Size() (n int) + func (m *CheckpointTaskResponse) Unmarshal(dAtA []byte) error + func (this *CheckpointTaskResponse) String() string + type CloseIORequest struct + ContainerID string + ExecID string + Stdin bool + func (*CloseIORequest) Descriptor() ([]byte, []int) + func (*CloseIORequest) ProtoMessage() + func (m *CloseIORequest) Marshal() (dAtA []byte, err error) + func (m *CloseIORequest) MarshalTo(dAtA []byte) (int, error) + func (m *CloseIORequest) Reset() + func (m *CloseIORequest) Size() (n int) + func (m *CloseIORequest) Unmarshal(dAtA []byte) error + func (this *CloseIORequest) String() string + type CreateTaskRequest struct + Checkpoint *containerd_types2.Descriptor + ContainerID string + Options *google_protobuf1.Any + Rootfs []*containerd_types.Mount + Stderr string + Stdin string + Stdout string + Terminal bool + func (*CreateTaskRequest) Descriptor() ([]byte, []int) + func (*CreateTaskRequest) ProtoMessage() + func (m *CreateTaskRequest) Marshal() (dAtA []byte, err error) + func (m *CreateTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CreateTaskRequest) Reset() + func (m *CreateTaskRequest) Size() (n int) + func (m *CreateTaskRequest) Unmarshal(dAtA []byte) error + func (this *CreateTaskRequest) String() string + type CreateTaskResponse struct + ContainerID string + Pid uint32 + func (*CreateTaskResponse) Descriptor() ([]byte, []int) + func (*CreateTaskResponse) ProtoMessage() + func (m *CreateTaskResponse) Marshal() (dAtA []byte, err error) + func (m *CreateTaskResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CreateTaskResponse) Reset() + func (m *CreateTaskResponse) Size() (n int) + func (m *CreateTaskResponse) Unmarshal(dAtA []byte) error + func (this *CreateTaskResponse) String() string + type DeleteProcessRequest struct + ContainerID string + ExecID string + func (*DeleteProcessRequest) Descriptor() ([]byte, []int) + func (*DeleteProcessRequest) ProtoMessage() + func (m *DeleteProcessRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteProcessRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteProcessRequest) Reset() + func (m *DeleteProcessRequest) Size() (n int) + func (m *DeleteProcessRequest) Unmarshal(dAtA []byte) error + func (this *DeleteProcessRequest) String() string + type DeleteResponse struct + ExitStatus uint32 + ExitedAt time.Time + ID string + Pid uint32 + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) Marshal() (dAtA []byte, err error) + func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) Size() (n int) + func (m *DeleteResponse) Unmarshal(dAtA []byte) error + func (this *DeleteResponse) String() string + type DeleteTaskRequest struct + ContainerID string + func (*DeleteTaskRequest) Descriptor() ([]byte, []int) + func (*DeleteTaskRequest) ProtoMessage() + func (m *DeleteTaskRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteTaskRequest) Reset() + func (m *DeleteTaskRequest) Size() (n int) + func (m *DeleteTaskRequest) Unmarshal(dAtA []byte) error + func (this *DeleteTaskRequest) String() string + type ExecProcessRequest struct + ContainerID string + ExecID string + Spec *google_protobuf1.Any + Stderr string + Stdin string + Stdout string + Terminal bool + func (*ExecProcessRequest) Descriptor() ([]byte, []int) + func (*ExecProcessRequest) ProtoMessage() + func (m *ExecProcessRequest) Marshal() (dAtA []byte, err error) + func (m *ExecProcessRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ExecProcessRequest) Reset() + func (m *ExecProcessRequest) Size() (n int) + func (m *ExecProcessRequest) Unmarshal(dAtA []byte) error + func (this *ExecProcessRequest) String() string + type ExecProcessResponse struct + func (*ExecProcessResponse) Descriptor() ([]byte, []int) + func (*ExecProcessResponse) ProtoMessage() + func (m *ExecProcessResponse) Marshal() (dAtA []byte, err error) + func (m *ExecProcessResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ExecProcessResponse) Reset() + func (m *ExecProcessResponse) Size() (n int) + func (m *ExecProcessResponse) Unmarshal(dAtA []byte) error + func (this *ExecProcessResponse) String() string + type GetRequest struct + ContainerID string + ExecID string + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (m *GetRequest) Marshal() (dAtA []byte, err error) + func (m *GetRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRequest) Reset() + func (m *GetRequest) Size() (n int) + func (m *GetRequest) Unmarshal(dAtA []byte) error + func (this *GetRequest) String() string + type GetResponse struct + Process *containerd_v1_types.Process + func (*GetResponse) Descriptor() ([]byte, []int) + func (*GetResponse) ProtoMessage() + func (m *GetResponse) Marshal() (dAtA []byte, err error) + func (m *GetResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetResponse) Reset() + func (m *GetResponse) Size() (n int) + func (m *GetResponse) Unmarshal(dAtA []byte) error + func (this *GetResponse) String() string + type KillRequest struct + All bool + ContainerID string + ExecID string + Signal uint32 + func (*KillRequest) Descriptor() ([]byte, []int) + func (*KillRequest) ProtoMessage() + func (m *KillRequest) Marshal() (dAtA []byte, err error) + func (m *KillRequest) MarshalTo(dAtA []byte) (int, error) + func (m *KillRequest) Reset() + func (m *KillRequest) Size() (n int) + func (m *KillRequest) Unmarshal(dAtA []byte) error + func (this *KillRequest) String() string + type ListPidsRequest struct + ContainerID string + func (*ListPidsRequest) Descriptor() ([]byte, []int) + func (*ListPidsRequest) ProtoMessage() + func (m *ListPidsRequest) Marshal() (dAtA []byte, err error) + func (m *ListPidsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListPidsRequest) Reset() + func (m *ListPidsRequest) Size() (n int) + func (m *ListPidsRequest) Unmarshal(dAtA []byte) error + func (this *ListPidsRequest) String() string + type ListPidsResponse struct + Processes []*containerd_v1_types.ProcessInfo + func (*ListPidsResponse) Descriptor() ([]byte, []int) + func (*ListPidsResponse) ProtoMessage() + func (m *ListPidsResponse) Marshal() (dAtA []byte, err error) + func (m *ListPidsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListPidsResponse) Reset() + func (m *ListPidsResponse) Size() (n int) + func (m *ListPidsResponse) Unmarshal(dAtA []byte) error + func (this *ListPidsResponse) String() string + type ListTasksRequest struct + Filter string + func (*ListTasksRequest) Descriptor() ([]byte, []int) + func (*ListTasksRequest) ProtoMessage() + func (m *ListTasksRequest) Marshal() (dAtA []byte, err error) + func (m *ListTasksRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ListTasksRequest) Reset() + func (m *ListTasksRequest) Size() (n int) + func (m *ListTasksRequest) Unmarshal(dAtA []byte) error + func (this *ListTasksRequest) String() string + type ListTasksResponse struct + Tasks []*containerd_v1_types.Process + func (*ListTasksResponse) Descriptor() ([]byte, []int) + func (*ListTasksResponse) ProtoMessage() + func (m *ListTasksResponse) Marshal() (dAtA []byte, err error) + func (m *ListTasksResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ListTasksResponse) Reset() + func (m *ListTasksResponse) Size() (n int) + func (m *ListTasksResponse) Unmarshal(dAtA []byte) error + func (this *ListTasksResponse) String() string + type MetricsRequest struct + Filters []string + func (*MetricsRequest) Descriptor() ([]byte, []int) + func (*MetricsRequest) ProtoMessage() + func (m *MetricsRequest) Marshal() (dAtA []byte, err error) + func (m *MetricsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MetricsRequest) Reset() + func (m *MetricsRequest) Size() (n int) + func (m *MetricsRequest) Unmarshal(dAtA []byte) error + func (this *MetricsRequest) String() string + type MetricsResponse struct + Metrics []*containerd_types1.Metric + func (*MetricsResponse) Descriptor() ([]byte, []int) + func (*MetricsResponse) ProtoMessage() + func (m *MetricsResponse) Marshal() (dAtA []byte, err error) + func (m *MetricsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *MetricsResponse) Reset() + func (m *MetricsResponse) Size() (n int) + func (m *MetricsResponse) Unmarshal(dAtA []byte) error + func (this *MetricsResponse) String() string + type PauseTaskRequest struct + ContainerID string + func (*PauseTaskRequest) Descriptor() ([]byte, []int) + func (*PauseTaskRequest) ProtoMessage() + func (m *PauseTaskRequest) Marshal() (dAtA []byte, err error) + func (m *PauseTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PauseTaskRequest) Reset() + func (m *PauseTaskRequest) Size() (n int) + func (m *PauseTaskRequest) Unmarshal(dAtA []byte) error + func (this *PauseTaskRequest) String() string + type ResizePtyRequest struct + ContainerID string + ExecID string + Height uint32 + Width uint32 + func (*ResizePtyRequest) Descriptor() ([]byte, []int) + func (*ResizePtyRequest) ProtoMessage() + func (m *ResizePtyRequest) Marshal() (dAtA []byte, err error) + func (m *ResizePtyRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResizePtyRequest) Reset() + func (m *ResizePtyRequest) Size() (n int) + func (m *ResizePtyRequest) Unmarshal(dAtA []byte) error + func (this *ResizePtyRequest) String() string + type ResumeTaskRequest struct + ContainerID string + func (*ResumeTaskRequest) Descriptor() ([]byte, []int) + func (*ResumeTaskRequest) ProtoMessage() + func (m *ResumeTaskRequest) Marshal() (dAtA []byte, err error) + func (m *ResumeTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResumeTaskRequest) Reset() + func (m *ResumeTaskRequest) Size() (n int) + func (m *ResumeTaskRequest) Unmarshal(dAtA []byte) error + func (this *ResumeTaskRequest) String() string + type StartRequest struct + ContainerID string + ExecID string + func (*StartRequest) Descriptor() ([]byte, []int) + func (*StartRequest) ProtoMessage() + func (m *StartRequest) Marshal() (dAtA []byte, err error) + func (m *StartRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StartRequest) Reset() + func (m *StartRequest) Size() (n int) + func (m *StartRequest) Unmarshal(dAtA []byte) error + func (this *StartRequest) String() string + type StartResponse struct + Pid uint32 + func (*StartResponse) Descriptor() ([]byte, []int) + func (*StartResponse) ProtoMessage() + func (m *StartResponse) Marshal() (dAtA []byte, err error) + func (m *StartResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StartResponse) Reset() + func (m *StartResponse) Size() (n int) + func (m *StartResponse) Unmarshal(dAtA []byte) error + func (this *StartResponse) String() string + type TasksClient interface + Checkpoint func(ctx context.Context, in *CheckpointTaskRequest, opts ...grpc.CallOption) (*CheckpointTaskResponse, error) + CloseIO func(ctx context.Context, in *CloseIORequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + Create func(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error) + Delete func(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + DeleteProcess func(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + Exec func(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) + Kill func(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + List func(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error) + ListPids func(ctx context.Context, in *ListPidsRequest, opts ...grpc.CallOption) (*ListPidsResponse, error) + Metrics func(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error) + Pause func(ctx context.Context, in *PauseTaskRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + ResizePty func(ctx context.Context, in *ResizePtyRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + Resume func(ctx context.Context, in *ResumeTaskRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + Start func(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) + Update func(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error) + Wait func(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error) + func NewTasksClient(cc *grpc.ClientConn) TasksClient + type TasksServer interface + Checkpoint func(context.Context, *CheckpointTaskRequest) (*CheckpointTaskResponse, error) + CloseIO func(context.Context, *CloseIORequest) (*google_protobuf.Empty, error) + Create func(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error) + Delete func(context.Context, *DeleteTaskRequest) (*DeleteResponse, error) + DeleteProcess func(context.Context, *DeleteProcessRequest) (*DeleteResponse, error) + Exec func(context.Context, *ExecProcessRequest) (*google_protobuf.Empty, error) + Get func(context.Context, *GetRequest) (*GetResponse, error) + Kill func(context.Context, *KillRequest) (*google_protobuf.Empty, error) + List func(context.Context, *ListTasksRequest) (*ListTasksResponse, error) + ListPids func(context.Context, *ListPidsRequest) (*ListPidsResponse, error) + Metrics func(context.Context, *MetricsRequest) (*MetricsResponse, error) + Pause func(context.Context, *PauseTaskRequest) (*google_protobuf.Empty, error) + ResizePty func(context.Context, *ResizePtyRequest) (*google_protobuf.Empty, error) + Resume func(context.Context, *ResumeTaskRequest) (*google_protobuf.Empty, error) + Start func(context.Context, *StartRequest) (*StartResponse, error) + Update func(context.Context, *UpdateTaskRequest) (*google_protobuf.Empty, error) + Wait func(context.Context, *WaitRequest) (*WaitResponse, error) + type UpdateTaskRequest struct + ContainerID string + Resources *google_protobuf1.Any + func (*UpdateTaskRequest) Descriptor() ([]byte, []int) + func (*UpdateTaskRequest) ProtoMessage() + func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateTaskRequest) Reset() + func (m *UpdateTaskRequest) Size() (n int) + func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error + func (this *UpdateTaskRequest) String() string + type WaitRequest struct + ContainerID string + ExecID string + func (*WaitRequest) Descriptor() ([]byte, []int) + func (*WaitRequest) ProtoMessage() + func (m *WaitRequest) Marshal() (dAtA []byte, err error) + func (m *WaitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WaitRequest) Reset() + func (m *WaitRequest) Size() (n int) + func (m *WaitRequest) Unmarshal(dAtA []byte) error + func (this *WaitRequest) String() string + type WaitResponse struct + ExitStatus uint32 + ExitedAt time.Time + func (*WaitResponse) Descriptor() ([]byte, []int) + func (*WaitResponse) ProtoMessage() + func (m *WaitResponse) Marshal() (dAtA []byte, err error) + func (m *WaitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WaitResponse) Reset() + func (m *WaitResponse) Size() (n int) + func (m *WaitResponse) Unmarshal(dAtA []byte) error + func (this *WaitResponse) String() string v1.1.0-rc.2 Apr 13, 2018 v1.1.0-rc.1 Apr 5, 2018 v1.1.0-rc.0 Mar 27, 2018
Go to main page