SiloKinesisStreamConfigurator Methods

Configures persistent streams.

ConfigureCheckpointer(Func<IServiceProvider, string, IStreamQueueCheckpointerFactory>, Action<OptionsBuilder<TOptions>>)

public SiloKinesisStreamConfigurator ConfigureCheckpointer<TOptions>(Func<IServiceProvider, string, IStreamQueueCheckpointerFactory> checkpointerFactoryBuilder, Action<OptionsBuilder<TOptions>> configureOptions)

Parameters

checkpointerFactoryBuilderFunc<IServiceProvider, string, IStreamQueueCheckpointerFactory>
configureOptionsAction<OptionsBuilder<TOptions>>

ConfigureKinesis(Action<KinesisStreamOptions>)

View source

public SiloKinesisStreamConfigurator ConfigureKinesis(Action<KinesisStreamOptions> configureOptions)

Parameters

configureOptionsAction<KinesisStreamOptions>

ConfigureKinesis(Action<OptionsBuilder<KinesisStreamOptions>>)

View source

public SiloKinesisStreamConfigurator ConfigureKinesis(Action<OptionsBuilder<KinesisStreamOptions>> configureOptions)

Parameters

configureOptionsAction<OptionsBuilder<KinesisStreamOptions>>

UseDynamoDBCheckpointer(Action<DynamoDBStreamQueueCheckpointerOptions>)

View source

public SiloKinesisStreamConfigurator UseDynamoDBCheckpointer(Action<DynamoDBStreamQueueCheckpointerOptions> configureOptions)

Configures the stream provider to persist checkpoints in DynamoDB.

Parameters

configureOptionsAction<DynamoDBStreamQueueCheckpointerOptions>

UseDynamoDBCheckpointer(Action<OptionsBuilder<DynamoDBStreamQueueCheckpointerOptions>>)

View source

public SiloKinesisStreamConfigurator UseDynamoDBCheckpointer(Action<OptionsBuilder<DynamoDBStreamQueueCheckpointerOptions>>? configureOptions = null)

Configures the stream provider to persist checkpoints in DynamoDB.

Parameters

configureOptionsAction<OptionsBuilder<DynamoDBStreamQueueCheckpointerOptions>>