listener

type Listener ¶

type Listener interface {
	Listen(ctx context.Context) error
	Close() error
}

Listener represents a process that listens to WAL events.

type ProcessWalEvent ¶ added in v0.4.0

type ProcessWalEvent func(context.Context, *wal.Event) error

type Processor ¶ added in v0.6.5

type Processor interface {
	ProcessWALEvent(context.Context, *wal.Event) error
	Close() error
}