Interface IInMemoryTransactionManager

Namespace

Silverback.Messaging.Broker.Kafka.Mocks

Assembly

Silverback.Integration.Kafka.Testing.dll

Coordinates the in-memory transactions for the IMockedConfluentProducer.

public interface IInMemoryTransactionManager

Methods

AbortTransaction(Guid)

Aborts the transaction.

void AbortTransaction(Guid transactionalUniqueId)

Parameters

transactionalUniqueId Guid

The transactional unique identifier.

BeginTransaction(Guid)

Begins a new transaction.

void BeginTransaction(Guid transactionalUniqueId)

Parameters

transactionalUniqueId Guid

The transactional unique identifier.

CommitTransaction(Guid)

Commits the transaction.

void CommitTransaction(Guid transactionalUniqueId)

Parameters

transactionalUniqueId Guid

The transactional unique identifier.

InitTransaction(string)

Initializes the transaction manager for the specified transactionalId.

Guid InitTransaction(string transactionalId)

Parameters

transactionalId string

The transactionalId of the producer.

Returns

Guid

The transactional unique identifier.

IsTransactionPending(Guid)

Gets a value indicating whether a transaction is pending for the specified transactional unique identifier.

bool IsTransactionPending(Guid transactionalUniqueId)

Parameters

transactionalUniqueId Guid

The transactional unique identifier.

Returns

bool

true if a transaction is pending, otherwise false.

SendOffsetsToTransaction(Guid, IEnumerable<TopicPartitionOffset>, IConsumerGroupMetadata)

Sends the consumed offsets to the transaction.

void SendOffsetsToTransaction(Guid transactionalUniqueId, IEnumerable<TopicPartitionOffset> offsets, IConsumerGroupMetadata groupMetadata)

Parameters

transactionalUniqueId Guid

The transactional unique identifier.

offsets IEnumerable<TopicPartitionOffset>

The offsets to send.

groupMetadata IConsumerGroupMetadata

The consumer group metadata.