Package io.streamthoughts.azkarra.runtime.service

Class AbstractAzkarraStreamsService

java.lang.Object

io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService

All Implemented Interfaces:

AzkarraContextAware, AzkarraStreamsService

Direct Known Subclasses:

LocalAzkarraStreamsService

public abstract class AbstractAzkarraStreamsService
extends Object
implements AzkarraStreamsService, AzkarraContextAware

Field Summary

Fields

Modifier and Type	Field	Description
protected AzkarraContext	context

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractAzkarraStreamsService()	Creates a new AbstractAzkarraStreamsService instance.

Method Summary

Modifier and Type	Method	Description
Set<StreamsExecutionEnvironment.View>	describeAllEnvironments()	Gets all existing streams environments.
StreamsExecutionEnvironment.View	describeEnvironmentByName(String name)	Gets the StreamsExecutionEnvironment for the specified name.
List<TopologyAndAliases>	getAllTopologies()	Gets the list of all topologies.
Set<String>	getSupportedEnvironmentTypes()	Gets all supported environment types.
TopologyDescriptor	getTopologyByAliasAndQualifiers(String alias, Qualifier<? extends TopologyProvider> qualifier)	Gets the TopologyDescriptor for the specified alias and qualifier.
TopologyDescriptor	getTopologyByAliasAndVersion(String alias, String version)	Gets the TopologyDescriptor for the specified alias and version.
Set<TopologyDescriptor>	getTopologyProviders()	Gets all topologies available locally.
List<Version>	getTopologyVersionsByAlias(String alias)	Gets all versions of TopologyDescriptor for the specified alias.
void	setAzkarraContext(AzkarraContext context)	Set the AzkarraContext that this object runs in.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.streamthoughts.azkarra.api.AzkarraStreamsService

addNewEnvironment, getAllStreamsContainersById, getContextConfig, getStreamsApplicationById, getStreamsContainerById, listAllKafkaStreamsApplicationIds, listAllKafkaStreamsContainerIds, restartStreamsContainer, startStreamsTopology, stopStreamsContainer, terminateStreamsApplication, terminateStreamsContainer

Field Detail

context

protected AzkarraContext context

Constructor Detail

AbstractAzkarraStreamsService

protected AbstractAzkarraStreamsService()

Creates a new AbstractAzkarraStreamsService instance.

Method Detail

getTopologyProviders

public Set<TopologyDescriptor> getTopologyProviders()

Gets all topologies available locally.

Specified by:

getTopologyProviders in interface AzkarraStreamsService

Returns:

a set of TopologyDescriptor instance.

getAllTopologies

public List<TopologyAndAliases> getAllTopologies()

Description copied from interface: AzkarraStreamsService

Gets the list of all topologies.

Specified by:

getAllTopologies in interface AzkarraStreamsService

Returns:

the list TopologyAndAliases.

getTopologyByAliasAndVersion

public TopologyDescriptor getTopologyByAliasAndVersion(String alias,
                                                       String version)

Gets the TopologyDescriptor for the specified alias and version.

Specified by:

getTopologyByAliasAndVersion in interface AzkarraStreamsService

Parameters:

alias - the topology alias.

version - the topology version.

Returns:

the TopologyDescriptor.

getTopologyByAliasAndQualifiers

public TopologyDescriptor getTopologyByAliasAndQualifiers(String alias,
                                                          Qualifier<? extends TopologyProvider> qualifier)

Gets the TopologyDescriptor for the specified alias and qualifier.

Specified by:

getTopologyByAliasAndQualifiers in interface AzkarraStreamsService

Parameters:

alias - the topology alias.

qualifier - the topology qualifier.

Returns:

the TopologyDescriptor.

getTopologyVersionsByAlias

public List<Version> getTopologyVersionsByAlias(String alias)

Gets all versions of TopologyDescriptor for the specified alias.

Specified by:

getTopologyVersionsByAlias in interface AzkarraStreamsService

Parameters:

alias - the topology alias.

getSupportedEnvironmentTypes

public Set<String> getSupportedEnvironmentTypes()

Gets all supported environment types.

Specified by:

getSupportedEnvironmentTypes in interface AzkarraStreamsService

Returns:

the set of the environment types.

describeAllEnvironments

public Set<StreamsExecutionEnvironment.View> describeAllEnvironments()

Gets all existing streams environments.

Specified by:

describeAllEnvironments in interface AzkarraStreamsService

Returns:

a set of StreamsExecutionEnvironment instance.

describeEnvironmentByName

public StreamsExecutionEnvironment.View describeEnvironmentByName(String name)

Gets the StreamsExecutionEnvironment for the specified name.

Specified by:

describeEnvironmentByName in interface AzkarraStreamsService

Parameters:

name - the environment name to find.

Returns:

the StreamsExecutionEnvironment.

setAzkarraContext

public void setAzkarraContext(AzkarraContext context)

Set the AzkarraContext that this object runs in.

Specified by:

setAzkarraContext in interface AzkarraContextAware

Parameters:

context - the AzkarraContext instance.