Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OutboxPattern ¶
func NewOutboxPattern ¶
func (*OutboxPattern) Close ¶
func (outbox *OutboxPattern) Close()
func (*OutboxPattern) PingContext ¶
func (outbox *OutboxPattern) PingContext(ctx context.Context) error
func (*OutboxPattern) Run ¶
func (outbox *OutboxPattern) Run(ctx context.Context, value chan interfaces.BinlogOutbox) (err error)
func (*OutboxPattern) SavePosition ¶
func (outbox *OutboxPattern) SavePosition() error
type OutboxPolling ¶
type OutboxPolling struct { *config.OutboxPolling // contains filtered or unexported fields }
func NewOutboxPolling ¶
func NewOutboxPolling( ctx context.Context, polling *config.OutboxPolling, publisher interfaces.Publisher, runInTransaction transaction, ) (*OutboxPolling, error)
func (*OutboxPolling) PingContext ¶
func (p *OutboxPolling) PingContext(ctx context.Context) error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.