Versions in this module Expand all Collapse all v0 v0.2.0 Sep 3, 2024 v0.1.0 Jul 11, 2024 Changes in this version + type Column struct + ID string + Name string + Type string + Value any + type CommitPosition string + type Data struct + Action string + Columns []Column + Identity []Column + LSN string + Metadata Metadata + Schema string + Table string + Timestamp string + func (d *Data) GetTimestamp() (time.Time, error) + func (d *Data) IsInsert() bool + func (d *Data) IsUpdate() bool + type Event struct + CommitPosition CommitPosition + Data *Data + type Metadata struct + InternalColIDs []string + InternalColVersion string + SchemaID xid.ID + TablePgstreamID string + func (m Metadata) IsEmpty() bool + func (m Metadata) IsIDColumn(colID string) bool + func (m Metadata) IsVersionColumn(colID string) bool
Go to main page