Versions in this module Expand all Collapse all v1 v1.0.0 Sep 20, 2019 Changes in this version + func New(ctx context.Context, logger *zap.SugaredLogger, errCh chan error, ...) *consumer + type Handler interface + HandleMessage func(dbtypes.LSN, message.Message) error + type Interface interface + AdvanceLSN func(dbtypes.LSN) + CurrentLSN func() dbtypes.LSN + Run func(Handler) error + SendStatus func() error + Wait func()
Go to main page