publisher

Documentation

Index

• type JetSteamPublisher
  • func New(eventPrefix string, nc *nats.Conn, maxInflight int) *JetSteamPublisher
  • func (jsp *JetSteamPublisher) Run(ourEvents postgres.OutboxEvents, ourDeliveredWALChan chan pglogrepl.LSN) error
  • func (jsp *JetSteamPublisher) WalUpdater(walDelivery chan pglogrepl.LSN) error
• type SendJob
• type SubjectMapper
  • func (sm *SubjectMapper) Map(data map[string]interface{}) string

Types

type JetSteamPublisher

type JetSteamPublisher struct {
	// contains filtered or unexported fields
}

func New

func New(eventPrefix string, nc *nats.Conn, maxInflight int) *JetSteamPublisher

func (*JetSteamPublisher) Run

func (jsp *JetSteamPublisher) Run(ourEvents postgres.OutboxEvents, ourDeliveredWALChan chan pglogrepl.LSN) error

func (*JetSteamPublisher) WalUpdater

func (jsp *JetSteamPublisher) WalUpdater(walDelivery chan pglogrepl.LSN) error

type SendJob

type SendJob struct {
	Ack   jetstream.PubAckFuture
	Wal   pglogrepl.LSN
	MsgID string
}

type SubjectMapper

type SubjectMapper struct {
	Prefix string
}

func (*SubjectMapper) Map

func (sm *SubjectMapper) Map(data map[string]interface{}) string