GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-27 21:41:01 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(core): fulfill del template request

Browse Source
This commit is contained in:
eeff
2023-03-17 10:16:24 +08:00
parent 7013d57914
commit 9648be1f02
3 changed files with 33 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/core/manager.c
+19
View File
@@ -326,6 +326,25 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data)
reply(manager, header, &e);
break;
}
case NEU_REQ_DEL_TEMPLATE: {
neu_resp_error_t e = { 0 };
neu_req_del_template_t *cmd = (neu_req_del_template_t *) &header[1];
if (strlen(cmd->name) > 0) {
e.error = neu_manager_del_template(manager, cmd->name);
} else {
neu_manager_clear_template(manager);
}
if (NEU_ERR_SUCCESS == e.error) {
// TODO: storage
}
header->type = NEU_RESP_ERROR;
strcpy(header->receiver, header->sender);
reply(manager, header, &e);
break;
}
case NEU_REQ_ADD_NODE: {
neu_req_add_node_t *cmd = (neu_req_add_node_t *) &header[1];
int error =
src/core/manager_internal.c
+10
View File
@@ -135,6 +135,16 @@ error:
return rv;
}
int neu_manager_del_template(neu_manager_t *manager, const char *name)
{
return neu_template_manager_del(manager->template_manager, name);
}
void neu_manager_clear_template(neu_manager_t *manager)
{
return neu_template_manager_clear(manager->template_manager);
}
UT_array *neu_manager_get_driver_group(neu_manager_t *manager)
{
UT_array *drivers =
src/core/manager_internal.h
+4 -2
View File
@@ -57,8 +57,10 @@ int neu_manager_del_node(neu_manager_t *manager, const char *node_name);
UT_array *neu_manager_get_nodes(neu_manager_t *manager, neu_node_type_e type,
const char *plugin, const char *node);
int neu_manager_add_template(neu_manager_t * manager,
neu_req_add_template_t *req);
int neu_manager_add_template(neu_manager_t * manager,
neu_req_add_template_t *req);
int neu_manager_del_template(neu_manager_t *manager, const char *name);
void neu_manager_clear_template(neu_manager_t *manager);
UT_array *neu_manager_get_driver_group(neu_manager_t *manager);