File tree Expand file tree Collapse file tree 1 file changed +8
-1
lines changed Expand file tree Collapse file tree 1 file changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -17,6 +17,8 @@ use std::thread::sleep;
17
17
use std:: time:: Duration ;
18
18
19
19
use common_base:: base:: tokio;
20
+ use common_meta_client:: to_digit_ver;
21
+ use common_meta_client:: MIN_METASRV_SEMVER ;
20
22
use common_meta_types:: protobuf:: meta_service_server:: MetaService ;
21
23
use common_meta_types:: protobuf:: meta_service_server:: MetaServiceServer ;
22
24
use common_meta_types:: protobuf:: ClientInfo ;
@@ -51,7 +53,12 @@ impl MetaService for GrpcServiceForTestImpl {
51
53
_request : Request < Streaming < common_meta_types:: protobuf:: HandshakeRequest > > ,
52
54
) -> Result < Response < Self :: HandshakeStream > , Status > {
53
55
tokio:: time:: sleep ( Duration :: from_secs ( 2 ) ) . await ;
54
- let output = futures:: stream:: once ( async { Ok ( HandshakeResponse :: default ( ) ) } ) ;
56
+ let output = futures:: stream:: once ( async {
57
+ Ok ( HandshakeResponse {
58
+ protocol_version : to_digit_ver ( & MIN_METASRV_SEMVER ) ,
59
+ payload : vec ! [ ] ,
60
+ } )
61
+ } ) ;
55
62
Ok ( Response :: new ( Box :: pin ( output) ) )
56
63
}
57
64
You can’t perform that action at this time.
0 commit comments