instrumentation

Documentation

Index

• func NewHandler(inner replication.Handler, instrumentation *otel.Instrumentation) (replication.Handler, error)
• type Handler
  • func (h *Handler) Close() error
  • func (h *Handler) GetLSNParser() replication.LSNParser
  • func (h *Handler) GetReplicationLag(ctx context.Context) (int64, error)
  • func (h *Handler) ReceiveMessage(ctx context.Context) (msg *replication.Message, err error)
  • func (h *Handler) StartReplication(ctx context.Context) error
  • func (h *Handler) SyncLSN(ctx context.Context, lsn replication.LSN) (err error)

Functions

func NewHandler

func NewHandler(inner replication.Handler, instrumentation *otel.Instrumentation) (replication.Handler, error)

Types

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

func (*Handler) Close

func (h *Handler) Close() error

func (*Handler) GetLSNParser

func (h *Handler) GetLSNParser() replication.LSNParser

func (*Handler) GetReplicationLag

func (h *Handler) GetReplicationLag(ctx context.Context) (int64, error)

func (*Handler) ReceiveMessage

func (h *Handler) ReceiveMessage(ctx context.Context) (msg *replication.Message, err error)

func (*Handler) StartReplication

func (h *Handler) StartReplication(ctx context.Context) error

func (*Handler) SyncLSN

func (h *Handler) SyncLSN(ctx context.Context, lsn replication.LSN) (err error)