postgres

Documentation

Index

• Constants
• func NewWatcher(db *pachsql.DB, listener collection.PostgresListener, id string, ...) (*watcher, error)
• type Event
• type EventType
• type WatcherOption
  • func WithBufferSize(size int) WatcherOption

Constants

const (
	DefaultBufferSize = 1000
)

Functions

func NewWatcher

func NewWatcher(db *pachsql.DB, listener collection.PostgresListener, id string, channel string, opts ...WatcherOption) (*watcher, error)

Types

type Event

type Event struct {
	Id   uint64
	Type EventType
	Err  error
}

type EventType

type EventType uint8

const (
	// EventInsert happens when an item is added
	EventInsert EventType = iota
	// EventUpdate happens when an item is updated
	EventUpdate
	// EventDelete happens when an item is removed
	EventDelete
)

type WatcherOption

type WatcherOption func(*watcher)

func WithBufferSize

func WithBufferSize(size int) WatcherOption