1 #include "nwnx_redis_lib"
89 string incrby_type =
"",
91 int incrby_offset = 0,
93 int incrby_increment = 0
223 int id_client_id = 0,
224 string addr_ip_port =
"",
225 string skipme_yes_no =
""
285 string connection_name
301 string unblock_type =
""
468 string reset_type =
""
925 string withcoord =
"",
927 string withdist =
"",
929 string withhash =
"",
935 string store_key =
"",
937 string storedist_key =
""
968 string withcoord =
"",
970 string withdist =
"",
972 string withhash =
"",
978 string store_key =
"",
980 string storedist_key =
""
1500 int samples_count = 0
1544 string replace =
"",
1545 string auth_password =
"",
1547 string keys_key =
""
1616 string arguments =
""
1656 string milliseconds_timestamp
1739 string argument =
""
1855 string serialized_value,
1857 string replace =
"",
1861 int idletime_seconds = 0,
1863 int freq_frequency = 0
2072 string condition =
""
2145 string save_mode =
""
2219 string argument =
""
2268 string by_pattern =
"",
2270 int limit_offset = 0,
2272 int limit_count = 0,
2273 string get_pattern =
"",
2277 string sorting =
"",
2279 string store_destination =
""
2498 string condition =
"",
2502 string increment =
"",
2570 int weights_weight = 0,
2572 string aggregate_aggregate =
""
2637 string withscores =
""
2655 int limit_offset = 0,
2675 int limit_offset = 0,
2699 string withscores =
"",
2701 int limit_offset = 0,
2800 string withscores =
""
2822 string withscores =
"",
2824 int limit_offset = 0,
2873 int weights_weight = 0,
2875 string aggregate_aggregate =
""
2892 string match_pattern =
"",
2894 int count_count = 0,
2895 string type_type =
""
2913 string match_pattern =
"",
2933 string match_pattern =
"",
2953 string match_pattern =
"",
2972 string consumers_key =
"",
2973 string consumers_groupname =
"",
2975 string groups_key =
"",
2977 string stream_key =
"",
3099 int count_count = 0,
3101 int block_milliseconds = 0,
3103 string streams =
"",
3120 string create_key =
"",
3121 string create_groupname =
"",
3122 string create_id_or__ =
"",
3124 string setid_key =
"",
3125 string setid_groupname =
"",
3126 string setid_id_or__ =
"",
3128 string destroy_key =
"",
3129 string destroy_groupname =
"",
3131 string delconsumer_key =
"",
3132 string delconsumer_groupname =
"",
3133 string delconsumer_consumername =
""
3154 string group_consumer,
3156 int count_count = 0,
3158 int block_milliseconds = 0,
3162 string streams =
"",
3194 string min_idle_time,
3199 int time_ms_unix_time = 0,
3201 int retrycount_count = 0
3222 string consumer =
""
3232 NWNXPushString(
"APPEND");
3233 NWNXPushString(key);
3234 NWNXPushString(value);
3235 NWNXCall(
"NWNX_Redis",
"Deferred");
3236 return NWNXPopInt();
3242 NWNXPushString(
"AUTH");
3243 NWNXPushString(password);
3244 NWNXCall(
"NWNX_Redis",
"Deferred");
3245 return NWNXPopInt();
3249 NWNXPushString(
"BGREWRITEAOF");
3250 NWNXCall(
"NWNX_Redis",
"Deferred");
3251 return NWNXPopInt();
3255 NWNXPushString(
"BGSAVE");
3256 NWNXCall(
"NWNX_Redis",
"Deferred");
3257 return NWNXPopInt();
3267 NWNXPushString(
"BITCOUNT");
3268 NWNXPushString(key);
3269 if (start != 0) NWNXPushString(IntToString(start));
3270 if (end != 0) NWNXPushString(IntToString(end));
3271 NWNXCall(
"NWNX_Redis",
"Deferred");
3272 return NWNXPopInt();
3278 string get_type =
"",
3282 string set_type =
"",
3288 string incrby_type =
"",
3290 int incrby_offset = 0,
3292 int incrby_increment = 0
3294 NWNXPushString(
"BITFIELD");
3295 NWNXPushString(key);
3296 if (get_type !=
"") NWNXPushString(get_type);
3297 if (get_offset != 0) NWNXPushString(IntToString(get_offset));
3298 if (set_type !=
"") NWNXPushString(set_type);
3299 if (set_offset != 0) NWNXPushString(IntToString(set_offset));
3300 if (set_value != 0) NWNXPushString(IntToString(set_value));
3301 if (incrby_type !=
"") NWNXPushString(incrby_type);
3302 if (incrby_offset != 0) NWNXPushString(IntToString(incrby_offset));
3303 if (incrby_increment != 0) NWNXPushString(IntToString(incrby_increment));
3304 NWNXCall(
"NWNX_Redis",
"Deferred");
3305 return NWNXPopInt();
3314 NWNXPushString(
"BITOP");
3315 NWNXPushString(operation);
3316 NWNXPushString(destkey);
3317 NWNXPushString(key);
3318 NWNXCall(
"NWNX_Redis",
"Deferred");
3319 return NWNXPopInt();
3331 NWNXPushString(
"BITPOS");
3332 NWNXPushString(key);
3333 NWNXPushString(IntToString(bit));
3334 if (start != 0) NWNXPushString(IntToString(start));
3335 if (end != 0) NWNXPushString(IntToString(end));
3336 NWNXCall(
"NWNX_Redis",
"Deferred");
3337 return NWNXPopInt();
3345 NWNXPushString(
"BLPOP");
3346 NWNXPushString(key);
3347 NWNXPushString(IntToString(timeout));
3348 NWNXCall(
"NWNX_Redis",
"Deferred");
3349 return NWNXPopInt();
3357 NWNXPushString(
"BRPOP");
3358 NWNXPushString(key);
3359 NWNXPushString(IntToString(timeout));
3360 NWNXCall(
"NWNX_Redis",
"Deferred");
3361 return NWNXPopInt();
3372 NWNXPushString(
"BRPOPLPUSH");
3373 NWNXPushString(source);
3374 NWNXPushString(destination);
3375 NWNXPushString(IntToString(timeout));
3376 NWNXCall(
"NWNX_Redis",
"Deferred");
3377 return NWNXPopInt();
3385 NWNXPushString(
"BZPOPMIN");
3386 NWNXPushString(key);
3387 NWNXPushString(IntToString(timeout));
3388 NWNXCall(
"NWNX_Redis",
"Deferred");
3389 return NWNXPopInt();
3397 NWNXPushString(
"BZPOPMAX");
3398 NWNXPushString(key);
3399 NWNXPushString(IntToString(timeout));
3400 NWNXCall(
"NWNX_Redis",
"Deferred");
3401 return NWNXPopInt();
3405 NWNXPushString(
"CLIENT_ID");
3406 NWNXCall(
"NWNX_Redis",
"Deferred");
3407 return NWNXPopInt();
3411 string ip_port =
"",
3413 int id_client_id = 0,
3414 string addr_ip_port =
"",
3415 string skipme_yes_no =
""
3417 NWNXPushString(
"CLIENT_KILL");
3418 if (ip_port !=
"") NWNXPushString(ip_port);
3419 if (id_client_id != 0) NWNXPushString(IntToString(id_client_id));
3420 if (addr_ip_port !=
"") NWNXPushString(addr_ip_port);
3421 if (skipme_yes_no !=
"") NWNXPushString(skipme_yes_no);
3422 NWNXCall(
"NWNX_Redis",
"Deferred");
3423 return NWNXPopInt();
3427 NWNXPushString(
"CLIENT_LIST");
3428 NWNXCall(
"NWNX_Redis",
"Deferred");
3429 return NWNXPopInt();
3433 NWNXPushString(
"CLIENT_GETNAME");
3434 NWNXCall(
"NWNX_Redis",
"Deferred");
3435 return NWNXPopInt();
3442 NWNXPushString(
"CLIENT_PAUSE");
3443 NWNXPushString(IntToString(timeout));
3444 NWNXCall(
"NWNX_Redis",
"Deferred");
3445 return NWNXPopInt();
3452 NWNXPushString(
"CLIENT_REPLY");
3453 NWNXPushString(reply_mode);
3454 NWNXCall(
"NWNX_Redis",
"Deferred");
3455 return NWNXPopInt();
3459 string connection_name
3461 NWNXPushString(
"CLIENT_SETNAME");
3462 NWNXPushString(connection_name);
3463 NWNXCall(
"NWNX_Redis",
"Deferred");
3464 return NWNXPopInt();
3470 string unblock_type =
""
3472 NWNXPushString(
"CLIENT_UNBLOCK");
3473 NWNXPushString(client_id);
3474 if (unblock_type !=
"") NWNXPushString(unblock_type);
3475 NWNXCall(
"NWNX_Redis",
"Deferred");
3476 return NWNXPopInt();
3483 NWNXPushString(
"CLUSTER_ADDSLOTS");
3484 NWNXPushString(IntToString(slot));
3485 NWNXCall(
"NWNX_Redis",
"Deferred");
3486 return NWNXPopInt();
3492 NWNXPushString(
"CLUSTER_COUNT_FAILURE_REPORTS");
3493 NWNXPushString(node_id);
3494 NWNXCall(
"NWNX_Redis",
"Deferred");
3495 return NWNXPopInt();
3502 NWNXPushString(
"CLUSTER_COUNTKEYSINSLOT");
3503 NWNXPushString(IntToString(slot));
3504 NWNXCall(
"NWNX_Redis",
"Deferred");
3505 return NWNXPopInt();
3512 NWNXPushString(
"CLUSTER_DELSLOTS");
3513 NWNXPushString(IntToString(slot));
3514 NWNXCall(
"NWNX_Redis",
"Deferred");
3515 return NWNXPopInt();
3522 NWNXPushString(
"CLUSTER_FAILOVER");
3523 if (options !=
"") NWNXPushString(options);
3524 NWNXCall(
"NWNX_Redis",
"Deferred");
3525 return NWNXPopInt();
3531 NWNXPushString(
"CLUSTER_FORGET");
3532 NWNXPushString(node_id);
3533 NWNXCall(
"NWNX_Redis",
"Deferred");
3534 return NWNXPopInt();
3543 NWNXPushString(
"CLUSTER_GETKEYSINSLOT");
3544 NWNXPushString(IntToString(slot));
3545 NWNXPushString(IntToString(count));
3546 NWNXCall(
"NWNX_Redis",
"Deferred");
3547 return NWNXPopInt();
3551 NWNXPushString(
"CLUSTER_INFO");
3552 NWNXCall(
"NWNX_Redis",
"Deferred");
3553 return NWNXPopInt();
3559 NWNXPushString(
"CLUSTER_KEYSLOT");
3560 NWNXPushString(key);
3561 NWNXCall(
"NWNX_Redis",
"Deferred");
3562 return NWNXPopInt();
3570 NWNXPushString(
"CLUSTER_MEET");
3572 NWNXPushString(IntToString(port));
3573 NWNXCall(
"NWNX_Redis",
"Deferred");
3574 return NWNXPopInt();
3578 NWNXPushString(
"CLUSTER_NODES");
3579 NWNXCall(
"NWNX_Redis",
"Deferred");
3580 return NWNXPopInt();
3586 NWNXPushString(
"CLUSTER_REPLICATE");
3587 NWNXPushString(node_id);
3588 NWNXCall(
"NWNX_Redis",
"Deferred");
3589 return NWNXPopInt();
3594 string reset_type =
""
3596 NWNXPushString(
"CLUSTER_RESET");
3597 if (reset_type !=
"") NWNXPushString(reset_type);
3598 NWNXCall(
"NWNX_Redis",
"Deferred");
3599 return NWNXPopInt();
3603 NWNXPushString(
"CLUSTER_SAVECONFIG");
3604 NWNXCall(
"NWNX_Redis",
"Deferred");
3605 return NWNXPopInt();
3612 NWNXPushString(
"CLUSTER_SET_CONFIG_EPOCH");
3613 NWNXPushString(IntToString(config_epoch));
3614 NWNXCall(
"NWNX_Redis",
"Deferred");
3615 return NWNXPopInt();
3625 NWNXPushString(
"CLUSTER_SETSLOT");
3626 NWNXPushString(IntToString(slot));
3627 NWNXPushString(subcommand);
3628 if (node_id !=
"") NWNXPushString(node_id);
3629 NWNXCall(
"NWNX_Redis",
"Deferred");
3630 return NWNXPopInt();
3636 NWNXPushString(
"CLUSTER_SLAVES");
3637 NWNXPushString(node_id);
3638 NWNXCall(
"NWNX_Redis",
"Deferred");
3639 return NWNXPopInt();
3645 NWNXPushString(
"CLUSTER_REPLICAS");
3646 NWNXPushString(node_id);
3647 NWNXCall(
"NWNX_Redis",
"Deferred");
3648 return NWNXPopInt();
3652 NWNXPushString(
"CLUSTER_SLOTS");
3653 NWNXCall(
"NWNX_Redis",
"Deferred");
3654 return NWNXPopInt();
3658 NWNXPushString(
"COMMAND");
3659 NWNXCall(
"NWNX_Redis",
"Deferred");
3660 return NWNXPopInt();
3664 NWNXPushString(
"COMMAND_COUNT");
3665 NWNXCall(
"NWNX_Redis",
"Deferred");
3666 return NWNXPopInt();
3670 NWNXPushString(
"COMMAND_GETKEYS");
3671 NWNXCall(
"NWNX_Redis",
"Deferred");
3672 return NWNXPopInt();
3678 NWNXPushString(
"COMMAND_INFO");
3679 NWNXPushString(command_name);
3680 NWNXCall(
"NWNX_Redis",
"Deferred");
3681 return NWNXPopInt();
3687 NWNXPushString(
"CONFIG_GET");
3688 NWNXPushString(parameter);
3689 NWNXCall(
"NWNX_Redis",
"Deferred");
3690 return NWNXPopInt();
3694 NWNXPushString(
"CONFIG_REWRITE");
3695 NWNXCall(
"NWNX_Redis",
"Deferred");
3696 return NWNXPopInt();
3703 NWNXPushString(
"CONFIG_SET");
3704 NWNXPushString(parameter);
3705 NWNXPushString(value);
3706 NWNXCall(
"NWNX_Redis",
"Deferred");
3707 return NWNXPopInt();
3711 NWNXPushString(
"CONFIG_RESETSTAT");
3712 NWNXCall(
"NWNX_Redis",
"Deferred");
3713 return NWNXPopInt();
3717 NWNXPushString(
"DBSIZE");
3718 NWNXCall(
"NWNX_Redis",
"Deferred");
3719 return NWNXPopInt();
3725 NWNXPushString(
"DEBUG_OBJECT");
3726 NWNXPushString(key);
3727 NWNXCall(
"NWNX_Redis",
"Deferred");
3728 return NWNXPopInt();
3732 NWNXPushString(
"DEBUG_SEGFAULT");
3733 NWNXCall(
"NWNX_Redis",
"Deferred");
3734 return NWNXPopInt();
3740 NWNXPushString(
"DECR");
3741 NWNXPushString(key);
3742 NWNXCall(
"NWNX_Redis",
"Deferred");
3743 return NWNXPopInt();
3751 NWNXPushString(
"DECRBY");
3752 NWNXPushString(key);
3753 NWNXPushString(IntToString(decrement));
3754 NWNXCall(
"NWNX_Redis",
"Deferred");
3755 return NWNXPopInt();
3761 NWNXPushString(
"DEL");
3762 NWNXPushString(key);
3763 NWNXCall(
"NWNX_Redis",
"Deferred");
3764 return NWNXPopInt();
3768 NWNXPushString(
"DISCARD");
3769 NWNXCall(
"NWNX_Redis",
"Deferred");
3770 return NWNXPopInt();
3776 NWNXPushString(
"DUMP");
3777 NWNXPushString(key);
3778 NWNXCall(
"NWNX_Redis",
"Deferred");
3779 return NWNXPopInt();
3785 NWNXPushString(
"ECHO");
3786 NWNXPushString(message);
3787 NWNXCall(
"NWNX_Redis",
"Deferred");
3788 return NWNXPopInt();
3798 NWNXPushString(
"EVAL");
3799 NWNXPushString(script);
3800 NWNXPushString(IntToString(numkeys));
3801 NWNXPushString(key);
3802 NWNXPushString(arg);
3803 NWNXCall(
"NWNX_Redis",
"Deferred");
3804 return NWNXPopInt();
3814 NWNXPushString(
"EVALSHA");
3815 NWNXPushString(sha1);
3816 NWNXPushString(IntToString(numkeys));
3817 NWNXPushString(key);
3818 NWNXPushString(arg);
3819 NWNXCall(
"NWNX_Redis",
"Deferred");
3820 return NWNXPopInt();
3824 NWNXPushString(
"EXEC");
3825 NWNXCall(
"NWNX_Redis",
"Deferred");
3826 return NWNXPopInt();
3832 NWNXPushString(
"EXISTS");
3833 NWNXPushString(key);
3834 NWNXCall(
"NWNX_Redis",
"Deferred");
3835 return NWNXPopInt();
3843 NWNXPushString(
"EXPIRE");
3844 NWNXPushString(key);
3845 NWNXPushString(IntToString(seconds));
3846 NWNXCall(
"NWNX_Redis",
"Deferred");
3847 return NWNXPopInt();
3855 NWNXPushString(
"EXPIREAT");
3856 NWNXPushString(key);
3857 NWNXPushString(timestamp);
3858 NWNXCall(
"NWNX_Redis",
"Deferred");
3859 return NWNXPopInt();
3866 NWNXPushString(
"FLUSHALL");
3867 if (async !=
"") NWNXPushString(async);
3868 NWNXCall(
"NWNX_Redis",
"Deferred");
3869 return NWNXPopInt();
3876 NWNXPushString(
"FLUSHDB");
3877 if (async !=
"") NWNXPushString(async);
3878 NWNXCall(
"NWNX_Redis",
"Deferred");
3879 return NWNXPopInt();
3890 NWNXPushString(
"GEOADD");
3891 NWNXPushString(key);
3892 NWNXPushString(FloatToString(longitude, 0));
3893 NWNXPushString(FloatToString(latitude, 0));
3894 NWNXPushString(member);
3895 NWNXCall(
"NWNX_Redis",
"Deferred");
3896 return NWNXPopInt();
3903 NWNXPushString(
"GEOHASH");
3904 NWNXPushString(key);
3905 NWNXPushString(member);
3906 NWNXCall(
"NWNX_Redis",
"Deferred");
3907 return NWNXPopInt();
3914 NWNXPushString(
"GEOPOS");
3915 NWNXPushString(key);
3916 NWNXPushString(member);
3917 NWNXCall(
"NWNX_Redis",
"Deferred");
3918 return NWNXPopInt();
3927 NWNXPushString(
"GEODIST");
3928 NWNXPushString(key);
3929 NWNXPushString(member1);
3930 NWNXPushString(member2);
3931 if (unit !=
"") NWNXPushString(unit);
3932 NWNXCall(
"NWNX_Redis",
"Deferred");
3933 return NWNXPopInt();
3947 string withcoord =
"",
3949 string withdist =
"",
3951 string withhash =
"",
3953 int count_count = 0,
3957 string store_key =
"",
3959 string storedist_key =
""
3961 NWNXPushString(
"GEORADIUS");
3962 NWNXPushString(key);
3963 NWNXPushString(FloatToString(longitude, 0));
3964 NWNXPushString(FloatToString(latitude, 0));
3965 NWNXPushString(FloatToString(radius, 0));
3966 NWNXPushString(unit);
3967 if (withcoord !=
"") NWNXPushString(withcoord);
3968 if (withdist !=
"") NWNXPushString(withdist);
3969 if (withhash !=
"") NWNXPushString(withhash);
3970 if (count_count != 0) NWNXPushString(IntToString(count_count));
3971 if (order !=
"") NWNXPushString(order);
3972 if (store_key !=
"") NWNXPushString(store_key);
3973 if (storedist_key !=
"") NWNXPushString(storedist_key);
3974 NWNXCall(
"NWNX_Redis",
"Deferred");
3975 return NWNXPopInt();
3986 string withcoord =
"",
3988 string withdist =
"",
3990 string withhash =
"",
3992 int count_count = 0,
3996 string store_key =
"",
3998 string storedist_key =
""
4000 NWNXPushString(
"GEORADIUSBYMEMBER");
4001 NWNXPushString(key);
4002 NWNXPushString(member);
4003 NWNXPushString(FloatToString(radius, 0));
4004 NWNXPushString(unit);
4005 if (withcoord !=
"") NWNXPushString(withcoord);
4006 if (withdist !=
"") NWNXPushString(withdist);
4007 if (withhash !=
"") NWNXPushString(withhash);
4008 if (count_count != 0) NWNXPushString(IntToString(count_count));
4009 if (order !=
"") NWNXPushString(order);
4010 if (store_key !=
"") NWNXPushString(store_key);
4011 if (storedist_key !=
"") NWNXPushString(storedist_key);
4012 NWNXCall(
"NWNX_Redis",
"Deferred");
4013 return NWNXPopInt();
4019 NWNXPushString(
"GET");
4020 NWNXPushString(key);
4021 NWNXCall(
"NWNX_Redis",
"Deferred");
4022 return NWNXPopInt();
4030 NWNXPushString(
"GETBIT");
4031 NWNXPushString(key);
4032 NWNXPushString(IntToString(offset));
4033 NWNXCall(
"NWNX_Redis",
"Deferred");
4034 return NWNXPopInt();
4044 NWNXPushString(
"GETRANGE");
4045 NWNXPushString(key);
4046 NWNXPushString(IntToString(start));
4047 NWNXPushString(IntToString(end));
4048 NWNXCall(
"NWNX_Redis",
"Deferred");
4049 return NWNXPopInt();
4056 NWNXPushString(
"GETSET");
4057 NWNXPushString(key);
4058 NWNXPushString(value);
4059 NWNXCall(
"NWNX_Redis",
"Deferred");
4060 return NWNXPopInt();
4067 NWNXPushString(
"HDEL");
4068 NWNXPushString(key);
4069 NWNXPushString(field);
4070 NWNXCall(
"NWNX_Redis",
"Deferred");
4071 return NWNXPopInt();
4078 NWNXPushString(
"HEXISTS");
4079 NWNXPushString(key);
4080 NWNXPushString(field);
4081 NWNXCall(
"NWNX_Redis",
"Deferred");
4082 return NWNXPopInt();
4089 NWNXPushString(
"HGET");
4090 NWNXPushString(key);
4091 NWNXPushString(field);
4092 NWNXCall(
"NWNX_Redis",
"Deferred");
4093 return NWNXPopInt();
4099 NWNXPushString(
"HGETALL");
4100 NWNXPushString(key);
4101 NWNXCall(
"NWNX_Redis",
"Deferred");
4102 return NWNXPopInt();
4111 NWNXPushString(
"HINCRBY");
4112 NWNXPushString(key);
4113 NWNXPushString(field);
4114 NWNXPushString(IntToString(increment));
4115 NWNXCall(
"NWNX_Redis",
"Deferred");
4116 return NWNXPopInt();
4125 NWNXPushString(
"HINCRBYFLOAT");
4126 NWNXPushString(key);
4127 NWNXPushString(field);
4128 NWNXPushString(FloatToString(increment, 0));
4129 NWNXCall(
"NWNX_Redis",
"Deferred");
4130 return NWNXPopInt();
4136 NWNXPushString(
"HKEYS");
4137 NWNXPushString(key);
4138 NWNXCall(
"NWNX_Redis",
"Deferred");
4139 return NWNXPopInt();
4145 NWNXPushString(
"HLEN");
4146 NWNXPushString(key);
4147 NWNXCall(
"NWNX_Redis",
"Deferred");
4148 return NWNXPopInt();
4155 NWNXPushString(
"HMGET");
4156 NWNXPushString(key);
4157 NWNXPushString(field);
4158 NWNXCall(
"NWNX_Redis",
"Deferred");
4159 return NWNXPopInt();
4167 NWNXPushString(
"HMSET");
4168 NWNXPushString(key);
4169 NWNXPushString(field);
4170 NWNXPushString(value);
4171 NWNXCall(
"NWNX_Redis",
"Deferred");
4172 return NWNXPopInt();
4180 NWNXPushString(
"HSET");
4181 NWNXPushString(key);
4182 NWNXPushString(field);
4183 NWNXPushString(value);
4184 NWNXCall(
"NWNX_Redis",
"Deferred");
4185 return NWNXPopInt();
4193 NWNXPushString(
"HSETNX");
4194 NWNXPushString(key);
4195 NWNXPushString(field);
4196 NWNXPushString(value);
4197 NWNXCall(
"NWNX_Redis",
"Deferred");
4198 return NWNXPopInt();
4205 NWNXPushString(
"HSTRLEN");
4206 NWNXPushString(key);
4207 NWNXPushString(field);
4208 NWNXCall(
"NWNX_Redis",
"Deferred");
4209 return NWNXPopInt();
4215 NWNXPushString(
"HVALS");
4216 NWNXPushString(key);
4217 NWNXCall(
"NWNX_Redis",
"Deferred");
4218 return NWNXPopInt();
4224 NWNXPushString(
"INCR");
4225 NWNXPushString(key);
4226 NWNXCall(
"NWNX_Redis",
"Deferred");
4227 return NWNXPopInt();
4235 NWNXPushString(
"INCRBY");
4236 NWNXPushString(key);
4237 NWNXPushString(IntToString(increment));
4238 NWNXCall(
"NWNX_Redis",
"Deferred");
4239 return NWNXPopInt();
4247 NWNXPushString(
"INCRBYFLOAT");
4248 NWNXPushString(key);
4249 NWNXPushString(FloatToString(increment, 0));
4250 NWNXCall(
"NWNX_Redis",
"Deferred");
4251 return NWNXPopInt();
4257 NWNXPushString(
"INFO");
4258 if (section !=
"") NWNXPushString(section);
4259 NWNXCall(
"NWNX_Redis",
"Deferred");
4260 return NWNXPopInt();
4266 NWNXPushString(
"KEYS");
4267 NWNXPushString(pattern);
4268 NWNXCall(
"NWNX_Redis",
"Deferred");
4269 return NWNXPopInt();
4273 NWNXPushString(
"LASTSAVE");
4274 NWNXCall(
"NWNX_Redis",
"Deferred");
4275 return NWNXPopInt();
4283 NWNXPushString(
"LINDEX");
4284 NWNXPushString(key);
4285 NWNXPushString(IntToString(index));
4286 NWNXCall(
"NWNX_Redis",
"Deferred");
4287 return NWNXPopInt();
4297 NWNXPushString(
"LINSERT");
4298 NWNXPushString(key);
4299 NWNXPushString(where);
4300 NWNXPushString(pivot);
4301 NWNXPushString(value);
4302 NWNXCall(
"NWNX_Redis",
"Deferred");
4303 return NWNXPopInt();
4309 NWNXPushString(
"LLEN");
4310 NWNXPushString(key);
4311 NWNXCall(
"NWNX_Redis",
"Deferred");
4312 return NWNXPopInt();
4318 NWNXPushString(
"LPOP");
4319 NWNXPushString(key);
4320 NWNXCall(
"NWNX_Redis",
"Deferred");
4321 return NWNXPopInt();
4328 NWNXPushString(
"LPUSH");
4329 NWNXPushString(key);
4330 NWNXPushString(value);
4331 NWNXCall(
"NWNX_Redis",
"Deferred");
4332 return NWNXPopInt();
4339 NWNXPushString(
"LPUSHX");
4340 NWNXPushString(key);
4341 NWNXPushString(value);
4342 NWNXCall(
"NWNX_Redis",
"Deferred");
4343 return NWNXPopInt();
4353 NWNXPushString(
"LRANGE");
4354 NWNXPushString(key);
4355 NWNXPushString(IntToString(start));
4356 NWNXPushString(IntToString(stop));
4357 NWNXCall(
"NWNX_Redis",
"Deferred");
4358 return NWNXPopInt();
4367 NWNXPushString(
"LREM");
4368 NWNXPushString(key);
4369 NWNXPushString(IntToString(count));
4370 NWNXPushString(value);
4371 NWNXCall(
"NWNX_Redis",
"Deferred");
4372 return NWNXPopInt();
4381 NWNXPushString(
"LSET");
4382 NWNXPushString(key);
4383 NWNXPushString(IntToString(index));
4384 NWNXPushString(value);
4385 NWNXCall(
"NWNX_Redis",
"Deferred");
4386 return NWNXPopInt();
4396 NWNXPushString(
"LTRIM");
4397 NWNXPushString(key);
4398 NWNXPushString(IntToString(start));
4399 NWNXPushString(IntToString(stop));
4400 NWNXCall(
"NWNX_Redis",
"Deferred");
4401 return NWNXPopInt();
4405 NWNXPushString(
"MEMORY_DOCTOR");
4406 NWNXCall(
"NWNX_Redis",
"Deferred");
4407 return NWNXPopInt();
4411 NWNXPushString(
"MEMORY_HELP");
4412 NWNXCall(
"NWNX_Redis",
"Deferred");
4413 return NWNXPopInt();
4417 NWNXPushString(
"MEMORY_MALLOC_STATS");
4418 NWNXCall(
"NWNX_Redis",
"Deferred");
4419 return NWNXPopInt();
4423 NWNXPushString(
"MEMORY_PURGE");
4424 NWNXCall(
"NWNX_Redis",
"Deferred");
4425 return NWNXPopInt();
4429 NWNXPushString(
"MEMORY_STATS");
4430 NWNXCall(
"NWNX_Redis",
"Deferred");
4431 return NWNXPopInt();
4437 int samples_count = 0
4439 NWNXPushString(
"MEMORY_USAGE");
4440 NWNXPushString(key);
4441 if (samples_count != 0) NWNXPushString(IntToString(samples_count));
4442 NWNXCall(
"NWNX_Redis",
"Deferred");
4443 return NWNXPopInt();
4449 NWNXPushString(
"MGET");
4450 NWNXPushString(key);
4451 NWNXCall(
"NWNX_Redis",
"Deferred");
4452 return NWNXPopInt();
4467 string replace =
"",
4468 string auth_password =
"",
4470 string keys_key =
""
4472 NWNXPushString(
"MIGRATE");
4473 NWNXPushString(host);
4474 NWNXPushString(port);
4475 NWNXPushString(key);
4476 NWNXPushString(IntToString(destination_db));
4477 NWNXPushString(IntToString(timeout));
4478 if (copy !=
"") NWNXPushString(copy);
4479 if (replace !=
"") NWNXPushString(replace);
4480 if (auth_password !=
"") NWNXPushString(auth_password);
4481 if (keys_key !=
"") NWNXPushString(keys_key);
4482 NWNXCall(
"NWNX_Redis",
"Deferred");
4483 return NWNXPopInt();
4487 NWNXPushString(
"MONITOR");
4488 NWNXCall(
"NWNX_Redis",
"Deferred");
4489 return NWNXPopInt();
4497 NWNXPushString(
"MOVE");
4498 NWNXPushString(key);
4499 NWNXPushString(IntToString(db));
4500 NWNXCall(
"NWNX_Redis",
"Deferred");
4501 return NWNXPopInt();
4508 NWNXPushString(
"MSET");
4509 NWNXPushString(key);
4510 NWNXPushString(value);
4511 NWNXCall(
"NWNX_Redis",
"Deferred");
4512 return NWNXPopInt();
4519 NWNXPushString(
"MSETNX");
4520 NWNXPushString(key);
4521 NWNXPushString(value);
4522 NWNXCall(
"NWNX_Redis",
"Deferred");
4523 return NWNXPopInt();
4527 NWNXPushString(
"MULTI");
4528 NWNXCall(
"NWNX_Redis",
"Deferred");
4529 return NWNXPopInt();
4534 string arguments =
""
4536 NWNXPushString(
"OBJECT");
4537 NWNXPushString(subcommand);
4538 if (arguments !=
"") NWNXPushString(arguments);
4539 NWNXCall(
"NWNX_Redis",
"Deferred");
4540 return NWNXPopInt();
4546 NWNXPushString(
"PERSIST");
4547 NWNXPushString(key);
4548 NWNXCall(
"NWNX_Redis",
"Deferred");
4549 return NWNXPopInt();
4557 NWNXPushString(
"PEXPIRE");
4558 NWNXPushString(key);
4559 NWNXPushString(IntToString(milliseconds));
4560 NWNXCall(
"NWNX_Redis",
"Deferred");
4561 return NWNXPopInt();
4567 string milliseconds_timestamp
4569 NWNXPushString(
"PEXPIREAT");
4570 NWNXPushString(key);
4571 NWNXPushString(milliseconds_timestamp);
4572 NWNXCall(
"NWNX_Redis",
"Deferred");
4573 return NWNXPopInt();
4580 NWNXPushString(
"PFADD");
4581 NWNXPushString(key);
4582 NWNXPushString(element);
4583 NWNXCall(
"NWNX_Redis",
"Deferred");
4584 return NWNXPopInt();
4590 NWNXPushString(
"PFCOUNT");
4591 NWNXPushString(key);
4592 NWNXCall(
"NWNX_Redis",
"Deferred");
4593 return NWNXPopInt();
4602 NWNXPushString(
"PFMERGE");
4603 NWNXPushString(destkey);
4604 NWNXPushString(sourcekey);
4605 NWNXCall(
"NWNX_Redis",
"Deferred");
4606 return NWNXPopInt();
4612 NWNXPushString(
"PING");
4613 if (message !=
"") NWNXPushString(message);
4614 NWNXCall(
"NWNX_Redis",
"Deferred");
4615 return NWNXPopInt();
4624 NWNXPushString(
"PSETEX");
4625 NWNXPushString(key);
4626 NWNXPushString(IntToString(milliseconds));
4627 NWNXPushString(value);
4628 NWNXCall(
"NWNX_Redis",
"Deferred");
4629 return NWNXPopInt();
4634 string argument =
""
4636 NWNXPushString(
"PUBSUB");
4637 NWNXPushString(subcommand);
4638 if (argument !=
"") NWNXPushString(argument);
4639 NWNXCall(
"NWNX_Redis",
"Deferred");
4640 return NWNXPopInt();
4646 NWNXPushString(
"PTTL");
4647 NWNXPushString(key);
4648 NWNXCall(
"NWNX_Redis",
"Deferred");
4649 return NWNXPopInt();
4656 NWNXPushString(
"PUBLISH");
4657 NWNXPushString(channel);
4658 NWNXPushString(message);
4659 NWNXCall(
"NWNX_Redis",
"Deferred");
4660 return NWNXPopInt();
4664 NWNXPushString(
"QUIT");
4665 NWNXCall(
"NWNX_Redis",
"Deferred");
4666 return NWNXPopInt();
4670 NWNXPushString(
"RANDOMKEY");
4671 NWNXCall(
"NWNX_Redis",
"Deferred");
4672 return NWNXPopInt();
4676 NWNXPushString(
"READONLY");
4677 NWNXCall(
"NWNX_Redis",
"Deferred");
4678 return NWNXPopInt();
4682 NWNXPushString(
"READWRITE");
4683 NWNXCall(
"NWNX_Redis",
"Deferred");
4684 return NWNXPopInt();
4692 NWNXPushString(
"RENAME");
4693 NWNXPushString(key);
4694 NWNXPushString(newkey);
4695 NWNXCall(
"NWNX_Redis",
"Deferred");
4696 return NWNXPopInt();
4704 NWNXPushString(
"RENAMENX");
4705 NWNXPushString(key);
4706 NWNXPushString(newkey);
4707 NWNXCall(
"NWNX_Redis",
"Deferred");
4708 return NWNXPopInt();
4715 string serialized_value,
4717 string replace =
"",
4721 int idletime_seconds = 0,
4723 int freq_frequency = 0
4725 NWNXPushString(
"RESTORE");
4726 NWNXPushString(key);
4727 NWNXPushString(IntToString(ttl));
4728 NWNXPushString(serialized_value);
4729 if (replace !=
"") NWNXPushString(replace);
4730 if (absttl !=
"") NWNXPushString(absttl);
4731 if (idletime_seconds != 0) NWNXPushString(IntToString(idletime_seconds));
4732 if (freq_frequency != 0) NWNXPushString(IntToString(freq_frequency));
4733 NWNXCall(
"NWNX_Redis",
"Deferred");
4734 return NWNXPopInt();
4738 NWNXPushString(
"ROLE");
4739 NWNXCall(
"NWNX_Redis",
"Deferred");
4740 return NWNXPopInt();
4746 NWNXPushString(
"RPOP");
4747 NWNXPushString(key);
4748 NWNXCall(
"NWNX_Redis",
"Deferred");
4749 return NWNXPopInt();
4758 NWNXPushString(
"RPOPLPUSH");
4759 NWNXPushString(source);
4760 NWNXPushString(destination);
4761 NWNXCall(
"NWNX_Redis",
"Deferred");
4762 return NWNXPopInt();
4769 NWNXPushString(
"RPUSH");
4770 NWNXPushString(key);
4771 NWNXPushString(value);
4772 NWNXCall(
"NWNX_Redis",
"Deferred");
4773 return NWNXPopInt();
4780 NWNXPushString(
"RPUSHX");
4781 NWNXPushString(key);
4782 NWNXPushString(value);
4783 NWNXCall(
"NWNX_Redis",
"Deferred");
4784 return NWNXPopInt();
4791 NWNXPushString(
"SADD");
4792 NWNXPushString(key);
4793 NWNXPushString(member);
4794 NWNXCall(
"NWNX_Redis",
"Deferred");
4795 return NWNXPopInt();
4799 NWNXPushString(
"SAVE");
4800 NWNXCall(
"NWNX_Redis",
"Deferred");
4801 return NWNXPopInt();
4807 NWNXPushString(
"SCARD");
4808 NWNXPushString(key);
4809 NWNXCall(
"NWNX_Redis",
"Deferred");
4810 return NWNXPopInt();
4817 NWNXPushString(
"SCRIPT_DEBUG");
4818 NWNXPushString(mode);
4819 NWNXCall(
"NWNX_Redis",
"Deferred");
4820 return NWNXPopInt();
4826 NWNXPushString(
"SCRIPT_EXISTS");
4827 NWNXPushString(sha1);
4828 NWNXCall(
"NWNX_Redis",
"Deferred");
4829 return NWNXPopInt();
4833 NWNXPushString(
"SCRIPT_FLUSH");
4834 NWNXCall(
"NWNX_Redis",
"Deferred");
4835 return NWNXPopInt();
4839 NWNXPushString(
"SCRIPT_KILL");
4840 NWNXCall(
"NWNX_Redis",
"Deferred");
4841 return NWNXPopInt();
4847 NWNXPushString(
"SCRIPT_LOAD");
4848 NWNXPushString(script);
4849 NWNXCall(
"NWNX_Redis",
"Deferred");
4850 return NWNXPopInt();
4856 NWNXPushString(
"SDIFF");
4857 NWNXPushString(key);
4858 NWNXCall(
"NWNX_Redis",
"Deferred");
4859 return NWNXPopInt();
4867 NWNXPushString(
"SDIFFSTORE");
4868 NWNXPushString(destination);
4869 NWNXPushString(key);
4870 NWNXCall(
"NWNX_Redis",
"Deferred");
4871 return NWNXPopInt();
4878 NWNXPushString(
"SELECT");
4879 NWNXPushString(IntToString(index));
4880 NWNXCall(
"NWNX_Redis",
"Deferred");
4881 return NWNXPopInt();
4888 string condition =
""
4890 NWNXPushString(
"SET");
4891 NWNXPushString(key);
4892 NWNXPushString(value);
4893 if (condition !=
"") NWNXPushString(condition);
4894 NWNXCall(
"NWNX_Redis",
"Deferred");
4895 return NWNXPopInt();
4904 NWNXPushString(
"SETBIT");
4905 NWNXPushString(key);
4906 NWNXPushString(IntToString(offset));
4907 NWNXPushString(value);
4908 NWNXCall(
"NWNX_Redis",
"Deferred");
4909 return NWNXPopInt();
4918 NWNXPushString(
"SETEX");
4919 NWNXPushString(key);
4920 NWNXPushString(IntToString(seconds));
4921 NWNXPushString(value);
4922 NWNXCall(
"NWNX_Redis",
"Deferred");
4923 return NWNXPopInt();
4930 NWNXPushString(
"SETNX");
4931 NWNXPushString(key);
4932 NWNXPushString(value);
4933 NWNXCall(
"NWNX_Redis",
"Deferred");
4934 return NWNXPopInt();
4943 NWNXPushString(
"SETRANGE");
4944 NWNXPushString(key);
4945 NWNXPushString(IntToString(offset));
4946 NWNXPushString(value);
4947 NWNXCall(
"NWNX_Redis",
"Deferred");
4948 return NWNXPopInt();
4953 string save_mode =
""
4955 NWNXPushString(
"SHUTDOWN");
4956 if (save_mode !=
"") NWNXPushString(save_mode);
4957 NWNXCall(
"NWNX_Redis",
"Deferred");
4958 return NWNXPopInt();
4964 NWNXPushString(
"SINTER");
4965 NWNXPushString(key);
4966 NWNXCall(
"NWNX_Redis",
"Deferred");
4967 return NWNXPopInt();
4975 NWNXPushString(
"SINTERSTORE");
4976 NWNXPushString(destination);
4977 NWNXPushString(key);
4978 NWNXCall(
"NWNX_Redis",
"Deferred");
4979 return NWNXPopInt();
4986 NWNXPushString(
"SISMEMBER");
4987 NWNXPushString(key);
4988 NWNXPushString(member);
4989 NWNXCall(
"NWNX_Redis",
"Deferred");
4990 return NWNXPopInt();
4997 NWNXPushString(
"SLAVEOF");
4998 NWNXPushString(host);
4999 NWNXPushString(port);
5000 NWNXCall(
"NWNX_Redis",
"Deferred");
5001 return NWNXPopInt();
5008 NWNXPushString(
"REPLICAOF");
5009 NWNXPushString(host);
5010 NWNXPushString(port);
5011 NWNXCall(
"NWNX_Redis",
"Deferred");
5012 return NWNXPopInt();
5017 string argument =
""
5019 NWNXPushString(
"SLOWLOG");
5020 NWNXPushString(subcommand);
5021 if (argument !=
"") NWNXPushString(argument);
5022 NWNXCall(
"NWNX_Redis",
"Deferred");
5023 return NWNXPopInt();
5029 NWNXPushString(
"SMEMBERS");
5030 NWNXPushString(key);
5031 NWNXCall(
"NWNX_Redis",
"Deferred");
5032 return NWNXPopInt();
5042 NWNXPushString(
"SMOVE");
5043 NWNXPushString(source);
5044 NWNXPushString(destination);
5045 NWNXPushString(member);
5046 NWNXCall(
"NWNX_Redis",
"Deferred");
5047 return NWNXPopInt();
5053 string by_pattern =
"",
5055 int limit_offset = 0,
5057 int limit_count = 0,
5058 string get_pattern =
"",
5062 string sorting =
"",
5064 string store_destination =
""
5066 NWNXPushString(
"SORT");
5067 NWNXPushString(key);
5068 if (by_pattern !=
"") NWNXPushString(by_pattern);
5069 if (limit_offset != 0) NWNXPushString(IntToString(limit_offset));
5070 if (limit_count != 0) NWNXPushString(IntToString(limit_count));
5071 if (get_pattern !=
"") NWNXPushString(get_pattern);
5072 if (order !=
"") NWNXPushString(order);
5073 if (sorting !=
"") NWNXPushString(sorting);
5074 if (store_destination !=
"") NWNXPushString(store_destination);
5075 NWNXCall(
"NWNX_Redis",
"Deferred");
5076 return NWNXPopInt();
5084 NWNXPushString(
"SPOP");
5085 NWNXPushString(key);
5086 if (count != 0) NWNXPushString(IntToString(count));
5087 NWNXCall(
"NWNX_Redis",
"Deferred");
5088 return NWNXPopInt();
5096 NWNXPushString(
"SRANDMEMBER");
5097 NWNXPushString(key);
5098 if (count != 0) NWNXPushString(IntToString(count));
5099 NWNXCall(
"NWNX_Redis",
"Deferred");
5100 return NWNXPopInt();
5107 NWNXPushString(
"SREM");
5108 NWNXPushString(key);
5109 NWNXPushString(member);
5110 NWNXCall(
"NWNX_Redis",
"Deferred");
5111 return NWNXPopInt();
5117 NWNXPushString(
"STRLEN");
5118 NWNXPushString(key);
5119 NWNXCall(
"NWNX_Redis",
"Deferred");
5120 return NWNXPopInt();
5126 NWNXPushString(
"SUNION");
5127 NWNXPushString(key);
5128 NWNXCall(
"NWNX_Redis",
"Deferred");
5129 return NWNXPopInt();
5137 NWNXPushString(
"SUNIONSTORE");
5138 NWNXPushString(destination);
5139 NWNXPushString(key);
5140 NWNXCall(
"NWNX_Redis",
"Deferred");
5141 return NWNXPopInt();
5150 NWNXPushString(
"SWAPDB");
5151 NWNXPushString(IntToString(index));
5152 NWNXPushString(IntToString(index_1));
5153 NWNXCall(
"NWNX_Redis",
"Deferred");
5154 return NWNXPopInt();
5158 NWNXPushString(
"SYNC");
5159 NWNXCall(
"NWNX_Redis",
"Deferred");
5160 return NWNXPopInt();
5164 NWNXPushString(
"TIME");
5165 NWNXCall(
"NWNX_Redis",
"Deferred");
5166 return NWNXPopInt();
5172 NWNXPushString(
"TOUCH");
5173 NWNXPushString(key);
5174 NWNXCall(
"NWNX_Redis",
"Deferred");
5175 return NWNXPopInt();
5181 NWNXPushString(
"TTL");
5182 NWNXPushString(key);
5183 NWNXCall(
"NWNX_Redis",
"Deferred");
5184 return NWNXPopInt();
5190 NWNXPushString(
"TYPE");
5191 NWNXPushString(key);
5192 NWNXCall(
"NWNX_Redis",
"Deferred");
5193 return NWNXPopInt();
5199 NWNXPushString(
"UNLINK");
5200 NWNXPushString(key);
5201 NWNXCall(
"NWNX_Redis",
"Deferred");
5202 return NWNXPopInt();
5206 NWNXPushString(
"UNWATCH");
5207 NWNXCall(
"NWNX_Redis",
"Deferred");
5208 return NWNXPopInt();
5217 NWNXPushString(
"WAIT");
5218 NWNXPushString(IntToString(numreplicas));
5219 NWNXPushString(IntToString(timeout));
5220 NWNXCall(
"NWNX_Redis",
"Deferred");
5221 return NWNXPopInt();
5227 NWNXPushString(
"WATCH");
5228 NWNXPushString(key);
5229 NWNXCall(
"NWNX_Redis",
"Deferred");
5230 return NWNXPopInt();
5236 string condition =
"",
5240 string increment =
"",
5245 NWNXPushString(
"ZADD");
5246 NWNXPushString(key);
5247 if (condition !=
"") NWNXPushString(condition);
5248 if (change !=
"") NWNXPushString(change);
5249 if (increment !=
"") NWNXPushString(increment);
5250 NWNXPushString(FloatToString(score, 0));
5251 NWNXPushString(member);
5252 NWNXCall(
"NWNX_Redis",
"Deferred");
5253 return NWNXPopInt();
5259 NWNXPushString(
"ZCARD");
5260 NWNXPushString(key);
5261 NWNXCall(
"NWNX_Redis",
"Deferred");
5262 return NWNXPopInt();
5272 NWNXPushString(
"ZCOUNT");
5273 NWNXPushString(key);
5274 NWNXPushString(FloatToString(min, 0));
5275 NWNXPushString(FloatToString(max, 0));
5276 NWNXCall(
"NWNX_Redis",
"Deferred");
5277 return NWNXPopInt();
5286 NWNXPushString(
"ZINCRBY");
5287 NWNXPushString(key);
5288 NWNXPushString(IntToString(increment));
5289 NWNXPushString(member);
5290 NWNXCall(
"NWNX_Redis",
"Deferred");
5291 return NWNXPopInt();
5301 int weights_weight = 0,
5303 string aggregate_aggregate =
""
5305 NWNXPushString(
"ZINTERSTORE");
5306 NWNXPushString(destination);
5307 NWNXPushString(IntToString(numkeys));
5308 NWNXPushString(key);
5309 if (weights_weight != 0) NWNXPushString(IntToString(weights_weight));
5310 if (aggregate_aggregate !=
"") NWNXPushString(aggregate_aggregate);
5311 NWNXCall(
"NWNX_Redis",
"Deferred");
5312 return NWNXPopInt();
5320 NWNXPushString(
"ZLEXCOUNT");
5321 NWNXPushString(key);
5322 NWNXPushString(min);
5323 NWNXPushString(max);
5324 NWNXCall(
"NWNX_Redis",
"Deferred");
5325 return NWNXPopInt();
5333 NWNXPushString(
"ZPOPMAX");
5334 NWNXPushString(key);
5335 if (count != 0) NWNXPushString(IntToString(count));
5336 NWNXCall(
"NWNX_Redis",
"Deferred");
5337 return NWNXPopInt();
5345 NWNXPushString(
"ZPOPMIN");
5346 NWNXPushString(key);
5347 if (count != 0) NWNXPushString(IntToString(count));
5348 NWNXCall(
"NWNX_Redis",
"Deferred");
5349 return NWNXPopInt();
5359 string withscores =
""
5361 NWNXPushString(
"ZRANGE");
5362 NWNXPushString(key);
5363 NWNXPushString(IntToString(start));
5364 NWNXPushString(IntToString(stop));
5365 if (withscores !=
"") NWNXPushString(withscores);
5366 NWNXCall(
"NWNX_Redis",
"Deferred");
5367 return NWNXPopInt();
5375 int limit_offset = 0,
5379 NWNXPushString(
"ZRANGEBYLEX");
5380 NWNXPushString(key);
5381 NWNXPushString(min);
5382 NWNXPushString(max);
5383 if (limit_offset != 0) NWNXPushString(IntToString(limit_offset));
5384 if (limit_count != 0) NWNXPushString(IntToString(limit_count));
5385 NWNXCall(
"NWNX_Redis",
"Deferred");
5386 return NWNXPopInt();
5394 int limit_offset = 0,
5398 NWNXPushString(
"ZREVRANGEBYLEX");
5399 NWNXPushString(key);
5400 NWNXPushString(max);
5401 NWNXPushString(min);
5402 if (limit_offset != 0) NWNXPushString(IntToString(limit_offset));
5403 if (limit_count != 0) NWNXPushString(IntToString(limit_count));
5404 NWNXCall(
"NWNX_Redis",
"Deferred");
5405 return NWNXPopInt();
5415 string withscores =
"",
5417 int limit_offset = 0,
5421 NWNXPushString(
"ZRANGEBYSCORE");
5422 NWNXPushString(key);
5423 NWNXPushString(FloatToString(min, 0));
5424 NWNXPushString(FloatToString(max, 0));
5425 if (withscores !=
"") NWNXPushString(withscores);
5426 if (limit_offset != 0) NWNXPushString(IntToString(limit_offset));
5427 if (limit_count != 0) NWNXPushString(IntToString(limit_count));
5428 NWNXCall(
"NWNX_Redis",
"Deferred");
5429 return NWNXPopInt();
5436 NWNXPushString(
"ZRANK");
5437 NWNXPushString(key);
5438 NWNXPushString(member);
5439 NWNXCall(
"NWNX_Redis",
"Deferred");
5440 return NWNXPopInt();
5447 NWNXPushString(
"ZREM");
5448 NWNXPushString(key);
5449 NWNXPushString(member);
5450 NWNXCall(
"NWNX_Redis",
"Deferred");
5451 return NWNXPopInt();
5459 NWNXPushString(
"ZREMRANGEBYLEX");
5460 NWNXPushString(key);
5461 NWNXPushString(min);
5462 NWNXPushString(max);
5463 NWNXCall(
"NWNX_Redis",
"Deferred");
5464 return NWNXPopInt();
5474 NWNXPushString(
"ZREMRANGEBYRANK");
5475 NWNXPushString(key);
5476 NWNXPushString(IntToString(start));
5477 NWNXPushString(IntToString(stop));
5478 NWNXCall(
"NWNX_Redis",
"Deferred");
5479 return NWNXPopInt();
5489 NWNXPushString(
"ZREMRANGEBYSCORE");
5490 NWNXPushString(key);
5491 NWNXPushString(FloatToString(min, 0));
5492 NWNXPushString(FloatToString(max, 0));
5493 NWNXCall(
"NWNX_Redis",
"Deferred");
5494 return NWNXPopInt();
5504 string withscores =
""
5506 NWNXPushString(
"ZREVRANGE");
5507 NWNXPushString(key);
5508 NWNXPushString(IntToString(start));
5509 NWNXPushString(IntToString(stop));
5510 if (withscores !=
"") NWNXPushString(withscores);
5511 NWNXCall(
"NWNX_Redis",
"Deferred");
5512 return NWNXPopInt();
5522 string withscores =
"",
5524 int limit_offset = 0,
5528 NWNXPushString(
"ZREVRANGEBYSCORE");
5529 NWNXPushString(key);
5530 NWNXPushString(FloatToString(max, 0));
5531 NWNXPushString(FloatToString(min, 0));
5532 if (withscores !=
"") NWNXPushString(withscores);
5533 if (limit_offset != 0) NWNXPushString(IntToString(limit_offset));
5534 if (limit_count != 0) NWNXPushString(IntToString(limit_count));
5535 NWNXCall(
"NWNX_Redis",
"Deferred");
5536 return NWNXPopInt();
5543 NWNXPushString(
"ZREVRANK");
5544 NWNXPushString(key);
5545 NWNXPushString(member);
5546 NWNXCall(
"NWNX_Redis",
"Deferred");
5547 return NWNXPopInt();
5554 NWNXPushString(
"ZSCORE");
5555 NWNXPushString(key);
5556 NWNXPushString(member);
5557 NWNXCall(
"NWNX_Redis",
"Deferred");
5558 return NWNXPopInt();
5568 int weights_weight = 0,
5570 string aggregate_aggregate =
""
5572 NWNXPushString(
"ZUNIONSTORE");
5573 NWNXPushString(destination);
5574 NWNXPushString(IntToString(numkeys));
5575 NWNXPushString(key);
5576 if (weights_weight != 0) NWNXPushString(IntToString(weights_weight));
5577 if (aggregate_aggregate !=
"") NWNXPushString(aggregate_aggregate);
5578 NWNXCall(
"NWNX_Redis",
"Deferred");
5579 return NWNXPopInt();
5586 string match_pattern =
"",
5588 int count_count = 0,
5589 string type_type =
""
5591 NWNXPushString(
"SCAN");
5592 NWNXPushString(IntToString(cursor));
5593 if (match_pattern !=
"") NWNXPushString(match_pattern);
5594 if (count_count != 0) NWNXPushString(IntToString(count_count));
5595 if (type_type !=
"") NWNXPushString(type_type);
5596 NWNXCall(
"NWNX_Redis",
"Deferred");
5597 return NWNXPopInt();
5605 string match_pattern =
"",
5609 NWNXPushString(
"SSCAN");
5610 NWNXPushString(key);
5611 NWNXPushString(IntToString(cursor));
5612 if (match_pattern !=
"") NWNXPushString(match_pattern);
5613 if (count_count != 0) NWNXPushString(IntToString(count_count));
5614 NWNXCall(
"NWNX_Redis",
"Deferred");
5615 return NWNXPopInt();
5623 string match_pattern =
"",
5627 NWNXPushString(
"HSCAN");
5628 NWNXPushString(key);
5629 NWNXPushString(IntToString(cursor));
5630 if (match_pattern !=
"") NWNXPushString(match_pattern);
5631 if (count_count != 0) NWNXPushString(IntToString(count_count));
5632 NWNXCall(
"NWNX_Redis",
"Deferred");
5633 return NWNXPopInt();
5641 string match_pattern =
"",
5645 NWNXPushString(
"ZSCAN");
5646 NWNXPushString(key);
5647 NWNXPushString(IntToString(cursor));
5648 if (match_pattern !=
"") NWNXPushString(match_pattern);
5649 if (count_count != 0) NWNXPushString(IntToString(count_count));
5650 NWNXCall(
"NWNX_Redis",
"Deferred");
5651 return NWNXPopInt();
5656 string consumers_key =
"",
5657 string consumers_groupname =
"",
5659 string groups_key =
"",
5661 string stream_key =
"",
5665 NWNXPushString(
"XINFO");
5666 if (consumers_key !=
"") NWNXPushString(consumers_key);
5667 if (consumers_groupname !=
"") NWNXPushString(consumers_groupname);
5668 if (groups_key !=
"") NWNXPushString(groups_key);
5669 if (stream_key !=
"") NWNXPushString(stream_key);
5670 if (help !=
"") NWNXPushString(help);
5671 NWNXCall(
"NWNX_Redis",
"Deferred");
5672 return NWNXPopInt();
5682 NWNXPushString(
"XADD");
5683 NWNXPushString(key);
5685 NWNXPushString(field);
5686 NWNXPushString(str);
5687 NWNXCall(
"NWNX_Redis",
"Deferred");
5688 return NWNXPopInt();
5700 NWNXPushString(
"XTRIM");
5701 NWNXPushString(key);
5702 NWNXPushString(strategy);
5703 if (approx !=
"") NWNXPushString(approx);
5704 NWNXPushString(IntToString(count));
5705 NWNXCall(
"NWNX_Redis",
"Deferred");
5706 return NWNXPopInt();
5713 NWNXPushString(
"XDEL");
5714 NWNXPushString(key);
5716 NWNXCall(
"NWNX_Redis",
"Deferred");
5717 return NWNXPopInt();
5727 NWNXPushString(
"XRANGE");
5728 NWNXPushString(key);
5729 NWNXPushString(start);
5730 NWNXPushString(end);
5731 if (count_count != 0) NWNXPushString(IntToString(count_count));
5732 NWNXCall(
"NWNX_Redis",
"Deferred");
5733 return NWNXPopInt();
5743 NWNXPushString(
"XREVRANGE");
5744 NWNXPushString(key);
5745 NWNXPushString(end);
5746 NWNXPushString(start);
5747 if (count_count != 0) NWNXPushString(IntToString(count_count));
5748 NWNXCall(
"NWNX_Redis",
"Deferred");
5749 return NWNXPopInt();
5755 NWNXPushString(
"XLEN");
5756 NWNXPushString(key);
5757 NWNXCall(
"NWNX_Redis",
"Deferred");
5758 return NWNXPopInt();
5763 int count_count = 0,
5765 int block_milliseconds = 0,
5767 string streams =
"",
5771 NWNXPushString(
"XREAD");
5772 if (count_count != 0) NWNXPushString(IntToString(count_count));
5773 if (block_milliseconds != 0) NWNXPushString(IntToString(block_milliseconds));
5774 NWNXPushString(streams);
5775 NWNXPushString(key);
5777 NWNXCall(
"NWNX_Redis",
"Deferred");
5778 return NWNXPopInt();
5783 string create_key =
"",
5784 string create_groupname =
"",
5785 string create_id_or__ =
"",
5787 string setid_key =
"",
5788 string setid_groupname =
"",
5789 string setid_id_or__ =
"",
5791 string destroy_key =
"",
5792 string destroy_groupname =
"",
5794 string delconsumer_key =
"",
5795 string delconsumer_groupname =
"",
5796 string delconsumer_consumername =
""
5798 NWNXPushString(
"XGROUP");
5799 if (create_key !=
"") NWNXPushString(create_key);
5800 if (create_groupname !=
"") NWNXPushString(create_groupname);
5801 if (create_id_or__ !=
"") NWNXPushString(create_id_or__);
5802 if (setid_key !=
"") NWNXPushString(setid_key);
5803 if (setid_groupname !=
"") NWNXPushString(setid_groupname);
5804 if (setid_id_or__ !=
"") NWNXPushString(setid_id_or__);
5805 if (destroy_key !=
"") NWNXPushString(destroy_key);
5806 if (destroy_groupname !=
"") NWNXPushString(destroy_groupname);
5807 if (delconsumer_key !=
"") NWNXPushString(delconsumer_key);
5808 if (delconsumer_groupname !=
"") NWNXPushString(delconsumer_groupname);
5809 if (delconsumer_consumername !=
"") NWNXPushString(delconsumer_consumername);
5810 NWNXCall(
"NWNX_Redis",
"Deferred");
5811 return NWNXPopInt();
5816 string group_consumer,
5818 int count_count = 0,
5820 int block_milliseconds = 0,
5824 string streams =
"",
5828 NWNXPushString(
"XREADGROUP");
5829 NWNXPushString(group_group);
5830 NWNXPushString(group_consumer);
5831 if (count_count != 0) NWNXPushString(IntToString(count_count));
5832 if (block_milliseconds != 0) NWNXPushString(IntToString(block_milliseconds));
5833 if (noack !=
"") NWNXPushString(noack);
5834 NWNXPushString(streams);
5835 NWNXPushString(key);
5837 NWNXCall(
"NWNX_Redis",
"Deferred");
5838 return NWNXPopInt();
5846 NWNXPushString(
"XACK");
5847 NWNXPushString(key);
5848 NWNXPushString(group);
5850 NWNXCall(
"NWNX_Redis",
"Deferred");
5851 return NWNXPopInt();
5858 string min_idle_time,
5863 int time_ms_unix_time = 0,
5865 int retrycount_count = 0
5867 NWNXPushString(
"XCLAIM");
5868 NWNXPushString(key);
5869 NWNXPushString(group);
5870 NWNXPushString(consumer);
5871 NWNXPushString(min_idle_time);
5873 if (idle_ms != 0) NWNXPushString(IntToString(idle_ms));
5874 if (time_ms_unix_time != 0) NWNXPushString(IntToString(time_ms_unix_time));
5875 if (retrycount_count != 0) NWNXPushString(IntToString(retrycount_count));
5876 NWNXCall(
"NWNX_Redis",
"Deferred");
5877 return NWNXPopInt();
5887 string consumer =
""
5889 NWNXPushString(
"XPENDING");
5890 NWNXPushString(key);
5891 NWNXPushString(group);
5892 if (start !=
"") NWNXPushString(start);
5893 if (end !=
"") NWNXPushString(end);
5894 if (count != 0) NWNXPushString(IntToString(count));
5895 if (consumer !=
"") NWNXPushString(consumer);
5896 NWNXCall(
"NWNX_Redis",
"Deferred");
5897 return NWNXPopInt();
int EXPIREAT(string key, string timestamp)
int EVALSHA(string sha1, int numkeys, string key, string arg)
int SORT(string key, string by_pattern="", int limit_offset=0, int limit_count=0, string get_pattern="", string order="", string sorting="", string store_destination="")
int ZRANGE(string key, int start, int stop, string withscores="")
int BLPOP(string key, int timeout)
int SINTERSTORE(string destination, string key)
int ZINTERSTORE(string destination, int numkeys, string key, int weights_weight=0, string aggregate_aggregate="")
int LINDEX(string key, int index)
int HMSET(string key, string field, string value)
int HSCAN(string key, int cursor, string match_pattern="", int count_count=0)
int CLUSTER_COUNTKEYSINSLOT(int slot)
int LPUSHX(string key, string value)
int HMGET(string key, string field)
int XCLAIM(string key, string group, string consumer, string min_idle_time, string ID, int idle_ms=0, int time_ms_unix_time=0, int retrycount_count=0)
int EVAL(string script, int numkeys, string key, string arg)
int CONFIG_SET(string parameter, string value)
int SUNIONSTORE(string destination, string key)
int SISMEMBER(string key, string member)
int CLUSTER_FORGET(string node_id)
int CLUSTER_GETKEYSINSLOT(int slot, int count)
int GETSET(string key, string value)
int ZREVRANK(string key, string member)
int COMMAND_INFO(string command_name)
int SPOP(string key, int count=0)
int SETRANGE(string key, int offset, string value)
int XTRIM(string key, string strategy, string approx="", int count=0)
int BRPOPLPUSH(string source, string destination, int timeout)
int SETEX(string key, int seconds, string value)
int CLUSTER_KEYSLOT(string key)
int BITOP(string operation, string destkey, string key)
int INFO(string section="")
int GEOADD(string key, float longitude, float latitude, string member)
int XDEL(string key, string ID)
int WAIT(int numreplicas, int timeout)
int BRPOP(string key, int timeout)
int GEODIST(string key, string member1, string member2, string unit="")
int GEOHASH(string key, string member)
int CLIENT_KILL(string ip_port="", int id_client_id=0, string addr_ip_port="", string skipme_yes_no="")
int LTRIM(string key, int start, int stop)
int RENAMENX(string key, string newkey)
int SCRIPT_DEBUG(string mode)
int INCRBYFLOAT(string key, float increment)
int CLUSTER_REPLICATE(string node_id)
int LINSERT(string key, string where, string pivot, string value)
int PUBLISH(string channel, string message)
int CLIENT_UNBLOCK(string client_id, string unblock_type="")
int XADD(string key, string ID, string field, string str)
int SCRIPT_LOAD(string script)
int ZINCRBY(string key, int increment, string member)
int SRANDMEMBER(string key, int count=0)
int ZUNIONSTORE(string destination, int numkeys, string key, int weights_weight=0, string aggregate_aggregate="")
int ZREMRANGEBYSCORE(string key, float min, float max)
int SET(string key, string value, string condition="")
int PFMERGE(string destkey, string sourcekey)
int PSETEX(string key, int milliseconds, string value)
int CLIENT_REPLY(string reply_mode)
int SHUTDOWN(string save_mode="")
int ZPOPMIN(string key, int count=0)
int INCRBY(string key, int increment)
int XREADGROUP(string group_group, string group_consumer, int count_count=0, int block_milliseconds=0, string noack="", string streams="", string key="", string ID="")
int ZREM(string key, string member)
int BZPOPMAX(string key, int timeout)
int CLUSTER_FAILOVER(string options="")
int LRANGE(string key, int start, int stop)
int SDIFFSTORE(string destination, string key)
int GETBIT(string key, int offset)
int CONFIG_GET(string parameter)
int CLUSTER_COUNT_FAILURE_REPORTS(string node_id)
int CLUSTER_SETSLOT(int slot, string subcommand, string node_id="")
int RPUSHX(string key, string value)
int XRANGE(string key, string start, string end, int count_count=0)
int HINCRBY(string key, string field, int increment)
int CLUSTER_REPLICAS(string node_id)
int CLIENT_PAUSE(int timeout)
int EXPIRE(string key, int seconds)
int SADD(string key, string member)
int CLUSTER_RESET(string reset_type="")
int XREVRANGE(string key, string end, string start, int count_count=0)
int SLAVEOF(string host, string port)
int HEXISTS(string key, string field)
int ZREVRANGEBYLEX(string key, string max, string min, int limit_offset=0, int limit_count=0)
int RESTORE(string key, int ttl, string serialized_value, string replace="", string absttl="", int idletime_seconds=0, int freq_frequency=0)
int LSET(string key, int index, string value)
int PFADD(string key, string element)
int ZRANGEBYSCORE(string key, float min, float max, string withscores="", int limit_offset=0, int limit_count=0)
int BZPOPMIN(string key, int timeout)
int BITFIELD(string key, string get_type="", int get_offset=0, string set_type="", int set_offset=0, int set_value=0, string incrby_type="", int incrby_offset=0, int incrby_increment=0)
int ZPOPMAX(string key, int count=0)
int MIGRATE(string host, string port, string key, int destination_db, int timeout, string copy="", string replace="", string auth_password="", string keys_key="")
int XREAD(int count_count=0, int block_milliseconds=0, string streams="", string key="", string ID="")
int LREM(string key, int count, string value)
int MSETNX(string key, string value)
int GEORADIUS(string key, float longitude, float latitude, float radius, string unit, string withcoord="", string withdist="", string withhash="", int count_count=0, string order="", string store_key="", string storedist_key="")
int ZSCAN(string key, int cursor, string match_pattern="", int count_count=0)
int MSET(string key, string value)
int HSTRLEN(string key, string field)
int DECRBY(string key, int decrement)
int ZADD(string key, string condition="", string change="", string increment="", float score=0.0, string member="")
int LPUSH(string key, string value)
int REPLICAOF(string host, string port)
int PEXPIREAT(string key, string milliseconds_timestamp)
int CLIENT_SETNAME(string connection_name)
int HGET(string key, string field)
int XACK(string key, string group, string ID)
int PING(string message="")
int ZSCORE(string key, string member)
int ZREMRANGEBYLEX(string key, string min, string max)
int SCAN(int cursor, string match_pattern="", int count_count=0, string type_type="")
int ZCOUNT(string key, float min, float max)
int FLUSHDB(string async="")
int SETBIT(string key, int offset, string value)
int HDEL(string key, string field)
int CLUSTER_SLAVES(string node_id)
int ZREMRANGEBYRANK(string key, int start, int stop)
int APPEND(string key, string value)
int ZREVRANGE(string key, int start, int stop, string withscores="")
int FLUSHALL(string async="")
int HSET(string key, string field, string value)
int ZRANGEBYLEX(string key, string min, string max, int limit_offset=0, int limit_count=0)
int AUTH(string password)
int RPOPLPUSH(string source, string destination)
int HINCRBYFLOAT(string key, string field, float increment)
int XINFO(string consumers_key="", string consumers_groupname="", string groups_key="", string stream_key="", string help="")
int SCRIPT_EXISTS(string sha1)
int XGROUP(string create_key="", string create_groupname="", string create_id_or__="", string setid_key="", string setid_groupname="", string setid_id_or__="", string destroy_key="", string destroy_groupname="", string delconsumer_key="", string delconsumer_groupname="", string delconsumer_consumername="")
int SETNX(string key, string value)
int HSETNX(string key, string field, string value)
int GETRANGE(string key, int start, int end)
int PEXPIRE(string key, int milliseconds)
int CLUSTER_DELSLOTS(int slot)
int SSCAN(string key, int cursor, string match_pattern="", int count_count=0)
int MEMORY_USAGE(string key, int samples_count=0)
int SLOWLOG(string subcommand, string argument="")
int BITPOS(string key, int bit, int start=0, int end=0)
int MEMORY_MALLOC_STATS()
int ZREVRANGEBYSCORE(string key, float max, float min, string withscores="", int limit_offset=0, int limit_count=0)
int OBJECT(string subcommand, string arguments="")
int CLUSTER_ADDSLOTS(int slot)
int SREM(string key, string member)
int GEORADIUSBYMEMBER(string key, string member, float radius, string unit, string withcoord="", string withdist="", string withhash="", int count_count=0, string order="", string store_key="", string storedist_key="")
int MOVE(string key, int db)
int XPENDING(string key, string group, string start="", string end="", int count=0, string consumer="")
int RENAME(string key, string newkey)
int BITCOUNT(string key, int start=0, int end=0)
int GEOPOS(string key, string member)
int CLUSTER_SET_CONFIG_EPOCH(int config_epoch)
int SMOVE(string source, string destination, string member)
int CLUSTER_MEET(string ip, int port)
int DEBUG_OBJECT(string key)
int SWAPDB(int index, int index_1)
int PUBSUB(string subcommand, string argument="")
int ZRANK(string key, string member)
int RPUSH(string key, string value)
int ZLEXCOUNT(string key, string min, string max)