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.296.1. Namespaces
      • 21.296.2. Classes
    • 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.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.296. Namespace ArmoniK.Core.Common.gRPC.Validators
  • Edit on GitHub

21.296. Namespace ArmoniK.Core.Common.gRPC.Validators

21.296.1. Namespaces

ArmoniK.Core.Common.gRPC.Validators.SessionsService

21.296.2. Classes

CancelTasksRequestValidator

Validator for

CreateLargeTaskRequestValidator

Validator for

CreateSessionRequestValidator

Validator for

CreateSmallTaskRequestValidator

Validator for

EventSubscriptionRequestValidator

Validator for

ListApplicationsRequestValidator

Validator for

ListPartitionsRequestValidator

Validator for

ListResultsRequestValidator

Validator for

ListSessionsRequestValidator

Validator for

ListTasksRequestValidator

Validator for

SessionFilterValidator

Validator for

SubmitTasksRequestValidator

Validator for

TaskFilterValidator

gRPC validator for

TaskOptionsValidator

Validator for

CreateSmallTaskRequestValidator.TaskRequestValidator

Validator for

Previous Next

© Copyright 2021-2025, ANEO.

Built with Sphinx using a theme provided by Read the Docs.