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. Environment variables
22. API reference
22.1. Namespace ArmoniK
22.2. Namespace ArmoniK.Api
22.3. Namespace ArmoniK.Api.gRPC
22.4. Namespace ArmoniK.Api.gRPC.V1
22.5. Class PayloadConfiguration
22.6. Namespace ArmoniK.Core
22.7. Namespace ArmoniK.Core.Adapters
22.8. Namespace ArmoniK.Core.Adapters.Amqp
22.9. Class ConnectionAmqp
22.10. Interface IConnectionAmqp
22.11. Class PullQueueStorage
22.12. Class PushQueueStorage
22.13. Class QueueBuilder
22.14. Class QueueMessageHandler
22.15. Class QueueStorage
22.16. Namespace ArmoniK.Core.Adapters.Embed
22.17. Class ObjectBuilder
22.18. Class ObjectStorage
22.19. Namespace ArmoniK.Core.Adapters.LocalStorage
22.20. Class ObjectBuilder
22.21. Class ObjectStorage
22.22. Namespace ArmoniK.Core.Adapters.Memory
22.23. Class ObjectStorage
22.24. Class PushQueueStorage
22.25. Class QueueStorage
22.26. Class ResultTable
22.27. Class ServiceCollectionExt
22.28. Class SessionTable
22.29. Class TaskTable
22.30. Namespace ArmoniK.Core.Adapters.MongoDB
22.31. Class AuthenticationTable
22.32. Class ChangeStreamUpdate
22.33. Namespace ArmoniK.Core.Adapters.MongoDB.Common
22.34. Class BaseTable<TData, TModelMapping>
22.35. Interface IMongoDataModelMapping<T>
22.36. Class MongoCollectionProvider<TData, TModelMapping>
22.37. Class SessionProvider
22.38. Namespace ArmoniK.Core.Adapters.MongoDB.Options
22.39. Class MongoDB
22.40. Class TableStorage
22.41. Class PartitionTable
22.42. Class ResultTable
22.43. Class ResultWatcher
22.44. Class ServiceCollectionExt
22.45. Class SessionTable
22.46. Namespace ArmoniK.Core.Adapters.MongoDB.Table
22.47. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
22.48. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
22.49. Class AuthDataAfterLookup
22.50. Class AuthDataModelMapping
22.51. Class MongoAuthResult
22.52. Class RoleDataModelMapping
22.53. Class UserDataAfterLookup
22.54. Class UserDataModelMapping
22.55. Class IndexHelper
22.56. Enum IndexType
22.57. Class PartitionDataModelMapping
22.58. Class ResultDataModelMapping
22.59. Class SessionDataModelMapping
22.60. Class ShardingExt
22.61. Class TaskDataModelMapping
22.62. Class TaskTable
22.63. Class TaskWatcher
22.64. Class WatchEnumerable<TOutput, TInput>
22.65. Class WatchEnumerator<TOutput, TInput>
22.66. Namespace ArmoniK.Core.Adapters.Nats
22.67. Class Heart
22.68. Class QueueBuilder
22.69. Namespace ArmoniK.Core.Adapters.PubSub
22.70. Class Heart
22.71. Class QueueBuilder
22.72. Namespace ArmoniK.Core.Adapters.QueueCommon
22.73. Class Amqp
22.74. Class QueueStorageBase
22.75. Namespace ArmoniK.Core.Adapters.Redis
22.76. Class ObjectBuilder
22.77. Class ObjectStorage
22.78. Namespace ArmoniK.Core.Adapters.Redis.Options
22.79. Class Redis
22.80. Namespace ArmoniK.Core.Adapters.S3
22.81. Class ObjectBuilder
22.82. Class ObjectStorage
22.83. Namespace ArmoniK.Core.Adapters.S3.Options
22.84. Class S3
22.85. Namespace ArmoniK.Core.Adapters.SQS
22.86. Class Heart
22.87. Class QueueBuilder
22.88. Namespace ArmoniK.Core.Base
22.89. Namespace ArmoniK.Core.Base.DataStructures
22.90. Enum HealthCheckTag
22.91. Class MessageData
22.92. Class ObjectData
22.93. Class TaskOptions
22.94. Namespace ArmoniK.Core.Base.Exceptions
22.95. Class ArmoniKException
22.96. Class ObjectDataNotFoundException
22.97. Class QueueInsertionFailedException
22.98. Interface IDependencyInjectionBuildable
22.99. Interface IHealthCheckProvider
22.100. Interface IInitializable
22.101. Interface IObjectStorage
22.102. Interface IPullQueueStorage
22.103. Interface IPushQueueStorage
22.104. Interface IQueueMessageHandler
22.105. Interface IQueueStorage
22.106. Enum QueueMessageStatus
22.107. Namespace ArmoniK.Core.Common
22.108. Namespace ArmoniK.Core.Common.Auth
22.109. Namespace ArmoniK.Core.Common.Auth.Authentication
22.110. Class AuthData
22.111. Class AuthenticationCache
22.112. Class AuthenticationCacheKey
22.113. Class Authenticator
22.114. Class AuthenticatorOptions
22.115. Interface IAuthenticationTable
22.116. Class RoleData
22.117. Class UserAuthenticationResult
22.118. Class UserData
22.119. Class UserIdentity
22.120. Namespace ArmoniK.Core.Common.Auth.Authorization
22.121. Class AuthorizationPolicyProvider
22.122. Class GeneralService
22.123. Class IgnoreAuthenticationAttribute
22.124. Class IgnoreAuthorizationAttribute
22.125. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
22.126. Class Permission
22.127. Class PermissionScope
22.128. Class ServicesPermissions
22.129. Class RequiresPermissionAttribute
22.130. Namespace ArmoniK.Core.Common.Client
22.131. Class GrpcChannelExt
22.132. Class SessionStats
22.133. Namespace ArmoniK.Core.Common.DynamicLoading
22.134. Class CollocatedAssemblyResolver
22.135. Namespace ArmoniK.Core.Common.Exceptions
22.136. Class InvalidSessionTransitionException
22.137. Class PartitionNotFoundException
22.138. Class ResultNotFoundException
22.139. Class SessionNotFoundException
22.140. Class SubmissionClosedException
22.141. Class TaskAlreadyExistsException
22.142. Class TaskAlreadyInFinalStateException
22.143. Class TaskCanceledException
22.144. Class TaskNotFoundException
22.145. Class TaskPausedException
22.146. Class TimeoutException
22.147. Class WorkerDownException
22.148. Class HealthCheckRecord
22.149. Class HealthCheckRecord.Publisher
22.150. Interface IAsyncInitialization<T>
22.151. Namespace ArmoniK.Core.Common.Injection
22.152. Namespace ArmoniK.Core.Common.Injection.Options
22.153. Class AdapterSettings
22.154. Class Components
22.155. Namespace ArmoniK.Core.Common.Injection.Options.Database
22.156. Class Authentication
22.157. Class Certificate
22.158. Class InitDatabase
22.159. Class Partition
22.160. Class Partitioning
22.161. Class Role
22.162. Class User
22.163. Class InitServices
22.164. Class InitWorker
22.165. Class Pollster
22.166. Class Submitter
22.167. Class ServiceCollectionExt
22.168. Namespace ArmoniK.Core.Common.Meter
22.169. Class FunctionExecutionMetrics<TIns>
22.170. Class MeterHolder
22.171. Namespace ArmoniK.Core.Common.Pollster
22.172. Enum AcquisitionStatus
22.173. Class Agent
22.174. Class AgentHandler
22.175. Class AgentIdentifier
22.176. Class DataPrefetcher
22.177. Interface IAgent
22.178. Interface IAgentHandler
22.179. Class Pollster
22.180. Class PostProcessingTaskQueue
22.181. Class PostProcessor
22.182. Class RunningTaskProcessor
22.183. Class RunningTaskQueue
22.184. Class TaskHandler
22.185. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
22.186. Interface ITaskProcessingChecker
22.187. Class TaskProcessingCheckerClient
22.188. Class TaskQueueBase
22.189. Namespace ArmoniK.Core.Common.StateMachines
22.190. Class ProcessReplyCreateLargeTaskStateMachine
22.191. Enum ProcessReplyCreateLargeTaskStateMachine.State
22.192. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
22.193. Namespace ArmoniK.Core.Common.Storage
22.194. Class Application
22.195. Namespace ArmoniK.Core.Common.Storage.Events
22.196. Interface IResultWatcher
22.197. Interface ITaskWatcher
22.198. Class NewResult
22.199. Class NewTask
22.200. Class ResultOwnerUpdate
22.201. Class ResultStatusUpdate
22.202. Class TaskStatusUpdate
22.203. Interface IPartitionTable
22.204. Interface IResultTable
22.205. Class IResultTable.ChangeResultOwnershipRequest
22.206. Interface ISessionTable
22.207. Interface ITaskTable
22.208. Class MaskedProjection
22.209. Class Output
22.210. Enum OutputStatus
22.211. Class PartitionData
22.212. Class PartitionTaskStatusCount
22.213. Class PodConfiguration
22.214. Class QueueMessageHandlerExt
22.215. Class Result
22.216. Class ResultCreationRequest
22.217. Class ResultIdStatus
22.218. Class ResultLifeCycleHelper
22.219. Enum ResultStatus
22.220. Class ResultTableExtensions
22.221. Class SessionData
22.222. Class SessionLifeCycleHelper
22.223. Enum SessionStatus
22.224. Class SessionTableExtensions
22.225. Class TaskCreationRequest
22.226. Class TaskData
22.227. Enum TaskDataFields
22.228. Class TaskDataHolder
22.229. Class TaskDataMask
22.230. Class TaskIdStatus
22.231. Class TaskInfo
22.232. Class TaskLifeCycleHelper
22.233. Enum TaskOptionsFields
22.234. Class TaskOptionsHolder
22.235. Enum TaskStatus
22.236. Class TaskStatusCount
22.237. Class TaskSubmissionRequest
22.238. Class TaskTableExtensions
22.239. Class UpdateDefinition<T>
22.240. Class UpdateDefinition<T>.PropertySet
22.241. Namespace ArmoniK.Core.Common.Stream
22.242. Namespace ArmoniK.Core.Common.Stream.Worker
22.243. Interface IWorkerStreamHandler
22.244. Class WorkerStreamHandler
22.245. Namespace ArmoniK.Core.Common.Utils
22.246. Class ActivityExt
22.247. Class ActivitySourceExt
22.248. Class ExceptionManager
22.249. Class ExceptionManager.Options
22.250. Class ExpressionsBuilders
22.251. Class LocalIpFinder
22.252. Class LoggerInit
22.253. Class RendezvousChannel<T>
22.254. Class ReplaceExpressionVisitor
22.255. Class ReplaceParameterVisitor
22.256. Namespace ArmoniK.Core.Common.gRPC
22.257. Namespace ArmoniK.Core.Common.gRPC.Convertors
22.258. Class OutputExt
22.259. Class ResultExt
22.260. Class ResultStatusExt
22.261. Class SessionDataExt
22.262. Class SessionStatusExt
22.263. Class SessionTableExt
22.264. Class TaskDataHolderExt
22.265. Class TaskOptionsExt
22.266. Class TaskStatusCountExt
22.267. Class TaskStatusExt
22.268. Class TaskTableExt
22.269. Class EnumFieldExt
22.270. Class ExceptionInterceptor
22.271. Class ExpressionBuilders
22.272. Class ExpressionExt
22.273. Class FilterRangeExt
22.274. Class GrpcHealthCheckServiceBase
22.275. Class ListApplicationsRequestExt
22.276. Class ListPartitionsRequestExt
22.277. Class ListResultsRequestExt
22.278. Class ListSessionsRequestExt
22.279. Class ListTasksRequestExt
22.280. Namespace ArmoniK.Core.Common.gRPC.Services
22.281. Class GrpcAgentService
22.282. Class GrpcApplicationsService
22.283. Class GrpcAuthService
22.284. Class GrpcEventsService
22.285. Class GrpcHealthChecksService
22.286. Class GrpcPartitionsService
22.287. Class GrpcResultsService
22.288. Class GrpcSessionsService
22.289. Class GrpcSubmitterExtensions
22.290. Class GrpcSubmitterService
22.291. Class GrpcTasksService
22.292. Class GrpcVersionsService
22.293. Interface ISubmitter
22.294. Class Submitter
22.295. Class TaskRequest
22.296. Class WatchToGrpc
22.297. Class SessionFilterExt
22.298. Class TaskFilterExt
22.299. Namespace ArmoniK.Core.Common.gRPC.Validators
22.300. Class CancelTasksRequestValidator
22.301. Class CreateLargeTaskRequestValidator
22.302. Class CreateSessionRequestValidator
22.303. Class CreateSmallTaskRequestValidator
22.304. Class CreateSmallTaskRequestValidator.TaskRequestValidator
22.305. Class EventSubscriptionRequestValidator
22.306. Class ListApplicationsRequestValidator
22.307. Class ListPartitionsRequestValidator
22.308. Class ListResultsRequestValidator
22.309. Class ListSessionsRequestValidator
22.310. Class ListTasksRequestValidator
22.311. Class SessionFilterValidator
22.312. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
22.313. Class CreateSessionRequestValidator
22.314. Class SubmitTasksRequestValidator
22.315. Class TaskFilterValidator
22.316. Class TaskOptionsValidator
22.317. Namespace ArmoniK.Core.Compute
22.318. Namespace ArmoniK.Core.Compute.PollingAgent
22.319. Class Program
22.320. Class Worker
22.321. Namespace ArmoniK.Core.Control
22.322. Namespace ArmoniK.Core.Control.Metrics
22.323. Class ArmoniKMeter
22.324. Namespace ArmoniK.Core.Control.Metrics.Options
22.325. Class MetricsExporter
22.326. Class Program
22.327. Namespace ArmoniK.Core.Control.PartitionMetrics
22.328. Class ArmoniKMeter
22.329. Namespace ArmoniK.Core.Control.PartitionMetrics.Options
22.330. Class MetricsExporter
22.331. Class Program
22.332. Namespace ArmoniK.Core.Control.Submitter
22.333. Class GrpcHealthCheckService
22.334. Class Program
22.335. Namespace ArmoniK.Core.ProfilingTools
22.336. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
22.337. Class ActivityExt
22.338. Class MongoExporterHelperExtensions
22.339. Class MongoExporterOptions
22.340. Class OpenTelemetryData
22.341. Class OpenTelemetryDataModelMapping
22.342. Namespace ArmoniK.Core.Tests
22.343. Namespace ArmoniK.Core.Tests.Queue
22.344. Class QueueStorageTests
22.345. Namespace ArmoniK.Core.Utils
22.346. Class ByteArrayComparer
22.347. Class CertificateValidator
22.348. Class ConfigurationExt
22.349. Class HealthCheck
22.350. Class HealthCheckResultCombiner
22.351. Class LoggerExt
22.352. Class QueryableExt
22.353. Class ServiceCollectionExt
22.354. Namespace ArmoniK.Samples
22.355. Namespace ArmoniK.Samples.Bench
22.356. Namespace ArmoniK.Samples.Bench.Client
22.357. Class ExecutionStats
22.358. Namespace ArmoniK.Samples.Bench.Client.Options
22.359. Class BenchOptions
22.360. Namespace ArmoniK.Samples.Bench.Server
22.361. Class BenchComputerService
22.362. Namespace ArmoniK.Samples.CrashingWorker
22.363. Namespace ArmoniK.Samples.CrashingWorker.Client
22.364. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
22.364.1. Classes
22.365. Class CrashingWorkerOptions
22.366. Namespace ArmoniK.Samples.CrashingWorker.Server
22.367. Class CrashingService
22.368. Namespace ArmoniK.Samples.HtcMock
22.369. Namespace ArmoniK.Samples.HtcMock.Client
22.370. Class GridClient
22.371. Class HtcMockClient
22.372. Namespace ArmoniK.Samples.HtcMock.Client.Options
22.373. Class HtcMock
22.374. Class SessionClient
22.375. Namespace ArmoniK.Samples.HtcMock.Server
22.376. Class SampleComputerService
22.377. Class Program
ArmoniK.Core
22.
API reference
22.364.
Namespace ArmoniK.Samples.CrashingWorker.Client.Options
Edit on GitHub
22.364.
Namespace ArmoniK.Samples.CrashingWorker.Client.Options
22.364.1.
Classes
CrashingWorkerOptions
Class containing options for CrashingWorkerOptions