server

package

Go to main page

Versions in this module

v0

v0.2.4

May 24, 2026

v0.2.3

May 24, 2026

v0.2.2

May 23, 2026

v0.2.1

May 14, 2026

v0.2.0

May 12, 2026

Changes in this version

+ const DefaultLivenessPath

+ const DefaultReadinessPath

+ const DevModeRiskAcceptanceV1

+ const HeuristicEventPayloadRiskAcceptanceV1

+ const InsecureModuleOriginsRiskAcceptanceV1

+ const RuntimeLogEventAttr

+ const RuntimeLogEventCatalogSchemaVersion

+ const UnsafeRawHTMLRiskAcceptanceV1

+ func HostedSurfaceProofSignature(secret []byte, method, requestURI string, info surface.Info, ...) string

+ func RuntimeUnsafePermissionsFromContext(ctx context.Context) (vdom.RuntimeUnsafePermissions, bool)

+ func WithRuntimeUnsafePermissions(ctx context.Context, perms vdom.RuntimeUnsafePermissions) context.Context

type Ctx

+ Blur func(id string)

+ BlurHID func(hid string)

+ Focus func(id string)

+ FocusHID func(hid string)

+ type HealthCheck func(r *http.Request) error

+ type HostedSurfaceAllowedSurface struct

+ Kind surface.Kind

+ Platform surface.Platform

+ type HostedSurfaceIdentity struct

+ Surface surface.Info

+ func ParseHostedSurfaceRequestHints(r *http.Request) (*HostedSurfaceIdentity, bool)

+ type HostedSurfaceVerifierConfig struct

+ AllowedOrigins []string

+ AllowedSurfaces []HostedSurfaceAllowedSurface

+ MaxClockSkew time.Duration

+ Now func() time.Time

+ ProofSecret []byte

+ type HostedSurfaceVerifyFunc func(r *http.Request) (*HostedSurfaceIdentity, error)

+ func NewMacOSHostedSurfaceVerifier(cfg HostedSurfaceVerifierConfig) (HostedSurfaceVerifyFunc, error)

+ func NewNativeHostedSurfaceVerifier(cfg HostedSurfaceVerifierConfig) (HostedSurfaceVerifyFunc, error)

+ type RuntimeLogEvent string

+ const RuntimeLogEventDOMEventRateLimited

+ const RuntimeLogEventEventDecodeRejected

+ const RuntimeLogEventEventQueueFull

+ const RuntimeLogEventEventTargetRejected

+ const RuntimeLogEventHookEventRateLimited

+ const RuntimeLogEventHookEventRejected

+ const RuntimeLogEventIslandEventRateLimited

+ const RuntimeLogEventIslandEventRejected

+ const RuntimeLogEventSessionReconnectFailed

+ const RuntimeLogEventSessionResumeAuthIdentityMismatch

+ const RuntimeLogEventSessionResumeAuthInvalid

+ const RuntimeLogEventSessionResumeAuthNotRehydrated

+ const RuntimeLogEventSessionResumeExpired

+ const RuntimeLogEventSessionResumeGuestHookError

+ const RuntimeLogEventSessionResumeHookError

+ const RuntimeLogEventSessionResumeHostedAuthMismatch

+ const RuntimeLogEventSessionResumeHostedAuthNeeded

+ const RuntimeLogEventSessionResumeHostedAuthUnexpected

+ const RuntimeLogEventSessionResumeNoAuthHooks

+ const RuntimeLogEventSessionResumeRebuildFailed

+ const RuntimeLogEventSessionResumeResyncFailed

+ const RuntimeLogEventSessionResumeRouteRemountFailed

+ const RuntimeLogEventSessionResumeSchemaMismatch

+ const RuntimeLogEventSessionResumeSucceeded

+ const RuntimeLogEventSessionResumeTrustSessionID

+ const RuntimeLogEventWasmEventRateLimited

+ const RuntimeLogEventWasmEventRejected

+ const RuntimeLogEventWebsocketHostedSurfaceAuthInvalid

+ type RuntimeLogEventSpec struct

+ Description string

+ Event RuntimeLogEvent

+ Level slog.Level

+ Message string

+ RequiredAttrs []string

+ func RuntimeLogEventCatalog() []RuntimeLogEventSpec

+ func RuntimeLogEventSpecFor(event RuntimeLogEvent) (RuntimeLogEventSpec, bool)

type Server

+ func (s *Server) IsHealthPath(path string) bool

+ func (s *Server) RequestHostAllowed(r *http.Request) bool

+ func (s *Server) UnsafeConfigReport() UnsafeConfigReport

type ServerConfig

+ AllowDevModeInNonLocalEnvironment bool

+ AllowInsecureModuleOriginsInProduction bool

+ DevModeRiskAcceptance string

+ HostedSurfaceTokenSecret []byte

+ HostedSurfaceVerifier HostedSurfaceVerifyFunc

+ InsecureModuleOriginsRiskAcceptance string

+ LivenessCheck HealthCheck

+ LivenessPath string

+ ReadinessCheck HealthCheck

+ ReadinessPath string

+ UnsafeRawHTMLRiskAcceptance string

+ func (c *ServerConfig) UnsafeConfigReport() UnsafeConfigReport

+ func (c *ServerConfig) WithHostedSurfaceTokenSecret(secret []byte) *ServerConfig

+ func (c *ServerConfig) WithHostedSurfaceVerifier(v HostedSurfaceVerifyFunc) *ServerConfig

type Session

+ func (s *Session) RegisterValidatedIslandHandler(id string, validate vango.IslandMessageValidator, ...) func()

+ func (s *Session) RegisterValidatedWasmHandler(id string, validate vango.WasmMessageValidator, ...) func()

type SessionConfig

+ AllowHeuristicEventPayloadsInProduction bool

+ HeuristicEventPayloadRiskAcceptance string

+ type UnsafeConfigCode string

+ const UnsafeConfigCodeDevMode

+ const UnsafeConfigCodeHeuristicEventPayloads

+ const UnsafeConfigCodeInsecureModuleOrigins

+ const UnsafeConfigCodeTrustSessionID

+ const UnsafeConfigCodeUnsafeRawHTML

+ type UnsafeConfigEntry struct

+ Code UnsafeConfigCode

+ Detail string

+ Severity UnsafeConfigSeverity

+ State UnsafeConfigState

+ Summary string

+ type UnsafeConfigReport struct

+ Entries []UnsafeConfigEntry

+ func (r UnsafeConfigReport) Empty() bool

+ type UnsafeConfigSeverity string

+ const UnsafeConfigSeverityCritical

+ const UnsafeConfigSeverityHigh

+ const UnsafeConfigSeverityModerate

+ type UnsafeConfigState string

+ const UnsafeConfigStateActive

+ const UnsafeConfigStatePermission

v0.1.0

Apr 2, 2026

Changes in this version

+ func ThinClientHash() string

+ func UserFromContextAs[T any](ctx context.Context) (T, bool)

type FormData

+ func (f FormData) GetAll(key string) []string

type SessionConfig

+ InitialMountResourcePreload bool

+ InitialMountResourceTimeout time.Duration

v0.0.3

Mar 10, 2026

Changes in this version

+ func BootstrapConfigFromContext(ctx context.Context) (bootstrap.Config, bool)

+ func ShellBridgeFromContext(ctx context.Context) shell.Bridge

+ func SurfaceInfoFromContext(ctx context.Context) surface.Info

+ func WithBootstrapConfig(ctx context.Context, cfg bootstrap.Config) context.Context

+ func WithShellBridge(ctx context.Context, bridge shell.Bridge) context.Context

+ func WithSurfaceInfo(ctx context.Context, info surface.Info) context.Context

type Ctx

+ Shell func() shell.Bridge

+ Surface func() surface.Info

type Server

+ func (s *Server) RuntimeBootstrap(r *http.Request) bootstrap.Config

type ServerConfig

+ PublicRuntimePrefix string

+ func (c *ServerConfig) WithPublicRuntimePrefix(prefix string) *ServerConfig

type Session

+ func (s *Session) CurrentRoutePath() string

+ func (s *Session) SetShellBridge(bridge shell.Bridge)

+ func (s *Session) SetSurfaceInfo(info surface.Info)

+ func (s *Session) ShellBridge() shell.Bridge

+ func (s *Session) SurfaceInfo() surface.Info

v0.0.2

Mar 6, 2026

Changes in this version

+ const TrustSessionIDRiskAcceptanceV1

type ServerConfig

+ AllowUnsafeRawHTMLInProduction bool

+ TrustSessionIDRiskAcceptance string

type Session

+ func (s *Session) SendIslandMessageToHID(hid string, payload any) error

+ func (s *Session) SendWasmMessageToHID(hid string, payload any) error

+ func (s *Session) SetUserID(id string)

type SessionConfig

+ EventHIDMaxBytes int

v0.0.1

Feb 24, 2026

Changes in this version

+ const CSPHeaderName

+ const CSPReportOnlyHeaderName

+ const CSRFCookieName

+ const CSRFHeaderName

+ const DefaultAuthSessionKey

+ var ErrAuthCheckPanicked = errors.New("server: auth check panicked")

+ var ErrConnectionClosed = errors.New("server: connection closed")

+ var ErrEventQueueFull = errors.New("server: event queue full")

+ var ErrForbidden = auth.ErrForbidden

+ var ErrHandlerNotFound = errors.New("server: handler not found")

+ var ErrInvalidCSRF = errors.New("server: invalid CSRF token")

+ var ErrInvalidHandshake = errors.New("server: invalid handshake")

+ var ErrMaxSessionsReached = errors.New("server: max sessions reached")

+ var ErrNoConnection = errors.New("server: no connection")

+ var ErrReadTimeout = errors.New("server: read timeout")

+ var ErrSecureCookiesRequired = errors.New("server: secure cookies require HTTPS or trusted proxy headers")

+ var ErrSessionClosed = errors.New("server: session closed")

+ var ErrSessionExpired = errors.New("server: session expired")

+ var ErrSessionNotFound = errors.New("server: session not found")

+ var ErrTooManyConcurrentHandshakes = errors.New("server: too many concurrent handshakes")

+ var ErrTooManyConcurrentHandshakesFromIP = errors.New("server: too many concurrent handshakes from this IP address")

+ var ErrTooManySessionsFromIP = errors.New("server: too many sessions from this IP address")

+ var ErrUnauthorized = auth.ErrUnauthorized

+ var ErrWriteTimeout = errors.New("server: write timeout")

+ func AllowAllOriginsCheck(*http.Request) bool

+ func AllowedOriginsCheck(allowedOrigins []string) func(*http.Request) bool

+ func BuildCSP(opts CSPOptions) string

+ func CSRFCtxToken(ctx Ctx) string

+ func CanonicalizePath(path string) (canonPath, query string, changed bool, err error)

+ func CurrentMemoryUsage() int64

+ func EstimateAnyMemory(value any) int64

+ func EstimateMapMemory(length, keySize, valueSize int) int64

+ func EstimateSliceMemory(length, elementSize int) int64

+ func EstimateStringMemory(s string) int64

+ func InspectState(session *Session) vruntime.StateInspection

+ func IsAuthError(err error) bool

+ func LoggerForEvent(ctx Ctx, base *slog.Logger) *slog.Logger

+ func NormalizeAuthCheckConfig(cfg *AuthCheckConfig)

+ func RunRouteMiddleware(ctx Ctx, middleware []RouteMiddleware, final func() error) (ranFinal bool, err error)

+ func SameOriginCheck(r *http.Request) bool

+ func SetCSRFCtxToken(ctx Ctx, token string)

+ func SetGlobalPrefetchLimit(limit int)

+ func TotalSystemMemory() int64

+ func UserFromContext(ctx context.Context) any

+ func ValidateExternalRedirectURL(rawURL string, allowedHosts []string) (string, bool)

+ func WithUser(ctx context.Context, user any) context.Context

+ type AppliedNavigateOptions struct

+ Params map[string]any

+ Replace bool

+ Scroll bool

+ func ApplyNavigateOptions(opts ...NavigateOption) AppliedNavigateOptions

+ func BuildNavigateURL(path string, opts ...NavigateOption) (fullPath string, applied AppliedNavigateOptions)

+ type AuthCheckConfig struct

+ Check func(ctx context.Context, p auth.Principal) error

+ FailureMode AuthFailureMode

+ Interval time.Duration

+ MaxStale time.Duration

+ OnExpired AuthExpiredConfig

+ Timeout time.Duration

+ type AuthExpiredAction int

+ const Custom

+ const ForceReload

+ const NavigateTo

+ type AuthExpiredConfig struct

+ Action AuthExpiredAction

+ Handler func(s *Session)

+ Path string

+ Reason AuthExpiredReason

+ type AuthExpiredReason int

+ const AuthExpiredActiveRevalidateFailed

+ const AuthExpiredNoRevalidationHooks

+ const AuthExpiredOnDemandRevalidateFailed

+ const AuthExpiredPassiveExpiry

+ const AuthExpiredResumeIdentityMismatch

+ const AuthExpiredResumeRehydrateFailed

+ const AuthExpiredUnknown

+ func (r AuthExpiredReason) String() string

+ type AuthFailureMode int

+ const FailClosed

+ const FailOpenWithGrace

+ type AuthResumePolicy int

+ const AuthResumePolicyStrict

+ const AuthResumePolicyTrustSessionID

+ func (p AuthResumePolicy) IsValid() bool

+ func (p AuthResumePolicy) String() string

+ type BudgetExceededMode int

+ const BudgetThrottle

+ const BudgetTripBreaker

+ type ByteSize int64

+ const GB

+ const KB

+ const MB

+ const TB

+ func (b ByteSize) String() string

+ type CSPOptions struct

+ AdditionalConnectSrc []string

+ AdditionalDirectives []string

+ AdditionalFontSrc []string

+ AdditionalImgSrc []string

+ AdditionalScriptSrc []string

+ AdditionalStyleSrc []string

+ AllowDataImages bool

+ AllowHTTPSImages bool

+ AllowInlineScripts bool

+ AllowInlineStyles bool

+ IncludeWS bool

+ IncludeWSS bool

+ ReportOnly bool

+ func DefaultCSPOptions() CSPOptions

+ func HardenedCSPOptions() CSPOptions

+ type CSRFError struct

+ Reason string

+ func (e CSRFError) Error() string

+ func (e CSRFError) StatusCode() int

+ type Component interface

+ Render func() *vdom.VNode

+ type ComponentInstance struct

+ Children []*ComponentInstance

+ Component Component

+ HID string

+ InstanceID string

+ Owner *vango.Owner

+ Parent *ComponentInstance

+ Props map[string]any

+ func (c *ComponentInstance) AddChild(child *ComponentInstance)

+ func (c *ComponentInstance) ClearDirty()

+ func (c *ComponentInstance) Dispose()

+ func (c *ComponentInstance) GetProp(key string) any

+ func (c *ComponentInstance) ID() uint64

+ func (c *ComponentInstance) IsDirty() bool

+ func (c *ComponentInstance) LastTree() *vdom.VNode

+ func (c *ComponentInstance) ListKeyPath() []string

+ func (c *ComponentInstance) MarkDirty()

+ func (c *ComponentInstance) MemoryUsage() int64

+ func (c *ComponentInstance) RemoveChild(child *ComponentInstance)

+ func (c *ComponentInstance) Render() *vdom.VNode

+ func (c *ComponentInstance) Session() *Session

+ func (c *ComponentInstance) SetLastTree(tree *vdom.VNode)

+ func (c *ComponentInstance) SetProp(key string, value any)

+ func (c *ComponentInstance) TrackDependency(dep vango.Dependency)

+ type CookieOption func(*CookiePolicyOptions)

+ func WithCookieHTTPOnly(enabled bool) CookieOption

+ type CookiePolicy struct

+ func (p *CookiePolicy) Apply(r *http.Request, cookie *http.Cookie, opts ...CookieOption) (*http.Cookie, error)

+ func (p *CookiePolicy) ApplyCookiePolicy(r *http.Request, cookie *http.Cookie) (*http.Cookie, error)

+ func (p *CookiePolicy) IsRequestSecure(r *http.Request) bool

+ type CookiePolicyOptions struct

+ type Ctx interface

+ AddPatchCount func(count int)

+ Asset func(source string) string

+ AuthSession func() auth.Session

+ BroadcastAuthLogout func()

+ Cookie func(name string) (*http.Cookie, error)

+ Dispatch func(fn func())

+ Done func() <-chan struct{}

+ Emit func(name string, data any)

+ Event func() *Event

+ Header func(key string) string

+ Logger func() *slog.Logger

+ Method func() string

+ Mode func() int

+ MustPrincipal func() auth.Principal

+ Navigate func(path string, opts ...NavigateOption)

+ Param func(key string) string

+ PatchCount func() int

+ Path func() string

+ Principal func() (auth.Principal, bool)

+ Query func() url.Values

+ QueryParam func(key string) string

+ Redirect func(url string, code int)

+ RedirectExternal func(url string, code int)

+ Request func() *http.Request

+ RevalidateAuth func() error

+ Session func() vango.Session

+ SetCookie func(cookie *http.Cookie)

+ SetCookieStrict func(cookie *http.Cookie, opts ...CookieOption) error

+ SetHeader func(key, value string)

+ SetUser func(user any)

+ SetValue func(key, value any)

+ Status func(code int)

+ StdContext func() context.Context

+ StormBudget func() vango.StormBudgetChecker

+ User func() any

+ Value func(key any) any

+ WithStdContext func(stdCtx context.Context) Ctx

+ func NewTestContext(s *Session) Ctx

+ func NewTestContextWithDebug(s *Session, debugMode bool) Ctx

+ type Event struct

+ HID string

+ Payload any

+ Seq uint64

+ Session *Session

+ Time time.Time

+ Type protocol.EventType

+ func (e *Event) TypeString() string

+ type EventRateLimiter struct

+ func (r *EventRateLimiter) Allow() bool

+ type FormData struct

+ func (f FormData) All() map[string]string

+ func (f FormData) Get(key string) string

+ func (f FormData) Has(key string) bool

+ type FuncComponent func() *vdom.VNode

+ func (f FuncComponent) Render() *vdom.VNode

+ type Handler func(event *Event)

+ type HandlerError struct

+ EventType string

+ HID string

+ Panic any

+ SessionID string

+ Stack []byte

+ func NewHandlerError(sessionID, hid, eventType string, panicVal any, stack []byte) *HandlerError

+ func (e *HandlerError) Error() string

+ type HookEvent struct

+ Data map[string]any

+ Name string

+ func (h HookEvent) Get(key string) any

+ func (h HookEvent) GetBool(key string) bool

+ func (h HookEvent) GetInt(key string) int

+ func (h HookEvent) GetString(key string) string

+ type InstancePath struct

+ KeyPath []string

+ RouteID string

+ StableID string

+ func ComputeInstancePath(session *Session, component *ComponentInstance, stableID string) InstancePath

+ func (p InstancePath) String() string

+ type KeyboardEvent struct

+ AltKey bool

+ CtrlKey bool

+ Key string

+ MetaKey bool

+ ShiftKey bool

+ type LayoutHandler func(ctx Ctx, children vango.Slot) *vdom.VNode

+ type ManagerStats struct

+ Active int

+ Peak int

+ TotalClosed uint64

+ TotalCreated uint64

+ TotalMemory int64

+ type MemoryMonitor struct

+ func NewMemoryMonitor(config *MemoryMonitorConfig) *MemoryMonitor

+ func (m *MemoryMonitor) ForceCheck()

+ func (m *MemoryMonitor) Pause()

+ func (m *MemoryMonitor) Resume()

+ func (m *MemoryMonitor) SetOnHardLimit(fn func(current, limit int64))

+ func (m *MemoryMonitor) SetOnSoftLimit(fn func(current, limit int64))

+ func (m *MemoryMonitor) Start()

+ func (m *MemoryMonitor) Stop()

+ type MemoryMonitorConfig struct

+ CheckInterval time.Duration

+ GCCooldown time.Duration

+ HardLimit int64

+ SoftLimit int64

+ func DefaultMemoryMonitorConfig() *MemoryMonitorConfig

+ type MemoryPressureLevel int

+ const MemoryPressureCritical

+ const MemoryPressureHigh

+ const MemoryPressureLow

+ const MemoryPressureNone

+ func GetMemoryPressureLevel(softLimit, hardLimit int64) MemoryPressureLevel

+ func (l MemoryPressureLevel) String() string

+ type MemoryStats struct

+ GCPauseTotal time.Duration

+ HeapAlloc int64

+ HeapIdle int64

+ HeapInuse int64

+ HeapReleased int64

+ HeapSys int64

+ LastGC time.Time

+ NumGC uint32

+ StackInuse int64

+ func GetMemoryStats() *MemoryStats

+ type MetricsCollector struct

+ func NewMetricsCollector() *MetricsCollector

+ func (m *MetricsCollector) RecordActionDuration(action string, ms int64)

+ func (m *MetricsCollector) RecordActionError(action string)

+ func (m *MetricsCollector) RecordBytesReceived(n int)

+ func (m *MetricsCollector) RecordBytesSent(n int)

+ func (m *MetricsCollector) RecordColdDeployAck(source string)

+ func (m *MetricsCollector) RecordEventDropped()

+ func (m *MetricsCollector) RecordEventLatency(latencyUs int64)

+ func (m *MetricsCollector) RecordEventProcessed()

+ func (m *MetricsCollector) RecordEventReceived()

+ func (m *MetricsCollector) RecordHandlerPanic()

+ func (m *MetricsCollector) RecordPatchBytes(route string, bytes int)

+ func (m *MetricsCollector) RecordPatchMismatch(reason string)

+ func (m *MetricsCollector) RecordPatchesSent(count int, bytes int)

+ func (m *MetricsCollector) RecordPersistBytes(stableID string, bytes int64)

+ func (m *MetricsCollector) RecordPersistBytesWritten(primitiveID string, bytes int64)

+ func (m *MetricsCollector) RecordPersistWriteRejected(reason string, primitiveID string)

+ func (m *MetricsCollector) RecordReadError()

+ func (m *MetricsCollector) RecordResourceDuration(resource string, ms int64)

+ func (m *MetricsCollector) RecordResourceError(resource string)

+ func (m *MetricsCollector) RecordResumeFailure(reason string)

+ func (m *MetricsCollector) RecordResumeSuccess()

+ func (m *MetricsCollector) RecordSchemaMismatch(reason string)

+ func (m *MetricsCollector) RecordSessionActive(delta int)

+ func (m *MetricsCollector) RecordSessionDetached(delta int)

+ func (m *MetricsCollector) RecordSessionPersistBytes(sessionID string, bytes int64)

+ func (m *MetricsCollector) RecordSignalWriteViolation(operation, reason string)

+ func (m *MetricsCollector) RecordWriteError()

+ func (m *MetricsCollector) Reset()

+ func (m *MetricsCollector) Snapshot() *ServerMetrics

+ type Middleware func(http.Handler) http.Handler

+ func CSPHeaderMiddleware(policy string, reportOnly bool) Middleware

+ func CSPMiddleware(opts CSPOptions) Middleware

+ type MouseEvent struct

+ AltKey bool

+ Button int

+ ClientX int

+ ClientY int

+ CtrlKey bool

+ MetaKey bool

+ ShiftKey bool

+ type NavigateEvent struct

+ Path string

+ Replace bool

+ type NavigateOption func(*navigateOptions)

+ func WithNavigateParams(params map[string]any) NavigateOption

+ func WithReplace() NavigateOption

+ func WithoutScroll() NavigateOption

+ type NavigateResult struct

+ Error error

+ Matched bool

+ NavPatch protocol.Patch

+ Patches []vdom.Patch

+ Path string

+ type OriginPolicyMode int

+ const OriginPolicyAllowAll

+ const OriginPolicyAllowedOrigins

+ const OriginPolicyCustom

+ const OriginPolicySameOrigin

+ const OriginPolicyUnset

+ type PageHandler func(ctx Ctx, params any) Component

+ type PatchHistory struct

+ func NewPatchHistory(capacity int) *PatchHistory

+ func (h *PatchHistory) Add(seq uint64, frame []byte)

+ func (h *PatchHistory) CanRecover(lastSeq uint64) bool

+ func (h *PatchHistory) Clear()

+ func (h *PatchHistory) Count() int

+ func (h *PatchHistory) GarbageCollect(ackSeq uint64)

+ func (h *PatchHistory) GetFrames(afterSeq, toSeq uint64) [][]byte

+ func (h *PatchHistory) MaxSeq() uint64

+ func (h *PatchHistory) MemoryUsage() int64

+ func (h *PatchHistory) MinSeq() uint64

+ type PatchHistoryEntry struct

+ Frame []byte

+ SentAt time.Time

+ Seq uint64

+ type PrefetchCache struct

+ func NewPrefetchCache(config *PrefetchConfig) *PrefetchCache

+ func (c *PrefetchCache) Clear()

+ func (c *PrefetchCache) Delete(path string)

+ func (c *PrefetchCache) Get(path string) *PrefetchCacheEntry

+ func (c *PrefetchCache) Len() int

+ func (c *PrefetchCache) MemoryUsage() int64

+ func (c *PrefetchCache) Set(path string, tree *vdom.VNode)

+ type PrefetchCacheEntry struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ Tree *vdom.VNode

+ func (e *PrefetchCacheEntry) IsExpired() bool

+ type PrefetchConfig struct

+ GlobalConcurrency int

+ MaxEntries int

+ RateLimit float64

+ SessionConcurrency int

+ TTL time.Duration

+ Timeout time.Duration

+ func DefaultPrefetchConfig() *PrefetchConfig

+ type PrefetchRateLimiter struct

+ func NewPrefetchRateLimiter(ratePerSecond float64) *PrefetchRateLimiter

+ func (r *PrefetchRateLimiter) Allow() bool

+ type PrefetchSemaphore struct

+ func GlobalPrefetchSemaphore() *PrefetchSemaphore

+ func NewPrefetchSemaphore(limit int) *PrefetchSemaphore

+ func (s *PrefetchSemaphore) Acquire() bool

+ func (s *PrefetchSemaphore) Release()

+ type PrimitiveInfo struct

+ AnchorKey string

+ Class string

+ DebugName string

+ InstancePath string

+ Kind string

+ Persisted bool

+ Primitive any

+ StableID string

+ type ProtocolError struct

+ Message string

+ Op string

+ SessionID string

+ func NewProtocolError(sessionID, op, message string) *ProtocolError

+ func (e *ProtocolError) Error() string

+ type ReconnectConfig struct

+ BaseDelay int

+ MaxDelay int

+ MaxRetries int

+ ToastMessage string

+ ToastOnReconnect bool

+ func DefaultReconnectConfig() *ReconnectConfig

+ type RenderMode int

+ const ModeNormal

+ const ModePrefetch

+ func (m RenderMode) String() string

+ type ResizeEvent struct

+ Height int

+ Width int

+ type RouteMatch interface

+ GetLayoutHandlers func() []LayoutHandler

+ GetMiddleware func() []RouteMiddleware

+ GetPageHandler func() PageHandler

+ GetParams func() map[string]string

+ type RouteMiddleware interface

+ Handle func(ctx Ctx, next func() error) error

+ type RouteNavigator struct

+ func NewRouteNavigator(session *Session, r Router) *RouteNavigator

+ func (rn *RouteNavigator) CurrentParams() map[string]string

+ func (rn *RouteNavigator) CurrentPath() string

+ func (rn *RouteNavigator) Navigate(path string, replace bool) *NavigateResult

+ type Router interface

+ Match func(method, path string) (RouteMatch, bool)

+ NotFound func() PageHandler

+ type SchemaError struct

+ IsCold bool

+ Message string

+ Reason string

+ Reasons []string

+ SchemaHash string

+ SchemaVersion uint16

+ func (e *SchemaError) Error() string

+ type ScrollEvent struct

+ ScrollLeft int

+ ScrollTop int

+ type Server struct

+ func MustNew(config *ServerConfig) *Server

+ func New(config *ServerConfig) (*Server, error)

+ func (s *Server) CSRFMiddleware() Middleware

+ func (s *Server) Config() *ServerConfig

+ func (s *Server) CookiePolicy() *CookiePolicy

+ func (s *Server) EnsureCSRFCookie(w http.ResponseWriter, r *http.Request) (string, error)

+ func (s *Server) GenerateCSRFToken() string

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

+ func (s *Server) Handler() http.Handler

+ func (s *Server) Logger() *slog.Logger

+ func (s *Server) Metrics() *ServerMetrics

+ func (s *Server) PageHandler() http.Handler

+ func (s *Server) Router() Router

+ func (s *Server) Run() error

+ func (s *Server) RunContext(ctx context.Context) error

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

+ func (s *Server) Sessions() *SessionManager

+ func (s *Server) SetAuthFunc(fn func(*http.Request) (any, error))

+ func (s *Server) SetCSRFCookie(w http.ResponseWriter, r *http.Request, token string) error

+ func (s *Server) SetHandler(h http.Handler)

+ func (s *Server) SetLogger(logger *slog.Logger)

+ func (s *Server) SetMetricsSink(sink vango.MetricsSink)

+ func (s *Server) SetRootComponent(factory func() Component)

+ func (s *Server) SetRouter(r Router)

+ func (s *Server) Shutdown(ctx context.Context) error

+ func (s *Server) UploadHandler(store upload.Store, config *upload.Config) http.Handler

+ func (s *Server) Use(mw Middleware)

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

+ func (s *Server) WebSocketHandler() http.Handler

+ func (s *Server) WebSocketURL(r *http.Request) string

+ type ServerConfig struct

+ Address string

+ AllowCustomOriginPolicy bool

+ AllowSameOrigin bool

+ AllowTrustSessionIDInProduction bool

+ AllowedHosts []string

+ AllowedOrigins []string

+ AllowedRedirectHosts []string

+ AssetResolver assets.Resolver

+ AuthResumePolicy AuthResumePolicy

+ CSRFEnabled bool

+ CSRFSecret []byte

+ CanonicalHost string

+ CheckOrigin func(r *http.Request) bool

+ CleanupInterval time.Duration

+ CookieDomain string

+ CookieHTTPOnly bool

+ DebugMode bool

+ DevMode bool

+ EvictOnIPLimit bool

+ EvictionPolicy SessionEvictionPolicy

+ GlobalSignalPubSub corevango.GlobalBroadcastBackend

+ GlobalSignalRefreshInterval time.Duration

+ IdleTimeout time.Duration

+ MaxConcurrentHandshakes int

+ MaxConcurrentHandshakesPerIP int

+ MaxDetachedSessions int

+ MaxMemoryPerSession int64

+ MaxSessions int

+ MaxSessionsPerIP int

+ OnSessionResume func(httpCtx context.Context, session *Session) error

+ OnSessionStart func(httpCtx context.Context, session *Session)

+ OriginPolicy OriginPolicyMode

+ PersistInterval time.Duration

+ PreUpgradeCheck func(r *http.Request) error

+ ReadBufferSize int

+ ReadHeaderTimeout time.Duration

+ ReadTimeout time.Duration

+ ReconnectConfig *ReconnectConfig

+ ResumeWindow time.Duration

+ SameSiteMode http.SameSite

+ SecureCookies bool

+ SessionConfig *SessionConfig

+ SessionLimits *SessionLimits

+ SessionStore session.SessionStore

+ ShutdownTimeout time.Duration

+ TrustedProxies []string

+ WriteBufferSize int

+ WriteTimeout time.Duration

+ func DefaultServerConfig() *ServerConfig

+ func (c *ServerConfig) Clone() *ServerConfig

+ func (c *ServerConfig) EnableToastOnReconnect(message string) *ServerConfig

+ func (c *ServerConfig) GetConfigWarnings() []string

+ func (c *ServerConfig) IsSecure() bool

+ func (c *ServerConfig) ValidateConfig() error

+ func (c *ServerConfig) WithAddress(addr string) *ServerConfig

+ func (c *ServerConfig) WithAllowedHosts(hosts ...string) *ServerConfig

+ func (c *ServerConfig) WithAllowedOrigins(origins ...string) *ServerConfig

+ func (c *ServerConfig) WithCSRFSecret(secret []byte) *ServerConfig

+ func (c *ServerConfig) WithCanonicalHost(host string) *ServerConfig

+ func (c *ServerConfig) WithCookieDomain(domain string) *ServerConfig

+ func (c *ServerConfig) WithCookieHTTPOnly(httpOnly bool) *ServerConfig

+ func (c *ServerConfig) WithDevMode() *ServerConfig

+ func (c *ServerConfig) WithEvictOnIPLimit(evict bool) *ServerConfig

+ func (c *ServerConfig) WithEvictionPolicy(policy SessionEvictionPolicy) *ServerConfig

+ func (c *ServerConfig) WithMaxConcurrentHandshakes(max int) *ServerConfig

+ func (c *ServerConfig) WithMaxConcurrentHandshakesPerIP(max int) *ServerConfig

+ func (c *ServerConfig) WithMaxDetachedSessions(max int) *ServerConfig

+ func (c *ServerConfig) WithMaxSessions(max int) *ServerConfig

+ func (c *ServerConfig) WithMaxSessionsPerIP(max int) *ServerConfig

+ func (c *ServerConfig) WithPersistInterval(d time.Duration) *ServerConfig

+ func (c *ServerConfig) WithPreUpgradeCheck(check func(r *http.Request) error) *ServerConfig

+ func (c *ServerConfig) WithReconnectConfig(rc *ReconnectConfig) *ServerConfig

+ func (c *ServerConfig) WithResumeWindow(d time.Duration) *ServerConfig

+ func (c *ServerConfig) WithSameSiteMode(mode http.SameSite) *ServerConfig

+ func (c *ServerConfig) WithSecureCookies(secure bool) *ServerConfig

+ func (c *ServerConfig) WithSessionConfig(sc *SessionConfig) *ServerConfig

+ func (c *ServerConfig) WithSessionStore(store session.SessionStore) *ServerConfig

+ type ServerMetrics struct

+ ActiveSessions int64

+ BytesReceived int64

+ BytesSent int64

+ CollectedAt time.Time

+ EventLatencyP50 int64

+ EventLatencyP99 int64

+ EventsDropped int64

+ EventsProcessed int64

+ EventsReceived int64

+ HandlerPanics int64

+ PatchBytes int64

+ PatchesSent int64

+ PeakSessions int64

+ PersistBytesTotal int64

+ PersistWriteRejectedTotal int64

+ ReadErrors int64

+ SchemaMismatchTotal int64

+ SessionCloses int64

+ SessionCreates int64

+ SignalWriteViolationTotal int64

+ TotalMemory int64

+ TotalSessions int64

+ WriteErrors int64

+ type Session struct

+ CreatedAt time.Time

+ CurrentRoute string

+ DetachedAt time.Time

+ ID string

+ IP string

+ LastActive time.Time

+ UserID string

+ func NewMockSession() *Session

+ func (s *Session) BroadcastAuth(channel, typ string, reason AuthExpiredReason)

+ func (s *Session) BudgetTracker() *vango.BudgetTracker

+ func (s *Session) BytesReceived(n int)

+ func (s *Session) Close()

+ func (s *Session) Config() *SessionConfig

+ func (s *Session) Conn() *websocket.Conn

+ func (s *Session) Delete(key string)

+ func (s *Session) Deserialize(data []byte) error

+ func (s *Session) DeserializeForSessionID(expectedSessionID string, data []byte) error

+ func (s *Session) Dispatch(fn func())

+ func (s *Session) Done() <-chan struct{}

+ func (s *Session) EventLoop()

+ func (s *Session) Events() <-chan *Event

+ func (s *Session) Get(key string) any

+ func (s *Session) GetAllData() map[string]any

+ func (s *Session) GetInt(key string) int

+ func (s *Session) GetString(key string) string

+ func (s *Session) HandleNavigate(path string, replace bool) error

+ func (s *Session) Has(key string) bool

+ func (s *Session) IsClosed() bool

+ func (s *Session) IsDetached() bool

+ func (s *Session) Logger() *slog.Logger

+ func (s *Session) MemoryUsage() int64

+ func (s *Session) MountRoot(component Component)

+ func (s *Session) Navigator() *RouteNavigator

+ func (s *Session) NeedsRestart() bool

+ func (s *Session) Owner() *vango.Owner

+ func (s *Session) PersistErrorHandler() func(*vango.PersistBudgetError)

+ func (s *Session) PrefetchCache() *PrefetchCache

+ func (s *Session) PrimitiveRegistry() *SessionPrimitiveRegistry

+ func (s *Session) QueueEvent(event *Event) error

+ func (s *Session) ReadLoop()

+ func (s *Session) RebuildHandlers() error

+ func (s *Session) RegisterIslandHandler(id string, handler vango.IslandMessageHandler) func()

+ func (s *Session) RegisterPrimitives(regs []vango.PrimitiveRegistration, component *ComponentInstance)

+ func (s *Session) RegisterWasmHandler(id string, handler vango.WasmMessageHandler) func()

+ func (s *Session) RestoreData(values map[string]any)

+ func (s *Session) Resume(conn *websocket.Conn, lastSeq uint64)

+ func (s *Session) RouteID() string

+ func (s *Session) SendClose(reason protocol.CloseReason, message string)

+ func (s *Session) SendHookRevert(hid string)

+ func (s *Session) SendIslandMessage(id string, payload any) error

+ func (s *Session) SendPatches(patches []protocol.Patch)

+ func (s *Session) SendResyncFull() error

+ func (s *Session) SendSessionRefresh(cmd *protocol.SessionRefreshCommand)

+ func (s *Session) SendWasmMessage(id string, payload any) error

+ func (s *Session) Serialize() ([]byte, error)

+ func (s *Session) SessionID() string

+ func (s *Session) Set(key string, value any)

+ func (s *Session) SetAssetResolver(r assets.Resolver)

+ func (s *Session) SetInitialURL(path string, params map[string]string)

+ func (s *Session) SetInt(key string, value int)

+ func (s *Session) SetJSON(key string, value any)

+ func (s *Session) SetPersistErrorHandler(fn func(*vango.PersistBudgetError))

+ func (s *Session) SetRouter(r Router)

+ func (s *Session) SetString(key string, value string)

+ func (s *Session) ShowPersistErrorBanner(err *vango.PersistBudgetError)

+ func (s *Session) Start()

+ func (s *Session) Stats() SessionStats

+ func (s *Session) StormBudget() vango.StormBudgetChecker

+ func (s *Session) TriggerSchemaRefresh(reason protocol.SchemaRefreshReason, debug string)

+ func (s *Session) UnregisterPrimitives(regs []vango.PrimitiveRegistration, component *ComponentInstance)

+ func (s *Session) UpdateLastActive()

+ func (s *Session) WriteLoop()

+ type SessionConfig struct

+ AllowRawHTMLInEventPayloads bool

+ AuthCheck *AuthCheckConfig

+ DOMEventRateLimit *corevango.EventRateLimitConfig

+ DebugMode bool

+ EnableCompression bool

+ EnableOptimistic bool

+ EventMiddleware []RouteMiddleware

+ EvictionPolicy SessionEvictionPolicy

+ HandshakeTimeout time.Duration

+ HeartbeatInterval time.Duration

+ HookEventMaxNameBytes int

+ HookEventMaxPayloadBytes int

+ HookEventRateLimit *corevango.EventRateLimitConfig

+ HookEventValidator corevango.HookEventValidator

+ IdleTimeout time.Duration

+ IslandEventMaxIDBytes int

+ IslandEventMaxJSONDepth int

+ IslandEventMaxPayloadBytes int

+ IslandEventMaxWrapperBytes int

+ IslandEventRateLimit *corevango.EventRateLimitConfig

+ IslandMessageValidator corevango.IslandMessageValidator

+ MaxBlobAgeMs int64

+ MaxDetachedSessions int

+ MaxDispatchQueue int

+ MaxEventQueue int

+ MaxHandshakePathBytes int

+ MaxMessageSize int64

+ MaxPatchHistory int

+ Metrics corevango.MetricsSink

+ Observability corevango.ObservabilityConfig

+ PersistenceSecret []byte

+ PersistenceSecretPrevious []byte

+ ReadTimeout time.Duration

+ ResyncRateLimitConfig *corevango.EventRateLimitConfig

+ StateBudget *corevango.StateBudgetConfig

+ StormBudget *StormBudgetConfig

+ URLPolicy vdom.URLPolicy

+ WasmEventMaxIDBytes int

+ WasmEventMaxJSONDepth int

+ WasmEventMaxPayloadBytes int

+ WasmEventMaxWrapperBytes int

+ WasmEventRateLimit *corevango.EventRateLimitConfig

+ WasmMessageValidator corevango.WasmMessageValidator

+ WriteTimeout time.Duration

+ func DefaultSessionConfig() *SessionConfig

+ func (c *SessionConfig) Clone() *SessionConfig

+ type SessionError struct

+ Err error

+ Op string

+ SessionID string

+ func NewSessionError(sessionID, op string, err error) *SessionError

+ func (e *SessionError) Error() string

+ func (e *SessionError) Unwrap() error

+ type SessionEvictionPolicy int

+ const EvictionLRU

+ const EvictionOldest

+ const EvictionRandom

+ type SessionLimits struct

+ MaxMemoryPerSession int64

+ MaxSessions int

+ MaxTotalMemory int64

+ func DefaultSessionLimits() *SessionLimits

+ type SessionManager struct

+ func NewSessionManager(config *SessionConfig, limits *SessionLimits, logger *slog.Logger) *SessionManager

+ func NewSessionManagerWithOptions(config *SessionConfig, limits *SessionLimits, logger *slog.Logger, ...) *SessionManager

+ func (sm *SessionManager) CheckIPLimit(ip string) error

+ func (sm *SessionManager) CheckMemoryPressure()

+ func (sm *SessionManager) Close(id string)

+ func (sm *SessionManager) Count() int

+ func (sm *SessionManager) Create(conn *websocket.Conn, userID, ip string) (*Session, error)

+ func (sm *SessionManager) DispatchAll(fn func(*Session))

+ func (sm *SessionManager) EvictLRU(count int) int

+ func (sm *SessionManager) ForEach(fn func(*Session) bool)

+ func (sm *SessionManager) Get(id string) *Session

+ func (sm *SessionManager) HasPersistence() bool

+ func (sm *SessionManager) MarkResumed(sessionID string)

+ func (sm *SessionManager) OnSessionDisconnect(sess *Session)

+ func (sm *SessionManager) OnSessionReconnect(sessionID string) (*Session, error)

+ func (sm *SessionManager) PersistenceManager() *session.Manager

+ func (sm *SessionManager) ResumeWindow() time.Duration

+ func (sm *SessionManager) SetBudgetTracker(tracker *vango.BudgetTracker)

+ func (sm *SessionManager) SetCleanupInterval(d time.Duration)

+ func (sm *SessionManager) SetMetricsSink(sink vango.MetricsSink)

+ func (sm *SessionManager) SetOnSessionClose(fn func(*Session))

+ func (sm *SessionManager) SetOnSessionCreate(fn func(*Session))

+ func (sm *SessionManager) Shutdown()

+ func (sm *SessionManager) ShutdownWithContext(ctx context.Context) error

+ func (sm *SessionManager) Stats() ManagerStats

+ func (sm *SessionManager) TotalMemoryUsage() int64

+ func (sm *SessionManager) UpdateSessionIP(session *Session, newIP string) error

+ type SessionManagerOptions struct

+ EvictOnIPLimit bool

+ EvictionPolicy SessionEvictionPolicy

+ GlobalSignalPubSub vango.GlobalBroadcastBackend

+ GlobalSignalRefreshInterval time.Duration

+ MaxDetachedSessions int

+ MaxSessionsPerIP int

+ PersistInterval time.Duration

+ RedirectAllowlist map[string]struct{}

+ ResumeWindow *time.Duration

+ SessionStore session.SessionStore

+ type SessionPrimitiveRegistry struct

+ func NewSessionPrimitiveRegistry() *SessionPrimitiveRegistry

+ func (r *SessionPrimitiveRegistry) All() []*PrimitiveInfo

+ func (r *SessionPrimitiveRegistry) AllPersisted() []*PrimitiveInfo

+ func (r *SessionPrimitiveRegistry) FindByDebugName(debugName string) []*PrimitiveInfo

+ func (r *SessionPrimitiveRegistry) FindByNameOrID(nameOrID string) (*PrimitiveInfo, bool)

+ func (r *SessionPrimitiveRegistry) FindByStableID(stableID string) []*PrimitiveInfo

+ func (r *SessionPrimitiveRegistry) Register(reg vango.PrimitiveRegistration, instancePath string)

+ func (r *SessionPrimitiveRegistry) SignalValue(nameOrID string) (any, bool)

+ func (r *SessionPrimitiveRegistry) Unregister(instancePath string)

+ type SessionStats struct

+ BytesRecv uint64

+ BytesSent uint64

+ ComponentCount int

+ CreatedAt time.Time

+ EventCount uint64

+ HandlerCount int

+ ID string

+ LastActive time.Time

+ PatchCount uint64

+ UserID string

+ type StormBudgetConfig struct

+ MaxActionStartsPerSecond int

+ MaxEffectRunsPerTick int

+ MaxGoLatestStartsPerSecond int

+ MaxResourceStartsPerSecond int

+ OnExceeded BudgetExceededMode

+ WindowDuration time.Duration

+ func DefaultStormBudgetConfig() *StormBudgetConfig

+ type TouchEvent struct

+ Touches []TouchPoint

+ type TouchPoint struct

+ ClientX int

+ ClientY int

+ ID int

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