Versions in this module Expand all Collapse all v1 v1.4.4 Mar 5, 2021 Changes in this version + var ErrIntOverflowShim = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthShim = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupShim = fmt.Errorf("proto: unexpected end of group") + func RegisterShimService(srv *github_com_containerd_ttrpc.Server, svc ShimService) + type CheckpointTaskRequest struct + Options *types1.Any + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CheckpointTaskRequest) Reset() + func (m *CheckpointTaskRequest) Size() (n int) + func (m *CheckpointTaskRequest) Unmarshal(dAtA []byte) error + func (m *CheckpointTaskRequest) XXX_DiscardUnknown() + func (m *CheckpointTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CheckpointTaskRequest) XXX_Merge(src proto.Message) + func (m *CheckpointTaskRequest) XXX_Size() int + func (m *CheckpointTaskRequest) XXX_Unmarshal(b []byte) error + func (this *CheckpointTaskRequest) String() string + type CloseIORequest struct + ID string + Stdin bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CloseIORequest) Reset() + func (m *CloseIORequest) Size() (n int) + func (m *CloseIORequest) Unmarshal(dAtA []byte) error + func (m *CloseIORequest) XXX_DiscardUnknown() + func (m *CloseIORequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CloseIORequest) XXX_Merge(src proto.Message) + func (m *CloseIORequest) XXX_Size() int + func (m *CloseIORequest) XXX_Unmarshal(b []byte) error + func (this *CloseIORequest) String() string + type CreateTaskRequest struct + Bundle string + Checkpoint string + ID string + Options *types1.Any + ParentCheckpoint string + Rootfs []*types.Mount + Runtime string + Stderr string + Stdin string + Stdout string + Terminal bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateTaskRequest) Reset() + func (m *CreateTaskRequest) Size() (n int) + func (m *CreateTaskRequest) Unmarshal(dAtA []byte) error + func (m *CreateTaskRequest) XXX_DiscardUnknown() + func (m *CreateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateTaskRequest) XXX_Merge(src proto.Message) + func (m *CreateTaskRequest) XXX_Size() int + func (m *CreateTaskRequest) XXX_Unmarshal(b []byte) error + func (this *CreateTaskRequest) String() string + type CreateTaskResponse struct + Pid uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CreateTaskResponse) Reset() + func (m *CreateTaskResponse) Size() (n int) + func (m *CreateTaskResponse) Unmarshal(dAtA []byte) error + func (m *CreateTaskResponse) XXX_DiscardUnknown() + func (m *CreateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateTaskResponse) XXX_Merge(src proto.Message) + func (m *CreateTaskResponse) XXX_Size() int + func (m *CreateTaskResponse) XXX_Unmarshal(b []byte) error + func (this *CreateTaskResponse) String() string + type DeleteProcessRequest struct + ID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteProcessRequest) Reset() + func (m *DeleteProcessRequest) Size() (n int) + func (m *DeleteProcessRequest) Unmarshal(dAtA []byte) error + func (m *DeleteProcessRequest) XXX_DiscardUnknown() + func (m *DeleteProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteProcessRequest) XXX_Merge(src proto.Message) + func (m *DeleteProcessRequest) XXX_Size() int + func (m *DeleteProcessRequest) XXX_Unmarshal(b []byte) error + func (this *DeleteProcessRequest) String() string + type DeleteResponse struct + ExitStatus uint32 + ExitedAt time.Time + Pid uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) Size() (n int) + func (m *DeleteResponse) Unmarshal(dAtA []byte) error + func (m *DeleteResponse) XXX_DiscardUnknown() + func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResponse) XXX_Merge(src proto.Message) + func (m *DeleteResponse) XXX_Size() int + func (m *DeleteResponse) XXX_Unmarshal(b []byte) error + func (this *DeleteResponse) String() string + type ExecProcessRequest struct + ID string + Spec *types1.Any + Stderr string + Stdin string + Stdout string + Terminal bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExecProcessRequest) Reset() + func (m *ExecProcessRequest) Size() (n int) + func (m *ExecProcessRequest) Unmarshal(dAtA []byte) error + func (m *ExecProcessRequest) XXX_DiscardUnknown() + func (m *ExecProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExecProcessRequest) XXX_Merge(src proto.Message) + func (m *ExecProcessRequest) XXX_Size() int + func (m *ExecProcessRequest) XXX_Unmarshal(b []byte) error + func (this *ExecProcessRequest) String() string + type ExecProcessResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExecProcessResponse) Reset() + func (m *ExecProcessResponse) Size() (n int) + func (m *ExecProcessResponse) Unmarshal(dAtA []byte) error + func (m *ExecProcessResponse) XXX_DiscardUnknown() + func (m *ExecProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExecProcessResponse) XXX_Merge(src proto.Message) + func (m *ExecProcessResponse) XXX_Size() int + func (m *ExecProcessResponse) XXX_Unmarshal(b []byte) error + func (this *ExecProcessResponse) String() string + type KillRequest struct + All bool + ID string + Signal uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KillRequest) Reset() + func (m *KillRequest) Size() (n int) + func (m *KillRequest) Unmarshal(dAtA []byte) error + func (m *KillRequest) XXX_DiscardUnknown() + func (m *KillRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KillRequest) XXX_Merge(src proto.Message) + func (m *KillRequest) XXX_Size() int + func (m *KillRequest) XXX_Unmarshal(b []byte) error + func (this *KillRequest) String() string + type ListPidsRequest struct + ID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListPidsRequest) Reset() + func (m *ListPidsRequest) Size() (n int) + func (m *ListPidsRequest) Unmarshal(dAtA []byte) error + func (m *ListPidsRequest) XXX_DiscardUnknown() + func (m *ListPidsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPidsRequest) XXX_Merge(src proto.Message) + func (m *ListPidsRequest) XXX_Size() int + func (m *ListPidsRequest) XXX_Unmarshal(b []byte) error + func (this *ListPidsRequest) String() string + type ListPidsResponse struct + Processes []*task.ProcessInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ListPidsResponse) Reset() + func (m *ListPidsResponse) Size() (n int) + func (m *ListPidsResponse) Unmarshal(dAtA []byte) error + func (m *ListPidsResponse) XXX_DiscardUnknown() + func (m *ListPidsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListPidsResponse) XXX_Merge(src proto.Message) + func (m *ListPidsResponse) XXX_Size() int + func (m *ListPidsResponse) XXX_Unmarshal(b []byte) error + func (this *ListPidsResponse) String() string + type ResizePtyRequest struct + Height uint32 + ID string + Width uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResizePtyRequest) Reset() + func (m *ResizePtyRequest) Size() (n int) + func (m *ResizePtyRequest) Unmarshal(dAtA []byte) error + func (m *ResizePtyRequest) XXX_DiscardUnknown() + func (m *ResizePtyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResizePtyRequest) XXX_Merge(src proto.Message) + func (m *ResizePtyRequest) XXX_Size() int + func (m *ResizePtyRequest) XXX_Unmarshal(b []byte) error + func (this *ResizePtyRequest) String() string + type ShimInfoResponse struct + ShimPid uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShimInfoResponse) Descriptor() ([]byte, []int) + func (*ShimInfoResponse) ProtoMessage() + func (m *ShimInfoResponse) Marshal() (dAtA []byte, err error) + func (m *ShimInfoResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ShimInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ShimInfoResponse) Reset() + func (m *ShimInfoResponse) Size() (n int) + func (m *ShimInfoResponse) Unmarshal(dAtA []byte) error + func (m *ShimInfoResponse) XXX_DiscardUnknown() + func (m *ShimInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShimInfoResponse) XXX_Merge(src proto.Message) + func (m *ShimInfoResponse) XXX_Size() int + func (m *ShimInfoResponse) XXX_Unmarshal(b []byte) error + func (this *ShimInfoResponse) String() string + type ShimService interface + Checkpoint func(ctx context.Context, req *CheckpointTaskRequest) (*types1.Empty, error) + CloseIO func(ctx context.Context, req *CloseIORequest) (*types1.Empty, error) + Create func(ctx context.Context, req *CreateTaskRequest) (*CreateTaskResponse, error) + Delete func(ctx context.Context, req *types1.Empty) (*DeleteResponse, error) + DeleteProcess func(ctx context.Context, req *DeleteProcessRequest) (*DeleteResponse, error) + Exec func(ctx context.Context, req *ExecProcessRequest) (*types1.Empty, error) + Kill func(ctx context.Context, req *KillRequest) (*types1.Empty, error) + ListPids func(ctx context.Context, req *ListPidsRequest) (*ListPidsResponse, error) + Pause func(ctx context.Context, req *types1.Empty) (*types1.Empty, error) + ResizePty func(ctx context.Context, req *ResizePtyRequest) (*types1.Empty, error) + Resume func(ctx context.Context, req *types1.Empty) (*types1.Empty, error) + ShimInfo func(ctx context.Context, req *types1.Empty) (*ShimInfoResponse, error) + Start func(ctx context.Context, req *StartRequest) (*StartResponse, error) + State func(ctx context.Context, req *StateRequest) (*StateResponse, error) + Update func(ctx context.Context, req *UpdateTaskRequest) (*types1.Empty, error) + Wait func(ctx context.Context, req *WaitRequest) (*WaitResponse, error) + func NewShimClient(client *github_com_containerd_ttrpc.Client) ShimService + type StartRequest struct + ID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StartRequest) Reset() + func (m *StartRequest) Size() (n int) + func (m *StartRequest) Unmarshal(dAtA []byte) error + func (m *StartRequest) XXX_DiscardUnknown() + func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StartRequest) XXX_Merge(src proto.Message) + func (m *StartRequest) XXX_Size() int + func (m *StartRequest) XXX_Unmarshal(b []byte) error + func (this *StartRequest) String() string + type StartResponse struct + ID string + Pid uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StartResponse) Reset() + func (m *StartResponse) Size() (n int) + func (m *StartResponse) Unmarshal(dAtA []byte) error + func (m *StartResponse) XXX_DiscardUnknown() + func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StartResponse) XXX_Merge(src proto.Message) + func (m *StartResponse) XXX_Size() int + func (m *StartResponse) XXX_Unmarshal(b []byte) error + func (this *StartResponse) String() string + type StateRequest struct + ID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StateRequest) Reset() + func (m *StateRequest) Size() (n int) + func (m *StateRequest) Unmarshal(dAtA []byte) error + func (m *StateRequest) XXX_DiscardUnknown() + func (m *StateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StateRequest) XXX_Merge(src proto.Message) + func (m *StateRequest) XXX_Size() int + func (m *StateRequest) XXX_Unmarshal(b []byte) error + func (this *StateRequest) String() string + type StateResponse struct + Bundle string + ExitStatus uint32 + ExitedAt time.Time + ID string + Pid uint32 + Status task.Status + Stderr string + Stdin string + Stdout string + Terminal bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StateResponse) Reset() + func (m *StateResponse) Size() (n int) + func (m *StateResponse) Unmarshal(dAtA []byte) error + func (m *StateResponse) XXX_DiscardUnknown() + func (m *StateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StateResponse) XXX_Merge(src proto.Message) + func (m *StateResponse) XXX_Size() int + func (m *StateResponse) XXX_Unmarshal(b []byte) error + func (this *StateResponse) String() string + type UpdateTaskRequest struct + Resources *types1.Any + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateTaskRequest) Reset() + func (m *UpdateTaskRequest) Size() (n int) + func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error + func (m *UpdateTaskRequest) XXX_DiscardUnknown() + func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateTaskRequest) XXX_Merge(src proto.Message) + func (m *UpdateTaskRequest) XXX_Size() int + func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error + func (this *UpdateTaskRequest) String() string + type WaitRequest struct + ID string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitRequest) Reset() + func (m *WaitRequest) Size() (n int) + func (m *WaitRequest) Unmarshal(dAtA []byte) error + func (m *WaitRequest) XXX_DiscardUnknown() + func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitRequest) XXX_Merge(src proto.Message) + func (m *WaitRequest) XXX_Size() int + func (m *WaitRequest) XXX_Unmarshal(b []byte) error + func (this *WaitRequest) String() string + type WaitResponse struct + ExitStatus uint32 + ExitedAt time.Time + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WaitResponse) Reset() + func (m *WaitResponse) Size() (n int) + func (m *WaitResponse) Unmarshal(dAtA []byte) error + func (m *WaitResponse) XXX_DiscardUnknown() + func (m *WaitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WaitResponse) XXX_Merge(src proto.Message) + func (m *WaitResponse) XXX_Size() int + func (m *WaitResponse) XXX_Unmarshal(b []byte) error + func (this *WaitResponse) String() string