Namespace MASES.EntityFrameworkCore.KNet.Metadata

Classes

KEFCoreComplexTypeConverterAttribute

Associates a IComplexTypeConverter implementation with this complex type, registering it in IComplexTypeConverterFactory at model finalization time.

KEFCoreIgnoreEquatableCheckAttribute

Suppresses the KEFCore equality check for this complex type.

KEFCoreIgnoreEventsAttribute

Disables KEFCore event management for this entity type, overriding the context-level default set by UseKEFCoreManageEvents().

KEFCoreProducerAttribute

Overrides producer configuration for the Kafka topic associated with this entity type. Only explicitly set properties override the global ProducerConfig.

KEFCoreReadOnlyAttribute

Marks this entity type as read-only within the current KEFCoreDbContext. Any attempt to write entries of this type via SaveChanges() will throw InvalidOperationException.

KEFCoreRocksDbLifecycleAttribute

Declares the IRocksDbLifecycleHandler type associated to an entity type.

KEFCoreSerDesAttribute

Overrides the serialization types for the Kafka topic associated with this entity type. Takes precedence over the context-level KeySerDesSelectorType, ValueSerDesSelectorType and ValueContainerType.

KEFCoreStoreLookupAttribute

Configures the Kafka Streams store query optimization flags for this entity type, overriding the context-level defaults set via KEFCoreDbContext options.

KEFCoreTopicAttribute

Overrides the Kafka topic name for an entity type. Takes precedence over TableAttribute> and entity name.

KEFCoreTopicPartitionsAttribute

Overrides the number of partitions for the Kafka topic associated with this entity type. Takes precedence over DefaultNumPartitions. Applied at topic creation time (EnsureCreated()).

KEFCoreTopicPrefixAttribute

Sets the Kafka topic prefix. Can be applied to an entity class or to a DbContext class (acts as default for all entities in that context).

KEFCoreTopicReplicationFactorAttribute

Overrides the replication factor for the Kafka topic associated with this entity type. Takes precedence over DefaultReplicationFactor. Applied at topic creation time (EnsureCreated()).

KEFCoreTopicRetentionAttribute

Overrides the retention policy for the Kafka topic associated with this entity type. Applied at topic creation time (EnsureCreated()).

KEFCoreTransactionalAttribute

Assigns this entity type to a Kafka transaction group, enabling exactly-once semantics for all entities sharing the same TransactionGroup.

KEFCoreValueBufferCacheAttribute

Configures an in-memory result cache for this entity type's Kafka Streams state store.

Two independent caches are maintained: one for forward enumeration (GetValueBuffers, GetValueBuffersRange, single key lookup) and one for reverse enumeration (GetValueBuffersReverse, GetValueBuffersReverseRange). Each is backed by its own SortedList<TKey, TValue> and populated independently on the first complete enumeration in the respective direction.

Partial enumerations (e.g. First(), Take(n)) never populate the cache. Both caches are invalidated automatically when new data arrives from the cluster via FreshEventChange.