Class PostgreSqlPipelineBuilderExtensions

Namespace

Pipelinez.PostgreSql

Assembly

Pipelinez.PostgreSql.dll

Provides PostgreSQL transport extension methods for PipelineBuilder<T>.

public static class PostgreSqlPipelineBuilderExtensions

Inheritance

object

PostgreSqlPipelineBuilderExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

WithPostgreSqlDeadLetterDestination<TRecord>(PipelineBuilder<TRecord>, PostgreSqlDeadLetterOptions, PostgreSqlTableMap<PipelineDeadLetterRecord<TRecord>>)

Configures the pipeline to write dead-letter records to PostgreSQL using a generated insert from a table map.

public static PipelineBuilder<TRecord> WithPostgreSqlDeadLetterDestination<TRecord>(this PipelineBuilder<TRecord> builder, PostgreSqlDeadLetterOptions options, PostgreSqlTableMap<PipelineDeadLetterRecord<TRecord>> tableMap) where TRecord : PipelineRecord

Parameters

builder PipelineBuilder<TRecord>

The pipeline builder to configure.

options PostgreSqlDeadLetterOptions

The PostgreSQL dead-letter destination options.

tableMap PostgreSqlTableMap<PipelineDeadLetterRecord<TRecord>>

The table map that defines the dead-letter schema, table, and columns.

Returns

PipelineBuilder<TRecord>

The same builder for chaining.

Type Parameters

TRecord

The pipeline record type contained in the dead-letter envelope.

WithPostgreSqlDeadLetterDestination<TRecord>(PipelineBuilder<TRecord>, PostgreSqlDeadLetterOptions, Func<PipelineDeadLetterRecord<TRecord>, PostgreSqlCommandDefinition>)

Configures the pipeline to write dead-letter records to PostgreSQL using consumer-provided SQL.

public static PipelineBuilder<TRecord> WithPostgreSqlDeadLetterDestination<TRecord>(this PipelineBuilder<TRecord> builder, PostgreSqlDeadLetterOptions options, Func<PipelineDeadLetterRecord<TRecord>, PostgreSqlCommandDefinition> commandFactory) where TRecord : PipelineRecord

Parameters

builder PipelineBuilder<TRecord>

The pipeline builder to configure.

options PostgreSqlDeadLetterOptions

The PostgreSQL dead-letter destination options.

commandFactory Func<PipelineDeadLetterRecord<TRecord>, PostgreSqlCommandDefinition>

The callback that creates a parameterized command definition for each dead-letter record.

Returns

PipelineBuilder<TRecord>

The same builder for chaining.

Type Parameters

TRecord

The pipeline record type contained in the dead-letter envelope.

WithPostgreSqlDestination<TRecord>(PipelineBuilder<TRecord>, PostgreSqlDestinationOptions, PostgreSqlTableMap<TRecord>)

Configures the pipeline to write successful records to PostgreSQL using a generated insert from a table map.

public static PipelineBuilder<TRecord> WithPostgreSqlDestination<TRecord>(this PipelineBuilder<TRecord> builder, PostgreSqlDestinationOptions options, PostgreSqlTableMap<TRecord> tableMap) where TRecord : PipelineRecord

Parameters

builder PipelineBuilder<TRecord>

The pipeline builder to configure.

options PostgreSqlDestinationOptions

The PostgreSQL destination options.

tableMap PostgreSqlTableMap<TRecord>

The table map that defines the destination schema, table, and columns.

Returns

PipelineBuilder<TRecord>

The same builder for chaining.

Type Parameters

TRecord

The pipeline record type.

WithPostgreSqlDestination<TRecord>(PipelineBuilder<TRecord>, PostgreSqlDestinationOptions, Func<TRecord, PostgreSqlCommandDefinition>)

Configures the pipeline to write successful records to PostgreSQL using consumer-provided SQL.

public static PipelineBuilder<TRecord> WithPostgreSqlDestination<TRecord>(this PipelineBuilder<TRecord> builder, PostgreSqlDestinationOptions options, Func<TRecord, PostgreSqlCommandDefinition> commandFactory) where TRecord : PipelineRecord

Parameters

builder PipelineBuilder<TRecord>

The pipeline builder to configure.

options PostgreSqlDestinationOptions

The PostgreSQL destination options.

commandFactory Func<TRecord, PostgreSqlCommandDefinition>

The callback that creates a parameterized command definition for each record.

Returns

PipelineBuilder<TRecord>

The same builder for chaining.

Type Parameters

TRecord

The pipeline record type.