Documentation
¶
Index ¶
- Variables
- func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)
- type Addr
- type CPUInfo
- func (*CPUInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CPUInfo) GetCPU() int32
- func (x *CPUInfo) GetCount() int32
- func (x *CPUInfo) GetFamily() string
- func (x *CPUInfo) GetPhysicalID() string
- func (x *CPUInfo) GetVendorID() string
- func (*CPUInfo) ProtoMessage()
- func (x *CPUInfo) ProtoReflect() protoreflect.Message
- func (x *CPUInfo) Reset()
- func (x *CPUInfo) String() string
- type CRIOImagePushArgs
- func (*CRIOImagePushArgs) Descriptor() ([]byte, []int)deprecated
- func (x *CRIOImagePushArgs) GetContainerStorage() string
- func (x *CRIOImagePushArgs) GetNewImageRef() string
- func (x *CRIOImagePushArgs) GetOriginalImageRef() string
- func (x *CRIOImagePushArgs) GetRegistryAuthToken() string
- func (x *CRIOImagePushArgs) GetRootfsDiffPath() string
- func (*CRIOImagePushArgs) ProtoMessage()
- func (x *CRIOImagePushArgs) ProtoReflect() protoreflect.Message
- func (x *CRIOImagePushArgs) Reset()
- func (x *CRIOImagePushArgs) String() string
- type CRIOImagePushResp
- type CRIORootfsDumpArgs
- func (*CRIORootfsDumpArgs) Descriptor() ([]byte, []int)deprecated
- func (x *CRIORootfsDumpArgs) GetContainerID() string
- func (x *CRIORootfsDumpArgs) GetContainerStorage() string
- func (x *CRIORootfsDumpArgs) GetDest() string
- func (x *CRIORootfsDumpArgs) GetRegistryAuthToken() string
- func (*CRIORootfsDumpArgs) ProtoMessage()
- func (x *CRIORootfsDumpArgs) ProtoReflect() protoreflect.Message
- func (x *CRIORootfsDumpArgs) Reset()
- func (x *CRIORootfsDumpArgs) String() string
- type CRIORootfsDumpResp
- func (*CRIORootfsDumpResp) Descriptor() ([]byte, []int)deprecated
- func (x *CRIORootfsDumpResp) GetDest() string
- func (*CRIORootfsDumpResp) ProtoMessage()
- func (x *CRIORootfsDumpResp) ProtoReflect() protoreflect.Message
- func (x *CRIORootfsDumpResp) Reset()
- func (x *CRIORootfsDumpResp) String() string
- type CRType
- type CheckpointFileStats
- func (*CheckpointFileStats) Descriptor() ([]byte, []int)deprecated
- func (x *CheckpointFileStats) GetDuration() int64
- func (x *CheckpointFileStats) GetSize() int64
- func (*CheckpointFileStats) ProtoMessage()
- func (x *CheckpointFileStats) ProtoReflect() protoreflect.Message
- func (x *CheckpointFileStats) Reset()
- func (x *CheckpointFileStats) String() string
- type CheckpointReason
- func (*CheckpointReason) Descriptor() ([]byte, []int)deprecated
- func (x *CheckpointReason) GetReason() CheckpointReason_CheckpointReasonEnum
- func (*CheckpointReason) ProtoMessage()
- func (x *CheckpointReason) ProtoReflect() protoreflect.Message
- func (x *CheckpointReason) Reset()
- func (x *CheckpointReason) String() string
- type CheckpointReason_CheckpointReasonEnum
- func (CheckpointReason_CheckpointReasonEnum) Descriptor() protoreflect.EnumDescriptor
- func (x CheckpointReason_CheckpointReasonEnum) Enum() *CheckpointReason_CheckpointReasonEnum
- func (CheckpointReason_CheckpointReasonEnum) EnumDescriptor() ([]byte, []int)deprecated
- func (x CheckpointReason_CheckpointReasonEnum) Number() protoreflect.EnumNumber
- func (x CheckpointReason_CheckpointReasonEnum) String() string
- func (CheckpointReason_CheckpointReasonEnum) Type() protoreflect.EnumType
- type CheckpointState
- func (CheckpointState) Descriptor() protoreflect.EnumDescriptor
- func (x CheckpointState) Enum() *CheckpointState
- func (CheckpointState) EnumDescriptor() ([]byte, []int)deprecated
- func (x CheckpointState) Number() protoreflect.EnumNumber
- func (x CheckpointState) String() string
- func (CheckpointState) Type() protoreflect.EnumType
- type ConnectionStat
- func (*ConnectionStat) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionStat) GetFamily() uint32
- func (x *ConnectionStat) GetFd() uint32
- func (x *ConnectionStat) GetLaddr() *Addr
- func (x *ConnectionStat) GetPID() int32
- func (x *ConnectionStat) GetRaddr() *Addr
- func (x *ConnectionStat) GetStatus() string
- func (x *ConnectionStat) GetType() uint32
- func (x *ConnectionStat) GetUIDs() []int32
- func (*ConnectionStat) ProtoMessage()
- func (x *ConnectionStat) ProtoReflect() protoreflect.Message
- func (x *ConnectionStat) Reset()
- func (x *ConnectionStat) String() string
- type ContainerRuntime
- func (ContainerRuntime) Descriptor() protoreflect.EnumDescriptor
- func (x ContainerRuntime) Enum() *ContainerRuntime
- func (ContainerRuntime) EnumDescriptor() ([]byte, []int)deprecated
- func (x ContainerRuntime) Number() protoreflect.EnumNumber
- func (x ContainerRuntime) String() string
- func (ContainerRuntime) Type() protoreflect.EnumType
- type ContainerdContainer
- func (*ContainerdContainer) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdContainer) GetContainerName() string
- func (x *ContainerdContainer) GetImageName() string
- func (x *ContainerdContainer) GetSandboxId() string
- func (x *ContainerdContainer) GetSandboxName() string
- func (x *ContainerdContainer) GetSandboxNamespace() string
- func (x *ContainerdContainer) GetSandboxUid() string
- func (*ContainerdContainer) ProtoMessage()
- func (x *ContainerdContainer) ProtoReflect() protoreflect.Message
- func (x *ContainerdContainer) Reset()
- func (x *ContainerdContainer) String() string
- type ContainerdDumpArgs
- func (*ContainerdDumpArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdDumpArgs) GetContainerdRootfsDumpArgs() *ContainerdRootfsDumpArgs
- func (x *ContainerdDumpArgs) GetRuncDumpArgs() *RuncDumpArgs
- func (*ContainerdDumpArgs) ProtoMessage()
- func (x *ContainerdDumpArgs) ProtoReflect() protoreflect.Message
- func (x *ContainerdDumpArgs) Reset()
- func (x *ContainerdDumpArgs) String() string
- type ContainerdDumpResp
- func (*ContainerdDumpResp) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdDumpResp) GetCheckpointPath() string
- func (x *ContainerdDumpResp) GetMessage() string
- func (*ContainerdDumpResp) ProtoMessage()
- func (x *ContainerdDumpResp) ProtoReflect() protoreflect.Message
- func (x *ContainerdDumpResp) Reset()
- func (x *ContainerdDumpResp) String() string
- type ContainerdQueryArgs
- func (*ContainerdQueryArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdQueryArgs) GetNamespace() string
- func (x *ContainerdQueryArgs) GetRoot() string
- func (*ContainerdQueryArgs) ProtoMessage()
- func (x *ContainerdQueryArgs) ProtoReflect() protoreflect.Message
- func (x *ContainerdQueryArgs) Reset()
- func (x *ContainerdQueryArgs) String() string
- type ContainerdQueryResp
- func (*ContainerdQueryResp) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdQueryResp) GetContainers() []*ContainerdContainer
- func (*ContainerdQueryResp) ProtoMessage()
- func (x *ContainerdQueryResp) ProtoReflect() protoreflect.Message
- func (x *ContainerdQueryResp) Reset()
- func (x *ContainerdQueryResp) String() string
- type ContainerdRestoreArgs
- func (*ContainerdRestoreArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdRestoreArgs) GetContainerID() string
- func (x *ContainerdRestoreArgs) GetImgPath() string
- func (*ContainerdRestoreArgs) ProtoMessage()
- func (x *ContainerdRestoreArgs) ProtoReflect() protoreflect.Message
- func (x *ContainerdRestoreArgs) Reset()
- func (x *ContainerdRestoreArgs) String() string
- type ContainerdRestoreResp
- func (*ContainerdRestoreResp) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdRestoreResp) GetMessage() string
- func (*ContainerdRestoreResp) ProtoMessage()
- func (x *ContainerdRestoreResp) ProtoReflect() protoreflect.Message
- func (x *ContainerdRestoreResp) Reset()
- func (x *ContainerdRestoreResp) String() string
- type ContainerdRootfsDumpArgs
- func (*ContainerdRootfsDumpArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdRootfsDumpArgs) GetAddress() string
- func (x *ContainerdRootfsDumpArgs) GetContainerID() string
- func (x *ContainerdRootfsDumpArgs) GetImageRef() string
- func (x *ContainerdRootfsDumpArgs) GetNamespace() string
- func (*ContainerdRootfsDumpArgs) ProtoMessage()
- func (x *ContainerdRootfsDumpArgs) ProtoReflect() protoreflect.Message
- func (x *ContainerdRootfsDumpArgs) Reset()
- func (x *ContainerdRootfsDumpArgs) String() string
- type ContainerdRootfsDumpResp
- func (*ContainerdRootfsDumpResp) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdRootfsDumpResp) GetImageRef() string
- func (*ContainerdRootfsDumpResp) ProtoMessage()
- func (x *ContainerdRootfsDumpResp) ProtoReflect() protoreflect.Message
- func (x *ContainerdRootfsDumpResp) Reset()
- func (x *ContainerdRootfsDumpResp) String() string
- type ContainerdRootfsRestoreArgs
- func (*ContainerdRootfsRestoreArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdRootfsRestoreArgs) GetAddress() string
- func (x *ContainerdRootfsRestoreArgs) GetContainerID() string
- func (x *ContainerdRootfsRestoreArgs) GetImageRef() string
- func (x *ContainerdRootfsRestoreArgs) GetNamespace() string
- func (*ContainerdRootfsRestoreArgs) ProtoMessage()
- func (x *ContainerdRootfsRestoreArgs) ProtoReflect() protoreflect.Message
- func (x *ContainerdRootfsRestoreArgs) Reset()
- func (x *ContainerdRootfsRestoreArgs) String() string
- type ContainerdRootfsRestoreResp
- func (*ContainerdRootfsRestoreResp) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerdRootfsRestoreResp) GetImageRef() string
- func (*ContainerdRootfsRestoreResp) ProtoMessage()
- func (x *ContainerdRootfsRestoreResp) ProtoReflect() protoreflect.Message
- func (x *ContainerdRootfsRestoreResp) Reset()
- func (x *ContainerdRootfsRestoreResp) String() string
- type CriuOpts
- func (*CriuOpts) Descriptor() ([]byte, []int)deprecated
- func (x *CriuOpts) GetAutoDedup() bool
- func (x *CriuOpts) GetEmptyNs() int32
- func (x *CriuOpts) GetExternal() []string
- func (x *CriuOpts) GetExternalUnixConnections() bool
- func (x *CriuOpts) GetFileLocks() bool
- func (x *CriuOpts) GetImagesDirectory() string
- func (x *CriuOpts) GetLazyPages() bool
- func (x *CriuOpts) GetLeaveRunning() bool
- func (x *CriuOpts) GetLsmMountContext() string
- func (x *CriuOpts) GetLsmProfile() string
- func (x *CriuOpts) GetParentImage() string
- func (x *CriuOpts) GetPreDump() bool
- func (x *CriuOpts) GetShellJob() bool
- func (x *CriuOpts) GetStatusFd() int32
- func (x *CriuOpts) GetTcpEstablished() bool
- func (x *CriuOpts) GetWorkDirectory() string
- func (*CriuOpts) ProtoMessage()
- func (x *CriuOpts) ProtoReflect() protoreflect.Message
- func (x *CriuOpts) Reset()
- func (x *CriuOpts) String() string
- type DetailedHealthCheckRequest
- func (*DetailedHealthCheckRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DetailedHealthCheckRequest) GetGID() int32
- func (x *DetailedHealthCheckRequest) GetGroups() []int32
- func (x *DetailedHealthCheckRequest) GetUID() int32
- func (*DetailedHealthCheckRequest) ProtoMessage()
- func (x *DetailedHealthCheckRequest) ProtoReflect() protoreflect.Message
- func (x *DetailedHealthCheckRequest) Reset()
- func (x *DetailedHealthCheckRequest) String() string
- type DetailedHealthCheckResponse
- func (*DetailedHealthCheckResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DetailedHealthCheckResponse) GetHealthCheckStats() *HealthCheckStats
- func (x *DetailedHealthCheckResponse) GetUnhealthyReasons() []string
- func (*DetailedHealthCheckResponse) ProtoMessage()
- func (x *DetailedHealthCheckResponse) ProtoReflect() protoreflect.Message
- func (x *DetailedHealthCheckResponse) Reset()
- func (x *DetailedHealthCheckResponse) String() string
- type DumpArgs
- func (*DumpArgs) Descriptor() ([]byte, []int)deprecated
- func (x *DumpArgs) GetDir() string
- func (x *DumpArgs) GetGPU() bool
- func (x *DumpArgs) GetJID() string
- func (x *DumpArgs) GetPID() int32
- func (x *DumpArgs) GetTcpEstablished() bool
- func (x *DumpArgs) GetType() CRType
- func (*DumpArgs) ProtoMessage()
- func (x *DumpArgs) ProtoReflect() protoreflect.Message
- func (x *DumpArgs) Reset()
- func (x *DumpArgs) String() string
- type DumpResp
- func (*DumpResp) Descriptor() ([]byte, []int)deprecated
- func (x *DumpResp) GetCheckpointID() string
- func (x *DumpResp) GetDumpStats() *DumpStats
- func (x *DumpResp) GetMessage() string
- func (x *DumpResp) GetState() *ProcessState
- func (x *DumpResp) GetUploadID() string
- func (*DumpResp) ProtoMessage()
- func (x *DumpResp) ProtoReflect() protoreflect.Message
- func (x *DumpResp) Reset()
- func (x *DumpResp) String() string
- type DumpStats
- func (*DumpStats) Descriptor() ([]byte, []int)deprecated
- func (x *DumpStats) GetCRIUDuration() int64
- func (x *DumpStats) GetCheckpointFileStats() *CheckpointFileStats
- func (x *DumpStats) GetContainerRuntime() ContainerRuntime
- func (x *DumpStats) GetDumpType() DumpType
- func (x *DumpStats) GetGPUDuration() int64
- func (x *DumpStats) GetKubernetes() bool
- func (x *DumpStats) GetPrepareDuration() int64
- func (x *DumpStats) GetUploadDuration() int64
- func (*DumpStats) ProtoMessage()
- func (x *DumpStats) ProtoReflect() protoreflect.Message
- func (x *DumpStats) Reset()
- func (x *DumpStats) String() string
- type DumpType
- type GetConfigRequest
- type GetConfigResponse
- type HealthCheckStats
- func (*HealthCheckStats) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCheckStats) GetCriuVersion() string
- func (x *HealthCheckStats) GetGPUHealthCheck() *gpu.HealthCheckResponse
- func (*HealthCheckStats) ProtoMessage()
- func (x *HealthCheckStats) ProtoReflect() protoreflect.Message
- func (x *HealthCheckStats) Reset()
- func (x *HealthCheckStats) String() string
- type HostInfo
- func (*HostInfo) Descriptor() ([]byte, []int)deprecated
- func (x *HostInfo) GetHostID() string
- func (x *HostInfo) GetHostname() string
- func (x *HostInfo) GetKernelArch() string
- func (x *HostInfo) GetKernelVersion() string
- func (x *HostInfo) GetOS() string
- func (x *HostInfo) GetPlatform() string
- func (x *HostInfo) GetVirtualizationRole() string
- func (x *HostInfo) GetVirtualizationSystem() string
- func (*HostInfo) ProtoMessage()
- func (x *HostInfo) ProtoReflect() protoreflect.Message
- func (x *HostInfo) Reset()
- func (x *HostInfo) String() string
- type JobState
- type LogStreamingArgs
- func (*LogStreamingArgs) Descriptor() ([]byte, []int)deprecated
- func (x *LogStreamingArgs) GetLevel() string
- func (x *LogStreamingArgs) GetMsg() string
- func (x *LogStreamingArgs) GetSource() string
- func (x *LogStreamingArgs) GetTimestamp() string
- func (*LogStreamingArgs) ProtoMessage()
- func (x *LogStreamingArgs) ProtoReflect() protoreflect.Message
- func (x *LogStreamingArgs) Reset()
- func (x *LogStreamingArgs) String() string
- type LogStreamingResp
- type MemoryInfo
- func (*MemoryInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MemoryInfo) GetAvailable() uint64
- func (x *MemoryInfo) GetTotal() uint64
- func (x *MemoryInfo) GetUsed() uint64
- func (*MemoryInfo) ProtoMessage()
- func (x *MemoryInfo) ProtoReflect() protoreflect.Message
- func (x *MemoryInfo) Reset()
- func (x *MemoryInfo) String() string
- type OpenFilesStat
- func (*OpenFilesStat) Descriptor() ([]byte, []int)deprecated
- func (x *OpenFilesStat) GetFd() uint64
- func (x *OpenFilesStat) GetMode() string
- func (x *OpenFilesStat) GetPath() string
- func (x *OpenFilesStat) GetStream() OpenFilesStat_StreamType
- func (*OpenFilesStat) ProtoMessage()
- func (x *OpenFilesStat) ProtoReflect() protoreflect.Message
- func (x *OpenFilesStat) Reset()
- func (x *OpenFilesStat) String() string
- type OpenFilesStat_StreamType
- func (OpenFilesStat_StreamType) Descriptor() protoreflect.EnumDescriptor
- func (x OpenFilesStat_StreamType) Enum() *OpenFilesStat_StreamType
- func (OpenFilesStat_StreamType) EnumDescriptor() ([]byte, []int)deprecated
- func (x OpenFilesStat_StreamType) Number() protoreflect.EnumNumber
- func (x OpenFilesStat_StreamType) String() string
- func (OpenFilesStat_StreamType) Type() protoreflect.EnumType
- type ProcessInfo
- func (*ProcessInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessInfo) GetAttachedToHardwareAccel() bool
- func (x *ProcessInfo) GetIsRunning() bool
- func (x *ProcessInfo) GetMemoryPercent() float32
- func (x *ProcessInfo) GetOpenConnections() []*ConnectionStat
- func (x *ProcessInfo) GetOpenFds() []*OpenFilesStat
- func (x *ProcessInfo) GetPID() int32
- func (x *ProcessInfo) GetStatus() string
- func (x *ProcessInfo) GetWorkingDir() string
- func (*ProcessInfo) ProtoMessage()
- func (x *ProcessInfo) ProtoReflect() protoreflect.Message
- func (x *ProcessInfo) Reset()
- func (x *ProcessInfo) String() string
- type ProcessState
- func (*ProcessState) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessState) GetCPUInfo() *CPUInfo
- func (x *ProcessState) GetCheckpointPath() string
- func (x *ProcessState) GetCheckpointState() CheckpointState
- func (x *ProcessState) GetContainerID() string
- func (x *ProcessState) GetGIDs() []int32
- func (x *ProcessState) GetGPUCheckpointed() bool
- func (x *ProcessState) GetGroups() []int32
- func (x *ProcessState) GetHostInfo() *HostInfo
- func (x *ProcessState) GetJID() string
- func (x *ProcessState) GetJobState() JobState
- func (x *ProcessState) GetMemoryInfo() *MemoryInfo
- func (x *ProcessState) GetPID() int32
- func (x *ProcessState) GetProcessInfo() *ProcessInfo
- func (x *ProcessState) GetRemoteState() []*RemoteState
- func (x *ProcessState) GetStartedAt() string
- func (x *ProcessState) GetTask() string
- func (x *ProcessState) GetUIDs() []int32
- func (*ProcessState) ProtoMessage()
- func (x *ProcessState) ProtoReflect() protoreflect.Message
- func (x *ProcessState) Reset()
- func (x *ProcessState) String() string
- type ProcessStateStreamingArgs
- func (*ProcessStateStreamingArgs) Descriptor() ([]byte, []int)deprecated
- func (x *ProcessStateStreamingArgs) GetJID() string
- func (*ProcessStateStreamingArgs) ProtoMessage()
- func (x *ProcessStateStreamingArgs) ProtoReflect() protoreflect.Message
- func (x *ProcessStateStreamingArgs) Reset()
- func (x *ProcessStateStreamingArgs) String() string
- type QueryArgs
- type QueryResp
- type RemoteState
- func (*RemoteState) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteState) GetCheckpointID() string
- func (x *RemoteState) GetTimestamp() int64
- func (x *RemoteState) GetUploadID() string
- func (*RemoteState) ProtoMessage()
- func (x *RemoteState) ProtoReflect() protoreflect.Message
- func (x *RemoteState) Reset()
- func (x *RemoteState) String() string
- type RestoreArgs
- func (*RestoreArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RestoreArgs) GetCheckpointID() string
- func (x *RestoreArgs) GetCheckpointPath() string
- func (x *RestoreArgs) GetGID() int32
- func (x *RestoreArgs) GetGroups() []int32
- func (x *RestoreArgs) GetJID() string
- func (x *RestoreArgs) GetTcpEstablished() bool
- func (x *RestoreArgs) GetType() CRType
- func (x *RestoreArgs) GetUID() int32
- func (*RestoreArgs) ProtoMessage()
- func (x *RestoreArgs) ProtoReflect() protoreflect.Message
- func (x *RestoreArgs) Reset()
- func (x *RestoreArgs) String() string
- type RestoreResp
- func (*RestoreResp) Descriptor() ([]byte, []int)deprecated
- func (x *RestoreResp) GetMessage() string
- func (x *RestoreResp) GetNewPID() int32
- func (x *RestoreResp) GetRestoreStats() *RestoreStats
- func (x *RestoreResp) GetState() *ProcessState
- func (*RestoreResp) ProtoMessage()
- func (x *RestoreResp) ProtoReflect() protoreflect.Message
- func (x *RestoreResp) Reset()
- func (x *RestoreResp) String() string
- type RestoreStats
- func (*RestoreStats) Descriptor() ([]byte, []int)deprecated
- func (x *RestoreStats) GetCRIUDuration() int64
- func (x *RestoreStats) GetCheckpointFileStats() *CheckpointFileStats
- func (x *RestoreStats) GetContainerRuntime() ContainerRuntime
- func (x *RestoreStats) GetDownloadDuration() int64
- func (x *RestoreStats) GetDumpType() DumpType
- func (x *RestoreStats) GetGPUDuration() int64
- func (x *RestoreStats) GetGPURestoreStats() *gpu.GPURestoreStats
- func (x *RestoreStats) GetPrepareDuration() int64
- func (*RestoreStats) ProtoMessage()
- func (x *RestoreStats) ProtoReflect() protoreflect.Message
- func (x *RestoreStats) Reset()
- func (x *RestoreStats) String() string
- type RuncContainer
- func (*RuncContainer) Descriptor() ([]byte, []int)deprecated
- func (x *RuncContainer) GetBundlePath() string
- func (x *RuncContainer) GetContainerName() string
- func (x *RuncContainer) GetID() string
- func (x *RuncContainer) GetImageName() string
- func (x *RuncContainer) GetSandboxId() string
- func (x *RuncContainer) GetSandboxName() string
- func (x *RuncContainer) GetSandboxUid() string
- func (*RuncContainer) ProtoMessage()
- func (x *RuncContainer) ProtoReflect() protoreflect.Message
- func (x *RuncContainer) Reset()
- func (x *RuncContainer) String() string
- type RuncDumpArgs
- func (*RuncDumpArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RuncDumpArgs) GetCheckpointPath() string
- func (x *RuncDumpArgs) GetContainerID() string
- func (x *RuncDumpArgs) GetCriuOpts() *CriuOpts
- func (x *RuncDumpArgs) GetGPU() bool
- func (x *RuncDumpArgs) GetPid() int32
- func (x *RuncDumpArgs) GetRoot() string
- func (x *RuncDumpArgs) GetState() *ProcessState
- func (x *RuncDumpArgs) GetType() CRType
- func (*RuncDumpArgs) ProtoMessage()
- func (x *RuncDumpArgs) ProtoReflect() protoreflect.Message
- func (x *RuncDumpArgs) Reset()
- func (x *RuncDumpArgs) String() string
- type RuncDumpResp
- func (*RuncDumpResp) Descriptor() ([]byte, []int)deprecated
- func (x *RuncDumpResp) GetCheckpointID() string
- func (x *RuncDumpResp) GetMessage() string
- func (x *RuncDumpResp) GetState() *ProcessState
- func (x *RuncDumpResp) GetUploadID() string
- func (*RuncDumpResp) ProtoMessage()
- func (x *RuncDumpResp) ProtoReflect() protoreflect.Message
- func (x *RuncDumpResp) Reset()
- func (x *RuncDumpResp) String() string
- type RuncGetPausePidArgs
- func (*RuncGetPausePidArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RuncGetPausePidArgs) GetBundlePath() string
- func (*RuncGetPausePidArgs) ProtoMessage()
- func (x *RuncGetPausePidArgs) ProtoReflect() protoreflect.Message
- func (x *RuncGetPausePidArgs) Reset()
- func (x *RuncGetPausePidArgs) String() string
- type RuncGetPausePidResp
- func (*RuncGetPausePidResp) Descriptor() ([]byte, []int)deprecated
- func (x *RuncGetPausePidResp) GetPausePid() int64
- func (*RuncGetPausePidResp) ProtoMessage()
- func (x *RuncGetPausePidResp) ProtoReflect() protoreflect.Message
- func (x *RuncGetPausePidResp) Reset()
- func (x *RuncGetPausePidResp) String() string
- type RuncOpts
- func (*RuncOpts) Descriptor() ([]byte, []int)deprecated
- func (x *RuncOpts) GetBundle() string
- func (x *RuncOpts) GetConsoleSocket() string
- func (x *RuncOpts) GetContainerID() string
- func (x *RuncOpts) GetDetach() bool
- func (x *RuncOpts) GetKeep() bool
- func (x *RuncOpts) GetNetPid() int32
- func (x *RuncOpts) GetNoMountFallback() bool
- func (x *RuncOpts) GetNoNewKeyring() bool
- func (x *RuncOpts) GetNoPivot() bool
- func (x *RuncOpts) GetNoSubreaper() bool
- func (x *RuncOpts) GetPidFile() string
- func (x *RuncOpts) GetPreserveFds() int32
- func (x *RuncOpts) GetRoot() string
- func (x *RuncOpts) GetRootless() string
- func (x *RuncOpts) GetSystemdCgroup() bool
- func (*RuncOpts) ProtoMessage()
- func (x *RuncOpts) ProtoReflect() protoreflect.Message
- func (x *RuncOpts) Reset()
- func (x *RuncOpts) String() string
- type RuncQueryArgs
- func (*RuncQueryArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RuncQueryArgs) GetContainerNames() []string
- func (x *RuncQueryArgs) GetNamespace() string
- func (x *RuncQueryArgs) GetRoot() string
- func (x *RuncQueryArgs) GetSandboxNames() []string
- func (*RuncQueryArgs) ProtoMessage()
- func (x *RuncQueryArgs) ProtoReflect() protoreflect.Message
- func (x *RuncQueryArgs) Reset()
- func (x *RuncQueryArgs) String() string
- type RuncQueryResp
- type RuncRestoreArgs
- func (*RuncRestoreArgs) Descriptor() ([]byte, []int)deprecated
- func (x *RuncRestoreArgs) GetCheckpointID() string
- func (x *RuncRestoreArgs) GetContainerID() string
- func (x *RuncRestoreArgs) GetImagePath() string
- func (x *RuncRestoreArgs) GetIsK3S() bool
- func (x *RuncRestoreArgs) GetOpts() *RuncOpts
- func (x *RuncRestoreArgs) GetType() CRType
- func (*RuncRestoreArgs) ProtoMessage()
- func (x *RuncRestoreArgs) ProtoReflect() protoreflect.Message
- func (x *RuncRestoreArgs) Reset()
- func (x *RuncRestoreArgs) String() string
- type RuncRestoreResp
- func (*RuncRestoreResp) Descriptor() ([]byte, []int)deprecated
- func (x *RuncRestoreResp) GetMessage() string
- func (x *RuncRestoreResp) GetState() *ProcessState
- func (*RuncRestoreResp) ProtoMessage()
- func (x *RuncRestoreResp) ProtoReflect() protoreflect.Message
- func (x *RuncRestoreResp) Reset()
- func (x *RuncRestoreResp) String() string
- type StartArgs
- func (*StartArgs) Descriptor() ([]byte, []int)deprecated
- func (x *StartArgs) GetEnv() []string
- func (x *StartArgs) GetGID() int32
- func (x *StartArgs) GetGPU() bool
- func (x *StartArgs) GetGroups() []int32
- func (x *StartArgs) GetJID() string
- func (x *StartArgs) GetLogOutputFile() string
- func (x *StartArgs) GetTask() string
- func (x *StartArgs) GetUID() int32
- func (x *StartArgs) GetWorkingDir() string
- func (*StartArgs) ProtoMessage()
- func (x *StartArgs) ProtoReflect() protoreflect.Message
- func (x *StartArgs) Reset()
- func (x *StartArgs) String() string
- type StartAttachArgs
- func (*StartAttachArgs) Descriptor() ([]byte, []int)deprecated
- func (x *StartAttachArgs) GetArgs() *StartArgs
- func (x *StartAttachArgs) GetStdin() string
- func (*StartAttachArgs) ProtoMessage()
- func (x *StartAttachArgs) ProtoReflect() protoreflect.Message
- func (x *StartAttachArgs) Reset()
- func (x *StartAttachArgs) String() string
- type StartAttachResp
- func (*StartAttachResp) Descriptor() ([]byte, []int)deprecated
- func (x *StartAttachResp) GetExitCode() int32
- func (x *StartAttachResp) GetStderr() string
- func (x *StartAttachResp) GetStdout() string
- func (*StartAttachResp) ProtoMessage()
- func (x *StartAttachResp) ProtoReflect() protoreflect.Message
- func (x *StartAttachResp) Reset()
- func (x *StartAttachResp) String() string
- type StartResp
- func (*StartResp) Descriptor() ([]byte, []int)deprecated
- func (x *StartResp) GetJID() string
- func (x *StartResp) GetMessage() string
- func (x *StartResp) GetPID() int32
- func (*StartResp) ProtoMessage()
- func (x *StartResp) ProtoReflect() protoreflect.Message
- func (x *StartResp) Reset()
- func (x *StartResp) String() string
- type TaskServiceClient
- type TaskServiceServer
- type TaskService_LogStreamingClient
- type TaskService_LogStreamingServer
- type TaskService_ProcessStateStreamingClient
- type TaskService_ProcessStateStreamingServer
- type TaskService_StartAttachClient
- type TaskService_StartAttachServer
- type UnimplementedTaskServiceServer
- func (UnimplementedTaskServiceServer) CRIOImagePush(context.Context, *CRIOImagePushArgs) (*CRIOImagePushResp, error)
- func (UnimplementedTaskServiceServer) CRIORootfsDump(context.Context, *CRIORootfsDumpArgs) (*CRIORootfsDumpResp, error)
- func (UnimplementedTaskServiceServer) ContainerdDump(context.Context, *ContainerdDumpArgs) (*ContainerdDumpResp, error)
- func (UnimplementedTaskServiceServer) ContainerdQuery(context.Context, *ContainerdQueryArgs) (*ContainerdQueryResp, error)
- func (UnimplementedTaskServiceServer) ContainerdRestore(context.Context, *ContainerdRestoreArgs) (*ContainerdRestoreResp, error)
- func (UnimplementedTaskServiceServer) ContainerdRootfsDump(context.Context, *ContainerdRootfsDumpArgs) (*ContainerdRootfsDumpResp, error)
- func (UnimplementedTaskServiceServer) ContainerdRootfsRestore(context.Context, *ContainerdRootfsRestoreArgs) (*ContainerdRootfsRestoreResp, error)
- func (UnimplementedTaskServiceServer) DetailedHealthCheck(context.Context, *DetailedHealthCheckRequest) (*DetailedHealthCheckResponse, error)
- func (UnimplementedTaskServiceServer) Dump(context.Context, *DumpArgs) (*DumpResp, error)
- func (UnimplementedTaskServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
- func (UnimplementedTaskServiceServer) LogStreaming(TaskService_LogStreamingServer) error
- func (UnimplementedTaskServiceServer) ProcessStateStreaming(*ProcessStateStreamingArgs, TaskService_ProcessStateStreamingServer) error
- func (UnimplementedTaskServiceServer) Query(context.Context, *QueryArgs) (*QueryResp, error)
- func (UnimplementedTaskServiceServer) Restore(context.Context, *RestoreArgs) (*RestoreResp, error)
- func (UnimplementedTaskServiceServer) RuncDump(context.Context, *RuncDumpArgs) (*RuncDumpResp, error)
- func (UnimplementedTaskServiceServer) RuncGetPausePid(context.Context, *RuncGetPausePidArgs) (*RuncGetPausePidResp, error)
- func (UnimplementedTaskServiceServer) RuncQuery(context.Context, *RuncQueryArgs) (*RuncQueryResp, error)
- func (UnimplementedTaskServiceServer) RuncRestore(context.Context, *RuncRestoreArgs) (*RuncRestoreResp, error)
- func (UnimplementedTaskServiceServer) Start(context.Context, *StartArgs) (*StartResp, error)
- func (UnimplementedTaskServiceServer) StartAttach(TaskService_StartAttachServer) error
- type UnsafeTaskServiceServer
Constants ¶
This section is empty.
Variables ¶
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.
var ( ContainerRuntime_name = map[int32]string{ 0: "CRIO", 1: "CONTAINERD", } ContainerRuntime_value = map[string]int32{ "CRIO": 0, "CONTAINERD": 1, } )
Enum value maps for ContainerRuntime.
var ( CRType_name = map[int32]string{ 0: "LOCAL", 1: "REMOTE", } CRType_value = map[string]int32{ "LOCAL": 0, "REMOTE": 1, } )
Enum value maps for CRType.
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.
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.
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.
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.
var File_task_proto protoreflect.FileDescriptor
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) ProtoMessage ¶
func (*Addr) ProtoMessage()
func (*Addr) ProtoReflect ¶ added in v0.8.1
func (x *Addr) ProtoReflect() protoreflect.Message
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) GetPhysicalID ¶ added in v0.9.204
func (*CPUInfo) GetVendorID ¶ added in v0.9.204
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
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
func (CRType) Descriptor ¶ added in v0.9.104
func (CRType) Descriptor() protoreflect.EnumDescriptor
func (CRType) EnumDescriptor
deprecated
added in
v0.9.104
func (CRType) Number ¶ added in v0.9.104
func (x CRType) Number() protoreflect.EnumNumber
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 (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) 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 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) Descriptor() protoreflect.EnumDescriptor
func (ContainerRuntime) Enum ¶ added in v0.9.215
func (x ContainerRuntime) Enum() *ContainerRuntime
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 (x ContainerRuntime) Number() protoreflect.EnumNumber
func (ContainerRuntime) String ¶ added in v0.9.215
func (x ContainerRuntime) String() string
func (ContainerRuntime) Type ¶ added in v0.9.215
func (ContainerRuntime) Type() protoreflect.EnumType
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 (x *ContainerdRootfsRestoreArgs) ProtoReflect() protoreflect.Message
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 (x *ContainerdRootfsRestoreResp) ProtoReflect() protoreflect.Message
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) GetAutoDedup ¶
func (*CriuOpts) GetEmptyNs ¶
func (*CriuOpts) GetExternal ¶ added in v0.9.202
func (*CriuOpts) GetExternalUnixConnections ¶
func (*CriuOpts) GetFileLocks ¶
func (*CriuOpts) GetImagesDirectory ¶
func (*CriuOpts) GetLazyPages ¶
func (*CriuOpts) GetLeaveRunning ¶
func (*CriuOpts) GetLsmMountContext ¶
func (*CriuOpts) GetLsmProfile ¶
func (*CriuOpts) GetParentImage ¶
func (*CriuOpts) GetPreDump ¶
func (*CriuOpts) GetShellJob ¶
func (*CriuOpts) GetStatusFd ¶
func (*CriuOpts) GetTcpEstablished ¶
func (*CriuOpts) GetWorkDirectory ¶
func (*CriuOpts) ProtoMessage ¶
func (*CriuOpts) ProtoMessage()
func (*CriuOpts) ProtoReflect ¶ added in v0.8.1
func (x *CriuOpts) ProtoReflect() protoreflect.Message
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 (x *DetailedHealthCheckRequest) ProtoReflect() protoreflect.Message
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 (x *DetailedHealthCheckResponse) ProtoReflect() protoreflect.Message
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) GetTcpEstablished ¶ added in v0.9.211
func (*DumpArgs) ProtoMessage ¶
func (*DumpArgs) ProtoMessage()
func (*DumpArgs) ProtoReflect ¶ added in v0.8.1
func (x *DumpArgs) ProtoReflect() protoreflect.Message
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) GetCheckpointID ¶ added in v0.8.9
func (*DumpResp) GetDumpStats ¶ added in v0.9.215
func (*DumpResp) GetMessage ¶
func (*DumpResp) GetState ¶ added in v0.9.204
func (x *DumpResp) GetState() *ProcessState
func (*DumpResp) GetUploadID ¶ added in v0.8.9
func (*DumpResp) ProtoMessage ¶
func (*DumpResp) ProtoMessage()
func (*DumpResp) ProtoReflect ¶ added in v0.8.1
func (x *DumpResp) ProtoReflect() protoreflect.Message
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) GetCRIUDuration ¶ added in v0.9.215
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 (*DumpStats) GetGPUDuration ¶ added in v0.9.215
func (*DumpStats) GetKubernetes ¶ added in v0.9.215
func (*DumpStats) GetPrepareDuration ¶ added in v0.9.215
func (*DumpStats) GetUploadDuration ¶ added in v0.9.215
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
type DumpType ¶ added in v0.9.215
type DumpType int32
func (DumpType) Descriptor ¶ added in v0.9.215
func (DumpType) Descriptor() protoreflect.EnumDescriptor
func (DumpType) EnumDescriptor
deprecated
added in
v0.9.215
func (DumpType) Number ¶ added in v0.9.215
func (x DumpType) Number() protoreflect.EnumNumber
func (DumpType) Type ¶ added in v0.9.215
func (DumpType) Type() protoreflect.EnumType
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) GetHostname ¶ added in v0.9.204
func (*HostInfo) GetKernelArch ¶ added in v0.9.204
func (*HostInfo) GetKernelVersion ¶ added in v0.9.204
func (*HostInfo) GetPlatform ¶ added in v0.9.204
func (*HostInfo) GetVirtualizationRole ¶ added in v0.9.204
func (*HostInfo) GetVirtualizationSystem ¶ added in v0.9.204
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
type JobState ¶ added in v0.9.104
type JobState int32
func (JobState) Descriptor ¶ added in v0.9.104
func (JobState) Descriptor() protoreflect.EnumDescriptor
func (JobState) EnumDescriptor
deprecated
added in
v0.9.104
func (JobState) Number ¶ added in v0.9.104
func (x JobState) Number() protoreflect.EnumNumber
func (JobState) Type ¶ added in v0.9.104
func (JobState) Type() protoreflect.EnumType
type LogStreamingArgs ¶
type LogStreamingArgs struct {
Timestamp string `protobuf:"bytes,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
Source string `protobuf:"bytes,2,opt,name=Source,proto3" json:"Source,omitempty"`
Level string `protobuf:"bytes,3,opt,name=Level,proto3" json:"Level,omitempty"`
Msg string `protobuf:"bytes,4,opt,name=Msg,proto3" json:"Msg,omitempty"`
// contains filtered or unexported fields
}
func (*LogStreamingArgs) Descriptor
deprecated
func (*LogStreamingArgs) Descriptor() ([]byte, []int)
Deprecated: Use LogStreamingArgs.ProtoReflect.Descriptor instead.
func (*LogStreamingArgs) GetLevel ¶
func (x *LogStreamingArgs) GetLevel() string
func (*LogStreamingArgs) GetMsg ¶
func (x *LogStreamingArgs) GetMsg() string
func (*LogStreamingArgs) GetSource ¶
func (x *LogStreamingArgs) GetSource() string
func (*LogStreamingArgs) GetTimestamp ¶
func (x *LogStreamingArgs) GetTimestamp() string
func (*LogStreamingArgs) ProtoMessage ¶
func (*LogStreamingArgs) ProtoMessage()
func (*LogStreamingArgs) ProtoReflect ¶ 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) 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 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 (x *ProcessStateStreamingArgs) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶ added in v0.9.104
func (*QueryArgs) ProtoMessage()
func (*QueryArgs) ProtoReflect ¶ added in v0.9.104
func (x *QueryArgs) ProtoReflect() protoreflect.Message
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) 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
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) GetConsoleSocket ¶
func (*RuncOpts) GetContainerID ¶ added in v0.9.104
func (*RuncOpts) GetNoMountFallback ¶
func (*RuncOpts) GetNoNewKeyring ¶
func (*RuncOpts) GetNoPivot ¶
func (*RuncOpts) GetNoSubreaper ¶
func (*RuncOpts) GetPidFile ¶
func (*RuncOpts) GetPreserveFds ¶
func (*RuncOpts) GetRootless ¶
func (*RuncOpts) GetSystemdCgroup ¶
func (*RuncOpts) ProtoMessage ¶
func (*RuncOpts) ProtoMessage()
func (*RuncOpts) ProtoReflect ¶ added in v0.8.1
func (x *RuncOpts) ProtoReflect() protoreflect.Message
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) GetLogOutputFile ¶ added in v0.9.104
func (*StartArgs) GetWorkingDir ¶ added in v0.9.104
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
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) GetMessage ¶ added in v0.9.104
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
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.
func NewTaskServiceClient ¶
func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient
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) CRIOImagePush(context.Context, *CRIOImagePushArgs) (*CRIOImagePushResp, error)
func (UnimplementedTaskServiceServer) CRIORootfsDump ¶ added in v0.9.208
func (UnimplementedTaskServiceServer) CRIORootfsDump(context.Context, *CRIORootfsDumpArgs) (*CRIORootfsDumpResp, error)
func (UnimplementedTaskServiceServer) ContainerdDump ¶ added in v0.9.104
func (UnimplementedTaskServiceServer) ContainerdDump(context.Context, *ContainerdDumpArgs) (*ContainerdDumpResp, error)
func (UnimplementedTaskServiceServer) ContainerdQuery ¶ added in v0.9.104
func (UnimplementedTaskServiceServer) ContainerdQuery(context.Context, *ContainerdQueryArgs) (*ContainerdQueryResp, error)
func (UnimplementedTaskServiceServer) ContainerdRestore ¶ added in v0.9.104
func (UnimplementedTaskServiceServer) ContainerdRestore(context.Context, *ContainerdRestoreArgs) (*ContainerdRestoreResp, error)
func (UnimplementedTaskServiceServer) ContainerdRootfsDump ¶ added in v0.9.202
func (UnimplementedTaskServiceServer) ContainerdRootfsDump(context.Context, *ContainerdRootfsDumpArgs) (*ContainerdRootfsDumpResp, error)
func (UnimplementedTaskServiceServer) ContainerdRootfsRestore ¶ added in v0.9.202
func (UnimplementedTaskServiceServer) ContainerdRootfsRestore(context.Context, *ContainerdRootfsRestoreArgs) (*ContainerdRootfsRestoreResp, error)
func (UnimplementedTaskServiceServer) DetailedHealthCheck ¶ added in v0.9.211
func (UnimplementedTaskServiceServer) DetailedHealthCheck(context.Context, *DetailedHealthCheckRequest) (*DetailedHealthCheckResponse, error)
func (UnimplementedTaskServiceServer) GetConfig ¶ added in v0.9.215
func (UnimplementedTaskServiceServer) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
func (UnimplementedTaskServiceServer) LogStreaming ¶
func (UnimplementedTaskServiceServer) LogStreaming(TaskService_LogStreamingServer) error
func (UnimplementedTaskServiceServer) ProcessStateStreaming ¶ added in v0.9.104
func (UnimplementedTaskServiceServer) ProcessStateStreaming(*ProcessStateStreamingArgs, TaskService_ProcessStateStreamingServer) 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) RuncGetPausePid ¶ added in v0.9.104
func (UnimplementedTaskServiceServer) RuncGetPausePid(context.Context, *RuncGetPausePidArgs) (*RuncGetPausePidResp, error)
func (UnimplementedTaskServiceServer) RuncQuery ¶ added in v0.9.104
func (UnimplementedTaskServiceServer) RuncQuery(context.Context, *RuncQueryArgs) (*RuncQueryResp, error)
func (UnimplementedTaskServiceServer) RuncRestore ¶
func (UnimplementedTaskServiceServer) RuncRestore(context.Context, *RuncRestoreArgs) (*RuncRestoreResp, error)
func (UnimplementedTaskServiceServer) StartAttach ¶ added in v0.9.219
func (UnimplementedTaskServiceServer) StartAttach(TaskService_StartAttachServer) 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.