Versions in this module Expand all Collapse all v1 v1.1.0 Feb 9, 2015 Changes in this version + const OptionKeepAlive + const OptionLinger + const OptionLocalAddress + const OptionNoDelay + const OptionRaw + const OptionReadQLen + const OptionRecvDeadline + const OptionRetryTime + const OptionSendDeadline + const OptionSubscribe + const OptionSurveyTime + const OptionTLSConfig + const OptionUnsubscribe + const OptionWriteQLen + const PortActionAdd + const PortActionRemove + const ProtoBus + const ProtoPair + const ProtoPub + const ProtoPull + const ProtoPush + const ProtoRep + const ProtoReq + const ProtoRespondent + const ProtoStar + const ProtoSub + const ProtoSurveyor + var ErrAddrInUse = errors.New("address in use") + var ErrBadAddr = errors.New("invalid address") + var ErrBadHeader = errors.New("invalid header received") + var ErrBadOption = errors.New("invalid or unsupported option") + var ErrBadProperty = errors.New("invalid property name") + var ErrBadProto = errors.New("invalid or unsupported protocol") + var ErrBadTran = errors.New("invalid or unsupported transport") + var ErrBadValue = errors.New("invalid option value") + var ErrBadVersion = errors.New("invalid protocol version") + var ErrClosed = errors.New("connection closed") + var ErrConnRefused = errors.New("connection refused") + var ErrGarbled = errors.New("message garbled") + var ErrPipeEmpty = errors.New("pipe empty") + var ErrPipeFull = errors.New("pipe full") + var ErrRecvTimeout = errors.New("receive time out") + var ErrSendTimeout = errors.New("send time out") + var ErrTooLong = errors.New("message is too long") + var ErrTooShort = errors.New("message is too short") + func Device(s1 Socket, s2 Socket) error + func MakeSocket(proto Protocol) *socket + func ProtocolName(number uint16) string + func StripScheme(t Transport, addr string) (string, error) + func ValidPeers(p1, p2 Protocol) bool + type CondTimed struct + func (cv *CondTimed) WaitAbsTimeout(when time.Time) bool + func (cv *CondTimed) WaitRelTimeout(when time.Duration) bool + type Dialer interface + Address func() string + Close func() error + Dial func() error + GetOption func(name string) (interface{}, error) + SetOption func(name string, value interface{}) error + type Endpoint interface + Close func() error + GetID func() uint32 + RecvMsg func() *Message + SendMsg func(*Message) error + type Listener interface + Address func() string + Close func() error + GetOption func(name string) (interface{}, error) + Listen func() error + SetOption func(name string, value interface{}) error + type Message struct + Body []byte + Header []byte + func NewMessage(sz int) *Message + func (m *Message) Dup() *Message + func (m *Message) Free() + type Pipe interface + Close func() error + GetProp func(string) (interface{}, error) + IsOpen func() bool + LocalProtocol func() uint16 + Recv func() (*Message, error) + RemoteProtocol func() uint16 + Send func(*Message) error + func NewConnPipe(c net.Conn, proto Protocol) (Pipe, error) + func NewConnPipeIPC(c net.Conn, proto Protocol) (Pipe, error) + type PipeDialer interface + Dial func() (Pipe, error) + GetOption func(name string) (value interface{}, err error) + SetOption func(name string, value interface{}) error + type PipeListener interface + Accept func() (Pipe, error) + Close func() error + GetOption func(name string) (value interface{}, err error) + Listen func() error + SetOption func(name string, value interface{}) error + type Port interface + Address func() string + Close func() error + Dialer func() Dialer + GetProp func(name string) (interface{}, error) + IsClient func() bool + IsOpen func() bool + IsServer func() bool + Listener func() Listener + LocalProtocol func() uint16 + RemoteProtocol func() uint16 + type PortAction int + type PortHook func(PortAction, Port) bool + type Protocol interface + AddEndpoint func(Endpoint) + GetOption func(string) (interface{}, error) + Init func(ProtocolSocket) + Name func() string + Number func() uint16 + PeerName func() string + PeerNumber func() uint16 + RemoveEndpoint func(Endpoint) + SetOption func(string, interface{}) error + Shutdown func(time.Duration) + type ProtocolRecvHook interface + RecvHook func(*Message) bool + type ProtocolSendHook interface + SendHook func(*Message) bool + type ProtocolSocket interface + CloseChannel func() <-chan struct{} + GetOption func(string) (interface{}, error) + RecvChannel func() chan<- *Message + SendChannel func() <-chan *Message + SetOption func(string, interface{}) error + type Socket interface + AddTransport func(Transport) + Close func() error + Dial func(addr string) error + DialOptions func(addr string, options map[string]interface{}) error + GetOption func(name string) (interface{}, error) + GetProtocol func() Protocol + Listen func(addr string) error + ListenOptions func(addr string, options map[string]interface{}) error + NewDialer func(addr string, options map[string]interface{}) (Dialer, error) + NewListener func(addr string, options map[string]interface{}) (Listener, error) + Recv func() ([]byte, error) + RecvMsg func() (*Message, error) + Send func([]byte) error + SendMsg func(*Message) error + SetOption func(name string, value interface{}) error + SetPortHook func(PortHook) PortHook + type Transport interface + GetOption func(string) (interface{}, error) + NewDialer func(url string, protocol Protocol) (PipeDialer, error) + NewListener func(url string, protocol Protocol) (PipeListener, error) + Scheme func() string + SetOption func(string, interface{}) error + type Waiter struct + func (w *Waiter) Add() + func (w *Waiter) Done() + func (w *Waiter) Init() + func (w *Waiter) Wait() + func (w *Waiter) WaitAbsTimeout(t time.Time) bool + func (w *Waiter) WaitRelTimeout(d time.Duration) bool v1.0.0 Jan 24, 2015
Go to main page