Show / Hide Table of Contents

Class PersistentChannelOptions

Represents persistent channel options.

Inheritance
Object
PersistentChannelOptions
Namespace: DotNext.Threading.Channels
Assembly: DotNext.Threading.dll
Syntax
public sealed class PersistentChannelOptions : ChannelOptions

Constructors

| Improve this Doc View Source

PersistentChannelOptions()

Initializes a new options with default settings.

Declaration
public PersistentChannelOptions()

Properties

| Improve this Doc View Source

BufferSize

Gets or sets size of internal buffer used to perform I/O operations.

Declaration
public int BufferSize { get; set; }
Property Value
Type Description
Int32
| Improve this Doc View Source

InitialPartitionSize

Gets or sets initial size of partition file, in bytes.

Declaration
public long InitialPartitionSize { get; set; }
Property Value
Type Description
Int64
Remarks

This property may help to avoid fragmentation of partition file on disk during writing.

| Improve this Doc View Source

Location

Gets or sets path used to store queue files.

Declaration
public string Location { get; set; }
Property Value
Type Description
String
| Improve this Doc View Source

PartitionCapacity

Gets or sets maximum number of messages per file.

Declaration
public int PartitionCapacity { get; set; }
Property Value
Type Description
Int32

Extension Methods

AsyncLockAcquisition.AcquireLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireUpgradeableReadLockAsync<T>(T, TimeSpan)
AsyncLockAcquisition.AcquireUpgradeableReadLockAsync<T>(T, CancellationToken)
ExpressionBuilder.Const<T>(T)
ObjectExtensions.GetUserData<T>(T)
ObjectExtensions.IsOneOf<T>(T, IEnumerable<T>)
ObjectExtensions.IsOneOf<T>(T, T[])
ObjectExtensions.Decompose<T, R1, R2>(T, Func<T, R1>, Func<T, R2>, out R1, out R2)
ObjectExtensions.Decompose<T, R1, R2>(T, ValueFunc<T, R1>, ValueFunc<T, R2>, out R1, out R2)
ObjectExtensions.Decompose<T, R1, R2>(T, Func<T, R1>, Func<T, R2>)
ObjectExtensions.Decompose<T, R1, R2>(T, ValueFunc<T, R1>, ValueFunc<T, R2>)
LockAcquisition.AcquireReadLock<T>(T)
LockAcquisition.AcquireReadLock<T>(T, TimeSpan)
LockAcquisition.AcquireWriteLock<T>(T)
LockAcquisition.AcquireWriteLock<T>(T, TimeSpan)
LockAcquisition.AcquireUpgradeableReadLock<T>(T)
LockAcquisition.AcquireUpgradeableReadLock<T>(T, TimeSpan)
  • Improve this Doc
  • View Source
Back to top Generated by DocFX