bus

Documentation

Index

• type Bus
  • func NewBus(name, unit, backend, frontend, capture string) *Bus
  • func (b *Bus) Run(done chan bool)

Types

type Bus

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

Bus defines the structure of a device for PUB/SUB messaging

func NewBus

func NewBus(name, unit, backend, frontend, capture string) *Bus

NewBus instantiates a new PUB/SUB bus type.

func (*Bus) Run

func (b *Bus) Run(done chan bool)

Run the bus routine that handles PUB/SUB messages.