Package co.decodable.sdk.pipeline.testing

Class TestEnvironment

java.lang.Object

co.decodable.sdk.pipeline.testing.TestEnvironment

All Implemented Interfaces:

EnvironmentAccess.Environment

public class TestEnvironment
extends Object
implements EnvironmentAccess.Environment

An EnvironmentAccess.Environment implementation for testing purposes, allowing to define one or more Decodable streams which then can be accessed from the job under test.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestEnvironment.Builder	A builder for creating new TestEnvironment instances.

Method Summary

Modifier and Type	Method	Description
String	bootstrapServers()	Returns the Kafka bootstrap server(s) configured for this environment.
static TestEnvironment.Builder	builder()	Returns a builder for creating a new TestEnvironment.
Map<String,String>	getEnvironmentConfiguration()	Returns the current environment variables, keyed by name.
String	topicFor(String streamName)	Returns the name of the Kafka topic backing the given stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

builder

public static TestEnvironment.Builder builder()

Returns a builder for creating a new TestEnvironment.

getEnvironmentConfiguration

public Map<String,String> getEnvironmentConfiguration()

Returns the current environment variables, keyed by name.

Specified by:

getEnvironmentConfiguration in interface EnvironmentAccess.Environment

topicFor

public String topicFor(String streamName)

Returns the name of the Kafka topic backing the given stream.

bootstrapServers

public String bootstrapServers()

Returns the Kafka bootstrap server(s) configured for this environment.