Uses of Interface
io.streamthoughts.azkarra.api.config.Conf
-
-
Uses of Conf in io.streamthoughts.azkarra.api
Fields in io.streamthoughts.azkarra.api declared as Conf Modifier and Type Field Description protected Conf
Executed. config
Methods in io.streamthoughts.azkarra.api that return Conf Modifier and Type Method Description Conf
AzkarraContext. getConfiguration()
Returns the global context streamsConfig of thisAzkarraContext
instance.Conf
StreamsExecutionEnvironment. getConfiguration()
Gets this environment configuration.Conf
AzkarraStreamsService. getContextConfig()
Conf
AzkarraStreamsService. getStreamsConfigById(String applicationId)
Returns theConf
for the specified streams application.Conf
StreamsLifecycleContext. streamsConfig()
Gets the configuration of the current streams instance.Methods in io.streamthoughts.azkarra.api with parameters of type Conf Modifier and Type Method Description AzkarraContext
AzkarraContext. addConfiguration(Conf configuration)
Adds the specifiedConf
to the configuration of thisAzkarraContext
.StreamsExecutionEnvironment
StreamsExecutionEnvironment. addFallbackConfiguration(Conf settings)
Adds streamsConfig that will be used in fallback if not present in defined environment streamsConfig.void
AzkarraStreamsService. addNewEnvironment(String name, Conf conf)
Adds a new environment to this application.AzkarraContext
AzkarraContext. setConfiguration(Conf configuration)
Sets the default configuration to be used for thisAzkarraContext
.StreamsExecutionEnvironment
StreamsExecutionEnvironment. setConfiguration(Conf configuration)
Sets this environment configuration.static Executed
Executed. with(Conf conf)
Static helper that can be used to creates a newExecuted
instance with the specified streams name and configuration.Executed
Executed. withConfig(Conf config)
Returns a newExecuted
with the specified config. -
Uses of Conf in io.streamthoughts.azkarra.api.components
Methods in io.streamthoughts.azkarra.api.components that return Conf Modifier and Type Method Description Conf
BaseComponentModule. getConfiguration()
Gets the configuration used by this component factory.Conf
ConfigurableComponentFactory. getConfiguration()
Gets the configuration used by this component factory.Methods in io.streamthoughts.azkarra.api.components with parameters of type Conf Modifier and Type Method Description void
BaseComponentModule. configure(Conf configuration)
Configures this instance with the specifiedConf
.T
GettableComponent. get(Conf conf)
Gets the instance of typeGettableComponent
, which may be shared or independent.<T> Collection<T>
ComponentFactory. getAllComponents(Class<T> type, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ComponentFactory. getAllComponents(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ComponentFactory. getAllComponents(String type, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ComponentFactory. getAllComponents(String type, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ContextAwareComponentFactory. getAllComponents(Class<T> type, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ContextAwareComponentFactory. getAllComponents(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ContextAwareComponentFactory. getAllComponents(String alias, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
ContextAwareComponentFactory. getAllComponents(String alias, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
DelegatingComponentFactory. getAllComponents(Class<T> type, Conf conf)
<T> Collection<T>
DelegatingComponentFactory. getAllComponents(Class<T> type, Conf conf, Qualifier<T> qualifier)
<T> Collection<T>
DelegatingComponentFactory. getAllComponents(String type, Conf conf)
<T> Collection<T>
DelegatingComponentFactory. getAllComponents(String type, Conf conf, Qualifier<T> qualifier)
<T> T
ComponentFactory. getComponent(Class<T> type, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ComponentFactory. getComponent(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ComponentFactory. getComponent(String type, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ComponentFactory. getComponent(String type, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ContextAwareComponentFactory. getComponent(Class<T> type, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ContextAwareComponentFactory. getComponent(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ContextAwareComponentFactory. getComponent(String alias, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
ContextAwareComponentFactory. getComponent(String alias, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
DelegatingComponentFactory. getComponent(Class<T> type, Conf conf)
<T> T
DelegatingComponentFactory. getComponent(Class<T> type, Conf conf, Qualifier<T> qualifier)
<T> T
DelegatingComponentFactory. getComponent(String type, Conf conf)
<T> T
DelegatingComponentFactory. getComponent(String type, Conf conf, Qualifier<T> qualifier)
void
ComponentFactory. init(Conf conf)
Initialize the component factory for the given configuration.void
DelegatingComponentFactory. init(Conf conf)
-
Uses of Conf in io.streamthoughts.azkarra.api.components.condition
Methods in io.streamthoughts.azkarra.api.components.condition that return Conf Modifier and Type Method Description Conf
ConditionContext. getConfig()
Get the configuration that was passed to get the component instance.Constructor parameters in io.streamthoughts.azkarra.api.components.condition with type arguments of type Conf Constructor Description OnPropertyCondition(Function<Conf,Optional<T>> accessor, Predicate<Optional<T>> predicate)
Creates a newOnPropertyCondition
instance. -
Uses of Conf in io.streamthoughts.azkarra.api.config
Classes in io.streamthoughts.azkarra.api.config that implement Conf Modifier and Type Class Description class
AbstractConf
class
ArgsConf
AConf
which is build from a list of arguments.class
ConfBuilder
Helper class which can be used for building newConf
instance.class
EmptyConf
class
MapConf
class
Property
A single key-value with configuration.Methods in io.streamthoughts.azkarra.api.config that return Conf Modifier and Type Method Description Conf
ConfBuilder. build()
Conf
RocksDBConfig. conf()
static Conf
Conf. empty()
Static helper that can be used to creates a new emptyConf
instance.Conf
Conf. getSubConf(String path)
Gets a required parameter as aConf
.Conf
ConfBuilder. getSubConf(String path)
Gets a required parameter as aConf
.Conf
EmptyConf. getSubConf(String key)
Gets a required parameter as aConf
.Conf
MapConf. getSubConf(String path)
Gets a required parameter as aConf
.static Conf
Conf. with(String path, Object value)
Static helper that can be used to creates a new emptyConf
instance using the specified key-value pair.static Conf
Conf. with(Map<String,?> map)
Conf
Conf. withFallback(Conf fallback)
Conf
ConfBuilder. withFallback(Conf fallback)
Conf
EmptyConf. withFallback(Conf fallback)
Conf
MapConf. withFallback(Conf fallback)
Methods in io.streamthoughts.azkarra.api.config that return types with arguments of type Conf Modifier and Type Method Description List<Conf>
Conf. getSubConfList(String path)
Gets a required parameter as a list ofConf
.List<Conf>
ConfBuilder. getSubConfList(String path)
Gets a required parameter as a list ofConf
.List<Conf>
EmptyConf. getSubConfList(String key)
Gets a required parameter as a list ofConf
.List<Conf>
MapConf. getSubConfList(String path)
Gets a required parameter as a list ofConf
.Methods in io.streamthoughts.azkarra.api.config with parameters of type Conf Modifier and Type Method Description void
Configurable. configure(Conf configuration)
Configures this instance with the specifiedConf
.void
ConfigurableSupplier. configure(Conf configs)
Configures this instance with the specifiedConf
.abstract T
ConfigurableSupplier. get(Conf configs)
static void
Configurable. mayConfigure(Object instance, Conf conf)
static ConfBuilder
ConfBuilder. newConf(Conf conf)
Conf
Conf. withFallback(Conf fallback)
Conf
ConfBuilder. withFallback(Conf fallback)
Conf
EmptyConf. withFallback(Conf fallback)
Conf
MapConf. withFallback(Conf fallback)
Constructors in io.streamthoughts.azkarra.api.config with parameters of type Conf Constructor Description MapConf(Map<String,?> parameters, Conf fallback, boolean explode)
-
Uses of Conf in io.streamthoughts.azkarra.api.providers
Methods in io.streamthoughts.azkarra.api.providers that return Conf Modifier and Type Method Description Conf
TopologyDescriptor. streamsConfigs()
-
Uses of Conf in io.streamthoughts.azkarra.api.server
Methods in io.streamthoughts.azkarra.api.server with parameters of type Conf Modifier and Type Method Description default void
AzkarraRestExtension. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.api.streams
Methods in io.streamthoughts.azkarra.api.streams that return Conf Modifier and Type Method Description protected Conf
OptimizedTopologyProvider. configuration()
ReturnsConf
defined for thisTopologyProvider
.Conf
KafkaStreamsContainer. streamsConfig()
Gets the configuration for thisKafkaStreams
instance.Methods in io.streamthoughts.azkarra.api.streams with parameters of type Conf Modifier and Type Method Description ApplicationId
ApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.void
OptimizedTopologyProvider. configure(Conf configuration)
Configures this instance with the specifiedConf
.org.apache.kafka.streams.KafkaStreams
KafkaStreamsFactory. make(org.apache.kafka.streams.Topology topology, Conf streamsConfig)
Creates a newKafkaStreams
instance for the given topology and config. -
Uses of Conf in io.streamthoughts.azkarra.api.streams.admin
Methods in io.streamthoughts.azkarra.api.streams.admin with parameters of type Conf Modifier and Type Method Description static org.apache.kafka.clients.admin.AdminClient
AdminClientUtils. newAdminClient(Conf config)
Creates a newAdminClient
instance. -
Uses of Conf in io.streamthoughts.azkarra.api.streams.internal
Methods in io.streamthoughts.azkarra.api.streams.internal that return Conf Modifier and Type Method Description Conf
InternalStreamsLifecycleContext. streamsConfig()
Gets the configuration of the current streams instance. -
Uses of Conf in io.streamthoughts.azkarra.api.streams.topology
Methods in io.streamthoughts.azkarra.api.streams.topology that return Conf Modifier and Type Method Description Conf
TopologyContainer. streamsConfig()
Methods in io.streamthoughts.azkarra.api.streams.topology with parameters of type Conf Modifier and Type Method Description void
TopologyContainer. streamsConfig(Conf streamsConfig)
Constructors in io.streamthoughts.azkarra.api.streams.topology with parameters of type Conf Constructor Description TopologyContainer(org.apache.kafka.streams.Topology topology, ApplicationId applicationId, Conf streamsConfig, TopologyMetadata metadata, List<StreamsLifecycleInterceptor> interceptors)
Creates a newTopologyContainer
instance. -
Uses of Conf in io.streamthoughts.azkarra.http
Methods in io.streamthoughts.azkarra.http that return Conf Modifier and Type Method Description Conf
ServerConfBuilder. build()
Methods in io.streamthoughts.azkarra.http with parameters of type Conf Modifier and Type Method Description void
UndertowEmbeddedServer. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.http.handler
Methods in io.streamthoughts.azkarra.http.handler that return Conf Modifier and Type Method Description Conf
ContextGetHandler.ContextPayload. getConfig()
Constructors in io.streamthoughts.azkarra.http.handler with parameters of type Conf Constructor Description ContextPayload(Conf config)
Creates a newContextGetHandler.ContextPayload
instance. -
Uses of Conf in io.streamthoughts.azkarra.http.routes
Methods in io.streamthoughts.azkarra.http.routes with parameters of type Conf Modifier and Type Method Description void
ApiDefaultRoutes. configure(Conf configuration)
Configures this instance with the specifiedConf
.void
ApiInfoRoutes. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.http.security
Constructors in io.streamthoughts.azkarra.http.security with parameters of type Conf Constructor Description SecurityConfig(Conf conf)
Creates a newSecurityConfig
instance. -
Uses of Conf in io.streamthoughts.azkarra.http.security.auth
Methods in io.streamthoughts.azkarra.http.security.auth with parameters of type Conf Modifier and Type Method Description void
InMemoryUserIdentityManager. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.http.security.authorizer
Methods in io.streamthoughts.azkarra.http.security.authorizer with parameters of type Conf Modifier and Type Method Description void
SimpleAuthorizationManager. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.metrics
Constructors in io.streamthoughts.azkarra.metrics with parameters of type Conf Constructor Description AzkarraMetricsConfig(Conf config)
Creates a newAzkarraMetricsConfig
instance. -
Uses of Conf in io.streamthoughts.azkarra.metrics.interceptor
Methods in io.streamthoughts.azkarra.metrics.interceptor with parameters of type Conf Modifier and Type Method Description void
MeterKafkaStreamsInterceptor. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.runtime.components
Methods in io.streamthoughts.azkarra.runtime.components with parameters of type Conf Modifier and Type Method Description <T> Collection<T>
DefaultComponentFactory. getAllComponents(Class<T> type, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
DefaultComponentFactory. getAllComponents(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
DefaultComponentFactory. getAllComponents(String alias, Conf conf)
Gets all instances, which may be shared or independent, for the specified type.<T> Collection<T>
DefaultComponentFactory. getAllComponents(String alias, Conf conf, Qualifier<T> qualifier)
Gets all instances, which may be shared or independent, for the specified type.<T> T
DefaultComponentFactory. getComponent(Class<T> type, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
DefaultComponentFactory. getComponent(Class<T> type, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.<T> T
DefaultComponentFactory. getComponent(String alias, Conf conf)
Gets an instance, which may be shared or independent, for the specified type.<T> T
DefaultComponentFactory. getComponent(String alias, Conf conf, Qualifier<T> qualifier)
Gets an instance, which may be shared or independent, for the specified type.void
DefaultComponentFactory. init(Conf conf)
Initialize the component factory for the given configuration. -
Uses of Conf in io.streamthoughts.azkarra.runtime.components.condition
Constructors in io.streamthoughts.azkarra.runtime.components.condition with parameters of type Conf Constructor Description ConfigConditionalContext(Conf config)
Creates a newConfigConditionalContext
instance. -
Uses of Conf in io.streamthoughts.azkarra.runtime.config
Methods in io.streamthoughts.azkarra.runtime.config that return Conf Modifier and Type Method Description Conf
AzkarraContextConfig. configs()
Methods in io.streamthoughts.azkarra.runtime.config with parameters of type Conf Modifier and Type Method Description AzkarraContextConfig
AzkarraContextConfig. addConfiguration(Conf configs)
Constructors in io.streamthoughts.azkarra.runtime.config with parameters of type Conf Constructor Description AzkarraContextConfig(Conf configs)
Creates a newAzkarraContextConfig
instance. -
Uses of Conf in io.streamthoughts.azkarra.runtime.context
Methods in io.streamthoughts.azkarra.runtime.context that return Conf Modifier and Type Method Description Conf
DefaultAzkarraContext. getConfiguration()
Returns the global context streamsConfig of thisAzkarraContext
instance.Methods in io.streamthoughts.azkarra.runtime.context with parameters of type Conf Modifier and Type Method Description AzkarraContext
DefaultAzkarraContext. addConfiguration(Conf configuration)
Adds the specifiedConf
to the configuration of thisAzkarraContext
.static AzkarraContext
DefaultAzkarraContext. create(Conf configuration)
Static helper that can be used to creates a newAzkarraContext
instance using a defaultComponentRegistry
and the specified configuration.AzkarraContext
DefaultAzkarraContext. setConfiguration(Conf configuration)
Sets the default configuration to be used for thisAzkarraContext
. -
Uses of Conf in io.streamthoughts.azkarra.runtime.context.internal
Methods in io.streamthoughts.azkarra.runtime.context.internal with parameters of type Conf Modifier and Type Method Description ApplicationId
ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration.T
ContextAwareGettableComponentSupplier. get(Conf configs)
TopologyProvider
ContextAwareTopologySupplier. get(Conf configs)
org.apache.kafka.streams.KafkaStreams
ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory. make(org.apache.kafka.streams.Topology topology, Conf streamsConfig)
Creates a newKafkaStreams
instance for the given topology and config. -
Uses of Conf in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env that return Conf Modifier and Type Method Description Conf
DefaultStreamsExecutionEnvironment. getConfiguration()
Gets this environment configuration.Methods in io.streamthoughts.azkarra.runtime.env with parameters of type Conf Modifier and Type Method Description StreamsExecutionEnvironment
DefaultStreamsExecutionEnvironment. addFallbackConfiguration(Conf fallback)
Adds streamsConfig that will be used in fallback if not present in defined environment streamsConfig.static StreamsExecutionEnvironment
DefaultStreamsExecutionEnvironment. create(Conf settings)
Static helper that can be used to creates a newStreamsExecutionEnvironment
instance from the specifiedConf
and using a generated env name.static StreamsExecutionEnvironment
DefaultStreamsExecutionEnvironment. create(Conf settings, String envName)
Static helper that can be used to creates a newStreamsExecutionEnvironment
instance from the specifiedConf
and env name.StreamsExecutionEnvironment
DefaultStreamsExecutionEnvironment. setConfiguration(Conf configuration)
Sets this environment configuration.Constructors in io.streamthoughts.azkarra.runtime.env with parameters of type Conf Constructor Description DefaultStreamsExecutionEnvironment(Conf configuration)
Creates a newDefaultStreamsExecutionEnvironment
instance. -
Uses of Conf in io.streamthoughts.azkarra.runtime.env.internal
Methods in io.streamthoughts.azkarra.runtime.env.internal with parameters of type Conf Modifier and Type Method Description T
EnvironmentAwareComponentSupplier. get(StreamsExecutionEnvironment environment, Conf componentConf)
-
Uses of Conf in io.streamthoughts.azkarra.runtime.interceptors
Methods in io.streamthoughts.azkarra.runtime.interceptors that return Conf Modifier and Type Method Description Conf
AutoCreateTopicsInterceptorConfig. originals()
Methods in io.streamthoughts.azkarra.runtime.interceptors with parameters of type Conf Modifier and Type Method Description void
AutoCreateTopicsInterceptor. configure(Conf configuration)
Configures this instance with the specifiedConf
.void
MonitoringStreamsInterceptor. configure(Conf configuration)
Configures this instance with the specifiedConf
.Constructors in io.streamthoughts.azkarra.runtime.interceptors with parameters of type Conf Constructor Description AutoCreateTopicsInterceptorConfig(Conf originals)
Creates a newAutoCreateTopicsInterceptorConfig
instance.MonitoringStreamsInterceptorConfig(Conf originals)
Creates a newMonitoringStreamsInterceptorConfig
instance. -
Uses of Conf in io.streamthoughts.azkarra.runtime.service
Methods in io.streamthoughts.azkarra.runtime.service that return Conf Modifier and Type Method Description Conf
LocalAzkarraStreamsService. getContextConfig()
Conf
LocalAzkarraStreamsService. getStreamsConfigById(String applicationId)
Returns theConf
for the specified streams application.Methods in io.streamthoughts.azkarra.runtime.service with parameters of type Conf Modifier and Type Method Description void
LocalAzkarraStreamsService. addNewEnvironment(String name, Conf conf)
Adds a new environment to this application. -
Uses of Conf in io.streamthoughts.azkarra.runtime.streams
Methods in io.streamthoughts.azkarra.runtime.streams with parameters of type Conf Modifier and Type Method Description ApplicationId
DefaultApplicationIdBuilder. buildApplicationId(TopologyMetadata metadata, Conf streamsConfig)
Builds theStreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration. -
Uses of Conf in io.streamthoughts.azkarra.runtime.streams.topology
Methods in io.streamthoughts.azkarra.runtime.streams.topology that return Conf Modifier and Type Method Description Conf
InternalExecuted. config()
-
Uses of Conf in io.streamthoughts.azkarra.serialization
Methods in io.streamthoughts.azkarra.serialization with parameters of type Conf Modifier and Type Method Description default void
Serdes. configure(Conf configuration)
Configure thisSerdes
. -
Uses of Conf in io.streamthoughts.azkarra.serialization.json
Methods in io.streamthoughts.azkarra.serialization.json with parameters of type Conf Modifier and Type Method Description void
ConfSerializer. serialize(Conf value, com.fasterxml.jackson.core.JsonGenerator gen, com.fasterxml.jackson.databind.SerializerProvider serializers)
-
Uses of Conf in io.streamthoughts.azkarra.streams
Methods in io.streamthoughts.azkarra.streams that return Conf Modifier and Type Method Description Conf
AzkarraApplication. getConfiguration()
Gets the configuration for thisAzkarraApplication
.Methods in io.streamthoughts.azkarra.streams with parameters of type Conf Modifier and Type Method Description AzkarraApplication
AzkarraApplication. addConfiguration(Conf configuration)
Adds the specifiedConf
to the configuration of thisAzkarraApplication
.AzkarraApplication
AzkarraApplication. enableHttpServer(boolean enableHttpServer, Conf conf)
AzkarraApplication
AzkarraApplication. setConfiguration(Conf configuration)
Sets theAzkarraApplication
configuration. -
Uses of Conf in io.streamthoughts.azkarra.streams.components
Methods in io.streamthoughts.azkarra.streams.components with parameters of type Conf Modifier and Type Method Description void
ReflectMethodComponentSupplier. configure(Conf configuration)
Configures this instance with the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.streams.config
Classes in io.streamthoughts.azkarra.streams.config that implement Conf Modifier and Type Class Description class
AzkarraConf
Fields in io.streamthoughts.azkarra.streams.config declared as Conf Modifier and Type Field Description protected Conf
HttpServerConf. originals
Methods in io.streamthoughts.azkarra.streams.config that return Conf Modifier and Type Method Description Conf
AzkarraConf. getSubConf(String key)
Gets a required parameter as aConf
.Conf
AzkarraConf. withFallback(Conf defaults)
Methods in io.streamthoughts.azkarra.streams.config that return types with arguments of type Conf Modifier and Type Method Description List<Conf>
AzkarraConf. getSubConfList(String key)
Gets a required parameter as a list ofConf
.Methods in io.streamthoughts.azkarra.streams.config with parameters of type Conf Modifier and Type Method Description static HttpServerConf
HttpServerConf. with(Conf conf)
Conf
AzkarraConf. withFallback(Conf defaults)
Constructors in io.streamthoughts.azkarra.streams.config with parameters of type Conf Constructor Description HttpServerConf(String listener, Integer port, Map<String,Object> overrides, Conf originals)
Creates a newHttpServerConf
instance. -
Uses of Conf in io.streamthoughts.azkarra.streams.config.internal
Methods in io.streamthoughts.azkarra.streams.config.internal that return Conf Modifier and Type Method Description Conf
InternalHttpServerConf. getConf()
-
Uses of Conf in io.streamthoughts.azkarra.streams.context
Methods in io.streamthoughts.azkarra.streams.context with parameters of type Conf Modifier and Type Method Description static AzkarraContext
AzkarraContextLoader. load(AzkarraContext context, Conf configuration)
Initialize the specifiedAzkarraContext
using the specifiedConf
. -
Uses of Conf in io.streamthoughts.azkarra.streams.context.internal
Methods in io.streamthoughts.azkarra.streams.context.internal that return Conf Modifier and Type Method Description Conf
EnvironmentConfig. config()
Gets the configuration for this environment.Conf
ApplicationConfig. context()
Gets the context configuration.Methods in io.streamthoughts.azkarra.streams.context.internal that return types with arguments of type Conf Modifier and Type Method Description Optional<Conf>
TopologyConfig. config()
Methods in io.streamthoughts.azkarra.streams.context.internal with parameters of type Conf Modifier and Type Method Description static ApplicationConfig
ApplicationConfig. read(Conf conf)
Static helper that can be used to creates a newApplicationConfig
instance from the providedConf
.ApplicationConfig
ApplicationConfig.Reader. read(Conf conf)
static EnvironmentConfig
EnvironmentConfig. read(Conf conf)
Static helper that can be used to creates a newEnvironmentConfig
instance from the providedConf
.static TopologyConfig
TopologyConfig. read(Conf conf)
Static helper that can be used to creates a newTopologyConfig
instance from the providedConf
.TopologyConfig
TopologyConfig.Reader. read(Conf conf)
-
Uses of Conf in io.streamthoughts.examples.azkarra.dependency
Methods in io.streamthoughts.examples.azkarra.dependency with parameters of type Conf Modifier and Type Method Description void
ComplexWordCountTopology. configure(Conf configuration)
void
ConfigurableStopWordsService. configure(Conf conf)
-
Uses of Conf in io.streamthoughts.examples.azkarra.topology
Methods in io.streamthoughts.examples.azkarra.topology with parameters of type Conf Modifier and Type Method Description void
ConfigurableWordCountTopology. configure(Conf configuration)
-