134 lines
2.6 KiB
Protocol Buffer
134 lines
2.6 KiB
Protocol Buffer
syntax = "proto3";
|
|
|
|
|
|
message Empty {}
|
|
|
|
//Event-relative area
|
|
|
|
message DiscoveryEvent {
|
|
string agentId = 1;
|
|
string taskId = 2;
|
|
enum DiscoveryEventType {
|
|
DISCOVERY_START = 0;
|
|
DISCOVERY_HOST_START = 1;
|
|
DISCOVERY_HOST_FOUND = 2;
|
|
DISCOVERY_HOST_DONE = 3;
|
|
DISCOVERY_PORT_START = 4;
|
|
DISCOVERY_PORT_FOUND = 5;
|
|
DISCOVERY_PORT_DONE = 6;
|
|
DISCOVERY_SERVICE_START = 7;
|
|
DISCOVERY_SERVICE_FOUND = 8;
|
|
DISCOVERY_SERVICE_DONE = 9;
|
|
DISCOVERY_DONE = 10;
|
|
}
|
|
DiscoveryEventType evtType = 3;
|
|
int64 occurredDate = 4;
|
|
map<string, string> data = 5;
|
|
}
|
|
|
|
service Discovery {
|
|
rpc event(DiscoveryEvent) returns (Empty){}
|
|
}
|
|
|
|
|
|
enum TaskResultState {
|
|
FAILED = 0;
|
|
SUCCEED = 1;
|
|
PROCEEDING = 2;
|
|
}
|
|
|
|
message TaskResultEvent {
|
|
string agentId = 1;
|
|
string taskId = 2;
|
|
enum TaskResultEventType {
|
|
TASK_POL_INTERVAL_UPDATE = 0;
|
|
TASK_SENSOR_START = 1;
|
|
TASK_SENSOR_STOP = 2;
|
|
TASK_SENSOR_ADD = 3;
|
|
TASK_SENSOR_REMOVE = 4;
|
|
TASK_SENSOR_UPDATE = 5;
|
|
TASK_CRAWLER_UPDATE = 6;
|
|
TASK_AGENT_UPDATE = 7;
|
|
TASK_LOG_SEND = 8;
|
|
}
|
|
TaskResultEventType evtType = 3;
|
|
int64 occurredDate = 4;
|
|
TaskResultState result = 5;
|
|
string description = 6;
|
|
}
|
|
|
|
service TaskResult {
|
|
rpc event(TaskResultEvent) returns (Empty){}
|
|
}
|
|
|
|
|
|
message AgentEvent {
|
|
string agentId = 1;
|
|
enum AgentEventType {
|
|
AGENT_STARTED = 0;
|
|
AGENT_ERROR = 1;
|
|
AGENT_STOP = 2;
|
|
}
|
|
AgentEventType evtType = 2;
|
|
int64 occurredDate = 3;
|
|
string description = 4;
|
|
message ErrorInfo {
|
|
int32 errorNum = 1;
|
|
string from = 2;
|
|
string errorMessage = 3;
|
|
}
|
|
ErrorInfo errInfo = 5;
|
|
}
|
|
|
|
service Event {
|
|
rpc event(AgentEvent) returns (Empty){}
|
|
}
|
|
//Event-relative area
|
|
|
|
|
|
//Data-relative area
|
|
message CollectedData {
|
|
string agentId = 1;
|
|
string sensorId = 2;
|
|
map<string, string> data = 3;
|
|
int64 startDate = 4;
|
|
int64 finishDate = 5;
|
|
}
|
|
|
|
service Data {
|
|
rpc sendMetric(CollectedData) returns (Empty) {}
|
|
rpc sendMeta(CollectedData) returns (Empty) {}
|
|
}
|
|
//Data-relative area
|
|
|
|
|
|
//Task polling-relative area
|
|
message TaskInfo {
|
|
string command = 1;
|
|
string taskId = 2;
|
|
map<string, string> data = 3;
|
|
}
|
|
|
|
message TaskList {
|
|
repeated TaskInfo taskList = 1;
|
|
}
|
|
|
|
service Task {
|
|
rpc requestTask(Empty) returns (TaskList) {}
|
|
}
|
|
//Task polling-relative area
|
|
|
|
|
|
//Init-relative area
|
|
message AgentInfo {
|
|
string agentId = 1;
|
|
}
|
|
|
|
message InitResponse {
|
|
string secretKey = 1;
|
|
}
|
|
|
|
service Initializer {
|
|
rpc agentStarting(AgentInfo) returns (InitResponse) {}
|
|
}
|
|
//Init-relative area |