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. Environment variables
  • 22. API reference
    • 22.1. Namespace ArmoniK
    • 22.2. Namespace ArmoniK.Api
    • 22.3. Namespace ArmoniK.Api.gRPC
    • 22.4. Namespace ArmoniK.Api.gRPC.V1
    • 22.5. Class PayloadConfiguration
    • 22.6. Namespace ArmoniK.Core
    • 22.7. Namespace ArmoniK.Core.Adapters
    • 22.8. Namespace ArmoniK.Core.Adapters.Amqp
    • 22.9. Class ConnectionAmqp
    • 22.10. Interface IConnectionAmqp
    • 22.11. Class PullQueueStorage
    • 22.12. Class PushQueueStorage
    • 22.13. Class QueueBuilder
    • 22.14. Class QueueMessageHandler
    • 22.15. Class QueueStorage
    • 22.16. Namespace ArmoniK.Core.Adapters.Embed
    • 22.17. Class ObjectBuilder
    • 22.18. Class ObjectStorage
    • 22.19. Namespace ArmoniK.Core.Adapters.LocalStorage
    • 22.20. Class ObjectBuilder
    • 22.21. Class ObjectStorage
    • 22.22. Namespace ArmoniK.Core.Adapters.Memory
    • 22.23. Class ObjectStorage
    • 22.24. Class PushQueueStorage
    • 22.25. Class QueueStorage
    • 22.26. Class ResultTable
    • 22.27. Class ServiceCollectionExt
    • 22.28. Class SessionTable
    • 22.29. Class TaskTable
    • 22.30. Namespace ArmoniK.Core.Adapters.MongoDB
    • 22.31. Class AuthenticationTable
    • 22.32. Class ChangeStreamUpdate
    • 22.33. Namespace ArmoniK.Core.Adapters.MongoDB.Common
    • 22.34. Class BaseTable<TData, TModelMapping>
    • 22.35. Interface IMongoDataModelMapping<T>
    • 22.36. Class MongoCollectionProvider<TData, TModelMapping>
    • 22.37. Class SessionProvider
    • 22.38. Namespace ArmoniK.Core.Adapters.MongoDB.Options
    • 22.39. Class MongoDB
    • 22.40. Class TableStorage
    • 22.41. Class PartitionTable
    • 22.42. Class ResultTable
    • 22.43. Class ResultWatcher
    • 22.44. Class ServiceCollectionExt
    • 22.45. Class SessionTable
    • 22.46. Namespace ArmoniK.Core.Adapters.MongoDB.Table
    • 22.47. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
    • 22.48. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
    • 22.49. Class AuthDataAfterLookup
    • 22.50. Class AuthDataModelMapping
    • 22.51. Class MongoAuthResult
    • 22.52. Class RoleDataModelMapping
    • 22.53. Class UserDataAfterLookup
    • 22.54. Class UserDataModelMapping
    • 22.55. Class IndexHelper
    • 22.56. Enum IndexType
    • 22.57. Class PartitionDataModelMapping
    • 22.58. Class ResultDataModelMapping
    • 22.59. Class SessionDataModelMapping
    • 22.60. Class ShardingExt
    • 22.61. Class TaskDataModelMapping
    • 22.62. Class TaskTable
    • 22.63. Class TaskWatcher
    • 22.64. Class WatchEnumerable<TOutput, TInput>
    • 22.65. Class WatchEnumerator<TOutput, TInput>
    • 22.66. Namespace ArmoniK.Core.Adapters.Nats
    • 22.67. Class Heart
    • 22.68. Class QueueBuilder
    • 22.69. Namespace ArmoniK.Core.Adapters.PubSub
    • 22.70. Class Heart
    • 22.71. Class QueueBuilder
    • 22.72. Namespace ArmoniK.Core.Adapters.QueueCommon
    • 22.73. Class Amqp
    • 22.74. Class QueueStorageBase
    • 22.75. Namespace ArmoniK.Core.Adapters.Redis
    • 22.76. Class ObjectBuilder
    • 22.77. Class ObjectStorage
    • 22.78. Namespace ArmoniK.Core.Adapters.Redis.Options
    • 22.79. Class Redis
    • 22.80. Namespace ArmoniK.Core.Adapters.S3
    • 22.81. Class ObjectBuilder
    • 22.82. Class ObjectStorage
    • 22.83. Namespace ArmoniK.Core.Adapters.S3.Options
    • 22.84. Class S3
    • 22.85. Namespace ArmoniK.Core.Adapters.SQS
    • 22.86. Class Heart
    • 22.87. Class QueueBuilder
    • 22.88. Namespace ArmoniK.Core.Base
    • 22.89. Namespace ArmoniK.Core.Base.DataStructures
    • 22.90. Enum HealthCheckTag
    • 22.91. Class MessageData
    • 22.92. Class ObjectData
    • 22.93. Class TaskOptions
    • 22.94. Namespace ArmoniK.Core.Base.Exceptions
    • 22.95. Class ArmoniKException
    • 22.96. Class ObjectDataNotFoundException
    • 22.97. Class QueueInsertionFailedException
    • 22.98. Interface IDependencyInjectionBuildable
    • 22.99. Interface IHealthCheckProvider
    • 22.100. Interface IInitializable
    • 22.101. Interface IObjectStorage
    • 22.102. Interface IPullQueueStorage
    • 22.103. Interface IPushQueueStorage
    • 22.104. Interface IQueueMessageHandler
    • 22.105. Interface IQueueStorage
    • 22.106. Enum QueueMessageStatus
    • 22.107. Namespace ArmoniK.Core.Common
    • 22.108. Namespace ArmoniK.Core.Common.Auth
    • 22.109. Namespace ArmoniK.Core.Common.Auth.Authentication
    • 22.110. Class AuthData
    • 22.111. Class AuthenticationCache
    • 22.112. Class AuthenticationCacheKey
    • 22.113. Class Authenticator
    • 22.114. Class AuthenticatorOptions
    • 22.115. Interface IAuthenticationTable
    • 22.116. Class RoleData
    • 22.117. Class UserAuthenticationResult
    • 22.118. Class UserData
    • 22.119. Class UserIdentity
    • 22.120. Namespace ArmoniK.Core.Common.Auth.Authorization
    • 22.121. Class AuthorizationPolicyProvider
    • 22.122. Class GeneralService
    • 22.123. Class IgnoreAuthenticationAttribute
    • 22.124. Class IgnoreAuthorizationAttribute
    • 22.125. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
    • 22.126. Class Permission
    • 22.127. Class PermissionScope
    • 22.128. Class ServicesPermissions
    • 22.129. Class RequiresPermissionAttribute
    • 22.130. Namespace ArmoniK.Core.Common.Client
    • 22.131. Class GrpcChannelExt
    • 22.132. Class SessionStats
    • 22.133. Namespace ArmoniK.Core.Common.DynamicLoading
    • 22.134. Class CollocatedAssemblyResolver
    • 22.135. Namespace ArmoniK.Core.Common.Exceptions
    • 22.136. Class InvalidSessionTransitionException
    • 22.137. Class PartitionNotFoundException
    • 22.138. Class ResultNotFoundException
    • 22.139. Class SessionNotFoundException
    • 22.140. Class SubmissionClosedException
    • 22.141. Class TaskAlreadyExistsException
    • 22.142. Class TaskAlreadyInFinalStateException
    • 22.143. Class TaskCanceledException
    • 22.144. Class TaskNotFoundException
    • 22.145. Class TaskPausedException
    • 22.146. Class TimeoutException
    • 22.147. Class WorkerDownException
    • 22.148. Class HealthCheckRecord
    • 22.149. Class HealthCheckRecord.Publisher
    • 22.150. Interface IAsyncInitialization<T>
    • 22.151. Namespace ArmoniK.Core.Common.Injection
    • 22.152. Namespace ArmoniK.Core.Common.Injection.Options
    • 22.153. Class AdapterSettings
    • 22.154. Class Components
    • 22.155. Namespace ArmoniK.Core.Common.Injection.Options.Database
    • 22.156. Class Authentication
    • 22.157. Class Certificate
    • 22.158. Class InitDatabase
    • 22.159. Class Partition
    • 22.160. Class Partitioning
    • 22.161. Class Role
    • 22.162. Class User
    • 22.163. Class InitServices
    • 22.164. Class InitWorker
    • 22.165. Class Pollster
    • 22.166. Class Submitter
    • 22.167. Class ServiceCollectionExt
    • 22.168. Namespace ArmoniK.Core.Common.Meter
    • 22.169. Class FunctionExecutionMetrics<TIns>
    • 22.170. Class MeterHolder
    • 22.171. Namespace ArmoniK.Core.Common.Pollster
    • 22.172. Enum AcquisitionStatus
    • 22.173. Class Agent
    • 22.174. Class AgentHandler
    • 22.175. Class AgentIdentifier
    • 22.176. Class DataPrefetcher
    • 22.177. Interface IAgent
    • 22.178. Interface IAgentHandler
    • 22.179. Class Pollster
    • 22.180. Class PostProcessingTaskQueue
    • 22.181. Class PostProcessor
    • 22.182. Class RunningTaskProcessor
    • 22.183. Class RunningTaskQueue
    • 22.184. Class TaskHandler
    • 22.185. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
    • 22.186. Interface ITaskProcessingChecker
    • 22.187. Class TaskProcessingCheckerClient
    • 22.188. Class TaskQueueBase
    • 22.189. Namespace ArmoniK.Core.Common.StateMachines
    • 22.190. Class ProcessReplyCreateLargeTaskStateMachine
    • 22.191. Enum ProcessReplyCreateLargeTaskStateMachine.State
    • 22.192. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
    • 22.193. Namespace ArmoniK.Core.Common.Storage
    • 22.194. Class Application
    • 22.195. Namespace ArmoniK.Core.Common.Storage.Events
    • 22.196. Interface IResultWatcher
    • 22.197. Interface ITaskWatcher
    • 22.198. Class NewResult
    • 22.199. Class NewTask
    • 22.200. Class ResultOwnerUpdate
    • 22.201. Class ResultStatusUpdate
    • 22.202. Class TaskStatusUpdate
    • 22.203. Interface IPartitionTable
    • 22.204. Interface IResultTable
    • 22.205. Class IResultTable.ChangeResultOwnershipRequest
    • 22.206. Interface ISessionTable
    • 22.207. Interface ITaskTable
    • 22.208. Class MaskedProjection
    • 22.209. Class Output
    • 22.210. Enum OutputStatus
    • 22.211. Class PartitionData
    • 22.212. Class PartitionTaskStatusCount
    • 22.213. Class PodConfiguration
    • 22.214. Class QueueMessageHandlerExt
    • 22.215. Class Result
    • 22.216. Class ResultCreationRequest
    • 22.217. Class ResultIdStatus
    • 22.218. Class ResultLifeCycleHelper
    • 22.219. Enum ResultStatus
    • 22.220. Class ResultTableExtensions
    • 22.221. Class SessionData
    • 22.222. Class SessionLifeCycleHelper
    • 22.223. Enum SessionStatus
    • 22.224. Class SessionTableExtensions
    • 22.225. Class TaskCreationRequest
    • 22.226. Class TaskData
    • 22.227. Enum TaskDataFields
    • 22.228. Class TaskDataHolder
    • 22.229. Class TaskDataMask
    • 22.230. Class TaskIdStatus
    • 22.231. Class TaskInfo
    • 22.232. Class TaskLifeCycleHelper
    • 22.233. Enum TaskOptionsFields
    • 22.234. Class TaskOptionsHolder
    • 22.235. Enum TaskStatus
    • 22.236. Class TaskStatusCount
    • 22.237. Class TaskSubmissionRequest
    • 22.238. Class TaskTableExtensions
    • 22.239. Class UpdateDefinition<T>
    • 22.240. Class UpdateDefinition<T>.PropertySet
    • 22.241. Namespace ArmoniK.Core.Common.Stream
    • 22.242. Namespace ArmoniK.Core.Common.Stream.Worker
    • 22.243. Interface IWorkerStreamHandler
    • 22.244. Class WorkerStreamHandler
    • 22.245. Namespace ArmoniK.Core.Common.Utils
    • 22.246. Class ActivityExt
    • 22.247. Class ActivitySourceExt
    • 22.248. Class ExceptionManager
    • 22.249. Class ExceptionManager.Options
    • 22.250. Class ExpressionsBuilders
    • 22.251. Class LocalIpFinder
    • 22.252. Class LoggerInit
    • 22.253. Class RendezvousChannel<T>
    • 22.254. Class ReplaceExpressionVisitor
    • 22.255. Class ReplaceParameterVisitor
    • 22.256. Namespace ArmoniK.Core.Common.gRPC
    • 22.257. Namespace ArmoniK.Core.Common.gRPC.Convertors
    • 22.258. Class OutputExt
    • 22.259. Class ResultExt
    • 22.260. Class ResultStatusExt
    • 22.261. Class SessionDataExt
    • 22.262. Class SessionStatusExt
    • 22.263. Class SessionTableExt
    • 22.264. Class TaskDataHolderExt
    • 22.265. Class TaskOptionsExt
    • 22.266. Class TaskStatusCountExt
    • 22.267. Class TaskStatusExt
    • 22.268. Class TaskTableExt
    • 22.269. Class EnumFieldExt
    • 22.270. Class ExceptionInterceptor
    • 22.271. Class ExpressionBuilders
    • 22.272. Class ExpressionExt
    • 22.273. Class FilterRangeExt
    • 22.274. Class GrpcHealthCheckServiceBase
    • 22.275. Class ListApplicationsRequestExt
    • 22.276. Class ListPartitionsRequestExt
    • 22.277. Class ListResultsRequestExt
    • 22.278. Class ListSessionsRequestExt
    • 22.279. Class ListTasksRequestExt
    • 22.280. Namespace ArmoniK.Core.Common.gRPC.Services
    • 22.281. Class GrpcAgentService
    • 22.282. Class GrpcApplicationsService
    • 22.283. Class GrpcAuthService
    • 22.284. Class GrpcEventsService
    • 22.285. Class GrpcHealthChecksService
    • 22.286. Class GrpcPartitionsService
    • 22.287. Class GrpcResultsService
    • 22.288. Class GrpcSessionsService
    • 22.289. Class GrpcSubmitterExtensions
    • 22.290. Class GrpcSubmitterService
    • 22.291. Class GrpcTasksService
    • 22.292. Class GrpcVersionsService
    • 22.293. Interface ISubmitter
    • 22.294. Class Submitter
    • 22.295. Class TaskRequest
    • 22.296. Class WatchToGrpc
    • 22.297. Class SessionFilterExt
    • 22.298. Class TaskFilterExt
    • 22.299. Namespace ArmoniK.Core.Common.gRPC.Validators
    • 22.300. Class CancelTasksRequestValidator
    • 22.301. Class CreateLargeTaskRequestValidator
    • 22.302. Class CreateSessionRequestValidator
    • 22.303. Class CreateSmallTaskRequestValidator
    • 22.304. Class CreateSmallTaskRequestValidator.TaskRequestValidator
    • 22.305. Class EventSubscriptionRequestValidator
    • 22.306. Class ListApplicationsRequestValidator
    • 22.307. Class ListPartitionsRequestValidator
    • 22.308. Class ListResultsRequestValidator
    • 22.309. Class ListSessionsRequestValidator
    • 22.310. Class ListTasksRequestValidator
    • 22.311. Class SessionFilterValidator
    • 22.312. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
    • 22.313. Class CreateSessionRequestValidator
    • 22.314. Class SubmitTasksRequestValidator
    • 22.315. Class TaskFilterValidator
    • 22.316. Class TaskOptionsValidator
    • 22.317. Namespace ArmoniK.Core.Compute
    • 22.318. Namespace ArmoniK.Core.Compute.PollingAgent
    • 22.319. Class Program
    • 22.320. Class Worker
    • 22.321. Namespace ArmoniK.Core.Control
      • 22.321.1. Namespaces
    • 22.322. Namespace ArmoniK.Core.Control.Metrics
    • 22.323. Class ArmoniKMeter
    • 22.324. Namespace ArmoniK.Core.Control.Metrics.Options
    • 22.325. Class MetricsExporter
    • 22.326. Class Program
    • 22.327. Namespace ArmoniK.Core.Control.PartitionMetrics
    • 22.328. Class ArmoniKMeter
    • 22.329. Namespace ArmoniK.Core.Control.PartitionMetrics.Options
    • 22.330. Class MetricsExporter
    • 22.331. Class Program
    • 22.332. Namespace ArmoniK.Core.Control.Submitter
    • 22.333. Class GrpcHealthCheckService
    • 22.334. Class Program
    • 22.335. Namespace ArmoniK.Core.ProfilingTools
    • 22.336. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
    • 22.337. Class ActivityExt
    • 22.338. Class MongoExporterHelperExtensions
    • 22.339. Class MongoExporterOptions
    • 22.340. Class OpenTelemetryData
    • 22.341. Class OpenTelemetryDataModelMapping
    • 22.342. Namespace ArmoniK.Core.Tests
    • 22.343. Namespace ArmoniK.Core.Tests.Queue
    • 22.344. Class QueueStorageTests
    • 22.345. Namespace ArmoniK.Core.Utils
    • 22.346. Class ByteArrayComparer
    • 22.347. Class CertificateValidator
    • 22.348. Class ConfigurationExt
    • 22.349. Class HealthCheck
    • 22.350. Class HealthCheckResultCombiner
    • 22.351. Class LoggerExt
    • 22.352. Class QueryableExt
    • 22.353. Class ServiceCollectionExt
    • 22.354. Namespace ArmoniK.Samples
    • 22.355. Namespace ArmoniK.Samples.Bench
    • 22.356. Namespace ArmoniK.Samples.Bench.Client
    • 22.357. Class ExecutionStats
    • 22.358. Namespace ArmoniK.Samples.Bench.Client.Options
    • 22.359. Class BenchOptions
    • 22.360. Namespace ArmoniK.Samples.Bench.Server
    • 22.361. Class BenchComputerService
    • 22.362. Namespace ArmoniK.Samples.CrashingWorker
    • 22.363. Namespace ArmoniK.Samples.CrashingWorker.Client
    • 22.364. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
    • 22.365. Class CrashingWorkerOptions
    • 22.366. Namespace ArmoniK.Samples.CrashingWorker.Server
    • 22.367. Class CrashingService
    • 22.368. Namespace ArmoniK.Samples.HtcMock
    • 22.369. Namespace ArmoniK.Samples.HtcMock.Client
    • 22.370. Class GridClient
    • 22.371. Class HtcMockClient
    • 22.372. Namespace ArmoniK.Samples.HtcMock.Client.Options
    • 22.373. Class HtcMock
    • 22.374. Class SessionClient
    • 22.375. Namespace ArmoniK.Samples.HtcMock.Server
    • 22.376. Class SampleComputerService
    • 22.377. Class Program
ArmoniK.Core
  • 22. API reference
  • 22.321. Namespace ArmoniK.Core.Control
  • Edit on GitHub

22.321. Namespace ArmoniK.Core.Control

22.321.1. Namespaces

ArmoniK.Core.Control.Metrics

ArmoniK.Core.Control.PartitionMetrics

ArmoniK.Core.Control.Submitter

Previous Next

© Copyright 2021-2026, ANEO.

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