astiws

Feb 3, 2024

Changes in this version

+ type OnServeError func(*Client, error)

+ type Server struct

+ Upgrader websocket.Upgrader

+ func NewServer(o ServerOptions) *Server

+ func (s *Server) Clients() []*Client

+ func (s *Server) Close() error

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

+ type ServerOptions struct

+ CheckOrigin func(r *http.Request) bool

+ ClientAdapter ClientAdapter

+ Logger astikit.StdLogger

+ MaxMessageSize int

+ OnServeError OnServeError

+ Timeout time.Duration

Dec 8, 2020

Changes in this version

type ClientConfiguration

+ Timeout time.Duration

type ManagerConfiguration

+ Timeout time.Duration

Feb 18, 2020

Changes in this version

type Client

+ func (c *Client) CloseWithCode(closeCode int) (err error)

Dec 23, 2019

Changes in this version

type Client

+ func (c *Client) DialAndRead(w *astikit.Worker, o DialAndReadOptions)

+ type DialAndReadOptions struct

+ Addr string

+ Header http.Header

+ OnDial func() error

+ OnReadError func(err error)

Dec 4, 2019

Changes in this version

type Client

+ func NewClientWithContext(ctx context.Context, cfg ClientConfiguration) (c *Client)

+ func (c *Client) Context() context.Context

+ func (c *Client) ExtendConnection() error

+ func (c *Client) SetMessageHandler(h MessageHandler)

+ func (c *Client) WithContext(ctx context.Context) *Client

+ func (c *Client) WriteJSON(m interface{}) (err error)

+ func (c *Client) WriteText(m []byte) (err error)

type Manager

+ func (m *Manager) AutoUnregisterClient(c *Client)

+ type MessageHandler func(m []byte) error

Dec 15, 2018

Changes in this version

+ const EventNameDisconnect

+ const PingPeriod

+ type BodyMessage struct

+ EventName string

+ Payload interface{}

+ type BodyMessageRead struct

+ Payload json.RawMessage

+ type Client struct

+ func NewClient(c ClientConfiguration) *Client

+ func (c *Client) AddListener(eventName string, f ListenerFunc)

+ func (c *Client) Close() (err error)

+ func (c *Client) DelListener(eventName string)

+ func (c *Client) Dial(addr string) error

+ func (c *Client) DialWithHeaders(addr string, h http.Header) (err error)

+ func (c *Client) HandlePing() error

+ func (c *Client) Read() (err error)

+ func (c *Client) SetListener(eventName string, f ListenerFunc)

+ func (c *Client) Write(eventName string, payload interface{}) (err error)

+ type ClientAdapter func(c *Client)

+ type ClientConfiguration struct

+ MaxMessageSize int

+ type ListenerFunc func(c *Client, eventName string, payload json.RawMessage) error

+ type Manager struct

+ Upgrader websocket.Upgrader

+ func NewManager(c ManagerConfiguration) *Manager

+ func (m *Manager) AutoRegisterClient(c *Client)

+ func (m *Manager) Client(k interface{}) (c *Client, ok bool)

+ func (m *Manager) Clients(fn func(k interface{}, c *Client) error)

+ func (m *Manager) Close() error

+ func (m *Manager) CountClients() int

+ func (m *Manager) Loop(fn func(k interface{}, c *Client))

+ func (m *Manager) RegisterClient(k interface{}, c *Client)

+ func (m *Manager) ServeHTTP(w http.ResponseWriter, r *http.Request, a ClientAdapter) (err error)

+ func (m *Manager) UnregisterClient(k interface{})

+ type ManagerConfiguration struct

+ CheckOrigin func(r *http.Request) bool

+ MaxMessageSize int