listener

package

Go to main page

Versions in this module

v1

v1.2.0

Jan 8, 2021

v1.1.0

Jan 8, 2021

Changes in this version

type RepositoryImpl

+ func (r RepositoryImpl) CreatePublication(name string) error

v1.0.1

Apr 29, 2020

Changes in this version

+ type RepositoryImpl struct

+ func (r RepositoryImpl) Close() error

+ func (r RepositoryImpl) GetSlotLSN(slotName string) (string, error)

+ func (r RepositoryImpl) IsAlive() bool

v1.0.0

Jan 28, 2020

Changes in this version

+ const BeginMsgType

+ const CommitMsgType

+ const DeleteMsgType

+ const ErrPublishEvent

+ const InsertMsgType

+ const NewTupleDataType

+ const NullDataType

+ const OriginMsgType

+ const RelationMsgType

+ const TextDataType

+ const ToastDataType

+ const TypeMsgType

+ const UpdateMsgType

+ type ActionData struct

+ Columns []Column

+ Kind ActionKind

+ Schema string

+ Table string

+ type ActionKind string

+ const ActionKindDelete

+ const ActionKindInsert

+ const ActionKindUpdate

+ type Begin struct

+ LSN int64

+ Timestamp time.Time

+ XID int32

+ type BinaryParser struct

+ func NewBinaryParser(byteOrder binary.ByteOrder) *BinaryParser

+ func (p *BinaryParser) ParseWalMessage(msg []byte, tx *WalTransaction) error

+ type Column struct

+ func (c *Column) AssertValue(src []byte)

+ type Commit struct

+ Flags int8

+ LSN int64

+ Timestamp time.Time

+ TransactionLSN int64

+ type DataType struct

+ ID int32

+ Name string

+ Namespace string

+ type Delete struct

+ KeyTuple bool

+ OldTuple bool

+ RelationID int32

+ Row []TupleData

type Event

+ EventTime time.Time

+ ID uuid.UUID

+ Schema string

+ type Insert struct

+ NewTuple bool

+ RelationID int32

+ Row []TupleData

type Listener

+ LSN uint64

+ type Origin struct

+ LSN int64

+ Name string

+ type Relation struct

+ Columns []RelationColumn

+ ID int32

+ Name string

+ Namespace string

+ Replica int8

+ type RelationColumn struct

+ Key bool

+ ModifierType int32

+ Name string

+ TypeID int32

+ type RelationData struct

+ Columns []Column

+ Schema string

+ Table string

+ type TupleData struct

+ Value []byte

+ type Update struct

+ KeyTuple bool

+ NewTuple bool

+ OldRow []TupleData

+ OldTuple bool

+ RelationID int32

+ Row []TupleData

+ type WalTransaction struct

+ Actions []ActionData

+ BeginTime *time.Time

+ CommitTime *time.Time

+ LSN int64

+ RelationStore map[int32]RelationData

+ func NewWalTransaction() *WalTransaction

+ func (w *WalTransaction) Clear()

+ func (w *WalTransaction) CreateEventsWithFilter(tableMap map[string][]string) []Event

+ func (w WalTransaction) CreateActionData(relationID int32, rows []TupleData, kind ActionKind) (a ActionData, err error)

v0

v0.1.0

Jan 8, 2020

Changes in this version

+ const ActionDelete

+ const ErrAckWalMessage

+ const ErrMarshalMsg

+ const ErrNatsConnection

+ const ErrPostgresConnection

+ const ErrReplicationConnection

+ const ErrSendStandbyStatus

+ const ErrUnmarshalMsg

+ const ErrValidateMessage

+ const NotValidMessage

+ const StartServiceMessage

+ const StopServiceMessage

+ func NewRepository(conn *pgx.Conn) *repositoryImpl

+ type ChangeItem struct

+ ColumnNames []string

+ ColumnTypes []string

+ ColumnValues []interface{}

+ Kind string

+ OldKeys struct{ ... }

+ Schema string

+ Table string

+ type Event struct

+ Action string

+ Data map[string]interface{}

+ Scheme string

+ Table string

+ func (e Event) GetSubjectName(prefix string) string

+ func (v *Event) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *Event) UnmarshalJSON(data []byte) error

+ func (v Event) MarshalEasyJSON(w *jwriter.Writer)

+ func (v Event) MarshalJSON() ([]byte, error)

+ type Listener struct

+ func NewWalListener(cfg *config.Config, repo repository, repl replication, publ publisher) *Listener

+ func (w *Listener) AckWalMessage(restartLSNStr string) error

+ func (w *Listener) Process() error

+ func (w *Listener) SendPeriodicHeartbeats(ctx context.Context)

+ func (w *Listener) SendStandbyStatus() error

+ func (w *Listener) Stop() error

+ func (w *Listener) Stream(ctx context.Context)

+ type NatsPublisher struct

+ func NewNatsPublisher(conn stan.Conn) *NatsPublisher

+ func (n NatsPublisher) Close() error

+ func (n NatsPublisher) Publish(subject string, msg []byte) error

+ type WalEvent struct

+ Change []ChangeItem

+ NextLSN string

+ func (v *WalEvent) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v *WalEvent) UnmarshalJSON(data []byte) error

+ func (v WalEvent) MarshalEasyJSON(w *jwriter.Writer)

+ func (v WalEvent) MarshalJSON() ([]byte, error)

+ func (w *WalEvent) CreateEventsWithFilter(tableMap map[string][]string) []Event

+ func (w *WalEvent) Validate() error

Other modules containing this package

github.com/ihippik/wal-listener/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL