Class SqliteKafkaOffsetStoreSettingsBuilder

Builds the SqliteKafkaOffsetStoreSettings.

Inheritance

object

SqliteKafkaOffsetStoreSettingsBuilder

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.Sqlite.dll

Syntax

public class SqliteKafkaOffsetStoreSettingsBuilder : IKafkaOffsetStoreSettingsImplementationBuilder

Constructors

SqliteKafkaOffsetStoreSettingsBuilder(string)

Initializes a new instance of the SqliteKafkaOffsetStoreSettingsBuilder class.

Declaration

public SqliteKafkaOffsetStoreSettingsBuilder(string connectionString)

Parameters

Type	Name	Description
string	connectionString	The connection string to the SQLite 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 SqliteKafkaOffsetStoreSettingsBuilder 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
SqliteKafkaOffsetStoreSettingsBuilder	The SqliteKafkaOffsetStoreSettingsBuilder so that additional calls can be chained.

WithCreateTableTimeout(TimeSpan)

Sets the timeout for the table creation.

Declaration

public SqliteKafkaOffsetStoreSettingsBuilder WithCreateTableTimeout(TimeSpan createTableTimeout)

Parameters

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

Returns

Type	Description
SqliteKafkaOffsetStoreSettingsBuilder	The SqliteOutboxSettingsBuilder so that additional calls can be chained.

WithDbCommandTimeout(TimeSpan)

Sets the database command timeout.

Declaration

public SqliteKafkaOffsetStoreSettingsBuilder WithDbCommandTimeout(TimeSpan dbCommandTimeout)

Parameters

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

Returns

Type	Description
SqliteKafkaOffsetStoreSettingsBuilder	The SqliteOutboxSettingsBuilder so that additional calls can be chained.

Implements

IKafkaOffsetStoreSettingsImplementationBuilder