Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DecoderValue ¶
type DecoderValue interface { pgtype.TextDecoder pgtype.Value }
type Relation ¶
type RelationSet ¶
type RelationSet struct {
// contains filtered or unexported fields
}
func NewRelationSet ¶
func NewRelationSet(ci *pgtype.ConnInfo) *RelationSet
NewRelationSet creates a new relation set. Optionally ConnInfo can be provided, however currently we need some changes to pgx to get it out from ReplicationConn.
func (*RelationSet) Add ¶
func (rs *RelationSet) Add(r Relation)
type Subscription ¶
type Subscription struct { Name string Publication string WaitTimeout time.Duration StatusTimeout time.Duration // Mutex is used to prevent reading and writing to a connection at the same time sync.Mutex // contains filtered or unexported fields }
func NewSubscription ¶
func NewSubscription(conn *pgx.ReplicationConn, name, publication string, walRetain uint64, failOnHandler bool) *Subscription
func (*Subscription) CreateSlot ¶
func (s *Subscription) CreateSlot() (err error)
CreateSlot creates a replication slot if it doesn't exist
func (*Subscription) Flush ¶
func (s *Subscription) Flush() error
Flush sends the status message to server indicating that we've fully applied all of the events until maxWal. This allows PostgreSQL to purge it's WAL logs
Click to show internal directories.
Click to hide internal directories.