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. 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. Interface IAsyncInitialization<T>
21.155. Namespace ArmoniK.Core.Common.Injection
21.156. Namespace ArmoniK.Core.Common.Injection.Options
21.157. Class AdapterSettings
21.158. Class Components
21.159. Class InitWorker
21.160. Class Pollster
21.161. Class Submitter
21.162. Class ServiceCollectionExt
21.163. Namespace ArmoniK.Core.Common.Meter
21.164. Class FunctionExecutionMetrics<TIns>
21.165. Class MeterHolder
21.166. Namespace ArmoniK.Core.Common.Pollster
21.167. Enum AcquisitionStatus
21.168. Class Agent
21.169. Class AgentHandler
21.170. Class AgentIdentifier
21.171. Class DataPrefetcher
21.172. Interface IAgent
21.173. Interface IAgentHandler
21.174. Class Pollster
21.175. Class PostProcessingTaskQueue
21.176. Class PostProcessor
21.177. Class RunningTaskProcessor
21.178. Class RunningTaskQueue
21.179. Class TaskHandler
21.180. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
21.181. Interface ITaskProcessingChecker
21.182. Class TaskProcessingCheckerClient
21.183. Class TaskQueueBase
21.184. Namespace ArmoniK.Core.Common.StateMachines
21.185. Class ProcessReplyCreateLargeTaskStateMachine
21.186. Enum ProcessReplyCreateLargeTaskStateMachine.State
21.187. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
21.188. Namespace ArmoniK.Core.Common.Storage
21.189. Class Application
21.190. Namespace ArmoniK.Core.Common.Storage.Events
21.191. Interface IResultWatcher
21.192. Interface ITaskWatcher
21.193. Class NewResult
21.194. Class NewTask
21.195. Class ResultOwnerUpdate
21.196. Class ResultStatusUpdate
21.197. Class TaskStatusUpdate
21.198. Interface IPartitionTable
21.199. Interface IResultTable
21.200. Class IResultTable.ChangeResultOwnershipRequest
21.201. Interface ISessionTable
21.202. Interface ITaskTable
21.203. Class MaskedProjection
21.204. Class Output
21.205. Enum OutputStatus
21.206. Class PartitionData
21.207. Class PartitionTaskStatusCount
21.208. Class PodConfiguration
21.209. Class QueueMessageHandlerExt
21.210. Class Result
21.211. Class ResultCreationRequest
21.212. Class ResultIdStatus
21.213. Class ResultLifeCycleHelper
21.214. Enum ResultStatus
21.215. Class ResultStatusCount
21.216. Class ResultTableExtensions
21.217. Class SessionData
21.218. Class SessionLifeCycleHelper
21.219. Enum SessionStatus
21.220. Class SessionTableExtensions
21.221. Class TaskCreationRequest
21.222. Class TaskData
21.223. Enum TaskDataFields
21.224. Class TaskDataHolder
21.225. Class TaskDataMask
21.226. Class TaskIdStatus
21.227. Class TaskInfo
21.228. Class TaskLifeCycleHelper
21.229. Enum TaskOptionsFields
21.230. Class TaskOptionsHolder
21.231. Enum TaskStatus
21.232. Class TaskStatusCount
21.233. Class TaskSubmissionRequest
21.234. Class TaskTableExtensions
21.235. Class UpdateDefinition<T>
21.236. Class UpdateDefinition<T>.PropertySet
21.237. Namespace ArmoniK.Core.Common.Stream
21.238. Namespace ArmoniK.Core.Common.Stream.Worker
21.239. Interface IWorkerStreamHandler
21.240. Class WorkerStreamHandler
21.241. Namespace ArmoniK.Core.Common.Utils
21.242. Class ActivityExt
21.243. Class ActivitySourceExt
21.244. Class ExceptionManager
21.245. Class ExceptionManager.Options
21.246. Class ExpressionsBuilders
21.247. Class LocalIpFinder
21.248. Class LoggerInit
21.249. Class RendezvousChannel<T>
21.250. Class ReplaceExpressionVisitor
21.251. Class ReplaceParameterVisitor
21.252. Namespace ArmoniK.Core.Common.gRPC
21.253. Namespace ArmoniK.Core.Common.gRPC.Convertors
21.254. Class OutputExt
21.255. Class ResultExt
21.256. Class ResultStatusExt
21.257. Class SessionDataExt
21.258. Class SessionStatusExt
21.259. Class SessionTableExt
21.260. Class TaskDataHolderExt
21.261. Class TaskOptionsExt
21.262. Class TaskStatusCountExt
21.263. Class TaskStatusExt
21.264. Class TaskTableExt
21.265. Class EnumFieldExt
21.266. Class ExceptionInterceptor
21.267. Class ExpressionBuilders
21.268. Class ExpressionExt
21.269. Class FilterRangeExt
21.270. Class GrpcHealthCheckServiceBase
21.271. Class ListApplicationsRequestExt
21.272. Class ListPartitionsRequestExt
21.273. Class ListResultsRequestExt
21.274. Class ListSessionsRequestExt
21.275. Class ListTasksRequestExt
21.276. Class RpcExt
21.277. Namespace ArmoniK.Core.Common.gRPC.Services
21.278. Class GrpcAgentService
21.279. Class GrpcApplicationsService
21.280. Class GrpcAuthService
21.281. Class GrpcEventsService
21.282. Class GrpcHealthChecksService
21.283. Class GrpcPartitionsService
21.284. Class GrpcResultsService
21.285. Class GrpcSessionsService
21.286. Class GrpcSubmitterExtensions
21.287. Class GrpcSubmitterService
21.288. Class GrpcTasksService
21.289. Class GrpcVersionsService
21.290. Interface ISubmitter
21.291. Class Submitter
21.292. Class TaskRequest
21.293. Class WatchToGrpc
21.294. Class SessionFilterExt
21.295. Class TaskFilterExt
21.296. Namespace ArmoniK.Core.Common.gRPC.Validators
21.297. Class CancelTasksRequestValidator
21.298. Class CreateLargeTaskRequestValidator
21.299. Class CreateSessionRequestValidator
21.300. Class CreateSmallTaskRequestValidator
21.301. Class CreateSmallTaskRequestValidator.TaskRequestValidator
21.302. Class EventSubscriptionRequestValidator
21.303. Class ListApplicationsRequestValidator
21.304. Class ListPartitionsRequestValidator
21.305. Class ListResultsRequestValidator
21.306. Class ListSessionsRequestValidator
21.307. Class ListTasksRequestValidator
21.308. Class SessionFilterValidator
21.309. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
21.310. Class CreateSessionRequestValidator
21.311. Class SubmitTasksRequestValidator
21.312. Class TaskFilterValidator
21.313. Class TaskOptionsValidator
21.314. Namespace ArmoniK.Core.Compute
21.315. Namespace ArmoniK.Core.Compute.PollingAgent
21.316. Class Program
21.317. Class Worker
21.318. Namespace ArmoniK.Core.Control
21.319. Namespace ArmoniK.Core.Control.Metrics
21.320. Class ArmoniKMeter
21.321. Namespace ArmoniK.Core.Control.Metrics.Options
21.322. Class MetricsExporter
21.323. Class Program
21.324. Namespace ArmoniK.Core.Control.PartitionMetrics
21.325. Class ArmoniKMeter
21.326. Namespace ArmoniK.Core.Control.PartitionMetrics.Options
21.327. Class MetricsExporter
21.328. Class Program
21.329. Namespace ArmoniK.Core.Control.Submitter
21.330. Class GrpcHealthCheckService
21.331. Class Program
21.332. Namespace ArmoniK.Core.ProfilingTools
21.333. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
21.334. Class ActivityExt
21.335. Class MongoExporterHelperExtensions
21.336. Class MongoExporterOptions
21.337. Class OpenTelemetryData
21.338. Class OpenTelemetryDataModelMapping
21.339. Namespace ArmoniK.Core.Tests
21.340. Namespace ArmoniK.Core.Tests.Queue
21.341. Class QueueStorageTests
21.342. Namespace ArmoniK.Core.Utils
21.343. Class CertificateValidator
21.344. Class ConfigurationExt
21.345. Class HealthCheck
21.346. Class HealthCheckResultCombiner
21.347. Class LoggerExt
21.348. Class QueryableExt
21.349. Class ServiceCollectionExt
21.350. Namespace ArmoniK.Samples
21.350.1. Namespaces
21.351. Namespace ArmoniK.Samples.Bench
21.352. Namespace ArmoniK.Samples.Bench.Client
21.353. Class ExecutionStats
21.354. Namespace ArmoniK.Samples.Bench.Client.Options
21.355. Class BenchOptions
21.356. Namespace ArmoniK.Samples.Bench.Server
21.357. Class BenchComputerService
21.358. Namespace ArmoniK.Samples.CrashingWorker
21.359. Namespace ArmoniK.Samples.CrashingWorker.Client
21.360. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
21.361. Class CrashingWorkerOptions
21.362. Namespace ArmoniK.Samples.CrashingWorker.Server
21.363. Class CrashingService
21.364. Namespace ArmoniK.Samples.HtcMock
21.365. Namespace ArmoniK.Samples.HtcMock.Client
21.366. Class GridClient
21.367. Class HtcMockClient
21.368. Namespace ArmoniK.Samples.HtcMock.Client.Options
21.369. Class HtcMock
21.370. Class SessionClient
21.371. Namespace ArmoniK.Samples.HtcMock.Server
21.372. Class SampleComputerService
ArmoniK.Core
21.
API reference
21.350.
Namespace ArmoniK.Samples
Edit on GitHub
21.350.
Namespace ArmoniK.Samples
21.350.1.
Namespaces
ArmoniK.Samples.Bench
ArmoniK.Samples.CrashingWorker
ArmoniK.Samples.HtcMock