hexkit
v8.5.0
User Guide
Reference
Changelog
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
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"
]