Skip to content

Commit

Permalink
chore: auto-gen by protobufs
Browse files Browse the repository at this point in the history
triggered by commit: instill-ai/protobufs@d71ac4d
  • Loading branch information
droplet-bot committed Aug 10, 2023
1 parent 74f1f36 commit 76c9a3d
Show file tree
Hide file tree
Showing 10 changed files with 351 additions and 89 deletions.
18 changes: 13 additions & 5 deletions vdp/connector/v1alpha/connector_definition_pb2.py

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

9 changes: 6 additions & 3 deletions vdp/connector/v1alpha/connector_private_service_pb2.py

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

37 changes: 37 additions & 0 deletions vdp/connector/v1alpha/connector_private_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
"""Client and server classes corresponding to protobuf-defined services."""
import grpc

from vdp.connector.v1alpha import connector_definition_pb2 as vdp_dot_connector_dot_v1alpha_dot_connector__definition__pb2
from vdp.connector.v1alpha import connector_pb2 as vdp_dot_connector_dot_v1alpha_dot_connector__pb2


Expand All @@ -15,6 +16,11 @@ def __init__(self, channel):
Args:
channel: A grpc.Channel.
"""
self.LookUpConnectorDefinitionAdmin = channel.unary_unary(
'/vdp.connector.v1alpha.ConnectorPrivateService/LookUpConnectorDefinitionAdmin',
request_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__definition__pb2.LookUpConnectorDefinitionAdminRequest.SerializeToString,
response_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__definition__pb2.LookUpConnectorDefinitionAdminResponse.FromString,
)
self.ListConnectorsAdmin = channel.unary_unary(
'/vdp.connector.v1alpha.ConnectorPrivateService/ListConnectorsAdmin',
request_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListConnectorsAdminRequest.SerializeToString,
Expand All @@ -36,6 +42,15 @@ class ConnectorPrivateServiceServicer(object):
"""Connector service responds to internal access
"""

def LookUpConnectorDefinitionAdmin(self, request, context):
"""LookUpConnectorDefinitionAdmin method receives a
LookUpConnectorDefinitionAdminRequest message and returns a
LookUpConnectorDefinitionAdminResponse
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def ListConnectorsAdmin(self, request, context):
"""ListConnectorsAdmin method receives a ListConnectorsAdminRequest
message and returns a ListConnectorsResponse message.
Expand Down Expand Up @@ -64,6 +79,11 @@ def CheckConnector(self, request, context):

def add_ConnectorPrivateServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'LookUpConnectorDefinitionAdmin': grpc.unary_unary_rpc_method_handler(
servicer.LookUpConnectorDefinitionAdmin,
request_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__definition__pb2.LookUpConnectorDefinitionAdminRequest.FromString,
response_serializer=vdp_dot_connector_dot_v1alpha_dot_connector__definition__pb2.LookUpConnectorDefinitionAdminResponse.SerializeToString,
),
'ListConnectorsAdmin': grpc.unary_unary_rpc_method_handler(
servicer.ListConnectorsAdmin,
request_deserializer=vdp_dot_connector_dot_v1alpha_dot_connector__pb2.ListConnectorsAdminRequest.FromString,
Expand All @@ -90,6 +110,23 @@ class ConnectorPrivateService(object):
"""Connector service responds to internal access
"""

@staticmethod
def LookUpConnectorDefinitionAdmin(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/vdp.connector.v1alpha.ConnectorPrivateService/LookUpConnectorDefinitionAdmin',
vdp_dot_connector_dot_v1alpha_dot_connector__definition__pb2.LookUpConnectorDefinitionAdminRequest.SerializeToString,
vdp_dot_connector_dot_v1alpha_dot_connector__definition__pb2.LookUpConnectorDefinitionAdminResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def ListConnectorsAdmin(request,
target,
Expand Down
Loading

0 comments on commit 76c9a3d

Please sign in to comment.