Versions in this module Expand all Collapse all v2 v2.0.0 Nov 2, 2018 Changes in this version + const ErrAddrInUse + const ErrBadAddr + const ErrBadHeader + const ErrBadOption + const ErrBadProperty + const ErrBadProto + const ErrBadTran + const ErrBadValue + const ErrBadVersion + const ErrCanceled + const ErrClosed + const ErrConnRefused + const ErrGarbled + const ErrNoContext + const ErrNotRaw + const ErrProtoOp + const ErrProtoState + const ErrRecvTimeout + const ErrSendTimeout + const ErrTLSNoCert + const ErrTLSNoConfig + const ErrTooLong + const ErrTooShort + const OptionBestEffort + const OptionDialAsynch + const OptionHTTPRequest + const OptionKeepAlive + const OptionKeepAliveTime + const OptionLinger + const OptionLocalAddr + const OptionMaxReconnectTime + const OptionMaxRecvSize + const OptionNoDelay + const OptionRaw + const OptionReadQLen + const OptionReconnectTime + const OptionRecvDeadline + const OptionRemoteAddr + const OptionRetryTime + const OptionSendDeadline + const OptionSubscribe + const OptionSurveyTime + const OptionTLSConfig + const OptionTLSConnState + const OptionTTL + const OptionUnsubscribe + const OptionWriteQLen + const PipeEventAttached + const PipeEventAttaching + const PipeEventDetached + const ProtoBus + const ProtoPair + const ProtoPub + const ProtoPull + const ProtoPush + const ProtoRep + const ProtoReq + const ProtoRespondent + const ProtoStar + const ProtoSub + const ProtoSurveyor + func Device(s1 Socket, s2 Socket) error + type Context interface + Close func() error + GetOption func(name string) (interface{}, error) + Recv func() ([]byte, error) + RecvMsg func() (*Message, error) + Send func([]byte) error + SendMsg func(*Message) error + SetOption func(name string, value interface{}) error + 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 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 + Pipe Pipe + func NewMessage(sz int) *Message + func (m *Message) Dup() *Message + func (m *Message) Free() + type Pipe interface + Address func() string + Close func() error + Dialer func() Dialer + GetOption func(name string) (interface{}, error) + ID func() uint32 + Listener func() Listener + type PipeEvent int + type PipeEventHook func(PipeEvent, Pipe) + type ProtocolBase interface + AddPipe func(ProtocolPipe) error + Info func() ProtocolInfo + OpenContext func() (ProtocolContext, error) + RemovePipe func(ProtocolPipe) + type ProtocolContext interface + Close func() error + GetOption func(string) (interface{}, error) + RecvMsg func() (*Message, error) + SendMsg func(*Message) error + SetOption func(string, interface{}) error + type ProtocolInfo struct + Peer uint16 + PeerName string + Self uint16 + SelfName string + type ProtocolPipe interface + Close func() error + ID func() uint32 + RecvMsg func() *Message + SendMsg func(*Message) error + type Socket interface + Close func() error + Dial func(addr string) error + DialOptions func(addr string, options map[string]interface{}) error + GetOption func(name string) (interface{}, error) + Info func() ProtocolInfo + 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) + OpenContext func() (Context, error) + Recv func() ([]byte, error) + RecvMsg func() (*Message, error) + Send func([]byte) error + SendMsg func(*Message) error + SetOption func(name string, value interface{}) error + SetPipeEventHook func(PipeEventHook) PipeEventHook + type TranDialer interface + Dial func() (TranPipe, error) + GetOption func(name string) (value interface{}, err error) + SetOption func(name string, value interface{}) error + type TranListener interface + Accept func() (TranPipe, error) + Address func() string + Close func() error + GetOption func(name string) (value interface{}, err error) + Listen func() error + SetOption func(name string, value interface{}) error + type TranPipe interface + Close func() error + GetOption func(string) (interface{}, error) + LocalProtocol func() uint16 + Recv func() (*Message, error) + RemoteProtocol func() uint16 + Send func(*Message) error + type Transport interface + NewDialer func(url string, sock Socket) (TranDialer, error) + NewListener func(url string, sock Socket) (TranListener, error) + Scheme func() string Other modules containing this package gopkg.in/nanomsg/mangos.v1