Class KafkaOffsetStoreScopeRelationalExtensions

Adds the storage-specific methods to the KafkaOffsetStoreScope.

Inheritance

object

KafkaOffsetStoreScopeRelationalExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly: Silverback.Storage.Relational.dll

Syntax

public static class KafkaOffsetStoreScopeRelationalExtensions

Methods

EnlistTransaction(KafkaOffsetStoreScope, IStorageTransaction)

Specifies the transaction to be used for storage operations.

Declaration

public static void EnlistTransaction(this KafkaOffsetStoreScope scope, IStorageTransaction transaction)

Parameters

Type	Name	Description
KafkaOffsetStoreScope	scope	The KafkaOffsetStoreScope.
IStorageTransaction	transaction	The transaction to be used.

EnlistTransaction(KafkaOffsetStoreScope, DbTransaction)

Specifies the DbTransaction to be used for storage operations.

Declaration

public static IStorageTransaction EnlistTransaction(this KafkaOffsetStoreScope scope, DbTransaction dbTransaction)

Parameters

Type	Name	Description
KafkaOffsetStoreScope	scope	The KafkaOffsetStoreScope.
DbTransaction	dbTransaction	The transaction to be used.

Returns

Type	Description
IStorageTransaction	The IStorageTransaction.