types

Documentation

Index

• type ChangeRecord
• type RelayMessage
• type RelayMessageOptions

Types

type ChangeRecord

type ChangeRecord struct {
	LSN       string                 `json:"lsn"`
	XID       int32                  `json:"xid"`
	Timestamp int64                  `json:"timestamp"`
	Table     string                 `json:"table"`
	Operation string                 `json:"operation"`
	Fields    map[string]interface{} `json:"fields"`
	OldFields map[string]interface{} `json:"old_fields,omitempty"`
}

ChangeRecord represents a single change to a table

type RelayMessage

type RelayMessage struct {
	Value   *ChangeRecord
	Options *RelayMessageOptions
}

RelayMessage encapsulates a ChangeRecord message that is read by relay.Run()

type RelayMessageOptions

type RelayMessageOptions struct {
}

RelayMessageOptions contains any additional options necessary for processing of ChangeRecord messages by the relayer