| const IgniteClient = require('apache-ignite-client'); |
| const IgniteClientConfiguration = IgniteClient.IgniteClientConfiguration; |
| const ObjectType = IgniteClient.ObjectType; |
| const CacheEntry = IgniteClient.CacheEntry; |
| |
| async function performCacheKeyValueOperations() { |
| const igniteClient = new IgniteClient(); |
| try { |
| await igniteClient.connect(new IgniteClientConfiguration('127.0.0.1:10800')); |
| const cache = (await igniteClient.getOrCreateCache('myCache')). |
| setKeyType(ObjectType.PRIMITIVE_TYPE.INTEGER); |
| // Put and get value |
| await cache.put(1, 'abc'); |
| const value = await cache.get(1); |
| console.log(value); |
| |
| // Put and get multiple values using putAll()/getAll() methods |
| await cache.putAll([new CacheEntry(2, 'value2'), new CacheEntry(3, 'value3')]); |
| const values = await cache.getAll([1, 2, 3]); |
| console.log(values.flatMap(val => val.getValue())); |
| |
| // Removes all entries from the cache |
| await cache.clear(); |
| } |
| catch (err) { |
| console.log(err.message); |
| } |
| finally { |
| igniteClient.disconnect(); |
| } |
| } |
| |
| performCacheKeyValueOperations(); |