task

package
v0.9.9 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for FlagEnum.

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 (
	DumpArgs_DumpType_name = map[int32]string{
		0: "LOCAL",
		1: "REMOTE",
	}
	DumpArgs_DumpType_value = map[string]int32{
		"LOCAL":  0,
		"REMOTE": 1,
	}
)

Enum value maps for DumpArgs_DumpType.

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

Enum value maps for RestoreArgs_RestoreType.

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

Enum value maps for ProcessState_ContainerRuntimeOpts.

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 (
	RuncDumpArgs_DumpType_name = map[int32]string{
		0: "LOCAL",
		1: "REMOTE",
	}
	RuncDumpArgs_DumpType_value = map[string]int32{
		"LOCAL":  0,
		"REMOTE": 1,
	}
)

Enum value maps for RuncDumpArgs_DumpType.

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

Enum value maps for RuncRestoreArgs_RestoreType.

View Source 
var File_task_proto protoreflect.FileDescriptor
View Source 
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedana.services.task.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Dump",
			Handler:    _TaskService_Dump_Handler,
		},
		{
			MethodName: "Restore",
			Handler:    _TaskService_Restore_Handler,
		},
		{
			MethodName: "ContainerDump",
			Handler:    _TaskService_ContainerDump_Handler,
		},
		{
			MethodName: "ContainerRestore",
			Handler:    _TaskService_ContainerRestore_Handler,
		},
		{
			MethodName: "RuncDump",
			Handler:    _TaskService_RuncDump_Handler,
		},
		{
			MethodName: "RuncRestore",
			Handler:    _TaskService_RuncRestore_Handler,
		},
		{
			MethodName: "StartTask",
			Handler:    _TaskService_StartTask_Handler,
		},
		{
			MethodName: "ListRuncContainers",
			Handler:    _TaskService_ListRuncContainers_Handler,
		},
		{
			MethodName: "GetRuncContainerByName",
			Handler:    _TaskService_GetRuncContainerByName_Handler,
		},
		{
			MethodName: "GetPausePid",
			Handler:    _TaskService_GetPausePid_Handler,
		},
		{
			MethodName: "ListContainers",
			Handler:    _TaskService_ListContainers_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "LogStreaming",
			Handler:       _TaskService_LogStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ClientStateStreaming",
			Handler:       _TaskService_ClientStateStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "MetaStateStreaming",
			Handler:       _TaskService_MetaStateStreaming_Handler,
			ServerStreams: true,
			ClientStreams: 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 Annotation added in v0.9.9 

type Annotation struct {
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Annotation) Descriptor deprecated added in v0.9.9 

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

Deprecated: Use Annotation.ProtoReflect.Descriptor instead.

func (*Annotation) GetAnnotations added in v0.9.9 

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

func (*Annotation) ProtoMessage added in v0.9.9 

func (*Annotation) ProtoMessage()

func (*Annotation) ProtoReflect added in v0.9.9 

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

func (*Annotation) Reset added in v0.9.9 

func (x *Annotation) Reset()

func (*Annotation) String added in v0.9.9 

func (x *Annotation) String() string

type CheckpointReason 

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

func (*CheckpointReason) Descriptor deprecated 

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

Deprecated: Use CheckpointReason.ProtoReflect.Descriptor instead.

func (*CheckpointReason) GetReason 

func (x *CheckpointReason) GetReason() CheckpointReason_CheckpointReasonEnum

func (*CheckpointReason) ProtoMessage 

func (*CheckpointReason) ProtoMessage()

func (*CheckpointReason) ProtoReflect 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) Descriptor() protoreflect.EnumDescriptor

func (CheckpointReason_CheckpointReasonEnum) Enum added in v0.8.1 

func (x CheckpointReason_CheckpointReasonEnum) Enum() *CheckpointReason_CheckpointReasonEnum

func (CheckpointReason_CheckpointReasonEnum) EnumDescriptor deprecated 

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

Deprecated: Use CheckpointReason_CheckpointReasonEnum.Descriptor instead.

func (CheckpointReason_CheckpointReasonEnum) Number added in v0.8.1 

func (x CheckpointReason_CheckpointReasonEnum) Number() protoreflect.EnumNumber

func (CheckpointReason_CheckpointReasonEnum) String 

func (x CheckpointReason_CheckpointReasonEnum) String() string

func (CheckpointReason_CheckpointReasonEnum) Type added in v0.8.1 

func (CheckpointReason_CheckpointReasonEnum) Type() protoreflect.EnumType

type CheckpointState 

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

func (CheckpointState) Descriptor added in v0.8.1 

func (CheckpointState) Descriptor() protoreflect.EnumDescriptor

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 (x CheckpointState) Number() protoreflect.EnumNumber

func (CheckpointState) String 

func (x CheckpointState) String() string

func (CheckpointState) Type added in v0.8.1 

func (CheckpointState) Type() protoreflect.EnumType

type ClientInfo 

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

func (*ClientInfo) Descriptor deprecated 

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetHostname 

func (x *ClientInfo) GetHostname() string

func (*ClientInfo) GetId 

func (x *ClientInfo) GetId() string

func (*ClientInfo) GetOS 

func (x *ClientInfo) GetOS() string

func (*ClientInfo) GetPlatform 

func (x *ClientInfo) GetPlatform() string

func (*ClientInfo) GetRemainingMemory 

func (x *ClientInfo) GetRemainingMemory() uint64

func (*ClientInfo) GetUptime 

func (x *ClientInfo) GetUptime() uint64

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect added in v0.8.1 

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

func (*ClientInfo) Reset 

func (x *ClientInfo) Reset()

func (*ClientInfo) String 

func (x *ClientInfo) String() string

type ClientStateStreamingResp 

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

func (*ClientStateStreamingResp) Descriptor deprecated 

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

Deprecated: Use ClientStateStreamingResp.ProtoReflect.Descriptor instead.

func (*ClientStateStreamingResp) GetStatus 

func (x *ClientStateStreamingResp) GetStatus() string

func (*ClientStateStreamingResp) ProtoMessage 

func (*ClientStateStreamingResp) ProtoMessage()

func (*ClientStateStreamingResp) ProtoReflect added in v0.8.1 

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

func (*ClientStateStreamingResp) Reset 

func (x *ClientStateStreamingResp) Reset()

func (*ClientStateStreamingResp) String 

func (x *ClientStateStreamingResp) String() string

type ConnectionStat 

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

func (*ConnectionStat) Descriptor deprecated 

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

Deprecated: Use ConnectionStat.ProtoReflect.Descriptor instead.

func (*ConnectionStat) GetFamily 

func (x *ConnectionStat) GetFamily() uint32

func (*ConnectionStat) GetFd 

func (x *ConnectionStat) GetFd() uint32

func (*ConnectionStat) GetLaddr 

func (x *ConnectionStat) GetLaddr() *Addr

func (*ConnectionStat) GetPID 

func (x *ConnectionStat) GetPID() int32

func (*ConnectionStat) GetRaddr 

func (x *ConnectionStat) GetRaddr() *Addr

func (*ConnectionStat) GetStatus 

func (x *ConnectionStat) GetStatus() string

func (*ConnectionStat) GetType 

func (x *ConnectionStat) GetType() uint32

func (*ConnectionStat) GetUids 

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

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

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetContainerName added in v0.9.9 

func (x *Container) GetContainerName() string

func (*Container) GetImageName added in v0.9.9 

func (x *Container) GetImageName() string

func (*Container) GetSandboxId added in v0.9.9 

func (x *Container) GetSandboxId() string

func (*Container) GetSandboxName added in v0.9.9 

func (x *Container) GetSandboxName() string

func (*Container) GetSandboxNamespace added in v0.9.9 

func (x *Container) GetSandboxNamespace() string

func (*Container) GetSandboxUid added in v0.9.9 

func (x *Container) GetSandboxUid() string

func (*Container) ProtoMessage added in v0.9.9 

func (*Container) ProtoMessage()

func (*Container) ProtoReflect added in v0.9.9 

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

func (*Container) Reset added in v0.9.9 

func (x *Container) Reset()

func (*Container) String added in v0.9.9 

func (x *Container) String() string

type ContainerDumpArgs 

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

func (*ContainerDumpArgs) Descriptor deprecated 

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

Deprecated: Use ContainerDumpArgs.ProtoReflect.Descriptor instead.

func (*ContainerDumpArgs) GetContainerId 

func (x *ContainerDumpArgs) GetContainerId() string

func (*ContainerDumpArgs) GetRef 

func (x *ContainerDumpArgs) GetRef() string

func (*ContainerDumpArgs) ProtoMessage 

func (*ContainerDumpArgs) ProtoMessage()

func (*ContainerDumpArgs) ProtoReflect added in v0.8.1 

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

func (*ContainerDumpArgs) Reset 

func (x *ContainerDumpArgs) Reset()

func (*ContainerDumpArgs) String 

func (x *ContainerDumpArgs) String() string

type ContainerDumpResp 

type ContainerDumpResp 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 (*ContainerDumpResp) Descriptor deprecated 

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

Deprecated: Use ContainerDumpResp.ProtoReflect.Descriptor instead.

func (*ContainerDumpResp) GetCheckpointPath 

func (x *ContainerDumpResp) GetCheckpointPath() string

func (*ContainerDumpResp) GetMessage 

func (x *ContainerDumpResp) GetMessage() string

func (*ContainerDumpResp) ProtoMessage 

func (*ContainerDumpResp) ProtoMessage()

func (*ContainerDumpResp) ProtoReflect added in v0.8.1 

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

func (*ContainerDumpResp) Reset 

func (x *ContainerDumpResp) Reset()

func (*ContainerDumpResp) String 

func (x *ContainerDumpResp) String() string

type ContainerRestoreArgs 

type ContainerRestoreArgs 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 (*ContainerRestoreArgs) Descriptor deprecated 

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

Deprecated: Use ContainerRestoreArgs.ProtoReflect.Descriptor instead.

func (*ContainerRestoreArgs) GetContainerId 

func (x *ContainerRestoreArgs) GetContainerId() string

func (*ContainerRestoreArgs) GetImgPath 

func (x *ContainerRestoreArgs) GetImgPath() string

func (*ContainerRestoreArgs) ProtoMessage 

func (*ContainerRestoreArgs) ProtoMessage()

func (*ContainerRestoreArgs) ProtoReflect added in v0.8.1 

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

func (*ContainerRestoreArgs) Reset 

func (x *ContainerRestoreArgs) Reset()

func (*ContainerRestoreArgs) String 

func (x *ContainerRestoreArgs) String() string

type ContainerRestoreResp 

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

func (*ContainerRestoreResp) Descriptor deprecated 

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

Deprecated: Use ContainerRestoreResp.ProtoReflect.Descriptor instead.

func (*ContainerRestoreResp) GetMessage 

func (x *ContainerRestoreResp) GetMessage() string

func (*ContainerRestoreResp) ProtoMessage 

func (*ContainerRestoreResp) ProtoMessage()

func (*ContainerRestoreResp) ProtoReflect added in v0.8.1 

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

func (*ContainerRestoreResp) Reset 

func (x *ContainerRestoreResp) Reset()

func (*ContainerRestoreResp) String 

func (x *ContainerRestoreResp) 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                 uint32 `protobuf:"varint,12,opt,name=EmptyNs,proto3" json:"EmptyNs,omitempty"`
	AutoDedup               bool   `protobuf:"varint,13,opt,name=AutoDedup,proto3" json:"AutoDedup,omitempty"`
	LazyPages               bool   `protobuf:"varint,14,opt,name=LazyPages,proto3" json:"LazyPages,omitempty"`
	StatusFd                int32  `protobuf:"varint,15,opt,name=StatusFd,proto3" json:"StatusFd,omitempty"`
	LsmProfile              string `protobuf:"bytes,16,opt,name=LsmProfile,proto3" json:"LsmProfile,omitempty"`
	LsmMountContext         string `protobuf:"bytes,17,opt,name=LsmMountContext,proto3" json:"LsmMountContext,omitempty"`
	// contains filtered or unexported fields
}

func (*CriuOpts) Descriptor deprecated 

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

Deprecated: Use CriuOpts.ProtoReflect.Descriptor instead.

func (*CriuOpts) GetAutoDedup 

func (x *CriuOpts) GetAutoDedup() bool

func (*CriuOpts) GetEmptyNs 

func (x *CriuOpts) GetEmptyNs() uint32

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

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

func (*CtrByNameArgs) Descriptor deprecated added in v0.9.5 

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

Deprecated: Use CtrByNameArgs.ProtoReflect.Descriptor instead.

func (*CtrByNameArgs) GetContainerName added in v0.9.5 

func (x *CtrByNameArgs) GetContainerName() string

func (*CtrByNameArgs) GetRoot added in v0.9.5 

func (x *CtrByNameArgs) GetRoot() string

func (*CtrByNameArgs) ProtoMessage added in v0.9.5 

func (*CtrByNameArgs) ProtoMessage()

func (*CtrByNameArgs) ProtoReflect added in v0.9.5 

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

func (*CtrByNameArgs) Reset added in v0.9.5 

func (x *CtrByNameArgs) Reset()

func (*CtrByNameArgs) String added in v0.9.5 

func (x *CtrByNameArgs) String() string

type CtrByNameResp added in v0.9.5 

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

func (*CtrByNameResp) Descriptor deprecated added in v0.9.5 

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

Deprecated: Use CtrByNameResp.ProtoReflect.Descriptor instead.

func (*CtrByNameResp) GetRuncBundlePath added in v0.9.5 

func (x *CtrByNameResp) GetRuncBundlePath() string

func (*CtrByNameResp) GetRuncContainerName added in v0.9.5 

func (x *CtrByNameResp) GetRuncContainerName() string

func (*CtrByNameResp) ProtoMessage added in v0.9.5 

func (*CtrByNameResp) ProtoMessage()

func (*CtrByNameResp) ProtoReflect added in v0.9.5 

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

func (*CtrByNameResp) Reset added in v0.9.5 

func (x *CtrByNameResp) Reset()

func (*CtrByNameResp) String added in v0.9.5 

func (x *CtrByNameResp) 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  DumpArgs_DumpType `protobuf:"varint,3,opt,name=Type,proto3,enum=cedana.services.task.DumpArgs_DumpType" json:"Type,omitempty"`
	JobID string            `protobuf:"bytes,4,opt,name=JobID,proto3" json:"JobID,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) GetJobID 

func (x *DumpArgs) GetJobID() string

func (*DumpArgs) GetPID 

func (x *DumpArgs) GetPID() int32

func (*DumpArgs) GetType 

func (x *DumpArgs) GetType() DumpArgs_DumpType

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 DumpArgs_DumpType 

type DumpArgs_DumpType int32
const (
	DumpArgs_LOCAL  DumpArgs_DumpType = 0
	DumpArgs_REMOTE DumpArgs_DumpType = 1
)

func (DumpArgs_DumpType) Descriptor added in v0.8.1 

func (DumpArgs_DumpType) Descriptor() protoreflect.EnumDescriptor

func (DumpArgs_DumpType) Enum added in v0.8.1 

func (x DumpArgs_DumpType) Enum() *DumpArgs_DumpType

func (DumpArgs_DumpType) EnumDescriptor deprecated 

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

Deprecated: Use DumpArgs_DumpType.Descriptor instead.

func (DumpArgs_DumpType) Number added in v0.8.1 

func (x DumpArgs_DumpType) Number() protoreflect.EnumNumber

func (DumpArgs_DumpType) String 

func (x DumpArgs_DumpType) String() string

func (DumpArgs_DumpType) Type added in v0.8.1 

func (DumpArgs_DumpType) Type() protoreflect.EnumType

type DumpResp 

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

func (*DumpResp) Descriptor deprecated 

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

Deprecated: Use DumpResp.ProtoReflect.Descriptor instead.

func (*DumpResp) GetCheckpointID added in v0.8.9 

func (x *DumpResp) GetCheckpointID() string

func (*DumpResp) GetMessage 

func (x *DumpResp) GetMessage() string

func (*DumpResp) GetUploadID added in v0.8.9 

func (x *DumpResp) GetUploadID() string

func (*DumpResp) ProtoMessage 

func (*DumpResp) ProtoMessage()

func (*DumpResp) ProtoReflect added in v0.8.1 

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

func (*DumpResp) Reset 

func (x *DumpResp) Reset()

func (*DumpResp) String 

func (x *DumpResp) String() string

type External added in v0.9.5 

type External struct {
	String_ []string `protobuf:"bytes,1,rep,name=String,proto3" json:"String,omitempty"`
	// contains filtered or unexported fields
}

func (*External) Descriptor deprecated added in v0.9.5 

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

Deprecated: Use External.ProtoReflect.Descriptor instead.

func (*External) GetString_ added in v0.9.5 

func (x *External) GetString_() []string

func (*External) ProtoMessage added in v0.9.5 

func (*External) ProtoMessage()

func (*External) ProtoReflect added in v0.9.5 

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

func (*External) Reset added in v0.9.5 

func (x *External) Reset()

func (*External) String added in v0.9.5 

func (x *External) String() string

type FlagEnum 

type FlagEnum int32
const (
	FlagEnum_JOB_STARTUP_FAILED FlagEnum = 0
	FlagEnum_JOB_KILLED         FlagEnum = 1
	FlagEnum_JOB_IDLE           FlagEnum = 2
	FlagEnum_JOB_RUNNING        FlagEnum = 3
	FlagEnum_JOB_PENDING        FlagEnum = 4
	FlagEnum_JOB_SETUP_FAILED   FlagEnum = 5
	FlagEnum_JOB_DONE           FlagEnum = 6
)

func (FlagEnum) Descriptor added in v0.8.1 

func (FlagEnum) Descriptor() protoreflect.EnumDescriptor

func (FlagEnum) Enum added in v0.8.1 

func (x FlagEnum) Enum() *FlagEnum

func (FlagEnum) EnumDescriptor deprecated 

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

Deprecated: Use FlagEnum.Descriptor instead.

func (FlagEnum) Number added in v0.8.1 

func (x FlagEnum) Number() protoreflect.EnumNumber

func (FlagEnum) String 

func (x FlagEnum) String() string

func (FlagEnum) Type added in v0.8.1 

func (FlagEnum) Type() protoreflect.EnumType

type ListArgs added in v0.9.9 

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

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

Deprecated: Use ListArgs.ProtoReflect.Descriptor instead.

func (*ListArgs) GetNamespace added in v0.9.9 

func (x *ListArgs) GetNamespace() string

func (*ListArgs) GetRoot added in v0.9.9 

func (x *ListArgs) GetRoot() string

func (*ListArgs) ProtoMessage added in v0.9.9 

func (*ListArgs) ProtoMessage()

func (*ListArgs) ProtoReflect added in v0.9.9 

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

func (*ListArgs) Reset added in v0.9.9 

func (x *ListArgs) Reset()

func (*ListArgs) String added in v0.9.9 

func (x *ListArgs) String() string

type ListResp added in v0.9.9 

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

func (*ListResp) Descriptor deprecated added in v0.9.9 

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

Deprecated: Use ListResp.ProtoReflect.Descriptor instead.

func (*ListResp) GetContainers added in v0.9.9 

func (x *ListResp) GetContainers() []*Container

func (*ListResp) ProtoMessage added in v0.9.9 

func (*ListResp) ProtoMessage()

func (*ListResp) ProtoReflect added in v0.9.9 

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

func (*ListResp) Reset added in v0.9.9 

func (x *ListResp) Reset()

func (*ListResp) String added in v0.9.9 

func (x *ListResp) String() string

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
}

Log Streaming args

func (*LogStreamingArgs) Descriptor deprecated 

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

Deprecated: Use LogStreamingArgs.ProtoReflect.Descriptor instead.

func (*LogStreamingArgs) GetLevel 

func (x *LogStreamingArgs) GetLevel() string

func (*LogStreamingArgs) GetMsg 

func (x *LogStreamingArgs) GetMsg() string

func (*LogStreamingArgs) GetSource 

func (x *LogStreamingArgs) GetSource() string

func (*LogStreamingArgs) GetTimestamp 

func (x *LogStreamingArgs) GetTimestamp() string

func (*LogStreamingArgs) ProtoMessage 

func (*LogStreamingArgs) ProtoMessage()

func (*LogStreamingArgs) ProtoReflect added in v0.8.1 

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

func (*LogStreamingArgs) Reset 

func (x *LogStreamingArgs) Reset()

func (*LogStreamingArgs) String 

func (x *LogStreamingArgs) String() string

type LogStreamingResp 

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

func (*LogStreamingResp) Descriptor deprecated 

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

Deprecated: Use LogStreamingResp.ProtoReflect.Descriptor instead.

func (*LogStreamingResp) GetStatus 

func (x *LogStreamingResp) GetStatus() string

func (*LogStreamingResp) ProtoMessage 

func (*LogStreamingResp) ProtoMessage()

func (*LogStreamingResp) ProtoReflect added in v0.8.1 

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

func (*LogStreamingResp) Reset 

func (x *LogStreamingResp) Reset()

func (*LogStreamingResp) String 

func (x *LogStreamingResp) String() string

type MetaStateStreamingArgs 

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

func (*MetaStateStreamingArgs) Descriptor deprecated 

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

Deprecated: Use MetaStateStreamingArgs.ProtoReflect.Descriptor instead.

func (*MetaStateStreamingArgs) GetCheckpointReason 

func (x *MetaStateStreamingArgs) GetCheckpointReason() *CheckpointReason

func (*MetaStateStreamingArgs) GetEvent 

func (x *MetaStateStreamingArgs) GetEvent() *ProviderEvent

func (*MetaStateStreamingArgs) ProtoMessage 

func (*MetaStateStreamingArgs) ProtoMessage()

func (*MetaStateStreamingArgs) ProtoReflect added in v0.8.1 

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

func (*MetaStateStreamingArgs) Reset 

func (x *MetaStateStreamingArgs) Reset()

func (*MetaStateStreamingArgs) String 

func (x *MetaStateStreamingArgs) String() string

type MetaStateStreamingResp 

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

func (*MetaStateStreamingResp) Descriptor deprecated 

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

Deprecated: Use MetaStateStreamingResp.ProtoReflect.Descriptor instead.

func (*MetaStateStreamingResp) GetStatus 

func (x *MetaStateStreamingResp) GetStatus() string

func (*MetaStateStreamingResp) ProtoMessage 

func (*MetaStateStreamingResp) ProtoMessage()

func (*MetaStateStreamingResp) ProtoReflect added in v0.8.1 

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

func (*MetaStateStreamingResp) Reset 

func (x *MetaStateStreamingResp) Reset()

func (*MetaStateStreamingResp) String 

func (x *MetaStateStreamingResp) String() string

type OpenFilesStat 

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

func (*OpenFilesStat) Descriptor deprecated 

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

Deprecated: Use OpenFilesStat.ProtoReflect.Descriptor instead.

func (*OpenFilesStat) GetFd 

func (x *OpenFilesStat) GetFd() uint64

func (*OpenFilesStat) GetMode added in v0.9.7 

func (x *OpenFilesStat) GetMode() string

func (*OpenFilesStat) GetPath 

func (x *OpenFilesStat) GetPath() string

func (*OpenFilesStat) GetStream added in v0.9.7 

func (x *OpenFilesStat) GetStream() OpenFilesStat_StreamType

func (*OpenFilesStat) ProtoMessage 

func (*OpenFilesStat) ProtoMessage()

func (*OpenFilesStat) ProtoReflect added in v0.8.1 

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

func (*OpenFilesStat) Reset 

func (x *OpenFilesStat) Reset()

func (*OpenFilesStat) String 

func (x *OpenFilesStat) String() string

type OpenFilesStat_StreamType added in v0.9.7 

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

func (OpenFilesStat_StreamType) Descriptor added in v0.9.7 

func (OpenFilesStat_StreamType) Descriptor() protoreflect.EnumDescriptor

func (OpenFilesStat_StreamType) Enum added in v0.9.7 

func (x OpenFilesStat_StreamType) Enum() *OpenFilesStat_StreamType

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 (x OpenFilesStat_StreamType) Number() protoreflect.EnumNumber

func (OpenFilesStat_StreamType) String added in v0.9.7 

func (x OpenFilesStat_StreamType) String() string

func (OpenFilesStat_StreamType) Type added in v0.9.7 

func (OpenFilesStat_StreamType) Type() protoreflect.EnumType

type PausePidArgs added in v0.9.5 

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

func (*PausePidArgs) Descriptor deprecated added in v0.9.5 

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

Deprecated: Use PausePidArgs.ProtoReflect.Descriptor instead.

func (*PausePidArgs) GetBundlePath added in v0.9.5 

func (x *PausePidArgs) GetBundlePath() string

func (*PausePidArgs) ProtoMessage added in v0.9.5 

func (*PausePidArgs) ProtoMessage()

func (*PausePidArgs) ProtoReflect added in v0.9.5 

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

func (*PausePidArgs) Reset added in v0.9.5 

func (x *PausePidArgs) Reset()

func (*PausePidArgs) String added in v0.9.5 

func (x *PausePidArgs) String() string

type PausePidResp added in v0.9.5 

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

func (*PausePidResp) Descriptor deprecated added in v0.9.5 

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

Deprecated: Use PausePidResp.ProtoReflect.Descriptor instead.

func (*PausePidResp) GetPausePid added in v0.9.5 

func (x *PausePidResp) GetPausePid() int64

func (*PausePidResp) ProtoMessage added in v0.9.5 

func (*PausePidResp) ProtoMessage()

func (*PausePidResp) ProtoReflect added in v0.9.5 

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

func (*PausePidResp) Reset added in v0.9.5 

func (x *PausePidResp) Reset()

func (*PausePidResp) String added in v0.9.5 

func (x *PausePidResp) String() string

type ProcessInfo 

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

func (*ProcessInfo) Descriptor deprecated 

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

Deprecated: Use ProcessInfo.ProtoReflect.Descriptor instead.

func (*ProcessInfo) GetAttachedToHardwareAccel 

func (x *ProcessInfo) GetAttachedToHardwareAccel() bool

func (*ProcessInfo) GetIsRunning 

func (x *ProcessInfo) GetIsRunning() bool

func (*ProcessInfo) GetMemoryPercent 

func (x *ProcessInfo) GetMemoryPercent() float32

func (*ProcessInfo) GetOpenConnections 

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

func (*ProcessInfo) GetOpenFds 

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

func (*ProcessInfo) GetPID 

func (x *ProcessInfo) GetPID() int32

func (*ProcessInfo) GetStatus 

func (x *ProcessInfo) GetStatus() string

func (*ProcessInfo) GetWorkingDir added in v0.9.7 

func (x *ProcessInfo) GetWorkingDir() string

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) ProtoReflect added in v0.8.1 

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

func (*ProcessInfo) Reset 

func (x *ProcessInfo) Reset()

func (*ProcessInfo) String 

func (x *ProcessInfo) String() string

type ProcessState 

type ProcessState struct {
	PID              int32                             `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	Task             string                            `protobuf:"bytes,2,opt,name=Task,proto3" json:"Task,omitempty"`
	ContainerRuntime ProcessState_ContainerRuntimeOpts `` /* 146-byte string literal not displayed */
	ContainerId      string                            `protobuf:"bytes,4,opt,name=ContainerId,proto3" json:"ContainerId,omitempty"`
	StartedAt        string                            `protobuf:"bytes,5,opt,name=StartedAt,proto3" json:"StartedAt,omitempty"`
	ProcessInfo      *ProcessInfo                      `protobuf:"bytes,6,opt,name=ProcessInfo,proto3" json:"ProcessInfo,omitempty"`
	CheckpointPath   string                            `protobuf:"bytes,7,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	CheckpointState  CheckpointState                   `` /* 126-byte string literal not displayed */
	Flag             FlagEnum                          `protobuf:"varint,9,opt,name=Flag,proto3,enum=cedana.services.task.FlagEnum" json:"Flag,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"`
	// contains filtered or unexported fields
}

func (*ProcessState) Descriptor deprecated 

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

Deprecated: Use ProcessState.ProtoReflect.Descriptor instead.

func (*ProcessState) GetCheckpointPath 

func (x *ProcessState) GetCheckpointPath() string

func (*ProcessState) GetCheckpointState 

func (x *ProcessState) GetCheckpointState() CheckpointState

func (*ProcessState) GetContainerId 

func (x *ProcessState) GetContainerId() string

func (*ProcessState) GetContainerRuntime 

func (x *ProcessState) GetContainerRuntime() ProcessState_ContainerRuntimeOpts

func (*ProcessState) GetFlag 

func (x *ProcessState) GetFlag() FlagEnum

func (*ProcessState) GetGPUCheckpointed added in v0.9.5 

func (x *ProcessState) GetGPUCheckpointed() bool

func (*ProcessState) GetPID 

func (x *ProcessState) GetPID() int32

func (*ProcessState) GetProcessInfo 

func (x *ProcessState) GetProcessInfo() *ProcessInfo

func (*ProcessState) GetRemoteState added in v0.8.9 

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

func (*ProcessState) GetStartedAt 

func (x *ProcessState) GetStartedAt() string

func (*ProcessState) GetTask 

func (x *ProcessState) GetTask() string

func (*ProcessState) ProtoMessage 

func (*ProcessState) ProtoMessage()

func (*ProcessState) ProtoReflect added in v0.8.1 

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

func (*ProcessState) Reset 

func (x *ProcessState) Reset()

func (*ProcessState) String 

func (x *ProcessState) String() string

type ProcessState_ContainerRuntimeOpts 

type ProcessState_ContainerRuntimeOpts int32
const (
	ProcessState_CONTAINERD ProcessState_ContainerRuntimeOpts = 0
	ProcessState_RUNC       ProcessState_ContainerRuntimeOpts = 1
)

func (ProcessState_ContainerRuntimeOpts) Descriptor added in v0.8.1 

func (ProcessState_ContainerRuntimeOpts) Descriptor() protoreflect.EnumDescriptor

func (ProcessState_ContainerRuntimeOpts) Enum added in v0.8.1 

func (x ProcessState_ContainerRuntimeOpts) Enum() *ProcessState_ContainerRuntimeOpts

func (ProcessState_ContainerRuntimeOpts) EnumDescriptor deprecated 

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

Deprecated: Use ProcessState_ContainerRuntimeOpts.Descriptor instead.

func (ProcessState_ContainerRuntimeOpts) Number added in v0.8.1 

func (x ProcessState_ContainerRuntimeOpts) Number() protoreflect.EnumNumber

func (ProcessState_ContainerRuntimeOpts) String 

func (x ProcessState_ContainerRuntimeOpts) String() string

func (ProcessState_ContainerRuntimeOpts) Type added in v0.8.1 

func (ProcessState_ContainerRuntimeOpts) Type() protoreflect.EnumType

type ProviderEvent 

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

func (*ProviderEvent) Descriptor deprecated 

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

Deprecated: Use ProviderEvent.ProtoReflect.Descriptor instead.

func (*ProviderEvent) GetFaultCode 

func (x *ProviderEvent) GetFaultCode() string

func (*ProviderEvent) GetInstanceID 

func (x *ProviderEvent) GetInstanceID() string

func (*ProviderEvent) GetMarkedForTermination 

func (x *ProviderEvent) GetMarkedForTermination() bool

func (*ProviderEvent) GetTerminationTime 

func (x *ProviderEvent) GetTerminationTime() int64

func (*ProviderEvent) ProtoMessage 

func (*ProviderEvent) ProtoMessage()

func (*ProviderEvent) ProtoReflect added in v0.8.1 

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

func (*ProviderEvent) Reset 

func (x *ProviderEvent) Reset()

func (*ProviderEvent) String 

func (x *ProviderEvent) String() string

type 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           RestoreArgs_RestoreType `protobuf:"varint,1,opt,name=Type,proto3,enum=cedana.services.task.RestoreArgs_RestoreType" 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"`
	JobID          string                  `protobuf:"bytes,4,opt,name=JobID,proto3" json:"JobID,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreArgs) Descriptor deprecated 

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

Deprecated: Use RestoreArgs.ProtoReflect.Descriptor instead.

func (*RestoreArgs) GetCheckpointId 

func (x *RestoreArgs) GetCheckpointId() string

func (*RestoreArgs) GetCheckpointPath 

func (x *RestoreArgs) GetCheckpointPath() string

func (*RestoreArgs) GetJobID added in v0.9.9 

func (x *RestoreArgs) GetJobID() string

func (*RestoreArgs) GetType 

func (x *RestoreArgs) GetType() RestoreArgs_RestoreType

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 RestoreArgs_RestoreType 

type RestoreArgs_RestoreType int32
const (
	RestoreArgs_LOCAL  RestoreArgs_RestoreType = 0
	RestoreArgs_REMOTE RestoreArgs_RestoreType = 1
)

func (RestoreArgs_RestoreType) Descriptor added in v0.8.1 

func (RestoreArgs_RestoreType) Descriptor() protoreflect.EnumDescriptor

func (RestoreArgs_RestoreType) Enum added in v0.8.1 

func (x RestoreArgs_RestoreType) Enum() *RestoreArgs_RestoreType

func (RestoreArgs_RestoreType) EnumDescriptor deprecated 

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

Deprecated: Use RestoreArgs_RestoreType.Descriptor instead.

func (RestoreArgs_RestoreType) Number added in v0.8.1 

func (x RestoreArgs_RestoreType) Number() protoreflect.EnumNumber

func (RestoreArgs_RestoreType) String 

func (x RestoreArgs_RestoreType) String() string

func (RestoreArgs_RestoreType) Type added in v0.8.1 

func (RestoreArgs_RestoreType) Type() protoreflect.EnumType

type RestoreResp 

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

func (*RestoreResp) Descriptor deprecated 

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

Deprecated: Use RestoreResp.ProtoReflect.Descriptor instead.

func (*RestoreResp) GetMessage 

func (x *RestoreResp) GetMessage() string

func (*RestoreResp) GetNewPID 

func (x *RestoreResp) GetNewPID() int32

func (*RestoreResp) ProtoMessage 

func (*RestoreResp) ProtoMessage()

func (*RestoreResp) ProtoReflect added in v0.8.1 

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

func (*RestoreResp) Reset 

func (x *RestoreResp) Reset()

func (*RestoreResp) String 

func (x *RestoreResp) String() string

type 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           RuncDumpArgs_DumpType `protobuf:"varint,5,opt,name=Type,proto3,enum=cedana.services.task.RuncDumpArgs_DumpType" json:"Type,omitempty"`
	JobID          string                `protobuf:"bytes,6,opt,name=JobID,proto3" json:"JobID,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 

func (x *RuncDumpArgs) GetContainerId() string

func (*RuncDumpArgs) GetCriuOpts 

func (x *RuncDumpArgs) GetCriuOpts() *CriuOpts

func (*RuncDumpArgs) GetJobID added in v0.9.7 

func (x *RuncDumpArgs) GetJobID() string

func (*RuncDumpArgs) GetRoot 

func (x *RuncDumpArgs) GetRoot() string

func (*RuncDumpArgs) GetType added in v0.9.7 

func (x *RuncDumpArgs) GetType() RuncDumpArgs_DumpType

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

type RuncDumpArgs_DumpType int32
const (
	RuncDumpArgs_LOCAL  RuncDumpArgs_DumpType = 0
	RuncDumpArgs_REMOTE RuncDumpArgs_DumpType = 1
)

func (RuncDumpArgs_DumpType) Descriptor added in v0.9.7 

func (RuncDumpArgs_DumpType) Descriptor() protoreflect.EnumDescriptor

func (RuncDumpArgs_DumpType) Enum added in v0.9.7 

func (x RuncDumpArgs_DumpType) Enum() *RuncDumpArgs_DumpType

func (RuncDumpArgs_DumpType) EnumDescriptor deprecated added in v0.9.7 

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

Deprecated: Use RuncDumpArgs_DumpType.Descriptor instead.

func (RuncDumpArgs_DumpType) Number added in v0.9.7 

func (x RuncDumpArgs_DumpType) Number() protoreflect.EnumNumber

func (RuncDumpArgs_DumpType) String added in v0.9.7 

func (x RuncDumpArgs_DumpType) String() string

func (RuncDumpArgs_DumpType) Type added in v0.9.7 

func (RuncDumpArgs_DumpType) Type() protoreflect.EnumType

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"`
	// 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.7 

func (x *RuncDumpResp) GetCheckpointId() string

func (*RuncDumpResp) GetMessage 

func (x *RuncDumpResp) GetMessage() 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 RuncList added in v0.9.5 

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

func (*RuncList) Descriptor deprecated added in v0.9.5 

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

Deprecated: Use RuncList.ProtoReflect.Descriptor instead.

func (*RuncList) GetContainers added in v0.9.5 

func (x *RuncList) GetContainers() []string

func (*RuncList) ProtoMessage added in v0.9.5 

func (*RuncList) ProtoMessage()

func (*RuncList) ProtoReflect added in v0.9.5 

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

func (*RuncList) Reset added in v0.9.5 

func (x *RuncList) Reset()

func (*RuncList) String added in v0.9.5 

func (x *RuncList) String() string

type RuncOpts 

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

func (*RuncOpts) Descriptor deprecated 

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

Deprecated: Use RuncOpts.ProtoReflect.Descriptor instead.

func (*RuncOpts) GetBundle 

func (x *RuncOpts) GetBundle() string

func (*RuncOpts) GetConsoleSocket 

func (x *RuncOpts) GetConsoleSocket() string

func (*RuncOpts) GetContainerId 

func (x *RuncOpts) GetContainerId() string

func (*RuncOpts) GetDetatch 

func (x *RuncOpts) GetDetatch() bool

func (*RuncOpts) GetKeep 

func (x *RuncOpts) GetKeep() bool

func (*RuncOpts) GetNetPid added in v0.9.5 

func (x *RuncOpts) GetNetPid() int32

func (*RuncOpts) GetNoMountFallback 

func (x *RuncOpts) GetNoMountFallback() bool

func (*RuncOpts) GetNoNewKeyring 

func (x *RuncOpts) GetNoNewKeyring() bool

func (*RuncOpts) GetNoPivot 

func (x *RuncOpts) GetNoPivot() bool

func (*RuncOpts) GetNoSubreaper 

func (x *RuncOpts) GetNoSubreaper() bool

func (*RuncOpts) GetPidFile 

func (x *RuncOpts) GetPidFile() string

func (*RuncOpts) GetPreserveFds 

func (x *RuncOpts) GetPreserveFds() int32

func (*RuncOpts) GetRoot 

func (x *RuncOpts) GetRoot() string

func (*RuncOpts) GetRootless 

func (x *RuncOpts) GetRootless() string

func (*RuncOpts) GetSystemdCgroup 

func (x *RuncOpts) GetSystemdCgroup() bool

func (*RuncOpts) ProtoMessage 

func (*RuncOpts) ProtoMessage()

func (*RuncOpts) ProtoReflect added in v0.8.1 

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

func (*RuncOpts) Reset 

func (x *RuncOpts) Reset()

func (*RuncOpts) String 

func (x *RuncOpts) String() string

type 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         RuncRestoreArgs_RestoreType `protobuf:"varint,5,opt,name=Type,proto3,enum=cedana.services.task.RuncRestoreArgs_RestoreType" 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.7 

func (x *RuncRestoreArgs) GetCheckpointId() string

func (*RuncRestoreArgs) GetContainerId 

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() RuncRestoreArgs_RestoreType

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

type RuncRestoreArgs_RestoreType int32
const (
	RuncRestoreArgs_LOCAL  RuncRestoreArgs_RestoreType = 0
	RuncRestoreArgs_REMOTE RuncRestoreArgs_RestoreType = 1
)

func (RuncRestoreArgs_RestoreType) Descriptor added in v0.9.7 

func (RuncRestoreArgs_RestoreType) Descriptor() protoreflect.EnumDescriptor

func (RuncRestoreArgs_RestoreType) Enum added in v0.9.7 

func (x RuncRestoreArgs_RestoreType) Enum() *RuncRestoreArgs_RestoreType

func (RuncRestoreArgs_RestoreType) EnumDescriptor deprecated added in v0.9.7 

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

Deprecated: Use RuncRestoreArgs_RestoreType.Descriptor instead.

func (RuncRestoreArgs_RestoreType) Number added in v0.9.7 

func (x RuncRestoreArgs_RestoreType) Number() protoreflect.EnumNumber

func (RuncRestoreArgs_RestoreType) String added in v0.9.7 

func (x RuncRestoreArgs_RestoreType) String() string

func (RuncRestoreArgs_RestoreType) Type added in v0.9.7 

func (RuncRestoreArgs_RestoreType) Type() protoreflect.EnumType

type RuncRestoreResp 

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

func (*RuncRestoreResp) Descriptor deprecated 

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

Deprecated: Use RuncRestoreResp.ProtoReflect.Descriptor instead.

func (*RuncRestoreResp) GetMessage 

func (x *RuncRestoreResp) GetMessage() string

func (*RuncRestoreResp) ProtoMessage 

func (*RuncRestoreResp) ProtoMessage()

func (*RuncRestoreResp) ProtoReflect added in v0.8.1 

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

func (*RuncRestoreResp) Reset 

func (x *RuncRestoreResp) Reset()

func (*RuncRestoreResp) String 

func (x *RuncRestoreResp) String() string

type RuncRoot added in v0.9.5 

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

func (*RuncRoot) Descriptor deprecated added in v0.9.5 

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

Deprecated: Use RuncRoot.ProtoReflect.Descriptor instead.

func (*RuncRoot) GetRoot added in v0.9.5 

func (x *RuncRoot) GetRoot() string

func (*RuncRoot) ProtoMessage added in v0.9.5 

func (*RuncRoot) ProtoMessage()

func (*RuncRoot) ProtoReflect added in v0.9.5 

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

func (*RuncRoot) Reset added in v0.9.5 

func (x *RuncRoot) Reset()

func (*RuncRoot) String added in v0.9.5 

func (x *RuncRoot) String() string

type StartTaskArgs 

type StartTaskArgs struct {
	Task          string `protobuf:"bytes,1,opt,name=Task,proto3" json:"Task,omitempty"`
	Id            string `protobuf:"bytes,2,opt,name=Id,proto3" json:"Id,omitempty"`
	WorkingDir    string `protobuf:"bytes,3,opt,name=WorkingDir,proto3" json:"WorkingDir,omitempty"`
	LogOutputFile string `protobuf:"bytes,4,opt,name=LogOutputFile,proto3" json:"LogOutputFile,omitempty"`
	UID           uint32 `protobuf:"varint,5,opt,name=UID,proto3" json:"UID,omitempty"`
	GID           uint32 `protobuf:"varint,6,opt,name=GID,proto3" json:"GID,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTaskArgs) Descriptor deprecated 

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

Deprecated: Use StartTaskArgs.ProtoReflect.Descriptor instead.

func (*StartTaskArgs) GetGID added in v0.9.5 

func (x *StartTaskArgs) GetGID() uint32

func (*StartTaskArgs) GetId 

func (x *StartTaskArgs) GetId() string

func (*StartTaskArgs) GetLogOutputFile added in v0.8.1 

func (x *StartTaskArgs) GetLogOutputFile() string

func (*StartTaskArgs) GetTask 

func (x *StartTaskArgs) GetTask() string

func (*StartTaskArgs) GetUID added in v0.9.5 

func (x *StartTaskArgs) GetUID() uint32

func (*StartTaskArgs) GetWorkingDir added in v0.8.1 

func (x *StartTaskArgs) GetWorkingDir() string

func (*StartTaskArgs) ProtoMessage 

func (*StartTaskArgs) ProtoMessage()

func (*StartTaskArgs) ProtoReflect added in v0.8.1 

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

func (*StartTaskArgs) Reset 

func (x *StartTaskArgs) Reset()

func (*StartTaskArgs) String 

func (x *StartTaskArgs) String() string

type StartTaskResp 

type StartTaskResp 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"`
	// contains filtered or unexported fields
}

func (*StartTaskResp) Descriptor deprecated 

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

Deprecated: Use StartTaskResp.ProtoReflect.Descriptor instead.

func (*StartTaskResp) GetMessage 

func (x *StartTaskResp) GetMessage() string

func (*StartTaskResp) GetPID 

func (x *StartTaskResp) GetPID() int32

func (*StartTaskResp) ProtoMessage 

func (*StartTaskResp) ProtoMessage()

func (*StartTaskResp) ProtoReflect added in v0.8.1 

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

func (*StartTaskResp) Reset 

func (x *StartTaskResp) Reset()

func (*StartTaskResp) String 

func (x *StartTaskResp) String() string

type TaskServiceClient 

type TaskServiceClient interface {
	Dump(ctx context.Context, in *DumpArgs, opts ...grpc.CallOption) (*DumpResp, error)
	Restore(ctx context.Context, in *RestoreArgs, opts ...grpc.CallOption) (*RestoreResp, error)
	ContainerDump(ctx context.Context, in *ContainerDumpArgs, opts ...grpc.CallOption) (*ContainerDumpResp, error)
	ContainerRestore(ctx context.Context, in *ContainerRestoreArgs, opts ...grpc.CallOption) (*ContainerRestoreResp, error)
	RuncDump(ctx context.Context, in *RuncDumpArgs, opts ...grpc.CallOption) (*RuncDumpResp, error)
	RuncRestore(ctx context.Context, in *RuncRestoreArgs, opts ...grpc.CallOption) (*RuncRestoreResp, error)
	StartTask(ctx context.Context, in *StartTaskArgs, opts ...grpc.CallOption) (*StartTaskResp, error)
	LogStreaming(ctx context.Context, opts ...grpc.CallOption) (TaskService_LogStreamingClient, error)
	ClientStateStreaming(ctx context.Context, opts ...grpc.CallOption) (TaskService_ClientStateStreamingClient, error)
	MetaStateStreaming(ctx context.Context, opts ...grpc.CallOption) (TaskService_MetaStateStreamingClient, error)
	ListRuncContainers(ctx context.Context, in *RuncRoot, opts ...grpc.CallOption) (*RuncList, error)
	GetRuncContainerByName(ctx context.Context, in *CtrByNameArgs, opts ...grpc.CallOption) (*CtrByNameResp, error)
	GetPausePid(ctx context.Context, in *PausePidArgs, opts ...grpc.CallOption) (*PausePidResp, error)
	ListContainers(ctx context.Context, in *ListArgs, opts ...grpc.CallOption) (*ListResp, error)
}

TaskServiceClient is the client API for TaskService service.

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

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	Dump(context.Context, *DumpArgs) (*DumpResp, error)
	Restore(context.Context, *RestoreArgs) (*RestoreResp, error)
	ContainerDump(context.Context, *ContainerDumpArgs) (*ContainerDumpResp, error)
	ContainerRestore(context.Context, *ContainerRestoreArgs) (*ContainerRestoreResp, error)
	RuncDump(context.Context, *RuncDumpArgs) (*RuncDumpResp, error)
	RuncRestore(context.Context, *RuncRestoreArgs) (*RuncRestoreResp, error)
	StartTask(context.Context, *StartTaskArgs) (*StartTaskResp, error)
	LogStreaming(TaskService_LogStreamingServer) error
	ClientStateStreaming(TaskService_ClientStateStreamingServer) error
	MetaStateStreaming(TaskService_MetaStateStreamingServer) error
	ListRuncContainers(context.Context, *RuncRoot) (*RuncList, error)
	GetRuncContainerByName(context.Context, *CtrByNameArgs) (*CtrByNameResp, error)
	GetPausePid(context.Context, *PausePidArgs) (*PausePidResp, error)
	ListContainers(context.Context, *ListArgs) (*ListResp, error)
	// contains filtered or unexported methods
}

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

type TaskService_ClientStateStreamingClient 

type TaskService_ClientStateStreamingClient interface {
	Send(*ClientStateStreamingResp) error
	Recv() (*ProcessState, error)
	grpc.ClientStream
}

type TaskService_ClientStateStreamingServer 

type TaskService_ClientStateStreamingServer interface {
	Send(*ProcessState) error
	Recv() (*ClientStateStreamingResp, error)
	grpc.ServerStream
}

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_MetaStateStreamingClient 

type TaskService_MetaStateStreamingClient interface {
	Send(*MetaStateStreamingArgs) error
	Recv() (*MetaStateStreamingResp, error)
	grpc.ClientStream
}

type TaskService_MetaStateStreamingServer 

type TaskService_MetaStateStreamingServer interface {
	Send(*MetaStateStreamingResp) error
	Recv() (*MetaStateStreamingArgs, error)
	grpc.ServerStream
}

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) ClientStateStreaming 

func (UnimplementedTaskServiceServer) ClientStateStreaming(TaskService_ClientStateStreamingServer) error

func (UnimplementedTaskServiceServer) ContainerDump 

func (UnimplementedTaskServiceServer) ContainerDump(context.Context, *ContainerDumpArgs) (*ContainerDumpResp, error)

func (UnimplementedTaskServiceServer) ContainerRestore 

func (UnimplementedTaskServiceServer) ContainerRestore(context.Context, *ContainerRestoreArgs) (*ContainerRestoreResp, error)

func (UnimplementedTaskServiceServer) Dump 

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

func (UnimplementedTaskServiceServer) GetPausePid added in v0.9.5 

func (UnimplementedTaskServiceServer) GetPausePid(context.Context, *PausePidArgs) (*PausePidResp, error)

func (UnimplementedTaskServiceServer) GetRuncContainerByName added in v0.9.5 

func (UnimplementedTaskServiceServer) GetRuncContainerByName(context.Context, *CtrByNameArgs) (*CtrByNameResp, error)

func (UnimplementedTaskServiceServer) ListContainers added in v0.9.9 

func (UnimplementedTaskServiceServer) ListContainers(context.Context, *ListArgs) (*ListResp, error)

func (UnimplementedTaskServiceServer) ListRuncContainers added in v0.9.5 

func (UnimplementedTaskServiceServer) ListRuncContainers(context.Context, *RuncRoot) (*RuncList, error)

func (UnimplementedTaskServiceServer) LogStreaming 

func (UnimplementedTaskServiceServer) LogStreaming(TaskService_LogStreamingServer) error

func (UnimplementedTaskServiceServer) MetaStateStreaming 

func (UnimplementedTaskServiceServer) MetaStateStreaming(TaskService_MetaStateStreamingServer) error

func (UnimplementedTaskServiceServer) Restore 

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

func (UnimplementedTaskServiceServer) RuncDump 

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

func (UnimplementedTaskServiceServer) RuncRestore 

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

func (UnimplementedTaskServiceServer) StartTask 

func (UnimplementedTaskServiceServer) StartTask(context.Context, *StartTaskArgs) (*StartTaskResp, error)

type UnsafeTaskServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.