wsp

Jan 8, 2024

Changes in this version

type Pool

+ func (p *Pool) GetIdleConnection(ctx context.Context) (conn *Connection)

+ func (p *Pool) RegisterConnection(ws *websocket.Conn)

+ func (p *Pool) SetSize(size int)

+ type Pools struct

+ func NewPools(timeout, idleTimeout time.Duration) *Pools

+ func (p *Pools) Clean()

+ func (p *Pools) GetPool(id PoolID) (pool *Pool, ok bool)

+ func (p *Pools) IsEmpty() bool

+ func (p *Pools) MoreThenOne() bool

+ func (p *Pools) RegisterConnection(ws *websocket.Conn) (err error)

+ func (p *Pools) Shutdown()

Dec 23, 2023

Changes in this version

type Connection

+ func (c *Connection) WritePump()

+ type Message struct

+ Type int

+ Value []byte

Dec 19, 2023

Changes in this version

+ type Config struct

+ IdleTimeout int

+ SecretKey string

+ Timeout int

+ func (c Config) GetTimeout() time.Duration

+ type Connection struct

+ func NewConnection(pool *Pool, ws *websocket.Conn) *Connection

+ func (c *Connection) Close()

+ func (c *Connection) Release()

+ func (c *Connection) Take() bool

+ type ConnectionRequest struct

+ func NewConnectionRequest(timeout time.Duration, serverId PoolID) (cr *ConnectionRequest)

+ type ConnectionStatus int

+ const Busy

+ const Closed

+ const Idle

+ type Pool struct

+ func NewPool(server *Server, id PoolID) *Pool

+ func (p *Pool) Clean()

+ func (p *Pool) IsEmpty() bool

+ func (p *Pool) Offer(connection *Connection)

+ func (p *Pool) Register(ws *websocket.Conn)

+ func (p *Pool) Shutdown()

+ func (p *Pool) Size() (ps *PoolSize)

+ type PoolID string

+ type PoolSize struct

+ Busy int

+ Closed int

+ Idle int

+ type Server struct

+ Config *Config

+ func NewServer(config *Config) (server *Server)

+ func (s *Server) GetServerID(r *http.Request) (serverID string, err error)

+ func (s *Server) Register(w http.ResponseWriter, r *http.Request)

+ func (s *Server) Request(w http.ResponseWriter, r *http.Request)

+ func (s *Server) Shutdown()

+ func (s *Server) Start()

+ func (s *Server) Ws(w http.ResponseWriter, r *http.Request)