xbus

Documentation

Overview

Package xbus implements the BUS protocol. This sends messages out to all peers, and receives their responses. It specifically filters messages sent to itself, so that a single BUS can be used to loop back to peers.

Index

• Constants
• func NewProtocol() protocol.Protocol
• func NewSocket() (protocol.Socket, error)

Constants

const (
	Self     = protocol.ProtoBus
	Peer     = protocol.ProtoBus
	SelfName = "bus"
	PeerName = "bus"
)

Protocol identity information.

Functions

func NewProtocol

func NewProtocol() protocol.Protocol

NewProtocol returns a new protocol implementation.

func NewSocket

func NewSocket() (protocol.Socket, error)

NewSocket allocates a raw Socket using the BUS protocol.