superviser

Documentation

Index

• func GetPitreos(logger *zap.Logger, backupURL string, appendOnlyFiles ...string) (*pitreos.PITR, error)
• func ListPitreosBackup(logger *zap.Logger, backupTag, backupStoreURL, prefix string, ...) ([]*pitreos.ListableBackup, error)
• type Superviser
  • func New(logger *zap.Logger, binary string, arguments []string) *Superviser
  • func (s *Superviser) GetLogPlugins() []logplugin.LogPlugin
  • func (s *Superviser) IsRunning() bool
  • func (s *Superviser) LastExitCode() int
  • func (s *Superviser) RegisterLogPlugin(plugin logplugin.LogPlugin)
  • func (s *Superviser) RegisterPostRestoreHandler(f func())
  • func (s *Superviser) Start(options ...manageos.StartOption) error
  • func (s *Superviser) Stop() error
  • func (s *Superviser) Stopped() <-chan struct{}

Functions

func GetPitreos

func GetPitreos(logger *zap.Logger, backupURL string, appendOnlyFiles ...string) (*pitreos.PITR, error)

func ListPitreosBackup

func ListPitreosBackup(logger *zap.Logger, backupTag, backupStoreURL, prefix string, limit, offset int) ([]*pitreos.ListableBackup, error)

Types

type Superviser

type Superviser struct {
	Binary    string
	Arguments []string
	Logger    *zap.Logger

	HandlePostRestore func()
	// contains filtered or unexported fields
}

func New

func New(logger *zap.Logger, binary string, arguments []string) *Superviser

func (*Superviser) GetLogPlugins

func (s *Superviser) GetLogPlugins() []logplugin.LogPlugin

func (*Superviser) IsRunning

func (s *Superviser) IsRunning() bool

func (*Superviser) LastExitCode

func (s *Superviser) LastExitCode() int

func (*Superviser) RegisterLogPlugin

func (s *Superviser) RegisterLogPlugin(plugin logplugin.LogPlugin)

func (*Superviser) RegisterPostRestoreHandler

func (s *Superviser) RegisterPostRestoreHandler(f func())

RegisterPostRestoreHandler adds a function called after a restore from backup or from snapshot

func (*Superviser) Start

func (s *Superviser) Start(options ...manageos.StartOption) error

func (*Superviser) Stop

func (s *Superviser) Stop() error

func (*Superviser) Stopped

func (s *Superviser) Stopped() <-chan struct{}