tasks

package
v1.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2024 License: Apache-2.0 Imports: 14 Imported by: 532

Documentation

Overview

Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: github.com/containerd/containerd/api/services/tasks/v1/tasks.proto

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 RegisterTTRPCTasksService added in v1.8.0 

func RegisterTTRPCTasksService(srv *ttrpc.Server, svc TTRPCTasksService)

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 

func (x *CheckpointTaskRequest) GetContainerID() string

func (*CheckpointTaskRequest) GetOptions 

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

func (*CheckpointTaskRequest) GetParentCheckpoint 

func (x *CheckpointTaskRequest) GetParentCheckpoint() string

func (*CheckpointTaskRequest) ProtoMessage 

func (*CheckpointTaskRequest) ProtoMessage()

func (*CheckpointTaskRequest) ProtoReflect 

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 

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

func (*CheckpointTaskResponse) ProtoMessage 

func (*CheckpointTaskResponse) ProtoMessage()

func (*CheckpointTaskResponse) ProtoReflect 

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 

func (x *CloseIORequest) GetContainerID() string

func (*CloseIORequest) GetExecID 

func (x *CloseIORequest) GetExecID() string

func (*CloseIORequest) GetStdin 

func (x *CloseIORequest) GetStdin() bool

func (*CloseIORequest) ProtoMessage 

func (*CloseIORequest) ProtoMessage()

func (*CloseIORequest) ProtoReflect 

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 

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

func (*CreateTaskRequest) GetContainerID 

func (x *CreateTaskRequest) GetContainerID() string

func (*CreateTaskRequest) GetOptions 

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

func (*CreateTaskRequest) GetRootfs 

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

func (*CreateTaskRequest) GetRuntimePath 

func (x *CreateTaskRequest) GetRuntimePath() string

func (*CreateTaskRequest) GetStderr 

func (x *CreateTaskRequest) GetStderr() string

func (*CreateTaskRequest) GetStdin 

func (x *CreateTaskRequest) GetStdin() string

func (*CreateTaskRequest) GetStdout 

func (x *CreateTaskRequest) GetStdout() string

func (*CreateTaskRequest) GetTerminal 

func (x *CreateTaskRequest) GetTerminal() bool

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect 

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 

func (x *CreateTaskResponse) GetContainerID() string

func (*CreateTaskResponse) GetPid 

func (x *CreateTaskResponse) GetPid() uint32

func (*CreateTaskResponse) ProtoMessage 

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) ProtoReflect 

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 

func (x *DeleteProcessRequest) GetContainerID() string

func (*DeleteProcessRequest) GetExecID 

func (x *DeleteProcessRequest) GetExecID() string

func (*DeleteProcessRequest) ProtoMessage 

func (*DeleteProcessRequest) ProtoMessage()

func (*DeleteProcessRequest) ProtoReflect 

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 

func (x *DeleteResponse) GetExitStatus() uint32

func (*DeleteResponse) GetExitedAt 

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

func (*DeleteResponse) GetID 

func (x *DeleteResponse) GetID() string

func (*DeleteResponse) GetPid 

func (x *DeleteResponse) GetPid() uint32

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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 

func (x *DeleteTaskRequest) GetContainerID() string

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect 

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 

func (x *ExecProcessRequest) GetContainerID() string

func (*ExecProcessRequest) GetExecID 

func (x *ExecProcessRequest) GetExecID() string

func (*ExecProcessRequest) GetSpec 

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

func (*ExecProcessRequest) GetStderr 

func (x *ExecProcessRequest) GetStderr() string

func (*ExecProcessRequest) GetStdin 

func (x *ExecProcessRequest) GetStdin() string

func (*ExecProcessRequest) GetStdout 

func (x *ExecProcessRequest) GetStdout() string

func (*ExecProcessRequest) GetTerminal 

func (x *ExecProcessRequest) GetTerminal() bool

func (*ExecProcessRequest) ProtoMessage 

func (*ExecProcessRequest) ProtoMessage()

func (*ExecProcessRequest) ProtoReflect 

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 

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 

func (x *GetRequest) GetContainerID() string

func (*GetRequest) GetExecID 

func (x *GetRequest) GetExecID() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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 

func (x *KillRequest) GetAll() bool

func (*KillRequest) GetContainerID 

func (x *KillRequest) GetContainerID() string

func (*KillRequest) GetExecID 

func (x *KillRequest) GetExecID() string

func (*KillRequest) GetSignal 

func (x *KillRequest) GetSignal() uint32

func (*KillRequest) ProtoMessage 

func (*KillRequest) ProtoMessage()

func (*KillRequest) ProtoReflect 

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 

func (x *ListPidsRequest) GetContainerID() string

func (*ListPidsRequest) ProtoMessage 

func (*ListPidsRequest) ProtoMessage()

func (*ListPidsRequest) ProtoReflect 

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 

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

func (*ListPidsResponse) ProtoMessage 

func (*ListPidsResponse) ProtoMessage()

func (*ListPidsResponse) ProtoReflect 

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 

func (x *ListTasksRequest) GetFilter() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

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 

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

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

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 

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

func (*MetricsRequest) ProtoMessage 

func (*MetricsRequest) ProtoMessage()

func (*MetricsRequest) ProtoReflect 

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 

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

func (*MetricsResponse) ProtoMessage 

func (*MetricsResponse) ProtoMessage()

func (*MetricsResponse) ProtoReflect 

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 

func (x *PauseTaskRequest) GetContainerID() string

func (*PauseTaskRequest) ProtoMessage 

func (*PauseTaskRequest) ProtoMessage()

func (*PauseTaskRequest) ProtoReflect 

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 

func (x *ResizePtyRequest) GetContainerID() string

func (*ResizePtyRequest) GetExecID 

func (x *ResizePtyRequest) GetExecID() string

func (*ResizePtyRequest) GetHeight 

func (x *ResizePtyRequest) GetHeight() uint32

func (*ResizePtyRequest) GetWidth 

func (x *ResizePtyRequest) GetWidth() uint32

func (*ResizePtyRequest) ProtoMessage 

func (*ResizePtyRequest) ProtoMessage()

func (*ResizePtyRequest) ProtoReflect 

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 

func (x *ResumeTaskRequest) GetContainerID() string

func (*ResumeTaskRequest) ProtoMessage 

func (*ResumeTaskRequest) ProtoMessage()

func (*ResumeTaskRequest) ProtoReflect 

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 

func (x *StartRequest) GetContainerID() string

func (*StartRequest) GetExecID 

func (x *StartRequest) GetExecID() string

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

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 

func (x *StartResponse) GetPid() uint32

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect 

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

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) String 

func (x *StartResponse) String() string

type TTRPCTasksService added in v1.8.0 

type TTRPCTasksService interface {
	Create(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	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(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)
}

func NewTTRPCTasksClient added in v1.8.0 

func NewTTRPCTasksClient(client *ttrpc.Client) TTRPCTasksService

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 

type UnimplementedTasksServer struct {
}

UnimplementedTasksServer must be embedded to have forward compatible implementations.

func (UnimplementedTasksServer) Checkpoint 

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

func (UnimplementedTasksServer) CloseIO 

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

func (UnimplementedTasksServer) Create 

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

func (UnimplementedTasksServer) Delete 

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

func (UnimplementedTasksServer) DeleteProcess 

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

func (UnimplementedTasksServer) Exec 

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

func (UnimplementedTasksServer) Get 

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

func (UnimplementedTasksServer) Kill 

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

func (UnimplementedTasksServer) List 

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

func (UnimplementedTasksServer) ListPids 

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

func (UnimplementedTasksServer) Metrics 

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

func (UnimplementedTasksServer) Pause 

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

func (UnimplementedTasksServer) ResizePty 

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

func (UnimplementedTasksServer) Resume 

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

func (UnimplementedTasksServer) Start 

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

func (UnimplementedTasksServer) Update 

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

func (UnimplementedTasksServer) Wait 

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

type UnsafeTasksServer 

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 

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

func (*UpdateTaskRequest) GetContainerID 

func (x *UpdateTaskRequest) GetContainerID() string

func (*UpdateTaskRequest) GetResources 

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

func (*UpdateTaskRequest) ProtoMessage 

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) ProtoReflect 

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 

func (x *WaitRequest) GetContainerID() string

func (*WaitRequest) GetExecID 

func (x *WaitRequest) GetExecID() string

func (*WaitRequest) ProtoMessage 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) ProtoReflect 

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 

func (x *WaitResponse) GetExitStatus() uint32

func (*WaitResponse) GetExitedAt 

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

func (*WaitResponse) ProtoMessage 

func (*WaitResponse) ProtoMessage()

func (*WaitResponse) ProtoReflect 

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.