nanomsg

Documentation

Index

• func NewPub(url string) mangos.Socket
• func NewSub(url string, topic []byte) (mangos.Socket, error)
• type Proxy
  • func NewProxy(url string) *Proxy
  • func (p *Proxy) Close()
  • func (p *Proxy) SubscribeTo(url string, wg *sync.WaitGroup)

Functions

func NewPub

func NewPub(url string) mangos.Socket

NewPub creates a new publisher socket

func NewSub

func NewSub(url string, topic []byte) (mangos.Socket, error)

NewSub creates a new subscriber socket

Types

type Proxy

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

Proxy is a proxy which can subscribe to multiple sockets and publish to a single socket

func NewProxy

func NewProxy(url string) *Proxy

NewProxy creates a new instance

func (*Proxy) Close

func (p *Proxy) Close()

Close stops and removes all subscribers

func (*Proxy) SubscribeTo

func (p *Proxy) SubscribeTo(url string, wg *sync.WaitGroup)

SubscribeTo a publisher