Class SilverbackStorageInitializerPostgreSqlExtensions

Namespace

Silverback.Storage

Assembly

Silverback.Storage.PostgreSql.dll

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

public static class SilverbackStorageInitializerPostgreSqlExtensions

Inheritance

object

SilverbackStorageInitializerPostgreSqlExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Methods

CreatePostgreSqlKafkaOffsetStoreAsync(SilverbackStorageInitializer, PostgreSqlKafkaOffsetStoreSettings)

Creates the PostgreSql kafka offset store table.

public static Task CreatePostgreSqlKafkaOffsetStoreAsync(this SilverbackStorageInitializer initializer, PostgreSqlKafkaOffsetStoreSettings settings)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

settings PostgreSqlKafkaOffsetStoreSettings

The kafka offset store settings.

Returns

Task

A Task representing the asynchronous operation.

CreatePostgreSqlKafkaOffsetStoreAsync(SilverbackStorageInitializer, string)

Creates the PostgreSql kafka offset store table.

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

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the PostgreSql database.

Returns

Task

A Task representing the asynchronous operation.

CreatePostgreSqlKafkaOffsetStoreAsync(SilverbackStorageInitializer, string, string, TimeSpan)

Creates the PostgreSql kafka offset store table.

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

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the PostgreSql 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.

CreatePostgreSqlLocksTableAsync(SilverbackStorageInitializer, PostgreSqlTableLockSettings)

Creates the PostgreSql locks table.

public static Task CreatePostgreSqlLocksTableAsync(this SilverbackStorageInitializer initializer, PostgreSqlTableLockSettings settings)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

settings PostgreSqlTableLockSettings

The locks settings.

Returns

Task

A Task representing the asynchronous operation.

CreatePostgreSqlLocksTableAsync(SilverbackStorageInitializer, string)

Creates the PostgreSql locks table.

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

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the PostgreSql database.

Returns

Task

A Task representing the asynchronous operation.

CreatePostgreSqlLocksTableAsync(SilverbackStorageInitializer, string, string, TimeSpan)

Creates the PostgreSql locks table.

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

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the PostgreSql database.

tableName string

The name of the locks table.

timeout TimeSpan

The table creation timeout.

Returns

Task

A Task representing the asynchronous operation.

CreatePostgreSqlOutboxAsync(SilverbackStorageInitializer, PostgreSqlOutboxSettings)

Creates the PostgreSql outbox table.

public static Task CreatePostgreSqlOutboxAsync(this SilverbackStorageInitializer initializer, PostgreSqlOutboxSettings settings)

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

settings PostgreSqlOutboxSettings

The outbox settings.

Returns

Task

A Task representing the asynchronous operation.

CreatePostgreSqlOutboxAsync(SilverbackStorageInitializer, string)

Creates the PostgreSql outbox table.

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

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the PostgreSql database.

Returns

Task

A Task representing the asynchronous operation.

CreatePostgreSqlOutboxAsync(SilverbackStorageInitializer, string, string, TimeSpan)

Creates the PostgreSql outbox table.

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

Parameters

initializer SilverbackStorageInitializer

The SilverbackStorageInitializer.

connectionString string

The connection string to the PostgreSql database.

tableName string

The name of the outbox table.

timeout TimeSpan

The table creation timeout.

Returns

Task

A Task representing the asynchronous operation.