Skip to content
Open
Show file tree
Hide file tree
Changes from 3 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions docs/devguide/running/deploy.md
Original file line number Diff line number Diff line change
Expand Up @@ -206,6 +206,7 @@ conductor.elasticsearch.version=0

```properties
conductor.indexing.enabled=true
conductor.indexing.type=elasticsearch
conductor.elasticsearch.url=http://es-host:9200
conductor.elasticsearch.version=7
conductor.elasticsearch.indexName=conductor
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,85 @@
/*
* Copyright 2026 Conductor Authors.
* <p>
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
* <p>
* http://www.apache.org/licenses/LICENSE-2.0
* <p>
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
* specific language governing permissions and limitations under the License.
*/
package com.netflix.conductor.es7.config;

import org.junit.Test;
import org.springframework.boot.test.context.runner.ApplicationContextRunner;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Conditional;
import org.springframework.context.annotation.Configuration;

import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;

public class ElasticSearchConditionsTest {

private final ApplicationContextRunner contextRunner =
new ApplicationContextRunner()
.withUserConfiguration(ConditionalTestConfiguration.class);

@Test
public void shouldActivateForElasticsearchV7Selector() {
contextRunner
.withPropertyValues(
"conductor.indexing.enabled=true",
"conductor.indexing.type=elasticsearch",
"conductor.elasticsearch.version=7")
.run(context -> assertTrue(context.containsBean("es7Marker")));
}

@Test
public void shouldActivateWhenVersionIsImplicit() {
contextRunner
.withPropertyValues(
"conductor.indexing.enabled=true", "conductor.indexing.type=elasticsearch")
.run(context -> assertTrue(context.containsBean("es7Marker")));
}

@Test
public void shouldNotActivateWhenIndexingIsDisabled() {
contextRunner
.withPropertyValues(
"conductor.indexing.enabled=false",
"conductor.indexing.type=elasticsearch",
"conductor.elasticsearch.version=7")
.run(context -> assertFalse(context.containsBean("es7Marker")));
}

@Test
public void shouldNotActivateForLegacyVersionPropertyOnly() {
contextRunner
.withPropertyValues(
"conductor.indexing.enabled=true", "conductor.elasticsearch.version=7")
.run(context -> assertFalse(context.containsBean("es7Marker")));
}

@Test
public void shouldNotActivateForElasticsearch8Selector() {
contextRunner
.withPropertyValues(
"conductor.indexing.enabled=true", "conductor.indexing.type=elasticsearch8")
.run(context -> assertFalse(context.containsBean("es7Marker")));
}

@Configuration(proxyBeanMethods = false)
@Conditional(ElasticSearchConditions.ElasticSearchV7Enabled.class)
static class ConditionalTestConfiguration {

@Bean
Marker es7Marker() {
return new Marker();
}
}

static class Marker {}
}
Loading