Created
April 22, 2022 09:16
-
-
Save oberstet/a7804cdfcb5de3567c4ad1c822753307 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(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