observer

Documentation

Overview

Package observer provides storage observer

Package observer provides storage observer

Package observer provides storage observer

Index

• type BackupInfo
• type Hook
• type Option
  • func WithBackupDuration(dur string) Option
  • func WithBlobStorage(storage storage.Storage) Option
  • func WithDir(dir string) Option
  • func WithErrGroup(eg errgroup.Group) Option
  • func WithHooks(hooks ...Hook) Option
  • func WithPostStopTimeout(dur string) Option
  • func WithTicker(enabled bool) Option
  • func WithWatch(enabled bool) Option
• type StorageObserver
  • func New(opts ...Option) (so StorageObserver, err error)

Types

type BackupInfo

type BackupInfo struct {
	StartTime time.Time
	EndTime   time.Time
	Bytes     int64

	*storage.StorageInfo
}

type Hook

type Hook interface {
	BeforeProcess(ctx context.Context, info *BackupInfo) (context.Context, error)
	AfterProcess(ctx context.Context, info *BackupInfo) error
}

type Option

type Option func(o *observer) error

func WithBackupDuration

func WithBackupDuration(dur string) Option

func WithBlobStorage

func WithBlobStorage(storage storage.Storage) Option

func WithDir

func WithDir(dir string) Option

func WithErrGroup

func WithErrGroup(eg errgroup.Group) Option

func WithHooks

func WithHooks(hooks ...Hook) Option

func WithPostStopTimeout

func WithPostStopTimeout(dur string) Option

func WithTicker

func WithTicker(enabled bool) Option

func WithWatch

func WithWatch(enabled bool) Option

type StorageObserver

type StorageObserver interface {
	Start(ctx context.Context) (<-chan error, error)
	PostStop(ctx context.Context) error
}

func New

func New(opts ...Option) (so StorageObserver, err error)