pg_listener

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

type ListenerConfig struct {
	PgConnStr string
	Interval  time.Duration
	Timeout   time.Duration
}

type NotificationHandler interface {
	HandleNotification(table string, data map[string]interface{}) error
}

type NotificationPayload struct {
	Table string                 `json:"table"`
	Data  map[string]interface{} `json:"data"`
}