task

package
v0.9.229 Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2024 License: AGPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TaskService_JobDump_FullMethodName                 = "/cedana.services.task.TaskService/JobDump"
	TaskService_JobRestore_FullMethodName              = "/cedana.services.task.TaskService/JobRestore"
	TaskService_JobRestoreAttach_FullMethodName        = "/cedana.services.task.TaskService/JobRestoreAttach"
	TaskService_JobQuery_FullMethodName                = "/cedana.services.task.TaskService/JobQuery"
	TaskService_Start_FullMethodName                   = "/cedana.services.task.TaskService/Start"
	TaskService_StartAttach_FullMethodName             = "/cedana.services.task.TaskService/StartAttach"
	TaskService_Dump_FullMethodName                    = "/cedana.services.task.TaskService/Dump"
	TaskService_Restore_FullMethodName                 = "/cedana.services.task.TaskService/Restore"
	TaskService_RestoreAttach_FullMethodName           = "/cedana.services.task.TaskService/RestoreAttach"
	TaskService_Manage_FullMethodName                  = "/cedana.services.task.TaskService/Manage"
	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_ContainerdRootfsDump_FullMethodName    = "/cedana.services.task.TaskService/ContainerdRootfsDump"
	TaskService_ContainerdRootfsRestore_FullMethodName = "/cedana.services.task.TaskService/ContainerdRootfsRestore"
	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_RuncManage_FullMethodName              = "/cedana.services.task.TaskService/RuncManage"
	TaskService_CRIORootfsDump_FullMethodName          = "/cedana.services.task.TaskService/CRIORootfsDump"
	TaskService_CRIOImagePush_FullMethodName           = "/cedana.services.task.TaskService/CRIOImagePush"
	TaskService_LogStreaming_FullMethodName            = "/cedana.services.task.TaskService/LogStreaming"
	TaskService_ProcessStateStreaming_FullMethodName   = "/cedana.services.task.TaskService/ProcessStateStreaming"
	TaskService_DetailedHealthCheck_FullMethodName     = "/cedana.services.task.TaskService/DetailedHealthCheck"
	TaskService_KataDump_FullMethodName                = "/cedana.services.task.TaskService/KataDump"
	TaskService_KataRestore_FullMethodName             = "/cedana.services.task.TaskService/KataRestore"
	TaskService_GetConfig_FullMethodName               = "/cedana.services.task.TaskService/GetConfig"
	TaskService_QueueCheckpoint_FullMethodName         = "/cedana.services.task.TaskService/QueueCheckpoint"
	TaskService_QueueRestore_FullMethodName            = "/cedana.services.task.TaskService/QueueRestore"
	TaskService_JobStatus_FullMethodName               = "/cedana.services.task.TaskService/JobStatus"
	TaskService_GetContainerInfo_FullMethodName        = "/cedana.services.task.TaskService/GetContainerInfo"
)

Variables

View Source 
var (
	DumpType_name = map[int32]string{
		0: "PROCESS",
		1: "RUNC",
		2: "KATA",
		3: "ROOTFS",
	}
	DumpType_value = map[string]int32{
		"PROCESS": 0,
		"RUNC":    1,
		"KATA":    2,
		"ROOTFS":  3,
	}
)

Enum value maps for DumpType.

View Source 
var (
	ContainerRuntime_name = map[int32]string{
		0: "CRIO",
		1: "CONTAINERD",
	}
	ContainerRuntime_value = map[string]int32{
		"CRIO":       0,
		"CONTAINERD": 1,
	}
)

Enum value maps for ContainerRuntime.

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 (
	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 (
	QueueJobStatusEnum_name = map[int32]string{
		0: "StatusUnvalidated",
		1: "StatusWaiting",
		2: "StatusActive",
		3: "StatusFail",
		4: "StatusSuccess",
		5: "StatusInvalid",
		6: "StatusEnded",
		7: "StatusUnknown",
	}
	QueueJobStatusEnum_value = map[string]int32{
		"StatusUnvalidated": 0,
		"StatusWaiting":     1,
		"StatusActive":      2,
		"StatusFail":        3,
		"StatusSuccess":     4,
		"StatusInvalid":     5,
		"StatusEnded":       6,
		"StatusUnknown":     7,
	}
)

Enum value maps for QueueJobStatusEnum.

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 File_task_proto protoreflect.FileDescriptor
View Source 
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedana.services.task.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "JobDump",
			Handler:    _TaskService_JobDump_Handler,
		},
		{
			MethodName: "JobRestore",
			Handler:    _TaskService_JobRestore_Handler,
		},
		{
			MethodName: "JobQuery",
			Handler:    _TaskService_JobQuery_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _TaskService_Start_Handler,
		},
		{
			MethodName: "Dump",
			Handler:    _TaskService_Dump_Handler,
		},
		{
			MethodName: "Restore",
			Handler:    _TaskService_Restore_Handler,
		},
		{
			MethodName: "Manage",
			Handler:    _TaskService_Manage_Handler,
		},
		{
			MethodName: "ContainerdDump",
			Handler:    _TaskService_ContainerdDump_Handler,
		},
		{
			MethodName: "ContainerdRestore",
			Handler:    _TaskService_ContainerdRestore_Handler,
		},
		{
			MethodName: "ContainerdQuery",
			Handler:    _TaskService_ContainerdQuery_Handler,
		},
		{
			MethodName: "ContainerdRootfsDump",
			Handler:    _TaskService_ContainerdRootfsDump_Handler,
		},
		{
			MethodName: "ContainerdRootfsRestore",
			Handler:    _TaskService_ContainerdRootfsRestore_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,
		},
		{
			MethodName: "RuncManage",
			Handler:    _TaskService_RuncManage_Handler,
		},
		{
			MethodName: "CRIORootfsDump",
			Handler:    _TaskService_CRIORootfsDump_Handler,
		},
		{
			MethodName: "CRIOImagePush",
			Handler:    _TaskService_CRIOImagePush_Handler,
		},
		{
			MethodName: "DetailedHealthCheck",
			Handler:    _TaskService_DetailedHealthCheck_Handler,
		},
		{
			MethodName: "KataDump",
			Handler:    _TaskService_KataDump_Handler,
		},
		{
			MethodName: "KataRestore",
			Handler:    _TaskService_KataRestore_Handler,
		},
		{
			MethodName: "GetConfig",
			Handler:    _TaskService_GetConfig_Handler,
		},
		{
			MethodName: "QueueCheckpoint",
			Handler:    _TaskService_QueueCheckpoint_Handler,
		},
		{
			MethodName: "QueueRestore",
			Handler:    _TaskService_QueueRestore_Handler,
		},
		{
			MethodName: "JobStatus",
			Handler:    _TaskService_JobStatus_Handler,
		},
		{
			MethodName: "GetContainerInfo",
			Handler:    _TaskService_GetContainerInfo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "JobRestoreAttach",
			Handler:       _TaskService_JobRestoreAttach_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "StartAttach",
			Handler:       _TaskService_StartAttach_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "RestoreAttach",
			Handler:       _TaskService_RestoreAttach_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			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 

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

func (*Addr) Reset 

func (x *Addr) Reset()

func (*Addr) String 

func (x *Addr) String() string

type AttachArgs added in v0.9.228 

type AttachArgs struct {

	// Types that are assignable to Args:
	//
	//	*AttachArgs_RestoreArgs
	//	*AttachArgs_JobRestoreArgs
	//	*AttachArgs_StartArgs
	Args  isAttachArgs_Args `protobuf_oneof:"Args"`
	Stdin string            `protobuf:"bytes,4,opt,name=Stdin,proto3" json:"Stdin,omitempty"` // TODO: add signals
	// contains filtered or unexported fields
}

func (*AttachArgs) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use AttachArgs.ProtoReflect.Descriptor instead.

func (*AttachArgs) GetArgs added in v0.9.228 

func (m *AttachArgs) GetArgs() isAttachArgs_Args

func (*AttachArgs) GetJobRestoreArgs added in v0.9.228 

func (x *AttachArgs) GetJobRestoreArgs() *JobRestoreArgs

func (*AttachArgs) GetRestoreArgs added in v0.9.228 

func (x *AttachArgs) GetRestoreArgs() *RestoreArgs

func (*AttachArgs) GetStartArgs added in v0.9.228 

func (x *AttachArgs) GetStartArgs() *StartArgs

func (*AttachArgs) GetStdin added in v0.9.228 

func (x *AttachArgs) GetStdin() string

func (*AttachArgs) ProtoMessage added in v0.9.228 

func (*AttachArgs) ProtoMessage()

func (*AttachArgs) ProtoReflect added in v0.9.228 

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

func (*AttachArgs) Reset added in v0.9.228 

func (x *AttachArgs) Reset()

func (*AttachArgs) String added in v0.9.228 

func (x *AttachArgs) String() string

type AttachArgs_JobRestoreArgs added in v0.9.228 

type AttachArgs_JobRestoreArgs struct {
	JobRestoreArgs *JobRestoreArgs `protobuf:"bytes,2,opt,name=JobRestoreArgs,proto3,oneof"`
}

type AttachArgs_RestoreArgs added in v0.9.228 

type AttachArgs_RestoreArgs struct {
	RestoreArgs *RestoreArgs `protobuf:"bytes,1,opt,name=RestoreArgs,proto3,oneof"`
}

type AttachArgs_StartArgs added in v0.9.228 

type AttachArgs_StartArgs struct {
	StartArgs *StartArgs `protobuf:"bytes,3,opt,name=StartArgs,proto3,oneof"`
}

type AttachResp added in v0.9.228 

type AttachResp struct {
	Stdout   string `protobuf:"bytes,1,opt,name=Stdout,proto3" json:"Stdout,omitempty"`
	Stderr   string `protobuf:"bytes,2,opt,name=Stderr,proto3" json:"Stderr,omitempty"`
	ExitCode int32  `protobuf:"varint,3,opt,name=ExitCode,proto3" json:"ExitCode,omitempty"`
	// contains filtered or unexported fields
}

func (*AttachResp) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use AttachResp.ProtoReflect.Descriptor instead.

func (*AttachResp) GetExitCode added in v0.9.228 

func (x *AttachResp) GetExitCode() int32

func (*AttachResp) GetStderr added in v0.9.228 

func (x *AttachResp) GetStderr() string

func (*AttachResp) GetStdout added in v0.9.228 

func (x *AttachResp) GetStdout() string

func (*AttachResp) ProtoMessage added in v0.9.228 

func (*AttachResp) ProtoMessage()

func (*AttachResp) ProtoReflect added in v0.9.228 

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

func (*AttachResp) Reset added in v0.9.228 

func (x *AttachResp) Reset()

func (*AttachResp) String added in v0.9.228 

func (x *AttachResp) String() string

type CPUInfo 

type CPUInfo struct {
	Count      int32  `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	CPU        int32  `protobuf:"varint,2,opt,name=CPU,proto3" json:"CPU,omitempty"`
	VendorID   string `protobuf:"bytes,3,opt,name=VendorID,proto3" json:"VendorID,omitempty"`
	Family     string `protobuf:"bytes,4,opt,name=Family,proto3" json:"Family,omitempty"`
	PhysicalID string `protobuf:"bytes,5,opt,name=PhysicalID,proto3" json:"PhysicalID,omitempty"`
	// contains filtered or unexported fields
}

func (*CPUInfo) Descriptor deprecated 

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

Deprecated: Use CPUInfo.ProtoReflect.Descriptor instead.

func (*CPUInfo) GetCPU 

func (x *CPUInfo) GetCPU() int32

func (*CPUInfo) GetCount 

func (x *CPUInfo) GetCount() int32

func (*CPUInfo) GetFamily 

func (x *CPUInfo) GetFamily() string

func (*CPUInfo) GetPhysicalID 

func (x *CPUInfo) GetPhysicalID() string

func (*CPUInfo) GetVendorID 

func (x *CPUInfo) GetVendorID() string

func (*CPUInfo) ProtoMessage 

func (*CPUInfo) ProtoMessage()

func (*CPUInfo) ProtoReflect 

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

func (*CPUInfo) Reset 

func (x *CPUInfo) Reset()

func (*CPUInfo) String 

func (x *CPUInfo) String() string

type CRIOImagePushArgs 

type CRIOImagePushArgs struct {
	OriginalImageRef      string `protobuf:"bytes,1,opt,name=OriginalImageRef,proto3" json:"OriginalImageRef,omitempty"`
	NewImageRef           string `protobuf:"bytes,2,opt,name=NewImageRef,proto3" json:"NewImageRef,omitempty"`
	RootfsDiffPath        string `protobuf:"bytes,3,opt,name=RootfsDiffPath,proto3" json:"RootfsDiffPath,omitempty"`
	ContainerStorage      string `protobuf:"bytes,4,opt,name=ContainerStorage,proto3" json:"ContainerStorage,omitempty"`
	RegistryAuthTokenPush string `protobuf:"bytes,5,opt,name=RegistryAuthTokenPush,proto3" json:"RegistryAuthTokenPush,omitempty"`
	RegistryAuthTokenPull string `protobuf:"bytes,6,opt,name=RegistryAuthTokenPull,proto3" json:"RegistryAuthTokenPull,omitempty"`
	// contains filtered or unexported fields
}

func (*CRIOImagePushArgs) Descriptor deprecated 

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

Deprecated: Use CRIOImagePushArgs.ProtoReflect.Descriptor instead.

func (*CRIOImagePushArgs) GetContainerStorage 

func (x *CRIOImagePushArgs) GetContainerStorage() string

func (*CRIOImagePushArgs) GetNewImageRef 

func (x *CRIOImagePushArgs) GetNewImageRef() string

func (*CRIOImagePushArgs) GetOriginalImageRef 

func (x *CRIOImagePushArgs) GetOriginalImageRef() string

func (*CRIOImagePushArgs) GetRegistryAuthTokenPull 

func (x *CRIOImagePushArgs) GetRegistryAuthTokenPull() string

func (*CRIOImagePushArgs) GetRegistryAuthTokenPush 

func (x *CRIOImagePushArgs) GetRegistryAuthTokenPush() string

func (*CRIOImagePushArgs) GetRootfsDiffPath 

func (x *CRIOImagePushArgs) GetRootfsDiffPath() string

func (*CRIOImagePushArgs) ProtoMessage 

func (*CRIOImagePushArgs) ProtoMessage()

func (*CRIOImagePushArgs) ProtoReflect 

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

func (*CRIOImagePushArgs) Reset 

func (x *CRIOImagePushArgs) Reset()

func (*CRIOImagePushArgs) String 

func (x *CRIOImagePushArgs) String() string

type CRIOImagePushResp 

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

func (*CRIOImagePushResp) Descriptor deprecated 

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

Deprecated: Use CRIOImagePushResp.ProtoReflect.Descriptor instead.

func (*CRIOImagePushResp) GetMessage 

func (x *CRIOImagePushResp) GetMessage() string

func (*CRIOImagePushResp) ProtoMessage 

func (*CRIOImagePushResp) ProtoMessage()

func (*CRIOImagePushResp) ProtoReflect 

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

func (*CRIOImagePushResp) Reset 

func (x *CRIOImagePushResp) Reset()

func (*CRIOImagePushResp) String 

func (x *CRIOImagePushResp) String() string

type CRIORootfsDumpArgs 

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

func (*CRIORootfsDumpArgs) Descriptor deprecated 

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

Deprecated: Use CRIORootfsDumpArgs.ProtoReflect.Descriptor instead.

func (*CRIORootfsDumpArgs) GetContainerID 

func (x *CRIORootfsDumpArgs) GetContainerID() string

func (*CRIORootfsDumpArgs) GetContainerStorage 

func (x *CRIORootfsDumpArgs) GetContainerStorage() string

func (*CRIORootfsDumpArgs) GetDest 

func (x *CRIORootfsDumpArgs) GetDest() string

func (*CRIORootfsDumpArgs) ProtoMessage 

func (*CRIORootfsDumpArgs) ProtoMessage()

func (*CRIORootfsDumpArgs) ProtoReflect 

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

func (*CRIORootfsDumpArgs) Reset 

func (x *CRIORootfsDumpArgs) Reset()

func (*CRIORootfsDumpArgs) String 

func (x *CRIORootfsDumpArgs) String() string

type CRIORootfsDumpResp 

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

func (*CRIORootfsDumpResp) Descriptor deprecated 

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

Deprecated: Use CRIORootfsDumpResp.ProtoReflect.Descriptor instead.

func (*CRIORootfsDumpResp) GetDest 

func (x *CRIORootfsDumpResp) GetDest() string

func (*CRIORootfsDumpResp) ProtoMessage 

func (*CRIORootfsDumpResp) ProtoMessage()

func (*CRIORootfsDumpResp) ProtoReflect 

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

func (*CRIORootfsDumpResp) Reset 

func (x *CRIORootfsDumpResp) Reset()

func (*CRIORootfsDumpResp) String 

func (x *CRIORootfsDumpResp) String() string

type CRType 

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

func (CRType) Descriptor 

func (CRType) Descriptor() protoreflect.EnumDescriptor

func (CRType) Enum 

func (x CRType) Enum() *CRType

func (CRType) EnumDescriptor deprecated 

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

Deprecated: Use CRType.Descriptor instead.

func (CRType) Number 

func (x CRType) Number() protoreflect.EnumNumber

func (CRType) String 

func (x CRType) String() string

func (CRType) Type 

func (CRType) Type() protoreflect.EnumType

type CheckpointFileStats 

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

func (*CheckpointFileStats) Descriptor deprecated 

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

Deprecated: Use CheckpointFileStats.ProtoReflect.Descriptor instead.

func (*CheckpointFileStats) GetDuration 

func (x *CheckpointFileStats) GetDuration() int64

func (*CheckpointFileStats) GetSize 

func (x *CheckpointFileStats) GetSize() int64

func (*CheckpointFileStats) ProtoMessage 

func (*CheckpointFileStats) ProtoMessage()

func (*CheckpointFileStats) ProtoReflect 

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

func (*CheckpointFileStats) Reset 

func (x *CheckpointFileStats) Reset()

func (*CheckpointFileStats) String 

func (x *CheckpointFileStats) String() string

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 (x *CheckpointReason) GetReason() CheckpointReason_CheckpointReasonEnum

func (*CheckpointReason) ProtoMessage 

func (*CheckpointReason) ProtoMessage()

func (*CheckpointReason) ProtoReflect 

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 

func (CheckpointReason_CheckpointReasonEnum) Descriptor() protoreflect.EnumDescriptor

func (CheckpointReason_CheckpointReasonEnum) Enum 

func (x CheckpointReason_CheckpointReasonEnum) Enum() *CheckpointReason_CheckpointReasonEnum

func (CheckpointReason_CheckpointReasonEnum) EnumDescriptor deprecated 

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

Deprecated: Use CheckpointReason_CheckpointReasonEnum.Descriptor instead.

func (CheckpointReason_CheckpointReasonEnum) Number 

func (x CheckpointReason_CheckpointReasonEnum) Number() protoreflect.EnumNumber

func (CheckpointReason_CheckpointReasonEnum) String 

func (x CheckpointReason_CheckpointReasonEnum) String() string

func (CheckpointReason_CheckpointReasonEnum) Type 

func (CheckpointReason_CheckpointReasonEnum) Type() protoreflect.EnumType

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 

func (CheckpointState) Descriptor() protoreflect.EnumDescriptor

func (CheckpointState) Enum 

func (x CheckpointState) Enum() *CheckpointState

func (CheckpointState) EnumDescriptor deprecated 

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

Deprecated: Use CheckpointState.Descriptor instead.

func (CheckpointState) Number 

func (x CheckpointState) Number() protoreflect.EnumNumber

func (CheckpointState) String 

func (x CheckpointState) String() string

func (CheckpointState) Type 

func (CheckpointState) Type() protoreflect.EnumType

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 

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

func (*ConnectionStat) ProtoMessage 

func (*ConnectionStat) ProtoMessage()

func (*ConnectionStat) ProtoReflect 

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

func (*ConnectionStat) Reset 

func (x *ConnectionStat) Reset()

func (*ConnectionStat) String 

func (x *ConnectionStat) String() string

type ContainerInfo added in v0.9.222 

type ContainerInfo struct {
	CpuTime           float64 `protobuf:"fixed64,1,opt,name=CpuTime,proto3" json:"CpuTime,omitempty"`
	FilesystemIoTime  float64 `protobuf:"fixed64,2,opt,name=FilesystemIoTime,proto3" json:"FilesystemIoTime,omitempty"`
	AcceleratorMemory float64 `protobuf:"fixed64,3,opt,name=AcceleratorMemory,proto3" json:"AcceleratorMemory,omitempty"`
	CurrentMemory     float64 `protobuf:"fixed64,4,opt,name=CurrentMemory,proto3" json:"CurrentMemory,omitempty"`
	NetworkIO         float64 `protobuf:"fixed64,5,opt,name=NetworkIO,proto3" json:"NetworkIO,omitempty"`
	DiskIO            float64 `protobuf:"fixed64,6,opt,name=DiskIO,proto3" json:"DiskIO,omitempty"`
	ContainerName     string  `protobuf:"bytes,7,opt,name=ContainerName,proto3" json:"ContainerName,omitempty"`
	Processes         string  `protobuf:"bytes,8,opt,name=Processes,proto3" json:"Processes,omitempty"`
	Labels            string  `protobuf:"bytes,9,opt,name=Labels,proto3" json:"Labels,omitempty"`
	Image             string  `protobuf:"bytes,10,opt,name=Image,proto3" json:"Image,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerInfo) Descriptor deprecated added in v0.9.222 

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

Deprecated: Use ContainerInfo.ProtoReflect.Descriptor instead.

func (*ContainerInfo) GetAcceleratorMemory added in v0.9.228 

func (x *ContainerInfo) GetAcceleratorMemory() float64

func (*ContainerInfo) GetContainerName added in v0.9.222 

func (x *ContainerInfo) GetContainerName() string

func (*ContainerInfo) GetCpuTime added in v0.9.222 

func (x *ContainerInfo) GetCpuTime() float64

func (*ContainerInfo) GetCurrentMemory added in v0.9.222 

func (x *ContainerInfo) GetCurrentMemory() float64

func (*ContainerInfo) GetDiskIO added in v0.9.222 

func (x *ContainerInfo) GetDiskIO() float64

func (*ContainerInfo) GetFilesystemIoTime added in v0.9.228 

func (x *ContainerInfo) GetFilesystemIoTime() float64

func (*ContainerInfo) GetImage added in v0.9.228 

func (x *ContainerInfo) GetImage() string

func (*ContainerInfo) GetLabels added in v0.9.228 

func (x *ContainerInfo) GetLabels() string

func (*ContainerInfo) GetNetworkIO added in v0.9.222 

func (x *ContainerInfo) GetNetworkIO() float64

func (*ContainerInfo) GetProcesses added in v0.9.228 

func (x *ContainerInfo) GetProcesses() string

func (*ContainerInfo) ProtoMessage added in v0.9.222 

func (*ContainerInfo) ProtoMessage()

func (*ContainerInfo) ProtoReflect added in v0.9.222 

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

func (*ContainerInfo) Reset added in v0.9.222 

func (x *ContainerInfo) Reset()

func (*ContainerInfo) String added in v0.9.222 

func (x *ContainerInfo) String() string

type ContainerInfoRequest added in v0.9.222 

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

func (*ContainerInfoRequest) Descriptor deprecated added in v0.9.222 

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

Deprecated: Use ContainerInfoRequest.ProtoReflect.Descriptor instead.

func (*ContainerInfoRequest) ProtoMessage added in v0.9.222 

func (*ContainerInfoRequest) ProtoMessage()

func (*ContainerInfoRequest) ProtoReflect added in v0.9.222 

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

func (*ContainerInfoRequest) Reset added in v0.9.222 

func (x *ContainerInfoRequest) Reset()

func (*ContainerInfoRequest) String added in v0.9.222 

func (x *ContainerInfoRequest) String() string

type ContainerRuntime 

type ContainerRuntime int32
const (
	ContainerRuntime_CRIO       ContainerRuntime = 0
	ContainerRuntime_CONTAINERD ContainerRuntime = 1
)

func (ContainerRuntime) Descriptor 

func (ContainerRuntime) Descriptor() protoreflect.EnumDescriptor

func (ContainerRuntime) Enum 

func (x ContainerRuntime) Enum() *ContainerRuntime

func (ContainerRuntime) EnumDescriptor deprecated 

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

Deprecated: Use ContainerRuntime.Descriptor instead.

func (ContainerRuntime) Number 

func (x ContainerRuntime) Number() protoreflect.EnumNumber

func (ContainerRuntime) String 

func (x ContainerRuntime) String() string

func (ContainerRuntime) Type 

func (ContainerRuntime) Type() protoreflect.EnumType

type ContainerdContainer 

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 

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

Deprecated: Use ContainerdContainer.ProtoReflect.Descriptor instead.

func (*ContainerdContainer) GetContainerName 

func (x *ContainerdContainer) GetContainerName() string

func (*ContainerdContainer) GetImageName 

func (x *ContainerdContainer) GetImageName() string

func (*ContainerdContainer) GetSandboxId 

func (x *ContainerdContainer) GetSandboxId() string

func (*ContainerdContainer) GetSandboxName 

func (x *ContainerdContainer) GetSandboxName() string

func (*ContainerdContainer) GetSandboxNamespace 

func (x *ContainerdContainer) GetSandboxNamespace() string

func (*ContainerdContainer) GetSandboxUid 

func (x *ContainerdContainer) GetSandboxUid() string

func (*ContainerdContainer) ProtoMessage 

func (*ContainerdContainer) ProtoMessage()

func (*ContainerdContainer) ProtoReflect 

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

func (*ContainerdContainer) Reset 

func (x *ContainerdContainer) Reset()

func (*ContainerdContainer) String 

func (x *ContainerdContainer) String() string

type ContainerdDumpArgs 

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

func (*ContainerdDumpArgs) Descriptor deprecated 

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

Deprecated: Use ContainerdDumpArgs.ProtoReflect.Descriptor instead.

func (*ContainerdDumpArgs) GetContainerdRootfsDumpArgs 

func (x *ContainerdDumpArgs) GetContainerdRootfsDumpArgs() *ContainerdRootfsDumpArgs

func (*ContainerdDumpArgs) GetRuncDumpArgs 

func (x *ContainerdDumpArgs) GetRuncDumpArgs() *RuncDumpArgs

func (*ContainerdDumpArgs) ProtoMessage 

func (*ContainerdDumpArgs) ProtoMessage()

func (*ContainerdDumpArgs) ProtoReflect 

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

func (*ContainerdDumpArgs) Reset 

func (x *ContainerdDumpArgs) Reset()

func (*ContainerdDumpArgs) String 

func (x *ContainerdDumpArgs) String() string

type ContainerdDumpResp 

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 

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

Deprecated: Use ContainerdDumpResp.ProtoReflect.Descriptor instead.

func (*ContainerdDumpResp) GetCheckpointPath 

func (x *ContainerdDumpResp) GetCheckpointPath() string

func (*ContainerdDumpResp) GetMessage 

func (x *ContainerdDumpResp) GetMessage() string

func (*ContainerdDumpResp) ProtoMessage 

func (*ContainerdDumpResp) ProtoMessage()

func (*ContainerdDumpResp) ProtoReflect 

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

func (*ContainerdDumpResp) Reset 

func (x *ContainerdDumpResp) Reset()

func (*ContainerdDumpResp) String 

func (x *ContainerdDumpResp) String() string

type ContainerdQueryArgs 

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 

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

Deprecated: Use ContainerdQueryArgs.ProtoReflect.Descriptor instead.

func (*ContainerdQueryArgs) GetNamespace 

func (x *ContainerdQueryArgs) GetNamespace() string

func (*ContainerdQueryArgs) GetRoot 

func (x *ContainerdQueryArgs) GetRoot() string

func (*ContainerdQueryArgs) ProtoMessage 

func (*ContainerdQueryArgs) ProtoMessage()

func (*ContainerdQueryArgs) ProtoReflect 

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

func (*ContainerdQueryArgs) Reset 

func (x *ContainerdQueryArgs) Reset()

func (*ContainerdQueryArgs) String 

func (x *ContainerdQueryArgs) String() string

type ContainerdQueryResp 

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

func (*ContainerdQueryResp) Descriptor deprecated 

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

Deprecated: Use ContainerdQueryResp.ProtoReflect.Descriptor instead.

func (*ContainerdQueryResp) GetContainers 

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

func (*ContainerdQueryResp) ProtoMessage 

func (*ContainerdQueryResp) ProtoMessage()

func (*ContainerdQueryResp) ProtoReflect 

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

func (*ContainerdQueryResp) Reset 

func (x *ContainerdQueryResp) Reset()

func (*ContainerdQueryResp) String 

func (x *ContainerdQueryResp) String() string

type ContainerdRestoreArgs 

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 

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

Deprecated: Use ContainerdRestoreArgs.ProtoReflect.Descriptor instead.

func (*ContainerdRestoreArgs) GetContainerID 

func (x *ContainerdRestoreArgs) GetContainerID() string

func (*ContainerdRestoreArgs) GetImgPath 

func (x *ContainerdRestoreArgs) GetImgPath() string

func (*ContainerdRestoreArgs) ProtoMessage 

func (*ContainerdRestoreArgs) ProtoMessage()

func (*ContainerdRestoreArgs) ProtoReflect 

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

func (*ContainerdRestoreArgs) Reset 

func (x *ContainerdRestoreArgs) Reset()

func (*ContainerdRestoreArgs) String 

func (x *ContainerdRestoreArgs) String() string

type ContainerdRestoreResp 

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

func (*ContainerdRestoreResp) Descriptor deprecated 

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

Deprecated: Use ContainerdRestoreResp.ProtoReflect.Descriptor instead.

func (*ContainerdRestoreResp) GetMessage 

func (x *ContainerdRestoreResp) GetMessage() string

func (*ContainerdRestoreResp) ProtoMessage 

func (*ContainerdRestoreResp) ProtoMessage()

func (*ContainerdRestoreResp) ProtoReflect 

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

func (*ContainerdRestoreResp) Reset 

func (x *ContainerdRestoreResp) Reset()

func (*ContainerdRestoreResp) String 

func (x *ContainerdRestoreResp) String() string

type ContainerdRootfsDumpArgs 

type ContainerdRootfsDumpArgs struct {
	ContainerID string `protobuf:"bytes,1,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	ImageRef    string `protobuf:"bytes,2,opt,name=ImageRef,proto3" json:"ImageRef,omitempty"`
	Address     string `protobuf:"bytes,3,opt,name=Address,proto3" json:"Address,omitempty"`
	Namespace   string `protobuf:"bytes,4,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerdRootfsDumpArgs) Descriptor deprecated 

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

Deprecated: Use ContainerdRootfsDumpArgs.ProtoReflect.Descriptor instead.

func (*ContainerdRootfsDumpArgs) GetAddress 

func (x *ContainerdRootfsDumpArgs) GetAddress() string

func (*ContainerdRootfsDumpArgs) GetContainerID 

func (x *ContainerdRootfsDumpArgs) GetContainerID() string

func (*ContainerdRootfsDumpArgs) GetImageRef 

func (x *ContainerdRootfsDumpArgs) GetImageRef() string

func (*ContainerdRootfsDumpArgs) GetNamespace 

func (x *ContainerdRootfsDumpArgs) GetNamespace() string

func (*ContainerdRootfsDumpArgs) ProtoMessage 

func (*ContainerdRootfsDumpArgs) ProtoMessage()

func (*ContainerdRootfsDumpArgs) ProtoReflect 

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

func (*ContainerdRootfsDumpArgs) Reset 

func (x *ContainerdRootfsDumpArgs) Reset()

func (*ContainerdRootfsDumpArgs) String 

func (x *ContainerdRootfsDumpArgs) String() string

type ContainerdRootfsDumpResp 

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

func (*ContainerdRootfsDumpResp) Descriptor deprecated 

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

Deprecated: Use ContainerdRootfsDumpResp.ProtoReflect.Descriptor instead.

func (*ContainerdRootfsDumpResp) GetImageRef 

func (x *ContainerdRootfsDumpResp) GetImageRef() string

func (*ContainerdRootfsDumpResp) ProtoMessage 

func (*ContainerdRootfsDumpResp) ProtoMessage()

func (*ContainerdRootfsDumpResp) ProtoReflect 

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

func (*ContainerdRootfsDumpResp) Reset 

func (x *ContainerdRootfsDumpResp) Reset()

func (*ContainerdRootfsDumpResp) String 

func (x *ContainerdRootfsDumpResp) String() string

type ContainerdRootfsRestoreArgs 

type ContainerdRootfsRestoreArgs struct {
	ContainerID string `protobuf:"bytes,1,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	ImageRef    string `protobuf:"bytes,2,opt,name=ImageRef,proto3" json:"ImageRef,omitempty"`
	Address     string `protobuf:"bytes,3,opt,name=Address,proto3" json:"Address,omitempty"`
	Namespace   string `protobuf:"bytes,4,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*ContainerdRootfsRestoreArgs) Descriptor deprecated 

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

Deprecated: Use ContainerdRootfsRestoreArgs.ProtoReflect.Descriptor instead.

func (*ContainerdRootfsRestoreArgs) GetAddress 

func (x *ContainerdRootfsRestoreArgs) GetAddress() string

func (*ContainerdRootfsRestoreArgs) GetContainerID 

func (x *ContainerdRootfsRestoreArgs) GetContainerID() string

func (*ContainerdRootfsRestoreArgs) GetImageRef 

func (x *ContainerdRootfsRestoreArgs) GetImageRef() string

func (*ContainerdRootfsRestoreArgs) GetNamespace 

func (x *ContainerdRootfsRestoreArgs) GetNamespace() string

func (*ContainerdRootfsRestoreArgs) ProtoMessage 

func (*ContainerdRootfsRestoreArgs) ProtoMessage()

func (*ContainerdRootfsRestoreArgs) ProtoReflect 

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

func (*ContainerdRootfsRestoreArgs) Reset 

func (x *ContainerdRootfsRestoreArgs) Reset()

func (*ContainerdRootfsRestoreArgs) String 

func (x *ContainerdRootfsRestoreArgs) String() string

type ContainerdRootfsRestoreResp 

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

func (*ContainerdRootfsRestoreResp) Descriptor deprecated 

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

Deprecated: Use ContainerdRootfsRestoreResp.ProtoReflect.Descriptor instead.

func (*ContainerdRootfsRestoreResp) GetImageRef 

func (x *ContainerdRootfsRestoreResp) GetImageRef() string

func (*ContainerdRootfsRestoreResp) ProtoMessage 

func (*ContainerdRootfsRestoreResp) ProtoMessage()

func (*ContainerdRootfsRestoreResp) ProtoReflect 

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

func (*ContainerdRootfsRestoreResp) Reset 

func (x *ContainerdRootfsRestoreResp) Reset()

func (*ContainerdRootfsRestoreResp) String 

func (x *ContainerdRootfsRestoreResp) String() string

type ContainersInfo added in v0.9.222 

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

func (*ContainersInfo) Descriptor deprecated added in v0.9.222 

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

Deprecated: Use ContainersInfo.ProtoReflect.Descriptor instead.

func (*ContainersInfo) GetContainers added in v0.9.222 

func (x *ContainersInfo) GetContainers() []*ContainerInfo

func (*ContainersInfo) ProtoMessage added in v0.9.222 

func (*ContainersInfo) ProtoMessage()

func (*ContainersInfo) ProtoReflect added in v0.9.222 

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

func (*ContainersInfo) Reset added in v0.9.222 

func (x *ContainersInfo) Reset()

func (*ContainersInfo) String added in v0.9.222 

func (x *ContainersInfo) 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"`
	Stream                  bool     `protobuf:"varint,10,opt,name=Stream,proto3" json:"Stream,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"`
	External                []string `protobuf:"bytes,18,rep,name=External,proto3" json:"External,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) GetExternal 

func (x *CriuOpts) GetExternal() []string

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) GetStream 

func (x *CriuOpts) GetStream() bool

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 

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

func (*CriuOpts) Reset 

func (x *CriuOpts) Reset()

func (*CriuOpts) String 

func (x *CriuOpts) String() string

type DetailedHealthCheckRequest 

type DetailedHealthCheckRequest struct {
	UID    int32   `protobuf:"varint,1,opt,name=UID,proto3" json:"UID,omitempty"`
	GID    int32   `protobuf:"varint,2,opt,name=GID,proto3" json:"GID,omitempty"`
	Groups []int32 `protobuf:"varint,3,rep,packed,name=Groups,proto3" json:"Groups,omitempty"`
	// contains filtered or unexported fields
}

func (*DetailedHealthCheckRequest) Descriptor deprecated 

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

Deprecated: Use DetailedHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*DetailedHealthCheckRequest) GetGID 

func (x *DetailedHealthCheckRequest) GetGID() int32

func (*DetailedHealthCheckRequest) GetGroups 

func (x *DetailedHealthCheckRequest) GetGroups() []int32

func (*DetailedHealthCheckRequest) GetUID 

func (x *DetailedHealthCheckRequest) GetUID() int32

func (*DetailedHealthCheckRequest) ProtoMessage 

func (*DetailedHealthCheckRequest) ProtoMessage()

func (*DetailedHealthCheckRequest) ProtoReflect 

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

func (*DetailedHealthCheckRequest) Reset 

func (x *DetailedHealthCheckRequest) Reset()

func (*DetailedHealthCheckRequest) String 

func (x *DetailedHealthCheckRequest) String() string

type DetailedHealthCheckResponse 

type DetailedHealthCheckResponse struct {
	HealthCheckStats *HealthCheckStats `protobuf:"bytes,1,opt,name=HealthCheckStats,proto3" json:"HealthCheckStats,omitempty"`
	UnhealthyReasons []string          `protobuf:"bytes,2,rep,name=unhealthyReasons,proto3" json:"unhealthyReasons,omitempty"`
	// contains filtered or unexported fields
}

func (*DetailedHealthCheckResponse) Descriptor deprecated 

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

Deprecated: Use DetailedHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*DetailedHealthCheckResponse) GetHealthCheckStats 

func (x *DetailedHealthCheckResponse) GetHealthCheckStats() *HealthCheckStats

func (*DetailedHealthCheckResponse) GetUnhealthyReasons 

func (x *DetailedHealthCheckResponse) GetUnhealthyReasons() []string

func (*DetailedHealthCheckResponse) ProtoMessage 

func (*DetailedHealthCheckResponse) ProtoMessage()

func (*DetailedHealthCheckResponse) ProtoReflect 

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

func (*DetailedHealthCheckResponse) Reset 

func (x *DetailedHealthCheckResponse) Reset()

func (*DetailedHealthCheckResponse) String 

func (x *DetailedHealthCheckResponse) 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"`
	Stream   bool      `protobuf:"varint,5,opt,name=Stream,proto3" json:"Stream,omitempty"`
	CriuOpts *CriuOpts `protobuf:"bytes,6,opt,name=CriuOpts,proto3" json:"CriuOpts,omitempty"`
	// contains filtered or unexported fields
}

func (*DumpArgs) Descriptor deprecated 

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

Deprecated: Use DumpArgs.ProtoReflect.Descriptor instead.

func (*DumpArgs) GetCriuOpts added in v0.9.221 

func (x *DumpArgs) GetCriuOpts() *CriuOpts

func (*DumpArgs) GetDir 

func (x *DumpArgs) GetDir() string

func (*DumpArgs) GetJID 

func (x *DumpArgs) GetJID() string

func (*DumpArgs) GetPID 

func (x *DumpArgs) GetPID() int32

func (*DumpArgs) GetStream 

func (x *DumpArgs) GetStream() bool

func (*DumpArgs) GetType 

func (x *DumpArgs) GetType() CRType

func (*DumpArgs) ProtoMessage 

func (*DumpArgs) ProtoMessage()

func (*DumpArgs) ProtoReflect 

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"`
	State        *ProcessState `protobuf:"bytes,4,opt,name=State,proto3" json:"State,omitempty"`
	DumpStats    *DumpStats    `protobuf:"bytes,5,opt,name=DumpStats,proto3" json:"DumpStats,omitempty"`
	// contains filtered or unexported fields
}

func (*DumpResp) Descriptor deprecated 

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

Deprecated: Use DumpResp.ProtoReflect.Descriptor instead.

func (*DumpResp) GetCheckpointID 

func (x *DumpResp) GetCheckpointID() string

func (*DumpResp) GetDumpStats 

func (x *DumpResp) GetDumpStats() *DumpStats

func (*DumpResp) GetMessage 

func (x *DumpResp) GetMessage() string

func (*DumpResp) GetState 

func (x *DumpResp) GetState() *ProcessState

func (*DumpResp) GetUploadID 

func (x *DumpResp) GetUploadID() string

func (*DumpResp) ProtoMessage 

func (*DumpResp) ProtoMessage()

func (*DumpResp) ProtoReflect 

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

func (*DumpResp) Reset 

func (x *DumpResp) Reset()

func (*DumpResp) String 

func (x *DumpResp) String() string

type DumpStats 

type DumpStats struct {
	DumpType            DumpType             `protobuf:"varint,1,opt,name=DumpType,proto3,enum=cedana.services.task.DumpType" json:"DumpType,omitempty"`
	PrepareDuration     int64                `protobuf:"varint,2,opt,name=PrepareDuration,proto3" json:"PrepareDuration,omitempty"`
	CRIUDuration        int64                `protobuf:"varint,3,opt,name=CRIUDuration,proto3" json:"CRIUDuration,omitempty"`
	GPUDuration         int64                `protobuf:"varint,4,opt,name=GPUDuration,proto3" json:"GPUDuration,omitempty"`
	UploadDuration      int64                `protobuf:"varint,5,opt,name=UploadDuration,proto3" json:"UploadDuration,omitempty"`
	ContainerRuntime    ContainerRuntime     `` /* 129-byte string literal not displayed */
	Kubernetes          bool                 `protobuf:"varint,7,opt,name=Kubernetes,proto3" json:"Kubernetes,omitempty"`
	CheckpointFileStats *CheckpointFileStats `protobuf:"bytes,8,opt,name=CheckpointFileStats,proto3" json:"CheckpointFileStats,omitempty"`
	// contains filtered or unexported fields
}

func (*DumpStats) Descriptor deprecated 

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

Deprecated: Use DumpStats.ProtoReflect.Descriptor instead.

func (*DumpStats) GetCRIUDuration 

func (x *DumpStats) GetCRIUDuration() int64

func (*DumpStats) GetCheckpointFileStats 

func (x *DumpStats) GetCheckpointFileStats() *CheckpointFileStats

func (*DumpStats) GetContainerRuntime 

func (x *DumpStats) GetContainerRuntime() ContainerRuntime

func (*DumpStats) GetDumpType 

func (x *DumpStats) GetDumpType() DumpType

func (*DumpStats) GetGPUDuration 

func (x *DumpStats) GetGPUDuration() int64

func (*DumpStats) GetKubernetes 

func (x *DumpStats) GetKubernetes() bool

func (*DumpStats) GetPrepareDuration 

func (x *DumpStats) GetPrepareDuration() int64

func (*DumpStats) GetUploadDuration 

func (x *DumpStats) GetUploadDuration() int64

func (*DumpStats) ProtoMessage 

func (*DumpStats) ProtoMessage()

func (*DumpStats) ProtoReflect 

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

func (*DumpStats) Reset 

func (x *DumpStats) Reset()

func (*DumpStats) String 

func (x *DumpStats) String() string

type DumpType 

type DumpType int32
const (
	DumpType_PROCESS DumpType = 0
	DumpType_RUNC    DumpType = 1
	DumpType_KATA    DumpType = 2
	DumpType_ROOTFS  DumpType = 3
)

func (DumpType) Descriptor 

func (DumpType) Descriptor() protoreflect.EnumDescriptor

func (DumpType) Enum 

func (x DumpType) Enum() *DumpType

func (DumpType) EnumDescriptor deprecated 

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

Deprecated: Use DumpType.Descriptor instead.

func (DumpType) Number 

func (x DumpType) Number() protoreflect.EnumNumber

func (DumpType) String 

func (x DumpType) String() string

func (DumpType) Type 

func (DumpType) Type() protoreflect.EnumType

type GetConfigRequest 

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

func (*GetConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConfigRequest) ProtoMessage 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) ProtoReflect 

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

func (*GetConfigRequest) Reset 

func (x *GetConfigRequest) Reset()

func (*GetConfigRequest) String 

func (x *GetConfigRequest) String() string

type GetConfigResponse 

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

func (*GetConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.

func (*GetConfigResponse) GetJSON 

func (x *GetConfigResponse) GetJSON() string

func (*GetConfigResponse) ProtoMessage 

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) ProtoReflect 

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

func (*GetConfigResponse) Reset 

func (x *GetConfigResponse) Reset()

func (*GetConfigResponse) String 

func (x *GetConfigResponse) String() string

type HealthCheckStats 

type HealthCheckStats struct {
	CriuVersion    string                   `protobuf:"bytes,1,opt,name=criuVersion,proto3" json:"criuVersion,omitempty"`
	GPUHealthCheck *gpu.HealthCheckResponse `protobuf:"bytes,2,opt,name=GPUHealthCheck,proto3" json:"GPUHealthCheck,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckStats) Descriptor deprecated 

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

Deprecated: Use HealthCheckStats.ProtoReflect.Descriptor instead.

func (*HealthCheckStats) GetCriuVersion 

func (x *HealthCheckStats) GetCriuVersion() string

func (*HealthCheckStats) GetGPUHealthCheck 

func (x *HealthCheckStats) GetGPUHealthCheck() *gpu.HealthCheckResponse

func (*HealthCheckStats) ProtoMessage 

func (*HealthCheckStats) ProtoMessage()

func (*HealthCheckStats) ProtoReflect 

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

func (*HealthCheckStats) Reset 

func (x *HealthCheckStats) Reset()

func (*HealthCheckStats) String 

func (x *HealthCheckStats) String() string

type HostInfo 

type HostInfo struct {
	HostID               string `protobuf:"bytes,1,opt,name=HostID,proto3" json:"HostID,omitempty"`
	Hostname             string `protobuf:"bytes,4,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	OS                   string `protobuf:"bytes,5,opt,name=OS,proto3" json:"OS,omitempty"`
	Platform             string `protobuf:"bytes,6,opt,name=Platform,proto3" json:"Platform,omitempty"`
	KernelVersion        string `protobuf:"bytes,7,opt,name=KernelVersion,proto3" json:"KernelVersion,omitempty"`
	KernelArch           string `protobuf:"bytes,8,opt,name=KernelArch,proto3" json:"KernelArch,omitempty"`
	VirtualizationSystem string `protobuf:"bytes,9,opt,name=VirtualizationSystem,proto3" json:"VirtualizationSystem,omitempty"`
	VirtualizationRole   string `protobuf:"bytes,10,opt,name=VirtualizationRole,proto3" json:"VirtualizationRole,omitempty"`
	// contains filtered or unexported fields
}

func (*HostInfo) Descriptor deprecated 

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

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetHostID 

func (x *HostInfo) GetHostID() string

func (*HostInfo) GetHostname 

func (x *HostInfo) GetHostname() string

func (*HostInfo) GetKernelArch 

func (x *HostInfo) GetKernelArch() string

func (*HostInfo) GetKernelVersion 

func (x *HostInfo) GetKernelVersion() string

func (*HostInfo) GetOS 

func (x *HostInfo) GetOS() string

func (*HostInfo) GetPlatform 

func (x *HostInfo) GetPlatform() string

func (*HostInfo) GetVirtualizationRole 

func (x *HostInfo) GetVirtualizationRole() string

func (*HostInfo) GetVirtualizationSystem 

func (x *HostInfo) GetVirtualizationSystem() string

func (*HostInfo) ProtoMessage 

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect 

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

func (*HostInfo) Reset 

func (x *HostInfo) Reset()

func (*HostInfo) String 

func (x *HostInfo) String() string

type JobDumpArgs added in v0.9.228 

type JobDumpArgs struct {
	JID      string    `protobuf:"bytes,1,opt,name=JID,proto3" json:"JID,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"`
	Stream   bool      `protobuf:"varint,4,opt,name=Stream,proto3" json:"Stream,omitempty"`
	CriuOpts *CriuOpts `protobuf:"bytes,5,opt,name=CriuOpts,proto3" json:"CriuOpts,omitempty"`
	// contains filtered or unexported fields
}

func (*JobDumpArgs) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use JobDumpArgs.ProtoReflect.Descriptor instead.

func (*JobDumpArgs) GetCriuOpts added in v0.9.228 

func (x *JobDumpArgs) GetCriuOpts() *CriuOpts

func (*JobDumpArgs) GetDir added in v0.9.228 

func (x *JobDumpArgs) GetDir() string

func (*JobDumpArgs) GetJID added in v0.9.228 

func (x *JobDumpArgs) GetJID() string

func (*JobDumpArgs) GetStream added in v0.9.228 

func (x *JobDumpArgs) GetStream() bool

func (*JobDumpArgs) GetType added in v0.9.228 

func (x *JobDumpArgs) GetType() CRType

func (*JobDumpArgs) ProtoMessage added in v0.9.228 

func (*JobDumpArgs) ProtoMessage()

func (*JobDumpArgs) ProtoReflect added in v0.9.228 

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

func (*JobDumpArgs) Reset added in v0.9.228 

func (x *JobDumpArgs) Reset()

func (*JobDumpArgs) String added in v0.9.228 

func (x *JobDumpArgs) String() string

type JobDumpResp added in v0.9.228 

type JobDumpResp 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"`
	State        *ProcessState `protobuf:"bytes,4,opt,name=State,proto3" json:"State,omitempty"`
	DumpStats    *DumpStats    `protobuf:"bytes,5,opt,name=DumpStats,proto3" json:"DumpStats,omitempty"`
	// contains filtered or unexported fields
}

func (*JobDumpResp) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use JobDumpResp.ProtoReflect.Descriptor instead.

func (*JobDumpResp) GetCheckpointID added in v0.9.228 

func (x *JobDumpResp) GetCheckpointID() string

func (*JobDumpResp) GetDumpStats added in v0.9.228 

func (x *JobDumpResp) GetDumpStats() *DumpStats

func (*JobDumpResp) GetMessage added in v0.9.228 

func (x *JobDumpResp) GetMessage() string

func (*JobDumpResp) GetState added in v0.9.228 

func (x *JobDumpResp) GetState() *ProcessState

func (*JobDumpResp) GetUploadID added in v0.9.228 

func (x *JobDumpResp) GetUploadID() string

func (*JobDumpResp) ProtoMessage added in v0.9.228 

func (*JobDumpResp) ProtoMessage()

func (*JobDumpResp) ProtoReflect added in v0.9.228 

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

func (*JobDumpResp) Reset added in v0.9.228 

func (x *JobDumpResp) Reset()

func (*JobDumpResp) String added in v0.9.228 

func (x *JobDumpResp) String() string

type JobQueryArgs added in v0.9.228 

type JobQueryArgs 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 (*JobQueryArgs) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use JobQueryArgs.ProtoReflect.Descriptor instead.

func (*JobQueryArgs) GetJIDs added in v0.9.228 

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

func (*JobQueryArgs) GetPIDs added in v0.9.228 

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

func (*JobQueryArgs) ProtoMessage added in v0.9.228 

func (*JobQueryArgs) ProtoMessage()

func (*JobQueryArgs) ProtoReflect added in v0.9.228 

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

func (*JobQueryArgs) Reset added in v0.9.228 

func (x *JobQueryArgs) Reset()

func (*JobQueryArgs) String added in v0.9.228 

func (x *JobQueryArgs) String() string

type JobQueryResp added in v0.9.228 

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

func (*JobQueryResp) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use JobQueryResp.ProtoReflect.Descriptor instead.

func (*JobQueryResp) GetProcesses added in v0.9.228 

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

func (*JobQueryResp) ProtoMessage added in v0.9.228 

func (*JobQueryResp) ProtoMessage()

func (*JobQueryResp) ProtoReflect added in v0.9.228 

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

func (*JobQueryResp) Reset added in v0.9.228 

func (x *JobQueryResp) Reset()

func (*JobQueryResp) String added in v0.9.228 

func (x *JobQueryResp) String() string

type JobRestoreArgs added in v0.9.228 

type JobRestoreArgs struct {
	JID      string    `protobuf:"bytes,1,opt,name=JID,proto3" json:"JID,omitempty"`
	Type     CRType    `protobuf:"varint,2,opt,name=Type,proto3,enum=cedana.services.task.CRType" json:"Type,omitempty"`
	CriuOpts *CriuOpts `protobuf:"bytes,3,opt,name=CriuOpts,proto3" json:"CriuOpts,omitempty"`
	Stream   bool      `protobuf:"varint,4,opt,name=Stream,proto3" json:"Stream,omitempty"`
	RuncOpts *RuncOpts `protobuf:"bytes,5,opt,name=RuncOpts,proto3" json:"RuncOpts,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRestoreArgs) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use JobRestoreArgs.ProtoReflect.Descriptor instead.

func (*JobRestoreArgs) GetCriuOpts added in v0.9.228 

func (x *JobRestoreArgs) GetCriuOpts() *CriuOpts

func (*JobRestoreArgs) GetJID added in v0.9.228 

func (x *JobRestoreArgs) GetJID() string

func (*JobRestoreArgs) GetRuncOpts added in v0.9.228 

func (x *JobRestoreArgs) GetRuncOpts() *RuncOpts

func (*JobRestoreArgs) GetStream added in v0.9.228 

func (x *JobRestoreArgs) GetStream() bool

func (*JobRestoreArgs) GetType added in v0.9.228 

func (x *JobRestoreArgs) GetType() CRType

func (*JobRestoreArgs) ProtoMessage added in v0.9.228 

func (*JobRestoreArgs) ProtoMessage()

func (*JobRestoreArgs) ProtoReflect added in v0.9.228 

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

func (*JobRestoreArgs) Reset added in v0.9.228 

func (x *JobRestoreArgs) Reset()

func (*JobRestoreArgs) String added in v0.9.228 

func (x *JobRestoreArgs) String() string

type JobRestoreResp added in v0.9.228 

type JobRestoreResp struct {
	Message      string        `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	State        *ProcessState `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
	RestoreStats *RestoreStats `protobuf:"bytes,3,opt,name=RestoreStats,proto3" json:"RestoreStats,omitempty"`
	// contains filtered or unexported fields
}

func (*JobRestoreResp) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use JobRestoreResp.ProtoReflect.Descriptor instead.

func (*JobRestoreResp) GetMessage added in v0.9.228 

func (x *JobRestoreResp) GetMessage() string

func (*JobRestoreResp) GetRestoreStats added in v0.9.228 

func (x *JobRestoreResp) GetRestoreStats() *RestoreStats

func (*JobRestoreResp) GetState added in v0.9.228 

func (x *JobRestoreResp) GetState() *ProcessState

func (*JobRestoreResp) ProtoMessage added in v0.9.228 

func (*JobRestoreResp) ProtoMessage()

func (*JobRestoreResp) ProtoReflect added in v0.9.228 

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

func (*JobRestoreResp) Reset added in v0.9.228 

func (x *JobRestoreResp) Reset()

func (*JobRestoreResp) String added in v0.9.228 

func (x *JobRestoreResp) String() string

type JobState 

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 

func (JobState) Descriptor() protoreflect.EnumDescriptor

func (JobState) Enum 

func (x JobState) Enum() *JobState

func (JobState) EnumDescriptor deprecated 

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

Deprecated: Use JobState.Descriptor instead.

func (JobState) Number 

func (x JobState) Number() protoreflect.EnumNumber

func (JobState) String 

func (x JobState) String() string

func (JobState) Type 

func (JobState) Type() protoreflect.EnumType

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 

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 

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

func (*LogStreamingResp) Reset 

func (x *LogStreamingResp) Reset()

func (*LogStreamingResp) String 

func (x *LogStreamingResp) String() string

type ManageArgs added in v0.9.228 

type ManageArgs struct {
	PID    int32   `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	JID    string  `protobuf:"bytes,2,opt,name=JID,proto3" json:"JID,omitempty"`
	GPU    bool    `protobuf:"varint,3,opt,name=GPU,proto3" json:"GPU,omitempty"`
	Groups []int32 `protobuf:"varint,4,rep,packed,name=Groups,proto3" json:"Groups,omitempty"`
	UID    int32   `protobuf:"varint,5,opt,name=UID,proto3" json:"UID,omitempty"`
	GID    int32   `protobuf:"varint,6,opt,name=GID,proto3" json:"GID,omitempty"`
	// contains filtered or unexported fields
}

func (*ManageArgs) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use ManageArgs.ProtoReflect.Descriptor instead.

func (*ManageArgs) GetGID added in v0.9.228 

func (x *ManageArgs) GetGID() int32

func (*ManageArgs) GetGPU added in v0.9.228 

func (x *ManageArgs) GetGPU() bool

func (*ManageArgs) GetGroups added in v0.9.228 

func (x *ManageArgs) GetGroups() []int32

func (*ManageArgs) GetJID added in v0.9.228 

func (x *ManageArgs) GetJID() string

func (*ManageArgs) GetPID added in v0.9.228 

func (x *ManageArgs) GetPID() int32

func (*ManageArgs) GetUID added in v0.9.228 

func (x *ManageArgs) GetUID() int32

func (*ManageArgs) ProtoMessage added in v0.9.228 

func (*ManageArgs) ProtoMessage()

func (*ManageArgs) ProtoReflect added in v0.9.228 

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

func (*ManageArgs) Reset added in v0.9.228 

func (x *ManageArgs) Reset()

func (*ManageArgs) String added in v0.9.228 

func (x *ManageArgs) String() string

type ManageResp added in v0.9.228 

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

func (*ManageResp) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use ManageResp.ProtoReflect.Descriptor instead.

func (*ManageResp) GetMessage added in v0.9.228 

func (x *ManageResp) GetMessage() string

func (*ManageResp) GetState added in v0.9.228 

func (x *ManageResp) GetState() *ProcessState

func (*ManageResp) ProtoMessage added in v0.9.228 

func (*ManageResp) ProtoMessage()

func (*ManageResp) ProtoReflect added in v0.9.228 

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

func (*ManageResp) Reset added in v0.9.228 

func (x *ManageResp) Reset()

func (*ManageResp) String added in v0.9.228 

func (x *ManageResp) String() string

type MemoryInfo 

type MemoryInfo struct {
	Total     uint64 `protobuf:"varint,1,opt,name=Total,proto3" json:"Total,omitempty"`
	Available uint64 `protobuf:"varint,2,opt,name=Available,proto3" json:"Available,omitempty"`
	Used      uint64 `protobuf:"varint,3,opt,name=Used,proto3" json:"Used,omitempty"`
	// contains filtered or unexported fields
}

func (*MemoryInfo) Descriptor deprecated 

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

Deprecated: Use MemoryInfo.ProtoReflect.Descriptor instead.

func (*MemoryInfo) GetAvailable 

func (x *MemoryInfo) GetAvailable() uint64

func (*MemoryInfo) GetTotal 

func (x *MemoryInfo) GetTotal() uint64

func (*MemoryInfo) GetUsed 

func (x *MemoryInfo) GetUsed() uint64

func (*MemoryInfo) ProtoMessage 

func (*MemoryInfo) ProtoMessage()

func (*MemoryInfo) ProtoReflect 

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

func (*MemoryInfo) Reset 

func (x *MemoryInfo) Reset()

func (*MemoryInfo) String 

func (x *MemoryInfo) 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 

func (x *OpenFilesStat) GetMode() string

func (*OpenFilesStat) GetPath 

func (x *OpenFilesStat) GetPath() string

func (*OpenFilesStat) GetStream 

func (x *OpenFilesStat) GetStream() OpenFilesStat_StreamType

func (*OpenFilesStat) ProtoMessage 

func (*OpenFilesStat) ProtoMessage()

func (*OpenFilesStat) ProtoReflect 

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

func (*OpenFilesStat) Reset 

func (x *OpenFilesStat) Reset()

func (*OpenFilesStat) String 

func (x *OpenFilesStat) String() string

type OpenFilesStat_StreamType 

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 

func (OpenFilesStat_StreamType) Descriptor() protoreflect.EnumDescriptor

func (OpenFilesStat_StreamType) Enum 

func (x OpenFilesStat_StreamType) Enum() *OpenFilesStat_StreamType

func (OpenFilesStat_StreamType) EnumDescriptor deprecated 

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

Deprecated: Use OpenFilesStat_StreamType.Descriptor instead.

func (OpenFilesStat_StreamType) Number 

func (x OpenFilesStat_StreamType) Number() protoreflect.EnumNumber

func (OpenFilesStat_StreamType) String 

func (x OpenFilesStat_StreamType) String() string

func (OpenFilesStat_StreamType) Type 

func (OpenFilesStat_StreamType) Type() protoreflect.EnumType

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 

func (x *ProcessInfo) GetWorkingDir() string

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoReflect 

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"`
	ContainerID     string          `protobuf:"bytes,3,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	StartedAt       string          `protobuf:"bytes,4,opt,name=StartedAt,proto3" json:"StartedAt,omitempty"`
	ProcessInfo     *ProcessInfo    `protobuf:"bytes,5,opt,name=ProcessInfo,proto3" json:"ProcessInfo,omitempty"`
	CheckpointPath  string          `protobuf:"bytes,6,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	CheckpointState CheckpointState `` /* 126-byte string literal not displayed */
	JobState        JobState        `protobuf:"varint,8,opt,name=JobState,proto3,enum=cedana.services.task.JobState" json:"JobState,omitempty"`
	RemoteState     []*RemoteState  `protobuf:"bytes,9,rep,name=RemoteState,proto3" json:"RemoteState,omitempty"`
	JID             string          `protobuf:"bytes,10,opt,name=JID,proto3" json:"JID,omitempty"`
	HostInfo        *HostInfo       `protobuf:"bytes,11,opt,name=HostInfo,proto3" json:"HostInfo,omitempty"`
	CPUInfo         *CPUInfo        `protobuf:"bytes,12,opt,name=CPUInfo,proto3" json:"CPUInfo,omitempty"`
	MemoryInfo      *MemoryInfo     `protobuf:"bytes,13,opt,name=MemoryInfo,proto3" json:"MemoryInfo,omitempty"`
	UIDs            []int32         `protobuf:"varint,14,rep,packed,name=UIDs,proto3" json:"UIDs,omitempty"`
	GIDs            []int32         `protobuf:"varint,15,rep,packed,name=GIDs,proto3" json:"GIDs,omitempty"`
	Groups          []int32         `protobuf:"varint,16,rep,packed,name=Groups,proto3" json:"Groups,omitempty"`
	GPU             bool            `protobuf:"varint,17,opt,name=GPU,proto3" json:"GPU,omitempty"`
	ContainerRoot   string          `protobuf:"bytes,18,opt,name=ContainerRoot,proto3" json:"ContainerRoot,omitempty"`
	ContainerBundle string          `protobuf:"bytes,19,opt,name=ContainerBundle,proto3" json:"ContainerBundle,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessState) Descriptor deprecated 

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

Deprecated: Use ProcessState.ProtoReflect.Descriptor instead.

func (*ProcessState) GetCPUInfo 

func (x *ProcessState) GetCPUInfo() *CPUInfo

func (*ProcessState) GetCheckpointPath 

func (x *ProcessState) GetCheckpointPath() string

func (*ProcessState) GetCheckpointState 

func (x *ProcessState) GetCheckpointState() CheckpointState

func (*ProcessState) GetContainerBundle added in v0.9.228 

func (x *ProcessState) GetContainerBundle() string

func (*ProcessState) GetContainerID 

func (x *ProcessState) GetContainerID() string

func (*ProcessState) GetContainerRoot added in v0.9.228 

func (x *ProcessState) GetContainerRoot() string

func (*ProcessState) GetGIDs 

func (x *ProcessState) GetGIDs() []int32

func (*ProcessState) GetGPU added in v0.9.228 

func (x *ProcessState) GetGPU() bool

func (*ProcessState) GetGroups 

func (x *ProcessState) GetGroups() []int32

func (*ProcessState) GetHostInfo 

func (x *ProcessState) GetHostInfo() *HostInfo

func (*ProcessState) GetJID 

func (x *ProcessState) GetJID() string

func (*ProcessState) GetJobState 

func (x *ProcessState) GetJobState() JobState

func (*ProcessState) GetMemoryInfo 

func (x *ProcessState) GetMemoryInfo() *MemoryInfo

func (*ProcessState) GetPID 

func (x *ProcessState) GetPID() int32

func (*ProcessState) GetProcessInfo 

func (x *ProcessState) GetProcessInfo() *ProcessInfo

func (*ProcessState) GetRemoteState 

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

func (*ProcessState) GetStartedAt 

func (x *ProcessState) GetStartedAt() string

func (*ProcessState) GetTask 

func (x *ProcessState) GetTask() string

func (*ProcessState) GetUIDs 

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

func (*ProcessState) ProtoMessage 

func (*ProcessState) ProtoMessage()

func (*ProcessState) ProtoReflect 

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

func (*ProcessState) Reset 

func (x *ProcessState) Reset()

func (*ProcessState) String 

func (x *ProcessState) String() string

type ProcessStateStreamingArgs 

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

func (*ProcessStateStreamingArgs) Descriptor deprecated 

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

Deprecated: Use ProcessStateStreamingArgs.ProtoReflect.Descriptor instead.

func (*ProcessStateStreamingArgs) GetJID 

func (x *ProcessStateStreamingArgs) GetJID() string

func (*ProcessStateStreamingArgs) ProtoMessage 

func (*ProcessStateStreamingArgs) ProtoMessage()

func (*ProcessStateStreamingArgs) ProtoReflect 

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

func (*ProcessStateStreamingArgs) Reset 

func (x *ProcessStateStreamingArgs) Reset()

func (*ProcessStateStreamingArgs) String 

func (x *ProcessStateStreamingArgs) String() string

type QueueJobCheckpointRequest added in v0.9.222 

type QueueJobCheckpointRequest struct {
	ContainerName string  `protobuf:"bytes,1,opt,name=ContainerName,proto3" json:"ContainerName,omitempty"`
	Namespace     string  `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	PodName       string  `protobuf:"bytes,3,opt,name=PodName,proto3" json:"PodName,omitempty"`
	ImageName     string  `protobuf:"bytes,4,opt,name=ImageName,proto3" json:"ImageName,omitempty"`
	Id            string  `protobuf:"bytes,5,opt,name=Id,proto3" json:"Id,omitempty"`
	RuntimeRoot   *string `protobuf:"bytes,6,opt,name=RuntimeRoot,proto3,oneof" json:"RuntimeRoot,omitempty"`
	RuntimeSock   *string `protobuf:"bytes,7,opt,name=RuntimeSock,proto3,oneof" json:"RuntimeSock,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueJobCheckpointRequest) Descriptor deprecated added in v0.9.222 

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

Deprecated: Use QueueJobCheckpointRequest.ProtoReflect.Descriptor instead.

func (*QueueJobCheckpointRequest) GetContainerName added in v0.9.222 

func (x *QueueJobCheckpointRequest) GetContainerName() string

func (*QueueJobCheckpointRequest) GetId added in v0.9.222 

func (x *QueueJobCheckpointRequest) GetId() string

func (*QueueJobCheckpointRequest) GetImageName added in v0.9.222 

func (x *QueueJobCheckpointRequest) GetImageName() string

func (*QueueJobCheckpointRequest) GetNamespace added in v0.9.222 

func (x *QueueJobCheckpointRequest) GetNamespace() string

func (*QueueJobCheckpointRequest) GetPodName added in v0.9.222 

func (x *QueueJobCheckpointRequest) GetPodName() string

func (*QueueJobCheckpointRequest) GetRuntimeRoot added in v0.9.226 

func (x *QueueJobCheckpointRequest) GetRuntimeRoot() string

func (*QueueJobCheckpointRequest) GetRuntimeSock added in v0.9.226 

func (x *QueueJobCheckpointRequest) GetRuntimeSock() string

func (*QueueJobCheckpointRequest) ProtoMessage added in v0.9.222 

func (*QueueJobCheckpointRequest) ProtoMessage()

func (*QueueJobCheckpointRequest) ProtoReflect added in v0.9.222 

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

func (*QueueJobCheckpointRequest) Reset added in v0.9.222 

func (x *QueueJobCheckpointRequest) Reset()

func (*QueueJobCheckpointRequest) String added in v0.9.222 

func (x *QueueJobCheckpointRequest) String() string

type QueueJobID added in v0.9.222 

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

func (*QueueJobID) Descriptor deprecated added in v0.9.222 

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

Deprecated: Use QueueJobID.ProtoReflect.Descriptor instead.

func (*QueueJobID) GetJobID added in v0.9.222 

func (x *QueueJobID) GetJobID() string

func (*QueueJobID) ProtoMessage added in v0.9.222 

func (*QueueJobID) ProtoMessage()

func (*QueueJobID) ProtoReflect added in v0.9.222 

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

func (*QueueJobID) Reset added in v0.9.222 

func (x *QueueJobID) Reset()

func (*QueueJobID) String added in v0.9.222 

func (x *QueueJobID) String() string

type QueueJobRestoreRequest added in v0.9.222 

type QueueJobRestoreRequest struct {
	ContainerName string `protobuf:"bytes,1,opt,name=ContainerName,proto3" json:"ContainerName,omitempty"`
	Namespace     string `protobuf:"bytes,2,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	PodName       string `protobuf:"bytes,3,opt,name=PodName,proto3" json:"PodName,omitempty"`
	SourceName    string `protobuf:"bytes,4,opt,name=SourceName,proto3" json:"SourceName,omitempty"`
	Id            string `protobuf:"bytes,5,opt,name=Id,proto3" json:"Id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueJobRestoreRequest) Descriptor deprecated added in v0.9.222 

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

Deprecated: Use QueueJobRestoreRequest.ProtoReflect.Descriptor instead.

func (*QueueJobRestoreRequest) GetContainerName added in v0.9.222 

func (x *QueueJobRestoreRequest) GetContainerName() string

func (*QueueJobRestoreRequest) GetId added in v0.9.222 

func (x *QueueJobRestoreRequest) GetId() string

func (*QueueJobRestoreRequest) GetNamespace added in v0.9.222 

func (x *QueueJobRestoreRequest) GetNamespace() string

func (*QueueJobRestoreRequest) GetPodName added in v0.9.222 

func (x *QueueJobRestoreRequest) GetPodName() string

func (*QueueJobRestoreRequest) GetSourceName added in v0.9.222 

func (x *QueueJobRestoreRequest) GetSourceName() string

func (*QueueJobRestoreRequest) ProtoMessage added in v0.9.222 

func (*QueueJobRestoreRequest) ProtoMessage()

func (*QueueJobRestoreRequest) ProtoReflect added in v0.9.222 

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

func (*QueueJobRestoreRequest) Reset added in v0.9.222 

func (x *QueueJobRestoreRequest) Reset()

func (*QueueJobRestoreRequest) String added in v0.9.222 

func (x *QueueJobRestoreRequest) String() string

type QueueJobStatus added in v0.9.222 

type QueueJobStatus struct {
	Status QueueJobStatusEnum `protobuf:"varint,1,opt,name=Status,proto3,enum=cedana.services.task.QueueJobStatusEnum" json:"Status,omitempty"`
	// contains filtered or unexported fields
}

func (*QueueJobStatus) Descriptor deprecated added in v0.9.222 

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

Deprecated: Use QueueJobStatus.ProtoReflect.Descriptor instead.

func (*QueueJobStatus) GetStatus added in v0.9.222 

func (x *QueueJobStatus) GetStatus() QueueJobStatusEnum

func (*QueueJobStatus) ProtoMessage added in v0.9.222 

func (*QueueJobStatus) ProtoMessage()

func (*QueueJobStatus) ProtoReflect added in v0.9.222 

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

func (*QueueJobStatus) Reset added in v0.9.222 

func (x *QueueJobStatus) Reset()

func (*QueueJobStatus) String added in v0.9.222 

func (x *QueueJobStatus) String() string

type QueueJobStatusEnum added in v0.9.222 

type QueueJobStatusEnum int32
const (
	QueueJobStatusEnum_StatusUnvalidated QueueJobStatusEnum = 0
	QueueJobStatusEnum_StatusWaiting     QueueJobStatusEnum = 1
	QueueJobStatusEnum_StatusActive      QueueJobStatusEnum = 2
	QueueJobStatusEnum_StatusFail        QueueJobStatusEnum = 3
	QueueJobStatusEnum_StatusSuccess     QueueJobStatusEnum = 4
	QueueJobStatusEnum_StatusInvalid     QueueJobStatusEnum = 5
	QueueJobStatusEnum_StatusEnded       QueueJobStatusEnum = 6
	QueueJobStatusEnum_StatusUnknown     QueueJobStatusEnum = 7
)

func (QueueJobStatusEnum) Descriptor added in v0.9.222 

func (QueueJobStatusEnum) Descriptor() protoreflect.EnumDescriptor

func (QueueJobStatusEnum) Enum added in v0.9.222 

func (x QueueJobStatusEnum) Enum() *QueueJobStatusEnum

func (QueueJobStatusEnum) EnumDescriptor deprecated added in v0.9.222 

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

Deprecated: Use QueueJobStatusEnum.Descriptor instead.

func (QueueJobStatusEnum) Number added in v0.9.222 

func (x QueueJobStatusEnum) Number() protoreflect.EnumNumber

func (QueueJobStatusEnum) String added in v0.9.222 

func (x QueueJobStatusEnum) String() string

func (QueueJobStatusEnum) Type added in v0.9.222 

func (QueueJobStatusEnum) Type() protoreflect.EnumType

type RemoteState 

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 

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

Deprecated: Use RemoteState.ProtoReflect.Descriptor instead.

func (*RemoteState) GetCheckpointID 

func (x *RemoteState) GetCheckpointID() string

func (*RemoteState) GetTimestamp 

func (x *RemoteState) GetTimestamp() int64

func (*RemoteState) GetUploadID 

func (x *RemoteState) GetUploadID() string

func (*RemoteState) ProtoMessage 

func (*RemoteState) ProtoMessage()

func (*RemoteState) ProtoReflect 

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

func (*RemoteState) Reset 

func (x *RemoteState) Reset()

func (*RemoteState) String 

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"`
	Stream         bool      `protobuf:"varint,5,opt,name=Stream,proto3" json:"Stream,omitempty"`
	CriuOpts       *CriuOpts `protobuf:"bytes,6,opt,name=CriuOpts,proto3" json:"CriuOpts,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreArgs) Descriptor deprecated 

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

Deprecated: Use RestoreArgs.ProtoReflect.Descriptor instead.

func (*RestoreArgs) GetCheckpointID 

func (x *RestoreArgs) GetCheckpointID() string

func (*RestoreArgs) GetCheckpointPath 

func (x *RestoreArgs) GetCheckpointPath() string

func (*RestoreArgs) GetCriuOpts added in v0.9.221 

func (x *RestoreArgs) GetCriuOpts() *CriuOpts

func (*RestoreArgs) GetJID 

func (x *RestoreArgs) GetJID() string

func (*RestoreArgs) GetStream 

func (x *RestoreArgs) GetStream() bool

func (*RestoreArgs) GetType 

func (x *RestoreArgs) GetType() CRType

func (*RestoreArgs) ProtoMessage 

func (*RestoreArgs) ProtoMessage()

func (*RestoreArgs) ProtoReflect 

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"`
	State        *ProcessState `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
	RestoreStats *RestoreStats `protobuf:"bytes,3,opt,name=RestoreStats,proto3" json:"RestoreStats,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) GetRestoreStats 

func (x *RestoreResp) GetRestoreStats() *RestoreStats

func (*RestoreResp) GetState 

func (x *RestoreResp) GetState() *ProcessState

func (*RestoreResp) ProtoMessage 

func (*RestoreResp) ProtoMessage()

func (*RestoreResp) ProtoReflect 

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

func (*RestoreResp) Reset 

func (x *RestoreResp) Reset()

func (*RestoreResp) String 

func (x *RestoreResp) String() string

type RestoreStats 

type RestoreStats struct {
	DumpType            DumpType             `protobuf:"varint,1,opt,name=DumpType,proto3,enum=cedana.services.task.DumpType" json:"DumpType,omitempty"`
	ContainerRuntime    ContainerRuntime     `` /* 129-byte string literal not displayed */
	PrepareDuration     int64                `protobuf:"varint,3,opt,name=PrepareDuration,proto3" json:"PrepareDuration,omitempty"`
	CRIUDuration        int64                `protobuf:"varint,4,opt,name=CRIUDuration,proto3" json:"CRIUDuration,omitempty"`
	GPUDuration         int64                `protobuf:"varint,5,opt,name=GPUDuration,proto3" json:"GPUDuration,omitempty"`
	DownloadDuration    int64                `protobuf:"varint,6,opt,name=DownloadDuration,proto3" json:"DownloadDuration,omitempty"`
	CheckpointFileStats *CheckpointFileStats `protobuf:"bytes,7,opt,name=CheckpointFileStats,proto3" json:"CheckpointFileStats,omitempty"`
	GPURestoreStats     *gpu.GPURestoreStats `protobuf:"bytes,8,opt,name=GPURestoreStats,proto3" json:"GPURestoreStats,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreStats) Descriptor deprecated 

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

Deprecated: Use RestoreStats.ProtoReflect.Descriptor instead.

func (*RestoreStats) GetCRIUDuration 

func (x *RestoreStats) GetCRIUDuration() int64

func (*RestoreStats) GetCheckpointFileStats 

func (x *RestoreStats) GetCheckpointFileStats() *CheckpointFileStats

func (*RestoreStats) GetContainerRuntime 

func (x *RestoreStats) GetContainerRuntime() ContainerRuntime

func (*RestoreStats) GetDownloadDuration 

func (x *RestoreStats) GetDownloadDuration() int64

func (*RestoreStats) GetDumpType 

func (x *RestoreStats) GetDumpType() DumpType

func (*RestoreStats) GetGPUDuration 

func (x *RestoreStats) GetGPUDuration() int64

func (*RestoreStats) GetGPURestoreStats 

func (x *RestoreStats) GetGPURestoreStats() *gpu.GPURestoreStats

func (*RestoreStats) GetPrepareDuration 

func (x *RestoreStats) GetPrepareDuration() int64

func (*RestoreStats) ProtoMessage 

func (*RestoreStats) ProtoMessage()

func (*RestoreStats) ProtoReflect 

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

func (*RestoreStats) Reset 

func (x *RestoreStats) Reset()

func (*RestoreStats) String 

func (x *RestoreStats) String() string

type RuncContainer 

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"`
	ContainerName string `protobuf:"bytes,3,opt,name=ContainerName,proto3" json:"ContainerName,omitempty"`
	ImageName     string `protobuf:"bytes,4,opt,name=ImageName,proto3" json:"ImageName,omitempty"`
	SandboxId     string `protobuf:"bytes,5,opt,name=SandboxId,proto3" json:"SandboxId,omitempty"`
	SandboxName   string `protobuf:"bytes,6,opt,name=SandboxName,proto3" json:"SandboxName,omitempty"`
	SandboxUid    string `protobuf:"bytes,7,opt,name=SandboxUid,proto3" json:"SandboxUid,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncContainer) Descriptor deprecated 

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

Deprecated: Use RuncContainer.ProtoReflect.Descriptor instead.

func (*RuncContainer) GetBundlePath 

func (x *RuncContainer) GetBundlePath() string

func (*RuncContainer) GetContainerName 

func (x *RuncContainer) GetContainerName() string

func (*RuncContainer) GetID 

func (x *RuncContainer) GetID() string

func (*RuncContainer) GetImageName 

func (x *RuncContainer) GetImageName() string

func (*RuncContainer) GetSandboxId 

func (x *RuncContainer) GetSandboxId() string

func (*RuncContainer) GetSandboxName 

func (x *RuncContainer) GetSandboxName() string

func (*RuncContainer) GetSandboxUid 

func (x *RuncContainer) GetSandboxUid() string

func (*RuncContainer) ProtoMessage 

func (*RuncContainer) ProtoMessage()

func (*RuncContainer) ProtoReflect 

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

func (*RuncContainer) Reset 

func (x *RuncContainer) Reset()

func (*RuncContainer) String 

func (x *RuncContainer) String() string

type RuncDumpArgs 

type RuncDumpArgs struct {
	Root        string    `protobuf:"bytes,1,opt,name=Root,proto3" json:"Root,omitempty"`
	Dir         string    `protobuf:"bytes,2,opt,name=Dir,proto3" json:"Dir,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"`
	// contains filtered or unexported fields
}

func (*RuncDumpArgs) Descriptor deprecated 

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

Deprecated: Use RuncDumpArgs.ProtoReflect.Descriptor instead.

func (*RuncDumpArgs) GetContainerID 

func (x *RuncDumpArgs) GetContainerID() string

func (*RuncDumpArgs) GetCriuOpts 

func (x *RuncDumpArgs) GetCriuOpts() *CriuOpts

func (*RuncDumpArgs) GetDir added in v0.9.228 

func (x *RuncDumpArgs) GetDir() string

func (*RuncDumpArgs) GetRoot 

func (x *RuncDumpArgs) GetRoot() string

func (*RuncDumpArgs) GetType 

func (x *RuncDumpArgs) GetType() CRType

func (*RuncDumpArgs) ProtoMessage 

func (*RuncDumpArgs) ProtoMessage()

func (*RuncDumpArgs) ProtoReflect 

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"`
	State        *ProcessState `protobuf:"bytes,4,opt,name=State,proto3" json:"State,omitempty"`
	DumpStats    *DumpStats    `protobuf:"bytes,5,opt,name=DumpStats,proto3" json:"DumpStats,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncDumpResp) Descriptor deprecated 

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

Deprecated: Use RuncDumpResp.ProtoReflect.Descriptor instead.

func (*RuncDumpResp) GetCheckpointID 

func (x *RuncDumpResp) GetCheckpointID() string

func (*RuncDumpResp) GetDumpStats added in v0.9.221 

func (x *RuncDumpResp) GetDumpStats() *DumpStats

func (*RuncDumpResp) GetMessage 

func (x *RuncDumpResp) GetMessage() string

func (*RuncDumpResp) GetState 

func (x *RuncDumpResp) GetState() *ProcessState

func (*RuncDumpResp) GetUploadID 

func (x *RuncDumpResp) GetUploadID() string

func (*RuncDumpResp) ProtoMessage 

func (*RuncDumpResp) ProtoMessage()

func (*RuncDumpResp) ProtoReflect 

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

func (*RuncDumpResp) Reset 

func (x *RuncDumpResp) Reset()

func (*RuncDumpResp) String 

func (x *RuncDumpResp) String() string

type RuncGetPausePidArgs 

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

func (*RuncGetPausePidArgs) Descriptor deprecated 

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

Deprecated: Use RuncGetPausePidArgs.ProtoReflect.Descriptor instead.

func (*RuncGetPausePidArgs) GetBundlePath 

func (x *RuncGetPausePidArgs) GetBundlePath() string

func (*RuncGetPausePidArgs) ProtoMessage 

func (*RuncGetPausePidArgs) ProtoMessage()

func (*RuncGetPausePidArgs) ProtoReflect 

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

func (*RuncGetPausePidArgs) Reset 

func (x *RuncGetPausePidArgs) Reset()

func (*RuncGetPausePidArgs) String 

func (x *RuncGetPausePidArgs) String() string

type RuncGetPausePidResp 

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

func (*RuncGetPausePidResp) Descriptor deprecated 

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

Deprecated: Use RuncGetPausePidResp.ProtoReflect.Descriptor instead.

func (*RuncGetPausePidResp) GetPausePid 

func (x *RuncGetPausePidResp) GetPausePid() int64

func (*RuncGetPausePidResp) ProtoMessage 

func (*RuncGetPausePidResp) ProtoMessage()

func (*RuncGetPausePidResp) ProtoReflect 

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

func (*RuncGetPausePidResp) Reset 

func (x *RuncGetPausePidResp) Reset()

func (*RuncGetPausePidResp) String 

func (x *RuncGetPausePidResp) String() string

type RuncManageArgs added in v0.9.228 

type RuncManageArgs struct {
	ContainerID string  `protobuf:"bytes,1,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	Root        string  `protobuf:"bytes,2,opt,name=Root,proto3" json:"Root,omitempty"`
	GPU         bool    `protobuf:"varint,3,opt,name=GPU,proto3" json:"GPU,omitempty"`
	Groups      []int32 `protobuf:"varint,4,rep,packed,name=Groups,proto3" json:"Groups,omitempty"`
	UID         int32   `protobuf:"varint,5,opt,name=UID,proto3" json:"UID,omitempty"`
	GID         int32   `protobuf:"varint,6,opt,name=GID,proto3" json:"GID,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncManageArgs) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use RuncManageArgs.ProtoReflect.Descriptor instead.

func (*RuncManageArgs) GetContainerID added in v0.9.228 

func (x *RuncManageArgs) GetContainerID() string

func (*RuncManageArgs) GetGID added in v0.9.228 

func (x *RuncManageArgs) GetGID() int32

func (*RuncManageArgs) GetGPU added in v0.9.228 

func (x *RuncManageArgs) GetGPU() bool

func (*RuncManageArgs) GetGroups added in v0.9.228 

func (x *RuncManageArgs) GetGroups() []int32

func (*RuncManageArgs) GetRoot added in v0.9.228 

func (x *RuncManageArgs) GetRoot() string

func (*RuncManageArgs) GetUID added in v0.9.228 

func (x *RuncManageArgs) GetUID() int32

func (*RuncManageArgs) ProtoMessage added in v0.9.228 

func (*RuncManageArgs) ProtoMessage()

func (*RuncManageArgs) ProtoReflect added in v0.9.228 

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

func (*RuncManageArgs) Reset added in v0.9.228 

func (x *RuncManageArgs) Reset()

func (*RuncManageArgs) String added in v0.9.228 

func (x *RuncManageArgs) String() string

type RuncManageResp added in v0.9.228 

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

func (*RuncManageResp) Descriptor deprecated added in v0.9.228 

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

Deprecated: Use RuncManageResp.ProtoReflect.Descriptor instead.

func (*RuncManageResp) GetMessage added in v0.9.228 

func (x *RuncManageResp) GetMessage() string

func (*RuncManageResp) GetState added in v0.9.228 

func (x *RuncManageResp) GetState() *ProcessState

func (*RuncManageResp) ProtoMessage added in v0.9.228 

func (*RuncManageResp) ProtoMessage()

func (*RuncManageResp) ProtoReflect added in v0.9.228 

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

func (*RuncManageResp) Reset added in v0.9.228 

func (x *RuncManageResp) Reset()

func (*RuncManageResp) String added in v0.9.228 

func (x *RuncManageResp) 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"`
	Detach          bool   `protobuf:"varint,12,opt,name=Detach,proto3" json:"Detach,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 

func (x *RuncOpts) GetContainerID() string

func (*RuncOpts) GetDetach 

func (x *RuncOpts) GetDetach() bool

func (*RuncOpts) GetKeep 

func (x *RuncOpts) GetKeep() bool

func (*RuncOpts) GetNetPid 

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 

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

func (*RuncOpts) Reset 

func (x *RuncOpts) Reset()

func (*RuncOpts) String 

func (x *RuncOpts) String() string

type RuncQueryArgs 

type RuncQueryArgs 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"`
	ContainerNames []string `protobuf:"bytes,3,rep,name=ContainerNames,proto3" json:"ContainerNames,omitempty"`
	SandboxNames   []string `protobuf:"bytes,4,rep,name=SandboxNames,proto3" json:"SandboxNames,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncQueryArgs) Descriptor deprecated 

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

Deprecated: Use RuncQueryArgs.ProtoReflect.Descriptor instead.

func (*RuncQueryArgs) GetContainerNames 

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

func (*RuncQueryArgs) GetNamespace 

func (x *RuncQueryArgs) GetNamespace() string

func (*RuncQueryArgs) GetRoot 

func (x *RuncQueryArgs) GetRoot() string

func (*RuncQueryArgs) GetSandboxNames 

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

func (*RuncQueryArgs) ProtoMessage 

func (*RuncQueryArgs) ProtoMessage()

func (*RuncQueryArgs) ProtoReflect 

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

func (*RuncQueryArgs) Reset 

func (x *RuncQueryArgs) Reset()

func (*RuncQueryArgs) String 

func (x *RuncQueryArgs) String() string

type RuncQueryResp 

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

func (*RuncQueryResp) Descriptor deprecated 

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

Deprecated: Use RuncQueryResp.ProtoReflect.Descriptor instead.

func (*RuncQueryResp) GetContainers 

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

func (*RuncQueryResp) ProtoMessage 

func (*RuncQueryResp) ProtoMessage()

func (*RuncQueryResp) ProtoReflect 

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

func (*RuncQueryResp) Reset 

func (x *RuncQueryResp) Reset()

func (*RuncQueryResp) String 

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"`
	Opts         *RuncOpts `protobuf:"bytes,3,opt,name=Opts,proto3" json:"Opts,omitempty"`
	Type         CRType    `protobuf:"varint,4,opt,name=Type,proto3,enum=cedana.services.task.CRType" json:"Type,omitempty"`
	CheckpointID string    `protobuf:"bytes,5,opt,name=CheckpointID,proto3" json:"CheckpointID,omitempty"`
	CriuOpts     *CriuOpts `protobuf:"bytes,6,opt,name=CriuOpts,proto3" json:"CriuOpts,omitempty"`
	// contains filtered or unexported fields
}

func (*RuncRestoreArgs) Descriptor deprecated 

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

Deprecated: Use RuncRestoreArgs.ProtoReflect.Descriptor instead.

func (*RuncRestoreArgs) GetCheckpointID 

func (x *RuncRestoreArgs) GetCheckpointID() string

func (*RuncRestoreArgs) GetContainerID 

func (x *RuncRestoreArgs) GetContainerID() string

func (*RuncRestoreArgs) GetCriuOpts added in v0.9.221 

func (x *RuncRestoreArgs) GetCriuOpts() *CriuOpts

func (*RuncRestoreArgs) GetImagePath 

func (x *RuncRestoreArgs) GetImagePath() string

func (*RuncRestoreArgs) GetOpts 

func (x *RuncRestoreArgs) GetOpts() *RuncOpts

func (*RuncRestoreArgs) GetType 

func (x *RuncRestoreArgs) GetType() CRType

func (*RuncRestoreArgs) ProtoMessage 

func (*RuncRestoreArgs) ProtoMessage()

func (*RuncRestoreArgs) ProtoReflect 

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"`
	State        *ProcessState `protobuf:"bytes,2,opt,name=State,proto3" json:"State,omitempty"`
	RestoreStats *RestoreStats `protobuf:"bytes,3,opt,name=RestoreStats,proto3" json:"RestoreStats,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) GetRestoreStats added in v0.9.221 

func (x *RuncRestoreResp) GetRestoreStats() *RestoreStats

func (*RuncRestoreResp) GetState 

func (x *RuncRestoreResp) GetState() *ProcessState

func (*RuncRestoreResp) ProtoMessage 

func (*RuncRestoreResp) ProtoMessage()

func (*RuncRestoreResp) ProtoReflect 

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

func (*RuncRestoreResp) Reset 

func (x *RuncRestoreResp) Reset()

func (*RuncRestoreResp) String 

func (x *RuncRestoreResp) String() string

type StartArgs 

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           int32    `protobuf:"varint,6,opt,name=UID,proto3" json:"UID,omitempty"`
	GID           int32    `protobuf:"varint,7,opt,name=GID,proto3" json:"GID,omitempty"`
	GPU           bool     `protobuf:"varint,8,opt,name=GPU,proto3" json:"GPU,omitempty"`
	Groups        []int32  `protobuf:"varint,9,rep,packed,name=Groups,proto3" json:"Groups,omitempty"`
	// contains filtered or unexported fields
}

func (*StartArgs) Descriptor deprecated 

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

Deprecated: Use StartArgs.ProtoReflect.Descriptor instead.

func (*StartArgs) GetEnv 

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

func (*StartArgs) GetGID 

func (x *StartArgs) GetGID() int32

func (*StartArgs) GetGPU 

func (x *StartArgs) GetGPU() bool

func (*StartArgs) GetGroups 

func (x *StartArgs) GetGroups() []int32

func (*StartArgs) GetJID 

func (x *StartArgs) GetJID() string

func (*StartArgs) GetLogOutputFile 

func (x *StartArgs) GetLogOutputFile() string

func (*StartArgs) GetTask 

func (x *StartArgs) GetTask() string

func (*StartArgs) GetUID 

func (x *StartArgs) GetUID() int32

func (*StartArgs) GetWorkingDir 

func (x *StartArgs) GetWorkingDir() string

func (*StartArgs) ProtoMessage 

func (*StartArgs) ProtoMessage()

func (*StartArgs) ProtoReflect 

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

func (*StartArgs) Reset 

func (x *StartArgs) Reset()

func (*StartArgs) String 

func (x *StartArgs) String() string

type StartResp 

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 

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

Deprecated: Use StartResp.ProtoReflect.Descriptor instead.

func (*StartResp) GetJID 

func (x *StartResp) GetJID() string

func (*StartResp) GetMessage 

func (x *StartResp) GetMessage() string

func (*StartResp) GetPID 

func (x *StartResp) GetPID() int32

func (*StartResp) ProtoMessage 

func (*StartResp) ProtoMessage()

func (*StartResp) ProtoReflect 

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

func (*StartResp) Reset 

func (x *StartResp) Reset()

func (*StartResp) String 

func (x *StartResp) String() string

type TaskServiceClient 

type TaskServiceClient interface {
	// Managed Job
	JobDump(ctx context.Context, in *JobDumpArgs, opts ...grpc.CallOption) (*JobDumpResp, error)
	JobRestore(ctx context.Context, in *JobRestoreArgs, opts ...grpc.CallOption) (*JobRestoreResp, error)
	JobRestoreAttach(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AttachArgs, AttachResp], error)
	JobQuery(ctx context.Context, in *JobQueryArgs, opts ...grpc.CallOption) (*JobQueryResp, error)
	// Process
	Start(ctx context.Context, in *StartArgs, opts ...grpc.CallOption) (*StartResp, error)
	StartAttach(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AttachArgs, AttachResp], error)
	Dump(ctx context.Context, in *DumpArgs, opts ...grpc.CallOption) (*DumpResp, error)
	Restore(ctx context.Context, in *RestoreArgs, opts ...grpc.CallOption) (*RestoreResp, error)
	RestoreAttach(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AttachArgs, AttachResp], error)
	Manage(ctx context.Context, in *ManageArgs, opts ...grpc.CallOption) (*ManageResp, 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)
	ContainerdRootfsDump(ctx context.Context, in *ContainerdRootfsDumpArgs, opts ...grpc.CallOption) (*ContainerdRootfsDumpResp, error)
	ContainerdRootfsRestore(ctx context.Context, in *ContainerdRootfsRestoreArgs, opts ...grpc.CallOption) (*ContainerdRootfsRestoreResp, 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)
	RuncManage(ctx context.Context, in *RuncManageArgs, opts ...grpc.CallOption) (*RuncManageResp, error)
	// CRIO
	CRIORootfsDump(ctx context.Context, in *CRIORootfsDumpArgs, opts ...grpc.CallOption) (*CRIORootfsDumpResp, error)
	CRIOImagePush(ctx context.Context, in *CRIOImagePushArgs, opts ...grpc.CallOption) (*CRIOImagePushResp, error)
	// Streaming
	LogStreaming(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[LogStreamingResp, LogStreamingArgs], error)
	ProcessStateStreaming(ctx context.Context, in *ProcessStateStreamingArgs, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ProcessState], error)
	// Health
	DetailedHealthCheck(ctx context.Context, in *DetailedHealthCheckRequest, opts ...grpc.CallOption) (*DetailedHealthCheckResponse, error)
	// Kata
	KataDump(ctx context.Context, in *DumpArgs, opts ...grpc.CallOption) (*DumpResp, error)
	KataRestore(ctx context.Context, in *RestoreArgs, opts ...grpc.CallOption) (*RestoreResp, error)
	// Config
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	// JobQueue
	QueueCheckpoint(ctx context.Context, in *QueueJobCheckpointRequest, opts ...grpc.CallOption) (*wrappers.BoolValue, error)
	QueueRestore(ctx context.Context, in *QueueJobRestoreRequest, opts ...grpc.CallOption) (*wrappers.BoolValue, error)
	JobStatus(ctx context.Context, in *QueueJobID, opts ...grpc.CallOption) (*QueueJobStatus, error)
	// ASR
	GetContainerInfo(ctx context.Context, in *ContainerInfoRequest, opts ...grpc.CallOption) (*ContainersInfo, 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.

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	// Managed Job
	JobDump(context.Context, *JobDumpArgs) (*JobDumpResp, error)
	JobRestore(context.Context, *JobRestoreArgs) (*JobRestoreResp, error)
	JobRestoreAttach(grpc.BidiStreamingServer[AttachArgs, AttachResp]) error
	JobQuery(context.Context, *JobQueryArgs) (*JobQueryResp, error)
	// Process
	Start(context.Context, *StartArgs) (*StartResp, error)
	StartAttach(grpc.BidiStreamingServer[AttachArgs, AttachResp]) error
	Dump(context.Context, *DumpArgs) (*DumpResp, error)
	Restore(context.Context, *RestoreArgs) (*RestoreResp, error)
	RestoreAttach(grpc.BidiStreamingServer[AttachArgs, AttachResp]) error
	Manage(context.Context, *ManageArgs) (*ManageResp, error)
	// Containerd
	ContainerdDump(context.Context, *ContainerdDumpArgs) (*ContainerdDumpResp, error)
	ContainerdRestore(context.Context, *ContainerdRestoreArgs) (*ContainerdRestoreResp, error)
	ContainerdQuery(context.Context, *ContainerdQueryArgs) (*ContainerdQueryResp, error)
	ContainerdRootfsDump(context.Context, *ContainerdRootfsDumpArgs) (*ContainerdRootfsDumpResp, error)
	ContainerdRootfsRestore(context.Context, *ContainerdRootfsRestoreArgs) (*ContainerdRootfsRestoreResp, 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)
	RuncManage(context.Context, *RuncManageArgs) (*RuncManageResp, error)
	// CRIO
	CRIORootfsDump(context.Context, *CRIORootfsDumpArgs) (*CRIORootfsDumpResp, error)
	CRIOImagePush(context.Context, *CRIOImagePushArgs) (*CRIOImagePushResp, error)
	// Streaming
	LogStreaming(grpc.BidiStreamingServer[LogStreamingResp, LogStreamingArgs]) error
	ProcessStateStreaming(*ProcessStateStreamingArgs, grpc.ServerStreamingServer[ProcessState]) error
	// Health
	DetailedHealthCheck(context.Context, *DetailedHealthCheckRequest) (*DetailedHealthCheckResponse, error)
	// Kata
	KataDump(context.Context, *DumpArgs) (*DumpResp, error)
	KataRestore(context.Context, *RestoreArgs) (*RestoreResp, error)
	// Config
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	// JobQueue
	QueueCheckpoint(context.Context, *QueueJobCheckpointRequest) (*wrappers.BoolValue, error)
	QueueRestore(context.Context, *QueueJobRestoreRequest) (*wrappers.BoolValue, error)
	JobStatus(context.Context, *QueueJobID) (*QueueJobStatus, error)
	// ASR
	GetContainerInfo(context.Context, *ContainerInfoRequest) (*ContainersInfo, error)
	// contains filtered or unexported methods
}

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

type TaskService_JobRestoreAttachClient added in v0.9.228 

type TaskService_JobRestoreAttachClient = grpc.BidiStreamingClient[AttachArgs, AttachResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_JobRestoreAttachServer added in v0.9.228 

type TaskService_JobRestoreAttachServer = grpc.BidiStreamingServer[AttachArgs, AttachResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_LogStreamingClient 

type TaskService_LogStreamingClient = grpc.BidiStreamingClient[LogStreamingResp, LogStreamingArgs]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_LogStreamingServer 

type TaskService_LogStreamingServer = grpc.BidiStreamingServer[LogStreamingResp, LogStreamingArgs]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_ProcessStateStreamingClient 

type TaskService_ProcessStateStreamingClient = grpc.ServerStreamingClient[ProcessState]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_ProcessStateStreamingServer 

type TaskService_ProcessStateStreamingServer = grpc.ServerStreamingServer[ProcessState]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_RestoreAttachClient 

type TaskService_RestoreAttachClient = grpc.BidiStreamingClient[AttachArgs, AttachResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_RestoreAttachServer 

type TaskService_RestoreAttachServer = grpc.BidiStreamingServer[AttachArgs, AttachResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_StartAttachClient 

type TaskService_StartAttachClient = grpc.BidiStreamingClient[AttachArgs, AttachResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type TaskService_StartAttachServer 

type TaskService_StartAttachServer = grpc.BidiStreamingServer[AttachArgs, AttachResp]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct{}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTaskServiceServer) CRIOImagePush 

func (UnimplementedTaskServiceServer) CRIOImagePush(context.Context, *CRIOImagePushArgs) (*CRIOImagePushResp, error)

func (UnimplementedTaskServiceServer) CRIORootfsDump 

func (UnimplementedTaskServiceServer) CRIORootfsDump(context.Context, *CRIORootfsDumpArgs) (*CRIORootfsDumpResp, error)

func (UnimplementedTaskServiceServer) ContainerdDump 

func (UnimplementedTaskServiceServer) ContainerdDump(context.Context, *ContainerdDumpArgs) (*ContainerdDumpResp, error)

func (UnimplementedTaskServiceServer) ContainerdQuery 

func (UnimplementedTaskServiceServer) ContainerdQuery(context.Context, *ContainerdQueryArgs) (*ContainerdQueryResp, error)

func (UnimplementedTaskServiceServer) ContainerdRestore 

func (UnimplementedTaskServiceServer) ContainerdRestore(context.Context, *ContainerdRestoreArgs) (*ContainerdRestoreResp, error)

func (UnimplementedTaskServiceServer) ContainerdRootfsDump 

func (UnimplementedTaskServiceServer) ContainerdRootfsDump(context.Context, *ContainerdRootfsDumpArgs) (*ContainerdRootfsDumpResp, error)

func (UnimplementedTaskServiceServer) ContainerdRootfsRestore 

func (UnimplementedTaskServiceServer) ContainerdRootfsRestore(context.Context, *ContainerdRootfsRestoreArgs) (*ContainerdRootfsRestoreResp, error)

func (UnimplementedTaskServiceServer) DetailedHealthCheck 

func (UnimplementedTaskServiceServer) DetailedHealthCheck(context.Context, *DetailedHealthCheckRequest) (*DetailedHealthCheckResponse, error)

func (UnimplementedTaskServiceServer) Dump 

func (UnimplementedTaskServiceServer) Dump(context.Context, *DumpArgs) (*DumpResp, error)

func (UnimplementedTaskServiceServer) GetConfig 

func (UnimplementedTaskServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)

func (UnimplementedTaskServiceServer) GetContainerInfo added in v0.9.222 

func (UnimplementedTaskServiceServer) GetContainerInfo(context.Context, *ContainerInfoRequest) (*ContainersInfo, error)

func (UnimplementedTaskServiceServer) JobDump added in v0.9.228 

func (UnimplementedTaskServiceServer) JobDump(context.Context, *JobDumpArgs) (*JobDumpResp, error)

func (UnimplementedTaskServiceServer) JobQuery added in v0.9.228 

func (UnimplementedTaskServiceServer) JobQuery(context.Context, *JobQueryArgs) (*JobQueryResp, error)

func (UnimplementedTaskServiceServer) JobRestore added in v0.9.228 

func (UnimplementedTaskServiceServer) JobRestore(context.Context, *JobRestoreArgs) (*JobRestoreResp, error)

func (UnimplementedTaskServiceServer) JobRestoreAttach added in v0.9.228 

func (UnimplementedTaskServiceServer) JobRestoreAttach(grpc.BidiStreamingServer[AttachArgs, AttachResp]) error

func (UnimplementedTaskServiceServer) JobStatus added in v0.9.222 

func (UnimplementedTaskServiceServer) JobStatus(context.Context, *QueueJobID) (*QueueJobStatus, error)

func (UnimplementedTaskServiceServer) KataDump 

func (UnimplementedTaskServiceServer) KataDump(context.Context, *DumpArgs) (*DumpResp, error)

func (UnimplementedTaskServiceServer) KataRestore 

func (UnimplementedTaskServiceServer) KataRestore(context.Context, *RestoreArgs) (*RestoreResp, error)

func (UnimplementedTaskServiceServer) LogStreaming 

func (UnimplementedTaskServiceServer) LogStreaming(grpc.BidiStreamingServer[LogStreamingResp, LogStreamingArgs]) error

func (UnimplementedTaskServiceServer) Manage added in v0.9.228 

func (UnimplementedTaskServiceServer) Manage(context.Context, *ManageArgs) (*ManageResp, error)

func (UnimplementedTaskServiceServer) ProcessStateStreaming 

func (UnimplementedTaskServiceServer) ProcessStateStreaming(*ProcessStateStreamingArgs, grpc.ServerStreamingServer[ProcessState]) error

func (UnimplementedTaskServiceServer) QueueCheckpoint added in v0.9.222 

func (UnimplementedTaskServiceServer) QueueCheckpoint(context.Context, *QueueJobCheckpointRequest) (*wrappers.BoolValue, error)

func (UnimplementedTaskServiceServer) QueueRestore added in v0.9.222 

func (UnimplementedTaskServiceServer) QueueRestore(context.Context, *QueueJobRestoreRequest) (*wrappers.BoolValue, error)

func (UnimplementedTaskServiceServer) Restore 

func (UnimplementedTaskServiceServer) Restore(context.Context, *RestoreArgs) (*RestoreResp, error)

func (UnimplementedTaskServiceServer) RestoreAttach 

func (UnimplementedTaskServiceServer) RestoreAttach(grpc.BidiStreamingServer[AttachArgs, AttachResp]) error

func (UnimplementedTaskServiceServer) RuncDump 

func (UnimplementedTaskServiceServer) RuncDump(context.Context, *RuncDumpArgs) (*RuncDumpResp, error)

func (UnimplementedTaskServiceServer) RuncGetPausePid 

func (UnimplementedTaskServiceServer) RuncGetPausePid(context.Context, *RuncGetPausePidArgs) (*RuncGetPausePidResp, error)

func (UnimplementedTaskServiceServer) RuncManage added in v0.9.228 

func (UnimplementedTaskServiceServer) RuncManage(context.Context, *RuncManageArgs) (*RuncManageResp, error)

func (UnimplementedTaskServiceServer) RuncQuery 

func (UnimplementedTaskServiceServer) RuncQuery(context.Context, *RuncQueryArgs) (*RuncQueryResp, error)

func (UnimplementedTaskServiceServer) RuncRestore 

func (UnimplementedTaskServiceServer) RuncRestore(context.Context, *RuncRestoreArgs) (*RuncRestoreResp, error)

func (UnimplementedTaskServiceServer) Start 

func (UnimplementedTaskServiceServer) Start(context.Context, *StartArgs) (*StartResp, error)

func (UnimplementedTaskServiceServer) StartAttach 

func (UnimplementedTaskServiceServer) StartAttach(grpc.BidiStreamingServer[AttachArgs, AttachResp]) error

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.

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.