diff options
| author | zhengchao <[email protected]> | 2022-03-20 21:16:04 +0500 |
|---|---|---|
| committer | zhengchao <[email protected]> | 2022-03-20 21:16:04 +0500 |
| commit | 87dde891c21d00b7d7e0d6e2aefe1b50b3da5518 (patch) | |
| tree | b4e9eae0651a91d7fa235665f1612093d7ded91b /include | |
| parent | 23e3d7e87dbe40659e3c8dc52cb59ff2fcee3dea (diff) | |
keyspace使用独立的event base,避免中断net中的event loop
Diffstat (limited to 'include')
| -rw-r--r-- | include/swarmkv/swarmkv.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/include/swarmkv/swarmkv.h b/include/swarmkv/swarmkv.h index cd1ad94..7bcb841 100644 --- a/include/swarmkv/swarmkv.h +++ b/include/swarmkv/swarmkv.h @@ -48,12 +48,14 @@ int swarmkv_options_set_bind_address(struct swarmkv_options *opts, const char* i int swarmkv_options_set_logger(struct swarmkv_options *opts, void *logger); int swarmkv_options_set_consul_port(struct swarmkv_options *opts, unsigned int consul_port); int swarmkv_options_set_dryrun(struct swarmkv_options *opts); +int swarmkv_options_set_worker_thread_number(struct swarmkv_options *opts, size_t nr_worker_threads); struct swarmkv *swarmkv_open(struct swarmkv_options *opts, const char * db_name, char **err); void swarmkv_close(struct swarmkv * db); +struct swarmkv_reply* swarmkv_command(struct swarmkv *db, const char *format, ...); void swarmkv_get_string(struct swarmkv * db, const char * key, size_t keylen, swarmkv_cmd_callback_func_t * cb, void * arg); |
