Class KafkaOffsetStoreScopeRelationalExtensions

Namespace

Silverback.Messaging.Consuming.KafkaOffsetStore

Assembly

Silverback.Storage.Relational.dll

Adds the storage-specific methods to the KafkaOffsetStoreScope.

public static class KafkaOffsetStoreScopeRelationalExtensions

Inheritance

object

KafkaOffsetStoreScopeRelationalExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

EnlistTransaction(KafkaOffsetStoreScope, IStorageTransaction)

Specifies the transaction to be used for storage operations.

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

Parameters

scope KafkaOffsetStoreScope

The KafkaOffsetStoreScope.

transaction IStorageTransaction

The transaction to be used.

EnlistTransaction(KafkaOffsetStoreScope, DbTransaction)

Specifies the DbTransaction to be used for storage operations.

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

Parameters

scope KafkaOffsetStoreScope

The KafkaOffsetStoreScope.

dbTransaction DbTransaction

The transaction to be used.

Returns

IStorageTransaction

The IStorageTransaction.