rue

package module

Go to main page

Versions in this module

v0

v0.0.8

Jun 23, 2026

v0.0.7

Jun 23, 2026

v0.0.6

Feb 25, 2026

retracted

v0.0.5

Jan 14, 2026

retracted

Changes in this version

+ var ErrRequestBodyTooLarge = errors.New("request body too large")

+ var ErrWebSocketOriginNotAllowed = errors.New("websocket: origin not allowed")

type Context

+ func (c *Context) DefaultQuery(key, defaultValue string) string

+ func (c *Context) Validate(obj any) error

type Engine

+ MaxRequestBodySize int64

+ RedirectTrailingSlash bool

+ func (e *Engine) SetTrustedProxies(proxies []string) error

type Executor

+ func NewExecutorWithLimits(schema *Schema, maxDepth, maxComplexity int) *Executor

type GraphQLConfig

+ MaxComplexity int

+ MaxDepth int

type RateLimiterConfig

+ CleanupInterval time.Duration

+ EntryTTL time.Duration

type RouterGroup

+ func (g *RouterGroup) CONNECT(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) TRACE(relativePath string, handlers ...HandlerFunc) *RouterGroup

type WebSocketConfig

+ CheckOrigin func(c *Context) bool

v0.0.4

Jan 9, 2026

retracted

v0.0.3

Jan 7, 2026

retracted

Changes in this version

type Engine

+ func (e *Engine) DisableStats() *Engine

+ func (e *Engine) SetStatsConfig(config StatsConfig) *Engine

+ func (e *Engine) SetStatsInterval(interval time.Duration) *Engine

type HandlerFunc

+ func SystemStats() HandlerFunc

+ func SystemStatsWithConfig(config StatsConfig) HandlerFunc

+ type ModeBuilder struct

+ func (b *ModeBuilder) EnableCaller(enable bool) *ModeBuilder

+ func (b *ModeBuilder) EnableColor(enable bool) *ModeBuilder

+ func (b *ModeBuilder) Format(format LogFormat) *ModeBuilder

+ func (b *ModeBuilder) LogLevel(level LogLevel) *ModeBuilder

+ type StatsConfig struct

+ Enabled bool

+ Interval time.Duration

+ func DefaultStatsConfig() StatsConfig

v0.0.2

Jan 6, 2026

retracted

Changes in this version

+ const EnvRueMode

+ var DefaultFuncMap = template.FuncMap

+ func IsDevMode() bool

+ func IsPrdMode() bool

+ func IsTestMode() bool

+ func LogDebug(msg string)

+ func LogDebugf(format string, args ...any)

+ func LogError(msg string)

+ func LogErrorWithErr(msg string, err error)

+ func LogErrorf(format string, args ...any)

+ func LogFatal(msg string)

+ func LogFatalf(format string, args ...any)

+ func LogInfo(msg string)

+ func LogInfof(format string, args ...any)

+ func LogStat(msg string)

+ func LogStatf(format string, args ...any)

+ func LogWarn(msg string)

+ func LogWarnf(format string, args ...any)

+ func SetDefaultLogger(l *Logger)

+ func SetMode(mode Mode)

+ type Delims struct

+ Left string

+ Right string

type Engine

+ Logger *Logger

+ Mode Mode

+ func (e *Engine) Delims(left, right string) *Engine

+ func (e *Engine) GetHTMLTemplate() *template.Template

+ func (e *Engine) LoadHTMLFS(fsys fs.FS, patterns ...string) error

+ func (e *Engine) LoadHTMLFSRecursive(fsys fs.FS, root string, filePattern string) error

+ func (e *Engine) LoadHTMLFiles(files ...string) error

+ func (e *Engine) LoadHTMLGlob(pattern string) error

+ func (e *Engine) SetFuncMap(funcMap template.FuncMap)

+ func (e *Engine) SetHTMLTemplate(tmpl *template.Template)

+ type HTMLRenderer struct

+ func NewHTMLRenderer() *HTMLRenderer

+ func (r *HTMLRenderer) Render(w io.Writer, name string, data any) error

type HandlerFunc

+ func RequestLogger() HandlerFunc

+ func RequestLoggerWithConfig(config RequestLoggerConfig) HandlerFunc

+ type LogEntry struct

+ Caller string

+ ClientIP string

+ Content string

+ Error string

+ Fields map[string]any

+ Func string

+ Latency string

+ Level string

+ Method string

+ Path string

+ Stack string

+ Status int

+ Timestamp string

+ type LogFormat int

+ const JSONFormat

+ const TextFormat

+ type LogLevel int

+ const DebugLevel

+ const ErrorLevel

+ const FatalLevel

+ const InfoLevel

+ const StatLevel

+ const WarnLevel

+ func (l LogLevel) Color() string

+ func (l LogLevel) String() string

type Logger

+ func GetDefaultLogger() *Logger

+ func NewLogger(opts ...LoggerOption) *Logger

+ func (l *Logger) Debug(msg string)

+ func (l *Logger) Debugf(format string, args ...any)

+ func (l *Logger) Error(msg string)

+ func (l *Logger) ErrorWithErr(msg string, err error)

+ func (l *Logger) Errorf(format string, args ...any)

+ func (l *Logger) Fatal(msg string)

+ func (l *Logger) Fatalf(format string, args ...any)

+ func (l *Logger) Info(msg string)

+ func (l *Logger) Infof(format string, args ...any)

+ func (l *Logger) SetFormat(format LogFormat)

+ func (l *Logger) SetLevel(level LogLevel)

+ func (l *Logger) Stat(msg string)

+ func (l *Logger) Statf(format string, args ...any)

+ func (l *Logger) Warn(msg string)

+ func (l *Logger) Warnf(format string, args ...any)

+ func (l *Logger) WithFields(fields map[string]any) *Logger

+ type LoggerOption func(*Logger)

+ func WithCaller(enable bool) LoggerOption

+ func WithCallerSkip(skip int) LoggerOption

+ func WithColor(enable bool) LoggerOption

+ func WithFormat(format LogFormat) LoggerOption

+ func WithLevel(level LogLevel) LoggerOption

+ func WithOutput(w io.Writer) LoggerOption

+ func WithTimeFormat(format string) LoggerOption

+ type Mode string

+ const DevMode

+ const PrdMode

+ const TestMode

+ func GetMode() Mode

+ type ModeConfig struct

+ EnableCaller bool

+ EnableColor bool

+ LogFormat LogFormat

+ LogLevel LogLevel

+ func GetModeConfig() ModeConfig

+ type RequestLoggerConfig struct

+ EnableCaller bool

+ EnableColor bool

+ Format LogFormat

+ Level LogLevel

+ Output io.Writer

+ SkipPaths []string

+ TimeFormat string

+ func DefaultRequestLoggerConfig() RequestLoggerConfig

v0.0.1

Jan 6, 2026

retracted

Changes in this version

+ const BinaryMessage

+ const CloseMessage

+ const PingMessage

+ const PongMessage

+ const TextMessage

+ var ErrBadRequest = NewError(http.StatusBadRequest, "Bad Request")

+ var ErrConflict = NewError(http.StatusConflict, "Conflict")

+ var ErrForbidden = NewError(http.StatusForbidden, "Forbidden")

+ var ErrGatewayTimeout = NewError(http.StatusGatewayTimeout, "Gateway Timeout")

+ var ErrInternalServerError = NewError(http.StatusInternalServerError, "Internal Server Error")

+ var ErrMethodNotAllowed = NewError(http.StatusMethodNotAllowed, "Method Not Allowed")

+ var ErrNotFound = NewError(http.StatusNotFound, "Not Found")

+ var ErrPayloadTooLarge = NewError(http.StatusRequestEntityTooLarge, "Payload Too Large")

+ var ErrRequestTimeout = NewError(http.StatusRequestTimeout, "Request Timeout")

+ var ErrServiceUnavailable = NewError(http.StatusServiceUnavailable, "Service Unavailable")

+ var ErrTooManyRequests = NewError(http.StatusTooManyRequests, "Too Many Requests")

+ var ErrUnauthorized = NewError(http.StatusUnauthorized, "Unauthorized")

+ var ErrUnprocessableEntity = NewError(http.StatusUnprocessableEntity, "Unprocessable Entity")

+ var ErrUnsupportedMedia = NewError(http.StatusUnsupportedMediaType, "Unsupported Media Type")

+ var ErrWebSocketClosed = errors.New("websocket: connection closed")

+ var ErrWebSocketInvalidData = errors.New("websocket: invalid data")

+ var ErrWebSocketUpgrade = errors.New("websocket: upgrade failed")

+ var GraphQLBoolean = &ScalarType

+ var GraphQLFloat = &ScalarType

+ var GraphQLID = &ScalarType

+ var GraphQLInt = &ScalarType

+ var GraphQLString = &ScalarType

+ func DefaultErrorHandler(c *Context, err error)

+ func GRPCAuth(authFunc func(ctx context.Context) (context.Context, error)) grpc.UnaryServerInterceptor

+ func GRPCLogger() grpc.UnaryServerInterceptor

+ func GRPCRateLimiter(allowFunc func(key string) bool, keyFunc func(ctx context.Context) string) grpc.UnaryServerInterceptor

+ func GRPCRecovery() grpc.UnaryServerInterceptor

+ func GRPCStreamAuth(authFunc func(ctx context.Context) (context.Context, error)) grpc.StreamServerInterceptor

+ func GRPCStreamLogger() grpc.StreamServerInterceptor

+ func GRPCStreamRecovery() grpc.StreamServerInterceptor

+ func GenerateToken(claims *JWTClaims, secret []byte) (string, error)

+ func GenerateTokenWithMethod(claims *JWTClaims, secret []byte, method string) (string, error)

+ type APIKeyConfig struct

+ ContextKey string

+ ErrorFunc func(*Context)

+ KeyLookup string

+ SkipFunc func(*Context) bool

+ Validator func(string) bool

+ func DefaultAPIKeyConfig() APIKeyConfig

+ type Agent struct

+ func NewAgent(engine *Engine) *Agent

+ func (a *Agent) AddHeader(key, value string) *Agent

+ func (a *Agent) ClearCookies() *Agent

+ func (a *Agent) ClearHeaders() *Agent

+ func (a *Agent) Delete(path string) *AgentResponse

+ func (a *Agent) Do(method, path string, body io.Reader) *AgentResponse

+ func (a *Agent) Get(path string) *AgentResponse

+ func (a *Agent) Head(path string) *AgentResponse

+ func (a *Agent) NewRequest(method, path string) *Request

+ func (a *Agent) Options(path string) *AgentResponse

+ func (a *Agent) Patch(path string, body io.Reader) *AgentResponse

+ func (a *Agent) PatchJSON(path string, obj any) *AgentResponse

+ func (a *Agent) Post(path string, body io.Reader) *AgentResponse

+ func (a *Agent) PostForm(path string, data url.Values) *AgentResponse

+ func (a *Agent) PostJSON(path string, obj any) *AgentResponse

+ func (a *Agent) Put(path string, body io.Reader) *AgentResponse

+ func (a *Agent) PutJSON(path string, obj any) *AgentResponse

+ func (a *Agent) SetCookie(cookie *http.Cookie) *Agent

+ func (a *Agent) SetHeader(key, value string) *Agent

+ type AgentResponse struct

+ Body []byte

+ Cookies []*http.Cookie

+ Headers http.Header

+ StatusCode int

+ func (r *AgentResponse) JSON(obj any) error

+ func (r *AgentResponse) String() string

+ type Argument struct

+ DefaultValue any

+ Description string

+ Name string

+ Type GraphQLType

+ type Binder interface

+ Bind func(c *Context, obj any) error

+ type BindingError struct

+ Field string

+ Reason string

+ func (e *BindingError) Error() string

+ type BrotliConfig struct

+ ContentTypes []string

+ Level int

+ MinLength int

+ SkipFunc func(*Context) bool

+ func DefaultBrotliConfig() BrotliConfig

+ type CORSConfig struct

+ AllowCredentials bool

+ AllowHeaders []string

+ AllowMethods []string

+ AllowOrigins []string

+ ExposeHeaders []string

+ MaxAge int

+ func DefaultCORSConfig() CORSConfig

+ type CompressConfig struct

+ BrotliLevel int

+ ContentTypes []string

+ GzipLevel int

+ MinLength int

+ SkipFunc func(*Context) bool

+ func DefaultCompressConfig() CompressConfig

+ type Context struct

+ Errors []error

+ Params Params

+ Request *http.Request

+ Writer ResponseWriter

+ func (c *Context) Abort()

+ func (c *Context) AbortWithError(code int, err error)

+ func (c *Context) AbortWithJSON(code int, obj any)

+ func (c *Context) AbortWithStatus(code int)

+ func (c *Context) Bind(obj any) error

+ func (c *Context) BindJSON(obj any) error

+ func (c *Context) BindQuery(obj any) error

+ func (c *Context) ClientIP() string

+ func (c *Context) ContentType() string

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

+ func (c *Context) Cookie(name string) (string, error)

+ func (c *Context) Data(code int, contentType string, data []byte) error

+ func (c *Context) Deadline() (deadline time.Time, ok bool)

+ func (c *Context) Done() <-chan struct{}

+ func (c *Context) Err() error

+ func (c *Context) Error(err error)

+ func (c *Context) File(filepath string)

+ func (c *Context) FormFile(name string) (*multipart.FileHeader, error)

+ func (c *Context) FullPath() string

+ func (c *Context) Get(key string) (any, bool)

+ func (c *Context) GetBool(key string) bool

+ func (c *Context) GetInt(key string) int

+ func (c *Context) GetString(key string) string

+ func (c *Context) HTML(code int, name string, data any) error

+ func (c *Context) Header(key string) string

+ func (c *Context) IndentedJSON(code int, obj any) error

+ func (c *Context) IsAborted() bool

+ func (c *Context) JSON(code int, obj any) error

+ func (c *Context) MultipartForm() (*multipart.Form, error)

+ func (c *Context) MustGet(key string) any

+ func (c *Context) Next()

+ func (c *Context) Param(key string) string

+ func (c *Context) PostForm(key string) string

+ func (c *Context) PostFormArray(key string) []string

+ func (c *Context) PostFormDefault(key, defaultValue string) string

+ func (c *Context) Query(key string) string

+ func (c *Context) QueryArray(key string) []string

+ func (c *Context) QueryDefault(key, defaultValue string) string

+ func (c *Context) QueryMap(key string) map[string]string

+ func (c *Context) Redirect(code int, location string)

+ func (c *Context) Set(key string, value any)

+ func (c *Context) SetCookie(name, value string, maxAge int, path, domain string, secure, httpOnly bool)

+ func (c *Context) SetHeader(key, value string)

+ func (c *Context) ShouldBind(obj any) error

+ func (c *Context) ShouldBindJSON(obj any) error

+ func (c *Context) Status(code int) *Context

+ func (c *Context) Stream(code int, contentType string, reader io.Reader) error

+ func (c *Context) String(code int, format string, values ...any) error

+ func (c *Context) Text(code int, text string) error

+ func (c *Context) Value(key any) any

+ func (c *Context) XML(code int, obj any) error

+ type DefaultBinder struct

+ func (b *DefaultBinder) Bind(c *Context, obj any) error

+ type DefaultValidator struct

+ func NewValidator() *DefaultValidator

+ func (v *DefaultValidator) RegisterValidation(tag string, fn ValidationFunc)

+ func (v *DefaultValidator) Validate(obj any) error

+ type Engine struct

+ Binder Binder

+ ErrorHandler ErrorHandler

+ MaxMultipartMemory int64

+ Renderer Renderer

+ Validator Validator

+ func Default() *Engine

+ func New() *Engine

+ func (e *Engine) OnRequest(fn func(*Context))

+ func (e *Engine) OnResponse(fn func(*Context))

+ func (e *Engine) OnShutdown(fn func())

+ func (e *Engine) OnStart(fn func())

+ func (e *Engine) Run(addr string) error

+ func (e *Engine) RunDualStack(httpAddr, http3Addr, certFile, keyFile string) error

+ func (e *Engine) RunQUIC(addr, certFile, keyFile string) error

+ func (e *Engine) RunQUICWithConfig(addr, certFile, keyFile string, config QUICConfig) error

+ func (e *Engine) RunTLS(addr, certFile, keyFile string) error

+ func (e *Engine) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (e *Engine) Shutdown(ctx context.Context) error

+ type Error struct

+ Code int

+ Details any

+ Err error

+ Message string

+ func NewError(code int, message string) *Error

+ func (e *Error) Error() string

+ func (e *Error) Is(target error) bool

+ func (e *Error) StatusCode() int

+ func (e *Error) Unwrap() error

+ func (e *Error) WithDetails(details any) *Error

+ func (e *Error) WithError(err error) *Error

+ func (e *Error) WithMessage(message string) *Error

+ type ErrorHandler func(*Context, error)

+ type ErrorHandlerFunc func(c *Context, err error)

+ func JSONErrorHandler(debug bool) ErrorHandlerFunc

+ type Executor struct

+ func NewExecutor(schema *Schema) *Executor

+ func (e *Executor) Execute(ctx *Context, req *GraphQLRequest) *GraphQLResponse

+ type Field struct

+ Args []*Argument

+ Description string

+ Name string

+ Resolve ResolveFunc

+ Type GraphQLType

+ type GRPCConfig struct

+ ConnectionTimeout time.Duration

+ EnableReflection bool

+ MaxConcurrentStreams uint32

+ MaxRecvMsgSize int

+ MaxSendMsgSize int

+ func DefaultGRPCConfig() *GRPCConfig

+ type GRPCContext struct

+ func GetGRPCContext(ctx context.Context) *GRPCContext

+ func NewGRPCContext(ctx context.Context) *GRPCContext

+ func (gc *GRPCContext) Abort()

+ func (gc *GRPCContext) Context() context.Context

+ func (gc *GRPCContext) Error(err error)

+ func (gc *GRPCContext) Errors() []error

+ func (gc *GRPCContext) Get(key string) (any, bool)

+ func (gc *GRPCContext) GetMetadata(key string) string

+ func (gc *GRPCContext) IsAborted() bool

+ func (gc *GRPCContext) Metadata() metadata.MD

+ func (gc *GRPCContext) MustGet(key string) any

+ func (gc *GRPCContext) Set(key string, value any)

+ type GRPCServer struct

+ func NewGRPCServer(engine *Engine) *GRPCServer

+ func NewGRPCServerWithConfig(engine *Engine, config *GRPCConfig) *GRPCServer

+ func (gs *GRPCServer) Build(opts ...grpc.ServerOption) *grpc.Server

+ func (gs *GRPCServer) GracefulStop()

+ func (gs *GRPCServer) Run(addr string) error

+ func (gs *GRPCServer) Serve(lis net.Listener) error

+ func (gs *GRPCServer) Server() *grpc.Server

+ func (gs *GRPCServer) Stop()

+ func (gs *GRPCServer) Use(middleware ...HandlerFunc) *GRPCServer

+ func (gs *GRPCServer) UseStream(interceptor grpc.StreamServerInterceptor) *GRPCServer

+ func (gs *GRPCServer) UseUnary(interceptor grpc.UnaryServerInterceptor) *GRPCServer

+ type GraphQLConfig struct

+ Playground bool

+ Schema *Schema

+ type GraphQLError struct

+ Locations []Location

+ Message string

+ Path []any

+ type GraphQLRequest struct

+ OperationName string

+ Query string

+ Variables map[string]any

+ type GraphQLResponse struct

+ Data any

+ Errors []GraphQLError

+ func (r *GraphQLResponse) MarshalJSON() ([]byte, error)

+ type GraphQLType interface

+ Description func() string

+ Name func() string

+ type GzipConfig struct

+ ContentTypes []string

+ Level int

+ MinLength int

+ SkipFunc func(*Context) bool

+ func DefaultGzipConfig() GzipConfig

+ type H map[string]any

+ type HTTP3Handler struct

+ func (h *HTTP3Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type HTTP3Server struct

+ func NewHTTP3Server(engine *Engine, config QUICConfig) *HTTP3Server

+ func (s *HTTP3Server) Close() error

+ func (s *HTTP3Server) CloseGracefully(timeout time.Duration) error

+ func (s *HTTP3Server) ListenAndServe(addr, certFile, keyFile string) error

+ type HandlerFunc func(*Context)

+ func APIKey(validator func(string) bool) HandlerFunc

+ func APIKeyWithConfig(config APIKeyConfig) HandlerFunc

+ func AltSvc(port int) HandlerFunc

+ func AltSvcWithMaxAge(port int, maxAge int) HandlerFunc

+ func Brotli() HandlerFunc

+ func BrotliWithConfig(config BrotliConfig) HandlerFunc

+ func CORS() HandlerFunc

+ func CORSWithConfig(config CORSConfig) HandlerFunc

+ func Compress() HandlerFunc

+ func CompressWithConfig(config CompressConfig) HandlerFunc

+ func GraphQL(schema *Schema) HandlerFunc

+ func GraphQLWithConfig(config GraphQLConfig) HandlerFunc

+ func Gzip() HandlerFunc

+ func GzipWithConfig(config GzipConfig) HandlerFunc

+ func JWT(secret []byte) HandlerFunc

+ func JWTWithConfig(config JWTConfig) HandlerFunc

+ func Logger() HandlerFunc

+ func LoggerWithConfig(config LoggerConfig) HandlerFunc

+ func RateLimiter() HandlerFunc

+ func RateLimiterWithConfig(config RateLimiterConfig) HandlerFunc

+ func Recovery() HandlerFunc

+ func RecoveryWithConfig(config RecoveryConfig) HandlerFunc

+ func WebSocket(handler *WebSocketHandler) HandlerFunc

+ func WebSocketWithConfig(handler *WebSocketHandler, config WebSocketConfig) HandlerFunc

+ type HandlersChain []HandlerFunc

+ func (c HandlersChain) Last() HandlerFunc

+ type ICECandidate struct

+ Candidate string

+ SDPMLineIndex int

+ SDPMid string

+ type JWTClaims struct

+ Audience string

+ Custom map[string]any

+ ExpiresAt int64

+ ID string

+ IssuedAt int64

+ Issuer string

+ NotBefore int64

+ Subject string

+ func ParseToken(tokenString string, secret []byte) (*JWTClaims, error)

+ type JWTConfig struct

+ AuthScheme string

+ ContextKey string

+ ErrorFunc func(*Context, error)

+ Secret []byte

+ SigningMethod string

+ SkipFunc func(*Context) bool

+ TokenLookup string

+ func DefaultJWTConfig() JWTConfig

+ type Location struct

+ Column int

+ Line int

+ type LoggerConfig struct

+ Format string

+ Output io.Writer

+ SkipPaths []string

+ TimeFormat string

+ func DefaultLoggerConfig() LoggerConfig

+ type ObjectType struct

+ func NewObjectType(name, description string) *ObjectType

+ func (o *ObjectType) AddField(field *Field)

+ func (o *ObjectType) Description() string

+ func (o *ObjectType) Name() string

+ type Operation struct

+ Name string

+ Selections []Selection

+ Type string

+ type Param struct

+ Key string

+ Value string

+ type Params []Param

+ func (ps Params) ByName(name string) string

+ func (ps Params) Get(name string) (string, bool)

+ type QUICConfig struct

+ AltSvcPort int

+ Enable0RTT bool

+ IdleTimeout time.Duration

+ MaxIncomingStreams int64

+ MaxIncomingUniStreams int64

+ TLSConfig *tls.Config

+ func DefaultQUICConfig() QUICConfig

+ type RateLimiterConfig struct

+ Burst int

+ ErrorFunc func(*Context)

+ KeyFunc func(*Context) string

+ Rate float64

+ SkipFunc func(*Context) bool

+ func DefaultRateLimiterConfig() RateLimiterConfig

+ type RecoveryConfig struct

+ Output io.Writer

+ PrintStack bool

+ StackAll bool

+ StackSize int

+ func DefaultRecoveryConfig() RecoveryConfig

+ type Renderer interface

+ Render func(w io.Writer, name string, data any) error

+ type Request struct

+ func (r *Request) Body(body io.Reader) *Request

+ func (r *Request) Form(data url.Values) *Request

+ func (r *Request) Header(key, value string) *Request

+ func (r *Request) JSON(obj any) *Request

+ func (r *Request) Query(key, value string) *Request

+ func (r *Request) Send() *AgentResponse

+ type ResolveContext struct

+ Args map[string]any

+ Context *Context

+ Info *ResolveInfo

+ Source any

+ type ResolveFunc func(ctx *ResolveContext) (any, error)

+ type ResolveInfo struct

+ FieldName string

+ ParentType GraphQLType

+ ReturnType GraphQLType

+ type ResponseWriter interface

+ Size func() int

+ Status func() int

+ WriteHeaderNow func()

+ WriteString func(s string) (int, error)

+ Written func() bool

+ type Router struct

+ type RouterGroup struct

+ func (g *RouterGroup) Any(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) DELETE(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) GET(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) Group(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) HEAD(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) Handle(method, relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) OPTIONS(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) PATCH(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) POST(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) PUT(relativePath string, handlers ...HandlerFunc) *RouterGroup

+ func (g *RouterGroup) Static(relativePath, root string) *RouterGroup

+ func (g *RouterGroup) StaticFS(relativePath string, fs http.FileSystem) *RouterGroup

+ func (g *RouterGroup) StaticFile(relativePath, filepath string) *RouterGroup

+ func (g *RouterGroup) Use(middleware ...HandlerFunc) *RouterGroup

+ type SDPMessage struct

+ SDP string

+ Type string

+ type SSEClient struct

+ func SSE(c *Context) (*SSEClient, error)

+ func SSEWithConfig(c *Context, config SSEConfig) (*SSEClient, error)

+ func (s *SSEClient) Close()

+ func (s *SSEClient) Done() <-chan bool

+ func (s *SSEClient) IsClosed() bool

+ func (s *SSEClient) Send(event *SSEEvent) error

+ func (s *SSEClient) SendComment(comment string) error

+ func (s *SSEClient) SendData(data string) error

+ func (s *SSEClient) SendEvent(event, data string) error

+ func (s *SSEClient) SendEventWithID(id, event, data string) error

+ type SSEConfig struct

+ KeepAlive bool

+ KeepAliveTime time.Duration

+ RetryInterval int

+ func DefaultSSEConfig() SSEConfig

+ type SSEEvent struct

+ Comment string

+ Data string

+ Event string

+ ID string

+ Retry int

+ type SSEHub struct

+ func NewSSEHub() *SSEHub

+ func (h *SSEHub) Broadcast(event *SSEEvent)

+ func (h *SSEHub) BroadcastData(data string)

+ func (h *SSEHub) BroadcastDataToRoom(room, data string)

+ func (h *SSEHub) BroadcastToRoom(room string, event *SSEEvent)

+ func (h *SSEHub) Count() int

+ func (h *SSEHub) Join(client *SSEClient, room string)

+ func (h *SSEHub) Leave(client *SSEClient, room string)

+ func (h *SSEHub) Register(client *SSEClient)

+ func (h *SSEHub) RoomCount(room string) int

+ func (h *SSEHub) Unregister(client *SSEClient)

+ type ScalarType struct

+ func (s *ScalarType) Description() string

+ func (s *ScalarType) Name() string

+ type Schema struct

+ Mutation *ObjectType

+ Query *ObjectType

+ func NewSchema() *Schema

+ func (s *Schema) SetMutation(mutation *ObjectType)

+ func (s *Schema) SetQuery(query *ObjectType)

+ type Selection struct

+ Alias string

+ Args map[string]any

+ Name string

+ Selections []Selection

+ type SignalMessage struct

+ From string

+ Payload any

+ Room string

+ To string

+ Type SignalType

+ type SignalType string

+ const SignalAnswer

+ const SignalCandidate

+ const SignalJoin

+ const SignalLeave

+ const SignalOffer

+ type SignalingPeer struct

+ Conn *WebSocketConn

+ ID string

+ Room string

+ type SignalingServer struct

+ OnMessage func(msg *SignalMessage)

+ OnPeerJoin func(peer *SignalingPeer)

+ OnPeerLeave func(peer *SignalingPeer)

+ func NewSignalingServer() *SignalingServer

+ func (s *SignalingServer) AddPeer(id string, conn *WebSocketConn) *SignalingPeer

+ func (s *SignalingServer) Broadcast(roomID string, msg *SignalMessage, excludePeerID string)

+ func (s *SignalingServer) GetPeer(id string) *SignalingPeer

+ func (s *SignalingServer) GetRoomPeers(roomID string) []*SignalingPeer

+ func (s *SignalingServer) HandleMessage(peerID string, data []byte) error

+ func (s *SignalingServer) JoinRoom(peerID, roomID string)

+ func (s *SignalingServer) LeaveRoom(peerID string)

+ func (s *SignalingServer) PeerCount() int

+ func (s *SignalingServer) RemovePeer(id string)

+ func (s *SignalingServer) RoomCount() int

+ func (s *SignalingServer) SendTo(peerID string, msg *SignalMessage) error

+ func (s *SignalingServer) WebSocketHandler() *WebSocketHandler

+ type ValidationError struct

+ Field string

+ Message string

+ Tag string

+ Value any

+ func (e *ValidationError) Error() string

+ type ValidationErrors []ValidationError

+ func (e ValidationErrors) Error() string

+ type ValidationFunc func(field reflect.Value, param string) bool

+ type Validator interface

+ Validate func(obj any) error

+ type WebSocketConfig struct

+ MaxMessageSize int64

+ PingPeriod time.Duration

+ PongWait time.Duration

+ ReadBufferSize int

+ WriteBufferSize int

+ func DefaultWebSocketConfig() WebSocketConfig

+ type WebSocketConn struct

+ func (c *WebSocketConn) Close() error

+ func (c *WebSocketConn) CloseWithCode(code int, reason string) error

+ func (c *WebSocketConn) Get(key string) (any, bool)

+ func (c *WebSocketConn) IsClosed() bool

+ func (c *WebSocketConn) LocalAddr() net.Addr

+ func (c *WebSocketConn) Ping(data []byte) error

+ func (c *WebSocketConn) Pong(data []byte) error

+ func (c *WebSocketConn) ReadMessage() (messageType int, data []byte, err error)

+ func (c *WebSocketConn) RemoteAddr() net.Addr

+ func (c *WebSocketConn) Send(message string) error

+ func (c *WebSocketConn) SendBinary(data []byte) error

+ func (c *WebSocketConn) Set(key string, value any)

+ func (c *WebSocketConn) WriteMessage(messageType int, data []byte) error

+ type WebSocketHandler struct

+ OnClose func(conn *WebSocketConn, code int, reason string)

+ OnConnect func(conn *WebSocketConn)

+ OnError func(conn *WebSocketConn, err error)

+ OnMessage func(conn *WebSocketConn, messageType int, data []byte)

+ OnPing func(conn *WebSocketConn, data []byte)

+ OnPong func(conn *WebSocketConn, data []byte)

+ type WebSocketHub struct

+ func NewWebSocketHub() *WebSocketHub

+ func (h *WebSocketHub) Broadcast(message string)

+ func (h *WebSocketHub) BroadcastBinary(data []byte)

+ func (h *WebSocketHub) BroadcastBinaryToRoom(room string, data []byte)

+ func (h *WebSocketHub) BroadcastToRoom(room, message string)

+ func (h *WebSocketHub) Count() int

+ func (h *WebSocketHub) Join(conn *WebSocketConn, room string)

+ func (h *WebSocketHub) Leave(conn *WebSocketConn, room string)

+ func (h *WebSocketHub) Register(conn *WebSocketConn)

+ func (h *WebSocketHub) RoomCount(room string) int

+ func (h *WebSocketHub) Unregister(conn *WebSocketConn)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL