Class P2PMessageQueueOptions

Namespace

DotCompute.Abstractions.Messaging

Assembly

DotCompute.Abstractions.dll

Options for configuring a P2P message queue.

public sealed class P2PMessageQueueOptions

Inheritance

object

P2PMessageQueueOptions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Properties

BackpressureStrategy

Gets or sets the backpressure strategy when queue is full.

public P2PBackpressureStrategy BackpressureStrategy { get; set; }

Property Value

P2PBackpressureStrategy

BatchSize

Gets or sets the batch size for optimized transfers.

public int BatchSize { get; set; }

Property Value

int

BlockingTimeoutMs

Gets or sets the timeout for blocking operations in milliseconds.

public int BlockingTimeoutMs { get; set; }

Property Value

int

Capacity

Gets or sets the queue capacity (number of messages).

public int Capacity { get; set; }

Property Value

int

Remarks

Must be a power of 2 for optimal performance. Will be rounded up if not. Default is 1024.

EnableTransferValidation

Gets or sets whether to enable transfer validation.

public bool EnableTransferValidation { get; set; }

Property Value

bool

PreferredTransferMode

Gets or sets the preferred transfer mode.

public P2PTransferMode PreferredTransferMode { get; set; }

Property Value

P2PTransferMode

StagingBufferSize

Gets or sets the size of the host staging buffer in bytes.

public int StagingBufferSize { get; set; }

Property Value

int

UsePinnedMemory

Gets or sets whether to use pinned memory for the ring buffer.

public bool UsePinnedMemory { get; set; }

Property Value

bool

Methods

Validate()

Validates and normalizes the options.

public void Validate()