Class MongoProcessStore
Implements TodoQueueStore using MongoDB
Inheritance
System.Object
MongoProcessStore
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)
Assembly: Azos.Sky.MongoDb.dll
Syntax
public sealed class MongoProcessStore : ProcessStore, IDisposable, IApplicationComponent
Constructors
MongoProcessStore(ProcessControllerService, IConfigSectionNode)
Declaration
public MongoProcessStore(ProcessControllerService director, IConfigSectionNode node)
Parameters
Fields
CONFIG_CONVERTER_SECTION
Declaration
public string CONFIG_CONVERTER_SECTION
Field Value
| Type |
Description |
| System.String |
|
CONFIG_MONGO_SECTION
Declaration
public string CONFIG_MONGO_SECTION
Field Value
| Type |
Description |
| System.String |
|
DEFAULT_BATCH_SIZE
Declaration
public const int DEFAULT_BATCH_SIZE = 32
Field Value
| Type |
Description |
| System.Int32 |
|
DEFAULT_FETCHBY_SIZE
Declaration
public const int DEFAULT_FETCHBY_SIZE = 32
Field Value
| Type |
Description |
| System.Int32 |
|
FLD_PROCESS_ABOUT
Declaration
public const string FLD_PROCESS_ABOUT = "ab"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_CONTENT
Declaration
public const string FLD_PROCESS_CONTENT = "c"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_DESCRIPTION
Declaration
public const string FLD_PROCESS_DESCRIPTION = "ds"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_PROCESSOR_ID
Declaration
public const string FLD_PROCESS_PROCESSOR_ID = "p"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_SERIALIZER
Declaration
public const string FLD_PROCESS_SERIALIZER = "sr"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_STATUS
Declaration
public const string FLD_PROCESS_STATUS = "st"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_STATUS_ABOUT
Declaration
public const string FLD_PROCESS_STATUS_ABOUT = "sab"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_STATUS_DESCRIPTION
Declaration
public const string FLD_PROCESS_STATUS_DESCRIPTION = "sds"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_STATUS_TIMESTAMP
Declaration
public const string FLD_PROCESS_STATUS_TIMESTAMP = "sts"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_TIMESTAMP
Declaration
public const string FLD_PROCESS_TIMESTAMP = "ts"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_TYPE
Declaration
public const string FLD_PROCESS_TYPE = "t"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_UNIQUE
Declaration
public const string FLD_PROCESS_UNIQUE = "u"
Field Value
| Type |
Description |
| System.String |
|
FLD_PROCESS_ZONE
Declaration
public const string FLD_PROCESS_ZONE = "z"
Field Value
| Type |
Description |
| System.String |
|
MAX_BATCH_SIZE
Declaration
public const int MAX_BATCH_SIZE = 1024
Field Value
| Type |
Description |
| System.Int32 |
|
MAX_FETCHBY_SIZE
Declaration
public const int MAX_FETCHBY_SIZE = 4096
Field Value
| Type |
Description |
| System.Int32 |
|
Properties
BatchSize
Declaration
[Config(Default = 32)]
public int BatchSize { get; }
Property Value
| Type |
Description |
| System.Int32 |
|
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
Delete(ProcessFrame, Object)
Declaration
public override void Delete(ProcessFrame frame, object transaction)
Parameters
| Type |
Name |
Description |
| ProcessFrame |
frame |
|
| System.Object |
transaction |
|
Overrides
Destructor()
Declaration
protected override void Destructor()
Overrides
List(Int32)
Declaration
public override IEnumerable<ProcessDescriptor> List(int processorID)
Parameters
| Type |
Name |
Description |
| System.Int32 |
processorID |
|
Returns
Overrides
Put(ProcessFrame, Object)
Declaration
public override void Put(ProcessFrame frame, object transaction)
Parameters
| Type |
Name |
Description |
| ProcessFrame |
frame |
|
| System.Object |
transaction |
|
Overrides
RollbackTransaction(Object)
Declaration
public override void RollbackTransaction(object transaction)
Parameters
| Type |
Name |
Description |
| System.Object |
transaction |
|
Overrides
TryGetByPID(PID, out ProcessFrame)
Declaration
public override bool TryGetByPID(PID pid, out ProcessFrame frame)
Parameters
Returns
| Type |
Description |
| System.Boolean |
|
Overrides
Update(ProcessFrame, Boolean, Object)
Declaration
public override void Update(ProcessFrame frame, bool sysOnly, object transaction)
Parameters
| Type |
Name |
Description |
| ProcessFrame |
frame |
|
| System.Boolean |
sysOnly |
|
| System.Object |
transaction |
|
Overrides
Implements
System.IDisposable
Extension Methods