Skip to content

Instantly share code, notes, and snippets.

@oberstet
Created April 22, 2022 09:16
Show Gist options
  • Save oberstet/a7804cdfcb5de3567c4ad1c822753307 to your computer and use it in GitHub Desktop.
Save oberstet/a7804cdfcb5de3567c4ad1c822753307 to your computer and use it in GitHub Desktop.
(cpy39_1) (base) oberstet@intel-nuci7:~/scm/crossbario/crossbar$ make find_registers
find crossbar -name "*.py" -exec grep -Hi -n2 "@wamp.register" {} \;
crossbar/network/_api.py-256- ApplicationSession.onLeave(self, details)
crossbar/network/_api.py-257-
crossbar/network/_api.py:258: @wamp.register('xbr.network.echo')
crossbar/network/_api.py-259- def echo(self, *args, **kwargs):
crossbar/network/_api.py-260- """
--
crossbar/network/_api.py-294- return CallResult(*args, **kwargs)
crossbar/network/_api.py-295-
crossbar/network/_api.py:296: @wamp.register('xbr.network.get_transaction_receipt', check_types=True)
crossbar/network/_api.py-297- async def get_transaction_receipt(self, transaction: bytes, details: Optional[CallDetails] = None) -> dict:
crossbar/network/_api.py-298- """
--
crossbar/network/_api.py-325- return receipt
crossbar/network/_api.py-326-
crossbar/network/_api.py:327: @wamp.register('xbr.network.get_gas_price', check_types=True)
crossbar/network/_api.py-328- async def get_gas_price(self, details: Optional[CallDetails] = None) -> bytes:
crossbar/network/_api.py-329- """
--
crossbar/network/_api.py-338- return gas_price
crossbar/network/_api.py-339-
crossbar/network/_api.py:340: @wamp.register('xbr.network.get_config', check_types=True)
crossbar/network/_api.py-341- async def get_config(self, include_eula_text: bool = False, details: Optional[CallDetails] = None) -> dict:
crossbar/network/_api.py-342- """
--
crossbar/network/_api.py-396- return config
crossbar/network/_api.py-397-
crossbar/network/_api.py:398: @wamp.register('xbr.network.get_status', check_types=True)
crossbar/network/_api.py-399- async def get_status(self, details: Optional[CallDetails] = None) -> dict:
crossbar/network/_api.py-400- """
--
crossbar/network/_api.py-440- return status
crossbar/network/_api.py-441-
crossbar/network/_api.py:442: @wamp.register('xbr.network.onboard_member', check_types=True)
crossbar/network/_api.py-443- async def onboard_member(self,
crossbar/network/_api.py-444- member_username: str,
--
crossbar/network/_api.py-552- return onboard_request_submitted
crossbar/network/_api.py-553-
crossbar/network/_api.py:554: @wamp.register('xbr.network.verify_onboard_member', check_types=True)
crossbar/network/_api.py-555- async def verify_onboard_member(self,
crossbar/network/_api.py-556- vaction_oid: bytes,
--
crossbar/network/_api.py-608- return onboard_request_verified
crossbar/network/_api.py-609-
crossbar/network/_api.py:610: @wamp.register('xbr.network.backup_wallet', check_types=True)
crossbar/network/_api.py-611- def backup_wallet(self,
crossbar/network/_api.py-612- member_oid: bytes,
--
crossbar/network/_api.py-635- raise NotImplementedError()
crossbar/network/_api.py-636-
crossbar/network/_api.py:637: @wamp.register('xbr.network.recover_wallet', check_types=True)
crossbar/network/_api.py-638- def recover_wallet(self,
crossbar/network/_api.py-639- member_email: str,
--
crossbar/network/_api.py-680- raise NotImplementedError()
crossbar/network/_api.py-681-
crossbar/network/_api.py:682: @wamp.register('xbr.network.verify_recover_wallet', check_types=True)
crossbar/network/_api.py-683- def verify_recover_wallet(self,
crossbar/network/_api.py-684- vaction_oid: bytes,
--
crossbar/network/_api.py-702- raise NotImplementedError()
crossbar/network/_api.py-703-
crossbar/network/_api.py:704: @wamp.register('xbr.network.get_member', check_types=True)
crossbar/network/_api.py-705- async def get_member(self, member_oid: bytes, details: Optional[CallDetails] = None) -> dict:
crossbar/network/_api.py-706- """
--
crossbar/network/_api.py-755- return member
crossbar/network/_api.py-756-
crossbar/network/_api.py:757: @wamp.register('xbr.network.get_member_by_wallet', check_types=True)
crossbar/network/_api.py-758- async def get_member_by_wallet(self, wallet_adr: bytes, details: Optional[CallDetails] = None) -> Optional[dict]:
crossbar/network/_api.py-759- """
--
crossbar/network/_api.py-782- return result
crossbar/network/_api.py-783-
crossbar/network/_api.py:784: @wamp.register('xbr.network.is_member', check_types=True)
crossbar/network/_api.py-785- async def is_member(self, wallet_adr: bytes, details: Optional[CallDetails] = None) -> bool:
crossbar/network/_api.py-786- """
--
crossbar/network/_api.py-810- return False
crossbar/network/_api.py-811-
crossbar/network/_api.py:812: @wamp.register('xbr.network.login_member', check_types=True)
crossbar/network/_api.py-813- async def login_member(self,
crossbar/network/_api.py-814- member_email: str,
--
crossbar/network/_api.py-897- return login_request_submitted
crossbar/network/_api.py-898-
crossbar/network/_api.py:899: @wamp.register('xbr.network.verify_login_member', check_types=True)
crossbar/network/_api.py-900- async def verify_login_member(self,
crossbar/network/_api.py-901- vaction_oid: bytes,
--
crossbar/network/_api.py-947- return login_request_verified
crossbar/network/_api.py-948-
crossbar/network/_api.py:949: @wamp.register('xbr.network.logout_member', check_types=True)
crossbar/network/_api.py-950- async def logout_member(self, details: CallDetails):
crossbar/network/_api.py-951- """
--
crossbar/network/_api.py-1012- return logout_info
crossbar/network/_api.py-1013-
crossbar/network/_api.py:1014: @wamp.register('xbr.network.get_member_logins', check_types=True)
crossbar/network/_api.py-1015- def get_member_logins(self, member_oid: bytes, details: Optional[CallDetails] = None) -> list:
crossbar/network/_api.py-1016- """
--
crossbar/network/_api.py-1055- return pubkeys
crossbar/network/_api.py-1056-
crossbar/network/_api.py:1057: @wamp.register('xbr.network.get_member_login', check_types=True)
crossbar/network/_api.py-1058- def get_member_login(self, member_oid: bytes, client_pubkey: bytes, details: Optional[CallDetails] = None) -> dict:
crossbar/network/_api.py-1059- """
--
crossbar/network/_api.py-1093- return userkey.marshal()
crossbar/network/_api.py-1094-
crossbar/network/_api.py:1095: @wamp.register('xbr.network.create_coin', check_types=True)
crossbar/network/_api.py-1096- async def create_coin(self,
crossbar/network/_api.py-1097- member_oid: bytes,
--
crossbar/network/_api.py-1154- return request
crossbar/network/_api.py-1155-
crossbar/network/_api.py:1156: @wamp.register('xbr.network.verify_create_coin', check_types=True)
crossbar/network/_api.py-1157- async def verify_create_coin(self,
crossbar/network/_api.py-1158- vaction_oid: bytes,
--
crossbar/network/_api.py-1206- return request_verified
crossbar/network/_api.py-1207-
crossbar/network/_api.py:1208: @wamp.register('xbr.network.get_coin', check_types=True)
crossbar/network/_api.py-1209- def get_coin(self,
crossbar/network/_api.py-1210- coin_oid: bytes,
--
crossbar/network/_api.py-1250- return coin
crossbar/network/_api.py-1251-
crossbar/network/_api.py:1252: @wamp.register('xbr.network.get_coin_by_symbol', check_types=True)
crossbar/network/_api.py-1253- def get_coin_by_symbol(self, symbol: str, details: Optional[CallDetails] = None) -> Optional[bytes]:
crossbar/network/_api.py-1254- """
--
crossbar/network/_api.py-1271- return None
crossbar/network/_api.py-1272-
crossbar/network/_api.py:1273: @wamp.register('xbr.network.get_coin_balance', check_types=True)
crossbar/network/_api.py-1274- async def get_coin_balance(self,
crossbar/network/_api.py-1275- member_oid: bytes,
--
crossbar/network/_api.py-1323- return balance
crossbar/network/_api.py-1324-
crossbar/network/_api.py:1325: @wamp.register('xbr.network.find_coins', check_types=False)
crossbar/network/_api.py-1326- async def find_coins(self,
crossbar/network/_api.py-1327- created_from: Optional[int] = None,
--
crossbar/network/_api.py-1354- return [self.XBR_COIN_OID.bytes]
crossbar/network/_api.py-1355-
crossbar/network/_api.py:1356: @wamp.register('xbr.network.does_hash_exist', check_types=True)
crossbar/network/_api.py-1357- async def does_hash_exist(self, ipfs_hash: str, details: Optional[CallDetails] = None):
crossbar/network/_api.py-1358- # https://ethereum.stackexchange.com/a/70204
--
crossbar/network/_api.py-1373- return False
crossbar/network/_api.py-1374-
crossbar/network/_api.py:1375: @wamp.register('xbr.network.create_market', check_types=True)
crossbar/network/_api.py-1376- async def create_market(self,
crossbar/network/_api.py-1377- member_oid: bytes,
--
crossbar/network/_api.py-1441- return request_submitted
crossbar/network/_api.py-1442-
crossbar/network/_api.py:1443: @wamp.register('xbr.network.verify_create_market', check_types=True)
crossbar/network/_api.py-1444- async def verify_create_market(self,
crossbar/network/_api.py-1445- vaction_oid: bytes,
--
crossbar/network/_api.py-1495- return create_market_request_verified
crossbar/network/_api.py-1496-
crossbar/network/_api.py:1497: @wamp.register('xbr.network.remove_market', check_types=True)
crossbar/network/_api.py-1498- def remove_market(self,
crossbar/network/_api.py-1499- member_oid: bytes,
--
crossbar/network/_api.py-1531- raise NotImplementedError()
crossbar/network/_api.py-1532-
crossbar/network/_api.py:1533: @wamp.register('xbr.network.update_market', check_types=True)
crossbar/network/_api.py-1534- def update_market(self, market_oid: bytes, attributes: Optional[dict], details: Optional[CallDetails] = None):
crossbar/network/_api.py-1535- """
--
crossbar/network/_api.py-1557- self._network.update_market(_market_oid, attributes)
crossbar/network/_api.py-1558-
crossbar/network/_api.py:1559: @wamp.register('xbr.network.get_market', check_types=True)
crossbar/network/_api.py-1560- async def get_market(self,
crossbar/network/_api.py-1561- market_oid: bytes,
--
crossbar/network/_api.py-1602- return market
crossbar/network/_api.py-1603-
crossbar/network/_api.py:1604: @wamp.register('xbr.network.get_markets_by_owner', check_types=True)
crossbar/network/_api.py-1605- def get_markets_by_owner(self, owner_oid: bytes, details: Optional[CallDetails] = None) -> list:
crossbar/network/_api.py-1606- """
--
crossbar/network/_api.py-1639- return markets
crossbar/network/_api.py-1640-
crossbar/network/_api.py:1641: @wamp.register('xbr.network.get_actors_in_market', check_types=True)
crossbar/network/_api.py-1642- def get_actors_in_market(self, market_oid: bytes, details: Optional[CallDetails] = None) -> list:
crossbar/network/_api.py-1643- """
--
crossbar/network/_api.py-1669- return actors_in_market
crossbar/network/_api.py-1670-
crossbar/network/_api.py:1671: @wamp.register('xbr.network.get_actor_in_market', check_types=True)
crossbar/network/_api.py-1672- def get_actor_in_market(self, market_oid: bytes, actor_adr: bytes, details: Optional[CallDetails] = None) -> list:
crossbar/network/_api.py-1673- """
--
crossbar/network/_api.py-1710- return result
crossbar/network/_api.py-1711-
crossbar/network/_api.py:1712: @wamp.register('xbr.network.get_markets_by_actor', check_types=True)
crossbar/network/_api.py-1713- def get_markets_by_actor(self, actor_oid: bytes, details: Optional[CallDetails] = None) -> list:
crossbar/network/_api.py-1714- """
--
crossbar/network/_api.py-1755- return markets
crossbar/network/_api.py-1756-
crossbar/network/_api.py:1757: @wamp.register('xbr.network.get_markets_by_coin', check_types=True)
crossbar/network/_api.py-1758- def get_markets_by_coin(self, coin_oid: bytes, details: Optional[CallDetails] = None) -> list:
crossbar/network/_api.py-1759- """
--
crossbar/network/_api.py-1790- # return markets
crossbar/network/_api.py-1791-
crossbar/network/_api.py:1792: @wamp.register('xbr.network.find_markets', check_types=False)
crossbar/network/_api.py-1793- async def find_markets(self,
crossbar/network/_api.py-1794- created_from: Optional[int] = None,
--
crossbar/network/_api.py-1893- return market_oids
crossbar/network/_api.py-1894-
crossbar/network/_api.py:1895: @wamp.register('xbr.network.join_market', check_types=False)
crossbar/network/_api.py-1896- async def join_market(self,
crossbar/network/_api.py-1897- member_id: bytes,
--
crossbar/network/_api.py-1971- return submitted
crossbar/network/_api.py-1972-
crossbar/network/_api.py:1973: @wamp.register('xbr.network.verify_join_market', check_types=True)
crossbar/network/_api.py-1974- async def verify_join_market(self,
crossbar/network/_api.py-1975- vaction_oid: bytes,
--
crossbar/network/_api.py-2021- return join_market_request_verified
crossbar/network/_api.py-2022-
crossbar/network/_api.py:2023: @wamp.register('xbr.network.create_catalog', check_types=True)
crossbar/network/_api.py-2024- async def create_catalog(self,
crossbar/network/_api.py-2025- member_oid: bytes,
--
crossbar/network/_api.py-2093- return submitted
crossbar/network/_api.py-2094-
crossbar/network/_api.py:2095: @wamp.register('xbr.network.verify_create_catalog', check_types=True)
crossbar/network/_api.py-2096- async def verify_create_catalog(self,
crossbar/network/_api.py-2097- vaction_oid: bytes,
--
crossbar/network/_api.py-2146- return created_catalog_request_verified
crossbar/network/_api.py-2147-
crossbar/network/_api.py:2148: @wamp.register('xbr.network.remove_catalog', check_types=True)
crossbar/network/_api.py-2149- def remove_catalog(self,
crossbar/network/_api.py-2150- member_oid: bytes,
--
crossbar/network/_api.py-2178- raise NotImplementedError()
crossbar/network/_api.py-2179-
crossbar/network/_api.py:2180: @wamp.register('xbr.network.get_catalogs_by_owner', check_types=True)
crossbar/network/_api.py-2181- def get_catalogs_by_owner(self, member_oid: bytes, details: Optional[CallDetails] = None):
crossbar/network/_api.py-2182- """
--
crossbar/network/_api.py-2213- return catalogs
crossbar/network/_api.py-2214-
crossbar/network/_api.py:2215: @wamp.register('xbr.network.get_catalog', check_types=True)
crossbar/network/_api.py-2216- def get_catalog(self,
crossbar/network/_api.py-2217- catalog_oid: bytes,
--
crossbar/network/_api.py-2239- return catalog.marshal()
crossbar/network/_api.py-2240-
crossbar/network/_api.py:2241: @wamp.register('xbr.network.find_catalogs', check_types=False)
crossbar/network/_api.py-2242- async def find_catalogs(self,
crossbar/network/_api.py-2243- created_from: Optional[int] = None,
--
crossbar/network/_api.py-2310- return catalog_oids
crossbar/network/_api.py-2311-
crossbar/network/_api.py:2312: @wamp.register('xbr.network.publish_api', check_types=True)
crossbar/network/_api.py-2313- def publish_api(self,
crossbar/network/_api.py-2314- member_oid: bytes,
--
crossbar/network/_api.py-2389- return result
crossbar/network/_api.py-2390-
crossbar/network/_api.py:2391: @wamp.register('xbr.network.verify_publish_api', check_types=True)
crossbar/network/_api.py-2392- async def verify_publish_api(self,
crossbar/network/_api.py-2393- vaction_oid: bytes,
--
crossbar/network/_api.py-2444- return created_catalog_request_verified
crossbar/network/_api.py-2445-
crossbar/network/_api.py:2446: @wamp.register('xbr.network.get_api', check_types=True)
crossbar/network/_api.py-2447- def get_api(self, api_oid: bytes, include_attributes: bool = False, details: Optional[CallDetails] = None) -> dict:
crossbar/network/_api.py-2448- """
--
crossbar/network/_api.py-2467- return api.marshal()
crossbar/network/_api.py-2468-
crossbar/network/_api.py:2469: @wamp.register('xbr.network.find_apis', check_types=False)
crossbar/network/_api.py-2470- async def find_apis(self,
crossbar/network/_api.py-2471- created_from: Optional[int] = None,
--
crossbar/network/_api.py-2538- return api_oids
crossbar/network/_api.py-2539-
crossbar/network/_api.py:2540: @wamp.register('xbr.network.create_domain', check_types=True)
crossbar/network/_api.py-2541- def create_domain(self,
crossbar/network/_api.py-2542- member_oid: bytes,
--
crossbar/network/_api.py-2570- raise NotImplementedError()
crossbar/network/_api.py-2571-
crossbar/network/_api.py:2572: @wamp.register('xbr.network.remove_domain', check_types=True)
crossbar/network/_api.py-2573- def remove_domain(self,
crossbar/network/_api.py-2574- member_oid: bytes,
--
crossbar/network/_api.py-2602- raise NotImplementedError()
crossbar/network/_api.py-2603-
crossbar/network/_api.py:2604: @wamp.register('xbr.network.get_domains_by_owner', check_types=True)
crossbar/network/_api.py-2605- def get_domains_by_owner(self, member_oid: bytes, details: Optional[CallDetails] = None):
crossbar/network/_api.py-2606- """
--
crossbar/network/_api.py-2619- raise NotImplementedError()
crossbar/network/_api.py-2620-
crossbar/network/_api.py:2621: @wamp.register('xbr.network.get_domain', check_types=True)
crossbar/network/_api.py-2622- def get_domain(self, domain_adr: bytes, details: Optional[CallDetails] = None):
crossbar/network/_api.py-2623- """
--
crossbar/network/_api.py-2636- raise NotImplementedError()
crossbar/network/_api.py-2637-
crossbar/network/_api.py:2638: @wamp.register('xbr.network.find_domains', check_types=True)
crossbar/network/_api.py-2639- def find_domains(self,
crossbar/network/_api.py-2640- include_owners: Optional[list] = None,
crossbar/master/cluster/routercluster.py-318- # return txaio.gather(dl)
crossbar/master/cluster/routercluster.py-319-
crossbar/master/cluster/routercluster.py:320: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-321- def list_routerclusters(self,
crossbar/master/cluster/routercluster.py-322- return_names: Optional[bool] = None,
--
crossbar/master/cluster/routercluster.py-362- return []
crossbar/master/cluster/routercluster.py-363-
crossbar/master/cluster/routercluster.py:364: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-365- def get_routercluster(self, routercluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/routercluster.py-366- """
--
crossbar/master/cluster/routercluster.py-402- 'no routercluster with oid {}'.format(routercluster_oid_))
crossbar/master/cluster/routercluster.py-403-
crossbar/master/cluster/routercluster.py:404: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-405- def get_routercluster_by_name(self, routercluster_name: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/routercluster.py-406- """
--
crossbar/master/cluster/routercluster.py-430- return routercluster.marshal()
crossbar/master/cluster/routercluster.py-431-
crossbar/master/cluster/routercluster.py:432: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-433- async def create_routercluster(self, routercluster: dict, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/routercluster.py-434- """
--
crossbar/master/cluster/routercluster.py-520- return res_obj
crossbar/master/cluster/routercluster.py-521-
crossbar/master/cluster/routercluster.py:522: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-523- async def delete_routercluster(self, routercluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/routercluster.py-524- """
--
crossbar/master/cluster/routercluster.py-586- return res_obj
crossbar/master/cluster/routercluster.py-587-
crossbar/master/cluster/routercluster.py:588: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-589- async def start_routercluster(self, routercluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/routercluster.py-590- """
--
crossbar/master/cluster/routercluster.py-667- return routercluster_starting
crossbar/master/cluster/routercluster.py-668-
crossbar/master/cluster/routercluster.py:669: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-670- async def stop_routercluster(self, routercluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/routercluster.py-671- """
--
crossbar/master/cluster/routercluster.py-732- return routercluster_stopping
crossbar/master/cluster/routercluster.py-733-
crossbar/master/cluster/routercluster.py:734: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-735- def stat_routercluster(self, routercluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/routercluster.py-736- """
--
crossbar/master/cluster/routercluster.py-750- raise NotImplementedError()
crossbar/master/cluster/routercluster.py-751-
crossbar/master/cluster/routercluster.py:752: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-753- def list_routercluster_nodes(self,
crossbar/master/cluster/routercluster.py-754- routercluster_oid: str,
--
crossbar/master/cluster/routercluster.py-829- return res
crossbar/master/cluster/routercluster.py-830-
crossbar/master/cluster/routercluster.py:831: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-832- async def add_routercluster_node(self,
crossbar/master/cluster/routercluster.py-833- routercluster_oid: str,
--
crossbar/master/cluster/routercluster.py-892- return res_obj
crossbar/master/cluster/routercluster.py-893-
crossbar/master/cluster/routercluster.py:894: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-895- async def remove_routercluster_node(self,
crossbar/master/cluster/routercluster.py-896- routercluster_oid: str,
--
crossbar/master/cluster/routercluster.py-958- return res_obj
crossbar/master/cluster/routercluster.py-959-
crossbar/master/cluster/routercluster.py:960: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-961- def get_routercluster_node(self,
crossbar/master/cluster/routercluster.py-962- routercluster_oid: str,
--
crossbar/master/cluster/routercluster.py-1018- return res_obj
crossbar/master/cluster/routercluster.py-1019-
crossbar/master/cluster/routercluster.py:1020: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-1021- def list_routercluster_workergroups(self,
crossbar/master/cluster/routercluster.py-1022- routercluster_oid: str,
--
crossbar/master/cluster/routercluster.py-1079- return workergroups
crossbar/master/cluster/routercluster.py-1080-
crossbar/master/cluster/routercluster.py:1081: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-1082- async def add_routercluster_workergroup(self,
crossbar/master/cluster/routercluster.py-1083- routercluster_oid: str,
--
crossbar/master/cluster/routercluster.py-1206- return res_obj
crossbar/master/cluster/routercluster.py-1207-
crossbar/master/cluster/routercluster.py:1208: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-1209- async def remove_routercluster_workergroup(self,
crossbar/master/cluster/routercluster.py-1210- routercluster_oid: str,
--
crossbar/master/cluster/routercluster.py-1292- return res_obj
crossbar/master/cluster/routercluster.py-1293-
crossbar/master/cluster/routercluster.py:1294: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-1295- def get_routercluster_workergroup(self,
crossbar/master/cluster/routercluster.py-1296- routercluster_oid: str,
--
crossbar/master/cluster/routercluster.py-1350- return workergroup.marshal()
crossbar/master/cluster/routercluster.py-1351-
crossbar/master/cluster/routercluster.py:1352: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-1353- def get_routercluster_workergroup_by_name(self,
crossbar/master/cluster/routercluster.py-1354- routercluster_name: str,
--
crossbar/master/cluster/routercluster.py-1388- return workergroup.marshal()
crossbar/master/cluster/routercluster.py-1389-
crossbar/master/cluster/routercluster.py:1390: @wamp.register(None, check_types=True)
crossbar/master/cluster/routercluster.py-1391- def stat_routercluster_workergroup(self,
crossbar/master/cluster/routercluster.py-1392- routercluster_oid: str,
crossbar/master/cluster/webcluster.py-586- # return txaio.gather(dl)
crossbar/master/cluster/webcluster.py-587-
crossbar/master/cluster/webcluster.py:588: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-589- def list_webclusters(self,
crossbar/master/cluster/webcluster.py-590- return_names: Optional[bool] = False,
--
crossbar/master/cluster/webcluster.py-631- return []
crossbar/master/cluster/webcluster.py-632-
crossbar/master/cluster/webcluster.py:633: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-634- def get_webcluster(self, webcluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/webcluster.py-635- """
--
crossbar/master/cluster/webcluster.py-691- 'no webcluster with oid {}'.format(webcluster_oid_))
crossbar/master/cluster/webcluster.py-692-
crossbar/master/cluster/webcluster.py:693: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-694- def get_webcluster_by_name(self, webcluster_name: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/webcluster.py-695- """
--
crossbar/master/cluster/webcluster.py-722- return webcluster.marshal()
crossbar/master/cluster/webcluster.py-723-
crossbar/master/cluster/webcluster.py:724: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-725- async def create_webcluster(self, webcluster: dict, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/webcluster.py-726- """
--
crossbar/master/cluster/webcluster.py-856- return res_obj
crossbar/master/cluster/webcluster.py-857-
crossbar/master/cluster/webcluster.py:858: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-859- async def delete_webcluster(self, webcluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/webcluster.py-860- """
--
crossbar/master/cluster/webcluster.py-943- return res_obj
crossbar/master/cluster/webcluster.py-944-
crossbar/master/cluster/webcluster.py:945: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-946- async def start_webcluster(self, webcluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/webcluster.py-947- """
--
crossbar/master/cluster/webcluster.py-1026- return webcluster_starting
crossbar/master/cluster/webcluster.py-1027-
crossbar/master/cluster/webcluster.py:1028: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1029- async def stop_webcluster(self, webcluster_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/webcluster.py-1030- """
--
crossbar/master/cluster/webcluster.py-1098- return webcluster_stopping
crossbar/master/cluster/webcluster.py-1099-
crossbar/master/cluster/webcluster.py:1100: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1101- def list_webcluster_nodes(self,
crossbar/master/cluster/webcluster.py-1102- webcluster_oid: str,
--
crossbar/master/cluster/webcluster.py-1184- return res
crossbar/master/cluster/webcluster.py-1185-
crossbar/master/cluster/webcluster.py:1186: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1187- async def add_webcluster_node(self,
crossbar/master/cluster/webcluster.py-1188- webcluster_oid: str,
--
crossbar/master/cluster/webcluster.py-1258- return res_obj
crossbar/master/cluster/webcluster.py-1259-
crossbar/master/cluster/webcluster.py:1260: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1261- async def remove_webcluster_node(self,
crossbar/master/cluster/webcluster.py-1262- webcluster_oid: str,
--
crossbar/master/cluster/webcluster.py-1328- return res_obj
crossbar/master/cluster/webcluster.py-1329-
crossbar/master/cluster/webcluster.py:1330: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1331- def get_webcluster_node(self, webcluster_oid: str, node_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/cluster/webcluster.py-1332- """
--
crossbar/master/cluster/webcluster.py-1389- return res_obj
crossbar/master/cluster/webcluster.py-1390-
crossbar/master/cluster/webcluster.py:1391: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1392- def list_webcluster_services(self,
crossbar/master/cluster/webcluster.py-1393- webcluster_oid: str,
--
crossbar/master/cluster/webcluster.py-1444- return res
crossbar/master/cluster/webcluster.py-1445-
crossbar/master/cluster/webcluster.py:1446: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1447- async def add_webcluster_service(self,
crossbar/master/cluster/webcluster.py-1448- webcluster_oid: str,
--
crossbar/master/cluster/webcluster.py-1567- return res_obj
crossbar/master/cluster/webcluster.py-1568-
crossbar/master/cluster/webcluster.py:1569: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1570- async def remove_webcluster_service(self,
crossbar/master/cluster/webcluster.py-1571- webcluster_oid: str,
--
crossbar/master/cluster/webcluster.py-1654- return res_obj
crossbar/master/cluster/webcluster.py-1655-
crossbar/master/cluster/webcluster.py:1656: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1657- def get_webcluster_service(self,
crossbar/master/cluster/webcluster.py-1658- webcluster_oid: str,
--
crossbar/master/cluster/webcluster.py-1715- return webservice.marshal()
crossbar/master/cluster/webcluster.py-1716-
crossbar/master/cluster/webcluster.py:1717: @wamp.register(None, check_types=True)
crossbar/master/cluster/webcluster.py-1718- def get_webcluster_service_by_path(self,
crossbar/master/cluster/webcluster.py-1719- webcluster_oid: str,
crossbar/master/mrealm/metadata.py-132- self._started = None
crossbar/master/mrealm/metadata.py-133-
crossbar/master/mrealm/metadata.py:134: @wamp.register(None)
crossbar/master/mrealm/metadata.py-135- def get_docs(self, otype, oid, details=None):
crossbar/master/mrealm/metadata.py-136- """
--
crossbar/master/mrealm/metadata.py-162- return None
crossbar/master/mrealm/metadata.py-163-
crossbar/master/mrealm/metadata.py:164: @wamp.register(None)
crossbar/master/mrealm/metadata.py-165- def add_docs(self, otype, oid, docs, details=None):
crossbar/master/mrealm/metadata.py-166- """
--
crossbar/master/mrealm/metadata.py-212- return result
crossbar/master/mrealm/metadata.py-213-
crossbar/master/mrealm/metadata.py:214: @wamp.register(None)
crossbar/master/mrealm/metadata.py-215- def delete_docs(self, oid, details=None):
crossbar/master/mrealm/metadata.py-216- """
crossbar/master/mrealm/controller.py-999- self._check_node_id(node_id, status)
crossbar/master/mrealm/controller.py-1000-
crossbar/master/mrealm/controller.py:1001: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1002- def get_status(self, details: Optional[CallDetails] = None) -> dict:
crossbar/master/mrealm/controller.py-1003- """
--
crossbar/master/mrealm/controller.py-1019- return res
crossbar/master/mrealm/controller.py-1020-
crossbar/master/mrealm/controller.py:1021: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1022- def get_nodes(self,
crossbar/master/mrealm/controller.py-1023- status: Optional[str] = None,
--
crossbar/master/mrealm/controller.py-1068- return res_
crossbar/master/mrealm/controller.py-1069-
crossbar/master/mrealm/controller.py:1070: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1071- def get_node(self, node_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/mrealm/controller.py-1072- """
--
crossbar/master/mrealm/controller.py-1105- return node_obj
crossbar/master/mrealm/controller.py-1106-
crossbar/master/mrealm/controller.py:1107: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1108- def get_node_by_authid(self, node_authid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/mrealm/controller.py-1109- """
--
crossbar/master/mrealm/controller.py-1163-
crossbar/master/mrealm/controller.py-1164- @inlineCallbacks
crossbar/master/mrealm/controller.py:1165: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1166- def get_trace_data(self,
crossbar/master/mrealm/controller.py-1167- trace_id: str,
--
crossbar/master/mrealm/controller.py-1203- returnValue(result)
crossbar/master/mrealm/controller.py-1204-
crossbar/master/mrealm/controller.py:1205: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1206- def get_trace(self, trace_id: str, details: Optional[CallDetails] = None) -> Optional[dict]:
crossbar/master/mrealm/controller.py-1207- """
--
crossbar/master/mrealm/controller.py-1237- return None
crossbar/master/mrealm/controller.py-1238-
crossbar/master/mrealm/controller.py:1239: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1240- def get_traces(self, details: Optional[CallDetails] = None) -> List[str]:
crossbar/master/mrealm/controller.py-1241- """
--
crossbar/master/mrealm/controller.py-1265- return sorted(trace_ids)
crossbar/master/mrealm/controller.py-1266-
crossbar/master/mrealm/controller.py:1267: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1268- def create_trace(self,
crossbar/master/mrealm/controller.py-1269- trace_id: str,
--
crossbar/master/mrealm/controller.py-1314-
crossbar/master/mrealm/controller.py-1315- @inlineCallbacks
crossbar/master/mrealm/controller.py:1316: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1317- def start_trace(self, trace_id: str, details: Optional[CallDetails] = None) -> Deferred:
crossbar/master/mrealm/controller.py-1318- """
--
crossbar/master/mrealm/controller.py-1407-
crossbar/master/mrealm/controller.py-1408- @inlineCallbacks
crossbar/master/mrealm/controller.py:1409: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1410- def stop_trace(self, trace_id: str, details: Optional[CallDetails] = None) -> Deferred:
crossbar/master/mrealm/controller.py-1411- """
--
crossbar/master/mrealm/controller.py-1485- returnValue(trace_stopped)
crossbar/master/mrealm/controller.py-1486-
crossbar/master/mrealm/controller.py:1487: @wamp.register(None, check_types=True)
crossbar/master/mrealm/controller.py-1488- def delete_trace(self, trace_id: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/mrealm/controller.py-1489- """
crossbar/master/mrealm/mrealm.py-110- return session.register(self, prefix=prefix, options=options)
crossbar/master/mrealm/mrealm.py-111-
crossbar/master/mrealm/mrealm.py:112: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-113- def list_mrealms(self, return_names=None, details=None):
crossbar/master/mrealm/mrealm.py-114- """
--
crossbar/master/mrealm/mrealm.py-157- return res
crossbar/master/mrealm/mrealm.py-158-
crossbar/master/mrealm/mrealm.py:159: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-160- def get_mrealm_by_name(self, mrealm_name, details=None):
crossbar/master/mrealm/mrealm.py-161- """
--
crossbar/master/mrealm/mrealm.py-190- 'no management realm with name {}'.format(mrealm_name))
crossbar/master/mrealm/mrealm.py-191-
crossbar/master/mrealm/mrealm.py:192: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-193- def get_mrealm(self, mrealm_oid, details=None):
crossbar/master/mrealm/mrealm.py-194- """
--
crossbar/master/mrealm/mrealm.py-245- 'no management realm with oid {}'.format(mrealm_oid))
crossbar/master/mrealm/mrealm.py-246-
crossbar/master/mrealm/mrealm.py:247: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-248- async def create_mrealm(self, mrealm, details=None):
crossbar/master/mrealm/mrealm.py-249- """
--
crossbar/master/mrealm/mrealm.py-356- return mrealm_obj
crossbar/master/mrealm/mrealm.py-357-
crossbar/master/mrealm/mrealm.py:358: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-359- def modify_mrealm(self, mrealm_oid, mrealm_diff, details=None):
crossbar/master/mrealm/mrealm.py-360- """
--
crossbar/master/mrealm/mrealm.py-385- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-386-
crossbar/master/mrealm/mrealm.py:387: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-388- async def delete_mrealm(self, mrealm_oid, cascade=False, details=None):
crossbar/master/mrealm/mrealm.py-389- """
--
crossbar/master/mrealm/mrealm.py-489- return deleted
crossbar/master/mrealm/mrealm.py-490-
crossbar/master/mrealm/mrealm.py:491: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-492- async def delete_mrealm_by_name(self, mrealm_name, cascade=False, details=None):
crossbar/master/mrealm/mrealm.py-493- """
--
crossbar/master/mrealm/mrealm.py-522- 'no management realm with name "{}"'.format(mrealm_name))
crossbar/master/mrealm/mrealm.py-523-
crossbar/master/mrealm/mrealm.py:524: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-525- def set_roles_on_mrealm_for_user(self, mrealm_oid, user_oid, user_roles, details=None):
crossbar/master/mrealm/mrealm.py-526- """
--
crossbar/master/mrealm/mrealm.py-546- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-547-
crossbar/master/mrealm/mrealm.py:548: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-549- def list_nodes(self, details=None):
crossbar/master/mrealm/mrealm.py-550- """
--
crossbar/master/mrealm/mrealm.py-557- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-558-
crossbar/master/mrealm/mrealm.py:559: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-560- def list_nodes_by_mrealm(self, mrealm_id, details=None):
crossbar/master/mrealm/mrealm.py-561- """
--
crossbar/master/mrealm/mrealm.py-570- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-571-
crossbar/master/mrealm/mrealm.py:572: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-573- def list_nodes_by_mrealm_name(self, mrealm_name, details=None):
crossbar/master/mrealm/mrealm.py-574- """
--
crossbar/master/mrealm/mrealm.py-583- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-584-
crossbar/master/mrealm/mrealm.py:585: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-586- def get_node(self, node_id, details=None):
crossbar/master/mrealm/mrealm.py-587- """
--
crossbar/master/mrealm/mrealm.py-596- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-597-
crossbar/master/mrealm/mrealm.py:598: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-599- def modify_node(self, node_id, node_delta, details=None):
crossbar/master/mrealm/mrealm.py-600- """
--
crossbar/master/mrealm/mrealm.py-610- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-611-
crossbar/master/mrealm/mrealm.py:612: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-613- def delete_node(self, node_id, details=None):
crossbar/master/mrealm/mrealm.py-614- """
--
crossbar/master/mrealm/mrealm.py-623- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-624-
crossbar/master/mrealm/mrealm.py:625: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-626- def stat_node(self, node_id, details=None):
crossbar/master/mrealm/mrealm.py-627- """
--
crossbar/master/mrealm/mrealm.py-636- raise NotImplementedError()
crossbar/master/mrealm/mrealm.py-637-
crossbar/master/mrealm/mrealm.py:638: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-639- def get_node_by_name(self, mrealm_name, node_name, details=None):
crossbar/master/mrealm/mrealm.py-640- """
--
crossbar/master/mrealm/mrealm.py-677- return node.marshal()
crossbar/master/mrealm/mrealm.py-678-
crossbar/master/mrealm/mrealm.py:679: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-680- async def pair_node(self, pubkey, realm_name, authid, authextra=None, details=None):
crossbar/master/mrealm/mrealm.py-681- """
--
crossbar/master/mrealm/mrealm.py-777- return node_obj
crossbar/master/mrealm/mrealm.py-778-
crossbar/master/mrealm/mrealm.py:779: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-780- async def unpair_node(self, node_oid, details=None):
crossbar/master/mrealm/mrealm.py-781- """
--
crossbar/master/mrealm/mrealm.py-870- return node_obj
crossbar/master/mrealm/mrealm.py-871-
crossbar/master/mrealm/mrealm.py:872: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-873- async def unpair_node_by_pubkey(self, pubkey, details=None):
crossbar/master/mrealm/mrealm.py-874- """
--
crossbar/master/mrealm/mrealm.py-894- raise ApplicationError('crossbar.error.no_such_object', 'no node with pubkey {}'.format(pubkey))
crossbar/master/mrealm/mrealm.py-895-
crossbar/master/mrealm/mrealm.py:896: @wamp.register(None)
crossbar/master/mrealm/mrealm.py-897- async def unpair_node_by_name(self, realm_name, authid, details=None):
crossbar/master/mrealm/mrealm.py-898- """
crossbar/master/arealm/arealm.py-1157- # return txaio.gather(dl)
crossbar/master/arealm/arealm.py-1158-
crossbar/master/arealm/arealm.py:1159: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1160- def list_arealms(self, return_names: Optional[bool] = None, details: Optional[CallDetails] = None) -> List[str]:
crossbar/master/arealm/arealm.py-1161- """
--
crossbar/master/arealm/arealm.py-1192- return []
crossbar/master/arealm/arealm.py-1193-
crossbar/master/arealm/arealm.py:1194: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1195- def get_arealm(self, arealm_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-1196- """
--
crossbar/master/arealm/arealm.py-1258- raise ApplicationError('crossbar.error.no_such_object', 'no arealm with oid {}'.format(arealm_oid_))
crossbar/master/arealm/arealm.py-1259-
crossbar/master/arealm/arealm.py:1260: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1261- def get_arealm_by_name(self, arealm_name: str, details: Optional[CallDetails] = None):
crossbar/master/arealm/arealm.py-1262- """
--
crossbar/master/arealm/arealm.py-1289- return arealm.marshal()
crossbar/master/arealm/arealm.py-1290-
crossbar/master/arealm/arealm.py:1291: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1292- async def create_arealm(self, arealm: dict, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-1293- """
--
crossbar/master/arealm/arealm.py-1365- return res_obj
crossbar/master/arealm/arealm.py-1366-
crossbar/master/arealm/arealm.py:1367: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1368- async def delete_arealm(self, arealm_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-1369- """
--
crossbar/master/arealm/arealm.py-1412- return arealm_obj
crossbar/master/arealm/arealm.py-1413-
crossbar/master/arealm/arealm.py:1414: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1415- async def start_arealm(self,
crossbar/master/arealm/arealm.py-1416- arealm_oid: str,
--
crossbar/master/arealm/arealm.py-1523- return arealm_starting
crossbar/master/arealm/arealm.py-1524-
crossbar/master/arealm/arealm.py:1525: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1526- async def stop_arealm(self, arealm_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-1527- """
--
crossbar/master/arealm/arealm.py-1585- return arealm_stopping
crossbar/master/arealm/arealm.py-1586-
crossbar/master/arealm/arealm.py:1587: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1588- def stat_arealm(self, arealm_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-1589- """
--
crossbar/master/arealm/arealm.py-1606- raise NotImplementedError()
crossbar/master/arealm/arealm.py-1607-
crossbar/master/arealm/arealm.py:1608: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1609- def list_router_workers(self, arealm_oid: str, details: Optional[CallDetails] = None) -> List[str]:
crossbar/master/arealm/arealm.py-1610- """
--
crossbar/master/arealm/arealm.py-1621- raise NotImplementedError()
crossbar/master/arealm/arealm.py-1622-
crossbar/master/arealm/arealm.py:1623: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1624- def list_principals(self,
crossbar/master/arealm/arealm.py-1625- arealm_oid: str,
--
crossbar/master/arealm/arealm.py-1673- return res
crossbar/master/arealm/arealm.py-1674-
crossbar/master/arealm/arealm.py:1675: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1676- def get_principal(self, arealm_oid: str, principal_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-1677- """
--
crossbar/master/arealm/arealm.py-1707- return obj
crossbar/master/arealm/arealm.py-1708-
crossbar/master/arealm/arealm.py:1709: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1710- def get_principal_by_name(self, arealm_oid: str, principal_name: str, details: Optional[CallDetails] = None):
crossbar/master/arealm/arealm.py-1711- """
--
crossbar/master/arealm/arealm.py-1742- return obj
crossbar/master/arealm/arealm.py-1743-
crossbar/master/arealm/arealm.py:1744: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1745- async def add_principal(self, arealm_oid: str, principal: dict, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-1746- """
--
crossbar/master/arealm/arealm.py-1810- return res_obj
crossbar/master/arealm/arealm.py-1811-
crossbar/master/arealm/arealm.py:1812: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1813- def remove_principal(self, arealm_oid: str, principal_oid: str, details: Optional[CallDetails] = None):
crossbar/master/arealm/arealm.py-1814- """
--
crossbar/master/arealm/arealm.py-1822- raise NotImplementedError()
crossbar/master/arealm/arealm.py-1823-
crossbar/master/arealm/arealm.py:1824: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1825- def list_principal_credentials(self,
crossbar/master/arealm/arealm.py-1826- arealm_oid: str,
--
crossbar/master/arealm/arealm.py-1875- return res
crossbar/master/arealm/arealm.py-1876-
crossbar/master/arealm/arealm.py:1877: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1878- def get_principal_credential(self,
crossbar/master/arealm/arealm.py-1879- arealm_oid: str,
--
crossbar/master/arealm/arealm.py-1892- raise NotImplementedError()
crossbar/master/arealm/arealm.py-1893-
crossbar/master/arealm/arealm.py:1894: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-1895- def add_principal_credential(self,
crossbar/master/arealm/arealm.py-1896- arealm_oid: str,
--
crossbar/master/arealm/arealm.py-2029- return credential_.marshal()
crossbar/master/arealm/arealm.py-2030-
crossbar/master/arealm/arealm.py:2031: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2032- def remove_principal_credential(self,
crossbar/master/arealm/arealm.py-2033- arealm_oid: str,
--
crossbar/master/arealm/arealm.py-2046- raise NotImplementedError()
crossbar/master/arealm/arealm.py-2047-
crossbar/master/arealm/arealm.py:2048: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2049- def list_roles(self, return_names: Optional[bool] = None, details: Optional[CallDetails] = None) -> List[str]:
crossbar/master/arealm/arealm.py-2050- """
--
crossbar/master/arealm/arealm.py-2077- return []
crossbar/master/arealm/arealm.py-2078-
crossbar/master/arealm/arealm.py:2079: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2080- def get_role(self, role_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-2081- """
--
crossbar/master/arealm/arealm.py-2107- raise ApplicationError('crossbar.error.no_such_object', 'no role with oid {}'.format(role_oid_))
crossbar/master/arealm/arealm.py-2108-
crossbar/master/arealm/arealm.py:2109: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2110- def get_role_by_name(self, role_name: str, details: Optional[CallDetails] = None):
crossbar/master/arealm/arealm.py-2111- """
--
crossbar/master/arealm/arealm.py-2134- return role.marshal()
crossbar/master/arealm/arealm.py-2135-
crossbar/master/arealm/arealm.py:2136: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2137- async def create_role(self, role: dict, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-2138- """
--
crossbar/master/arealm/arealm.py-2168- return res_obj
crossbar/master/arealm/arealm.py-2169-
crossbar/master/arealm/arealm.py:2170: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2171- async def delete_role(self, role_oid: str, details: Optional[CallDetails] = None):
crossbar/master/arealm/arealm.py-2172- """
--
crossbar/master/arealm/arealm.py-2209- return res_obj
crossbar/master/arealm/arealm.py-2210-
crossbar/master/arealm/arealm.py:2211: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2212- def list_role_permissions(self,
crossbar/master/arealm/arealm.py-2213- role_oid: str,
--
crossbar/master/arealm/arealm.py-2249- return res
crossbar/master/arealm/arealm.py-2250-
crossbar/master/arealm/arealm.py:2251: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2252- async def add_role_permission(self,
crossbar/master/arealm/arealm.py-2253- role_oid: str,
--
crossbar/master/arealm/arealm.py-2298- return res_obj
crossbar/master/arealm/arealm.py-2299-
crossbar/master/arealm/arealm.py:2300: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2301- async def remove_role_permission(self,
crossbar/master/arealm/arealm.py-2302- role_oid: str,
--
crossbar/master/arealm/arealm.py-2346- return res_obj
crossbar/master/arealm/arealm.py-2347-
crossbar/master/arealm/arealm.py:2348: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2349- def get_role_permission(self, role_oid: str, permission_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-2350- """
--
crossbar/master/arealm/arealm.py-2390- return res_obj
crossbar/master/arealm/arealm.py-2391-
crossbar/master/arealm/arealm.py:2392: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2393- def get_role_permissions_by_uri(self,
crossbar/master/arealm/arealm.py-2394- role_oid: str,
--
crossbar/master/arealm/arealm.py-2431- return res
crossbar/master/arealm/arealm.py-2432-
crossbar/master/arealm/arealm.py:2433: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2434- def list_arealm_roles(self,
crossbar/master/arealm/arealm.py-2435- arealm_oid: str,
--
crossbar/master/arealm/arealm.py-2474- return res
crossbar/master/arealm/arealm.py-2475-
crossbar/master/arealm/arealm.py:2476: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2477- async def add_arealm_role(self,
crossbar/master/arealm/arealm.py-2478- arealm_oid: str,
--
crossbar/master/arealm/arealm.py-2524- return res_obj
crossbar/master/arealm/arealm.py-2525-
crossbar/master/arealm/arealm.py:2526: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2527- async def remove_arealm_role(self, arealm_oid: str, role_oid: str, details: Optional[CallDetails] = None):
crossbar/master/arealm/arealm.py-2528- """
--
crossbar/master/arealm/arealm.py-2579- return res_obj
crossbar/master/arealm/arealm.py-2580-
crossbar/master/arealm/arealm.py:2581: @wamp.register(None, check_types=True)
crossbar/master/arealm/arealm.py-2582- def get_arealm_role(self, arealm_oid: str, role_oid: str, details: Optional[CallDetails] = None) -> dict:
crossbar/master/arealm/arealm.py-2583- """
crossbar/master/node/controller.py-68- return session.register(self, prefix=prefix, options=options)
crossbar/master/node/controller.py-69-
crossbar/master/node/controller.py:70: @wamp.register(None)
crossbar/master/node/controller.py-71- def get_status(self, details=None):
crossbar/master/node/controller.py-72- """
--
crossbar/master/node/controller.py-98- return res
crossbar/master/node/controller.py-99-
crossbar/master/node/controller.py:100: @wamp.register(None)
crossbar/master/node/controller.py-101- def get_version(self, details=None):
crossbar/master/node/controller.py-102- """
--
crossbar/master/node/controller.py-121- return versions.marshal()
crossbar/master/node/controller.py-122-
crossbar/master/node/controller.py:123: @wamp.register(None)
crossbar/master/node/controller.py-124- def get_license(self, details=None):
crossbar/master/node/controller.py-125- """
crossbar/master/node/node.py-335- func=hltype(self._initialize_mrealm))
crossbar/master/node/node.py-336-
crossbar/master/node/node.py:337: @wamp.register(None)
crossbar/master/node/node.py-338- async def activate_realm(self, mrealm_obj, details=None):
crossbar/master/node/node.py-339- mrealm = ManagementRealm.parse(mrealm_obj)
--
crossbar/master/node/node.py-341- await self._initialize_mrealm(mrealm)
crossbar/master/node/node.py-342-
crossbar/master/node/node.py:343: @wamp.register(None)
crossbar/master/node/node.py-344- async def deactivate_realm(self, mrealm_obj, details=None):
crossbar/master/node/node.py-345- mrealm = ManagementRealm.parse(mrealm_obj)
crossbar/master/node/user.py-35- return session.register(self, prefix=prefix, options=options)
crossbar/master/node/user.py-36-
crossbar/master/node/user.py:37: @wamp.register(None)
crossbar/master/node/user.py-38- def list_organizations(self, details=None):
crossbar/master/node/user.py-39- """
--
crossbar/master/node/user.py-70- return []
crossbar/master/node/user.py-71-
crossbar/master/node/user.py:72: @wamp.register(None)
crossbar/master/node/user.py-73- def get_organization(self, org_oid, details=None):
crossbar/master/node/user.py-74- """
--
crossbar/master/node/user.py-121- raise ApplicationError('crossbar.error.no_such_object', 'no organization with oid {}'.format(org_oid))
crossbar/master/node/user.py-122-
crossbar/master/node/user.py:123: @wamp.register(None)
crossbar/master/node/user.py-124- async def create_organization(self, organization, details=None):
crossbar/master/node/user.py-125- """
--
crossbar/master/node/user.py-154- return res_obj
crossbar/master/node/user.py-155-
crossbar/master/node/user.py:156: @wamp.register(None)
crossbar/master/node/user.py-157- async def modify_organization(self, org_oid, org_delta, details=None):
crossbar/master/node/user.py-158- """
--
crossbar/master/node/user.py-166- raise NotImplementedError()
crossbar/master/node/user.py-167-
crossbar/master/node/user.py:168: @wamp.register(None)
crossbar/master/node/user.py-169- async def delete_organization(self, org_oid, cascade=False, details=None):
crossbar/master/node/user.py-170- """
--
crossbar/master/node/user.py-201- return res_obj
crossbar/master/node/user.py-202-
crossbar/master/node/user.py:203: @wamp.register(None)
crossbar/master/node/user.py-204- def get_user(self, user_id, details=None):
crossbar/master/node/user.py-205- """
--
crossbar/master/node/user.py-230- raise ApplicationError('crossbar.error.no_such_object', 'no user with oid {}'.format(user_id))
crossbar/master/node/user.py-231-
crossbar/master/node/user.py:232: @wamp.register(None)
crossbar/master/node/user.py-233- def get_user_by_pubkey(self, pubkey, details=None):
crossbar/master/node/user.py-234- """
--
crossbar/master/node/user.py-253- raise ApplicationError('crossbar.error.no_such_object', 'no user with pubkey {}'.format(pubkey))
crossbar/master/node/user.py-254-
crossbar/master/node/user.py:255: @wamp.register(None)
crossbar/master/node/user.py-256- def get_user_by_email(self, email, details=None):
crossbar/master/node/user.py-257- """
--
crossbar/master/node/user.py-274- raise ApplicationError('crossbar.error.no_such_object', 'no user with email "{}"'.format(email))
crossbar/master/node/user.py-275-
crossbar/master/node/user.py:276: @wamp.register(None)
crossbar/master/node/user.py-277- async def modify_user(self, user_id, user_delta, details=None):
crossbar/master/node/user.py-278- """
--
crossbar/master/node/user.py-298- raise NotImplementedError()
crossbar/master/node/user.py-299-
crossbar/master/node/user.py:300: @wamp.register(None)
crossbar/master/node/user.py-301- def list_users(self, details=None):
crossbar/master/node/user.py-302- """
--
crossbar/master/node/user.py-314- return users
crossbar/master/node/user.py-315-
crossbar/master/node/user.py:316: @wamp.register(None)
crossbar/master/node/user.py-317- async def list_users_by_organization(self, org_id, details=None):
crossbar/master/node/user.py-318- """
--
crossbar/master/node/user.py-327- raise NotImplementedError()
crossbar/master/node/user.py-328-
crossbar/master/node/user.py:329: @wamp.register(None)
crossbar/master/node/user.py-330- async def list_organizations_by_user(self, user_id, details=None):
crossbar/master/node/user.py-331- """
--
crossbar/master/node/user.py-340- raise NotImplementedError()
crossbar/master/node/user.py-341-
crossbar/master/node/user.py:342: @wamp.register(None)
crossbar/master/node/user.py-343- async def set_roles_on_organization_for_user(self, org_id, user_id, roles, details=None):
crossbar/master/node/user.py-344- """
--
crossbar/master/node/user.py-359- raise NotImplementedError()
crossbar/master/node/user.py-360-
crossbar/master/node/user.py:361: @wamp.register(None)
crossbar/master/node/user.py-362- async def get_roles_on_organization_for_user(self, org_id, user_id, details=None):
crossbar/master/node/user.py-363- """
crossbar/master/xbr/_marketplace.py-15- XBR Market Maker.
crossbar/master/xbr/_marketplace.py-16- """
crossbar/master/xbr/_marketplace.py:17: @wamp.register(None)
crossbar/master/xbr/_marketplace.py-18- def publish(self, publisher_id, api_id, service_id, price=None, details=None):
crossbar/master/xbr/_marketplace.py-19- """
crossbar/worker/router.py-142- dl.addBoth(lambda _: super(RouterController, self).onLeave(details))
crossbar/worker/router.py-143-
crossbar/worker/router.py:144: @wamp.register(None)
crossbar/worker/router.py-145- def get_router_realms(self, details=None):
crossbar/worker/router.py-146- """
--
crossbar/worker/router.py-157- return sorted(self.realms.keys())
crossbar/worker/router.py-158-
crossbar/worker/router.py:159: @wamp.register(None)
crossbar/worker/router.py-160- def get_router_realm(self, realm_id, details=None):
crossbar/worker/router.py-161- """
--
crossbar/worker/router.py-178- return self.realms[realm_id].marshal()
crossbar/worker/router.py-179-
crossbar/worker/router.py:180: @wamp.register(None)
crossbar/worker/router.py-181- def get_router_realm_by_name(self, realm_name, details=None):
crossbar/worker/router.py-182- """
--
crossbar/worker/router.py-201- return self.realms[self.realm_to_id[realm_name]].marshal()
crossbar/worker/router.py-202-
crossbar/worker/router.py:203: @wamp.register(None)
crossbar/worker/router.py-204- def get_router_realm_stats(self, realm_id=None, details=None):
crossbar/worker/router.py-205- """
--
crossbar/worker/router.py-232- return res
crossbar/worker/router.py-233-
crossbar/worker/router.py:234: @wamp.register(None)
crossbar/worker/router.py-235- @inlineCallbacks
crossbar/worker/router.py-236- def start_router_realm(self, realm_id, realm_config, details=None):
--
crossbar/worker/router.py-354- return event
crossbar/worker/router.py-355-
crossbar/worker/router.py:356: @wamp.register(None)
crossbar/worker/router.py-357- @inlineCallbacks
crossbar/worker/router.py-358- def stop_router_realm(self, realm_id, details=None):
--
crossbar/worker/router.py-463- return succeed(session)
crossbar/worker/router.py-464-
crossbar/worker/router.py:465: @wamp.register(None)
crossbar/worker/router.py-466- def get_router_realm_roles(self, realm_id, details=None):
crossbar/worker/router.py-467- """
--
crossbar/worker/router.py-484- return self.realms[realm_id].roles.values()
crossbar/worker/router.py-485-
crossbar/worker/router.py:486: @wamp.register(None)
crossbar/worker/router.py-487- def get_router_realm_role(self, realm_id, role_id, details=None):
crossbar/worker/router.py-488- """
--
crossbar/worker/router.py-515- return self.realms[realm_id].roles[role_id].marshal()
crossbar/worker/router.py-516-
crossbar/worker/router.py:517: @wamp.register(None)
crossbar/worker/router.py-518- def start_router_realm_role(self, realm_id, role_id, role_config, details=None):
crossbar/worker/router.py-519- """
--
crossbar/worker/router.py-570- return event
crossbar/worker/router.py-571-
crossbar/worker/router.py:572: @wamp.register(None)
crossbar/worker/router.py-573- def stop_router_realm_role(self, realm_id, role_id, details=None):
crossbar/worker/router.py-574- """
--
crossbar/worker/router.py-604- return event
crossbar/worker/router.py-605-
crossbar/worker/router.py:606: @wamp.register(None)
crossbar/worker/router.py-607- def get_router_components(self, details=None):
crossbar/worker/router.py-608- """
--
crossbar/worker/router.py-626- return res
crossbar/worker/router.py-627-
crossbar/worker/router.py:628: @wamp.register(None)
crossbar/worker/router.py-629- def get_router_component(self, id, details=None):
crossbar/worker/router.py-630- """
--
crossbar/worker/router.py-646- raise ApplicationError("crossbar.error.no_such_object", "No component {}".format(id))
crossbar/worker/router.py-647-
crossbar/worker/router.py:648: @wamp.register(None)
crossbar/worker/router.py-649- def start_router_component(self, id, config, details=None):
crossbar/worker/router.py-650- """
--
crossbar/worker/router.py-834- return started_d
crossbar/worker/router.py-835-
crossbar/worker/router.py:836: @wamp.register(None)
crossbar/worker/router.py-837- def stop_router_component(self, id, details=None):
crossbar/worker/router.py-838- """
--
crossbar/worker/router.py-859- raise ApplicationError("crossbar.error.no_such_object", "No component {}".format(id))
crossbar/worker/router.py-860-
crossbar/worker/router.py:861: @wamp.register(None)
crossbar/worker/router.py-862- def get_router_transports(self, details=None):
crossbar/worker/router.py-863- """
--
crossbar/worker/router.py-877- return res
crossbar/worker/router.py-878-
crossbar/worker/router.py:879: @wamp.register(None)
crossbar/worker/router.py-880- def get_router_transport(self, transport_id, details=None):
crossbar/worker/router.py-881- """
--
crossbar/worker/router.py-897- raise ApplicationError("crossbar.error.no_such_object", "No transport {}".format(transport_id))
crossbar/worker/router.py-898-
crossbar/worker/router.py:899: @wamp.register(None)
crossbar/worker/router.py-900- def start_router_transport(self, transport_id, config, create_paths=False, details=None):
crossbar/worker/router.py-901- """
--
crossbar/worker/router.py-973- return d
crossbar/worker/router.py-974-
crossbar/worker/router.py:975: @wamp.register(None)
crossbar/worker/router.py-976- def stop_router_transport(self, transport_id, details=None):
crossbar/worker/router.py-977- """
--
crossbar/worker/router.py-1022- return d
crossbar/worker/router.py-1023-
crossbar/worker/router.py:1024: @wamp.register(None)
crossbar/worker/router.py-1025- def kill_by_authid(self, realm_id, authid, reason, message=None, details=None):
crossbar/worker/router.py-1026- self.log.info('Killing sessions by authid="{authid}" ..',
--
crossbar/worker/router.py-1035- return self.realms[realm_id].session.session_kill_by_authid(authid, reason, message=message, details=details)
crossbar/worker/router.py-1036-
crossbar/worker/router.py:1037: @wamp.register(None)
crossbar/worker/router.py-1038- def get_router_realm_links(self, realm_id, details=None):
crossbar/worker/router.py-1039- """
--
crossbar/worker/router.py-1060- return sorted([str(k) for k in rlink_manager.keys()])
crossbar/worker/router.py-1061-
crossbar/worker/router.py:1062: @wamp.register(None)
crossbar/worker/router.py-1063- def get_router_realm_link(self, realm_id, link_id, details=None):
crossbar/worker/router.py-1064- """
--
crossbar/worker/router.py-1095- return rlink.marshal()
crossbar/worker/router.py-1096-
crossbar/worker/router.py:1097: @wamp.register(None)
crossbar/worker/router.py-1098- @inlineCallbacks
crossbar/worker/router.py-1099- def start_router_realm_link(self, realm_id, link_id, link_config, details=None):
--
crossbar/worker/router.py-1170- returnValue(started)
crossbar/worker/router.py-1171-
crossbar/worker/router.py:1172: @wamp.register(None)
crossbar/worker/router.py-1173- @inlineCallbacks
crossbar/worker/router.py-1174- def stop_router_realm_link(self, realm_id, link_id, details=None):
crossbar/worker/transport.py-433- self.transports = {}
crossbar/worker/transport.py-434-
crossbar/worker/transport.py:435: @wamp.register(None)
crossbar/worker/transport.py-436- @inlineCallbacks
crossbar/worker/transport.py-437- def start_web_transport_service(self, transport_id, path, config, details=None):
--
crossbar/worker/transport.py-507- returnValue(on_web_transport_service_started)
crossbar/worker/transport.py-508-
crossbar/worker/transport.py:509: @wamp.register(None)
crossbar/worker/transport.py-510- def stop_web_transport_service(self, transport_id, path, details=None):
crossbar/worker/transport.py-511- """
--
crossbar/worker/transport.py-564- return on_web_transport_service_stopped
crossbar/worker/transport.py-565-
crossbar/worker/transport.py:566: @wamp.register(None)
crossbar/worker/transport.py-567- def get_web_transport_service(self, transport_id, path, details=None):
crossbar/worker/transport.py-568- self.log.debug('{func}(transport_id={transport_id}, path="{path}")',
--
crossbar/worker/transport.py-586- return transport.marshal()
crossbar/worker/transport.py-587-
crossbar/worker/transport.py:588: @wamp.register(None)
crossbar/worker/transport.py-589- def get_web_transport_services(self, transport_id, details=None):
crossbar/worker/transport.py-590- self.log.debug('{func}(transport_id={transport_id})',
crossbar/worker/proxy.py-1624- yield self.publish_ready()
crossbar/worker/proxy.py-1625-
crossbar/worker/proxy.py:1626: @wamp.register(None)
crossbar/worker/proxy.py-1627- def get_proxy_transports(self, details=None):
crossbar/worker/proxy.py-1628- """
--
crossbar/worker/proxy.py-1640- return sorted(self.transports.keys())
crossbar/worker/proxy.py-1641-
crossbar/worker/proxy.py:1642: @wamp.register(None)
crossbar/worker/proxy.py-1643- def get_proxy_transport(self, transport_id, details=None):
crossbar/worker/proxy.py-1644- """
--
crossbar/worker/proxy.py-1663-
crossbar/worker/proxy.py-1664- @inlineCallbacks
crossbar/worker/proxy.py:1665: @wamp.register(None)
crossbar/worker/proxy.py-1666- def start_proxy_transport(self, transport_id, config, details=None):
crossbar/worker/proxy.py-1667- """
--
crossbar/worker/proxy.py-1724-
crossbar/worker/proxy.py-1725- @inlineCallbacks
crossbar/worker/proxy.py:1726: @wamp.register(None)
crossbar/worker/proxy.py-1727- def stop_proxy_transport(self, transport_id, details=None):
crossbar/worker/proxy.py-1728- """
--
crossbar/worker/proxy.py-1753- return transport_stopped
crossbar/worker/proxy.py-1754-
crossbar/worker/proxy.py:1755: @wamp.register(None)
crossbar/worker/proxy.py-1756- def get_proxy_routes(self, details=None):
crossbar/worker/proxy.py-1757- """
--
crossbar/worker/proxy.py-1769- return sorted(self._routes.keys())
crossbar/worker/proxy.py-1770-
crossbar/worker/proxy.py:1771: @wamp.register(None)
crossbar/worker/proxy.py-1772- def list_proxy_realm_routes(self, realm_name, details=None):
crossbar/worker/proxy.py-1773- """
--
crossbar/worker/proxy.py-1780- 'No route for realm "{}" in proxy'.format(realm_name))
crossbar/worker/proxy.py-1781-
crossbar/worker/proxy.py:1782: @wamp.register(None)
crossbar/worker/proxy.py-1783- def get_proxy_realm_route(self, realm_name, route_id, details=None):
crossbar/worker/proxy.py-1784- """
--
crossbar/worker/proxy.py-1803-
crossbar/worker/proxy.py-1804- @inlineCallbacks
crossbar/worker/proxy.py:1805: @wamp.register(None)
crossbar/worker/proxy.py-1806- def start_proxy_realm_route(self, realm_name, config, details=None):
crossbar/worker/proxy.py-1807- """
--
crossbar/worker/proxy.py-1876-
crossbar/worker/proxy.py-1877- @inlineCallbacks
crossbar/worker/proxy.py:1878: @wamp.register(None)
crossbar/worker/proxy.py-1879- def stop_proxy_realm_route(self, realm_name, route_id, details=None):
crossbar/worker/proxy.py-1880- """
--
crossbar/worker/proxy.py-1908- returnValue(route.marshal())
crossbar/worker/proxy.py-1909-
crossbar/worker/proxy.py:1910: @wamp.register(None)
crossbar/worker/proxy.py-1911- def get_proxy_connections(self, details=None):
crossbar/worker/proxy.py-1912- """
--
crossbar/worker/proxy.py-1922- return sorted(self._connections.keys())
crossbar/worker/proxy.py-1923-
crossbar/worker/proxy.py:1924: @wamp.register(None)
crossbar/worker/proxy.py-1925- def get_proxy_connection(self, connection_id, details=None):
crossbar/worker/proxy.py-1926- """
--
crossbar/worker/proxy.py-1944-
crossbar/worker/proxy.py-1945- @inlineCallbacks
crossbar/worker/proxy.py:1946: @wamp.register(None)
crossbar/worker/proxy.py-1947- def start_proxy_connection(self, connection_id, config, details=None):
crossbar/worker/proxy.py-1948- """
--
crossbar/worker/proxy.py-1972-
crossbar/worker/proxy.py-1973- @inlineCallbacks
crossbar/worker/proxy.py:1974: @wamp.register(None)
crossbar/worker/proxy.py-1975- def stop_proxy_connection(self, connection_id, details=None):
crossbar/worker/proxy.py-1976- """
crossbar/worker/container.py-124- yield self.publish_ready()
crossbar/worker/container.py-125-
crossbar/worker/container.py:126: @wamp.register(None)
crossbar/worker/container.py-127- def shutdown(self, details=None):
crossbar/worker/container.py-128- """
--
crossbar/worker/container.py-145- return stopped_component_ids
crossbar/worker/container.py-146-
crossbar/worker/container.py:147: @wamp.register(None)
crossbar/worker/container.py-148- def start_component(self, component_id, config, reload_modules=False, details=None):
crossbar/worker/container.py-149- """
--
crossbar/worker/container.py-502- return event
crossbar/worker/container.py-503-
crossbar/worker/container.py:504: @wamp.register(None)
crossbar/worker/container.py-505- @inlineCallbacks
crossbar/worker/container.py-506- def restart_component(self, component_id, reload_modules=False, details=None):
--
crossbar/worker/container.py-552- returnValue(restarted)
crossbar/worker/container.py-553-
crossbar/worker/container.py:554: @wamp.register(None)
crossbar/worker/container.py-555- @inlineCallbacks
crossbar/worker/container.py-556- def stop_component(self, component_id, details=None):
--
crossbar/worker/container.py-611- returnValue(stopped)
crossbar/worker/container.py-612-
crossbar/worker/container.py:613: @wamp.register(None)
crossbar/worker/container.py-614- def get_component(self, component_id, details=None):
crossbar/worker/container.py-615- """
--
crossbar/worker/container.py-636- return self.components[component_id].marshal()
crossbar/worker/container.py-637-
crossbar/worker/container.py:638: @wamp.register(None)
crossbar/worker/container.py-639- def get_components(self, details=None):
crossbar/worker/container.py-640- """
crossbar/worker/controller.py-87- yield NativeProcess.onJoin(self, details)
crossbar/worker/controller.py-88-
crossbar/worker/controller.py:89: # above upcall registers all our "@wamp.register(None)" methods
crossbar/worker/controller.py-90-
crossbar/worker/controller.py-91- # setup SIGTERM handler to orderly shutdown the worker
--
crossbar/worker/controller.py-128- term_print('CROSSBAR[{}]:WORKER_STARTED'.format(self.config.extra.worker))
crossbar/worker/controller.py-129-
crossbar/worker/controller.py:130: @wamp.register(None)
crossbar/worker/controller.py-131- @inlineCallbacks
crossbar/worker/controller.py-132- def shutdown(self, details=None):
--
crossbar/worker/controller.py-158- self._reactor.callLater(0, self.leave)
crossbar/worker/controller.py-159-
crossbar/worker/controller.py:160: @wamp.register(None)
crossbar/worker/controller.py-161- def set_node_id(self, node_id, details=None):
crossbar/worker/controller.py-162- self._node_id = node_id
crossbar/worker/controller.py-163-
crossbar/worker/controller.py:164: @wamp.register(None)
crossbar/worker/controller.py-165- def get_node_id(self, details=None):
crossbar/worker/controller.py-166- return self._node_id
crossbar/worker/controller.py-167-
crossbar/worker/controller.py:168: @wamp.register(None)
crossbar/worker/controller.py-169- def get_profilers(self, details=None):
crossbar/worker/controller.py-170- """
--
crossbar/worker/controller.py-181- return [p.marshal() for p in PROFILERS.items()]
crossbar/worker/controller.py-182-
crossbar/worker/controller.py:183: @wamp.register(None)
crossbar/worker/controller.py-184- def start_profiler(self, profiler='vmprof', runtime=10, start_async=True, details=None):
crossbar/worker/controller.py-185- """
--
crossbar/worker/controller.py-274- return profile_finished
crossbar/worker/controller.py-275-
crossbar/worker/controller.py:276: @wamp.register(None)
crossbar/worker/controller.py-277- def get_profile(self, profile_id, details=None):
crossbar/worker/controller.py-278- """
--
crossbar/worker/controller.py-290- raise ApplicationError('crossbar.error.no_such_object', 'no profile with ID {} saved'.format(profile_id))
crossbar/worker/controller.py-291-
crossbar/worker/controller.py:292: @wamp.register(None)
crossbar/worker/controller.py-293- def get_pythonpath(self, details=None):
crossbar/worker/controller.py-294- """
--
crossbar/worker/controller.py-304- return sys.path
crossbar/worker/controller.py-305-
crossbar/worker/controller.py:306: @wamp.register(None)
crossbar/worker/controller.py-307- def add_pythonpath(self, paths, prepend=True, details=None):
crossbar/worker/controller.py-308- """
crossbar/worker/testee.py-130- yield self.publish_ready()
crossbar/worker/testee.py-131-
crossbar/worker/testee.py:132: @wamp.register(None)
crossbar/worker/testee.py-133- def get_websocket_testee_transport(self, details=None):
crossbar/worker/testee.py-134- """
--
crossbar/worker/testee.py-136- self.log.debug("{name}.get_websocket_testee_transport", name=self.__class__.__name__)
crossbar/worker/testee.py-137-
crossbar/worker/testee.py:138: @wamp.register(None)
crossbar/worker/testee.py-139- def start_websocket_testee_transport(self, id, config, details=None):
crossbar/worker/testee.py-140- """
--
crossbar/worker/testee.py-192- return d
crossbar/worker/testee.py-193-
crossbar/worker/testee.py:194: @wamp.register(None)
crossbar/worker/testee.py-195- def stop_websocket_testee_transport(self, id, details=None):
crossbar/worker/testee.py-196- """
crossbar/node/controller.py-145- yield NativeProcess.onJoin(self, details)
crossbar/node/controller.py-146-
crossbar/node/controller.py:147: # above upcall registers procedures we have marked with @wamp.register(None)
crossbar/node/controller.py-148-
crossbar/node/controller.py-149- # we need to catch SIGINT here to properly shutdown the
--
crossbar/node/controller.py-179- self.log.debug("Node controller ready")
crossbar/node/controller.py-180-
crossbar/node/controller.py:181: @wamp.register(None)
crossbar/node/controller.py-182- def get_status(self, details=None):
crossbar/node/controller.py-183- """
--
crossbar/node/controller.py-206- }
crossbar/node/controller.py-207-
crossbar/node/controller.py:208: @wamp.register(None)
crossbar/node/controller.py-209- def get_system_stats(self, details=None):
crossbar/node/controller.py-210- """
--
crossbar/node/controller.py-233- return res
crossbar/node/controller.py-234-
crossbar/node/controller.py:235: @wamp.register(None)
crossbar/node/controller.py-236- @inlineCallbacks
crossbar/node/controller.py-237- def shutdown(self, restart=False, mode=None, details=None):
--
crossbar/node/controller.py-293- pass
crossbar/node/controller.py-294-
crossbar/node/controller.py:295: @wamp.register(None)
crossbar/node/controller.py-296- def get_workers(self, filter_types=[], details=None):
crossbar/node/controller.py-297- """
--
crossbar/node/controller.py-311- return sorted(worker_ids)
crossbar/node/controller.py-312-
crossbar/node/controller.py:313: @wamp.register(None)
crossbar/node/controller.py-314- def get_worker(self, worker_id, include_stats=False, details=None):
crossbar/node/controller.py-315- """
--
crossbar/node/controller.py-346- return worker_info
crossbar/node/controller.py-347-
crossbar/node/controller.py:348: @wamp.register(None)
crossbar/node/controller.py-349- def start_worker(self, worker_id, worker_type, worker_options=None, details=None):
crossbar/node/controller.py-350- """
--
crossbar/node/controller.py-368- raise Exception('invalid worker type "{}"'.format(worker_type))
crossbar/node/controller.py-369-
crossbar/node/controller.py:370: @wamp.register(None)
crossbar/node/controller.py-371- def stop_worker(self, worker_id, kill=False, details=None):
crossbar/node/controller.py-372- """
--
crossbar/node/controller.py-398- raise Exception('logic error')
crossbar/node/controller.py-399-
crossbar/node/controller.py:400: @wamp.register(None)
crossbar/node/controller.py-401- def get_worker_log(self, worker_id, limit=100, details=None):
crossbar/node/controller.py-402- """
--
crossbar/node/controller.py-418- return self._workers[worker_id].getlog(limit)
crossbar/node/controller.py-419-
crossbar/node/controller.py:420: @wamp.register(None)
crossbar/node/controller.py-421- def sign_challenge(self,
crossbar/node/controller.py-422- challenge_method,
--
crossbar/node/controller.py-429- return sign_challenge(data, self._node._node_key.sign)
crossbar/node/controller.py-430-
crossbar/node/controller.py:431: @wamp.register(None)
crossbar/node/controller.py-432- def get_public_key(self, details=None):
crossbar/node/controller.py-433- return self._node._node_key.public_key()
crossbar/common/process.py-216- returnValue(regs)
crossbar/common/process.py-217-
crossbar/common/process.py:218: @wamp.register(None)
crossbar/common/process.py-219- def get_cpu_count(self, logical=True, details=None):
crossbar/common/process.py-220- """
--
crossbar/common/process.py-235- return psutil.cpu_count(logical=logical)
crossbar/common/process.py-236-
crossbar/common/process.py:237: @wamp.register(None)
crossbar/common/process.py-238- def get_cpus(self, details=None):
crossbar/common/process.py-239- """
--
crossbar/common/process.py-249- return self._pinfo.cpus
crossbar/common/process.py-250-
crossbar/common/process.py:251: @wamp.register(None)
crossbar/common/process.py-252- def get_cpu_affinity(self, details=None):
crossbar/common/process.py-253- """
--
crossbar/common/process.py-272- return current_affinity
crossbar/common/process.py-273-
crossbar/common/process.py:274: @wamp.register(None)
crossbar/common/process.py-275- def set_cpu_affinity(self, cpus, relative=True, details=None):
crossbar/common/process.py-276- """
--
crossbar/common/process.py-330- return new_affinity
crossbar/common/process.py-331-
crossbar/common/process.py:332: @wamp.register(None)
crossbar/common/process.py-333- def get_process_info(self, details=None):
crossbar/common/process.py-334- """
--
crossbar/common/process.py-347- raise ApplicationError("crossbar.error.feature_unavailable", emsg)
crossbar/common/process.py-348-
crossbar/common/process.py:349: @wamp.register(None)
crossbar/common/process.py-350- def get_process_stats(self, details=None):
crossbar/common/process.py-351- """
--
crossbar/common/process.py-362- raise ApplicationError("crossbar.error.feature_unavailable", emsg)
crossbar/common/process.py-363-
crossbar/common/process.py:364: @wamp.register(None)
crossbar/common/process.py-365- def get_process_monitor(self, details=None):
crossbar/common/process.py-366- self.log.debug("{cls}.get_process_monitor", cls=self.__class__.__name__)
--
crossbar/common/process.py-372- raise ApplicationError("crossbar.error.feature_unavailable", emsg)
crossbar/common/process.py-373-
crossbar/common/process.py:374: @wamp.register(None)
crossbar/common/process.py-375- def set_process_stats_monitoring(self, interval, details=None):
crossbar/common/process.py-376- """
--
crossbar/common/process.py-413- raise ApplicationError("crossbar.error.feature_unavailable", emsg)
crossbar/common/process.py-414-
crossbar/common/process.py:415: @wamp.register(None)
crossbar/common/process.py-416- def trigger_gc(self, details=None):
crossbar/common/process.py-417- """
--
crossbar/common/process.py-471- return duration
crossbar/common/process.py-472-
crossbar/common/process.py:473: @wamp.register(None)
crossbar/common/process.py-474- @inlineCallbacks
crossbar/common/process.py-475- def start_manhole(self, config, details=None):
--
crossbar/common/process.py-630- returnValue(started_info)
crossbar/common/process.py-631-
crossbar/common/process.py:632: @wamp.register(None)
crossbar/common/process.py-633- @inlineCallbacks
crossbar/common/process.py-634- def stop_manhole(self, details=None):
--
crossbar/common/process.py-686- returnValue(stopped_info)
crossbar/common/process.py-687-
crossbar/common/process.py:688: @wamp.register(None)
crossbar/common/process.py-689- def get_manhole(self, details=None):
crossbar/common/process.py-690- """
--
crossbar/common/process.py-705- return self._manhole_service.marshal()
crossbar/common/process.py-706-
crossbar/common/process.py:707: @wamp.register(None)
crossbar/common/process.py-708- def utcnow(self, details=None):
crossbar/common/process.py-709- """
--
crossbar/common/process.py-724- return utcnow()
crossbar/common/process.py-725-
crossbar/common/process.py:726: @wamp.register(None)
crossbar/common/process.py-727- def started(self, details=None):
crossbar/common/process.py-728- """
--
crossbar/common/process.py-743- return utcstr(self._started)
crossbar/common/process.py-744-
crossbar/common/process.py:745: @wamp.register(None)
crossbar/common/process.py-746- def uptime(self, details=None):
crossbar/common/process.py-747- """
crossbar/edge/worker/router.py-157- self._next_trace = 1
crossbar/edge/worker/router.py-158-
crossbar/edge/worker/router.py:159: @wamp.register(None)
crossbar/edge/worker/router.py-160- def start_router_realm(self, realm_id, realm_config, details=None):
crossbar/edge/worker/router.py-161- self.log.info('Starting router realm "{realm_id}" {method}',
--
crossbar/edge/worker/router.py-187- trace.maybe_trace_tx_msg(session, msg)
crossbar/edge/worker/router.py-188-
crossbar/edge/worker/router.py:189: @wamp.register(None)
crossbar/edge/worker/router.py-190- def get_traces(self, include_stopped=False, details=None):
crossbar/edge/worker/router.py-191- self.log.debug('get_traces(inclue_stopped="{include_stopped}")', include_stopped=include_stopped)
--
crossbar/edge/worker/router.py-193- return sorted(self._traces.keys())
crossbar/edge/worker/router.py-194-
crossbar/edge/worker/router.py:195: @wamp.register(None)
crossbar/edge/worker/router.py-196- def get_trace(self, trace_id, details=None):
crossbar/edge/worker/router.py-197- self.log.debug('get_trace(trace_id="{trace_id}")', trace_id=trace_id)
--
crossbar/edge/worker/router.py-202- return self._traces[trace_id].marshal()
crossbar/edge/worker/router.py-203-
crossbar/edge/worker/router.py:204: @wamp.register(None)
crossbar/edge/worker/router.py-205- def start_trace(self, trace_id=None, trace_options=None, details=None):
crossbar/edge/worker/router.py-206- self.log.info('start_trace(trace_id="{trace_id}", trace_options="{trace_options}")',
--
crossbar/edge/worker/router.py-301- return trace_started
crossbar/edge/worker/router.py-302-
crossbar/edge/worker/router.py:303: @wamp.register(None)
crossbar/edge/worker/router.py-304- def stop_trace(self, trace_id, details=None):
crossbar/edge/worker/router.py-305- self.log.info('stop_trace(trace_id="{trace_id}")', trace_id=trace_id)
--
crossbar/edge/worker/router.py-319- return trace_stopped
crossbar/edge/worker/router.py-320-
crossbar/edge/worker/router.py:321: @wamp.register(None)
crossbar/edge/worker/router.py-322- def get_trace_data(self, trace_id, from_seq, to_seq=None, limit=None, details=None):
crossbar/edge/worker/router.py-323- self.log.debug(
--
crossbar/edge/worker/router.py-337- return self._traces[trace_id].get_data(from_seq, to_seq, limit)
crossbar/edge/worker/router.py-338-
crossbar/edge/worker/router.py:339: @wamp.register(None)
crossbar/edge/worker/router.py-340- def start_router_realm_interface(self, realm_id, interface_id, interface_config, details=None):
crossbar/edge/worker/router.py-341- if realm_id not in self.realms:
--
crossbar/edge/worker/router.py-357- self.publish(topic, event, options=PublishOptions(exclude=caller))
crossbar/edge/worker/router.py-358-
crossbar/edge/worker/router.py:359: @wamp.register(None)
crossbar/edge/worker/router.py-360- def stop_router_realm_interface(self, realm_id, interface_id, details=None):
crossbar/edge/worker/router.py-361- if realm_id not in self.realms:
--
crossbar/edge/worker/router.py-368- del self.realms[realm_id].interfaces[interface_id]
crossbar/edge/worker/router.py-369-
crossbar/edge/worker/router.py:370: @wamp.register(None)
crossbar/edge/worker/router.py-371- def get_router_realm_interface(self, realm_id, details=None):
crossbar/edge/worker/router.py-372- if realm_id not in self.realms:
crossbar/edge/worker/xbrmm.py-858-
crossbar/edge/worker/xbrmm.py-859- @inlineCallbacks
crossbar/edge/worker/xbrmm.py:860: @wamp.register(None)
crossbar/edge/worker/xbrmm.py-861- def start_market_maker(self, maker_id, config, details=None):
crossbar/edge/worker/xbrmm.py-862- """
--
crossbar/edge/worker/xbrmm.py-909-
crossbar/edge/worker/xbrmm.py-910- @inlineCallbacks
crossbar/edge/worker/xbrmm.py:911: @wamp.register(None)
crossbar/edge/worker/xbrmm.py-912- def stop_market_maker(self, maker_id, details=None):
crossbar/edge/worker/xbrmm.py-913- if type(maker_id) != str:
crossbar/edge/worker/xbr/_marketmaker.py-532-
crossbar/edge/worker/xbr/_marketmaker.py-533- # FIXME: remove after refactoring
crossbar/edge/worker/xbr/_marketmaker.py:534: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-535- async def status(self, details: Optional[CallDetails]) -> dict:
crossbar/edge/worker/xbr/_marketmaker.py-536- """
--
crossbar/edge/worker/xbr/_marketmaker.py-564- return status
crossbar/edge/worker/xbr/_marketmaker.py-565-
crossbar/edge/worker/xbr/_marketmaker.py:566: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-567- async def get_transaction_receipt(self, transaction: bytes, details: Optional[CallDetails] = None) -> dict:
crossbar/edge/worker/xbr/_marketmaker.py-568- assert details is None or isinstance(
--
crossbar/edge/worker/xbr/_marketmaker.py-594- return receipt
crossbar/edge/worker/xbr/_marketmaker.py-595-
crossbar/edge/worker/xbr/_marketmaker.py:596: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-597- async def get_gas_price(self, details: Optional[CallDetails] = None) -> bytes:
crossbar/edge/worker/xbr/_marketmaker.py-598- assert details is None or isinstance(
--
crossbar/edge/worker/xbr/_marketmaker.py-606- return gas_price
crossbar/edge/worker/xbr/_marketmaker.py-607-
crossbar/edge/worker/xbr/_marketmaker.py:608: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-609- async def get_config(self, include_eula_text: bool = False, details: Optional[CallDetails] = None) -> dict:
crossbar/edge/worker/xbr/_marketmaker.py-610- assert type(include_eula_text) == bool, 'include_eula_text must be bool, was {}'.format(
--
crossbar/edge/worker/xbr/_marketmaker.py-666- return config
crossbar/edge/worker/xbr/_marketmaker.py-667-
crossbar/edge/worker/xbr/_marketmaker.py:668: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-669- async def get_status(self, details: Optional[CallDetails] = None) -> dict:
crossbar/edge/worker/xbr/_marketmaker.py-670- assert details is None or isinstance(
--
crossbar/edge/worker/xbr/_marketmaker.py-693- return status
crossbar/edge/worker/xbr/_marketmaker.py-694-
crossbar/edge/worker/xbr/_marketmaker.py:695: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-696- async def place_offer(self,
crossbar/edge/worker/xbr/_marketmaker.py-697- key_id,
--
crossbar/edge/worker/xbr/_marketmaker.py-867- return offer_created
crossbar/edge/worker/xbr/_marketmaker.py-868-
crossbar/edge/worker/xbr/_marketmaker.py:869: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-870- def get_offer(self, offer_id, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-871- """
--
crossbar/edge/worker/xbr/_marketmaker.py-894- return offer.marshal()
crossbar/edge/worker/xbr/_marketmaker.py-895-
crossbar/edge/worker/xbr/_marketmaker.py:896: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-897- def query_offers(self,
crossbar/edge/worker/xbr/_marketmaker.py-898- api_id,
--
crossbar/edge/worker/xbr/_marketmaker.py-974- raise NotImplementedError()
crossbar/edge/worker/xbr/_marketmaker.py-975-
crossbar/edge/worker/xbr/_marketmaker.py:976: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-977- def revoke_offer(self, key_id, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-978- """
--
crossbar/edge/worker/xbr/_marketmaker.py-1025- return offer_revoked
crossbar/edge/worker/xbr/_marketmaker.py-1026-
crossbar/edge/worker/xbr/_marketmaker.py:1027: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-1028- def get_quote(self, key_id, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-1029- """
--
crossbar/edge/worker/xbr/_marketmaker.py-1079- return quote
crossbar/edge/worker/xbr/_marketmaker.py-1080-
crossbar/edge/worker/xbr/_marketmaker.py:1081: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-1082- async def buy_key(self,
crossbar/edge/worker/xbr/_marketmaker.py-1083- delegate_adr,
--
crossbar/edge/worker/xbr/_marketmaker.py-1599- return receipt
crossbar/edge/worker/xbr/_marketmaker.py-1600-
crossbar/edge/worker/xbr/_marketmaker.py:1601: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-1602- async def open_channel(self,
crossbar/edge/worker/xbr/_marketmaker.py-1603- member_adr: bytes,
--
crossbar/edge/worker/xbr/_marketmaker.py-1744- return open_channel_submitted
crossbar/edge/worker/xbr/_marketmaker.py-1745-
crossbar/edge/worker/xbr/_marketmaker.py:1746: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-1747- async def close_channel(self,
crossbar/edge/worker/xbr/_marketmaker.py-1748- channel_oid: bytes,
--
crossbar/edge/worker/xbr/_marketmaker.py-1945- return closing
crossbar/edge/worker/xbr/_marketmaker.py-1946-
crossbar/edge/worker/xbr/_marketmaker.py:1947: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-1948- def get_payment_channel(self, channel_oid, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-1949- """
--
crossbar/edge/worker/xbr/_marketmaker.py-1977- return channel.marshal()
crossbar/edge/worker/xbr/_marketmaker.py-1978-
crossbar/edge/worker/xbr/_marketmaker.py:1979: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-1980- def get_channels_by_delegate(self,
crossbar/edge/worker/xbr/_marketmaker.py-1981- delegate_adr: bytes,
--
crossbar/edge/worker/xbr/_marketmaker.py-2027- return channels
crossbar/edge/worker/xbr/_marketmaker.py-2028-
crossbar/edge/worker/xbr/_marketmaker.py:2029: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2030- def get_channels_by_actor(self, member_adr, channel_type, filter_open=True, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-2031- if channel_type not in [cfxdb.xbrmm.ChannelType.PAYMENT, cfxdb.xbrmm.ChannelType.PAYING]:
--
crossbar/edge/worker/xbr/_marketmaker.py-2072- return channels
crossbar/edge/worker/xbr/_marketmaker.py-2073-
crossbar/edge/worker/xbr/_marketmaker.py:2074: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2075- def get_payment_channel_balance(self, channel_oid, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-2076- """
--
crossbar/edge/worker/xbr/_marketmaker.py-2105- return balance.marshal()
crossbar/edge/worker/xbr/_marketmaker.py-2106-
crossbar/edge/worker/xbr/_marketmaker.py:2107: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2108- def get_paying_channel(self, channel_oid, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-2109- """
--
crossbar/edge/worker/xbr/_marketmaker.py-2137- return channel.marshal()
crossbar/edge/worker/xbr/_marketmaker.py-2138-
crossbar/edge/worker/xbr/_marketmaker.py:2139: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2140- def get_paying_channel_balance(self, channel_oid, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-2141- """
--
crossbar/edge/worker/xbr/_marketmaker.py-2170- return balance.marshal()
crossbar/edge/worker/xbr/_marketmaker.py-2171-
crossbar/edge/worker/xbr/_marketmaker.py:2172: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2173- def get_active_payment_channel(self, delegate_adr, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-2174- """
--
crossbar/edge/worker/xbr/_marketmaker.py-2205- return None
crossbar/edge/worker/xbr/_marketmaker.py-2206-
crossbar/edge/worker/xbr/_marketmaker.py:2207: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2208- def get_active_paying_channel(self, delegate_adr, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-2209- """
--
crossbar/edge/worker/xbr/_marketmaker.py-2366- raise Exception('failed to transfer tokens [2]')
crossbar/edge/worker/xbr/_marketmaker.py-2367-
crossbar/edge/worker/xbr/_marketmaker.py:2368: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2369- async def set_consent(self,
crossbar/edge/worker/xbr/_marketmaker.py-2370- member_adr: bytes,
--
crossbar/edge/worker/xbr/_marketmaker.py-2517- return consent_.marshal()
crossbar/edge/worker/xbr/_marketmaker.py-2518-
crossbar/edge/worker/xbr/_marketmaker.py:2519: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2520- def get_consent(self,
crossbar/edge/worker/xbr/_marketmaker.py-2521- market_oid: bytes,
--
crossbar/edge/worker/xbr/_marketmaker.py-2548- return consent.marshal()
crossbar/edge/worker/xbr/_marketmaker.py-2549-
crossbar/edge/worker/xbr/_marketmaker.py:2550: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2551- async def find_consents(self,
crossbar/edge/worker/xbr/_marketmaker.py-2552- created_from: Optional[int] = None,
--
crossbar/edge/worker/xbr/_marketmaker.py-2609- raise NotImplementedError()
crossbar/edge/worker/xbr/_marketmaker.py-2610-
crossbar/edge/worker/xbr/_marketmaker.py:2611: @wamp.register(None, check_types=True)
crossbar/edge/worker/xbr/_marketmaker.py-2612- async def get_catalogs_by_owner(self, owner_adr: bytes, details: Optional[CallDetails] = None):
crossbar/edge/worker/xbr/_marketmaker.py-2613- """
crossbar/edge/worker/hostmonitor.py-76- self.disconnect()
crossbar/edge/worker/hostmonitor.py-77-
crossbar/edge/worker/hostmonitor.py:78: @wamp.register(None)
crossbar/edge/worker/hostmonitor.py-79- def get_monitoring(self, sensors=None, details=None):
crossbar/edge/worker/hostmonitor.py-80- if self._run:
--
crossbar/edge/worker/hostmonitor.py-100- return monitoring
crossbar/edge/worker/hostmonitor.py-101-
crossbar/edge/worker/hostmonitor.py:102: @wamp.register(None)
crossbar/edge/worker/hostmonitor.py-103- def start_monitoring(self, config, details=None):
crossbar/edge/worker/hostmonitor.py-104- """
--
crossbar/edge/worker/hostmonitor.py-173- return started
crossbar/edge/worker/hostmonitor.py-174-
crossbar/edge/worker/hostmonitor.py:175: @wamp.register(None)
crossbar/edge/worker/hostmonitor.py-176- def stop_monitoring(self, details=None):
crossbar/edge/worker/hostmonitor.py-177- self.log.info('HostMonitor stop monitoring ..')
crossbar/edge/node/node.py-156- self._docker_client = None
crossbar/edge/node/node.py-157-
crossbar/edge/node/node.py:158: @wamp.register(None)
crossbar/edge/node/node.py-159- def get_status(self, details=None):
crossbar/edge/node/node.py-160- """
--
crossbar/edge/node/node.py-192- "Docker not available or Docker daemon integration not enabled")
crossbar/edge/node/node.py-193-
crossbar/edge/node/node.py:194: @wamp.register(None)
crossbar/edge/node/node.py-195- @inlineCallbacks
crossbar/edge/node/node.py-196- def get_docker_info(self, details=None):
--
crossbar/edge/node/node.py-201- return (yield self._docker_client.get_info())
crossbar/edge/node/node.py-202-
crossbar/edge/node/node.py:203: @wamp.register(None)
crossbar/edge/node/node.py-204- @inlineCallbacks
crossbar/edge/node/node.py-205- def get_docker_ping(self, details=None):
--
crossbar/edge/node/node.py-210- return (yield self._docker_client.ping())
crossbar/edge/node/node.py-211-
crossbar/edge/node/node.py:212: @wamp.register(None)
crossbar/edge/node/node.py-213- @inlineCallbacks
crossbar/edge/node/node.py-214- def get_docker_version(self, details=None):
--
crossbar/edge/node/node.py-219- return (yield self._docker_client.version())
crossbar/edge/node/node.py-220-
crossbar/edge/node/node.py:221: @wamp.register(None)
crossbar/edge/node/node.py-222- @inlineCallbacks
crossbar/edge/node/node.py-223- def get_docker_df(self, details=None):
--
crossbar/edge/node/node.py-228- return (yield self._docker_client.df())
crossbar/edge/node/node.py-229-
crossbar/edge/node/node.py:230: @wamp.register(None)
crossbar/edge/node/node.py-231- @inlineCallbacks
crossbar/edge/node/node.py-232- def get_docker_containers(self, details=None):
--
crossbar/edge/node/node.py-237- return (yield self._docker_client.get_containers())
crossbar/edge/node/node.py-238-
crossbar/edge/node/node.py:239: @wamp.register(None)
crossbar/edge/node/node.py-240- @inlineCallbacks
crossbar/edge/node/node.py-241- def get_docker_container(self, container_id, details=None):
--
crossbar/edge/node/node.py-246- return (yield self._docker_client.get_container(container_id))
crossbar/edge/node/node.py-247-
crossbar/edge/node/node.py:248: @wamp.register(None)
crossbar/edge/node/node.py-249- @inlineCallbacks
crossbar/edge/node/node.py-250- def start_docker_container(self, container_id, details=None):
--
crossbar/edge/node/node.py-255- return (yield self._docker_client.start(container_id))
crossbar/edge/node/node.py-256-
crossbar/edge/node/node.py:257: @wamp.register(None)
crossbar/edge/node/node.py-258- @inlineCallbacks
crossbar/edge/node/node.py-259- def create_docker_container(self, image, config={}, details=None):
--
crossbar/edge/node/node.py-264- return (yield self._docker_client.create(image, config))
crossbar/edge/node/node.py-265-
crossbar/edge/node/node.py:266: @wamp.register(None)
crossbar/edge/node/node.py-267- @inlineCallbacks
crossbar/edge/node/node.py-268- def stop_docker_container(self, container_id, details=None):
--
crossbar/edge/node/node.py-273- return (yield self._docker_client.container(container_id, 'stop'))
crossbar/edge/node/node.py-274-
crossbar/edge/node/node.py:275: @wamp.register(None)
crossbar/edge/node/node.py-276- @inlineCallbacks
crossbar/edge/node/node.py-277- def restart_docker_container(self, container_id, details=None):
--
crossbar/edge/node/node.py-282- return (yield self._docker_client.restart(container_id))
crossbar/edge/node/node.py-283-
crossbar/edge/node/node.py:284: @wamp.register(None)
crossbar/edge/node/node.py-285- @inlineCallbacks
crossbar/edge/node/node.py-286- def destroy_docker_container(self, container_id, details=None):
--
crossbar/edge/node/node.py-291- return (yield self._docker_client.container(container_id, 'remove'))
crossbar/edge/node/node.py-292-
crossbar/edge/node/node.py:293: @wamp.register(None)
crossbar/edge/node/node.py-294- @inlineCallbacks
crossbar/edge/node/node.py-295- def pause_docker_container(self, container_id, details=None):
--
crossbar/edge/node/node.py-300- return (yield self._docker_client.container(container_id, 'pause'))
crossbar/edge/node/node.py-301-
crossbar/edge/node/node.py:302: @wamp.register(None)
crossbar/edge/node/node.py-303- @inlineCallbacks
crossbar/edge/node/node.py-304- def unpause_docker_container(self, container_id, details=None):
--
crossbar/edge/node/node.py-309- return (yield self._docker_client.container(container_id, 'unpause'))
crossbar/edge/node/node.py-310-
crossbar/edge/node/node.py:311: @wamp.register(None)
crossbar/edge/node/node.py-312- def request_docker_tty(self, id, details=None):
crossbar/edge/node/node.py-313- """
--
crossbar/edge/node/node.py-317- return self._docker_client.request_tty(id)
crossbar/edge/node/node.py-318-
crossbar/edge/node/node.py:319: @wamp.register(None)
crossbar/edge/node/node.py-320- @inlineCallbacks
crossbar/edge/node/node.py-321- def watch_docker_container(self, container_id, tty_id, details=None):
--
crossbar/edge/node/node.py-326- return (yield self._docker_client.watch(container_id, tty_id))
crossbar/edge/node/node.py-327-
crossbar/edge/node/node.py:328: @wamp.register(None)
crossbar/edge/node/node.py-329- @inlineCallbacks
crossbar/edge/node/node.py-330- def shell_docker_container(self, container_id, tty_id, details=None):
--
crossbar/edge/node/node.py-335- return (yield self._docker_client.shell(container_id, tty_id))
crossbar/edge/node/node.py-336-
crossbar/edge/node/node.py:337: @wamp.register(None)
crossbar/edge/node/node.py-338- @inlineCallbacks
crossbar/edge/node/node.py-339- def backlog_docker_container(self, container_id, details=None):
--
crossbar/edge/node/node.py-344- return (yield self._docker_client.backlog(container_id))
crossbar/edge/node/node.py-345-
crossbar/edge/node/node.py:346: @wamp.register(None)
crossbar/edge/node/node.py-347- @inlineCallbacks
crossbar/edge/node/node.py-348- def keystroke_docker_container(self, container_id, data, details=None):
--
crossbar/edge/node/node.py-353- return (yield self._docker_client.keystroke(container_id, data))
crossbar/edge/node/node.py-354-
crossbar/edge/node/node.py:355: @wamp.register(None)
crossbar/edge/node/node.py-356- @inlineCallbacks
crossbar/edge/node/node.py-357- def get_docker_images(self, details=None):
--
crossbar/edge/node/node.py-362- return (yield self._docker_client.get_images())
crossbar/edge/node/node.py-363-
crossbar/edge/node/node.py:364: @wamp.register(None)
crossbar/edge/node/node.py-365- @inlineCallbacks
crossbar/edge/node/node.py-366- def delete_docker_image(self, image_id, details=None):
--
crossbar/edge/node/node.py-371- return (yield self._docker_client.delete_image(image_id))
crossbar/edge/node/node.py-372-
crossbar/edge/node/node.py:373: @wamp.register(None)
crossbar/edge/node/node.py-374- @inlineCallbacks
crossbar/edge/node/node.py-375- def get_docker_image(self, image_id, details=None):
--
crossbar/edge/node/node.py-380- return (yield self._docker_client.get_image(image_id))
crossbar/edge/node/node.py-381-
crossbar/edge/node/node.py:382: @wamp.register(None)
crossbar/edge/node/node.py-383- @inlineCallbacks
crossbar/edge/node/node.py-384- def remove_docker_image(self, image_id, details=None):
--
crossbar/edge/node/node.py-389- return (yield self._docker_client.image(image_id, 'remove'))
crossbar/edge/node/node.py-390-
crossbar/edge/node/node.py:391: @wamp.register(None)
crossbar/edge/node/node.py-392- @inlineCallbacks
crossbar/edge/node/node.py-393- def prune_docker_images(self, filter, details=None):
--
crossbar/edge/node/node.py-398- return (yield self._docker_client.prune(filter))
crossbar/edge/node/node.py-399-
crossbar/edge/node/node.py:400: @wamp.register(None)
crossbar/edge/node/node.py-401- @inlineCallbacks
crossbar/edge/node/node.py-402- def fs_docker_open(self, id, path, details=None):
--
crossbar/edge/node/node.py-407- return (yield self._docker_client.fs_open(id, path))
crossbar/edge/node/node.py-408-
crossbar/edge/node/node.py:409: @wamp.register(None)
crossbar/edge/node/node.py-410- @inlineCallbacks
crossbar/edge/node/node.py-411- def fs_docker_get(self, id, path, details=None):
--
crossbar/edge/node/node.py-416- return (yield self._docker_client.fs_get(id, path))
crossbar/edge/node/node.py-417-
crossbar/edge/node/node.py:418: @wamp.register(None)
crossbar/edge/node/node.py-419- @inlineCallbacks
crossbar/edge/node/node.py-420- def fs_docker_put(self, id, path, data, details=None):
crossbar/router/service.py-182- super(RouterServiceAgent, self).onUserError(failure, msg)
crossbar/router/service.py-183-
crossbar/router/service.py:184: @wamp.register('wamp.session.list')
crossbar/router/service.py-185- def session_list(self, filter_authroles=None, details=None):
crossbar/router/service.py-186- """
--
crossbar/router/service.py-207- return session_ids
crossbar/router/service.py-208-
crossbar/router/service.py:209: @wamp.register('wamp.session.count')
crossbar/router/service.py-210- def session_count(self, filter_authroles=None, details=None):
crossbar/router/service.py-211- """
--
crossbar/router/service.py-228- return session_count
crossbar/router/service.py-229-
crossbar/router/service.py:230: @wamp.register('wamp.session.get')
crossbar/router/service.py-231- def session_get(self, session_id, details=None):
crossbar/router/service.py-232- """
--
crossbar/router/service.py-259- )
crossbar/router/service.py-260-
crossbar/router/service.py:261: @wamp.register('wamp.session.add_testament')
crossbar/router/service.py-262- def session_add_testament(self, topic, args, kwargs, publish_options=None, scope="destroyed", details=None):
crossbar/router/service.py-263- """
--
crossbar/router/service.py-301- return pub_id
crossbar/router/service.py-302-
crossbar/router/service.py:303: @wamp.register('wamp.session.flush_testaments')
crossbar/router/service.py-304- def session_flush_testaments(self, scope="destroyed", details=None):
crossbar/router/service.py-305- """
--
crossbar/router/service.py-323- return flushed
crossbar/router/service.py-324-
crossbar/router/service.py:325: @wamp.register('wamp.session.kill')
crossbar/router/service.py-326- def session_kill(self, session_id, reason=None, message=None, details=None):
crossbar/router/service.py-327- """
--
crossbar/router/service.py-356- )
crossbar/router/service.py-357-
crossbar/router/service.py:358: @wamp.register('wamp.session.kill_by_authid')
crossbar/router/service.py-359- def session_kill_by_authid(self, authid, reason=None, message=None, details=None):
crossbar/router/service.py-360- """
--
crossbar/router/service.py-388- return killed
crossbar/router/service.py-389-
crossbar/router/service.py:390: @wamp.register('wamp.session.kill_by_authrole')
crossbar/router/service.py-391- def session_kill_by_authrole(self, authrole, reason=None, message=None, details=None):
crossbar/router/service.py-392- """
--
crossbar/router/service.py-420- return killed
crossbar/router/service.py-421-
crossbar/router/service.py:422: @wamp.register('wamp.registration.remove_callee')
crossbar/router/service.py-423- def registration_remove_callee(self, registration_id, callee_id, reason=None, details=None):
crossbar/router/service.py-424- """
--
crossbar/router/service.py-460- )
crossbar/router/service.py-461-
crossbar/router/service.py:462: @wamp.register('wamp.subscription.remove_subscriber')
crossbar/router/service.py-463- def subscription_remove_subscriber(self, subscription_id, subscriber_id, reason=None, details=None):
crossbar/router/service.py-464- """
--
crossbar/router/service.py-500- )
crossbar/router/service.py-501-
crossbar/router/service.py:502: @wamp.register('wamp.registration.get')
crossbar/router/service.py-503- def registration_get(self, registration_id, details=None):
crossbar/router/service.py-504- """
--
crossbar/router/service.py-534- )
crossbar/router/service.py-535-
crossbar/router/service.py:536: @wamp.register('wamp.subscription.get')
crossbar/router/service.py-537- def subscription_get(self, subscription_id, details=None):
crossbar/router/service.py-538- """
--
crossbar/router/service.py-567- )
crossbar/router/service.py-568-
crossbar/router/service.py:569: @wamp.register('wamp.registration.list')
crossbar/router/service.py-570- def registration_list(self, session_id=None, details=None):
crossbar/router/service.py-571- """
--
crossbar/router/service.py-628- return regs
crossbar/router/service.py-629-
crossbar/router/service.py:630: @wamp.register('wamp.subscription.list')
crossbar/router/service.py-631- def subscription_list(self, session_id=None, details=None):
crossbar/router/service.py-632- """
--
crossbar/router/service.py-690- return subs
crossbar/router/service.py-691-
crossbar/router/service.py:692: @wamp.register('wamp.registration.match')
crossbar/router/service.py-693- def registration_match(self, procedure, details=None):
crossbar/router/service.py-694- """
--
crossbar/router/service.py-710- return None
crossbar/router/service.py-711-
crossbar/router/service.py:712: @wamp.register('wamp.subscription.match')
crossbar/router/service.py-713- def subscription_match(self, topic, details=None):
crossbar/router/service.py-714- """
--
crossbar/router/service.py-737- return None
crossbar/router/service.py-738-
crossbar/router/service.py:739: @wamp.register('wamp.registration.lookup')
crossbar/router/service.py-740- def registration_lookup(self, procedure, options=None, details=None):
crossbar/router/service.py-741- """
--
crossbar/router/service.py-762- return None
crossbar/router/service.py-763-
crossbar/router/service.py:764: @wamp.register('wamp.subscription.lookup')
crossbar/router/service.py-765- def subscription_lookup(self, topic, options=None, details=None):
crossbar/router/service.py-766- """
--
crossbar/router/service.py-787- return None
crossbar/router/service.py-788-
crossbar/router/service.py:789: @wamp.register('wamp.registration.list_callees')
crossbar/router/service.py-790- def registration_list_callees(self, registration_id, details=None):
crossbar/router/service.py-791- """
--
crossbar/router/service.py-817- )
crossbar/router/service.py-818-
crossbar/router/service.py:819: @wamp.register('wamp.subscription.list_subscribers')
crossbar/router/service.py-820- def subscription_list_subscribers(self, subscription_id, details=None):
crossbar/router/service.py-821- """
--
crossbar/router/service.py-847- )
crossbar/router/service.py-848-
crossbar/router/service.py:849: @wamp.register('wamp.registration.count_callees')
crossbar/router/service.py-850- def registration_count_callees(self, registration_id, details=None):
crossbar/router/service.py-851- """
--
crossbar/router/service.py-873- )
crossbar/router/service.py-874-
crossbar/router/service.py:875: @wamp.register('wamp.subscription.count_subscribers')
crossbar/router/service.py-876- def subscription_count_subscribers(self, subscription_id, details=None):
crossbar/router/service.py-877- """
--
crossbar/router/service.py-900- )
crossbar/router/service.py-901-
crossbar/router/service.py:902: @wamp.register('wamp.subscription.get_events')
crossbar/router/service.py-903- def subscription_get_events(self, subscription_id, limit=10, details=None):
crossbar/router/service.py-904- """
(cpy39_1) (base) oberstet@intel-nuci7:~/scm/crossbario/crossbar$
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment