Package io.vertigo.datafactory.plugins.search.elasticsearch.client

Class ClientESSearchServicesPlugin

  • All Implemented Interfaces:
    io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Plugin, SearchServicesPlugin
    public final class ClientESSearchServicesPlugin
extends Object
implements SearchServicesPlugin, io.vertigo.core.node.component.Activeable
    Gestion de la connexion au serveur Solr de manière transactionnel.
    Author:
    dchallas, npiedeloup

    • Field Detail

      • SUFFIX_SORT_FIELD

        public static final String SUFFIX_SORT_FIELD
        field suffix for keyword fields added by this plugin.
        See Also:
        Constant Field Values

    • Constructor Detail

      • ClientESSearchServicesPlugin

        @Inject
public ClientESSearchServicesPlugin​(String envIndexPrefix,
                                    int defaultMaxRows,
                                    String configFile,
                                    Optional<String> connectorNameOpt,
                                    List<io.vertigo.connectors.elasticsearch.ElasticSearchConnector> elasticSearchConnectors,
                                    CodecManager codecManager,
                                    io.vertigo.datamodel.smarttype.SmartTypeManager smartTypeManager,
                                    io.vertigo.core.resource.ResourceManager resourceManager)
        Constructor.
        Parameters:
        envIndexPrefix - ES index name
        indexNameIsPrefix - indexName use as prefix
        defaultMaxRows - Nombre de lignes
        codecManager - Manager de codec
        configFile - Fichier de configuration des indexs
        resourceManager - Manager des resources

    • Method Detail

      • start

        public void start()
        Specified by:
        start in interface io.vertigo.core.node.component.Activeable

      • stop

        public void stop()
        Specified by:
        stop in interface io.vertigo.core.node.component.Activeable

      • putAll

        public <S extends io.vertigo.datamodel.structure.model.KeyConcept,​I extends io.vertigo.datamodel.structure.model.DtObject> void putAll​(SearchIndexDefinition indexDefinition,
                                                                                                                                             Collection<SearchIndex<S,​I>> indexCollection)
        Ajout de plusieurs ressources à l'index. Si les éléments étaient déjà dans l'index ils sont remplacés.
        Specified by:
        putAll in interface SearchServicesPlugin
        Type Parameters:
        S - Type du keyConcept métier indexé
        I - Type de l'objet représentant l'index
        Parameters:
        indexDefinition - Type de l'index
        indexCollection - Liste des objets à pousser dans l'index

      • put

        public <S extends io.vertigo.datamodel.structure.model.KeyConcept,​I extends io.vertigo.datamodel.structure.model.DtObject> void put​(SearchIndexDefinition indexDefinition,
                                                                                                                                          SearchIndex<S,​I> index)
        Ajout d'une ressource à l'index. Si l'élément était déjà dans l'index il est remplacé.
        Specified by:
        put in interface SearchServicesPlugin
        Type Parameters:
        S - Type du keyConcept métier indexé
        I - Type de l'objet représentant l'index
        Parameters:
        indexDefinition - Type de l'index
        index - Objet à pousser dans l'index

      • remove

        public <S extends io.vertigo.datamodel.structure.model.KeyConcept> void remove​(SearchIndexDefinition indexDefinition,
                                                                               io.vertigo.datamodel.structure.model.UID<S> uri)
        Suppression d'une ressource de l'index.
        Specified by:
        remove in interface SearchServicesPlugin
        Type Parameters:
        S - Type du keyConcept métier indexé
        Parameters:
        indexDefinition - Type de l'index
        uri - UID de la ressource à supprimer

      • loadList

        public <R extends io.vertigo.datamodel.structure.model.DtObject> FacetedQueryResult<R,​SearchQuery> loadList​(List<SearchIndexDefinition> indexDefinitions,
                                                                                                                  SearchQuery searchQuery,
                                                                                                                  io.vertigo.datamodel.structure.model.DtListState listState)
        Récupération du résultat issu d'une requête.
        Specified by:
        loadList in interface SearchServicesPlugin
        Type Parameters:
        R - Type de l'objet resultant de la recherche
        searchQuery - critères initiaux
        listState - Etat de la liste (tri et pagination)
        Returns:
        Résultat correspondant à la requête

      • remove

        public void remove​(SearchIndexDefinition indexDefinition,
                   ListFilter listFilter)
        Suppression des données correspondant à un filtre.
        Specified by:
        remove in interface SearchServicesPlugin
        Parameters:
        indexDefinition - Type de l'index
        listFilter - Filtre des éléments à supprimer

      • checkClusterHealth

        public io.vertigo.core.analytics.health.HealthMeasure checkClusterHealth()