Interface IMessage

Represents message that can be transferred between cluster nodes.

Inherited Members

IDataTransferObject.Empty

IDataTransferObject.IsReusable

IDataTransferObject.Length

IDataTransferObject.WriteToAsync<TWriter>(TWriter, CancellationToken)

IDataTransferObject.TransformAsync<TResult, TTransformation>(Stream, TTransformation, bool, Memory<byte>, CancellationToken)

IDataTransferObject.TransformAsync<TResult, TTransformation>(Stream, TTransformation, bool, MemoryAllocator<byte>, CancellationToken)

IDataTransferObject.TransformAsync<TResult, TTransformation>(Stream, TTransformation, bool, CancellationToken)

IDataTransferObject.TransformAsync<TResult, TTransformation>(PipeReader, TTransformation, CancellationToken)

IDataTransferObject.TransformAsync<TResult, TTransformation>(TTransformation, CancellationToken)

IDataTransferObject.TryGetMemory(out ReadOnlyMemory<byte>)

Namespace: DotNext.Net.Cluster.Messaging

Assembly: DotNext.Net.Cluster.dll

Syntax

public interface IMessage : IDataTransferObject

Remarks

Message is a low-level abstraction representing logical protocol-independent transport unit used for communication between nodes. This interface should not be implemented by entities at higher level of abstraction such as Business Layer. It is similar to Data Transfer Object.

Properties

Name

Gets name of the message.

Declaration

string Name { get; }

Property Value

Type	Description
string

Type

MIME type of the message.

Declaration

ContentType Type { get; }

Property Value

Type	Description
ContentType

Extension Methods

BasicExtensions.As<T>(T)

BasicExtensions.GetUserData<T>(T)

BasicExtensions.IsBetween<T, TLowerBound, TUpperBound>(T, TLowerBound, TUpperBound)

BasicExtensions.IsOneOf<T>(T, ReadOnlySpan<T>)

DataTransferObject.ToByteArrayAsync<TObject>(TObject, MemoryAllocator<byte>?, CancellationToken)

DataTransferObject.ToMemoryAsync<TObject>(TObject, MemoryAllocator<byte>?, CancellationToken)

DataTransferObject.ToStringAsync<TObject>(TObject, Encoding, MemoryAllocator<byte>?, CancellationToken)

DataTransferObject.TransformAsync<TResult, TObject>(TObject, Func<IAsyncBinaryReader, CancellationToken, ValueTask<TResult>>, CancellationToken)

DataTransferObject.WriteToAsync<TObject>(TObject, IBufferWriter<byte>, CancellationToken)

DataTransferObject.WriteToAsync<TObject>(TObject, PipeWriter, long, CancellationToken)

DataTransferObject.WriteToAsync<TObject>(TObject, Stream, int, CancellationToken)

DataTransferObject.WriteToAsync<TObject>(TObject, Stream, Memory<byte>, CancellationToken)

ExpressionBuilder.Const<T>(T)

Messenger.ReadAsTextAsync(IMessage, CancellationToken)

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)

See Also

TextMessage

StreamMessage