File Coverage

blib/lib/OpenSearch/Client/Core/3_0/Direct.pm

Criterion	Covered	Total	%
statement	9	57	15.7
branch			n/a
condition	0	12	0.0
subroutine	3	43	6.9
pod	2	2	100.0
total	14	114	12.2

# OpenSearch::Client is an unofficial client for OpenSearch.
# It is derived from Search::Elasticsearch version 7.714
# License details from the original work are contained in the
# NOTICE file distributed with this work.
#
#-----------------------------------------------------------------------
# OpenSearch::Client
#-----------------------------------------------------------------------
# Copyright 2026 Mark Dootson
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

package OpenSearch::Client::Core::3_0::Direct;
$OpenSearch::Client::Core::3_0::Direct::VERSION = '3.007002';
use Moo;
with 'OpenSearch::Client::Core::3_0::Role::API';
with 'OpenSearch::Client::Role::Client::Direct';

use OpenSearch::Client::Util qw(parse_params is_compat);
use namespace::clean;

sub _namespace {__PACKAGE__}


has 'asynchronous_search'        => ( is => 'lazy', init_arg => undef );
has 'cat'                        => ( is => 'lazy', init_arg => undef );
has 'cluster'                    => ( is => 'lazy', init_arg => undef );
has 'dangling_indices'           => ( is => 'lazy', init_arg => undef );
has 'flow_framework'             => ( is => 'lazy', init_arg => undef );
has 'geospatial'                 => ( is => 'lazy', init_arg => undef );
has 'indices'                    => ( is => 'lazy', init_arg => undef );
has 'ingest'                     => ( is => 'lazy', init_arg => undef );
has 'ingestion'                  => ( is => 'lazy', init_arg => undef );
has 'insights'                   => ( is => 'lazy', init_arg => undef );
has 'ism'                        => ( is => 'lazy', init_arg => undef );
has 'knn'                        => ( is => 'lazy', init_arg => undef );
has 'list'                       => ( is => 'lazy', init_arg => undef );
has 'ltr'                        => ( is => 'lazy', init_arg => undef );
has 'ml'                         => ( is => 'lazy', init_arg => undef );
has 'neural'                     => ( is => 'lazy', init_arg => undef );
has 'nodes'                      => ( is => 'lazy', init_arg => undef );
has 'notifications'              => ( is => 'lazy', init_arg => undef );
has 'observability'              => ( is => 'lazy', init_arg => undef );
has 'ppl'                        => ( is => 'lazy', init_arg => undef );
has 'query'                      => ( is => 'lazy', init_arg => undef );
has 'remote_store'               => ( is => 'lazy', init_arg => undef );
has 'replication'                => ( is => 'lazy', init_arg => undef );
has 'rollups'                    => ( is => 'lazy', init_arg => undef );
has 'search_pipeline'            => ( is => 'lazy', init_arg => undef );
has 'search_relevance'           => ( is => 'lazy', init_arg => undef );
has 'security'                   => ( is => 'lazy', init_arg => undef );
has 'security_analytics'         => ( is => 'lazy', init_arg => undef );
has 'sm'                         => ( is => 'lazy', init_arg => undef );
has 'snapshot'                   => ( is => 'lazy', init_arg => undef );
has 'sql'                        => ( is => 'lazy', init_arg => undef );
has 'tasks'                      => ( is => 'lazy', init_arg => undef );
has 'transforms'                 => ( is => 'lazy', init_arg => undef );
has 'ubi'                        => ( is => 'lazy', init_arg => undef );
has 'wlm'                        => ( is => 'lazy', init_arg => undef );
has 'bulk_helper_class'    => ( is => 'rw' );
has 'scroll_helper_class'  => ( is => 'rw' );
has '_bulk_class'          => ( is => 'lazy' );
has '_scroll_class'        => ( is => 'lazy' );

#===================================
sub _build__bulk_class {
#===================================
    my $self       = shift;
    my $bulk_class = $self->bulk_helper_class
        || 'Core::' . $self->api_version . '::Helper::Bulk';
    $self->_build_helper( 'bulk', $bulk_class );
}

#===================================
sub _build__scroll_class {
#===================================
    my $self         = shift;
    my $scroll_class = $self->scroll_helper_class
        || 'Core::' . $self->api_version . '::Helper::Scroll';
    $self->_build_helper( 'scroll', $scroll_class );
}

#===================================
sub bulk_helper {
#===================================
    my ( $self, $params ) = parse_params(@_);
    $params->{os} ||= $self;
    $self->_bulk_class->new($params);
}

#===================================
sub scroll_helper {
#===================================
    my ( $self, $params ) = parse_params(@_);
    $params->{os} ||= $self;
    $self->_scroll_class->new($params);
}


sub _build_asynchronous_search   { shift->_build_namespace('AsyncSearch') }
sub _build_cat                   { shift->_build_namespace('Cat') }
sub _build_cluster               { shift->_build_namespace('Cluster') }
sub _build_dangling_indices      { shift->_build_namespace('DanglingIndices') }
sub _build_flow_framework        { shift->_build_namespace('FlowFramework') }
sub _build_geospatial            { shift->_build_namespace('GeoSpatial') }
sub _build_indices               { shift->_build_namespace('Indices') }
sub _build_ingest                { shift->_build_namespace('Ingest') }
sub _build_ingestion             { shift->_build_namespace('Ingestion') }
sub _build_insights              { shift->_build_namespace('Insights') }
sub _build_ism                   { shift->_build_namespace('ISM') }
sub _build_knn                   { shift->_build_namespace('KNN') }
sub _build_list                  { shift->_build_namespace('List') }
sub _build_ltr                   { shift->_build_namespace('LTR') }
sub _build_ml                    { shift->_build_namespace('ML') }
sub _build_neural                { shift->_build_namespace('Neural') }
sub _build_nodes                 { shift->_build_namespace('Nodes') }
sub _build_notifications         { shift->_build_namespace('Notifications') }
sub _build_observability         { shift->_build_namespace('Observability') }
sub _build_ppl                   { shift->_build_namespace('PPL') }
sub _build_query                 { shift->_build_namespace('Query') }
sub _build_remote_store          { shift->_build_namespace('RemoteStore') }
sub _build_replication           { shift->_build_namespace('Replication') }
sub _build_rollups               { shift->_build_namespace('Rollups') }
sub _build_search_pipeline       { shift->_build_namespace('SearchPipeline') }
sub _build_search_relevance      { shift->_build_namespace('SearchRelevance') }
sub _build_security              { shift->_build_namespace('Security') }
sub _build_security_analytics    { shift->_build_namespace('SecurityAnalytics') }
sub _build_sm                    { shift->_build_namespace('SnapshotManagement') }
sub _build_snapshot              { shift->_build_namespace('Snapshot') }
sub _build_sql                   { shift->_build_namespace('SQL') }
sub _build_tasks                 { shift->_build_namespace('Tasks') }
sub _build_transforms            { shift->_build_namespace('Transforms') }
sub _build_ubi                   { shift->_build_namespace('UBI') }
sub _build_wlm                   { shift->_build_namespace('WLM') }

__PACKAGE__->_install_api('_core');

1;

__END__