Class DefaultKdbStore

Provides default implementation of IKdbDataStore

Inheritance
System.Object
DisposableObject
ApplicationComponent
Daemon
Daemon<IApplicationComponent>
DaemonWithInstrumentation<IApplicationComponent>
DefaultKdbStore
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.Kdb
Assembly: Azos.Sky.MongoDb.dll
Syntax
public sealed class DefaultKdbStore : DaemonWithInstrumentation<IApplicationComponent>, IDaemon, IDaemonView, INamed, ILocalizedTimeProvider, IKdbDataStoreImplementation, IKdbDataStore, IDataStoreImplementation, IDataStore, IApplicationComponent, IDisposable, IConfigurable, IInstrumentable, IExternallyParameterized

Constructors

DefaultKdbStore(IApplicationComponent)

Declaration
public DefaultKdbStore(IApplicationComponent director)
Parameters
Type Name Description
IApplicationComponent director

DefaultKdbStore(IApplicationComponent, String)

Declaration
public DefaultKdbStore(IApplicationComponent director, string name)
Parameters
Type Name Description
IApplicationComponent director
System.String name

DefaultKdbStore(IApplication)

Declaration
public DefaultKdbStore(IApplication app)
Parameters
Type Name Description
IApplication app

DefaultKdbStore(IApplication, String)

Declaration
public DefaultKdbStore(IApplication app, string name)
Parameters
Type Name Description
IApplication app
System.String name

Fields

CONFIG_FALLBACK_SECTION

Declaration
public const string CONFIG_FALLBACK_SECTION = "fallback"
Field Value
Type Description
System.String

CONFIG_ORDER_ATTR

Declaration
public const string CONFIG_ORDER_ATTR = "order"
Field Value
Type Description
System.String

CONFIG_PRIMARY_CONNECT_STRING_ATTR

Declaration
public const string CONFIG_PRIMARY_CONNECT_STRING_ATTR = "primary-cs"
Field Value
Type Description
System.String

CONFIG_SECONDARY_CONNECT_STRING_ATTR

Declaration
public const string CONFIG_SECONDARY_CONNECT_STRING_ATTR = "secondary-cs"
Field Value
Type Description
System.String

CONFIG_SHARD_SECTION

Declaration
public const string CONFIG_SHARD_SECTION = "shard"
Field Value
Type Description
System.String

Kdb_TARGET

Declaration
public const string Kdb_TARGET = "kdb"
Field Value
Type Description
System.String

Properties

ComponentLogTopic

Declaration
public override string ComponentLogTopic { get; }
Property Value
Type Description
System.String
Overrides

InstrumentationEnabled

Implements IInstrumentable

Declaration
[Config(Default = false)]
[ExternalParameter(new string[]{"data", "instrumentation"})]
public override bool InstrumentationEnabled { get; set; }
Property Value
Type Description
System.Boolean
Overrides
Azos.Apps.DaemonWithInstrumentation<Azos.Apps.IApplicationComponent>.InstrumentationEnabled

LogLevel

Declaration
[Config(Default = MessageType.Error)]
[ExternalParameter(new string[]{"data", "instrumentation"})]
public MessageType LogLevel { get; set; }
Property Value
Type Description
MessageType

RootShardSet

Declaration
public DefaultKdbStore.ShardSet RootShardSet { get; }
Property Value
Type Description
DefaultKdbStore.ShardSet

TargetName

Declaration
public string TargetName { get; }
Property Value
Type Description
System.String

Methods

Delete(String, Byte[])

Declaration
public bool Delete(string table, byte[] key)
Parameters
Type Name Description
System.String table
System.Byte[] key
Returns
Type Description
System.Boolean

Destructor()

Declaration
protected override void Destructor()
Overrides

DoAcceptManagerVisit(Object, DateTime)

Declaration
protected override void DoAcceptManagerVisit(object manager, DateTime managerNow)
Parameters
Type Name Description
System.Object manager
System.DateTime managerNow
Overrides

DoConfigure(IConfigSectionNode)

Declaration
protected override void DoConfigure(IConfigSectionNode node)
Parameters
Type Name Description
IConfigSectionNode node
Overrides

DoStart()

Declaration
protected override void DoStart()
Overrides

DoWaitForCompleteStop()

Declaration
protected override void DoWaitForCompleteStop()
Overrides

Get(String, Byte[])

Declaration
public Doc Get(string table, byte[] key)
Parameters
Type Name Description
System.String table
System.Byte[] key
Returns
Type Description
Doc

Get<TRow>(String, Byte[], Boolean)

Declaration
public KdbRecord<TRow> Get<TRow>(string table, byte[] key, bool dontToch = false)

    where TRow : Doc
Parameters
Type Name Description
System.String table
System.Byte[] key
System.Boolean dontToch
Returns
Type Description
KdbRecord<TRow>
Type Parameters
Name Description
TRow

GetRaw(String, Byte[], Boolean)

Declaration
public KdbRecord<byte[]> GetRaw(string table, byte[] key, bool dontToch = false)
Parameters
Type Name Description
System.String table
System.Byte[] key
System.Boolean dontToch
Returns
Type Description
KdbRecord<System.Byte[]>

Put(String, Byte[], Doc, Int32, Nullable<DateTime>)

Declaration
public void Put(string table, byte[] key, Doc value, int slidingExpirationDays = -1, DateTime? absoluteExpirationDateUtc = default(DateTime? ))
Parameters
Type Name Description
System.String table
System.Byte[] key
Doc value
System.Int32 slidingExpirationDays
System.Nullable<System.DateTime> absoluteExpirationDateUtc

PutRaw(String, Byte[], Byte[], Int32, Nullable<DateTime>)

Declaration
public void PutRaw(string table, byte[] key, byte[] value, int slidingExpirationDays = -1, DateTime? absoluteExpirationDateUtc = default(DateTime? ))
Parameters
Type Name Description
System.String table
System.Byte[] key
System.Byte[] value
System.Int32 slidingExpirationDays
System.Nullable<System.DateTime> absoluteExpirationDateUtc

TestConnection()

Declaration
public void TestConnection()

Explicit Interface Implementations

IDataStoreImplementation.LogLevel

Declaration
StoreLogLevel IDataStoreImplementation.LogLevel { get; set; }
Returns
Type Description
StoreLogLevel

Implements

System.IDisposable

Extension Methods