Class PostgreSqlKafkaOffsetStoreSettings

The PostgreSqlKafkaOffsetStore settings.

Inheritance
object
KafkaOffsetStoreSettings
PostgreSqlKafkaOffsetStoreSettings
Inherited Members
Namespace: Silverback.Messaging.Consuming.KafkaOffsetStore
Assembly: Silverback.Storage.PostgreSql.dll
Syntax
public record PostgreSqlKafkaOffsetStoreSettings : KafkaOffsetStoreSettings, IValidatableSettings, IEquatable<KafkaOffsetStoreSettings>, IDatabaseConnectionSettings, IEquatable<PostgreSqlKafkaOffsetStoreSettings>

Constructors

PostgreSqlKafkaOffsetStoreSettings(PostgreSqlKafkaOffsetStoreSettings)

The PostgreSqlKafkaOffsetStore settings.

Declaration
protected PostgreSqlKafkaOffsetStoreSettings(PostgreSqlKafkaOffsetStoreSettings original)
Parameters
Type Name Description
PostgreSqlKafkaOffsetStoreSettings original

PostgreSqlKafkaOffsetStoreSettings(string)

Initializes a new instance of the PostgreSqlKafkaOffsetStoreSettings class.

Declaration
public PostgreSqlKafkaOffsetStoreSettings(string connectionString)
Parameters
Type Name Description
string connectionString

The connection string to the PostgreSql database.

Properties

ConnectionString

Gets the connection string to the PostgreSql database.

Declaration
public string ConnectionString { get; }
Property Value
Type Description
string

CreateTableTimeout

Gets the timeout for the table creation. The default is 30 seconds.

Declaration
public TimeSpan CreateTableTimeout { get; init; }
Property Value
Type Description
TimeSpan

DbCommandTimeout

Gets the database command timeout. The default is 10 seconds.

Declaration
public TimeSpan DbCommandTimeout { get; init; }
Property Value
Type Description
TimeSpan

EqualityContract

The PostgreSqlKafkaOffsetStore settings.

Declaration
protected override Type EqualityContract { get; }
Property Value
Type Description
Type
Overrides

TableName

Gets the name of the Kafka offset store table. The default is "SilverbackKafkaOffsets".

Declaration
public string TableName { get; init; }
Property Value
Type Description
string

Methods

Equals(KafkaOffsetStoreSettings?)

The PostgreSqlKafkaOffsetStore settings.

Declaration
public override sealed bool Equals(KafkaOffsetStoreSettings? other)
Parameters
Type Name Description
KafkaOffsetStoreSettings other
Returns
Type Description
bool
Overrides

Equals(PostgreSqlKafkaOffsetStoreSettings?)

The PostgreSqlKafkaOffsetStore settings.

Declaration
public virtual bool Equals(PostgreSqlKafkaOffsetStoreSettings? other)
Parameters
Type Name Description
PostgreSqlKafkaOffsetStoreSettings other
Returns
Type Description
bool

Equals(object?)

The PostgreSqlKafkaOffsetStore settings.

Declaration
public override bool Equals(object? obj)
Parameters
Type Name Description
object obj
Returns
Type Description
bool
Overrides

GetHashCode()

The PostgreSqlKafkaOffsetStore settings.

Declaration
public override int GetHashCode()
Returns
Type Description
int
Overrides

PrintMembers(StringBuilder)

The PostgreSqlKafkaOffsetStore settings.

Declaration
protected override bool PrintMembers(StringBuilder builder)
Parameters
Type Name Description
StringBuilder builder
Returns
Type Description
bool
Overrides

ToString()

The PostgreSqlKafkaOffsetStore settings.

Declaration
public override string ToString()
Returns
Type Description
string
Overrides

Validate()

Throws a SilverbackConfigurationException if the configuration is not valid.

Declaration
public override void Validate()
Overrides

Operators

operator ==(PostgreSqlKafkaOffsetStoreSettings?, PostgreSqlKafkaOffsetStoreSettings?)

The PostgreSqlKafkaOffsetStore settings.

Declaration
public static bool operator ==(PostgreSqlKafkaOffsetStoreSettings? left, PostgreSqlKafkaOffsetStoreSettings? right)
Parameters
Type Name Description
PostgreSqlKafkaOffsetStoreSettings left
PostgreSqlKafkaOffsetStoreSettings right
Returns
Type Description
bool

operator !=(PostgreSqlKafkaOffsetStoreSettings?, PostgreSqlKafkaOffsetStoreSettings?)

The PostgreSqlKafkaOffsetStore settings.

Declaration
public static bool operator !=(PostgreSqlKafkaOffsetStoreSettings? left, PostgreSqlKafkaOffsetStoreSettings? right)
Parameters
Type Name Description
PostgreSqlKafkaOffsetStoreSettings left
PostgreSqlKafkaOffsetStoreSettings right
Returns
Type Description
bool

Implements