Skip to content

Commit

Permalink
Change elastic config entry back from nodes to endpoints.
Browse files Browse the repository at this point in the history
Postponing this breaking change until 0.10.

Signed-off-by: Matthias Wahl <mwahl@wayfair.com>
  • Loading branch information
Matthias Wahl committed Jan 26, 2021
1 parent b8e2c34 commit e6b34fc
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 6 deletions.
4 changes: 0 additions & 4 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,6 @@

## Latest

### Breaking Changes

* elastic sink config value `endpoints` renamed to `nodes` [#715](https://github.com/tremor-rs/tremor-runtime/pull/715)

### New features

* Default to thin-lto for all builds (prior this was only done in docker)
Expand Down
4 changes: 2 additions & 2 deletions src/sink/elastic.rs
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ use tremor_script::Object;
#[derive(Debug, Deserialize)]
pub struct Config {
/// list of endpoint urls
pub nodes: Vec<String>,
pub endpoints: Vec<String>,
/// maximum number of paralel in flight batches (default: 4)
#[serde(default = "concurrency")]
pub concurrency: usize,
Expand All @@ -78,7 +78,7 @@ impl offramp::Impl for Elastic {
if let Some(config) = config {
let config: Config = Config::new(config)?;
let client = SyncClientBuilder::new()
.static_nodes(config.nodes.into_iter())
.static_nodes(config.endpoints.into_iter())
.build()?;

let queue = AsyncSink::new(config.concurrency);
Expand Down

0 comments on commit e6b34fc

Please sign in to comment.