websocket

package

v0.1.5 Latest Latest Go to latest Published: Aug 8, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func IsErrorOfInterest(err error) bool

type Client struct {
	// contains filtered or unexported fields
}

func NewClient(ctx context.Context, conn *websocket.Conn) (*Client, error)

func (c *Client) Done() <-chan struct{}

func (c *Client) ID() string

func (c *Client) SetMessageHandler(handler HandleWebsocketMessage)

func (c *Client) Start() error

func (c *Client) Stop()

func (c *Client) Write(msg []byte) (int, error)

type HandleWebsocketMessage func([]byte) error

type Hub struct {
	// contains filtered or unexported fields
}

func NewHub(ctx context.Context) *Hub

func (h *Hub) Close() error

func (h *Hub) Register(client *Client) error

func (h *Hub) Start() error

func (h *Hub) Stop() error

func (h *Hub) Unregister(client *Client) error

func (h *Hub) Wait() error

func (h *Hub) Write(msg []byte) (int, error)