package protocol
Get desktop application:
View/edit binary Protocol Buffers messages
service BlobStore
protocol.proto:136rpc UploadBlob (stream , )
protocol.proto:137message
protocol.proto:112string name = 1
optional timestamp = 2
bytes data = 3
message
protocol.proto:118(message has no fields)
rpc FetchBlob (, )
protocol.proto:138message
protocol.proto:120string name = 1
message
protocol.proto:124optional timestamp = 1
rpc DownloadBlob (, stream )
protocol.proto:139message
protocol.proto:128string name = 1
message
protocol.proto:132bytes data = 1
service CacheStore
cache_store.proto:179rpc Ping (, )
cache_store.proto:180rpc Get (, )
cache_store.proto:181message
cache_store.proto:55string name = 1
message
cache_store.proto:59optional string value = 1
rpc Set (, )
cache_store.proto:182message
cache_store.proto:63repeated values = 1
message
cache_store.proto:67(message has no fields)
rpc Delete (, )
cache_store.proto:183message
cache_store.proto:69string name = 1
message
cache_store.proto:73(message has no fields)
rpc GetSet (, )
cache_store.proto:184message
cache_store.proto:75string key = 1
message
cache_store.proto:79repeated string members = 1
rpc SetSet (, )
cache_store.proto:185message
cache_store.proto:83string key = 1
repeated string members = 2
message
cache_store.proto:88(message has no fields)
rpc AddSet (, )
cache_store.proto:186message
cache_store.proto:90string key = 1
repeated string members = 2
message
cache_store.proto:95(message has no fields)
rpc RemSet (, )
cache_store.proto:187message
cache_store.proto:97string key = 1
repeated string members = 2
message
cache_store.proto:102(message has no fields)
rpc Push (, )
cache_store.proto:188message
cache_store.proto:104string name = 1
string value = 2
message
cache_store.proto:109(message has no fields)
rpc Pop (, )
cache_store.proto:189message
cache_store.proto:111string name = 1
message
cache_store.proto:115optional string value = 1
rpc Remain (, )
cache_store.proto:190message
cache_store.proto:119string name = 1
message
cache_store.proto:123int64 count = 1
rpc AddScores (, )
cache_store.proto:191message
cache_store.proto:127string collection = 1
string subset = 2
repeated documents = 3
message
cache_store.proto:133(message has no fields)
rpc SearchScores (, )
cache_store.proto:192message
cache_store.proto:135string collection = 1
string subset = 2
repeated string query = 3
int32 begin = 4
int32 end = 5
message
cache_store.proto:143repeated documents = 1
rpc DeleteScores (, )
cache_store.proto:193message
cache_store.proto:147repeated string collection = 1
optional condition = 2
message
cache_store.proto:152(message has no fields)
rpc UpdateScores (, )
cache_store.proto:194message
cache_store.proto:154repeated string collection = 1
optional string subset = 2
string id = 3
optional patch = 4
message
cache_store.proto:161(message has no fields)
message
cache_store.proto:163repeated points = 1
message
cache_store.proto:167(message has no fields)
message
cache_store.proto:169string name = 1
optional begin = 2
optional end = 3
message
cache_store.proto:175repeated points = 1
service DataStore
data_store.proto:225rpc Ping (, )
data_store.proto:226rpc BatchInsertItems (, )
data_store.proto:227message
data_store.proto:49repeated items = 1
message
data_store.proto:53(message has no fields)
rpc BatchGetItems (, )
data_store.proto:228message
data_store.proto:55repeated string item_ids = 1
message
data_store.proto:59repeated items = 1
rpc DeleteItem (, )
data_store.proto:229message
data_store.proto:63string item_id = 1
message
data_store.proto:67(message has no fields)
rpc GetItem (, )
data_store.proto:230message
data_store.proto:69string item_id = 1
message
data_store.proto:73optional item = 1
rpc ModifyItem (, )
data_store.proto:231message
data_store.proto:77string item_id = 1
optional patch = 2
message
data_store.proto:82(message has no fields)
rpc GetItems (, )
data_store.proto:232message
data_store.proto:84string cursor = 1
int32 n = 2
optional begin_time = 3
message
data_store.proto:90string cursor = 1
repeated items = 2
rpc GetItemFeedback (, )
data_store.proto:233message
data_store.proto:95string item_id = 1
repeated string feedback_types = 2
rpc BatchInsertUsers (, )
data_store.proto:234message
data_store.proto:100repeated users = 1
message
data_store.proto:104(message has no fields)
rpc DeleteUser (, )
data_store.proto:235message
data_store.proto:106string user_id = 1
message
data_store.proto:110(message has no fields)
rpc GetUser (, )
data_store.proto:236message
data_store.proto:112string user_id = 1
message
data_store.proto:116optional user = 1
rpc ModifyUser (, )
data_store.proto:237message
data_store.proto:120string user_id = 1
optional patch = 2
message
data_store.proto:125(message has no fields)
rpc GetUsers (, )
data_store.proto:238message
data_store.proto:127string cursor = 1
int32 n = 2
message
data_store.proto:132string cursor = 1
repeated users = 2
rpc GetUserFeedback (, )
data_store.proto:239message
data_store.proto:137string user_id = 1
optional end_time = 2
repeated string feedback_types = 3
message
data_store.proto:143string user_id = 1
string item_id = 2
repeated string feedback_types = 3
message
data_store.proto:149string user_id = 1
string item_id = 2
repeated string feedback_types = 3
message
data_store.proto:155int32 count = 1
message
data_store.proto:159repeated feedback = 1
bool insert_user = 2
bool insert_item = 3
bool overwrite = 4
message
data_store.proto:166(message has no fields)
rpc GetFeedback (, )
data_store.proto:243message
data_store.proto:168string cursor = 1
int32 n = 2
optional begin_time = 3
optional end_time = 4
repeated string feedback_types = 5
rpc GetUserStream (, stream )
data_store.proto:244message
data_store.proto:181int32 batch_size = 1
message
data_store.proto:185repeated users = 1
rpc GetItemStream (, stream )
data_store.proto:245message
data_store.proto:189int32 batch_size = 1
optional time_limit = 2
message
data_store.proto:194repeated items = 1
rpc GetFeedbackStream (, stream )
data_store.proto:246message
data_store.proto:198int32 batch_size = 1
optional scan_options = 2
message
data_store.proto:203repeated feedback = 1
rpc CountUsers (, )
data_store.proto:247message
data_store.proto:207(message has no fields)
message
data_store.proto:209int32 count = 1
rpc CountItems (, )
data_store.proto:248message
data_store.proto:213(message has no fields)
message
data_store.proto:215int32 count = 1
rpc CountFeedback (, )
data_store.proto:249message
data_store.proto:219(message has no fields)
message
data_store.proto:221int32 count = 1
service Master
protocol.proto:55rpc GetMeta (, )
protocol.proto:58meta distribute
message
protocol.proto:84NodeType node_type = 1
string uuid = 2
string binary_version = 4
string hostname = 5
message
protocol.proto:67string config = 1
int64 ranking_model_version = 3
int64 click_model_version = 4
string me = 5
repeated string servers = 6
repeated string workers = 7
rpc GetRankingModel (, stream )
protocol.proto:61data distribute
rpc GetClickModel (, stream )
protocol.proto:62rpc PushProgress (, )
protocol.proto:64message
protocol.proto:102repeated progress = 1
message
protocol.proto:106(message has no fields)
message
protocol.proto:40Used in: , ,
string namespace = 1
string feedback_type = 2
string user_id = 3
string item_id = 4
optional timestamp = 5
string comment = 6
message
protocol.proto:76Used as response type in: Master.GetClickModel, Master.GetRankingModel
bytes data = 1
message
data_store.proto:176Used as response type in: DataStore.GetFeedback, DataStore.GetItemFeedback, DataStore.GetUserFeedback, DataStore.GetUserItemFeedback
string cursor = 1
repeated feedback = 2
message
protocol.proto:30Used in: , , , ,
string namespace = 1
string item_id = 2
bool is_hidden = 3
repeated string categories = 4
optional timestamp = 5
bytes labels = 6
string comment = 7
message
data_store.proto:30Used in:
optional bool is_hidden = 1
repeated string categories = 2
optional timestamp = 3
bytes labels = 4
optional string comment = 5
message
encoding.proto:27string id = 1
repeated float data = 2
Used in:
Server = 0
Worker = 1
Client = 2
message
protocol.proto:108Used as request type in: CacheStore.Ping, DataStore.Ping
(message has no fields)
message
protocol.proto:110Used as response type in: CacheStore.Ping, DataStore.Ping
(message has no fields)
message
protocol.proto:91Used in:
string tracer = 1
string name = 2
string status = 3
string error = 4
int64 count = 5
int64 total = 6
int64 start_time = 7
int64 finish_time = 8
message
data_store.proto:38Used in:
optional string begin_user_id = 1
optional string end_user_id = 2
optional string begin_item_id = 3
optional string end_item_id = 4
optional begin_time = 5
optional end_time = 6
repeated string feedback_types = 7
bool order_by_item_id = 8
message
cache_store.proto:29Used in: ,
string id = 1
double score = 2
bool is_hidden = 3
repeated string categories = 4
optional timestamp = 5
message
cache_store.proto:37Used in:
optional string subset = 1
optional string id = 2
optional before = 3
message
cache_store.proto:43Used in:
optional bool is_hidden = 1
repeated string categories = 2
optional double score = 3
message
encoding.proto:21repeated string key = 1
repeated int32 shape = 2
repeated float data = 3
message
cache_store.proto:49Used in: ,
string name = 1
optional timestamp = 2
double value = 3
message
protocol.proto:23Used in: , , ,
string user_id = 1
bytes labels = 2
string comment = 3
repeated string subscribe = 4
message
data_store.proto:24Used in:
bytes labels = 1
optional string comment = 2
repeated string subscribe = 3
message
cache_store.proto:24Used in:
string name = 1
string value = 2
message
protocol.proto:80Used as request type in: Master.GetClickModel, Master.GetRankingModel
int64 version = 1