tasks

package
v1.0.0-alpha6 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2017 License: Apache-2.0, CC-BY-SA-4.0 Imports: 15 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

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_types1.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_types1.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 {
	Pids []uint32 `protobuf:"varint,1,rep,packed,name=pids" json:"pids,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 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)
}

func NewTasksClient 

func NewTasksClient(cc *grpc.ClientConn) TasksClient

type TasksServer 

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

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

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.