Documentation
¶
Index ¶
Constants ¶
View Source
const ( INSERT = "INSERT" UPDATE = "UPDATE" DELETE = "DELETE" )
Variables ¶
View Source
var Event = struct { Entity string Columns []string }{}
Event - Structure for Notification
Functions ¶
This section is empty.
Types ¶
type Notification ¶
type Notification struct {
Entity string `json:"entity"`
Action string `json:"action"`
OldData map[string]interface{} `json:"old_data"`
NewData map[string]interface{} `json:"new_data"`
}
Notification - Structure for Notification
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
Publisher - Structure for Publisher
func NewPublisher ¶
func NewPublisher(ctx context.Context, url string, sl string, op string, tables []string, logger logger.Interface) (publisher *Publisher, err error)
NewPublisher - Creates new publisher
func (*Publisher) CreateReplicationSlotServer ¶
CreateReplicationSlotServer -
Source Files
Click to show internal directories.
Click to hide internal directories.