Documentation ¶
Index ¶
- Constants
- Variables
- type Channel
- type ChannelClient
- type Channels
- func (c *Channels) Add(channel string, ch Channel)
- func (c *Channels) Bind(event string, h Handler)
- func (c *Channels) ConnectedState(connected bool)
- func (c *Channels) Find(channel string) Channel
- func (c *Channels) HandleEvent(event Event)
- func (c *Channels) Remove(channel string)
- func (c *Channels) SubscriptionSucceded(channel string, succeded bool)
- func (c *Channels) Unbind(event string, h Handler)
- type Client
- type Config
- type DelayError
- type Error
- type Event
- type Handler
- type HandlerFunc
- type PlainClient
- type PublicChannel
- func (c *PublicChannel) Bind(event string, h Handler)
- func (c *PublicChannel) BindAll(h Handler)
- func (c *PublicChannel) BindAllFunc(h func(Event))
- func (c *PublicChannel) BindFunc(event string, h func(Event))
- func (c *PublicChannel) HandleEvent(event Event)
- func (c *PublicChannel) SetActive(active bool)
- func (c *PublicChannel) Subscribe()
- func (c *PublicChannel) Unbind(event string, h Handler)
- func (c *PublicChannel) UnbindAll(h Handler)
- func (c *PublicChannel) UnbindAllFunc(h func(Event))
- func (c *PublicChannel) UnbindFunc(event string, h func(Event))
- func (c *PublicChannel) Unsubscribe()
- func (c *PublicChannel) UpdateClientState(connected bool)
- type Socket
- type TimeoutReason
- type TimeoutTimer
Constants ¶
View Source
const ( IN_CHANNEL_SIZE = 100 OUT_CHANNEL_SIZE = 10 )
View Source
const (
MAX_RECONNECT_WAIT = time.Second * 30
)
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel interface { Handler UpdateClientState(connected bool) SetActive(active bool) Subscribe() Unsubscribe() Bind(event string, h Handler) Unbind(event string, h Handler) BindAll(h Handler) UnbindAll(h Handler) BindFunc(event string, h func(Event)) UnbindFunc(event string, h func(Event)) BindAllFunc(h func(Event)) UnbindAllFunc(h func(Event)) }
type ChannelClient ¶
type Channels ¶
func NewChannels ¶
func NewChannels(client ChannelClient) *Channels
func (*Channels) ConnectedState ¶
func (*Channels) HandleEvent ¶
func (*Channels) SubscriptionSucceded ¶
type Client ¶
type Config ¶
type HandlerFunc ¶
type HandlerFunc func(Event)
func (HandlerFunc) HandleEvent ¶
func (f HandlerFunc) HandleEvent(e Event)
type PlainClient ¶
type PlainClient struct {
// contains filtered or unexported fields
}
func (*PlainClient) Close ¶
func (c *PlainClient) Close()
func (*PlainClient) HandleConnected ¶
func (c *PlainClient) HandleConnected()
func (*PlainClient) HandleDisconnect ¶
func (c *PlainClient) HandleDisconnect() bool
func (*PlainClient) HandleMessage ¶
func (c *PlainClient) HandleMessage(msg []byte) error
func (*PlainClient) SendMessage ¶
func (c *PlainClient) SendMessage(msg []byte)
func (*PlainClient) SendPing ¶
func (c *PlainClient) SendPing()
type PublicChannel ¶
func NewPublicChannel ¶
func NewPublicChannel(channel string, client ChannelClient) *PublicChannel
func (*PublicChannel) Bind ¶
func (c *PublicChannel) Bind(event string, h Handler)
func (*PublicChannel) BindAll ¶
func (c *PublicChannel) BindAll(h Handler)
func (*PublicChannel) BindAllFunc ¶
func (c *PublicChannel) BindAllFunc(h func(Event))
func (*PublicChannel) BindFunc ¶
func (c *PublicChannel) BindFunc(event string, h func(Event))
func (*PublicChannel) HandleEvent ¶
func (c *PublicChannel) HandleEvent(event Event)
func (*PublicChannel) SetActive ¶
func (c *PublicChannel) SetActive(active bool)
func (*PublicChannel) Subscribe ¶
func (c *PublicChannel) Subscribe()
func (*PublicChannel) Unbind ¶
func (c *PublicChannel) Unbind(event string, h Handler)
func (*PublicChannel) UnbindAll ¶
func (c *PublicChannel) UnbindAll(h Handler)
func (*PublicChannel) UnbindAllFunc ¶
func (c *PublicChannel) UnbindAllFunc(h func(Event))
func (*PublicChannel) UnbindFunc ¶
func (c *PublicChannel) UnbindFunc(event string, h func(Event))
func (*PublicChannel) Unsubscribe ¶
func (c *PublicChannel) Unsubscribe()
func (*PublicChannel) UpdateClientState ¶
func (c *PublicChannel) UpdateClientState(connected bool)
type Socket ¶
type Socket struct {
// contains filtered or unexported fields
}
func (*Socket) HandleConnected ¶
func (s *Socket) HandleConnected()
func (*Socket) HandlePong ¶
func (s *Socket) HandlePong()
func (*Socket) SendMessage ¶
func (*Socket) SetActivityTimeout ¶
func (*Socket) SetTimeout ¶
func (s *Socket) SetTimeout(reason TimeoutReason, d time.Duration)
type TimeoutReason ¶
type TimeoutReason int
const ( NoTimeout TimeoutReason = iota ConnectTimeout ActivityTimeout PingTimeout )
type TimeoutTimer ¶
type TimeoutTimer struct { C <-chan time.Time Reason TimeoutReason // contains filtered or unexported fields }
func (*TimeoutTimer) Expired ¶
func (t *TimeoutTimer) Expired() bool
func (*TimeoutTimer) Reset ¶
func (t *TimeoutTimer) Reset()
func (*TimeoutTimer) SetTimeout ¶
func (t *TimeoutTimer) SetTimeout(reason TimeoutReason, d time.Duration)
func (*TimeoutTimer) Stop ¶
func (t *TimeoutTimer) Stop()
Click to show internal directories.
Click to hide internal directories.