Versions in this module Expand all Collapse all v1 v1.0.0 Sep 20, 2019 Changes in this version + const MsgBegin + const MsgCommit + const MsgDelete + const MsgInsert + const MsgOrigin + const MsgRelation + const MsgTruncate + const MsgType + const MsgUpdate + const ReplicaIdentityDefault + const ReplicaIdentityFull + const ReplicaIdentityIndex + const ReplicaIdentityNothing + const TupleNull + const TupleText + const TupleUnchanged + type Begin struct + FinalLSN dbtypes.LSN + Timestamp time.Time + XID int32 + func (m Begin) String() string + type Column struct + IsKey bool + Mode int32 + Name string + TypeOID dbtypes.OID + type Commit struct + Flags uint8 + LSN dbtypes.LSN + Timestamp time.Time + TransactionLSN dbtypes.LSN + func (m Commit) String() string + type Delete struct + IsKey bool + IsOld bool + OldRow Row + RelationOID dbtypes.OID + func (m Delete) String() string + type Insert struct + IsNew bool + NewRow Row + RelationOID dbtypes.OID + func (m Insert) String() string + type MType int + func (t MType) String() string + type Message interface + type NamespacedName struct + Name string + Namespace string + func (n NamespacedName) Sanitize() string + func (n NamespacedName) String() string + type Origin struct + LSN dbtypes.LSN + Name string + func (m Origin) String() string + type Relation struct + Columns []Column + OID dbtypes.OID + ReplicaIdentity ReplicaIdentity + func (r *Relation) Equal(rel2 *Relation) bool + func (r Relation) String() string + type ReplicaIdentity uint8 + func (r *ReplicaIdentity) DecodeText(ci *pgtype.ConnInfo, src []byte) error + func (r *ReplicaIdentity) UnmarshalYAML(unmarshal func(interface{}) error) error + func (r ReplicaIdentity) MarshalYAML() (interface{}, error) + func (r ReplicaIdentity) String() string + type Row []*Tuple + func (r Row) Bytes() []byte + type Truncate struct + Cascade bool + RelationOIDs []dbtypes.OID + RestartIdentity bool + func (m Truncate) String() string + type Tuple struct + Kind TupleKind + Value []byte + func (t Tuple) Bytes() []byte + func (t Tuple) String() string + type TupleKind uint8 + func (t TupleKind) String() string + type Type struct + OID dbtypes.OID + func (m Type) String() string + type Update struct + IsKey bool + IsNew bool + IsOld bool + NewRow Row + OldRow Row + RelationOID dbtypes.OID + func (m Update) String() string
Go to main page