v1

Jan 25, 2026

Changes in this version

+ func SetImageBasePath(path string)

Aug 11, 2025

Changes in this version

+ const UpperSuffix

+ func UpperPath(id string) string

Mar 30, 2025

Changes in this version

+ const LiveMigrateAnnotationKey

+ const MigrateAnnotationKey

+ const NodeNameEnvKey

+ const PodIPEnvKey

+ const SnapshotSuffix

+ const SocketPath

+ const WorkDirSuffix

+ var File_node_proto protoreflect.FileDescriptor

+ func ImagePath(id string) string

+ func LazyPagesSocket(id string) string

+ func PreDumpDir(id string) string

+ func RegisterNodeService(srv *ttrpc.Server, svc NodeService)

+ func RelativePreDumpDir() string

+ func SnapshotPath(id string) string

+ func WorkDirPath(id string) string

+ type CriuLazyPagesRequest struct

+ Address string

+ CheckpointPath string

+ Port int32

+ Tls bool

+ func (*CriuLazyPagesRequest) Descriptor() ([]byte, []int)

+ func (*CriuLazyPagesRequest) ProtoMessage()

+ func (x *CriuLazyPagesRequest) GetAddress() string

+ func (x *CriuLazyPagesRequest) GetCheckpointPath() string

+ func (x *CriuLazyPagesRequest) GetPort() int32

+ func (x *CriuLazyPagesRequest) GetTls() bool

+ func (x *CriuLazyPagesRequest) ProtoReflect() protoreflect.Message

+ func (x *CriuLazyPagesRequest) Reset()

+ func (x *CriuLazyPagesRequest) String() string

+ type EvacRequest struct

+ MigrationInfo *MigrationInfo

+ PodInfo *PodInfo

+ func (*EvacRequest) Descriptor() ([]byte, []int)

+ func (*EvacRequest) ProtoMessage()

+ func (x *EvacRequest) GetMigrationInfo() *MigrationInfo

+ func (x *EvacRequest) GetPodInfo() *PodInfo

+ func (x *EvacRequest) ProtoReflect() protoreflect.Message

+ func (x *EvacRequest) Reset()

+ func (x *EvacRequest) String() string

+ type EvacResponse struct

+ Empty *emptypb.Empty

+ func (*EvacResponse) Descriptor() ([]byte, []int)

+ func (*EvacResponse) ProtoMessage()

+ func (x *EvacResponse) GetEmpty() *emptypb.Empty

+ func (x *EvacResponse) ProtoReflect() protoreflect.Message

+ func (x *EvacResponse) Reset()

+ func (x *EvacResponse) String() string

+ type Image struct

+ ImageData []byte

+ func (*Image) Descriptor() ([]byte, []int)

+ func (*Image) ProtoMessage()

+ func (x *Image) GetImageData() []byte

+ func (x *Image) ProtoReflect() protoreflect.Message

+ func (x *Image) Reset()

+ func (x *Image) String() string

+ type MigrationInfo struct

+ BundleDir string

+ ImageId string

+ LiveMigration bool

+ PausedAt *timestamppb.Timestamp

+ Ports []int32

+ RestoreEnd *timestamppb.Timestamp

+ RestoreStart *timestamppb.Timestamp

+ func (*MigrationInfo) Descriptor() ([]byte, []int)

+ func (*MigrationInfo) ProtoMessage()

+ func (x *MigrationInfo) GetBundleDir() string

+ func (x *MigrationInfo) GetImageId() string

+ func (x *MigrationInfo) GetLiveMigration() bool

+ func (x *MigrationInfo) GetPausedAt() *timestamppb.Timestamp

+ func (x *MigrationInfo) GetPorts() []int32

+ func (x *MigrationInfo) GetRestoreEnd() *timestamppb.Timestamp

+ func (x *MigrationInfo) GetRestoreStart() *timestamppb.Timestamp

+ func (x *MigrationInfo) ProtoReflect() protoreflect.Message

+ func (x *MigrationInfo) Reset()

+ func (x *MigrationInfo) String() string

+ type NodeClient interface

+ Evac func(context.Context, *EvacRequest) (*EvacResponse, error)

+ FinishRestore func(context.Context, *RestoreRequest) (*RestoreResponse, error)

+ NewCriuLazyPages func(context.Context, *CriuLazyPagesRequest) (*emptypb.Empty, error)

+ PrepareEvac func(context.Context, *EvacRequest) (*EvacResponse, error)

+ PullImage func(context.Context, *PullImageRequest) (Node_PullImageClient, error)

+ Restore func(context.Context, *RestoreRequest) (*RestoreResponse, error)

+ func NewNodeClient(client *ttrpc.Client) NodeClient

+ type NodeService interface

+ Evac func(context.Context, *EvacRequest) (*EvacResponse, error)

+ FinishRestore func(context.Context, *RestoreRequest) (*RestoreResponse, error)

+ NewCriuLazyPages func(context.Context, *CriuLazyPagesRequest) (*emptypb.Empty, error)

+ PrepareEvac func(context.Context, *EvacRequest) (*EvacResponse, error)

+ PullImage func(context.Context, *PullImageRequest, Node_PullImageServer) error

+ Restore func(context.Context, *RestoreRequest) (*RestoreResponse, error)

+ type Node_PullImageClient interface

+ Recv func() (*Image, error)

+ type Node_PullImageServer interface

+ Send func(*Image) error

+ type PodInfo struct

+ ContainerName string

+ Name string

+ Namespace string

+ Ports []int32

+ func (*PodInfo) Descriptor() ([]byte, []int)

+ func (*PodInfo) ProtoMessage()

+ func (x *PodInfo) GetContainerName() string

+ func (x *PodInfo) GetName() string

+ func (x *PodInfo) GetNamespace() string

+ func (x *PodInfo) GetPorts() []int32

+ func (x *PodInfo) ProtoReflect() protoreflect.Message

+ func (x *PodInfo) Reset()

+ func (x *PodInfo) String() string

+ type PullImageRequest struct

+ ImageId string

+ func (*PullImageRequest) Descriptor() ([]byte, []int)

+ func (*PullImageRequest) ProtoMessage()

+ func (x *PullImageRequest) GetImageId() string

+ func (x *PullImageRequest) ProtoReflect() protoreflect.Message

+ func (x *PullImageRequest) Reset()

+ func (x *PullImageRequest) String() string

+ type RestoreRequest struct

+ MigrationInfo *MigrationInfo

+ PodInfo *PodInfo

+ func (*RestoreRequest) Descriptor() ([]byte, []int)

+ func (*RestoreRequest) ProtoMessage()

+ func (x *RestoreRequest) GetMigrationInfo() *MigrationInfo

+ func (x *RestoreRequest) GetPodInfo() *PodInfo

+ func (x *RestoreRequest) ProtoReflect() protoreflect.Message

+ func (x *RestoreRequest) Reset()

+ func (x *RestoreRequest) String() string

+ type RestoreResponse struct

+ MigrationInfo *MigrationInfo

+ func (*RestoreResponse) Descriptor() ([]byte, []int)

+ func (*RestoreResponse) ProtoMessage()

+ func (x *RestoreResponse) GetMigrationInfo() *MigrationInfo

+ func (x *RestoreResponse) ProtoReflect() protoreflect.Message

+ func (x *RestoreResponse) Reset()

+ func (x *RestoreResponse) String() string