persister

Documentation

Index

• Variables
• type Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMaxMPS(mps int) Option
  • func WithMetrics(r metrics.Registerer) Option
  • func WithNumWorkers(n int) Option
• type Persister
  • func NewPersister(p puller.Puller, opts ...Option) Persister

Variables

var (
	ErrUnknownEvent    = errors.New("metricsevent persister: unknown metrics event")
	ErrInvalidDuration = errors.New("metricsevent persister: invalid duration")
	ErrUnknownApiId    = errors.New("metricsevent persister: unknown api id")
)

Types

type Option

type Option func(*options)

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMaxMPS

func WithMaxMPS(mps int) Option

func WithMetrics

func WithMetrics(r metrics.Registerer) Option

func WithNumWorkers

func WithNumWorkers(n int) Option

type Persister

type Persister interface {
	Run() error
	Stop()
	Check(context.Context) health.Status
}

func NewPersister

func NewPersister(p puller.Puller, opts ...Option) Persister