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.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.362.1. Classes
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.362.
Namespace ArmoniK.Samples.CrashingWorker.Server
Edit on GitHub
17.362.
Namespace ArmoniK.Samples.CrashingWorker.Server
17.362.1.
Classes
CrashingService