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. Install on Windows 11
  • 9. Project components
  • 10. Initialization
  • 11. Agent cache
  • 12. Tasks
  • 13. Authentication and Authorization
  • 14. Adaptors
  • 15. RabbitMQ Limitations
  • 16. MongoDB client connection problem
  • 17. Using external plugins with ArmoniK.Core
  • 18. TLS Implementation in the ArmoniK Core
  • 19. Partitions
  • 20. Artemis
  • 21. How to use ArmoniK RPCs
  • 22. Tasks Service RPCs actions
  • 23. Results Service RPCs actions
  • 24. Sessions Service RPCs actions
  • 25. Environment variables
  • 26. API reference
    • 26.1. Namespace ArmoniK
    • 26.2. Namespace ArmoniK.Core
      • 26.2.1. Namespaces
    • 26.3. Namespace ArmoniK.Core.Adapters
    • 26.4. Namespace ArmoniK.Core.Adapters.Amqp
    • 26.5. Class ConnectionAmqp
    • 26.6. Interface IConnectionAmqp
    • 26.7. Class PullQueueStorage
    • 26.8. Class PushQueueStorage
    • 26.9. Class QueueBuilder
    • 26.10. Class QueueMessageHandler
    • 26.11. Class QueueStorage
    • 26.12. Namespace ArmoniK.Core.Adapters.Embed
    • 26.13. Class ObjectBuilder
    • 26.14. Class ObjectStorage
    • 26.15. Namespace ArmoniK.Core.Adapters.LocalStorage
    • 26.16. Class ObjectBuilder
    • 26.17. Class ObjectStorage
    • 26.18. Namespace ArmoniK.Core.Adapters.Memory
    • 26.19. Class ObjectStorage
    • 26.20. Class PushQueueStorage
    • 26.21. Class QueueStorage
    • 26.22. Class ResultTable
    • 26.23. Class ServiceCollectionExt
    • 26.24. Class SessionTable
    • 26.25. Class TaskTable
    • 26.26. Namespace ArmoniK.Core.Adapters.MongoDB
    • 26.27. Class AuthenticationTable
    • 26.28. Class ChangeStreamUpdate
    • 26.29. Namespace ArmoniK.Core.Adapters.MongoDB.Common
    • 26.30. Class BaseTable<TData, TModelMapping>
    • 26.31. Interface IMongoDataModelMapping<T>
    • 26.32. Class MongoCollectionProvider<TData, TModelMapping>
    • 26.33. Class SessionProvider
    • 26.34. Namespace ArmoniK.Core.Adapters.MongoDB.Options
    • 26.35. Class MongoDB
    • 26.36. Class TableStorage
    • 26.37. Class PartitionTable
    • 26.38. Class ResultTable
    • 26.39. Class ResultWatcher
    • 26.40. Class ServiceCollectionExt
    • 26.41. Class SessionTable
    • 26.42. Namespace ArmoniK.Core.Adapters.MongoDB.Table
    • 26.43. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
    • 26.44. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
    • 26.45. Class AuthDataAfterLookup
    • 26.46. Class AuthDataModelMapping
    • 26.47. Class MongoAuthResult
    • 26.48. Class RoleDataModelMapping
    • 26.49. Class UserDataAfterLookup
    • 26.50. Class UserDataModelMapping
    • 26.51. Class IndexHelper
    • 26.52. Class PartitionDataModelMapping
    • 26.53. Class ResultDataModelMapping
    • 26.54. Class SessionDataModelMapping
    • 26.55. Class ShardingExt
    • 26.56. Class TaskDataModelMapping
    • 26.57. Class TaskTable
    • 26.58. Class TaskWatcher
    • 26.59. Class WatchEnumerable<TOutput, TInput>
    • 26.60. Class WatchEnumerator<TOutput, TInput>
    • 26.61. Namespace ArmoniK.Core.Adapters.Nats
    • 26.62. Class Heart
    • 26.63. Class QueueBuilder
    • 26.64. Namespace ArmoniK.Core.Adapters.NullStorage
    • 26.65. Class ObjectBuilder
    • 26.66. Class ObjectStorage
    • 26.67. Namespace ArmoniK.Core.Adapters.PubSub
    • 26.68. Class Heart
    • 26.69. Class QueueBuilder
    • 26.70. Namespace ArmoniK.Core.Adapters.QueueCommon
    • 26.71. Class Amqp
    • 26.72. Class QueueStorageBase
    • 26.73. Namespace ArmoniK.Core.Adapters.Redis
    • 26.74. Class ObjectBuilder
    • 26.75. Class ObjectStorage
    • 26.76. Namespace ArmoniK.Core.Adapters.Redis.Options
    • 26.77. Class Redis
    • 26.78. Namespace ArmoniK.Core.Adapters.S3
    • 26.79. Class ObjectBuilder
    • 26.80. Class ObjectStorage
    • 26.81. Namespace ArmoniK.Core.Adapters.S3.Options
    • 26.82. Class S3
    • 26.83. Namespace ArmoniK.Core.Adapters.SQS
    • 26.84. Class Heart
    • 26.85. Class QueueBuilder
    • 26.86. Namespace ArmoniK.Core.Base
    • 26.87. Namespace ArmoniK.Core.Base.DataStructures
    • 26.88. Enum HealthCheckTag
    • 26.89. Class MessageData
    • 26.90. Class ObjectData
    • 26.91. Class TaskOptions
    • 26.92. Namespace ArmoniK.Core.Base.Exceptions
    • 26.93. Class ArmoniKException
    • 26.94. Class ObjectDataNotFoundException
    • 26.95. Class QueueInsertionFailedException
    • 26.96. Interface IDependencyInjectionBuildable
    • 26.97. Interface IHealthCheckProvider
    • 26.98. Interface IInitializable
    • 26.99. Interface IObjectStorage
    • 26.100. Interface IPullQueueStorage
    • 26.101. Interface IPushQueueStorage
    • 26.102. Interface IQueueMessageHandler
    • 26.103. Interface IQueueStorage
    • 26.104. Enum QueueMessageStatus
    • 26.105. Namespace ArmoniK.Core.Common
    • 26.106. Namespace ArmoniK.Core.Common.Auth
    • 26.107. Namespace ArmoniK.Core.Common.Auth.Authentication
    • 26.108. Class AuthData
    • 26.109. Class AuthenticationCache
    • 26.110. Class AuthenticationCacheKey
    • 26.111. Class Authenticator
    • 26.112. Class AuthenticatorOptions
    • 26.113. Interface IAuthenticationTable
    • 26.114. Class RoleData
    • 26.115. Class UserAuthenticationResult
    • 26.116. Class UserData
    • 26.117. Class UserIdentity
    • 26.118. Namespace ArmoniK.Core.Common.Auth.Authorization
    • 26.119. Class AuthorizationPolicyProvider
    • 26.120. Class GeneralService
    • 26.121. Class IgnoreAuthenticationAttribute
    • 26.122. Class IgnoreAuthorizationAttribute
    • 26.123. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
    • 26.124. Class Permission
    • 26.125. Class PermissionScope
    • 26.126. Class ServicesPermissions
    • 26.127. Class RequiresPermissionAttribute
    • 26.128. Namespace ArmoniK.Core.Common.Client
    • 26.129. Class GrpcChannelExt
    • 26.130. Class SessionStats
    • 26.131. Namespace ArmoniK.Core.Common.DynamicLoading
    • 26.132. Class CollocatedAssemblyResolver
    • 26.133. Namespace ArmoniK.Core.Common.Exceptions
    • 26.134. Class InvalidSessionTransitionException
    • 26.135. Class PartitionNotFoundException
    • 26.136. Class ResultNotFoundException
    • 26.137. Class SessionNotFoundException
    • 26.138. Class SubmissionClosedException
    • 26.139. Class TaskAlreadyExistsException
    • 26.140. Class TaskAlreadyInFinalStateException
    • 26.141. Class TaskCanceledException
    • 26.142. Class TaskNotFoundException
    • 26.143. Class TaskPausedException
    • 26.144. Class TimeoutException
    • 26.145. Class WorkerDownException
    • 26.146. Class HealthCheckRecord
    • 26.147. Class HealthCheckRecord.Publisher
    • 26.148. Interface IAsyncInitialization<T>
    • 26.149. Namespace ArmoniK.Core.Common.Injection
    • 26.150. Namespace ArmoniK.Core.Common.Injection.Options
    • 26.151. Class AdapterSettings
    • 26.152. Class Components
    • 26.153. Namespace ArmoniK.Core.Common.Injection.Options.Database
    • 26.154. Class Authentication
    • 26.155. Class Certificate
    • 26.156. Class InitDatabase
    • 26.157. Class Partition
    • 26.158. Class Partitioning
    • 26.159. Class Role
    • 26.160. Class User
    • 26.161. Class InitServices
    • 26.162. Class InitWorker
    • 26.163. Class Pollster
    • 26.164. Class Submitter
    • 26.165. Class ServiceCollectionExt
    • 26.166. Namespace ArmoniK.Core.Common.Meter
    • 26.167. Class FunctionExecutionMetrics<TIns>
    • 26.168. Class MeterHolder
    • 26.169. Namespace ArmoniK.Core.Common.Pollster
    • 26.170. Enum AcquisitionStatus
    • 26.171. Class Agent
    • 26.172. Class AgentHandler
    • 26.173. Class AgentIdentifier
    • 26.174. Class DataPrefetcher
    • 26.175. Interface IAgent
    • 26.176. Interface IAgentHandler
    • 26.177. Class Pollster
    • 26.178. Class PostProcessingTaskQueue
    • 26.179. Class PostProcessor
    • 26.180. Class RunningTaskProcessor
    • 26.181. Class RunningTaskQueue
    • 26.182. Class TaskHandler
    • 26.183. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
    • 26.184. Interface ITaskProcessingChecker
    • 26.185. Class TaskProcessingCheckerClient
    • 26.186. Class TaskQueueBase
    • 26.187. Namespace ArmoniK.Core.Common.StateMachines
    • 26.188. Class ProcessReplyCreateLargeTaskStateMachine
    • 26.189. Enum ProcessReplyCreateLargeTaskStateMachine.State
    • 26.190. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
    • 26.191. Namespace ArmoniK.Core.Common.Storage
    • 26.192. Class Application
    • 26.193. Namespace ArmoniK.Core.Common.Storage.Events
    • 26.194. Interface IResultWatcher
    • 26.195. Interface ITaskWatcher
    • 26.196. Class NewResult
    • 26.197. Class NewTask
    • 26.198. Class ResultOwnerUpdate
    • 26.199. Class ResultStatusUpdate
    • 26.200. Class TaskStatusUpdate
    • 26.201. Interface IPartitionTable
    • 26.202. Interface IResultTable
    • 26.203. Class IResultTable.ChangeResultOwnershipRequest
    • 26.204. Interface ISessionTable
    • 26.205. Interface ITaskTable
    • 26.206. Class MaskedProjection
    • 26.207. Class Output
    • 26.208. Enum OutputStatus
    • 26.209. Class PartitionData
    • 26.210. Class PartitionTaskStatusCount
    • 26.211. Class PodConfiguration
    • 26.212. Class QueueMessageHandlerExt
    • 26.213. Class Result
    • 26.214. Class ResultCreationRequest
    • 26.215. Class ResultIdStatus
    • 26.216. Class ResultLifeCycleHelper
    • 26.217. Enum ResultStatus
    • 26.218. Class ResultTableExtensions
    • 26.219. Class SessionData
    • 26.220. Class SessionLifeCycleHelper
    • 26.221. Enum SessionStatus
    • 26.222. Class SessionTableExtensions
    • 26.223. Class TaskCreationRequest
    • 26.224. Class TaskData
    • 26.225. Enum TaskDataFields
    • 26.226. Class TaskDataHolder
    • 26.227. Class TaskDataMask
    • 26.228. Class TaskIdStatus
    • 26.229. Class TaskInfo
    • 26.230. Class TaskLifeCycleHelper
    • 26.231. Enum TaskOptionsFields
    • 26.232. Class TaskOptionsHolder
    • 26.233. Enum TaskStatus
    • 26.234. Class TaskStatusCount
    • 26.235. Class TaskSubmissionRequest
    • 26.236. Class TaskTableExtensions
    • 26.237. Class UpdateDefinition<T>
    • 26.238. Class UpdateDefinition<T>.PropertySet
    • 26.239. Namespace ArmoniK.Core.Common.Stream
    • 26.240. Namespace ArmoniK.Core.Common.Stream.Worker
    • 26.241. Interface IWorkerStreamHandler
    • 26.242. Class WorkerStreamHandler
    • 26.243. Namespace ArmoniK.Core.Common.Utils
    • 26.244. Class ActivityExt
    • 26.245. Class ActivitySourceExt
    • 26.246. Class ExceptionManager
    • 26.247. Class ExceptionManager.Options
    • 26.248. Class ExpressionsBuilders
    • 26.249. Class FileExt
    • 26.250. Class LocalIpFinder
    • 26.251. Class LoggerInit
    • 26.252. Class RendezvousChannel<T>
    • 26.253. Class ReplaceExpressionVisitor
    • 26.254. Class ReplaceParameterVisitor
    • 26.255. Namespace ArmoniK.Core.Common.gRPC
    • 26.256. Namespace ArmoniK.Core.Common.gRPC.Convertors
    • 26.257. Class OutputExt
    • 26.258. Class ResultExt
    • 26.259. Class ResultStatusExt
    • 26.260. Class SessionDataExt
    • 26.261. Class SessionStatusExt
    • 26.262. Class SessionTableExt
    • 26.263. Class TaskDataHolderExt
    • 26.264. Class TaskOptionsExt
    • 26.265. Class TaskStatusCountExt
    • 26.266. Class TaskStatusExt
    • 26.267. Class TaskTableExt
    • 26.268. Class EnumFieldExt
    • 26.269. Class ExceptionInterceptor
    • 26.270. Class ExpressionBuilders
    • 26.271. Class ExpressionExt
    • 26.272. Class FilterRangeExt
    • 26.273. Class GrpcHealthCheckServiceBase
    • 26.274. Class ListApplicationsRequestExt
    • 26.275. Class ListPartitionsRequestExt
    • 26.276. Class ListResultsRequestExt
    • 26.277. Class ListSessionsRequestExt
    • 26.278. Class ListTasksRequestExt
    • 26.279. Namespace ArmoniK.Core.Common.gRPC.Services
    • 26.280. Class GrpcAgentService
    • 26.281. Class GrpcApplicationsService
    • 26.282. Class GrpcAuthService
    • 26.283. Class GrpcEventsService
    • 26.284. Class GrpcHealthChecksService
    • 26.285. Class GrpcPartitionsService
    • 26.286. Class GrpcResultsService
    • 26.287. Class GrpcSessionsService
    • 26.288. Class GrpcSubmitterExtensions
    • 26.289. Class GrpcSubmitterService
    • 26.290. Class GrpcTasksService
    • 26.291. Class GrpcVersionsService
    • 26.292. Interface ISubmitter
    • 26.293. Class Submitter
    • 26.294. Class TaskRequest
    • 26.295. Class WatchToGrpc
    • 26.296. Class SessionFilterExt
    • 26.297. Class TaskFilterExt
    • 26.298. Namespace ArmoniK.Core.Common.gRPC.Validators
    • 26.299. Class CancelTasksRequestValidator
    • 26.300. Class CreateLargeTaskRequestValidator
    • 26.301. Class CreateSessionRequestValidator
    • 26.302. Class CreateSmallTaskRequestValidator
    • 26.303. Class CreateSmallTaskRequestValidator.TaskRequestValidator
    • 26.304. Class EventSubscriptionRequestValidator
    • 26.305. Class ListApplicationsRequestValidator
    • 26.306. Class ListPartitionsRequestValidator
    • 26.307. Class ListResultsRequestValidator
    • 26.308. Class ListSessionsRequestValidator
    • 26.309. Class ListTasksRequestValidator
    • 26.310. Class SessionFilterValidator
    • 26.311. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
    • 26.312. Class CreateSessionRequestValidator
    • 26.313. Class SubmitTasksRequestValidator
    • 26.314. Class TaskFilterValidator
    • 26.315. Class TaskOptionsValidator
    • 26.316. Namespace ArmoniK.Core.Compute
    • 26.317. Namespace ArmoniK.Core.Compute.PollingAgent
    • 26.318. Class Program
    • 26.319. Class Worker
    • 26.320. Namespace ArmoniK.Core.Control
    • 26.321. Namespace ArmoniK.Core.Control.Metrics
    • 26.322. Class ArmoniKMeter
    • 26.323. Namespace ArmoniK.Core.Control.Metrics.Options
    • 26.324. Class MetricsExporter
    • 26.325. Class Program
    • 26.326. Namespace ArmoniK.Core.Control.Submitter
    • 26.327. Class GrpcHealthCheckService
    • 26.328. Class Program
    • 26.329. Namespace ArmoniK.Core.ProfilingTools
    • 26.330. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
    • 26.331. Class ActivityExt
    • 26.332. Class MongoExporterHelperExtensions
    • 26.333. Class MongoExporterOptions
    • 26.334. Class OpenTelemetryData
    • 26.335. Class OpenTelemetryDataModelMapping
    • 26.336. Namespace ArmoniK.Core.Tests
    • 26.337. Namespace ArmoniK.Core.Tests.Queue
    • 26.338. Class QueueStorageTests
    • 26.339. Namespace ArmoniK.Core.Tests.UploadBench
    • 26.340. Namespace ArmoniK.Core.Tests.UploadBench.Options
    • 26.341. Class UploadBench
    • 26.342. Class UploadBenchClient
    • 26.343. Namespace ArmoniK.Core.Utils
    • 26.344. Class ByteArrayComparer
    • 26.345. Class CertificateValidator
    • 26.346. Class ConfigurationExt
    • 26.347. Class HealthCheck
    • 26.348. Class HealthCheckResultCombiner
    • 26.349. Class LoggerExt
    • 26.350. Class QueryableExt
    • 26.351. Class ServiceCollectionExt
    • 26.352. Namespace ArmoniK.Samples
    • 26.353. Namespace ArmoniK.Samples.Bench
    • 26.354. Namespace ArmoniK.Samples.Bench.Client
    • 26.355. Class ExecutionStats
    • 26.356. Namespace ArmoniK.Samples.Bench.Client.Options
    • 26.357. Class BenchOptions
    • 26.358. Namespace ArmoniK.Samples.Bench.Server
    • 26.359. Class BenchComputerService
    • 26.360. Namespace ArmoniK.Samples.CrashingWorker
    • 26.361. Namespace ArmoniK.Samples.CrashingWorker.Client
    • 26.362. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
    • 26.363. Class CrashingWorkerOptions
    • 26.364. Namespace ArmoniK.Samples.CrashingWorker.Server
    • 26.365. Class CrashingService
    • 26.366. Namespace ArmoniK.Samples.HtcMock
    • 26.367. Namespace ArmoniK.Samples.HtcMock.Client
    • 26.368. Class GridClient
    • 26.369. Class HtcMockClient
    • 26.370. Namespace ArmoniK.Samples.HtcMock.Client.Options
    • 26.371. Class HtcMock
    • 26.372. Class SessionClient
    • 26.373. Namespace ArmoniK.Samples.HtcMock.Server
    • 26.374. Class SampleComputerService
    • 26.375. Class Program
ArmoniK.Core
  • 26. API reference
  • 26.2. Namespace ArmoniK.Core
  • Edit on GitHub

26.2. Namespace ArmoniK.Core

26.2.1. Namespaces

ArmoniK.Core.Adapters

ArmoniK.Core.Base

ArmoniK.Core.Common

ArmoniK.Core.Compute

ArmoniK.Core.Control

ArmoniK.Core.ProfilingTools

ArmoniK.Core.Tests

ArmoniK.Core.Utils

Previous Next

© Copyright 2021-2026, ANEO.

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