v1

package
v0.9.1 Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-ttrpc. DO NOT EDIT. source: node.proto

Index

Constants

View Source 
const (
	SocketPath = runPath + "node.sock"

	SnapshotSuffix           = "snapshot"
	UpperSuffix              = "upper"
	WorkDirSuffix            = "work"
	MigrateAnnotationKey     = "zeropod.ctrox.dev/migrate"
	LiveMigrateAnnotationKey = "zeropod.ctrox.dev/live-migrate"
	NodeNameEnvKey           = "NODE_NAME"
	PodIPEnvKey              = "POD_IP"
)

Variables

View Source 
var File_node_proto protoreflect.FileDescriptor

Functions

func ImagePath 

func ImagePath(id string) string

func LazyPagesSocket 

func LazyPagesSocket(id string) string

func PreDumpDir 

func PreDumpDir(id string) string

func RegisterNodeService 

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

func RelativePreDumpDir 

func RelativePreDumpDir() string

func SnapshotPath 

func SnapshotPath(id string) string

func UpperPath added in v0.7.0 

func UpperPath(id string) string

func WorkDirPath 

func WorkDirPath(id string) string

Types

type CriuLazyPagesRequest 

type CriuLazyPagesRequest struct {
	CheckpointPath string `protobuf:"bytes,1,opt,name=checkpoint_path,json=checkpointPath,proto3" json:"checkpoint_path,omitempty"`
	Address        string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Port           int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Tls            bool   `protobuf:"varint,4,opt,name=tls,proto3" json:"tls,omitempty"`
	// contains filtered or unexported fields
}

func (*CriuLazyPagesRequest) Descriptor deprecated 

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

Deprecated: Use CriuLazyPagesRequest.ProtoReflect.Descriptor instead.

func (*CriuLazyPagesRequest) GetAddress 

func (x *CriuLazyPagesRequest) GetAddress() string

func (*CriuLazyPagesRequest) GetCheckpointPath 

func (x *CriuLazyPagesRequest) GetCheckpointPath() string

func (*CriuLazyPagesRequest) GetPort 

func (x *CriuLazyPagesRequest) GetPort() int32

func (*CriuLazyPagesRequest) GetTls 

func (x *CriuLazyPagesRequest) GetTls() bool

func (*CriuLazyPagesRequest) ProtoMessage 

func (*CriuLazyPagesRequest) ProtoMessage()

func (*CriuLazyPagesRequest) ProtoReflect 

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

func (*CriuLazyPagesRequest) Reset 

func (x *CriuLazyPagesRequest) Reset()

func (*CriuLazyPagesRequest) String 

func (x *CriuLazyPagesRequest) String() string

type EvacRequest 

type EvacRequest struct {
	PodInfo       *PodInfo       `protobuf:"bytes,1,opt,name=pod_info,json=podInfo,proto3" json:"pod_info,omitempty"`
	MigrationInfo *MigrationInfo `protobuf:"bytes,2,opt,name=migration_info,json=migrationInfo,proto3" json:"migration_info,omitempty"`
	// contains filtered or unexported fields
}

func (*EvacRequest) Descriptor deprecated 

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

Deprecated: Use EvacRequest.ProtoReflect.Descriptor instead.

func (*EvacRequest) GetMigrationInfo 

func (x *EvacRequest) GetMigrationInfo() *MigrationInfo

func (*EvacRequest) GetPodInfo 

func (x *EvacRequest) GetPodInfo() *PodInfo

func (*EvacRequest) ProtoMessage 

func (*EvacRequest) ProtoMessage()

func (*EvacRequest) ProtoReflect 

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

func (*EvacRequest) Reset 

func (x *EvacRequest) Reset()

func (*EvacRequest) String 

func (x *EvacRequest) String() string

type EvacResponse 

type EvacResponse struct {
	Empty *emptypb.Empty `protobuf:"bytes,1,opt,name=empty,proto3" json:"empty,omitempty"`
	// contains filtered or unexported fields
}

func (*EvacResponse) Descriptor deprecated 

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

Deprecated: Use EvacResponse.ProtoReflect.Descriptor instead.

func (*EvacResponse) GetEmpty 

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

func (*EvacResponse) ProtoMessage 

func (*EvacResponse) ProtoMessage()

func (*EvacResponse) ProtoReflect 

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

func (*EvacResponse) Reset 

func (x *EvacResponse) Reset()

func (*EvacResponse) String 

func (x *EvacResponse) String() string

type Image 

type Image struct {
	ImageData []byte `protobuf:"bytes,1,opt,name=imageData,proto3" json:"imageData,omitempty"`
	// contains filtered or unexported fields
}

func (*Image) Descriptor deprecated 

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

Deprecated: Use Image.ProtoReflect.Descriptor instead.

func (*Image) GetImageData 

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

func (*Image) ProtoMessage 

func (*Image) ProtoMessage()

func (*Image) ProtoReflect 

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

func (*Image) Reset 

func (x *Image) Reset()

func (*Image) String 

func (x *Image) String() string

type MigrationInfo 

type MigrationInfo struct {
	ImageId       string                 `protobuf:"bytes,1,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	BundleDir     string                 `protobuf:"bytes,2,opt,name=bundle_dir,json=bundleDir,proto3" json:"bundle_dir,omitempty"`
	LiveMigration bool                   `protobuf:"varint,3,opt,name=live_migration,json=liveMigration,proto3" json:"live_migration,omitempty"`
	PausedAt      *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=paused_at,json=pausedAt,proto3" json:"paused_at,omitempty"`
	RestoreStart  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=restore_start,json=restoreStart,proto3" json:"restore_start,omitempty"`
	RestoreEnd    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=restore_end,json=restoreEnd,proto3" json:"restore_end,omitempty"`
	Ports         []int32                `protobuf:"varint,7,rep,packed,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

func (*MigrationInfo) Descriptor deprecated 

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

Deprecated: Use MigrationInfo.ProtoReflect.Descriptor instead.

func (*MigrationInfo) GetBundleDir 

func (x *MigrationInfo) GetBundleDir() string

func (*MigrationInfo) GetImageId 

func (x *MigrationInfo) GetImageId() string

func (*MigrationInfo) GetLiveMigration 

func (x *MigrationInfo) GetLiveMigration() bool

func (*MigrationInfo) GetPausedAt 

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

func (*MigrationInfo) GetPorts 

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

func (*MigrationInfo) GetRestoreEnd 

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

func (*MigrationInfo) GetRestoreStart 

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

func (*MigrationInfo) ProtoMessage 

func (*MigrationInfo) ProtoMessage()

func (*MigrationInfo) ProtoReflect 

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

func (*MigrationInfo) Reset 

func (x *MigrationInfo) Reset()

func (*MigrationInfo) String 

func (x *MigrationInfo) String() string

type NodeClient 

type NodeClient interface {
	Evac(context.Context, *EvacRequest) (*EvacResponse, error)
	PrepareEvac(context.Context, *EvacRequest) (*EvacResponse, error)
	Restore(context.Context, *RestoreRequest) (*RestoreResponse, error)
	FinishRestore(context.Context, *RestoreRequest) (*RestoreResponse, error)
	NewCriuLazyPages(context.Context, *CriuLazyPagesRequest) (*emptypb.Empty, error)
	PullImage(context.Context, *PullImageRequest) (Node_PullImageClient, error)
}

func NewNodeClient 

func NewNodeClient(client *ttrpc.Client) NodeClient

type NodeService 

type NodeService interface {
	Evac(context.Context, *EvacRequest) (*EvacResponse, error)
	PrepareEvac(context.Context, *EvacRequest) (*EvacResponse, error)
	Restore(context.Context, *RestoreRequest) (*RestoreResponse, error)
	FinishRestore(context.Context, *RestoreRequest) (*RestoreResponse, error)
	NewCriuLazyPages(context.Context, *CriuLazyPagesRequest) (*emptypb.Empty, error)
	PullImage(context.Context, *PullImageRequest, Node_PullImageServer) error
}

type Node_PullImageClient 

type Node_PullImageClient interface {
	Recv() (*Image, error)
	ttrpc.ClientStream
}

type Node_PullImageServer 

type Node_PullImageServer interface {
	Send(*Image) error
	ttrpc.StreamServer
}

type PodInfo 

type PodInfo struct {
	Name          string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace     string  `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ContainerName string  `protobuf:"bytes,3,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	Ports         []int32 `protobuf:"varint,4,rep,packed,name=ports,proto3" json:"ports,omitempty"`
	// contains filtered or unexported fields
}

func (*PodInfo) Descriptor deprecated 

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

Deprecated: Use PodInfo.ProtoReflect.Descriptor instead.

func (*PodInfo) GetContainerName 

func (x *PodInfo) GetContainerName() string

func (*PodInfo) GetName 

func (x *PodInfo) GetName() string

func (*PodInfo) GetNamespace 

func (x *PodInfo) GetNamespace() string

func (*PodInfo) GetPorts 

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

func (*PodInfo) ProtoMessage 

func (*PodInfo) ProtoMessage()

func (*PodInfo) ProtoReflect 

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

func (*PodInfo) Reset 

func (x *PodInfo) Reset()

func (*PodInfo) String 

func (x *PodInfo) String() string

type PullImageRequest 

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

func (*PullImageRequest) Descriptor deprecated 

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

Deprecated: Use PullImageRequest.ProtoReflect.Descriptor instead.

func (*PullImageRequest) GetImageId 

func (x *PullImageRequest) GetImageId() string

func (*PullImageRequest) ProtoMessage 

func (*PullImageRequest) ProtoMessage()

func (*PullImageRequest) ProtoReflect 

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

func (*PullImageRequest) Reset 

func (x *PullImageRequest) Reset()

func (*PullImageRequest) String 

func (x *PullImageRequest) String() string

type RestoreRequest 

type RestoreRequest struct {
	PodInfo       *PodInfo       `protobuf:"bytes,1,opt,name=pod_info,json=podInfo,proto3" json:"pod_info,omitempty"`
	MigrationInfo *MigrationInfo `protobuf:"bytes,2,opt,name=migration_info,json=migrationInfo,proto3" json:"migration_info,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreRequest) Descriptor deprecated 

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

Deprecated: Use RestoreRequest.ProtoReflect.Descriptor instead.

func (*RestoreRequest) GetMigrationInfo 

func (x *RestoreRequest) GetMigrationInfo() *MigrationInfo

func (*RestoreRequest) GetPodInfo 

func (x *RestoreRequest) GetPodInfo() *PodInfo

func (*RestoreRequest) ProtoMessage 

func (*RestoreRequest) ProtoMessage()

func (*RestoreRequest) ProtoReflect 

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

func (*RestoreRequest) Reset 

func (x *RestoreRequest) Reset()

func (*RestoreRequest) String 

func (x *RestoreRequest) String() string

type RestoreResponse 

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

func (*RestoreResponse) Descriptor deprecated 

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

Deprecated: Use RestoreResponse.ProtoReflect.Descriptor instead.

func (*RestoreResponse) GetMigrationInfo 

func (x *RestoreResponse) GetMigrationInfo() *MigrationInfo

func (*RestoreResponse) ProtoMessage 

func (*RestoreResponse) ProtoMessage()

func (*RestoreResponse) ProtoReflect 

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

func (*RestoreResponse) Reset 

func (x *RestoreResponse) Reset()

func (*RestoreResponse) String 

func (x *RestoreResponse) String() string

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.