task

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2023 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TaskService_Dump_FullMethodName                 = "/cedana.services.task.TaskService/Dump"
	TaskService_Restore_FullMethodName              = "/cedana.services.task.TaskService/Restore"
	TaskService_ContainerDump_FullMethodName        = "/cedana.services.task.TaskService/ContainerDump"
	TaskService_ContainerRestore_FullMethodName     = "/cedana.services.task.TaskService/ContainerRestore"
	TaskService_RuncDump_FullMethodName             = "/cedana.services.task.TaskService/RuncDump"
	TaskService_RuncRestore_FullMethodName          = "/cedana.services.task.TaskService/RuncRestore"
	TaskService_StartTask_FullMethodName            = "/cedana.services.task.TaskService/StartTask"
	TaskService_LogStreaming_FullMethodName         = "/cedana.services.task.TaskService/LogStreaming"
	TaskService_ClientStateStreaming_FullMethodName = "/cedana.services.task.TaskService/ClientStateStreaming"
	TaskService_MetaStateStreaming_FullMethodName   = "/cedana.services.task.TaskService/MetaStateStreaming"
)

Variables

View Source 
var CheckpointReason_CheckpointReasonEnum_name = map[int32]string{
	0: "INSTANCE_TERMINATION",
	1: "JOB_TERMINATION",
	2: "HEARTBEAT",
}
View Source 
var CheckpointReason_CheckpointReasonEnum_value = map[string]int32{
	"INSTANCE_TERMINATION": 0,
	"JOB_TERMINATION":      1,
	"HEARTBEAT":            2,
}
View Source 
var CheckpointState_name = map[int32]string{
	0: "CHECKPOINTED",
	1: "CHECKPOINT_FAILED",
	2: "RESTORED",
	3: "RESTORE_FAILED",
}
View Source 
var CheckpointState_value = map[string]int32{
	"CHECKPOINTED":      0,
	"CHECKPOINT_FAILED": 1,
	"RESTORED":          2,
	"RESTORE_FAILED":    3,
}
View Source 
var DumpArgs_DumpType_name = map[int32]string{
	0: "SELF_SERVE",
	1: "MARKET",
}
View Source 
var DumpArgs_DumpType_value = map[string]int32{
	"SELF_SERVE": 0,
	"MARKET":     1,
}
View Source 
var FlagEnum_name = map[int32]string{
	0: "JOB_STARTUP_FAILED",
	1: "JOB_KILLED",
	2: "JOB_IDLE",
	3: "JOB_RUNNING",
	4: "JOB_PENDING",
	5: "JOB_SETUP_FAILED",
	6: "JOB_DONE",
}
View Source 
var FlagEnum_value = map[string]int32{
	"JOB_STARTUP_FAILED": 0,
	"JOB_KILLED":         1,
	"JOB_IDLE":           2,
	"JOB_RUNNING":        3,
	"JOB_PENDING":        4,
	"JOB_SETUP_FAILED":   5,
	"JOB_DONE":           6,
}
View Source 
var ProcessState_ContainerRuntimeOpts_name = map[int32]string{
	0: "CONTAINERD",
	1: "RUNC",
}
View Source 
var ProcessState_ContainerRuntimeOpts_value = map[string]int32{
	"CONTAINERD": 0,
	"RUNC":       1,
}
View Source 
var RestoreArgs_RestoreType_name = map[int32]string{
	0: "LOCAL",
	1: "REMOTE",
}
View Source 
var RestoreArgs_RestoreType_value = map[string]int32{
	"LOCAL":  0,
	"REMOTE": 1,
}
View Source 
var TaskService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cedana.services.task.TaskService",
	HandlerType: (*TaskServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Dump",
			Handler:    _TaskService_Dump_Handler,
		},
		{
			MethodName: "Restore",
			Handler:    _TaskService_Restore_Handler,
		},
		{
			MethodName: "ContainerDump",
			Handler:    _TaskService_ContainerDump_Handler,
		},
		{
			MethodName: "ContainerRestore",
			Handler:    _TaskService_ContainerRestore_Handler,
		},
		{
			MethodName: "RuncDump",
			Handler:    _TaskService_RuncDump_Handler,
		},
		{
			MethodName: "RuncRestore",
			Handler:    _TaskService_RuncRestore_Handler,
		},
		{
			MethodName: "StartTask",
			Handler:    _TaskService_StartTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "LogStreaming",
			Handler:       _TaskService_LogStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ClientStateStreaming",
			Handler:       _TaskService_ClientStateStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "MetaStateStreaming",
			Handler:       _TaskService_MetaStateStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "task.proto",
}

TaskService_ServiceDesc is the grpc.ServiceDesc for TaskService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s grpc.ServiceRegistrar, srv TaskServiceServer)

Types

type Addr 

type Addr struct {
	IP                   string   `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"`
	Port                 uint32   `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Addr) Descriptor 

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

func (*Addr) GetIP 

func (m *Addr) GetIP() string

func (*Addr) GetPort 

func (m *Addr) GetPort() uint32

func (*Addr) ProtoMessage 

func (*Addr) ProtoMessage()

func (*Addr) Reset 

func (m *Addr) Reset()

func (*Addr) String 

func (m *Addr) String() string

func (*Addr) XXX_DiscardUnknown 

func (m *Addr) XXX_DiscardUnknown()

func (*Addr) XXX_Marshal 

func (m *Addr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Addr) XXX_Merge 

func (m *Addr) XXX_Merge(src proto.Message)

func (*Addr) XXX_Size 

func (m *Addr) XXX_Size() int

func (*Addr) XXX_Unmarshal 

func (m *Addr) XXX_Unmarshal(b []byte) error

type CheckpointReason 

type CheckpointReason struct {
	Reason               CheckpointReason_CheckpointReasonEnum `` /* 130-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*CheckpointReason) Descriptor 

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

func (*CheckpointReason) GetReason 

func (m *CheckpointReason) GetReason() CheckpointReason_CheckpointReasonEnum

func (*CheckpointReason) ProtoMessage 

func (*CheckpointReason) ProtoMessage()

func (*CheckpointReason) Reset 

func (m *CheckpointReason) Reset()

func (*CheckpointReason) String 

func (m *CheckpointReason) String() string

func (*CheckpointReason) XXX_DiscardUnknown 

func (m *CheckpointReason) XXX_DiscardUnknown()

func (*CheckpointReason) XXX_Marshal 

func (m *CheckpointReason) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckpointReason) XXX_Merge 

func (m *CheckpointReason) XXX_Merge(src proto.Message)

func (*CheckpointReason) XXX_Size 

func (m *CheckpointReason) XXX_Size() int

func (*CheckpointReason) XXX_Unmarshal 

func (m *CheckpointReason) XXX_Unmarshal(b []byte) error

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

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

func (CheckpointReason_CheckpointReasonEnum) String 

func (x CheckpointReason_CheckpointReasonEnum) String() string

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

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

func (CheckpointState) String 

func (x CheckpointState) String() string

type ClientInfo 

type ClientInfo struct {
	Id                   string   `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Hostname             string   `protobuf:"bytes,2,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
	Platform             string   `protobuf:"bytes,3,opt,name=Platform,proto3" json:"Platform,omitempty"`
	OS                   string   `protobuf:"bytes,4,opt,name=OS,proto3" json:"OS,omitempty"`
	Uptime               uint64   `protobuf:"varint,5,opt,name=Uptime,proto3" json:"Uptime,omitempty"`
	RemainingMemory      uint64   `protobuf:"varint,6,opt,name=RemainingMemory,proto3" json:"RemainingMemory,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientInfo) Descriptor 

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

func (*ClientInfo) GetHostname 

func (m *ClientInfo) GetHostname() string

func (*ClientInfo) GetId 

func (m *ClientInfo) GetId() string

func (*ClientInfo) GetOS 

func (m *ClientInfo) GetOS() string

func (*ClientInfo) GetPlatform 

func (m *ClientInfo) GetPlatform() string

func (*ClientInfo) GetRemainingMemory 

func (m *ClientInfo) GetRemainingMemory() uint64

func (*ClientInfo) GetUptime 

func (m *ClientInfo) GetUptime() uint64

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) Reset 

func (m *ClientInfo) Reset()

func (*ClientInfo) String 

func (m *ClientInfo) String() string

func (*ClientInfo) XXX_DiscardUnknown 

func (m *ClientInfo) XXX_DiscardUnknown()

func (*ClientInfo) XXX_Marshal 

func (m *ClientInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientInfo) XXX_Merge 

func (m *ClientInfo) XXX_Merge(src proto.Message)

func (*ClientInfo) XXX_Size 

func (m *ClientInfo) XXX_Size() int

func (*ClientInfo) XXX_Unmarshal 

func (m *ClientInfo) XXX_Unmarshal(b []byte) error

type ClientStateStreamingResp 

type ClientStateStreamingResp struct {
	Status               string   `protobuf:"bytes,1,opt,name=Status,proto3" json:"Status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientStateStreamingResp) Descriptor 

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

func (*ClientStateStreamingResp) GetStatus 

func (m *ClientStateStreamingResp) GetStatus() string

func (*ClientStateStreamingResp) ProtoMessage 

func (*ClientStateStreamingResp) ProtoMessage()

func (*ClientStateStreamingResp) Reset 

func (m *ClientStateStreamingResp) Reset()

func (*ClientStateStreamingResp) String 

func (m *ClientStateStreamingResp) String() string

func (*ClientStateStreamingResp) XXX_DiscardUnknown 

func (m *ClientStateStreamingResp) XXX_DiscardUnknown()

func (*ClientStateStreamingResp) XXX_Marshal 

func (m *ClientStateStreamingResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientStateStreamingResp) XXX_Merge 

func (m *ClientStateStreamingResp) XXX_Merge(src proto.Message)

func (*ClientStateStreamingResp) XXX_Size 

func (m *ClientStateStreamingResp) XXX_Size() int

func (*ClientStateStreamingResp) XXX_Unmarshal 

func (m *ClientStateStreamingResp) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConnectionStat) Descriptor 

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

func (*ConnectionStat) GetFamily 

func (m *ConnectionStat) GetFamily() uint32

func (*ConnectionStat) GetFd 

func (m *ConnectionStat) GetFd() uint32

func (*ConnectionStat) GetLaddr 

func (m *ConnectionStat) GetLaddr() *Addr

func (*ConnectionStat) GetPID 

func (m *ConnectionStat) GetPID() int32

func (*ConnectionStat) GetRaddr 

func (m *ConnectionStat) GetRaddr() *Addr

func (*ConnectionStat) GetStatus 

func (m *ConnectionStat) GetStatus() string

func (*ConnectionStat) GetType 

func (m *ConnectionStat) GetType() uint32

func (*ConnectionStat) GetUids 

func (m *ConnectionStat) GetUids() []int32

func (*ConnectionStat) ProtoMessage 

func (*ConnectionStat) ProtoMessage()

func (*ConnectionStat) Reset 

func (m *ConnectionStat) Reset()

func (*ConnectionStat) String 

func (m *ConnectionStat) String() string

func (*ConnectionStat) XXX_DiscardUnknown 

func (m *ConnectionStat) XXX_DiscardUnknown()

func (*ConnectionStat) XXX_Marshal 

func (m *ConnectionStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectionStat) XXX_Merge 

func (m *ConnectionStat) XXX_Merge(src proto.Message)

func (*ConnectionStat) XXX_Size 

func (m *ConnectionStat) XXX_Size() int

func (*ConnectionStat) XXX_Unmarshal 

func (m *ConnectionStat) XXX_Unmarshal(b []byte) error

type ContainerDumpArgs 

type ContainerDumpArgs struct {
	ContainerId          string   `protobuf:"bytes,1,opt,name=ContainerId,proto3" json:"ContainerId,omitempty"`
	Ref                  string   `protobuf:"bytes,2,opt,name=Ref,proto3" json:"Ref,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerDumpArgs) Descriptor 

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

func (*ContainerDumpArgs) GetContainerId 

func (m *ContainerDumpArgs) GetContainerId() string

func (*ContainerDumpArgs) GetRef 

func (m *ContainerDumpArgs) GetRef() string

func (*ContainerDumpArgs) ProtoMessage 

func (*ContainerDumpArgs) ProtoMessage()

func (*ContainerDumpArgs) Reset 

func (m *ContainerDumpArgs) Reset()

func (*ContainerDumpArgs) String 

func (m *ContainerDumpArgs) String() string

func (*ContainerDumpArgs) XXX_DiscardUnknown 

func (m *ContainerDumpArgs) XXX_DiscardUnknown()

func (*ContainerDumpArgs) XXX_Marshal 

func (m *ContainerDumpArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerDumpArgs) XXX_Merge 

func (m *ContainerDumpArgs) XXX_Merge(src proto.Message)

func (*ContainerDumpArgs) XXX_Size 

func (m *ContainerDumpArgs) XXX_Size() int

func (*ContainerDumpArgs) XXX_Unmarshal 

func (m *ContainerDumpArgs) XXX_Unmarshal(b []byte) error

type ContainerDumpResp 

type ContainerDumpResp struct {
	CheckpointPath       string   `protobuf:"bytes,1,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerDumpResp) Descriptor 

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

func (*ContainerDumpResp) GetCheckpointPath 

func (m *ContainerDumpResp) GetCheckpointPath() string

func (*ContainerDumpResp) GetMessage 

func (m *ContainerDumpResp) GetMessage() string

func (*ContainerDumpResp) ProtoMessage 

func (*ContainerDumpResp) ProtoMessage()

func (*ContainerDumpResp) Reset 

func (m *ContainerDumpResp) Reset()

func (*ContainerDumpResp) String 

func (m *ContainerDumpResp) String() string

func (*ContainerDumpResp) XXX_DiscardUnknown 

func (m *ContainerDumpResp) XXX_DiscardUnknown()

func (*ContainerDumpResp) XXX_Marshal 

func (m *ContainerDumpResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerDumpResp) XXX_Merge 

func (m *ContainerDumpResp) XXX_Merge(src proto.Message)

func (*ContainerDumpResp) XXX_Size 

func (m *ContainerDumpResp) XXX_Size() int

func (*ContainerDumpResp) XXX_Unmarshal 

func (m *ContainerDumpResp) XXX_Unmarshal(b []byte) error

type ContainerRestoreArgs 

type ContainerRestoreArgs struct {
	ImgPath              string   `protobuf:"bytes,1,opt,name=ImgPath,proto3" json:"ImgPath,omitempty"`
	ContainerId          string   `protobuf:"bytes,2,opt,name=ContainerId,proto3" json:"ContainerId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerRestoreArgs) Descriptor 

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

func (*ContainerRestoreArgs) GetContainerId 

func (m *ContainerRestoreArgs) GetContainerId() string

func (*ContainerRestoreArgs) GetImgPath 

func (m *ContainerRestoreArgs) GetImgPath() string

func (*ContainerRestoreArgs) ProtoMessage 

func (*ContainerRestoreArgs) ProtoMessage()

func (*ContainerRestoreArgs) Reset 

func (m *ContainerRestoreArgs) Reset()

func (*ContainerRestoreArgs) String 

func (m *ContainerRestoreArgs) String() string

func (*ContainerRestoreArgs) XXX_DiscardUnknown 

func (m *ContainerRestoreArgs) XXX_DiscardUnknown()

func (*ContainerRestoreArgs) XXX_Marshal 

func (m *ContainerRestoreArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerRestoreArgs) XXX_Merge 

func (m *ContainerRestoreArgs) XXX_Merge(src proto.Message)

func (*ContainerRestoreArgs) XXX_Size 

func (m *ContainerRestoreArgs) XXX_Size() int

func (*ContainerRestoreArgs) XXX_Unmarshal 

func (m *ContainerRestoreArgs) XXX_Unmarshal(b []byte) error

type ContainerRestoreResp 

type ContainerRestoreResp struct {
	Message              string   `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerRestoreResp) Descriptor 

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

func (*ContainerRestoreResp) GetMessage 

func (m *ContainerRestoreResp) GetMessage() string

func (*ContainerRestoreResp) ProtoMessage 

func (*ContainerRestoreResp) ProtoMessage()

func (*ContainerRestoreResp) Reset 

func (m *ContainerRestoreResp) Reset()

func (*ContainerRestoreResp) String 

func (m *ContainerRestoreResp) String() string

func (*ContainerRestoreResp) XXX_DiscardUnknown 

func (m *ContainerRestoreResp) XXX_DiscardUnknown()

func (*ContainerRestoreResp) XXX_Marshal 

func (m *ContainerRestoreResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerRestoreResp) XXX_Merge 

func (m *ContainerRestoreResp) XXX_Merge(src proto.Message)

func (*ContainerRestoreResp) XXX_Size 

func (m *ContainerRestoreResp) XXX_Size() int

func (*ContainerRestoreResp) XXX_Unmarshal 

func (m *ContainerRestoreResp) XXX_Unmarshal(b []byte) error

type CriuOpts 

type CriuOpts struct {
	ImagesDirectory         string   `protobuf:"bytes,1,opt,name=ImagesDirectory,proto3" json:"ImagesDirectory,omitempty"`
	WorkDirectory           string   `protobuf:"bytes,2,opt,name=WorkDirectory,proto3" json:"WorkDirectory,omitempty"`
	ParentImage             string   `protobuf:"bytes,3,opt,name=ParentImage,proto3" json:"ParentImage,omitempty"`
	LeaveRunning            bool     `protobuf:"varint,4,opt,name=LeaveRunning,proto3" json:"LeaveRunning,omitempty"`
	TcpEstablished          bool     `protobuf:"varint,5,opt,name=TcpEstablished,proto3" json:"TcpEstablished,omitempty"`
	ExternalUnixConnections bool     `protobuf:"varint,6,opt,name=ExternalUnixConnections,proto3" json:"ExternalUnixConnections,omitempty"`
	ShellJob                bool     `protobuf:"varint,7,opt,name=ShellJob,proto3" json:"ShellJob,omitempty"`
	FileLocks               bool     `protobuf:"varint,8,opt,name=FileLocks,proto3" json:"FileLocks,omitempty"`
	PreDump                 bool     `protobuf:"varint,9,opt,name=PreDump,proto3" json:"PreDump,omitempty"`
	EmptyNs                 uint32   `protobuf:"varint,12,opt,name=EmptyNs,proto3" json:"EmptyNs,omitempty"`
	AutoDedup               bool     `protobuf:"varint,13,opt,name=AutoDedup,proto3" json:"AutoDedup,omitempty"`
	LazyPages               bool     `protobuf:"varint,14,opt,name=LazyPages,proto3" json:"LazyPages,omitempty"`
	StatusFd                int32    `protobuf:"varint,15,opt,name=StatusFd,proto3" json:"StatusFd,omitempty"`
	LsmProfile              string   `protobuf:"bytes,16,opt,name=LsmProfile,proto3" json:"LsmProfile,omitempty"`
	LsmMountContext         string   `protobuf:"bytes,17,opt,name=LsmMountContext,proto3" json:"LsmMountContext,omitempty"`
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

func (*CriuOpts) Descriptor 

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

func (*CriuOpts) GetAutoDedup 

func (m *CriuOpts) GetAutoDedup() bool

func (*CriuOpts) GetEmptyNs 

func (m *CriuOpts) GetEmptyNs() uint32

func (*CriuOpts) GetExternalUnixConnections 

func (m *CriuOpts) GetExternalUnixConnections() bool

func (*CriuOpts) GetFileLocks 

func (m *CriuOpts) GetFileLocks() bool

func (*CriuOpts) GetImagesDirectory 

func (m *CriuOpts) GetImagesDirectory() string

func (*CriuOpts) GetLazyPages 

func (m *CriuOpts) GetLazyPages() bool

func (*CriuOpts) GetLeaveRunning 

func (m *CriuOpts) GetLeaveRunning() bool

func (*CriuOpts) GetLsmMountContext 

func (m *CriuOpts) GetLsmMountContext() string

func (*CriuOpts) GetLsmProfile 

func (m *CriuOpts) GetLsmProfile() string

func (*CriuOpts) GetParentImage 

func (m *CriuOpts) GetParentImage() string

func (*CriuOpts) GetPreDump 

func (m *CriuOpts) GetPreDump() bool

func (*CriuOpts) GetShellJob 

func (m *CriuOpts) GetShellJob() bool

func (*CriuOpts) GetStatusFd 

func (m *CriuOpts) GetStatusFd() int32

func (*CriuOpts) GetTcpEstablished 

func (m *CriuOpts) GetTcpEstablished() bool

func (*CriuOpts) GetWorkDirectory 

func (m *CriuOpts) GetWorkDirectory() string

func (*CriuOpts) ProtoMessage 

func (*CriuOpts) ProtoMessage()

func (*CriuOpts) Reset 

func (m *CriuOpts) Reset()

func (*CriuOpts) String 

func (m *CriuOpts) String() string

func (*CriuOpts) XXX_DiscardUnknown 

func (m *CriuOpts) XXX_DiscardUnknown()

func (*CriuOpts) XXX_Marshal 

func (m *CriuOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CriuOpts) XXX_Merge 

func (m *CriuOpts) XXX_Merge(src proto.Message)

func (*CriuOpts) XXX_Size 

func (m *CriuOpts) XXX_Size() int

func (*CriuOpts) XXX_Unmarshal 

func (m *CriuOpts) XXX_Unmarshal(b []byte) error

type DumpArgs 

type DumpArgs struct {
	PID                  int32             `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	Dir                  string            `protobuf:"bytes,2,opt,name=Dir,proto3" json:"Dir,omitempty"`
	Type                 DumpArgs_DumpType `protobuf:"varint,3,opt,name=Type,proto3,enum=cedana.services.task.DumpArgs_DumpType" json:"Type,omitempty"`
	JobID                string            `protobuf:"bytes,4,opt,name=JobID,proto3" json:"JobID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*DumpArgs) Descriptor 

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

func (*DumpArgs) GetDir 

func (m *DumpArgs) GetDir() string

func (*DumpArgs) GetJobID 

func (m *DumpArgs) GetJobID() string

func (*DumpArgs) GetPID 

func (m *DumpArgs) GetPID() int32

func (*DumpArgs) GetType 

func (m *DumpArgs) GetType() DumpArgs_DumpType

func (*DumpArgs) ProtoMessage 

func (*DumpArgs) ProtoMessage()

func (*DumpArgs) Reset 

func (m *DumpArgs) Reset()

func (*DumpArgs) String 

func (m *DumpArgs) String() string

func (*DumpArgs) XXX_DiscardUnknown 

func (m *DumpArgs) XXX_DiscardUnknown()

func (*DumpArgs) XXX_Marshal 

func (m *DumpArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DumpArgs) XXX_Merge 

func (m *DumpArgs) XXX_Merge(src proto.Message)

func (*DumpArgs) XXX_Size 

func (m *DumpArgs) XXX_Size() int

func (*DumpArgs) XXX_Unmarshal 

func (m *DumpArgs) XXX_Unmarshal(b []byte) error

type DumpArgs_DumpType 

type DumpArgs_DumpType int32
const (
	DumpArgs_SELF_SERVE DumpArgs_DumpType = 0
	DumpArgs_MARKET     DumpArgs_DumpType = 1
)

func (DumpArgs_DumpType) EnumDescriptor 

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

func (DumpArgs_DumpType) String 

func (x DumpArgs_DumpType) String() string

type DumpResp 

type DumpResp struct {
	Message              string   `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DumpResp) Descriptor 

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

func (*DumpResp) GetMessage 

func (m *DumpResp) GetMessage() string

func (*DumpResp) ProtoMessage 

func (*DumpResp) ProtoMessage()

func (*DumpResp) Reset 

func (m *DumpResp) Reset()

func (*DumpResp) String 

func (m *DumpResp) String() string

func (*DumpResp) XXX_DiscardUnknown 

func (m *DumpResp) XXX_DiscardUnknown()

func (*DumpResp) XXX_Marshal 

func (m *DumpResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DumpResp) XXX_Merge 

func (m *DumpResp) XXX_Merge(src proto.Message)

func (*DumpResp) XXX_Size 

func (m *DumpResp) XXX_Size() int

func (*DumpResp) XXX_Unmarshal 

func (m *DumpResp) XXX_Unmarshal(b []byte) error

type FlagEnum 

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

func (FlagEnum) EnumDescriptor 

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

func (FlagEnum) String 

func (x FlagEnum) String() string

type LogStreamingArgs 

type LogStreamingArgs struct {
	Timestamp            string   `protobuf:"bytes,1,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=Source,proto3" json:"Source,omitempty"`
	Level                string   `protobuf:"bytes,3,opt,name=Level,proto3" json:"Level,omitempty"`
	Msg                  string   `protobuf:"bytes,4,opt,name=Msg,proto3" json:"Msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Log Streaming args

func (*LogStreamingArgs) Descriptor 

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

func (*LogStreamingArgs) GetLevel 

func (m *LogStreamingArgs) GetLevel() string

func (*LogStreamingArgs) GetMsg 

func (m *LogStreamingArgs) GetMsg() string

func (*LogStreamingArgs) GetSource 

func (m *LogStreamingArgs) GetSource() string

func (*LogStreamingArgs) GetTimestamp 

func (m *LogStreamingArgs) GetTimestamp() string

func (*LogStreamingArgs) ProtoMessage 

func (*LogStreamingArgs) ProtoMessage()

func (*LogStreamingArgs) Reset 

func (m *LogStreamingArgs) Reset()

func (*LogStreamingArgs) String 

func (m *LogStreamingArgs) String() string

func (*LogStreamingArgs) XXX_DiscardUnknown 

func (m *LogStreamingArgs) XXX_DiscardUnknown()

func (*LogStreamingArgs) XXX_Marshal 

func (m *LogStreamingArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogStreamingArgs) XXX_Merge 

func (m *LogStreamingArgs) XXX_Merge(src proto.Message)

func (*LogStreamingArgs) XXX_Size 

func (m *LogStreamingArgs) XXX_Size() int

func (*LogStreamingArgs) XXX_Unmarshal 

func (m *LogStreamingArgs) XXX_Unmarshal(b []byte) error

type LogStreamingResp 

type LogStreamingResp struct {
	Status               string   `protobuf:"bytes,1,opt,name=Status,proto3" json:"Status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogStreamingResp) Descriptor 

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

func (*LogStreamingResp) GetStatus 

func (m *LogStreamingResp) GetStatus() string

func (*LogStreamingResp) ProtoMessage 

func (*LogStreamingResp) ProtoMessage()

func (*LogStreamingResp) Reset 

func (m *LogStreamingResp) Reset()

func (*LogStreamingResp) String 

func (m *LogStreamingResp) String() string

func (*LogStreamingResp) XXX_DiscardUnknown 

func (m *LogStreamingResp) XXX_DiscardUnknown()

func (*LogStreamingResp) XXX_Marshal 

func (m *LogStreamingResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogStreamingResp) XXX_Merge 

func (m *LogStreamingResp) XXX_Merge(src proto.Message)

func (*LogStreamingResp) XXX_Size 

func (m *LogStreamingResp) XXX_Size() int

func (*LogStreamingResp) XXX_Unmarshal 

func (m *LogStreamingResp) XXX_Unmarshal(b []byte) error

type MetaStateStreamingArgs 

type MetaStateStreamingArgs struct {
	Event                *ProviderEvent    `protobuf:"bytes,1,opt,name=Event,proto3" json:"Event,omitempty"`
	CheckpointReason     *CheckpointReason `protobuf:"bytes,2,opt,name=CheckpointReason,proto3" json:"CheckpointReason,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MetaStateStreamingArgs) Descriptor 

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

func (*MetaStateStreamingArgs) GetCheckpointReason 

func (m *MetaStateStreamingArgs) GetCheckpointReason() *CheckpointReason

func (*MetaStateStreamingArgs) GetEvent 

func (m *MetaStateStreamingArgs) GetEvent() *ProviderEvent

func (*MetaStateStreamingArgs) ProtoMessage 

func (*MetaStateStreamingArgs) ProtoMessage()

func (*MetaStateStreamingArgs) Reset 

func (m *MetaStateStreamingArgs) Reset()

func (*MetaStateStreamingArgs) String 

func (m *MetaStateStreamingArgs) String() string

func (*MetaStateStreamingArgs) XXX_DiscardUnknown 

func (m *MetaStateStreamingArgs) XXX_DiscardUnknown()

func (*MetaStateStreamingArgs) XXX_Marshal 

func (m *MetaStateStreamingArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetaStateStreamingArgs) XXX_Merge 

func (m *MetaStateStreamingArgs) XXX_Merge(src proto.Message)

func (*MetaStateStreamingArgs) XXX_Size 

func (m *MetaStateStreamingArgs) XXX_Size() int

func (*MetaStateStreamingArgs) XXX_Unmarshal 

func (m *MetaStateStreamingArgs) XXX_Unmarshal(b []byte) error

type MetaStateStreamingResp 

type MetaStateStreamingResp struct {
	Status               string   `protobuf:"bytes,1,opt,name=Status,proto3" json:"Status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MetaStateStreamingResp) Descriptor 

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

func (*MetaStateStreamingResp) GetStatus 

func (m *MetaStateStreamingResp) GetStatus() string

func (*MetaStateStreamingResp) ProtoMessage 

func (*MetaStateStreamingResp) ProtoMessage()

func (*MetaStateStreamingResp) Reset 

func (m *MetaStateStreamingResp) Reset()

func (*MetaStateStreamingResp) String 

func (m *MetaStateStreamingResp) String() string

func (*MetaStateStreamingResp) XXX_DiscardUnknown 

func (m *MetaStateStreamingResp) XXX_DiscardUnknown()

func (*MetaStateStreamingResp) XXX_Marshal 

func (m *MetaStateStreamingResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetaStateStreamingResp) XXX_Merge 

func (m *MetaStateStreamingResp) XXX_Merge(src proto.Message)

func (*MetaStateStreamingResp) XXX_Size 

func (m *MetaStateStreamingResp) XXX_Size() int

func (*MetaStateStreamingResp) XXX_Unmarshal 

func (m *MetaStateStreamingResp) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OpenFilesStat) Descriptor 

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

func (*OpenFilesStat) GetFd 

func (m *OpenFilesStat) GetFd() uint64

func (*OpenFilesStat) GetPath 

func (m *OpenFilesStat) GetPath() string

func (*OpenFilesStat) ProtoMessage 

func (*OpenFilesStat) ProtoMessage()

func (*OpenFilesStat) Reset 

func (m *OpenFilesStat) Reset()

func (*OpenFilesStat) String 

func (m *OpenFilesStat) String() string

func (*OpenFilesStat) XXX_DiscardUnknown 

func (m *OpenFilesStat) XXX_DiscardUnknown()

func (*OpenFilesStat) XXX_Marshal 

func (m *OpenFilesStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OpenFilesStat) XXX_Merge 

func (m *OpenFilesStat) XXX_Merge(src proto.Message)

func (*OpenFilesStat) XXX_Size 

func (m *OpenFilesStat) XXX_Size() int

func (*OpenFilesStat) XXX_Unmarshal 

func (m *OpenFilesStat) XXX_Unmarshal(b []byte) error

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"`
	OpenWriteOnlyFilePaths  []string          `protobuf:"bytes,4,rep,name=OpenWriteOnlyFilePaths,proto3" json:"OpenWriteOnlyFilePaths,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"`
	XXX_NoUnkeyedLiteral    struct{}          `json:"-"`
	XXX_unrecognized        []byte            `json:"-"`
	XXX_sizecache           int32             `json:"-"`
}

func (*ProcessInfo) Descriptor 

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

func (*ProcessInfo) GetAttachedToHardwareAccel 

func (m *ProcessInfo) GetAttachedToHardwareAccel() bool

func (*ProcessInfo) GetIsRunning 

func (m *ProcessInfo) GetIsRunning() bool

func (*ProcessInfo) GetMemoryPercent 

func (m *ProcessInfo) GetMemoryPercent() float32

func (*ProcessInfo) GetOpenConnections 

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

func (*ProcessInfo) GetOpenFds 

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

func (*ProcessInfo) GetOpenWriteOnlyFilePaths 

func (m *ProcessInfo) GetOpenWriteOnlyFilePaths() []string

func (*ProcessInfo) GetPID 

func (m *ProcessInfo) GetPID() int32

func (*ProcessInfo) GetStatus 

func (m *ProcessInfo) GetStatus() string

func (*ProcessInfo) ProtoMessage 

func (*ProcessInfo) ProtoMessage()

func (*ProcessInfo) Reset 

func (m *ProcessInfo) Reset()

func (*ProcessInfo) String 

func (m *ProcessInfo) String() string

func (*ProcessInfo) XXX_DiscardUnknown 

func (m *ProcessInfo) XXX_DiscardUnknown()

func (*ProcessInfo) XXX_Marshal 

func (m *ProcessInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessInfo) XXX_Merge 

func (m *ProcessInfo) XXX_Merge(src proto.Message)

func (*ProcessInfo) XXX_Size 

func (m *ProcessInfo) XXX_Size() int

func (*ProcessInfo) XXX_Unmarshal 

func (m *ProcessInfo) XXX_Unmarshal(b []byte) error

type ProcessState 

type ProcessState struct {
	PID                  int32                             `protobuf:"varint,1,opt,name=PID,proto3" json:"PID,omitempty"`
	Task                 string                            `protobuf:"bytes,2,opt,name=Task,proto3" json:"Task,omitempty"`
	ContainerRuntime     ProcessState_ContainerRuntimeOpts `` /* 146-byte string literal not displayed */
	ContainerId          string                            `protobuf:"bytes,4,opt,name=ContainerId,proto3" json:"ContainerId,omitempty"`
	StartedAt            string                            `protobuf:"bytes,5,opt,name=StartedAt,proto3" json:"StartedAt,omitempty"`
	ProcessInfo          *ProcessInfo                      `protobuf:"bytes,6,opt,name=ProcessInfo,proto3" json:"ProcessInfo,omitempty"`
	CheckpointPath       string                            `protobuf:"bytes,7,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	CheckpointState      CheckpointState                   `` /* 126-byte string literal not displayed */
	Flag                 FlagEnum                          `protobuf:"varint,9,opt,name=Flag,proto3,enum=cedana.services.task.FlagEnum" json:"Flag,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*ProcessState) Descriptor 

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

func (*ProcessState) GetCheckpointPath 

func (m *ProcessState) GetCheckpointPath() string

func (*ProcessState) GetCheckpointState 

func (m *ProcessState) GetCheckpointState() CheckpointState

func (*ProcessState) GetContainerId 

func (m *ProcessState) GetContainerId() string

func (*ProcessState) GetContainerRuntime 

func (m *ProcessState) GetContainerRuntime() ProcessState_ContainerRuntimeOpts

func (*ProcessState) GetFlag 

func (m *ProcessState) GetFlag() FlagEnum

func (*ProcessState) GetPID 

func (m *ProcessState) GetPID() int32

func (*ProcessState) GetProcessInfo 

func (m *ProcessState) GetProcessInfo() *ProcessInfo

func (*ProcessState) GetStartedAt 

func (m *ProcessState) GetStartedAt() string

func (*ProcessState) GetTask 

func (m *ProcessState) GetTask() string

func (*ProcessState) ProtoMessage 

func (*ProcessState) ProtoMessage()

func (*ProcessState) Reset 

func (m *ProcessState) Reset()

func (*ProcessState) String 

func (m *ProcessState) String() string

func (*ProcessState) XXX_DiscardUnknown 

func (m *ProcessState) XXX_DiscardUnknown()

func (*ProcessState) XXX_Marshal 

func (m *ProcessState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProcessState) XXX_Merge 

func (m *ProcessState) XXX_Merge(src proto.Message)

func (*ProcessState) XXX_Size 

func (m *ProcessState) XXX_Size() int

func (*ProcessState) XXX_Unmarshal 

func (m *ProcessState) XXX_Unmarshal(b []byte) error

type ProcessState_ContainerRuntimeOpts 

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

func (ProcessState_ContainerRuntimeOpts) EnumDescriptor 

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

func (ProcessState_ContainerRuntimeOpts) String 

func (x ProcessState_ContainerRuntimeOpts) String() string

type ProviderEvent 

type ProviderEvent struct {
	InstanceID           string   `protobuf:"bytes,1,opt,name=InstanceID,proto3" json:"InstanceID,omitempty"`
	FaultCode            string   `protobuf:"bytes,2,opt,name=FaultCode,proto3" json:"FaultCode,omitempty"`
	MarkedForTermination bool     `protobuf:"varint,3,opt,name=MarkedForTermination,proto3" json:"MarkedForTermination,omitempty"`
	TerminationTime      int64    `protobuf:"varint,4,opt,name=TerminationTime,proto3" json:"TerminationTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ProviderEvent) Descriptor 

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

func (*ProviderEvent) GetFaultCode 

func (m *ProviderEvent) GetFaultCode() string

func (*ProviderEvent) GetInstanceID 

func (m *ProviderEvent) GetInstanceID() string

func (*ProviderEvent) GetMarkedForTermination 

func (m *ProviderEvent) GetMarkedForTermination() bool

func (*ProviderEvent) GetTerminationTime 

func (m *ProviderEvent) GetTerminationTime() int64

func (*ProviderEvent) ProtoMessage 

func (*ProviderEvent) ProtoMessage()

func (*ProviderEvent) Reset 

func (m *ProviderEvent) Reset()

func (*ProviderEvent) String 

func (m *ProviderEvent) String() string

func (*ProviderEvent) XXX_DiscardUnknown 

func (m *ProviderEvent) XXX_DiscardUnknown()

func (*ProviderEvent) XXX_Marshal 

func (m *ProviderEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProviderEvent) XXX_Merge 

func (m *ProviderEvent) XXX_Merge(src proto.Message)

func (*ProviderEvent) XXX_Size 

func (m *ProviderEvent) XXX_Size() int

func (*ProviderEvent) XXX_Unmarshal 

func (m *ProviderEvent) XXX_Unmarshal(b []byte) error

type RestoreArgs 

type RestoreArgs struct {
	Type                 RestoreArgs_RestoreType `protobuf:"varint,1,opt,name=Type,proto3,enum=cedana.services.task.RestoreArgs_RestoreType" json:"Type,omitempty"`
	CheckpointId         string                  `protobuf:"bytes,2,opt,name=CheckpointId,proto3" json:"CheckpointId,omitempty"`
	CheckpointPath       string                  `protobuf:"bytes,3,opt,name=CheckpointPath,proto3" json:"CheckpointPath,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*RestoreArgs) Descriptor 

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

func (*RestoreArgs) GetCheckpointId 

func (m *RestoreArgs) GetCheckpointId() string

func (*RestoreArgs) GetCheckpointPath 

func (m *RestoreArgs) GetCheckpointPath() string

func (*RestoreArgs) GetType 

func (m *RestoreArgs) GetType() RestoreArgs_RestoreType

func (*RestoreArgs) ProtoMessage 

func (*RestoreArgs) ProtoMessage()

func (*RestoreArgs) Reset 

func (m *RestoreArgs) Reset()

func (*RestoreArgs) String 

func (m *RestoreArgs) String() string

func (*RestoreArgs) XXX_DiscardUnknown 

func (m *RestoreArgs) XXX_DiscardUnknown()

func (*RestoreArgs) XXX_Marshal 

func (m *RestoreArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreArgs) XXX_Merge 

func (m *RestoreArgs) XXX_Merge(src proto.Message)

func (*RestoreArgs) XXX_Size 

func (m *RestoreArgs) XXX_Size() int

func (*RestoreArgs) XXX_Unmarshal 

func (m *RestoreArgs) XXX_Unmarshal(b []byte) error

type RestoreArgs_RestoreType 

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

func (RestoreArgs_RestoreType) EnumDescriptor 

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

func (RestoreArgs_RestoreType) String 

func (x RestoreArgs_RestoreType) 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestoreResp) Descriptor 

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

func (*RestoreResp) GetMessage 

func (m *RestoreResp) GetMessage() string

func (*RestoreResp) GetNewPID 

func (m *RestoreResp) GetNewPID() int32

func (*RestoreResp) ProtoMessage 

func (*RestoreResp) ProtoMessage()

func (*RestoreResp) Reset 

func (m *RestoreResp) Reset()

func (*RestoreResp) String 

func (m *RestoreResp) String() string

func (*RestoreResp) XXX_DiscardUnknown 

func (m *RestoreResp) XXX_DiscardUnknown()

func (*RestoreResp) XXX_Marshal 

func (m *RestoreResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RestoreResp) XXX_Merge 

func (m *RestoreResp) XXX_Merge(src proto.Message)

func (*RestoreResp) XXX_Size 

func (m *RestoreResp) XXX_Size() int

func (*RestoreResp) XXX_Unmarshal 

func (m *RestoreResp) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RuncDumpArgs) Descriptor 

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

func (*RuncDumpArgs) GetCheckpointPath 

func (m *RuncDumpArgs) GetCheckpointPath() string

func (*RuncDumpArgs) GetContainerId 

func (m *RuncDumpArgs) GetContainerId() string

func (*RuncDumpArgs) GetCriuOpts 

func (m *RuncDumpArgs) GetCriuOpts() *CriuOpts

func (*RuncDumpArgs) GetRoot 

func (m *RuncDumpArgs) GetRoot() string

func (*RuncDumpArgs) ProtoMessage 

func (*RuncDumpArgs) ProtoMessage()

func (*RuncDumpArgs) Reset 

func (m *RuncDumpArgs) Reset()

func (*RuncDumpArgs) String 

func (m *RuncDumpArgs) String() string

func (*RuncDumpArgs) XXX_DiscardUnknown 

func (m *RuncDumpArgs) XXX_DiscardUnknown()

func (*RuncDumpArgs) XXX_Marshal 

func (m *RuncDumpArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RuncDumpArgs) XXX_Merge 

func (m *RuncDumpArgs) XXX_Merge(src proto.Message)

func (*RuncDumpArgs) XXX_Size 

func (m *RuncDumpArgs) XXX_Size() int

func (*RuncDumpArgs) XXX_Unmarshal 

func (m *RuncDumpArgs) XXX_Unmarshal(b []byte) error

type RuncDumpResp 

type RuncDumpResp struct {
	Message              string   `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RuncDumpResp) Descriptor 

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

func (*RuncDumpResp) GetMessage 

func (m *RuncDumpResp) GetMessage() string

func (*RuncDumpResp) ProtoMessage 

func (*RuncDumpResp) ProtoMessage()

func (*RuncDumpResp) Reset 

func (m *RuncDumpResp) Reset()

func (*RuncDumpResp) String 

func (m *RuncDumpResp) String() string

func (*RuncDumpResp) XXX_DiscardUnknown 

func (m *RuncDumpResp) XXX_DiscardUnknown()

func (*RuncDumpResp) XXX_Marshal 

func (m *RuncDumpResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RuncDumpResp) XXX_Merge 

func (m *RuncDumpResp) XXX_Merge(src proto.Message)

func (*RuncDumpResp) XXX_Size 

func (m *RuncDumpResp) XXX_Size() int

func (*RuncDumpResp) XXX_Unmarshal 

func (m *RuncDumpResp) XXX_Unmarshal(b []byte) error

type RuncOpts 

type RuncOpts struct {
	Root                 string   `protobuf:"bytes,1,opt,name=Root,proto3" json:"Root,omitempty"`
	ContainerId          string   `protobuf:"bytes,2,opt,name=ContainerId,proto3" json:"ContainerId,omitempty"`
	Bundle               string   `protobuf:"bytes,3,opt,name=Bundle,proto3" json:"Bundle,omitempty"`
	SystemdCgroup        bool     `protobuf:"varint,4,opt,name=SystemdCgroup,proto3" json:"SystemdCgroup,omitempty"`
	NoPivot              bool     `protobuf:"varint,5,opt,name=NoPivot,proto3" json:"NoPivot,omitempty"`
	NoMountFallback      bool     `protobuf:"varint,6,opt,name=NoMountFallback,proto3" json:"NoMountFallback,omitempty"`
	NoNewKeyring         bool     `protobuf:"varint,7,opt,name=NoNewKeyring,proto3" json:"NoNewKeyring,omitempty"`
	Rootless             string   `protobuf:"bytes,8,opt,name=Rootless,proto3" json:"Rootless,omitempty"`
	NoSubreaper          bool     `protobuf:"varint,9,opt,name=NoSubreaper,proto3" json:"NoSubreaper,omitempty"`
	Keep                 bool     `protobuf:"varint,10,opt,name=Keep,proto3" json:"Keep,omitempty"`
	ConsoleSocket        string   `protobuf:"bytes,11,opt,name=ConsoleSocket,proto3" json:"ConsoleSocket,omitempty"`
	Detatch              bool     `protobuf:"varint,12,opt,name=Detatch,proto3" json:"Detatch,omitempty"`
	PidFile              string   `protobuf:"bytes,13,opt,name=PidFile,proto3" json:"PidFile,omitempty"`
	PreserveFds          int32    `protobuf:"varint,14,opt,name=PreserveFds,proto3" json:"PreserveFds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RuncOpts) Descriptor 

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

func (*RuncOpts) GetBundle 

func (m *RuncOpts) GetBundle() string

func (*RuncOpts) GetConsoleSocket 

func (m *RuncOpts) GetConsoleSocket() string

func (*RuncOpts) GetContainerId 

func (m *RuncOpts) GetContainerId() string

func (*RuncOpts) GetDetatch 

func (m *RuncOpts) GetDetatch() bool

func (*RuncOpts) GetKeep 

func (m *RuncOpts) GetKeep() bool

func (*RuncOpts) GetNoMountFallback 

func (m *RuncOpts) GetNoMountFallback() bool

func (*RuncOpts) GetNoNewKeyring 

func (m *RuncOpts) GetNoNewKeyring() bool

func (*RuncOpts) GetNoPivot 

func (m *RuncOpts) GetNoPivot() bool

func (*RuncOpts) GetNoSubreaper 

func (m *RuncOpts) GetNoSubreaper() bool

func (*RuncOpts) GetPidFile 

func (m *RuncOpts) GetPidFile() string

func (*RuncOpts) GetPreserveFds 

func (m *RuncOpts) GetPreserveFds() int32

func (*RuncOpts) GetRoot 

func (m *RuncOpts) GetRoot() string

func (*RuncOpts) GetRootless 

func (m *RuncOpts) GetRootless() string

func (*RuncOpts) GetSystemdCgroup 

func (m *RuncOpts) GetSystemdCgroup() bool

func (*RuncOpts) ProtoMessage 

func (*RuncOpts) ProtoMessage()

func (*RuncOpts) Reset 

func (m *RuncOpts) Reset()

func (*RuncOpts) String 

func (m *RuncOpts) String() string

func (*RuncOpts) XXX_DiscardUnknown 

func (m *RuncOpts) XXX_DiscardUnknown()

func (*RuncOpts) XXX_Marshal 

func (m *RuncOpts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RuncOpts) XXX_Merge 

func (m *RuncOpts) XXX_Merge(src proto.Message)

func (*RuncOpts) XXX_Size 

func (m *RuncOpts) XXX_Size() int

func (*RuncOpts) XXX_Unmarshal 

func (m *RuncOpts) XXX_Unmarshal(b []byte) error

type RuncRestoreArgs 

type RuncRestoreArgs struct {
	ContainerId          string    `protobuf:"bytes,1,opt,name=ContainerId,proto3" json:"ContainerId,omitempty"`
	ImagePath            string    `protobuf:"bytes,2,opt,name=ImagePath,proto3" json:"ImagePath,omitempty"`
	Opts                 *RuncOpts `protobuf:"bytes,4,opt,name=Opts,proto3" json:"Opts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RuncRestoreArgs) Descriptor 

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

func (*RuncRestoreArgs) GetContainerId 

func (m *RuncRestoreArgs) GetContainerId() string

func (*RuncRestoreArgs) GetImagePath 

func (m *RuncRestoreArgs) GetImagePath() string

func (*RuncRestoreArgs) GetOpts 

func (m *RuncRestoreArgs) GetOpts() *RuncOpts

func (*RuncRestoreArgs) ProtoMessage 

func (*RuncRestoreArgs) ProtoMessage()

func (*RuncRestoreArgs) Reset 

func (m *RuncRestoreArgs) Reset()

func (*RuncRestoreArgs) String 

func (m *RuncRestoreArgs) String() string

func (*RuncRestoreArgs) XXX_DiscardUnknown 

func (m *RuncRestoreArgs) XXX_DiscardUnknown()

func (*RuncRestoreArgs) XXX_Marshal 

func (m *RuncRestoreArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RuncRestoreArgs) XXX_Merge 

func (m *RuncRestoreArgs) XXX_Merge(src proto.Message)

func (*RuncRestoreArgs) XXX_Size 

func (m *RuncRestoreArgs) XXX_Size() int

func (*RuncRestoreArgs) XXX_Unmarshal 

func (m *RuncRestoreArgs) XXX_Unmarshal(b []byte) error

type RuncRestoreResp 

type RuncRestoreResp struct {
	Message              string   `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RuncRestoreResp) Descriptor 

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

func (*RuncRestoreResp) GetMessage 

func (m *RuncRestoreResp) GetMessage() string

func (*RuncRestoreResp) ProtoMessage 

func (*RuncRestoreResp) ProtoMessage()

func (*RuncRestoreResp) Reset 

func (m *RuncRestoreResp) Reset()

func (*RuncRestoreResp) String 

func (m *RuncRestoreResp) String() string

func (*RuncRestoreResp) XXX_DiscardUnknown 

func (m *RuncRestoreResp) XXX_DiscardUnknown()

func (*RuncRestoreResp) XXX_Marshal 

func (m *RuncRestoreResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RuncRestoreResp) XXX_Merge 

func (m *RuncRestoreResp) XXX_Merge(src proto.Message)

func (*RuncRestoreResp) XXX_Size 

func (m *RuncRestoreResp) XXX_Size() int

func (*RuncRestoreResp) XXX_Unmarshal 

func (m *RuncRestoreResp) XXX_Unmarshal(b []byte) error

type StartTaskArgs 

type StartTaskArgs struct {
	Task                 string   `protobuf:"bytes,1,opt,name=Task,proto3" json:"Task,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=Id,proto3" json:"Id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartTaskArgs) Descriptor 

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

func (*StartTaskArgs) GetId 

func (m *StartTaskArgs) GetId() string

func (*StartTaskArgs) GetTask 

func (m *StartTaskArgs) GetTask() string

func (*StartTaskArgs) ProtoMessage 

func (*StartTaskArgs) ProtoMessage()

func (*StartTaskArgs) Reset 

func (m *StartTaskArgs) Reset()

func (*StartTaskArgs) String 

func (m *StartTaskArgs) String() string

func (*StartTaskArgs) XXX_DiscardUnknown 

func (m *StartTaskArgs) XXX_DiscardUnknown()

func (*StartTaskArgs) XXX_Marshal 

func (m *StartTaskArgs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartTaskArgs) XXX_Merge 

func (m *StartTaskArgs) XXX_Merge(src proto.Message)

func (*StartTaskArgs) XXX_Size 

func (m *StartTaskArgs) XXX_Size() int

func (*StartTaskArgs) XXX_Unmarshal 

func (m *StartTaskArgs) XXX_Unmarshal(b []byte) error

type StartTaskResp 

type StartTaskResp struct {
	Message              string   `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	PID                  int32    `protobuf:"varint,2,opt,name=PID,proto3" json:"PID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartTaskResp) Descriptor 

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

func (*StartTaskResp) GetMessage 

func (m *StartTaskResp) GetMessage() string

func (*StartTaskResp) GetPID 

func (m *StartTaskResp) GetPID() int32

func (*StartTaskResp) ProtoMessage 

func (*StartTaskResp) ProtoMessage()

func (*StartTaskResp) Reset 

func (m *StartTaskResp) Reset()

func (*StartTaskResp) String 

func (m *StartTaskResp) String() string

func (*StartTaskResp) XXX_DiscardUnknown 

func (m *StartTaskResp) XXX_DiscardUnknown()

func (*StartTaskResp) XXX_Marshal 

func (m *StartTaskResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartTaskResp) XXX_Merge 

func (m *StartTaskResp) XXX_Merge(src proto.Message)

func (*StartTaskResp) XXX_Size 

func (m *StartTaskResp) XXX_Size() int

func (*StartTaskResp) XXX_Unmarshal 

func (m *StartTaskResp) XXX_Unmarshal(b []byte) error

type TaskServiceClient 

type TaskServiceClient interface {
	Dump(ctx context.Context, in *DumpArgs, opts ...grpc.CallOption) (*DumpResp, error)
	Restore(ctx context.Context, in *RestoreArgs, opts ...grpc.CallOption) (*RestoreResp, error)
	ContainerDump(ctx context.Context, in *ContainerDumpArgs, opts ...grpc.CallOption) (*ContainerDumpResp, error)
	ContainerRestore(ctx context.Context, in *ContainerRestoreArgs, opts ...grpc.CallOption) (*ContainerRestoreResp, error)
	RuncDump(ctx context.Context, in *RuncDumpArgs, opts ...grpc.CallOption) (*RuncDumpResp, error)
	RuncRestore(ctx context.Context, in *RuncRestoreArgs, opts ...grpc.CallOption) (*RuncRestoreResp, error)
	StartTask(ctx context.Context, in *StartTaskArgs, opts ...grpc.CallOption) (*StartTaskResp, error)
	LogStreaming(ctx context.Context, opts ...grpc.CallOption) (TaskService_LogStreamingClient, error)
	ClientStateStreaming(ctx context.Context, opts ...grpc.CallOption) (TaskService_ClientStateStreamingClient, error)
	MetaStateStreaming(ctx context.Context, opts ...grpc.CallOption) (TaskService_MetaStateStreamingClient, error)
}

TaskServiceClient is the client API for TaskService service.

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

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	Dump(context.Context, *DumpArgs) (*DumpResp, error)
	Restore(context.Context, *RestoreArgs) (*RestoreResp, error)
	ContainerDump(context.Context, *ContainerDumpArgs) (*ContainerDumpResp, error)
	ContainerRestore(context.Context, *ContainerRestoreArgs) (*ContainerRestoreResp, error)
	RuncDump(context.Context, *RuncDumpArgs) (*RuncDumpResp, error)
	RuncRestore(context.Context, *RuncRestoreArgs) (*RuncRestoreResp, error)
	StartTask(context.Context, *StartTaskArgs) (*StartTaskResp, error)
	LogStreaming(TaskService_LogStreamingServer) error
	ClientStateStreaming(TaskService_ClientStateStreamingServer) error
	MetaStateStreaming(TaskService_MetaStateStreamingServer) error
	// contains filtered or unexported methods
}

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

type TaskService_ClientStateStreamingClient 

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

type TaskService_ClientStateStreamingServer 

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

type TaskService_LogStreamingClient 

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

type TaskService_LogStreamingServer 

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

type TaskService_MetaStateStreamingClient 

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

type TaskService_MetaStateStreamingServer 

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

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTaskServiceServer) ClientStateStreaming 

func (UnimplementedTaskServiceServer) ClientStateStreaming(TaskService_ClientStateStreamingServer) error

func (UnimplementedTaskServiceServer) ContainerDump 

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

func (UnimplementedTaskServiceServer) ContainerRestore 

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

func (UnimplementedTaskServiceServer) Dump 

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

func (UnimplementedTaskServiceServer) LogStreaming 

func (UnimplementedTaskServiceServer) LogStreaming(TaskService_LogStreamingServer) error

func (UnimplementedTaskServiceServer) MetaStateStreaming 

func (UnimplementedTaskServiceServer) MetaStateStreaming(TaskService_MetaStateStreamingServer) error

func (UnimplementedTaskServiceServer) Restore 

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

func (UnimplementedTaskServiceServer) RuncDump 

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

func (UnimplementedTaskServiceServer) RuncRestore 

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

func (UnimplementedTaskServiceServer) StartTask 

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

type UnsafeTaskServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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