Class SilverbackStorageInitializerPostgreSqlExtensions

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

Inheritance

object

SilverbackStorageInitializerPostgreSqlExtensions

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Storage

Assembly: Silverback.Storage.PostgreSql.dll

Syntax

public static class SilverbackStorageInitializerPostgreSqlExtensions

Methods

CreatePostgreSqlKafkaOffsetStoreAsync(SilverbackStorageInitializer, PostgreSqlKafkaOffsetStoreSettings)

Creates the PostgreSql kafka offset store table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
PostgreSqlKafkaOffsetStoreSettings	settings	The kafka offset store settings.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

CreatePostgreSqlKafkaOffsetStoreAsync(SilverbackStorageInitializer, string)

Creates the PostgreSql kafka offset store table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
string	connectionString	The connection string to the PostgreSql database.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

CreatePostgreSqlKafkaOffsetStoreAsync(SilverbackStorageInitializer, string, string, TimeSpan)

Creates the PostgreSql kafka offset store table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
string	connectionString	The connection string to the PostgreSql database.
string	tableName	The name of the kafka offset store table.
TimeSpan	timeout	The table creation timeout.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

CreatePostgreSqlLocksTableAsync(SilverbackStorageInitializer, PostgreSqlTableLockSettings)

Creates the PostgreSql locks table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
PostgreSqlTableLockSettings	settings	The locks settings.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

CreatePostgreSqlLocksTableAsync(SilverbackStorageInitializer, string)

Creates the PostgreSql locks table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
string	connectionString	The connection string to the PostgreSql database.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

CreatePostgreSqlLocksTableAsync(SilverbackStorageInitializer, string, string, TimeSpan)

Creates the PostgreSql locks table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
string	connectionString	The connection string to the PostgreSql database.
string	tableName	The name of the locks table.
TimeSpan	timeout	The table creation timeout.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

CreatePostgreSqlOutboxAsync(SilverbackStorageInitializer, PostgreSqlOutboxSettings)

Creates the PostgreSql outbox table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
PostgreSqlOutboxSettings	settings	The outbox settings.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

CreatePostgreSqlOutboxAsync(SilverbackStorageInitializer, string)

Creates the PostgreSql outbox table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
string	connectionString	The connection string to the PostgreSql database.

Returns

Type	Description
Task	A Task representing the asynchronous operation.

CreatePostgreSqlOutboxAsync(SilverbackStorageInitializer, string, string, TimeSpan)

Creates the PostgreSql outbox table.

Declaration

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

Parameters

Type	Name	Description
SilverbackStorageInitializer	initializer	The SilverbackStorageInitializer.
string	connectionString	The connection string to the PostgreSql database.
string	tableName	The name of the outbox table.
TimeSpan	timeout	The table creation timeout.

Returns

Type	Description
Task	A Task representing the asynchronous operation.