ArmoniK.Core

Contents:

  • 1. ArmoniK.Core
  • 2. Local Deployment of ArmoniK.Core
  • 3. Tests in ArmoniK.Core
  • 4. How to execute tests in ArmoniK.Core?
  • 5. ArmoniK.Core performance tests with HtcMock
  • 6. How to migrate ArmoniK.Core dependencies during upgrade ?
  • 7. Create a Windows Virtual Machine on AWS to Deploy ArmoniK Core
  • 8. Project components
  • 9. Tasks
  • 10. Authentication and Authorization
  • 11. Adaptors
  • 12. RabbitMQ Limitations
  • 13. MongoDB client connection problem
  • 14. Using external plugins with ArmoniK.Core
  • 15. TLS Implementation in the ArmoniK Core
  • 16. Artemis
  • 17. How to use ArmoniK RPCs
  • 18. Tasks Service RPCs actions
  • 19. Results Service RPCs actions
  • 20. Sessions Service RPCs actions
  • 21. API reference
    • 21.1. Namespace ArmoniK
    • 21.2. Namespace ArmoniK.Api
    • 21.3. Namespace ArmoniK.Api.gRPC
    • 21.4. Namespace ArmoniK.Api.gRPC.V1
    • 21.5. Class PayloadConfiguration
    • 21.6. Namespace ArmoniK.Core
    • 21.7. Namespace ArmoniK.Core.Adapters
    • 21.8. Namespace ArmoniK.Core.Adapters.Amqp
    • 21.9. Class ConnectionAmqp
    • 21.10. Interface IConnectionAmqp
    • 21.11. Class PullQueueStorage
    • 21.12. Class PushQueueStorage
    • 21.13. Class QueueBuilder
    • 21.14. Class QueueMessageHandler
    • 21.15. Class QueueStorage
    • 21.16. Namespace ArmoniK.Core.Adapters.Embed
    • 21.17. Class ObjectBuilder
    • 21.18. Class ObjectStorage
    • 21.19. Namespace ArmoniK.Core.Adapters.LocalStorage
    • 21.20. Class ObjectBuilder
    • 21.21. Class ObjectStorage
    • 21.22. Namespace ArmoniK.Core.Adapters.Memory
    • 21.23. Class ObjectStorage
    • 21.24. Class PushQueueStorage
    • 21.25. Class QueueStorage
    • 21.26. Class ResultTable
    • 21.27. Class ServiceCollectionExt
    • 21.28. Class SessionTable
    • 21.29. Class TaskTable
    • 21.30. Namespace ArmoniK.Core.Adapters.MongoDB
    • 21.31. Class AuthenticationTable
    • 21.32. Class ChangeStreamUpdate
    • 21.33. Namespace ArmoniK.Core.Adapters.MongoDB.Common
    • 21.34. Class BaseTable<TData, TModelMapping>
    • 21.35. Interface IMongoDataModelMapping<T>
    • 21.36. Class MongoCollectionProvider<TData, TModelMapping>
    • 21.37. Class SessionProvider
    • 21.38. Namespace ArmoniK.Core.Adapters.MongoDB.Options
    • 21.39. Class MongoDB
    • 21.40. Class TableStorage
    • 21.41. Class PartitionTable
    • 21.42. Class ResultTable
    • 21.43. Class ResultWatcher
    • 21.44. Class ServiceCollectionExt
    • 21.45. Class SessionTable
    • 21.46. Namespace ArmoniK.Core.Adapters.MongoDB.Table
    • 21.47. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
    • 21.48. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
    • 21.49. Class AuthDataAfterLookup
    • 21.50. Class AuthDataModelMapping
    • 21.51. Class MongoAuthResult
    • 21.52. Class RoleDataModelMapping
    • 21.53. Class UserDataAfterLookup
    • 21.54. Class UserDataModelMapping
    • 21.55. Class IndexHelper
    • 21.56. Enum IndexType
    • 21.57. Class PartitionDataModelMapping
    • 21.58. Class ResultDataModelMapping
    • 21.59. Class SessionDataModelMapping
    • 21.60. Class ShardingExt
    • 21.61. Class TaskDataModelMapping
    • 21.62. Class TaskTable
    • 21.63. Class TaskWatcher
    • 21.64. Class WatchEnumerable<TOutput, TInput>
    • 21.65. Class WatchEnumerator<TOutput, TInput>
    • 21.66. Namespace ArmoniK.Core.Adapters.PubSub
    • 21.67. Class Heart
    • 21.68. Class QueueBuilder
    • 21.69. Namespace ArmoniK.Core.Adapters.QueueCommon
    • 21.70. Class Amqp
    • 21.71. Class QueueStorageBase
    • 21.72. Namespace ArmoniK.Core.Adapters.RabbitMQ
    • 21.73. Class ConnectionRabbit
    • 21.74. Interface IConnectionRabbit
    • 21.75. Class PullQueueStorage
    • 21.76. Class PushQueueStorage
    • 21.77. Class QueueBuilder
    • 21.78. Class QueueMessageHandler
    • 21.79. Class QueueStorage
    • 21.80. Namespace ArmoniK.Core.Adapters.Redis
    • 21.81. Class ObjectBuilder
    • 21.82. Class ObjectStorage
    • 21.83. Namespace ArmoniK.Core.Adapters.Redis.Options
    • 21.84. Class Redis
    • 21.85. Namespace ArmoniK.Core.Adapters.S3
    • 21.86. Class ObjectBuilder
    • 21.87. Class ObjectStorage
    • 21.88. Namespace ArmoniK.Core.Adapters.S3.Options
    • 21.89. Class S3
    • 21.90. Namespace ArmoniK.Core.Adapters.SQS
    • 21.91. Class Heart
    • 21.92. Class QueueBuilder
    • 21.93. Namespace ArmoniK.Core.Base
    • 21.94. Namespace ArmoniK.Core.Base.DataStructures
    • 21.95. Enum HealthCheckTag
    • 21.96. Class MessageData
    • 21.97. Class ObjectData
    • 21.98. Class TaskOptions
    • 21.99. Namespace ArmoniK.Core.Base.Exceptions
    • 21.100. Class ArmoniKException
    • 21.101. Class ObjectDataNotFoundException
    • 21.102. Interface IDependencyInjectionBuildable
    • 21.103. Interface IHealthCheckProvider
    • 21.104. Interface IInitializable
    • 21.105. Interface IObjectStorage
    • 21.106. Interface IPullQueueStorage
    • 21.107. Interface IPushQueueStorage
    • 21.108. Interface IQueueMessageHandler
    • 21.109. Interface IQueueStorage
    • 21.110. Enum QueueMessageStatus
    • 21.111. Namespace ArmoniK.Core.Common
    • 21.112. Namespace ArmoniK.Core.Common.Auth
    • 21.113. Namespace ArmoniK.Core.Common.Auth.Authentication
    • 21.114. Class AuthData
    • 21.115. Class AuthenticationCache
    • 21.116. Class AuthenticationCacheKey
    • 21.117. Class Authenticator
    • 21.118. Class AuthenticatorOptions
    • 21.119. Interface IAuthenticationTable
    • 21.120. Class RoleData
    • 21.121. Class UserAuthenticationResult
    • 21.122. Class UserData
    • 21.123. Class UserIdentity
    • 21.124. Namespace ArmoniK.Core.Common.Auth.Authorization
    • 21.125. Class AuthorizationPolicyProvider
    • 21.126. Class GeneralService
    • 21.127. Class IgnoreAuthenticationAttribute
    • 21.128. Class IgnoreAuthorizationAttribute
    • 21.129. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
    • 21.130. Class Permission
    • 21.131. Class PermissionScope
    • 21.132. Class ServicesPermissions
    • 21.133. Class RequiresPermissionAttribute
    • 21.134. Namespace ArmoniK.Core.Common.Client
    • 21.135. Class GrpcChannelExt
    • 21.136. Class SessionStats
    • 21.137. Namespace ArmoniK.Core.Common.DynamicLoading
    • 21.138. Class CollocatedAssemblyResolver
    • 21.139. Namespace ArmoniK.Core.Common.Exceptions
    • 21.140. Class InvalidSessionTransitionException
    • 21.141. Class PartitionNotFoundException
    • 21.142. Class ResultNotFoundException
    • 21.143. Class SessionNotFoundException
    • 21.144. Class SubmissionClosedException
    • 21.145. Class TaskAlreadyExistsException
    • 21.146. Class TaskAlreadyInFinalStateException
    • 21.147. Class TaskCanceledException
    • 21.148. Class TaskNotFoundException
    • 21.149. Class TaskPausedException
    • 21.150. Class TimeoutException
    • 21.151. Class WorkerDownException
    • 21.152. Class HealthCheckRecord
    • 21.153. Class HealthCheckRecord.Publisher
    • 21.154. Interface IAsyncInitialization<T>
    • 21.155. Namespace ArmoniK.Core.Common.Injection
    • 21.156. Namespace ArmoniK.Core.Common.Injection.Options
    • 21.157. Class AdapterSettings
    • 21.158. Class Components
    • 21.159. Namespace ArmoniK.Core.Common.Injection.Options.Database
    • 21.160. Class Authentication
    • 21.161. Class Certificate
    • 21.162. Class InitDatabase
    • 21.163. Class Partition
    • 21.164. Class Partitioning
    • 21.165. Class Role
    • 21.166. Class User
    • 21.167. Class InitServices
    • 21.168. Class InitWorker
    • 21.169. Class Pollster
    • 21.170. Class Submitter
    • 21.171. Class ServiceCollectionExt
    • 21.172. Namespace ArmoniK.Core.Common.Meter
    • 21.173. Class FunctionExecutionMetrics<TIns>
    • 21.174. Class MeterHolder
    • 21.175. Namespace ArmoniK.Core.Common.Pollster
    • 21.176. Enum AcquisitionStatus
    • 21.177. Class Agent
    • 21.178. Class AgentHandler
    • 21.179. Class AgentIdentifier
    • 21.180. Class DataPrefetcher
    • 21.181. Interface IAgent
    • 21.182. Interface IAgentHandler
    • 21.183. Class Pollster
    • 21.184. Class PostProcessingTaskQueue
    • 21.185. Class PostProcessor
    • 21.186. Class RunningTaskProcessor
    • 21.187. Class RunningTaskQueue
      • 21.187.1. Inheritance
      • 21.187.2. Inherited Members
    • 21.188. Class TaskHandler
    • 21.189. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
    • 21.190. Interface ITaskProcessingChecker
    • 21.191. Class TaskProcessingCheckerClient
    • 21.192. Class TaskQueueBase
    • 21.193. Namespace ArmoniK.Core.Common.StateMachines
    • 21.194. Class ProcessReplyCreateLargeTaskStateMachine
    • 21.195. Enum ProcessReplyCreateLargeTaskStateMachine.State
    • 21.196. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
    • 21.197. Namespace ArmoniK.Core.Common.Storage
    • 21.198. Class Application
    • 21.199. Namespace ArmoniK.Core.Common.Storage.Events
    • 21.200. Interface IResultWatcher
    • 21.201. Interface ITaskWatcher
    • 21.202. Class NewResult
    • 21.203. Class NewTask
    • 21.204. Class ResultOwnerUpdate
    • 21.205. Class ResultStatusUpdate
    • 21.206. Class TaskStatusUpdate
    • 21.207. Interface IPartitionTable
    • 21.208. Interface IResultTable
    • 21.209. Class IResultTable.ChangeResultOwnershipRequest
    • 21.210. Interface ISessionTable
    • 21.211. Interface ITaskTable
    • 21.212. Class MaskedProjection
    • 21.213. Class Output
    • 21.214. Enum OutputStatus
    • 21.215. Class PartitionData
    • 21.216. Class PartitionTaskStatusCount
    • 21.217. Class PodConfiguration
    • 21.218. Class QueueMessageHandlerExt
    • 21.219. Class Result
    • 21.220. Class ResultCreationRequest
    • 21.221. Class ResultIdStatus
    • 21.222. Class ResultLifeCycleHelper
    • 21.223. Enum ResultStatus
    • 21.224. Class ResultTableExtensions
    • 21.225. Class SessionData
    • 21.226. Class SessionLifeCycleHelper
    • 21.227. Enum SessionStatus
    • 21.228. Class SessionTableExtensions
    • 21.229. Class TaskCreationRequest
    • 21.230. Class TaskData
    • 21.231. Enum TaskDataFields
    • 21.232. Class TaskDataHolder
    • 21.233. Class TaskDataMask
    • 21.234. Class TaskIdStatus
    • 21.235. Class TaskInfo
    • 21.236. Class TaskLifeCycleHelper
    • 21.237. Enum TaskOptionsFields
    • 21.238. Class TaskOptionsHolder
    • 21.239. Enum TaskStatus
    • 21.240. Class TaskStatusCount
    • 21.241. Class TaskSubmissionRequest
    • 21.242. Class TaskTableExtensions
    • 21.243. Class UpdateDefinition<T>
    • 21.244. Class UpdateDefinition<T>.PropertySet
    • 21.245. Namespace ArmoniK.Core.Common.Stream
    • 21.246. Namespace ArmoniK.Core.Common.Stream.Worker
    • 21.247. Interface IWorkerStreamHandler
    • 21.248. Class WorkerStreamHandler
    • 21.249. Namespace ArmoniK.Core.Common.Utils
    • 21.250. Class ActivityExt
    • 21.251. Class ActivitySourceExt
    • 21.252. Class ExceptionManager
    • 21.253. Class ExceptionManager.Options
    • 21.254. Class ExpressionsBuilders
    • 21.255. Class LocalIpFinder
    • 21.256. Class LoggerInit
    • 21.257. Class RendezvousChannel<T>
    • 21.258. Class ReplaceExpressionVisitor
    • 21.259. Class ReplaceParameterVisitor
    • 21.260. Namespace ArmoniK.Core.Common.gRPC
    • 21.261. Namespace ArmoniK.Core.Common.gRPC.Convertors
    • 21.262. Class OutputExt
    • 21.263. Class ResultExt
    • 21.264. Class ResultStatusExt
    • 21.265. Class SessionDataExt
    • 21.266. Class SessionStatusExt
    • 21.267. Class SessionTableExt
    • 21.268. Class TaskDataHolderExt
    • 21.269. Class TaskOptionsExt
    • 21.270. Class TaskStatusCountExt
    • 21.271. Class TaskStatusExt
    • 21.272. Class TaskTableExt
    • 21.273. Class EnumFieldExt
    • 21.274. Class ExceptionInterceptor
    • 21.275. Class ExpressionBuilders
    • 21.276. Class ExpressionExt
    • 21.277. Class FilterRangeExt
    • 21.278. Class GrpcHealthCheckServiceBase
    • 21.279. Class ListApplicationsRequestExt
    • 21.280. Class ListPartitionsRequestExt
    • 21.281. Class ListResultsRequestExt
    • 21.282. Class ListSessionsRequestExt
    • 21.283. Class ListTasksRequestExt
    • 21.284. Namespace ArmoniK.Core.Common.gRPC.Services
    • 21.285. Class GrpcAgentService
    • 21.286. Class GrpcApplicationsService
    • 21.287. Class GrpcAuthService
    • 21.288. Class GrpcEventsService
    • 21.289. Class GrpcHealthChecksService
    • 21.290. Class GrpcPartitionsService
    • 21.291. Class GrpcResultsService
    • 21.292. Class GrpcSessionsService
    • 21.293. Class GrpcSubmitterExtensions
    • 21.294. Class GrpcSubmitterService
    • 21.295. Class GrpcTasksService
    • 21.296. Class GrpcVersionsService
    • 21.297. Interface ISubmitter
    • 21.298. Class Submitter
    • 21.299. Class TaskRequest
    • 21.300. Class WatchToGrpc
    • 21.301. Class SessionFilterExt
    • 21.302. Class TaskFilterExt
    • 21.303. Namespace ArmoniK.Core.Common.gRPC.Validators
    • 21.304. Class CancelTasksRequestValidator
    • 21.305. Class CreateLargeTaskRequestValidator
    • 21.306. Class CreateSessionRequestValidator
    • 21.307. Class CreateSmallTaskRequestValidator
    • 21.308. Class CreateSmallTaskRequestValidator.TaskRequestValidator
    • 21.309. Class EventSubscriptionRequestValidator
    • 21.310. Class ListApplicationsRequestValidator
    • 21.311. Class ListPartitionsRequestValidator
    • 21.312. Class ListResultsRequestValidator
    • 21.313. Class ListSessionsRequestValidator
    • 21.314. Class ListTasksRequestValidator
    • 21.315. Class SessionFilterValidator
    • 21.316. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
    • 21.317. Class CreateSessionRequestValidator
    • 21.318. Class SubmitTasksRequestValidator
    • 21.319. Class TaskFilterValidator
    • 21.320. Class TaskOptionsValidator
    • 21.321. Namespace ArmoniK.Core.Compute
    • 21.322. Namespace ArmoniK.Core.Compute.PollingAgent
    • 21.323. Class Program
    • 21.324. Class Worker
    • 21.325. Namespace ArmoniK.Core.Control
    • 21.326. Namespace ArmoniK.Core.Control.Metrics
    • 21.327. Class ArmoniKMeter
    • 21.328. Namespace ArmoniK.Core.Control.Metrics.Options
    • 21.329. Class MetricsExporter
    • 21.330. Class Program
    • 21.331. Namespace ArmoniK.Core.Control.PartitionMetrics
    • 21.332. Class ArmoniKMeter
    • 21.333. Namespace ArmoniK.Core.Control.PartitionMetrics.Options
    • 21.334. Class MetricsExporter
    • 21.335. Class Program
    • 21.336. Namespace ArmoniK.Core.Control.Submitter
    • 21.337. Class GrpcHealthCheckService
    • 21.338. Class Program
    • 21.339. Namespace ArmoniK.Core.ProfilingTools
    • 21.340. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
    • 21.341. Class ActivityExt
    • 21.342. Class MongoExporterHelperExtensions
    • 21.343. Class MongoExporterOptions
    • 21.344. Class OpenTelemetryData
    • 21.345. Class OpenTelemetryDataModelMapping
    • 21.346. Namespace ArmoniK.Core.Tests
    • 21.347. Namespace ArmoniK.Core.Tests.Queue
    • 21.348. Class QueueStorageTests
    • 21.349. Namespace ArmoniK.Core.Utils
    • 21.350. Class CertificateValidator
    • 21.351. Class ConfigurationExt
    • 21.352. Class HealthCheck
    • 21.353. Class HealthCheckResultCombiner
    • 21.354. Class LoggerExt
    • 21.355. Class QueryableExt
    • 21.356. Class ServiceCollectionExt
    • 21.357. Namespace ArmoniK.Samples
    • 21.358. Namespace ArmoniK.Samples.Bench
    • 21.359. Namespace ArmoniK.Samples.Bench.Client
    • 21.360. Class ExecutionStats
    • 21.361. Namespace ArmoniK.Samples.Bench.Client.Options
    • 21.362. Class BenchOptions
    • 21.363. Namespace ArmoniK.Samples.Bench.Server
    • 21.364. Class BenchComputerService
    • 21.365. Namespace ArmoniK.Samples.CrashingWorker
    • 21.366. Namespace ArmoniK.Samples.CrashingWorker.Client
    • 21.367. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
    • 21.368. Class CrashingWorkerOptions
    • 21.369. Namespace ArmoniK.Samples.CrashingWorker.Server
    • 21.370. Class CrashingService
    • 21.371. Namespace ArmoniK.Samples.HtcMock
    • 21.372. Namespace ArmoniK.Samples.HtcMock.Client
    • 21.373. Class GridClient
    • 21.374. Class HtcMockClient
    • 21.375. Namespace ArmoniK.Samples.HtcMock.Client.Options
    • 21.376. Class HtcMock
    • 21.377. Class SessionClient
    • 21.378. Namespace ArmoniK.Samples.HtcMock.Server
    • 21.379. Class SampleComputerService
ArmoniK.Core
  • 21. API reference
  • 21.187. Class RunningTaskQueue
  • Edit on GitHub

21.187. Class RunningTaskQueue

Namespace: ArmoniK.Core.Common.Pollster
Assembly: ArmoniK.Core.Common.dll

Represents a queue for managing running tasks in the . Inherits from and provides functionality specific to active task processing.

public sealed class RunningTaskQueue : TaskQueueBase

21.187.1. Inheritance

object ← RendezvousChannel<TaskHandler> ← TaskQueueBase ← RunningTaskQueue

21.187.2. Inherited Members

RendezvousChannel<TaskHandler>.IsReaderClosed, RendezvousChannel<TaskHandler>.IsWriterClosed, RendezvousChannel<TaskHandler>.WriteAsync(TaskHandler, TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.ReadAsync(TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.CloseReader(), RendezvousChannel<TaskHandler>.CloseWriter(), RendezvousChannel<TaskHandler>.WaitForReader(TimeSpan, CancellationToken), RendezvousChannel<TaskHandler>.WaitForWriter(TimeSpan, CancellationToken), object.Equals(object?), object.Equals(object?, object?), object.GetHashCode(), object.GetType(), object.ReferenceEquals(object?, object?), object.ToString()

Previous Next

© Copyright 2021-2025, ANEO.

Built with Sphinx using a theme provided by Read the Docs.