daemon

package
v1.36.10-2025110508185... Latest Latest
Warning

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

 Go to latest Published: unknown License: AGPL-3.0 Imports: 10 Imported by: 19

Documentation

Index

Constants

View Source 
const AttachReq_Input_not_set_case case_AttachReq_Input = 0
View Source 
const AttachReq_Signal_case case_AttachReq_Input = 3
View Source 
const AttachReq_Stdin_case case_AttachReq_Input = 2
View Source 
const AttachResp_ExitCode_case case_AttachResp_Output = 3
View Source 
const AttachResp_Output_not_set_case case_AttachResp_Output = 0
View Source 
const AttachResp_Stderr_case case_AttachResp_Output = 2
View Source 
const AttachResp_Stdout_case case_AttachResp_Output = 1

Variables

View Source 
var (
	DumpAction_name = map[int32]string{
		0: "DUMP",
		1: "FREEZE_ONLY",
		2: "UNFREEZE_ONLY",
	}
	DumpAction_value = map[string]int32{
		"DUMP":          0,
		"FREEZE_ONLY":   1,
		"UNFREEZE_ONLY": 2,
	}
)

Enum value maps for DumpAction.

View Source 
var (
	RunAction_name = map[int32]string{
		0: "START_NEW",
		1: "MANAGE_EXISTING",
		2: "MANAGE_UPCOMING",
	}
	RunAction_value = map[string]int32{
		"START_NEW":       0,
		"MANAGE_EXISTING": 1,
		"MANAGE_UPCOMING": 2,
	}
)

Enum value maps for RunAction.

View Source 
var File_daemon_checkpoint_proto protoreflect.FileDescriptor
View Source 
var File_daemon_daemon_proto protoreflect.FileDescriptor
View Source 
var File_daemon_health_proto protoreflect.FileDescriptor
View Source 
var File_daemon_host_proto protoreflect.FileDescriptor
View Source 
var File_daemon_misc_proto protoreflect.FileDescriptor
View Source 
var File_daemon_process_proto protoreflect.FileDescriptor
View Source 
var File_daemon_query_proto protoreflect.FileDescriptor
View Source 
var File_daemon_socket_proto protoreflect.FileDescriptor

Functions

This section is empty.

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

func (x *Addr) GetIP() string

func (*Addr) GetPort 

func (x *Addr) GetPort() uint32

func (*Addr) ProtoMessage 

func (*Addr) ProtoMessage()

func (*Addr) ProtoReflect 

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

func (*Addr) Reset 

func (x *Addr) Reset()

func (*Addr) SetIP 

func (x *Addr) SetIP(v string)

func (*Addr) SetPort 

func (x *Addr) SetPort(v uint32)

func (*Addr) String 

func (x *Addr) String() string

type Addr_builder 

type Addr_builder struct {
	IP   string
	Port uint32
	// contains filtered or unexported fields
}

func (Addr_builder) Build 

func (b0 Addr_builder) Build() *Addr

type AttachReq 

type AttachReq struct {
	PID uint32 `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"` // PID of the process to attach to
	// Types that are valid to be assigned to Input:
	//
	//	*AttachReq_Stdin
	//	*AttachReq_Signal
	Input isAttachReq_Input `protobuf_oneof:"Input"`
	// contains filtered or unexported fields
}

func (*AttachReq) ClearInput 

func (x *AttachReq) ClearInput()

func (*AttachReq) ClearSignal 

func (x *AttachReq) ClearSignal()

func (*AttachReq) ClearStdin 

func (x *AttachReq) ClearStdin()

func (*AttachReq) GetInput 

func (x *AttachReq) GetInput() isAttachReq_Input

func (*AttachReq) GetPID 

func (x *AttachReq) GetPID() uint32

func (*AttachReq) GetSignal 

func (x *AttachReq) GetSignal() int32

func (*AttachReq) GetStdin 

func (x *AttachReq) GetStdin() []byte

func (*AttachReq) HasInput 

func (x *AttachReq) HasInput() bool

func (*AttachReq) HasSignal 

func (x *AttachReq) HasSignal() bool

func (*AttachReq) HasStdin 

func (x *AttachReq) HasStdin() bool

func (*AttachReq) ProtoMessage 

func (*AttachReq) ProtoMessage()

func (*AttachReq) ProtoReflect 

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

func (*AttachReq) Reset 

func (x *AttachReq) Reset()

func (*AttachReq) SetPID 

func (x *AttachReq) SetPID(v uint32)

func (*AttachReq) SetSignal 

func (x *AttachReq) SetSignal(v int32)

func (*AttachReq) SetStdin 

func (x *AttachReq) SetStdin(v []byte)

func (*AttachReq) String 

func (x *AttachReq) String() string

func (*AttachReq) WhichInput 

func (x *AttachReq) WhichInput() case_AttachReq_Input

type AttachReq_Signal 

type AttachReq_Signal struct {
	Signal int32 `protobuf:"varint,3,opt,name=Signal,proto3,oneof"` // signal to send to the process
}

type AttachReq_Stdin 

type AttachReq_Stdin struct {
	Stdin []byte `protobuf:"bytes,2,opt,name=Stdin,proto3,oneof"` // standard input bytes
}

type AttachReq_builder 

type AttachReq_builder struct {
	PID uint32
	// Fields of oneof Input:
	Stdin  []byte
	Signal *int32
	// contains filtered or unexported fields
}

func (AttachReq_builder) Build 

func (b0 AttachReq_builder) Build() *AttachReq

type AttachResp 

type AttachResp struct {

	// Types that are valid to be assigned to Output:
	//
	//	*AttachResp_Stdout
	//	*AttachResp_Stderr
	//	*AttachResp_ExitCode
	Output isAttachResp_Output `protobuf_oneof:"Output"`
	// contains filtered or unexported fields
}

func (*AttachResp) ClearExitCode 

func (x *AttachResp) ClearExitCode()

func (*AttachResp) ClearOutput 

func (x *AttachResp) ClearOutput()

func (*AttachResp) ClearStderr 

func (x *AttachResp) ClearStderr()

func (*AttachResp) ClearStdout 

func (x *AttachResp) ClearStdout()

func (*AttachResp) GetExitCode 

func (x *AttachResp) GetExitCode() int32

func (*AttachResp) GetOutput 

func (x *AttachResp) GetOutput() isAttachResp_Output

func (*AttachResp) GetStderr 

func (x *AttachResp) GetStderr() []byte

func (*AttachResp) GetStdout 

func (x *AttachResp) GetStdout() []byte

func (*AttachResp) HasExitCode 

func (x *AttachResp) HasExitCode() bool

func (*AttachResp) HasOutput 

func (x *AttachResp) HasOutput() bool

func (*AttachResp) HasStderr 

func (x *AttachResp) HasStderr() bool

func (*AttachResp) HasStdout 

func (x *AttachResp) HasStdout() bool

func (*AttachResp) ProtoMessage 

func (*AttachResp) ProtoMessage()

func (*AttachResp) ProtoReflect 

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

func (*AttachResp) Reset 

func (x *AttachResp) Reset()

func (*AttachResp) SetExitCode 

func (x *AttachResp) SetExitCode(v int32)

func (*AttachResp) SetStderr 

func (x *AttachResp) SetStderr(v []byte)

func (*AttachResp) SetStdout 

func (x *AttachResp) SetStdout(v []byte)

func (*AttachResp) String 

func (x *AttachResp) String() string

func (*AttachResp) WhichOutput 

func (x *AttachResp) WhichOutput() case_AttachResp_Output

type AttachResp_ExitCode 

type AttachResp_ExitCode struct {
	ExitCode int32 `protobuf:"varint,3,opt,name=ExitCode,proto3,oneof"` // exit code of the process
}

type AttachResp_Stderr 

type AttachResp_Stderr struct {
	Stderr []byte `protobuf:"bytes,2,opt,name=Stderr,proto3,oneof"` // standard error bytes
}

type AttachResp_Stdout 

type AttachResp_Stdout struct {
	Stdout []byte `protobuf:"bytes,1,opt,name=Stdout,proto3,oneof"` // standard output bytes
}

type AttachResp_builder 

type AttachResp_builder struct {

	// Fields of oneof Output:
	Stdout   []byte
	Stderr   []byte
	ExitCode *int32
	// contains filtered or unexported fields
}

func (AttachResp_builder) Build 

func (b0 AttachResp_builder) Build() *AttachResp

type CPU 

type CPU 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 (*CPU) GetCPU 

func (x *CPU) GetCPU() int32

func (*CPU) GetCount 

func (x *CPU) GetCount() int32

func (*CPU) GetFamily 

func (x *CPU) GetFamily() string

func (*CPU) GetPhysicalID 

func (x *CPU) GetPhysicalID() string

func (*CPU) GetVendorID 

func (x *CPU) GetVendorID() string

func (*CPU) ProtoMessage 

func (*CPU) ProtoMessage()

func (*CPU) ProtoReflect 

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

func (*CPU) Reset 

func (x *CPU) Reset()

func (*CPU) SetCPU 

func (x *CPU) SetCPU(v int32)

func (*CPU) SetCount 

func (x *CPU) SetCount(v int32)

func (*CPU) SetFamily 

func (x *CPU) SetFamily(v string)

func (*CPU) SetPhysicalID 

func (x *CPU) SetPhysicalID(v string)

func (*CPU) SetVendorID 

func (x *CPU) SetVendorID(v string)

func (*CPU) String 

func (x *CPU) String() string

type CPU_builder 

type CPU_builder struct {
	Count      int32
	CPU        int32
	VendorID   string
	Family     string
	PhysicalID string
	// contains filtered or unexported fields
}

func (CPU_builder) Build 

func (b0 CPU_builder) Build() *CPU

type Checkpoint 

type Checkpoint struct {
	ID   string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`   // Unique ID of the checkpoint
	JID  string `protobuf:"bytes,2,opt,name=JID,proto3" json:"JID,omitempty"` // Job ID of the job that was checkpointed
	Path string `protobuf:"bytes,3,opt,name=Path,proto3" json:"Path,omitempty"`
	Time int64  `protobuf:"varint,4,opt,name=Time,proto3" json:"Time,omitempty"` // Cached time in Unix milliseconds
	Size int64  `protobuf:"varint,5,opt,name=Size,proto3" json:"Size,omitempty"` // Cached size in bytes
	// contains filtered or unexported fields
}

func (*Checkpoint) GetID 

func (x *Checkpoint) GetID() string

func (*Checkpoint) GetJID 

func (x *Checkpoint) GetJID() string

func (*Checkpoint) GetPath 

func (x *Checkpoint) GetPath() string

func (*Checkpoint) GetSize 

func (x *Checkpoint) GetSize() int64

func (*Checkpoint) GetTime 

func (x *Checkpoint) GetTime() int64

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) ProtoReflect 

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

func (*Checkpoint) Reset 

func (x *Checkpoint) Reset()

func (*Checkpoint) SetID 

func (x *Checkpoint) SetID(v string)

func (*Checkpoint) SetJID 

func (x *Checkpoint) SetJID(v string)

func (*Checkpoint) SetPath 

func (x *Checkpoint) SetPath(v string)

func (*Checkpoint) SetSize 

func (x *Checkpoint) SetSize(v int64)

func (*Checkpoint) SetTime 

func (x *Checkpoint) SetTime(v int64)

func (*Checkpoint) String 

func (x *Checkpoint) String() string

type Checkpoint_builder 

type Checkpoint_builder struct {
	ID   string
	JID  string
	Path string
	Time int64
	Size int64
	// contains filtered or unexported fields
}

func (Checkpoint_builder) Build 

func (b0 Checkpoint_builder) Build() *Checkpoint

type Connection 

type Connection 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   []uint32 `protobuf:"varint,7,rep,packed,name=UIDs,proto3" json:"UIDs,omitempty"`
	PID    uint32   `protobuf:"varint,8,opt,name=PID,proto3" json:"PID,omitempty"`
	// contains filtered or unexported fields
}

func (*Connection) ClearLaddr 

func (x *Connection) ClearLaddr()

func (*Connection) ClearRaddr 

func (x *Connection) ClearRaddr()

func (*Connection) GetFamily 

func (x *Connection) GetFamily() uint32

func (*Connection) GetFd 

func (x *Connection) GetFd() uint32

func (*Connection) GetLaddr 

func (x *Connection) GetLaddr() *Addr

func (*Connection) GetPID 

func (x *Connection) GetPID() uint32

func (*Connection) GetRaddr 

func (x *Connection) GetRaddr() *Addr

func (*Connection) GetStatus 

func (x *Connection) GetStatus() string

func (*Connection) GetType 

func (x *Connection) GetType() uint32

func (*Connection) GetUIDs 

func (x *Connection) GetUIDs() []uint32

func (*Connection) HasLaddr 

func (x *Connection) HasLaddr() bool

func (*Connection) HasRaddr 

func (x *Connection) HasRaddr() bool

func (*Connection) ProtoMessage 

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect 

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

func (*Connection) Reset 

func (x *Connection) Reset()

func (*Connection) SetFamily 

func (x *Connection) SetFamily(v uint32)

func (*Connection) SetFd 

func (x *Connection) SetFd(v uint32)

func (*Connection) SetLaddr 

func (x *Connection) SetLaddr(v *Addr)

func (*Connection) SetPID 

func (x *Connection) SetPID(v uint32)

func (*Connection) SetRaddr 

func (x *Connection) SetRaddr(v *Addr)

func (*Connection) SetStatus 

func (x *Connection) SetStatus(v string)

func (*Connection) SetType 

func (x *Connection) SetType(v uint32)

func (*Connection) SetUIDs 

func (x *Connection) SetUIDs(v []uint32)

func (*Connection) String 

func (x *Connection) String() string

type Connection_builder 

type Connection_builder struct {
	Fd     uint32
	Family uint32
	Type   uint32
	Laddr  *Addr
	Raddr  *Addr
	Status string
	UIDs   []uint32
	PID    uint32
	// contains filtered or unexported fields
}

func (Connection_builder) Build 

func (b0 Connection_builder) Build() *Connection

type DeleteCheckpointReq 

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

func (*DeleteCheckpointReq) GetID 

func (x *DeleteCheckpointReq) GetID() string

func (*DeleteCheckpointReq) ProtoMessage 

func (*DeleteCheckpointReq) ProtoMessage()

func (*DeleteCheckpointReq) ProtoReflect 

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

func (*DeleteCheckpointReq) Reset 

func (x *DeleteCheckpointReq) Reset()

func (*DeleteCheckpointReq) SetID 

func (x *DeleteCheckpointReq) SetID(v string)

func (*DeleteCheckpointReq) String 

func (x *DeleteCheckpointReq) String() string

type DeleteCheckpointReq_builder 

type DeleteCheckpointReq_builder struct {
	ID string
	// contains filtered or unexported fields
}

func (DeleteCheckpointReq_builder) Build 

func (b0 DeleteCheckpointReq_builder) Build() *DeleteCheckpointReq

type DeleteCheckpointResp 

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

func (*DeleteCheckpointResp) ProtoMessage 

func (*DeleteCheckpointResp) ProtoMessage()

func (*DeleteCheckpointResp) ProtoReflect 

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

func (*DeleteCheckpointResp) Reset 

func (x *DeleteCheckpointResp) Reset()

func (*DeleteCheckpointResp) String 

func (x *DeleteCheckpointResp) String() string

type DeleteCheckpointResp_builder 

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

func (DeleteCheckpointResp_builder) Build 

func (b0 DeleteCheckpointResp_builder) Build() *DeleteCheckpointResp

type DeleteReq 

type DeleteReq struct {
	JIDs []string `protobuf:"bytes,1,rep,name=JIDs,proto3" json:"JIDs,omitempty"` // JIDs of the jobs to delete
	// contains filtered or unexported fields
}

func (*DeleteReq) GetJIDs 

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

func (*DeleteReq) ProtoMessage 

func (*DeleteReq) ProtoMessage()

func (*DeleteReq) ProtoReflect 

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

func (*DeleteReq) Reset 

func (x *DeleteReq) Reset()

func (*DeleteReq) SetJIDs 

func (x *DeleteReq) SetJIDs(v []string)

func (*DeleteReq) String 

func (x *DeleteReq) String() string

type DeleteReq_builder 

type DeleteReq_builder struct {
	JIDs []string
	// contains filtered or unexported fields
}

func (DeleteReq_builder) Build 

func (b0 DeleteReq_builder) Build() *DeleteReq

type DeleteResp 

type DeleteResp struct {
	Messages []string `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"` // messages from the delete operation
	// contains filtered or unexported fields
}

func (*DeleteResp) GetMessages 

func (x *DeleteResp) GetMessages() []string

func (*DeleteResp) ProtoMessage 

func (*DeleteResp) ProtoMessage()

func (*DeleteResp) ProtoReflect 

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

func (*DeleteResp) Reset 

func (x *DeleteResp) Reset()

func (*DeleteResp) SetMessages 

func (x *DeleteResp) SetMessages(v []string)

func (*DeleteResp) String 

func (x *DeleteResp) String() string

type DeleteResp_builder 

type DeleteResp_builder struct {
	Messages []string
	// contains filtered or unexported fields
}

func (DeleteResp_builder) Build 

func (b0 DeleteResp_builder) Build() *DeleteResp

type Details 

type Details struct {
	JID     *string  `protobuf:"bytes,1,opt,name=JID,proto3,oneof" json:"JID,omitempty"`         // job ID, if applicable
	Process *Process `protobuf:"bytes,2,opt,name=Process,proto3,oneof" json:"Process,omitempty"` // process details, if applicable
	// Plugin-specific job details:
	Runc       *runc.Runc             `protobuf:"bytes,101,opt,name=Runc,proto3,oneof" json:"Runc,omitempty"`             // runc plugin details
	Containerd *containerd.Containerd `protobuf:"bytes,102,opt,name=Containerd,proto3,oneof" json:"Containerd,omitempty"` // containerd plugin details
	Kata       *kata.Kata             `protobuf:"bytes,103,opt,name=Kata,proto3,oneof" json:"Kata,omitempty"`             // kata containers plugin details
	Slurm      *slurm.Slurm           `protobuf:"bytes,104,opt,name=Slurm,proto3,oneof" json:"Slurm,omitempty"`
	// contains filtered or unexported fields
}

Details are plugin-specific or 'type' specific details.

func (*Details) ClearContainerd 

func (x *Details) ClearContainerd()

func (*Details) ClearJID 

func (x *Details) ClearJID()

func (*Details) ClearKata 

func (x *Details) ClearKata()

func (*Details) ClearProcess 

func (x *Details) ClearProcess()

func (*Details) ClearRunc 

func (x *Details) ClearRunc()

func (*Details) ClearSlurm 

func (x *Details) ClearSlurm()

func (*Details) GetContainerd 

func (x *Details) GetContainerd() *containerd.Containerd

func (*Details) GetJID 

func (x *Details) GetJID() string

func (*Details) GetKata 

func (x *Details) GetKata() *kata.Kata

func (*Details) GetProcess 

func (x *Details) GetProcess() *Process

func (*Details) GetRunc 

func (x *Details) GetRunc() *runc.Runc

func (*Details) GetSlurm 

func (x *Details) GetSlurm() *slurm.Slurm

func (*Details) HasContainerd 

func (x *Details) HasContainerd() bool

func (*Details) HasJID 

func (x *Details) HasJID() bool

func (*Details) HasKata 

func (x *Details) HasKata() bool

func (*Details) HasProcess 

func (x *Details) HasProcess() bool

func (*Details) HasRunc 

func (x *Details) HasRunc() bool

func (*Details) HasSlurm 

func (x *Details) HasSlurm() bool

func (*Details) ProtoMessage 

func (*Details) ProtoMessage()

func (*Details) ProtoReflect 

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

func (*Details) Reset 

func (x *Details) Reset()

func (*Details) SetContainerd 

func (x *Details) SetContainerd(v *containerd.Containerd)

func (*Details) SetJID 

func (x *Details) SetJID(v string)

func (*Details) SetKata 

func (x *Details) SetKata(v *kata.Kata)

func (*Details) SetProcess 

func (x *Details) SetProcess(v *Process)

func (*Details) SetRunc 

func (x *Details) SetRunc(v *runc.Runc)

func (*Details) SetSlurm 

func (x *Details) SetSlurm(v *slurm.Slurm)

func (*Details) String 

func (x *Details) String() string

type Details_builder 

type Details_builder struct {
	JID     *string
	Process *Process
	// Plugin-specific job details:
	Runc       *runc.Runc
	Containerd *containerd.Containerd
	Kata       *kata.Kata
	Slurm      *slurm.Slurm
	// contains filtered or unexported fields
}

func (Details_builder) Build 

func (b0 Details_builder) Build() *Details

type DumpAction 

type DumpAction int32
const (
	DumpAction_DUMP          DumpAction = 0 // full dump
	DumpAction_FREEZE_ONLY   DumpAction = 1 // freeze only
	DumpAction_UNFREEZE_ONLY DumpAction = 2 // unfreeze only
)

func (DumpAction) Descriptor 

func (DumpAction) Descriptor() protoreflect.EnumDescriptor

func (DumpAction) Enum 

func (x DumpAction) Enum() *DumpAction

func (DumpAction) Number 

func (x DumpAction) Number() protoreflect.EnumNumber

func (DumpAction) String 

func (x DumpAction) String() string

func (DumpAction) Type 

func (DumpAction) Type() protoreflect.EnumType

type DumpReq 

type DumpReq struct {
	Details       *Details       `protobuf:"bytes,1,opt,name=Details,proto3" json:"Details,omitempty"`                       // details about the job, process, or container to dump
	Dir           string         `protobuf:"bytes,2,opt,name=Dir,proto3" json:"Dir,omitempty"`                               // directory to dump to
	Name          string         `protobuf:"bytes,3,opt,name=Name,proto3" json:"Name,omitempty"`                             // name of the dump
	Compression   string         `protobuf:"bytes,4,opt,name=Compression,proto3" json:"Compression,omitempty"`               // tar, gzip, lz4, none
	Streams       int32          `protobuf:"varint,5,opt,name=Streams,proto3" json:"Streams,omitempty"`                      // number of parallel streams for dumping, 0 for no streaming
	Type          string         `protobuf:"bytes,6,opt,name=Type,proto3" json:"Type,omitempty"`                             // type of the dump, e.g., runc, containerd, kata
	Criu          *criu.CriuOpts `protobuf:"bytes,7,opt,name=Criu,proto3" json:"Criu,omitempty"`                             // CRIU overrides for the dump
	GPUFreezeType string         `protobuf:"bytes,8,opt,name=GPUFreezeType,proto3" json:"GPUFreezeType,omitempty"`           // type of GPU freeze to use, e.g., IPC, NCCL
	Action        DumpAction     `protobuf:"varint,9,opt,name=Action,proto3,enum=daemon.DumpAction" json:"Action,omitempty"` // action to perform: dump, freeze only, unfreeze only
	// contains filtered or unexported fields
}

func (*DumpReq) ClearCriu 

func (x *DumpReq) ClearCriu()

func (*DumpReq) ClearDetails 

func (x *DumpReq) ClearDetails()

func (*DumpReq) GetAction 

func (x *DumpReq) GetAction() DumpAction

func (*DumpReq) GetCompression 

func (x *DumpReq) GetCompression() string

func (*DumpReq) GetCriu 

func (x *DumpReq) GetCriu() *criu.CriuOpts

func (*DumpReq) GetDetails 

func (x *DumpReq) GetDetails() *Details

func (*DumpReq) GetDir 

func (x *DumpReq) GetDir() string

func (*DumpReq) GetGPUFreezeType 

func (x *DumpReq) GetGPUFreezeType() string

func (*DumpReq) GetName 

func (x *DumpReq) GetName() string

func (*DumpReq) GetStreams 

func (x *DumpReq) GetStreams() int32

func (*DumpReq) GetType 

func (x *DumpReq) GetType() string

func (*DumpReq) HasCriu 

func (x *DumpReq) HasCriu() bool

func (*DumpReq) HasDetails 

func (x *DumpReq) HasDetails() bool

func (*DumpReq) ProtoMessage 

func (*DumpReq) ProtoMessage()

func (*DumpReq) ProtoReflect 

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

func (*DumpReq) Reset 

func (x *DumpReq) Reset()

func (*DumpReq) SetAction 

func (x *DumpReq) SetAction(v DumpAction)

func (*DumpReq) SetCompression 

func (x *DumpReq) SetCompression(v string)

func (*DumpReq) SetCriu 

func (x *DumpReq) SetCriu(v *criu.CriuOpts)

func (*DumpReq) SetDetails 

func (x *DumpReq) SetDetails(v *Details)

func (*DumpReq) SetDir 

func (x *DumpReq) SetDir(v string)

func (*DumpReq) SetGPUFreezeType 

func (x *DumpReq) SetGPUFreezeType(v string)

func (*DumpReq) SetName 

func (x *DumpReq) SetName(v string)

func (*DumpReq) SetStreams 

func (x *DumpReq) SetStreams(v int32)

func (*DumpReq) SetType 

func (x *DumpReq) SetType(v string)

func (*DumpReq) String 

func (x *DumpReq) String() string

type DumpReq_builder 

type DumpReq_builder struct {
	Details       *Details
	Dir           string
	Name          string
	Compression   string
	Streams       int32
	Type          string
	Criu          *criu.CriuOpts
	GPUFreezeType string
	Action        DumpAction
	// contains filtered or unexported fields
}

func (DumpReq_builder) Build 

func (b0 DumpReq_builder) Build() *DumpReq

type DumpResp 

type DumpResp struct {
	Messages []string      `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"` // messages from the dump
	Paths    []string      `protobuf:"bytes,2,rep,name=Paths,proto3" json:"Paths,omitempty"`       // path to the dump file(s)
	State    *ProcessState `protobuf:"bytes,3,opt,name=State,proto3" json:"State,omitempty"`       // state of the process(es) during the dump
	// contains filtered or unexported fields
}

func (*DumpResp) ClearState 

func (x *DumpResp) ClearState()

func (*DumpResp) GetMessages 

func (x *DumpResp) GetMessages() []string

func (*DumpResp) GetPaths 

func (x *DumpResp) GetPaths() []string

func (*DumpResp) GetState 

func (x *DumpResp) GetState() *ProcessState

func (*DumpResp) HasState 

func (x *DumpResp) HasState() bool

func (*DumpResp) ProtoMessage 

func (*DumpResp) ProtoMessage()

func (*DumpResp) ProtoReflect 

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

func (*DumpResp) Reset 

func (x *DumpResp) Reset()

func (*DumpResp) SetMessages 

func (x *DumpResp) SetMessages(v []string)

func (*DumpResp) SetPaths 

func (x *DumpResp) SetPaths(v []string)

func (*DumpResp) SetState 

func (x *DumpResp) SetState(v *ProcessState)

func (*DumpResp) String 

func (x *DumpResp) String() string

type DumpResp_builder 

type DumpResp_builder struct {
	Messages []string
	Paths    []string
	State    *ProcessState
	// contains filtered or unexported fields
}

func (DumpResp_builder) Build 

func (b0 DumpResp_builder) Build() *DumpResp

type DumpVMReq 

type DumpVMReq struct {
	Details *Details `protobuf:"bytes,1,opt,name=Details,proto3" json:"Details,omitempty"` // details about the VM to dump
	Dir     string   `protobuf:"bytes,2,opt,name=Dir,proto3" json:"Dir,omitempty"`         // directory to dump the VM to
	Type    string   `protobuf:"bytes,3,opt,name=Type,proto3" json:"Type,omitempty"`       // type of the VM, e.g., qemu, kvm
	// contains filtered or unexported fields
}

func (*DumpVMReq) ClearDetails 

func (x *DumpVMReq) ClearDetails()

func (*DumpVMReq) GetDetails 

func (x *DumpVMReq) GetDetails() *Details

func (*DumpVMReq) GetDir 

func (x *DumpVMReq) GetDir() string

func (*DumpVMReq) GetType 

func (x *DumpVMReq) GetType() string

func (*DumpVMReq) HasDetails 

func (x *DumpVMReq) HasDetails() bool

func (*DumpVMReq) ProtoMessage 

func (*DumpVMReq) ProtoMessage()

func (*DumpVMReq) ProtoReflect 

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

func (*DumpVMReq) Reset 

func (x *DumpVMReq) Reset()

func (*DumpVMReq) SetDetails 

func (x *DumpVMReq) SetDetails(v *Details)

func (*DumpVMReq) SetDir 

func (x *DumpVMReq) SetDir(v string)

func (*DumpVMReq) SetType 

func (x *DumpVMReq) SetType(v string)

func (*DumpVMReq) String 

func (x *DumpVMReq) String() string

type DumpVMReq_builder 

type DumpVMReq_builder struct {
	Details *Details
	Dir     string
	Type    string
	// contains filtered or unexported fields
}

func (DumpVMReq_builder) Build 

func (b0 DumpVMReq_builder) Build() *DumpVMReq

type DumpVMResp 

type DumpVMResp struct {
	TarDumpDir string `protobuf:"bytes,1,opt,name=TarDumpDir,proto3" json:"TarDumpDir,omitempty"` // directory where the VM dump is stored
	// contains filtered or unexported fields
}

func (*DumpVMResp) GetTarDumpDir 

func (x *DumpVMResp) GetTarDumpDir() string

func (*DumpVMResp) ProtoMessage 

func (*DumpVMResp) ProtoMessage()

func (*DumpVMResp) ProtoReflect 

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

func (*DumpVMResp) Reset 

func (x *DumpVMResp) Reset()

func (*DumpVMResp) SetTarDumpDir 

func (x *DumpVMResp) SetTarDumpDir(v string)

func (*DumpVMResp) String 

func (x *DumpVMResp) String() string

type DumpVMResp_builder 

type DumpVMResp_builder struct {
	TarDumpDir string
	// contains filtered or unexported fields
}

func (DumpVMResp_builder) Build 

func (b0 DumpVMResp_builder) Build() *DumpVMResp

type Empty 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Empty_builder 

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

func (Empty_builder) Build 

func (b0 Empty_builder) Build() *Empty

type File 

type File 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"`
	MountID uint64 `protobuf:"varint,4,opt,name=MountID,proto3" json:"MountID,omitempty"`
	Inode   uint64 `protobuf:"varint,5,opt,name=Inode,proto3" json:"Inode,omitempty"`
	IsTTY   bool   `protobuf:"varint,6,opt,name=IsTTY,proto3" json:"IsTTY,omitempty"`
	Dev     uint64 `protobuf:"varint,7,opt,name=Dev,proto3" json:"Dev,omitempty"`
	Rdev    uint64 `protobuf:"varint,8,opt,name=Rdev,proto3" json:"Rdev,omitempty"`
	// contains filtered or unexported fields
}

func (*File) GetDev 

func (x *File) GetDev() uint64

func (*File) GetFd 

func (x *File) GetFd() uint64

func (*File) GetInode 

func (x *File) GetInode() uint64

func (*File) GetIsTTY 

func (x *File) GetIsTTY() bool

func (*File) GetMode 

func (x *File) GetMode() string

func (*File) GetMountID 

func (x *File) GetMountID() uint64

func (*File) GetPath 

func (x *File) GetPath() string

func (*File) GetRdev 

func (x *File) GetRdev() uint64

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect 

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

func (*File) Reset 

func (x *File) Reset()

func (*File) SetDev 

func (x *File) SetDev(v uint64)

func (*File) SetFd 

func (x *File) SetFd(v uint64)

func (*File) SetInode 

func (x *File) SetInode(v uint64)

func (*File) SetIsTTY 

func (x *File) SetIsTTY(v bool)

func (*File) SetMode 

func (x *File) SetMode(v string)

func (*File) SetMountID 

func (x *File) SetMountID(v uint64)

func (*File) SetPath 

func (x *File) SetPath(v string)

func (*File) SetRdev 

func (x *File) SetRdev(v uint64)

func (*File) String 

func (x *File) String() string

type File_builder 

type File_builder struct {
	Path    string
	Fd      uint64
	Mode    string
	MountID uint64
	Inode   uint64
	IsTTY   bool
	Dev     uint64
	Rdev    uint64
	// contains filtered or unexported fields
}

func (File_builder) Build 

func (b0 File_builder) Build() *File

type GetCheckpointReq 

type GetCheckpointReq struct {
	ID  *string `protobuf:"bytes,1,opt,name=ID,proto3,oneof" json:"ID,omitempty"`   // Get a specific checkpoint
	JID *string `protobuf:"bytes,2,opt,name=JID,proto3,oneof" json:"JID,omitempty"` // Get latest checkpoint for a job
	// contains filtered or unexported fields
}

func (*GetCheckpointReq) ClearID 

func (x *GetCheckpointReq) ClearID()

func (*GetCheckpointReq) ClearJID 

func (x *GetCheckpointReq) ClearJID()

func (*GetCheckpointReq) GetID 

func (x *GetCheckpointReq) GetID() string

func (*GetCheckpointReq) GetJID 

func (x *GetCheckpointReq) GetJID() string

func (*GetCheckpointReq) HasID 

func (x *GetCheckpointReq) HasID() bool

func (*GetCheckpointReq) HasJID 

func (x *GetCheckpointReq) HasJID() bool

func (*GetCheckpointReq) ProtoMessage 

func (*GetCheckpointReq) ProtoMessage()

func (*GetCheckpointReq) ProtoReflect 

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

func (*GetCheckpointReq) Reset 

func (x *GetCheckpointReq) Reset()

func (*GetCheckpointReq) SetID 

func (x *GetCheckpointReq) SetID(v string)

func (*GetCheckpointReq) SetJID 

func (x *GetCheckpointReq) SetJID(v string)

func (*GetCheckpointReq) String 

func (x *GetCheckpointReq) String() string

type GetCheckpointReq_builder 

type GetCheckpointReq_builder struct {
	ID  *string
	JID *string
	// contains filtered or unexported fields
}

func (GetCheckpointReq_builder) Build 

func (b0 GetCheckpointReq_builder) Build() *GetCheckpointReq

type GetCheckpointResp 

type GetCheckpointResp struct {
	Checkpoint *Checkpoint `protobuf:"bytes,1,opt,name=Checkpoint,proto3,oneof" json:"Checkpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCheckpointResp) ClearCheckpoint 

func (x *GetCheckpointResp) ClearCheckpoint()

func (*GetCheckpointResp) GetCheckpoint 

func (x *GetCheckpointResp) GetCheckpoint() *Checkpoint

func (*GetCheckpointResp) HasCheckpoint 

func (x *GetCheckpointResp) HasCheckpoint() bool

func (*GetCheckpointResp) ProtoMessage 

func (*GetCheckpointResp) ProtoMessage()

func (*GetCheckpointResp) ProtoReflect 

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

func (*GetCheckpointResp) Reset 

func (x *GetCheckpointResp) Reset()

func (*GetCheckpointResp) SetCheckpoint 

func (x *GetCheckpointResp) SetCheckpoint(v *Checkpoint)

func (*GetCheckpointResp) String 

func (x *GetCheckpointResp) String() string

type GetCheckpointResp_builder 

type GetCheckpointResp_builder struct {
	Checkpoint *Checkpoint
	// contains filtered or unexported fields
}

func (GetCheckpointResp_builder) Build 

func (b0 GetCheckpointResp_builder) Build() *GetCheckpointResp

type GetReq 

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

func (*GetReq) GetJID 

func (x *GetReq) GetJID() string

func (*GetReq) ProtoMessage 

func (*GetReq) ProtoMessage()

func (*GetReq) ProtoReflect 

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

func (*GetReq) Reset 

func (x *GetReq) Reset()

func (*GetReq) SetJID 

func (x *GetReq) SetJID(v string)

func (*GetReq) String 

func (x *GetReq) String() string

type GetReq_builder 

type GetReq_builder struct {
	JID string
	// contains filtered or unexported fields
}

func (GetReq_builder) Build 

func (b0 GetReq_builder) Build() *GetReq

type GetResp 

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

func (*GetResp) ClearJob 

func (x *GetResp) ClearJob()

func (*GetResp) GetJob 

func (x *GetResp) GetJob() *Job

func (*GetResp) HasJob 

func (x *GetResp) HasJob() bool

func (*GetResp) ProtoMessage 

func (*GetResp) ProtoMessage()

func (*GetResp) ProtoReflect 

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

func (*GetResp) Reset 

func (x *GetResp) Reset()

func (*GetResp) SetJob 

func (x *GetResp) SetJob(v *Job)

func (*GetResp) String 

func (x *GetResp) String() string

type GetResp_builder 

type GetResp_builder struct {
	Job *Job
	// contains filtered or unexported fields
}

func (GetResp_builder) Build 

func (b0 GetResp_builder) Build() *GetResp

type HealthCheckComponent 

type HealthCheckComponent struct {
	Name     string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Data     string   `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	Errors   []string `protobuf:"bytes,3,rep,name=Errors,proto3" json:"Errors,omitempty"`
	Warnings []string `protobuf:"bytes,4,rep,name=Warnings,proto3" json:"Warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckComponent) GetData 

func (x *HealthCheckComponent) GetData() string

func (*HealthCheckComponent) GetErrors 

func (x *HealthCheckComponent) GetErrors() []string

func (*HealthCheckComponent) GetName 

func (x *HealthCheckComponent) GetName() string

func (*HealthCheckComponent) GetWarnings 

func (x *HealthCheckComponent) GetWarnings() []string

func (*HealthCheckComponent) ProtoMessage 

func (*HealthCheckComponent) ProtoMessage()

func (*HealthCheckComponent) ProtoReflect 

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

func (*HealthCheckComponent) Reset 

func (x *HealthCheckComponent) Reset()

func (*HealthCheckComponent) SetData 

func (x *HealthCheckComponent) SetData(v string)

func (*HealthCheckComponent) SetErrors 

func (x *HealthCheckComponent) SetErrors(v []string)

func (*HealthCheckComponent) SetName 

func (x *HealthCheckComponent) SetName(v string)

func (*HealthCheckComponent) SetWarnings 

func (x *HealthCheckComponent) SetWarnings(v []string)

func (*HealthCheckComponent) String 

func (x *HealthCheckComponent) String() string

type HealthCheckComponent_builder 

type HealthCheckComponent_builder struct {
	Name     string
	Data     string
	Errors   []string
	Warnings []string
	// contains filtered or unexported fields
}

func (HealthCheckComponent_builder) Build 

func (b0 HealthCheckComponent_builder) Build() *HealthCheckComponent

type HealthCheckReq 

type HealthCheckReq struct {
	Full bool `protobuf:"varint,1,opt,name=Full,proto3" json:"Full,omitempty"` // Health check installed plugins too.
	// contains filtered or unexported fields
}

func (*HealthCheckReq) GetFull 

func (x *HealthCheckReq) GetFull() bool

func (*HealthCheckReq) ProtoMessage 

func (*HealthCheckReq) ProtoMessage()

func (*HealthCheckReq) ProtoReflect 

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

func (*HealthCheckReq) Reset 

func (x *HealthCheckReq) Reset()

func (*HealthCheckReq) SetFull 

func (x *HealthCheckReq) SetFull(v bool)

func (*HealthCheckReq) String 

func (x *HealthCheckReq) String() string

type HealthCheckReq_builder 

type HealthCheckReq_builder struct {
	Full bool
	// contains filtered or unexported fields
}

func (HealthCheckReq_builder) Build 

func (b0 HealthCheckReq_builder) Build() *HealthCheckReq

type HealthCheckResp 

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

func (*HealthCheckResp) GetResults 

func (x *HealthCheckResp) GetResults() []*HealthCheckResult

func (*HealthCheckResp) ProtoMessage 

func (*HealthCheckResp) ProtoMessage()

func (*HealthCheckResp) ProtoReflect 

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

func (*HealthCheckResp) Reset 

func (x *HealthCheckResp) Reset()

func (*HealthCheckResp) SetResults 

func (x *HealthCheckResp) SetResults(v []*HealthCheckResult)

func (*HealthCheckResp) String 

func (x *HealthCheckResp) String() string

type HealthCheckResp_builder 

type HealthCheckResp_builder struct {
	Results []*HealthCheckResult
	// contains filtered or unexported fields
}

func (HealthCheckResp_builder) Build 

func (b0 HealthCheckResp_builder) Build() *HealthCheckResp

type HealthCheckResult 

type HealthCheckResult struct {
	Name       string                  `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Components []*HealthCheckComponent `protobuf:"bytes,2,rep,name=Components,proto3" json:"Components,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthCheckResult) GetComponents 

func (x *HealthCheckResult) GetComponents() []*HealthCheckComponent

func (*HealthCheckResult) GetName 

func (x *HealthCheckResult) GetName() string

func (*HealthCheckResult) ProtoMessage 

func (*HealthCheckResult) ProtoMessage()

func (*HealthCheckResult) ProtoReflect 

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

func (*HealthCheckResult) Reset 

func (x *HealthCheckResult) Reset()

func (*HealthCheckResult) SetComponents 

func (x *HealthCheckResult) SetComponents(v []*HealthCheckComponent)

func (*HealthCheckResult) SetName 

func (x *HealthCheckResult) SetName(v string)

func (*HealthCheckResult) String 

func (x *HealthCheckResult) String() string

type HealthCheckResult_builder 

type HealthCheckResult_builder struct {
	Name       string
	Components []*HealthCheckComponent
	// contains filtered or unexported fields
}

func (HealthCheckResult_builder) Build 

func (b0 HealthCheckResult_builder) Build() *HealthCheckResult

type Host 

type Host struct {
	ID                   string  `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	MAC                  string  `protobuf:"bytes,2,opt,name=MAC,proto3" json:"MAC,omitempty"`
	Hostname             string  `protobuf:"bytes,3,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	OS                   string  `protobuf:"bytes,4,opt,name=OS,proto3" json:"OS,omitempty"`
	Platform             string  `protobuf:"bytes,5,opt,name=Platform,proto3" json:"Platform,omitempty"`
	KernelVersion        string  `protobuf:"bytes,6,opt,name=KernelVersion,proto3" json:"KernelVersion,omitempty"`
	KernelArch           string  `protobuf:"bytes,7,opt,name=KernelArch,proto3" json:"KernelArch,omitempty"`
	VirtualizationSystem string  `protobuf:"bytes,8,opt,name=VirtualizationSystem,proto3" json:"VirtualizationSystem,omitempty"`
	VirtualizationRole   string  `protobuf:"bytes,9,opt,name=VirtualizationRole,proto3" json:"VirtualizationRole,omitempty"`
	CPU                  *CPU    `protobuf:"bytes,10,opt,name=CPU,proto3" json:"CPU,omitempty"`
	Memory               *Memory `protobuf:"bytes,11,opt,name=Memory,proto3" json:"Memory,omitempty"`
	// contains filtered or unexported fields
}

func (*Host) ClearCPU 

func (x *Host) ClearCPU()

func (*Host) ClearMemory 

func (x *Host) ClearMemory()

func (*Host) GetCPU 

func (x *Host) GetCPU() *CPU

func (*Host) GetHostname 

func (x *Host) GetHostname() string

func (*Host) GetID 

func (x *Host) GetID() string

func (*Host) GetKernelArch 

func (x *Host) GetKernelArch() string

func (*Host) GetKernelVersion 

func (x *Host) GetKernelVersion() string

func (*Host) GetMAC 

func (x *Host) GetMAC() string

func (*Host) GetMemory 

func (x *Host) GetMemory() *Memory

func (*Host) GetOS 

func (x *Host) GetOS() string

func (*Host) GetPlatform 

func (x *Host) GetPlatform() string

func (*Host) GetVirtualizationRole 

func (x *Host) GetVirtualizationRole() string

func (*Host) GetVirtualizationSystem 

func (x *Host) GetVirtualizationSystem() string

func (*Host) HasCPU 

func (x *Host) HasCPU() bool

func (*Host) HasMemory 

func (x *Host) HasMemory() bool

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) ProtoReflect 

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

func (*Host) Reset 

func (x *Host) Reset()

func (*Host) SetCPU 

func (x *Host) SetCPU(v *CPU)

func (*Host) SetHostname 

func (x *Host) SetHostname(v string)

func (*Host) SetID 

func (x *Host) SetID(v string)

func (*Host) SetKernelArch 

func (x *Host) SetKernelArch(v string)

func (*Host) SetKernelVersion 

func (x *Host) SetKernelVersion(v string)

func (*Host) SetMAC 

func (x *Host) SetMAC(v string)

func (*Host) SetMemory 

func (x *Host) SetMemory(v *Memory)

func (*Host) SetOS 

func (x *Host) SetOS(v string)

func (*Host) SetPlatform 

func (x *Host) SetPlatform(v string)

func (*Host) SetVirtualizationRole 

func (x *Host) SetVirtualizationRole(v string)

func (*Host) SetVirtualizationSystem 

func (x *Host) SetVirtualizationSystem(v string)

func (*Host) String 

func (x *Host) String() string

type Host_builder 

type Host_builder struct {
	ID                   string
	MAC                  string
	Hostname             string
	OS                   string
	Platform             string
	KernelVersion        string
	KernelArch           string
	VirtualizationSystem string
	VirtualizationRole   string
	CPU                  *CPU
	Memory               *Memory
	// contains filtered or unexported fields
}

func (Host_builder) Build 

func (b0 Host_builder) Build() *Host

type Job 

type Job struct {
	Details *Details      `protobuf:"bytes,1,opt,name=Details,proto3" json:"Details,omitempty"` // plugin-specific or type-specific details
	JID     string        `protobuf:"bytes,2,opt,name=JID,proto3" json:"JID,omitempty"`         // unique job ID
	Type    string        `protobuf:"bytes,3,opt,name=Type,proto3" json:"Type,omitempty"`       // type of the job, e.g., runc, containerd, kata
	State   *ProcessState `protobuf:"bytes,4,opt,name=State,proto3" json:"State,omitempty"`     // process state of the job
	Log     string        `protobuf:"bytes,5,opt,name=Log,proto3" json:"Log,omitempty"`         // standard IO log file for the job
	// contains filtered or unexported fields
}

func (*Job) ClearDetails 

func (x *Job) ClearDetails()

func (*Job) ClearState 

func (x *Job) ClearState()

func (*Job) GetDetails 

func (x *Job) GetDetails() *Details

func (*Job) GetJID 

func (x *Job) GetJID() string

func (*Job) GetLog 

func (x *Job) GetLog() string

func (*Job) GetState 

func (x *Job) GetState() *ProcessState

func (*Job) GetType 

func (x *Job) GetType() string

func (*Job) HasDetails 

func (x *Job) HasDetails() bool

func (*Job) HasState 

func (x *Job) HasState() bool

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) SetDetails 

func (x *Job) SetDetails(v *Details)

func (*Job) SetJID 

func (x *Job) SetJID(v string)

func (*Job) SetLog 

func (x *Job) SetLog(v string)

func (*Job) SetState 

func (x *Job) SetState(v *ProcessState)

func (*Job) SetType 

func (x *Job) SetType(v string)

func (*Job) String 

func (x *Job) String() string

type Job_builder 

type Job_builder struct {
	Details *Details
	JID     string
	Type    string
	State   *ProcessState
	Log     string
	// contains filtered or unexported fields
}

func (Job_builder) Build 

func (b0 Job_builder) Build() *Job

type KillReq 

type KillReq struct {
	JIDs   []string `protobuf:"bytes,1,rep,name=JIDs,proto3" json:"JIDs,omitempty"`      // JIDs of the jobs to kill
	Signal int32    `protobuf:"varint,2,opt,name=Signal,proto3" json:"Signal,omitempty"` // signal to send to the jobs
	// contains filtered or unexported fields
}

func (*KillReq) GetJIDs 

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

func (*KillReq) GetSignal 

func (x *KillReq) GetSignal() int32

func (*KillReq) ProtoMessage 

func (*KillReq) ProtoMessage()

func (*KillReq) ProtoReflect 

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

func (*KillReq) Reset 

func (x *KillReq) Reset()

func (*KillReq) SetJIDs 

func (x *KillReq) SetJIDs(v []string)

func (*KillReq) SetSignal 

func (x *KillReq) SetSignal(v int32)

func (*KillReq) String 

func (x *KillReq) String() string

type KillReq_builder 

type KillReq_builder struct {
	JIDs   []string
	Signal int32
	// contains filtered or unexported fields
}

func (KillReq_builder) Build 

func (b0 KillReq_builder) Build() *KillReq

type KillResp 

type KillResp struct {
	Messages []string `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"` // messages from the kill operation
	// contains filtered or unexported fields
}

func (*KillResp) GetMessages 

func (x *KillResp) GetMessages() []string

func (*KillResp) ProtoMessage 

func (*KillResp) ProtoMessage()

func (*KillResp) ProtoReflect 

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

func (*KillResp) Reset 

func (x *KillResp) Reset()

func (*KillResp) SetMessages 

func (x *KillResp) SetMessages(v []string)

func (*KillResp) String 

func (x *KillResp) String() string

type KillResp_builder 

type KillResp_builder struct {
	Messages []string
	// contains filtered or unexported fields
}

func (KillResp_builder) Build 

func (b0 KillResp_builder) Build() *KillResp

type ListCheckpointsReq 

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

func (*ListCheckpointsReq) GetJID 

func (x *ListCheckpointsReq) GetJID() string

func (*ListCheckpointsReq) ProtoMessage 

func (*ListCheckpointsReq) ProtoMessage()

func (*ListCheckpointsReq) ProtoReflect 

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

func (*ListCheckpointsReq) Reset 

func (x *ListCheckpointsReq) Reset()

func (*ListCheckpointsReq) SetJID 

func (x *ListCheckpointsReq) SetJID(v string)

func (*ListCheckpointsReq) String 

func (x *ListCheckpointsReq) String() string

type ListCheckpointsReq_builder 

type ListCheckpointsReq_builder struct {
	JID string
	// contains filtered or unexported fields
}

func (ListCheckpointsReq_builder) Build 

func (b0 ListCheckpointsReq_builder) Build() *ListCheckpointsReq

type ListCheckpointsResp 

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

func (*ListCheckpointsResp) GetCheckpoints 

func (x *ListCheckpointsResp) GetCheckpoints() []*Checkpoint

func (*ListCheckpointsResp) ProtoMessage 

func (*ListCheckpointsResp) ProtoMessage()

func (*ListCheckpointsResp) ProtoReflect 

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

func (*ListCheckpointsResp) Reset 

func (x *ListCheckpointsResp) Reset()

func (*ListCheckpointsResp) SetCheckpoints 

func (x *ListCheckpointsResp) SetCheckpoints(v []*Checkpoint)

func (*ListCheckpointsResp) String 

func (x *ListCheckpointsResp) String() string

type ListCheckpointsResp_builder 

type ListCheckpointsResp_builder struct {
	Checkpoints []*Checkpoint
	// contains filtered or unexported fields
}

func (ListCheckpointsResp_builder) Build 

func (b0 ListCheckpointsResp_builder) Build() *ListCheckpointsResp

type ListReq 

type ListReq struct {
	Remote bool     `protobuf:"varint,1,opt,name=Remote,proto3" json:"Remote,omitempty"` // include jobs from remote hosts
	JIDs   []string `protobuf:"bytes,2,rep,name=JIDs,proto3" json:"JIDs,omitempty"`      // list specific jobs by JID
	// contains filtered or unexported fields
}

func (*ListReq) GetJIDs 

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

func (*ListReq) GetRemote 

func (x *ListReq) GetRemote() bool

func (*ListReq) ProtoMessage 

func (*ListReq) ProtoMessage()

func (*ListReq) ProtoReflect 

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

func (*ListReq) Reset 

func (x *ListReq) Reset()

func (*ListReq) SetJIDs 

func (x *ListReq) SetJIDs(v []string)

func (*ListReq) SetRemote 

func (x *ListReq) SetRemote(v bool)

func (*ListReq) String 

func (x *ListReq) String() string

type ListReq_builder 

type ListReq_builder struct {
	Remote bool
	JIDs   []string
	// contains filtered or unexported fields
}

func (ListReq_builder) Build 

func (b0 ListReq_builder) Build() *ListReq

type ListResp 

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

func (*ListResp) GetJobs 

func (x *ListResp) GetJobs() []*Job

func (*ListResp) ProtoMessage 

func (*ListResp) ProtoMessage()

func (*ListResp) ProtoReflect 

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

func (*ListResp) Reset 

func (x *ListResp) Reset()

func (*ListResp) SetJobs 

func (x *ListResp) SetJobs(v []*Job)

func (*ListResp) String 

func (x *ListResp) String() string

type ListResp_builder 

type ListResp_builder struct {
	Jobs []*Job
	// contains filtered or unexported fields
}

func (ListResp_builder) Build 

func (b0 ListResp_builder) Build() *ListResp

type Memory 

type Memory 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 (*Memory) GetAvailable 

func (x *Memory) GetAvailable() uint64

func (*Memory) GetTotal 

func (x *Memory) GetTotal() uint64

func (*Memory) GetUsed 

func (x *Memory) GetUsed() uint64

func (*Memory) ProtoMessage 

func (*Memory) ProtoMessage()

func (*Memory) ProtoReflect 

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

func (*Memory) Reset 

func (x *Memory) Reset()

func (*Memory) SetAvailable 

func (x *Memory) SetAvailable(v uint64)

func (*Memory) SetTotal 

func (x *Memory) SetTotal(v uint64)

func (*Memory) SetUsed 

func (x *Memory) SetUsed(v uint64)

func (*Memory) String 

func (x *Memory) String() string

type Memory_builder 

type Memory_builder struct {
	Total     uint64
	Available uint64
	Used      uint64
	// contains filtered or unexported fields
}

func (Memory_builder) Build 

func (b0 Memory_builder) Build() *Memory

type Mount 

type Mount struct {
	ID         uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Parent     int32  `protobuf:"varint,2,opt,name=Parent,proto3" json:"Parent,omitempty"`
	Major      int32  `protobuf:"varint,3,opt,name=Major,proto3" json:"Major,omitempty"`
	Minor      int32  `protobuf:"varint,4,opt,name=Minor,proto3" json:"Minor,omitempty"`
	Root       string `protobuf:"bytes,5,opt,name=Root,proto3" json:"Root,omitempty"`
	MountPoint string `protobuf:"bytes,6,opt,name=MountPoint,proto3" json:"MountPoint,omitempty"`
	Options    string `protobuf:"bytes,7,opt,name=Options,proto3" json:"Options,omitempty"`
	FSType     string `protobuf:"bytes,8,opt,name=FSType,proto3" json:"FSType,omitempty"`
	// contains filtered or unexported fields
}

func (*Mount) GetFSType 

func (x *Mount) GetFSType() string

func (*Mount) GetID 

func (x *Mount) GetID() uint64

func (*Mount) GetMajor 

func (x *Mount) GetMajor() int32

func (*Mount) GetMinor 

func (x *Mount) GetMinor() int32

func (*Mount) GetMountPoint 

func (x *Mount) GetMountPoint() string

func (*Mount) GetOptions 

func (x *Mount) GetOptions() string

func (*Mount) GetParent 

func (x *Mount) GetParent() int32

func (*Mount) GetRoot 

func (x *Mount) GetRoot() string

func (*Mount) ProtoMessage 

func (*Mount) ProtoMessage()

func (*Mount) ProtoReflect 

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

func (*Mount) Reset 

func (x *Mount) Reset()

func (*Mount) SetFSType 

func (x *Mount) SetFSType(v string)

func (*Mount) SetID 

func (x *Mount) SetID(v uint64)

func (*Mount) SetMajor 

func (x *Mount) SetMajor(v int32)

func (*Mount) SetMinor 

func (x *Mount) SetMinor(v int32)

func (*Mount) SetMountPoint 

func (x *Mount) SetMountPoint(v string)

func (*Mount) SetOptions 

func (x *Mount) SetOptions(v string)

func (*Mount) SetParent 

func (x *Mount) SetParent(v int32)

func (*Mount) SetRoot 

func (x *Mount) SetRoot(v string)

func (*Mount) String 

func (x *Mount) String() string

type Mount_builder 

type Mount_builder struct {
	ID         uint64
	Parent     int32
	Major      int32
	Minor      int32
	Root       string
	MountPoint string
	Options    string
	FSType     string
	// contains filtered or unexported fields
}

func (Mount_builder) Build 

func (b0 Mount_builder) Build() *Mount

type Process 

type Process struct {
	PID uint32 `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	// For run
	Path       string   `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`
	WorkingDir string   `protobuf:"bytes,3,opt,name=WorkingDir,proto3" json:"WorkingDir,omitempty"`
	Args       []string `protobuf:"bytes,4,rep,name=Args,proto3" json:"Args,omitempty"`
	// contains filtered or unexported fields
}

func (*Process) GetArgs 

func (x *Process) GetArgs() []string

func (*Process) GetPID 

func (x *Process) GetPID() uint32

func (*Process) GetPath 

func (x *Process) GetPath() string

func (*Process) GetWorkingDir 

func (x *Process) GetWorkingDir() string

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) SetArgs 

func (x *Process) SetArgs(v []string)

func (*Process) SetPID 

func (x *Process) SetPID(v uint32)

func (*Process) SetPath 

func (x *Process) SetPath(v string)

func (*Process) SetWorkingDir 

func (x *Process) SetWorkingDir(v string)

func (*Process) String 

func (x *Process) String() string

type ProcessState 

type ProcessState struct {
	PID             uint32          `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	Cmdline         string          `protobuf:"bytes,2,opt,name=Cmdline,proto3" json:"Cmdline,omitempty"`      // the original command line of the process
	StartTime       uint64          `protobuf:"varint,3,opt,name=StartTime,proto3" json:"StartTime,omitempty"` // in Unix milliseconds
	OpenFiles       []*File         `protobuf:"bytes,4,rep,name=OpenFiles,proto3" json:"OpenFiles,omitempty"`
	OpenConnections []*Connection   `protobuf:"bytes,5,rep,name=OpenConnections,proto3" json:"OpenConnections,omitempty"`
	Mounts          []*Mount        `protobuf:"bytes,6,rep,name=Mounts,proto3" json:"Mounts,omitempty"`
	WorkingDir      string          `protobuf:"bytes,7,opt,name=WorkingDir,proto3" json:"WorkingDir,omitempty"`
	Status          string          `protobuf:"bytes,8,opt,name=Status,proto3" json:"Status,omitempty"`
	IsRunning       bool            `protobuf:"varint,9,opt,name=IsRunning,proto3" json:"IsRunning,omitempty"`
	Host            *Host           `protobuf:"bytes,11,opt,name=Host,proto3" json:"Host,omitempty"`
	UIDs            []uint32        `protobuf:"varint,12,rep,packed,name=UIDs,proto3" json:"UIDs,omitempty"`
	GIDs            []uint32        `protobuf:"varint,13,rep,packed,name=GIDs,proto3" json:"GIDs,omitempty"`
	Groups          []uint32        `protobuf:"varint,14,rep,packed,name=Groups,proto3" json:"Groups,omitempty"`
	SID             uint32          `protobuf:"varint,15,opt,name=SID,proto3" json:"SID,omitempty"` // session ID
	GPUEnabled      bool            `protobuf:"varint,16,opt,name=GPUEnabled,proto3" json:"GPUEnabled,omitempty"`
	GPUID           string          `protobuf:"bytes,17,opt,name=GPUID,proto3" json:"GPUID,omitempty"`       // GPU controller ID
	Children        []*ProcessState `protobuf:"bytes,18,rep,name=Children,proto3" json:"Children,omitempty"` // child processes
	// contains filtered or unexported fields
}

func (*ProcessState) ClearHost 

func (x *ProcessState) ClearHost()

func (*ProcessState) GetChildren 

func (x *ProcessState) GetChildren() []*ProcessState

func (*ProcessState) GetCmdline 

func (x *ProcessState) GetCmdline() string

func (*ProcessState) GetGIDs 

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

func (*ProcessState) GetGPUEnabled 

func (x *ProcessState) GetGPUEnabled() bool

func (*ProcessState) GetGPUID 

func (x *ProcessState) GetGPUID() string

func (*ProcessState) GetGroups 

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

func (*ProcessState) GetHost 

func (x *ProcessState) GetHost() *Host

func (*ProcessState) GetIsRunning 

func (x *ProcessState) GetIsRunning() bool

func (*ProcessState) GetMounts 

func (x *ProcessState) GetMounts() []*Mount

func (*ProcessState) GetOpenConnections 

func (x *ProcessState) GetOpenConnections() []*Connection

func (*ProcessState) GetOpenFiles 

func (x *ProcessState) GetOpenFiles() []*File

func (*ProcessState) GetPID 

func (x *ProcessState) GetPID() uint32

func (*ProcessState) GetSID 

func (x *ProcessState) GetSID() uint32

func (*ProcessState) GetStartTime 

func (x *ProcessState) GetStartTime() uint64

func (*ProcessState) GetStatus 

func (x *ProcessState) GetStatus() string

func (*ProcessState) GetUIDs 

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

func (*ProcessState) GetWorkingDir 

func (x *ProcessState) GetWorkingDir() string

func (*ProcessState) HasHost 

func (x *ProcessState) HasHost() bool

func (*ProcessState) ProtoMessage 

func (*ProcessState) ProtoMessage()

func (*ProcessState) ProtoReflect 

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

func (*ProcessState) Reset 

func (x *ProcessState) Reset()

func (*ProcessState) SetChildren 

func (x *ProcessState) SetChildren(v []*ProcessState)

func (*ProcessState) SetCmdline 

func (x *ProcessState) SetCmdline(v string)

func (*ProcessState) SetGIDs 

func (x *ProcessState) SetGIDs(v []uint32)

func (*ProcessState) SetGPUEnabled 

func (x *ProcessState) SetGPUEnabled(v bool)

func (*ProcessState) SetGPUID 

func (x *ProcessState) SetGPUID(v string)

func (*ProcessState) SetGroups 

func (x *ProcessState) SetGroups(v []uint32)

func (*ProcessState) SetHost 

func (x *ProcessState) SetHost(v *Host)

func (*ProcessState) SetIsRunning 

func (x *ProcessState) SetIsRunning(v bool)

func (*ProcessState) SetMounts 

func (x *ProcessState) SetMounts(v []*Mount)

func (*ProcessState) SetOpenConnections 

func (x *ProcessState) SetOpenConnections(v []*Connection)

func (*ProcessState) SetOpenFiles 

func (x *ProcessState) SetOpenFiles(v []*File)

func (*ProcessState) SetPID 

func (x *ProcessState) SetPID(v uint32)

func (*ProcessState) SetSID 

func (x *ProcessState) SetSID(v uint32)

func (*ProcessState) SetStartTime 

func (x *ProcessState) SetStartTime(v uint64)

func (*ProcessState) SetStatus 

func (x *ProcessState) SetStatus(v string)

func (*ProcessState) SetUIDs 

func (x *ProcessState) SetUIDs(v []uint32)

func (*ProcessState) SetWorkingDir 

func (x *ProcessState) SetWorkingDir(v string)

func (*ProcessState) String 

func (x *ProcessState) String() string

type ProcessState_builder 

type ProcessState_builder struct {
	PID             uint32
	Cmdline         string
	StartTime       uint64
	OpenFiles       []*File
	OpenConnections []*Connection
	Mounts          []*Mount
	WorkingDir      string
	Status          string
	IsRunning       bool
	Host            *Host
	UIDs            []uint32
	GIDs            []uint32
	Groups          []uint32
	SID             uint32
	GPUEnabled      bool
	GPUID           string
	Children        []*ProcessState
	// contains filtered or unexported fields
}

func (ProcessState_builder) Build 

func (b0 ProcessState_builder) Build() *ProcessState

type Process_builder 

type Process_builder struct {
	PID uint32
	// For run
	Path       string
	WorkingDir string
	Args       []string
	// contains filtered or unexported fields
}

func (Process_builder) Build 

func (b0 Process_builder) Build() *Process

type QueryReq 

type QueryReq struct {
	Type string         `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Runc *runc.QueryReq `protobuf:"bytes,2,opt,name=Runc,proto3,oneof" json:"Runc,omitempty"`
	K8S  *k8s.QueryReq  `protobuf:"bytes,3,opt,name=K8s,proto3,oneof" json:"K8s,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryReq) ClearK8S 

func (x *QueryReq) ClearK8S()

func (*QueryReq) ClearRunc 

func (x *QueryReq) ClearRunc()

func (*QueryReq) GetK8S 

func (x *QueryReq) GetK8S() *k8s.QueryReq

func (*QueryReq) GetRunc 

func (x *QueryReq) GetRunc() *runc.QueryReq

func (*QueryReq) GetType 

func (x *QueryReq) GetType() string

func (*QueryReq) HasK8S 

func (x *QueryReq) HasK8S() bool

func (*QueryReq) HasRunc 

func (x *QueryReq) HasRunc() bool

func (*QueryReq) ProtoMessage 

func (*QueryReq) ProtoMessage()

func (*QueryReq) ProtoReflect 

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

func (*QueryReq) Reset 

func (x *QueryReq) Reset()

func (*QueryReq) SetK8S 

func (x *QueryReq) SetK8S(v *k8s.QueryReq)

func (*QueryReq) SetRunc 

func (x *QueryReq) SetRunc(v *runc.QueryReq)

func (*QueryReq) SetType 

func (x *QueryReq) SetType(v string)

func (*QueryReq) String 

func (x *QueryReq) String() string

type QueryReq_builder 

type QueryReq_builder struct {
	Type string
	Runc *runc.QueryReq
	K8S  *k8s.QueryReq
	// contains filtered or unexported fields
}

func (QueryReq_builder) Build 

func (b0 QueryReq_builder) Build() *QueryReq

type QueryResp 

type QueryResp struct {
	Messages []string        `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"`
	Runc     *runc.QueryResp `protobuf:"bytes,2,opt,name=Runc,proto3,oneof" json:"Runc,omitempty"`
	K8S      *k8s.QueryResp  `protobuf:"bytes,3,opt,name=K8s,proto3,oneof" json:"K8s,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResp) ClearK8S 

func (x *QueryResp) ClearK8S()

func (*QueryResp) ClearRunc 

func (x *QueryResp) ClearRunc()

func (*QueryResp) GetK8S 

func (x *QueryResp) GetK8S() *k8s.QueryResp

func (*QueryResp) GetMessages 

func (x *QueryResp) GetMessages() []string

func (*QueryResp) GetRunc 

func (x *QueryResp) GetRunc() *runc.QueryResp

func (*QueryResp) HasK8S 

func (x *QueryResp) HasK8S() bool

func (*QueryResp) HasRunc 

func (x *QueryResp) HasRunc() bool

func (*QueryResp) ProtoMessage 

func (*QueryResp) ProtoMessage()

func (*QueryResp) ProtoReflect 

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

func (*QueryResp) Reset 

func (x *QueryResp) Reset()

func (*QueryResp) SetK8S 

func (x *QueryResp) SetK8S(v *k8s.QueryResp)

func (*QueryResp) SetMessages 

func (x *QueryResp) SetMessages(v []string)

func (*QueryResp) SetRunc 

func (x *QueryResp) SetRunc(v *runc.QueryResp)

func (*QueryResp) String 

func (x *QueryResp) String() string

type QueryResp_builder 

type QueryResp_builder struct {
	Messages []string
	Runc     *runc.QueryResp
	K8S      *k8s.QueryResp
	// contains filtered or unexported fields
}

func (QueryResp_builder) Build 

func (b0 QueryResp_builder) Build() *QueryResp

type RestoreReq 

type RestoreReq struct {
	Details    *Details       `protobuf:"bytes,1,opt,name=Details,proto3" json:"Details,omitempty"` // details about the job, process, or container to restore
	Path       string         `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`       // compression is auto-detected
	PidFile    string         `protobuf:"bytes,3,opt,name=PidFile,proto3" json:"PidFile,omitempty"` // file to write the PID to
	Type       string         `protobuf:"bytes,4,opt,name=Type,proto3" json:"Type,omitempty"`       // type of the restore, e.g., runc, containerd, kata
	Criu       *criu.CriuOpts `protobuf:"bytes,5,opt,name=Criu,proto3" json:"Criu,omitempty"`
	Log        string         `protobuf:"bytes,6,opt,name=Log,proto3" json:"Log,omitempty"`                // standard IO log file
	Attachable bool           `protobuf:"varint,7,opt,name=Attachable,proto3" json:"Attachable,omitempty"` // whether to restore with attachable standard IO
	UID        uint32         `protobuf:"varint,8,opt,name=UID,proto3" json:"UID,omitempty"`               // user ID of calling process
	GID        uint32         `protobuf:"varint,9,opt,name=GID,proto3" json:"GID,omitempty"`               // group ID of calling process
	Groups     []uint32       `protobuf:"varint,10,rep,packed,name=Groups,proto3" json:"Groups,omitempty"` // groups of the calling process
	Env        []string       `protobuf:"bytes,11,rep,name=Env,proto3" json:"Env,omitempty"`               // environment variables of the calling process
	// contains filtered or unexported fields
}

func (*RestoreReq) ClearCriu 

func (x *RestoreReq) ClearCriu()

func (*RestoreReq) ClearDetails 

func (x *RestoreReq) ClearDetails()

func (*RestoreReq) GetAttachable 

func (x *RestoreReq) GetAttachable() bool

func (*RestoreReq) GetCriu 

func (x *RestoreReq) GetCriu() *criu.CriuOpts

func (*RestoreReq) GetDetails 

func (x *RestoreReq) GetDetails() *Details

func (*RestoreReq) GetEnv 

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

func (*RestoreReq) GetGID 

func (x *RestoreReq) GetGID() uint32

func (*RestoreReq) GetGroups 

func (x *RestoreReq) GetGroups() []uint32

func (*RestoreReq) GetLog 

func (x *RestoreReq) GetLog() string

func (*RestoreReq) GetPath 

func (x *RestoreReq) GetPath() string

func (*RestoreReq) GetPidFile 

func (x *RestoreReq) GetPidFile() string

func (*RestoreReq) GetType 

func (x *RestoreReq) GetType() string

func (*RestoreReq) GetUID 

func (x *RestoreReq) GetUID() uint32

func (*RestoreReq) HasCriu 

func (x *RestoreReq) HasCriu() bool

func (*RestoreReq) HasDetails 

func (x *RestoreReq) HasDetails() bool

func (*RestoreReq) ProtoMessage 

func (*RestoreReq) ProtoMessage()

func (*RestoreReq) ProtoReflect 

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

func (*RestoreReq) Reset 

func (x *RestoreReq) Reset()

func (*RestoreReq) SetAttachable 

func (x *RestoreReq) SetAttachable(v bool)

func (*RestoreReq) SetCriu 

func (x *RestoreReq) SetCriu(v *criu.CriuOpts)

func (*RestoreReq) SetDetails 

func (x *RestoreReq) SetDetails(v *Details)

func (*RestoreReq) SetEnv 

func (x *RestoreReq) SetEnv(v []string)

func (*RestoreReq) SetGID 

func (x *RestoreReq) SetGID(v uint32)

func (*RestoreReq) SetGroups 

func (x *RestoreReq) SetGroups(v []uint32)

func (*RestoreReq) SetLog 

func (x *RestoreReq) SetLog(v string)

func (*RestoreReq) SetPath 

func (x *RestoreReq) SetPath(v string)

func (*RestoreReq) SetPidFile 

func (x *RestoreReq) SetPidFile(v string)

func (*RestoreReq) SetType 

func (x *RestoreReq) SetType(v string)

func (*RestoreReq) SetUID 

func (x *RestoreReq) SetUID(v uint32)

func (*RestoreReq) String 

func (x *RestoreReq) String() string

type RestoreReq_builder 

type RestoreReq_builder struct {
	Details    *Details
	Path       string
	PidFile    string
	Type       string
	Criu       *criu.CriuOpts
	Log        string
	Attachable bool
	UID        uint32
	GID        uint32
	Groups     []uint32
	Env        []string
	// contains filtered or unexported fields
}

func (RestoreReq_builder) Build 

func (b0 RestoreReq_builder) Build() *RestoreReq

type RestoreResp 

type RestoreResp struct {
	Messages []string      `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"` // messages from the restore
	PID      uint32        `protobuf:"varint,2,opt,name=PID,proto3" json:"PID,omitempty"`          // PID of the restored process
	State    *ProcessState `protobuf:"bytes,3,opt,name=State,proto3" json:"State,omitempty"`       // state of the process after restore
	// contains filtered or unexported fields
}

func (*RestoreResp) ClearState 

func (x *RestoreResp) ClearState()

func (*RestoreResp) GetMessages 

func (x *RestoreResp) GetMessages() []string

func (*RestoreResp) GetPID 

func (x *RestoreResp) GetPID() uint32

func (*RestoreResp) GetState 

func (x *RestoreResp) GetState() *ProcessState

func (*RestoreResp) HasState 

func (x *RestoreResp) HasState() bool

func (*RestoreResp) ProtoMessage 

func (*RestoreResp) ProtoMessage()

func (*RestoreResp) ProtoReflect 

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

func (*RestoreResp) Reset 

func (x *RestoreResp) Reset()

func (*RestoreResp) SetMessages 

func (x *RestoreResp) SetMessages(v []string)

func (*RestoreResp) SetPID 

func (x *RestoreResp) SetPID(v uint32)

func (*RestoreResp) SetState 

func (x *RestoreResp) SetState(v *ProcessState)

func (*RestoreResp) String 

func (x *RestoreResp) String() string

type RestoreResp_builder 

type RestoreResp_builder struct {
	Messages []string
	PID      uint32
	State    *ProcessState
	// contains filtered or unexported fields
}

func (RestoreResp_builder) Build 

func (b0 RestoreResp_builder) Build() *RestoreResp

type RestoreVMReq 

type RestoreVMReq struct {
	VMSnapshot        bool                 `protobuf:"varint,1,opt,name=VMSnapshot,proto3" json:"VMSnapshot,omitempty"`        // whether to restore a VM snapshot
	VMSocketPath      string               `protobuf:"bytes,2,opt,name=VMSocketPath,proto3" json:"VMSocketPath,omitempty"`     // path to the VM socket
	VMSnapshotPath    string               `protobuf:"bytes,3,opt,name=VMSnapshotPath,proto3" json:"VMSnapshotPath,omitempty"` // path to the VM snapshot
	RestoredNetConfig []*RestoredNetConfig `protobuf:"bytes,4,rep,name=RestoredNetConfig,proto3" json:"RestoredNetConfig,omitempty"`
	Type              string               `protobuf:"bytes,5,opt,name=Type,proto3" json:"Type,omitempty"` // type of the VM, e.g., clh
	RequestIDs        []string             `protobuf:"bytes,6,rep,name=RequestIDs,proto3" json:"RequestIDs,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreVMReq) GetRequestIDs 

func (x *RestoreVMReq) GetRequestIDs() []string

func (*RestoreVMReq) GetRestoredNetConfig 

func (x *RestoreVMReq) GetRestoredNetConfig() []*RestoredNetConfig

func (*RestoreVMReq) GetType 

func (x *RestoreVMReq) GetType() string

func (*RestoreVMReq) GetVMSnapshot 

func (x *RestoreVMReq) GetVMSnapshot() bool

func (*RestoreVMReq) GetVMSnapshotPath 

func (x *RestoreVMReq) GetVMSnapshotPath() string

func (*RestoreVMReq) GetVMSocketPath 

func (x *RestoreVMReq) GetVMSocketPath() string

func (*RestoreVMReq) ProtoMessage 

func (*RestoreVMReq) ProtoMessage()

func (*RestoreVMReq) ProtoReflect 

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

func (*RestoreVMReq) Reset 

func (x *RestoreVMReq) Reset()

func (*RestoreVMReq) SetRequestIDs 

func (x *RestoreVMReq) SetRequestIDs(v []string)

func (*RestoreVMReq) SetRestoredNetConfig 

func (x *RestoreVMReq) SetRestoredNetConfig(v []*RestoredNetConfig)

func (*RestoreVMReq) SetType 

func (x *RestoreVMReq) SetType(v string)

func (*RestoreVMReq) SetVMSnapshot 

func (x *RestoreVMReq) SetVMSnapshot(v bool)

func (*RestoreVMReq) SetVMSnapshotPath 

func (x *RestoreVMReq) SetVMSnapshotPath(v string)

func (*RestoreVMReq) SetVMSocketPath 

func (x *RestoreVMReq) SetVMSocketPath(v string)

func (*RestoreVMReq) String 

func (x *RestoreVMReq) String() string

type RestoreVMReq_builder 

type RestoreVMReq_builder struct {
	VMSnapshot        bool
	VMSocketPath      string
	VMSnapshotPath    string
	RestoredNetConfig []*RestoredNetConfig
	Type              string
	RequestIDs        []string
	// contains filtered or unexported fields
}

func (RestoreVMReq_builder) Build 

func (b0 RestoreVMReq_builder) Build() *RestoreVMReq

type RestoreVMResp 

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

func (*RestoreVMResp) GetState 

func (x *RestoreVMResp) GetState() string

func (*RestoreVMResp) ProtoMessage 

func (*RestoreVMResp) ProtoMessage()

func (*RestoreVMResp) ProtoReflect 

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

func (*RestoreVMResp) Reset 

func (x *RestoreVMResp) Reset()

func (*RestoreVMResp) SetState 

func (x *RestoreVMResp) SetState(v string)

func (*RestoreVMResp) String 

func (x *RestoreVMResp) String() string

type RestoreVMResp_builder 

type RestoreVMResp_builder struct {
	State string
	// contains filtered or unexported fields
}

func (RestoreVMResp_builder) Build 

func (b0 RestoreVMResp_builder) Build() *RestoreVMResp

type RestoredNetConfig 

type RestoredNetConfig struct {
	ID     string  `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` // ID of the network configuration
	NumFDs int64   `protobuf:"varint,2,opt,name=NumFDs,proto3" json:"NumFDs,omitempty"`
	Fds    []int64 `protobuf:"varint,3,rep,packed,name=Fds,proto3" json:"Fds,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoredNetConfig) GetFds 

func (x *RestoredNetConfig) GetFds() []int64

func (*RestoredNetConfig) GetID 

func (x *RestoredNetConfig) GetID() string

func (*RestoredNetConfig) GetNumFDs 

func (x *RestoredNetConfig) GetNumFDs() int64

func (*RestoredNetConfig) ProtoMessage 

func (*RestoredNetConfig) ProtoMessage()

func (*RestoredNetConfig) ProtoReflect 

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

func (*RestoredNetConfig) Reset 

func (x *RestoredNetConfig) Reset()

func (*RestoredNetConfig) SetFds 

func (x *RestoredNetConfig) SetFds(v []int64)

func (*RestoredNetConfig) SetID 

func (x *RestoredNetConfig) SetID(v string)

func (*RestoredNetConfig) SetNumFDs 

func (x *RestoredNetConfig) SetNumFDs(v int64)

func (*RestoredNetConfig) String 

func (x *RestoredNetConfig) String() string

type RestoredNetConfig_builder 

type RestoredNetConfig_builder struct {
	ID     string
	NumFDs int64
	Fds    []int64
	// contains filtered or unexported fields
}

func (RestoredNetConfig_builder) Build 

func (b0 RestoredNetConfig_builder) Build() *RestoredNetConfig

type RunAction 

type RunAction int32
const (
	RunAction_START_NEW       RunAction = 0 // start a new job
	RunAction_MANAGE_EXISTING RunAction = 1 // manage an existing job
	RunAction_MANAGE_UPCOMING RunAction = 2 // manage an upcoming job
)

func (RunAction) Descriptor 

func (RunAction) Descriptor() protoreflect.EnumDescriptor

func (RunAction) Enum 

func (x RunAction) Enum() *RunAction

func (RunAction) Number 

func (x RunAction) Number() protoreflect.EnumNumber

func (RunAction) String 

func (x RunAction) String() string

func (RunAction) Type 

func (RunAction) Type() protoreflect.EnumType

type RunReq 

type RunReq struct {
	Details    *Details  `protobuf:"bytes,1,opt,name=Details,proto3" json:"Details,omitempty"`
	JID        string    `protobuf:"bytes,2,opt,name=JID,proto3" json:"JID,omitempty"`                              // job ID, if empty a new one will be generated
	PidFile    string    `protobuf:"bytes,3,opt,name=PidFile,proto3" json:"PidFile,omitempty"`                      // file to write the PID to
	GPUEnabled bool      `protobuf:"varint,4,opt,name=GPUEnabled,proto3" json:"GPUEnabled,omitempty"`               // whether to enable GPU C/R support for the job
	GPUTracing bool      `protobuf:"varint,5,opt,name=GPUTracing,proto3" json:"GPUTracing,omitempty"`               // whether to enable GPU tracing for the job
	Type       string    `protobuf:"bytes,6,opt,name=Type,proto3" json:"Type,omitempty"`                            // type of the job, e.g., runc, containerd, kata
	Log        string    `protobuf:"bytes,7,opt,name=Log,proto3" json:"Log,omitempty"`                              // standard IO log file
	Attachable bool      `protobuf:"varint,8,opt,name=Attachable,proto3" json:"Attachable,omitempty"`               // whether to run the job with attachable standard IO
	Action     RunAction `protobuf:"varint,9,opt,name=Action,proto3,enum=daemon.RunAction" json:"Action,omitempty"` // action to use for the job
	UID        uint32    `protobuf:"varint,10,opt,name=UID,proto3" json:"UID,omitempty"`                            // user ID of the calling process
	GID        uint32    `protobuf:"varint,11,opt,name=GID,proto3" json:"GID,omitempty"`                            // group ID of the calling process
	Groups     []uint32  `protobuf:"varint,12,rep,packed,name=Groups,proto3" json:"Groups,omitempty"`               // groups of the calling process
	Env        []string  `protobuf:"bytes,13,rep,name=Env,proto3" json:"Env,omitempty"`                             // environment variables of the calling process
	// contains filtered or unexported fields
}

func (*RunReq) ClearDetails 

func (x *RunReq) ClearDetails()

func (*RunReq) GetAction 

func (x *RunReq) GetAction() RunAction

func (*RunReq) GetAttachable 

func (x *RunReq) GetAttachable() bool

func (*RunReq) GetDetails 

func (x *RunReq) GetDetails() *Details

func (*RunReq) GetEnv 

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

func (*RunReq) GetGID 

func (x *RunReq) GetGID() uint32

func (*RunReq) GetGPUEnabled 

func (x *RunReq) GetGPUEnabled() bool

func (*RunReq) GetGPUTracing 

func (x *RunReq) GetGPUTracing() bool

func (*RunReq) GetGroups 

func (x *RunReq) GetGroups() []uint32

func (*RunReq) GetJID 

func (x *RunReq) GetJID() string

func (*RunReq) GetLog 

func (x *RunReq) GetLog() string

func (*RunReq) GetPidFile 

func (x *RunReq) GetPidFile() string

func (*RunReq) GetType 

func (x *RunReq) GetType() string

func (*RunReq) GetUID 

func (x *RunReq) GetUID() uint32

func (*RunReq) HasDetails 

func (x *RunReq) HasDetails() bool

func (*RunReq) ProtoMessage 

func (*RunReq) ProtoMessage()

func (*RunReq) ProtoReflect 

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

func (*RunReq) Reset 

func (x *RunReq) Reset()

func (*RunReq) SetAction 

func (x *RunReq) SetAction(v RunAction)

func (*RunReq) SetAttachable 

func (x *RunReq) SetAttachable(v bool)

func (*RunReq) SetDetails 

func (x *RunReq) SetDetails(v *Details)

func (*RunReq) SetEnv 

func (x *RunReq) SetEnv(v []string)

func (*RunReq) SetGID 

func (x *RunReq) SetGID(v uint32)

func (*RunReq) SetGPUEnabled 

func (x *RunReq) SetGPUEnabled(v bool)

func (*RunReq) SetGPUTracing 

func (x *RunReq) SetGPUTracing(v bool)

func (*RunReq) SetGroups 

func (x *RunReq) SetGroups(v []uint32)

func (*RunReq) SetJID 

func (x *RunReq) SetJID(v string)

func (*RunReq) SetLog 

func (x *RunReq) SetLog(v string)

func (*RunReq) SetPidFile 

func (x *RunReq) SetPidFile(v string)

func (*RunReq) SetType 

func (x *RunReq) SetType(v string)

func (*RunReq) SetUID 

func (x *RunReq) SetUID(v uint32)

func (*RunReq) String 

func (x *RunReq) String() string

type RunReq_builder 

type RunReq_builder struct {
	Details    *Details
	JID        string
	PidFile    string
	GPUEnabled bool
	GPUTracing bool
	Type       string
	Log        string
	Attachable bool
	Action     RunAction
	UID        uint32
	GID        uint32
	Groups     []uint32
	Env        []string
	// contains filtered or unexported fields
}

func (RunReq_builder) Build 

func (b0 RunReq_builder) Build() *RunReq

type RunResp 

type RunResp struct {
	Messages []string `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages,omitempty"` // messages from the run operation
	PID      uint32   `protobuf:"varint,2,opt,name=PID,proto3" json:"PID,omitempty"`          // PID of the started or managed process
	// contains filtered or unexported fields
}

func (*RunResp) GetMessages 

func (x *RunResp) GetMessages() []string

func (*RunResp) GetPID 

func (x *RunResp) GetPID() uint32

func (*RunResp) ProtoMessage 

func (*RunResp) ProtoMessage()

func (*RunResp) ProtoReflect 

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

func (*RunResp) Reset 

func (x *RunResp) Reset()

func (*RunResp) SetMessages 

func (x *RunResp) SetMessages(v []string)

func (*RunResp) SetPID 

func (x *RunResp) SetPID(v uint32)

func (*RunResp) String 

func (x *RunResp) String() string

type RunResp_builder 

type RunResp_builder struct {
	Messages []string
	PID      uint32
	// contains filtered or unexported fields
}

func (RunResp_builder) Build 

func (b0 RunResp_builder) Build() *RunResp

type SocketResp 

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

func (*SocketResp) GetSocketPath 

func (x *SocketResp) GetSocketPath() string

func (*SocketResp) ProtoMessage 

func (*SocketResp) ProtoMessage()

func (*SocketResp) ProtoReflect 

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

func (*SocketResp) Reset 

func (x *SocketResp) Reset()

func (*SocketResp) SetSocketPath 

func (x *SocketResp) SetSocketPath(v string)

func (*SocketResp) String 

func (x *SocketResp) String() string

type SocketResp_builder 

type SocketResp_builder struct {
	SocketPath string
	// contains filtered or unexported fields
}

func (SocketResp_builder) Build 

func (b0 SocketResp_builder) Build() *SocketResp

Source Files

  • checkpoint.pb.go
  • daemon.pb.go
  • health.pb.go
  • host.pb.go
  • misc.pb.go
  • process.pb.go
  • query.pb.go
  • socket.pb.go

Jump to

Keyboard shortcuts

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