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. Tasks
  • 11. Authentication and Authorization
  • 12. Adaptors
  • 13. RabbitMQ Limitations
  • 14. MongoDB client connection problem
  • 15. Using external plugins with ArmoniK.Core
  • 16. TLS Implementation in the ArmoniK Core
  • 17. Artemis
  • 18. How to use ArmoniK RPCs
  • 19. Tasks Service RPCs actions
  • 20. Results Service RPCs actions
  • 21. Sessions Service RPCs actions
  • 22. Environment variables
  • 23. API reference
    • 23.1. Namespace ArmoniK
    • 23.2. Namespace ArmoniK.Core
    • 23.3. Namespace ArmoniK.Core.Adapters
      • 23.3.1. Namespaces
    • 23.4. Namespace ArmoniK.Core.Adapters.Amqp
    • 23.5. Class ConnectionAmqp
    • 23.6. Interface IConnectionAmqp
    • 23.7. Class PullQueueStorage
    • 23.8. Class PushQueueStorage
    • 23.9. Class QueueBuilder
    • 23.10. Class QueueMessageHandler
    • 23.11. Class QueueStorage
    • 23.12. Namespace ArmoniK.Core.Adapters.Embed
    • 23.13. Class ObjectBuilder
    • 23.14. Class ObjectStorage
    • 23.15. Namespace ArmoniK.Core.Adapters.LocalStorage
    • 23.16. Class ObjectBuilder
    • 23.17. Class ObjectStorage
    • 23.18. Namespace ArmoniK.Core.Adapters.Memory
    • 23.19. Class ObjectStorage
    • 23.20. Class PushQueueStorage
    • 23.21. Class QueueStorage
    • 23.22. Class ResultTable
    • 23.23. Class ServiceCollectionExt
    • 23.24. Class SessionTable
    • 23.25. Class TaskTable
    • 23.26. Namespace ArmoniK.Core.Adapters.MongoDB
    • 23.27. Class AuthenticationTable
    • 23.28. Class ChangeStreamUpdate
    • 23.29. Namespace ArmoniK.Core.Adapters.MongoDB.Common
    • 23.30. Class BaseTable<TData, TModelMapping>
    • 23.31. Interface IMongoDataModelMapping<T>
    • 23.32. Class MongoCollectionProvider<TData, TModelMapping>
    • 23.33. Class SessionProvider
    • 23.34. Namespace ArmoniK.Core.Adapters.MongoDB.Options
    • 23.35. Class MongoDB
    • 23.36. Class TableStorage
    • 23.37. Class PartitionTable
    • 23.38. Class ResultTable
    • 23.39. Class ResultWatcher
    • 23.40. Class ServiceCollectionExt
    • 23.41. Class SessionTable
    • 23.42. Namespace ArmoniK.Core.Adapters.MongoDB.Table
    • 23.43. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
    • 23.44. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
    • 23.45. Class AuthDataAfterLookup
    • 23.46. Class AuthDataModelMapping
    • 23.47. Class MongoAuthResult
    • 23.48. Class RoleDataModelMapping
    • 23.49. Class UserDataAfterLookup
    • 23.50. Class UserDataModelMapping
    • 23.51. Class IndexHelper
    • 23.52. Class PartitionDataModelMapping
    • 23.53. Class ResultDataModelMapping
    • 23.54. Class SessionDataModelMapping
    • 23.55. Class ShardingExt
    • 23.56. Class TaskDataModelMapping
    • 23.57. Class TaskTable
    • 23.58. Class TaskWatcher
    • 23.59. Class WatchEnumerable<TOutput, TInput>
    • 23.60. Class WatchEnumerator<TOutput, TInput>
    • 23.61. Namespace ArmoniK.Core.Adapters.Nats
    • 23.62. Class Heart
    • 23.63. Class QueueBuilder
    • 23.64. Namespace ArmoniK.Core.Adapters.NullStorage
    • 23.65. Class ObjectBuilder
    • 23.66. Class ObjectStorage
    • 23.67. Namespace ArmoniK.Core.Adapters.PubSub
    • 23.68. Class Heart
    • 23.69. Class QueueBuilder
    • 23.70. Namespace ArmoniK.Core.Adapters.QueueCommon
    • 23.71. Class Amqp
    • 23.72. Class QueueStorageBase
    • 23.73. Namespace ArmoniK.Core.Adapters.Redis
    • 23.74. Class ObjectBuilder
    • 23.75. Class ObjectStorage
    • 23.76. Namespace ArmoniK.Core.Adapters.Redis.Options
    • 23.77. Class Redis
    • 23.78. Namespace ArmoniK.Core.Adapters.S3
    • 23.79. Class ObjectBuilder
    • 23.80. Class ObjectStorage
    • 23.81. Namespace ArmoniK.Core.Adapters.S3.Options
    • 23.82. Class S3
    • 23.83. Namespace ArmoniK.Core.Adapters.SQS
    • 23.84. Class Heart
    • 23.85. Class QueueBuilder
    • 23.86. Namespace ArmoniK.Core.Base
    • 23.87. Namespace ArmoniK.Core.Base.DataStructures
    • 23.88. Enum HealthCheckTag
    • 23.89. Class MessageData
    • 23.90. Class ObjectData
    • 23.91. Class TaskOptions
    • 23.92. Namespace ArmoniK.Core.Base.Exceptions
    • 23.93. Class ArmoniKException
    • 23.94. Class ObjectDataNotFoundException
    • 23.95. Class QueueInsertionFailedException
    • 23.96. Interface IDependencyInjectionBuildable
    • 23.97. Interface IHealthCheckProvider
    • 23.98. Interface IInitializable
    • 23.99. Interface IObjectStorage
    • 23.100. Interface IPullQueueStorage
    • 23.101. Interface IPushQueueStorage
    • 23.102. Interface IQueueMessageHandler
    • 23.103. Interface IQueueStorage
    • 23.104. Enum QueueMessageStatus
    • 23.105. Namespace ArmoniK.Core.Common
    • 23.106. Namespace ArmoniK.Core.Common.Auth
    • 23.107. Namespace ArmoniK.Core.Common.Auth.Authentication
    • 23.108. Class AuthData
    • 23.109. Class AuthenticationCache
    • 23.110. Class AuthenticationCacheKey
    • 23.111. Class Authenticator
    • 23.112. Class AuthenticatorOptions
    • 23.113. Interface IAuthenticationTable
    • 23.114. Class RoleData
    • 23.115. Class UserAuthenticationResult
    • 23.116. Class UserData
    • 23.117. Class UserIdentity
    • 23.118. Namespace ArmoniK.Core.Common.Auth.Authorization
    • 23.119. Class AuthorizationPolicyProvider
    • 23.120. Class GeneralService
    • 23.121. Class IgnoreAuthenticationAttribute
    • 23.122. Class IgnoreAuthorizationAttribute
    • 23.123. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
    • 23.124. Class Permission
    • 23.125. Class PermissionScope
    • 23.126. Class ServicesPermissions
    • 23.127. Class RequiresPermissionAttribute
    • 23.128. Namespace ArmoniK.Core.Common.Client
    • 23.129. Class GrpcChannelExt
    • 23.130. Class SessionStats
    • 23.131. Namespace ArmoniK.Core.Common.DynamicLoading
    • 23.132. Class CollocatedAssemblyResolver
    • 23.133. Namespace ArmoniK.Core.Common.Exceptions
    • 23.134. Class InvalidSessionTransitionException
    • 23.135. Class PartitionNotFoundException
    • 23.136. Class ResultNotFoundException
    • 23.137. Class SessionNotFoundException
    • 23.138. Class SubmissionClosedException
    • 23.139. Class TaskAlreadyExistsException
    • 23.140. Class TaskAlreadyInFinalStateException
    • 23.141. Class TaskCanceledException
    • 23.142. Class TaskNotFoundException
    • 23.143. Class TaskPausedException
    • 23.144. Class TimeoutException
    • 23.145. Class WorkerDownException
    • 23.146. Class HealthCheckRecord
    • 23.147. Class HealthCheckRecord.Publisher
    • 23.148. Interface IAsyncInitialization<T>
    • 23.149. Namespace ArmoniK.Core.Common.Injection
    • 23.150. Namespace ArmoniK.Core.Common.Injection.Options
    • 23.151. Class AdapterSettings
    • 23.152. Class Components
    • 23.153. Namespace ArmoniK.Core.Common.Injection.Options.Database
    • 23.154. Class Authentication
    • 23.155. Class Certificate
    • 23.156. Class InitDatabase
    • 23.157. Class Partition
    • 23.158. Class Partitioning
    • 23.159. Class Role
    • 23.160. Class User
    • 23.161. Class InitServices
    • 23.162. Class InitWorker
    • 23.163. Class Pollster
    • 23.164. Class Submitter
    • 23.165. Class ServiceCollectionExt
    • 23.166. Namespace ArmoniK.Core.Common.Meter
    • 23.167. Class FunctionExecutionMetrics<TIns>
    • 23.168. Class MeterHolder
    • 23.169. Namespace ArmoniK.Core.Common.Pollster
    • 23.170. Enum AcquisitionStatus
    • 23.171. Class Agent
    • 23.172. Class AgentHandler
    • 23.173. Class AgentIdentifier
    • 23.174. Class DataPrefetcher
    • 23.175. Interface IAgent
    • 23.176. Interface IAgentHandler
    • 23.177. Class Pollster
    • 23.178. Class PostProcessingTaskQueue
    • 23.179. Class PostProcessor
    • 23.180. Class RunningTaskProcessor
    • 23.181. Class RunningTaskQueue
    • 23.182. Class TaskHandler
    • 23.183. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
    • 23.184. Interface ITaskProcessingChecker
    • 23.185. Class TaskProcessingCheckerClient
    • 23.186. Class TaskQueueBase
    • 23.187. Namespace ArmoniK.Core.Common.StateMachines
    • 23.188. Class ProcessReplyCreateLargeTaskStateMachine
    • 23.189. Enum ProcessReplyCreateLargeTaskStateMachine.State
    • 23.190. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
    • 23.191. Namespace ArmoniK.Core.Common.Storage
    • 23.192. Class Application
    • 23.193. Namespace ArmoniK.Core.Common.Storage.Events
    • 23.194. Interface IResultWatcher
    • 23.195. Interface ITaskWatcher
    • 23.196. Class NewResult
    • 23.197. Class NewTask
    • 23.198. Class ResultOwnerUpdate
    • 23.199. Class ResultStatusUpdate
    • 23.200. Class TaskStatusUpdate
    • 23.201. Interface IPartitionTable
    • 23.202. Interface IResultTable
    • 23.203. Class IResultTable.ChangeResultOwnershipRequest
    • 23.204. Interface ISessionTable
    • 23.205. Interface ITaskTable
    • 23.206. Class MaskedProjection
    • 23.207. Class Output
    • 23.208. Enum OutputStatus
    • 23.209. Class PartitionData
    • 23.210. Class PartitionTaskStatusCount
    • 23.211. Class PodConfiguration
    • 23.212. Class QueueMessageHandlerExt
    • 23.213. Class Result
    • 23.214. Class ResultCreationRequest
    • 23.215. Class ResultIdStatus
    • 23.216. Class ResultLifeCycleHelper
    • 23.217. Enum ResultStatus
    • 23.218. Class ResultTableExtensions
    • 23.219. Class SessionData
    • 23.220. Class SessionLifeCycleHelper
    • 23.221. Enum SessionStatus
    • 23.222. Class SessionTableExtensions
    • 23.223. Class TaskCreationRequest
    • 23.224. Class TaskData
    • 23.225. Enum TaskDataFields
    • 23.226. Class TaskDataHolder
    • 23.227. Class TaskDataMask
    • 23.228. Class TaskIdStatus
    • 23.229. Class TaskInfo
    • 23.230. Class TaskLifeCycleHelper
    • 23.231. Enum TaskOptionsFields
    • 23.232. Class TaskOptionsHolder
    • 23.233. Enum TaskStatus
    • 23.234. Class TaskStatusCount
    • 23.235. Class TaskSubmissionRequest
    • 23.236. Class TaskTableExtensions
    • 23.237. Class UpdateDefinition<T>
    • 23.238. Class UpdateDefinition<T>.PropertySet
    • 23.239. Namespace ArmoniK.Core.Common.Stream
    • 23.240. Namespace ArmoniK.Core.Common.Stream.Worker
    • 23.241. Interface IWorkerStreamHandler
    • 23.242. Class WorkerStreamHandler
    • 23.243. Namespace ArmoniK.Core.Common.Utils
    • 23.244. Class ActivityExt
    • 23.245. Class ActivitySourceExt
    • 23.246. Class ExceptionManager
    • 23.247. Class ExceptionManager.Options
    • 23.248. Class ExpressionsBuilders
    • 23.249. Class FileExt
    • 23.250. Class LocalIpFinder
    • 23.251. Class LoggerInit
    • 23.252. Class RendezvousChannel<T>
    • 23.253. Class ReplaceExpressionVisitor
    • 23.254. Class ReplaceParameterVisitor
    • 23.255. Namespace ArmoniK.Core.Common.gRPC
    • 23.256. Namespace ArmoniK.Core.Common.gRPC.Convertors
    • 23.257. Class OutputExt
    • 23.258. Class ResultExt
    • 23.259. Class ResultStatusExt
    • 23.260. Class SessionDataExt
    • 23.261. Class SessionStatusExt
    • 23.262. Class SessionTableExt
    • 23.263. Class TaskDataHolderExt
    • 23.264. Class TaskOptionsExt
    • 23.265. Class TaskStatusCountExt
    • 23.266. Class TaskStatusExt
    • 23.267. Class TaskTableExt
    • 23.268. Class EnumFieldExt
    • 23.269. Class ExceptionInterceptor
    • 23.270. Class ExpressionBuilders
    • 23.271. Class ExpressionExt
    • 23.272. Class FilterRangeExt
    • 23.273. Class GrpcHealthCheckServiceBase
    • 23.274. Class ListApplicationsRequestExt
    • 23.275. Class ListPartitionsRequestExt
    • 23.276. Class ListResultsRequestExt
    • 23.277. Class ListSessionsRequestExt
    • 23.278. Class ListTasksRequestExt
    • 23.279. Namespace ArmoniK.Core.Common.gRPC.Services
    • 23.280. Class GrpcAgentService
    • 23.281. Class GrpcApplicationsService
    • 23.282. Class GrpcAuthService
    • 23.283. Class GrpcEventsService
    • 23.284. Class GrpcHealthChecksService
    • 23.285. Class GrpcPartitionsService
    • 23.286. Class GrpcResultsService
    • 23.287. Class GrpcSessionsService
    • 23.288. Class GrpcSubmitterExtensions
    • 23.289. Class GrpcSubmitterService
    • 23.290. Class GrpcTasksService
    • 23.291. Class GrpcVersionsService
    • 23.292. Interface ISubmitter
    • 23.293. Class Submitter
    • 23.294. Class TaskRequest
    • 23.295. Class WatchToGrpc
    • 23.296. Class SessionFilterExt
    • 23.297. Class TaskFilterExt
    • 23.298. Namespace ArmoniK.Core.Common.gRPC.Validators
    • 23.299. Class CancelTasksRequestValidator
    • 23.300. Class CreateLargeTaskRequestValidator
    • 23.301. Class CreateSessionRequestValidator
    • 23.302. Class CreateSmallTaskRequestValidator
    • 23.303. Class CreateSmallTaskRequestValidator.TaskRequestValidator
    • 23.304. Class EventSubscriptionRequestValidator
    • 23.305. Class ListApplicationsRequestValidator
    • 23.306. Class ListPartitionsRequestValidator
    • 23.307. Class ListResultsRequestValidator
    • 23.308. Class ListSessionsRequestValidator
    • 23.309. Class ListTasksRequestValidator
    • 23.310. Class SessionFilterValidator
    • 23.311. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
    • 23.312. Class CreateSessionRequestValidator
    • 23.313. Class SubmitTasksRequestValidator
    • 23.314. Class TaskFilterValidator
    • 23.315. Class TaskOptionsValidator
    • 23.316. Namespace ArmoniK.Core.Compute
    • 23.317. Namespace ArmoniK.Core.Compute.PollingAgent
    • 23.318. Class Program
    • 23.319. Class Worker
    • 23.320. Namespace ArmoniK.Core.Control
    • 23.321. Namespace ArmoniK.Core.Control.Metrics
    • 23.322. Class ArmoniKMeter
    • 23.323. Namespace ArmoniK.Core.Control.Metrics.Options
    • 23.324. Class MetricsExporter
    • 23.325. Class Program
    • 23.326. Namespace ArmoniK.Core.Control.Submitter
    • 23.327. Class GrpcHealthCheckService
    • 23.328. Class Program
    • 23.329. Namespace ArmoniK.Core.ProfilingTools
    • 23.330. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
    • 23.331. Class ActivityExt
    • 23.332. Class MongoExporterHelperExtensions
    • 23.333. Class MongoExporterOptions
    • 23.334. Class OpenTelemetryData
    • 23.335. Class OpenTelemetryDataModelMapping
    • 23.336. Namespace ArmoniK.Core.Tests
    • 23.337. Namespace ArmoniK.Core.Tests.Queue
    • 23.338. Class QueueStorageTests
    • 23.339. Namespace ArmoniK.Core.Tests.UploadBench
    • 23.340. Namespace ArmoniK.Core.Tests.UploadBench.Options
    • 23.341. Class UploadBench
    • 23.342. Class UploadBenchClient
    • 23.343. Namespace ArmoniK.Core.Utils
    • 23.344. Class ByteArrayComparer
    • 23.345. Class CertificateValidator
    • 23.346. Class ConfigurationExt
    • 23.347. Class HealthCheck
    • 23.348. Class HealthCheckResultCombiner
    • 23.349. Class LoggerExt
    • 23.350. Class QueryableExt
    • 23.351. Class ServiceCollectionExt
    • 23.352. Namespace ArmoniK.Samples
    • 23.353. Namespace ArmoniK.Samples.Bench
    • 23.354. Namespace ArmoniK.Samples.Bench.Client
    • 23.355. Class ExecutionStats
    • 23.356. Namespace ArmoniK.Samples.Bench.Client.Options
    • 23.357. Class BenchOptions
    • 23.358. Namespace ArmoniK.Samples.Bench.Server
    • 23.359. Class BenchComputerService
    • 23.360. Namespace ArmoniK.Samples.CrashingWorker
    • 23.361. Namespace ArmoniK.Samples.CrashingWorker.Client
    • 23.362. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
    • 23.363. Class CrashingWorkerOptions
    • 23.364. Namespace ArmoniK.Samples.CrashingWorker.Server
    • 23.365. Class CrashingService
    • 23.366. Namespace ArmoniK.Samples.HtcMock
    • 23.367. Namespace ArmoniK.Samples.HtcMock.Client
    • 23.368. Class GridClient
    • 23.369. Class HtcMockClient
    • 23.370. Namespace ArmoniK.Samples.HtcMock.Client.Options
    • 23.371. Class HtcMock
    • 23.372. Class SessionClient
    • 23.373. Namespace ArmoniK.Samples.HtcMock.Server
    • 23.374. Class SampleComputerService
    • 23.375. Class Program
ArmoniK.Core
  • 23. API reference
  • 23.3. Namespace ArmoniK.Core.Adapters
  • Edit on GitHub

23.3. Namespace ArmoniK.Core.Adapters

23.3.1. Namespaces

ArmoniK.Core.Adapters.Amqp

ArmoniK.Core.Adapters.Embed

ArmoniK.Core.Adapters.LocalStorage

ArmoniK.Core.Adapters.Memory

ArmoniK.Core.Adapters.MongoDB

ArmoniK.Core.Adapters.Nats

ArmoniK.Core.Adapters.NullStorage

ArmoniK.Core.Adapters.PubSub

ArmoniK.Core.Adapters.QueueCommon

ArmoniK.Core.Adapters.Redis

ArmoniK.Core.Adapters.S3

ArmoniK.Core.Adapters.SQS

Previous Next

© Copyright 2021-2026, ANEO.

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