Versions in this module Expand all Collapse all v0 v0.1.0 Apr 5, 2019 Changes in this version + const CBOR + const JSON + const MSGPACK + func CookieURL(routerURL string) (*url.URL, error) + type AuthFunc func(challenge *wamp.Challenge) (signature string, details wamp.Dict) + type Client struct + func ConnectLocal(router router.Router, cfg Config) (*Client, error) + func ConnectNet(routerURL string, cfg Config) (*Client, error) + func NewClient(p wamp.Peer, cfg Config) (*Client, error) + func (c *Client) Call(ctx context.Context, procedure string, options wamp.Dict, args wamp.List, ...) (*wamp.Result, error) + func (c *Client) CallProgress(ctx context.Context, procedure string, options wamp.Dict, args wamp.List, ...) (*wamp.Result, error) + func (c *Client) Close() error + func (c *Client) Done() <-chan struct{} + func (c *Client) HasFeature(role, feature string) bool + func (c *Client) ID() wamp.ID + func (c *Client) Logger() stdlog.StdLog + func (c *Client) Publish(topic string, options wamp.Dict, args wamp.List, kwargs wamp.Dict) error + func (c *Client) RealmDetails() wamp.Dict + func (c *Client) Register(procedure string, fn InvocationHandler, options wamp.Dict) error + func (c *Client) RegistrationID(procedure string) (regID wamp.ID, ok bool) + func (c *Client) RouterGoodbye() *wamp.Goodbye + func (c *Client) SendProgress(ctx context.Context, args wamp.List, kwArgs wamp.Dict) error + func (c *Client) Subscribe(topic string, fn EventHandler, options wamp.Dict) error + func (c *Client) SubscriptionID(topic string) (subID wamp.ID, ok bool) + func (c *Client) Unregister(procedure string) error + func (c *Client) Unsubscribe(topic string) error + type ClientConfig = Config + type Config struct + AuthHandlers map[string]AuthFunc + Debug bool + Dial transport.DialFunc + HelloDetails wamp.Dict + Logger stdlog.StdLog + Realm string + RecvLimit int + ResponseTimeout time.Duration + Serialization serialize.Serialization + TlsCfg *tls.Config + WsCfg transport.WebsocketConfig + type EventHandler func(args wamp.List, kwargs, details wamp.Dict) + type InvocationHandler func(context.Context, wamp.List, wamp.Dict, wamp.Dict) (result *InvokeResult) + type InvokeResult struct + Args wamp.List + Err wamp.URI + Kwargs wamp.Dict + type ProgressCallback func(*wamp.Result) + type RPCError struct + Err *wamp.Error + Procedure string + func (rpce RPCError) Error() string