Class RealtimeArchiveWriter

Namespace

Fluxzy.Writers

Assembly

Fluxzy.Core.dll

public abstract class RealtimeArchiveWriter

Inheritance

object

RealtimeArchiveWriter

Derived

DirectoryArchiveWriter

EventOnlyArchiveWriter

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Fields

ErrorCount

protected int ErrorCount

Field Value

int

InternalTotalProcessedExchanges

protected long InternalTotalProcessedExchanges

Field Value

long

Properties

TotalProcessedExchanges

public long TotalProcessedExchanges { get; }

Property Value

long

Methods

ClearErrors()

public abstract void ClearErrors()

CreateRequestBodyStream(int)

public abstract Stream CreateRequestBodyStream(int exchangeId)

Parameters

exchangeId int

Returns

Stream

CreateResponseBodyStream(int)

public abstract Stream CreateResponseBodyStream(int exchangeId)

Parameters

exchangeId int

Returns

Stream

CreateWebSocketRequestContent(int, int)

public abstract Stream CreateWebSocketRequestContent(int exchangeId, int messageId)

Parameters

exchangeId int

messageId int

Returns

Stream

CreateWebSocketResponseContent(int, int)

public abstract Stream CreateWebSocketResponseContent(int exchangeId, int messageId)

Parameters

exchangeId int

messageId int

Returns

Stream

Dispose()

public void Dispose()

Dispose(bool)

protected virtual void Dispose(bool disposing)

Parameters

disposing bool

GetDumpfilePath(int)

public virtual string GetDumpfilePath(int connectionId)

Parameters

connectionId int

Returns

string

Init()

public virtual void Init()

InternalUpdate(DownstreamErrorInfo, CancellationToken)

protected abstract void InternalUpdate(DownstreamErrorInfo connectionInfo, CancellationToken cancellationToken)

Parameters

connectionInfo DownstreamErrorInfo

cancellationToken CancellationToken

RegisterExchangeLimit(int?, Action)

public virtual void RegisterExchangeLimit(int? maxExchangeCount, Action onMaxExchangeCountReached)

Parameters

maxExchangeCount int?

onMaxExchangeCountReached Action

Update(ConnectionInfo, CancellationToken)

public abstract void Update(ConnectionInfo connectionInfo, CancellationToken cancellationToken)

Parameters

connectionInfo ConnectionInfo

cancellationToken CancellationToken

Update(Connection, CancellationToken)

public virtual void Update(Connection connection, CancellationToken cancellationToken)

Parameters

connection Connection

cancellationToken CancellationToken

Update(Exchange, ArchiveUpdateType, CancellationToken)

public virtual void Update(Exchange exchange, ArchiveUpdateType updateType, CancellationToken cancellationToken)

Parameters

exchange Exchange

updateType ArchiveUpdateType

cancellationToken CancellationToken

Update(DownstreamErrorInfo, CancellationToken)

public virtual void Update(DownstreamErrorInfo errorInfo, CancellationToken cancellationToken)

Parameters

errorInfo DownstreamErrorInfo

cancellationToken CancellationToken

Update(ExchangeInfo, CancellationToken)

public abstract bool Update(ExchangeInfo exchangeInfo, CancellationToken cancellationToken)

Parameters

exchangeInfo ExchangeInfo

cancellationToken CancellationToken

Returns

bool

UpdateTags(IEnumerable<Tag>)

public abstract void UpdateTags(IEnumerable<Tag> tags)

Parameters

tags IEnumerable<Tag>

Events

ConnectionUpdated

public event EventHandler<ConnectionUpdateEventArgs>? ConnectionUpdated

Event Type

EventHandler<ConnectionUpdateEventArgs>

ErrorUpdated

public event EventHandler<DownstreamErrorEventArgs>? ErrorUpdated

Event Type

EventHandler<DownstreamErrorEventArgs>

ExchangeUpdated

public event EventHandler<ExchangeUpdateEventArgs>? ExchangeUpdated

Event Type

EventHandler<ExchangeUpdateEventArgs>