crossbar.edge.worker.xbrmm¶

Classes¶

`MarketplaceController`	A native Crossbar.io worker process. The worker will be connected
`MarketplaceControllerProcess`	Internal run-time representation of a native worker (router or

Module Contents¶

class MarketplaceController(config=None, reactor=None, personality=None)[source]¶

Bases: crossbar.worker.controller.WorkerController

A native Crossbar.io worker process. The worker will be connected to the node’s management router running inside the node controller via WAMP-over-stdio.

STATUS_RUNNING = 'running'[source]¶

STATUS_STARTING = 'starting'[source]¶

STATUS_STOPPING = 'stopping'[source]¶

WORKER_TITLE = 'Marketplace'[source]¶

WORKER_TYPE = 'marketplace'[source]¶

_bc_gw_config[source]¶

_blockchain_config[source]¶

_chain_id[source]¶

_database_config[source]¶

_db[source]¶

_dbpath = b'.'[source]¶

_download_ipfs_file(file_hash)[source]¶

_get_balances(wallet_adr)[source]¶

Parameters:: wallet_adr
Returns:

_get_gas_price()[source]¶

Returns:

_get_transaction_receipt(transaction: bytes)[source]¶

Parameters:: transaction
Returns:

_ipfs_files_dir[source]¶

_ipfs_files_directory[source]¶

_maker_adr2id[source]¶

_makers[source]¶

_meta[source]¶

_monitor_blockchain(gateway_config, scan_from_block, period=300)[source]¶

Parameters:

gateway_config
scan_from_block
period

Returns:

_process_block(w3, block_number, Events)[source]¶

Parameters:

w3
block_number
Events

Returns:

_run_monitor = None[source]¶

_status = None[source]¶

_trigger_monitor_blockchain()[source]¶

_w3[source]¶

_xbr[source]¶

_xbrmm[source]¶

log[source]¶

onJoin(details, publish_ready=True)[source]¶: Called when worker process has joined the node management realm.

onLeave(details)[source]¶

Parameters:: details
Returns:

start_market_maker(maker_id, config, details=None)[source]¶: Starts a XBR Market Maker providing services in a specific XBR market.

stop_market_maker(maker_id, details=None)[source]¶

class MarketplaceControllerProcess(controller, id, who=None, keeplog=None)[source]¶

Bases: crossbar.node.worker.NativeWorkerProcess

Internal run-time representation of a native worker (router or container currently) process.

LOGNAME = 'Marketplace'[source]¶

TYPE = 'marketplace'[source]¶