model

Documentation

Index

• func GetChange(dd map[string]interface{}, op string) (vnewkeys map[string]interface{})
• func IsChange(dd map[string]interface{}, op string, k string) (interface{}, bool)
• func KeyExist(dd map[string]interface{}, k string) (interface{}, bool)
• func PutWalData(data *WalData)
• type Operation
  • func (o Operation) String() string
• type WalData
  • func NewWalData() *WalData
  • func Parse(msg *pgx.WalMessage) (*WalData, error)
  • func (d *WalData) Reset()

Functions

func GetChange

func GetChange(dd map[string]interface{}, op string) (vnewkeys map[string]interface{})

func IsChange

func IsChange(dd map[string]interface{}, op string, k string) (interface{}, bool)

change return true; not return false

func KeyExist

func KeyExist(dd map[string]interface{}, k string) (interface{}, bool)

func PutWalData

func PutWalData(data *WalData)

PutWalData putback data to pool

Types

type Operation

type Operation uint8

Operation type

const (
	// Insert operation
	Insert Operation = iota
	// Delete operation
	Delete
	// Update operation
	Update
	// Begin transaction
	Begin
	// Commit transaction
	Commit
	// Unknow operation
	Unknow
)

func (Operation) String

func (o Operation) String() string

type WalData

type WalData struct {
	OperationType Operation
	Schema        string
	Table         string
	Data          map[string]interface{}
	Timestamp     int64
	Pos           uint64
	Rule          *conf.Rule
}

WalData represent parsed wal log data

func NewWalData

func NewWalData() *WalData

NewWalData get data from pool

func Parse

func Parse(msg *pgx.WalMessage) (*WalData, error)

Parse test_decoding format wal to WalData

func (*WalData) Reset

func (d *WalData) Reset()

Reset for reuse