Module org.elasticsearch.server

Package org.elasticsearch.indices

Class SystemDataStreamDescriptor

java.lang.Object

org.elasticsearch.indices.SystemDataStreamDescriptor

public class SystemDataStreamDescriptor
extends Object

Describes a DataStream that is reserved for use by a system feature.

A system data stream is managed by the system and protected by the system against user modifications so that system features are not broken by inadvertent user operations.

Unlike a SystemIndexDescriptor, a SystemDataStreamDescriptor does not take an index pattern. Rather, it derives the expected backing index pattern from the data stream name.

A SystemDataStreamDescriptor defines a list of allowed product origins. If that list is empty, only system operations can read, write to, or modify the system data stream. If there are entries in the list, then a special request header must be used in any request that accesses the system data stream, either through plugin-provided APIs or through data stream APIs.

A SystemDataStreamDescriptor may be internal or external. If internal, the system feature must define APIs for interacting with the system data stream. If external, the system feature will allow use of the data stream API, assuming the correct permissions and product origin flag.

One interesting implementation detail is that the SystemDataStreamDescriptor manages its own templates for the data stream, so although they have names, they are never listed in the index template or component template APIs.

The descriptor also provides names for the thread pools that Elasticsearch should use to read, search, or modify the descriptor’s indices.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	SystemDataStreamDescriptor.Type

Constructor Summary

Constructors

Constructor	Description
SystemDataStreamDescriptor(String dataStreamName, String description, SystemDataStreamDescriptor.Type type, ComposableIndexTemplate composableIndexTemplate, Map<String,ComponentTemplate> componentTemplates, List<String> allowedElasticProductOrigins, ExecutorNames executorNames)	Creates a new descriptor for a system data descriptor

Method Summary

Modifier and Type	Method	Description
List<String>	getAllowedElasticProductOrigins()
List<String>	getBackingIndexNames(Metadata metadata)	Retrieve backing indices for this system data stream
String	getBackingIndexPattern()
Map<String,ComponentTemplate>	getComponentTemplates()
ComposableIndexTemplate	getComposableIndexTemplate()
String	getDataStreamName()
String	getDescription()
ExecutorNames	getThreadPoolNames()	Get the names of the thread pools that should be used for operations on this data stream.
boolean	isExternal()

Methods inherited from class java.lang.Object

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

Constructor Details

SystemDataStreamDescriptor

public SystemDataStreamDescriptor(String dataStreamName,
 String description,
 SystemDataStreamDescriptor.Type type,
 ComposableIndexTemplate composableIndexTemplate,
 Map<String,ComponentTemplate> componentTemplates,
 List<String> allowedElasticProductOrigins,
 ExecutorNames executorNames)

Creates a new descriptor for a system data descriptor

Parameters:

dataStreamName - the name of the data stream. Must not be null

description - a brief description of what the data stream is used for. Must not be null

type - the SystemDataStreamDescriptor.Type of the data stream which determines how the data stream can be accessed. Must not be null

composableIndexTemplate - the ComposableIndexTemplate that contains the mappings and settings for the data stream. Must not be null

componentTemplates - a map that contains ComponentTemplate instances corresponding to those references in the ComposableIndexTemplate

allowedElasticProductOrigins - a list of product origin values that are allowed to access this data stream if the type is SystemDataStreamDescriptor.Type.EXTERNAL. Must not be null

executorNames - thread pools that should be used for operations on the system data stream

Method Details

getDataStreamName

public String getDataStreamName()

getBackingIndexNames

public List<String> getBackingIndexNames(Metadata metadata)

Retrieve backing indices for this system data stream

Parameters:

metadata - Metadata in which to look for indices

Returns:

List of names of backing indices

getDescription

public String getDescription()

getComposableIndexTemplate

public ComposableIndexTemplate getComposableIndexTemplate()

isExternal

public boolean isExternal()

getBackingIndexPattern

public String getBackingIndexPattern()

getAllowedElasticProductOrigins

public List<String> getAllowedElasticProductOrigins()

getComponentTemplates

public Map<String,ComponentTemplate> getComponentTemplates()

getThreadPoolNames

public ExecutorNames getThreadPoolNames()

Get the names of the thread pools that should be used for operations on this data stream.

Returns:

Names for get, search, and write executors.