pgtypes

Documentation

Index

• Constants
• type BeginMessage
  • func (m BeginMessage) String() string
• type CommitMessage
  • func (m CommitMessage) String() string
• type DeleteMessage
  • func (m DeleteMessage) String() string
• type InsertMessage
  • func (m InsertMessage) String() string
• type LSN
  • func (lsn LSN) String() string
• type LogicalReplicationMessage
  • func (m *LogicalReplicationMessage) Decode(src []byte) (err error)
  • func (m *LogicalReplicationMessage) IsTransactional() bool
  • func (m *LogicalReplicationMessage) SetType(t pglogrepl.MessageType)
  • func (m *LogicalReplicationMessage) String() string
  • func (m *LogicalReplicationMessage) Type() pglogrepl.MessageType
• type OriginMessage
  • func (m OriginMessage) String() string
• type RelationMessage
  • func (m RelationMessage) String() string
• type ReplicaIdentity
  • func AsReplicaIdentity(val string) ReplicaIdentity
  • func (ri ReplicaIdentity) Description() string
  • func (ri *ReplicaIdentity) Scan(src interface{}) error
• type TruncateMessage
  • func (m TruncateMessage) String() string
• type TypeMessage
  • func (m TypeMessage) String() string
• type UpdateMessage
  • func (m UpdateMessage) String() string
• type XLogData

Constants

const (
	MessageTypeLogicalDecodingMessage pglogrepl.MessageType = 'M'
)

Types

type BeginMessage

type BeginMessage pglogrepl.BeginMessage

func (BeginMessage) String

func (m BeginMessage) String() string

type CommitMessage

type CommitMessage pglogrepl.CommitMessage

func (CommitMessage) String

func (m CommitMessage) String() string

type DeleteMessage

type DeleteMessage struct {
	*pglogrepl.DeleteMessage
	OldValues map[string]any
}

func (DeleteMessage) String

func (m DeleteMessage) String() string

type InsertMessage

type InsertMessage struct {
	*pglogrepl.InsertMessage
	NewValues map[string]any
}

func (InsertMessage) String

func (m InsertMessage) String() string

type LSN

type LSN pglogrepl.LSN

func (LSN) String

func (lsn LSN) String() string

type LogicalReplicationMessage

type LogicalReplicationMessage struct {

	// Flags is either 0 (non-transactional) or 1 (transactional)
	Flags uint8
	// Xid is the transaction id (if transactional logical replication message)
	Xid *uint32
	// LSN is the LSN of the logical replication message
	LSN pglogrepl.LSN
	// Prefix is the prefix of the logical replication message
	Prefix string
	// Content is the content of the logical replication message
	Content []byte
	// contains filtered or unexported fields
}

LogicalReplicationMessage is a logical replication message.

func (*LogicalReplicationMessage) Decode

func (m *LogicalReplicationMessage) Decode(src []byte) (err error)

func (*LogicalReplicationMessage) IsTransactional

func (m *LogicalReplicationMessage) IsTransactional() bool

func (*LogicalReplicationMessage) SetType

func (m *LogicalReplicationMessage) SetType(t pglogrepl.MessageType)

func (*LogicalReplicationMessage) String

func (m *LogicalReplicationMessage) String() string

func (*LogicalReplicationMessage) Type

func (m *LogicalReplicationMessage) Type() pglogrepl.MessageType

Type returns message type.

type OriginMessage

type OriginMessage pglogrepl.OriginMessage

func (OriginMessage) String

func (m OriginMessage) String() string

type RelationMessage

type RelationMessage pglogrepl.RelationMessage

func (RelationMessage) String

func (m RelationMessage) String() string

type ReplicaIdentity

type ReplicaIdentity string

const (
	NOTHING ReplicaIdentity = "n"
	FULL    ReplicaIdentity = "f"
	DEFAULT ReplicaIdentity = "d"
	INDEX   ReplicaIdentity = "i"
	UNKNOWN ReplicaIdentity = ""
)

func AsReplicaIdentity

func AsReplicaIdentity(val string) ReplicaIdentity

func (ReplicaIdentity) Description

func (ri ReplicaIdentity) Description() string

Description returns a description of this REPLICA IDENTITY Values are in sync with debezium project: https://github.com/debezium/debezium/blob/main/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/connection/ServerInfo.java

func (*ReplicaIdentity) Scan

func (ri *ReplicaIdentity) Scan(src interface{}) error

type TruncateMessage

type TruncateMessage pglogrepl.TruncateMessage

func (TruncateMessage) String

func (m TruncateMessage) String() string

type TypeMessage

type TypeMessage pglogrepl.TypeMessage

func (TypeMessage) String

func (m TypeMessage) String() string

type UpdateMessage

type UpdateMessage struct {
	*pglogrepl.UpdateMessage
	OldValues map[string]any
	NewValues map[string]any
}

func (UpdateMessage) String

func (m UpdateMessage) String() string

type XLogData

type XLogData struct {
	pglogrepl.XLogData

	LastBegin  LSN
	LastCommit LSN
	Xid        uint32
}