Documentation
¶
Overview ¶
Package cdc contains a utility for receiving notifications whenever the contents of a database table are changed.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Set is used by wire. Set = wire.NewSet(ProvideNotifier) )
Functions ¶
This section is empty.
Types ¶
type Notification ¶
type Notification struct {
Table string // The table that was updated
Key json.RawMessage // The primary key for the table
Payload json.RawMessage // The JSON payload associated with the notification
}
A Notification is emitted at least once for each data update.
func (*Notification) String ¶
func (n *Notification) String() string
type Notifier ¶
type Notifier struct {
// contains filtered or unexported fields
}
Notifier is a factory for CDC notification channels.
func ProvideNotifier ¶
ProvideNotifier is called by wire.
Source Files
Click to show internal directories.
Click to hide internal directories.