task

package
v1.7.10 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2023 License: Apache-2.0 Imports: 14 Imported by: 7

Documentation

Overview

Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: github.com/containerd/containerd/api/runtime/task/v3/shim.proto

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_containerd_containerd_api_runtime_task_v3_shim_proto protoreflect.FileDescriptor
View Source 
var Task_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "containerd.task.v3.Task",
	HandlerType: (*TaskServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "State",
			Handler:    _Task_State_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _Task_Create_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _Task_Start_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Task_Delete_Handler,
		},
		{
			MethodName: "Pids",
			Handler:    _Task_Pids_Handler,
		},
		{
			MethodName: "Pause",
			Handler:    _Task_Pause_Handler,
		},
		{
			MethodName: "Resume",
			Handler:    _Task_Resume_Handler,
		},
		{
			MethodName: "Checkpoint",
			Handler:    _Task_Checkpoint_Handler,
		},
		{
			MethodName: "Kill",
			Handler:    _Task_Kill_Handler,
		},
		{
			MethodName: "Exec",
			Handler:    _Task_Exec_Handler,
		},
		{
			MethodName: "ResizePty",
			Handler:    _Task_ResizePty_Handler,
		},
		{
			MethodName: "CloseIO",
			Handler:    _Task_CloseIO_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Task_Update_Handler,
		},
		{
			MethodName: "Wait",
			Handler:    _Task_Wait_Handler,
		},
		{
			MethodName: "Stats",
			Handler:    _Task_Stats_Handler,
		},
		{
			MethodName: "Connect",
			Handler:    _Task_Connect_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Task_Shutdown_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/containerd/containerd/api/runtime/task/v3/shim.proto",
}

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

Functions

func RegisterTTRPCTaskService 

func RegisterTTRPCTaskService(srv *ttrpc.Server, svc TTRPCTaskService)

func RegisterTaskServer 

func RegisterTaskServer(s grpc.ServiceRegistrar, srv TaskServer)

Types

type CheckpointTaskRequest 

type CheckpointTaskRequest struct {
	ID      string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Path    string     `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Options *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) GetID 

func (x *CheckpointTaskRequest) GetID() string

func (*CheckpointTaskRequest) GetOptions 

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

func (*CheckpointTaskRequest) GetPath 

func (x *CheckpointTaskRequest) GetPath() 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 CloseIORequest 

type CloseIORequest struct {
	ID     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Stdin  bool   `protobuf:"varint,3,opt,name=stdin,proto3" json:"stdin,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseIORequest) Descriptor deprecated 

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

Deprecated: Use CloseIORequest.ProtoReflect.Descriptor instead.

func (*CloseIORequest) GetExecID 

func (x *CloseIORequest) GetExecID() string

func (*CloseIORequest) GetID 

func (x *CloseIORequest) GetID() 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 ConnectRequest 

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

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetID 

func (x *ConnectRequest) GetID() string

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

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

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type ConnectResponse 

type ConnectResponse struct {
	ShimPid uint32 `protobuf:"varint,1,opt,name=shim_pid,json=shimPid,proto3" json:"shim_pid,omitempty"`
	TaskPid uint32 `protobuf:"varint,2,opt,name=task_pid,json=taskPid,proto3" json:"task_pid,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectResponse) Descriptor deprecated 

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

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetShimPid 

func (x *ConnectResponse) GetShimPid() uint32

func (*ConnectResponse) GetTaskPid 

func (x *ConnectResponse) GetTaskPid() uint32

func (*ConnectResponse) GetVersion 

func (x *ConnectResponse) GetVersion() string

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect 

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

func (*ConnectResponse) Reset 

func (x *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (x *ConnectResponse) String() string

type CreateTaskRequest 

type CreateTaskRequest struct {
	ID               string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Bundle           string         `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Rootfs           []*types.Mount `protobuf:"bytes,3,rep,name=rootfs,proto3" json:"rootfs,omitempty"`
	Terminal         bool           `protobuf:"varint,4,opt,name=terminal,proto3" json:"terminal,omitempty"`
	Stdin            string         `protobuf:"bytes,5,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout           string         `protobuf:"bytes,6,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr           string         `protobuf:"bytes,7,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Checkpoint       string         `protobuf:"bytes,8,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	ParentCheckpoint string         `protobuf:"bytes,9,opt,name=parent_checkpoint,json=parentCheckpoint,proto3" json:"parent_checkpoint,omitempty"`
	Options          *anypb.Any     `protobuf:"bytes,10,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetBundle 

func (x *CreateTaskRequest) GetBundle() string

func (*CreateTaskRequest) GetCheckpoint 

func (x *CreateTaskRequest) GetCheckpoint() string

func (*CreateTaskRequest) GetID 

func (x *CreateTaskRequest) GetID() string

func (*CreateTaskRequest) GetOptions 

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

func (*CreateTaskRequest) GetParentCheckpoint 

func (x *CreateTaskRequest) GetParentCheckpoint() string

func (*CreateTaskRequest) GetRootfs 

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

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 {
	Pid uint32 `protobuf:"varint,1,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) 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 DeleteRequest 

type DeleteRequest struct {
	ID     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetExecID 

func (x *DeleteRequest) GetExecID() string

func (*DeleteRequest) GetID 

func (x *DeleteRequest) GetID() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Pid        uint32                 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitStatus uint32                 `protobuf:"varint,2,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt   *timestamppb.Timestamp `protobuf:"bytes,3,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) 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 ExecProcessRequest 

type ExecProcessRequest struct {
	ID       string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID   string     `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Terminal bool       `protobuf:"varint,3,opt,name=terminal,proto3" json:"terminal,omitempty"`
	Stdin    string     `protobuf:"bytes,4,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout   string     `protobuf:"bytes,5,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr   string     `protobuf:"bytes,6,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Spec     *anypb.Any `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecProcessRequest) Descriptor deprecated 

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

Deprecated: Use ExecProcessRequest.ProtoReflect.Descriptor instead.

func (*ExecProcessRequest) GetExecID 

func (x *ExecProcessRequest) GetExecID() string

func (*ExecProcessRequest) GetID 

func (x *ExecProcessRequest) GetID() 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 KillRequest 

type KillRequest struct {
	ID     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Signal uint32 `protobuf:"varint,3,opt,name=signal,proto3" json:"signal,omitempty"`
	All    bool   `protobuf:"varint,4,opt,name=all,proto3" json:"all,omitempty"`
	// 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) GetExecID 

func (x *KillRequest) GetExecID() string

func (*KillRequest) GetID 

func (x *KillRequest) GetID() 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 PauseRequest 

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

func (*PauseRequest) Descriptor deprecated 

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

Deprecated: Use PauseRequest.ProtoReflect.Descriptor instead.

func (*PauseRequest) GetID 

func (x *PauseRequest) GetID() string

func (*PauseRequest) ProtoMessage 

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) ProtoReflect 

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

func (*PauseRequest) Reset 

func (x *PauseRequest) Reset()

func (*PauseRequest) String 

func (x *PauseRequest) String() string

type PidsRequest 

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

func (*PidsRequest) Descriptor deprecated 

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

Deprecated: Use PidsRequest.ProtoReflect.Descriptor instead.

func (*PidsRequest) GetID 

func (x *PidsRequest) GetID() string

func (*PidsRequest) ProtoMessage 

func (*PidsRequest) ProtoMessage()

func (*PidsRequest) ProtoReflect 

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

func (*PidsRequest) Reset 

func (x *PidsRequest) Reset()

func (*PidsRequest) String 

func (x *PidsRequest) String() string

type PidsResponse 

type PidsResponse struct {
	Processes []*task.ProcessInfo `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*PidsResponse) Descriptor deprecated 

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

Deprecated: Use PidsResponse.ProtoReflect.Descriptor instead.

func (*PidsResponse) GetProcesses 

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

func (*PidsResponse) ProtoMessage 

func (*PidsResponse) ProtoMessage()

func (*PidsResponse) ProtoReflect 

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

func (*PidsResponse) Reset 

func (x *PidsResponse) Reset()

func (*PidsResponse) String 

func (x *PidsResponse) String() string

type ResizePtyRequest 

type ResizePtyRequest struct {
	ID     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Width  uint32 `protobuf:"varint,3,opt,name=width,proto3" json:"width,omitempty"`
	Height uint32 `protobuf:"varint,4,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

func (*ResizePtyRequest) Descriptor deprecated 

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

Deprecated: Use ResizePtyRequest.ProtoReflect.Descriptor instead.

func (*ResizePtyRequest) GetExecID 

func (x *ResizePtyRequest) GetExecID() string

func (*ResizePtyRequest) GetHeight 

func (x *ResizePtyRequest) GetHeight() uint32

func (*ResizePtyRequest) GetID 

func (x *ResizePtyRequest) GetID() string

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 ResumeRequest 

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

func (*ResumeRequest) Descriptor deprecated 

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetID 

func (x *ResumeRequest) GetID() string

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect 

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

func (*ResumeRequest) Reset 

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (x *ResumeRequest) String() string

type ShutdownRequest 

type ShutdownRequest struct {
	ID  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Now bool   `protobuf:"varint,2,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) GetID 

func (x *ShutdownRequest) GetID() string

func (*ShutdownRequest) GetNow 

func (x *ShutdownRequest) GetNow() bool

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type StartRequest 

type StartRequest struct {
	ID     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartRequest) Descriptor deprecated 

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

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) GetExecID 

func (x *StartRequest) GetExecID() string

func (*StartRequest) GetID 

func (x *StartRequest) GetID() 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 StateRequest 

type StateRequest struct {
	ID     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StateRequest) Descriptor deprecated 

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

Deprecated: Use StateRequest.ProtoReflect.Descriptor instead.

func (*StateRequest) GetExecID 

func (x *StateRequest) GetExecID() string

func (*StateRequest) GetID 

func (x *StateRequest) GetID() string

func (*StateRequest) ProtoMessage 

func (*StateRequest) ProtoMessage()

func (*StateRequest) ProtoReflect 

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

func (*StateRequest) Reset 

func (x *StateRequest) Reset()

func (*StateRequest) String 

func (x *StateRequest) String() string

type StateResponse 

type StateResponse struct {
	ID         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Bundle     string                 `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Pid        uint32                 `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
	Status     task.Status            `protobuf:"varint,4,opt,name=status,proto3,enum=containerd.v1.types.Status" json:"status,omitempty"`
	Stdin      string                 `protobuf:"bytes,5,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout     string                 `protobuf:"bytes,6,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr     string                 `protobuf:"bytes,7,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Terminal   bool                   `protobuf:"varint,8,opt,name=terminal,proto3" json:"terminal,omitempty"`
	ExitStatus uint32                 `protobuf:"varint,9,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt   *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=exited_at,json=exitedAt,proto3" json:"exited_at,omitempty"`
	ExecID     string                 `protobuf:"bytes,11,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StateResponse) Descriptor deprecated 

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

Deprecated: Use StateResponse.ProtoReflect.Descriptor instead.

func (*StateResponse) GetBundle 

func (x *StateResponse) GetBundle() string

func (*StateResponse) GetExecID 

func (x *StateResponse) GetExecID() string

func (*StateResponse) GetExitStatus 

func (x *StateResponse) GetExitStatus() uint32

func (*StateResponse) GetExitedAt 

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

func (*StateResponse) GetID 

func (x *StateResponse) GetID() string

func (*StateResponse) GetPid 

func (x *StateResponse) GetPid() uint32

func (*StateResponse) GetStatus 

func (x *StateResponse) GetStatus() task.Status

func (*StateResponse) GetStderr 

func (x *StateResponse) GetStderr() string

func (*StateResponse) GetStdin 

func (x *StateResponse) GetStdin() string

func (*StateResponse) GetStdout 

func (x *StateResponse) GetStdout() string

func (*StateResponse) GetTerminal 

func (x *StateResponse) GetTerminal() bool

func (*StateResponse) ProtoMessage 

func (*StateResponse) ProtoMessage()

func (*StateResponse) ProtoReflect 

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

func (*StateResponse) Reset 

func (x *StateResponse) Reset()

func (*StateResponse) String 

func (x *StateResponse) String() string

type StatsRequest 

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

func (*StatsRequest) Descriptor deprecated 

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

Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.

func (*StatsRequest) GetID 

func (x *StatsRequest) GetID() string

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) ProtoReflect 

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

func (*StatsRequest) Reset 

func (x *StatsRequest) Reset()

func (*StatsRequest) String 

func (x *StatsRequest) String() string

type StatsResponse 

type StatsResponse struct {
	Stats *anypb.Any `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsResponse) Descriptor deprecated 

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

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetStats 

func (x *StatsResponse) GetStats() *anypb.Any

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect 

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

func (*StatsResponse) Reset 

func (x *StatsResponse) Reset()

func (*StatsResponse) String 

func (x *StatsResponse) String() string

type TTRPCTaskService 

type TTRPCTaskService interface {
	State(context.Context, *StateRequest) (*StateResponse, error)
	Create(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Pids(context.Context, *PidsRequest) (*PidsResponse, error)
	Pause(context.Context, *PauseRequest) (*emptypb.Empty, error)
	Resume(context.Context, *ResumeRequest) (*emptypb.Empty, error)
	Checkpoint(context.Context, *CheckpointTaskRequest) (*emptypb.Empty, 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)
	Update(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)
	Wait(context.Context, *WaitRequest) (*WaitResponse, error)
	Stats(context.Context, *StatsRequest) (*StatsResponse, error)
	Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*emptypb.Empty, error)
}

func NewTTRPCTaskClient 

func NewTTRPCTaskClient(client *ttrpc.Client) TTRPCTaskService

type TaskClient 

type TaskClient interface {
	State(ctx context.Context, in *StateRequest, opts ...grpc.CallOption) (*StateResponse, error)
	Create(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Pids(ctx context.Context, in *PidsRequest, opts ...grpc.CallOption) (*PidsResponse, error)
	Pause(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Resume(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Checkpoint(ctx context.Context, in *CheckpointTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	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)
	Update(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (*WaitResponse, error)
	Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error)
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

TaskClient is the client API for Task 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 NewTaskClient 

func NewTaskClient(cc grpc.ClientConnInterface) TaskClient

type TaskServer 

type TaskServer interface {
	State(context.Context, *StateRequest) (*StateResponse, error)
	Create(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Pids(context.Context, *PidsRequest) (*PidsResponse, error)
	Pause(context.Context, *PauseRequest) (*emptypb.Empty, error)
	Resume(context.Context, *ResumeRequest) (*emptypb.Empty, error)
	Checkpoint(context.Context, *CheckpointTaskRequest) (*emptypb.Empty, 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)
	Update(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)
	Wait(context.Context, *WaitRequest) (*WaitResponse, error)
	Stats(context.Context, *StatsRequest) (*StatsResponse, error)
	Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

TaskServer is the server API for Task service. All implementations must embed UnimplementedTaskServer for forward compatibility

type UnimplementedTaskServer 

type UnimplementedTaskServer struct {
}

UnimplementedTaskServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServer) Checkpoint 

func (UnimplementedTaskServer) Checkpoint(context.Context, *CheckpointTaskRequest) (*emptypb.Empty, error)

func (UnimplementedTaskServer) CloseIO 

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

func (UnimplementedTaskServer) Connect 

func (UnimplementedTaskServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)

func (UnimplementedTaskServer) Create 

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

func (UnimplementedTaskServer) Delete 

func (UnimplementedTaskServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedTaskServer) Exec 

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

func (UnimplementedTaskServer) Kill 

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

func (UnimplementedTaskServer) Pause 

func (UnimplementedTaskServer) Pause(context.Context, *PauseRequest) (*emptypb.Empty, error)

func (UnimplementedTaskServer) Pids 

func (UnimplementedTaskServer) Pids(context.Context, *PidsRequest) (*PidsResponse, error)

func (UnimplementedTaskServer) ResizePty 

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

func (UnimplementedTaskServer) Resume 

func (UnimplementedTaskServer) Resume(context.Context, *ResumeRequest) (*emptypb.Empty, error)

func (UnimplementedTaskServer) Shutdown 

func (UnimplementedTaskServer) Shutdown(context.Context, *ShutdownRequest) (*emptypb.Empty, error)

func (UnimplementedTaskServer) Start 

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

func (UnimplementedTaskServer) State 

func (UnimplementedTaskServer) State(context.Context, *StateRequest) (*StateResponse, error)

func (UnimplementedTaskServer) Stats 

func (UnimplementedTaskServer) Stats(context.Context, *StatsRequest) (*StatsResponse, error)

func (UnimplementedTaskServer) Update 

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

func (UnimplementedTaskServer) Wait 

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

type UnsafeTaskServer 

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

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

type UpdateTaskRequest 

type UpdateTaskRequest struct {
	ID          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"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) GetID 

func (x *UpdateTaskRequest) GetID() 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 {
	ID     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ExecID string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitRequest) Descriptor deprecated 

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

Deprecated: Use WaitRequest.ProtoReflect.Descriptor instead.

func (*WaitRequest) GetExecID 

func (x *WaitRequest) GetExecID() string

func (*WaitRequest) GetID 

func (x *WaitRequest) GetID() 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.