checkpoint

Documentation

Index

• Constants
• func NewSPDYExecutor(urlStr string) (remotecommand.Executor, error)
• type Config
• type RemoteCMDExecutorFactory
• type Server
  • func NewServer(service Service) *Server
  • func (s *Server) CheckpointStatus(ctx context.Context, req *checkpointv1alpha1.CheckpointStatusRequest) (*checkpointv1alpha1.CheckpointStatusResponse, error)
  • func (s *Server) CreateCheckpoint(ctx context.Context, req *checkpointv1alpha1.CreateCheckpointRequest) (*checkpointv1alpha1.CreateCheckpointResponse, error)
• type Service
• type ServiceImpl
  • func NewService(logger *slog.Logger, cfg Config, criService cri.Service, ...) *ServiceImpl
  • func (s *ServiceImpl) CheckpointStatus(checkpointID string) *status.Status
  • func (s *ServiceImpl) CollectGarbage(ctx context.Context) error
  • func (s *ServiceImpl) CreateCheckpoint(ctx context.Context, baseRef name.Reference) (string, error)

Constants

const Namespace = "checkpoint"

Functions

func NewSPDYExecutor

func NewSPDYExecutor(urlStr string) (remotecommand.Executor, error)

Types

type Config

type Config struct {
	CPUPeriod                int64
	CPUQuota                 int64
	MemoryLimitBytes         int64
	CheckpointFileDir        string
	CheckpointTimeoutSeconds int64
	RegistryUser             string
	RegistryPass             string
	ListenAddr               string
	StatusRetentionPeriod    time.Duration
	ContainerReadyTimeout    time.Duration
	WaitAfterServerInit      time.Duration
}

type RemoteCMDExecutorFactory

type RemoteCMDExecutorFactory func(url string) (remotecommand.Executor, error)

type Server

type Server struct {
	checkpointv1alpha1.UnimplementedCheckpointServiceServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(service Service) *Server

func (*Server) CheckpointStatus

func (s *Server) CheckpointStatus(
	ctx context.Context,
	req *checkpointv1alpha1.CheckpointStatusRequest,
) (*checkpointv1alpha1.CheckpointStatusResponse, error)

func (*Server) CreateCheckpoint

func (s *Server) CreateCheckpoint(
	ctx context.Context,
	req *checkpointv1alpha1.CreateCheckpointRequest,
) (*checkpointv1alpha1.CreateCheckpointResponse, error)

type Service

type Service interface {
	CreateCheckpoint(ctx context.Context, baseRef name.Reference) (string, error)
	CheckpointStatus(checkpointID string) *status.Status
}

type ServiceImpl

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

func NewService

func NewService(
	logger *slog.Logger,
	cfg Config,
	criService cri.Service,
	imgService image.Service,
	statusStore status.Store,
	newRemoteCMDExecutor RemoteCMDExecutorFactory,
	portAlloc *workload.PortAllocator,

) *ServiceImpl

func (*ServiceImpl) CheckpointStatus

func (s *ServiceImpl) CheckpointStatus(checkpointID string) *status.Status

func (*ServiceImpl) CollectGarbage

func (s *ServiceImpl) CollectGarbage(ctx context.Context) error

CollectGarbage removes all checkpoint tarballs and pods of checkpoint jobs that have failed or completed successfully.

func (*ServiceImpl) CreateCheckpoint

func (s *ServiceImpl) CreateCheckpoint(ctx context.Context, baseRef name.Reference) (string, error)