diff options
Diffstat (limited to 'src/swarmkv.c')
| -rw-r--r-- | src/swarmkv.c | 24 |
1 files changed, 24 insertions, 0 deletions
diff --git a/src/swarmkv.c b/src/swarmkv.c index d3013ef..34f3ae8 100644 --- a/src/swarmkv.c +++ b/src/swarmkv.c @@ -26,6 +26,7 @@ #include "t_bloom_filter.h" #include "t_cms.h" #include "t_hyperloglog.h" +#include "t_spread_sketch.h" #include "uthash.h" #include "sds.h" @@ -1177,6 +1178,29 @@ void command_spec_init(struct swarmkv *db) 1, 1, CMD_KEY_RO, REPLY_EMPTY_ARRAY, AUTO_ROUTE, pfinfo_command, db->mod_store); + /*Spread sketch commands*/ + swarmkv_command_table_register(db->mod_command_table, "SSINITBYDIM", "key width depth precision [TIME window-milliseconds]", + 4, 1, CMD_KEY_OW, REPLY_EMPTY_ARRAY, AUTO_ROUTE, + ssinitbydim_command, db->mod_store); + swarmkv_command_table_register(db->mod_command_table, "SSINITBYCAPACITY", "key capacity precision [TIME window-milliseconds]*/", + 3, 1, CMD_KEY_OW, REPLY_EMPTY_ARRAY, AUTO_ROUTE, + ssinitbycapacity_command, db->mod_store); + swarmkv_command_table_register(db->mod_command_table, "SSADD", "key entry item [item ...] ", + 3, 1, CMD_KEY_RW, REPLY_INT_MINORS1, AUTO_ROUTE, + ssadd_command, db->mod_store); + swarmkv_command_table_register(db->mod_command_table, "SSLIST", "key", + 1, 1, CMD_KEY_RO, REPLY_EMPTY_ARRAY, AUTO_ROUTE, + sslist_command, db->mod_store); + swarmkv_command_table_register(db->mod_command_table, "SSQUERY", "key entry", + 2, 1, CMD_KEY_RO, REPLY_INT_0, AUTO_ROUTE, + ssquery_command, db->mod_store); + swarmkv_command_table_register(db->mod_command_table, "SSMQUERY", "key entry [entry ...]", + 2, 1, CMD_KEY_RO, REPLY_EMPTY_ARRAY, AUTO_ROUTE, + ssmquery_command, db->mod_store); + swarmkv_command_table_register(db->mod_command_table, "SSINFO", "key", + 1, 1, CMD_KEY_RO, REPLY_EMPTY_ARRAY, AUTO_ROUTE, + ssinfo_command, db->mod_store); + /* Debug Commands */ swarmkv_command_table_register(db->mod_command_table, "INFO", "[section]", 0, KEY_OFFSET_NONE, CMD_KEY_NA, REPLY_NA, AUTO_ROUTE, |