eventbus

Documentation

Index

• type EventBus
  • func NewEventBus(a app.App, host string, handler EventBusHandler, options Options) *EventBus
  • func (eb *EventBus) Close()
  • func (eb *EventBus) Connect() error
  • func (eb *EventBus) ConnectToSTAN() error
  • func (eb *EventBus) GetConnection() *nats.Conn
  • func (eb *EventBus) GetSTANConnection() stan.Conn
  • func (eb *EventBus) ReconnectHandler(natsConn *nats.Conn)
• type EventBusHandler
• type Options

Types

type EventBus

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

func NewEventBus

func NewEventBus(a app.App, host string, handler EventBusHandler, options Options) *EventBus

func (*EventBus) Close

func (eb *EventBus) Close()

func (*EventBus) Connect

func (eb *EventBus) Connect() error

func (*EventBus) ConnectToSTAN

func (eb *EventBus) ConnectToSTAN() error

func (*EventBus) GetConnection

func (eb *EventBus) GetConnection() *nats.Conn

func (*EventBus) GetSTANConnection

func (eb *EventBus) GetSTANConnection() stan.Conn

func (*EventBus) ReconnectHandler

func (eb *EventBus) ReconnectHandler(natsConn *nats.Conn)

type EventBusHandler

type EventBusHandler struct {
	Reconnect  func(natsConn *nats.Conn)
	Disconnect func(natsConn *nats.Conn)
}

type Options

type Options struct {
	ClusterID           string
	ClientName          string
	PingInterval        time.Duration
	MaxPingsOutstanding int
	MaxReconnects       int
}