pubsub

Documentation

Index

• Variables
• func NewPubSub(exchange string, queue string)
• func Publish(data Message)
• func Subscribe() <-chan Message
• type Message
• type PubSub

Variables

var PubSubEvents = pubsubEvents{
	BlockMined:         "BLOCK.MINED",
	TransactionCreated: "TRANSACTION.CREATED",
	ChainPublished:     "CHAIN.PUBLISHED",
	ChainRequested:     "CHAIN.REQUESTED",
}

PubSubEvents Constants

Functions

func NewPubSub

func NewPubSub(exchange string, queue string)

NewPubSub Function

func Publish

func Publish(data Message)

Publish Method

func Subscribe

func Subscribe() <-chan Message

Subscribe Method

Types

type Message

type Message struct {
	Event string
	Data  interface{}
}

Message Structure

type PubSub

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

PubSub Struct