router

Apr 24, 2024

Changes in this version

type WebsocketServer

+ TrackingCookieSameSiteAttribute http.SameSite

+ TrackingCookieSecureAttribute bool

Sep 16, 2023

Changes in this version

+ var ErrPPTNotSupportedByPeer = errors.New(...)

type RealmConfig

+ TopicEventHistoryConfigs []*TopicEventHistoryConfig

type Router

+ RouterFeatures func() *wamp.Dict

+ type TopicEventHistoryConfig struct

+ Limit int

+ MatchPolicy string

+ Topic wamp.URI

Nov 29, 2020

Changes in this version

type Config

+ MemStatsLogSec int

Oct 31, 2020

Changes in this version

+ var Version string

Sep 30, 2019

Changes in this version

+ type Authorizer interface

+ Authorize func(*wamp.Session, wamp.Message) (bool, error)

+ type Config struct

+ Debug bool

+ RealmConfigs []*RealmConfig

+ RealmTemplate *RealmConfig

+ type FilterFactory func(msg *wamp.Publish) PublishFilter

+ type PublishFilter interface

+ Allowed func(sess *wamp.Session) bool

+ func NewSimplePublishFilter(msg *wamp.Publish) PublishFilter

+ type RawSocketServer struct

+ KeepAlive time.Duration

+ OutQueueSize int

+ RecvLimit int

+ func NewRawSocketServer(r Router) *RawSocketServer

+ func (s *RawSocketServer) ListenAndServe(network, address string) (io.Closer, error)

+ func (s *RawSocketServer) ListenAndServeTLS(network, address string, tlscfg *tls.Config, certFile, keyFile string) (io.Closer, error)

+ type RealmConfig struct

+ AllowDisclose bool

+ AnonymousAuth bool

+ Authenticators []auth.Authenticator

+ Authorizer Authorizer

+ EnableMetaKill bool

+ EnableMetaModify bool

+ MetaIncludeSessionDetails []string

+ MetaStrict bool

+ PublishFilterFactory FilterFactory

+ RequireLocalAuth bool

+ RequireLocalAuthz bool

+ StrictURI bool

+ URI wamp.URI

+ type Router interface

+ AddRealm func(*RealmConfig) error

+ Attach func(wamp.Peer) error

+ AttachClient func(wamp.Peer, wamp.Dict) error

+ Close func()

+ Logger func() stdlog.StdLog

+ RemoveRealm func(wamp.URI)

+ func NewRouter(config *Config, logger stdlog.StdLog) (Router, error)

+ type WebsocketServer struct

+ BinarySerializer serialize.Serializer

+ EnableRequestCapture bool

+ EnableTrackingCookie bool

+ KeepAlive time.Duration

+ OutQueueSize int

+ TextSerializer serialize.Serializer

+ Upgrader *websocket.Upgrader

+ func NewWebsocketServer(r Router) *WebsocketServer

+ func (s *WebsocketServer) AllowOrigins(origins []string) error

+ func (s *WebsocketServer) ListenAndServe(address string) (io.Closer, error)

+ func (s *WebsocketServer) ListenAndServeTLS(address string, tlscfg *tls.Config, certFile, keyFile string) (io.Closer, error)

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