Class DirectoryArchiveWriter

Namespace

Fluxzy.Writers

Assembly

Fluxzy.Core.dll

public class DirectoryArchiveWriter : RealtimeArchiveWriter

Inheritance

object

RealtimeArchiveWriter

DirectoryArchiveWriter

Inherited Members

RealtimeArchiveWriter.ErrorCount

RealtimeArchiveWriter.InternalTotalProcessedExchanges

RealtimeArchiveWriter.TotalProcessedExchanges

RealtimeArchiveWriter.RegisterExchangeLimit(int?, Action)

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

Constructors

DirectoryArchiveWriter(string, Filter?)

public DirectoryArchiveWriter(string baseDirectory, Filter? saveFilter)

Parameters

baseDirectory string

saveFilter Filter

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

GetDumpfilePath(int)

Gets the dump file path for the specified connection ID.

public override string GetDumpfilePath(int connectionId)

Parameters

connectionId int

The ID of the connection.

Returns

string

The dump file path as a string.

GetNextIds()

public (int ExchangeId, int ConnectionId) GetNextIds()

Returns

(int ExchangeId, int ConnectionId)

Init()

public override void Init()

InternalUpdate(DownstreamErrorInfo, CancellationToken)

Performs the internal update logic for the specified connection.

protected override void InternalUpdate(DownstreamErrorInfo errorInfo, CancellationToken cancellationToken)

Parameters

errorInfo DownstreamErrorInfo

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.

WriteAsset(string, Stream)

public void WriteAsset(string relativePath, Stream stream)

Parameters

relativePath string

stream Stream