hfc.fabric.channel.channel_eventhub

Module Contents

Classes

EventRegistration(onEvent=None, unregister=True, disconnect=False)	A class represents event registration.
ChaincodeRegistration(ccid, pattern, er, as_array)	A class represents chaincode registration.
ChannelEventHub(peer, channel_name, requestor)	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)