manager

Documentation

Index

• func MaybePrepareTransfer()
• type StopComponent
• type TransferManager
  • func NewTransferManager(pm *pipeline.Manager, lsm *logstream.Manager) *TransferManager
  • func (tm *TransferManager) AddStopComponents(stopComponents ...StopComponent)
  • func (tm *TransferManager) ListenTransfer()
  • func (tm *TransferManager) StopAndSaveState() ([]byte, error)
  • func (tm *TransferManager) StopSaveStateToFile() error
  • func (tm *TransferManager) Transfer() error
  • func (tm *TransferManager) TransferDone()

Functions

func MaybePrepareTransfer

func MaybePrepareTransfer()

Types

type StopComponent

type StopComponent interface {
	Stop()
}

type TransferManager

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

TransferManager is responsible for handling the logic of lossless restart/deployment.

func NewTransferManager

func NewTransferManager(pm *pipeline.Manager, lsm *logstream.Manager) *TransferManager

func (*TransferManager) AddStopComponents

func (tm *TransferManager) AddStopComponents(stopComponents ...StopComponent)

func (*TransferManager) ListenTransfer

func (tm *TransferManager) ListenTransfer()

func (*TransferManager) StopAndSaveState

func (tm *TransferManager) StopAndSaveState() ([]byte, error)

StopAndSaveState stops all active components and dumps their state to []byte

func (*TransferManager) StopSaveStateToFile

func (tm *TransferManager) StopSaveStateToFile() error

func (*TransferManager) Transfer

func (tm *TransferManager) Transfer() error

Transfer transfers state from old instance to current instance

func (*TransferManager) TransferDone

func (tm *TransferManager) TransferDone()