File Coverage

blib/lib/ArangoDB2/Admin.pm

Criterion	Covered	Total	%
statement	12	61	19.6
branch	0	2	0.0
condition			n/a
subroutine	4	34	11.7
pod	30	30	100.0
total	46	127	36.2

package ArangoDB2::Admin;

use strict;
use warnings;

use base qw(
    ArangoDB2::Base
);

use JSON::XS;

my $JSON = JSON::XS->new->utf8;



###############
# API METHODS #
###############

# echo
#
# GET /_admin/echo
sub echo
{
    my($self) = @_;
    # make request
    return $self->arango->http->get('/_admin/echo');
}

# execute
#
# POST /_admin/execute
sub execute
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['program','returnAsJSON']);
    my $program = delete $args->{program};
    # make request
    return $self->arango->http->post(
        '/_admin/execute',
        $args,
        $program,
    );
}

# log
#
# GET /_admin/log
sub log
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, [qw(
        upto level start size offset search sort
    )]);
    # make request
    return $self->arango->http->get('/_admin/log', $args);
}

# routingReload
#
# POST /_admin/routing/reload
sub routingReload
{
    my($self) = @_;
    # make request
    return $self->arango->http->post('/_admin/routing/reload');
}

# serverRole
#
# GET /_admin/server/role
sub serverRole
{
    my($self) = @_;
    # make request
    return $self->arango->http->get('/_admin/server/role');
}

# shutdown
#
# GET /_admin/shutdown
sub shutdown
{
    my($self) = @_;
    # make request
    return $self->arango->http->get('/_admin/shutdown');
}

# statistics
#
# GET /_admin/statistics
sub statistics
{
    my($self) = @_;
    # make request
    return $self->arango->http->get('/_admin/statistics');
}

# statisticsDescription
#
# GET /_admin/statistics-description
sub statisticsDescription
{
    my($self) = @_;
    # make request
    return $self->arango->http->get('/_admin/statistics-description');
}

# test
#
# POST /_admin/test
sub test
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['tests']);
    # make request
    return $self->arango->http->post('/_admin/test', $args->{tests});
}

# time
#
# GET /_admin/time
sub time
{
    my($self) = @_;
    # make request
    return $self->arango->http->get('/_admin/time');
}

# walFlush
#
# PUT /_admin/wal/flush
sub walFlush
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, ['waitForSync', 'waitForCollector']);
    # make request
    return $self->arango->http->put('/_admin/wal/flush', $args);
}

# walProperties
#
# GET /_admin/wal/properties
# PUT /_admin/wal/properties
sub walProperties
{
    my($self, $args) = @_;
    # process args
    $args = $self->_build_args($args, [qw(
        allowOversizeEntries logfileSize historicLogfiles
        reserveLogfiles throttleWait throttleWhenPending
    )]);
    # request path
    my $path = '/_admin/wal/properties';
    # make request
    return $args
        ? $self->arango->http->put($path, undef, $JSON->encode($args))
        : $self->arango->http->get($path);
}

####################
# PROPERTY METHODS #
####################

sub allowOversizeEntries { shift->_get_set_bool('allowOversizeEntries', @_) }
sub level { shift->_get_set('level', @_) }
sub logfileSize { shift->_get_set('logfileSize', @_) }
sub historicLogfiles { shift->_get_set('historicLogfiles', @_) }
sub offset { shift->_get_set('offset', @_) }
sub program { shift->_get_set('program', @_) }
sub reserveLogfiles { shift->_get_set('reserveLogfiles', @_) }
sub returnAsJSON { shift->_get_set_bool('returnAsJSON', @_) }
sub search { shift->_get_set('search', @_) }
sub size { shift->_get_set('size', @_) }
sub sort { shift->_get_set('sort', @_) }
sub start { shift->_get_set('start', @_) }
sub tests { shift->_get_set('tests', @_) }
sub throttleWait { shift->_get_set('throttleWait', @_) }
sub throttleWhenPending { shift->_get_set('throttleWhenPending', @_) }
sub upto { shift->_get_set('upto', @_) }
sub waitForCollector { shift->_get_set_bool('waitForCollector', @_) }
sub waitForSync { shift->_get_set_bool('waitForSync', @_) }

1;

__END__