task

package
v0.9.219 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2024 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

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 (
	OpenFilesStat_StreamType_name = map[int32]string{
		0: "STDIN",
		1: "STDOUT",
		2: "STDERR",
		3: "NONE",
	}
	OpenFilesStat_StreamType_value = map[string]int32{
		"STDIN":  0,
		"STDOUT": 1,
		"STDERR": 2,
		"NONE":   3,
	}
)

Enum value maps for OpenFilesStat_StreamType.

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

Enum value maps for CheckpointReason_CheckpointReasonEnum.

View Source
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedana.services.task.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _TaskService_Start_Handler,
		},
		{
			MethodName: "Dump",
			Handler:    _TaskService_Dump_Handler,
		},
		{
			MethodName: "Restore",
			Handler:    _TaskService_Restore_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _TaskService_Query_Handler,
		},
		{
			MethodName: "ContainerdDump",
			Handler:    _TaskService_ContainerdDump_Handler,
		},
		{
			MethodName: "ContainerdRestore",
			Handler:    _TaskService_ContainerdRestore_Handler,
		},
		{
			MethodName: "ContainerdQuery",
			Handler:    _TaskService_ContainerdQuery_Handler,
		},
		{
			MethodName: "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: "CRIORootfsDump",
			Handler:    _TaskService_CRIORootfsDump_Handler,
		},
		{
			MethodName: "CRIOImagePush",
			Handler:    _TaskService_CRIOImagePush_Handler,
		},
		{
			MethodName: "DetailedHealthCheck",
			Handler:    _TaskService_DetailedHealthCheck_Handler,
		},
		{
			MethodName: "GetConfig",
			Handler:    _TaskService_GetConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StartAttach",
			Handler:       _TaskService_StartAttach_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 added in v0.8.1

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

func (*Addr) Reset

func (x *Addr) Reset()

func (*Addr) String

func (x *Addr) String() string

type CPUInfo added in v0.9.204

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 added in v0.9.204

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

Deprecated: Use CPUInfo.ProtoReflect.Descriptor instead.

func (*CPUInfo) GetCPU added in v0.9.204

func (x *CPUInfo) GetCPU() int32

func (*CPUInfo) GetCount added in v0.9.204

func (x *CPUInfo) GetCount() int32

func (*CPUInfo) GetFamily added in v0.9.204

func (x *CPUInfo) GetFamily() string

func (*CPUInfo) GetPhysicalID added in v0.9.204

func (x *CPUInfo) GetPhysicalID() string

func (*CPUInfo) GetVendorID added in v0.9.204

func (x *CPUInfo) GetVendorID() string

func (*CPUInfo) ProtoMessage added in v0.9.204

func (*CPUInfo) ProtoMessage()

func (*CPUInfo) ProtoReflect added in v0.9.204

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

func (*CPUInfo) Reset added in v0.9.204

func (x *CPUInfo) Reset()

func (*CPUInfo) String added in v0.9.204

func (x *CPUInfo) String() string

type CRIOImagePushArgs added in v0.9.208

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

func (*CRIOImagePushArgs) Descriptor deprecated added in v0.9.208

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

Deprecated: Use CRIOImagePushArgs.ProtoReflect.Descriptor instead.

func (*CRIOImagePushArgs) GetContainerStorage added in v0.9.211

func (x *CRIOImagePushArgs) GetContainerStorage() string

func (*CRIOImagePushArgs) GetNewImageRef added in v0.9.208

func (x *CRIOImagePushArgs) GetNewImageRef() string

func (*CRIOImagePushArgs) GetOriginalImageRef added in v0.9.208

func (x *CRIOImagePushArgs) GetOriginalImageRef() string

func (*CRIOImagePushArgs) GetRegistryAuthToken added in v0.9.215

func (x *CRIOImagePushArgs) GetRegistryAuthToken() string

func (*CRIOImagePushArgs) GetRootfsDiffPath added in v0.9.208

func (x *CRIOImagePushArgs) GetRootfsDiffPath() string

func (*CRIOImagePushArgs) ProtoMessage added in v0.9.208

func (*CRIOImagePushArgs) ProtoMessage()

func (*CRIOImagePushArgs) ProtoReflect added in v0.9.208

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

func (*CRIOImagePushArgs) Reset added in v0.9.208

func (x *CRIOImagePushArgs) Reset()

func (*CRIOImagePushArgs) String added in v0.9.208

func (x *CRIOImagePushArgs) String() string

type CRIOImagePushResp added in v0.9.208

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

func (*CRIOImagePushResp) Descriptor deprecated added in v0.9.208

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

Deprecated: Use CRIOImagePushResp.ProtoReflect.Descriptor instead.

func (*CRIOImagePushResp) GetMessage added in v0.9.208

func (x *CRIOImagePushResp) GetMessage() string

func (*CRIOImagePushResp) ProtoMessage added in v0.9.208

func (*CRIOImagePushResp) ProtoMessage()

func (*CRIOImagePushResp) ProtoReflect added in v0.9.208

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

func (*CRIOImagePushResp) Reset added in v0.9.208

func (x *CRIOImagePushResp) Reset()

func (*CRIOImagePushResp) String added in v0.9.208

func (x *CRIOImagePushResp) String() string

type CRIORootfsDumpArgs added in v0.9.208

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

func (*CRIORootfsDumpArgs) Descriptor deprecated added in v0.9.208

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

Deprecated: Use CRIORootfsDumpArgs.ProtoReflect.Descriptor instead.

func (*CRIORootfsDumpArgs) GetContainerID added in v0.9.208

func (x *CRIORootfsDumpArgs) GetContainerID() string

func (*CRIORootfsDumpArgs) GetContainerStorage added in v0.9.208

func (x *CRIORootfsDumpArgs) GetContainerStorage() string

func (*CRIORootfsDumpArgs) GetDest added in v0.9.208

func (x *CRIORootfsDumpArgs) GetDest() string

func (*CRIORootfsDumpArgs) GetRegistryAuthToken added in v0.9.215

func (x *CRIORootfsDumpArgs) GetRegistryAuthToken() string

func (*CRIORootfsDumpArgs) ProtoMessage added in v0.9.208

func (*CRIORootfsDumpArgs) ProtoMessage()

func (*CRIORootfsDumpArgs) ProtoReflect added in v0.9.208

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

func (*CRIORootfsDumpArgs) Reset added in v0.9.208

func (x *CRIORootfsDumpArgs) Reset()

func (*CRIORootfsDumpArgs) String added in v0.9.208

func (x *CRIORootfsDumpArgs) String() string

type CRIORootfsDumpResp added in v0.9.208

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

func (*CRIORootfsDumpResp) Descriptor deprecated added in v0.9.208

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

Deprecated: Use CRIORootfsDumpResp.ProtoReflect.Descriptor instead.

func (*CRIORootfsDumpResp) GetDest added in v0.9.208

func (x *CRIORootfsDumpResp) GetDest() string

func (*CRIORootfsDumpResp) ProtoMessage added in v0.9.208

func (*CRIORootfsDumpResp) ProtoMessage()

func (*CRIORootfsDumpResp) ProtoReflect added in v0.9.208

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

func (*CRIORootfsDumpResp) Reset added in v0.9.208

func (x *CRIORootfsDumpResp) Reset()

func (*CRIORootfsDumpResp) String added in v0.9.208

func (x *CRIORootfsDumpResp) String() string

type CRType added in v0.9.104

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

func (CRType) Descriptor added in v0.9.104

func (CRType) Descriptor() protoreflect.EnumDescriptor

func (CRType) Enum added in v0.9.104

func (x CRType) Enum() *CRType

func (CRType) EnumDescriptor deprecated added in v0.9.104

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

Deprecated: Use CRType.Descriptor instead.

func (CRType) Number added in v0.9.104

func (x CRType) Number() protoreflect.EnumNumber

func (CRType) String added in v0.9.104

func (x CRType) String() string

func (CRType) Type added in v0.9.104

func (CRType) Type() protoreflect.EnumType

type CheckpointFileStats added in v0.9.215

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 added in v0.9.215

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

Deprecated: Use CheckpointFileStats.ProtoReflect.Descriptor instead.

func (*CheckpointFileStats) GetDuration added in v0.9.215

func (x *CheckpointFileStats) GetDuration() int64

func (*CheckpointFileStats) GetSize added in v0.9.215

func (x *CheckpointFileStats) GetSize() int64

func (*CheckpointFileStats) ProtoMessage added in v0.9.215

func (*CheckpointFileStats) ProtoMessage()

func (*CheckpointFileStats) ProtoReflect added in v0.9.215

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

func (*CheckpointFileStats) Reset added in v0.9.215

func (x *CheckpointFileStats) Reset()

func (*CheckpointFileStats) String added in v0.9.215

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 (*CheckpointReason) ProtoMessage

func (*CheckpointReason) ProtoMessage()

func (*CheckpointReason) ProtoReflect added in v0.8.1

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

func (*CheckpointReason) Reset

func (x *CheckpointReason) Reset()

func (*CheckpointReason) String

func (x *CheckpointReason) String() string

type CheckpointReason_CheckpointReasonEnum

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

func (CheckpointReason_CheckpointReasonEnum) Descriptor added in v0.8.1

func (CheckpointReason_CheckpointReasonEnum) Enum added in v0.8.1

func (CheckpointReason_CheckpointReasonEnum) EnumDescriptor deprecated

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

Deprecated: Use CheckpointReason_CheckpointReasonEnum.Descriptor instead.

func (CheckpointReason_CheckpointReasonEnum) Number added in v0.8.1

func (CheckpointReason_CheckpointReasonEnum) String

func (CheckpointReason_CheckpointReasonEnum) Type added in v0.8.1

type CheckpointState

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

func (CheckpointState) Descriptor added in v0.8.1

func (CheckpointState) Enum added in v0.8.1

func (x CheckpointState) Enum() *CheckpointState

func (CheckpointState) EnumDescriptor deprecated

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

Deprecated: Use CheckpointState.Descriptor instead.

func (CheckpointState) Number added in v0.8.1

func (CheckpointState) String

func (x CheckpointState) String() string

func (CheckpointState) Type added in v0.8.1

type ConnectionStat

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

func (*ConnectionStat) Descriptor deprecated

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

Deprecated: Use ConnectionStat.ProtoReflect.Descriptor instead.

func (*ConnectionStat) GetFamily

func (x *ConnectionStat) GetFamily() uint32

func (*ConnectionStat) GetFd

func (x *ConnectionStat) GetFd() uint32

func (*ConnectionStat) GetLaddr

func (x *ConnectionStat) GetLaddr() *Addr

func (*ConnectionStat) GetPID

func (x *ConnectionStat) GetPID() int32

func (*ConnectionStat) GetRaddr

func (x *ConnectionStat) GetRaddr() *Addr

func (*ConnectionStat) GetStatus

func (x *ConnectionStat) GetStatus() string

func (*ConnectionStat) GetType

func (x *ConnectionStat) GetType() uint32

func (*ConnectionStat) GetUIDs added in v0.9.104

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

func (*ConnectionStat) ProtoMessage

func (*ConnectionStat) ProtoMessage()

func (*ConnectionStat) ProtoReflect added in v0.8.1

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

func (*ConnectionStat) Reset

func (x *ConnectionStat) Reset()

func (*ConnectionStat) String

func (x *ConnectionStat) String() string

type ContainerRuntime added in v0.9.215

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

func (ContainerRuntime) Descriptor added in v0.9.215

func (ContainerRuntime) Enum added in v0.9.215

func (ContainerRuntime) EnumDescriptor deprecated added in v0.9.215

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

Deprecated: Use ContainerRuntime.Descriptor instead.

func (ContainerRuntime) Number added in v0.9.215

func (ContainerRuntime) String added in v0.9.215

func (x ContainerRuntime) String() string

func (ContainerRuntime) Type added in v0.9.215

type ContainerdContainer added in v0.9.104

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

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

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

Deprecated: Use ContainerdContainer.ProtoReflect.Descriptor instead.

func (*ContainerdContainer) GetContainerName added in v0.9.104

func (x *ContainerdContainer) GetContainerName() string

func (*ContainerdContainer) GetImageName added in v0.9.104

func (x *ContainerdContainer) GetImageName() string

func (*ContainerdContainer) GetSandboxId added in v0.9.104

func (x *ContainerdContainer) GetSandboxId() string

func (*ContainerdContainer) GetSandboxName added in v0.9.104

func (x *ContainerdContainer) GetSandboxName() string

func (*ContainerdContainer) GetSandboxNamespace added in v0.9.104

func (x *ContainerdContainer) GetSandboxNamespace() string

func (*ContainerdContainer) GetSandboxUid added in v0.9.104

func (x *ContainerdContainer) GetSandboxUid() string

func (*ContainerdContainer) ProtoMessage added in v0.9.104

func (*ContainerdContainer) ProtoMessage()

func (*ContainerdContainer) ProtoReflect added in v0.9.104

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

func (*ContainerdContainer) Reset added in v0.9.104

func (x *ContainerdContainer) Reset()

func (*ContainerdContainer) String added in v0.9.104

func (x *ContainerdContainer) String() string

type ContainerdDumpArgs added in v0.9.104

type ContainerdDumpArgs struct {
	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 added in v0.9.104

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

Deprecated: Use ContainerdDumpArgs.ProtoReflect.Descriptor instead.

func (*ContainerdDumpArgs) GetContainerdRootfsDumpArgs added in v0.9.216

func (x *ContainerdDumpArgs) GetContainerdRootfsDumpArgs() *ContainerdRootfsDumpArgs

func (*ContainerdDumpArgs) GetRuncDumpArgs added in v0.9.216

func (x *ContainerdDumpArgs) GetRuncDumpArgs() *RuncDumpArgs

func (*ContainerdDumpArgs) ProtoMessage added in v0.9.104

func (*ContainerdDumpArgs) ProtoMessage()

func (*ContainerdDumpArgs) ProtoReflect added in v0.9.104

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

func (*ContainerdDumpArgs) Reset added in v0.9.104

func (x *ContainerdDumpArgs) Reset()

func (*ContainerdDumpArgs) String added in v0.9.104

func (x *ContainerdDumpArgs) String() string

type ContainerdDumpResp added in v0.9.104

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

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

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

Deprecated: Use ContainerdDumpResp.ProtoReflect.Descriptor instead.

func (*ContainerdDumpResp) GetCheckpointPath added in v0.9.104

func (x *ContainerdDumpResp) GetCheckpointPath() string

func (*ContainerdDumpResp) GetMessage added in v0.9.104

func (x *ContainerdDumpResp) GetMessage() string

func (*ContainerdDumpResp) ProtoMessage added in v0.9.104

func (*ContainerdDumpResp) ProtoMessage()

func (*ContainerdDumpResp) ProtoReflect added in v0.9.104

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

func (*ContainerdDumpResp) Reset added in v0.9.104

func (x *ContainerdDumpResp) Reset()

func (*ContainerdDumpResp) String added in v0.9.104

func (x *ContainerdDumpResp) String() string

type ContainerdQueryArgs added in v0.9.104

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

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

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

Deprecated: Use ContainerdQueryArgs.ProtoReflect.Descriptor instead.

func (*ContainerdQueryArgs) GetNamespace added in v0.9.104

func (x *ContainerdQueryArgs) GetNamespace() string

func (*ContainerdQueryArgs) GetRoot added in v0.9.104

func (x *ContainerdQueryArgs) GetRoot() string

func (*ContainerdQueryArgs) ProtoMessage added in v0.9.104

func (*ContainerdQueryArgs) ProtoMessage()

func (*ContainerdQueryArgs) ProtoReflect added in v0.9.104

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

func (*ContainerdQueryArgs) Reset added in v0.9.104

func (x *ContainerdQueryArgs) Reset()

func (*ContainerdQueryArgs) String added in v0.9.104

func (x *ContainerdQueryArgs) String() string

type ContainerdQueryResp added in v0.9.104

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

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

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

Deprecated: Use ContainerdQueryResp.ProtoReflect.Descriptor instead.

func (*ContainerdQueryResp) GetContainers added in v0.9.104

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

func (*ContainerdQueryResp) ProtoMessage added in v0.9.104

func (*ContainerdQueryResp) ProtoMessage()

func (*ContainerdQueryResp) ProtoReflect added in v0.9.104

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

func (*ContainerdQueryResp) Reset added in v0.9.104

func (x *ContainerdQueryResp) Reset()

func (*ContainerdQueryResp) String added in v0.9.104

func (x *ContainerdQueryResp) String() string

type ContainerdRestoreArgs added in v0.9.104

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

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

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

Deprecated: Use ContainerdRestoreArgs.ProtoReflect.Descriptor instead.

func (*ContainerdRestoreArgs) GetContainerID added in v0.9.104

func (x *ContainerdRestoreArgs) GetContainerID() string

func (*ContainerdRestoreArgs) GetImgPath added in v0.9.104

func (x *ContainerdRestoreArgs) GetImgPath() string

func (*ContainerdRestoreArgs) ProtoMessage added in v0.9.104

func (*ContainerdRestoreArgs) ProtoMessage()

func (*ContainerdRestoreArgs) ProtoReflect added in v0.9.104

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

func (*ContainerdRestoreArgs) Reset added in v0.9.104

func (x *ContainerdRestoreArgs) Reset()

func (*ContainerdRestoreArgs) String added in v0.9.104

func (x *ContainerdRestoreArgs) String() string

type ContainerdRestoreResp added in v0.9.104

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

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

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

Deprecated: Use ContainerdRestoreResp.ProtoReflect.Descriptor instead.

func (*ContainerdRestoreResp) GetMessage added in v0.9.104

func (x *ContainerdRestoreResp) GetMessage() string

func (*ContainerdRestoreResp) ProtoMessage added in v0.9.104

func (*ContainerdRestoreResp) ProtoMessage()

func (*ContainerdRestoreResp) ProtoReflect added in v0.9.104

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

func (*ContainerdRestoreResp) Reset added in v0.9.104

func (x *ContainerdRestoreResp) Reset()

func (*ContainerdRestoreResp) String added in v0.9.104

func (x *ContainerdRestoreResp) String() string

type ContainerdRootfsDumpArgs added in v0.9.202

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 added in v0.9.202

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

Deprecated: Use ContainerdRootfsDumpArgs.ProtoReflect.Descriptor instead.

func (*ContainerdRootfsDumpArgs) GetAddress added in v0.9.202

func (x *ContainerdRootfsDumpArgs) GetAddress() string

func (*ContainerdRootfsDumpArgs) GetContainerID added in v0.9.202

func (x *ContainerdRootfsDumpArgs) GetContainerID() string

func (*ContainerdRootfsDumpArgs) GetImageRef added in v0.9.202

func (x *ContainerdRootfsDumpArgs) GetImageRef() string

func (*ContainerdRootfsDumpArgs) GetNamespace added in v0.9.202

func (x *ContainerdRootfsDumpArgs) GetNamespace() string

func (*ContainerdRootfsDumpArgs) ProtoMessage added in v0.9.202

func (*ContainerdRootfsDumpArgs) ProtoMessage()

func (*ContainerdRootfsDumpArgs) ProtoReflect added in v0.9.202

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

func (*ContainerdRootfsDumpArgs) Reset added in v0.9.202

func (x *ContainerdRootfsDumpArgs) Reset()

func (*ContainerdRootfsDumpArgs) String added in v0.9.202

func (x *ContainerdRootfsDumpArgs) String() string

type ContainerdRootfsDumpResp added in v0.9.202

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

func (*ContainerdRootfsDumpResp) Descriptor deprecated added in v0.9.202

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

Deprecated: Use ContainerdRootfsDumpResp.ProtoReflect.Descriptor instead.

func (*ContainerdRootfsDumpResp) GetImageRef added in v0.9.202

func (x *ContainerdRootfsDumpResp) GetImageRef() string

func (*ContainerdRootfsDumpResp) ProtoMessage added in v0.9.202

func (*ContainerdRootfsDumpResp) ProtoMessage()

func (*ContainerdRootfsDumpResp) ProtoReflect added in v0.9.202

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

func (*ContainerdRootfsDumpResp) Reset added in v0.9.202

func (x *ContainerdRootfsDumpResp) Reset()

func (*ContainerdRootfsDumpResp) String added in v0.9.202

func (x *ContainerdRootfsDumpResp) String() string

type ContainerdRootfsRestoreArgs added in v0.9.202

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 added in v0.9.202

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

Deprecated: Use ContainerdRootfsRestoreArgs.ProtoReflect.Descriptor instead.

func (*ContainerdRootfsRestoreArgs) GetAddress added in v0.9.202

func (x *ContainerdRootfsRestoreArgs) GetAddress() string

func (*ContainerdRootfsRestoreArgs) GetContainerID added in v0.9.202

func (x *ContainerdRootfsRestoreArgs) GetContainerID() string

func (*ContainerdRootfsRestoreArgs) GetImageRef added in v0.9.202

func (x *ContainerdRootfsRestoreArgs) GetImageRef() string

func (*ContainerdRootfsRestoreArgs) GetNamespace added in v0.9.202

func (x *ContainerdRootfsRestoreArgs) GetNamespace() string

func (*ContainerdRootfsRestoreArgs) ProtoMessage added in v0.9.202

func (*ContainerdRootfsRestoreArgs) ProtoMessage()

func (*ContainerdRootfsRestoreArgs) ProtoReflect added in v0.9.202

func (*ContainerdRootfsRestoreArgs) Reset added in v0.9.202

func (x *ContainerdRootfsRestoreArgs) Reset()

func (*ContainerdRootfsRestoreArgs) String added in v0.9.202

func (x *ContainerdRootfsRestoreArgs) String() string

type ContainerdRootfsRestoreResp added in v0.9.202

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

func (*ContainerdRootfsRestoreResp) Descriptor deprecated added in v0.9.202

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

Deprecated: Use ContainerdRootfsRestoreResp.ProtoReflect.Descriptor instead.

func (*ContainerdRootfsRestoreResp) GetImageRef added in v0.9.202

func (x *ContainerdRootfsRestoreResp) GetImageRef() string

func (*ContainerdRootfsRestoreResp) ProtoMessage added in v0.9.202

func (*ContainerdRootfsRestoreResp) ProtoMessage()

func (*ContainerdRootfsRestoreResp) ProtoReflect added in v0.9.202

func (*ContainerdRootfsRestoreResp) Reset added in v0.9.202

func (x *ContainerdRootfsRestoreResp) Reset()

func (*ContainerdRootfsRestoreResp) String added in v0.9.202

func (x *ContainerdRootfsRestoreResp) String() string

type CriuOpts

type CriuOpts struct {
	ImagesDirectory         string   `protobuf:"bytes,1,opt,name=ImagesDirectory,proto3" json:"ImagesDirectory,omitempty"`
	WorkDirectory           string   `protobuf:"bytes,2,opt,name=WorkDirectory,proto3" json:"WorkDirectory,omitempty"`
	ParentImage             string   `protobuf:"bytes,3,opt,name=ParentImage,proto3" json:"ParentImage,omitempty"`
	LeaveRunning            bool     `protobuf:"varint,4,opt,name=LeaveRunning,proto3" json:"LeaveRunning,omitempty"`
	TcpEstablished          bool     `protobuf:"varint,5,opt,name=TcpEstablished,proto3" json:"TcpEstablished,omitempty"`
	ExternalUnixConnections bool     `protobuf:"varint,6,opt,name=ExternalUnixConnections,proto3" json:"ExternalUnixConnections,omitempty"`
	ShellJob                bool     `protobuf:"varint,7,opt,name=ShellJob,proto3" json:"ShellJob,omitempty"`
	FileLocks               bool     `protobuf:"varint,8,opt,name=FileLocks,proto3" json:"FileLocks,omitempty"`
	PreDump                 bool     `protobuf:"varint,9,opt,name=PreDump,proto3" json:"PreDump,omitempty"`
	EmptyNs                 int32    `protobuf:"varint,12,opt,name=EmptyNs,proto3" json:"EmptyNs,omitempty"`
	AutoDedup               bool     `protobuf:"varint,13,opt,name=AutoDedup,proto3" json:"AutoDedup,omitempty"`
	LazyPages               bool     `protobuf:"varint,14,opt,name=LazyPages,proto3" json:"LazyPages,omitempty"`
	StatusFd                int32    `protobuf:"varint,15,opt,name=StatusFd,proto3" json:"StatusFd,omitempty"`
	LsmProfile              string   `protobuf:"bytes,16,opt,name=LsmProfile,proto3" json:"LsmProfile,omitempty"`
	LsmMountContext         string   `protobuf:"bytes,17,opt,name=LsmMountContext,proto3" json:"LsmMountContext,omitempty"`
	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 added in v0.9.202

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

func (x *CriuOpts) GetTcpEstablished() bool

func (*CriuOpts) GetWorkDirectory

func (x *CriuOpts) GetWorkDirectory() string

func (*CriuOpts) ProtoMessage

func (*CriuOpts) ProtoMessage()

func (*CriuOpts) ProtoReflect added in v0.8.1

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

func (*CriuOpts) Reset

func (x *CriuOpts) Reset()

func (*CriuOpts) String

func (x *CriuOpts) String() string

type DetailedHealthCheckRequest added in v0.9.211

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 added in v0.9.211

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

Deprecated: Use DetailedHealthCheckRequest.ProtoReflect.Descriptor instead.

func (*DetailedHealthCheckRequest) GetGID added in v0.9.212

func (x *DetailedHealthCheckRequest) GetGID() int32

func (*DetailedHealthCheckRequest) GetGroups added in v0.9.212

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

func (*DetailedHealthCheckRequest) GetUID added in v0.9.212

func (x *DetailedHealthCheckRequest) GetUID() int32

func (*DetailedHealthCheckRequest) ProtoMessage added in v0.9.211

func (*DetailedHealthCheckRequest) ProtoMessage()

func (*DetailedHealthCheckRequest) ProtoReflect added in v0.9.211

func (*DetailedHealthCheckRequest) Reset added in v0.9.211

func (x *DetailedHealthCheckRequest) Reset()

func (*DetailedHealthCheckRequest) String added in v0.9.211

func (x *DetailedHealthCheckRequest) String() string

type DetailedHealthCheckResponse added in v0.9.211

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 added in v0.9.211

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

Deprecated: Use DetailedHealthCheckResponse.ProtoReflect.Descriptor instead.

func (*DetailedHealthCheckResponse) GetHealthCheckStats added in v0.9.211

func (x *DetailedHealthCheckResponse) GetHealthCheckStats() *HealthCheckStats

func (*DetailedHealthCheckResponse) GetUnhealthyReasons added in v0.9.211

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

func (*DetailedHealthCheckResponse) ProtoMessage added in v0.9.211

func (*DetailedHealthCheckResponse) ProtoMessage()

func (*DetailedHealthCheckResponse) ProtoReflect added in v0.9.211

func (*DetailedHealthCheckResponse) Reset added in v0.9.211

func (x *DetailedHealthCheckResponse) Reset()

func (*DetailedHealthCheckResponse) String added in v0.9.211

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

func (*DumpArgs) Descriptor deprecated

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

Deprecated: Use DumpArgs.ProtoReflect.Descriptor instead.

func (*DumpArgs) GetDir

func (x *DumpArgs) GetDir() string

func (*DumpArgs) GetGPU added in v0.9.200

func (x *DumpArgs) GetGPU() bool

func (*DumpArgs) GetJID added in v0.9.104

func (x *DumpArgs) GetJID() string

func (*DumpArgs) GetPID

func (x *DumpArgs) GetPID() int32

func (*DumpArgs) GetTcpEstablished added in v0.9.211

func (x *DumpArgs) GetTcpEstablished() bool

func (*DumpArgs) GetType

func (x *DumpArgs) GetType() CRType

func (*DumpArgs) ProtoMessage

func (*DumpArgs) ProtoMessage()

func (*DumpArgs) ProtoReflect added in v0.8.1

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

func (*DumpArgs) Reset

func (x *DumpArgs) Reset()

func (*DumpArgs) String

func (x *DumpArgs) String() string

type DumpResp

type DumpResp struct {
	Message      string        `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	CheckpointID string        `protobuf:"bytes,2,opt,name=CheckpointID,proto3" json:"CheckpointID,omitempty"`
	UploadID     string        `protobuf:"bytes,3,opt,name=UploadID,proto3" json:"UploadID,omitempty"`
	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 added in v0.8.9

func (x *DumpResp) GetCheckpointID() string

func (*DumpResp) GetDumpStats added in v0.9.215

func (x *DumpResp) GetDumpStats() *DumpStats

func (*DumpResp) GetMessage

func (x *DumpResp) GetMessage() string

func (*DumpResp) GetState added in v0.9.204

func (x *DumpResp) GetState() *ProcessState

func (*DumpResp) GetUploadID added in v0.8.9

func (x *DumpResp) GetUploadID() string

func (*DumpResp) ProtoMessage

func (*DumpResp) ProtoMessage()

func (*DumpResp) ProtoReflect added in v0.8.1

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

func (*DumpResp) Reset

func (x *DumpResp) Reset()

func (*DumpResp) String

func (x *DumpResp) String() string

type DumpStats added in v0.9.215

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 added in v0.9.215

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

Deprecated: Use DumpStats.ProtoReflect.Descriptor instead.

func (*DumpStats) GetCRIUDuration added in v0.9.215

func (x *DumpStats) GetCRIUDuration() int64

func (*DumpStats) GetCheckpointFileStats added in v0.9.215

func (x *DumpStats) GetCheckpointFileStats() *CheckpointFileStats

func (*DumpStats) GetContainerRuntime added in v0.9.215

func (x *DumpStats) GetContainerRuntime() ContainerRuntime

func (*DumpStats) GetDumpType added in v0.9.215

func (x *DumpStats) GetDumpType() DumpType

func (*DumpStats) GetGPUDuration added in v0.9.215

func (x *DumpStats) GetGPUDuration() int64

func (*DumpStats) GetKubernetes added in v0.9.215

func (x *DumpStats) GetKubernetes() bool

func (*DumpStats) GetPrepareDuration added in v0.9.215

func (x *DumpStats) GetPrepareDuration() int64

func (*DumpStats) GetUploadDuration added in v0.9.215

func (x *DumpStats) GetUploadDuration() int64

func (*DumpStats) ProtoMessage added in v0.9.215

func (*DumpStats) ProtoMessage()

func (*DumpStats) ProtoReflect added in v0.9.215

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

func (*DumpStats) Reset added in v0.9.215

func (x *DumpStats) Reset()

func (*DumpStats) String added in v0.9.215

func (x *DumpStats) String() string

type DumpType added in v0.9.215

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

func (DumpType) Descriptor added in v0.9.215

func (DumpType) Descriptor() protoreflect.EnumDescriptor

func (DumpType) Enum added in v0.9.215

func (x DumpType) Enum() *DumpType

func (DumpType) EnumDescriptor deprecated added in v0.9.215

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

Deprecated: Use DumpType.Descriptor instead.

func (DumpType) Number added in v0.9.215

func (x DumpType) Number() protoreflect.EnumNumber

func (DumpType) String added in v0.9.215

func (x DumpType) String() string

func (DumpType) Type added in v0.9.215

type GetConfigRequest added in v0.9.215

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

func (*GetConfigRequest) Descriptor deprecated added in v0.9.215

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

Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConfigRequest) ProtoMessage added in v0.9.215

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) ProtoReflect added in v0.9.215

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

func (*GetConfigRequest) Reset added in v0.9.215

func (x *GetConfigRequest) Reset()

func (*GetConfigRequest) String added in v0.9.215

func (x *GetConfigRequest) String() string

type GetConfigResponse added in v0.9.215

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

func (*GetConfigResponse) Descriptor deprecated added in v0.9.215

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

Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.

func (*GetConfigResponse) GetJSON added in v0.9.215

func (x *GetConfigResponse) GetJSON() string

func (*GetConfigResponse) ProtoMessage added in v0.9.215

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) ProtoReflect added in v0.9.215

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

func (*GetConfigResponse) Reset added in v0.9.215

func (x *GetConfigResponse) Reset()

func (*GetConfigResponse) String added in v0.9.215

func (x *GetConfigResponse) String() string

type HealthCheckStats added in v0.9.211

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 added in v0.9.211

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

Deprecated: Use HealthCheckStats.ProtoReflect.Descriptor instead.

func (*HealthCheckStats) GetCriuVersion added in v0.9.211

func (x *HealthCheckStats) GetCriuVersion() string

func (*HealthCheckStats) GetGPUHealthCheck added in v0.9.211

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

func (*HealthCheckStats) ProtoMessage added in v0.9.211

func (*HealthCheckStats) ProtoMessage()

func (*HealthCheckStats) ProtoReflect added in v0.9.211

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

func (*HealthCheckStats) Reset added in v0.9.211

func (x *HealthCheckStats) Reset()

func (*HealthCheckStats) String added in v0.9.211

func (x *HealthCheckStats) String() string

type HostInfo added in v0.9.204

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 added in v0.9.204

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

Deprecated: Use HostInfo.ProtoReflect.Descriptor instead.

func (*HostInfo) GetHostID added in v0.9.204

func (x *HostInfo) GetHostID() string

func (*HostInfo) GetHostname added in v0.9.204

func (x *HostInfo) GetHostname() string

func (*HostInfo) GetKernelArch added in v0.9.204

func (x *HostInfo) GetKernelArch() string

func (*HostInfo) GetKernelVersion added in v0.9.204

func (x *HostInfo) GetKernelVersion() string

func (*HostInfo) GetOS added in v0.9.204

func (x *HostInfo) GetOS() string

func (*HostInfo) GetPlatform added in v0.9.204

func (x *HostInfo) GetPlatform() string

func (*HostInfo) GetVirtualizationRole added in v0.9.204

func (x *HostInfo) GetVirtualizationRole() string

func (*HostInfo) GetVirtualizationSystem added in v0.9.204

func (x *HostInfo) GetVirtualizationSystem() string

func (*HostInfo) ProtoMessage added in v0.9.204

func (*HostInfo) ProtoMessage()

func (*HostInfo) ProtoReflect added in v0.9.204

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

func (*HostInfo) Reset added in v0.9.204

func (x *HostInfo) Reset()

func (*HostInfo) String added in v0.9.204

func (x *HostInfo) String() string

type JobState added in v0.9.104

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

func (JobState) Descriptor added in v0.9.104

func (JobState) Descriptor() protoreflect.EnumDescriptor

func (JobState) Enum added in v0.9.104

func (x JobState) Enum() *JobState

func (JobState) EnumDescriptor deprecated added in v0.9.104

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

Deprecated: Use JobState.Descriptor instead.

func (JobState) Number added in v0.9.104

func (x JobState) Number() protoreflect.EnumNumber

func (JobState) String added in v0.9.104

func (x JobState) String() string

func (JobState) Type added in v0.9.104

type LogStreamingArgs

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

func (*LogStreamingArgs) Descriptor deprecated

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

Deprecated: Use LogStreamingArgs.ProtoReflect.Descriptor instead.

func (*LogStreamingArgs) GetLevel

func (x *LogStreamingArgs) GetLevel() string

func (*LogStreamingArgs) GetMsg

func (x *LogStreamingArgs) GetMsg() string

func (*LogStreamingArgs) GetSource

func (x *LogStreamingArgs) GetSource() string

func (*LogStreamingArgs) GetTimestamp

func (x *LogStreamingArgs) GetTimestamp() string

func (*LogStreamingArgs) ProtoMessage

func (*LogStreamingArgs) ProtoMessage()

func (*LogStreamingArgs) ProtoReflect added in v0.8.1

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

func (*LogStreamingArgs) Reset

func (x *LogStreamingArgs) Reset()

func (*LogStreamingArgs) String

func (x *LogStreamingArgs) String() string

type LogStreamingResp

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

func (*LogStreamingResp) Descriptor deprecated

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

Deprecated: Use LogStreamingResp.ProtoReflect.Descriptor instead.

func (*LogStreamingResp) GetStatus

func (x *LogStreamingResp) GetStatus() string

func (*LogStreamingResp) ProtoMessage

func (*LogStreamingResp) ProtoMessage()

func (*LogStreamingResp) ProtoReflect added in v0.8.1

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

func (*LogStreamingResp) Reset

func (x *LogStreamingResp) Reset()

func (*LogStreamingResp) String

func (x *LogStreamingResp) String() string

type MemoryInfo added in v0.9.204

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 added in v0.9.204

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

Deprecated: Use MemoryInfo.ProtoReflect.Descriptor instead.

func (*MemoryInfo) GetAvailable added in v0.9.204

func (x *MemoryInfo) GetAvailable() uint64

func (*MemoryInfo) GetTotal added in v0.9.204

func (x *MemoryInfo) GetTotal() uint64

func (*MemoryInfo) GetUsed added in v0.9.204

func (x *MemoryInfo) GetUsed() uint64

func (*MemoryInfo) ProtoMessage added in v0.9.204

func (*MemoryInfo) ProtoMessage()

func (*MemoryInfo) ProtoReflect added in v0.9.204

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

func (*MemoryInfo) Reset added in v0.9.204

func (x *MemoryInfo) Reset()

func (*MemoryInfo) String added in v0.9.204

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 added in v0.9.7

func (x *OpenFilesStat) GetMode() string

func (*OpenFilesStat) GetPath

func (x *OpenFilesStat) GetPath() string

func (*OpenFilesStat) GetStream added in v0.9.7

func (x *OpenFilesStat) GetStream() OpenFilesStat_StreamType

func (*OpenFilesStat) ProtoMessage

func (*OpenFilesStat) ProtoMessage()

func (*OpenFilesStat) ProtoReflect added in v0.8.1

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

func (*OpenFilesStat) Reset

func (x *OpenFilesStat) Reset()

func (*OpenFilesStat) String

func (x *OpenFilesStat) String() string

type OpenFilesStat_StreamType added in v0.9.7

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

func (OpenFilesStat_StreamType) Descriptor added in v0.9.7

func (OpenFilesStat_StreamType) Enum added in v0.9.7

func (OpenFilesStat_StreamType) EnumDescriptor deprecated added in v0.9.7

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

Deprecated: Use OpenFilesStat_StreamType.Descriptor instead.

func (OpenFilesStat_StreamType) Number added in v0.9.7

func (OpenFilesStat_StreamType) String added in v0.9.7

func (x OpenFilesStat_StreamType) String() string

func (OpenFilesStat_StreamType) Type added in v0.9.7

type ProcessInfo

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

func (*ProcessInfo) Descriptor deprecated

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

Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.

func (*ProcessInfo) GetAttachedToHardwareAccel

func (x *ProcessInfo) GetAttachedToHardwareAccel() bool

func (*ProcessInfo) GetIsRunning

func (x *ProcessInfo) GetIsRunning() bool

func (*ProcessInfo) GetMemoryPercent

func (x *ProcessInfo) GetMemoryPercent() float32

func (*ProcessInfo) GetOpenConnections

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

func (*ProcessInfo) GetOpenFds

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

func (*ProcessInfo) GetPID

func (x *ProcessInfo) GetPID() int32

func (*ProcessInfo) GetStatus

func (x *ProcessInfo) GetStatus() string

func (*ProcessInfo) GetWorkingDir added in v0.9.7

func (x *ProcessInfo) GetWorkingDir() string

func (*ProcessInfo) ProtoMessage

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoReflect added in v0.8.1

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

func (*ProcessInfo) Reset

func (x *ProcessInfo) Reset()

func (*ProcessInfo) String

func (x *ProcessInfo) String() string

type ProcessState

type ProcessState struct {
	PID             int32           `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	Task            string          `protobuf:"bytes,2,opt,name=Task,proto3" json:"Task,omitempty"`
	ContainerID     string          `protobuf:"bytes,4,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	StartedAt       string          `protobuf:"bytes,5,opt,name=StartedAt,proto3" json:"StartedAt,omitempty"`
	ProcessInfo     *ProcessInfo    `protobuf:"bytes,6,opt,name=ProcessInfo,proto3" json:"ProcessInfo,omitempty"`
	CheckpointPath  string          `protobuf:"bytes,7,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	CheckpointState CheckpointState `` /* 126-byte string literal not displayed */
	JobState        JobState        `protobuf:"varint,9,opt,name=JobState,proto3,enum=cedana.services.task.JobState" json:"JobState,omitempty"`
	RemoteState     []*RemoteState  `protobuf:"bytes,10,rep,name=RemoteState,proto3" json:"RemoteState,omitempty"`
	GPUCheckpointed bool            `protobuf:"varint,11,opt,name=GPUCheckpointed,proto3" json:"GPUCheckpointed,omitempty"`
	JID             string          `protobuf:"bytes,12,opt,name=JID,proto3" json:"JID,omitempty"`
	HostInfo        *HostInfo       `protobuf:"bytes,13,opt,name=HostInfo,proto3" json:"HostInfo,omitempty"`
	CPUInfo         *CPUInfo        `protobuf:"bytes,14,opt,name=CPUInfo,proto3" json:"CPUInfo,omitempty"`
	MemoryInfo      *MemoryInfo     `protobuf:"bytes,15,opt,name=MemoryInfo,proto3" json:"MemoryInfo,omitempty"`
	UIDs            []int32         `protobuf:"varint,16,rep,packed,name=UIDs,proto3" json:"UIDs,omitempty"`
	GIDs            []int32         `protobuf:"varint,17,rep,packed,name=GIDs,proto3" json:"GIDs,omitempty"`
	Groups          []int32         `protobuf:"varint,18,rep,packed,name=Groups,proto3" json:"Groups,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessState) Descriptor deprecated

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

Deprecated: Use ProcessState.ProtoReflect.Descriptor instead.

func (*ProcessState) GetCPUInfo added in v0.9.204

func (x *ProcessState) GetCPUInfo() *CPUInfo

func (*ProcessState) GetCheckpointPath

func (x *ProcessState) GetCheckpointPath() string

func (*ProcessState) GetCheckpointState

func (x *ProcessState) GetCheckpointState() CheckpointState

func (*ProcessState) GetContainerID added in v0.9.104

func (x *ProcessState) GetContainerID() string

func (*ProcessState) GetGIDs added in v0.9.215

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

func (*ProcessState) GetGPUCheckpointed added in v0.9.5

func (x *ProcessState) GetGPUCheckpointed() bool

func (*ProcessState) GetGroups added in v0.9.215

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

func (*ProcessState) GetHostInfo added in v0.9.204

func (x *ProcessState) GetHostInfo() *HostInfo

func (*ProcessState) GetJID added in v0.9.104

func (x *ProcessState) GetJID() string

func (*ProcessState) GetJobState added in v0.9.104

func (x *ProcessState) GetJobState() JobState

func (*ProcessState) GetMemoryInfo added in v0.9.204

func (x *ProcessState) GetMemoryInfo() *MemoryInfo

func (*ProcessState) GetPID

func (x *ProcessState) GetPID() int32

func (*ProcessState) GetProcessInfo

func (x *ProcessState) GetProcessInfo() *ProcessInfo

func (*ProcessState) GetRemoteState added in v0.8.9

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

func (*ProcessState) GetStartedAt

func (x *ProcessState) GetStartedAt() string

func (*ProcessState) GetTask

func (x *ProcessState) GetTask() string

func (*ProcessState) GetUIDs added in v0.9.215

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

func (*ProcessState) ProtoMessage

func (*ProcessState) ProtoMessage()

func (*ProcessState) ProtoReflect added in v0.8.1

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

func (*ProcessState) Reset

func (x *ProcessState) Reset()

func (*ProcessState) String

func (x *ProcessState) String() string

type ProcessStateStreamingArgs added in v0.9.104

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

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

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

Deprecated: Use ProcessStateStreamingArgs.ProtoReflect.Descriptor instead.

func (*ProcessStateStreamingArgs) GetJID added in v0.9.104

func (x *ProcessStateStreamingArgs) GetJID() string

func (*ProcessStateStreamingArgs) ProtoMessage added in v0.9.104

func (*ProcessStateStreamingArgs) ProtoMessage()

func (*ProcessStateStreamingArgs) ProtoReflect added in v0.9.104

func (*ProcessStateStreamingArgs) Reset added in v0.9.104

func (x *ProcessStateStreamingArgs) Reset()

func (*ProcessStateStreamingArgs) String added in v0.9.104

func (x *ProcessStateStreamingArgs) String() string

type QueryArgs added in v0.9.104

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

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

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

Deprecated: Use QueryArgs.ProtoReflect.Descriptor instead.

func (*QueryArgs) GetJIDs added in v0.9.104

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

func (*QueryArgs) GetPIDs added in v0.9.104

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

func (*QueryArgs) ProtoMessage added in v0.9.104

func (*QueryArgs) ProtoMessage()

func (*QueryArgs) ProtoReflect added in v0.9.104

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

func (*QueryArgs) Reset added in v0.9.104

func (x *QueryArgs) Reset()

func (*QueryArgs) String added in v0.9.104

func (x *QueryArgs) String() string

type QueryResp added in v0.9.104

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

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

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

Deprecated: Use QueryResp.ProtoReflect.Descriptor instead.

func (*QueryResp) GetProcesses added in v0.9.104

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

func (*QueryResp) ProtoMessage added in v0.9.104

func (*QueryResp) ProtoMessage()

func (*QueryResp) ProtoReflect added in v0.9.104

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

func (*QueryResp) Reset added in v0.9.104

func (x *QueryResp) Reset()

func (*QueryResp) String added in v0.9.104

func (x *QueryResp) String() string

type RemoteState added in v0.8.9

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

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

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

Deprecated: Use RemoteState.ProtoReflect.Descriptor instead.

func (*RemoteState) GetCheckpointID added in v0.8.9

func (x *RemoteState) GetCheckpointID() string

func (*RemoteState) GetTimestamp added in v0.9.9

func (x *RemoteState) GetTimestamp() int64

func (*RemoteState) GetUploadID added in v0.8.9

func (x *RemoteState) GetUploadID() string

func (*RemoteState) ProtoMessage added in v0.8.9

func (*RemoteState) ProtoMessage()

func (*RemoteState) ProtoReflect added in v0.8.9

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

func (*RemoteState) Reset added in v0.8.9

func (x *RemoteState) Reset()

func (*RemoteState) String added in v0.8.9

func (x *RemoteState) String() string

type RestoreArgs

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

func (*RestoreArgs) Descriptor deprecated

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

Deprecated: Use RestoreArgs.ProtoReflect.Descriptor instead.

func (*RestoreArgs) GetCheckpointID added in v0.9.104

func (x *RestoreArgs) GetCheckpointID() string

func (*RestoreArgs) GetCheckpointPath

func (x *RestoreArgs) GetCheckpointPath() string

func (*RestoreArgs) GetGID added in v0.9.95

func (x *RestoreArgs) GetGID() int32

func (*RestoreArgs) GetGroups added in v0.9.211

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

func (*RestoreArgs) GetJID added in v0.9.104

func (x *RestoreArgs) GetJID() string

func (*RestoreArgs) GetTcpEstablished added in v0.9.211

func (x *RestoreArgs) GetTcpEstablished() bool

func (*RestoreArgs) GetType

func (x *RestoreArgs) GetType() CRType

func (*RestoreArgs) GetUID added in v0.9.95

func (x *RestoreArgs) GetUID() int32

func (*RestoreArgs) ProtoMessage

func (*RestoreArgs) ProtoMessage()

func (*RestoreArgs) ProtoReflect added in v0.8.1

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

func (*RestoreArgs) Reset

func (x *RestoreArgs) Reset()

func (*RestoreArgs) String

func (x *RestoreArgs) String() string

type RestoreResp

type RestoreResp struct {
	Message      string        `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	NewPID       int32         `protobuf:"varint,2,opt,name=NewPID,proto3" json:"NewPID,omitempty"`
	State        *ProcessState `protobuf:"bytes,3,opt,name=State,proto3" json:"State,omitempty"`
	RestoreStats *RestoreStats `protobuf:"bytes,6,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) GetNewPID

func (x *RestoreResp) GetNewPID() int32

func (*RestoreResp) GetRestoreStats added in v0.9.215

func (x *RestoreResp) GetRestoreStats() *RestoreStats

func (*RestoreResp) GetState added in v0.9.204

func (x *RestoreResp) GetState() *ProcessState

func (*RestoreResp) ProtoMessage

func (*RestoreResp) ProtoMessage()

func (*RestoreResp) ProtoReflect added in v0.8.1

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

func (*RestoreResp) Reset

func (x *RestoreResp) Reset()

func (*RestoreResp) String

func (x *RestoreResp) String() string

type RestoreStats added in v0.9.215

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 added in v0.9.215

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

Deprecated: Use RestoreStats.ProtoReflect.Descriptor instead.

func (*RestoreStats) GetCRIUDuration added in v0.9.215

func (x *RestoreStats) GetCRIUDuration() int64

func (*RestoreStats) GetCheckpointFileStats added in v0.9.215

func (x *RestoreStats) GetCheckpointFileStats() *CheckpointFileStats

func (*RestoreStats) GetContainerRuntime added in v0.9.215

func (x *RestoreStats) GetContainerRuntime() ContainerRuntime

func (*RestoreStats) GetDownloadDuration added in v0.9.215

func (x *RestoreStats) GetDownloadDuration() int64

func (*RestoreStats) GetDumpType added in v0.9.215

func (x *RestoreStats) GetDumpType() DumpType

func (*RestoreStats) GetGPUDuration added in v0.9.215

func (x *RestoreStats) GetGPUDuration() int64

func (*RestoreStats) GetGPURestoreStats added in v0.9.216

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

func (*RestoreStats) GetPrepareDuration added in v0.9.215

func (x *RestoreStats) GetPrepareDuration() int64

func (*RestoreStats) ProtoMessage added in v0.9.215

func (*RestoreStats) ProtoMessage()

func (*RestoreStats) ProtoReflect added in v0.9.215

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

func (*RestoreStats) Reset added in v0.9.215

func (x *RestoreStats) Reset()

func (*RestoreStats) String added in v0.9.215

func (x *RestoreStats) String() string

type RuncContainer added in v0.9.104

type RuncContainer struct {
	ID            string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	BundlePath    string `protobuf:"bytes,2,opt,name=BundlePath,proto3" json:"BundlePath,omitempty"`
	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 added in v0.9.104

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

Deprecated: Use RuncContainer.ProtoReflect.Descriptor instead.

func (*RuncContainer) GetBundlePath added in v0.9.104

func (x *RuncContainer) GetBundlePath() string

func (*RuncContainer) GetContainerName added in v0.9.202

func (x *RuncContainer) GetContainerName() string

func (*RuncContainer) GetID added in v0.9.104

func (x *RuncContainer) GetID() string

func (*RuncContainer) GetImageName added in v0.9.202

func (x *RuncContainer) GetImageName() string

func (*RuncContainer) GetSandboxId added in v0.9.202

func (x *RuncContainer) GetSandboxId() string

func (*RuncContainer) GetSandboxName added in v0.9.202

func (x *RuncContainer) GetSandboxName() string

func (*RuncContainer) GetSandboxUid added in v0.9.202

func (x *RuncContainer) GetSandboxUid() string

func (*RuncContainer) ProtoMessage added in v0.9.104

func (*RuncContainer) ProtoMessage()

func (*RuncContainer) ProtoReflect added in v0.9.104

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

func (*RuncContainer) Reset added in v0.9.104

func (x *RuncContainer) Reset()

func (*RuncContainer) String added in v0.9.104

func (x *RuncContainer) String() string

type RuncDumpArgs

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

func (*RuncDumpArgs) Descriptor deprecated

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

Deprecated: Use RuncDumpArgs.ProtoReflect.Descriptor instead.

func (*RuncDumpArgs) GetCheckpointPath

func (x *RuncDumpArgs) GetCheckpointPath() string

func (*RuncDumpArgs) GetContainerID added in v0.9.104

func (x *RuncDumpArgs) GetContainerID() string

func (*RuncDumpArgs) GetCriuOpts

func (x *RuncDumpArgs) GetCriuOpts() *CriuOpts

func (*RuncDumpArgs) GetGPU added in v0.9.200

func (x *RuncDumpArgs) GetGPU() bool

func (*RuncDumpArgs) GetPid added in v0.9.202

func (x *RuncDumpArgs) GetPid() int32

func (*RuncDumpArgs) GetRoot

func (x *RuncDumpArgs) GetRoot() string

func (*RuncDumpArgs) GetState added in v0.9.204

func (x *RuncDumpArgs) GetState() *ProcessState

func (*RuncDumpArgs) GetType added in v0.9.7

func (x *RuncDumpArgs) GetType() CRType

func (*RuncDumpArgs) ProtoMessage

func (*RuncDumpArgs) ProtoMessage()

func (*RuncDumpArgs) ProtoReflect added in v0.8.1

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

func (*RuncDumpArgs) Reset

func (x *RuncDumpArgs) Reset()

func (*RuncDumpArgs) String

func (x *RuncDumpArgs) String() string

type RuncDumpResp

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

func (*RuncDumpResp) Descriptor deprecated

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

Deprecated: Use RuncDumpResp.ProtoReflect.Descriptor instead.

func (*RuncDumpResp) GetCheckpointID added in v0.9.104

func (x *RuncDumpResp) GetCheckpointID() string

func (*RuncDumpResp) GetMessage

func (x *RuncDumpResp) GetMessage() string

func (*RuncDumpResp) GetState added in v0.9.204

func (x *RuncDumpResp) GetState() *ProcessState

func (*RuncDumpResp) GetUploadID added in v0.9.104

func (x *RuncDumpResp) GetUploadID() string

func (*RuncDumpResp) ProtoMessage

func (*RuncDumpResp) ProtoMessage()

func (*RuncDumpResp) ProtoReflect added in v0.8.1

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

func (*RuncDumpResp) Reset

func (x *RuncDumpResp) Reset()

func (*RuncDumpResp) String

func (x *RuncDumpResp) String() string

type RuncGetPausePidArgs added in v0.9.104

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

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

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

Deprecated: Use RuncGetPausePidArgs.ProtoReflect.Descriptor instead.

func (*RuncGetPausePidArgs) GetBundlePath added in v0.9.104

func (x *RuncGetPausePidArgs) GetBundlePath() string

func (*RuncGetPausePidArgs) ProtoMessage added in v0.9.104

func (*RuncGetPausePidArgs) ProtoMessage()

func (*RuncGetPausePidArgs) ProtoReflect added in v0.9.104

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

func (*RuncGetPausePidArgs) Reset added in v0.9.104

func (x *RuncGetPausePidArgs) Reset()

func (*RuncGetPausePidArgs) String added in v0.9.104

func (x *RuncGetPausePidArgs) String() string

type RuncGetPausePidResp added in v0.9.104

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

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

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

Deprecated: Use RuncGetPausePidResp.ProtoReflect.Descriptor instead.

func (*RuncGetPausePidResp) GetPausePid added in v0.9.104

func (x *RuncGetPausePidResp) GetPausePid() int64

func (*RuncGetPausePidResp) ProtoMessage added in v0.9.104

func (*RuncGetPausePidResp) ProtoMessage()

func (*RuncGetPausePidResp) ProtoReflect added in v0.9.104

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

func (*RuncGetPausePidResp) Reset added in v0.9.104

func (x *RuncGetPausePidResp) Reset()

func (*RuncGetPausePidResp) String added in v0.9.104

func (x *RuncGetPausePidResp) String() string

type RuncOpts

type RuncOpts struct {
	Root            string `protobuf:"bytes,1,opt,name=Root,proto3" json:"Root,omitempty"`
	ContainerID     string `protobuf:"bytes,2,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	Bundle          string `protobuf:"bytes,3,opt,name=Bundle,proto3" json:"Bundle,omitempty"`
	SystemdCgroup   bool   `protobuf:"varint,4,opt,name=SystemdCgroup,proto3" json:"SystemdCgroup,omitempty"`
	NoPivot         bool   `protobuf:"varint,5,opt,name=NoPivot,proto3" json:"NoPivot,omitempty"`
	NoMountFallback bool   `protobuf:"varint,6,opt,name=NoMountFallback,proto3" json:"NoMountFallback,omitempty"`
	NoNewKeyring    bool   `protobuf:"varint,7,opt,name=NoNewKeyring,proto3" json:"NoNewKeyring,omitempty"`
	Rootless        string `protobuf:"bytes,8,opt,name=Rootless,proto3" json:"Rootless,omitempty"`
	NoSubreaper     bool   `protobuf:"varint,9,opt,name=NoSubreaper,proto3" json:"NoSubreaper,omitempty"`
	Keep            bool   `protobuf:"varint,10,opt,name=Keep,proto3" json:"Keep,omitempty"`
	ConsoleSocket   string `protobuf:"bytes,11,opt,name=ConsoleSocket,proto3" json:"ConsoleSocket,omitempty"`
	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 added in v0.9.104

func (x *RuncOpts) GetContainerID() string

func (*RuncOpts) GetDetach added in v0.9.211

func (x *RuncOpts) GetDetach() bool

func (*RuncOpts) GetKeep

func (x *RuncOpts) GetKeep() bool

func (*RuncOpts) GetNetPid added in v0.9.5

func (x *RuncOpts) GetNetPid() int32

func (*RuncOpts) GetNoMountFallback

func (x *RuncOpts) GetNoMountFallback() bool

func (*RuncOpts) GetNoNewKeyring

func (x *RuncOpts) GetNoNewKeyring() bool

func (*RuncOpts) GetNoPivot

func (x *RuncOpts) GetNoPivot() bool

func (*RuncOpts) GetNoSubreaper

func (x *RuncOpts) GetNoSubreaper() bool

func (*RuncOpts) GetPidFile

func (x *RuncOpts) GetPidFile() string

func (*RuncOpts) GetPreserveFds

func (x *RuncOpts) GetPreserveFds() int32

func (*RuncOpts) GetRoot

func (x *RuncOpts) GetRoot() string

func (*RuncOpts) GetRootless

func (x *RuncOpts) GetRootless() string

func (*RuncOpts) GetSystemdCgroup

func (x *RuncOpts) GetSystemdCgroup() bool

func (*RuncOpts) ProtoMessage

func (*RuncOpts) ProtoMessage()

func (*RuncOpts) ProtoReflect added in v0.8.1

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

func (*RuncOpts) Reset

func (x *RuncOpts) Reset()

func (*RuncOpts) String

func (x *RuncOpts) String() string

type RuncQueryArgs added in v0.9.104

type RuncQueryArgs struct {
	Root           string   `protobuf:"bytes,1,opt,name=Root,proto3" json:"Root,omitempty"`
	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 added in v0.9.104

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

Deprecated: Use RuncQueryArgs.ProtoReflect.Descriptor instead.

func (*RuncQueryArgs) GetContainerNames added in v0.9.104

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

func (*RuncQueryArgs) GetNamespace added in v0.9.202

func (x *RuncQueryArgs) GetNamespace() string

func (*RuncQueryArgs) GetRoot added in v0.9.104

func (x *RuncQueryArgs) GetRoot() string

func (*RuncQueryArgs) GetSandboxNames added in v0.9.202

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

func (*RuncQueryArgs) ProtoMessage added in v0.9.104

func (*RuncQueryArgs) ProtoMessage()

func (*RuncQueryArgs) ProtoReflect added in v0.9.104

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

func (*RuncQueryArgs) Reset added in v0.9.104

func (x *RuncQueryArgs) Reset()

func (*RuncQueryArgs) String added in v0.9.104

func (x *RuncQueryArgs) String() string

type RuncQueryResp added in v0.9.104

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

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

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

Deprecated: Use RuncQueryResp.ProtoReflect.Descriptor instead.

func (*RuncQueryResp) GetContainers added in v0.9.104

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

func (*RuncQueryResp) ProtoMessage added in v0.9.104

func (*RuncQueryResp) ProtoMessage()

func (*RuncQueryResp) ProtoReflect added in v0.9.104

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

func (*RuncQueryResp) Reset added in v0.9.104

func (x *RuncQueryResp) Reset()

func (*RuncQueryResp) String added in v0.9.104

func (x *RuncQueryResp) String() string

type RuncRestoreArgs

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

func (*RuncRestoreArgs) Descriptor deprecated

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

Deprecated: Use RuncRestoreArgs.ProtoReflect.Descriptor instead.

func (*RuncRestoreArgs) GetCheckpointID added in v0.9.104

func (x *RuncRestoreArgs) GetCheckpointID() string

func (*RuncRestoreArgs) GetContainerID added in v0.9.104

func (x *RuncRestoreArgs) GetContainerID() string

func (*RuncRestoreArgs) GetImagePath

func (x *RuncRestoreArgs) GetImagePath() string

func (*RuncRestoreArgs) GetIsK3S added in v0.9.5

func (x *RuncRestoreArgs) GetIsK3S() bool

func (*RuncRestoreArgs) GetOpts

func (x *RuncRestoreArgs) GetOpts() *RuncOpts

func (*RuncRestoreArgs) GetType added in v0.9.7

func (x *RuncRestoreArgs) GetType() CRType

func (*RuncRestoreArgs) ProtoMessage

func (*RuncRestoreArgs) ProtoMessage()

func (*RuncRestoreArgs) ProtoReflect added in v0.8.1

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

func (*RuncRestoreArgs) Reset

func (x *RuncRestoreArgs) Reset()

func (*RuncRestoreArgs) String

func (x *RuncRestoreArgs) String() string

type RuncRestoreResp

type RuncRestoreResp struct {
	Message string        `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	State   *ProcessState `protobuf:"bytes,2,opt,name=State,proto3" json:"State,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) GetState added in v0.9.204

func (x *RuncRestoreResp) GetState() *ProcessState

func (*RuncRestoreResp) ProtoMessage

func (*RuncRestoreResp) ProtoMessage()

func (*RuncRestoreResp) ProtoReflect added in v0.8.1

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

func (*RuncRestoreResp) Reset

func (x *RuncRestoreResp) Reset()

func (*RuncRestoreResp) String

func (x *RuncRestoreResp) String() string

type StartArgs added in v0.9.104

type StartArgs struct {
	Task          string   `protobuf:"bytes,1,opt,name=Task,proto3" json:"Task,omitempty"`
	JID           string   `protobuf:"bytes,2,opt,name=JID,proto3" json:"JID,omitempty"`
	WorkingDir    string   `protobuf:"bytes,3,opt,name=WorkingDir,proto3" json:"WorkingDir,omitempty"`
	Env           []string `protobuf:"bytes,4,rep,name=Env,proto3" json:"Env,omitempty"`
	LogOutputFile string   `protobuf:"bytes,5,opt,name=LogOutputFile,proto3" json:"LogOutputFile,omitempty"`
	UID           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 added in v0.9.104

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

Deprecated: Use StartArgs.ProtoReflect.Descriptor instead.

func (*StartArgs) GetEnv added in v0.9.104

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

func (*StartArgs) GetGID added in v0.9.104

func (x *StartArgs) GetGID() int32

func (*StartArgs) GetGPU added in v0.9.200

func (x *StartArgs) GetGPU() bool

func (*StartArgs) GetGroups added in v0.9.211

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

func (*StartArgs) GetJID added in v0.9.104

func (x *StartArgs) GetJID() string

func (*StartArgs) GetLogOutputFile added in v0.9.104

func (x *StartArgs) GetLogOutputFile() string

func (*StartArgs) GetTask added in v0.9.104

func (x *StartArgs) GetTask() string

func (*StartArgs) GetUID added in v0.9.104

func (x *StartArgs) GetUID() int32

func (*StartArgs) GetWorkingDir added in v0.9.104

func (x *StartArgs) GetWorkingDir() string

func (*StartArgs) ProtoMessage added in v0.9.104

func (*StartArgs) ProtoMessage()

func (*StartArgs) ProtoReflect added in v0.9.104

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

func (*StartArgs) Reset added in v0.9.104

func (x *StartArgs) Reset()

func (*StartArgs) String added in v0.9.104

func (x *StartArgs) String() string

type StartAttachArgs added in v0.9.219

type StartAttachArgs struct {
	Args  *StartArgs `protobuf:"bytes,1,opt,name=Args,proto3" json:"Args,omitempty"`
	Stdin string     `protobuf:"bytes,2,opt,name=Stdin,proto3" json:"Stdin,omitempty"` // TODO:add signals
	// contains filtered or unexported fields
}

func (*StartAttachArgs) Descriptor deprecated added in v0.9.219

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

Deprecated: Use StartAttachArgs.ProtoReflect.Descriptor instead.

func (*StartAttachArgs) GetArgs added in v0.9.219

func (x *StartAttachArgs) GetArgs() *StartArgs

func (*StartAttachArgs) GetStdin added in v0.9.219

func (x *StartAttachArgs) GetStdin() string

func (*StartAttachArgs) ProtoMessage added in v0.9.219

func (*StartAttachArgs) ProtoMessage()

func (*StartAttachArgs) ProtoReflect added in v0.9.219

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

func (*StartAttachArgs) Reset added in v0.9.219

func (x *StartAttachArgs) Reset()

func (*StartAttachArgs) String added in v0.9.219

func (x *StartAttachArgs) String() string

type StartAttachResp added in v0.9.219

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

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

Deprecated: Use StartAttachResp.ProtoReflect.Descriptor instead.

func (*StartAttachResp) GetExitCode added in v0.9.219

func (x *StartAttachResp) GetExitCode() int32

func (*StartAttachResp) GetStderr added in v0.9.219

func (x *StartAttachResp) GetStderr() string

func (*StartAttachResp) GetStdout added in v0.9.219

func (x *StartAttachResp) GetStdout() string

func (*StartAttachResp) ProtoMessage added in v0.9.219

func (*StartAttachResp) ProtoMessage()

func (*StartAttachResp) ProtoReflect added in v0.9.219

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

func (*StartAttachResp) Reset added in v0.9.219

func (x *StartAttachResp) Reset()

func (*StartAttachResp) String added in v0.9.219

func (x *StartAttachResp) String() string

type StartResp added in v0.9.104

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

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

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

Deprecated: Use StartResp.ProtoReflect.Descriptor instead.

func (*StartResp) GetJID added in v0.9.104

func (x *StartResp) GetJID() string

func (*StartResp) GetMessage added in v0.9.104

func (x *StartResp) GetMessage() string

func (*StartResp) GetPID added in v0.9.104

func (x *StartResp) GetPID() int32

func (*StartResp) ProtoMessage added in v0.9.104

func (*StartResp) ProtoMessage()

func (*StartResp) ProtoReflect added in v0.9.104

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

func (*StartResp) Reset added in v0.9.104

func (x *StartResp) Reset()

func (*StartResp) String added in v0.9.104

func (x *StartResp) String() string

type TaskServiceClient

type TaskServiceClient interface {
	// Process
	Start(ctx context.Context, in *StartArgs, opts ...grpc.CallOption) (*StartResp, error)
	Dump(ctx context.Context, in *DumpArgs, opts ...grpc.CallOption) (*DumpResp, error)
	Restore(ctx context.Context, in *RestoreArgs, opts ...grpc.CallOption) (*RestoreResp, error)
	Query(ctx context.Context, in *QueryArgs, opts ...grpc.CallOption) (*QueryResp, error)
	// Containerd
	ContainerdDump(ctx context.Context, in *ContainerdDumpArgs, opts ...grpc.CallOption) (*ContainerdDumpResp, error)
	ContainerdRestore(ctx context.Context, in *ContainerdRestoreArgs, opts ...grpc.CallOption) (*ContainerdRestoreResp, error)
	ContainerdQuery(ctx context.Context, in *ContainerdQueryArgs, opts ...grpc.CallOption) (*ContainerdQueryResp, error)
	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)
	// CRIO
	CRIORootfsDump(ctx context.Context, in *CRIORootfsDumpArgs, opts ...grpc.CallOption) (*CRIORootfsDumpResp, error)
	CRIOImagePush(ctx context.Context, in *CRIOImagePushArgs, opts ...grpc.CallOption) (*CRIOImagePushResp, error)
	// Streaming
	StartAttach(ctx context.Context, opts ...grpc.CallOption) (TaskService_StartAttachClient, error)
	LogStreaming(ctx context.Context, opts ...grpc.CallOption) (TaskService_LogStreamingClient, error)
	ProcessStateStreaming(ctx context.Context, in *ProcessStateStreamingArgs, opts ...grpc.CallOption) (TaskService_ProcessStateStreamingClient, error)
	// Health
	DetailedHealthCheck(ctx context.Context, in *DetailedHealthCheckRequest, opts ...grpc.CallOption) (*DetailedHealthCheckResponse, error)
	// Config
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
}

TaskServiceClient is the client API for TaskService service.

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

type TaskServiceServer

type TaskServiceServer interface {
	// Process
	Start(context.Context, *StartArgs) (*StartResp, error)
	Dump(context.Context, *DumpArgs) (*DumpResp, error)
	Restore(context.Context, *RestoreArgs) (*RestoreResp, error)
	Query(context.Context, *QueryArgs) (*QueryResp, error)
	// Containerd
	ContainerdDump(context.Context, *ContainerdDumpArgs) (*ContainerdDumpResp, error)
	ContainerdRestore(context.Context, *ContainerdRestoreArgs) (*ContainerdRestoreResp, error)
	ContainerdQuery(context.Context, *ContainerdQueryArgs) (*ContainerdQueryResp, error)
	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)
	// CRIO
	CRIORootfsDump(context.Context, *CRIORootfsDumpArgs) (*CRIORootfsDumpResp, error)
	CRIOImagePush(context.Context, *CRIOImagePushArgs) (*CRIOImagePushResp, error)
	// Streaming
	StartAttach(TaskService_StartAttachServer) error
	LogStreaming(TaskService_LogStreamingServer) error
	ProcessStateStreaming(*ProcessStateStreamingArgs, TaskService_ProcessStateStreamingServer) error
	// Health
	DetailedHealthCheck(context.Context, *DetailedHealthCheckRequest) (*DetailedHealthCheckResponse, error)
	// Config
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	// contains filtered or unexported methods
}

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

type TaskService_LogStreamingClient

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

type TaskService_LogStreamingServer

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

type TaskService_ProcessStateStreamingClient added in v0.9.104

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

type TaskService_ProcessStateStreamingServer added in v0.9.104

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

type TaskService_StartAttachClient added in v0.9.219

type TaskService_StartAttachClient interface {
	Send(*StartAttachArgs) error
	Recv() (*StartAttachResp, error)
	grpc.ClientStream
}

type TaskService_StartAttachServer added in v0.9.219

type TaskService_StartAttachServer interface {
	Send(*StartAttachResp) error
	Recv() (*StartAttachArgs, error)
	grpc.ServerStream
}

type UnimplementedTaskServiceServer

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) CRIOImagePush added in v0.9.208

func (UnimplementedTaskServiceServer) CRIORootfsDump added in v0.9.208

func (UnimplementedTaskServiceServer) ContainerdDump added in v0.9.104

func (UnimplementedTaskServiceServer) ContainerdQuery added in v0.9.104

func (UnimplementedTaskServiceServer) ContainerdRestore added in v0.9.104

func (UnimplementedTaskServiceServer) ContainerdRootfsDump added in v0.9.202

func (UnimplementedTaskServiceServer) ContainerdRootfsRestore added in v0.9.202

func (UnimplementedTaskServiceServer) DetailedHealthCheck added in v0.9.211

func (UnimplementedTaskServiceServer) Dump

func (UnimplementedTaskServiceServer) GetConfig added in v0.9.215

func (UnimplementedTaskServiceServer) LogStreaming

func (UnimplementedTaskServiceServer) ProcessStateStreaming added in v0.9.104

func (UnimplementedTaskServiceServer) Query added in v0.9.104

func (UnimplementedTaskServiceServer) Restore

func (UnimplementedTaskServiceServer) RuncDump

func (UnimplementedTaskServiceServer) RuncGetPausePid added in v0.9.104

func (UnimplementedTaskServiceServer) RuncQuery added in v0.9.104

func (UnimplementedTaskServiceServer) RuncRestore

func (UnimplementedTaskServiceServer) Start added in v0.9.104

func (UnimplementedTaskServiceServer) StartAttach added in v0.9.219

type UnsafeTaskServiceServer

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

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

Jump to

Keyboard shortcuts

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