cdc_postgres

Documentation

Index

• func NewService(opts *cli.Options) (*pgx.ReplicationConn, error)
• func Read(opts *cli.Options, _ *desc.MessageDescriptor) error
• func Relay(opts *cli.Options, relayCh chan interface{}, shutdownCtx context.Context) (relay.IRelayBackend, error)
• type CDCPostgres
  • func (p *CDCPostgres) Read() error
• type Relayer
  • func (r *Relayer) Relay() error

Functions

func NewService

func NewService(opts *cli.Options) (*pgx.ReplicationConn, error)

func Read

func Read(opts *cli.Options, _ *desc.MessageDescriptor) error

func Relay

func Relay(opts *cli.Options, relayCh chan interface{}, shutdownCtx context.Context) (relay.IRelayBackend, error)

Types

type CDCPostgres

type CDCPostgres struct {
	Options *cli.Options
	Service *pgx.ReplicationConn
	Log     *logrus.Entry
	Printer printer.IPrinter
}

func (*CDCPostgres) Read

func (p *CDCPostgres) Read() error

type Relayer

type Relayer struct {
	Options *cli.Options
	RelayCh chan interface{}

	Service     *pgx.ReplicationConn
	ShutdownCtx context.Context
	// contains filtered or unexported fields
}

func (*Relayer) Relay

func (r *Relayer) Relay() error