router

package

Go to main page

Versions in this module

v2

v2.1.0

Jul 27, 2018

Changes in this version

type Broker

+ 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

type RealmConfig

+ EnableMetaKill bool

+ EnableMetaModify bool

v2.0.4

Jun 24, 2018

Changes in this version

+ type Config struct

+ Debug bool

+ RealmConfigs []*RealmConfig

+ RealmTemplate *RealmConfig

type RealmConfig

+ MetaIncludeSessionDetails []string

+ MetaStrict bool

+ RequireLocalAuthz bool

v2.0.3

May 15, 2018

Changes in this version

type WebsocketServer

+ EnableRequestCapture bool

+ EnableTrackingCookie bool

+ KeepAlive time.Duration

v2.0.2

Mar 24, 2018

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 *wamp.Session, msg *wamp.Publish)

+ func (b *Broker) RemoveSession(sess *wamp.Session)

+ func (b *Broker) Role() wamp.Dict

+ func (b *Broker) Subscribe(sub *wamp.Session, msg *wamp.Subscribe)

+ func (b *Broker) Unsubscribe(sub *wamp.Session, msg *wamp.Unsubscribe)

+ type Dealer struct

+ func NewDealer(logger stdlog.StdLog, strictURI, allowDisclose, debug bool) *Dealer

+ func (d *Dealer) Call(caller *wamp.Session, msg *wamp.Call)

+ func (d *Dealer) Cancel(caller *wamp.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 *wamp.Session, msg *wamp.Register)

+ func (d *Dealer) RemoveSession(sess *wamp.Session)

+ func (d *Dealer) Role() wamp.Dict

+ func (d *Dealer) SetMetaPeer(metaPeer wamp.Peer)

+ func (d *Dealer) Unregister(callee *wamp.Session, msg *wamp.Unregister)

+ func (d *Dealer) Yield(callee *wamp.Session, msg *wamp.Yield)

+ 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

+ RequireLocalAuth 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 *RouterConfig, logger stdlog.StdLog) (Router, error)

+ type RouterConfig struct

+ Debug bool

+ RealmConfigs []*RealmConfig

+ RealmTemplate *RealmConfig

+ type WebsocketServer struct

+ BinarySerializer serialize.Serializer

+ TextSerializer serialize.Serializer

+ Upgrader *websocket.Upgrader

+ func NewWebsocketServer(r Router) *WebsocketServer

+ 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)

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