Documentation ¶
Index ¶
- Constants
- func Closed()
- type AcceptMessage
- type ClosedMessage
- type Conn
- func (c *Conn) Close()
- func (c *Conn) Dial(addr string, timeout time.Duration) error
- func (c *Conn) EscalateFailure(reason interface{}, message interface{})
- func (c *Conn) IsConnected() bool
- func (c *Conn) Register(key interface{}, f func(ctx context.Context, message proto.Message) error)
- func (c *Conn) RequestMessage(message proto.Message, timeout int64) (proto.Message, error)
- type ConnState
- type Future
- type IntervalLinkNode
- type PingMessage
- type RecviceMessage
Constants ¶
View Source
const ( LCS_Disconnected = iota LCS_Connecting LCS_Connected LCS_Disconnecting )
Variables ¶
This section is empty.
Functions ¶
Types ¶
type AcceptMessage ¶
type AcceptMessage struct { }
type ClosedMessage ¶
type ClosedMessage struct { }
type Conn ¶
type Conn struct {
// contains filtered or unexported fields
}
func (*Conn) EscalateFailure ¶
func (c *Conn) EscalateFailure(reason interface{}, message interface{})
func (*Conn) IsConnected ¶
type IntervalLinkNode ¶
type IntervalLinkNode struct { intrusive.LinkedNode Value interface{} }
type PingMessage ¶
type PingMessage struct { }
type RecviceMessage ¶
Click to show internal directories.
Click to hide internal directories.