Interface ITransactionalEntityTypeProducer

Namespace

MASES.EntityFrameworkCore.KNet.Storage.Internal

Assembly

MASES.EntityFrameworkCore.KNet.dll

Extends IEntityTypeProducer with Kafka transactional producer support. Implemented only by entity type producers that belong to a transaction group declared via KEFCoreTransactionalAttribute or HasKEFCoreTransactionGroup(EntityTypeBuilder, string).

public interface ITransactionalEntityTypeProducer : IEntityTypeProducer, IDisposable

Inherited Members

IEntityTypeProducer.EntityType

IEntityTypeProducer.Register(IKEFCoreDatabase)

IEntityTypeProducer.Unregister(IKEFCoreDatabase)

IEntityTypeProducer.Commit(IList<Future<RecordMetadata>>, IEnumerable<IKEFCoreRowBag>)

IEntityTypeProducer.GetValueBuffers(IKEFCoreDatabase)

IEntityTypeProducer.GetValueBuffer(IKEFCoreDatabase, object[])

IEntityTypeProducer.GetValueBuffersRange(IKEFCoreDatabase, object[], object[])

IEntityTypeProducer.GetValueBuffersReverse(IKEFCoreDatabase)

IEntityTypeProducer.GetValueBuffersReverseRange(IKEFCoreDatabase, object[], object[])

IEntityTypeProducer.GetValueBuffersByPrefix(IKEFCoreDatabase, object[])

IEntityTypeProducer.Start(IKEFCoreDatabase)

IEntityTypeProducer.EnsureSynchronized(long)

IDisposable.Dispose()

Properties

TransactionGroup

The transaction group this producer belongs to.

string TransactionGroup { get; }

Property Value

string

Methods

AbortPendingOffsets()

Discards accumulated pending offsets after a Kafka transaction abort.

void AbortPendingOffsets()

CommitPendingOffsets()

Forwards accumulated pending offsets to IStreamsManager after a Kafka transaction commit.

void CommitPendingOffsets()