mangos

package module

Go to main page

Versions in this module

v2

v2.0.8

Jan 15, 2020

Changes in this version

type Message

+ func (m *Message) Clone()

+ func (m *Message) MakeUnique() *Message

v2.0.7

Dec 20, 2019

v2.0.6

Dec 9, 2019

v2.0.5

Nov 25, 2019

Changes in this version

type ProtocolPipe

+ GetPrivate func() interface{}

+ SetPrivate func(interface{})

v2.0.4

Nov 19, 2019

v2.0.3

Nov 18, 2019

v2.0.2

Dec 1, 2018

v2.0.1

Dec 1, 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

nanomsg.org/go/mangos

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL