pubsub

Documentation

Index

• Constants
• func Create(broker *nucleo.BrokerDelegates) transit.Transit
• type ActionError
• type PubSub
  • func (pubsub *PubSub) Connect() chan error
  • func (pubsub *PubSub) Disconnect() chan error
  • func (pubsub *PubSub) DiscoverNode(nodeID string)
  • func (pubsub *PubSub) DiscoverNodes() chan bool
  • func (pubsub *PubSub) Emit(context nucleo.BrokerContext)
  • func (pubsub *PubSub) Ready()
  • func (pubsub *PubSub) Request(context nucleo.BrokerContext) chan nucleo.Payload
  • func (pubsub *PubSub) SendHeartbeat()
  • func (pubsub *PubSub) SendPing()

Constants

const DATATYPE_BUFFER = 3

const DATATYPE_JSON = 2

const DATATYPE_NULL = 1

const DATATYPE_UNDEFINED = 0

Functions

func Create

func Create(broker *nucleo.BrokerDelegates) transit.Transit

Types

type ActionError

type ActionError interface {
	Error() string
	Stack() string
}

type PubSub

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

PubSub is a transit implementation.

func (*PubSub) Connect

func (pubsub *PubSub) Connect() chan error

Connect : connect the transit with the transporter, subscribe to all events and start publishing its node info

func (*PubSub) Disconnect

func (pubsub *PubSub) Disconnect() chan error

Disconnect : disconnect the transit's transporter.

func (*PubSub) DiscoverNode

func (pubsub *PubSub) DiscoverNode(nodeID string)

func (*PubSub) DiscoverNodes

func (pubsub *PubSub) DiscoverNodes() chan bool

DiscoverNodes will check if there are neighbours and return true if any are found ;).

func (*PubSub) Emit

func (pubsub *PubSub) Emit(context nucleo.BrokerContext)

Emit emit an event to all services that listens to this event.

func (*PubSub) Ready

func (pubsub *PubSub) Ready()

func (*PubSub) Request

func (pubsub *PubSub) Request(context nucleo.BrokerContext) chan nucleo.Payload

func (*PubSub) SendHeartbeat

func (pubsub *PubSub) SendHeartbeat()

func (*PubSub) SendPing

func (pubsub *PubSub) SendPing()