zeromq

package
v0.0.0-...-d79959a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 24, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const ConnectionGraceTimeout = time.Millisecond * 20
View Source
const TopicsAll = ""

Variables

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL