faust.types.sensors

class faust.types.sensors.SensorInterfaceT[source]
on_message_in(tp: faust.types.tuples.TP, offset: int, message: faust.types.tuples.Message) → None[source]
Return type:None
on_stream_event_in(tp: faust.types.tuples.TP, offset: int, stream: faust.types.streams.StreamT, event: faust.types.events.EventT) → None[source]
Return type:None
on_stream_event_out(tp: faust.types.tuples.TP, offset: int, stream: faust.types.streams.StreamT, event: faust.types.events.EventT) → None[source]
Return type:None
on_topic_buffer_full(topic: faust.types.topics.TopicT) → None[source]
Return type:None
on_message_out(tp: faust.types.tuples.TP, offset: int, message: faust.types.tuples.Message) → None[source]
Return type:None
on_table_get(table: faust.types.tables.CollectionT, key: Any) → None[source]
Return type:None
on_table_set(table: faust.types.tables.CollectionT, key: Any, value: Any) → None[source]
Return type:None
on_table_del(table: faust.types.tables.CollectionT, key: Any) → None[source]
Return type:None
on_commit_initiated(consumer: faust.types.transports.ConsumerT) → Any[source]
Return type:Any
on_commit_completed(consumer: faust.types.transports.ConsumerT, state: Any) → None[source]
Return type:None
on_send_initiated(producer: faust.types.transports.ProducerT, topic: str, message: faust.types.tuples.PendingMessage, keysize: int, valsize: int) → Any[source]
Return type:Any
on_send_completed(producer: faust.types.transports.ProducerT, state: Any, metadata: faust.types.tuples.RecordMetadata) → None[source]
Return type:None
on_send_error(producer: faust.types.transports.ProducerT, exc: BaseException, state: Any) → None[source]
Return type:None
class faust.types.sensors.SensorT(*, beacon: mode.utils.types.trees.NodeT = None, loop: asyncio.events.AbstractEventLoop = None) → None[source]
class faust.types.sensors.SensorDelegateT[source]
add(sensor: faust.types.sensors.SensorT) → None[source]
Return type:None
remove(sensor: faust.types.sensors.SensorT) → None[source]
Return type:None