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 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. API reference
    • 17.1. Namespace ArmoniK
    • 17.2. Namespace ArmoniK.Api
    • 17.3. Namespace ArmoniK.Api.gRPC
    • 17.4. Namespace ArmoniK.Api.gRPC.V1
    • 17.5. Class PayloadConfiguration
    • 17.6. Namespace ArmoniK.Core
    • 17.7. Namespace ArmoniK.Core.Adapters
    • 17.8. Namespace ArmoniK.Core.Adapters.Amqp
    • 17.9. Class ConnectionAmqp
    • 17.10. Interface IConnectionAmqp
    • 17.11. Class PullQueueStorage
    • 17.12. Class PushQueueStorage
    • 17.13. Class QueueBuilder
    • 17.14. Class QueueMessageHandler
    • 17.15. Class QueueStorage
    • 17.16. Namespace ArmoniK.Core.Adapters.Embed
    • 17.17. Class ObjectBuilder
    • 17.18. Class ObjectStorage
    • 17.19. Namespace ArmoniK.Core.Adapters.LocalStorage
    • 17.20. Class ObjectBuilder
    • 17.21. Class ObjectStorage
    • 17.22. Namespace ArmoniK.Core.Adapters.Memory
    • 17.23. Class ObjectStorage
    • 17.24. Class PushQueueStorage
    • 17.25. Class QueueStorage
    • 17.26. Class ResultTable
    • 17.27. Class ServiceCollectionExt
    • 17.28. Class SessionTable
    • 17.29. Class TaskTable
    • 17.30. Namespace ArmoniK.Core.Adapters.MongoDB
    • 17.31. Class AuthenticationTable
    • 17.32. Class ChangeStreamUpdate
    • 17.33. Namespace ArmoniK.Core.Adapters.MongoDB.Common
    • 17.34. Interface IMongoDataModelMapping<T>
    • 17.35. Class MongoCollectionProvider<TData, TModelMapping>
    • 17.36. Class SessionProvider
    • 17.37. Namespace ArmoniK.Core.Adapters.MongoDB.Options
    • 17.38. Class MongoDB
    • 17.39. Class TableStorage
    • 17.40. Class PartitionTable
    • 17.41. Class ResultTable
    • 17.42. Class ResultWatcher
    • 17.43. Class ServiceCollectionExt
    • 17.44. Class SessionTable
    • 17.45. Namespace ArmoniK.Core.Adapters.MongoDB.Table
    • 17.46. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
    • 17.47. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
    • 17.48. Class AuthDataAfterLookup
    • 17.49. Class AuthDataModelMapping
    • 17.50. Class AuthMongoUtils
    • 17.51. Class IdArraySerializer
    • 17.52. Class IdSerializer
    • 17.53. Class MongoAuthResult
    • 17.54. Class RoleDataModelMapping
    • 17.55. Class UserDataAfterLookup
    • 17.56. Class UserDataModelMapping
    • 17.57. Class IndexHelper
    • 17.58. Enum IndexType
    • 17.59. Class PartitionDataModelMapping
    • 17.60. Class ResultDataModelMapping
    • 17.61. Class SessionDataModelMapping
    • 17.62. Class ShardingExt
    • 17.63. Class TaskDataModelMapping
    • 17.64. Class TaskTable
    • 17.65. Class TaskWatcher
    • 17.66. Class WatchEnumerable<TOutput, TInput>
    • 17.67. Class WatchEnumerator<TOutput, TInput>
    • 17.68. Namespace ArmoniK.Core.Adapters.PubSub
    • 17.69. Class Heart
    • 17.70. Class QueueBuilder
    • 17.71. Namespace ArmoniK.Core.Adapters.QueueCommon
    • 17.72. Class Amqp
    • 17.73. Class QueueStorageBase
    • 17.74. Namespace ArmoniK.Core.Adapters.RabbitMQ
    • 17.75. Class ConnectionRabbit
    • 17.76. Interface IConnectionRabbit
    • 17.77. Class PullQueueStorage
    • 17.78. Class PushQueueStorage
    • 17.79. Class QueueBuilder
    • 17.80. Class QueueMessageHandler
    • 17.81. Class QueueStorage
    • 17.82. Namespace ArmoniK.Core.Adapters.Redis
    • 17.83. Class ObjectBuilder
    • 17.84. Class ObjectStorage
    • 17.85. Namespace ArmoniK.Core.Adapters.Redis.Options
    • 17.86. Class Redis
    • 17.87. Namespace ArmoniK.Core.Adapters.S3
    • 17.88. Class ObjectBuilder
    • 17.89. Class ObjectStorage
    • 17.90. Namespace ArmoniK.Core.Adapters.S3.Options
    • 17.91. Class S3
    • 17.92. Namespace ArmoniK.Core.Adapters.SQS
    • 17.93. Class Heart
    • 17.94. Class QueueBuilder
    • 17.95. Namespace ArmoniK.Core.Base
    • 17.96. Namespace ArmoniK.Core.Base.DataStructures
    • 17.97. Enum HealthCheckTag
    • 17.98. Class MessageData
    • 17.99. Class ObjectData
    • 17.100. Class TaskOptions
    • 17.101. Namespace ArmoniK.Core.Base.Exceptions
    • 17.102. Class ArmoniKException
    • 17.103. Class ObjectDataNotFoundException
    • 17.104. Interface IDependencyInjectionBuildable
    • 17.105. Interface IHealthCheckProvider
    • 17.106. Interface IInitializable
    • 17.107. Interface IObjectStorage
    • 17.108. Interface IPullQueueStorage
    • 17.109. Interface IPushQueueStorage
    • 17.110. Interface IQueueMessageHandler
    • 17.111. Interface IQueueStorage
    • 17.112. Enum QueueMessageStatus
    • 17.113. Namespace ArmoniK.Core.Common
    • 17.114. Namespace ArmoniK.Core.Common.Auth
    • 17.115. Namespace ArmoniK.Core.Common.Auth.Authentication
    • 17.116. Class AuthData
    • 17.117. Class AuthenticationCache
    • 17.118. Class AuthenticationCacheKey
    • 17.119. Class Authenticator
    • 17.120. Class AuthenticatorOptions
    • 17.121. Interface IAuthenticationTable
    • 17.122. Class RoleData
    • 17.123. Class UserAuthenticationResult
    • 17.124. Class UserData
    • 17.125. Class UserIdentity
    • 17.126. Namespace ArmoniK.Core.Common.Auth.Authorization
    • 17.127. Class AuthorizationPolicyProvider
    • 17.128. Class GeneralService
    • 17.129. Class IgnoreAuthenticationAttribute
    • 17.130. Class IgnoreAuthorizationAttribute
    • 17.131. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
    • 17.132. Class Permission
    • 17.133. Class PermissionScope
    • 17.134. Class ServicesPermissions
    • 17.135. Class RequiresPermissionAttribute
    • 17.136. Namespace ArmoniK.Core.Common.Client
    • 17.137. Class GrpcChannelExt
    • 17.138. Class SessionStats
    • 17.139. Namespace ArmoniK.Core.Common.DynamicLoading
    • 17.140. Class CollocatedAssemblyResolver
    • 17.141. Namespace ArmoniK.Core.Common.Exceptions
      • 17.141.1. Classes
    • 17.142. Class InvalidSessionTransitionException
    • 17.143. Class PartitionNotFoundException
    • 17.144. Class ResultNotFoundException
    • 17.145. Class SessionNotFoundException
    • 17.146. Class SubmissionClosedException
    • 17.147. Class TaskAlreadyExistsException
    • 17.148. Class TaskAlreadyInFinalStateException
    • 17.149. Class TaskCanceledException
    • 17.150. Class TaskNotFoundException
    • 17.151. Class TaskPausedException
    • 17.152. Class TimeoutException
    • 17.153. Interface IAsyncInitialization<T>
    • 17.154. Namespace ArmoniK.Core.Common.Injection
    • 17.155. Namespace ArmoniK.Core.Common.Injection.Options
    • 17.156. Class AdapterSettings
    • 17.157. Class Components
    • 17.158. Class InitWorker
    • 17.159. Class Pollster
    • 17.160. Class Submitter
    • 17.161. Class ServiceCollectionExt
    • 17.162. Namespace ArmoniK.Core.Common.Meter
    • 17.163. Class FunctionExecutionMetrics<TIns>
    • 17.164. Class MeterHolder
    • 17.165. Namespace ArmoniK.Core.Common.Pollster
    • 17.166. Enum AcquisitionStatus
    • 17.167. Class Agent
    • 17.168. Class AgentHandler
    • 17.169. Class AgentIdentifier
    • 17.170. Class DataPrefetcher
    • 17.171. Interface IAgent
    • 17.172. Interface IAgentHandler
    • 17.173. Class Pollster
    • 17.174. Class PostProcessingTaskQueue
    • 17.175. Class PostProcessor
    • 17.176. Class RunningTaskProcessor
    • 17.177. Class RunningTaskQueue
    • 17.178. Class TaskHandler
    • 17.179. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
    • 17.180. Interface ITaskProcessingChecker
    • 17.181. Class TaskProcessingCheckerClient
    • 17.182. Class TaskQueueBase
    • 17.183. Namespace ArmoniK.Core.Common.StateMachines
    • 17.184. Class ProcessReplyCreateLargeTaskStateMachine
    • 17.185. Enum ProcessReplyCreateLargeTaskStateMachine.State
    • 17.186. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
    • 17.187. Namespace ArmoniK.Core.Common.Storage
    • 17.188. Class Application
    • 17.189. Namespace ArmoniK.Core.Common.Storage.Events
    • 17.190. Interface IResultWatcher
    • 17.191. Interface ITaskWatcher
    • 17.192. Class NewResult
    • 17.193. Class NewTask
    • 17.194. Class ResultOwnerUpdate
    • 17.195. Class ResultStatusUpdate
    • 17.196. Class TaskStatusUpdate
    • 17.197. Interface IPartitionTable
    • 17.198. Interface IResultTable
    • 17.199. Class IResultTable.ChangeResultOwnershipRequest
    • 17.200. Interface ISessionTable
    • 17.201. Interface ITaskTable
    • 17.202. Class MaskedProjection
    • 17.203. Class Output
    • 17.204. Enum OutputStatus
    • 17.205. Class PartitionData
    • 17.206. Class PartitionTaskStatusCount
    • 17.207. Class PodConfiguration
    • 17.208. Class QueueMessageHandlerExt
    • 17.209. Class Result
    • 17.210. Class ResultCreationRequest
    • 17.211. Class ResultIdStatus
    • 17.212. Class ResultLifeCycleHelper
    • 17.213. Enum ResultStatus
    • 17.214. Class ResultStatusCount
    • 17.215. Class ResultTableExtensions
    • 17.216. Class SessionData
    • 17.217. Class SessionLifeCycleHelper
    • 17.218. Enum SessionStatus
    • 17.219. Class SessionTableExtensions
    • 17.220. Class StatusTime
    • 17.221. Class TaskCreationRequest
    • 17.222. Class TaskData
    • 17.223. Enum TaskDataFields
    • 17.224. Class TaskDataHolder
    • 17.225. Class TaskDataMask
    • 17.226. Class TaskIdStatus
    • 17.227. Class TaskInfo
    • 17.228. Class TaskLifeCycleHelper
    • 17.229. Enum TaskOptionsFields
    • 17.230. Class TaskOptionsHolder
    • 17.231. Enum TaskStatus
    • 17.232. Class TaskStatusCount
    • 17.233. Class TaskSubmissionRequest
    • 17.234. Class TaskTableExtensions
    • 17.235. Class UpdateDefinition<T>
    • 17.236. Class UpdateDefinition<T>.PropertySet
    • 17.237. Namespace ArmoniK.Core.Common.Stream
    • 17.238. Namespace ArmoniK.Core.Common.Stream.Worker
    • 17.239. Interface IWorkerStreamHandler
    • 17.240. Class WorkerStreamHandler
    • 17.241. Namespace ArmoniK.Core.Common.Utils
    • 17.242. Class ActivityExt
    • 17.243. Class ActivitySourceExt
    • 17.244. Class ExceptionManager
    • 17.245. Class ExceptionManager.Options
    • 17.246. Class ExpressionsBuilders
    • 17.247. Class LocalIpFinder
    • 17.248. Class LoggerInit
    • 17.249. Class RendezvousChannel<T>
    • 17.250. Class ReplaceExpressionVisitor
    • 17.251. Class ReplaceParameterVisitor
    • 17.252. Namespace ArmoniK.Core.Common.gRPC
    • 17.253. Namespace ArmoniK.Core.Common.gRPC.Convertors
    • 17.254. Class OutputExt
    • 17.255. Class ResultExt
    • 17.256. Class ResultStatusExt
    • 17.257. Class SessionDataExt
    • 17.258. Class SessionStatusExt
    • 17.259. Class SessionTableExt
    • 17.260. Class TaskDataHolderExt
    • 17.261. Class TaskOptionsExt
    • 17.262. Class TaskStatusCountExt
    • 17.263. Class TaskStatusExt
    • 17.264. Class TaskTableExt
    • 17.265. Class EnumFieldExt
    • 17.266. Class ExceptionInterceptor
    • 17.267. Class ExpressionBuilders
    • 17.268. Class ExpressionExt
    • 17.269. Class FilterRangeExt
    • 17.270. Class GrpcHealthCheckServiceBase
    • 17.271. Class ListApplicationsRequestExt
    • 17.272. Class ListPartitionsRequestExt
    • 17.273. Class ListResultsRequestExt
    • 17.274. Class ListSessionsRequestExt
    • 17.275. Class ListTasksRequestExt
    • 17.276. Class RpcExt
    • 17.277. Namespace ArmoniK.Core.Common.gRPC.Services
    • 17.278. Class GrpcAgentService
    • 17.279. Class GrpcApplicationsService
    • 17.280. Class GrpcAuthService
    • 17.281. Class GrpcEventsService
    • 17.282. Class GrpcHealthChecksService
    • 17.283. Class GrpcPartitionsService
    • 17.284. Class GrpcResultsService
    • 17.285. Class GrpcSessionsService
    • 17.286. Class GrpcSubmitterExtensions
    • 17.287. Class GrpcSubmitterService
    • 17.288. Class GrpcTasksService
    • 17.289. Class GrpcVersionsService
    • 17.290. Interface ISubmitter
    • 17.291. Class Submitter
    • 17.292. Class TaskRequest
    • 17.293. Class WatchToGrpc
    • 17.294. Class SessionFilterExt
    • 17.295. Class TaskFilterExt
    • 17.296. Namespace ArmoniK.Core.Common.gRPC.Validators
    • 17.297. Class CancelTasksRequestValidator
    • 17.298. Class CreateLargeTaskRequestValidator
    • 17.299. Class CreateSessionRequestValidator
    • 17.300. Class CreateSmallTaskRequestValidator
    • 17.301. Class CreateSmallTaskRequestValidator.TaskRequestValidator
    • 17.302. Class EventSubscriptionRequestValidator
    • 17.303. Class ListApplicationsRequestValidator
    • 17.304. Class ListPartitionsRequestValidator
    • 17.305. Class ListResultsRequestValidator
    • 17.306. Class ListSessionsRequestValidator
    • 17.307. Class ListTasksRequestValidator
    • 17.308. Class SessionFilterValidator
    • 17.309. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
    • 17.310. Class CreateSessionRequestValidator
    • 17.311. Class SubmitTasksRequestValidator
    • 17.312. Class TaskFilterValidator
    • 17.313. Class TaskOptionsValidator
    • 17.314. Namespace ArmoniK.Core.Compute
    • 17.315. Namespace ArmoniK.Core.Compute.PollingAgent
    • 17.316. Class Program
    • 17.317. Class Worker
    • 17.318. Namespace ArmoniK.Core.Control
    • 17.319. Namespace ArmoniK.Core.Control.Metrics
    • 17.320. Class ArmoniKMeter
    • 17.321. Namespace ArmoniK.Core.Control.Metrics.Options
    • 17.322. Class MetricsExporter
    • 17.323. Class Program
    • 17.324. Namespace ArmoniK.Core.Control.PartitionMetrics
    • 17.325. Class ArmoniKMeter
    • 17.326. Namespace ArmoniK.Core.Control.PartitionMetrics.Options
    • 17.327. Class MetricsExporter
    • 17.328. Class Program
    • 17.329. Namespace ArmoniK.Core.Control.Submitter
    • 17.330. Class GrpcHealthCheckService
    • 17.331. Class Program
    • 17.332. Namespace ArmoniK.Core.ProfilingTools
    • 17.333. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
    • 17.334. Class ActivityExt
    • 17.335. Class MongoExporterHelperExtensions
    • 17.336. Class MongoExporterOptions
    • 17.337. Class OpenTelemetryData
    • 17.338. Class OpenTelemetryDataModelMapping
    • 17.339. Namespace ArmoniK.Core.Tests
    • 17.340. Namespace ArmoniK.Core.Tests.Queue
    • 17.341. Class QueueStorageTests
    • 17.342. Namespace ArmoniK.Core.Utils
    • 17.343. Class CertificateValidator
    • 17.344. Class ConfigurationExt
    • 17.345. Class HealthCheck
    • 17.346. Class HealthCheckResultCombiner
    • 17.347. Class LoggerExt
    • 17.348. Class QueryableExt
    • 17.349. Class ServiceCollectionExt
    • 17.350. Namespace ArmoniK.Samples
    • 17.351. Namespace ArmoniK.Samples.Bench
    • 17.352. Namespace ArmoniK.Samples.Bench.Client
    • 17.353. Class ExecutionStats
    • 17.354. Namespace ArmoniK.Samples.Bench.Client.Options
    • 17.355. Class BenchOptions
    • 17.356. Namespace ArmoniK.Samples.Bench.Server
    • 17.357. Class BenchComputerService
    • 17.358. Namespace ArmoniK.Samples.CrashingWorker
    • 17.359. Namespace ArmoniK.Samples.CrashingWorker.Client
    • 17.360. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
    • 17.361. Class CrashingWorkerOptions
    • 17.362. Namespace ArmoniK.Samples.CrashingWorker.Server
    • 17.363. Class CrashingService
    • 17.364. Namespace ArmoniK.Samples.HtcMock
    • 17.365. Namespace ArmoniK.Samples.HtcMock.Client
    • 17.366. Class GridClient
    • 17.367. Class HtcMockClient
    • 17.368. Namespace ArmoniK.Samples.HtcMock.Client.Options
    • 17.369. Class HtcMock
    • 17.370. Class SessionClient
    • 17.371. Namespace ArmoniK.Samples.HtcMock.Server
    • 17.372. Class SampleComputerService
ArmoniK.Core
  • 17. API reference
  • 17.141. Namespace ArmoniK.Core.Common.Exceptions
  • Edit on GitHub

17.141. Namespace ArmoniK.Core.Common.Exceptions

17.141.1. Classes

InvalidSessionTransitionException

PartitionNotFoundException

ResultNotFoundException

SessionNotFoundException

SubmissionClosedException

TaskAlreadyExistsException

TaskAlreadyInFinalStateException

TaskCanceledException

TaskNotFoundException

TaskPausedException

TimeoutException

Previous Next

© Copyright 2021-2025, ANEO.

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