faust.types.transports
¶
-
faust.types.transports.
ConsumerCallback
¶ alias of
typing.Callable
-
faust.types.transports.
TPorTopicSet
¶ alias of
typing.AbstractSet
-
faust.types.transports.
PartitionsRevokedCallback
¶ alias of
typing.Callable
-
faust.types.transports.
PartitionsAssignedCallback
¶ alias of
typing.Callable
-
faust.types.transports.
PartitionerT
¶ alias of
typing.Callable
-
class
faust.types.transports.
ProducerT
(transport: faust.types.transports.TransportT, loop: asyncio.events.AbstractEventLoop = None, **kwargs: Any) → None[source]¶ -
transport
= None¶ The transport that created this Producer.
-
abstract async
send
(topic: str, key: Optional[bytes], value: Optional[bytes], partition: Optional[int], timestamp: Optional[float], headers: Union[List[Tuple[str, bytes]], Mapping[str, bytes], None], *, transactional_id: str = None) → Awaitable[faust.types.tuples.RecordMetadata][source]¶ - Return type
-
abstract async
send_and_wait
(topic: str, key: Optional[bytes], value: Optional[bytes], partition: Optional[int], timestamp: Optional[float], headers: Union[List[Tuple[str, bytes]], Mapping[str, bytes], None], *, transactional_id: str = None) → faust.types.tuples.RecordMetadata[source]¶ - Return type
-
abstract async
create_topic
(topic: str, partitions: int, replication: int, *, config: Mapping[str, Any] = None, timeout: Union[datetime.timedelta, float, str] = 1000.0, retention: Union[datetime.timedelta, float, str] = None, compacting: bool = None, deleting: bool = None, ensure_created: bool = False) → None[source]¶ - Return type
None
-
-
class
faust.types.transports.
TransactionManagerT
(transport: faust.types.transports.TransportT, loop: asyncio.events.AbstractEventLoop = None, *, consumer: faust.types.transports.ConsumerT, producer: faust.types.transports.ProducerT, **kwargs: Any) → None[source]¶ -
abstract async
on_partitions_revoked
(revoked: Set[faust.types.tuples.TP]) → None[source]¶ - Return type
None
-
abstract async
on_rebalance
(assigned: Set[faust.types.tuples.TP], revoked: Set[faust.types.tuples.TP], newly_assigned: Set[faust.types.tuples.TP]) → None[source]¶ - Return type
None
-
abstract async
-
class
faust.types.transports.
ConsumerT
(transport: faust.types.transports.TransportT, callback: Callable[faust.types.tuples.Message, Awaitable], on_partitions_revoked: Callable[Set[faust.types.tuples.TP], Awaitable[None]], on_partitions_assigned: Callable[Set[faust.types.tuples.TP], Awaitable[None]], *, commit_interval: float = None, loop: asyncio.events.AbstractEventLoop = None, **kwargs: Any) → None[source]¶ -
transport
= None¶ The transport that created this Consumer.
-
commit_interval
= None¶ How often we commit topic offsets. See
broker_commit_interval
.
-
randomly_assigned_topics
= None¶ Set of topic names that are considered “randomly assigned”. This means we don’t crash if it’s not part of our assignment. Used by e.g. the leader assignor service.
-
abstract async
create_topic
(topic: str, partitions: int, replication: int, *, config: Mapping[str, Any] = None, timeout: Union[datetime.timedelta, float, str] = 1000.0, retention: Union[datetime.timedelta, float, str] = None, compacting: bool = None, deleting: bool = None, ensure_created: bool = False) → None[source]¶ - Return type
None
-
abstract async
getmany
(timeout: float) → AsyncIterator[Tuple[faust.types.tuples.TP, faust.types.tuples.Message]][source]¶
-
abstract async
seek_wait
(partitions: Mapping[faust.types.tuples.TP, int]) → None[source]¶ - Return type
None
-
abstract async
commit
(topics: AbstractSet[Union[str, faust.types.tuples.TP]] = None, start_new_transaction: bool = True) → bool[source]¶ - Return type
-
abstract async
earliest_offsets
(*partitions: faust.types.tuples.TP) → Mapping[faust.types.tuples.TP, int][source]¶
-
abstract async
highwaters
(*partitions: faust.types.tuples.TP) → Mapping[faust.types.tuples.TP, int][source]¶
-
-
class
faust.types.transports.
ConductorT
(app: faust.types.transports._AppT, **kwargs: Any) → None[source]¶
-
class
faust.types.transports.
TransportT
(url: List[yarl.URL], app: faust.types.transports._AppT, loop: asyncio.events.AbstractEventLoop = None) → None[source]¶ -
Consumer
= None¶ The Consumer class used for this type of transport.
-
Producer
= None¶ The Producer class used for this type of transport.
-
TransactionManager
= None¶ The TransactionManager class used for managing multiple transactions.
-
Conductor
= None¶ The Conductor class used to delegate messages from Consumer to streams.
-
Fetcher
= None¶ The Fetcher service used for this type of transport.
-
url
= None¶ //localhost).
- Type
The URL to use for this transport (e.g. kafka
-
driver_version
= None¶ String identifying the underlying driver used for this transport. E.g. for aiokafka this could be
aiokafka 0.4.1
.
-
abstract
create_consumer
(callback: Callable[faust.types.tuples.Message, Awaitable], **kwargs: Any) → faust.types.transports.ConsumerT[source]¶ - Return type
-
abstract
create_transaction_manager
(consumer: faust.types.transports.ConsumerT, producer: faust.types.transports.ProducerT, **kwargs: Any) → faust.types.transports.TransactionManagerT[source]¶ - Return type
-