package
0.0.0-20210623111042-e758639c4af5
Repository: https://github.com/blendle/pg2kafka.git
Documentation: pkg.go.dev

# Functions

New creates a new Queue, connected to the given database URL.
NewWithDB creates a new Queue with the given database.

# Structs

Event represents the queued event in the database.
Queue represents the queue of snapshot/create/update/delete events stored in the database.

# Type aliases

ByteString is a special type of byte array with implemented interfaces to convert from and to JSON and SQL values.