observer

Documentation

Overview

Package observer provides storage observer

Package observer provides storage observer

Index

• 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 WithPostStopTimeout(dur string) Option
• type StorageObserver
  • func New(opts ...Option) (so StorageObserver, err error)

Types

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 WithPostStopTimeout

func WithPostStopTimeout(dur string) 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)