transactional_outbox

Documentation

Index

• Variables
• type Config
  • func DefaultConfig() Config
  • func (c Config) ValidateConfigFields() error
• type Outbox
  • func NewOutbox[T any](config Config, builder *squirrel_builder.Builder, logger log.Logger) (*Outbox[T], error)
  • func (o *Outbox[T]) Close() error
  • func (o *Outbox[T]) SaveEvents(txCtx squirrel_builder.TransactionContext, datas ...T) error
  • func (o *Outbox[T]) SetProcessingFunction(processingFunction func(ctx context.Context, data T) error)

Variables

var DatabaseMigrations embed.FS

Types

type Config

type Config struct {
	QueryTimeout       time.Duration
	TickerDuration     time.Duration
	ErrorMaxValue      int64
	QueryErrorMaxValue int64
	NumberOfWorkers    int64
	BatchSize          uint64
}

func DefaultConfig

func DefaultConfig() Config

func (Config) ValidateConfigFields

func (c Config) ValidateConfigFields() error

type Outbox

type Outbox[T any] struct {
	// contains filtered or unexported fields
}

func NewOutbox

func NewOutbox[T any](
	config Config,
	builder *squirrel_builder.Builder,
	logger log.Logger,
) (*Outbox[T], error)

func (*Outbox[T]) Close

func (o *Outbox[T]) Close() error

func (*Outbox[T]) SaveEvents

func (o *Outbox[T]) SaveEvents(
	txCtx squirrel_builder.TransactionContext,
	datas ...T,
) error

func (*Outbox[T]) SetProcessingFunction

func (o *Outbox[T]) SetProcessingFunction(processingFunction func(ctx context.Context, data T) error)