Show / Hide Table of Contents

Class PersistentChannelOptions

Represents persistent channel options.

Inheritance
object
ChannelOptions
PersistentChannelOptions
Inherited Members
ChannelOptions.AllowSynchronousContinuations
ChannelOptions.SingleReader
ChannelOptions.SingleWriter
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: DotNext.Threading.Channels
Assembly: DotNext.Threading.dll
Syntax
public sealed class PersistentChannelOptions : ChannelOptions

Constructors

| Edit this page View Source

PersistentChannelOptions()

Initializes a new options with default settings.

Declaration
public PersistentChannelOptions()

Properties

| Edit this page 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
int
| Edit this page View Source

InitialPartitionSize

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

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

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

| Edit this page View Source

Location

Gets or sets path used to store queue files.

Declaration
public string Location { get; set; }
Property Value
Type Description
string
| Edit this page View Source

MeasurementTags

Gets or sets a list of tags to be associated with each measurement.

Declaration
[CLSCompliant(false)]
public TagList MeasurementTags { get; set; }
Property Value
Type Description
TagList
| Edit this page View Source

PartitionCapacity

Gets or sets maximum number of messages per file.

Declaration
public int PartitionCapacity { get; set; }
Property Value
Type Description
int
| Edit this page View Source

ReliableEnumeration

Gets or sets a value indicating that ReadAllAsync(CancellationToken) must provide reliable (transactional) enumeration over persisted elements.

Declaration
public bool ReliableEnumeration { get; set; }
Property Value
Type Description
bool
Remarks

Reliable read means that the element obtained via Current is not marked as read before the next call of MoveNextAsync(). Note that reliable enumeration affects the performance of asynchronous enumerator.

Extension Methods

BasicExtensions.As<T>(T)
BasicExtensions.GetUserData<T>(T)
BasicExtensions.IsBetween<T, TLowerBound, TUpperBound>(T, TLowerBound, TUpperBound)
BasicExtensions.IsOneOf<T>(T, ReadOnlySpan<T>)
ExpressionBuilder.Const<T>(T)
AsyncLockAcquisition.AcquireLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireLockAsync<T>(T, TimeSpan, CancellationToken)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireReadLockAsync<T>(T, TimeSpan, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, TimeSpan, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, CancellationToken)
AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, TimeSpan, CancellationToken)
LockAcquisition.AcquireReadLock<T>(T)
LockAcquisition.AcquireReadLock<T>(T, TimeSpan)
LockAcquisition.AcquireUpgradeableReadLock<T>(T)
LockAcquisition.AcquireUpgradeableReadLock<T>(T, TimeSpan)
LockAcquisition.AcquireWriteLock<T>(T)
LockAcquisition.AcquireWriteLock<T>(T, TimeSpan)
  • Edit this page
  • View Source
☀
☾
In this article
Back to top
Supported by the .NET Foundation
☀
☾