hexkit
v9.0.3
User Guide
Reference
API
/
custom_types.KafkaCompressionType
API Index
Core Types & Base Classes
custom_types.ID
custom_types.JsonObject
custom_types.Ascii
custom_types.AsyncConstructable
custom_types.AsyncContextConstructable
custom_types.KafkaCompressionType
custom_types.PytestScope
base.InboundProviderBase
Configuration
config.config_from_yaml
config.get_default_config_yaml
config.ConfigYamlDoesNotExist
General Utilities
utils.calc_part_size
utils.check_ascii
utils.validate_fields_in_model
utils.round_datetime_to_ms
utils.now_utc_ms_prec
utils.FieldNotInModelError
utils.NonAsciiStrError
Correlation IDs
correlation.get_correlation_id
correlation.new_correlation_id
correlation.validate_correlation_id
correlation.correlation_id_from_str
correlation.set_context_var
correlation.set_correlation_id
correlation.set_new_correlation_id
correlation.CorrelationIdContextError
correlation.InvalidCorrelationIdError
OpenTelemetry
opentelemetry.OpenTelemetryConfig
opentelemetry.configure_opentelemetry
Logging
log.LoggingConfig
log.configure_logging
log.JsonFormatter
log.RecordCompiler
Protocols — Events
protocols.eventpub.EventPublisherProtocol
protocols.eventsub.EventSubscriberProtocol
protocols.eventsub.DLQSubscriberProtocol
Protocols — Data Access Objects
protocols.dao.Dao
protocols.dao.DaoFactoryProtocol
protocols.dao.DaoFactoryBase
protocols.dao.FindResult
protocols.daopub.DaoPublisher
protocols.daopub.DaoPublisherFactoryProtocol
protocols.daosub.DaoSubscriberProtocol
protocols.daosub.DtoValidationError
protocols.dao.DaoError
protocols.dao.ResourceNotFoundError
protocols.dao.ResourceAlreadyExistsError
protocols.dao.UniqueConstraintViolationError
protocols.dao.FindError
protocols.dao.InvalidFindMappingError
protocols.dao.MultipleHitsFoundError
protocols.dao.NoHitsFoundError
protocols.dao.DbTimeoutError
Protocols — Storage
protocols.kvstore.KeyValueStoreProtocol
protocols.objstorage.ObjectStorageProtocol
protocols.objstorage.PresignedPostURL
Provider — Apache Kafka
providers.akafka.KafkaConfig
providers.akafka.KafkaEventPublisher
providers.akafka.KafkaEventSubscriber
providers.akafka.KafkaOutboxSubscriber
providers.akafka.ComboTranslator
Provider — MongoDB
providers.mongodb.MongoDbConfig
providers.mongodb.MongoDbDaoFactory
providers.mongodb.MongoDbDao
providers.mongodb.MongoDbBytesKeyValueStore
providers.mongodb.MongoDbStrKeyValueStore
providers.mongodb.MongoDbJsonKeyValueStore
providers.mongodb.MongoDbDtoKeyValueStore
MongoDB Migration Tooling
providers.mongodb.migrations.MigrationConfig
providers.mongodb.migrations.MigrationManager
providers.mongodb.migrations.MigrationDefinition
providers.mongodb.migrations.Reversible
providers.mongodb.migrations.check_db_version
providers.mongodb.migrations.validate_doc
providers.mongodb.migrations.MigrationStepError
providers.mongodb.migrations.DbVersionMismatchError
providers.mongodb.migrations.helpers.convert_uuids_and_datetimes_v6
providers.mongodb.migrations.helpers.convert_outbox_correlation_id_v6
providers.mongodb.migrations.helpers.convert_persistent_event_v6
Provider — MongoDB + Kafka
providers.mongokafka.MongoKafkaConfig
providers.mongokafka.MongoKafkaDaoPublisherFactory
providers.mongokafka.PersistentKafkaPublisher
providers.mongokafka.PersistentKafkaEvent
Provider — S3
providers.s3.S3Config
providers.s3.S3ObjectStorage
providers.s3.S3BytesKeyValueStore
providers.s3.S3StrKeyValueStore
providers.s3.S3JsonKeyValueStore
providers.s3.S3DtoKeyValueStore
Provider — Redis
providers.redis.RedisConfig
providers.redis.RedisBytesKeyValueStore
providers.redis.RedisStrKeyValueStore
providers.redis.RedisJsonKeyValueStore
providers.redis.RedisDtoKeyValueStore
Provider — HashiCorp Vault
providers.vault.VaultConfig
providers.vault.VaultBytesKeyValueStore
providers.vault.VaultStrKeyValueStore
providers.vault.VaultJsonKeyValueStore
providers.vault.VaultDtoKeyValueStore
Provider — In-Memory (Testing)
providers.testing.InMemEventPublisher
providers.testing.InMemEventStore
providers.testing.InMemBytesKeyValueStore
providers.testing.InMemStrKeyValueStore
providers.testing.InMemJsonKeyValueStore
providers.testing.InMemDtoKeyValueStore
providers.testing.new_mock_dao_class
providers.testing.MockDAOEmptyError
providers.testing.TopicExhaustedError
custom_types.KafkaCompressionType
custom_types.KafkaCompressionType
=
Literal[
'gzip'
,
'snappy'
,
'lz4'
,
'zstd'
]