nats

package

v0.13.0 Latest Latest Go to latest Published: Apr 2, 2021 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bounoable/cqrs-es

Documentation ¶

Index ¶

func EventBus(eventCfg cqrs.EventConfig, options ...EventBusOption) (cqrs.EventBus, error)
func EventBusWithConnection(nc *nats.Conn, eventCfg cqrs.EventConfig, options ...EventBusOption) cqrs.EventBus
func WithEventBusFactory(options ...EventBusOption) setup.Option
func WithEventBusFactoryWithConnection(nc *nats.Conn, options ...EventBusOption) setup.Option
type Config
type EventBusOption

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func EventBus ¶ added in v0.11.0

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

EventBus ...

func EventBusWithConnection ¶ added in v0.11.0

func EventBusWithConnection(nc *nats.Conn, eventCfg cqrs.EventConfig, options ...EventBusOption) cqrs.EventBus

EventBusWithConnection returns a new NATS event bus.

func WithEventBusFactory ¶

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

WithEventBusFactory ...

func WithEventBusFactoryWithConnection ¶

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

WithEventBusFactoryWithConnection ...

Types ¶

type Config ¶

type Config struct {
	URL            string
	SubjectPrefix  string
	BufferSize     int
	QueueGroup     string
	ConnectOptions []nats.Option
	Logger         *log.Logger
}

Config is the events bus config.

type EventBusOption ¶

type EventBusOption func(*Config)

EventBusOption ...

func BufferSize ¶ added in v0.5.2

func BufferSize(size int) EventBusOption

BufferSize ...

func ConnectOptions ¶

func ConnectOptions(options ...nats.Option) EventBusOption

ConnectOptions ...

func Logger ¶

func Logger(logger *log.Logger) EventBusOption

Logger ...

func QueueGroup ¶

func QueueGroup(group string) EventBusOption

QueueGroup ...

func SubjectPrefix ¶

func SubjectPrefix(prefix string) EventBusOption

SubjectPrefix ...

func URL ¶

func URL(url string) EventBusOption

URL ...

Source Files ¶

View all Source files

eventbus.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL