v1

package
v0.6.1 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 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"
	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 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.