crossbar.personality

Attributes

Classes

Personality

Software personality for Crossbar.io OSS.

Functions

_check_proxy_config(personality, config)

create_realm_inventory(→ crossbar.interfaces.IInventory)

create_realm_store(→ crossbar.interfaces.IRealmStore)

Factory for creating realm stores (which store call queues and event history).

default_native_workers()

do_nothing(*args, **kw)

Module Contents

class Personality[source]

Bases: object

Software personality for Crossbar.io OSS.

This is a policy class that configures various parts of Crossbar.io’s behavior.

BANNER[source]
DESC = Multiline-String[source]
Show Value
"""Crossbar.io is a decentralized data plane for XBR/WAMP based application
service and data routing, built on Crossbar.io OSS."""
EXTRA_AUTH_METHODS: Dict[str, object][source]
LICENSE = ('crossbar', 'LICENSE')[source]
LICENSES_OSS = ('crossbar', 'LICENSES-OSS')[source]
NAME = 'standalone'[source]
Node[source]
NodeOptions[source]
REALM_STORES: Dict[str, object][source]
RouterTransport[source]
RouterWebTransport[source]
TEMPLATE_DIRS = [('crossbar', 'webservice/templates')][source]
TITLE = 'Crossbar.io'[source]
WEB_SERVICE_CHECKERS: Dict[str, object][source]
WEB_SERVICE_FACTORIES: Dict[str, object][source]
WorkerKlasses[source]
check_config[source]
check_config_file[source]
check_connecting_endpoint[source]
check_connecting_transport[source]
check_container[source]
check_container_component[source]
check_container_options[source]
check_controller[source]
check_controller_options[source]
check_guest[source]
check_listening_endpoint[source]
check_listening_endpoint_onion[source]
check_listening_transport_flashpolicy[source]
check_listening_transport_mqtt[source]
check_listening_transport_rawsocket[source]
check_listening_transport_stream_testee[source]
check_listening_transport_universal[source]
check_listening_transport_web[source]
check_listening_transport_websocket[source]
check_listening_transport_websocket_testee[source]
check_manhole[source]
check_node_key[source]
check_paths[source]
check_router[source]
check_router_component[source]
check_router_options[source]
check_router_realm[source]
check_router_realm_role[source]
check_router_transport[source]
check_transport_auth[source]
check_web_path_service[source]
check_websocket_testee[source]
check_websocket_testee_options[source]
check_worker[source]
convert_config_file[source]
create_realm_inventory[source]
create_realm_store[source]
create_router_transport[source]
log[source]
native_workers[source]
upgrade_config_file[source]
_BANNER = Multiline-String[source]
Show Value
"""
    :::::::::::::::::
          :::::          _____                 __              _
    :::::   :   :::::   / ___/______  ___ ___ / /  ___ _____  (_)__
    :::::::   :::::::  / /__/ __/ _ \(_-<(_-</ _ \/ _ `/ __/ / / _ \
    :::::   :   :::::  \___/_/  \___/___/___/_.__/\_,_/_/ (_)_/\___/
          :::::
    :::::::::::::::::   {title} v{version} [{build}]

    Copyright (c) 2013-{year} typedef int GmbH. Licensed under EUPLv1.2.
"""
_DESC = Multiline-String[source]
Show Value
"""Crossbar.io is a decentralized data plane for XBR/WAMP based application
service and data routing, built on Crossbar.io OSS."""
_TITLE = 'Crossbar.io'[source]
_check_proxy_config(personality, config)[source]
create_realm_inventory(personality, factory, config) crossbar.interfaces.IInventory[source]
{
    "version": 2,
    "workers": [
        {
            "type": "router",
            "realms": [
                {
                    "name": "realm1",
                    "inventory": {
                        "type": "wamp.eth",
                        "catalogs": [
                            {
                                "name": "pydefi",
                                "filename": "../schema/trading.bfbs"
                            }
                        ]
                    }
                }
            ]
        }
    ]
}
Parameters:
Returns:

A new realm inventory object.

create_realm_store(personality, factory, config) crossbar.interfaces.IRealmStore[source]

Factory for creating realm stores (which store call queues and event history).

"store": {
    "type": "memory",   // type of realm store: "memory"
    "limit": 100,       // global default for limit on call queues / event history
    "call-queue": [
        {
            "uri": "com.example.compute",
            "match": "exact",
            "limit": 1000   // procedure specific call queue limit
        }
    ],
    "event-history": [
        {
            "uri": "com.example.oncounter",
            "match": "exact",
            "limit": 1000   // topic specific history limit
        }
    ]
}
Parameters:
default_native_workers()[source]
do_nothing(*args, **kw)[source]