Class MongoLogArchiveStore

Implements Log Archive store using MongoDB

Inheritance
System.Object
DisposableObject
ApplicationComponent
LogArchiveStore
MongoLogArchiveStore
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.Log.Server
Assembly: Azos.Sky.MongoDb.dll
Syntax
public sealed class MongoLogArchiveStore : LogArchiveStore, IDisposable, IApplicationComponent

Constructors

MongoLogArchiveStore(LogReceiverService, LogArchiveDimensionsMapper, IConfigSectionNode)

Declaration
public MongoLogArchiveStore(LogReceiverService director, LogArchiveDimensionsMapper mapper, IConfigSectionNode node)
Parameters
Type Name Description
LogReceiverService director
LogArchiveDimensionsMapper mapper
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 = "archive"
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

List(String, DateTime, DateTime, Nullable<MessageType>, String, String, String, Nullable<Guid>, Int32)

Declaration
public override IEnumerable<Message> List(string archiveDimensionsFilter, DateTime startDate, DateTime endDate, MessageType? type = default(MessageType? ), string host = null, string channel = null, string topic = null, Guid? relatedTo = default(Guid? ), int skipCount = 0)
Parameters
Type Name Description
System.String archiveDimensionsFilter
System.DateTime startDate
System.DateTime endDate
System.Nullable<MessageType> type
System.String host
System.String channel
System.String topic
System.Nullable<System.Guid> relatedTo
System.Int32 skipCount
Returns
Type Description
System.Collections.Generic.IEnumerable<Message>
Overrides

Put(Message, Object)

Declaration
public override void Put(Message message, object transaction)
Parameters
Type Name Description
Message message
System.Object transaction
Overrides

RollbackTransaction(Object)

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

TryGetByID(Guid, out Message, String)

Declaration
public override bool TryGetByID(Guid id, out Message message, string channel = null)
Parameters
Type Name Description
System.Guid id
Message message
System.String channel
Returns
Type Description
System.Boolean
Overrides

Implements

System.IDisposable

Extension Methods