Documentation ¶
Index ¶
Constants ¶
View Source
const (
DefaultBufferSize = 1000
)
Variables ¶
This section is empty.
Functions ¶
func NewWatcher ¶
func NewWatcher(db *pachsql.DB, listener collection.PostgresListener, id string, channel string, opts ...WatcherOption) (*watcher, error)
Types ¶
type WatcherOption ¶
type WatcherOption func(*watcher)
func WithBufferSize ¶
func WithBufferSize(size int) WatcherOption
Click to show internal directories.
Click to hide internal directories.