Versions in this module Expand all Collapse all v0 v0.0.2 Jan 3, 2026 v0.0.1 Sep 26, 2023 Changes in this version + const BYTE + const BinaryMessage + const CloseMessage + const GIGABYTE + const KILOBYTE + const MEGABYTE + const PingMessage + const PongMessage + const TextMessage + var BroadcastLimitExceededCloseMessage = websocket.FormatCloseMessage(websocket.ClosePolicyViolation, "client broadcast message limit exceeded") + var ErrStoreLimitExceeded = errors.New("websockets store limit exceeded") + func Pub(ctx context.Context, host string, isSecure bool, path string, id string, ...) (err error) + func PubWithBearerToken(ctx context.Context, host string, token string, isSecure bool, path string, ...) (err error) + func PubWithHeader(parentCtx context.Context, host string, header http.Header, isSecure bool, ...) (err error) + type Client struct + CloseGracePeriod time.Duration + Dialer *websocket.Dialer + MaxMessageSize int64 + PingPeriod time.Duration + PongWait time.Duration + WriteWait time.Duration + func NewClient(host string, isSecure bool, path string, id string) *Client + func NewClientWithBearerToken(host string, token string, isSecure bool, path string, id string) *Client + func NewClientWithHeader(host string, header http.Header, isSecure bool, path string, id string) *Client + func (c *Client) AllowInsecureConnections() + func (c *Client) ReadMessage() (messageType int, p []byte, err error) + func (c *Client) Start(parentCtx context.Context, messageFunc func(message []byte) (err error)) (err error) + func (c *Client) WriteJSON(v interface{}) (err error) + func (c *Client) WriteMessage(messageType int, data []byte) (err error) + func (c *Client) WriteMessageSlice(dataSlice [][]byte) (err error) + func (c *Client) WriteTextMessage(data []byte) (err error) + type Server struct + func NewServer(ctx context.Context) *Server + func NewServerWithSettings(ctx context.Context, writeWait time.Duration, pongWait time.Duration, ...) *Server + func (s *Server) HandlePub(channel string, w http.ResponseWriter, r *http.Request) (err error) + func (s *Server) HandlePubSub(channel string, w http.ResponseWriter, r *http.Request) (err error) + func (s *Server) HandlePubSubWithHeader(channel string, header http.Header, w http.ResponseWriter, r *http.Request) (err error) + func (s *Server) HandlePubSubWithHeaderAndLimits(channel string, header http.Header, storeLimit int64, ...) (err error) + func (s *Server) HandlePubWithHeader(channel string, header http.Header, w http.ResponseWriter, r *http.Request) (err error) + func (s *Server) HandlePubWithHeaderAndLimits(channel string, header http.Header, storeLimit int64, ...) (err error) + func (s *Server) HandleSub(channel string, w http.ResponseWriter, r *http.Request) (err error) + func (s *Server) HandleSubWithHeader(channel string, header http.Header, w http.ResponseWriter, r *http.Request) (err error) + func (s *Server) HandleSubWithHeaderAndLimits(channel string, header http.Header, storeLimit int64, ...) (err error) + type Store struct
Go to main page