Class MongoTelemetryArchiveStore

Implements Telemetry Archive using MongoDb

Inheritance
System.Object
DisposableObject
ApplicationComponent
TelemetryArchiveStore
MongoTelemetryArchiveStore
Implements
System.IDisposable
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
Namespace: Azos.Sky.Instrumentation.Server
Assembly: Azos.Sky.MongoDb.dll
Syntax
public sealed class MongoTelemetryArchiveStore : TelemetryArchiveStore, IDisposable, IApplicationComponent

Constructors

MongoTelemetryArchiveStore(TelemetryReceiverService, IConfigSectionNode)

Declaration
public MongoTelemetryArchiveStore(TelemetryReceiverService director, IConfigSectionNode node)
Parameters
Type Name Description
TelemetryReceiverService director
IConfigSectionNode node

Fields

CONFIG_DEFAULT_CHANNEL_ATTR

Declaration
public const string CONFIG_DEFAULT_CHANNEL_ATTR = "default-channel"
Field Value
Type Description
System.String

CONFIG_MONGO_SECTION

Declaration
public const string CONFIG_MONGO_SECTION = "mongo"
Field Value
Type Description
System.String

DEFAULT_CHANNEL

Declaration
public const string DEFAULT_CHANNEL = "telemetry"
Field Value
Type Description
System.String

DEFAULT_FETCHBY_SIZE

Declaration
public const int DEFAULT_FETCHBY_SIZE = 32
Field Value
Type Description
System.Int32

MAX_FETCHBY_SIZE

Declaration
public const int MAX_FETCHBY_SIZE = 4096
Field Value
Type Description
System.Int32

Properties

FetchBy

Declaration
[Config(Default = 32)]
public int FetchBy { get; }
Property Value
Type Description
System.Int32

Methods

BeginTransaction()

Declaration
public override object BeginTransaction()
Returns
Type Description
System.Object
Overrides

CommitTransaction(Object)

Declaration
public override void CommitTransaction(object transaction)
Parameters
Type Name Description
System.Object transaction
Overrides

Destructor()

Declaration
protected override void Destructor()
Overrides

Put(Datum[], Object)

Declaration
public override void Put(Datum[] data, object transaction)
Parameters
Type Name Description
Datum[] data
System.Object transaction
Overrides

RollbackTransaction(Object)

Declaration
public override void RollbackTransaction(object transaction)
Parameters
Type Name Description
System.Object transaction
Overrides

Implements

System.IDisposable

Extension Methods