tasks

package
v1.2.12 Latest Latest
Warning

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

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

Documentation

Overview

Package tasks is a generated protocol buffer package.

It is generated from these files:

github.com/containerd/containerd/api/services/tasks/v1/tasks.proto

It has these top-level messages:

CreateTaskRequest
CreateTaskResponse
StartRequest
StartResponse
DeleteTaskRequest
DeleteResponse
DeleteProcessRequest
GetRequest
GetResponse
ListTasksRequest
ListTasksResponse
KillRequest
ExecProcessRequest
ExecProcessResponse
ResizePtyRequest
CloseIORequest
PauseTaskRequest
ResumeTaskRequest
ListPidsRequest
ListPidsResponse
CheckpointTaskRequest
CheckpointTaskResponse
UpdateTaskRequest
MetricsRequest
MetricsResponse
WaitRequest
WaitResponse

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthTasks = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTasks   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterTasksServer

func RegisterTasksServer(s *grpc.Server, srv TasksServer)

Types

type CheckpointTaskRequest

type CheckpointTaskRequest struct {
	ContainerID      string                                     `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ParentCheckpoint github_com_opencontainers_go_digest.Digest `` /* 153-byte string literal not displayed */
	Options          *google_protobuf1.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 CheckpointTaskResponse

type CheckpointTaskResponse struct {
	Descriptors []*containerd_types2.Descriptor `protobuf:"bytes,1,rep,name=descriptors" json:"descriptors,omitempty"`
}

func (*CheckpointTaskResponse) Descriptor

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

func (*CheckpointTaskResponse) Marshal

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

func (*CheckpointTaskResponse) MarshalTo

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

func (*CheckpointTaskResponse) ProtoMessage

func (*CheckpointTaskResponse) ProtoMessage()

func (*CheckpointTaskResponse) Reset

func (m *CheckpointTaskResponse) Reset()

func (*CheckpointTaskResponse) Size

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

func (*CheckpointTaskResponse) String

func (this *CheckpointTaskResponse) String() string

func (*CheckpointTaskResponse) Unmarshal

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

type CloseIORequest

type CloseIORequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_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 CreateTaskRequest

type CreateTaskRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// RootFS provides the pre-chroot mounts to perform in the shim before
	// executing the container task.
	//
	// These are for mounts that cannot be performed in the user namespace.
	// Typically, these mounts should be resolved from snapshots specified on
	// the container object.
	Rootfs     []*containerd_types.Mount     `protobuf:"bytes,3,rep,name=rootfs" json:"rootfs,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"`
	Terminal   bool                          `protobuf:"varint,7,opt,name=terminal,proto3" json:"terminal,omitempty"`
	Checkpoint *containerd_types2.Descriptor `protobuf:"bytes,8,opt,name=checkpoint" json:"checkpoint,omitempty"`
	Options    *google_protobuf1.Any         `protobuf:"bytes,9,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 {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Pid         uint32 `protobuf:"varint,2,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 DeleteProcessRequest

type DeleteProcessRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID      string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
}

func (*DeleteProcessRequest) Descriptor

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

func (*DeleteProcessRequest) Marshal

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

func (*DeleteProcessRequest) MarshalTo

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

func (*DeleteProcessRequest) ProtoMessage

func (*DeleteProcessRequest) ProtoMessage()

func (*DeleteProcessRequest) Reset

func (m *DeleteProcessRequest) Reset()

func (*DeleteProcessRequest) Size

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

func (*DeleteProcessRequest) String

func (this *DeleteProcessRequest) String() string

func (*DeleteProcessRequest) Unmarshal

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

type DeleteResponse

type DeleteResponse struct {
	ID         string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Pid        uint32    `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitStatus uint32    `protobuf:"varint,3,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt   time.Time `protobuf:"bytes,4,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 DeleteTaskRequest

type DeleteTaskRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*DeleteTaskRequest) Descriptor

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

func (*DeleteTaskRequest) Marshal

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

func (*DeleteTaskRequest) MarshalTo

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

func (*DeleteTaskRequest) ProtoMessage

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) Reset

func (m *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) Size

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

func (*DeleteTaskRequest) String

func (this *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) Unmarshal

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

type ExecProcessRequest

type ExecProcessRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Stdin       string `protobuf:"bytes,2,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout      string `protobuf:"bytes,3,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr      string `protobuf:"bytes,4,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Terminal    bool   `protobuf:"varint,5,opt,name=terminal,proto3" json:"terminal,omitempty"`
	// Spec for starting a process in the target container.
	//
	// For runc, this is a process spec, for example.
	Spec *google_protobuf1.Any `protobuf:"bytes,6,opt,name=spec" json:"spec,omitempty"`
	// id of the exec process
	ExecID string `protobuf:"bytes,7,opt,name=exec_id,json=execId,proto3" json:"exec_id,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 GetRequest

type GetRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID      string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
}

func (*GetRequest) Descriptor

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

func (*GetRequest) Marshal

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

func (*GetRequest) MarshalTo

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

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset

func (m *GetRequest) Reset()

func (*GetRequest) Size

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

func (*GetRequest) String

func (this *GetRequest) String() string

func (*GetRequest) Unmarshal

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

type GetResponse

type GetResponse struct {
	Process *containerd_v1_types.Process `protobuf:"bytes,1,opt,name=process" json:"process,omitempty"`
}

func (*GetResponse) Descriptor

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

func (*GetResponse) Marshal

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

func (*GetResponse) MarshalTo

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

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset

func (m *GetResponse) Reset()

func (*GetResponse) Size

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

func (*GetResponse) String

func (this *GetResponse) String() string

func (*GetResponse) Unmarshal

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

type KillRequest

type KillRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_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 ListPidsRequest

type ListPidsRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*ListPidsRequest) Descriptor

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

func (*ListPidsRequest) Marshal

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

func (*ListPidsRequest) MarshalTo

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

func (*ListPidsRequest) ProtoMessage

func (*ListPidsRequest) ProtoMessage()

func (*ListPidsRequest) Reset

func (m *ListPidsRequest) Reset()

func (*ListPidsRequest) Size

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

func (*ListPidsRequest) String

func (this *ListPidsRequest) String() string

func (*ListPidsRequest) Unmarshal

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

type ListPidsResponse

type ListPidsResponse struct {
	// Processes includes the process ID and additional process information
	Processes []*containerd_v1_types.ProcessInfo `protobuf:"bytes,1,rep,name=processes" json:"processes,omitempty"`
}

func (*ListPidsResponse) Descriptor

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

func (*ListPidsResponse) Marshal

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

func (*ListPidsResponse) MarshalTo

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

func (*ListPidsResponse) ProtoMessage

func (*ListPidsResponse) ProtoMessage()

func (*ListPidsResponse) Reset

func (m *ListPidsResponse) Reset()

func (*ListPidsResponse) Size

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

func (*ListPidsResponse) String

func (this *ListPidsResponse) String() string

func (*ListPidsResponse) Unmarshal

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

type ListTasksRequest

type ListTasksRequest struct {
	Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
}

func (*ListTasksRequest) Descriptor

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

func (*ListTasksRequest) Marshal

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

func (*ListTasksRequest) MarshalTo

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

func (*ListTasksRequest) ProtoMessage

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) Reset

func (m *ListTasksRequest) Reset()

func (*ListTasksRequest) Size

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

func (*ListTasksRequest) String

func (this *ListTasksRequest) String() string

func (*ListTasksRequest) Unmarshal

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

type ListTasksResponse

type ListTasksResponse struct {
	Tasks []*containerd_v1_types.Process `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
}

func (*ListTasksResponse) Descriptor

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

func (*ListTasksResponse) Marshal

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

func (*ListTasksResponse) MarshalTo

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

func (*ListTasksResponse) ProtoMessage

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) Reset

func (m *ListTasksResponse) Reset()

func (*ListTasksResponse) Size

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

func (*ListTasksResponse) String

func (this *ListTasksResponse) String() string

func (*ListTasksResponse) Unmarshal

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

type MetricsRequest

type MetricsRequest struct {
	Filters []string `protobuf:"bytes,1,rep,name=filters" json:"filters,omitempty"`
}

func (*MetricsRequest) Descriptor

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

func (*MetricsRequest) Marshal

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

func (*MetricsRequest) MarshalTo

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

func (*MetricsRequest) ProtoMessage

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) Reset

func (m *MetricsRequest) Reset()

func (*MetricsRequest) Size

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

func (*MetricsRequest) String

func (this *MetricsRequest) String() string

func (*MetricsRequest) Unmarshal

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

type MetricsResponse

type MetricsResponse struct {
	Metrics []*containerd_types1.Metric `protobuf:"bytes,1,rep,name=metrics" json:"metrics,omitempty"`
}

func (*MetricsResponse) Descriptor

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

func (*MetricsResponse) Marshal

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

func (*MetricsResponse) MarshalTo

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

func (*MetricsResponse) ProtoMessage

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) Reset

func (m *MetricsResponse) Reset()

func (*MetricsResponse) Size

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

func (*MetricsResponse) String

func (this *MetricsResponse) String() string

func (*MetricsResponse) Unmarshal

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

type PauseTaskRequest

type PauseTaskRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*PauseTaskRequest) Descriptor

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

func (*PauseTaskRequest) Marshal

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

func (*PauseTaskRequest) MarshalTo

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

func (*PauseTaskRequest) ProtoMessage

func (*PauseTaskRequest) ProtoMessage()

func (*PauseTaskRequest) Reset

func (m *PauseTaskRequest) Reset()

func (*PauseTaskRequest) Size

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

func (*PauseTaskRequest) String

func (this *PauseTaskRequest) String() string

func (*PauseTaskRequest) Unmarshal

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

type ResizePtyRequest

type ResizePtyRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_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 ResumeTaskRequest

type ResumeTaskRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*ResumeTaskRequest) Descriptor

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

func (*ResumeTaskRequest) Marshal

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

func (*ResumeTaskRequest) MarshalTo

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

func (*ResumeTaskRequest) ProtoMessage

func (*ResumeTaskRequest) ProtoMessage()

func (*ResumeTaskRequest) Reset

func (m *ResumeTaskRequest) Reset()

func (*ResumeTaskRequest) Size

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

func (*ResumeTaskRequest) String

func (this *ResumeTaskRequest) String() string

func (*ResumeTaskRequest) Unmarshal

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

type StartRequest

type StartRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_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 TasksClient

type TasksClient interface {
	// Create a task.
	Create(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error)
	// Start a process.
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	// Delete a task and on disk state.
	Delete(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	DeleteProcess(ctx context.Context, in *DeleteProcessRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	List(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	// Kill a task or process.
	Kill(ctx context.Context, in *KillRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	Exec(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	ResizePty(ctx context.Context, in *ResizePtyRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	CloseIO(ctx context.Context, in *CloseIORequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	Pause(ctx context.Context, in *PauseTaskRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	Resume(ctx context.Context, in *ResumeTaskRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	ListPids(ctx context.Context, in *ListPidsRequest, opts ...grpc.CallOption) (*ListPidsResponse, error)
	Checkpoint(ctx context.Context, in *CheckpointTaskRequest, opts ...grpc.CallOption) (*CheckpointTaskResponse, error)
	Update(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error)
	Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error)
}

func NewTasksClient

func NewTasksClient(cc *grpc.ClientConn) TasksClient

type UpdateTaskRequest

type UpdateTaskRequest struct {
	ContainerID string                `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Resources   *google_protobuf1.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 {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL