AnyEvent-InfluxDB
view release on metacpan or search on metacpan
fill => 'none',
order_by => 'time DESC',
limit => 10,
offset => 3,
# downsample result to another database, retention policy and measurement
into => 'otherdb."default".cpu_load_per5m',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to select data: @_");
}
);
my $results = $cv->recv;
for my $row ( @{ $results } ) {
print "Measurement: $row->{name}\n";
print "Values:\n";
for my $value ( @{ $row->{values} || [] } ) {
# or query created from arguments
database => "mydb",
# retention policy parameters
duration => '7d',
shard_duration => '30m',
replication => 3,
name => 'oneweek',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create database: @_");
}
);
$cv->recv;
Creates database specified by "database" argument.
If one of retention policy parameters is specified then the database
drop_database
$cv = AE::cv;
$db->drop_database(
# raw query
q => "DROP DATABASE mydb",
# or query created from arguments
database => "mydb",
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop database: @_");
}
);
$cv->recv;
Drops database specified by "database" argument.
The required "on_success" code reference is executed if request was
# raw query
q => "DROP SERIES FROM cpu_load WHERE host = 'server02'",
# or query created from arguments
measurement => 'cpu_load',
where => q{host = 'server02'},
# multiple measurements can also be specified
measurements => [qw( cpu_load cpu_temp )],
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop measurement: @_");
}
);
$cv->recv;
Drops series from single measurement "measurement" (or many using
"measurements") and/or filtered by "where" clause from database
"database".
$db->delete_series(
database => 'mydb',
# raw query
q => "DELETE FROM cpu_load WHERE host = 'server02' AND time < '2016-01-01'",
# or query created from arguments
measurement => 'cpu_load',
where => q{host = 'server02' AND time < '2016-01-01'},
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop measurement: @_");
}
);
$cv->recv;
Deletes all points from a measurement "measurement" and/or filtered by
"where" clause from database "database".
$cv = AE::cv;
$db->drop_measurement(
database => 'mydb',
# raw query
q => "DROP MEASUREMENT cpu_load",
# or query created from arguments
measurement => 'cpu_load',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop measurement: @_");
}
);
$cv->recv;
Drops measurement "measurement".
The required "on_success" code reference is executed if request was
$cv = AE::cv;
$db->drop_shard(
database => 'mydb',
# raw query
q => "DROP SHARD 1",
# or query created from arguments
id => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop measurement: @_");
}
);
$cv->recv;
Drops shard identified by id number "id".
The required "on_success" code reference is executed if request was
"duration" for all currently running queries.
The required "on_success" code reference is executed if request was
successful, otherwise executes the required "on_error" code reference.
kill_query
$cv = AE::cv;
$db->kill_query(
id => 36,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to kill query: @_");
}
);
$cv->recv;
Stops a running query identified by id number "id".
The required "on_success" code reference is executed if request was
q => "CREATE RETENTION POLICY last_day ON mydb DURATION 1d REPLICATION 1",
# or query created from arguments
name => 'last_day',
database => 'mydb',
duration => '1d',
shard_duration => '168h',
replication => 1,
default => 0,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create retention policy: @_");
}
);
$cv->recv;
Creates new retention policy named by "name" on database "database" with
duration "duration", shard group duration "shard_duration" and
replication factor "replication". If "default" is provided and true the
# or query created from arguments
name => 'last_day',
database => 'mydb',
duration => '1d',
shard_duration => '12h',
replication => 1,
default => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to alter retention policy: @_");
}
);
$cv->recv;
Modifies retention policy named by "name" on database "database". At
least one of duration "duration", replication factor "replication" or
flag "default" must be set.
drop_retention_policy
$cv = AE::cv;
$db->drop_retention_policy(
# raw query
q => "DROP RETENTION POLICY last_day ON mydb",
# or query created from arguments
name => "last_day",
database => "mydb",
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop retention policy: @_");
}
);
$cv->recv;
Drops specified by "name" retention policy on database "database".
The required "on_success" code reference is executed if request was
show_retention_policies
$cv = AE::cv;
$db->show_retention_policies(
# raw query
q => "SHOW RETENTION POLICIES ON mydb",
# or query created from arguments
database => 'mydb',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list retention policies: @_");
}
);
my @retention_policies = $cv->recv;
for my $rp ( @retention_policies ) {
print "Name: $rp->{name}\n";
print "Duration: $rp->{duration}\n";
print "Shard group duration: $rp->{shardGroupDuration}\n";
# or query created from arguments
measurement => 'cpu_load',
where => q{host = 'server02'},
order_by => 'region',
limit => 10,
offset => 3,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list series: @_");
}
);
my @series = $cv->recv;
print "$_\n" for @series;
Returns names of series from database "database" using optional
measurement "measurement" and optional "where" clause.
# or query created from arguments
measurement => '/cpu_load.*/',
where => q{host = 'server02'},
order_by => 'region',
limit => 10,
offset => 3,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list measurements: @_");
}
);
my @measurements = $cv->recv;
print "$_\n" for @measurements;
Returns names of measurements from database "database", optionally
filtered with regular expression "measurement" and optional "where"
# raw query
q => "SHOW TAG KEYS FROM cpu_load WHERE host = 'server02' LIMIT 10 OFFSET 3",
# or query created from arguments
measurement => 'cpu_load',
where => q{host = 'server02'},
limit => 10,
offset => 3,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list tag keys: @_");
}
);
my $tag_keys = $cv->recv;
for my $measurement ( sort keys %{ $tag_keys } ) {
print "Measurement: $measurement\n";
print " * $_\n" for @{ $tag_keys->{$measurement} };
}
measurement => 'cpu_load',
# single key
key => q{"host"},
# or a list of keys
keys => [qw( "host" "region" )],
limit => 10,
offset => 3,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list tag values: @_");
}
);
my $tag_values = $cv->recv;
for my $measurement ( sort keys %{ $tag_values } ) {
print "Measurement: $measurement\n";
for my $tag_key ( sort keys %{ $tag_values->{$measurement} } ) {
print " Tag key: $tag_key\n";
$cv = AE::cv;
$db->show_field_keys(
database => 'mydb',
# raw query
q => "SHOW FIELD KEYS FROM cpu_load",
# or query created from arguments
measurement => 'cpu_load',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list field keys: @_");
}
);
my $field_keys = $cv->recv;
for my $measurement ( sort keys %{ $field_keys } ) {
print "Measurement: $measurement\n";
for my $field ( @{ $field_keys->{$measurement} } ) {
print " Key: $field->{key}\n";
$cv = AE::cv;
$db->create_user(
# raw query
q => "CREATE USER jdoe WITH PASSWORD 'mypassword' WITH ALL PRIVILEGES",
# or query created from arguments
username => 'jdoe',
password => 'mypassword',
all_privileges => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create user: @_");
}
);
$cv->recv;
Creates user with "username" and "password". If flag "all_privileges" is
set to true created user will be granted cluster administration
privileges.
set_user_password
$cv = AE::cv;
$db->set_user_password(
# raw query
q => "SET PASSWORD FOR jdoe = 'otherpassword'",
# or query created from arguments
username => 'jdoe',
password => 'otherpassword',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to set password: @_");
}
);
$cv->recv;
Sets password to "password" for the user identified by "username".
Note: "password" will be automatically enclosed in single quotes.
# or query created from arguments
username => 'jdoe',
# privileges at single database
database => 'mydb',
access => 'ALL',
# or to grant cluster administration privileges
all_privileges => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to grant privileges: @_");
}
);
$cv->recv;
Grants to user "username" access "access" on database "database". If
flag "all_privileges" is set it grants cluster administration privileges
instead.
show_grants
$cv = AE::cv;
$db->show_grants(
# raw query
q => "SHOW GRANTS FOR jdoe",
# or query created from arguments
username => 'jdoe',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list users: @_");
}
);
my @grants = $cv->recv;
for my $g ( @grants ) {
print "Database: $g->{database}\n";
print "Privilege: $g->{privilege}\n";
}
# or query created from arguments
username => 'jdoe',
# privileges at single database
database => 'mydb',
access => 'WRITE',
# or to revoke cluster administration privileges
all_privileges => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to revoke privileges: @_");
}
);
$cv->recv;
Revokes from user "username" access "access" on database "database". If
flag "all_privileges" is set it revokes cluster administration
privileges instead.
drop_user
$cv = AE::cv;
$db->drop_user(
# raw query
q => "DROP USER jdoe",
# or query created from arguments
username => 'jdoe',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop user: @_");
}
);
$cv->recv;
Drops user "username".
The required "on_success" code reference is executed if request was
.' SELECT MEAN(value) INTO "cpu_load_per5m" FROM cpu_load GROUP BY time(5m)'
.' END',
# or query created from arguments
database => 'mydb',
name => 'per5minutes',
every => '10s',
for => '2m',
query => 'SELECT MEAN(value) INTO "cpu_load_per5m" FROM cpu_load GROUP BY time(5m)',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create continuous query: @_");
}
);
$cv->recv;
Creates new continuous query named by "name" on database "database"
using query "query". Optional "every" and "for" define the resampling
times.
drop_continuous_query
$cv = AE::cv;
$db->drop_continuous_query(
# raw query
q => 'DROP CONTINUOUS QUERY per5minutes ON mydb',
# or query created from arguments
database => 'mydb',
name => 'per5minutes',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop continuous query: @_");
}
);
$cv->recv;
Drops continuous query named by "name" on database "database".
The required "on_success" code reference is executed if request was
# or query created from arguments
name => q{alldata},
database => q{"mydb"},
rp => q{"default"},
mode => "ANY",
destinations => [
q{'udp://h1.example.com:9090'},
q{'udp://h2.example.com:9090'}
],
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create subscription: @_");
}
);
$cv->recv;
Creates a new subscription "name" on database "database" with retention
policy "rp" with mode "mode" to destinations provided as "destinations".
The "destinations" could be either a single scalar value or array
$cv = AE::cv;
$db->drop_subscription(
# raw query
q => 'DROP SUBSCRIPTION "alldata" ON "mydb"."default"',
# or query created from arguments
name => q{"alldata"},
database => q{"mydb"},
rp => q{"default"},
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop subscription: @_");
}
);
$cv->recv;
Drops subscription "name" on database "database" with retention policy
"rp".
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
fill => 'none',
order_by => 'time DESC',
limit => 10,
offset => 3,
# downsample result to another database, retention policy and measurement
into => 'otherdb."default".cpu_load_per5m',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to select data: @_");
}
);
my $results = $cv->recv;
for my $row ( @{ $results } ) {
print "Measurement: $row->{name}\n";
print "Values:\n";
for my $value ( @{ $row->{values} || [] } ) {
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# or query created from arguments
database => "mydb",
# retention policy parameters
duration => '7d',
shard_duration => '30m',
replication => 3,
name => 'oneweek',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create database: @_");
}
);
$cv->recv;
Creates database specified by C<database> argument.
If one of retention policy parameters is specified then the database will be
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
=head3 drop_database
$cv = AE::cv;
$db->drop_database(
# raw query
q => "DROP DATABASE mydb",
# or query created from arguments
database => "mydb",
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop database: @_");
}
);
$cv->recv;
Drops database specified by C<database> argument.
The required C<on_success> code reference is executed if request was successful,
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# raw query
q => "DROP SERIES FROM cpu_load WHERE host = 'server02'",
# or query created from arguments
measurement => 'cpu_load',
where => q{host = 'server02'},
# multiple measurements can also be specified
measurements => [qw( cpu_load cpu_temp )],
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop measurement: @_");
}
);
$cv->recv;
Drops series from single measurement C<measurement> (or many using C<measurements>)
and/or filtered by C<where> clause from database C<database>.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$db->delete_series(
database => 'mydb',
# raw query
q => "DELETE FROM cpu_load WHERE host = 'server02' AND time < '2016-01-01'",
# or query created from arguments
measurement => 'cpu_load',
where => q{host = 'server02' AND time < '2016-01-01'},
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop measurement: @_");
}
);
$cv->recv;
Deletes all points from a measurement C<measurement>
and/or filtered by C<where> clause from database C<database>.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$cv = AE::cv;
$db->drop_measurement(
database => 'mydb',
# raw query
q => "DROP MEASUREMENT cpu_load",
# or query created from arguments
measurement => 'cpu_load',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop measurement: @_");
}
);
$cv->recv;
Drops measurement C<measurement>.
The required C<on_success> code reference is executed if request was successful,
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$cv = AE::cv;
$db->drop_shard(
database => 'mydb',
# raw query
q => "DROP SHARD 1",
# or query created from arguments
id => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop measurement: @_");
}
);
$cv->recv;
Drops shard identified by id number C<id>.
The required C<on_success> code reference is executed if request was successful,
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
The required C<on_success> code reference is executed if request was successful,
otherwise executes the required C<on_error> code reference.
=head3 kill_query
$cv = AE::cv;
$db->kill_query(
id => 36,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to kill query: @_");
}
);
$cv->recv;
Stops a running query identified by id number C<id>.
The required C<on_success> code reference is executed if request was successful,
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
q => "CREATE RETENTION POLICY last_day ON mydb DURATION 1d REPLICATION 1",
# or query created from arguments
name => 'last_day',
database => 'mydb',
duration => '1d',
shard_duration => '168h',
replication => 1,
default => 0,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create retention policy: @_");
}
);
$cv->recv;
Creates new retention policy named by C<name> on database C<database> with
duration C<duration>, shard group duration C<shard_duration> and replication
factor C<replication>. If C<default> is provided and true the created retention
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# or query created from arguments
name => 'last_day',
database => 'mydb',
duration => '1d',
shard_duration => '12h',
replication => 1,
default => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to alter retention policy: @_");
}
);
$cv->recv;
Modifies retention policy named by C<name> on database C<database>. At least one
of duration C<duration>, replication factor C<replication> or flag C<default>
must be set.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$cv = AE::cv;
$db->drop_retention_policy(
# raw query
q => "DROP RETENTION POLICY last_day ON mydb",
# or query created from arguments
name => "last_day",
database => "mydb",
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop retention policy: @_");
}
);
$cv->recv;
Drops specified by C<name> retention policy on database C<database>.
The required C<on_success> code reference is executed if request was successful,
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
=head3 show_retention_policies
$cv = AE::cv;
$db->show_retention_policies(
# raw query
q => "SHOW RETENTION POLICIES ON mydb",
# or query created from arguments
database => 'mydb',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list retention policies: @_");
}
);
my @retention_policies = $cv->recv;
for my $rp ( @retention_policies ) {
print "Name: $rp->{name}\n";
print "Duration: $rp->{duration}\n";
print "Shard group duration: $rp->{shardGroupDuration}\n";
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# or query created from arguments
measurement => 'cpu_load',
where => q{host = 'server02'},
order_by => 'region',
limit => 10,
offset => 3,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list series: @_");
}
);
my @series = $cv->recv;
print "$_\n" for @series;
Returns names of series from database C<database> using optional measurement C<measurement>
and optional C<where> clause.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# or query created from arguments
measurement => '/cpu_load.*/',
where => q{host = 'server02'},
order_by => 'region',
limit => 10,
offset => 3,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list measurements: @_");
}
);
my @measurements = $cv->recv;
print "$_\n" for @measurements;
Returns names of measurements from database C<database>, optionally filtered with
regular expression C<measurement> and optional C<where> clause.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# raw query
q => "SHOW TAG KEYS FROM cpu_load WHERE host = 'server02' LIMIT 10 OFFSET 3",
# or query created from arguments
measurement => 'cpu_load',
where => q{host = 'server02'},
limit => 10,
offset => 3,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list tag keys: @_");
}
);
my $tag_keys = $cv->recv;
for my $measurement ( sort keys %{ $tag_keys } ) {
print "Measurement: $measurement\n";
print " * $_\n" for @{ $tag_keys->{$measurement} };
}
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
measurement => 'cpu_load',
# single key
key => q{"host"},
# or a list of keys
keys => [qw( "host" "region" )],
limit => 10,
offset => 3,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list tag values: @_");
}
);
my $tag_values = $cv->recv;
for my $measurement ( sort keys %{ $tag_values } ) {
print "Measurement: $measurement\n";
for my $tag_key ( sort keys %{ $tag_values->{$measurement} } ) {
print " Tag key: $tag_key\n";
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$cv = AE::cv;
$db->show_field_keys(
database => 'mydb',
# raw query
q => "SHOW FIELD KEYS FROM cpu_load",
# or query created from arguments
measurement => 'cpu_load',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list field keys: @_");
}
);
my $field_keys = $cv->recv;
for my $measurement ( sort keys %{ $field_keys } ) {
print "Measurement: $measurement\n";
for my $field ( @{ $field_keys->{$measurement} } ) {
print " Key: $field->{key}\n";
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$cv = AE::cv;
$db->create_user(
# raw query
q => "CREATE USER jdoe WITH PASSWORD 'mypassword' WITH ALL PRIVILEGES",
# or query created from arguments
username => 'jdoe',
password => 'mypassword',
all_privileges => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create user: @_");
}
);
$cv->recv;
Creates user with C<username> and C<password>. If flag C<all_privileges> is set
to true created user will be granted cluster administration privileges.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$cv = AE::cv;
$db->set_user_password(
# raw query
q => "SET PASSWORD FOR jdoe = 'otherpassword'",
# or query created from arguments
username => 'jdoe',
password => 'otherpassword',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to set password: @_");
}
);
$cv->recv;
Sets password to C<password> for the user identified by C<username>.
Note: C<password> will be automatically enclosed in single quotes.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# or query created from arguments
username => 'jdoe',
# privileges at single database
database => 'mydb',
access => 'ALL',
# or to grant cluster administration privileges
all_privileges => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to grant privileges: @_");
}
);
$cv->recv;
Grants to user C<username> access C<access> on database C<database>.
If flag C<all_privileges> is set it grants cluster administration privileges
instead.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
=head3 show_grants
$cv = AE::cv;
$db->show_grants(
# raw query
q => "SHOW GRANTS FOR jdoe",
# or query created from arguments
username => 'jdoe',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to list users: @_");
}
);
my @grants = $cv->recv;
for my $g ( @grants ) {
print "Database: $g->{database}\n";
print "Privilege: $g->{privilege}\n";
}
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# or query created from arguments
username => 'jdoe',
# privileges at single database
database => 'mydb',
access => 'WRITE',
# or to revoke cluster administration privileges
all_privileges => 1,
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to revoke privileges: @_");
}
);
$cv->recv;
Revokes from user C<username> access C<access> on database C<database>.
If flag C<all_privileges> is set it revokes cluster administration privileges
instead.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
=head3 drop_user
$cv = AE::cv;
$db->drop_user(
# raw query
q => "DROP USER jdoe",
# or query created from arguments
username => 'jdoe',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop user: @_");
}
);
$cv->recv;
Drops user C<username>.
The required C<on_success> code reference is executed if request was successful,
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
.' SELECT MEAN(value) INTO "cpu_load_per5m" FROM cpu_load GROUP BY time(5m)'
.' END',
# or query created from arguments
database => 'mydb',
name => 'per5minutes',
every => '10s',
for => '2m',
query => 'SELECT MEAN(value) INTO "cpu_load_per5m" FROM cpu_load GROUP BY time(5m)',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create continuous query: @_");
}
);
$cv->recv;
Creates new continuous query named by C<name> on database C<database> using
query C<query>. Optional C<every> and C<for> define the resampling
times.
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$cv = AE::cv;
$db->drop_continuous_query(
# raw query
q => 'DROP CONTINUOUS QUERY per5minutes ON mydb',
# or query created from arguments
database => 'mydb',
name => 'per5minutes',
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop continuous query: @_");
}
);
$cv->recv;
Drops continuous query named by C<name> on database C<database>.
The required C<on_success> code reference is executed if request was successful,
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
# or query created from arguments
name => q{alldata},
database => q{"mydb"},
rp => q{"default"},
mode => "ANY",
destinations => [
q{'udp://h1.example.com:9090'},
q{'udp://h2.example.com:9090'}
],
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to create subscription: @_");
}
);
$cv->recv;
Creates a new subscription C<name> on database C<database> with retention policy
C<rp> with mode C<mode> to destinations provided as C<destinations>. The
C<destinations> could be either a single scalar value or array reference to a
lib/AnyEvent/InfluxDB.pm view on Meta::CPAN
$cv = AE::cv;
$db->drop_subscription(
# raw query
q => 'DROP SUBSCRIPTION "alldata" ON "mydb"."default"',
# or query created from arguments
name => q{"alldata"},
database => q{"mydb"},
rp => q{"default"},
# callbacks
on_success => $cv,
on_error => sub {
$cv->croak("Failed to drop subscription: @_");
}
);
$cv->recv;
Drops subscription C<name> on database C<database> with retention policy
C<rp>.
( run in 1.019 second using v1.01-cache-2.11-cpan-d6f9594c0a5 )