Class TodoQueueService
Service that enqueues todos
Inheritance
System.Object
TodoQueueService
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.dll
Syntax
public sealed class TodoQueueService : AgentServiceBase, IDisposable, IDaemon, IDaemonView, INamed, IConfigurable, ILocalizedTimeProvider, IInstrumentable, IExternallyParameterized, ITodoQueue, ISkyService, ITodoHost, IApplicationComponent
Constructors
TodoQueueService(IApplicationComponent)
Declaration
public TodoQueueService(IApplicationComponent director)
Parameters
TodoQueueService(IApplication)
Declaration
public TodoQueueService(IApplication app)
Parameters
Fields
ALL
Declaration
public const string ALL = "*"
Field Value
| Type |
Description |
| System.String |
|
CONFIG_QUEUE_SECTION
Declaration
public const string CONFIG_QUEUE_SECTION = "queue"
Field Value
| Type |
Description |
| System.String |
|
CONFIG_QUEUE_STORE_SECTION
Declaration
public const string CONFIG_QUEUE_STORE_SECTION = "queue-store"
Field Value
| Type |
Description |
| System.String |
|
CONFIG_TYPE_RESOLVER_SECTION
Declaration
public const string CONFIG_TYPE_RESOLVER_SECTION = "type-resolver"
Field Value
| Type |
Description |
| System.String |
|
FULL_BATCH_SIZE
Declaration
public const int FULL_BATCH_SIZE = 1024
Field Value
| Type |
Description |
| System.Int32 |
|
Properties
ComponentLogTopic
Declaration
public override string ComponentLogTopic { get; }
Property Value
| Type |
Description |
| System.String |
|
Overrides
ThreadGranularityMs
Declaration
public override int ThreadGranularityMs { get; }
Property Value
| Type |
Description |
| System.Int32 |
|
Overrides
Methods
Destructor()
Declaration
protected override void Destructor()
Overrides
Declaration
protected override void DoConfigure(IConfigSectionNode node)
Parameters
Overrides
DoDumpStats(IInstrumentation, DateTime)
Declaration
protected override void DoDumpStats(IInstrumentation instr, DateTime utcNow)
Parameters
Overrides
DoResetStats(DateTime)
Declaration
protected override void DoResetStats(DateTime utcNow)
Parameters
| Type |
Name |
Description |
| System.DateTime |
utcNow |
|
Overrides
DoSignalStop()
Declaration
protected override void DoSignalStop()
Overrides
DoStart()
Declaration
protected override void DoStart()
Overrides
DoThreadSpin(DateTime)
Declaration
protected override void DoThreadSpin(DateTime utcNow)
Parameters
| Type |
Name |
Description |
| System.DateTime |
utcNow |
|
Overrides
DoWaitForCompleteStop()
Declaration
protected override void DoWaitForCompleteStop()
Overrides
Enqueue(TodoFrame[])
Routes todos to appropriate queue and enqueues for processing
Declaration
public int Enqueue(TodoFrame[] todos)
Parameters
Returns
| Type |
Description |
| System.Int32 |
|
Enqueue(IEnumerable<Todo>)
Routes todos to appropriate queue and enqueues for processing
Declaration
public int Enqueue(IEnumerable<Todo> todos)
Parameters
| Type |
Name |
Description |
| System.Collections.Generic.IEnumerable<Todo> |
todos |
|
Returns
| Type |
Description |
| System.Int32 |
|
Explicit Interface Implementations
ITodoHost.LocalEnqueue(Todo)
Declaration
void ITodoHost.LocalEnqueue(Todo todo)
Parameters
| Type |
Name |
Description |
| Todo |
todo |
|
ITodoHost.LocalEnqueue(IEnumerable<Todo>)
Declaration
void ITodoHost.LocalEnqueue(IEnumerable<Todo> todos)
Parameters
| Type |
Name |
Description |
| System.Collections.Generic.IEnumerable<Todo> |
todos |
|
ITodoHost.LocalEnqueueAsync(IEnumerable<Todo>)
Declaration
Task ITodoHost.LocalEnqueueAsync(IEnumerable<Todo> todos)
Parameters
| Type |
Name |
Description |
| System.Collections.Generic.IEnumerable<Todo> |
todos |
|
Returns
| Type |
Description |
| System.Threading.Tasks.Task |
|
Implements
System.IDisposable
Extension Methods