pubsub

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 1, 2015 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Broker

type Broker struct {
	PubEndpoint string
	PubSocket   *zmq.Socket
	SubEndpoint string
	SubSocket   *zmq.Socket
}

func New

func New(pubEndpoint string, subEndpoint string) (b Broker)

func (*Broker) Close

func (b *Broker) Close()

func (*Broker) CloseSocket

func (b *Broker) CloseSocket(socket *zmq.Socket)

func (*Broker) Poll

func (b *Broker) Poll()

type Topic

type Topic map[string]string

Jump to

Keyboard shortcuts

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