Async-Redis

 view release on metacpan or  search on metacpan

script/commands.json  view on Meta::CPAN

                    }
                },
                "find_keys": {
                    "type": "range",
                    "spec": {
                        "lastkey": 0,
                        "keystep": 1,
                        "limit": 0
                    }
                },
                "not_key": true
            }
        ],
        "arguments": [
            {
                "name": "shardchannel",
                "type": "string",
                "display_text": "shardchannel"
            },
            {
                "name": "message",

script/commands.json  view on Meta::CPAN

                    }
                },
                "find_keys": {
                    "type": "range",
                    "spec": {
                        "lastkey": -1,
                        "keystep": 1,
                        "limit": 0
                    }
                },
                "not_key": true
            }
        ],
        "arguments": [
            {
                "name": "shardchannel",
                "type": "string",
                "display_text": "shardchannel",
                "multiple": true
            }
        ],

script/commands.json  view on Meta::CPAN

                    }
                },
                "find_keys": {
                    "type": "range",
                    "spec": {
                        "lastkey": -1,
                        "keystep": 1,
                        "limit": 0
                    }
                },
                "not_key": true
            }
        ],
        "arguments": [
            {
                "name": "shardchannel",
                "type": "string",
                "display_text": "shardchannel",
                "optional": true,
                "multiple": true
            }

t/60-scripting/pipeline-scripts.t  view on Meta::CPAN

        run { cleanup_keys($r, 'dedup:*') };
        $r->disconnect;
    };

    subtest 'unknown script in pipeline error' => sub {
        my $r = Async::Redis->new(host => $ENV{REDIS_HOST} // 'localhost');
        run { $r->connect };

        my $pipe = $r->pipeline;
        $pipe->set('err:key', 'value');
        $pipe->run_script('not_defined', 'err:key');

        like(
            dies { run { $pipe->execute } },
            qr/Unknown script.*not_defined/,
            'pipeline dies on unknown script'
        );

        $r->disconnect;
    };

    subtest 'pipeline with script after script_flush' => sub {
        my $r = Async::Redis->new(host => $ENV{REDIS_HOST} // 'localhost');
        run { $r->connect };