task

package
v0.9.201 Latest Latest
Warning

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

Go to latest
Published: Jun 3, 2024 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TaskService_Start_FullMethodName                 = "/cedana.services.task.TaskService/Start"
	TaskService_Dump_FullMethodName                  = "/cedana.services.task.TaskService/Dump"
	TaskService_Restore_FullMethodName               = "/cedana.services.task.TaskService/Restore"
	TaskService_Query_FullMethodName                 = "/cedana.services.task.TaskService/Query"
	TaskService_ContainerdDump_FullMethodName        = "/cedana.services.task.TaskService/ContainerdDump"
	TaskService_ContainerdRestore_FullMethodName     = "/cedana.services.task.TaskService/ContainerdRestore"
	TaskService_ContainerdQuery_FullMethodName       = "/cedana.services.task.TaskService/ContainerdQuery"
	TaskService_RuncDump_FullMethodName              = "/cedana.services.task.TaskService/RuncDump"
	TaskService_RuncRestore_FullMethodName           = "/cedana.services.task.TaskService/RuncRestore"
	TaskService_RuncQuery_FullMethodName             = "/cedana.services.task.TaskService/RuncQuery"
	TaskService_RuncGetPausePid_FullMethodName       = "/cedana.services.task.TaskService/RuncGetPausePid"
	TaskService_LogStreaming_FullMethodName          = "/cedana.services.task.TaskService/LogStreaming"
	TaskService_ProcessStateStreaming_FullMethodName = "/cedana.services.task.TaskService/ProcessStateStreaming"
)

Variables

View Source
var (
	CRType_name = map[int32]string{
		0: "LOCAL",
		1: "REMOTE",
	}
	CRType_value = map[string]int32{
		"LOCAL":  0,
		"REMOTE": 1,
	}
)

Enum value maps for CRType.

View Source
var (
	ContainerRuntimeOpts_name = map[int32]string{
		0: "CONTAINERD",
		1: "RUNC",
	}
	ContainerRuntimeOpts_value = map[string]int32{
		"CONTAINERD": 0,
		"RUNC":       1,
	}
)

Enum value maps for ContainerRuntimeOpts.

View Source
var (
	JobState_name = map[int32]string{
		0: "JOB_STARTUP_FAILED",
		1: "JOB_KILLED",
		2: "JOB_IDLE",
		3: "JOB_RUNNING",
		4: "JOB_PENDING",
		5: "JOB_DONE",
	}
	JobState_value = map[string]int32{
		"JOB_STARTUP_FAILED": 0,
		"JOB_KILLED":         1,
		"JOB_IDLE":           2,
		"JOB_RUNNING":        3,
		"JOB_PENDING":        4,
		"JOB_DONE":           5,
	}
)

Enum value maps for JobState.

View Source
var (
	CheckpointState_name = map[int32]string{
		0: "CHECKPOINTED",
		1: "CHECKPOINT_FAILED",
		2: "RESTORED",
		3: "RESTORE_FAILED",
	}
	CheckpointState_value = map[string]int32{
		"CHECKPOINTED":      0,
		"CHECKPOINT_FAILED": 1,
		"RESTORED":          2,
		"RESTORE_FAILED":    3,
	}
)

Enum value maps for CheckpointState.

View Source
var (
	OpenFilesStat_StreamType_name = map[int32]string{
		0: "STDIN",
		1: "STDOUT",
		2: "STDERR",
		3: "NONE",
	}
	OpenFilesStat_StreamType_value = map[string]int32{
		"STDIN":  0,
		"STDOUT": 1,
		"STDERR": 2,
		"NONE":   3,
	}
)

Enum value maps for OpenFilesStat_StreamType.

View Source
var (
	CheckpointReason_CheckpointReasonEnum_name = map[int32]string{
		0: "INSTANCE_TERMINATION",
		1: "JOB_TERMINATION",
		2: "HEARTBEAT",
	}
	CheckpointReason_CheckpointReasonEnum_value = map[string]int32{
		"INSTANCE_TERMINATION": 0,
		"JOB_TERMINATION":      1,
		"HEARTBEAT":            2,
	}
)

Enum value maps for CheckpointReason_CheckpointReasonEnum.

View Source
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedana.services.task.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _TaskService_Start_Handler,
		},
		{
			MethodName: "Dump",
			Handler:    _TaskService_Dump_Handler,
		},
		{
			MethodName: "Restore",
			Handler:    _TaskService_Restore_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _TaskService_Query_Handler,
		},
		{
			MethodName: "ContainerdDump",
			Handler:    _TaskService_ContainerdDump_Handler,
		},
		{
			MethodName: "ContainerdRestore",
			Handler:    _TaskService_ContainerdRestore_Handler,
		},
		{
			MethodName: "ContainerdQuery",
			Handler:    _TaskService_ContainerdQuery_Handler,
		},
		{
			MethodName: "RuncDump",
			Handler:    _TaskService_RuncDump_Handler,
		},
		{
			MethodName: "RuncRestore",
			Handler:    _TaskService_RuncRestore_Handler,
		},
		{
			MethodName: "RuncQuery",
			Handler:    _TaskService_RuncQuery_Handler,
		},
		{
			MethodName: "RuncGetPausePid",
			Handler:    _TaskService_RuncGetPausePid_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "LogStreaming",
			Handler:       _TaskService_LogStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ProcessStateStreaming",
			Handler:       _TaskService_ProcessStateStreaming_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "task.proto",
}

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

Functions

func RegisterTaskServiceServer

func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)

Types

type Addr

type Addr struct {
	IP   string `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	// contains filtered or unexported fields
}

func (*Addr) Descriptor deprecated

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

Deprecated: Use Addr.ProtoReflect.Descriptor instead.

func (*Addr) GetIP

func (x *Addr) GetIP() string

func (*Addr) GetPort

func (x *Addr) GetPort() uint32

func (*Addr) ProtoMessage

func (*Addr) ProtoMessage()

func (*Addr) ProtoReflect added in v0.8.1

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

func (*Addr) Reset

func (x *Addr) Reset()

func (*Addr) String

func (x *Addr) String() string

type CRType added in v0.9.104

type CRType int32
const (
	CRType_LOCAL  CRType = 0
	CRType_REMOTE CRType = 1
)

func (CRType) Descriptor added in v0.9.104

func (CRType) Descriptor() protoreflect.EnumDescriptor

func (CRType) Enum added in v0.9.104

func (x CRType) Enum() *CRType

func (CRType) EnumDescriptor deprecated added in v0.9.104

func (CRType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CRType.Descriptor instead.

func (CRType) Number added in v0.9.104

func (x CRType) Number() protoreflect.EnumNumber

func (CRType) String added in v0.9.104

func (x CRType) String() string

func (CRType) Type added in v0.9.104

func (CRType) Type() protoreflect.EnumType

type CheckpointReason

type CheckpointReason struct {
	Reason CheckpointReason_CheckpointReasonEnum `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CheckpointReason) Descriptor deprecated

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

Deprecated: Use CheckpointReason.ProtoReflect.Descriptor instead.

func (*CheckpointReason) GetReason

func (*CheckpointReason) ProtoMessage

func (*CheckpointReason) ProtoMessage()

func (*CheckpointReason) ProtoReflect added in v0.8.1

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

func (*CheckpointReason) Reset

func (x *CheckpointReason) Reset()

func (*CheckpointReason) String

func (x *CheckpointReason) String() string

type CheckpointReason_CheckpointReasonEnum

type CheckpointReason_CheckpointReasonEnum int32
const (
	CheckpointReason_INSTANCE_TERMINATION CheckpointReason_CheckpointReasonEnum = 0
	CheckpointReason_JOB_TERMINATION      CheckpointReason_CheckpointReasonEnum = 1
	CheckpointReason_HEARTBEAT            CheckpointReason_CheckpointReasonEnum = 2
)

func (CheckpointReason_CheckpointReasonEnum) Descriptor added in v0.8.1

func (CheckpointReason_CheckpointReasonEnum) Enum added in v0.8.1

func (CheckpointReason_CheckpointReasonEnum) EnumDescriptor deprecated

func (CheckpointReason_CheckpointReasonEnum) EnumDescriptor() ([]byte, []int)

Deprecated: Use CheckpointReason_CheckpointReasonEnum.Descriptor instead.

func (CheckpointReason_CheckpointReasonEnum) Number added in v0.8.1

func (CheckpointReason_CheckpointReasonEnum) String

func (CheckpointReason_CheckpointReasonEnum) Type added in v0.8.1

type CheckpointState

type CheckpointState int32
const (
	CheckpointState_CHECKPOINTED      CheckpointState = 0
	CheckpointState_CHECKPOINT_FAILED CheckpointState = 1
	CheckpointState_RESTORED          CheckpointState = 2
	CheckpointState_RESTORE_FAILED    CheckpointState = 3
)

func (CheckpointState) Descriptor added in v0.8.1

func (CheckpointState) Enum added in v0.8.1

func (x CheckpointState) Enum() *CheckpointState

func (CheckpointState) EnumDescriptor deprecated

func (CheckpointState) EnumDescriptor() ([]byte, []int)

Deprecated: Use CheckpointState.Descriptor instead.

func (CheckpointState) Number added in v0.8.1

func (CheckpointState) String

func (x CheckpointState) String() string

func (CheckpointState) Type added in v0.8.1

type ClientInfo

type ClientInfo struct {
	Id              string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Hostname        string `protobuf:"bytes,2,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	Platform        string `protobuf:"bytes,3,opt,name=Platform,proto3" json:"Platform,omitempty"`
	OS              string `protobuf:"bytes,4,opt,name=OS,proto3" json:"OS,omitempty"`
	Uptime          uint64 `protobuf:"varint,5,opt,name=Uptime,proto3" json:"Uptime,omitempty"`
	RemainingMemory uint64 `protobuf:"varint,6,opt,name=RemainingMemory,proto3" json:"RemainingMemory,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientInfo) Descriptor deprecated

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetHostname

func (x *ClientInfo) GetHostname() string

func (*ClientInfo) GetId

func (x *ClientInfo) GetId() string

func (*ClientInfo) GetOS

func (x *ClientInfo) GetOS() string

func (*ClientInfo) GetPlatform

func (x *ClientInfo) GetPlatform() string

func (*ClientInfo) GetRemainingMemory

func (x *ClientInfo) GetRemainingMemory() uint64

func (*ClientInfo) GetUptime

func (x *ClientInfo) GetUptime() uint64

func (*ClientInfo) ProtoMessage

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect added in v0.8.1

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

func (*ClientInfo) Reset

func (x *ClientInfo) Reset()

func (*ClientInfo) String

func (x *ClientInfo) String() string

type ConnectionStat

type ConnectionStat struct {
	Fd     uint32  `protobuf:"varint,1,opt,name=Fd,proto3" json:"Fd,omitempty"`
	Family uint32  `protobuf:"varint,2,opt,name=Family,proto3" json:"Family,omitempty"`
	Type   uint32  `protobuf:"varint,3,opt,name=Type,proto3" json:"Type,omitempty"`
	Laddr  *Addr   `protobuf:"bytes,4,opt,name=Laddr,proto3" json:"Laddr,omitempty"`
	Raddr  *Addr   `protobuf:"bytes,5,opt,name=Raddr,proto3" json:"Raddr,omitempty"`
	Status string  `protobuf:"bytes,6,opt,name=Status,proto3" json:"Status,omitempty"`
	UIDs   []int32 `protobuf:"varint,7,rep,packed,name=UIDs,proto3" json:"UIDs,omitempty"`
	PID    int32   `protobuf:"varint,8,opt,name=PID,proto3" json:"PID,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionStat) Descriptor deprecated

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

Deprecated: Use ConnectionStat.ProtoReflect.Descriptor instead.

func (*ConnectionStat) GetFamily

func (x *ConnectionStat) GetFamily() uint32

func (*ConnectionStat) GetFd

func (x *ConnectionStat) GetFd() uint32

func (*ConnectionStat) GetLaddr

func (x *ConnectionStat) GetLaddr() *Addr

func (*ConnectionStat) GetPID

func (x *ConnectionStat) GetPID() int32

func (*ConnectionStat) GetRaddr

func (x *ConnectionStat) GetRaddr() *Addr

func (*ConnectionStat) GetStatus

func (x *ConnectionStat) GetStatus() string

func (*ConnectionStat) GetType

func (x *ConnectionStat) GetType() uint32

func (*ConnectionStat) GetUIDs added in v0.9.104

func (x *ConnectionStat) GetUIDs() []int32

func (*ConnectionStat) ProtoMessage

func (*ConnectionStat) ProtoMessage()

func (*ConnectionStat) ProtoReflect added in v0.8.1

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

func (*ConnectionStat) Reset

func (x *ConnectionStat) Reset()

func (*ConnectionStat) String

func (x *ConnectionStat) String() string

type ContainerRuntimeOpts added in v0.9.104

type ContainerRuntimeOpts int32
const (
	ContainerRuntimeOpts_CONTAINERD ContainerRuntimeOpts = 0
	ContainerRuntimeOpts_RUNC       ContainerRuntimeOpts = 1
)

func (ContainerRuntimeOpts) Descriptor added in v0.9.104

func (ContainerRuntimeOpts) Enum added in v0.9.104

func (ContainerRuntimeOpts) EnumDescriptor deprecated added in v0.9.104

func (ContainerRuntimeOpts) EnumDescriptor() ([]byte, []int)

Deprecated: Use ContainerRuntimeOpts.Descriptor instead.

func (ContainerRuntimeOpts) Number added in v0.9.104

func (ContainerRuntimeOpts) String added in v0.9.104

func (x ContainerRuntimeOpts) String() string

func (ContainerRuntimeOpts) Type added in v0.9.104

type ContainerdContainer added in v0.9.104

type ContainerdContainer struct {
	ContainerName    string `protobuf:"bytes,1,opt,name=ContainerName,proto3" json:"ContainerName,omitempty"`
	ImageName        string `protobuf:"bytes,2,opt,name=ImageName,proto3" json:"ImageName,omitempty"`
	SandboxId        string `protobuf:"bytes,3,opt,name=SandboxId,proto3" json:"SandboxId,omitempty"`
	SandboxName      string `protobuf:"bytes,4,opt,name=SandboxName,proto3" json:"SandboxName,omitempty"`
	SandboxNamespace string `protobuf:"bytes,5,opt,name=SandboxNamespace,proto3" json:"SandboxNamespace,omitempty"`
	SandboxUid       string `protobuf:"bytes,6,opt,name=SandboxUid,proto3" json:"SandboxUid,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerdContainer) Descriptor deprecated added in v0.9.104

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

Deprecated: Use ContainerdContainer.ProtoReflect.Descriptor instead.

func (*ContainerdContainer) GetContainerName added in v0.9.104

func (x *ContainerdContainer) GetContainerName() string

func (*ContainerdContainer) GetImageName added in v0.9.104

func (x *ContainerdContainer) GetImageName() string

func (*ContainerdContainer) GetSandboxId added in v0.9.104

func (x *ContainerdContainer) GetSandboxId() string

func (*ContainerdContainer) GetSandboxName added in v0.9.104

func (x *ContainerdContainer) GetSandboxName() string

func (*ContainerdContainer) GetSandboxNamespace added in v0.9.104

func (x *ContainerdContainer) GetSandboxNamespace() string

func (*ContainerdContainer) GetSandboxUid added in v0.9.104

func (x *ContainerdContainer) GetSandboxUid() string

func (*ContainerdContainer) ProtoMessage added in v0.9.104

func (*ContainerdContainer) ProtoMessage()

func (*ContainerdContainer) ProtoReflect added in v0.9.104

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

func (*ContainerdContainer) Reset added in v0.9.104

func (x *ContainerdContainer) Reset()

func (*ContainerdContainer) String added in v0.9.104

func (x *ContainerdContainer) String() string

type ContainerdDumpArgs added in v0.9.104

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

func (*ContainerdDumpArgs) Descriptor deprecated added in v0.9.104

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

Deprecated: Use ContainerdDumpArgs.ProtoReflect.Descriptor instead.

func (*ContainerdDumpArgs) GetContainerID added in v0.9.104

func (x *ContainerdDumpArgs) GetContainerID() string

func (*ContainerdDumpArgs) GetRef added in v0.9.104

func (x *ContainerdDumpArgs) GetRef() string

func (*ContainerdDumpArgs) ProtoMessage added in v0.9.104

func (*ContainerdDumpArgs) ProtoMessage()

func (*ContainerdDumpArgs) ProtoReflect added in v0.9.104

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

func (*ContainerdDumpArgs) Reset added in v0.9.104

func (x *ContainerdDumpArgs) Reset()

func (*ContainerdDumpArgs) String added in v0.9.104

func (x *ContainerdDumpArgs) String() string

type ContainerdDumpResp added in v0.9.104

type ContainerdDumpResp struct {
	CheckpointPath string `protobuf:"bytes,1,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	Message        string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerdDumpResp) Descriptor deprecated added in v0.9.104

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

Deprecated: Use ContainerdDumpResp.ProtoReflect.Descriptor instead.

func (*ContainerdDumpResp) GetCheckpointPath added in v0.9.104

func (x *ContainerdDumpResp) GetCheckpointPath() string

func (*ContainerdDumpResp) GetMessage added in v0.9.104

func (x *ContainerdDumpResp) GetMessage() string

func (*ContainerdDumpResp) ProtoMessage added in v0.9.104

func (*ContainerdDumpResp) ProtoMessage()

func (*ContainerdDumpResp) ProtoReflect added in v0.9.104

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

func (*ContainerdDumpResp) Reset added in v0.9.104

func (x *ContainerdDumpResp) Reset()

func (*ContainerdDumpResp) String added in v0.9.104

func (x *ContainerdDumpResp) String() string

type ContainerdQueryArgs added in v0.9.104

type ContainerdQueryArgs struct {
	Root      string `protobuf:"bytes,1,opt,name=Root,proto3" json:"Root,omitempty"`
	Namespace string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerdQueryArgs) Descriptor deprecated added in v0.9.104

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

Deprecated: Use ContainerdQueryArgs.ProtoReflect.Descriptor instead.

func (*ContainerdQueryArgs) GetNamespace added in v0.9.104

func (x *ContainerdQueryArgs) GetNamespace() string

func (*ContainerdQueryArgs) GetRoot added in v0.9.104

func (x *ContainerdQueryArgs) GetRoot() string

func (*ContainerdQueryArgs) ProtoMessage added in v0.9.104

func (*ContainerdQueryArgs) ProtoMessage()

func (*ContainerdQueryArgs) ProtoReflect added in v0.9.104

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

func (*ContainerdQueryArgs) Reset added in v0.9.104

func (x *ContainerdQueryArgs) Reset()

func (*ContainerdQueryArgs) String added in v0.9.104

func (x *ContainerdQueryArgs) String() string

type ContainerdQueryResp added in v0.9.104

type ContainerdQueryResp struct {
	Containers []*ContainerdContainer `protobuf:"bytes,1,rep,name=Containers,proto3" json:"Containers,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerdQueryResp) Descriptor deprecated added in v0.9.104

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

Deprecated: Use ContainerdQueryResp.ProtoReflect.Descriptor instead.

func (*ContainerdQueryResp) GetContainers added in v0.9.104

func (x *ContainerdQueryResp) GetContainers() []*ContainerdContainer

func (*ContainerdQueryResp) ProtoMessage added in v0.9.104

func (*ContainerdQueryResp) ProtoMessage()

func (*ContainerdQueryResp) ProtoReflect added in v0.9.104

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

func (*ContainerdQueryResp) Reset added in v0.9.104

func (x *ContainerdQueryResp) Reset()

func (*ContainerdQueryResp) String added in v0.9.104

func (x *ContainerdQueryResp) String() string

type ContainerdRestoreArgs added in v0.9.104

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

func (*ContainerdRestoreArgs) Descriptor deprecated added in v0.9.104

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

Deprecated: Use ContainerdRestoreArgs.ProtoReflect.Descriptor instead.

func (*ContainerdRestoreArgs) GetContainerID added in v0.9.104

func (x *ContainerdRestoreArgs) GetContainerID() string

func (*ContainerdRestoreArgs) GetImgPath added in v0.9.104

func (x *ContainerdRestoreArgs) GetImgPath() string

func (*ContainerdRestoreArgs) ProtoMessage added in v0.9.104

func (*ContainerdRestoreArgs) ProtoMessage()

func (*ContainerdRestoreArgs) ProtoReflect added in v0.9.104

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

func (*ContainerdRestoreArgs) Reset added in v0.9.104

func (x *ContainerdRestoreArgs) Reset()

func (*ContainerdRestoreArgs) String added in v0.9.104

func (x *ContainerdRestoreArgs) String() string

type ContainerdRestoreResp added in v0.9.104

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

func (*ContainerdRestoreResp) Descriptor deprecated added in v0.9.104

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

Deprecated: Use ContainerdRestoreResp.ProtoReflect.Descriptor instead.

func (*ContainerdRestoreResp) GetMessage added in v0.9.104

func (x *ContainerdRestoreResp) GetMessage() string

func (*ContainerdRestoreResp) ProtoMessage added in v0.9.104

func (*ContainerdRestoreResp) ProtoMessage()

func (*ContainerdRestoreResp) ProtoReflect added in v0.9.104

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

func (*ContainerdRestoreResp) Reset added in v0.9.104

func (x *ContainerdRestoreResp) Reset()

func (*ContainerdRestoreResp) String added in v0.9.104

func (x *ContainerdRestoreResp) String() string

type CriuOpts

type CriuOpts struct {
	ImagesDirectory         string `protobuf:"bytes,1,opt,name=ImagesDirectory,proto3" json:"ImagesDirectory,omitempty"`
	WorkDirectory           string `protobuf:"bytes,2,opt,name=WorkDirectory,proto3" json:"WorkDirectory,omitempty"`
	ParentImage             string `protobuf:"bytes,3,opt,name=ParentImage,proto3" json:"ParentImage,omitempty"`
	LeaveRunning            bool   `protobuf:"varint,4,opt,name=LeaveRunning,proto3" json:"LeaveRunning,omitempty"`
	TcpEstablished          bool   `protobuf:"varint,5,opt,name=TcpEstablished,proto3" json:"TcpEstablished,omitempty"`
	ExternalUnixConnections bool   `protobuf:"varint,6,opt,name=ExternalUnixConnections,proto3" json:"ExternalUnixConnections,omitempty"`
	ShellJob                bool   `protobuf:"varint,7,opt,name=ShellJob,proto3" json:"ShellJob,omitempty"`
	FileLocks               bool   `protobuf:"varint,8,opt,name=FileLocks,proto3" json:"FileLocks,omitempty"`
	PreDump                 bool   `protobuf:"varint,9,opt,name=PreDump,proto3" json:"PreDump,omitempty"`
	EmptyNs                 int32  `protobuf:"varint,12,opt,name=EmptyNs,proto3" json:"EmptyNs,omitempty"`
	AutoDedup               bool   `protobuf:"varint,13,opt,name=AutoDedup,proto3" json:"AutoDedup,omitempty"`
	LazyPages               bool   `protobuf:"varint,14,opt,name=LazyPages,proto3" json:"LazyPages,omitempty"`
	StatusFd                int32  `protobuf:"varint,15,opt,name=StatusFd,proto3" json:"StatusFd,omitempty"`
	LsmProfile              string `protobuf:"bytes,16,opt,name=LsmProfile,proto3" json:"LsmProfile,omitempty"`
	LsmMountContext         string `protobuf:"bytes,17,opt,name=LsmMountContext,proto3" json:"LsmMountContext,omitempty"`
	// contains filtered or unexported fields
}

func (*CriuOpts) Descriptor deprecated

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

Deprecated: Use CriuOpts.ProtoReflect.Descriptor instead.

func (*CriuOpts) GetAutoDedup

func (x *CriuOpts) GetAutoDedup() bool

func (*CriuOpts) GetEmptyNs

func (x *CriuOpts) GetEmptyNs() int32

func (*CriuOpts) GetExternalUnixConnections

func (x *CriuOpts) GetExternalUnixConnections() bool

func (*CriuOpts) GetFileLocks

func (x *CriuOpts) GetFileLocks() bool

func (*CriuOpts) GetImagesDirectory

func (x *CriuOpts) GetImagesDirectory() string

func (*CriuOpts) GetLazyPages

func (x *CriuOpts) GetLazyPages() bool

func (*CriuOpts) GetLeaveRunning

func (x *CriuOpts) GetLeaveRunning() bool

func (*CriuOpts) GetLsmMountContext

func (x *CriuOpts) GetLsmMountContext() string

func (*CriuOpts) GetLsmProfile

func (x *CriuOpts) GetLsmProfile() string

func (*CriuOpts) GetParentImage

func (x *CriuOpts) GetParentImage() string

func (*CriuOpts) GetPreDump

func (x *CriuOpts) GetPreDump() bool

func (*CriuOpts) GetShellJob

func (x *CriuOpts) GetShellJob() bool

func (*CriuOpts) GetStatusFd

func (x *CriuOpts) GetStatusFd() int32

func (*CriuOpts) GetTcpEstablished

func (x *CriuOpts) GetTcpEstablished() bool

func (*CriuOpts) GetWorkDirectory

func (x *CriuOpts) GetWorkDirectory() string

func (*CriuOpts) ProtoMessage

func (*CriuOpts) ProtoMessage()

func (*CriuOpts) ProtoReflect added in v0.8.1

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

func (*CriuOpts) Reset

func (x *CriuOpts) Reset()

func (*CriuOpts) String

func (x *CriuOpts) String() string

type DumpArgs

type DumpArgs struct {
	PID  int32  `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	Dir  string `protobuf:"bytes,2,opt,name=Dir,proto3" json:"Dir,omitempty"`
	Type CRType `protobuf:"varint,3,opt,name=Type,proto3,enum=cedana.services.task.CRType" json:"Type,omitempty"`
	JID  string `protobuf:"bytes,4,opt,name=JID,proto3" json:"JID,omitempty"`
	GPU  bool   `protobuf:"varint,5,opt,name=GPU,proto3" json:"GPU,omitempty"`
	// contains filtered or unexported fields
}

func (*DumpArgs) Descriptor deprecated

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

Deprecated: Use DumpArgs.ProtoReflect.Descriptor instead.

func (*DumpArgs) GetDir

func (x *DumpArgs) GetDir() string

func (*DumpArgs) GetGPU added in v0.9.200

func (x *DumpArgs) GetGPU() bool

func (*DumpArgs) GetJID added in v0.9.104

func (x *DumpArgs) GetJID() string

func (*DumpArgs) GetPID

func (x *DumpArgs) GetPID() int32

func (*DumpArgs) GetType

func (x *DumpArgs) GetType() CRType

func (*DumpArgs) ProtoMessage

func (*DumpArgs) ProtoMessage()

func (*DumpArgs) ProtoReflect added in v0.8.1

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

func (*DumpArgs) Reset

func (x *DumpArgs) Reset()

func (*DumpArgs) String

func (x *DumpArgs) String() string

type DumpResp

type DumpResp struct {
	Message      string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	CheckpointID string `protobuf:"bytes,2,opt,name=CheckpointID,proto3" json:"CheckpointID,omitempty"`
	UploadID     string `protobuf:"bytes,3,opt,name=UploadID,proto3" json:"UploadID,omitempty"`
	// contains filtered or unexported fields
}

func (*DumpResp) Descriptor deprecated

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

Deprecated: Use DumpResp.ProtoReflect.Descriptor instead.

func (*DumpResp) GetCheckpointID added in v0.8.9

func (x *DumpResp) GetCheckpointID() string

func (*DumpResp) GetMessage

func (x *DumpResp) GetMessage() string

func (*DumpResp) GetUploadID added in v0.8.9

func (x *DumpResp) GetUploadID() string

func (*DumpResp) ProtoMessage

func (*DumpResp) ProtoMessage()

func (*DumpResp) ProtoReflect added in v0.8.1

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

func (*DumpResp) Reset

func (x *DumpResp) Reset()

func (*DumpResp) String

func (x *DumpResp) String() string

type JobState added in v0.9.104

type JobState int32
const (
	JobState_JOB_STARTUP_FAILED JobState = 0
	JobState_JOB_KILLED         JobState = 1
	JobState_JOB_IDLE           JobState = 2
	JobState_JOB_RUNNING        JobState = 3
	JobState_JOB_PENDING        JobState = 4
	JobState_JOB_DONE           JobState = 5
)

func (JobState) Descriptor added in v0.9.104

func (JobState) Descriptor() protoreflect.EnumDescriptor

func (JobState) Enum added in v0.9.104

func (x JobState) Enum() *JobState

func (JobState) EnumDescriptor deprecated added in v0.9.104

func (JobState) EnumDescriptor() ([]byte, []int)

Deprecated: Use JobState.Descriptor instead.

func (JobState) Number added in v0.9.104

func (x JobState) Number() protoreflect.EnumNumber

func (JobState) String added in v0.9.104

func (x JobState) String() string

func (JobState) Type added in v0.9.104

type LogStreamingArgs

type LogStreamingArgs struct {
	Timestamp string `protobuf:"bytes,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Source    string `protobuf:"bytes,2,opt,name=Source,proto3" json:"Source,omitempty"`
	Level     string `protobuf:"bytes,3,opt,name=Level,proto3" json:"Level,omitempty"`
	Msg       string `protobuf:"bytes,4,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

func (*LogStreamingArgs) Descriptor deprecated

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

Deprecated: Use LogStreamingArgs.ProtoReflect.Descriptor instead.

func (*LogStreamingArgs) GetLevel

func (x *LogStreamingArgs) GetLevel() string

func (*LogStreamingArgs) GetMsg

func (x *LogStreamingArgs) GetMsg() string

func (*LogStreamingArgs) GetSource

func (x *LogStreamingArgs) GetSource() string

func (*LogStreamingArgs) GetTimestamp

func (x *LogStreamingArgs) GetTimestamp() string

func (*LogStreamingArgs) ProtoMessage

func (*LogStreamingArgs) ProtoMessage()

func (*LogStreamingArgs) ProtoReflect added in v0.8.1

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

func (*LogStreamingArgs) Reset

func (x *LogStreamingArgs) Reset()

func (*LogStreamingArgs) String

func (x *LogStreamingArgs) String() string

type LogStreamingResp

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

func (*LogStreamingResp) Descriptor deprecated

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

Deprecated: Use LogStreamingResp.ProtoReflect.Descriptor instead.

func (*LogStreamingResp) GetStatus

func (x *LogStreamingResp) GetStatus() string

func (*LogStreamingResp) ProtoMessage

func (*LogStreamingResp) ProtoMessage()

func (*LogStreamingResp) ProtoReflect added in v0.8.1

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

func (*LogStreamingResp) Reset

func (x *LogStreamingResp) Reset()

func (*LogStreamingResp) String

func (x *LogStreamingResp) String() string

type MetaStateStreamingArgs

type MetaStateStreamingArgs struct {
	Event            *ProviderEvent    `protobuf:"bytes,1,opt,name=Event,proto3" json:"Event,omitempty"`
	CheckpointReason *CheckpointReason `protobuf:"bytes,2,opt,name=CheckpointReason,proto3" json:"CheckpointReason,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaStateStreamingArgs) Descriptor deprecated

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

Deprecated: Use MetaStateStreamingArgs.ProtoReflect.Descriptor instead.

func (*MetaStateStreamingArgs) GetCheckpointReason

func (x *MetaStateStreamingArgs) GetCheckpointReason() *CheckpointReason

func (*MetaStateStreamingArgs) GetEvent

func (x *MetaStateStreamingArgs) GetEvent() *ProviderEvent

func (*MetaStateStreamingArgs) ProtoMessage

func (*MetaStateStreamingArgs) ProtoMessage()

func (*MetaStateStreamingArgs) ProtoReflect added in v0.8.1

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

func (*MetaStateStreamingArgs) Reset

func (x *MetaStateStreamingArgs) Reset()

func (*MetaStateStreamingArgs) String

func (x *MetaStateStreamingArgs) String() string

type MetaStateStreamingResp

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

func (*MetaStateStreamingResp) Descriptor deprecated

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

Deprecated: Use MetaStateStreamingResp.ProtoReflect.Descriptor instead.

func (*MetaStateStreamingResp) GetStatus

func (x *MetaStateStreamingResp) GetStatus() string

func (*MetaStateStreamingResp) ProtoMessage

func (*MetaStateStreamingResp) ProtoMessage()

func (*MetaStateStreamingResp) ProtoReflect added in v0.8.1

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

func (*MetaStateStreamingResp) Reset

func (x *MetaStateStreamingResp) Reset()

func (*MetaStateStreamingResp) String

func (x *MetaStateStreamingResp) String() string

type OpenFilesStat

type OpenFilesStat struct {
	Path   string                   `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	Fd     uint64                   `protobuf:"varint,2,opt,name=Fd,proto3" json:"Fd,omitempty"`
	Mode   string                   `protobuf:"bytes,3,opt,name=Mode,proto3" json:"Mode,omitempty"`
	Stream OpenFilesStat_StreamType `protobuf:"varint,5,opt,name=Stream,proto3,enum=cedana.services.task.OpenFilesStat_StreamType" json:"Stream,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenFilesStat) Descriptor deprecated

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

Deprecated: Use OpenFilesStat.ProtoReflect.Descriptor instead.

func (*OpenFilesStat) GetFd

func (x *OpenFilesStat) GetFd() uint64

func (*OpenFilesStat) GetMode added in v0.9.7

func (x *OpenFilesStat) GetMode() string

func (*OpenFilesStat) GetPath

func (x *OpenFilesStat) GetPath() string

func (*OpenFilesStat) GetStream added in v0.9.7

func (x *OpenFilesStat) GetStream() OpenFilesStat_StreamType

func (*OpenFilesStat) ProtoMessage

func (*OpenFilesStat) ProtoMessage()

func (*OpenFilesStat) ProtoReflect added in v0.8.1

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

func (*OpenFilesStat) Reset

func (x *OpenFilesStat) Reset()

func (*OpenFilesStat) String

func (x *OpenFilesStat) String() string

type OpenFilesStat_StreamType added in v0.9.7

type OpenFilesStat_StreamType int32
const (
	OpenFilesStat_STDIN  OpenFilesStat_StreamType = 0
	OpenFilesStat_STDOUT OpenFilesStat_StreamType = 1
	OpenFilesStat_STDERR OpenFilesStat_StreamType = 2
	OpenFilesStat_NONE   OpenFilesStat_StreamType = 3
)

func (OpenFilesStat_StreamType) Descriptor added in v0.9.7

func (OpenFilesStat_StreamType) Enum added in v0.9.7

func (OpenFilesStat_StreamType) EnumDescriptor deprecated added in v0.9.7

func (OpenFilesStat_StreamType) EnumDescriptor() ([]byte, []int)

Deprecated: Use OpenFilesStat_StreamType.Descriptor instead.

func (OpenFilesStat_StreamType) Number added in v0.9.7

func (OpenFilesStat_StreamType) String added in v0.9.7

func (x OpenFilesStat_StreamType) String() string

func (OpenFilesStat_StreamType) Type added in v0.9.7

type ProcessInfo

type ProcessInfo struct {
	PID                     int32             `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	AttachedToHardwareAccel bool              `protobuf:"varint,2,opt,name=AttachedToHardwareAccel,proto3" json:"AttachedToHardwareAccel,omitempty"`
	OpenFds                 []*OpenFilesStat  `protobuf:"bytes,3,rep,name=OpenFds,proto3" json:"OpenFds,omitempty"`
	WorkingDir              string            `protobuf:"bytes,4,opt,name=WorkingDir,proto3" json:"WorkingDir,omitempty"`
	OpenConnections         []*ConnectionStat `protobuf:"bytes,5,rep,name=OpenConnections,proto3" json:"OpenConnections,omitempty"`
	MemoryPercent           float32           `protobuf:"fixed32,6,opt,name=MemoryPercent,proto3" json:"MemoryPercent,omitempty"`
	IsRunning               bool              `protobuf:"varint,7,opt,name=IsRunning,proto3" json:"IsRunning,omitempty"`
	Status                  string            `protobuf:"bytes,8,opt,name=Status,proto3" json:"Status,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInfo) Descriptor deprecated

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

Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.

func (*ProcessInfo) GetAttachedToHardwareAccel

func (x *ProcessInfo) GetAttachedToHardwareAccel() bool

func (*ProcessInfo) GetIsRunning

func (x *ProcessInfo) GetIsRunning() bool

func (*ProcessInfo) GetMemoryPercent

func (x *ProcessInfo) GetMemoryPercent() float32

func (*ProcessInfo) GetOpenConnections

func (x *ProcessInfo) GetOpenConnections() []*ConnectionStat

func (*ProcessInfo) GetOpenFds

func (x *ProcessInfo) GetOpenFds() []*OpenFilesStat

func (*ProcessInfo) GetPID

func (x *ProcessInfo) GetPID() int32

func (*ProcessInfo) GetStatus

func (x *ProcessInfo) GetStatus() string

func (*ProcessInfo) GetWorkingDir added in v0.9.7

func (x *ProcessInfo) GetWorkingDir() string

func (*ProcessInfo) ProtoMessage

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoReflect added in v0.8.1

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

func (*ProcessInfo) Reset

func (x *ProcessInfo) Reset()

func (*ProcessInfo) String

func (x *ProcessInfo) String() string

type ProcessState

type ProcessState struct {
	PID              int32                `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	Task             string               `protobuf:"bytes,2,opt,name=Task,proto3" json:"Task,omitempty"`
	ContainerRuntime ContainerRuntimeOpts `` /* 133-byte string literal not displayed */
	ContainerID      string               `protobuf:"bytes,4,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	StartedAt        string               `protobuf:"bytes,5,opt,name=StartedAt,proto3" json:"StartedAt,omitempty"`
	ProcessInfo      *ProcessInfo         `protobuf:"bytes,6,opt,name=ProcessInfo,proto3" json:"ProcessInfo,omitempty"`
	CheckpointPath   string               `protobuf:"bytes,7,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	CheckpointState  CheckpointState      `` /* 126-byte string literal not displayed */
	JobState         JobState             `protobuf:"varint,9,opt,name=JobState,proto3,enum=cedana.services.task.JobState" json:"JobState,omitempty"`
	RemoteState      []*RemoteState       `protobuf:"bytes,10,rep,name=RemoteState,proto3" json:"RemoteState,omitempty"`
	GPUCheckpointed  bool                 `protobuf:"varint,11,opt,name=GPUCheckpointed,proto3" json:"GPUCheckpointed,omitempty"`
	JID              string               `protobuf:"bytes,12,opt,name=JID,proto3" json:"JID,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessState) Descriptor deprecated

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

Deprecated: Use ProcessState.ProtoReflect.Descriptor instead.

func (*ProcessState) GetCheckpointPath

func (x *ProcessState) GetCheckpointPath() string

func (*ProcessState) GetCheckpointState

func (x *ProcessState) GetCheckpointState() CheckpointState

func (*ProcessState) GetContainerID added in v0.9.104

func (x *ProcessState) GetContainerID() string

func (*ProcessState) GetContainerRuntime

func (x *ProcessState) GetContainerRuntime() ContainerRuntimeOpts

func (*ProcessState) GetGPUCheckpointed added in v0.9.5

func (x *ProcessState) GetGPUCheckpointed() bool

func (*ProcessState) GetJID added in v0.9.104

func (x *ProcessState) GetJID() string

func (*ProcessState) GetJobState added in v0.9.104

func (x *ProcessState) GetJobState() JobState

func (*ProcessState) GetPID

func (x *ProcessState) GetPID() int32

func (*ProcessState) GetProcessInfo

func (x *ProcessState) GetProcessInfo() *ProcessInfo

func (*ProcessState) GetRemoteState added in v0.8.9

func (x *ProcessState) GetRemoteState() []*RemoteState

func (*ProcessState) GetStartedAt

func (x *ProcessState) GetStartedAt() string

func (*ProcessState) GetTask

func (x *ProcessState) GetTask() string

func (*ProcessState) ProtoMessage

func (*ProcessState) ProtoMessage()

func (*ProcessState) ProtoReflect added in v0.8.1

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

func (*ProcessState) Reset

func (x *ProcessState) Reset()

func (*ProcessState) String

func (x *ProcessState) String() string

type ProcessStateStreamingArgs added in v0.9.104

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

func (*ProcessStateStreamingArgs) Descriptor deprecated added in v0.9.104

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

Deprecated: Use ProcessStateStreamingArgs.ProtoReflect.Descriptor instead.

func (*ProcessStateStreamingArgs) GetJID added in v0.9.104

func (x *ProcessStateStreamingArgs) GetJID() string

func (*ProcessStateStreamingArgs) ProtoMessage added in v0.9.104

func (*ProcessStateStreamingArgs) ProtoMessage()

func (*ProcessStateStreamingArgs) ProtoReflect added in v0.9.104

func (*ProcessStateStreamingArgs) Reset added in v0.9.104

func (x *ProcessStateStreamingArgs) Reset()

func (*ProcessStateStreamingArgs) String added in v0.9.104

func (x *ProcessStateStreamingArgs) String() string

type ProviderEvent

type ProviderEvent struct {
	InstanceID           string `protobuf:"bytes,1,opt,name=InstanceID,proto3" json:"InstanceID,omitempty"`
	FaultCode            string `protobuf:"bytes,2,opt,name=FaultCode,proto3" json:"FaultCode,omitempty"`
	MarkedForTermination bool   `protobuf:"varint,3,opt,name=MarkedForTermination,proto3" json:"MarkedForTermination,omitempty"`
	TerminationTime      int64  `protobuf:"varint,4,opt,name=TerminationTime,proto3" json:"TerminationTime,omitempty"`
	// contains filtered or unexported fields
}

func (*ProviderEvent) Descriptor deprecated

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

Deprecated: Use ProviderEvent.ProtoReflect.Descriptor instead.

func (*ProviderEvent) GetFaultCode

func (x *ProviderEvent) GetFaultCode() string

func (*ProviderEvent) GetInstanceID

func (x *ProviderEvent) GetInstanceID() string

func (*ProviderEvent) GetMarkedForTermination

func (x *ProviderEvent) GetMarkedForTermination() bool

func (*ProviderEvent) GetTerminationTime

func (x *ProviderEvent) GetTerminationTime() int64

func (*ProviderEvent) ProtoMessage

func (*ProviderEvent) ProtoMessage()

func (*ProviderEvent) ProtoReflect added in v0.8.1

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

func (*ProviderEvent) Reset

func (x *ProviderEvent) Reset()

func (*ProviderEvent) String

func (x *ProviderEvent) String() string

type QueryArgs added in v0.9.104

type QueryArgs struct {
	PIDs []int32  `protobuf:"varint,1,rep,packed,name=PIDs,proto3" json:"PIDs,omitempty"`
	JIDs []string `protobuf:"bytes,2,rep,name=JIDs,proto3" json:"JIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryArgs) Descriptor deprecated added in v0.9.104

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

Deprecated: Use QueryArgs.ProtoReflect.Descriptor instead.

func (*QueryArgs) GetJIDs added in v0.9.104

func (x *QueryArgs) GetJIDs() []string

func (*QueryArgs) GetPIDs added in v0.9.104

func (x *QueryArgs) GetPIDs() []int32

func (*QueryArgs) ProtoMessage added in v0.9.104

func (*QueryArgs) ProtoMessage()

func (*QueryArgs) ProtoReflect added in v0.9.104

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

func (*QueryArgs) Reset added in v0.9.104

func (x *QueryArgs) Reset()

func (*QueryArgs) String added in v0.9.104

func (x *QueryArgs) String() string

type QueryResp added in v0.9.104

type QueryResp struct {
	Processes []*ProcessState `protobuf:"bytes,1,rep,name=Processes,proto3" json:"Processes,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResp) Descriptor deprecated added in v0.9.104

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

Deprecated: Use QueryResp.ProtoReflect.Descriptor instead.

func (*QueryResp) GetProcesses added in v0.9.104

func (x *QueryResp) GetProcesses() []*ProcessState

func (*QueryResp) ProtoMessage added in v0.9.104

func (*QueryResp) ProtoMessage()

func (*QueryResp) ProtoReflect added in v0.9.104

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

func (*QueryResp) Reset added in v0.9.104

func (x *QueryResp) Reset()

func (*QueryResp) String added in v0.9.104

func (x *QueryResp) String() string

type RemoteState added in v0.8.9

type RemoteState struct {
	CheckpointID string `protobuf:"bytes,1,opt,name=CheckpointID,proto3" json:"CheckpointID,omitempty"`
	UploadID     string `protobuf:"bytes,2,opt,name=UploadID,proto3" json:"UploadID,omitempty"`
	Timestamp    int64  `protobuf:"varint,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteState) Descriptor deprecated added in v0.8.9

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

Deprecated: Use RemoteState.ProtoReflect.Descriptor instead.

func (*RemoteState) GetCheckpointID added in v0.8.9

func (x *RemoteState) GetCheckpointID() string

func (*RemoteState) GetTimestamp added in v0.9.9

func (x *RemoteState) GetTimestamp() int64

func (*RemoteState) GetUploadID added in v0.8.9

func (x *RemoteState) GetUploadID() string

func (*RemoteState) ProtoMessage added in v0.8.9

func (*RemoteState) ProtoMessage()

func (*RemoteState) ProtoReflect added in v0.8.9

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

func (*RemoteState) Reset added in v0.8.9

func (x *RemoteState) Reset()

func (*RemoteState) String added in v0.8.9

func (x *RemoteState) String() string

type RestoreArgs

type RestoreArgs struct {
	Type           CRType `protobuf:"varint,1,opt,name=Type,proto3,enum=cedana.services.task.CRType" json:"Type,omitempty"`
	CheckpointID   string `protobuf:"bytes,2,opt,name=CheckpointID,proto3" json:"CheckpointID,omitempty"`
	CheckpointPath string `protobuf:"bytes,3,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	JID            string `protobuf:"bytes,4,opt,name=JID,proto3" json:"JID,omitempty"`
	UID            uint32 `protobuf:"varint,5,opt,name=UID,proto3" json:"UID,omitempty"`
	GID            uint32 `protobuf:"varint,6,opt,name=GID,proto3" json:"GID,omitempty"`
	GPU            bool   `protobuf:"varint,7,opt,name=GPU,proto3" json:"GPU,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreArgs) Descriptor deprecated

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

Deprecated: Use RestoreArgs.ProtoReflect.Descriptor instead.

func (*RestoreArgs) GetCheckpointID added in v0.9.104

func (x *RestoreArgs) GetCheckpointID() string

func (*RestoreArgs) GetCheckpointPath

func (x *RestoreArgs) GetCheckpointPath() string

func (*RestoreArgs) GetGID added in v0.9.95

func (x *RestoreArgs) GetGID() uint32

func (*RestoreArgs) GetGPU added in v0.9.200

func (x *RestoreArgs) GetGPU() bool

func (*RestoreArgs) GetJID added in v0.9.104

func (x *RestoreArgs) GetJID() string

func (*RestoreArgs) GetType

func (x *RestoreArgs) GetType() CRType

func (*RestoreArgs) GetUID added in v0.9.95

func (x *RestoreArgs) GetUID() uint32

func (*RestoreArgs) ProtoMessage

func (*RestoreArgs) ProtoMessage()

func (*RestoreArgs) ProtoReflect added in v0.8.1

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

func (*RestoreArgs) Reset

func (x *RestoreArgs) Reset()

func (*RestoreArgs) String

func (x *RestoreArgs) String() string

type RestoreResp

type RestoreResp struct {
	Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	NewPID  int32  `protobuf:"varint,2,opt,name=NewPID,proto3" json:"NewPID,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreResp) Descriptor deprecated

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

Deprecated: Use RestoreResp.ProtoReflect.Descriptor instead.

func (*RestoreResp) GetMessage

func (x *RestoreResp) GetMessage() string

func (*RestoreResp) GetNewPID

func (x *RestoreResp) GetNewPID() int32

func (*RestoreResp) ProtoMessage

func (*RestoreResp) ProtoMessage()

func (*RestoreResp) ProtoReflect added in v0.8.1

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

func (*RestoreResp) Reset

func (x *RestoreResp) Reset()

func (*RestoreResp) String

func (x *RestoreResp) String() string

type RuncContainer added in v0.9.104

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

func (*RuncContainer) Descriptor deprecated added in v0.9.104

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

Deprecated: Use RuncContainer.ProtoReflect.Descriptor instead.

func (*RuncContainer) GetBundlePath added in v0.9.104

func (x *RuncContainer) GetBundlePath() string

func (*RuncContainer) GetID added in v0.9.104

func (x *RuncContainer) GetID() string

func (*RuncContainer) ProtoMessage added in v0.9.104

func (*RuncContainer) ProtoMessage()

func (*RuncContainer) ProtoReflect added in v0.9.104

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

func (*RuncContainer) Reset added in v0.9.104

func (x *RuncContainer) Reset()

func (*RuncContainer) String added in v0.9.104

func (x *RuncContainer) String() string

type RuncDumpArgs

type RuncDumpArgs struct {
	Root           string    `protobuf:"bytes,1,opt,name=Root,proto3" json:"Root,omitempty"`
	CheckpointPath string    `protobuf:"bytes,2,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	ContainerID    string    `protobuf:"bytes,3,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	CriuOpts       *CriuOpts `protobuf:"bytes,4,opt,name=CriuOpts,proto3" json:"CriuOpts,omitempty"`
	Type           CRType    `protobuf:"varint,5,opt,name=Type,proto3,enum=cedana.services.task.CRType" json:"Type,omitempty"`
	GPU            bool      `protobuf:"varint,6,opt,name=GPU,proto3" json:"GPU,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncDumpArgs) Descriptor deprecated

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

Deprecated: Use RuncDumpArgs.ProtoReflect.Descriptor instead.

func (*RuncDumpArgs) GetCheckpointPath

func (x *RuncDumpArgs) GetCheckpointPath() string

func (*RuncDumpArgs) GetContainerID added in v0.9.104

func (x *RuncDumpArgs) GetContainerID() string

func (*RuncDumpArgs) GetCriuOpts

func (x *RuncDumpArgs) GetCriuOpts() *CriuOpts

func (*RuncDumpArgs) GetGPU added in v0.9.200

func (x *RuncDumpArgs) GetGPU() bool

func (*RuncDumpArgs) GetRoot

func (x *RuncDumpArgs) GetRoot() string

func (*RuncDumpArgs) GetType added in v0.9.7

func (x *RuncDumpArgs) GetType() CRType

func (*RuncDumpArgs) ProtoMessage

func (*RuncDumpArgs) ProtoMessage()

func (*RuncDumpArgs) ProtoReflect added in v0.8.1

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

func (*RuncDumpArgs) Reset

func (x *RuncDumpArgs) Reset()

func (*RuncDumpArgs) String

func (x *RuncDumpArgs) String() string

type RuncDumpResp

type RuncDumpResp struct {
	Message      string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	CheckpointID string `protobuf:"bytes,2,opt,name=CheckpointID,proto3" json:"CheckpointID,omitempty"`
	UploadID     string `protobuf:"bytes,3,opt,name=UploadID,proto3" json:"UploadID,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncDumpResp) Descriptor deprecated

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

Deprecated: Use RuncDumpResp.ProtoReflect.Descriptor instead.

func (*RuncDumpResp) GetCheckpointID added in v0.9.104

func (x *RuncDumpResp) GetCheckpointID() string

func (*RuncDumpResp) GetMessage

func (x *RuncDumpResp) GetMessage() string

func (*RuncDumpResp) GetUploadID added in v0.9.104

func (x *RuncDumpResp) GetUploadID() string

func (*RuncDumpResp) ProtoMessage

func (*RuncDumpResp) ProtoMessage()

func (*RuncDumpResp) ProtoReflect added in v0.8.1

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

func (*RuncDumpResp) Reset

func (x *RuncDumpResp) Reset()

func (*RuncDumpResp) String

func (x *RuncDumpResp) String() string

type RuncGetPausePidArgs added in v0.9.104

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

func (*RuncGetPausePidArgs) Descriptor deprecated added in v0.9.104

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

Deprecated: Use RuncGetPausePidArgs.ProtoReflect.Descriptor instead.

func (*RuncGetPausePidArgs) GetBundlePath added in v0.9.104

func (x *RuncGetPausePidArgs) GetBundlePath() string

func (*RuncGetPausePidArgs) ProtoMessage added in v0.9.104

func (*RuncGetPausePidArgs) ProtoMessage()

func (*RuncGetPausePidArgs) ProtoReflect added in v0.9.104

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

func (*RuncGetPausePidArgs) Reset added in v0.9.104

func (x *RuncGetPausePidArgs) Reset()

func (*RuncGetPausePidArgs) String added in v0.9.104

func (x *RuncGetPausePidArgs) String() string

type RuncGetPausePidResp added in v0.9.104

type RuncGetPausePidResp struct {
	PausePid int64 `protobuf:"varint,1,opt,name=PausePid,proto3" json:"PausePid,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncGetPausePidResp) Descriptor deprecated added in v0.9.104

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

Deprecated: Use RuncGetPausePidResp.ProtoReflect.Descriptor instead.

func (*RuncGetPausePidResp) GetPausePid added in v0.9.104

func (x *RuncGetPausePidResp) GetPausePid() int64

func (*RuncGetPausePidResp) ProtoMessage added in v0.9.104

func (*RuncGetPausePidResp) ProtoMessage()

func (*RuncGetPausePidResp) ProtoReflect added in v0.9.104

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

func (*RuncGetPausePidResp) Reset added in v0.9.104

func (x *RuncGetPausePidResp) Reset()

func (*RuncGetPausePidResp) String added in v0.9.104

func (x *RuncGetPausePidResp) String() string

type RuncOpts

type RuncOpts struct {
	Root            string `protobuf:"bytes,1,opt,name=Root,proto3" json:"Root,omitempty"`
	ContainerID     string `protobuf:"bytes,2,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	Bundle          string `protobuf:"bytes,3,opt,name=Bundle,proto3" json:"Bundle,omitempty"`
	SystemdCgroup   bool   `protobuf:"varint,4,opt,name=SystemdCgroup,proto3" json:"SystemdCgroup,omitempty"`
	NoPivot         bool   `protobuf:"varint,5,opt,name=NoPivot,proto3" json:"NoPivot,omitempty"`
	NoMountFallback bool   `protobuf:"varint,6,opt,name=NoMountFallback,proto3" json:"NoMountFallback,omitempty"`
	NoNewKeyring    bool   `protobuf:"varint,7,opt,name=NoNewKeyring,proto3" json:"NoNewKeyring,omitempty"`
	Rootless        string `protobuf:"bytes,8,opt,name=Rootless,proto3" json:"Rootless,omitempty"`
	NoSubreaper     bool   `protobuf:"varint,9,opt,name=NoSubreaper,proto3" json:"NoSubreaper,omitempty"`
	Keep            bool   `protobuf:"varint,10,opt,name=Keep,proto3" json:"Keep,omitempty"`
	ConsoleSocket   string `protobuf:"bytes,11,opt,name=ConsoleSocket,proto3" json:"ConsoleSocket,omitempty"`
	Detatch         bool   `protobuf:"varint,12,opt,name=Detatch,proto3" json:"Detatch,omitempty"`
	PidFile         string `protobuf:"bytes,13,opt,name=PidFile,proto3" json:"PidFile,omitempty"`
	PreserveFds     int32  `protobuf:"varint,14,opt,name=PreserveFds,proto3" json:"PreserveFds,omitempty"`
	NetPid          int32  `protobuf:"varint,15,opt,name=NetPid,proto3" json:"NetPid,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncOpts) Descriptor deprecated

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

Deprecated: Use RuncOpts.ProtoReflect.Descriptor instead.

func (*RuncOpts) GetBundle

func (x *RuncOpts) GetBundle() string

func (*RuncOpts) GetConsoleSocket

func (x *RuncOpts) GetConsoleSocket() string

func (*RuncOpts) GetContainerID added in v0.9.104

func (x *RuncOpts) GetContainerID() string

func (*RuncOpts) GetDetatch

func (x *RuncOpts) GetDetatch() bool

func (*RuncOpts) GetKeep

func (x *RuncOpts) GetKeep() bool

func (*RuncOpts) GetNetPid added in v0.9.5

func (x *RuncOpts) GetNetPid() int32

func (*RuncOpts) GetNoMountFallback

func (x *RuncOpts) GetNoMountFallback() bool

func (*RuncOpts) GetNoNewKeyring

func (x *RuncOpts) GetNoNewKeyring() bool

func (*RuncOpts) GetNoPivot

func (x *RuncOpts) GetNoPivot() bool

func (*RuncOpts) GetNoSubreaper

func (x *RuncOpts) GetNoSubreaper() bool

func (*RuncOpts) GetPidFile

func (x *RuncOpts) GetPidFile() string

func (*RuncOpts) GetPreserveFds

func (x *RuncOpts) GetPreserveFds() int32

func (*RuncOpts) GetRoot

func (x *RuncOpts) GetRoot() string

func (*RuncOpts) GetRootless

func (x *RuncOpts) GetRootless() string

func (*RuncOpts) GetSystemdCgroup

func (x *RuncOpts) GetSystemdCgroup() bool

func (*RuncOpts) ProtoMessage

func (*RuncOpts) ProtoMessage()

func (*RuncOpts) ProtoReflect added in v0.8.1

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

func (*RuncOpts) Reset

func (x *RuncOpts) Reset()

func (*RuncOpts) String

func (x *RuncOpts) String() string

type RuncQueryArgs added in v0.9.104

type RuncQueryArgs struct {
	Root           string   `protobuf:"bytes,1,opt,name=Root,proto3" json:"Root,omitempty"`
	ContainerNames []string `protobuf:"bytes,2,rep,name=ContainerNames,proto3" json:"ContainerNames,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncQueryArgs) Descriptor deprecated added in v0.9.104

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

Deprecated: Use RuncQueryArgs.ProtoReflect.Descriptor instead.

func (*RuncQueryArgs) GetContainerNames added in v0.9.104

func (x *RuncQueryArgs) GetContainerNames() []string

func (*RuncQueryArgs) GetRoot added in v0.9.104

func (x *RuncQueryArgs) GetRoot() string

func (*RuncQueryArgs) ProtoMessage added in v0.9.104

func (*RuncQueryArgs) ProtoMessage()

func (*RuncQueryArgs) ProtoReflect added in v0.9.104

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

func (*RuncQueryArgs) Reset added in v0.9.104

func (x *RuncQueryArgs) Reset()

func (*RuncQueryArgs) String added in v0.9.104

func (x *RuncQueryArgs) String() string

type RuncQueryResp added in v0.9.104

type RuncQueryResp struct {
	Containers []*RuncContainer `protobuf:"bytes,1,rep,name=Containers,proto3" json:"Containers,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncQueryResp) Descriptor deprecated added in v0.9.104

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

Deprecated: Use RuncQueryResp.ProtoReflect.Descriptor instead.

func (*RuncQueryResp) GetContainers added in v0.9.104

func (x *RuncQueryResp) GetContainers() []*RuncContainer

func (*RuncQueryResp) ProtoMessage added in v0.9.104

func (*RuncQueryResp) ProtoMessage()

func (*RuncQueryResp) ProtoReflect added in v0.9.104

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

func (*RuncQueryResp) Reset added in v0.9.104

func (x *RuncQueryResp) Reset()

func (*RuncQueryResp) String added in v0.9.104

func (x *RuncQueryResp) String() string

type RuncRestoreArgs

type RuncRestoreArgs struct {
	ContainerID  string    `protobuf:"bytes,1,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	ImagePath    string    `protobuf:"bytes,2,opt,name=ImagePath,proto3" json:"ImagePath,omitempty"`
	IsK3S        bool      `protobuf:"varint,3,opt,name=IsK3s,proto3" json:"IsK3s,omitempty"`
	Opts         *RuncOpts `protobuf:"bytes,4,opt,name=Opts,proto3" json:"Opts,omitempty"`
	Type         CRType    `protobuf:"varint,5,opt,name=Type,proto3,enum=cedana.services.task.CRType" json:"Type,omitempty"`
	CheckpointID string    `protobuf:"bytes,6,opt,name=CheckpointID,proto3" json:"CheckpointID,omitempty"`
	GPU          bool      `protobuf:"varint,7,opt,name=GPU,proto3" json:"GPU,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncRestoreArgs) Descriptor deprecated

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

Deprecated: Use RuncRestoreArgs.ProtoReflect.Descriptor instead.

func (*RuncRestoreArgs) GetCheckpointID added in v0.9.104

func (x *RuncRestoreArgs) GetCheckpointID() string

func (*RuncRestoreArgs) GetContainerID added in v0.9.104

func (x *RuncRestoreArgs) GetContainerID() string

func (*RuncRestoreArgs) GetGPU added in v0.9.200

func (x *RuncRestoreArgs) GetGPU() bool

func (*RuncRestoreArgs) GetImagePath

func (x *RuncRestoreArgs) GetImagePath() string

func (*RuncRestoreArgs) GetIsK3S added in v0.9.5

func (x *RuncRestoreArgs) GetIsK3S() bool

func (*RuncRestoreArgs) GetOpts

func (x *RuncRestoreArgs) GetOpts() *RuncOpts

func (*RuncRestoreArgs) GetType added in v0.9.7

func (x *RuncRestoreArgs) GetType() CRType

func (*RuncRestoreArgs) ProtoMessage

func (*RuncRestoreArgs) ProtoMessage()

func (*RuncRestoreArgs) ProtoReflect added in v0.8.1

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

func (*RuncRestoreArgs) Reset

func (x *RuncRestoreArgs) Reset()

func (*RuncRestoreArgs) String

func (x *RuncRestoreArgs) String() string

type RuncRestoreResp

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

func (*RuncRestoreResp) Descriptor deprecated

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

Deprecated: Use RuncRestoreResp.ProtoReflect.Descriptor instead.

func (*RuncRestoreResp) GetMessage

func (x *RuncRestoreResp) GetMessage() string

func (*RuncRestoreResp) ProtoMessage

func (*RuncRestoreResp) ProtoMessage()

func (*RuncRestoreResp) ProtoReflect added in v0.8.1

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

func (*RuncRestoreResp) Reset

func (x *RuncRestoreResp) Reset()

func (*RuncRestoreResp) String

func (x *RuncRestoreResp) String() string

type StartArgs added in v0.9.104

type StartArgs struct {
	Task          string   `protobuf:"bytes,1,opt,name=Task,proto3" json:"Task,omitempty"`
	JID           string   `protobuf:"bytes,2,opt,name=JID,proto3" json:"JID,omitempty"`
	WorkingDir    string   `protobuf:"bytes,3,opt,name=WorkingDir,proto3" json:"WorkingDir,omitempty"`
	Env           []string `protobuf:"bytes,4,rep,name=Env,proto3" json:"Env,omitempty"`
	LogOutputFile string   `protobuf:"bytes,5,opt,name=LogOutputFile,proto3" json:"LogOutputFile,omitempty"`
	UID           uint32   `protobuf:"varint,6,opt,name=UID,proto3" json:"UID,omitempty"`
	GID           uint32   `protobuf:"varint,7,opt,name=GID,proto3" json:"GID,omitempty"`
	GPU           bool     `protobuf:"varint,8,opt,name=GPU,proto3" json:"GPU,omitempty"`
	// contains filtered or unexported fields
}

func (*StartArgs) Descriptor deprecated added in v0.9.104

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

Deprecated: Use StartArgs.ProtoReflect.Descriptor instead.

func (*StartArgs) GetEnv added in v0.9.104

func (x *StartArgs) GetEnv() []string

func (*StartArgs) GetGID added in v0.9.104

func (x *StartArgs) GetGID() uint32

func (*StartArgs) GetGPU added in v0.9.200

func (x *StartArgs) GetGPU() bool

func (*StartArgs) GetJID added in v0.9.104

func (x *StartArgs) GetJID() string

func (*StartArgs) GetLogOutputFile added in v0.9.104

func (x *StartArgs) GetLogOutputFile() string

func (*StartArgs) GetTask added in v0.9.104

func (x *StartArgs) GetTask() string

func (*StartArgs) GetUID added in v0.9.104

func (x *StartArgs) GetUID() uint32

func (*StartArgs) GetWorkingDir added in v0.9.104

func (x *StartArgs) GetWorkingDir() string

func (*StartArgs) ProtoMessage added in v0.9.104

func (*StartArgs) ProtoMessage()

func (*StartArgs) ProtoReflect added in v0.9.104

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

func (*StartArgs) Reset added in v0.9.104

func (x *StartArgs) Reset()

func (*StartArgs) String added in v0.9.104

func (x *StartArgs) String() string

type StartResp added in v0.9.104

type StartResp struct {
	Message string `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	PID     int32  `protobuf:"varint,2,opt,name=PID,proto3" json:"PID,omitempty"`
	JID     string `protobuf:"bytes,3,opt,name=JID,proto3" json:"JID,omitempty"`
	// contains filtered or unexported fields
}

func (*StartResp) Descriptor deprecated added in v0.9.104

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

Deprecated: Use StartResp.ProtoReflect.Descriptor instead.

func (*StartResp) GetJID added in v0.9.104

func (x *StartResp) GetJID() string

func (*StartResp) GetMessage added in v0.9.104

func (x *StartResp) GetMessage() string

func (*StartResp) GetPID added in v0.9.104

func (x *StartResp) GetPID() int32

func (*StartResp) ProtoMessage added in v0.9.104

func (*StartResp) ProtoMessage()

func (*StartResp) ProtoReflect added in v0.9.104

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

func (*StartResp) Reset added in v0.9.104

func (x *StartResp) Reset()

func (*StartResp) String added in v0.9.104

func (x *StartResp) String() string

type TaskServiceClient

type TaskServiceClient interface {
	// Process
	Start(ctx context.Context, in *StartArgs, opts ...grpc.CallOption) (*StartResp, error)
	Dump(ctx context.Context, in *DumpArgs, opts ...grpc.CallOption) (*DumpResp, error)
	Restore(ctx context.Context, in *RestoreArgs, opts ...grpc.CallOption) (*RestoreResp, error)
	Query(ctx context.Context, in *QueryArgs, opts ...grpc.CallOption) (*QueryResp, error)
	// Containerd
	ContainerdDump(ctx context.Context, in *ContainerdDumpArgs, opts ...grpc.CallOption) (*ContainerdDumpResp, error)
	ContainerdRestore(ctx context.Context, in *ContainerdRestoreArgs, opts ...grpc.CallOption) (*ContainerdRestoreResp, error)
	ContainerdQuery(ctx context.Context, in *ContainerdQueryArgs, opts ...grpc.CallOption) (*ContainerdQueryResp, error)
	// Runc
	RuncDump(ctx context.Context, in *RuncDumpArgs, opts ...grpc.CallOption) (*RuncDumpResp, error)
	RuncRestore(ctx context.Context, in *RuncRestoreArgs, opts ...grpc.CallOption) (*RuncRestoreResp, error)
	RuncQuery(ctx context.Context, in *RuncQueryArgs, opts ...grpc.CallOption) (*RuncQueryResp, error)
	RuncGetPausePid(ctx context.Context, in *RuncGetPausePidArgs, opts ...grpc.CallOption) (*RuncGetPausePidResp, error)
	// Streaming
	LogStreaming(ctx context.Context, opts ...grpc.CallOption) (TaskService_LogStreamingClient, error)
	ProcessStateStreaming(ctx context.Context, in *ProcessStateStreamingArgs, opts ...grpc.CallOption) (TaskService_ProcessStateStreamingClient, error)
}

TaskServiceClient is the client API for TaskService 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.

type TaskServiceServer

type TaskServiceServer interface {
	// Process
	Start(context.Context, *StartArgs) (*StartResp, error)
	Dump(context.Context, *DumpArgs) (*DumpResp, error)
	Restore(context.Context, *RestoreArgs) (*RestoreResp, error)
	Query(context.Context, *QueryArgs) (*QueryResp, error)
	// Containerd
	ContainerdDump(context.Context, *ContainerdDumpArgs) (*ContainerdDumpResp, error)
	ContainerdRestore(context.Context, *ContainerdRestoreArgs) (*ContainerdRestoreResp, error)
	ContainerdQuery(context.Context, *ContainerdQueryArgs) (*ContainerdQueryResp, error)
	// Runc
	RuncDump(context.Context, *RuncDumpArgs) (*RuncDumpResp, error)
	RuncRestore(context.Context, *RuncRestoreArgs) (*RuncRestoreResp, error)
	RuncQuery(context.Context, *RuncQueryArgs) (*RuncQueryResp, error)
	RuncGetPausePid(context.Context, *RuncGetPausePidArgs) (*RuncGetPausePidResp, error)
	// Streaming
	LogStreaming(TaskService_LogStreamingServer) error
	ProcessStateStreaming(*ProcessStateStreamingArgs, TaskService_ProcessStateStreamingServer) error
	// contains filtered or unexported methods
}

TaskServiceServer is the server API for TaskService service. All implementations must embed UnimplementedTaskServiceServer for forward compatibility

type TaskService_LogStreamingClient

type TaskService_LogStreamingClient interface {
	Send(*LogStreamingResp) error
	Recv() (*LogStreamingArgs, error)
	grpc.ClientStream
}

type TaskService_LogStreamingServer

type TaskService_LogStreamingServer interface {
	Send(*LogStreamingArgs) error
	Recv() (*LogStreamingResp, error)
	grpc.ServerStream
}

type TaskService_ProcessStateStreamingClient added in v0.9.104

type TaskService_ProcessStateStreamingClient interface {
	Recv() (*ProcessState, error)
	grpc.ClientStream
}

type TaskService_ProcessStateStreamingServer added in v0.9.104

type TaskService_ProcessStateStreamingServer interface {
	Send(*ProcessState) error
	grpc.ServerStream
}

type UnimplementedTaskServiceServer

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) ContainerdDump added in v0.9.104

func (UnimplementedTaskServiceServer) ContainerdQuery added in v0.9.104

func (UnimplementedTaskServiceServer) ContainerdRestore added in v0.9.104

func (UnimplementedTaskServiceServer) Dump

func (UnimplementedTaskServiceServer) LogStreaming

func (UnimplementedTaskServiceServer) ProcessStateStreaming added in v0.9.104

func (UnimplementedTaskServiceServer) Query added in v0.9.104

func (UnimplementedTaskServiceServer) Restore

func (UnimplementedTaskServiceServer) RuncDump

func (UnimplementedTaskServiceServer) RuncGetPausePid added in v0.9.104

func (UnimplementedTaskServiceServer) RuncQuery added in v0.9.104

func (UnimplementedTaskServiceServer) RuncRestore

func (UnimplementedTaskServiceServer) Start added in v0.9.104

type UnsafeTaskServiceServer

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

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

Jump to

Keyboard shortcuts

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