stan

Mar 24, 2020

Changes in this version

+ func EventBus(eventCfg cqrs.EventConfig, options ...EventBusOption) (cqrs.EventBus, error)

+ func EventBusWithConnection(sc stan.Conn, eventCfg cqrs.EventConfig, options ...EventBusOption) cqrs.EventBus

+ func EventBusWithNATSConnection(nc *nats.Conn, eventCfg cqrs.EventConfig, options ...EventBusOption) (cqrs.EventBus, error)

Jan 3, 2020

Changes in this version

+ func NewEventBus(eventCfg cqrs.EventConfig, options ...EventBusOption) (cqrs.EventBus, error)

+ func NewEventBusWithConnection(sc stan.Conn, eventCfg cqrs.EventConfig, options ...EventBusOption) cqrs.EventBus

+ func NewEventBusWithNATSConnection(nc *nats.Conn, eventCfg cqrs.EventConfig, options ...EventBusOption) (cqrs.EventBus, error)

+ func WithEventBusFactory(options ...EventBusOption) setup.Option

+ func WithEventBusFactoryWithConnection(sc stan.Conn, options ...EventBusOption) setup.Option

+ func WithEventBusFactoryWithNATSConnection(nc *nats.Conn, options ...EventBusOption) setup.Option

+ type Config struct

+ BufferSize int

+ ClientID string

+ ClusterID string

+ ConnectOptions []stan.Option

+ DurableName string

+ Logger *log.Logger

+ QueueGroup string

+ SubjectPrefix string

+ SubscriptionOptions []stan.SubscriptionOption

+ URL string

+ type EventBusOption func(*Config)

+ func BufferSize(size int) EventBusOption

+ func ClientID(id string) EventBusOption

+ func ClusterID(id string) EventBusOption

+ func ConnectOptions(options ...stan.Option) EventBusOption

+ func DurableName(name string) EventBusOption

+ func Logger(logger *log.Logger) EventBusOption

+ func QueueGroup(group string) EventBusOption

+ func SubjectPrefix(prefix string) EventBusOption

+ func SubscriptionOptions(options ...stan.SubscriptionOption) EventBusOption

+ func URL(url string) EventBusOption