mangos

package module

Go to main page

Versions in this module

v1

v1.4.0

Jun 23, 2018

v1.3.0

Jun 8, 2018

Changes in this version

+ const OptionBestEffort

v1.2.0

Jul 6, 2016

Changes in this version

+ const OptionMaxReconnectTime

+ const OptionMaxRecvSize

+ const OptionReconnectTime

+ const OptionTTL

+ const PropHTTPRequest

+ const PropLocalAddr

+ const PropRemoteAddr

+ const PropTLSConnState

+ var ErrProtoOp = errors.New("invalid operation for protocol")

+ var ErrProtoState = errors.New("incorrect protocol state")

+ var ErrTLSNoCert = errors.New("missing TLS certificates")

+ var ErrTLSNoConfig = errors.New("missing TLS configuration")

+ func DrainChannel(ch chan<- *Message, expire time.Time) bool

+ func NullRecv(ep Endpoint)

+ func ResolveTCPAddr(addr string) (*net.TCPAddr, error)

type Message

+ Port Port

+ func (m *Message) Expired() bool

type PipeListener

+ Address func() string

type ProtocolSocket

+ SetRecvError func(error)

+ SetSendError func(error)

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

Incompatible versions in this module

v2.0.0+incompatible

Nov 2, 2018

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