task

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 17, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

This section is empty.

Variables ¶

View Source 
var (
	ErrInvalidLengthShim        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowShim          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupShim = fmt.Errorf("proto: unexpected end of group")
)

Functions ¶

func RegisterTaskService ¶ 

func RegisterTaskService(srv *github_com_containerd_ttrpc.Server, svc TaskService)

Types ¶

type CheckpointTaskRequest ¶ 

type CheckpointTaskRequest struct {
	ID                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Path                 string      `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Options              *types1.Any `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CheckpointTaskRequest) Descriptor ¶ 

func (*CheckpointTaskRequest) Descriptor() ([]byte, []int)

func (*CheckpointTaskRequest) Marshal ¶ 

func (m *CheckpointTaskRequest) Marshal() (dAtA []byte, err error)

func (*CheckpointTaskRequest) MarshalTo ¶ 

func (m *CheckpointTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*CheckpointTaskRequest) MarshalToSizedBuffer ¶ 

func (m *CheckpointTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckpointTaskRequest) ProtoMessage ¶ 

func (*CheckpointTaskRequest) ProtoMessage()

func (*CheckpointTaskRequest) Reset ¶ 

func (m *CheckpointTaskRequest) Reset()

func (*CheckpointTaskRequest) Size ¶ 

func (m *CheckpointTaskRequest) Size() (n int)

func (*CheckpointTaskRequest) String ¶ 

func (this *CheckpointTaskRequest) String() string

func (*CheckpointTaskRequest) Unmarshal ¶ 

func (m *CheckpointTaskRequest) Unmarshal(dAtA []byte) error

func (*CheckpointTaskRequest) XXX_DiscardUnknown ¶ 

func (m *CheckpointTaskRequest) XXX_DiscardUnknown()

func (*CheckpointTaskRequest) XXX_Marshal ¶ 

func (m *CheckpointTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckpointTaskRequest) XXX_Merge ¶ 

func (m *CheckpointTaskRequest) XXX_Merge(src proto.Message)

func (*CheckpointTaskRequest) XXX_Size ¶ 

func (m *CheckpointTaskRequest) XXX_Size() int

func (*CheckpointTaskRequest) XXX_Unmarshal ¶ 

func (m *CheckpointTaskRequest) XXX_Unmarshal(b []byte) error

type CloseIORequest ¶ 

type CloseIORequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Stdin                bool     `protobuf:"varint,3,opt,name=stdin,proto3" json:"stdin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseIORequest) Descriptor ¶ 

func (*CloseIORequest) Descriptor() ([]byte, []int)

func (*CloseIORequest) Marshal ¶ 

func (m *CloseIORequest) Marshal() (dAtA []byte, err error)

func (*CloseIORequest) MarshalTo ¶ 

func (m *CloseIORequest) MarshalTo(dAtA []byte) (int, error)

func (*CloseIORequest) MarshalToSizedBuffer ¶ 

func (m *CloseIORequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CloseIORequest) ProtoMessage ¶ 

func (*CloseIORequest) ProtoMessage()

func (*CloseIORequest) Reset ¶ 

func (m *CloseIORequest) Reset()

func (*CloseIORequest) Size ¶ 

func (m *CloseIORequest) Size() (n int)

func (*CloseIORequest) String ¶ 

func (this *CloseIORequest) String() string

func (*CloseIORequest) Unmarshal ¶ 

func (m *CloseIORequest) Unmarshal(dAtA []byte) error

func (*CloseIORequest) XXX_DiscardUnknown ¶ 

func (m *CloseIORequest) XXX_DiscardUnknown()

func (*CloseIORequest) XXX_Marshal ¶ 

func (m *CloseIORequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseIORequest) XXX_Merge ¶ 

func (m *CloseIORequest) XXX_Merge(src proto.Message)

func (*CloseIORequest) XXX_Size ¶ 

func (m *CloseIORequest) XXX_Size() int

func (*CloseIORequest) XXX_Unmarshal ¶ 

func (m *CloseIORequest) XXX_Unmarshal(b []byte) error

type ConnectRequest ¶ 

type ConnectRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConnectRequest) Descriptor ¶ 

func (*ConnectRequest) Descriptor() ([]byte, []int)

func (*ConnectRequest) Marshal ¶ 

func (m *ConnectRequest) Marshal() (dAtA []byte, err error)

func (*ConnectRequest) MarshalTo ¶ 

func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error)

func (*ConnectRequest) MarshalToSizedBuffer ¶ 

func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnectRequest) ProtoMessage ¶ 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset ¶ 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) Size ¶ 

func (m *ConnectRequest) Size() (n int)

func (*ConnectRequest) String ¶ 

func (this *ConnectRequest) String() string

func (*ConnectRequest) Unmarshal ¶ 

func (m *ConnectRequest) Unmarshal(dAtA []byte) error

func (*ConnectRequest) XXX_DiscardUnknown ¶ 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal ¶ 

func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectRequest) XXX_Merge ¶ 

func (m *ConnectRequest) XXX_Merge(src proto.Message)

func (*ConnectRequest) XXX_Size ¶ 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal ¶ 

func (m *ConnectRequest) XXX_Unmarshal(b []byte) error

type ConnectResponse ¶ 

type ConnectResponse struct {
	ShimPid              uint32   `protobuf:"varint,1,opt,name=shim_pid,json=shimPid,proto3" json:"shim_pid,omitempty"`
	TaskPid              uint32   `protobuf:"varint,2,opt,name=task_pid,json=taskPid,proto3" json:"task_pid,omitempty"`
	Version              string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConnectResponse) Descriptor ¶ 

func (*ConnectResponse) Descriptor() ([]byte, []int)

func (*ConnectResponse) Marshal ¶ 

func (m *ConnectResponse) Marshal() (dAtA []byte, err error)

func (*ConnectResponse) MarshalTo ¶ 

func (m *ConnectResponse) MarshalTo(dAtA []byte) (int, error)

func (*ConnectResponse) MarshalToSizedBuffer ¶ 

func (m *ConnectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConnectResponse) ProtoMessage ¶ 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset ¶ 

func (m *ConnectResponse) Reset()

func (*ConnectResponse) Size ¶ 

func (m *ConnectResponse) Size() (n int)

func (*ConnectResponse) String ¶ 

func (this *ConnectResponse) String() string

func (*ConnectResponse) Unmarshal ¶ 

func (m *ConnectResponse) Unmarshal(dAtA []byte) error

func (*ConnectResponse) XXX_DiscardUnknown ¶ 

func (m *ConnectResponse) XXX_DiscardUnknown()

func (*ConnectResponse) XXX_Marshal ¶ 

func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectResponse) XXX_Merge ¶ 

func (m *ConnectResponse) XXX_Merge(src proto.Message)

func (*ConnectResponse) XXX_Size ¶ 

func (m *ConnectResponse) XXX_Size() int

func (*ConnectResponse) XXX_Unmarshal ¶ 

func (m *ConnectResponse) XXX_Unmarshal(b []byte) error

type CreateTaskRequest ¶ 

type CreateTaskRequest struct {
	ID                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Bundle               string         `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Rootfs               []*types.Mount `protobuf:"bytes,3,rep,name=rootfs,proto3" json:"rootfs,omitempty"`
	Terminal             bool           `protobuf:"varint,4,opt,name=terminal,proto3" json:"terminal,omitempty"`
	Stdin                string         `protobuf:"bytes,5,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout               string         `protobuf:"bytes,6,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr               string         `protobuf:"bytes,7,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Checkpoint           string         `protobuf:"bytes,8,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	ParentCheckpoint     string         `protobuf:"bytes,9,opt,name=parent_checkpoint,json=parentCheckpoint,proto3" json:"parent_checkpoint,omitempty"`
	Options              *types1.Any    `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CreateTaskRequest) Descriptor ¶ 

func (*CreateTaskRequest) Descriptor() ([]byte, []int)

func (*CreateTaskRequest) Marshal ¶ 

func (m *CreateTaskRequest) Marshal() (dAtA []byte, err error)

func (*CreateTaskRequest) MarshalTo ¶ 

func (m *CreateTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateTaskRequest) MarshalToSizedBuffer ¶ 

func (m *CreateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateTaskRequest) ProtoMessage ¶ 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) Reset ¶ 

func (m *CreateTaskRequest) Reset()

func (*CreateTaskRequest) Size ¶ 

func (m *CreateTaskRequest) Size() (n int)

func (*CreateTaskRequest) String ¶ 

func (this *CreateTaskRequest) String() string

func (*CreateTaskRequest) Unmarshal ¶ 

func (m *CreateTaskRequest) Unmarshal(dAtA []byte) error

func (*CreateTaskRequest) XXX_DiscardUnknown ¶ 

func (m *CreateTaskRequest) XXX_DiscardUnknown()

func (*CreateTaskRequest) XXX_Marshal ¶ 

func (m *CreateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTaskRequest) XXX_Merge ¶ 

func (m *CreateTaskRequest) XXX_Merge(src proto.Message)

func (*CreateTaskRequest) XXX_Size ¶ 

func (m *CreateTaskRequest) XXX_Size() int

func (*CreateTaskRequest) XXX_Unmarshal ¶ 

func (m *CreateTaskRequest) XXX_Unmarshal(b []byte) error

type CreateTaskResponse ¶ 

type CreateTaskResponse struct {
	Pid                  uint32   `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTaskResponse) Descriptor ¶ 

func (*CreateTaskResponse) Descriptor() ([]byte, []int)

func (*CreateTaskResponse) Marshal ¶ 

func (m *CreateTaskResponse) Marshal() (dAtA []byte, err error)

func (*CreateTaskResponse) MarshalTo ¶ 

func (m *CreateTaskResponse) MarshalTo(dAtA []byte) (int, error)

func (*CreateTaskResponse) MarshalToSizedBuffer ¶ 

func (m *CreateTaskResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateTaskResponse) ProtoMessage ¶ 

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) Reset ¶ 

func (m *CreateTaskResponse) Reset()

func (*CreateTaskResponse) Size ¶ 

func (m *CreateTaskResponse) Size() (n int)

func (*CreateTaskResponse) String ¶ 

func (this *CreateTaskResponse) String() string

func (*CreateTaskResponse) Unmarshal ¶ 

func (m *CreateTaskResponse) Unmarshal(dAtA []byte) error

func (*CreateTaskResponse) XXX_DiscardUnknown ¶ 

func (m *CreateTaskResponse) XXX_DiscardUnknown()

func (*CreateTaskResponse) XXX_Marshal ¶ 

func (m *CreateTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateTaskResponse) XXX_Merge ¶ 

func (m *CreateTaskResponse) XXX_Merge(src proto.Message)

func (*CreateTaskResponse) XXX_Size ¶ 

func (m *CreateTaskResponse) XXX_Size() int

func (*CreateTaskResponse) XXX_Unmarshal ¶ 

func (m *CreateTaskResponse) XXX_Unmarshal(b []byte) error

type DeleteRequest ¶ 

type DeleteRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor ¶ 

func (*DeleteRequest) Descriptor() ([]byte, []int)

func (*DeleteRequest) Marshal ¶ 

func (m *DeleteRequest) Marshal() (dAtA []byte, err error)

func (*DeleteRequest) MarshalTo ¶ 

func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToSizedBuffer ¶ 

func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteRequest) ProtoMessage ¶ 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset ¶ 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size ¶ 

func (m *DeleteRequest) Size() (n int)

func (*DeleteRequest) String ¶ 

func (this *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal ¶ 

func (m *DeleteRequest) Unmarshal(dAtA []byte) error

func (*DeleteRequest) XXX_DiscardUnknown ¶ 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal ¶ 

func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRequest) XXX_Merge ¶ 

func (m *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size ¶ 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal ¶ 

func (m *DeleteRequest) XXX_Unmarshal(b []byte) error

type DeleteResponse ¶ 

type DeleteResponse struct {
	Pid                  uint32    `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitStatus           uint32    `protobuf:"varint,2,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt             time.Time `protobuf:"bytes,3,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DeleteResponse) Descriptor ¶ 

func (*DeleteResponse) Descriptor() ([]byte, []int)

func (*DeleteResponse) Marshal ¶ 

func (m *DeleteResponse) Marshal() (dAtA []byte, err error)

func (*DeleteResponse) MarshalTo ¶ 

func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalToSizedBuffer ¶ 

func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteResponse) ProtoMessage ¶ 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset ¶ 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size ¶ 

func (m *DeleteResponse) Size() (n int)

func (*DeleteResponse) String ¶ 

func (this *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal ¶ 

func (m *DeleteResponse) Unmarshal(dAtA []byte) error

func (*DeleteResponse) XXX_DiscardUnknown ¶ 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal ¶ 

func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteResponse) XXX_Merge ¶ 

func (m *DeleteResponse) XXX_Merge(src proto.Message)

func (*DeleteResponse) XXX_Size ¶ 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal ¶ 

func (m *DeleteResponse) XXX_Unmarshal(b []byte) error

type ExecProcessRequest ¶ 

type ExecProcessRequest struct {
	ID                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID               string      `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Terminal             bool        `protobuf:"varint,3,opt,name=terminal,proto3" json:"terminal,omitempty"`
	Stdin                string      `protobuf:"bytes,4,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout               string      `protobuf:"bytes,5,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr               string      `protobuf:"bytes,6,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Spec                 *types1.Any `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*ExecProcessRequest) Descriptor ¶ 

func (*ExecProcessRequest) Descriptor() ([]byte, []int)

func (*ExecProcessRequest) Marshal ¶ 

func (m *ExecProcessRequest) Marshal() (dAtA []byte, err error)

func (*ExecProcessRequest) MarshalTo ¶ 

func (m *ExecProcessRequest) MarshalTo(dAtA []byte) (int, error)

func (*ExecProcessRequest) MarshalToSizedBuffer ¶ 

func (m *ExecProcessRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecProcessRequest) ProtoMessage ¶ 

func (*ExecProcessRequest) ProtoMessage()

func (*ExecProcessRequest) Reset ¶ 

func (m *ExecProcessRequest) Reset()

func (*ExecProcessRequest) Size ¶ 

func (m *ExecProcessRequest) Size() (n int)

func (*ExecProcessRequest) String ¶ 

func (this *ExecProcessRequest) String() string

func (*ExecProcessRequest) Unmarshal ¶ 

func (m *ExecProcessRequest) Unmarshal(dAtA []byte) error

func (*ExecProcessRequest) XXX_DiscardUnknown ¶ 

func (m *ExecProcessRequest) XXX_DiscardUnknown()

func (*ExecProcessRequest) XXX_Marshal ¶ 

func (m *ExecProcessRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecProcessRequest) XXX_Merge ¶ 

func (m *ExecProcessRequest) XXX_Merge(src proto.Message)

func (*ExecProcessRequest) XXX_Size ¶ 

func (m *ExecProcessRequest) XXX_Size() int

func (*ExecProcessRequest) XXX_Unmarshal ¶ 

func (m *ExecProcessRequest) XXX_Unmarshal(b []byte) error

type ExecProcessResponse ¶ 

type ExecProcessResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecProcessResponse) Descriptor ¶ 

func (*ExecProcessResponse) Descriptor() ([]byte, []int)

func (*ExecProcessResponse) Marshal ¶ 

func (m *ExecProcessResponse) Marshal() (dAtA []byte, err error)

func (*ExecProcessResponse) MarshalTo ¶ 

func (m *ExecProcessResponse) MarshalTo(dAtA []byte) (int, error)

func (*ExecProcessResponse) MarshalToSizedBuffer ¶ 

func (m *ExecProcessResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecProcessResponse) ProtoMessage ¶ 

func (*ExecProcessResponse) ProtoMessage()

func (*ExecProcessResponse) Reset ¶ 

func (m *ExecProcessResponse) Reset()

func (*ExecProcessResponse) Size ¶ 

func (m *ExecProcessResponse) Size() (n int)

func (*ExecProcessResponse) String ¶ 

func (this *ExecProcessResponse) String() string

func (*ExecProcessResponse) Unmarshal ¶ 

func (m *ExecProcessResponse) Unmarshal(dAtA []byte) error

func (*ExecProcessResponse) XXX_DiscardUnknown ¶ 

func (m *ExecProcessResponse) XXX_DiscardUnknown()

func (*ExecProcessResponse) XXX_Marshal ¶ 

func (m *ExecProcessResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecProcessResponse) XXX_Merge ¶ 

func (m *ExecProcessResponse) XXX_Merge(src proto.Message)

func (*ExecProcessResponse) XXX_Size ¶ 

func (m *ExecProcessResponse) XXX_Size() int

func (*ExecProcessResponse) XXX_Unmarshal ¶ 

func (m *ExecProcessResponse) XXX_Unmarshal(b []byte) error

type KillRequest ¶ 

type KillRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Signal               uint32   `protobuf:"varint,3,opt,name=signal,proto3" json:"signal,omitempty"`
	All                  bool     `protobuf:"varint,4,opt,name=all,proto3" json:"all,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KillRequest) Descriptor ¶ 

func (*KillRequest) Descriptor() ([]byte, []int)

func (*KillRequest) Marshal ¶ 

func (m *KillRequest) Marshal() (dAtA []byte, err error)

func (*KillRequest) MarshalTo ¶ 

func (m *KillRequest) MarshalTo(dAtA []byte) (int, error)

func (*KillRequest) MarshalToSizedBuffer ¶ 

func (m *KillRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KillRequest) ProtoMessage ¶ 

func (*KillRequest) ProtoMessage()

func (*KillRequest) Reset ¶ 

func (m *KillRequest) Reset()

func (*KillRequest) Size ¶ 

func (m *KillRequest) Size() (n int)

func (*KillRequest) String ¶ 

func (this *KillRequest) String() string

func (*KillRequest) Unmarshal ¶ 

func (m *KillRequest) Unmarshal(dAtA []byte) error

func (*KillRequest) XXX_DiscardUnknown ¶ 

func (m *KillRequest) XXX_DiscardUnknown()

func (*KillRequest) XXX_Marshal ¶ 

func (m *KillRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KillRequest) XXX_Merge ¶ 

func (m *KillRequest) XXX_Merge(src proto.Message)

func (*KillRequest) XXX_Size ¶ 

func (m *KillRequest) XXX_Size() int

func (*KillRequest) XXX_Unmarshal ¶ 

func (m *KillRequest) XXX_Unmarshal(b []byte) error

type PauseRequest ¶ 

type PauseRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseRequest) Descriptor ¶ 

func (*PauseRequest) Descriptor() ([]byte, []int)

func (*PauseRequest) Marshal ¶ 

func (m *PauseRequest) Marshal() (dAtA []byte, err error)

func (*PauseRequest) MarshalTo ¶ 

func (m *PauseRequest) MarshalTo(dAtA []byte) (int, error)

func (*PauseRequest) MarshalToSizedBuffer ¶ 

func (m *PauseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PauseRequest) ProtoMessage ¶ 

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) Reset ¶ 

func (m *PauseRequest) Reset()

func (*PauseRequest) Size ¶ 

func (m *PauseRequest) Size() (n int)

func (*PauseRequest) String ¶ 

func (this *PauseRequest) String() string

func (*PauseRequest) Unmarshal ¶ 

func (m *PauseRequest) Unmarshal(dAtA []byte) error

func (*PauseRequest) XXX_DiscardUnknown ¶ 

func (m *PauseRequest) XXX_DiscardUnknown()

func (*PauseRequest) XXX_Marshal ¶ 

func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseRequest) XXX_Merge ¶ 

func (m *PauseRequest) XXX_Merge(src proto.Message)

func (*PauseRequest) XXX_Size ¶ 

func (m *PauseRequest) XXX_Size() int

func (*PauseRequest) XXX_Unmarshal ¶ 

func (m *PauseRequest) XXX_Unmarshal(b []byte) error

type PidsRequest ¶ 

type PidsRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PidsRequest) Descriptor ¶ 

func (*PidsRequest) Descriptor() ([]byte, []int)

func (*PidsRequest) Marshal ¶ 

func (m *PidsRequest) Marshal() (dAtA []byte, err error)

func (*PidsRequest) MarshalTo ¶ 

func (m *PidsRequest) MarshalTo(dAtA []byte) (int, error)

func (*PidsRequest) MarshalToSizedBuffer ¶ 

func (m *PidsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PidsRequest) ProtoMessage ¶ 

func (*PidsRequest) ProtoMessage()

func (*PidsRequest) Reset ¶ 

func (m *PidsRequest) Reset()

func (*PidsRequest) Size ¶ 

func (m *PidsRequest) Size() (n int)

func (*PidsRequest) String ¶ 

func (this *PidsRequest) String() string

func (*PidsRequest) Unmarshal ¶ 

func (m *PidsRequest) Unmarshal(dAtA []byte) error

func (*PidsRequest) XXX_DiscardUnknown ¶ 

func (m *PidsRequest) XXX_DiscardUnknown()

func (*PidsRequest) XXX_Marshal ¶ 

func (m *PidsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PidsRequest) XXX_Merge ¶ 

func (m *PidsRequest) XXX_Merge(src proto.Message)

func (*PidsRequest) XXX_Size ¶ 

func (m *PidsRequest) XXX_Size() int

func (*PidsRequest) XXX_Unmarshal ¶ 

func (m *PidsRequest) XXX_Unmarshal(b []byte) error

type PidsResponse ¶ 

type PidsResponse struct {
	Processes            []*task.ProcessInfo `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*PidsResponse) Descriptor ¶ 

func (*PidsResponse) Descriptor() ([]byte, []int)

func (*PidsResponse) Marshal ¶ 

func (m *PidsResponse) Marshal() (dAtA []byte, err error)

func (*PidsResponse) MarshalTo ¶ 

func (m *PidsResponse) MarshalTo(dAtA []byte) (int, error)

func (*PidsResponse) MarshalToSizedBuffer ¶ 

func (m *PidsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PidsResponse) ProtoMessage ¶ 

func (*PidsResponse) ProtoMessage()

func (*PidsResponse) Reset ¶ 

func (m *PidsResponse) Reset()

func (*PidsResponse) Size ¶ 

func (m *PidsResponse) Size() (n int)

func (*PidsResponse) String ¶ 

func (this *PidsResponse) String() string

func (*PidsResponse) Unmarshal ¶ 

func (m *PidsResponse) Unmarshal(dAtA []byte) error

func (*PidsResponse) XXX_DiscardUnknown ¶ 

func (m *PidsResponse) XXX_DiscardUnknown()

func (*PidsResponse) XXX_Marshal ¶ 

func (m *PidsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PidsResponse) XXX_Merge ¶ 

func (m *PidsResponse) XXX_Merge(src proto.Message)

func (*PidsResponse) XXX_Size ¶ 

func (m *PidsResponse) XXX_Size() int

func (*PidsResponse) XXX_Unmarshal ¶ 

func (m *PidsResponse) XXX_Unmarshal(b []byte) error

type ResizePtyRequest ¶ 

type ResizePtyRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Width                uint32   `protobuf:"varint,3,opt,name=width,proto3" json:"width,omitempty"`
	Height               uint32   `protobuf:"varint,4,opt,name=height,proto3" json:"height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResizePtyRequest) Descriptor ¶ 

func (*ResizePtyRequest) Descriptor() ([]byte, []int)

func (*ResizePtyRequest) Marshal ¶ 

func (m *ResizePtyRequest) Marshal() (dAtA []byte, err error)

func (*ResizePtyRequest) MarshalTo ¶ 

func (m *ResizePtyRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResizePtyRequest) MarshalToSizedBuffer ¶ 

func (m *ResizePtyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResizePtyRequest) ProtoMessage ¶ 

func (*ResizePtyRequest) ProtoMessage()

func (*ResizePtyRequest) Reset ¶ 

func (m *ResizePtyRequest) Reset()

func (*ResizePtyRequest) Size ¶ 

func (m *ResizePtyRequest) Size() (n int)

func (*ResizePtyRequest) String ¶ 

func (this *ResizePtyRequest) String() string

func (*ResizePtyRequest) Unmarshal ¶ 

func (m *ResizePtyRequest) Unmarshal(dAtA []byte) error

func (*ResizePtyRequest) XXX_DiscardUnknown ¶ 

func (m *ResizePtyRequest) XXX_DiscardUnknown()

func (*ResizePtyRequest) XXX_Marshal ¶ 

func (m *ResizePtyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResizePtyRequest) XXX_Merge ¶ 

func (m *ResizePtyRequest) XXX_Merge(src proto.Message)

func (*ResizePtyRequest) XXX_Size ¶ 

func (m *ResizePtyRequest) XXX_Size() int

func (*ResizePtyRequest) XXX_Unmarshal ¶ 

func (m *ResizePtyRequest) XXX_Unmarshal(b []byte) error

type ResumeRequest ¶ 

type ResumeRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResumeRequest) Descriptor ¶ 

func (*ResumeRequest) Descriptor() ([]byte, []int)

func (*ResumeRequest) Marshal ¶ 

func (m *ResumeRequest) Marshal() (dAtA []byte, err error)

func (*ResumeRequest) MarshalTo ¶ 

func (m *ResumeRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResumeRequest) MarshalToSizedBuffer ¶ 

func (m *ResumeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResumeRequest) ProtoMessage ¶ 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) Reset ¶ 

func (m *ResumeRequest) Reset()

func (*ResumeRequest) Size ¶ 

func (m *ResumeRequest) Size() (n int)

func (*ResumeRequest) String ¶ 

func (this *ResumeRequest) String() string

func (*ResumeRequest) Unmarshal ¶ 

func (m *ResumeRequest) Unmarshal(dAtA []byte) error

func (*ResumeRequest) XXX_DiscardUnknown ¶ 

func (m *ResumeRequest) XXX_DiscardUnknown()

func (*ResumeRequest) XXX_Marshal ¶ 

func (m *ResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResumeRequest) XXX_Merge ¶ 

func (m *ResumeRequest) XXX_Merge(src proto.Message)

func (*ResumeRequest) XXX_Size ¶ 

func (m *ResumeRequest) XXX_Size() int

func (*ResumeRequest) XXX_Unmarshal ¶ 

func (m *ResumeRequest) XXX_Unmarshal(b []byte) error

type ShutdownRequest ¶ 

type ShutdownRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Now                  bool     `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShutdownRequest) Descriptor ¶ 

func (*ShutdownRequest) Descriptor() ([]byte, []int)

func (*ShutdownRequest) Marshal ¶ 

func (m *ShutdownRequest) Marshal() (dAtA []byte, err error)

func (*ShutdownRequest) MarshalTo ¶ 

func (m *ShutdownRequest) MarshalTo(dAtA []byte) (int, error)

func (*ShutdownRequest) MarshalToSizedBuffer ¶ 

func (m *ShutdownRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ShutdownRequest) ProtoMessage ¶ 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) Reset ¶ 

func (m *ShutdownRequest) Reset()

func (*ShutdownRequest) Size ¶ 

func (m *ShutdownRequest) Size() (n int)

func (*ShutdownRequest) String ¶ 

func (this *ShutdownRequest) String() string

func (*ShutdownRequest) Unmarshal ¶ 

func (m *ShutdownRequest) Unmarshal(dAtA []byte) error

func (*ShutdownRequest) XXX_DiscardUnknown ¶ 

func (m *ShutdownRequest) XXX_DiscardUnknown()

func (*ShutdownRequest) XXX_Marshal ¶ 

func (m *ShutdownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShutdownRequest) XXX_Merge ¶ 

func (m *ShutdownRequest) XXX_Merge(src proto.Message)

func (*ShutdownRequest) XXX_Size ¶ 

func (m *ShutdownRequest) XXX_Size() int

func (*ShutdownRequest) XXX_Unmarshal ¶ 

func (m *ShutdownRequest) XXX_Unmarshal(b []byte) error

type StartRequest ¶ 

type StartRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartRequest) Descriptor ¶ 

func (*StartRequest) Descriptor() ([]byte, []int)

func (*StartRequest) Marshal ¶ 

func (m *StartRequest) Marshal() (dAtA []byte, err error)

func (*StartRequest) MarshalTo ¶ 

func (m *StartRequest) MarshalTo(dAtA []byte) (int, error)

func (*StartRequest) MarshalToSizedBuffer ¶ 

func (m *StartRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartRequest) ProtoMessage ¶ 

func (*StartRequest) ProtoMessage()

func (*StartRequest) Reset ¶ 

func (m *StartRequest) Reset()

func (*StartRequest) Size ¶ 

func (m *StartRequest) Size() (n int)

func (*StartRequest) String ¶ 

func (this *StartRequest) String() string

func (*StartRequest) Unmarshal ¶ 

func (m *StartRequest) Unmarshal(dAtA []byte) error

func (*StartRequest) XXX_DiscardUnknown ¶ 

func (m *StartRequest) XXX_DiscardUnknown()

func (*StartRequest) XXX_Marshal ¶ 

func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartRequest) XXX_Merge ¶ 

func (m *StartRequest) XXX_Merge(src proto.Message)

func (*StartRequest) XXX_Size ¶ 

func (m *StartRequest) XXX_Size() int

func (*StartRequest) XXX_Unmarshal ¶ 

func (m *StartRequest) XXX_Unmarshal(b []byte) error

type StartResponse ¶ 

type StartResponse struct {
	Pid                  uint32   `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartResponse) Descriptor ¶ 

func (*StartResponse) Descriptor() ([]byte, []int)

func (*StartResponse) Marshal ¶ 

func (m *StartResponse) Marshal() (dAtA []byte, err error)

func (*StartResponse) MarshalTo ¶ 

func (m *StartResponse) MarshalTo(dAtA []byte) (int, error)

func (*StartResponse) MarshalToSizedBuffer ¶ 

func (m *StartResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StartResponse) ProtoMessage ¶ 

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset ¶ 

func (m *StartResponse) Reset()

func (*StartResponse) Size ¶ 

func (m *StartResponse) Size() (n int)

func (*StartResponse) String ¶ 

func (this *StartResponse) String() string

func (*StartResponse) Unmarshal ¶ 

func (m *StartResponse) Unmarshal(dAtA []byte) error

func (*StartResponse) XXX_DiscardUnknown ¶ 

func (m *StartResponse) XXX_DiscardUnknown()

func (*StartResponse) XXX_Marshal ¶ 

func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartResponse) XXX_Merge ¶ 

func (m *StartResponse) XXX_Merge(src proto.Message)

func (*StartResponse) XXX_Size ¶ 

func (m *StartResponse) XXX_Size() int

func (*StartResponse) XXX_Unmarshal ¶ 

func (m *StartResponse) XXX_Unmarshal(b []byte) error

type StateRequest ¶ 

type StateRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateRequest) Descriptor ¶ 

func (*StateRequest) Descriptor() ([]byte, []int)

func (*StateRequest) Marshal ¶ 

func (m *StateRequest) Marshal() (dAtA []byte, err error)

func (*StateRequest) MarshalTo ¶ 

func (m *StateRequest) MarshalTo(dAtA []byte) (int, error)

func (*StateRequest) MarshalToSizedBuffer ¶ 

func (m *StateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StateRequest) ProtoMessage ¶ 

func (*StateRequest) ProtoMessage()

func (*StateRequest) Reset ¶ 

func (m *StateRequest) Reset()

func (*StateRequest) Size ¶ 

func (m *StateRequest) Size() (n int)

func (*StateRequest) String ¶ 

func (this *StateRequest) String() string

func (*StateRequest) Unmarshal ¶ 

func (m *StateRequest) Unmarshal(dAtA []byte) error

func (*StateRequest) XXX_DiscardUnknown ¶ 

func (m *StateRequest) XXX_DiscardUnknown()

func (*StateRequest) XXX_Marshal ¶ 

func (m *StateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateRequest) XXX_Merge ¶ 

func (m *StateRequest) XXX_Merge(src proto.Message)

func (*StateRequest) XXX_Size ¶ 

func (m *StateRequest) XXX_Size() int

func (*StateRequest) XXX_Unmarshal ¶ 

func (m *StateRequest) XXX_Unmarshal(b []byte) error

type StateResponse ¶ 

type StateResponse struct {
	ID                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Bundle               string      `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Pid                  uint32      `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
	Status               task.Status `protobuf:"varint,4,opt,name=status,proto3,enum=containerd.v1.types.Status" json:"status,omitempty"`
	Stdin                string      `protobuf:"bytes,5,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout               string      `protobuf:"bytes,6,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr               string      `protobuf:"bytes,7,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Terminal             bool        `protobuf:"varint,8,opt,name=terminal,proto3" json:"terminal,omitempty"`
	ExitStatus           uint32      `protobuf:"varint,9,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt             time.Time   `protobuf:"bytes,10,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"`
	ExecID               string      `protobuf:"bytes,11,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*StateResponse) Descriptor ¶ 

func (*StateResponse) Descriptor() ([]byte, []int)

func (*StateResponse) Marshal ¶ 

func (m *StateResponse) Marshal() (dAtA []byte, err error)

func (*StateResponse) MarshalTo ¶ 

func (m *StateResponse) MarshalTo(dAtA []byte) (int, error)

func (*StateResponse) MarshalToSizedBuffer ¶ 

func (m *StateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StateResponse) ProtoMessage ¶ 

func (*StateResponse) ProtoMessage()

func (*StateResponse) Reset ¶ 

func (m *StateResponse) Reset()

func (*StateResponse) Size ¶ 

func (m *StateResponse) Size() (n int)

func (*StateResponse) String ¶ 

func (this *StateResponse) String() string

func (*StateResponse) Unmarshal ¶ 

func (m *StateResponse) Unmarshal(dAtA []byte) error

func (*StateResponse) XXX_DiscardUnknown ¶ 

func (m *StateResponse) XXX_DiscardUnknown()

func (*StateResponse) XXX_Marshal ¶ 

func (m *StateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StateResponse) XXX_Merge ¶ 

func (m *StateResponse) XXX_Merge(src proto.Message)

func (*StateResponse) XXX_Size ¶ 

func (m *StateResponse) XXX_Size() int

func (*StateResponse) XXX_Unmarshal ¶ 

func (m *StateResponse) XXX_Unmarshal(b []byte) error

type StatsRequest ¶ 

type StatsRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatsRequest) Descriptor ¶ 

func (*StatsRequest) Descriptor() ([]byte, []int)

func (*StatsRequest) Marshal ¶ 

func (m *StatsRequest) Marshal() (dAtA []byte, err error)

func (*StatsRequest) MarshalTo ¶ 

func (m *StatsRequest) MarshalTo(dAtA []byte) (int, error)

func (*StatsRequest) MarshalToSizedBuffer ¶ 

func (m *StatsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatsRequest) ProtoMessage ¶ 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) Reset ¶ 

func (m *StatsRequest) Reset()

func (*StatsRequest) Size ¶ 

func (m *StatsRequest) Size() (n int)

func (*StatsRequest) String ¶ 

func (this *StatsRequest) String() string

func (*StatsRequest) Unmarshal ¶ 

func (m *StatsRequest) Unmarshal(dAtA []byte) error

func (*StatsRequest) XXX_DiscardUnknown ¶ 

func (m *StatsRequest) XXX_DiscardUnknown()

func (*StatsRequest) XXX_Marshal ¶ 

func (m *StatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatsRequest) XXX_Merge ¶ 

func (m *StatsRequest) XXX_Merge(src proto.Message)

func (*StatsRequest) XXX_Size ¶ 

func (m *StatsRequest) XXX_Size() int

func (*StatsRequest) XXX_Unmarshal ¶ 

func (m *StatsRequest) XXX_Unmarshal(b []byte) error

type StatsResponse ¶ 

type StatsResponse struct {
	Stats                *types1.Any `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*StatsResponse) Descriptor ¶ 

func (*StatsResponse) Descriptor() ([]byte, []int)

func (*StatsResponse) Marshal ¶ 

func (m *StatsResponse) Marshal() (dAtA []byte, err error)

func (*StatsResponse) MarshalTo ¶ 

func (m *StatsResponse) MarshalTo(dAtA []byte) (int, error)

func (*StatsResponse) MarshalToSizedBuffer ¶ 

func (m *StatsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatsResponse) ProtoMessage ¶ 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) Reset ¶ 

func (m *StatsResponse) Reset()

func (*StatsResponse) Size ¶ 

func (m *StatsResponse) Size() (n int)

func (*StatsResponse) String ¶ 

func (this *StatsResponse) String() string

func (*StatsResponse) Unmarshal ¶ 

func (m *StatsResponse) Unmarshal(dAtA []byte) error

func (*StatsResponse) XXX_DiscardUnknown ¶ 

func (m *StatsResponse) XXX_DiscardUnknown()

func (*StatsResponse) XXX_Marshal ¶ 

func (m *StatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatsResponse) XXX_Merge ¶ 

func (m *StatsResponse) XXX_Merge(src proto.Message)

func (*StatsResponse) XXX_Size ¶ 

func (m *StatsResponse) XXX_Size() int

func (*StatsResponse) XXX_Unmarshal ¶ 

func (m *StatsResponse) XXX_Unmarshal(b []byte) error

type TaskService ¶ 

type TaskService interface {
	State(ctx context.Context, req *StateRequest) (*StateResponse, error)
	Create(ctx context.Context, req *CreateTaskRequest) (*CreateTaskResponse, error)
	Start(ctx context.Context, req *StartRequest) (*StartResponse, error)
	Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)
	Pids(ctx context.Context, req *PidsRequest) (*PidsResponse, error)
	Pause(ctx context.Context, req *PauseRequest) (*types1.Empty, error)
	Resume(ctx context.Context, req *ResumeRequest) (*types1.Empty, error)
	Checkpoint(ctx context.Context, req *CheckpointTaskRequest) (*types1.Empty, error)
	Kill(ctx context.Context, req *KillRequest) (*types1.Empty, error)
	Exec(ctx context.Context, req *ExecProcessRequest) (*types1.Empty, error)
	ResizePty(ctx context.Context, req *ResizePtyRequest) (*types1.Empty, error)
	CloseIO(ctx context.Context, req *CloseIORequest) (*types1.Empty, error)
	Update(ctx context.Context, req *UpdateTaskRequest) (*types1.Empty, error)
	Wait(ctx context.Context, req *WaitRequest) (*WaitResponse, error)
	Stats(ctx context.Context, req *StatsRequest) (*StatsResponse, error)
	Connect(ctx context.Context, req *ConnectRequest) (*ConnectResponse, error)
	Shutdown(ctx context.Context, req *ShutdownRequest) (*types1.Empty, error)
}

func NewTaskClient ¶ 

func NewTaskClient(client *github_com_containerd_ttrpc.Client) TaskService

type UpdateTaskRequest ¶ 

type UpdateTaskRequest struct {
	ID                   string      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Resources            *types1.Any `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*UpdateTaskRequest) Descriptor ¶ 

func (*UpdateTaskRequest) Descriptor() ([]byte, []int)

func (*UpdateTaskRequest) Marshal ¶ 

func (m *UpdateTaskRequest) Marshal() (dAtA []byte, err error)

func (*UpdateTaskRequest) MarshalTo ¶ 

func (m *UpdateTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateTaskRequest) MarshalToSizedBuffer ¶ 

func (m *UpdateTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateTaskRequest) ProtoMessage ¶ 

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) Reset ¶ 

func (m *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) Size ¶ 

func (m *UpdateTaskRequest) Size() (n int)

func (*UpdateTaskRequest) String ¶ 

func (this *UpdateTaskRequest) String() string

func (*UpdateTaskRequest) Unmarshal ¶ 

func (m *UpdateTaskRequest) Unmarshal(dAtA []byte) error

func (*UpdateTaskRequest) XXX_DiscardUnknown ¶ 

func (m *UpdateTaskRequest) XXX_DiscardUnknown()

func (*UpdateTaskRequest) XXX_Marshal ¶ 

func (m *UpdateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateTaskRequest) XXX_Merge ¶ 

func (m *UpdateTaskRequest) XXX_Merge(src proto.Message)

func (*UpdateTaskRequest) XXX_Size ¶ 

func (m *UpdateTaskRequest) XXX_Size() int

func (*UpdateTaskRequest) XXX_Unmarshal ¶ 

func (m *UpdateTaskRequest) XXX_Unmarshal(b []byte) error

type WaitRequest ¶ 

type WaitRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID               string   `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitRequest) Descriptor ¶ 

func (*WaitRequest) Descriptor() ([]byte, []int)

func (*WaitRequest) Marshal ¶ 

func (m *WaitRequest) Marshal() (dAtA []byte, err error)

func (*WaitRequest) MarshalTo ¶ 

func (m *WaitRequest) MarshalTo(dAtA []byte) (int, error)

func (*WaitRequest) MarshalToSizedBuffer ¶ 

func (m *WaitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WaitRequest) ProtoMessage ¶ 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) Reset ¶ 

func (m *WaitRequest) Reset()

func (*WaitRequest) Size ¶ 

func (m *WaitRequest) Size() (n int)

func (*WaitRequest) String ¶ 

func (this *WaitRequest) String() string

func (*WaitRequest) Unmarshal ¶ 

func (m *WaitRequest) Unmarshal(dAtA []byte) error

func (*WaitRequest) XXX_DiscardUnknown ¶ 

func (m *WaitRequest) XXX_DiscardUnknown()

func (*WaitRequest) XXX_Marshal ¶ 

func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaitRequest) XXX_Merge ¶ 

func (m *WaitRequest) XXX_Merge(src proto.Message)

func (*WaitRequest) XXX_Size ¶ 

func (m *WaitRequest) XXX_Size() int

func (*WaitRequest) XXX_Unmarshal ¶ 

func (m *WaitRequest) XXX_Unmarshal(b []byte) error

type WaitResponse ¶ 

type WaitResponse struct {
	ExitStatus           uint32    `protobuf:"varint,1,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt             time.Time `protobuf:"bytes,2,opt,name=exited_at,json=exitedAt,proto3,stdtime" json:"exited_at"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*WaitResponse) Descriptor ¶ 

func (*WaitResponse) Descriptor() ([]byte, []int)

func (*WaitResponse) Marshal ¶ 

func (m *WaitResponse) Marshal() (dAtA []byte, err error)

func (*WaitResponse) MarshalTo ¶ 

func (m *WaitResponse) MarshalTo(dAtA []byte) (int, error)

func (*WaitResponse) MarshalToSizedBuffer ¶ 

func (m *WaitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WaitResponse) ProtoMessage ¶ 

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) Reset ¶ 

func (m *WaitResponse) Reset()

func (*WaitResponse) Size ¶ 

func (m *WaitResponse) Size() (n int)

func (*WaitResponse) String ¶ 

func (this *WaitResponse) String() string

func (*WaitResponse) Unmarshal ¶ 

func (m *WaitResponse) Unmarshal(dAtA []byte) error

func (*WaitResponse) XXX_DiscardUnknown ¶ 

func (m *WaitResponse) XXX_DiscardUnknown()

func (*WaitResponse) XXX_Marshal ¶ 

func (m *WaitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaitResponse) XXX_Merge ¶ 

func (m *WaitResponse) XXX_Merge(src proto.Message)

func (*WaitResponse) XXX_Size ¶ 

func (m *WaitResponse) XXX_Size() int

func (*WaitResponse) XXX_Unmarshal ¶ 

func (m *WaitResponse) XXX_Unmarshal(b []byte) error

Source Files ¶

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.