Class PostgreSqlKafkaOffsetStoreSettingsBuilder

Builds the PostgreSqlKafkaOffsetStoreSettings.

Inheritance

object

PostgreSqlKafkaOffsetStoreSettingsBuilder

Implements

IKafkaOffsetStoreSettingsImplementationBuilder

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: Silverback.Messaging.Configuration

Assembly: Silverback.Storage.PostgreSql.dll

Syntax

public class PostgreSqlKafkaOffsetStoreSettingsBuilder : IKafkaOffsetStoreSettingsImplementationBuilder

Constructors

PostgreSqlKafkaOffsetStoreSettingsBuilder(string)

Initializes a new instance of the PostgreSqlKafkaOffsetStoreSettingsBuilder class.

Declaration

public PostgreSqlKafkaOffsetStoreSettingsBuilder(string connectionString)

Parameters

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

Methods

Build()

Builds the settings instance.

Declaration

public KafkaOffsetStoreSettings Build()

Returns

Type	Description
KafkaOffsetStoreSettings	The KafkaOffsetStoreSettings.

UseTable(string)

Sets the table name.

Declaration

public PostgreSqlKafkaOffsetStoreSettingsBuilder UseTable(string tableName)

Parameters

Type	Name	Description
string	tableName	The name of the Kafka offset store table. If not specified, the default "SilverbackKafkaOffsets" will be used.

Returns

Type	Description
PostgreSqlKafkaOffsetStoreSettingsBuilder	The PostgreSqlKafkaOffsetStoreSettingsBuilder so that additional calls can be chained.

WithCreateTableTimeout(TimeSpan)

Sets the timeout for the table creation.

Declaration

public PostgreSqlKafkaOffsetStoreSettingsBuilder WithCreateTableTimeout(TimeSpan createTableTimeout)

Parameters

Type	Name	Description
TimeSpan	createTableTimeout	The timeout for the table creation. The default is 30 seconds.

Returns

Type	Description
PostgreSqlKafkaOffsetStoreSettingsBuilder	The PostgreSqlOutboxSettingsBuilder so that additional calls can be chained.

WithDbCommandTimeout(TimeSpan)

Sets the database command timeout.

Declaration

public PostgreSqlKafkaOffsetStoreSettingsBuilder WithDbCommandTimeout(TimeSpan dbCommandTimeout)

Parameters

Type	Name	Description
TimeSpan	dbCommandTimeout	The timeout for the database commands. The default is 10 seconds.

Returns

Type	Description
PostgreSqlKafkaOffsetStoreSettingsBuilder	The PostgreSqlOutboxSettingsBuilder so that additional calls can be chained.

Implements

IKafkaOffsetStoreSettingsImplementationBuilder