Skip to content
Orleans logoMicrosoft Orleans

ClusterClientSqsStreamConfigurator Methods

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

ConfigurePartitioning(int)

View source
public ClusterClientSqsStreamConfigurator 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 ClusterClientSqsStreamConfigurator 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 ClusterClientSqsStreamConfigurator 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.