snapper

Documentation

Index

• func WithLogger(ctx context.Context, log Logger) context.Context
• type Logger
• type PeriodicOrManual
  • func FromConfig(g *config.Global, fsf *filters.DatasetMapFilter, in config.SnapshottingEnum) (*PeriodicOrManual, error)
  • func (s *PeriodicOrManual) Run(ctx context.Context, wakeUpCommon chan<- struct{})
• type SnapState
  • func (i SnapState) String() string
• type Snapper
  • func PeriodicFromConfig(g *config.Global, fsf *filters.DatasetMapFilter, ...) (*Snapper, error)
  • func (s *Snapper) Run(ctx context.Context, snapshotsTaken chan<- struct{})
• type State
  • func (i State) String() string

Functions

func WithLogger

func WithLogger(ctx context.Context, log Logger) context.Context

Types

type Logger

type Logger = logger.Logger

type PeriodicOrManual

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

FIXME: properly abstract snapshotting:

• split up things that trigger snapshotting from the mechanism
• timer-based trigger (periodic)
• call from control socket (manual)
• mixed modes?
• support a `zrepl snapshot JOBNAME` subcommand for config.SnapshottingManual

func FromConfig

func FromConfig(g *config.Global, fsf *filters.DatasetMapFilter, in config.SnapshottingEnum) (*PeriodicOrManual, error)

func (*PeriodicOrManual) Run

func (s *PeriodicOrManual) Run(ctx context.Context, wakeUpCommon chan<- struct{})

type SnapState

type SnapState uint

const (
	SnapPending SnapState = 1 << iota
	SnapStarted
	SnapDone
	SnapError
)

func (SnapState) String

func (i SnapState) String() string

type Snapper

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

func PeriodicFromConfig

func PeriodicFromConfig(g *config.Global, fsf *filters.DatasetMapFilter, in *config.SnapshottingPeriodic) (*Snapper, error)

func (*Snapper) Run

func (s *Snapper) Run(ctx context.Context, snapshotsTaken chan<- struct{})

type State

type State uint

const (
	SyncUp State = 1 << iota
	SyncUpErrWait
	Planning
	Snapshotting
	Waiting
	ErrorWait
	Stopped
)

func (State) String

func (i State) String() string