consumer

Documentation

Index

• func New(ctx context.Context, errCh chan error, dbCfg pgx.ConnConfig, ...) *consumer
• type Handler
• type Interface

Functions

func New

func New(ctx context.Context, errCh chan error, dbCfg pgx.ConnConfig, slotName, publicationName string, startLSN utils.LSN) *consumer

New instantiates the consumer

Types

type Handler

type Handler interface {
	HandleMessage(utils.LSN, message.Message) error
}

Handler represents interface for processing logical replication messages

type Interface

type Interface interface {
	SendStatus() error
	Run(Handler) error
	AdvanceLSN(utils.LSN)
	Wait()
}

Interface represents interface for the consumer