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. Install on Windows 11
9. Project components
10. Initialization
11. Agent cache
12. Tasks
13. Authentication and Authorization
14. Adaptors
15. RabbitMQ Limitations
16. MongoDB client connection problem
17. Using external plugins with ArmoniK.Core
18. TLS Implementation in the ArmoniK Core
19. Partitions
20. Artemis
21. How to use ArmoniK RPCs
22. Tasks Service RPCs actions
23. Results Service RPCs actions
24. Sessions Service RPCs actions
25. Environment variables
26. API reference
26.1. Namespace ArmoniK
26.2. Namespace ArmoniK.Core
26.3. Namespace ArmoniK.Core.Adapters
26.4. Namespace ArmoniK.Core.Adapters.Amqp
26.5. Class ConnectionAmqp
26.6. Interface IConnectionAmqp
26.7. Class PullQueueStorage
26.8. Class PushQueueStorage
26.9. Class QueueBuilder
26.10. Class QueueMessageHandler
26.11. Class QueueStorage
26.12. Namespace ArmoniK.Core.Adapters.Embed
26.13. Class ObjectBuilder
26.14. Class ObjectStorage
26.15. Namespace ArmoniK.Core.Adapters.Gcs
26.16. Class ObjectBuilder
26.17. Class ObjectStorage
26.18. Namespace ArmoniK.Core.Adapters.Gcs.Options
26.19. Class Gcs
26.20. Namespace ArmoniK.Core.Adapters.LocalStorage
26.21. Class ObjectBuilder
26.22. Class ObjectStorage
26.23. Namespace ArmoniK.Core.Adapters.Memory
26.24. Class ObjectStorage
26.25. Class PushQueueStorage
26.26. Class QueueStorage
26.27. Class ResultTable
26.28. Class ServiceCollectionExt
26.29. Class SessionTable
26.30. Class TaskTable
26.31. Namespace ArmoniK.Core.Adapters.MongoDB
26.32. Class AuthenticationTable
26.33. Class ChangeStreamUpdate
26.34. Namespace ArmoniK.Core.Adapters.MongoDB.Common
26.35. Class BaseTable<TData, TModelMapping>
26.36. Interface IMongoDataModelMapping<T>
26.37. Class MongoCollectionProvider<TData, TModelMapping>
26.38. Class SessionProvider
26.39. Namespace ArmoniK.Core.Adapters.MongoDB.Options
26.40. Class MongoDB
26.41. Class TableStorage
26.42. Class PartitionTable
26.43. Class ResultTable
26.44. Class ResultWatcher
26.45. Class ServiceCollectionExt
26.46. Class SessionTable
26.47. Namespace ArmoniK.Core.Adapters.MongoDB.Table
26.48. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
26.49. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
26.50. Class AuthDataAfterLookup
26.51. Class AuthDataModelMapping
26.52. Class MongoAuthResult
26.53. Class RoleDataModelMapping
26.54. Class UserDataAfterLookup
26.55. Class UserDataModelMapping
26.56. Class IndexHelper
26.57. Class PartitionDataModelMapping
26.58. Class ResultDataModelMapping
26.59. Class SessionDataModelMapping
26.60. Class ShardingExt
26.61. Class TaskDataModelMapping
26.62. Class TaskTable
26.63. Class TaskWatcher
26.64. Class WatchEnumerable<TOutput, TInput>
26.65. Class WatchEnumerator<TOutput, TInput>
26.66. Namespace ArmoniK.Core.Adapters.Nats
26.67. Class Heart
26.68. Class QueueBuilder
26.69. Namespace ArmoniK.Core.Adapters.NullStorage
26.70. Class ObjectBuilder
26.71. Class ObjectStorage
26.72. Namespace ArmoniK.Core.Adapters.PubSub
26.73. Class Heart
26.74. Class QueueBuilder
26.75. Namespace ArmoniK.Core.Adapters.QueueCommon
26.76. Class Amqp
26.77. Class QueueStorageBase
26.78. Namespace ArmoniK.Core.Adapters.Redis
26.79. Class ObjectBuilder
26.80. Class ObjectStorage
26.81. Namespace ArmoniK.Core.Adapters.Redis.Options
26.82. Class Redis
26.83. Namespace ArmoniK.Core.Adapters.S3
26.84. Class ObjectBuilder
26.85. Class ObjectStorage
26.86. Namespace ArmoniK.Core.Adapters.S3.Options
26.87. Class S3
26.88. Namespace ArmoniK.Core.Adapters.SQS
26.89. Class Heart
26.90. Class QueueBuilder
26.91. Namespace ArmoniK.Core.Base
26.92. Namespace ArmoniK.Core.Base.DataStructures
26.93. Enum HealthCheckTag
26.94. Class MessageData
26.95. Class ObjectData
26.96. Class TaskOptions
26.97. Namespace ArmoniK.Core.Base.Exceptions
26.98. Class ArmoniKException
26.99. Class ObjectDataNotFoundException
26.100. Class QueueInsertionFailedException
26.101. Interface IDependencyInjectionBuildable
26.102. Interface IHealthCheckProvider
26.103. Interface IInitializable
26.104. Interface IObjectStorage
26.105. Interface IPullQueueStorage
26.106. Interface IPushQueueStorage
26.107. Interface IQueueMessageHandler
26.108. Interface IQueueStorage
26.109. Enum QueueMessageStatus
26.110. Namespace ArmoniK.Core.Common
26.111. Namespace ArmoniK.Core.Common.Auth
26.112. Namespace ArmoniK.Core.Common.Auth.Authentication
26.113. Class AuthData
26.114. Class AuthenticationCache
26.115. Class AuthenticationCacheKey
26.116. Class Authenticator
26.117. Class AuthenticatorOptions
26.118. Interface IAuthenticationTable
26.119. Class RoleData
26.120. Class UserAuthenticationResult
26.121. Class UserData
26.122. Class UserIdentity
26.123. Namespace ArmoniK.Core.Common.Auth.Authorization
26.124. Class AuthorizationPolicyProvider
26.125. Class GeneralService
26.126. Class IgnoreAuthenticationAttribute
26.127. Class IgnoreAuthorizationAttribute
26.128. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
26.129. Class Permission
26.130. Class PermissionScope
26.131. Class ServicesPermissions
26.132. Class RequiresPermissionAttribute
26.133. Namespace ArmoniK.Core.Common.Client
26.134. Class GrpcChannelExt
26.135. Class SessionStats
26.136. Namespace ArmoniK.Core.Common.DynamicLoading
26.137. Class CollocatedAssemblyResolver
26.138. Namespace ArmoniK.Core.Common.Exceptions
26.139. Class InvalidSessionTransitionException
26.140. Class PartitionNotFoundException
26.141. Class ResultNotFoundException
26.142. Class SessionNotFoundException
26.143. Class SubmissionClosedException
26.144. Class TaskAlreadyExistsException
26.145. Class TaskAlreadyInFinalStateException
26.146. Class TaskCanceledException
26.147. Class TaskNotFoundException
26.148. Class TaskPausedException
26.149. Class TimeoutException
26.150. Class WorkerDownException
26.151. Class HealthCheckRecord
26.152. Class HealthCheckRecord.Publisher
26.153. Interface IAsyncInitialization<T>
26.154. Namespace ArmoniK.Core.Common.Injection
26.155. Namespace ArmoniK.Core.Common.Injection.Options
26.156. Class AdapterSettings
26.157. Class Components
26.158. Namespace ArmoniK.Core.Common.Injection.Options.Database
26.159. Class Authentication
26.160. Class Certificate
26.161. Class InitDatabase
26.162. Class Partition
26.163. Class Partitioning
26.164. Class Role
26.165. Class User
26.166. Class InitServices
26.167. Class InitWorker
26.168. Class Pollster
26.169. Class Submitter
26.170. Class ServiceCollectionExt
26.171. Namespace ArmoniK.Core.Common.Meter
26.172. Class FunctionExecutionMetrics<TIns>
26.173. Class MeterHolder
26.174. Namespace ArmoniK.Core.Common.Pollster
26.175. Enum AcquisitionStatus
26.176. Class Agent
26.177. Class AgentHandler
26.178. Class AgentIdentifier
26.179. Class DataPrefetcher
26.180. Interface IAgent
26.181. Interface IAgentHandler
26.182. Class Pollster
26.183. Class PostProcessingTaskQueue
26.184. Class PostProcessor
26.185. Class RunningTaskProcessor
26.186. Class RunningTaskQueue
26.187. Class TaskHandler
26.188. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
26.189. Interface ITaskProcessingChecker
26.190. Class TaskProcessingCheckerClient
26.191. Class TaskQueueBase
26.192. Namespace ArmoniK.Core.Common.StateMachines
26.193. Class ProcessReplyCreateLargeTaskStateMachine
26.194. Enum ProcessReplyCreateLargeTaskStateMachine.State
26.195. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
26.196. Namespace ArmoniK.Core.Common.Storage
26.197. Class Application
26.198. Namespace ArmoniK.Core.Common.Storage.Events
26.199. Interface IResultWatcher
26.200. Interface ITaskWatcher
26.201. Class NewResult
26.202. Class NewTask
26.203. Class ResultOwnerUpdate
26.204. Class ResultStatusUpdate
26.205. Class TaskStatusUpdate
26.206. Interface IPartitionTable
26.207. Interface IResultTable
26.208. Class IResultTable.ChangeResultOwnershipRequest
26.209. Interface ISessionTable
26.210. Interface ITaskTable
26.211. Class MaskedProjection
26.212. Class Output
26.213. Enum OutputStatus
26.214. Class PartitionData
26.215. Class PartitionTaskStatusCount
26.216. Class PodConfiguration
26.217. Class QueueMessageHandlerExt
26.218. Class Result
26.219. Class ResultCreationRequest
26.220. Class ResultIdStatus
26.221. Class ResultLifeCycleHelper
26.222. Enum ResultStatus
26.223. Class ResultTableExtensions
26.224. Class SessionData
26.225. Class SessionLifeCycleHelper
26.226. Enum SessionStatus
26.227. Class SessionTableExtensions
26.228. Class TaskCreationRequest
26.229. Class TaskData
26.230. Enum TaskDataFields
26.231. Class TaskDataHolder
26.232. Class TaskDataMask
26.233. Class TaskIdStatus
26.234. Class TaskInfo
26.235. Class TaskLifeCycleHelper
26.236. Enum TaskOptionsFields
26.237. Class TaskOptionsHolder
26.238. Enum TaskStatus
26.239. Class TaskStatusCount
26.240. Class TaskSubmissionRequest
26.241. Class TaskTableExtensions
26.242. Class UpdateDefinition<T>
26.243. Class UpdateDefinition<T>.PropertySet
26.244. Namespace ArmoniK.Core.Common.Stream
26.245. Namespace ArmoniK.Core.Common.Stream.Worker
26.246. Interface IWorkerStreamHandler
26.247. Class WorkerStreamHandler
26.248. Namespace ArmoniK.Core.Common.Utils
26.249. Class ActivityExt
26.250. Class ActivitySourceExt
26.251. Class ExceptionManager
26.252. Class ExceptionManager.Options
26.253. Class ExpressionsBuilders
26.254. Class FileExt
26.255. Class LocalIpFinder
26.256. Class LoggerInit
26.257. Class RendezvousChannel<T>
26.258. Class ReplaceExpressionVisitor
26.259. Class ReplaceParameterVisitor
26.260. Namespace ArmoniK.Core.Common.gRPC
26.261. Namespace ArmoniK.Core.Common.gRPC.Convertors
26.262. Class OutputExt
26.263. Class ResultExt
26.264. Class ResultStatusExt
26.265. Class SessionDataExt
26.266. Class SessionStatusExt
26.267. Class SessionTableExt
26.268. Class TaskDataHolderExt
26.269. Class TaskOptionsExt
26.270. Class TaskStatusCountExt
26.271. Class TaskStatusExt
26.272. Class TaskTableExt
26.273. Class EnumFieldExt
26.274. Class ExceptionInterceptor
26.275. Class ExpressionBuilders
26.276. Class ExpressionExt
26.277. Class FilterRangeExt
26.278. Class GrpcHealthCheckServiceBase
26.279. Class ListApplicationsRequestExt
26.280. Class ListPartitionsRequestExt
26.281. Class ListResultsRequestExt
26.282. Class ListSessionsRequestExt
26.283. Class ListTasksRequestExt
26.284. Namespace ArmoniK.Core.Common.gRPC.Services
26.285. Class GrpcAgentService
26.286. Class GrpcApplicationsService
26.287. Class GrpcAuthService
26.288. Class GrpcEventsService
26.289. Class GrpcHealthChecksService
26.290. Class GrpcPartitionsService
26.291. Class GrpcResultsService
26.292. Class GrpcSessionsService
26.293. Class GrpcSubmitterExtensions
26.294. Class GrpcSubmitterService
26.295. Class GrpcTasksService
26.296. Class GrpcVersionsService
26.297. Interface ISubmitter
26.298. Class Submitter
26.299. Class TaskRequest
26.300. Class WatchToGrpc
26.301. Class SessionFilterExt
26.302. Class TaskFilterExt
26.303. Namespace ArmoniK.Core.Common.gRPC.Validators
26.304. Class CancelTasksRequestValidator
26.305. Class CreateLargeTaskRequestValidator
26.306. Class CreateSessionRequestValidator
26.307. Class CreateSmallTaskRequestValidator
26.308. Class CreateSmallTaskRequestValidator.TaskRequestValidator
26.309. Class EventSubscriptionRequestValidator
26.310. Class ListApplicationsRequestValidator
26.311. Class ListPartitionsRequestValidator
26.312. Class ListResultsRequestValidator
26.313. Class ListSessionsRequestValidator
26.314. Class ListTasksRequestValidator
26.315. Class SessionFilterValidator
26.316. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
26.317. Class CreateSessionRequestValidator
26.318. Class SubmitTasksRequestValidator
26.319. Class TaskFilterValidator
26.320. Class TaskOptionsValidator
26.321. Namespace ArmoniK.Core.Compute
26.322. Namespace ArmoniK.Core.Compute.PollingAgent
26.323. Class Program
26.324. Class Worker
26.325. Namespace ArmoniK.Core.Control
26.326. Namespace ArmoniK.Core.Control.Metrics
26.327. Class ArmoniKMeter
26.328. Namespace ArmoniK.Core.Control.Metrics.Options
26.329. Class MetricsExporter
26.330. Class Program
26.331. Namespace ArmoniK.Core.Control.Submitter
26.332. Class GrpcHealthCheckService
26.333. Class Program
26.334. Namespace ArmoniK.Core.ProfilingTools
26.335. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
26.336. Class ActivityExt
26.337. Class MongoExporterHelperExtensions
26.338. Class MongoExporterOptions
26.339. Class OpenTelemetryData
26.340. Class OpenTelemetryDataModelMapping
26.341. Namespace ArmoniK.Core.Tests
26.342. Namespace ArmoniK.Core.Tests.Queue
26.343. Class QueueStorageTests
26.344. Namespace ArmoniK.Core.Tests.UploadBench
26.345. Namespace ArmoniK.Core.Tests.UploadBench.Options
26.345.1. Classes
26.346. Class UploadBench
26.347. Class UploadBenchClient
26.348. Namespace ArmoniK.Core.Utils
26.349. Class ByteArrayComparer
26.350. Class CertificateValidator
26.351. Class ConfigurationExt
26.352. Class HealthCheck
26.353. Class HealthCheckResultCombiner
26.354. Class LoggerExt
26.355. Class QueryableExt
26.356. Class ServiceCollectionExt
26.357. Namespace ArmoniK.Samples
26.358. Namespace ArmoniK.Samples.Bench
26.359. Namespace ArmoniK.Samples.Bench.Client
26.360. Class ExecutionStats
26.361. Namespace ArmoniK.Samples.Bench.Client.Options
26.362. Class BenchOptions
26.363. Namespace ArmoniK.Samples.Bench.Server
26.364. Class BenchComputerService
26.365. Namespace ArmoniK.Samples.CrashingWorker
26.366. Namespace ArmoniK.Samples.CrashingWorker.Client
26.367. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
26.368. Class CrashingWorkerOptions
26.369. Namespace ArmoniK.Samples.CrashingWorker.Server
26.370. Class CrashingService
26.371. Namespace ArmoniK.Samples.HtcMock
26.372. Namespace ArmoniK.Samples.HtcMock.Client
26.373. Class GridClient
26.374. Class HtcMockClient
26.375. Namespace ArmoniK.Samples.HtcMock.Client.Options
26.376. Class HtcMock
26.377. Class SessionClient
26.378. Namespace ArmoniK.Samples.HtcMock.Server
26.379. Class SampleComputerService
26.380. Class Program
ArmoniK.Core
26.
API reference
26.345.
Namespace ArmoniK.Core.Tests.UploadBench.Options
Edit on GitHub
26.345.
Namespace ArmoniK.Core.Tests.UploadBench.Options
26.345.1.
Classes
UploadBench
Class containing options for UploadBench