dlq

package
v0.0.0-...-9e054ec Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

View Source 
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].

View Source 
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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.