faust.types.settings
-
class
faust.types.settings.
Settings
(id: str, *, version: int = None, broker: Union[str, yarl.URL] = None, broker_client_id: str = None, broker_commit_every: int = None, broker_commit_interval: Union[datetime.timedelta, float, str] = None, broker_commit_livelock_soft_timeout: Union[datetime.timedelta, float, str] = None, broker_session_timeout: Union[datetime.timedelta, float, str] = None, broker_heartbeat_interval: Union[datetime.timedelta, float, str] = None, broker_check_crcs: bool = None, agent_supervisor: Union[typing.Type[mode.types.supervisors.SupervisorStrategyT], str] = None, store: Union[str, yarl.URL] = None, autodiscover: Union[bool, typing.Iterable[str], typing.Callable[[], typing.Iterable[str]]] = None, origin: str = None, canonical_url: Union[str, yarl.URL] = None, datadir: Union[pathlib.Path, str] = None, tabledir: Union[pathlib.Path, str] = None, key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, loghandlers: List[logging.StreamHandler] = None, table_cleanup_interval: Union[datetime.timedelta, float, str] = None, table_standby_replicas: int = None, topic_replication_factor: int = None, topic_partitions: int = None, id_format: str = None, reply_to: str = None, reply_to_prefix: str = None, reply_create_topic: bool = None, reply_expires: Union[datetime.timedelta, float, str] = None, stream_buffer_maxsize: int = None, stream_wait_empty: bool = None, stream_ack_cancelled_tasks: bool = None, stream_ack_exceptions: bool = None, stream_publish_on_commit: bool = None, producer_linger_ms: int = None, producer_max_batch_size: int = None, producer_acks: int = None, producer_max_request_size: int = None, producer_compression_type: str = None, worker_redirect_stdouts: bool = None, worker_redirect_stdouts_level: Union[int, str] = None, Agent: Union[typing.Type[faust.types.agents.AgentT], str] = None, Stream: Union[typing.Type[faust.types.streams.StreamT], str] = None, Table: Union[typing.Type[faust.types.tables.TableT], str] = None, TableManager: Union[typing.Type[faust.types.tables.TableManagerT], str] = None, Serializers: Union[typing.Type[faust.types.serializers.RegistryT], str] = None, Worker: Union[typing.Type[faust.types.settings.WorkerT], str] = None, PartitionAssignor: Union[typing.Type[faust.types.assignor.PartitionAssignorT], str] = None, LeaderAssignor: Union[typing.Type[faust.types.assignor.LeaderAssignorT], str] = None, Router: Union[typing.Type[faust.types.router.RouterT], str] = None, Topic: Union[typing.Type[faust.types.topics.TopicT], str] = None, HttpClient: Union[typing.Type[faust.types.web.HttpClientT], str] = None, Monitor: Union[typing.Type[faust.types.sensors.SensorT], str] = None, url: Union[str, yarl.URL] = None, **kwargs) → None[source]
-
classmethod
setting_names
() → Set[str][source]
-
-
id_format
= '{id}-v{self.version}'
-
origin
= None
-
autodiscover
= False
-
broker_client_id
= 'faust-1.0.30'
-
broker_commit_every
= 10000
-
broker_check_crcs
= True
-
key_serializer
= 'json'
-
value_serializer
= 'json'
-
table_standby_replicas
= 1
-
topic_replication_factor
= 1
-
topic_partitions
= 8
-
reply_create_topic
= False
-
stream_buffer_maxsize
= 4096
-
stream_wait_empty
= False
-
stream_ack_cancelled_tasks
= False
-
stream_ack_exceptions
= True
-
stream_publish_on_commit
= True
-
producer_linger_ms
= 0
-
producer_max_batch_size
= 16384
-
producer_acks
= -1
-
producer_max_request_size
= 1000000
-
producer_compression_type
= None
-
worker_redirect_stdouts
= True
-
worker_redirect_stdouts_level
= 'WARN'
-
reply_to_prefix
= 'f-reply-'
-
prepare_id
(id: str) → str[source]
-
-
prepare_datadir
(datadir: Union[str, pathlib.Path]) → pathlib.Path[source]
-
-
prepare_tabledir
(tabledir: Union[str, pathlib.Path]) → pathlib.Path[source]
-
-
name
-
id
-
version
-
broker
-
store
-
canonical_url
-
datadir
-
appdir
-
tabledir
-
broker_session_timeout
-
broker_heartbeat_interval
-
broker_commit_interval
-
broker_commit_livelock_soft_timeout
-
table_cleanup_interval
-
reply_expires
-
agent_supervisor
-
Agent
-
Stream
-
Table
-
TableManager
-
Serializers
-
Worker
-
PartitionAssignor
-
LeaderAssignor
-
Router
-
Topic
-
HttpClient
-
Monitor