push

Documentation

Index

• func HandleSock(ctx context.Context, sock zmtp.Socket, queue <-chan zmtp.Message) (err error)
• func PullFromWritePoint(wc *socketutil.WaitCloser[struct{}], push chan<- zmtp.Message, ...)
• type Push
  • func (p *Push) Bind(tp transport.Transport, url *url.URL) error
  • func (p *Push) Close() error
  • func (p *Push) Connect(tp transport.Transport, url *url.URL) error
  • func (p *Push) Disconnect(url *url.URL) error
  • func (p *Push) Meta() zmtp.Metadata
  • func (p *Push) MetaHandler(meta zmtp.Metadata) error
  • func (p *Push) Name() string
  • func (p *Push) Recv() ([]zmtp.Message, error)
  • func (p *Push) Send(data []zmtp.Message) error
  • func (p *Push) Unbind(url *url.URL) error

Functions

func HandleSock

func HandleSock(ctx context.Context, sock zmtp.Socket, queue <-chan zmtp.Message) (err error)

func PullFromWritePoint

func PullFromWritePoint(wc *socketutil.WaitCloser[struct{}], push chan<- zmtp.Message, writePoint chan []zmtp.Message)

Types

type Push

type Push struct {
	context.Context
	Cancel context.CancelFunc
	*gomq.Config
	Mech              zmtp.Mechanism
	ConnectionDrivers map[string]*socketutil.ConnectionDriver
	BindDrivers       map[string]*socketutil.BindDriver
	ConnectionHandles map[string]socketutil.WaitCloser[struct{}]
	EventBus          gomq.EventBus
	WritePoint        chan []zmtp.Message
}

Push implements the zmq push socket.

func (*Push) Bind

func (p *Push) Bind(tp transport.Transport, url *url.URL) error

func (*Push) Close

func (p *Push) Close() error

func (*Push) Connect

func (p *Push) Connect(tp transport.Transport, url *url.URL) error

func (*Push) Disconnect

func (p *Push) Disconnect(url *url.URL) error

func (*Push) Meta

func (p *Push) Meta() zmtp.Metadata

func (*Push) MetaHandler

func (p *Push) MetaHandler(meta zmtp.Metadata) error

func (*Push) Name

func (p *Push) Name() string

func (*Push) Recv

func (p *Push) Recv() ([]zmtp.Message, error)

func (*Push) Send

func (p *Push) Send(data []zmtp.Message) error

func (*Push) Unbind

func (p *Push) Unbind(url *url.URL) error