Versions in this module Expand all Collapse all v0 v0.1.0 Apr 5, 2019 Changes in this version + type Authorizer interface + Authorize func(*wamp.Session, wamp.Message) (bool, error) + type Broker struct + func NewBroker(logger stdlog.StdLog, strictURI, allowDisclose, debug bool, ...) *Broker + func (b *Broker) Close() + func (b *Broker) Publish(pub *session, msg *wamp.Publish) + func (b *Broker) RemoveSession(sess *session) + func (b *Broker) Role() wamp.Dict + func (b *Broker) SubCountSubscribers(msg *wamp.Invocation) wamp.Message + func (b *Broker) SubGet(msg *wamp.Invocation) wamp.Message + func (b *Broker) SubList(msg *wamp.Invocation) wamp.Message + func (b *Broker) SubListSubscribers(msg *wamp.Invocation) wamp.Message + func (b *Broker) SubLookup(msg *wamp.Invocation) wamp.Message + func (b *Broker) SubMatch(msg *wamp.Invocation) wamp.Message + func (b *Broker) Subscribe(sub *session, msg *wamp.Subscribe) + func (b *Broker) Unsubscribe(sub *session, msg *wamp.Unsubscribe) + type Config struct + Debug bool + RealmConfigs []*RealmConfig + RealmTemplate *RealmConfig + type Dealer struct + func NewDealer(logger stdlog.StdLog, strictURI, allowDisclose, debug bool) *Dealer + func (d *Dealer) Call(caller *session, msg *wamp.Call) + func (d *Dealer) Cancel(caller *session, msg *wamp.Cancel) + func (d *Dealer) Close() + func (d *Dealer) Error(msg *wamp.Error) + func (d *Dealer) RegCountCallees(msg *wamp.Invocation) wamp.Message + func (d *Dealer) RegGet(msg *wamp.Invocation) wamp.Message + func (d *Dealer) RegList(msg *wamp.Invocation) wamp.Message + func (d *Dealer) RegListCallees(msg *wamp.Invocation) wamp.Message + func (d *Dealer) RegLookup(msg *wamp.Invocation) wamp.Message + func (d *Dealer) RegMatch(msg *wamp.Invocation) wamp.Message + func (d *Dealer) Register(callee *session, msg *wamp.Register) + func (d *Dealer) RemoveSession(sess *session) + func (d *Dealer) Role() wamp.Dict + func (d *Dealer) SetMetaPeer(metaPeer wamp.Peer) + func (d *Dealer) Unregister(callee *session, msg *wamp.Unregister) + func (d *Dealer) Yield(callee *session, msg *wamp.Yield) + 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 + func NewRawSocketServer(r Router, recvLimit int, keepAlive time.Duration) *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 RouterConfig = Config + type WebsocketServer struct + BinarySerializer serialize.Serializer + EnableRequestCapture bool + EnableTrackingCookie bool + KeepAlive time.Duration + 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) + func (s *WebsocketServer) SetConfig(wsCfg transport.WebsocketConfig)