forwarder

Documentation

Index

• Constants
• Variables
• type DBForwarder
  • func New(db db.DB, bus bus.Bus, options *Options) (*DBForwarder, error)
  • func (fw *DBForwarder) Start(ctx context.Context) error
  • func (fw *DBForwarder) Stop() error
• type Options

Constants

const DefaultPollingInterval = 100 * time.Millisecond

Variables

var DefaultOptions = &Options{
	PollingInterval: DefaultPollingInterval,
	Serializer:      serialization.NewProtobufSerializer(),
	OutboxTableName: "event_outbox",
}

Types

type DBForwarder

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

func New

func New(db db.DB, bus bus.Bus, options *Options) (*DBForwarder, error)

func (*DBForwarder) Start

func (fw *DBForwarder) Start(ctx context.Context) error

func (*DBForwarder) Stop

func (fw *DBForwarder) Stop() error

type Options

type Options struct {
	PollingInterval time.Duration
	Serializer      serialization.Serializer
	OutboxTableName string
	Logger          *zap.Logger
}