Versions in this module Expand all Collapse all v1 v1.2.6 Apr 5, 2019 v1.2.5 Mar 13, 2019 v1.2.4 Feb 14, 2019 v1.2.3 Feb 6, 2019 v1.2.2 Jan 8, 2019 v1.2.1 Dec 5, 2018 v1.2.1-rc.0 Nov 21, 2018 v1.2.0 Oct 24, 2018 Changes in this version + var ErrIntOverflowShim = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthShim = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterTaskService(srv *ttrpc.Server, svc TaskService) + type CheckpointTaskRequest struct + ID string + Options *google_protobuf.Any + Path string + 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 CloseIORequest struct + ExecID string + ID 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 ConnectRequest struct + ID string + func (*ConnectRequest) Descriptor() ([]byte, []int) + func (*ConnectRequest) ProtoMessage() + func (m *ConnectRequest) Marshal() (dAtA []byte, err error) + func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ConnectRequest) Reset() + func (m *ConnectRequest) Size() (n int) + func (m *ConnectRequest) Unmarshal(dAtA []byte) error + func (this *ConnectRequest) String() string + type ConnectResponse struct + ShimPid uint32 + TaskPid uint32 + Version string + func (*ConnectResponse) Descriptor() ([]byte, []int) + func (*ConnectResponse) ProtoMessage() + func (m *ConnectResponse) Marshal() (dAtA []byte, err error) + func (m *ConnectResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ConnectResponse) Reset() + func (m *ConnectResponse) Size() (n int) + func (m *ConnectResponse) Unmarshal(dAtA []byte) error + func (this *ConnectResponse) String() string + type CreateTaskRequest struct + Bundle string + Checkpoint string + ID string + Options *google_protobuf.Any + ParentCheckpoint string + 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 + 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 DeleteRequest struct + ExecID string + ID string + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) Marshal() (dAtA []byte, err error) + func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) Size() (n int) + func (m *DeleteRequest) Unmarshal(dAtA []byte) error + func (this *DeleteRequest) String() string + type DeleteResponse struct + ExitStatus uint32 + ExitedAt time.Time + 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 ExecProcessRequest struct + ExecID string + ID string + Spec *google_protobuf.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 KillRequest struct + All bool + ExecID string + ID 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 PauseRequest struct + ID string + func (*PauseRequest) Descriptor() ([]byte, []int) + func (*PauseRequest) ProtoMessage() + func (m *PauseRequest) Marshal() (dAtA []byte, err error) + func (m *PauseRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PauseRequest) Reset() + func (m *PauseRequest) Size() (n int) + func (m *PauseRequest) Unmarshal(dAtA []byte) error + func (this *PauseRequest) String() string + type PidsRequest struct + ID string + func (*PidsRequest) Descriptor() ([]byte, []int) + func (*PidsRequest) ProtoMessage() + func (m *PidsRequest) Marshal() (dAtA []byte, err error) + func (m *PidsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PidsRequest) Reset() + func (m *PidsRequest) Size() (n int) + func (m *PidsRequest) Unmarshal(dAtA []byte) error + func (this *PidsRequest) String() string + type PidsResponse struct + Processes []*containerd_v1_types.ProcessInfo + func (*PidsResponse) Descriptor() ([]byte, []int) + func (*PidsResponse) ProtoMessage() + func (m *PidsResponse) Marshal() (dAtA []byte, err error) + func (m *PidsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PidsResponse) Reset() + func (m *PidsResponse) Size() (n int) + func (m *PidsResponse) Unmarshal(dAtA []byte) error + func (this *PidsResponse) String() string + type ResizePtyRequest struct + ExecID string + Height uint32 + ID string + 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 ResumeRequest struct + ID string + func (*ResumeRequest) Descriptor() ([]byte, []int) + func (*ResumeRequest) ProtoMessage() + func (m *ResumeRequest) Marshal() (dAtA []byte, err error) + func (m *ResumeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ResumeRequest) Reset() + func (m *ResumeRequest) Size() (n int) + func (m *ResumeRequest) Unmarshal(dAtA []byte) error + func (this *ResumeRequest) String() string + type ShutdownRequest struct + ID string + Now bool + func (*ShutdownRequest) Descriptor() ([]byte, []int) + func (*ShutdownRequest) ProtoMessage() + func (m *ShutdownRequest) Marshal() (dAtA []byte, err error) + func (m *ShutdownRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ShutdownRequest) Reset() + func (m *ShutdownRequest) Size() (n int) + func (m *ShutdownRequest) Unmarshal(dAtA []byte) error + func (this *ShutdownRequest) String() string + type StartRequest struct + ExecID string + ID 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 StateRequest struct + ExecID string + ID string + func (*StateRequest) Descriptor() ([]byte, []int) + func (*StateRequest) ProtoMessage() + func (m *StateRequest) Marshal() (dAtA []byte, err error) + func (m *StateRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StateRequest) Reset() + func (m *StateRequest) Size() (n int) + func (m *StateRequest) Unmarshal(dAtA []byte) error + func (this *StateRequest) String() string + type StateResponse struct + Bundle string + ExitStatus uint32 + ExitedAt time.Time + ID string + Pid uint32 + Status containerd_v1_types.Status + Stderr string + Stdin string + Stdout string + Terminal bool + func (*StateResponse) Descriptor() ([]byte, []int) + func (*StateResponse) ProtoMessage() + func (m *StateResponse) Marshal() (dAtA []byte, err error) + func (m *StateResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StateResponse) Reset() + func (m *StateResponse) Size() (n int) + func (m *StateResponse) Unmarshal(dAtA []byte) error + func (this *StateResponse) String() string + type StatsRequest struct + ID string + func (*StatsRequest) Descriptor() ([]byte, []int) + func (*StatsRequest) ProtoMessage() + func (m *StatsRequest) Marshal() (dAtA []byte, err error) + func (m *StatsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StatsRequest) Reset() + func (m *StatsRequest) Size() (n int) + func (m *StatsRequest) Unmarshal(dAtA []byte) error + func (this *StatsRequest) String() string + type StatsResponse struct + Stats *google_protobuf.Any + func (*StatsResponse) Descriptor() ([]byte, []int) + func (*StatsResponse) ProtoMessage() + func (m *StatsResponse) Marshal() (dAtA []byte, err error) + func (m *StatsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StatsResponse) Reset() + func (m *StatsResponse) Size() (n int) + func (m *StatsResponse) Unmarshal(dAtA []byte) error + func (this *StatsResponse) String() string + type TaskService interface + Checkpoint func(ctx context.Context, req *CheckpointTaskRequest) (*google_protobuf1.Empty, error) + CloseIO func(ctx context.Context, req *CloseIORequest) (*google_protobuf1.Empty, error) + Connect func(ctx context.Context, req *ConnectRequest) (*ConnectResponse, error) + Create func(ctx context.Context, req *CreateTaskRequest) (*CreateTaskResponse, error) + Delete func(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error) + Exec func(ctx context.Context, req *ExecProcessRequest) (*google_protobuf1.Empty, error) + Kill func(ctx context.Context, req *KillRequest) (*google_protobuf1.Empty, error) + Pause func(ctx context.Context, req *PauseRequest) (*google_protobuf1.Empty, error) + Pids func(ctx context.Context, req *PidsRequest) (*PidsResponse, error) + ResizePty func(ctx context.Context, req *ResizePtyRequest) (*google_protobuf1.Empty, error) + Resume func(ctx context.Context, req *ResumeRequest) (*google_protobuf1.Empty, error) + Shutdown func(ctx context.Context, req *ShutdownRequest) (*google_protobuf1.Empty, error) + Start func(ctx context.Context, req *StartRequest) (*StartResponse, error) + State func(ctx context.Context, req *StateRequest) (*StateResponse, error) + Stats func(ctx context.Context, req *StatsRequest) (*StatsResponse, error) + Update func(ctx context.Context, req *UpdateTaskRequest) (*google_protobuf1.Empty, error) + Wait func(ctx context.Context, req *WaitRequest) (*WaitResponse, error) + func NewTaskClient(client *ttrpc.Client) TaskService + type UpdateTaskRequest struct + ID string + Resources *google_protobuf.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 + ExecID string + ID 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.2.0-rc.2 Oct 16, 2018 v1.2.0-rc.1 Oct 3, 2018 v1.2.0-rc.0 Sep 20, 2018 v1.2.0-beta.2 Aug 28, 2018 v1.2.0-beta.1 Aug 23, 2018 v1.2.0-beta.0 Aug 16, 2018
Go to main page