From 66d07846d1446fe7228f63376a11a87e5415706e Mon Sep 17 00:00:00 2001 From: droplet-bot Date: Mon, 12 Feb 2024 15:06:52 +0000 Subject: [PATCH] chore: auto-gen by protobufs triggered by commit: https://github.com/instill-ai/protobufs/commit/ed5ef1ddbeb1da3553dec7e0cf3e4ef4c1b013b0 --- vdp/controller/v1beta/controller_pb2.py | 71 ----- vdp/controller/v1beta/controller_pb2.pyi | 259 ------------------ vdp/controller/v1beta/controller_pb2_grpc.py | 4 - vdp/controller/v1beta/controller_pb2_grpc.pyi | 17 -- .../v1beta/controller_service_pb2.py | 43 --- .../v1beta/controller_service_pb2.pyi | 7 - .../v1beta/controller_service_pb2_grpc.py | 213 -------------- .../v1beta/controller_service_pb2_grpc.pyi | 154 ----------- 8 files changed, 768 deletions(-) delete mode 100644 vdp/controller/v1beta/controller_pb2.py delete mode 100644 vdp/controller/v1beta/controller_pb2.pyi delete mode 100644 vdp/controller/v1beta/controller_pb2_grpc.py delete mode 100644 vdp/controller/v1beta/controller_pb2_grpc.pyi delete mode 100644 vdp/controller/v1beta/controller_service_pb2.py delete mode 100644 vdp/controller/v1beta/controller_service_pb2.pyi delete mode 100644 vdp/controller/v1beta/controller_service_pb2_grpc.py delete mode 100644 vdp/controller/v1beta/controller_service_pb2_grpc.pyi diff --git a/vdp/controller/v1beta/controller_pb2.py b/vdp/controller/v1beta/controller_pb2.py deleted file mode 100644 index 597be21..0000000 --- a/vdp/controller/v1beta/controller_pb2.py +++ /dev/null @@ -1,71 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: vdp/controller/v1beta/controller.proto -"""Generated protocol buffer code.""" -from google.protobuf import descriptor as _descriptor -from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - -from common.healthcheck.v1beta import healthcheck_pb2 as common_dot_healthcheck_dot_v1beta_dot_healthcheck__pb2 -from google.api import field_behavior_pb2 as google_dot_api_dot_field__behavior__pb2 -from google.api import resource_pb2 as google_dot_api_dot_resource__pb2 -from protoc_gen_openapiv2.options import annotations_pb2 as protoc__gen__openapiv2_dot_options_dot_annotations__pb2 -from vdp.pipeline.v1beta import connector_pb2 as vdp_dot_pipeline_dot_v1beta_dot_connector__pb2 -from vdp.pipeline.v1beta import pipeline_pb2 as vdp_dot_pipeline_dot_v1beta_dot_pipeline__pb2 - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n&vdp/controller/v1beta/controller.proto\x12\x15vdp.controller.v1beta\x1a+common/healthcheck/v1beta/healthcheck.proto\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\x1a#vdp/pipeline/v1beta/connector.proto\x1a\"vdp/pipeline/v1beta/pipeline.proto\"\x96\x01\n\x0fLivenessRequest\x12j\n\x14health_check_request\x18\x01 \x01(\x0b\x32-.common.healthcheck.v1beta.HealthCheckRequestB\x04\xe2\x41\x01\x01H\x00R\x12healthCheckRequest\x88\x01\x01\x42\x17\n\x15_health_check_request\"v\n\x10LivenessResponse\x12\x62\n\x15health_check_response\x18\x01 \x01(\x0b\x32..common.healthcheck.v1beta.HealthCheckResponseR\x13healthCheckResponse\"\x97\x01\n\x10ReadinessRequest\x12j\n\x14health_check_request\x18\x01 \x01(\x0b\x32-.common.healthcheck.v1beta.HealthCheckRequestB\x04\xe2\x41\x01\x01H\x00R\x12healthCheckRequest\x88\x01\x01\x42\x17\n\x15_health_check_request\"w\n\x11ReadinessResponse\x12\x62\n\x15health_check_response\x18\x01 \x01(\x0b\x32..common.healthcheck.v1beta.HealthCheckResponseR\x13healthCheckResponse\"\xbf\x03\n\x08Resource\x12\x33\n\x12resource_permalink\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\x11resourcePermalink\x12\x43\n\x0epipeline_state\x18\x03 \x01(\x0e\x32\x1a.vdp.pipeline.v1beta.StateH\x00R\rpipelineState\x12O\n\x0f\x63onnector_state\x18\x04 \x01(\x0e\x32$.vdp.pipeline.v1beta.Connector.StateH\x00R\x0e\x63onnectorState\x12\x63\n\rbackend_state\x18\x05 \x01(\x0e\x32<.common.healthcheck.v1beta.HealthCheckResponse.ServingStatusH\x00R\x0c\x62\x61\x63kendState\x12%\n\x08progress\x18\x06 \x01(\x05\x42\x04\xe2\x41\x01\x01H\x01R\x08progress\x88\x01\x01:F\xea\x41\x43\n\x19\x61pi.instill.tech/Resource\x12&resources/{resource_uuid}/types/{type}B\x07\n\x05stateB\x0b\n\t_progress\"\x8b\x01\n\x12GetResourceRequest\x12u\n\x12resource_permalink\x18\x01 \x01(\tBF\x92\x41!\xca>\x1e\xfa\x02\x1bresource.resource_permalink\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/ResourceR\x11resourcePermalink\"R\n\x13GetResourceResponse\x12;\n\x08resource\x18\x01 \x01(\x0b\x32\x1f.vdp.controller.v1beta.ResourceR\x08resource\"\x96\x01\n\x15UpdateResourceRequest\x12\x41\n\x08resource\x18\x01 \x01(\x0b\x32\x1f.vdp.controller.v1beta.ResourceB\x04\xe2\x41\x01\x02R\x08resource\x12*\n\x0bworkflow_id\x18\x02 \x01(\tB\x04\xe2\x41\x01\x01H\x00R\nworkflowId\x88\x01\x01\x42\x0e\n\x0c_workflow_id\"U\n\x16UpdateResourceResponse\x12;\n\x08resource\x18\x01 \x01(\x0b\x32\x1f.vdp.controller.v1beta.ResourceR\x08resource\"\x8e\x01\n\x15\x44\x65leteResourceRequest\x12u\n\x12resource_permalink\x18\x01 \x01(\tBF\x92\x41!\xca>\x1e\xfa\x02\x1bresource.resource_permalink\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/ResourceR\x11resourcePermalink\"\x18\n\x16\x44\x65leteResourceResponseB\xec\x01\n\x19\x63om.vdp.controller.v1betaB\x0f\x43ontrollerProtoP\x01ZHgithub.com/instill-ai/protogen-go/vdp/controller/v1beta;controllerv1beta\xa2\x02\x03VCX\xaa\x02\x15Vdp.Controller.V1beta\xca\x02\x15Vdp\\Controller\\V1beta\xe2\x02!Vdp\\Controller\\V1beta\\GPBMetadata\xea\x02\x17Vdp::Controller::V1betab\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'vdp.controller.v1beta.controller_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'\n\031com.vdp.controller.v1betaB\017ControllerProtoP\001ZHgithub.com/instill-ai/protogen-go/vdp/controller/v1beta;controllerv1beta\242\002\003VCX\252\002\025Vdp.Controller.V1beta\312\002\025Vdp\\Controller\\V1beta\342\002!Vdp\\Controller\\V1beta\\GPBMetadata\352\002\027Vdp::Controller::V1beta' - _LIVENESSREQUEST.fields_by_name['health_check_request']._options = None - _LIVENESSREQUEST.fields_by_name['health_check_request']._serialized_options = b'\342A\001\001' - _READINESSREQUEST.fields_by_name['health_check_request']._options = None - _READINESSREQUEST.fields_by_name['health_check_request']._serialized_options = b'\342A\001\001' - _RESOURCE.fields_by_name['resource_permalink']._options = None - _RESOURCE.fields_by_name['resource_permalink']._serialized_options = b'\342A\001\002' - _RESOURCE.fields_by_name['progress']._options = None - _RESOURCE.fields_by_name['progress']._serialized_options = b'\342A\001\001' - _RESOURCE._options = None - _RESOURCE._serialized_options = b'\352AC\n\031api.instill.tech/Resource\022&resources/{resource_uuid}/types/{type}' - _GETRESOURCEREQUEST.fields_by_name['resource_permalink']._options = None - _GETRESOURCEREQUEST.fields_by_name['resource_permalink']._serialized_options = b'\222A!\312>\036\372\002\033resource.resource_permalink\342A\001\002\372A\033\n\031api.instill.tech/Resource' - _UPDATERESOURCEREQUEST.fields_by_name['resource']._options = None - _UPDATERESOURCEREQUEST.fields_by_name['resource']._serialized_options = b'\342A\001\002' - _UPDATERESOURCEREQUEST.fields_by_name['workflow_id']._options = None - _UPDATERESOURCEREQUEST.fields_by_name['workflow_id']._serialized_options = b'\342A\001\001' - _DELETERESOURCEREQUEST.fields_by_name['resource_permalink']._options = None - _DELETERESOURCEREQUEST.fields_by_name['resource_permalink']._serialized_options = b'\222A!\312>\036\372\002\033resource.resource_permalink\342A\001\002\372A\033\n\031api.instill.tech/Resource' - _globals['_LIVENESSREQUEST']._serialized_start=292 - _globals['_LIVENESSREQUEST']._serialized_end=442 - _globals['_LIVENESSRESPONSE']._serialized_start=444 - _globals['_LIVENESSRESPONSE']._serialized_end=562 - _globals['_READINESSREQUEST']._serialized_start=565 - _globals['_READINESSREQUEST']._serialized_end=716 - _globals['_READINESSRESPONSE']._serialized_start=718 - _globals['_READINESSRESPONSE']._serialized_end=837 - _globals['_RESOURCE']._serialized_start=840 - _globals['_RESOURCE']._serialized_end=1287 - _globals['_GETRESOURCEREQUEST']._serialized_start=1290 - _globals['_GETRESOURCEREQUEST']._serialized_end=1429 - _globals['_GETRESOURCERESPONSE']._serialized_start=1431 - _globals['_GETRESOURCERESPONSE']._serialized_end=1513 - _globals['_UPDATERESOURCEREQUEST']._serialized_start=1516 - _globals['_UPDATERESOURCEREQUEST']._serialized_end=1666 - _globals['_UPDATERESOURCERESPONSE']._serialized_start=1668 - _globals['_UPDATERESOURCERESPONSE']._serialized_end=1753 - _globals['_DELETERESOURCEREQUEST']._serialized_start=1756 - _globals['_DELETERESOURCEREQUEST']._serialized_end=1898 - _globals['_DELETERESOURCERESPONSE']._serialized_start=1900 - _globals['_DELETERESOURCERESPONSE']._serialized_end=1924 -# @@protoc_insertion_point(module_scope) diff --git a/vdp/controller/v1beta/controller_pb2.pyi b/vdp/controller/v1beta/controller_pb2.pyi deleted file mode 100644 index e7980f9..0000000 --- a/vdp/controller/v1beta/controller_pb2.pyi +++ /dev/null @@ -1,259 +0,0 @@ -""" -@generated by mypy-protobuf. Do not edit manually! -isort:skip_file -""" -import builtins -import common.healthcheck.v1beta.healthcheck_pb2 -import google.protobuf.descriptor -import google.protobuf.message -import sys -import typing -import vdp.pipeline.v1beta.connector_pb2 -import vdp.pipeline.v1beta.pipeline_pb2 - -if sys.version_info >= (3, 8): - import typing as typing_extensions -else: - import typing_extensions - -DESCRIPTOR: google.protobuf.descriptor.FileDescriptor - -@typing_extensions.final -class LivenessRequest(google.protobuf.message.Message): - """LivenessRequest represents a request to check a service liveness status""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - HEALTH_CHECK_REQUEST_FIELD_NUMBER: builtins.int - @property - def health_check_request(self) -> common.healthcheck.v1beta.healthcheck_pb2.HealthCheckRequest: - """HealthCheckRequest message""" - def __init__( - self, - *, - health_check_request: common.healthcheck.v1beta.healthcheck_pb2.HealthCheckRequest | None = ..., - ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["_health_check_request", b"_health_check_request", "health_check_request", b"health_check_request"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["_health_check_request", b"_health_check_request", "health_check_request", b"health_check_request"]) -> None: ... - def WhichOneof(self, oneof_group: typing_extensions.Literal["_health_check_request", b"_health_check_request"]) -> typing_extensions.Literal["health_check_request"] | None: ... - -global___LivenessRequest = LivenessRequest - -@typing_extensions.final -class LivenessResponse(google.protobuf.message.Message): - """LivenessResponse represents a response for a service liveness status""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - HEALTH_CHECK_RESPONSE_FIELD_NUMBER: builtins.int - @property - def health_check_response(self) -> common.healthcheck.v1beta.healthcheck_pb2.HealthCheckResponse: - """HealthCheckResponse message""" - def __init__( - self, - *, - health_check_response: common.healthcheck.v1beta.healthcheck_pb2.HealthCheckResponse | None = ..., - ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["health_check_response", b"health_check_response"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["health_check_response", b"health_check_response"]) -> None: ... - -global___LivenessResponse = LivenessResponse - -@typing_extensions.final -class ReadinessRequest(google.protobuf.message.Message): - """ReadinessRequest represents a request to check a service readiness status""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - HEALTH_CHECK_REQUEST_FIELD_NUMBER: builtins.int - @property - def health_check_request(self) -> common.healthcheck.v1beta.healthcheck_pb2.HealthCheckRequest: - """HealthCheckRequest message""" - def __init__( - self, - *, - health_check_request: common.healthcheck.v1beta.healthcheck_pb2.HealthCheckRequest | None = ..., - ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["_health_check_request", b"_health_check_request", "health_check_request", b"health_check_request"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["_health_check_request", b"_health_check_request", "health_check_request", b"health_check_request"]) -> None: ... - def WhichOneof(self, oneof_group: typing_extensions.Literal["_health_check_request", b"_health_check_request"]) -> typing_extensions.Literal["health_check_request"] | None: ... - -global___ReadinessRequest = ReadinessRequest - -@typing_extensions.final -class ReadinessResponse(google.protobuf.message.Message): - """ReadinessResponse represents a response for a service readiness status""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - HEALTH_CHECK_RESPONSE_FIELD_NUMBER: builtins.int - @property - def health_check_response(self) -> common.healthcheck.v1beta.healthcheck_pb2.HealthCheckResponse: - """HealthCheckResponse message""" - def __init__( - self, - *, - health_check_response: common.healthcheck.v1beta.healthcheck_pb2.HealthCheckResponse | None = ..., - ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["health_check_response", b"health_check_response"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["health_check_response", b"health_check_response"]) -> None: ... - -global___ReadinessResponse = ReadinessResponse - -@typing_extensions.final -class Resource(google.protobuf.message.Message): - """Resource represents the current information of a resource""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - RESOURCE_PERMALINK_FIELD_NUMBER: builtins.int - PIPELINE_STATE_FIELD_NUMBER: builtins.int - CONNECTOR_STATE_FIELD_NUMBER: builtins.int - BACKEND_STATE_FIELD_NUMBER: builtins.int - PROGRESS_FIELD_NUMBER: builtins.int - resource_permalink: builtins.str - """Permalink of a resouce. For example: - "resources/{resource_uuid}/types/{type}" - """ - pipeline_state: vdp.pipeline.v1beta.pipeline_pb2.State.ValueType - """Pipeline state""" - connector_state: vdp.pipeline.v1beta.connector_pb2.Connector.State.ValueType - """Connector state""" - backend_state: common.healthcheck.v1beta.healthcheck_pb2.HealthCheckResponse.ServingStatus.ValueType - """Backend service state""" - progress: builtins.int - """Resource longrunning progress""" - def __init__( - self, - *, - resource_permalink: builtins.str = ..., - pipeline_state: vdp.pipeline.v1beta.pipeline_pb2.State.ValueType = ..., - connector_state: vdp.pipeline.v1beta.connector_pb2.Connector.State.ValueType = ..., - backend_state: common.healthcheck.v1beta.healthcheck_pb2.HealthCheckResponse.ServingStatus.ValueType = ..., - progress: builtins.int | None = ..., - ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["_progress", b"_progress", "backend_state", b"backend_state", "connector_state", b"connector_state", "pipeline_state", b"pipeline_state", "progress", b"progress", "state", b"state"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["_progress", b"_progress", "backend_state", b"backend_state", "connector_state", b"connector_state", "pipeline_state", b"pipeline_state", "progress", b"progress", "resource_permalink", b"resource_permalink", "state", b"state"]) -> None: ... - @typing.overload - def WhichOneof(self, oneof_group: typing_extensions.Literal["_progress", b"_progress"]) -> typing_extensions.Literal["progress"] | None: ... - @typing.overload - def WhichOneof(self, oneof_group: typing_extensions.Literal["state", b"state"]) -> typing_extensions.Literal["pipeline_state", "connector_state", "backend_state"] | None: ... - -global___Resource = Resource - -@typing_extensions.final -class GetResourceRequest(google.protobuf.message.Message): - """GetResourceRequest represents a request to query a resource's state""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - RESOURCE_PERMALINK_FIELD_NUMBER: builtins.int - resource_permalink: builtins.str - """Permalink of a resouce. For example: - "resources/{resource_uuid}/types/{type}" - """ - def __init__( - self, - *, - resource_permalink: builtins.str = ..., - ) -> None: ... - def ClearField(self, field_name: typing_extensions.Literal["resource_permalink", b"resource_permalink"]) -> None: ... - -global___GetResourceRequest = GetResourceRequest - -@typing_extensions.final -class GetResourceResponse(google.protobuf.message.Message): - """GetResourceResponse represents a response to fetch a resource's state""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - RESOURCE_FIELD_NUMBER: builtins.int - @property - def resource(self) -> global___Resource: - """Retrieved resource state""" - def __init__( - self, - *, - resource: global___Resource | None = ..., - ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["resource", b"resource"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["resource", b"resource"]) -> None: ... - -global___GetResourceResponse = GetResourceResponse - -@typing_extensions.final -class UpdateResourceRequest(google.protobuf.message.Message): - """UpdateResourceRequest represents a request to update a resource's state""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - RESOURCE_FIELD_NUMBER: builtins.int - WORKFLOW_ID_FIELD_NUMBER: builtins.int - @property - def resource(self) -> global___Resource: - """Resource state""" - workflow_id: builtins.str - """Resource longrunnning workflow id""" - def __init__( - self, - *, - resource: global___Resource | None = ..., - workflow_id: builtins.str | None = ..., - ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["_workflow_id", b"_workflow_id", "resource", b"resource", "workflow_id", b"workflow_id"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["_workflow_id", b"_workflow_id", "resource", b"resource", "workflow_id", b"workflow_id"]) -> None: ... - def WhichOneof(self, oneof_group: typing_extensions.Literal["_workflow_id", b"_workflow_id"]) -> typing_extensions.Literal["workflow_id"] | None: ... - -global___UpdateResourceRequest = UpdateResourceRequest - -@typing_extensions.final -class UpdateResourceResponse(google.protobuf.message.Message): - """UpdateResourceResponse represents a response to update a resource's state""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - RESOURCE_FIELD_NUMBER: builtins.int - @property - def resource(self) -> global___Resource: - """Updated resource state""" - def __init__( - self, - *, - resource: global___Resource | None = ..., - ) -> None: ... - def HasField(self, field_name: typing_extensions.Literal["resource", b"resource"]) -> builtins.bool: ... - def ClearField(self, field_name: typing_extensions.Literal["resource", b"resource"]) -> None: ... - -global___UpdateResourceResponse = UpdateResourceResponse - -@typing_extensions.final -class DeleteResourceRequest(google.protobuf.message.Message): - """DeleteResourceRequest represents a request to delete a resource's state""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - RESOURCE_PERMALINK_FIELD_NUMBER: builtins.int - resource_permalink: builtins.str - """Permalink of a resouce. For example: - "resources/{resource_uuid}/types/{type}" - """ - def __init__( - self, - *, - resource_permalink: builtins.str = ..., - ) -> None: ... - def ClearField(self, field_name: typing_extensions.Literal["resource_permalink", b"resource_permalink"]) -> None: ... - -global___DeleteResourceRequest = DeleteResourceRequest - -@typing_extensions.final -class DeleteResourceResponse(google.protobuf.message.Message): - """DeleteResourceResponse represents an empty response""" - - DESCRIPTOR: google.protobuf.descriptor.Descriptor - - def __init__( - self, - ) -> None: ... - -global___DeleteResourceResponse = DeleteResourceResponse diff --git a/vdp/controller/v1beta/controller_pb2_grpc.py b/vdp/controller/v1beta/controller_pb2_grpc.py deleted file mode 100644 index 2daafff..0000000 --- a/vdp/controller/v1beta/controller_pb2_grpc.py +++ /dev/null @@ -1,4 +0,0 @@ -# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! -"""Client and server classes corresponding to protobuf-defined services.""" -import grpc - diff --git a/vdp/controller/v1beta/controller_pb2_grpc.pyi b/vdp/controller/v1beta/controller_pb2_grpc.pyi deleted file mode 100644 index b13382f..0000000 --- a/vdp/controller/v1beta/controller_pb2_grpc.pyi +++ /dev/null @@ -1,17 +0,0 @@ -""" -@generated by mypy-protobuf. Do not edit manually! -isort:skip_file -""" -import abc -import collections.abc -import grpc -import grpc.aio -import typing - -_T = typing.TypeVar('_T') - -class _MaybeAsyncIterator(collections.abc.AsyncIterator[_T], collections.abc.Iterator[_T], metaclass=abc.ABCMeta): - ... - -class _ServicerContext(grpc.ServicerContext, grpc.aio.ServicerContext): # type: ignore - ... diff --git a/vdp/controller/v1beta/controller_service_pb2.py b/vdp/controller/v1beta/controller_service_pb2.py deleted file mode 100644 index aa68bcc..0000000 --- a/vdp/controller/v1beta/controller_service_pb2.py +++ /dev/null @@ -1,43 +0,0 @@ -# -*- coding: utf-8 -*- -# Generated by the protocol buffer compiler. DO NOT EDIT! -# source: vdp/controller/v1beta/controller_service.proto -"""Generated protocol buffer code.""" -from google.protobuf import descriptor as _descriptor -from google.protobuf import descriptor_pool as _descriptor_pool -from google.protobuf import symbol_database as _symbol_database -from google.protobuf.internal import builder as _builder -# @@protoc_insertion_point(imports) - -_sym_db = _symbol_database.Default() - - -from google.api import annotations_pb2 as google_dot_api_dot_annotations__pb2 -from google.api import client_pb2 as google_dot_api_dot_client__pb2 -from google.api import visibility_pb2 as google_dot_api_dot_visibility__pb2 -from vdp.controller.v1beta import controller_pb2 as vdp_dot_controller_dot_v1beta_dot_controller__pb2 - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n.vdp/controller/v1beta/controller_service.proto\x12\x15vdp.controller.v1beta\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a\x1bgoogle/api/visibility.proto\x1a&vdp/controller/v1beta/controller.proto2\xf2\x06\n\x18\x43ontrollerPrivateService\x12\x94\x01\n\x08Liveness\x12&.vdp.controller.v1beta.LivenessRequest\x1a\'.vdp.controller.v1beta.LivenessResponse\"7\x82\xd3\xe4\x93\x02\x31\x12\x12/v1beta/__livenessZ\x1b\x12\x19/v1beta/health/controller\x12{\n\tReadiness\x12\'.vdp.controller.v1beta.ReadinessRequest\x1a(.vdp.controller.v1beta.ReadinessResponse\"\x1b\x82\xd3\xe4\x93\x02\x15\x12\x13/v1beta/__readiness\x12\xb3\x01\n\x0bGetResource\x12).vdp.controller.v1beta.GetResourceRequest\x1a*.vdp.controller.v1beta.GetResourceResponse\"M\xda\x41\x12resource_permalink\x82\xd3\xe4\x93\x02\x32\x12\x30/v1beta/{resource_permalink=resources/*/types/*}\x12\xba\x01\n\x0eUpdateResource\x12,.vdp.controller.v1beta.UpdateResourceRequest\x1a-.vdp.controller.v1beta.UpdateResourceResponse\"K\x82\xd3\xe4\x93\x02\x45\x32\x39/v1beta/{resource.resource_permalink=resources/*/types/*}:\x08resource\x12\xbc\x01\n\x0e\x44\x65leteResource\x12,.vdp.controller.v1beta.DeleteResourceRequest\x1a-.vdp.controller.v1beta.DeleteResourceResponse\"M\xda\x41\x12resource_permalink\x82\xd3\xe4\x93\x02\x32*0/v1beta/{resource_permalink=resources/*/types/*}\x1a\x10\xfa\xd2\xe4\x93\x02\n\x12\x08INTERNALB\xf3\x01\n\x19\x63om.vdp.controller.v1betaB\x16\x43ontrollerServiceProtoP\x01ZHgithub.com/instill-ai/protogen-go/vdp/controller/v1beta;controllerv1beta\xa2\x02\x03VCX\xaa\x02\x15Vdp.Controller.V1beta\xca\x02\x15Vdp\\Controller\\V1beta\xe2\x02!Vdp\\Controller\\V1beta\\GPBMetadata\xea\x02\x17Vdp::Controller::V1betab\x06proto3') - -_globals = globals() -_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'vdp.controller.v1beta.controller_service_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'\n\031com.vdp.controller.v1betaB\026ControllerServiceProtoP\001ZHgithub.com/instill-ai/protogen-go/vdp/controller/v1beta;controllerv1beta\242\002\003VCX\252\002\025Vdp.Controller.V1beta\312\002\025Vdp\\Controller\\V1beta\342\002!Vdp\\Controller\\V1beta\\GPBMetadata\352\002\027Vdp::Controller::V1beta' - _CONTROLLERPRIVATESERVICE._options = None - _CONTROLLERPRIVATESERVICE._serialized_options = b'\372\322\344\223\002\n\022\010INTERNAL' - _CONTROLLERPRIVATESERVICE.methods_by_name['Liveness']._options = None - _CONTROLLERPRIVATESERVICE.methods_by_name['Liveness']._serialized_options = b'\202\323\344\223\0021\022\022/v1beta/__livenessZ\033\022\031/v1beta/health/controller' - _CONTROLLERPRIVATESERVICE.methods_by_name['Readiness']._options = None - _CONTROLLERPRIVATESERVICE.methods_by_name['Readiness']._serialized_options = b'\202\323\344\223\002\025\022\023/v1beta/__readiness' - _CONTROLLERPRIVATESERVICE.methods_by_name['GetResource']._options = None - _CONTROLLERPRIVATESERVICE.methods_by_name['GetResource']._serialized_options = b'\332A\022resource_permalink\202\323\344\223\0022\0220/v1beta/{resource_permalink=resources/*/types/*}' - _CONTROLLERPRIVATESERVICE.methods_by_name['UpdateResource']._options = None - _CONTROLLERPRIVATESERVICE.methods_by_name['UpdateResource']._serialized_options = b'\202\323\344\223\002E29/v1beta/{resource.resource_permalink=resources/*/types/*}:\010resource' - _CONTROLLERPRIVATESERVICE.methods_by_name['DeleteResource']._options = None - _CONTROLLERPRIVATESERVICE.methods_by_name['DeleteResource']._serialized_options = b'\332A\022resource_permalink\202\323\344\223\0022*0/v1beta/{resource_permalink=resources/*/types/*}' - _globals['_CONTROLLERPRIVATESERVICE']._serialized_start=198 - _globals['_CONTROLLERPRIVATESERVICE']._serialized_end=1080 -# @@protoc_insertion_point(module_scope) diff --git a/vdp/controller/v1beta/controller_service_pb2.pyi b/vdp/controller/v1beta/controller_service_pb2.pyi deleted file mode 100644 index e08fa11..0000000 --- a/vdp/controller/v1beta/controller_service_pb2.pyi +++ /dev/null @@ -1,7 +0,0 @@ -""" -@generated by mypy-protobuf. Do not edit manually! -isort:skip_file -""" -import google.protobuf.descriptor - -DESCRIPTOR: google.protobuf.descriptor.FileDescriptor diff --git a/vdp/controller/v1beta/controller_service_pb2_grpc.py b/vdp/controller/v1beta/controller_service_pb2_grpc.py deleted file mode 100644 index 24e8414..0000000 --- a/vdp/controller/v1beta/controller_service_pb2_grpc.py +++ /dev/null @@ -1,213 +0,0 @@ -# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT! -"""Client and server classes corresponding to protobuf-defined services.""" -import grpc - -from vdp.controller.v1beta import controller_pb2 as vdp_dot_controller_dot_v1beta_dot_controller__pb2 - - -class ControllerPrivateServiceStub(object): - """Controller service responds to incoming controller requests - """ - - def __init__(self, channel): - """Constructor. - - Args: - channel: A grpc.Channel. - """ - self.Liveness = channel.unary_unary( - '/vdp.controller.v1beta.ControllerPrivateService/Liveness', - request_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.LivenessRequest.SerializeToString, - response_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.LivenessResponse.FromString, - ) - self.Readiness = channel.unary_unary( - '/vdp.controller.v1beta.ControllerPrivateService/Readiness', - request_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.ReadinessRequest.SerializeToString, - response_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.ReadinessResponse.FromString, - ) - self.GetResource = channel.unary_unary( - '/vdp.controller.v1beta.ControllerPrivateService/GetResource', - request_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.GetResourceRequest.SerializeToString, - response_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.GetResourceResponse.FromString, - ) - self.UpdateResource = channel.unary_unary( - '/vdp.controller.v1beta.ControllerPrivateService/UpdateResource', - request_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.UpdateResourceRequest.SerializeToString, - response_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.UpdateResourceResponse.FromString, - ) - self.DeleteResource = channel.unary_unary( - '/vdp.controller.v1beta.ControllerPrivateService/DeleteResource', - request_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.DeleteResourceRequest.SerializeToString, - response_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.DeleteResourceResponse.FromString, - ) - - -class ControllerPrivateServiceServicer(object): - """Controller service responds to incoming controller requests - """ - - def Liveness(self, request, context): - """Liveness method receives a LivenessRequest message and returns a - LivenessResponse message. - See https://github.com/grpc/grpc/blob/master/doc/health-checking.md - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def Readiness(self, request, context): - """Readiness method receives a ReadinessRequest message and returns a - ReadinessResponse message. - See https://github.com/grpc/grpc/blob/master/doc/health-checking.md - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def GetResource(self, request, context): - """GetResource method receives a GetResourceRequest message - and returns a GetResourceResponse - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def UpdateResource(self, request, context): - """UpdateResource method receives a UpdateResourceRequest message - and returns a UpdateResourceResponse - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - def DeleteResource(self, request, context): - """DeleteResource method receives a DeleteResourceRequest message - and returns a DeleteResourceResponse - """ - context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') - - -def add_ControllerPrivateServiceServicer_to_server(servicer, server): - rpc_method_handlers = { - 'Liveness': grpc.unary_unary_rpc_method_handler( - servicer.Liveness, - request_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.LivenessRequest.FromString, - response_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.LivenessResponse.SerializeToString, - ), - 'Readiness': grpc.unary_unary_rpc_method_handler( - servicer.Readiness, - request_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.ReadinessRequest.FromString, - response_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.ReadinessResponse.SerializeToString, - ), - 'GetResource': grpc.unary_unary_rpc_method_handler( - servicer.GetResource, - request_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.GetResourceRequest.FromString, - response_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.GetResourceResponse.SerializeToString, - ), - 'UpdateResource': grpc.unary_unary_rpc_method_handler( - servicer.UpdateResource, - request_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.UpdateResourceRequest.FromString, - response_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.UpdateResourceResponse.SerializeToString, - ), - 'DeleteResource': grpc.unary_unary_rpc_method_handler( - servicer.DeleteResource, - request_deserializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.DeleteResourceRequest.FromString, - response_serializer=vdp_dot_controller_dot_v1beta_dot_controller__pb2.DeleteResourceResponse.SerializeToString, - ), - } - generic_handler = grpc.method_handlers_generic_handler( - 'vdp.controller.v1beta.ControllerPrivateService', rpc_method_handlers) - server.add_generic_rpc_handlers((generic_handler,)) - - - # This class is part of an EXPERIMENTAL API. -class ControllerPrivateService(object): - """Controller service responds to incoming controller requests - """ - - @staticmethod - def Liveness(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.controller.v1beta.ControllerPrivateService/Liveness', - vdp_dot_controller_dot_v1beta_dot_controller__pb2.LivenessRequest.SerializeToString, - vdp_dot_controller_dot_v1beta_dot_controller__pb2.LivenessResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def Readiness(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.controller.v1beta.ControllerPrivateService/Readiness', - vdp_dot_controller_dot_v1beta_dot_controller__pb2.ReadinessRequest.SerializeToString, - vdp_dot_controller_dot_v1beta_dot_controller__pb2.ReadinessResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def GetResource(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.controller.v1beta.ControllerPrivateService/GetResource', - vdp_dot_controller_dot_v1beta_dot_controller__pb2.GetResourceRequest.SerializeToString, - vdp_dot_controller_dot_v1beta_dot_controller__pb2.GetResourceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def UpdateResource(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.controller.v1beta.ControllerPrivateService/UpdateResource', - vdp_dot_controller_dot_v1beta_dot_controller__pb2.UpdateResourceRequest.SerializeToString, - vdp_dot_controller_dot_v1beta_dot_controller__pb2.UpdateResourceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) - - @staticmethod - def DeleteResource(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.controller.v1beta.ControllerPrivateService/DeleteResource', - vdp_dot_controller_dot_v1beta_dot_controller__pb2.DeleteResourceRequest.SerializeToString, - vdp_dot_controller_dot_v1beta_dot_controller__pb2.DeleteResourceResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) diff --git a/vdp/controller/v1beta/controller_service_pb2_grpc.pyi b/vdp/controller/v1beta/controller_service_pb2_grpc.pyi deleted file mode 100644 index 72f756b..0000000 --- a/vdp/controller/v1beta/controller_service_pb2_grpc.pyi +++ /dev/null @@ -1,154 +0,0 @@ -""" -@generated by mypy-protobuf. Do not edit manually! -isort:skip_file -""" -import abc -import collections.abc -import grpc -import grpc.aio -import typing -import vdp.controller.v1beta.controller_pb2 - -_T = typing.TypeVar('_T') - -class _MaybeAsyncIterator(collections.abc.AsyncIterator[_T], collections.abc.Iterator[_T], metaclass=abc.ABCMeta): - ... - -class _ServicerContext(grpc.ServicerContext, grpc.aio.ServicerContext): # type: ignore - ... - -class ControllerPrivateServiceStub: - """Controller service responds to incoming controller requests""" - - def __init__(self, channel: typing.Union[grpc.Channel, grpc.aio.Channel]) -> None: ... - Liveness: grpc.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.LivenessRequest, - vdp.controller.v1beta.controller_pb2.LivenessResponse, - ] - """Liveness method receives a LivenessRequest message and returns a - LivenessResponse message. - See https://github.com/grpc/grpc/blob/master/doc/health-checking.md - """ - Readiness: grpc.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.ReadinessRequest, - vdp.controller.v1beta.controller_pb2.ReadinessResponse, - ] - """Readiness method receives a ReadinessRequest message and returns a - ReadinessResponse message. - See https://github.com/grpc/grpc/blob/master/doc/health-checking.md - """ - GetResource: grpc.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.GetResourceRequest, - vdp.controller.v1beta.controller_pb2.GetResourceResponse, - ] - """GetResource method receives a GetResourceRequest message - and returns a GetResourceResponse - """ - UpdateResource: grpc.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.UpdateResourceRequest, - vdp.controller.v1beta.controller_pb2.UpdateResourceResponse, - ] - """UpdateResource method receives a UpdateResourceRequest message - and returns a UpdateResourceResponse - """ - DeleteResource: grpc.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.DeleteResourceRequest, - vdp.controller.v1beta.controller_pb2.DeleteResourceResponse, - ] - """DeleteResource method receives a DeleteResourceRequest message - and returns a DeleteResourceResponse - """ - -class ControllerPrivateServiceAsyncStub: - """Controller service responds to incoming controller requests""" - - Liveness: grpc.aio.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.LivenessRequest, - vdp.controller.v1beta.controller_pb2.LivenessResponse, - ] - """Liveness method receives a LivenessRequest message and returns a - LivenessResponse message. - See https://github.com/grpc/grpc/blob/master/doc/health-checking.md - """ - Readiness: grpc.aio.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.ReadinessRequest, - vdp.controller.v1beta.controller_pb2.ReadinessResponse, - ] - """Readiness method receives a ReadinessRequest message and returns a - ReadinessResponse message. - See https://github.com/grpc/grpc/blob/master/doc/health-checking.md - """ - GetResource: grpc.aio.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.GetResourceRequest, - vdp.controller.v1beta.controller_pb2.GetResourceResponse, - ] - """GetResource method receives a GetResourceRequest message - and returns a GetResourceResponse - """ - UpdateResource: grpc.aio.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.UpdateResourceRequest, - vdp.controller.v1beta.controller_pb2.UpdateResourceResponse, - ] - """UpdateResource method receives a UpdateResourceRequest message - and returns a UpdateResourceResponse - """ - DeleteResource: grpc.aio.UnaryUnaryMultiCallable[ - vdp.controller.v1beta.controller_pb2.DeleteResourceRequest, - vdp.controller.v1beta.controller_pb2.DeleteResourceResponse, - ] - """DeleteResource method receives a DeleteResourceRequest message - and returns a DeleteResourceResponse - """ - -class ControllerPrivateServiceServicer(metaclass=abc.ABCMeta): - """Controller service responds to incoming controller requests""" - - @abc.abstractmethod - def Liveness( - self, - request: vdp.controller.v1beta.controller_pb2.LivenessRequest, - context: _ServicerContext, - ) -> typing.Union[vdp.controller.v1beta.controller_pb2.LivenessResponse, collections.abc.Awaitable[vdp.controller.v1beta.controller_pb2.LivenessResponse]]: - """Liveness method receives a LivenessRequest message and returns a - LivenessResponse message. - See https://github.com/grpc/grpc/blob/master/doc/health-checking.md - """ - @abc.abstractmethod - def Readiness( - self, - request: vdp.controller.v1beta.controller_pb2.ReadinessRequest, - context: _ServicerContext, - ) -> typing.Union[vdp.controller.v1beta.controller_pb2.ReadinessResponse, collections.abc.Awaitable[vdp.controller.v1beta.controller_pb2.ReadinessResponse]]: - """Readiness method receives a ReadinessRequest message and returns a - ReadinessResponse message. - See https://github.com/grpc/grpc/blob/master/doc/health-checking.md - """ - @abc.abstractmethod - def GetResource( - self, - request: vdp.controller.v1beta.controller_pb2.GetResourceRequest, - context: _ServicerContext, - ) -> typing.Union[vdp.controller.v1beta.controller_pb2.GetResourceResponse, collections.abc.Awaitable[vdp.controller.v1beta.controller_pb2.GetResourceResponse]]: - """GetResource method receives a GetResourceRequest message - and returns a GetResourceResponse - """ - @abc.abstractmethod - def UpdateResource( - self, - request: vdp.controller.v1beta.controller_pb2.UpdateResourceRequest, - context: _ServicerContext, - ) -> typing.Union[vdp.controller.v1beta.controller_pb2.UpdateResourceResponse, collections.abc.Awaitable[vdp.controller.v1beta.controller_pb2.UpdateResourceResponse]]: - """UpdateResource method receives a UpdateResourceRequest message - and returns a UpdateResourceResponse - """ - @abc.abstractmethod - def DeleteResource( - self, - request: vdp.controller.v1beta.controller_pb2.DeleteResourceRequest, - context: _ServicerContext, - ) -> typing.Union[vdp.controller.v1beta.controller_pb2.DeleteResourceResponse, collections.abc.Awaitable[vdp.controller.v1beta.controller_pb2.DeleteResourceResponse]]: - """DeleteResource method receives a DeleteResourceRequest message - and returns a DeleteResourceResponse - """ - -def add_ControllerPrivateServiceServicer_to_server(servicer: ControllerPrivateServiceServicer, server: typing.Union[grpc.Server, grpc.aio.Server]) -> None: ...