pqm

package

v0.0.0-...-d84d9e5 Latest Latest Go to latest Published: Mar 12, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Action string

const (
	Update Action = "UPDATE"
	Delete Action = "DELETE"
	Insert Action = "INSERT"
)

func (a Action) String() string

type Callback[T Channelizer] func(*Message[T])

type Channelizer interface {
	GetTableName() string
	GetListenerKey() string
}

type Message[T any] struct {
	Table  string `json:"table"`
	Action Action `json:"action"`
	Data   T      `json:"data"`
	Old    T      `json:"old"`
}

func ParseMessage[T any](b []byte) (message *Message[T], err error)

type Monitor[T Channelizer] struct {
	// contains filtered or unexported fields
}

func NewMonitor[T Channelizer](dsn string, t T, receiver Callback[T]) *Monitor[T]

func (m *Monitor[T]) GetListenerCount() (n int)

func (m *Monitor[T]) GetListeners(data T) (chs []chan T)

func (m *Monitor[T]) Listen()

func (m *Monitor[T]) RemoveListener(ch chan T)

func (m *Monitor[T]) SetListener(data T, ch chan T)