persister

Documentation

Index

• Variables
• type Option
  • func WithFlushInterval(i time.Duration) Option
  • func WithFlushSize(s int) Option
  • func WithLogger(l *zap.Logger) Option
  • func WithMaxMPS(mps int) Option
  • func WithMetrics(r metrics.Registerer) Option
  • func WithNumWorkers(n int) Option
  • func WithWriteCacheInterval(i time.Duration) Option
• type Persister
  • func NewPersister(p puller.Puller, mysqlClient mysql.Client, ...) *Persister
  • func (p *Persister) Check(ctx context.Context) health.Status
  • func (p *Persister) Run() error
  • func (p *Persister) Stop()

Variables

var (
	ErrUnexpectedMessageType = errors.New("eventpersister: unexpected message type")
	ErrAutoOpsRulesNotFound  = errors.New("eventpersister: auto ops rules not found")
	ErrExperimentNotFound    = errors.New("eventpersister: experiment not found")
	ErrNoAutoOpsRules        = errors.New("eventpersister: no auto ops rules")
	ErrNoExperiments         = errors.New("eventpersister: no experiments")
	ErrNothingToLink         = errors.New("eventpersister: nothing to link")
	ErrReasonNil             = errors.New("eventpersister: reason is nil")
)

Types

type Option

type Option func(*options)

func WithFlushInterval

func WithFlushInterval(i time.Duration) Option

func WithFlushSize

func WithFlushSize(s int) Option

func WithLogger

func WithLogger(l *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

func WithWriteCacheInterval

func WithWriteCacheInterval(i time.Duration) Option

type Persister

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

func NewPersister

func NewPersister(
	p puller.Puller,
	mysqlClient mysql.Client,
	v3Cache cache.MultiGetDeleteCountCache,
	opts ...Option,
) *Persister

func (*Persister) Check

func (p *Persister) Check(ctx context.Context) health.Status

func (*Persister) Run

func (p *Persister) Run() error

func (*Persister) Stop

func (p *Persister) Stop()