NAME

Data::AnyXfer::Elastic::ServerDict - Logic for server selection and metadata lookup

SYNOPSIS

            

              
              
use Data::AnyXfer::Elastic::ServerDict ();
# Create dictionary from env
my $dict = Data::AnyXfer::Elastic::ServerDict->from_env;
# Or manually add server definitions
my $dict = Data::AnyXfer::Elastic::ServerDict->new;
$dict->add_server_definition($def);
# Now lookup information needed for connecting or importing
# data
my @nodes = $dict->all_testing_nodes;
my @nodes = $dict->all_development_nodes;
my @nodes = $dict->get_silo_nodes('public_data');
            
          

DESCRIPTION

This class provides the metadata and connection info lookup logic for Data::AnyXfer::Elastic to locate or populate your Elasticsearch instances.

METHODS

from_env

            

              
              
# Create dictionary from env
my $dict = Data::AnyXfer::Elastic::ServerDict->from_env;
            
          

Creates a server dict using "load_from_env" in Data::AnyXfer::Elastic::ServerDefinition.

Returns a new Data::AnyXfer::Elastic::ServerDict instance.

add_server_definition

            

              
              
$dict->add_server_definition(
  Data::AnyXfer::Elastic::ServerDefinition->new( ... )
);
            
          

Adds a server definition to the

LOOKUP METHODS

all_production_nodes

            

              
              
my @nodes = $dict->all_production_nodes;
            
          

Return connection details for all elasticsearch nodes in the production environment.

all_development_nodes

            

              
              
my @nodes = $dict->all_development_nodes;
            
          

Return connection details for all elasticsearch nodes in the development environment.

all_testing_nodes

            

              
              
my $nodes = $dict->all_testing_nodes;
            
          

Return connection details for all elasticsearch nodes in the testing environment.

list_silos

            

              
              
my @silo_names = $dict->list_silos;
            
          

Retrieves all known silo names..

get_silo_nodes

            

              
              
my @node_groups = $dict->get_silo_nodes($silo_name);
            
          

Retrieves groups of nodes assigned to clusters tagged with the given silo.

get_silo_write_nodes

            

              
              
my @node_groups = $dict->get_silo_write_nodes($silo_name);
            
          

Retrieves groups of nodes assigned to clusters tagged with the given silo, like get_silo_nodes but looks for a cluser_nodes definition, before falling back to nodes.

get_node_version

            

              
              
my $version = $dict->get_node_version('test-es-1.example.com:9200');
            
          

Returns the target node's elasticsearch version as defined by all matching Data::AnyXfer::Elastic::ServerDefinition instances belonging to this ServerDict.

COPYRIGHT

This software is copyright (c) 2019, Anthony Lucas.

This is free software; you can redistribute it and/or modify it under the same terms as the Perl 5 programming language system itself.

cpanm Data::AnyXfer

perl -MCPAN -e shell
install Data::AnyXfer