zmq

Documentation

Index

• Variables
• func GetAddressTopics() []string
• type AddressTopics
• type Publisher
  • func NewPublisher() (*Publisher, error)
  • func (pub *Publisher) Send(topic string, messages []string) error
  • func (pub *Publisher) Shutdown() error
  • func (pub *Publisher) Start() error
• type SpecialTopics
  • func GetSpecialTopics() *SpecialTopics
  • func (st *SpecialTopics) AddressTopics()

Variables

var (
	PLUGIN = node.NewPlugin("ZMQ", node.Disabled, configure, run)
)

var (
	// RegisteredZMQTopics lists the available topics
	RegisteredZMQTopics = []string{
		topicLMI,
		topicLMSI,
		topicLMHS,
		topicLM,
		topicLSM,
		topicSN,
		topicTxTrytes,
		topicTX,
		topicSpentAddress,
	}
)

Functions

func GetAddressTopics

func GetAddressTopics() []string

GetAddressTopics returns subscribed addresses

Types

type AddressTopics

type AddressTopics struct {
	Addressses []string
	// contains filtered or unexported fields
}

AddressTopics stuct

type Publisher

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

Publisher is a simple zmq publisher abstraction

func NewPublisher

func NewPublisher() (*Publisher, error)

NewPublisher creates a new publisher.

func (*Publisher) Send

func (pub *Publisher) Send(topic string, messages []string) error

Send sends a new list of messages.

func (*Publisher) Shutdown

func (pub *Publisher) Shutdown() error

Shutdown stops the publisher.

func (*Publisher) Start

func (pub *Publisher) Start() error

Start the publisher on the given port.

type SpecialTopics

type SpecialTopics struct {
	Topics []string
}

SpecialTopics struct

func GetSpecialTopics

func GetSpecialTopics() *SpecialTopics

GetSpecialTopics is a sortet list of special topics (e.g. Addresses)

func (*SpecialTopics) AddressTopics

func (st *SpecialTopics) AddressTopics()

AddressTopics filters SpecialTopics for address topics