pubsub

Nov 14, 2024

Changes in this version

+ func Marshal(v any) []byte

+ type Broker interface

+ CreateStream func(streamName, subject string, dedupWindow time.Duration) error

+ Publish func(subject string, message []byte, msgID ...string) error

+ Subscribe func(subject string, group string, handler func([]byte) ([]byte, error)) error

+ type NATSBroker struct

+ func MustNewNATSBroker(url string, redisAddr string) *NATSBroker

+ func NewNATSBroker(url string, redisAddr string) (*NATSBroker, error)

+ func (n *NATSBroker) CreateStream(streamName, subject string, dedupWindow time.Duration) error

+ func (n *NATSBroker) Publish(subject string, message []byte, msgID ...string) error

+ func (n *NATSBroker) Subscribe(subject, group string, handler func([]byte) ([]byte, error)) error