messagebus

Documentation

Index

• Constants
• type Config
  • func NewConfig(url string) *Config
• type MessageBus
  • func NewMessageBus(config *Config) (*MessageBus, error)
  • func (m *MessageBus) Close()
• type Msg

Constants

const DefaultUrl = nats.DefaultURL

Types

type Config

type Config struct {
	Url string
}

Config represents the configuration.

func NewConfig

func NewConfig(url string) *Config

NewConfig returns an instance of Config with defaults.

type MessageBus

type MessageBus struct {
	Config     *Config
	Connection *nats.Conn
}

func NewMessageBus

func NewMessageBus(config *Config) (*MessageBus, error)

Create new message bus wrapper, for this repo NATS is hardcoded. This module should serve as message routing across multiple protocols (RMQ, 0MQ, Tibrv etc)

func (*MessageBus) Close

func (m *MessageBus) Close()

Close underlying messaging bus driver

type Msg

type Msg nats.Msg