messagebus

package

v0.15.6 Latest Latest Go to latest Published: Jan 23, 2024 License: ISC Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package messagebus - a queuing system for all message packets whether internally generated or received from peers

View Source

const Default = -1

for select the default queue size

View Source

var Bus busses

Bus - all available message queues

This section is empty.

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

BroadcastQueue - a 1:M queue out is synchronous, so messages to routines not waiting are dropped

func (queue *BroadcastQueue) Chan(size int) <-chan Message

Chan - get a new channel to read from a 1:M queue each call gets a distinct channel

func (queue *BroadcastQueue) Release()

Release - release the incoming and outgoing queue

func (queue *BroadcastQueue) Send(command string, parameters ...[]byte)

Send - send a message to a 1:M queue

type Message struct {
	Command    string   // type of packed data
	Parameters [][]byte // array of parameters
}

Message - message to put into a queue

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

Queue - a 1:1 queue

func (queue *Queue) Chan() <-chan Message

Chan - channel to read from 1:1 queue can only be called once

func (queue *Queue) Release()

Release - give the channel back

func (queue *Queue) Send(command string, parameters ...[]byte)

Send - send a message to a 1:1 queue but only if listener is connected