hfc.fabric.channel.channel_eventhub
¶
Module Contents¶
Classes¶
|
A class represents event registration. |
|
A class represents chaincode registration. |
|
A class represents channel event hub. |
-
hfc.fabric.channel.channel_eventhub.
_logger
¶
-
hfc.fabric.channel.channel_eventhub.
NO_START_STOP
= 0¶
-
hfc.fabric.channel.channel_eventhub.
START_ONLY
= 1¶
-
hfc.fabric.channel.channel_eventhub.
END_ONLY
= 2¶
-
hfc.fabric.channel.channel_eventhub.
START_AND_END
= 3¶
-
class
hfc.fabric.channel.channel_eventhub.
EventRegistration
(onEvent=None, unregister=True, disconnect=False)¶ Bases:
object
A class represents event registration.
-
class
hfc.fabric.channel.channel_eventhub.
ChaincodeRegistration
(ccid, pattern, er, as_array)¶ Bases:
object
A class represents chaincode registration.
-
class
hfc.fabric.channel.channel_eventhub.
ChannelEventHub
(peer, channel_name, requestor)¶ Bases:
object
A class represents channel event hub.
-
property
connected
(self)¶ Get the connected :return: The connected
-
_create_seek_info
(self, start=None, stop=None)¶
-
_get_stream
(self)¶ get the events of the channel.
- Returns
the events in success or None in fail.
-
check_start_stop_connect
(self, start=None, stop=None)¶
-
check_start_stop_listener
(self, start=None, stop=None)¶
-
_processBlockEvents
(self, block)¶
-
registerBlockEvent
(self, unregister=True, start=None, stop=None, disconnect=False, onEvent=None)¶
-
unregisterBlockEvent
(self, reg_num)¶
-
handle_filtered_tx
(self, block, tx_id, er)¶
-
handle_full_tx
(self, block, tx_id, er)¶
-
_processTxEvents
(self, block)¶
-
registerTxEvent
(self, tx_id, unregister=None, start=None, stop=None, disconnect=False, onEvent=None)¶
-
unregisterTxEvent
(self, tx_id)¶
-
_queue_chaincode_event
(self, chaincode_event, block_number, tx_id, tx_status, all_events)¶
-
handle_filtered_chaincode
(self, block, all_events)¶
-
_handle_full_chaincode
(self, tx, block_number, tx_id, tx_status, all_events)¶
-
handle_full_chaincode
(self, block, all_events)¶
-
_processChaincodeEvents
(self, block)¶
-
registerChaincodeEvent
(self, ccid, pattern, unregister=False, start=None, stop=None, as_array=None, disconnect=False, onEvent=None)¶
-
unregisterChaincodeEvent
(self, cr)¶
-
have_registrations
(self)¶
-
_on_end_actions
(self, event_reg, unregister_action, startstop_mode, unregister, disconnect)¶
-
check_replay_end
(self)¶
-
async
handle_stream
(self, stream)¶
-
connect
(self, filtered=True, start=None, stop=None, as_array=False, target=None, signed_event=None)¶
-
disconnect
(self)¶
-
property