messagebus

Documentation

Overview

a queue system to transfer transactions

Index

• Variables
• type BroadcastQueue
  • func (queue *BroadcastQueue) Chan(size int) <-chan Message
  • func (queue *BroadcastQueue) Send(command string, parameters ...[]byte)
• type Message
• type Queue
  • func (queue *Queue) Chan() <-chan Message
  • func (queue *Queue) Release()
  • func (queue *Queue) Send(command string, parameters ...[]byte)

Variables

var Bus busses

the instance

Types

type BroadcastQueue

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

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

func (*BroadcastQueue) Chan

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

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

func (*BroadcastQueue) Send

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

send a message to a 1:M queue

type Message

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

message to put into a queue

type Queue

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

a 1:1 queue

func (*Queue) Chan

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

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

func (*Queue) Release

func (queue *Queue) Release()

give the channel back

func (*Queue) Send

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

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