tasks

package
v1.7.12 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2024 License: Apache-2.0 Imports: 13 Imported by: 534

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_containerd_containerd_api_services_tasks_v1_tasks_proto protoreflect.FileDescriptor
View Source 
var Tasks_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "containerd.services.tasks.v1.Tasks",
	HandlerType: (*TasksServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Tasks_Create_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _Tasks_Start_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Tasks_Delete_Handler,
		},
		{
			MethodName: "DeleteProcess",
			Handler:    _Tasks_DeleteProcess_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Tasks_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Tasks_List_Handler,
		},
		{
			MethodName: "Kill",
			Handler:    _Tasks_Kill_Handler,
		},
		{
			MethodName: "Exec",
			Handler:    _Tasks_Exec_Handler,
		},
		{
			MethodName: "ResizePty",
			Handler:    _Tasks_ResizePty_Handler,
		},
		{
			MethodName: "CloseIO",
			Handler:    _Tasks_CloseIO_Handler,
		},
		{
			MethodName: "Pause",
			Handler:    _Tasks_Pause_Handler,
		},
		{
			MethodName: "Resume",
			Handler:    _Tasks_Resume_Handler,
		},
		{
			MethodName: "ListPids",
			Handler:    _Tasks_ListPids_Handler,
		},
		{
			MethodName: "Checkpoint",
			Handler:    _Tasks_Checkpoint_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Tasks_Update_Handler,
		},
		{
			MethodName: "Metrics",
			Handler:    _Tasks_Metrics_Handler,
		},
		{
			MethodName: "Wait",
			Handler:    _Tasks_Wait_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/containerd/containerd/api/services/tasks/v1/tasks.proto",
}

Tasks_ServiceDesc is the grpc.ServiceDesc for Tasks service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTasksServer 

func RegisterTasksServer(s grpc.ServiceRegistrar, 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 string     `protobuf:"bytes,2,opt,name=parent_checkpoint,json=parentCheckpoint,proto3" json:"parent_checkpoint,omitempty"`
	Options          *anypb.Any `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckpointTaskRequest) Descriptor deprecated 

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

Deprecated: Use CheckpointTaskRequest.ProtoReflect.Descriptor instead.

func (*CheckpointTaskRequest) GetContainerID added in v1.7.0 

func (x *CheckpointTaskRequest) GetContainerID() string

func (*CheckpointTaskRequest) GetOptions added in v1.7.0 

func (x *CheckpointTaskRequest) GetOptions() *anypb.Any

func (*CheckpointTaskRequest) GetParentCheckpoint added in v1.7.0 

func (x *CheckpointTaskRequest) GetParentCheckpoint() string

func (*CheckpointTaskRequest) ProtoMessage 

func (*CheckpointTaskRequest) ProtoMessage()

func (*CheckpointTaskRequest) ProtoReflect added in v1.7.0 

func (x *CheckpointTaskRequest) ProtoReflect() protoreflect.Message

func (*CheckpointTaskRequest) Reset 

func (x *CheckpointTaskRequest) Reset()

func (*CheckpointTaskRequest) String 

func (x *CheckpointTaskRequest) String() string

type CheckpointTaskResponse 

type CheckpointTaskResponse struct {
	Descriptors []*types.Descriptor `protobuf:"bytes,1,rep,name=descriptors,proto3" json:"descriptors,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckpointTaskResponse) Descriptor deprecated 

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

Deprecated: Use CheckpointTaskResponse.ProtoReflect.Descriptor instead.

func (*CheckpointTaskResponse) GetDescriptors added in v1.7.0 

func (x *CheckpointTaskResponse) GetDescriptors() []*types.Descriptor

func (*CheckpointTaskResponse) ProtoMessage 

func (*CheckpointTaskResponse) ProtoMessage()

func (*CheckpointTaskResponse) ProtoReflect added in v1.7.0 

func (x *CheckpointTaskResponse) ProtoReflect() protoreflect.Message

func (*CheckpointTaskResponse) Reset 

func (x *CheckpointTaskResponse) Reset()

func (*CheckpointTaskResponse) String 

func (x *CheckpointTaskResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*CloseIORequest) Descriptor deprecated 

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

Deprecated: Use CloseIORequest.ProtoReflect.Descriptor instead.

func (*CloseIORequest) GetContainerID added in v1.7.0 

func (x *CloseIORequest) GetContainerID() string

func (*CloseIORequest) GetExecID added in v1.7.0 

func (x *CloseIORequest) GetExecID() string

func (*CloseIORequest) GetStdin added in v1.7.0 

func (x *CloseIORequest) GetStdin() bool

func (*CloseIORequest) ProtoMessage 

func (*CloseIORequest) ProtoMessage()

func (*CloseIORequest) ProtoReflect added in v1.7.0 

func (x *CloseIORequest) ProtoReflect() protoreflect.Message

func (*CloseIORequest) Reset 

func (x *CloseIORequest) Reset()

func (*CloseIORequest) String 

func (x *CloseIORequest) String() string

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      []*types.Mount    `protobuf:"bytes,3,rep,name=rootfs,proto3" 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  *types.Descriptor `protobuf:"bytes,8,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	Options     *anypb.Any        `protobuf:"bytes,9,opt,name=options,proto3" json:"options,omitempty"`
	RuntimePath string            `protobuf:"bytes,10,opt,name=runtime_path,json=runtimePath,proto3" json:"runtime_path,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetCheckpoint added in v1.7.0 

func (x *CreateTaskRequest) GetCheckpoint() *types.Descriptor

func (*CreateTaskRequest) GetContainerID added in v1.7.0 

func (x *CreateTaskRequest) GetContainerID() string

func (*CreateTaskRequest) GetOptions added in v1.7.0 

func (x *CreateTaskRequest) GetOptions() *anypb.Any

func (*CreateTaskRequest) GetRootfs added in v1.7.0 

func (x *CreateTaskRequest) GetRootfs() []*types.Mount

func (*CreateTaskRequest) GetRuntimePath added in v1.7.0 

func (x *CreateTaskRequest) GetRuntimePath() string

func (*CreateTaskRequest) GetStderr added in v1.7.0 

func (x *CreateTaskRequest) GetStderr() string

func (*CreateTaskRequest) GetStdin added in v1.7.0 

func (x *CreateTaskRequest) GetStdin() string

func (*CreateTaskRequest) GetStdout added in v1.7.0 

func (x *CreateTaskRequest) GetStdout() string

func (*CreateTaskRequest) GetTerminal added in v1.7.0 

func (x *CreateTaskRequest) GetTerminal() bool

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect added in v1.7.0 

func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message

func (*CreateTaskRequest) Reset 

func (x *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String 

func (x *CreateTaskRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*CreateTaskResponse) Descriptor deprecated 

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

Deprecated: Use CreateTaskResponse.ProtoReflect.Descriptor instead.

func (*CreateTaskResponse) GetContainerID added in v1.7.0 

func (x *CreateTaskResponse) GetContainerID() string

func (*CreateTaskResponse) GetPid added in v1.7.0 

func (x *CreateTaskResponse) GetPid() uint32

func (*CreateTaskResponse) ProtoMessage 

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) ProtoReflect added in v1.7.0 

func (x *CreateTaskResponse) ProtoReflect() protoreflect.Message

func (*CreateTaskResponse) Reset 

func (x *CreateTaskResponse) Reset()

func (*CreateTaskResponse) String 

func (x *CreateTaskResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*DeleteProcessRequest) Descriptor deprecated 

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

Deprecated: Use DeleteProcessRequest.ProtoReflect.Descriptor instead.

func (*DeleteProcessRequest) GetContainerID added in v1.7.0 

func (x *DeleteProcessRequest) GetContainerID() string

func (*DeleteProcessRequest) GetExecID added in v1.7.0 

func (x *DeleteProcessRequest) GetExecID() string

func (*DeleteProcessRequest) ProtoMessage 

func (*DeleteProcessRequest) ProtoMessage()

func (*DeleteProcessRequest) ProtoReflect added in v1.7.0 

func (x *DeleteProcessRequest) ProtoReflect() protoreflect.Message

func (*DeleteProcessRequest) Reset 

func (x *DeleteProcessRequest) Reset()

func (*DeleteProcessRequest) String 

func (x *DeleteProcessRequest) String() string

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   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=exited_at,json=exitedAt,proto3" json:"exited_at,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetExitStatus added in v1.7.0 

func (x *DeleteResponse) GetExitStatus() uint32

func (*DeleteResponse) GetExitedAt added in v1.7.0 

func (x *DeleteResponse) GetExitedAt() *timestamppb.Timestamp

func (*DeleteResponse) GetID added in v1.7.0 

func (x *DeleteResponse) GetID() string

func (*DeleteResponse) GetPid added in v1.7.0 

func (x *DeleteResponse) GetPid() uint32

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect added in v1.7.0 

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type DeleteTaskRequest 

type DeleteTaskRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTaskRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetContainerID added in v1.7.0 

func (x *DeleteTaskRequest) GetContainerID() string

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect added in v1.7.0 

func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteTaskRequest) Reset 

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (x *DeleteTaskRequest) String() string

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 *anypb.Any `protobuf:"bytes,6,opt,name=spec,proto3" json:"spec,omitempty"`
	// id of the exec process
	ExecID string `protobuf:"bytes,7,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecProcessRequest) Descriptor deprecated 

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

Deprecated: Use ExecProcessRequest.ProtoReflect.Descriptor instead.

func (*ExecProcessRequest) GetContainerID added in v1.7.0 

func (x *ExecProcessRequest) GetContainerID() string

func (*ExecProcessRequest) GetExecID added in v1.7.0 

func (x *ExecProcessRequest) GetExecID() string

func (*ExecProcessRequest) GetSpec added in v1.7.0 

func (x *ExecProcessRequest) GetSpec() *anypb.Any

func (*ExecProcessRequest) GetStderr added in v1.7.0 

func (x *ExecProcessRequest) GetStderr() string

func (*ExecProcessRequest) GetStdin added in v1.7.0 

func (x *ExecProcessRequest) GetStdin() string

func (*ExecProcessRequest) GetStdout added in v1.7.0 

func (x *ExecProcessRequest) GetStdout() string

func (*ExecProcessRequest) GetTerminal added in v1.7.0 

func (x *ExecProcessRequest) GetTerminal() bool

func (*ExecProcessRequest) ProtoMessage 

func (*ExecProcessRequest) ProtoMessage()

func (*ExecProcessRequest) ProtoReflect added in v1.7.0 

func (x *ExecProcessRequest) ProtoReflect() protoreflect.Message

func (*ExecProcessRequest) Reset 

func (x *ExecProcessRequest) Reset()

func (*ExecProcessRequest) String 

func (x *ExecProcessRequest) String() string

type ExecProcessResponse 

type ExecProcessResponse struct {
	// contains filtered or unexported fields
}

func (*ExecProcessResponse) Descriptor deprecated 

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

Deprecated: Use ExecProcessResponse.ProtoReflect.Descriptor instead.

func (*ExecProcessResponse) ProtoMessage 

func (*ExecProcessResponse) ProtoMessage()

func (*ExecProcessResponse) ProtoReflect added in v1.7.0 

func (x *ExecProcessResponse) ProtoReflect() protoreflect.Message

func (*ExecProcessResponse) Reset 

func (x *ExecProcessResponse) Reset()

func (*ExecProcessResponse) String 

func (x *ExecProcessResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetContainerID added in v1.7.0 

func (x *GetRequest) GetContainerID() string

func (*GetRequest) GetExecID added in v1.7.0 

func (x *GetRequest) GetExecID() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect added in v1.7.0 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Process *task.Process `protobuf:"bytes,1,opt,name=process,proto3" json:"process,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetProcess added in v1.7.0 

func (x *GetResponse) GetProcess() *task.Process

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect added in v1.7.0 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*KillRequest) Descriptor deprecated 

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

Deprecated: Use KillRequest.ProtoReflect.Descriptor instead.

func (*KillRequest) GetAll added in v1.7.0 

func (x *KillRequest) GetAll() bool

func (*KillRequest) GetContainerID added in v1.7.0 

func (x *KillRequest) GetContainerID() string

func (*KillRequest) GetExecID added in v1.7.0 

func (x *KillRequest) GetExecID() string

func (*KillRequest) GetSignal added in v1.7.0 

func (x *KillRequest) GetSignal() uint32

func (*KillRequest) ProtoMessage 

func (*KillRequest) ProtoMessage()

func (*KillRequest) ProtoReflect added in v1.7.0 

func (x *KillRequest) ProtoReflect() protoreflect.Message

func (*KillRequest) Reset 

func (x *KillRequest) Reset()

func (*KillRequest) String 

func (x *KillRequest) String() string

type ListPidsRequest 

type ListPidsRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPidsRequest) Descriptor deprecated 

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

Deprecated: Use ListPidsRequest.ProtoReflect.Descriptor instead.

func (*ListPidsRequest) GetContainerID added in v1.7.0 

func (x *ListPidsRequest) GetContainerID() string

func (*ListPidsRequest) ProtoMessage 

func (*ListPidsRequest) ProtoMessage()

func (*ListPidsRequest) ProtoReflect added in v1.7.0 

func (x *ListPidsRequest) ProtoReflect() protoreflect.Message

func (*ListPidsRequest) Reset 

func (x *ListPidsRequest) Reset()

func (*ListPidsRequest) String 

func (x *ListPidsRequest) String() string

type ListPidsResponse 

type ListPidsResponse struct {

	// Processes includes the process ID and additional process information
	Processes []*task.ProcessInfo `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPidsResponse) Descriptor deprecated 

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

Deprecated: Use ListPidsResponse.ProtoReflect.Descriptor instead.

func (*ListPidsResponse) GetProcesses added in v1.7.0 

func (x *ListPidsResponse) GetProcesses() []*task.ProcessInfo

func (*ListPidsResponse) ProtoMessage 

func (*ListPidsResponse) ProtoMessage()

func (*ListPidsResponse) ProtoReflect added in v1.7.0 

func (x *ListPidsResponse) ProtoReflect() protoreflect.Message

func (*ListPidsResponse) Reset 

func (x *ListPidsResponse) Reset()

func (*ListPidsResponse) String 

func (x *ListPidsResponse) String() string

type ListTasksRequest 

type ListTasksRequest struct {
	Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetFilter added in v1.7.0 

func (x *ListTasksRequest) GetFilter() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect added in v1.7.0 

func (x *ListTasksRequest) ProtoReflect() protoreflect.Message

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListTasksResponse 

type ListTasksResponse struct {
	Tasks []*task.Process `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetTasks added in v1.7.0 

func (x *ListTasksResponse) GetTasks() []*task.Process

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect added in v1.7.0 

func (x *ListTasksResponse) ProtoReflect() protoreflect.Message

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

type MetricsRequest 

type MetricsRequest struct {
	Filters []string `protobuf:"bytes,1,rep,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsRequest) Descriptor deprecated 

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

Deprecated: Use MetricsRequest.ProtoReflect.Descriptor instead.

func (*MetricsRequest) GetFilters added in v1.7.0 

func (x *MetricsRequest) GetFilters() []string

func (*MetricsRequest) ProtoMessage 

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) ProtoReflect added in v1.7.0 

func (x *MetricsRequest) ProtoReflect() protoreflect.Message

func (*MetricsRequest) Reset 

func (x *MetricsRequest) Reset()

func (*MetricsRequest) String 

func (x *MetricsRequest) String() string

type MetricsResponse 

type MetricsResponse struct {
	Metrics []*types.Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricsResponse) Descriptor deprecated 

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

Deprecated: Use MetricsResponse.ProtoReflect.Descriptor instead.

func (*MetricsResponse) GetMetrics added in v1.7.0 

func (x *MetricsResponse) GetMetrics() []*types.Metric

func (*MetricsResponse) ProtoMessage 

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect added in v1.7.0 

func (x *MetricsResponse) ProtoReflect() protoreflect.Message

func (*MetricsResponse) Reset 

func (x *MetricsResponse) Reset()

func (*MetricsResponse) String 

func (x *MetricsResponse) String() string

type PauseTaskRequest 

type PauseTaskRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseTaskRequest) Descriptor deprecated 

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

Deprecated: Use PauseTaskRequest.ProtoReflect.Descriptor instead.

func (*PauseTaskRequest) GetContainerID added in v1.7.0 

func (x *PauseTaskRequest) GetContainerID() string

func (*PauseTaskRequest) ProtoMessage 

func (*PauseTaskRequest) ProtoMessage()

func (*PauseTaskRequest) ProtoReflect added in v1.7.0 

func (x *PauseTaskRequest) ProtoReflect() protoreflect.Message

func (*PauseTaskRequest) Reset 

func (x *PauseTaskRequest) Reset()

func (*PauseTaskRequest) String 

func (x *PauseTaskRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ResizePtyRequest) Descriptor deprecated 

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

Deprecated: Use ResizePtyRequest.ProtoReflect.Descriptor instead.

func (*ResizePtyRequest) GetContainerID added in v1.7.0 

func (x *ResizePtyRequest) GetContainerID() string

func (*ResizePtyRequest) GetExecID added in v1.7.0 

func (x *ResizePtyRequest) GetExecID() string

func (*ResizePtyRequest) GetHeight added in v1.7.0 

func (x *ResizePtyRequest) GetHeight() uint32

func (*ResizePtyRequest) GetWidth added in v1.7.0 

func (x *ResizePtyRequest) GetWidth() uint32

func (*ResizePtyRequest) ProtoMessage 

func (*ResizePtyRequest) ProtoMessage()

func (*ResizePtyRequest) ProtoReflect added in v1.7.0 

func (x *ResizePtyRequest) ProtoReflect() protoreflect.Message

func (*ResizePtyRequest) Reset 

func (x *ResizePtyRequest) Reset()

func (*ResizePtyRequest) String 

func (x *ResizePtyRequest) String() string

type ResumeTaskRequest 

type ResumeTaskRequest struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeTaskRequest) Descriptor deprecated 

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

Deprecated: Use ResumeTaskRequest.ProtoReflect.Descriptor instead.

func (*ResumeTaskRequest) GetContainerID added in v1.7.0 

func (x *ResumeTaskRequest) GetContainerID() string

func (*ResumeTaskRequest) ProtoMessage 

func (*ResumeTaskRequest) ProtoMessage()

func (*ResumeTaskRequest) ProtoReflect added in v1.7.0 

func (x *ResumeTaskRequest) ProtoReflect() protoreflect.Message

func (*ResumeTaskRequest) Reset 

func (x *ResumeTaskRequest) Reset()

func (*ResumeTaskRequest) String 

func (x *ResumeTaskRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*StartRequest) Descriptor deprecated 

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

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) GetContainerID added in v1.7.0 

func (x *StartRequest) GetContainerID() string

func (*StartRequest) GetExecID added in v1.7.0 

func (x *StartRequest) GetExecID() string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect added in v1.7.0 

func (x *StartRequest) ProtoReflect() protoreflect.Message

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) String 

func (x *StartRequest) String() string

type StartResponse 

type StartResponse struct {
	Pid uint32 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*StartResponse) Descriptor deprecated 

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

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) GetPid added in v1.7.0 

func (x *StartResponse) GetPid() uint32

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect added in v1.7.0 

func (x *StartResponse) ProtoReflect() protoreflect.Message

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) String 

func (x *StartResponse) String() string

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) (*emptypb.Empty, error)
	Exec(ctx context.Context, in *ExecProcessRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ResizePty(ctx context.Context, in *ResizePtyRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CloseIO(ctx context.Context, in *CloseIORequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Pause(ctx context.Context, in *PauseTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Resume(ctx context.Context, in *ResumeTaskRequest, opts ...grpc.CallOption) (*emptypb.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) (*emptypb.Empty, error)
	Metrics(ctx context.Context, in *MetricsRequest, opts ...grpc.CallOption) (*MetricsResponse, error)
	Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error)
}

TasksClient is the client API for Tasks service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTasksClient 

func NewTasksClient(cc grpc.ClientConnInterface) 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) (*emptypb.Empty, error)
	Exec(context.Context, *ExecProcessRequest) (*emptypb.Empty, error)
	ResizePty(context.Context, *ResizePtyRequest) (*emptypb.Empty, error)
	CloseIO(context.Context, *CloseIORequest) (*emptypb.Empty, error)
	Pause(context.Context, *PauseTaskRequest) (*emptypb.Empty, error)
	Resume(context.Context, *ResumeTaskRequest) (*emptypb.Empty, error)
	ListPids(context.Context, *ListPidsRequest) (*ListPidsResponse, error)
	Checkpoint(context.Context, *CheckpointTaskRequest) (*CheckpointTaskResponse, error)
	Update(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)
	Metrics(context.Context, *MetricsRequest) (*MetricsResponse, error)
	Wait(context.Context, *WaitRequest) (*WaitResponse, error)
	// contains filtered or unexported methods
}

TasksServer is the server API for Tasks service. All implementations must embed UnimplementedTasksServer for forward compatibility

type UnimplementedTasksServer added in v1.4.0 

type UnimplementedTasksServer struct {
}

UnimplementedTasksServer must be embedded to have forward compatible implementations.

func (UnimplementedTasksServer) Checkpoint added in v1.4.0 

func (UnimplementedTasksServer) Checkpoint(context.Context, *CheckpointTaskRequest) (*CheckpointTaskResponse, error)

func (UnimplementedTasksServer) CloseIO added in v1.4.0 

func (UnimplementedTasksServer) CloseIO(context.Context, *CloseIORequest) (*emptypb.Empty, error)

func (UnimplementedTasksServer) Create added in v1.4.0 

func (UnimplementedTasksServer) Create(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)

func (UnimplementedTasksServer) Delete added in v1.4.0 

func (UnimplementedTasksServer) Delete(context.Context, *DeleteTaskRequest) (*DeleteResponse, error)

func (UnimplementedTasksServer) DeleteProcess added in v1.4.0 

func (UnimplementedTasksServer) DeleteProcess(context.Context, *DeleteProcessRequest) (*DeleteResponse, error)

func (UnimplementedTasksServer) Exec added in v1.4.0 

func (UnimplementedTasksServer) Exec(context.Context, *ExecProcessRequest) (*emptypb.Empty, error)

func (UnimplementedTasksServer) Get added in v1.4.0 

func (UnimplementedTasksServer) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedTasksServer) Kill added in v1.4.0 

func (UnimplementedTasksServer) Kill(context.Context, *KillRequest) (*emptypb.Empty, error)

func (UnimplementedTasksServer) List added in v1.4.0 

func (UnimplementedTasksServer) List(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

func (UnimplementedTasksServer) ListPids added in v1.4.0 

func (UnimplementedTasksServer) ListPids(context.Context, *ListPidsRequest) (*ListPidsResponse, error)

func (UnimplementedTasksServer) Metrics added in v1.4.0 

func (UnimplementedTasksServer) Metrics(context.Context, *MetricsRequest) (*MetricsResponse, error)

func (UnimplementedTasksServer) Pause added in v1.4.0 

func (UnimplementedTasksServer) Pause(context.Context, *PauseTaskRequest) (*emptypb.Empty, error)

func (UnimplementedTasksServer) ResizePty added in v1.4.0 

func (UnimplementedTasksServer) ResizePty(context.Context, *ResizePtyRequest) (*emptypb.Empty, error)

func (UnimplementedTasksServer) Resume added in v1.4.0 

func (UnimplementedTasksServer) Resume(context.Context, *ResumeTaskRequest) (*emptypb.Empty, error)

func (UnimplementedTasksServer) Start added in v1.4.0 

func (UnimplementedTasksServer) Start(context.Context, *StartRequest) (*StartResponse, error)

func (UnimplementedTasksServer) Update added in v1.4.0 

func (UnimplementedTasksServer) Update(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)

func (UnimplementedTasksServer) Wait added in v1.4.0 

func (UnimplementedTasksServer) Wait(context.Context, *WaitRequest) (*WaitResponse, error)

type UnsafeTasksServer added in v1.7.0 

type UnsafeTasksServer interface {
	// contains filtered or unexported methods
}

UnsafeTasksServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TasksServer will result in compilation errors.

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	ContainerID string            `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Resources   *anypb.Any        `protobuf:"bytes,2,opt,name=resources,proto3" json:"resources,omitempty"`
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateTaskRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskRequest) GetAnnotations added in v1.7.0 

func (x *UpdateTaskRequest) GetAnnotations() map[string]string

func (*UpdateTaskRequest) GetContainerID added in v1.7.0 

func (x *UpdateTaskRequest) GetContainerID() string

func (*UpdateTaskRequest) GetResources added in v1.7.0 

func (x *UpdateTaskRequest) GetResources() *anypb.Any

func (*UpdateTaskRequest) ProtoMessage 

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) ProtoReflect added in v1.7.0 

func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message

func (*UpdateTaskRequest) Reset 

func (x *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) String 

func (x *UpdateTaskRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*WaitRequest) Descriptor deprecated 

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

Deprecated: Use WaitRequest.ProtoReflect.Descriptor instead.

func (*WaitRequest) GetContainerID added in v1.7.0 

func (x *WaitRequest) GetContainerID() string

func (*WaitRequest) GetExecID added in v1.7.0 

func (x *WaitRequest) GetExecID() string

func (*WaitRequest) ProtoMessage 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) ProtoReflect added in v1.7.0 

func (x *WaitRequest) ProtoReflect() protoreflect.Message

func (*WaitRequest) Reset 

func (x *WaitRequest) Reset()

func (*WaitRequest) String 

func (x *WaitRequest) String() string

type WaitResponse 

type WaitResponse struct {
	ExitStatus uint32                 `protobuf:"varint,1,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=exited_at,json=exitedAt,proto3" json:"exited_at,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitResponse) Descriptor deprecated 

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

Deprecated: Use WaitResponse.ProtoReflect.Descriptor instead.

func (*WaitResponse) GetExitStatus added in v1.7.0 

func (x *WaitResponse) GetExitStatus() uint32

func (*WaitResponse) GetExitedAt added in v1.7.0 

func (x *WaitResponse) GetExitedAt() *timestamppb.Timestamp

func (*WaitResponse) ProtoMessage 

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) ProtoReflect added in v1.7.0 

func (x *WaitResponse) ProtoReflect() protoreflect.Message

func (*WaitResponse) Reset 

func (x *WaitResponse) Reset()

func (*WaitResponse) String 

func (x *WaitResponse) String() string

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.