replication

Documentation

Index

• Variables
• type Handler
• type LSN
• type LSNParser
• type Message

Variables

var ErrConnTimeout = errors.New("connection timeout")

Types

type Handler

type Handler interface {
	StartReplication(ctx context.Context) error
	ReceiveMessage(ctx context.Context) (*Message, error)
	SyncLSN(ctx context.Context, lsn LSN) error
	GetReplicationLag(ctx context.Context) (int64, error)
	GetLSNParser() LSNParser
	Close() error
}

Handler manages the replication operations

type LSN

type LSN uint64

type LSNParser

type LSNParser interface {
	ToString(LSN) string
	FromString(string) (LSN, error)
}

LSNParser handles the LSN type conversion

type Message

type Message struct {
	LSN            LSN
	Data           []byte
	ServerTime     time.Time
	ReplyRequested bool
}

Message contains the replication data