Skip to content

RedisBrokerParams

faststream.redis.schemas.types.RedisBrokerParams #

Bases: RedisConnectionParams

graceful_timeout instance-attribute #

graceful_timeout: float | None

ack_policy instance-attribute #

ack_policy: AckPolicy

decoder instance-attribute #

decoder: CustomCallable | None

codec instance-attribute #

codec: CodecProto | None

parser instance-attribute #

parser: CustomCallable | None

dependencies instance-attribute #

dependencies: Iterable[Dependant]

middlewares instance-attribute #

middlewares: Sequence[BrokerMiddleware[Any, Any]]

routers instance-attribute #

routers: Iterable[RedisRegistrator]

message_format instance-attribute #

message_format: type[MessageFormat]

security instance-attribute #

security: BaseSecurity | None

specification_url instance-attribute #

specification_url: str | None

protocol instance-attribute #

protocol: str | None

protocol_version instance-attribute #

protocol_version: str | None

description instance-attribute #

description: str | None

tags instance-attribute #

tags: Iterable[Tag | TagDict]

logger instance-attribute #

logger: LoggerProto

log_level instance-attribute #

log_level: int

apply_types instance-attribute #

apply_types: bool

serializer instance-attribute #

serializer: SerializerProto

provider instance-attribute #

provider: Provider | None

context instance-attribute #

context: ContextRepo | None

host instance-attribute #

host: str

port instance-attribute #

port: str | int

db instance-attribute #

db: str | int

connection_class instance-attribute #

connection_class: type[Connection]

client_name instance-attribute #

client_name: str | None

health_check_interval instance-attribute #

health_check_interval: float

max_connections instance-attribute #

max_connections: int | None

socket_timeout instance-attribute #

socket_timeout: float | None

socket_connect_timeout instance-attribute #

socket_connect_timeout: float | None

socket_read_size instance-attribute #

socket_read_size: int

socket_keepalive instance-attribute #

socket_keepalive: bool

socket_keepalive_options instance-attribute #

socket_keepalive_options: Mapping[int, int | bytes] | None

socket_type instance-attribute #

socket_type: int

retry_on_timeout instance-attribute #

retry_on_timeout: bool

encoding instance-attribute #

encoding: str

encoding_errors instance-attribute #

encoding_errors: str

parser_class instance-attribute #

parser_class: type[BaseParser]

encoder_class instance-attribute #

encoder_class: type[Encoder]