SiloKinesisStreamConfigurator Methods

Configures an Amazon Kinesis Data Streams-backed persistent stream provider on an Orleans silo.

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

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

Configures the component used to persist per-shard stream checkpoints.

Parameters

checkpointerFactoryBuilderFunc<IServiceProvider, string, IStreamQueueCheckpointerFactory>: The factory invoked with the service provider and stream provider name to create the checkpointer factory.
configureOptionsAction<OptionsBuilder<TOptions>>: The delegate used to configure the named checkpointer options.

Returns

The stream provider configurator.

ConfigureKinesis(Action<KinesisStreamOptions>)

View source

public SiloKinesisStreamConfigurator ConfigureKinesis(Action<KinesisStreamOptions> configureOptions)

Configures the Kinesis options for the stream provider.

Parameters

configureOptionsAction<KinesisStreamOptions>: The delegate used to configure the Kinesis options.

Returns

The stream provider configurator.

ConfigureKinesis(Action<OptionsBuilder<KinesisStreamOptions>>)

View source

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

Configures the Kinesis options for the stream provider.

Parameters

configureOptionsAction<OptionsBuilder<KinesisStreamOptions>>: The delegate used to configure the named KinesisStreamOptions.

Returns

The stream provider configurator.

UseDynamoDBCheckpointer(Action<DynamoDBStreamQueueCheckpointerOptions>)

View source

public SiloKinesisStreamConfigurator UseDynamoDBCheckpointer(Action<DynamoDBStreamQueueCheckpointerOptions> configureOptions)

Configures the stream provider to persist checkpoints in DynamoDB.

Parameters

configureOptionsAction<DynamoDBStreamQueueCheckpointerOptions>: The delegate used to configure the DynamoDB checkpointer options.

Returns

The stream provider configurator.

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>>: The optional delegate used to configure the named DynamoDB checkpointer options.

Returns

The stream provider configurator.