package grpc
Get desktop application:
View/edit binary Protocol Buffers messages
rpc Connect (, stream )
dependencies_service_v2.proto:43message
dependencies_service_v2.proto:13string node_key = 1
message
dependencies_service_v2.proto:23DependenciesServiceV2Code code = 1
string task_id = 2
string lang = 3
string proxy = 4
repeated dependencies = 5
rpc Sync (, )
dependencies_service_v2.proto:44message
dependencies_service_v2.proto:31string node_key = 1
string lang = 2
repeated dependencies = 3
rpc UpdateTaskLog (stream , )
dependencies_service_v2.proto:45message
dependencies_service_v2.proto:37string task_id = 1
repeated string log_lines = 2
rpc Connect (stream , stream )
message_service.proto:9
rpc Send (, )
metrics_service_v2.proto:28message
metrics_service_v2.proto:8string type = 1
string node_key = 2
int64 timestamp = 3
float cpu_usage_percent = 4
uint64 total_memory = 5
uint64 available_memory = 6
uint64 used_memory = 7
float used_memory_percent = 8
uint64 total_disk = 9
uint64 available_disk = 10
uint64 used_disk = 11
float used_disk_percent = 12
float disk_read_bytes_rate = 15
float disk_write_bytes_rate = 16
float network_bytes_sent_rate = 17
float network_bytes_recv_rate = 18
rpc GetById (, )
model_base_service.proto:10rpc Get (, )
model_base_service.proto:11rpc GetList (, )
model_base_service.proto:12rpc Delete (, )
model_base_service.proto:14rpc Update (, )
model_base_service.proto:18rpc UpdateDoc (, )
model_base_service.proto:19rpc Insert (, )
model_base_service.proto:20rpc Count (, )
model_base_service.proto:21
message
model_service_v2_request.proto:6string node_key = 1
string model_type = 2
string id = 3
rpc GetOne (, )
model_base_service_v2.proto:11string node_key = 1
string model_type = 2
bytes query = 3
bytes find_options = 4
string node_key = 1
string model_type = 2
bytes query = 3
bytes find_options = 4
string node_key = 1
string model_type = 2
string id = 3
string node_key = 1
string model_type = 2
bytes query = 3
string node_key = 1
string model_type = 2
bytes query = 3
string node_key = 1
string model_type = 2
string id = 3
bytes update = 4
string node_key = 1
string model_type = 2
bytes query = 3
bytes update = 4
string node_key = 1
string model_type = 2
bytes query = 3
bytes update = 4
string node_key = 1
string model_type = 2
string id = 3
bytes model = 4
string node_key = 1
string model_type = 2
bytes query = 3
bytes model = 4
string node_key = 1
string model_type = 2
bytes model = 3
string node_key = 1
string model_type = 2
bytes models = 3
rpc Count (, )
model_base_service_v2.proto:23string node_key = 1
string model_type = 2
bytes query = 3
rpc Do (, )
model_delegate.proto:10
service NodeService
node_service.proto:21rpc Register (, )
node_service.proto:22message
node_service.proto:10string key = 1
string name = 2
bool isMaster = 3
string authKey = 4
int32 maxRunners = 5
rpc SendHeartbeat (, )
node_service.proto:23message
node_service.proto:17string key = 1
rpc Subscribe (, stream )
node_service.proto:24rpc Unsubscribe (, )
node_service.proto:25
rpc Register (, )
plugin_service.proto:11rpc Subscribe (, stream )
plugin_service.proto:12rpc Poll (stream , stream )
plugin_service.proto:13
service TaskService
task_service.proto:15rpc Subscribe (stream , )
task_service.proto:16rpc Fetch (, )
task_service.proto:17message
task_service.proto:10string node_key = 1
string task_id = 2
Used in:
SYNC = 0
INSTALL = 1
UNINSTALL = 2
message
dependencies_service_v2.proto:8Used in: ,
string name = 1
string version = 2
message
node.proto:6string _id = 1
string name = 2
string ip = 3
string port = 5
string mac = 6
string hostname = 7
string description = 8
string key = 9
bool is_master = 11
string update_ts = 12
string create_ts = 13
int64 update_ts_unix = 14
message
node_info.proto:6string key = 1
bool is_master = 2
message
plugin_request.proto:6Used as request type in: PluginService.Register, PluginService.Subscribe
string name = 1
string node_key = 2
bytes data = 3
message
request.proto:6Used as request type in: ModelBaseService.Count, ModelBaseService.Delete, ModelBaseService.DeleteById, ModelBaseService.DeleteList, ModelBaseService.ForceDeleteList, ModelBaseService.Get, ModelBaseService.GetById, ModelBaseService.GetList, ModelBaseService.Insert, ModelBaseService.Update, ModelBaseService.UpdateById, ModelBaseService.UpdateDoc, ModelDelegate.Do, NodeService.Subscribe, NodeService.Unsubscribe, TaskService.Fetch
string node_key = 1
bytes data = 2
message
response.proto:8Used as response type in: DependenciesServiceV2.Sync, DependenciesServiceV2.UpdateTaskLog, MetricsServiceV2.Send, ModelBaseService.Count, ModelBaseService.Delete, ModelBaseService.DeleteById, ModelBaseService.DeleteList, ModelBaseService.ForceDeleteList, ModelBaseService.Get, ModelBaseService.GetById, ModelBaseService.GetList, ModelBaseService.Insert, ModelBaseService.Update, ModelBaseService.UpdateById, ModelBaseService.UpdateDoc, ModelBaseServiceV2.Count, ModelBaseServiceV2.DeleteById, ModelBaseServiceV2.DeleteMany, ModelBaseServiceV2.DeleteOne, ModelBaseServiceV2.GetById, ModelBaseServiceV2.GetMany, ModelBaseServiceV2.GetOne, ModelBaseServiceV2.InsertMany, ModelBaseServiceV2.InsertOne, ModelBaseServiceV2.ReplaceById, ModelBaseServiceV2.ReplaceOne, ModelBaseServiceV2.UpdateById, ModelBaseServiceV2.UpdateMany, ModelBaseServiceV2.UpdateOne, ModelDelegate.Do, NodeService.Register, NodeService.SendHeartbeat, NodeService.Unsubscribe, PluginService.Register, TaskService.Fetch, TaskService.SendNotification, TaskService.Subscribe
ResponseCode code = 1
string message = 2
bytes data = 3
string error = 4
int64 total = 5
message
stream_message.proto:8Used as request type in: MessageService.Connect, PluginService.Poll, TaskService.Subscribe
Used as response type in: MessageService.Connect, NodeService.Subscribe, PluginService.Poll, PluginService.Subscribe
StreamMessageCode code = 1
string node_key = 2
string key = 3
string from = 4
string to = 5
bytes data = 6
string error = 7
Used in:
PING = 0
ping worker nodes to check their health
RUN_TASK = 1
ask worker node(s) to run task with given id
CANCEL_TASK = 2
ask worker node(s) to cancel task with given id
INSERT_DATA = 3
insert data
INSERT_LOGS = 4
insert logs
SEND_EVENT = 5
send event
INSTALL_PLUGIN = 6
install plugin
UNINSTALL_PLUGIN = 7
uninstall plugin
START_PLUGIN = 8
start plugin
STOP_PLUGIN = 9
stop plugin
CONNECT = 10
connect
DISCONNECT = 11
disconnect
SEND = 12
send
message
stream_message_data_task.proto:6string task_id = 1
string data = 2
message
task.proto:6string _id = 1
string spider_id = 2
string status = 5
string node_id = 6
string cmd = 8
string param = 9
string error = 10
int32 pid = 16
string run_type = 17
string schedule_id = 18
string type = 19