Documentation
¶
Index ¶
- func AuthHandler[Params, AuthModel any](callbacksFunc func() AuthCallbacks[Params, AuthModel], ...) simba.Handler
- func Handler[Params any](callbacksFunc func() Callbacks[Params], options ...HandlerOption) simba.Handler
- type AuthCallbackHandlerFunc
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetAccepts() string
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetAuthHandler() any
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetAuthModel() any
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetHandler() any
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetParams() any
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetProduces() string
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetRequestBody() any
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetResponseBody() any
- func (h *AuthCallbackHandlerFunc[Params, AuthModel]) ServeHTTP(w http.ResponseWriter, r *http.Request)
- type AuthCallbacks
- type CallbackHandlerFunc
- func (h *CallbackHandlerFunc[Params]) GetAccepts() string
- func (h *CallbackHandlerFunc[Params]) GetAuthHandler() any
- func (h *CallbackHandlerFunc[Params]) GetAuthModel() any
- func (h *CallbackHandlerFunc[Params]) GetHandler() any
- func (h *CallbackHandlerFunc[Params]) GetParams() any
- func (h *CallbackHandlerFunc[Params]) GetProduces() string
- func (h *CallbackHandlerFunc[Params]) GetRequestBody() any
- func (h *CallbackHandlerFunc[Params]) GetResponseBody() any
- func (h *CallbackHandlerFunc[Params]) ServeHTTP(w http.ResponseWriter, r *http.Request)
- type Callbacks
- type Connection
- type HandlerOption
- type Middleware
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AuthHandler ¶
func AuthHandler[Params, AuthModel any]( callbacksFunc func() AuthCallbacks[Params, AuthModel], authHandler simba.AuthHandler[AuthModel], options ...HandlerOption, ) simba.Handler
AuthHandler creates an authenticated handler that uses callbacks for WebSocket lifecycle events.
Example usage:
bearerAuth := simba.BearerAuth(authFunc, simba.BearerAuthConfig{...})
app.Router.GET("/ws/chat", simba.AuthWebSocketHandler(
simba.AuthCallbacks[Params, User]{
OnConnect: func(ctx context.Context, conn *simba.Connection, params Params, user User) error {
registry.Add(user.ID, conn)
return conn.WriteText(fmt.Sprintf("Welcome %s!", user.Name))
},
OnMessage: func(ctx context.Context, conn *simba.Connection, msgType simba.MessageType, data []byte, user User) error {
// Handle message with user context
return nil
},
OnDisconnect: func(ctx context.Context, connID string, params Params, user User, err error) {
registry.Remove(user.ID, connID)
},
},
bearerAuth,
))
func Handler ¶
func Handler[Params any](callbacksFunc func() Callbacks[Params], options ...HandlerOption) simba.Handler
Handler creates a handler that uses callbacks for WebSocket lifecycle events.
Example usage:
app.Router.GET("/ws/echo", simba.WebSocketHandler(
echoCallbacks,
simba.WithMiddleware(
wsMiddleware.TraceID(),
wsMiddleware.Logger(),
),
))
Where echoCallbacks is a function:
func echoCallbacks() simba.Callbacks[simbaModels.NoParams] {
return simba.Callbacks[simbaModels.NoParams]{
OnMessage: func(ctx context.Context, conn *simba.Connection, data []byte) error {
return conn.WriteText("Echo: " + string(data))
},
}
}
Types ¶
type AuthCallbackHandlerFunc ¶
type AuthCallbackHandlerFunc[Params, AuthModel any] struct { // contains filtered or unexported fields }
AuthCallbackHandlerFunc handles authenticated WebSocket connections with callbacks.
func (*AuthCallbackHandlerFunc[Params, AuthModel]) GetAccepts ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetAccepts() string
func (*AuthCallbackHandlerFunc[Params, AuthModel]) GetAuthHandler ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetAuthHandler() any
func (*AuthCallbackHandlerFunc[Params, AuthModel]) GetAuthModel ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetAuthModel() any
func (*AuthCallbackHandlerFunc[Params, AuthModel]) GetHandler ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetHandler() any
func (*AuthCallbackHandlerFunc[Params, AuthModel]) GetParams ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetParams() any
func (*AuthCallbackHandlerFunc[Params, AuthModel]) GetProduces ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetProduces() string
func (*AuthCallbackHandlerFunc[Params, AuthModel]) GetRequestBody ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetRequestBody() any
func (*AuthCallbackHandlerFunc[Params, AuthModel]) GetResponseBody ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) GetResponseBody() any
func (*AuthCallbackHandlerFunc[Params, AuthModel]) ServeHTTP ¶
func (h *AuthCallbackHandlerFunc[Params, AuthModel]) ServeHTTP(w http.ResponseWriter, r *http.Request)
ServeHTTP implements the http.Handler interface.
type AuthCallbacks ¶
type AuthCallbacks[Params, AuthModel any] struct { // OnConnect is called after WebSocket upgrade succeeds. // Return an error to reject the connection. OnConnect func(ctx context.Context, conn *Connection, params Params, auth AuthModel) error // OnMessage is called for each incoming message (required). // Return an error to trigger OnError or close the connection. OnMessage func(ctx context.Context, conn *Connection, data []byte, auth AuthModel) error // OnDisconnect is called when the connection closes. // The err parameter is nil for clean close, non-nil otherwise. // Guaranteed to run via defer, making it safe for cleanup. OnDisconnect func(ctx context.Context, connID string, params Params, auth AuthModel, err error) // OnError is called when OnMessage returns an error. // Return true to continue, false to close the connection. // If not provided, errors close the connection. OnError func(ctx context.Context, conn *Connection, err error) bool }
AuthCallbacks defines lifecycle callbacks for an authenticated WebSocket connection. Same as Callbacks but includes the authenticated user model in each callback.
type CallbackHandlerFunc ¶
type CallbackHandlerFunc[Params any] struct { // contains filtered or unexported fields }
CallbackHandlerFunc handles WebSocket connections with callbacks.
func (*CallbackHandlerFunc[Params]) GetAccepts ¶
func (h *CallbackHandlerFunc[Params]) GetAccepts() string
func (*CallbackHandlerFunc[Params]) GetAuthHandler ¶
func (h *CallbackHandlerFunc[Params]) GetAuthHandler() any
func (*CallbackHandlerFunc[Params]) GetAuthModel ¶
func (h *CallbackHandlerFunc[Params]) GetAuthModel() any
func (*CallbackHandlerFunc[Params]) GetHandler ¶
func (h *CallbackHandlerFunc[Params]) GetHandler() any
func (*CallbackHandlerFunc[Params]) GetParams ¶
func (h *CallbackHandlerFunc[Params]) GetParams() any
func (*CallbackHandlerFunc[Params]) GetProduces ¶
func (h *CallbackHandlerFunc[Params]) GetProduces() string
func (*CallbackHandlerFunc[Params]) GetRequestBody ¶
func (h *CallbackHandlerFunc[Params]) GetRequestBody() any
func (*CallbackHandlerFunc[Params]) GetResponseBody ¶
func (h *CallbackHandlerFunc[Params]) GetResponseBody() any
func (*CallbackHandlerFunc[Params]) ServeHTTP ¶
func (h *CallbackHandlerFunc[Params]) ServeHTTP(w http.ResponseWriter, r *http.Request)
ServeHTTP implements the http.Handler interface.
type Callbacks ¶
type Callbacks[Params any] struct { // OnConnect is called after WebSocket upgrade succeeds. // Return an error to reject the connection. OnConnect func(ctx context.Context, conn *Connection, params Params) error // OnMessage is called for each incoming message (required). // Return an error to trigger OnError or close the connection. OnMessage func(ctx context.Context, conn *Connection, data []byte) error // OnDisconnect is called when the connection closes. // The err parameter is nil for clean close, non-nil otherwise. // Guaranteed to run via defer, making it safe for cleanup. OnDisconnect func(ctx context.Context, connID string, params Params, err error) // OnError is called when OnMessage returns an error. // Return true to continue, false to close the connection. // If not provided, errors close the connection. OnError func(ctx context.Context, conn *Connection, err error) bool }
Callbacks defines lifecycle callbacks for a WebSocket connection.
type Connection ¶
type Connection struct {
// ID is a unique identifier (UUID) for this connection.
// Use this to track connections in external registries.
ID string
// contains filtered or unexported fields
}
WebSocketConnection represents an active WebSocket connection. It provides thread-safe methods for sending messages. The ID can be used to reference this connection in external systems (e.g., Redis, database) for multi-instance message routing.
func (*Connection) Close ¶
func (c *Connection) Close() error
Close closes the WebSocket connection.
func (*Connection) WriteBinary ¶
func (c *Connection) WriteBinary(ctx context.Context, data []byte) error
WriteBinary sends a binary message to the client (thread-safe).
type HandlerOption ¶
type HandlerOption interface {
// contains filtered or unexported methods
}
HandlerOption is an option for configuring WebSocket handlers.
func WithMiddleware ¶
func WithMiddleware(middleware ...Middleware) HandlerOption
WithMiddleware adds middleware to the WebSocket handler. Middleware runs before each callback invocation, allowing you to enrich the context.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.