faust.types.sensors
-
class
faust.types.sensors.
SensorInterfaceT
[source]
-
abstract
on_message_in
(tp: faust.types.tuples.TP, offset: int, message: faust.types.tuples.Message) → None[source]
- Return type
None
-
abstract
on_stream_event_in
(tp: faust.types.tuples.TP, offset: int, stream: faust.types.streams.StreamT, event: faust.types.events.EventT) → Optional[Dict][source]
- Return type
Optional
[Dict
[~KT, ~VT]]
-
abstract
on_stream_event_out
(tp: faust.types.tuples.TP, offset: int, stream: faust.types.streams.StreamT, event: faust.types.events.EventT, state: Dict = None) → None[source]
- Return type
None
-
abstract
on_topic_buffer_full
(topic: faust.types.topics.TopicT) → None[source]
- Return type
None
-
abstract
on_message_out
(tp: faust.types.tuples.TP, offset: int, message: faust.types.tuples.Message) → None[source]
- Return type
None
-
abstract
on_table_get
(table: faust.types.tables.CollectionT, key: Any) → None[source]
- Return type
None
-
abstract
on_table_set
(table: faust.types.tables.CollectionT, key: Any, value: Any) → None[source]
- Return type
None
-
abstract
on_table_del
(table: faust.types.tables.CollectionT, key: Any) → None[source]
- Return type
None
-
abstract
on_commit_initiated
(consumer: faust.types.transports.ConsumerT) → Any[source]
- Return type
Any
-
abstract
on_commit_completed
(consumer: faust.types.transports.ConsumerT, state: Any) → None[source]
- Return type
None
-
abstract
on_send_initiated
(producer: faust.types.transports.ProducerT, topic: str, message: faust.types.tuples.PendingMessage, keysize: int, valsize: int) → Any[source]
- Return type
Any
-
abstract
on_send_completed
(producer: faust.types.transports.ProducerT, state: Any, metadata: faust.types.tuples.RecordMetadata) → None[source]
- Return type
None
-
abstract
on_send_error
(producer: faust.types.transports.ProducerT, exc: BaseException, state: Any) → None[source]
- Return type
None
-
abstract
on_assignment_start
(assignor: faust.types.assignor.PartitionAssignorT) → Dict[source]
- Return type
Dict
[~KT, ~VT]
-
abstract
on_assignment_error
(assignor: faust.types.assignor.PartitionAssignorT, state: Dict, exc: BaseException) → None[source]
- Return type
None
-
abstract
on_assignment_completed
(assignor: faust.types.assignor.PartitionAssignorT, state: Dict) → None[source]
- Return type
None
-
abstract
on_rebalance_start
(app: faust.types.sensors._AppT) → Dict[source]
- Return type
Dict
[~KT, ~VT]
-
abstract
on_rebalance_return
(app: faust.types.sensors._AppT, state: Dict) → None[source]
- Return type
None
-
abstract
on_rebalance_end
(app: faust.types.sensors._AppT, state: Dict) → 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]
-
abstract
add
(sensor: faust.types.sensors.SensorT) → None[source]
- Return type
None
-
abstract
remove
(sensor: faust.types.sensors.SensorT) → None[source]
- Return type
None