DR-Tarantool

 view release on metacpan or  search on metacpan

lib/DR/Tarantool/AsyncClient.pm  view on Meta::CPAN

=item flags (optional)

Server flags, as described in perldoc L<DR::Tarantool/:constant>.

=item callback

=back

=cut

sub update {
    my $self = shift;
    my $space = shift;
    my $key = shift;
    my $op = shift;
    $self->_llc->_check_cb( my $cb = pop );
    my $flags = shift || 0;

    my $s = $self->space($space);

    $self->_llc->update(

lib/DR/Tarantool/LLClient.pm  view on Meta::CPAN

=item operations list

=item flags (optional)

=item callback for results

=back

=cut

sub update :method {

    my $self = shift;
    $self->_check_number(           my $ns = shift          );
    $self->_check_tuple(            my $key = shift         );
    $self->_check_operations(       my $operations = shift  );
    $self->_check_cb(               my $cb = pop            );
    $self->_check_number(           my $flags = pop || 0    );

    my $id = $self->_req_id;
    my $pkt = DR::Tarantool::_pkt_update($id, $ns, $flags, $key, $operations);

lib/DR/Tarantool/LLSyncClient.pm  view on Meta::CPAN

    $self->_check_tuple(    my $tuple = shift       );
    $self->_check_number(   my $flags = pop || 0    );
    croak "insert: tuple must be ARRAYREF" unless ref $tuple eq 'ARRAY';
    $flags ||= 0;
    
    my $id = $self->_req_id;
    my $pkt = DR::Tarantool::_pkt_insert( $id, $space, $flags, $tuple );
    return $self->_request( $id, $pkt );
}

sub update :method {

    my $self = shift;
    $self->_check_number(           my $ns = shift          );
    $self->_check_tuple(            my $key = shift         );
    $self->_check_operations(       my $operations = shift  );
    $self->_check_number(           my $flags = pop || 0    );

    my $id = $self->_req_id;
    my $pkt = DR::Tarantool::_pkt_update($id, $ns, $flags, $key, $operations);
    return $self->_request( $id, $pkt );

lib/DR/Tarantool/MsgPack/AsyncClient.pm  view on Meta::CPAN

        $opts{limit},
        $opts{offset},
        $opts{iterator},
        sub {
            my ($res) = @_;
            _cb_default($res, $s, $cb);
        }
    );
}

sub update :method {
    my $self = shift;
    my $cb = pop;
    $self->_llc->_check_cb( $cb );
    my $space = shift;
    my $key = shift;
    my $ops = shift;

    my $sno;
    my $s;
    if (Scalar::Util::looks_like_number $space) {

lib/DR/Tarantool/MsgPack/LLClient.pm  view on Meta::CPAN

    $self->_check_cb($cb);
    my $space = shift;
    my $key = shift;

    my $id = $self->_req_id;
    my $pkt = DR::Tarantool::MsgPack::Proto::del($id, $space, $key);
    $self->_request($id, $pkt, $cb);
    return;
}

sub update {
    my $self = shift;
    my $cb = pop;
    $self->_check_cb($cb);

    my $space = shift;
    my $key = shift;
    my $ops = shift;


    my $id = $self->_req_id;

lib/DR/Tarantool/MsgPack/Proto.pm  view on Meta::CPAN

                IPROTO_SPACE_ID,    $space,
                IPROTO_KEY,         $key,
            }
        ;
    }
    # HACK
    _call_lua($sync, "box.space.$space:delete", $key);
}


sub update($$$$) {
    my ($sync, $space, $key, $ops) = @_;
    croak 'Oplist must be Arrayref' unless 'ARRAY' eq ref $ops;
    $key = [ $key ] unless ref $key;
    croak "Cant convert HashRef to key" if 'HASH' eq ref $key;

    if (looks_like_number $space) {
        return request
            {
                IPROTO_SYNC,        $sync,
                IPROTO_CODE,        IPROTO_UPDATE,

lib/DR/Tarantool/RealSyncClient.pm  view on Meta::CPAN

        $s->number,
        $s->_index( $index )->{no},
        $s->pack_keys( $keys, $index ),
        $limit,
        $offset
    );

    return $unpack->($self, $res, $s);
}

sub update {
    my $self = shift;
    my $space = shift;
    my $key = shift;
    my $op = shift;
    my $flags = shift || 0;

    my $s = $self->space($space);

    my $res = $self->_llc->update(
        $s->number,

 view all matches for this distribution
 view release on metacpan -  search on metacpan