(Piper) Node Monitor API

---

1 Base API Url

---

[GET/POST],POST则使用json格式

[http:]xxxx:8617/efm.doaction?ac=action

---

2 node manage

---

名称	接口说明	参数说明	约束
addResource	add resource socket	type=SQL/NOSQL/INSTRUCTION&socket={json}
removeResource	remove resource socket	type=SQL&name=socketName	Be care full,this will remove all relative instance
getNodeConfig	get node start run configure parameters.	None
setNodeConfig	set node start configure parameters,will auto write into file.	k=instances&v=test:1&type=set/remove
getStatus	get node environmental state.	None
startSearcherService	open node searcher service	None
stopSearcherService	stop node searcher service	None
startHttpReaderServiceService	start node http reader pipe service	None
stopHttpReaderServiceService	stop node http reader pipe service	None
restartNode	restart node	None
loadHandler	Loading Java handler classes in real time	None	only support no dependency handler like org.elasticflow.writerUnit.handler

---

---

3 instance manage

---

名称	接口说明	参数说明	约束
getInstances	get all instances info	None
getInstanceSeqs	get instance L1seqs	{"instance":"xxx"}
cloneInstance	Clone the instance	{"instance":"test","new_instance_name":"test_new"}
resetInstanceState	reset Instance full+increment running state	{"instance":"xxx"}
reloadInstanceConfig	reload instance config and rebuild instance task	{"instance":"xx","reset":"true/false"}	reset true will recreate the instance in java from instance configure.
runNow	Perform the instance task immediately	{"instance":"xx","type":"full/increment"}
addInstance	push instance to system	{"instance":"xxx:1"}
stopInstance	stop instance job	{"instance=xxx":"type":"full/increment"}
resumeInstance	resume instance job	{"instance=xxx":"type":"full/increment"}
removeInstance	remove instance stop relate jobs and save to configure file.	{"instance":"xxx"}
deleteInstanceData	delete Instance Data through alias or Instance data name	{"instance":"xxx"}
getInstanceInfo	get instance detail informations.	{"instance":"xxx"}
runCode	run ElasticFlow CPU instruction program.	{"script":"script content"}
setInstancePipeConfig	Modify task configure	{"instance":"xxx","param.name":"TransParam.multiThread","param.value":false}