Cassandra-Client

 view release on metacpan or  search on metacpan

META.json  view on Meta::CPAN

            "AnyEvent::XSPromises" : "0",
            "Clone" : "0.36",
            "Devel::GlobalDestruction" : "0.11",
            "EV" : "4",
            "Encode" : "0",
            "Exporter" : "0",
            "IO::Socket::INET" : "0",
            "IO::Socket::INET6" : "0",
            "List::Util" : "0",
            "Net::SSLeay" : "1.63",
            "Ref::Util" : "0.008",
            "Scalar::Util" : "0",
            "Socket" : "0",
            "Sub::Current" : "0",
            "Time::HiRes" : "0",
            "XSLoader" : "0",
            "constant" : "0",
            "if" : "0",
            "overload" : "0",
            "parent" : "0",
            "perl" : "5.010",

META.yml  view on Meta::CPAN

  AnyEvent::XSPromises: '0'
  Clone: '0.36'
  Devel::GlobalDestruction: '0.11'
  EV: '4'
  Encode: '0'
  Exporter: '0'
  IO::Socket::INET: '0'
  IO::Socket::INET6: '0'
  List::Util: '0'
  Net::SSLeay: '1.63'
  Ref::Util: '0.008'
  Scalar::Util: '0'
  Socket: '0'
  Sub::Current: '0'
  Time::HiRes: '0'
  XSLoader: '0'
  constant: '0'
  if: '0'
  overload: '0'
  parent: '0'
  perl: '5.010'

Makefile.PL  view on Meta::CPAN

    "AnyEvent::XSPromises" => 0,
    "Clone" => "0.36",
    "Devel::GlobalDestruction" => "0.11",
    "EV" => 4,
    "Encode" => 0,
    "Exporter" => 0,
    "IO::Socket::INET" => 0,
    "IO::Socket::INET6" => 0,
    "List::Util" => 0,
    "Net::SSLeay" => "1.63",
    "Ref::Util" => "0.008",
    "Scalar::Util" => 0,
    "Socket" => 0,
    "Sub::Current" => 0,
    "Time::HiRes" => 0,
    "XSLoader" => 0,
    "constant" => 0,
    "if" => 0,
    "overload" => 0,
    "parent" => 0,
    "strict" => 0,

Makefile.PL  view on Meta::CPAN

  "Devel::Cycle" => 0,
  "Devel::GlobalDestruction" => "0.11",
  "EV" => 4,
  "Encode" => 0,
  "Exporter" => 0,
  "File::Basename" => 0,
  "IO::Socket::INET" => 0,
  "IO::Socket::INET6" => 0,
  "List::Util" => 0,
  "Net::SSLeay" => "1.63",
  "Ref::Util" => "0.008",
  "Scalar::Util" => 0,
  "Socket" => 0,
  "Sub::Current" => 0,
  "Test::Exception" => 0,
  "Test::More" => 0,
  "Time::HiRes" => 0,
  "XSLoader" => 0,
  "constant" => 0,
  "if" => 0,
  "lib" => 0,

lib/Cassandra/Client.pm  view on Meta::CPAN

use Cassandra::Client::Policy::Throttle::Default;
use Cassandra::Client::Policy::LoadBalancing::Default;
use Cassandra::Client::Pool;
use Cassandra::Client::TLSHandling;
use Cassandra::Client::Util qw/series whilst/;

use Clone 0.36 qw/clone/;
use List::Util qw/shuffle/;
use AnyEvent::XSPromises qw/deferred/;
use Time::HiRes ();
use Ref::Util 0.008 qw/is_ref/;
use Devel::GlobalDestruction 0.11;
use XSLoader;

our $XS_VERSION = ($Cassandra::Client::VERSION || '');
$XS_VERSION =~ s/\A(\d+)\.(\d+)(\d{3})\z/$1.$2_$3/;
XSLoader::load(__PACKAGE__, $XS_VERSION);

sub new {
    my ($class, %args)= @_;

lib/Cassandra/Client/Config.pm  view on Meta::CPAN

package Cassandra::Client::Config;
our $AUTHORITY = 'cpan:TVDW';
$Cassandra::Client::Config::VERSION = '0.21';
use 5.010;
use strict;
use warnings;

use Ref::Util qw/is_plain_arrayref is_plain_coderef is_blessed_ref/;
use Cassandra::Client::Policy::Auth::Password;

sub new {
    my ($class, $config)= @_;

    my $self= bless {
        anyevent                => 0,
        contact_points          => undef,
        port                    => 9042,
        cql_version             => undef,

lib/Cassandra/Client/Connection.pm  view on Meta::CPAN

package Cassandra::Client::Connection;
our $AUTHORITY = 'cpan:TVDW';
$Cassandra::Client::Connection::VERSION = '0.21';
use 5.010;
use strict;
use warnings;
use vars qw/$BUFFER/;

use Ref::Util qw/is_blessed_ref is_plain_arrayref/;
use IO::Socket::INET;
use IO::Socket::INET6;
use Errno qw/EAGAIN/;
use Socket qw/SOL_SOCKET IPPROTO_TCP SO_KEEPALIVE TCP_NODELAY/;
use Scalar::Util qw/weaken/;
use Net::SSLeay qw/ERROR_WANT_READ ERROR_WANT_WRITE ERROR_NONE/;

use Cassandra::Client::Util;
use Cassandra::Client::Protocol qw/
    :constants

lib/Cassandra/Client/Policy/Throttle/Adaptive.pm  view on Meta::CPAN

package Cassandra::Client::Policy::Throttle::Adaptive;
our $AUTHORITY = 'cpan:TVDW';
$Cassandra::Client::Policy::Throttle::Adaptive::VERSION = '0.21';
use parent 'Cassandra::Client::Policy::Throttle::Default';
use 5.010;
use strict;
use warnings;
use Time::HiRes qw/CLOCK_MONOTONIC/;
use Ref::Util qw/is_blessed_ref/;
use Cassandra::Client::Error::ClientThrottlingError;

sub new {
    my ($class, %args)= @_;
    return bless {
        ratio => $args{ratio} || 2,
        time => $args{time} || 120,

        window => [],
        window_success => 0,