Coverage for mcpgateway / plugins / framework / external / grpc / proto / plugin_service_pb2_grpc.py: 100%

1# -*- coding: utf-8 -*- 

2# noqa: D100, D101, D102, D103, D104, D107, D400, D415 

3# ruff: noqa 

4# type: ignore 

5# pylint: skip-file 

6# Generated by protoc - do not edit 

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

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

9# Standard 

10 

11# Third-Party 

12import grpc 

13 

14# First-Party 

15from mcpgateway.plugins.framework.external.grpc.proto import plugin_service_pb2 as plugin__service__pb2 

16 

17GRPC_GENERATED_VERSION = "1.76.0" 

18GRPC_VERSION = grpc.__version__ 

19_version_not_supported = False 

20 

21try: 

22 # Third-Party 

23 from grpc._utilities import first_version_is_lower 

24 

25 _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION) 

26except ImportError: # pragma: no cover 

27 _version_not_supported = True 

28 

29if _version_not_supported: # pragma: no cover 

30 raise RuntimeError( 

31 f"The grpc package installed is at version {GRPC_VERSION}," 

32 + " but the generated code in plugin_service_pb2_grpc.py depends on" 

33 + f" grpcio>={GRPC_GENERATED_VERSION}." 

34 + f" Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}" 

35 + f" or downgrade your generated code using grpcio-tools<={GRPC_VERSION}." 

36 ) 

37 

38 

39class PluginServiceStub(object): 

40 """============================================================================ 

41 Plugin Service - Main service for external plugin communication 

42 ============================================================================ 

43 

44 """ 

45 

46 def __init__(self, channel): 

47 """Constructor. 

48 

49 Args: 

50 channel: A grpc.Channel. 

51 """ 

52 self.GetPluginConfig = channel.unary_unary( 

53 "/mcpgateway.plugins.PluginService/GetPluginConfig", 

54 request_serializer=plugin__service__pb2.GetPluginConfigRequest.SerializeToString, 

55 response_deserializer=plugin__service__pb2.GetPluginConfigResponse.FromString, 

56 _registered_method=True, 

57 ) 

58 self.GetPluginConfigs = channel.unary_unary( 

59 "/mcpgateway.plugins.PluginService/GetPluginConfigs", 

60 request_serializer=plugin__service__pb2.GetPluginConfigsRequest.SerializeToString, 

61 response_deserializer=plugin__service__pb2.GetPluginConfigsResponse.FromString, 

62 _registered_method=True, 

63 ) 

64 self.InvokeHook = channel.unary_unary( 

65 "/mcpgateway.plugins.PluginService/InvokeHook", 

66 request_serializer=plugin__service__pb2.InvokeHookRequest.SerializeToString, 

67 response_deserializer=plugin__service__pb2.InvokeHookResponse.FromString, 

68 _registered_method=True, 

69 ) 

70 

71 

72class PluginServiceServicer(object): 

73 """============================================================================ 

74 Plugin Service - Main service for external plugin communication 

75 ============================================================================ 

76 

77 """ 

78 

79 def GetPluginConfig(self, request, context): 

80 """Get configuration for a single plugin by name""" 

81 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

83 raise NotImplementedError("Method not implemented!") 

84 

85 def GetPluginConfigs(self, request, context): 

86 """Get configurations for all plugins on the server""" 

87 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

89 raise NotImplementedError("Method not implemented!") 

90 

91 def InvokeHook(self, request, context): 

92 """Invoke a plugin hook""" 

93 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

95 raise NotImplementedError("Method not implemented!") 

96 

97 

98def add_PluginServiceServicer_to_server(servicer, server): 

99 rpc_method_handlers = { 

100 "GetPluginConfig": grpc.unary_unary_rpc_method_handler( 

101 servicer.GetPluginConfig, 

102 request_deserializer=plugin__service__pb2.GetPluginConfigRequest.FromString, 

103 response_serializer=plugin__service__pb2.GetPluginConfigResponse.SerializeToString, 

104 ), 

105 "GetPluginConfigs": grpc.unary_unary_rpc_method_handler( 

106 servicer.GetPluginConfigs, 

107 request_deserializer=plugin__service__pb2.GetPluginConfigsRequest.FromString, 

108 response_serializer=plugin__service__pb2.GetPluginConfigsResponse.SerializeToString, 

109 ), 

110 "InvokeHook": grpc.unary_unary_rpc_method_handler( 

111 servicer.InvokeHook, 

112 request_deserializer=plugin__service__pb2.InvokeHookRequest.FromString, 

113 response_serializer=plugin__service__pb2.InvokeHookResponse.SerializeToString, 

114 ), 

115 } 

116 generic_handler = grpc.method_handlers_generic_handler("mcpgateway.plugins.PluginService", rpc_method_handlers) 

117 server.add_generic_rpc_handlers((generic_handler,)) 

118 server.add_registered_method_handlers("mcpgateway.plugins.PluginService", rpc_method_handlers) 

119 

120 

121# This class is part of an EXPERIMENTAL API. 

122class PluginService(object): 

123 """============================================================================ 

124 Plugin Service - Main service for external plugin communication 

125 ============================================================================ 

126 

127 """ 

128 

129 @staticmethod 

130 def GetPluginConfig(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): 

131 return grpc.experimental.unary_unary( 

132 request, 

133 target, 

134 "/mcpgateway.plugins.PluginService/GetPluginConfig", 

135 plugin__service__pb2.GetPluginConfigRequest.SerializeToString, 

136 plugin__service__pb2.GetPluginConfigResponse.FromString, 

137 options, 

138 channel_credentials, 

139 insecure, 

140 call_credentials, 

141 compression, 

142 wait_for_ready, 

143 timeout, 

144 metadata, 

145 _registered_method=True, 

146 ) 

147 

148 @staticmethod 

149 def GetPluginConfigs(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): 

150 return grpc.experimental.unary_unary( 

151 request, 

152 target, 

153 "/mcpgateway.plugins.PluginService/GetPluginConfigs", 

154 plugin__service__pb2.GetPluginConfigsRequest.SerializeToString, 

155 plugin__service__pb2.GetPluginConfigsResponse.FromString, 

156 options, 

157 channel_credentials, 

158 insecure, 

159 call_credentials, 

160 compression, 

161 wait_for_ready, 

162 timeout, 

163 metadata, 

164 _registered_method=True, 

165 ) 

166 

167 @staticmethod 

168 def InvokeHook(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): 

169 return grpc.experimental.unary_unary( 

170 request, 

171 target, 

172 "/mcpgateway.plugins.PluginService/InvokeHook", 

173 plugin__service__pb2.InvokeHookRequest.SerializeToString, 

174 plugin__service__pb2.InvokeHookResponse.FromString, 

175 options, 

176 channel_credentials, 

177 insecure, 

178 call_credentials, 

179 compression, 

180 wait_for_ready, 

181 timeout, 

182 metadata, 

183 _registered_method=True, 

184 ) 

185 

186 

187class HealthStub(object): 

188 """============================================================================ 

189 Health Service - Standard gRPC health checking 

190 ============================================================================ 

191 

192 """ 

193 

194 def __init__(self, channel): 

195 """Constructor. 

196 

197 Args: 

198 channel: A grpc.Channel. 

199 """ 

200 self.Check = channel.unary_unary( 

201 "/mcpgateway.plugins.Health/Check", 

202 request_serializer=plugin__service__pb2.HealthCheckRequest.SerializeToString, 

203 response_deserializer=plugin__service__pb2.HealthCheckResponse.FromString, 

204 _registered_method=True, 

205 ) 

206 

207 

208class HealthServicer(object): 

209 """============================================================================ 

210 Health Service - Standard gRPC health checking 

211 ============================================================================ 

212 

213 """ 

214 

215 def Check(self, request, context): 

216 """Check the health status of the plugin server""" 

217 context.set_code(grpc.StatusCode.UNIMPLEMENTED) 

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

219 raise NotImplementedError("Method not implemented!") 

220 

221 

222def add_HealthServicer_to_server(servicer, server): 

223 rpc_method_handlers = { 

224 "Check": grpc.unary_unary_rpc_method_handler( 

225 servicer.Check, 

226 request_deserializer=plugin__service__pb2.HealthCheckRequest.FromString, 

227 response_serializer=plugin__service__pb2.HealthCheckResponse.SerializeToString, 

228 ), 

229 } 

230 generic_handler = grpc.method_handlers_generic_handler("mcpgateway.plugins.Health", rpc_method_handlers) 

231 server.add_generic_rpc_handlers((generic_handler,)) 

232 server.add_registered_method_handlers("mcpgateway.plugins.Health", rpc_method_handlers) 

233 

234 

235# This class is part of an EXPERIMENTAL API. 

236class Health(object): 

237 """============================================================================ 

238 Health Service - Standard gRPC health checking 

239 ============================================================================ 

240 

241 """ 

242 

243 @staticmethod 

244 def Check(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): 

245 return grpc.experimental.unary_unary( 

246 request, 

247 target, 

248 "/mcpgateway.plugins.Health/Check", 

249 plugin__service__pb2.HealthCheckRequest.SerializeToString, 

250 plugin__service__pb2.HealthCheckResponse.FromString, 

251 options, 

252 channel_credentials, 

253 insecure, 

254 call_credentials, 

255 compression, 

256 wait_for_ready, 

257 timeout, 

258 metadata, 

259 _registered_method=True, 

260 )