Versions in this module Expand all Collapse all v0 v0.0.0 Dec 20, 2023 Changes in this version + const All + const Broadcast + const DefaultClientSourcePath + const DefaultWebsocketMaxMessageSize + const DefaultWebsocketPingPeriod + const DefaultWebsocketPongTimeout + const DefaultWebsocketReadBufferSize + const DefaultWebsocketReadTimeout + const DefaultWebsocketWriteTimeout + const DefaultWebsocketWriterBufferSize + const WriteWait + var ClientSource = []byte(...) + var DefaultIDGenerator = func(context.Context) string + type Config struct + BinaryMessages bool + CheckOrigin func(r *http.Request) bool + ClientSourcePath string + Endpoint string + Error func(w http.ResponseWriter, r *http.Request, status int, reason error) + IDGenerator func(ctx context.Context) string + MaxMessageSize int64 + PingPeriod time.Duration + PongTimeout time.Duration + ReadBufferSize int + ReadTimeout time.Duration + Subprotocols []string + WriteBufferSize int + WriteTimeout time.Duration + func (c Config) Validate() Config + type Connection interface + Context func() context.Context + Disconnect func() error + FireStatusCode func(errorMessage string) + GetValue func(key string) interface{} + GetValueArrString func(key string) []string + GetValueInt func(key string) int + GetValueString func(key string) string + ID func() string + Join func(string) + Leave func(string) bool + On func(string, MessageFunc) + OnDisconnect func(DisconnectFunc) + OnLeave func(roomLeaveCb LeaveRoomFunc) + OnMessage func(NativeMessageFunc) + OnStatusCode func(ErrorFunc) + SetValue func(key string, value interface{}) + To func(string) Emitter + type ConnectionFunc func(Connection) + type ConnectionValues []connectionValue + func (r *ConnectionValues) Get(key string) interface{} + func (r *ConnectionValues) Reset() + func (r *ConnectionValues) Set(key string, value interface{}) + type DisconnectFunc func() + type Emitter interface + Emit func(string, interface{}) error + EmitMessage func([]byte) error + type ErrorFunc (func(string)) + type LeaveRoomFunc func(roomName string) + type MessageFunc interface + type NativeMessageFunc func([]byte) + type Server interface + Attach func(app *iris.Application) + Disconnect func(connID string) error + GetConnectionsByRoom func(roomName string) []Connection + Handler func() context.Handler + IsConnected func(connID string) bool + Join func(roomName string, connID string) + Leave func(roomName string, connID string) bool + LeaveAll func(connID string) + OnConnection func(cb ConnectionFunc) + func New(cfg Config) Server + type UnderlineConnection interface + Close func() error + NextWriter func(messageType int) (io.WriteCloser, error) + ReadMessage func() (messageType int, p []byte, err error) + SetPingHandler func(h func(appData string) error) + SetPongHandler func(h func(appData string) error) + SetReadDeadline func(t time.Time) error + SetReadLimit func(limit int64) + SetWriteDeadline func(t time.Time) error + WriteControl func(messageType int, data []byte, deadline time.Time) error + WriteMessage func(messageType int, data []byte) error
Go to main page