task

package
v1.2.14 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package task is a generated protocol buffer package.

It is generated from these files: 

github.com/containerd/containerd/runtime/v2/task/shim.proto

It has these top-level messages: 

CreateTaskRequest
CreateTaskResponse
DeleteRequest
DeleteResponse
ExecProcessRequest
ExecProcessResponse
ResizePtyRequest
StateRequest
StateResponse
KillRequest
CloseIORequest
PidsRequest
PidsResponse
CheckpointTaskRequest
UpdateTaskRequest
StartRequest
StartResponse
WaitRequest
WaitResponse
StatsRequest
StatsResponse
ConnectRequest
ConnectResponse
ShutdownRequest
PauseRequest
ResumeRequest

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")
)

Functions

func RegisterTaskService 

func RegisterTaskService(srv *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 *google_protobuf.Any `protobuf:"bytes,3,opt,name=options" json:"options,omitempty"`
}

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) 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

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"`
}

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) 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

type ConnectRequest 

type ConnectRequest struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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) 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

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"`
}

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) 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

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           []*containerd_types.Mount `protobuf:"bytes,3,rep,name=rootfs" 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          *google_protobuf.Any      `protobuf:"bytes,10,opt,name=options" json:"options,omitempty"`
}

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) 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

type CreateTaskResponse 

type CreateTaskResponse struct {
	Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
}

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) 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

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"`
}

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) 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

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,stdtime" json:"exited_at"`
}

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) 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

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     *google_protobuf.Any `protobuf:"bytes,7,opt,name=spec" json:"spec,omitempty"`
}

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) 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

type ExecProcessResponse 

type ExecProcessResponse struct {
}

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) 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

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"`
}

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) 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

type PauseRequest 

type PauseRequest struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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) 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

type PidsRequest 

type PidsRequest struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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) 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

type PidsResponse 

type PidsResponse struct {
	Processes []*containerd_v1_types.ProcessInfo `protobuf:"bytes,1,rep,name=processes" json:"processes,omitempty"`
}

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) 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

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"`
}

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) 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

type ResumeRequest 

type ResumeRequest struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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) 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

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"`
}

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) 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

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"`
}

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) 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

type StartResponse 

type StartResponse struct {
	Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
}

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) 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

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"`
}

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) 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

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     containerd_v1_types.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,stdtime" json:"exited_at"`
}

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) 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

type StatsRequest 

type StatsRequest struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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) 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

type StatsResponse 

type StatsResponse struct {
	Stats *google_protobuf.Any `protobuf:"bytes,1,opt,name=stats" json:"stats,omitempty"`
}

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) 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

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) (*google_protobuf1.Empty, error)
	Resume(ctx context.Context, req *ResumeRequest) (*google_protobuf1.Empty, error)
	Checkpoint(ctx context.Context, req *CheckpointTaskRequest) (*google_protobuf1.Empty, error)
	Kill(ctx context.Context, req *KillRequest) (*google_protobuf1.Empty, error)
	Exec(ctx context.Context, req *ExecProcessRequest) (*google_protobuf1.Empty, error)
	ResizePty(ctx context.Context, req *ResizePtyRequest) (*google_protobuf1.Empty, error)
	CloseIO(ctx context.Context, req *CloseIORequest) (*google_protobuf1.Empty, error)
	Update(ctx context.Context, req *UpdateTaskRequest) (*google_protobuf1.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) (*google_protobuf1.Empty, error)
}

func NewTaskClient 

func NewTaskClient(client *ttrpc.Client) TaskService

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	ID        string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Resources *google_protobuf.Any `protobuf:"bytes,2,opt,name=resources" json:"resources,omitempty"`
}

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) 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

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"`
}

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) 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

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,stdtime" json:"exited_at"`
}

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) 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

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.