Coverage for src / mysingle / protos / services / backtest / v1 / backtest_service_pb2_grpc.py: 0%

1# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! 

2"""Client and server classes corresponding to protobuf-defined services.""" 

3 

4import grpc 

5 

6from mysingle.protos.services.backtest.v1 import ( 

7 backtest_service_pb2 as services_dot_backtest_dot_v1_dot_backtest__service__pb2, 

8) 

9 

10 

11class BacktestServiceStub(object): 

12 """BacktestService service definition for executing and monitoring strategy backtests.""" 

13 

14 def __init__(self, channel): 

15 """Constructor. 

16 

17 Args: 

18 channel: A grpc.Channel. 

19 """ 

20 self.ExecuteBacktest = channel.unary_unary( 

21 "/backtest.BacktestService/ExecuteBacktest", 

22 request_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ExecuteBacktestRequest.SerializeToString, 

23 response_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ExecuteBacktestResponse.FromString, 

24 _registered_method=True, 

25 ) 

26 self.GetBacktestResult = channel.unary_unary( 

27 "/backtest.BacktestService/GetBacktestResult", 

28 request_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.GetBacktestResultRequest.SerializeToString, 

29 response_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.BacktestResultResponse.FromString, 

30 _registered_method=True, 

31 ) 

32 self.StreamBacktestProgress = channel.unary_stream( 

33 "/backtest.BacktestService/StreamBacktestProgress", 

34 request_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.StreamProgressRequest.SerializeToString, 

35 response_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ProgressUpdate.FromString, 

36 _registered_method=True, 

37 ) 

38 self.GetBacktestMetrics = channel.unary_unary( 

39 "/backtest.BacktestService/GetBacktestMetrics", 

40 request_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.GetMetricsRequest.SerializeToString, 

41 response_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.MetricsResponse.FromString, 

42 _registered_method=True, 

43 ) 

44 self.ListBacktests = channel.unary_unary( 

45 "/backtest.BacktestService/ListBacktests", 

46 request_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ListBacktestsRequest.SerializeToString, 

47 response_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ListBacktestsResponse.FromString, 

48 _registered_method=True, 

49 ) 

50 self.CancelBacktest = channel.unary_unary( 

51 "/backtest.BacktestService/CancelBacktest", 

52 request_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.CancelBacktestRequest.SerializeToString, 

53 response_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.CancelBacktestResponse.FromString, 

54 _registered_method=True, 

55 ) 

56 self.HealthCheck = channel.unary_unary( 

57 "/backtest.BacktestService/HealthCheck", 

58 request_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.HealthCheckRequest.SerializeToString, 

59 response_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.HealthCheckResponse.FromString, 

60 _registered_method=True, 

61 ) 

62 

63 

64class BacktestServiceServicer(object): 

65 """BacktestService service definition for executing and monitoring strategy backtests.""" 

66 

67 def ExecuteBacktest(self, request, context): 

68 """Execute backtest for a strategy""" 

69 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

70 context.set_details("Method not implemented!") 

71 raise NotImplementedError("Method not implemented!") 

72 

73 def GetBacktestResult(self, request, context): 

74 """Get backtest result by ID""" 

75 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

76 context.set_details("Method not implemented!") 

77 raise NotImplementedError("Method not implemented!") 

78 

79 def StreamBacktestProgress(self, request, context): 

80 """Stream backtest progress updates""" 

81 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

82 context.set_details("Method not implemented!") 

83 raise NotImplementedError("Method not implemented!") 

84 

85 def GetBacktestMetrics(self, request, context): 

86 """Get backtest metrics""" 

87 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

88 context.set_details("Method not implemented!") 

89 raise NotImplementedError("Method not implemented!") 

90 

91 def ListBacktests(self, request, context): 

92 """List backtests for a user""" 

93 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

94 context.set_details("Method not implemented!") 

95 raise NotImplementedError("Method not implemented!") 

96 

97 def CancelBacktest(self, request, context): 

98 """Cancel a running backtest""" 

99 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

100 context.set_details("Method not implemented!") 

101 raise NotImplementedError("Method not implemented!") 

102 

103 def HealthCheck(self, request, context): 

104 """Health check""" 

105 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

106 context.set_details("Method not implemented!") 

107 raise NotImplementedError("Method not implemented!") 

108 

109 

110def add_BacktestServiceServicer_to_server(servicer, server): 

111 rpc_method_handlers = { 

112 "ExecuteBacktest": grpc.unary_unary_rpc_method_handler( 

113 servicer.ExecuteBacktest, 

114 request_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ExecuteBacktestRequest.FromString, 

115 response_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ExecuteBacktestResponse.SerializeToString, 

116 ), 

117 "GetBacktestResult": grpc.unary_unary_rpc_method_handler( 

118 servicer.GetBacktestResult, 

119 request_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.GetBacktestResultRequest.FromString, 

120 response_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.BacktestResultResponse.SerializeToString, 

121 ), 

122 "StreamBacktestProgress": grpc.unary_stream_rpc_method_handler( 

123 servicer.StreamBacktestProgress, 

124 request_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.StreamProgressRequest.FromString, 

125 response_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ProgressUpdate.SerializeToString, 

126 ), 

127 "GetBacktestMetrics": grpc.unary_unary_rpc_method_handler( 

128 servicer.GetBacktestMetrics, 

129 request_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.GetMetricsRequest.FromString, 

130 response_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.MetricsResponse.SerializeToString, 

131 ), 

132 "ListBacktests": grpc.unary_unary_rpc_method_handler( 

133 servicer.ListBacktests, 

134 request_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ListBacktestsRequest.FromString, 

135 response_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.ListBacktestsResponse.SerializeToString, 

136 ), 

137 "CancelBacktest": grpc.unary_unary_rpc_method_handler( 

138 servicer.CancelBacktest, 

139 request_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.CancelBacktestRequest.FromString, 

140 response_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.CancelBacktestResponse.SerializeToString, 

141 ), 

142 "HealthCheck": grpc.unary_unary_rpc_method_handler( 

143 servicer.HealthCheck, 

144 request_deserializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.HealthCheckRequest.FromString, 

145 response_serializer=services_dot_backtest_dot_v1_dot_backtest__service__pb2.HealthCheckResponse.SerializeToString, 

146 ), 

147 } 

148 generic_handler = grpc.method_handlers_generic_handler( 

149 "backtest.BacktestService", rpc_method_handlers 

150 ) 

151 server.add_generic_rpc_handlers((generic_handler,)) 

152 server.add_registered_method_handlers( 

153 "backtest.BacktestService", rpc_method_handlers 

154 ) 

155 

156 

157# This class is part of an EXPERIMENTAL API. 

158class BacktestService(object): 

159 """BacktestService service definition for executing and monitoring strategy backtests.""" 

160 

161 @staticmethod 

162 def ExecuteBacktest( 

163 request, 

164 target, 

165 options=(), 

166 channel_credentials=None, 

167 call_credentials=None, 

168 insecure=False, 

169 compression=None, 

170 wait_for_ready=None, 

171 timeout=None, 

172 metadata=None, 

173 ): 

174 return grpc.experimental.unary_unary( 

175 request, 

176 target, 

177 "/backtest.BacktestService/ExecuteBacktest", 

178 services_dot_backtest_dot_v1_dot_backtest__service__pb2.ExecuteBacktestRequest.SerializeToString, 

179 services_dot_backtest_dot_v1_dot_backtest__service__pb2.ExecuteBacktestResponse.FromString, 

180 options, 

181 channel_credentials, 

182 insecure, 

183 call_credentials, 

184 compression, 

185 wait_for_ready, 

186 timeout, 

187 metadata, 

188 _registered_method=True, 

189 ) 

190 

191 @staticmethod 

192 def GetBacktestResult( 

193 request, 

194 target, 

195 options=(), 

196 channel_credentials=None, 

197 call_credentials=None, 

198 insecure=False, 

199 compression=None, 

200 wait_for_ready=None, 

201 timeout=None, 

202 metadata=None, 

203 ): 

204 return grpc.experimental.unary_unary( 

205 request, 

206 target, 

207 "/backtest.BacktestService/GetBacktestResult", 

208 services_dot_backtest_dot_v1_dot_backtest__service__pb2.GetBacktestResultRequest.SerializeToString, 

209 services_dot_backtest_dot_v1_dot_backtest__service__pb2.BacktestResultResponse.FromString, 

210 options, 

211 channel_credentials, 

212 insecure, 

213 call_credentials, 

214 compression, 

215 wait_for_ready, 

216 timeout, 

217 metadata, 

218 _registered_method=True, 

219 ) 

220 

221 @staticmethod 

222 def StreamBacktestProgress( 

223 request, 

224 target, 

225 options=(), 

226 channel_credentials=None, 

227 call_credentials=None, 

228 insecure=False, 

229 compression=None, 

230 wait_for_ready=None, 

231 timeout=None, 

232 metadata=None, 

233 ): 

234 return grpc.experimental.unary_stream( 

235 request, 

236 target, 

237 "/backtest.BacktestService/StreamBacktestProgress", 

238 services_dot_backtest_dot_v1_dot_backtest__service__pb2.StreamProgressRequest.SerializeToString, 

239 services_dot_backtest_dot_v1_dot_backtest__service__pb2.ProgressUpdate.FromString, 

240 options, 

241 channel_credentials, 

242 insecure, 

243 call_credentials, 

244 compression, 

245 wait_for_ready, 

246 timeout, 

247 metadata, 

248 _registered_method=True, 

249 ) 

250 

251 @staticmethod 

252 def GetBacktestMetrics( 

253 request, 

254 target, 

255 options=(), 

256 channel_credentials=None, 

257 call_credentials=None, 

258 insecure=False, 

259 compression=None, 

260 wait_for_ready=None, 

261 timeout=None, 

262 metadata=None, 

263 ): 

264 return grpc.experimental.unary_unary( 

265 request, 

266 target, 

267 "/backtest.BacktestService/GetBacktestMetrics", 

268 services_dot_backtest_dot_v1_dot_backtest__service__pb2.GetMetricsRequest.SerializeToString, 

269 services_dot_backtest_dot_v1_dot_backtest__service__pb2.MetricsResponse.FromString, 

270 options, 

271 channel_credentials, 

272 insecure, 

273 call_credentials, 

274 compression, 

275 wait_for_ready, 

276 timeout, 

277 metadata, 

278 _registered_method=True, 

279 ) 

280 

281 @staticmethod 

282 def ListBacktests( 

283 request, 

284 target, 

285 options=(), 

286 channel_credentials=None, 

287 call_credentials=None, 

288 insecure=False, 

289 compression=None, 

290 wait_for_ready=None, 

291 timeout=None, 

292 metadata=None, 

293 ): 

294 return grpc.experimental.unary_unary( 

295 request, 

296 target, 

297 "/backtest.BacktestService/ListBacktests", 

298 services_dot_backtest_dot_v1_dot_backtest__service__pb2.ListBacktestsRequest.SerializeToString, 

299 services_dot_backtest_dot_v1_dot_backtest__service__pb2.ListBacktestsResponse.FromString, 

300 options, 

301 channel_credentials, 

302 insecure, 

303 call_credentials, 

304 compression, 

305 wait_for_ready, 

306 timeout, 

307 metadata, 

308 _registered_method=True, 

309 ) 

310 

311 @staticmethod 

312 def CancelBacktest( 

313 request, 

314 target, 

315 options=(), 

316 channel_credentials=None, 

317 call_credentials=None, 

318 insecure=False, 

319 compression=None, 

320 wait_for_ready=None, 

321 timeout=None, 

322 metadata=None, 

323 ): 

324 return grpc.experimental.unary_unary( 

325 request, 

326 target, 

327 "/backtest.BacktestService/CancelBacktest", 

328 services_dot_backtest_dot_v1_dot_backtest__service__pb2.CancelBacktestRequest.SerializeToString, 

329 services_dot_backtest_dot_v1_dot_backtest__service__pb2.CancelBacktestResponse.FromString, 

330 options, 

331 channel_credentials, 

332 insecure, 

333 call_credentials, 

334 compression, 

335 wait_for_ready, 

336 timeout, 

337 metadata, 

338 _registered_method=True, 

339 ) 

340 

341 @staticmethod 

342 def HealthCheck( 

343 request, 

344 target, 

345 options=(), 

346 channel_credentials=None, 

347 call_credentials=None, 

348 insecure=False, 

349 compression=None, 

350 wait_for_ready=None, 

351 timeout=None, 

352 metadata=None, 

353 ): 

354 return grpc.experimental.unary_unary( 

355 request, 

356 target, 

357 "/backtest.BacktestService/HealthCheck", 

358 services_dot_backtest_dot_v1_dot_backtest__service__pb2.HealthCheckRequest.SerializeToString, 

359 services_dot_backtest_dot_v1_dot_backtest__service__pb2.HealthCheckResponse.FromString, 

360 options, 

361 channel_credentials, 

362 insecure, 

363 call_credentials, 

364 compression, 

365 wait_for_ready, 

366 timeout, 

367 metadata, 

368 _registered_method=True, 

369 )