forked from MistEO/Pallas-Bot
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
基于gRPC包装了pymongo中的若干个方法,使客户端无感(真的吗)切换到通过rpc
- Loading branch information
Showing
13 changed files
with
1,103 additions
and
7 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,81 @@ | ||
syntax = "proto3"; | ||
|
||
package pymongoRPC; | ||
|
||
service MongoDBService { | ||
rpc Find(FindRequest) returns (FindResponse); | ||
rpc FindOne(FindOneRequest) returns (FindOneResponse); | ||
rpc InsertOne(InsertOneRequest) returns (InsertOneResponse); | ||
rpc InsertMany(InsertManyRequest) returns (InsertManyResponse); | ||
rpc UpdateOne(UpdateOneRequest) returns (UpdateOneResponse); | ||
rpc DeleteMany(DeleteManyRequest) returns (DeleteManyResponse); | ||
rpc CreateIndex(CreateIndexRequest) returns (CreateIndexResponse); | ||
} | ||
|
||
message FindRequest { | ||
string collection = 1; | ||
string filter = 2; // JSON | ||
} | ||
|
||
message FindResponse { | ||
string documents = 1; // JSON | ||
} | ||
|
||
message FindOneRequest { | ||
string collection = 1; | ||
string filter = 2; // JSON | ||
} | ||
|
||
message FindOneResponse { | ||
string document = 1; // JSON | ||
} | ||
|
||
message InsertOneRequest { | ||
string collection = 1; | ||
string document = 2; // JSON | ||
} | ||
|
||
message InsertOneResponse { | ||
string insertedId = 1; | ||
} | ||
|
||
message InsertManyRequest { | ||
string collection = 1; | ||
string documents = 2; //JSON | ||
} | ||
|
||
message InsertManyResponse { | ||
string insertedIds = 1; | ||
} | ||
|
||
message UpdateOneRequest { | ||
string collection = 1; | ||
string filter = 2; // JSON | ||
string update = 3; // JSON | ||
bool upsert = 4; | ||
} | ||
|
||
message UpdateOneResponse { | ||
int32 matchedCount = 1; | ||
int32 modifiedCount = 2; | ||
} | ||
|
||
message DeleteManyRequest { | ||
string collection = 1; | ||
string filter = 2; // JSON | ||
} | ||
|
||
message DeleteManyResponse { | ||
int32 deletedCount = 1; | ||
} | ||
|
||
message CreateIndexRequest { | ||
string collection = 1; | ||
string keys = 2; // JSON | ||
string name = 3; | ||
string default_language = 4; | ||
} | ||
|
||
message CreateIndexResponse { | ||
string indexName = 1; | ||
} |
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
Oops, something went wrong.