Skip to content

0.5.0: Merge pull request #91 from rchicoli/rewrite-bulk

Choose a tag to compare

@rchicoli rchicoli released this 04 May 13:39
· 5 commits to master since this release
73c8ec4
  • an UUID (16 bytes) is added to each document
  • docker containerCreated timestamp will have the same timezone as the timestamp field
  • tests bulk rejections
  • add backoff strategy to bulk processor

baaa668 elasticsearch: skip error on mapping request
fcf3b60 makefile: correct indentation
aaf16c0 elasticsearch: reuse bulk processor with logging
9fc9363 docker: fix docker create timestamp
de2fd45 Merge pull request #92 from [secure]/check-timeout
1762c85 elasticsearch: resend bulk rejection messages
6de16ad elasticsearch: add retry function for commiting bulk
8e5ec53 elasticsearch: check if result is nil before parsing
032570b docker: split new container func
7685e43 release: new custom bulk processor
5dcae91 docker: remove unused ticker from container type
ff24e61 tests: improve bulk multi message
5099d75 docker: simplify the bulk worker
739b67f docker: create a bulk worker type for the bulk service
a4a2efb tests: disable retry tests
ffb9daa make: add plugin_set to all stage
21c8501 docker: return instead of break
f8d3fab docker: defer flush on last pipe and close client connection on stop
8fbb583 docker: close client on closed channel
e41165b tests: reconnection
e996bb6 errgroup: remove internal package
b6de7e2 elasticsearch: implement new bulk service for all clients
57a8888 docker: add flush interval to log pipeline
6deffda elasticsearch: create a bulk interface
3e28b21 workaround: fix bulk service
f8200c1 tests: add multiple messages to bulk
2635c73 elasticsearch: check if bulkResponse is nil before return
55429f1 config: change timeout to time duration and set the default value to 10s
101ed50 tests: check the bulk interval time and if actions and disable are disabled
ecd8e6e tests: remove old stats from bulk tests
ca543d2 docker: ignore if bulk size or actions is negative
560c837 tests: remove old stats log opt
2b3a2e0 docker: implement custom bulk for all elasticsearch versions
6b17199 docker: add internal errgroup for running sync once
0402c4f docker: rewrite bulk service