Class EventOnlyArchiveWriter

Namespace

Fluxzy.Writers

Assembly

Fluxzy.Core.dll

public class EventOnlyArchiveWriter : RealtimeArchiveWriter

Inheritance

object

RealtimeArchiveWriter

EventOnlyArchiveWriter

Derived

PcapOnlyArchiveWriter

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()

ConnectionUpdateRequired(Connection)

Check whether calling Update(ConnectionInfo, CancellationToken) is necessary

protected override bool ConnectionUpdateRequired(Connection connection)

Parameters

connection Connection

Returns

bool

CreateRequestBodyStream(int)

Creates a request body stream for the specified exchange ID.

public override Stream CreateRequestBodyStream(int exchangeId)

Parameters

exchangeId int

The ID of the exchange.

Returns

Stream

A stream representing the request body.

CreateResponseBodyStream(int)

Creates the response body stream for the given exchange ID.

public override Stream CreateResponseBodyStream(int exchangeId)

Parameters

exchangeId int

The identifier of the exchange.

Returns

Stream

The response body stream.

CreateWebSocketRequestContent(int, int)

Creates the content of a WebSocket request.

public override Stream CreateWebSocketRequestContent(int exchangeId, int messageId)

Parameters

exchangeId int

The ID of the exchange.

messageId int

The ID of the message.

Returns

Stream

A Stream representing the content of the WebSocket request.

CreateWebSocketResponseContent(int, int)

Creates the content for the WebSocket response.

public override Stream CreateWebSocketResponseContent(int exchangeId, int messageId)

Parameters

exchangeId int

The ID of the exchange.

messageId int

The ID of the message.

Returns

Stream

A Stream containing the response content.

ExchangeUpdateRequired(Exchange)

Check whether calling Update(ExchangeInfo, CancellationToken) is necessary

protected override bool ExchangeUpdateRequired(Exchange exchange)

Parameters

exchange Exchange

Returns

bool

InternalUpdate(DownstreamErrorInfo, CancellationToken)

Performs the internal update logic for the specified connection.

protected override void InternalUpdate(DownstreamErrorInfo connectionInfo, CancellationToken cancellationToken)

Parameters

connectionInfo DownstreamErrorInfo

The information about the connection.

cancellationToken CancellationToken

A cancellation token to cancel the operation.

Update(ConnectionInfo, CancellationToken)

Updates the connection information for the given connection.

public override void Update(ConnectionInfo connectionInfo, CancellationToken cancellationToken)

Parameters

connectionInfo ConnectionInfo

The new connection information to be updated.

cancellationToken CancellationToken

The cancellation token to cancel the update operation.

Update(ExchangeInfo, CancellationToken)

Updates the exchange information.

public override bool Update(ExchangeInfo exchangeInfo, CancellationToken cancellationToken)

Parameters

exchangeInfo ExchangeInfo

The exchange information to update.

cancellationToken CancellationToken

The cancellation token.

Returns

bool

Returns a value indicating whether the update was successful.

UpdateTags(IEnumerable<Tag>)

Updates the tags associated with the item.

public override void UpdateTags(IEnumerable<Tag> tags)

Parameters

tags IEnumerable<Tag>

The tags to be updated.