Skip to main content
Ctrl
+
K
Safir
Site Navigation
User guide
API reference
Change log
Development guide
Rubin docs
GitHub
Site Navigation
User guide
API reference
Change log
Development guide
Rubin docs
GitHub
Section Navigation
build_arq_redis_settings
ArqJobError
JobNotQueued
JobNotFound
JobResultUnavailable
ArqMode
JobMetadata
JobResult
ArqQueue
RedisArqQueue
MockArqQueue
WorkerSettings
build_worker
WorkerConfig
WorkerError
WorkerErrorType
WorkerFatalError
WorkerJobInfo
WorkerResult
WorkerTimeoutError
WorkerTransientError
WorkerUsageError
T
UWS_QUEUE_NAME
run_with_asyncio
AsyncMultiQueue
AsyncMultiQueueError
F
P
display_help
create_async_session
create_database_engine
datetime_from_db
datetime_to_db
initialize_database
is_database_current
retry_async_transaction
run_migrations_offline
run_migrations_online
stamp_database
stamp_database_async
unstamp_database
AlembicConfigError
DatabaseInitializationError
RetryP
RetryT
current_datetime
format_datetime_for_logging
isodatetime
parse_isodatetime
parse_timedelta
ArqDependency
arq_dependency
DatabaseSessionDependency
db_session_dependency
auth_delegated_token_dependency
auth_dependency
auth_logger_dependency
HTTPClientDependency
DEFAULT_HTTP_TIMEOUT
http_client_dependency
LoggerDependency
logger_dependency
EventDependency
EventMaker
E
client_request_error_handler
ClientRequestError
SignedURLService
GitHubAppClientFactory
GitHubRepoOwnerModel
GitHubUserModel
GitHubRepositoryModel
GitHubPullState
GitHubPullRequestModel
GitHubBranchCommitModel
GitHubBranchModel
GitHubBlobModel
GitHubCheckSuiteStatus
GitHubCheckSuiteConclusion
GitHubCheckSuiteModel
GitHubCheckRunStatus
GitHubCheckRunConclusion
GitHubCheckRunAnnotationLevel
GitHubCheckSuiteId
GitHubCheckRunOutput
GitHubCheckRunPrInfoModel
GitHubCheckRunModel
GitHubAppInstallationModel
GitHubPushEventModel
GitHubAppInstallationEventRepoModel
GitHubAppInstallationEventAction
GitHubAppInstallationEventModel
GitHubAppInstallationRepositoriesEventAction
GitHubAppInstallationRepositoriesEventModel
GitHubPullRequestEventAction
GitHubPullRequestEventModel
GitHubCheckSuiteEventAction
GitHubCheckSuiteEventModel
GitHubCheckRunEventAction
GitHubCheckRunEventModel
AIOKafkaParams
FastStreamBrokerParams
IncompatibleSchemaError
InvalidAvroNameError
InvalidMetadataError
KafkaConnectionSettings
PlaintextSettings
PlaintextSettings
SaslMechanism
SaslPlaintextSettings
SaslSslSettings
SecurityProtocol
SslSettings
SslSettings
PydanticSchemaManager
SchemaInfo
SchemaManagerSettings
SchemaManagerSettings
SchemaRegistryClientParams
SchemaRegistryClientParams
Compatibility
UnknownDeserializeError
UnknownSchemaError
initialize_kubernetes
add_log_severity
configure_logging
configure_alembic_logging
configure_uvicorn_logging
LogLevel
Profile
get_metadata
get_project_url
Metadata
DuplicateEventError
EventManager
EventManagerUnintializedError
EventMetadata
EventPayload
EventPublisher
KafkaMetricsConfiguration
KafkaTopicError
KafkaTopicError
MetricsConfiguration
ErrorDetail
ErrorLocation
ErrorModel
CaseInsensitiveQueryMiddleware
XForwardedMiddleware
normalize_datetime
normalize_isodatetime
to_camel_case
validate_exactly_one_of
CamelCaseModel
DeserializeError
EncryptedPydanticRedisStorage
PydanticRedisStorage
SlackBaseBlock
SlackBaseField
SlackCodeBlock
SlackCodeField
SlackException
SlackMessage
SlackTextBlock
SlackTextField
SlackWebException
SlackIgnoredException
SlackRouteErrorHandler
SlackWebhookClient
patch_google_storage
MockBlob
MockBucket
MockStorageClient
patch_kubernetes
strip_none
MockKubernetesApi
mock_slack_webhook
MockSlackWebhook
spawn_uvicorn
ServerNotListeningError
UvicornProcess
MockUWSJobRunner
uws_post_params_dependency
DatabaseSchemaError
ErrorCode
MultiValuedParameterError
ParameterError
ParameterParseError
ParametersModel
UWSApplication
UWSAppSettings
UWSConfig
UWSError
UWSJob
UWSJobError
UWSJobParameter
UWSJobResult
UWSRoute
UWSSchemaBase
UsageError
AIOKafkaParams
¶
class
safir.kafka.
AIOKafkaParams
¶
Bases:
TypedDict
On this page
AIOKafkaParams
Edit this page