Versions in this module Expand all Collapse all v1 v1.0.1 May 28, 2025 v1.0.0 May 28, 2025 Changes in this version + type Encoder interface + Decode func(data []byte) (interface{}, error) + Encode func(v interface{}) ([]byte, error) + type Event struct + Data interface{} + Metadata map[string]string + Subject string + type LocalDispatcher struct + func NewLocalDispatcher(ctx context.Context) *LocalDispatcher + func (ed *LocalDispatcher) Publish(subject string, data interface{}) error + func (ed *LocalDispatcher) Subscribe(name string, subjects ...string) (<-chan Event, func()) + type NatsDispatcher struct + func NewNatsDispatcher(ctx context.Context, nc *nats.Conn, handler Encoder) (*NatsDispatcher, error) + func (d *NatsDispatcher) Close() + func (d *NatsDispatcher) Publish(subject string, data interface{}) error + func (d *NatsDispatcher) Subscribe(name string, subjects ...string) (<-chan Event, func()) + type NatsJetDispatcher struct + func NewNatsJetDispatcher(ctx context.Context, nc *nats.Conn, handler Encoder) (*NatsJetDispatcher, error) + func (d *NatsJetDispatcher) Publish(subject string, data interface{}) error + func (d *NatsJetDispatcher) Subscribe(name string, subjects ...string) (<-chan Event, func()) + type StreamConsumer struct + type SubjectConsumer struct
Go to main page