gotrade: github.com/cyanly/gotrade/core/messagebus Index | Files | Directories

package messagebus

import "github.com/cyanly/gotrade/core/messagebus"

Index

Package Files

config.go messagebus.go

Constants

const DefaultUrl = nats.DefaultURL

type Config Uses

type Config struct {
    Url string
}

Config represents the configuration.

func NewConfig Uses

func NewConfig(url string) *Config

NewConfig returns an instance of Config with defaults.

type MessageBus Uses

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

func NewMessageBus Uses

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 Uses

func (m *MessageBus) Close()

Close underlying messaging bus driver

type Msg Uses

type Msg nats.Msg

Directories

PathSynopsis
test

Package messagebus imports 1 packages (graph) and is imported by 3 packages. Updated 2016-07-20. Refresh now. Tools for package owners.