faust.types.agents
¶
-
faust.types.agents.
AgentErrorHandler
¶ alias of
typing.Callable
-
faust.types.agents.
AgentFun
¶ alias of
typing.Callable
-
faust.types.agents.
SinkT
= typing.Union[_ForwardRef('AgentT'), faust.types.channels.ChannelT, typing.Callable[[typing.Any], typing.Union[typing.Awaitable, NoneType]]]¶ Agent, Channel or callable/async callable taking value as argument.
- Type
A sink can be
-
class
faust.types.agents.
ActorT
(agent: faust.types.agents.AgentT, stream: faust.types.streams.StreamT, it: _T, active_partitions: Set[faust.types.tuples.TP] = None, **kwargs) → None[source]¶ -
index
= None¶ If multiple instance are started for concurrency, this is its index.
-
-
class
faust.types.agents.
AsyncIterableActorT
(agent: faust.types.agents.AgentT, stream: faust.types.streams.StreamT, it: _T, active_partitions: Set[faust.types.tuples.TP] = None, **kwargs) → None[source]¶ Used for agent function that yields.
-
class
faust.types.agents.
AwaitableActorT
(agent: faust.types.agents.AgentT, stream: faust.types.streams.StreamT, it: _T, active_partitions: Set[faust.types.tuples.TP] = None, **kwargs) → None[source]¶ Used for agent function that do not yield.
-
faust.types.agents.
ActorRefT
¶ alias of
faust.types.agents.ActorT
-
class
faust.types.agents.
AgentT
(fun: Callable[faust.types.streams.StreamT, Union[Coroutine[[Any, Any], None], Awaitable[None], AsyncIterable]], *, name: str = None, app: faust.types.agents._AppT = None, channel: Union[str, faust.types.channels.ChannelT] = None, concurrency: int = 1, sink: Iterable[Union[AgentT, faust.types.channels.ChannelT, Callable[Any, Optional[Awaitable]]]] = None, on_error: Callable[[AgentT, BaseException], Awaitable] = None, supervisor_strategy: Type[mode.types.supervisors.SupervisorStrategyT] = None, help: str = None, key_type: Union[Type[faust.types.models.ModelT], Type[bytes], Type[str]] = None, value_type: Union[Type[faust.types.models.ModelT], Type[bytes], Type[str]] = None, isolated_partitions: bool = False, **kwargs) → None[source]¶ -
abstract
test_context
(channel: faust.types.channels.ChannelT = None, supervisor_strategy: mode.types.supervisors.SupervisorStrategyT = None, **kwargs) → faust.types.agents.AgentTestWrapperT[source]¶ - Return type
-
abstract
add_sink
(sink: Union[AgentT, faust.types.channels.ChannelT, Callable[Any, Optional[Awaitable]]]) → None[source]¶ - Return type
None
-
abstract
clone
(*, cls: Type[AgentT] = None, **kwargs) → faust.types.agents.AgentT[source]¶ - Return type
AgentT
[]
-
abstract property
channel_iterator
¶ - Return type
AsyncIterator
[+T_co]
-
abstract
-
class
faust.types.agents.
AgentManagerT
(*, beacon: mode.utils.types.trees.NodeT = None, loop: asyncio.events.AbstractEventLoop = None) → None[source]¶
-
class
faust.types.agents.
AgentTestWrapperT
(*args, original_channel: faust.types.channels.ChannelT = None, **kwargs) → None[source]¶ -
sent_offset
= 0¶
-
processed_offset
= 0¶
-
abstract
to_message
(key: Union[bytes, faust.types.core._ModelT, Any, None], value: Union[bytes, faust.types.core._ModelT, Any], *, partition: int = 0, offset: int = 0, timestamp: float = None, timestamp_type: int = 0, headers: Union[List[Tuple[str, bytes]], Mapping[str, bytes]] = None) → faust.types.tuples.Message[source]¶ - Return type
-