Class SilverbackStorageInitializerSqliteExtensions

Namespace

Silverback.Storage

Assembly

Silverback.Storage.Sqlite.dll

Adds the Silverback.Storage.Sqlite specific methods to the SilverbackStorageInitializer.

public static class SilverbackStorageInitializerSqliteExtensions

Inheritance

object

SilverbackStorageInitializerSqliteExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

CreateSqliteKafkaOffsetStoreAsync(SilverbackStorageInitializer, SqliteKafkaOffsetStoreSettings)

Creates the SQLite kafka offset store table.

public static Task CreateSqliteKafkaOffsetStoreAsync(this SilverbackStorageInitializer initializer, SqliteKafkaOffsetStoreSettings settings)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

settings SqliteKafkaOffsetStoreSettings

The kafka offset store settings.

Returns

Task

A Task representing the asynchronous operation.

CreateSqliteKafkaOffsetStoreAsync(SilverbackStorageInitializer, string)

Creates the SQLite kafka offset store table.

public static Task CreateSqliteKafkaOffsetStoreAsync(this SilverbackStorageInitializer initializer, string connectionString)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the SQLite database.

Returns

Task

A Task representing the asynchronous operation.

CreateSqliteKafkaOffsetStoreAsync(SilverbackStorageInitializer, string, string, TimeSpan)

Creates the SQLite kafka offset store table.

public static Task CreateSqliteKafkaOffsetStoreAsync(this SilverbackStorageInitializer initializer, string connectionString, string tableName, TimeSpan timeout)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the SQLite database.

tableName string

The name of the kafka offset store table.

timeout TimeSpan

The table creation timeout.

Returns

Task

A Task representing the asynchronous operation.

CreateSqliteOutboxAsync(SilverbackStorageInitializer, SqliteOutboxSettings)

Creates the SQLite outbox table.

public static Task CreateSqliteOutboxAsync(this SilverbackStorageInitializer initializer, SqliteOutboxSettings settings)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

settings SqliteOutboxSettings

The outbox settings.

Returns

Task

A Task representing the asynchronous operation.

CreateSqliteOutboxAsync(SilverbackStorageInitializer, string)

Creates the SQLite outbox table.

public static Task CreateSqliteOutboxAsync(this SilverbackStorageInitializer initializer, string connectionString)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the SQLite database.

Returns

Task

A Task representing the asynchronous operation.

CreateSqliteOutboxAsync(SilverbackStorageInitializer, string, string, TimeSpan)

Creates the SQLite outbox table.

public static Task CreateSqliteOutboxAsync(this SilverbackStorageInitializer initializer, string connectionString, string tableName, TimeSpan timeout)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the SQLite database.

tableName string

The name of the outbox table.

timeout TimeSpan

The table creation timeout.

Returns

Task

A Task representing the asynchronous operation.