pubsub

type GetPostgresListenerFunc func() (*pq.Listener, error)

type Message struct {
	UUID    uuid.UUID
	Time    time.Time
	Payload []byte
}

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

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

type PubSub interface {
	Publish(channel string, message Message) error
	Subscribe(channel string) (Stream, error)
}

type Stream interface {
	Channel() <-chan Message
	Close() error
}