Documentation ¶
Overview ¶
Package zenio implements ØMQ (ZMTP) and nanomsg (SP) in Go without any dependencies on zeromq or nanomsg.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultSP = &sp.Negotiator{} DefaultZMTP = &zmtp.Negotiator{} )
Functions ¶
Types ¶
type BufferMessage ¶
BufferMessage adds buffering to a message. It makes it possible to read the whole message into memory and rewind it again.
func NewBufferMessage ¶
func NewBufferMessage(m protocol.Message) *BufferMessage
func (*BufferMessage) More ¶
func (b *BufferMessage) More() bool
func (*BufferMessage) Reset ¶
func (b *BufferMessage) Reset()
type BytesMessage ¶
type BytesMessage struct {
// contains filtered or unexported fields
}
func NewBytesMessage ¶
func NewBytesMessage(frames [][]byte) *BytesMessage
func (*BytesMessage) More ¶
func (b *BytesMessage) More() bool
func (*BytesMessage) Reset ¶
func (b *BytesMessage) Reset()
type Protocol ¶
type Protocol interface { // Send encodes the protocol data from Envelope and Message and writes it to // the underlying writer. Send(Envelope, protocol.Message) error // Recv reads protocol data from the underlying reader and decodes it into // Envelope and Message. Recv(Envelope, protocol.Message) error }
Directories ¶
Path | Synopsis |
---|---|
Package perf contains utility functions for the performance programs of zenio.
|
Package perf contains utility functions for the performance programs of zenio. |
Protocol contains the abstraction required for protocols in Zenio.
|
Protocol contains the abstraction required for protocols in Zenio. |
sp
Package sp implements the wire format used for Scalable Protocols.
|
Package sp implements the wire format used for Scalable Protocols. |
zmtp
Package zmtp implements the wire format used in ZMTP, the ZeroMQ Message Transport Protocol.
|
Package zmtp implements the wire format used in ZMTP, the ZeroMQ Message Transport Protocol. |
Click to show internal directories.
Click to hide internal directories.