dlq

Documentation

Overview

Package dlq writes unhandled mutations to dead-letter queues in the target database.

Index

• Variables
• func ProvideDLQs(cfg *Config, pool *types.TargetPool, watchers types.Watchers) types.DLQs
• type Config
  • func (c *Config) Bind(f *pflag.FlagSet)
  • func (c *Config) Preflight() error

Variables

var BasicSchemas = map[types.Product]string{
	types.ProductCockroachDB: basicCRDBSchema,
	types.ProductMariaDB:     basicMySQLSchema,
	types.ProductMySQL:       basicMySQLSchema,
	types.ProductOracle:      basicOraSchema,
	types.ProductPostgreSQL:  basicPGSchema,
}

BasicSchemas is a collection of suggested schemas for the DLQ table. It is exported so that tests which require the DLQ can use the suggested schemas. See [all.Fixture.CreateDLQTable].

var Set = wire.NewSet(ProvideDLQs)

Set is used by Wire.

Functions

func ProvideDLQs

func ProvideDLQs(cfg *Config, pool *types.TargetPool, watchers types.Watchers) types.DLQs

ProvideDLQs is called by Wire to construct the DLQs instance.

Types

type Config

type Config struct {
	TableName ident.Ident // Default name within the target schema.
}

Config controls the DLQ behavior.

func (*Config) Bind

func (c *Config) Bind(f *pflag.FlagSet)

Bind adds configuration flags to the set.

func (*Config) Preflight

func (c *Config) Preflight() error

Preflight validates the configuration.