ws

type AuthCb func(w http.ResponseWriter, r *http.Request) (string, int, error)

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

type ClientConfig struct {
	// URL specifies the WebSocket URL to connect to.
	// Should start with either `ws://` or `wss://`.
	URL string
	// ConnID specifies the id of the connection to be used in case of
	// reconnection. Should be left empty on initial connect.
	ConnID string
	// AuthToken specifies the token to be used to authenticate
	// the connection.
	AuthToken string
}

type ClientOption func(c *Client) error

type Message struct {
	ClientID string
	ConnID   string
	Type     MessageType
	Data     []byte
}

type MessageType int

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

type ServerConfig struct {
	// ReadBufferSize specifies the size of the internal buffer
	// used to read from a ws connection.
	ReadBufferSize int
	// WriteBufferSize specifies the size of the internal buffer
	// used to wirte to a ws connection.
	WriteBufferSize int
	// PingInterval specifies the interval at which the server should send ping
	// messages to its connections. If the client doesn't respond in 2*PingInterval
	// the server will consider the client as disconnected and drop the connection.
	PingInterval time.Duration
}

type ServerOption func(s *Server) error