websocket

Sep 29, 2024

Changes in this version

+ var MaxRetryAttempts = 5

+ var PingPeriod = (PongWait * 9) / 10

+ var PongWait = 60 * time.Second

+ var ReconnectTimeout = 5 * time.Second

+ var RunTimeTree = ConnectionTree

+ var WriteWait = 10 * time.Second

+ func Managed(config ...Config) pine.Handler

+ func New(handler func(conn *Conn, ctx *pine.Ctx), config ...Config) pine.Handler

+ func WatchFile(path string, conn *Conn) error

+ type Channel struct

+ CM sync.Mutex

+ Clients []*Client

+ ID uuid.UUID

+ Message chan []byte

+ func (c *Channel) Broadcast()

+ func (c *Channel) MoveClientToChannel(client *Client, newChannel *Channel) error

+ func (c *Channel) RemoveClientFromChannel(clientId uuid.UUID)

+ type Client struct

+ Channel *Channel

+ Conn *websocket.Conn

+ IP string

+ Id uuid.UUID

+ Send chan []byte

+ type Config struct

+ CheckOrigin func(r *http.Request) bool

+ EnableCompression bool

+ Error func(w http.ResponseWriter, r *http.Request, status int, reason error)

+ HandshakeTimeout time.Duration

+ ReadBufferSize int

+ SubprotocolsAllowed []string

+ Type string

+ WriteBufferSize int

+ type Conn struct

+ type ConnectionTree struct

+ CM sync.RWMutex

+ Channels map[uuid.UUID]*Channel

+ Clients map[uuid.UUID]Client

+ func (c *ConnectionTree) RemoveClient(clientID uuid.UUID)