DR::Tarantool::CoroClient3pm

An asynchronous coro driver for tarantool <http://tarantool.org>

Usage

    use DR::Tarantool::CoroClient;
    use Coro;
    my $client = DR::Tarantool::CoroClient->connect(
        port    => $port,
        spaces  => $spaces;
    );
    my @res;
    for (1 .. 100) {
        async {
            push @res => $client->select(space_name => $_);
        }
    }
    cede while @res < 100;

Methods

connect

Connects to Tarantool.

Arguments

The same as "connect" in DR::Tarantool::AsyncClient, excluding the callback.

Returns a connection handle or croaks an error.

Additional arguments

raise_error: If true (default behaviour) the driver throws an exception for each server error.

ping

The same as "ping" in DR::Tarantool::AsyncClient, excluding the callback.

Returns true on success, false on error.

insert

The same as "insert" in DR::Tarantool::AsyncClient, excluding the callback.

Returns the inserted tuple or undef. Croaks an error if insert failed (raise_error must be set).

select

The same as "select" in DR::Tarantool::AsyncClient, excluding the callback.

Returns tuple or tuples that match selection criteria, or undef if no matching tuples were found. Croaks an error if an error occurred (provided raise_error is set).

update

The same as "update" in DR::Tarantool::AsyncClient, excluding the callback.

Returns the new value of the tuple. Croaks an error if update failed (provided raise_error is set).

delete

The same as "delete" in DR::Tarantool::AsyncClient, excluding the callback.

Returns the deleted tuple, or undef. Croaks error if an error occurred (provided raise_error is set).

call_lua

The same as "call_lua" in DR::Tarantool::AsyncClient, excluding the callback.

Returns a tuple or tuples returned by the called procedure. Croaks an error if an error occurred (provided raise_error is set).

Releases

4 releases since Debian 7 (Wheezy); the text changed 3 times.