zeromq

Documentation

Index

• Constants
• func NewProxy(frontendAddress, backendAddress string) *service.Service
• func StartProxy(frontendAddress, backendAddress string) error
• func StartSubscriber(address, topics string, onMessage message.Handler) error
• func WaitForConnection()
• type Publisher
  • func NewPublisher(address string) *Publisher
  • func (p *Publisher) SendMessage(topic string, content ...any)
• type Subscriber
  • func NewSubscriber(address, topics string) *Subscriber

Constants

const ConnectionGraceTimeout = time.Millisecond * 20

const TopicsAll = ""

Functions

func NewProxy

func NewProxy(frontendAddress, backendAddress string) *service.Service

func StartProxy

func StartProxy(frontendAddress, backendAddress string) error

func StartSubscriber

func StartSubscriber(address, topics string, onMessage message.Handler) error

func WaitForConnection

func WaitForConnection()

Types

type Publisher

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

func NewPublisher

func NewPublisher(address string) *Publisher

func (*Publisher) SendMessage

func (p *Publisher) SendMessage(topic string, content ...any)

type Subscriber

type Subscriber struct {
	*service.Service
	OnMessage message.Handler
}

func NewSubscriber

func NewSubscriber(address, topics string) *Subscriber