Interface IInMemoryTransactionManager

Coordinates the in-memory transactions for the IMockedConfluentProducer.

Namespace: Silverback.Messaging.Broker.Kafka.Mocks

Assembly: Silverback.Integration.Kafka.Testing.dll

Syntax

public interface IInMemoryTransactionManager

Methods

AbortTransaction(Guid)

Aborts the transaction.

Declaration

void AbortTransaction(Guid transactionalUniqueId)

Parameters

Type	Name	Description
Guid	transactionalUniqueId	The transactional unique identifier.

BeginTransaction(Guid)

Begins a new transaction.

Declaration

void BeginTransaction(Guid transactionalUniqueId)

Parameters

Type	Name	Description
Guid	transactionalUniqueId	The transactional unique identifier.

CommitTransaction(Guid)

Commits the transaction.

Declaration

void CommitTransaction(Guid transactionalUniqueId)

Parameters

Type	Name	Description
Guid	transactionalUniqueId	The transactional unique identifier.

InitTransaction(string)

Initializes the transaction manager for the specified transactionalId.

Declaration

Guid InitTransaction(string transactionalId)

Parameters

Type	Name	Description
string	transactionalId	The transactionalId of the producer.

Returns

Type	Description
Guid	The transactional unique identifier.

IsTransactionPending(Guid)

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

Declaration

bool IsTransactionPending(Guid transactionalUniqueId)

Parameters

Type	Name	Description
Guid	transactionalUniqueId	The transactional unique identifier.

Returns

Type	Description
bool	true if a transaction is pending, otherwise false.

SendOffsetsToTransaction(Guid, IEnumerable<TopicPartitionOffset>, IConsumerGroupMetadata)

Sends the consumed offsets to the transaction.

Declaration

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

Parameters

Type	Name	Description
Guid	transactionalUniqueId	The transactional unique identifier.
IEnumerable<TopicPartitionOffset>	offsets	The offsets to send.
IConsumerGroupMetadata	groupMetadata	The consumer group metadata.