SiloSqsStreamConfigurator Methods

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.SQS
4. SiloSqsStreamConfigurator
5. Methods

Markdown

Configures an Amazon SQS-backed persistent stream provider on an Orleans silo.

ConfigureCache(int)

View source

public SiloSqsStreamConfigurator ConfigureCache(int cacheSize = 4096)

Configures the number of stream batches retained in each receiver cache.

Parameters

cacheSizeint

The number of stream batches retained in each receiver cache.

Returns

The stream provider configurator.

ConfigurePartitioning(int)

View source

public SiloSqsStreamConfigurator ConfigurePartitioning(int numOfparitions = 8)

Configures the number of SQS queues used to partition streams.

Parameters

numOfparitionsint

The number of SQS queues.

Returns

The stream provider configurator.

ConfigureSqs(Action<OptionsBuilder<SqsOptions>>)

View source

public SiloSqsStreamConfigurator ConfigureSqs(Action<OptionsBuilder<SqsOptions>> configureOptions)

Configures the SQS options for the stream provider.

Parameters

configureOptionsAction<OptionsBuilder<SqsOptions>>

The delegate used to configure the named SqsOptions.

Returns

The stream provider configurator.

UseDataAdapter(Func<IServiceProvider, string, ISQSDataAdapter>)

View source

public SiloSqsStreamConfigurator UseDataAdapter(Func<IServiceProvider, string, ISQSDataAdapter> factory)

Configures the data adapter used to convert between Orleans stream batches and SQS messages.

Parameters

factoryFunc<IServiceProvider, string, ISQSDataAdapter>

The factory invoked with the service provider and stream provider name to create the data adapter.

Returns

The stream provider configurator.