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

21.319. Namespace ArmoniK.Core.Control

21.319.1. Namespaces

ArmoniK.Core.Control.Metrics

ArmoniK.Core.Control.PartitionMetrics

ArmoniK.Core.Control.Submitter

Previous Next

© Copyright 2021-2025, ANEO.

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