backup

Documentation

Index

• Constants
• Variables
• func NewDockerClient() *client.Client
• func NewKetiClient() keticlient.KetiV1Interface
• func NewKubeClient() clientset.Interface
• type CheckpointCollector
  • func NewCheckpointCollector() *CheckpointCollector
  • func (c *CheckpointCollector) CheckpointCreate(ctx context.Context, in *checkpointcollector.CreateCheckpoint) (*checkpointcollector.PodReturnValue, error)
  • func (c *CheckpointCollector) ContainerSync()
  • func (c *CheckpointCollector) ConvertPod(ctx context.Context, in *checkpointcollector.Convert) (*checkpointcollector.Empty, error)
  • func (c *CheckpointCollector) ConvertPodToMigPod(containers map[string]string)
  • func (c *CheckpointCollector) CreateDocker(in *checkpointcollector.Connect, ...) error
  • func (c *CheckpointCollector) ExecPod(*checkpointcollector.ExecValue, ...) error
  • func (c *CheckpointCollector) HandleCheckPoint(podname resource)
  • func (c *CheckpointCollector) HandleCheckPointAll(pods map[string]map[string]string)
  • func (c *CheckpointCollector) LogPod(ctx context.Context, msg *checkpointcollector.LogValue) (*checkpointcollector.LogReturnValue, error)
  • func (c *CheckpointCollector) NewContainerLister()
  • func (c *CheckpointCollector) Run()
  • func (c *CheckpointCollector) SetCheckpointPeriod(ctx context.Context, in *checkpointcollector.InputValue) (*checkpointcollector.ReturnValue, error)
• type GRPCHandler
• type LogConnection

Constants

const (
	ConvertType receivetype = "convert"
	Migration   receivetype = "migration"
)

Variables

var OldPeriod int64

Functions

func NewDockerClient

func NewDockerClient() *client.Client

func NewKetiClient

func NewKetiClient() keticlient.KetiV1Interface

func NewKubeClient

func NewKubeClient() clientset.Interface

Types

type CheckpointCollector

type CheckpointCollector struct {
	Cnumber      int
	Pods         map[string]map[string]string
	DockerClient *client.Client
	KubeClient   clientset.Interface
	KetiClient   keticlient.KetiV1Interface
	Period       int64
	UpdateChan   chan resource
	DoneChan     chan int
	Connection   *LogConnection
}

func NewCheckpointCollector

func NewCheckpointCollector() *CheckpointCollector

func (*CheckpointCollector) CheckpointCreate

func (c *CheckpointCollector) CheckpointCreate(ctx context.Context, in *checkpointcollector.CreateCheckpoint) (*checkpointcollector.PodReturnValue, error)

func (*CheckpointCollector) ContainerSync

func (c *CheckpointCollector) ContainerSync()

func (*CheckpointCollector) ConvertPod

func (c *CheckpointCollector) ConvertPod(ctx context.Context, in *checkpointcollector.Convert) (*checkpointcollector.Empty, error)

func (*CheckpointCollector) ConvertPodToMigPod

func (c *CheckpointCollector) ConvertPodToMigPod(containers map[string]string)

func (*CheckpointCollector) CreateDocker

func (c *CheckpointCollector) CreateDocker(in *checkpointcollector.Connect, stream checkpointcollector.CheckpointPeriod_CreateDockerServer) error

func (*CheckpointCollector) ExecPod

func (c *CheckpointCollector) ExecPod(*checkpointcollector.ExecValue, checkpointcollector.CheckpointPeriod_ExecPodServer) error

func (*CheckpointCollector) HandleCheckPoint

func (c *CheckpointCollector) HandleCheckPoint(podname resource)

func (*CheckpointCollector) HandleCheckPointAll

func (c *CheckpointCollector) HandleCheckPointAll(pods map[string]map[string]string)

func (*CheckpointCollector) LogPod

func (c *CheckpointCollector) LogPod(ctx context.Context, msg *checkpointcollector.LogValue) (*checkpointcollector.LogReturnValue, error)

func (*CheckpointCollector) NewContainerLister

func (c *CheckpointCollector) NewContainerLister()

func (*CheckpointCollector) Run

func (c *CheckpointCollector) Run()

func (*CheckpointCollector) SetCheckpointPeriod

func (c *CheckpointCollector) SetCheckpointPeriod(ctx context.Context, in *checkpointcollector.InputValue) (*checkpointcollector.ReturnValue, error)

type GRPCHandler

type GRPCHandler interface {
	HandleCheckPoint(podname resource)
	HandleCheckPointAll(pods map[string]map[string]string)
}

type LogConnection

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