changelog

Documentation

Index

• Constants
• Variables
• func ThisInstanceCluster() string
• func Worker(ctx context.Context, cfg *config.AppConfig, bufPipe pipe.Pipe, tp pool.Thread) bool
• type Reader
• type ReaderConstructor

Constants

const SeqnoSaveInterval = 1000000

SeqnoSaveInterval is the number of messages after which seqno gets persisted in state

Variables

var Plugins map[string]ReaderConstructor

Plugins contains registered binlog reader plugins

Functions

func ThisInstanceCluster

func ThisInstanceCluster() string

ThisInstanceCluster returns the cluster name name this instance's binlog * mysqlReader is working on. This is used by local streamers to identify tables they * have to stream

func Worker

func Worker(ctx context.Context, cfg *config.AppConfig, bufPipe pipe.Pipe, tp pool.Thread) bool

Worker iterates over available workers and try start them

Types

type Reader

type Reader interface {
	//Worker is a main log reader routine
	//returns false if no more log readers of this type are needed
	Worker() bool
}

Reader is a contract for changelog reader

type ReaderConstructor

type ReaderConstructor func(ctx context.Context, cfg *config.AppConfig, bufPipe pipe.Pipe, t pool.Thread) (Reader, error)

ReaderConstructor initializes logger plugin