persister

Documentation

Index

• type Option
  • func WithFlushInterval(i time.Duration) Option
  • func WithFlushSize(s int) 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, mysqlClient mysql.Client, opts ...Option) *Persister
  • func (p *Persister) Check(ctx context.Context) health.Status
  • func (p *Persister) Run() error
  • func (p *Persister) Stop()

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(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 struct {
	// contains filtered or unexported fields
}

func NewPersister

func NewPersister(
	p puller.Puller,
	mysqlClient mysql.Client,
	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()