Class EventOnlyArchiveWriter

Namespace

Fluxzy.Writers

Assembly

Fluxzy.Core.dll

public class EventOnlyArchiveWriter : RealtimeArchiveWriter

Inheritance

object

RealtimeArchiveWriter

EventOnlyArchiveWriter

Inherited Members

RealtimeArchiveWriter.ErrorCount

RealtimeArchiveWriter.InternalTotalProcessedExchanges

RealtimeArchiveWriter.TotalProcessedExchanges

RealtimeArchiveWriter.Init()

RealtimeArchiveWriter.RegisterExchangeLimit(int?, Action)

RealtimeArchiveWriter.GetDumpfilePath(int)

RealtimeArchiveWriter.Dispose()

RealtimeArchiveWriter.ExchangeUpdated

RealtimeArchiveWriter.ConnectionUpdated

RealtimeArchiveWriter.ErrorUpdated

RealtimeArchiveWriter.Update(DownstreamErrorInfo, CancellationToken)

RealtimeArchiveWriter.Update(Connection, CancellationToken)

RealtimeArchiveWriter.Update(Exchange, ArchiveUpdateType, CancellationToken)

RealtimeArchiveWriter.Dispose(bool)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

ClearErrors()

public override void ClearErrors()

CreateRequestBodyStream(int)

public override Stream CreateRequestBodyStream(int exchangeId)

Parameters

exchangeId int

Returns

Stream

CreateResponseBodyStream(int)

public override Stream CreateResponseBodyStream(int exchangeId)

Parameters

exchangeId int

Returns

Stream

CreateWebSocketRequestContent(int, int)

public override Stream CreateWebSocketRequestContent(int exchangeId, int messageId)

Parameters

exchangeId int

messageId int

Returns

Stream

CreateWebSocketResponseContent(int, int)

public override Stream CreateWebSocketResponseContent(int exchangeId, int messageId)

Parameters

exchangeId int

messageId int

Returns

Stream

InternalUpdate(DownstreamErrorInfo, CancellationToken)

protected override void InternalUpdate(DownstreamErrorInfo connectionInfo, CancellationToken cancellationToken)

Parameters

connectionInfo DownstreamErrorInfo

cancellationToken CancellationToken

Update(ConnectionInfo, CancellationToken)

public override void Update(ConnectionInfo connectionInfo, CancellationToken cancellationToken)

Parameters

connectionInfo ConnectionInfo

cancellationToken CancellationToken

Update(ExchangeInfo, CancellationToken)

public override bool Update(ExchangeInfo exchangeInfo, CancellationToken cancellationToken)

Parameters

exchangeInfo ExchangeInfo

cancellationToken CancellationToken

Returns

bool

UpdateTags(IEnumerable<Tag>)

public override void UpdateTags(IEnumerable<Tag> tags)

Parameters

tags IEnumerable<Tag>