faust.types.app
¶
-
class
faust.types.app.
AppT
(id: str, *, monitor: faust.types.app._Monitor, config_source: Any = None, **options: Any) → None[source]¶ Abstract type for the Faust application.
See also
-
finalized
= False¶ Set to true when the app is finalized (can read configuration).
-
configured
= False¶ Set to true when the app has read configuration.
-
rebalancing
= False¶ Set to true if the worker is currently rebalancing.
-
rebalancing_count
= 0¶
-
unassigned
= False¶
-
in_worker
= False¶
-
on_configured
(*args: Any, **kwargs: Any) → None = <SyncSignal: AppT.on_configured>¶
-
on_before_configured
(*args: Any, **kwargs: Any) → None = <SyncSignal: AppT.on_before_configured>¶
-
on_after_configured
(*args: Any, **kwargs: Any) → None = <SyncSignal: AppT.on_after_configured>¶
-
on_partitions_assigned
(*args: Any, **kwargs: Any) → None = <Signal: AppT.on_partitions_assigned>¶
-
on_partitions_revoked
(*args: Any, **kwargs: Any) → None = <Signal: AppT.on_partitions_revoked>¶
-
on_rebalance_complete
(*args: Any, **kwargs: Any) → None = <Signal: AppT.on_rebalance_complete>¶
-
on_before_shutdown
(*args: Any, **kwargs: Any) → None = <Signal: AppT.on_before_shutdown>¶
-
on_worker_init
(*args: Any, **kwargs: Any) → None = <SyncSignal: AppT.on_worker_init>¶
-
on_produce_message
(*args: Any, **kwargs: Any) → None = <SyncSignal: AppT.on_produce_message>¶
-
abstract
config_from_object
(obj: Any, *, silent: bool = False, force: bool = False) → None[source]¶ - Return type
None
-
abstract
discover
(*extra_modules: str, categories: Iterable[str] = ('a', 'b', 'c'), ignore: Iterable[Any] = ('foo', 'bar')) → None[source]¶ - Return type
None
-
abstract
topic
(*topics: str, pattern: Union[str, Pattern[~AnyStr]] = None, schema: faust.types.app._SchemaT = None, key_type: faust.types.app._ModelArg = None, value_type: faust.types.app._ModelArg = None, key_serializer: Union[faust.types.codecs.CodecT, str, None] = None, value_serializer: Union[faust.types.codecs.CodecT, str, None] = None, partitions: int = None, retention: Union[datetime.timedelta, float, str] = None, compacting: bool = None, deleting: bool = None, replicas: int = None, acks: bool = True, internal: bool = False, config: Mapping[str, Any] = None, maxsize: int = None, allow_empty: bool = False, loop: asyncio.events.AbstractEventLoop = None) → faust.types.topics.TopicT[source]¶ - Return type
TopicT
[]
-
abstract
channel
(*, schema: faust.types.app._SchemaT = None, key_type: faust.types.app._ModelArg = None, value_type: faust.types.app._ModelArg = None, maxsize: int = None, loop: asyncio.events.AbstractEventLoop = None) → faust.types.channels.ChannelT[source]¶ - Return type
ChannelT
[]
-
abstract
agent
(channel: Union[str, faust.types.channels.ChannelT] = None, *, name: str = None, concurrency: int = 1, supervisor_strategy: Type[mode.types.supervisors.SupervisorStrategyT] = None, sink: Iterable[Union[AgentT, faust.types.channels.ChannelT, Callable[Any, Optional[Awaitable]]]] = None, isolated_partitions: bool = False, use_reply_headers: bool = False, **kwargs: Any) → Callable[Callable[faust.types.streams.StreamT, Union[Coroutine[[Any, Any], None], Awaitable[None], AsyncIterable]], faust.types.agents.AgentT][source]¶
-
abstract
task
(fun: Union[Callable[AppT, Awaitable], Callable[Awaitable]], *, on_leader: bool = False, traced: bool = True) → Callable[source]¶
-
abstract
timer
(interval: Union[datetime.timedelta, float, str], on_leader: bool = False, traced: bool = True, name: str = None, max_drift_correction: float = 0.1) → Callable[source]¶ - Return type
-
abstract
crontab
(cron_format: str, *, timezone: datetime.tzinfo = None, on_leader: bool = False, traced: bool = True) → Callable[source]¶ - Return type
-
abstract
service
(cls: Type[mode.types.services.ServiceT]) → Type[mode.types.services.ServiceT][source]¶
-
abstract
stream
(channel: AsyncIterable, beacon: mode.utils.types.trees.NodeT = None, **kwargs: Any) → faust.types.streams.StreamT[source]¶ - Return type
StreamT
[+T_co]
-
abstract
Table
(name: str, *, default: Callable[Any] = None, window: faust.types.windows.WindowT = None, partitions: int = None, help: str = None, **kwargs: Any) → faust.types.tables.TableT[source]¶ - Return type
TableT
[~KT, ~VT]
-
abstract
SetTable
(name: str, *, window: faust.types.windows.WindowT = None, partitions: int = None, start_manager: bool = False, help: str = None, **kwargs: Any) → faust.types.tables.TableT[source]¶ - Return type
TableT
[~KT, ~VT]
-
abstract
page
(path: str, *, base: Type[faust.types.web.View] = <class 'faust.types.web.View'>, cors_options: Mapping[str, faust.types.web.ResourceOptions] = None, name: str = None) → Callable[Union[Type[faust.types.web.View], Callable[[faust.types.web.View, faust.types.web.Request], Union[Coroutine[[Any, Any], faust.types.web.Response], Awaitable[faust.types.web.Response]]], Callable[[faust.types.web.View, faust.types.web.Request, Any, Any], Union[Coroutine[[Any, Any], faust.types.web.Response], Awaitable[faust.types.web.Response]]]], Type[faust.types.web.View]][source]¶
-
abstract
table_route
(table: faust.types.tables.CollectionT, shard_param: str = None, *, query_param: str = None, match_info: str = None, exact_key: str = None) → Callable[Union[Callable[[faust.types.web.View, faust.types.web.Request], Union[Coroutine[[Any, Any], faust.types.web.Response], Awaitable[faust.types.web.Response]]], Callable[[faust.types.web.View, faust.types.web.Request, Any, Any], Union[Coroutine[[Any, Any], faust.types.web.Response], Awaitable[faust.types.web.Response]]]], Union[Callable[[faust.types.web.View, faust.types.web.Request], Union[Coroutine[[Any, Any], faust.types.web.Response], Awaitable[faust.types.web.Response]]], Callable[[faust.types.web.View, faust.types.web.Request, Any, Any], Union[Coroutine[[Any, Any], faust.types.web.Response], Awaitable[faust.types.web.Response]]]]][source]¶ - Return type
Callable
[[Union
[Callable
[[View
,Request
],Union
[Coroutine
[Any
,Any
,Response
],Awaitable
[Response
]]],Callable
[[View
,Request
,Any
,Any
],Union
[Coroutine
[Any
,Any
,Response
],Awaitable
[Response
]]]]],Union
[Callable
[[View
,Request
],Union
[Coroutine
[Any
,Any
,Response
],Awaitable
[Response
]]],Callable
[[View
,Request
,Any
,Any
],Union
[Coroutine
[Any
,Any
,Response
],Awaitable
[Response
]]]]]
-
abstract
command
(*options: Any, base: Type[faust.types.app._AppCommand] = None, **kwargs: Any) → Callable[Callable, Type[faust.types.app._AppCommand]][source]¶
-
abstract async
send
(channel: Union[faust.types.channels.ChannelT, str], key: Union[bytes, faust.types.core._ModelT, Any, None] = None, value: Union[bytes, faust.types.core._ModelT, Any] = None, partition: int = None, timestamp: float = None, headers: Union[List[Tuple[str, bytes]], Mapping[str, bytes], None] = None, schema: faust.types.app._SchemaT = None, key_serializer: Union[faust.types.codecs.CodecT, str, None] = None, value_serializer: Union[faust.types.codecs.CodecT, str, None] = None, callback: Callable[faust.types.tuples.FutureMessage, Union[None, Awaitable[None]]] = None) → Awaitable[faust.types.tuples.RecordMetadata][source]¶ - Return type
-
abstract
FlowControlQueue
(maxsize: int = None, *, clear_on_resume: bool = False, loop: asyncio.events.AbstractEventLoop = None) → mode.utils.queues.ThrowableQueue[source]¶ - Return type
-
property
conf
¶ - Return type
_Settings
-
abstract property
transport
¶ - Return type
-
abstract property
producer_transport
¶ - Return type
-
abstract property
cache
¶ - Return type
-
abstract property
monitor
¶ - Return type
_Monitor
-
abstract property
http_client
¶ - Return type
ClientSession
-
abstract property
assignor
¶ - Return type
-