[fix] Fix blockstat indeaxtion : use bulk and flush in a async thread (80a4386a) · Commits · jm / duniter4j

Commit 80a4386a authored 7 years ago by Benoit Lavenier

Browse files

[fix] Fix blockstat indeaxtion : use bulk and flush in a async thread

parent 1e524990

No related branches found

No related tags found

No related merge requests found

Hide whitespace changes

Inline Side-by-side

Showing

duniter4j-core-client/src/main/java/org/duniter/core/client/model/bma/BlockchainBlock.java 3 additions, 3 deletions

...va/org/duniter/core/client/model/bma/BlockchainBlock.java
duniter4j-core-client/src/main/java/org/duniter/core/client/model/local/Peer.java 6 additions, 2 deletions

...c/main/java/org/duniter/core/client/model/local/Peer.java
duniter4j-core-client/src/main/java/org/duniter/core/client/service/HttpServiceImpl.java 1 addition, 1 deletion

...java/org/duniter/core/client/service/HttpServiceImpl.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/PluginInit.java 15 additions, 9 deletions

...e/src/main/java/org/duniter/elasticsearch/PluginInit.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/PluginSettings.java 1 addition, 1 deletion

...c/main/java/org/duniter/elasticsearch/PluginSettings.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/client/Duniter4jClient.java 10 additions, 0 deletions

...ava/org/duniter/elasticsearch/client/Duniter4jClient.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/client/Duniter4jClientImpl.java 46 additions, 3 deletions

...org/duniter/elasticsearch/client/Duniter4jClientImpl.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/dao/BlockDao.java 4 additions, 0 deletions

...src/main/java/org/duniter/elasticsearch/dao/BlockDao.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/dao/BlockStatDao.java 3 additions, 1 deletion

...main/java/org/duniter/elasticsearch/dao/BlockStatDao.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/dao/impl/BlockDaoImpl.java 26 additions, 0 deletions

...java/org/duniter/elasticsearch/dao/impl/BlockDaoImpl.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/dao/impl/BlockStatDaoImpl.java 26 additions, 2 deletions

.../org/duniter/elasticsearch/dao/impl/BlockStatDaoImpl.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/model/BlockchainBlockStat.java 3 additions, 3 deletions

.../org/duniter/elasticsearch/model/BlockchainBlockStat.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/service/AbstractBlockchainListenerService.java 62 additions, 30 deletions

...sticsearch/service/AbstractBlockchainListenerService.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/service/BlockchainService.java 0 additions, 13 deletions

.../org/duniter/elasticsearch/service/BlockchainService.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/service/BlockchainStatsService.java 44 additions, 29 deletions

...duniter/elasticsearch/service/BlockchainStatsService.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/service/changes/ChangeEvent.java 13 additions, 2 deletions

...rg/duniter/elasticsearch/service/changes/ChangeEvent.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/threadpool/CompletableActionFuture.java 133 additions, 0 deletions

...ter/elasticsearch/threadpool/CompletableActionFuture.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/threadpool/LoggingScheduledThreadPoolExecutor.java 89 additions, 0 deletions

...search/threadpool/LoggingScheduledThreadPoolExecutor.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/threadpool/RetryPolicy.java 43 additions, 0 deletions

...ava/org/duniter/elasticsearch/threadpool/RetryPolicy.java
duniter4j-es-core/src/main/java/org/duniter/elasticsearch/threadpool/ThreadPool.java 34 additions, 10 deletions

...java/org/duniter/elasticsearch/threadpool/ThreadPool.java

with 562 additions and 109 deletions

Please register or to comment