faust.types.sensors

class faust.types.sensors.SensorInterfaceT[source]
abstract on_message_in(tp: TP, offset: int, message: Message) → None[source]
Return type:

None

abstract on_stream_event_in(tp: TP, offset: int, stream: StreamT, event: EventT) → Optional[Dict][source]
Return type:

_UnionGenericAlias[_SpecialGenericAlias, None]

abstract on_stream_event_out(tp: TP, offset: int, stream: StreamT, event: EventT, state: Optional[Dict] = None) → None[source]
Return type:

None

abstract on_topic_buffer_full(tp: TP) → None[source]
Return type:

None

abstract on_message_out(tp: TP, offset: int, message: Message) → None[source]
Return type:

None

abstract on_table_get(table: CollectionT, key: Any) → None[source]
Return type:

None

abstract on_table_set(table: CollectionT, key: Any, value: Any) → None[source]
Return type:

None

abstract on_table_del(table: CollectionT, key: Any) → None[source]
Return type:

None

abstract on_commit_initiated(consumer: ConsumerT) → Any[source]
Return type:

Any

abstract on_commit_completed(consumer: ConsumerT, state: Any) → None[source]
Return type:

None

abstract on_send_initiated(producer: ProducerT, topic: str, message: PendingMessage, keysize: int, valsize: int) → Any[source]
Return type:

Any

abstract on_send_completed(producer: ProducerT, state: Any, metadata: RecordMetadata) → None[source]
Return type:

None

abstract on_send_error(producer: ProducerT, exc: BaseException, state: Any) → None[source]
Return type:

None

abstract on_assignment_start(assignor: PartitionAssignorT) → Dict[source]
Return type:

_SpecialGenericAlias

abstract on_assignment_error(assignor: PartitionAssignorT, state: Dict, exc: BaseException) → None[source]
Return type:

None

abstract on_assignment_completed(assignor: PartitionAssignorT, state: Dict) → None[source]
Return type:

None

abstract on_rebalance_start(app: _AppT) → Dict[source]
Return type:

_SpecialGenericAlias

abstract on_rebalance_return(app: _AppT, state: Dict) → None[source]
Return type:

None

abstract on_rebalance_end(app: _AppT, state: Dict) → None[source]
Return type:

None

abstract on_web_request_start(app: _AppT, request: Request, *, view: Optional[View] = None) → Dict[source]
Return type:

_SpecialGenericAlias

abstract on_web_request_end(app: _AppT, request: Request, response: Optional[Response], state: Dict, *, view: Optional[View] = None) → None[source]
Return type:

None

abstract on_threaded_producer_buffer_processed(app: _AppT, size: int) → None[source]
Return type:

None

class faust.types.sensors.SensorT(*, beacon: Optional[NodeT] = None, loop: Optional[AbstractEventLoop] = None)[source]
class faust.types.sensors.SensorDelegateT[source]
abstract add(sensor: SensorT) → None[source]
Return type:

None

abstract remove(sensor: SensorT) → None[source]
Return type:

None