messagebus

Documentation

Overview

a queue system to transfer transactions

Index

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

Variables

var Bus busses

the instance

Types

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
}

structure of an individual queue

func (*Queue) Chan

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

channel to read from

func (*Queue) Send

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

send a message to a queue