AnyEvent-PgRecvlogical

 view release on metacpan or  search on metacpan

META.yml  view on Meta::CPAN

  version: '1.4'
name: AnyEvent-PgRecvlogical
requires:
  AnyEvent: '0'
  AnyEvent::Util: '0'
  Carp: '0'
  DBD::Pg: v3.7.0
  DBI: '0'
  Moo: '0'
  Promises: '0.99'
  Try::Tiny: '0'
  Types::Standard: '0'
  constant: '0'
  curry: '0'
  namespace::clean: '0'
resources:
  bugtracker: https://github.com/mydimension/AnyEvent-PgRecvlogical/issues
  homepage: https://github.com/mydimension/AnyEvent-PgRecvlogical
  repository: https://github.com/mydimension/AnyEvent-PgRecvlogical.git
version: '1.04'
x_generated_by_perl: v5.34.3

Makefile.PL  view on Meta::CPAN

  "LICENSE" => "perl",
  "NAME" => "AnyEvent::PgRecvlogical",
  "PREREQ_PM" => {
    "AnyEvent" => 0,
    "AnyEvent::Util" => 0,
    "Carp" => 0,
    "DBD::Pg" => "3.7.0",
    "DBI" => 0,
    "Moo" => 0,
    "Promises" => "0.99",
    "Try::Tiny" => 0,
    "Types::Standard" => 0,
    "constant" => 0,
    "curry" => 0,
    "namespace::clean" => 0
  },
  "TEST_REQUIRES" => {
    "File::Basename" => 0,
    "File::Spec" => 0,
    "Test::More" => 0,
    "Test::PostgreSQL" => 0,

Makefile.PL  view on Meta::CPAN

  "AnyEvent::Util" => 0,
  "Carp" => 0,
  "DBD::Pg" => "3.7.0",
  "DBI" => 0,
  "File::Basename" => 0,
  "File::Spec" => 0,
  "Moo" => 0,
  "Promises" => "0.99",
  "Test::More" => 0,
  "Test::PostgreSQL" => 0,
  "Try::Tiny" => 0,
  "Types::Standard" => 0,
  "constant" => 0,
  "curry" => 0,
  "namespace::clean" => 0,
  "ok" => 0,
  "strict" => 0,
  "warnings" => 0
);

lib/AnyEvent/PgRecvlogical.pm  view on Meta::CPAN

=cut

use Moo;
use DBI;
use DBD::Pg 3.7.0 ':async';
use AnyEvent;
use AnyEvent::Util 'guard';
use Promises 0.99 backend => ['AnyEvent'], qw(deferred);
use Types::Standard ':all';
use Try::Tiny;
use Carp 'croak';
use curry;

use constant {
    AWAIT_INTERVAL    => 1,
    USECS             => 1_000_000,
    PG_MIN_VERSION    => 9_04_00,
    PG_MIN_NOEXPORT   => 10_00_00,
    PG_STATE_DUPEOBJ  => '42710',
    PG_EPOCH_DELTA    => 946_684_800,

t/01_recv.t  view on Meta::CPAN

#!/usr/bin/env perl

use strict;
use warnings;
use Test::More;
use Test::PostgreSQL;
use AnyEvent;
use File::Basename;
use File::Spec;
use Promises backend => ['AnyEvent'], qw(deferred);
use Try::Tiny;

use AnyEvent::PgRecvlogical;

my $CV;
my $end_cv = AE::cv;

sub ae_sleep {
    my $t  = shift || 0;
    my $cv = AE::cv;
    $cv->begin; my $wt = AE::timer $t, 0, sub { $cv->end };