bridge

Documentation

Index

• Constants
• func NewLogger(level string, format string) *zap.SugaredLogger
• type Duplicate
  • func NewDuplicate() *Duplicate
  • func (d *Duplicate) Ensure(e *db.Event)
  • func (d *Duplicate) Exists(e *db.Event) bool
• type ErrorHandlerFunc
• type Sync
  • func New(db db.DB, pub kafka.Publisher, dup *Duplicate, sc *stats.Collector, ...) *Sync
  • func (s *Sync) Close() (err error)
  • func (s *Sync) Run(ctx context.Context) error
• type SyncOption
  • func TopicPrefix(prefix string) SyncOption

Constants

const DefaultTopicPrefix = "es.aggregate."

Functions

func NewLogger

func NewLogger(level string, format string) *zap.SugaredLogger

Types

type Duplicate

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

func NewDuplicate

func NewDuplicate() *Duplicate

func (*Duplicate) Ensure

func (d *Duplicate) Ensure(e *db.Event)

func (*Duplicate) Exists

func (d *Duplicate) Exists(e *db.Event) bool

type ErrorHandlerFunc

type ErrorHandlerFunc func(ctx context.Context, err error)

type Sync

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

func New

func New(
	db db.DB,
	pub kafka.Publisher,
	dup *Duplicate,
	sc *stats.Collector,
	logger *zap.SugaredLogger,
	options ...SyncOption,
) *Sync

func (*Sync) Close

func (s *Sync) Close() (err error)

func (*Sync) Run

func (s *Sync) Run(ctx context.Context) error

type SyncOption

type SyncOption func(s *Sync)

func TopicPrefix

func TopicPrefix(prefix string) SyncOption