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

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

GetDumpfilePath(int)

public override string GetDumpfilePath(int connectionId)

Parameters

connectionId int

Returns

string

Init()

public override void Init()

InternalUpdate(DownstreamErrorInfo, CancellationToken)

protected override void InternalUpdate(DownstreamErrorInfo errorInfo, CancellationToken cancellationToken)

Parameters

errorInfo 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>