Coverage for src / mysingle / protos / services / ml / v1 / ml_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.ml.v1 import ( 

7 ml_service_pb2 as services_dot_ml_dot_v1_dot_ml__service__pb2, 

8) 

9 

10 

11class MLServiceStub(object): 

12 """ML Service - gRPC API used for ML prediction, walk-forward optimization, and 

13 feature storage workflows. 

14 """ 

15 

16 def __init__(self, channel): 

17 """Constructor. 

18 

19 Args: 

20 channel: A grpc.Channel. 

21 """ 

22 self.OptimizeParameters = channel.unary_stream( 

23 "/ml.MLService/OptimizeParameters", 

24 request_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.OptimizeRequest.SerializeToString, 

25 response_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.OptimizeProgress.FromString, 

26 _registered_method=True, 

27 ) 

28 self.AnalyzeWalkForward = channel.unary_unary( 

29 "/ml.MLService/AnalyzeWalkForward", 

30 request_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeRequest.SerializeToString, 

31 response_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeResponse.FromString, 

32 _registered_method=True, 

33 ) 

34 self.PredictSignal = channel.unary_unary( 

35 "/ml.MLService/PredictSignal", 

36 request_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.MLPredictionRequest.SerializeToString, 

37 response_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.MLSignalInsight.FromString, 

38 _registered_method=True, 

39 ) 

40 self.PredictSignalsBatch = channel.unary_stream( 

41 "/ml.MLService/PredictSignalsBatch", 

42 request_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.BatchMLPredictionRequest.SerializeToString, 

43 response_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.MLSignalInsight.FromString, 

44 _registered_method=True, 

45 ) 

46 self.StoreFeatures = channel.unary_unary( 

47 "/ml.MLService/StoreFeatures", 

48 request_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.FeatureStoreRequest.SerializeToString, 

49 response_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.FeatureStoreResponse.FromString, 

50 _registered_method=True, 

51 ) 

52 self.HealthCheck = channel.unary_unary( 

53 "/ml.MLService/HealthCheck", 

54 request_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.HealthCheckRequest.SerializeToString, 

55 response_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.HealthCheckResponse.FromString, 

56 _registered_method=True, 

57 ) 

58 self.AnalyzeMLBacktestPerformance = channel.unary_unary( 

59 "/ml.MLService/AnalyzeMLBacktestPerformance", 

60 request_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeMLBacktestPerformanceRequest.SerializeToString, 

61 response_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeMLBacktestPerformanceResponse.FromString, 

62 _registered_method=True, 

63 ) 

64 

65 

66class MLServiceServicer(object): 

67 """ML Service - gRPC API used for ML prediction, walk-forward optimization, and 

68 feature storage workflows. 

69 """ 

70 

71 def OptimizeParameters(self, request, context): 

72 """Walk-forward parameter optimization streaming progress updates to callers.""" 

73 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

75 raise NotImplementedError("Method not implemented!") 

76 

77 def AnalyzeWalkForward(self, request, context): 

78 """Run statistical analysis across walk-forward windows.""" 

79 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

81 raise NotImplementedError("Method not implemented!") 

82 

83 def PredictSignal(self, request, context): 

84 """Generate a single ML signal prediction.""" 

85 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

87 raise NotImplementedError("Method not implemented!") 

88 

89 def PredictSignalsBatch(self, request, context): 

90 """Stream batch ML predictions for multiple feature vectors.""" 

91 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

93 raise NotImplementedError("Method not implemented!") 

94 

95 def StoreFeatures(self, request, context): 

96 """Store computed features inside the feature store.""" 

97 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

99 raise NotImplementedError("Method not implemented!") 

100 

101 def HealthCheck(self, request, context): 

102 """Report service health state.""" 

103 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

105 raise NotImplementedError("Method not implemented!") 

106 

107 def AnalyzeMLBacktestPerformance(self, request, context): 

108 """Analyze ML-driven backtest performance submitted by backtest service.""" 

109 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

111 raise NotImplementedError("Method not implemented!") 

112 

113 

114def add_MLServiceServicer_to_server(servicer, server): 

115 rpc_method_handlers = { 

116 "OptimizeParameters": grpc.unary_stream_rpc_method_handler( 

117 servicer.OptimizeParameters, 

118 request_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.OptimizeRequest.FromString, 

119 response_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.OptimizeProgress.SerializeToString, 

120 ), 

121 "AnalyzeWalkForward": grpc.unary_unary_rpc_method_handler( 

122 servicer.AnalyzeWalkForward, 

123 request_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeRequest.FromString, 

124 response_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeResponse.SerializeToString, 

125 ), 

126 "PredictSignal": grpc.unary_unary_rpc_method_handler( 

127 servicer.PredictSignal, 

128 request_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.MLPredictionRequest.FromString, 

129 response_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.MLSignalInsight.SerializeToString, 

130 ), 

131 "PredictSignalsBatch": grpc.unary_stream_rpc_method_handler( 

132 servicer.PredictSignalsBatch, 

133 request_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.BatchMLPredictionRequest.FromString, 

134 response_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.MLSignalInsight.SerializeToString, 

135 ), 

136 "StoreFeatures": grpc.unary_unary_rpc_method_handler( 

137 servicer.StoreFeatures, 

138 request_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.FeatureStoreRequest.FromString, 

139 response_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.FeatureStoreResponse.SerializeToString, 

140 ), 

141 "HealthCheck": grpc.unary_unary_rpc_method_handler( 

142 servicer.HealthCheck, 

143 request_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.HealthCheckRequest.FromString, 

144 response_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.HealthCheckResponse.SerializeToString, 

145 ), 

146 "AnalyzeMLBacktestPerformance": grpc.unary_unary_rpc_method_handler( 

147 servicer.AnalyzeMLBacktestPerformance, 

148 request_deserializer=services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeMLBacktestPerformanceRequest.FromString, 

149 response_serializer=services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeMLBacktestPerformanceResponse.SerializeToString, 

150 ), 

151 } 

152 generic_handler = grpc.method_handlers_generic_handler( 

153 "ml.MLService", rpc_method_handlers 

154 ) 

155 server.add_generic_rpc_handlers((generic_handler,)) 

156 server.add_registered_method_handlers("ml.MLService", rpc_method_handlers) 

157 

158 

159# This class is part of an EXPERIMENTAL API. 

160class MLService(object): 

161 """ML Service - gRPC API used for ML prediction, walk-forward optimization, and 

162 feature storage workflows. 

163 """ 

164 

165 @staticmethod 

166 def OptimizeParameters( 

167 request, 

168 target, 

169 options=(), 

170 channel_credentials=None, 

171 call_credentials=None, 

172 insecure=False, 

173 compression=None, 

174 wait_for_ready=None, 

175 timeout=None, 

176 metadata=None, 

177 ): 

178 return grpc.experimental.unary_stream( 

179 request, 

180 target, 

181 "/ml.MLService/OptimizeParameters", 

182 services_dot_ml_dot_v1_dot_ml__service__pb2.OptimizeRequest.SerializeToString, 

183 services_dot_ml_dot_v1_dot_ml__service__pb2.OptimizeProgress.FromString, 

184 options, 

185 channel_credentials, 

186 insecure, 

187 call_credentials, 

188 compression, 

189 wait_for_ready, 

190 timeout, 

191 metadata, 

192 _registered_method=True, 

193 ) 

194 

195 @staticmethod 

196 def AnalyzeWalkForward( 

197 request, 

198 target, 

199 options=(), 

200 channel_credentials=None, 

201 call_credentials=None, 

202 insecure=False, 

203 compression=None, 

204 wait_for_ready=None, 

205 timeout=None, 

206 metadata=None, 

207 ): 

208 return grpc.experimental.unary_unary( 

209 request, 

210 target, 

211 "/ml.MLService/AnalyzeWalkForward", 

212 services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeRequest.SerializeToString, 

213 services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeResponse.FromString, 

214 options, 

215 channel_credentials, 

216 insecure, 

217 call_credentials, 

218 compression, 

219 wait_for_ready, 

220 timeout, 

221 metadata, 

222 _registered_method=True, 

223 ) 

224 

225 @staticmethod 

226 def PredictSignal( 

227 request, 

228 target, 

229 options=(), 

230 channel_credentials=None, 

231 call_credentials=None, 

232 insecure=False, 

233 compression=None, 

234 wait_for_ready=None, 

235 timeout=None, 

236 metadata=None, 

237 ): 

238 return grpc.experimental.unary_unary( 

239 request, 

240 target, 

241 "/ml.MLService/PredictSignal", 

242 services_dot_ml_dot_v1_dot_ml__service__pb2.MLPredictionRequest.SerializeToString, 

243 services_dot_ml_dot_v1_dot_ml__service__pb2.MLSignalInsight.FromString, 

244 options, 

245 channel_credentials, 

246 insecure, 

247 call_credentials, 

248 compression, 

249 wait_for_ready, 

250 timeout, 

251 metadata, 

252 _registered_method=True, 

253 ) 

254 

255 @staticmethod 

256 def PredictSignalsBatch( 

257 request, 

258 target, 

259 options=(), 

260 channel_credentials=None, 

261 call_credentials=None, 

262 insecure=False, 

263 compression=None, 

264 wait_for_ready=None, 

265 timeout=None, 

266 metadata=None, 

267 ): 

268 return grpc.experimental.unary_stream( 

269 request, 

270 target, 

271 "/ml.MLService/PredictSignalsBatch", 

272 services_dot_ml_dot_v1_dot_ml__service__pb2.BatchMLPredictionRequest.SerializeToString, 

273 services_dot_ml_dot_v1_dot_ml__service__pb2.MLSignalInsight.FromString, 

274 options, 

275 channel_credentials, 

276 insecure, 

277 call_credentials, 

278 compression, 

279 wait_for_ready, 

280 timeout, 

281 metadata, 

282 _registered_method=True, 

283 ) 

284 

285 @staticmethod 

286 def StoreFeatures( 

287 request, 

288 target, 

289 options=(), 

290 channel_credentials=None, 

291 call_credentials=None, 

292 insecure=False, 

293 compression=None, 

294 wait_for_ready=None, 

295 timeout=None, 

296 metadata=None, 

297 ): 

298 return grpc.experimental.unary_unary( 

299 request, 

300 target, 

301 "/ml.MLService/StoreFeatures", 

302 services_dot_ml_dot_v1_dot_ml__service__pb2.FeatureStoreRequest.SerializeToString, 

303 services_dot_ml_dot_v1_dot_ml__service__pb2.FeatureStoreResponse.FromString, 

304 options, 

305 channel_credentials, 

306 insecure, 

307 call_credentials, 

308 compression, 

309 wait_for_ready, 

310 timeout, 

311 metadata, 

312 _registered_method=True, 

313 ) 

314 

315 @staticmethod 

316 def HealthCheck( 

317 request, 

318 target, 

319 options=(), 

320 channel_credentials=None, 

321 call_credentials=None, 

322 insecure=False, 

323 compression=None, 

324 wait_for_ready=None, 

325 timeout=None, 

326 metadata=None, 

327 ): 

328 return grpc.experimental.unary_unary( 

329 request, 

330 target, 

331 "/ml.MLService/HealthCheck", 

332 services_dot_ml_dot_v1_dot_ml__service__pb2.HealthCheckRequest.SerializeToString, 

333 services_dot_ml_dot_v1_dot_ml__service__pb2.HealthCheckResponse.FromString, 

334 options, 

335 channel_credentials, 

336 insecure, 

337 call_credentials, 

338 compression, 

339 wait_for_ready, 

340 timeout, 

341 metadata, 

342 _registered_method=True, 

343 ) 

344 

345 @staticmethod 

346 def AnalyzeMLBacktestPerformance( 

347 request, 

348 target, 

349 options=(), 

350 channel_credentials=None, 

351 call_credentials=None, 

352 insecure=False, 

353 compression=None, 

354 wait_for_ready=None, 

355 timeout=None, 

356 metadata=None, 

357 ): 

358 return grpc.experimental.unary_unary( 

359 request, 

360 target, 

361 "/ml.MLService/AnalyzeMLBacktestPerformance", 

362 services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeMLBacktestPerformanceRequest.SerializeToString, 

363 services_dot_ml_dot_v1_dot_ml__service__pb2.AnalyzeMLBacktestPerformanceResponse.FromString, 

364 options, 

365 channel_credentials, 

366 insecure, 

367 call_credentials, 

368 compression, 

369 wait_for_ready, 

370 timeout, 

371 metadata, 

372 _registered_method=True, 

373 )