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. Tasks
11. Authentication and Authorization
12. Adaptors
13. RabbitMQ Limitations
14. MongoDB client connection problem
15. Using external plugins with ArmoniK.Core
16. TLS Implementation in the ArmoniK Core
17. Artemis
18. How to use ArmoniK RPCs
19. Tasks Service RPCs actions
20. Results Service RPCs actions
21. Sessions Service RPCs actions
22. Environment variables
23. API reference
23.1. Namespace ArmoniK
23.2. Namespace ArmoniK.Core
23.3. Namespace ArmoniK.Core.Adapters
23.4. Namespace ArmoniK.Core.Adapters.Amqp
23.5. Class ConnectionAmqp
23.6. Interface IConnectionAmqp
23.7. Class PullQueueStorage
23.8. Class PushQueueStorage
23.9. Class QueueBuilder
23.10. Class QueueMessageHandler
23.11. Class QueueStorage
23.12. Namespace ArmoniK.Core.Adapters.Embed
23.13. Class ObjectBuilder
23.14. Class ObjectStorage
23.15. Namespace ArmoniK.Core.Adapters.LocalStorage
23.16. Class ObjectBuilder
23.17. Class ObjectStorage
23.18. Namespace ArmoniK.Core.Adapters.Memory
23.19. Class ObjectStorage
23.20. Class PushQueueStorage
23.21. Class QueueStorage
23.22. Class ResultTable
23.23. Class ServiceCollectionExt
23.24. Class SessionTable
23.25. Class TaskTable
23.26. Namespace ArmoniK.Core.Adapters.MongoDB
23.27. Class AuthenticationTable
23.28. Class ChangeStreamUpdate
23.29. Namespace ArmoniK.Core.Adapters.MongoDB.Common
23.30. Class BaseTable<TData, TModelMapping>
23.31. Interface IMongoDataModelMapping<T>
23.32. Class MongoCollectionProvider<TData, TModelMapping>
23.33. Class SessionProvider
23.34. Namespace ArmoniK.Core.Adapters.MongoDB.Options
23.35. Class MongoDB
23.36. Class TableStorage
23.37. Class PartitionTable
23.38. Class ResultTable
23.39. Class ResultWatcher
23.40. Class ServiceCollectionExt
23.41. Class SessionTable
23.42. Namespace ArmoniK.Core.Adapters.MongoDB.Table
23.43. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel
23.44. Namespace ArmoniK.Core.Adapters.MongoDB.Table.DataModel.Auth
23.45. Class AuthDataAfterLookup
23.46. Class AuthDataModelMapping
23.47. Class MongoAuthResult
23.48. Class RoleDataModelMapping
23.49. Class UserDataAfterLookup
23.50. Class UserDataModelMapping
23.51. Class IndexHelper
23.52. Class PartitionDataModelMapping
23.53. Class ResultDataModelMapping
23.54. Class SessionDataModelMapping
23.55. Class ShardingExt
23.56. Class TaskDataModelMapping
23.57. Class TaskTable
23.58. Class TaskWatcher
23.59. Class WatchEnumerable<TOutput, TInput>
23.60. Class WatchEnumerator<TOutput, TInput>
23.61. Namespace ArmoniK.Core.Adapters.Nats
23.62. Class Heart
23.63. Class QueueBuilder
23.64. Namespace ArmoniK.Core.Adapters.NullStorage
23.65. Class ObjectBuilder
23.66. Class ObjectStorage
23.67. Namespace ArmoniK.Core.Adapters.PubSub
23.68. Class Heart
23.69. Class QueueBuilder
23.70. Namespace ArmoniK.Core.Adapters.QueueCommon
23.71. Class Amqp
23.72. Class QueueStorageBase
23.73. Namespace ArmoniK.Core.Adapters.Redis
23.74. Class ObjectBuilder
23.75. Class ObjectStorage
23.76. Namespace ArmoniK.Core.Adapters.Redis.Options
23.77. Class Redis
23.78. Namespace ArmoniK.Core.Adapters.S3
23.79. Class ObjectBuilder
23.80. Class ObjectStorage
23.81. Namespace ArmoniK.Core.Adapters.S3.Options
23.82. Class S3
23.83. Namespace ArmoniK.Core.Adapters.SQS
23.84. Class Heart
23.85. Class QueueBuilder
23.86. Namespace ArmoniK.Core.Base
23.87. Namespace ArmoniK.Core.Base.DataStructures
23.88. Enum HealthCheckTag
23.89. Class MessageData
23.90. Class ObjectData
23.91. Class TaskOptions
23.92. Namespace ArmoniK.Core.Base.Exceptions
23.93. Class ArmoniKException
23.94. Class ObjectDataNotFoundException
23.95. Class QueueInsertionFailedException
23.96. Interface IDependencyInjectionBuildable
23.97. Interface IHealthCheckProvider
23.98. Interface IInitializable
23.99. Interface IObjectStorage
23.100. Interface IPullQueueStorage
23.101. Interface IPushQueueStorage
23.102. Interface IQueueMessageHandler
23.103. Interface IQueueStorage
23.104. Enum QueueMessageStatus
23.105. Namespace ArmoniK.Core.Common
23.106. Namespace ArmoniK.Core.Common.Auth
23.107. Namespace ArmoniK.Core.Common.Auth.Authentication
23.108. Class AuthData
23.109. Class AuthenticationCache
23.110. Class AuthenticationCacheKey
23.111. Class Authenticator
23.112. Class AuthenticatorOptions
23.113. Interface IAuthenticationTable
23.114. Class RoleData
23.115. Class UserAuthenticationResult
23.116. Class UserData
23.117. Class UserIdentity
23.118. Namespace ArmoniK.Core.Common.Auth.Authorization
23.119. Class AuthorizationPolicyProvider
23.120. Class GeneralService
23.121. Class IgnoreAuthenticationAttribute
23.122. Class IgnoreAuthorizationAttribute
23.123. Namespace ArmoniK.Core.Common.Auth.Authorization.Permissions
23.124. Class Permission
23.125. Class PermissionScope
23.126. Class ServicesPermissions
23.127. Class RequiresPermissionAttribute
23.128. Namespace ArmoniK.Core.Common.Client
23.129. Class GrpcChannelExt
23.130. Class SessionStats
23.131. Namespace ArmoniK.Core.Common.DynamicLoading
23.132. Class CollocatedAssemblyResolver
23.133. Namespace ArmoniK.Core.Common.Exceptions
23.134. Class InvalidSessionTransitionException
23.135. Class PartitionNotFoundException
23.136. Class ResultNotFoundException
23.137. Class SessionNotFoundException
23.138. Class SubmissionClosedException
23.139. Class TaskAlreadyExistsException
23.140. Class TaskAlreadyInFinalStateException
23.141. Class TaskCanceledException
23.142. Class TaskNotFoundException
23.143. Class TaskPausedException
23.144. Class TimeoutException
23.145. Class WorkerDownException
23.146. Class HealthCheckRecord
23.147. Class HealthCheckRecord.Publisher
23.148. Interface IAsyncInitialization<T>
23.149. Namespace ArmoniK.Core.Common.Injection
23.150. Namespace ArmoniK.Core.Common.Injection.Options
23.151. Class AdapterSettings
23.152. Class Components
23.153. Namespace ArmoniK.Core.Common.Injection.Options.Database
23.154. Class Authentication
23.155. Class Certificate
23.156. Class InitDatabase
23.157. Class Partition
23.158. Class Partitioning
23.159. Class Role
23.160. Class User
23.161. Class InitServices
23.162. Class InitWorker
23.163. Class Pollster
23.164. Class Submitter
23.165. Class ServiceCollectionExt
23.166. Namespace ArmoniK.Core.Common.Meter
23.167. Class FunctionExecutionMetrics<TIns>
23.168. Class MeterHolder
23.169. Namespace ArmoniK.Core.Common.Pollster
23.170. Enum AcquisitionStatus
23.171. Class Agent
23.172. Class AgentHandler
23.173. Class AgentIdentifier
23.174. Class DataPrefetcher
23.175. Interface IAgent
23.176. Interface IAgentHandler
23.177. Class Pollster
23.178. Class PostProcessingTaskQueue
23.179. Class PostProcessor
23.180. Class RunningTaskProcessor
23.181. Class RunningTaskQueue
23.182. Class TaskHandler
23.183. Namespace ArmoniK.Core.Common.Pollster.TaskProcessingChecker
23.184. Interface ITaskProcessingChecker
23.185. Class TaskProcessingCheckerClient
23.186. Class TaskQueueBase
23.187. Namespace ArmoniK.Core.Common.StateMachines
23.188. Class ProcessReplyCreateLargeTaskStateMachine
23.189. Enum ProcessReplyCreateLargeTaskStateMachine.State
23.190. Enum ProcessReplyCreateLargeTaskStateMachine.Triggers
23.191. Namespace ArmoniK.Core.Common.Storage
23.192. Class Application
23.193. Namespace ArmoniK.Core.Common.Storage.Events
23.194. Interface IResultWatcher
23.195. Interface ITaskWatcher
23.196. Class NewResult
23.197. Class NewTask
23.198. Class ResultOwnerUpdate
23.199. Class ResultStatusUpdate
23.200. Class TaskStatusUpdate
23.201. Interface IPartitionTable
23.202. Interface IResultTable
23.203. Class IResultTable.ChangeResultOwnershipRequest
23.204. Interface ISessionTable
23.205. Interface ITaskTable
23.206. Class MaskedProjection
23.207. Class Output
23.208. Enum OutputStatus
23.209. Class PartitionData
23.210. Class PartitionTaskStatusCount
23.211. Class PodConfiguration
23.212. Class QueueMessageHandlerExt
23.213. Class Result
23.214. Class ResultCreationRequest
23.215. Class ResultIdStatus
23.216. Class ResultLifeCycleHelper
23.217. Enum ResultStatus
23.218. Class ResultTableExtensions
23.219. Class SessionData
23.220. Class SessionLifeCycleHelper
23.221. Enum SessionStatus
23.222. Class SessionTableExtensions
23.223. Class TaskCreationRequest
23.224. Class TaskData
23.225. Enum TaskDataFields
23.226. Class TaskDataHolder
23.227. Class TaskDataMask
23.228. Class TaskIdStatus
23.229. Class TaskInfo
23.230. Class TaskLifeCycleHelper
23.231. Enum TaskOptionsFields
23.232. Class TaskOptionsHolder
23.233. Enum TaskStatus
23.234. Class TaskStatusCount
23.235. Class TaskSubmissionRequest
23.236. Class TaskTableExtensions
23.237. Class UpdateDefinition<T>
23.238. Class UpdateDefinition<T>.PropertySet
23.239. Namespace ArmoniK.Core.Common.Stream
23.240. Namespace ArmoniK.Core.Common.Stream.Worker
23.241. Interface IWorkerStreamHandler
23.242. Class WorkerStreamHandler
23.243. Namespace ArmoniK.Core.Common.Utils
23.244. Class ActivityExt
23.245. Class ActivitySourceExt
23.246. Class ExceptionManager
23.247. Class ExceptionManager.Options
23.248. Class ExpressionsBuilders
23.249. Class FileExt
23.250. Class LocalIpFinder
23.251. Class LoggerInit
23.252. Class RendezvousChannel<T>
23.253. Class ReplaceExpressionVisitor
23.254. Class ReplaceParameterVisitor
23.255. Namespace ArmoniK.Core.Common.gRPC
23.256. Namespace ArmoniK.Core.Common.gRPC.Convertors
23.257. Class OutputExt
23.258. Class ResultExt
23.259. Class ResultStatusExt
23.260. Class SessionDataExt
23.261. Class SessionStatusExt
23.262. Class SessionTableExt
23.263. Class TaskDataHolderExt
23.264. Class TaskOptionsExt
23.265. Class TaskStatusCountExt
23.266. Class TaskStatusExt
23.267. Class TaskTableExt
23.268. Class EnumFieldExt
23.269. Class ExceptionInterceptor
23.270. Class ExpressionBuilders
23.271. Class ExpressionExt
23.272. Class FilterRangeExt
23.273. Class GrpcHealthCheckServiceBase
23.274. Class ListApplicationsRequestExt
23.275. Class ListPartitionsRequestExt
23.276. Class ListResultsRequestExt
23.277. Class ListSessionsRequestExt
23.278. Class ListTasksRequestExt
23.279. Namespace ArmoniK.Core.Common.gRPC.Services
23.280. Class GrpcAgentService
23.281. Class GrpcApplicationsService
23.282. Class GrpcAuthService
23.283. Class GrpcEventsService
23.284. Class GrpcHealthChecksService
23.285. Class GrpcPartitionsService
23.286. Class GrpcResultsService
23.287. Class GrpcSessionsService
23.288. Class GrpcSubmitterExtensions
23.289. Class GrpcSubmitterService
23.290. Class GrpcTasksService
23.291. Class GrpcVersionsService
23.292. Interface ISubmitter
23.293. Class Submitter
23.294. Class TaskRequest
23.295. Class WatchToGrpc
23.296. Class SessionFilterExt
23.297. Class TaskFilterExt
23.298. Namespace ArmoniK.Core.Common.gRPC.Validators
23.299. Class CancelTasksRequestValidator
23.300. Class CreateLargeTaskRequestValidator
23.301. Class CreateSessionRequestValidator
23.302. Class CreateSmallTaskRequestValidator
23.303. Class CreateSmallTaskRequestValidator.TaskRequestValidator
23.304. Class EventSubscriptionRequestValidator
23.305. Class ListApplicationsRequestValidator
23.306. Class ListPartitionsRequestValidator
23.307. Class ListResultsRequestValidator
23.308. Class ListSessionsRequestValidator
23.309. Class ListTasksRequestValidator
23.310. Class SessionFilterValidator
23.311. Namespace ArmoniK.Core.Common.gRPC.Validators.SessionsService
23.312. Class CreateSessionRequestValidator
23.313. Class SubmitTasksRequestValidator
23.314. Class TaskFilterValidator
23.315. Class TaskOptionsValidator
23.316. Namespace ArmoniK.Core.Compute
23.317. Namespace ArmoniK.Core.Compute.PollingAgent
23.318. Class Program
23.319. Class Worker
23.320. Namespace ArmoniK.Core.Control
23.321. Namespace ArmoniK.Core.Control.Metrics
23.322. Class ArmoniKMeter
23.323. Namespace ArmoniK.Core.Control.Metrics.Options
23.323.1. Classes
23.324. Class MetricsExporter
23.325. Class Program
23.326. Namespace ArmoniK.Core.Control.Submitter
23.327. Class GrpcHealthCheckService
23.328. Class Program
23.329. Namespace ArmoniK.Core.ProfilingTools
23.330. Namespace ArmoniK.Core.ProfilingTools.OpenTelemetryExporter
23.331. Class ActivityExt
23.332. Class MongoExporterHelperExtensions
23.333. Class MongoExporterOptions
23.334. Class OpenTelemetryData
23.335. Class OpenTelemetryDataModelMapping
23.336. Namespace ArmoniK.Core.Tests
23.337. Namespace ArmoniK.Core.Tests.Queue
23.338. Class QueueStorageTests
23.339. Namespace ArmoniK.Core.Tests.UploadBench
23.340. Namespace ArmoniK.Core.Tests.UploadBench.Options
23.341. Class UploadBench
23.342. Class UploadBenchClient
23.343. Namespace ArmoniK.Core.Utils
23.344. Class ByteArrayComparer
23.345. Class CertificateValidator
23.346. Class ConfigurationExt
23.347. Class HealthCheck
23.348. Class HealthCheckResultCombiner
23.349. Class LoggerExt
23.350. Class QueryableExt
23.351. Class ServiceCollectionExt
23.352. Namespace ArmoniK.Samples
23.353. Namespace ArmoniK.Samples.Bench
23.354. Namespace ArmoniK.Samples.Bench.Client
23.355. Class ExecutionStats
23.356. Namespace ArmoniK.Samples.Bench.Client.Options
23.357. Class BenchOptions
23.358. Namespace ArmoniK.Samples.Bench.Server
23.359. Class BenchComputerService
23.360. Namespace ArmoniK.Samples.CrashingWorker
23.361. Namespace ArmoniK.Samples.CrashingWorker.Client
23.362. Namespace ArmoniK.Samples.CrashingWorker.Client.Options
23.363. Class CrashingWorkerOptions
23.364. Namespace ArmoniK.Samples.CrashingWorker.Server
23.365. Class CrashingService
23.366. Namespace ArmoniK.Samples.HtcMock
23.367. Namespace ArmoniK.Samples.HtcMock.Client
23.368. Class GridClient
23.369. Class HtcMockClient
23.370. Namespace ArmoniK.Samples.HtcMock.Client.Options
23.371. Class HtcMock
23.372. Class SessionClient
23.373. Namespace ArmoniK.Samples.HtcMock.Server
23.374. Class SampleComputerService
23.375. Class Program
ArmoniK.Core
23.
API reference
23.323.
Namespace ArmoniK.Core.Control.Metrics.Options
Edit on GitHub
23.323.
Namespace ArmoniK.Core.Control.Metrics.Options
23.323.1.
Classes
MetricsExporter
Represents the configuration settings for the metrics exporter.