From 76c9a3de1f1c3b9a82bdfce37c808665b08cdff3 Mon Sep 17 00:00:00 2001 From: droplet-bot Date: Thu, 10 Aug 2023 07:53:53 +0000 Subject: [PATCH] chore: auto-gen by protobufs triggered by commit: https://github.com/instill-ai/protobufs/commit/d71ac4d41220229d0758a2ef1bbaa9a0551bab90 --- .../v1alpha/connector_definition_pb2.py | 18 +- .../v1alpha/connector_private_service_pb2.py | 9 +- .../connector_private_service_pb2_grpc.py | 37 +++++ .../v1alpha/operator_definition_pb2.py | 88 ++++++++++ .../v1alpha/operator_definition_pb2_grpc.py | 4 + vdp/pipeline/v1alpha/pipeline_pb2.py | 154 +++++++++--------- .../v1alpha/pipeline_private_service_pb2.py | 9 +- .../pipeline_private_service_pb2_grpc.py | 37 +++++ .../v1alpha/pipeline_public_service_pb2.py | 11 +- .../pipeline_public_service_pb2_grpc.py | 73 +++++++++ 10 files changed, 351 insertions(+), 89 deletions(-) create mode 100644 vdp/pipeline/v1alpha/operator_definition_pb2.py create mode 100644 vdp/pipeline/v1alpha/operator_definition_pb2_grpc.py diff --git a/vdp/connector/v1alpha/connector_definition_pb2.py b/vdp/connector/v1alpha/connector_definition_pb2.py index b1806ba..482e91f 100644 --- a/vdp/connector/v1alpha/connector_definition_pb2.py +++ b/vdp/connector/v1alpha/connector_definition_pb2.py @@ -18,7 +18,7 @@ from vdp.connector.v1alpha import spec_pb2 as vdp_dot_connector_dot_v1alpha_dot_spec__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n0vdp/connector/v1alpha/connector_definition.proto\x12\x15vdp.connector.v1alpha\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a\x1cgoogle/protobuf/struct.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\x1a vdp/connector/v1alpha/spec.proto\"\x94\x05\n\x13\x43onnectorDefinition\x12\x18\n\x04name\x18\x01 \x01(\tB\x04\xe2\x41\x01\x03R\x04name\x12\x16\n\x03uid\x18\x02 \x01(\tB\x04\xe2\x41\x01\x03R\x03uid\x12\x14\n\x02id\x18\x03 \x01(\tB\x04\xe2\x41\x01\x05R\x02id\x12\x1a\n\x05title\x18\x04 \x01(\tB\x04\xe2\x41\x01\x03R\x05title\x12\x31\n\x11\x64ocumentation_url\x18\x05 \x01(\tB\x04\xe2\x41\x01\x03R\x10\x64ocumentationUrl\x12\x18\n\x04icon\x18\x06 \x01(\tB\x04\xe2\x41\x01\x03R\x04icon\x12\x35\n\x04spec\x18\x07 \x01(\x0b\x32\x1b.vdp.connector.v1alpha.SpecB\x04\xe2\x41\x01\x03R\x04spec\x12Q\n\x0e\x63onnector_type\x18\x08 \x01(\x0e\x32$.vdp.connector.v1alpha.ConnectorTypeB\x04\xe2\x41\x01\x03R\rconnectorType\x12\"\n\ttombstone\x18\t \x01(\x08\x42\x04\xe2\x41\x01\x03R\ttombstone\x12\x1c\n\x06public\x18\n \x01(\x08\x42\x04\xe2\x41\x01\x03R\x06public\x12\x1c\n\x06\x63ustom\x18\x0b \x01(\x08\x42\x04\xe2\x41\x01\x03R\x06\x63ustom\x12\x1f\n\x08icon_url\x18\x0c \x01(\tB\x04\xe2\x41\x01\x03R\x07iconUrl\x12\x1c\n\x06vendor\x18\r \x01(\tB\x04\xe2\x41\x01\x03R\x06vendor\x12J\n\x11vendor_attributes\x18\x0e \x01(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x03R\x10vendorAttributes:W\xea\x41T\n$api.instill.tech/ConnectorDefinition\x12,connector-definitions/{connector-definition}\"\x83\x02\n\x1fListConnectorDefinitionsRequest\x12&\n\tpage_size\x18\x01 \x01(\x03\x42\x04\xe2\x41\x01\x01H\x00R\x08pageSize\x88\x01\x01\x12(\n\npage_token\x18\x02 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\tpageToken\x88\x01\x01\x12:\n\x04view\x18\x03 \x01(\x0e\x32\x1b.vdp.connector.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x02R\x04view\x88\x01\x01\x12!\n\x06\x66ilter\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x03R\x06\x66ilter\x88\x01\x01\x42\x0c\n\n_page_sizeB\r\n\x0b_page_tokenB\x07\n\x05_viewB\t\n\x07_filter\"\xca\x01\n ListConnectorDefinitionsResponse\x12_\n\x15\x63onnector_definitions\x18\x01 \x03(\x0b\x32*.vdp.connector.v1alpha.ConnectorDefinitionR\x14\x63onnectorDefinitions\x12&\n\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x12\x1d\n\ntotal_size\x18\x03 \x01(\x03R\ttotalSize\"\xc9\x01\n\x1dGetConnectorDefinitionRequest\x12\x63\n\x04name\x18\x01 \x01(\tBO\x92\x41\x1f\xca>\x1c\xfa\x02\x19\x63onnector_definition.name\xe2\x41\x01\x02\xfa\x41&\n$api.instill.tech/ConnectorDefinitionR\x04name\x12:\n\x04view\x18\x02 \x01(\x0e\x32\x1b.vdp.connector.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"\x7f\n\x1eGetConnectorDefinitionResponse\x12]\n\x14\x63onnector_definition\x18\x01 \x01(\x0b\x32*.vdp.connector.v1alpha.ConnectorDefinitionR\x13\x63onnectorDefinition*;\n\x04View\x12\x14\n\x10VIEW_UNSPECIFIED\x10\x00\x12\x0e\n\nVIEW_BASIC\x10\x01\x12\r\n\tVIEW_FULL\x10\x02*\xd6\x01\n\rConnectorType\x12\x1e\n\x1a\x43ONNECTOR_TYPE_UNSPECIFIED\x10\x00\x12\x19\n\x15\x43ONNECTOR_TYPE_SOURCE\x10\x01\x12\x1e\n\x1a\x43ONNECTOR_TYPE_DESTINATION\x10\x02\x12\x15\n\x11\x43ONNECTOR_TYPE_AI\x10\x03\x12\x1d\n\x19\x43ONNECTOR_TYPE_BLOCKCHAIN\x10\x04\x12\x17\n\x13\x43ONNECTOR_TYPE_DATA\x10\x05\x12\x1b\n\x17\x43ONNECTOR_TYPE_OPERATOR\x10\x06\x42\xf5\x01\n\x19\x63om.vdp.connector.v1alphaB\x18\x43onnectorDefinitionProtoP\x01ZHgithub.com/instill-ai/protogen-go/vdp/connector/v1alpha;connectorv1alpha\xa2\x02\x03VCX\xaa\x02\x15Vdp.Connector.V1alpha\xca\x02\x15Vdp\\Connector\\V1alpha\xe2\x02!Vdp\\Connector\\V1alpha\\GPBMetadata\xea\x02\x17Vdp::Connector::V1alphab\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n0vdp/connector/v1alpha/connector_definition.proto\x12\x15vdp.connector.v1alpha\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a\x1cgoogle/protobuf/struct.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\x1a vdp/connector/v1alpha/spec.proto\"\x94\x05\n\x13\x43onnectorDefinition\x12\x18\n\x04name\x18\x01 \x01(\tB\x04\xe2\x41\x01\x03R\x04name\x12\x16\n\x03uid\x18\x02 \x01(\tB\x04\xe2\x41\x01\x03R\x03uid\x12\x14\n\x02id\x18\x03 \x01(\tB\x04\xe2\x41\x01\x05R\x02id\x12\x1a\n\x05title\x18\x04 \x01(\tB\x04\xe2\x41\x01\x03R\x05title\x12\x31\n\x11\x64ocumentation_url\x18\x05 \x01(\tB\x04\xe2\x41\x01\x03R\x10\x64ocumentationUrl\x12\x18\n\x04icon\x18\x06 \x01(\tB\x04\xe2\x41\x01\x03R\x04icon\x12\x35\n\x04spec\x18\x07 \x01(\x0b\x32\x1b.vdp.connector.v1alpha.SpecB\x04\xe2\x41\x01\x03R\x04spec\x12Q\n\x0e\x63onnector_type\x18\x08 \x01(\x0e\x32$.vdp.connector.v1alpha.ConnectorTypeB\x04\xe2\x41\x01\x03R\rconnectorType\x12\"\n\ttombstone\x18\t \x01(\x08\x42\x04\xe2\x41\x01\x03R\ttombstone\x12\x1c\n\x06public\x18\n \x01(\x08\x42\x04\xe2\x41\x01\x03R\x06public\x12\x1c\n\x06\x63ustom\x18\x0b \x01(\x08\x42\x04\xe2\x41\x01\x03R\x06\x63ustom\x12\x1f\n\x08icon_url\x18\x0c \x01(\tB\x04\xe2\x41\x01\x03R\x07iconUrl\x12\x1c\n\x06vendor\x18\r \x01(\tB\x04\xe2\x41\x01\x03R\x06vendor\x12J\n\x11vendor_attributes\x18\x0e \x01(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x03R\x10vendorAttributes:W\xea\x41T\n$api.instill.tech/ConnectorDefinition\x12,connector-definitions/{connector-definition}\"\x83\x02\n\x1fListConnectorDefinitionsRequest\x12&\n\tpage_size\x18\x01 \x01(\x03\x42\x04\xe2\x41\x01\x01H\x00R\x08pageSize\x88\x01\x01\x12(\n\npage_token\x18\x02 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\tpageToken\x88\x01\x01\x12:\n\x04view\x18\x03 \x01(\x0e\x32\x1b.vdp.connector.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x02R\x04view\x88\x01\x01\x12!\n\x06\x66ilter\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x03R\x06\x66ilter\x88\x01\x01\x42\x0c\n\n_page_sizeB\r\n\x0b_page_tokenB\x07\n\x05_viewB\t\n\x07_filter\"\xca\x01\n ListConnectorDefinitionsResponse\x12_\n\x15\x63onnector_definitions\x18\x01 \x03(\x0b\x32*.vdp.connector.v1alpha.ConnectorDefinitionR\x14\x63onnectorDefinitions\x12&\n\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x12\x1d\n\ntotal_size\x18\x03 \x01(\x03R\ttotalSize\"\xc9\x01\n\x1dGetConnectorDefinitionRequest\x12\x63\n\x04name\x18\x01 \x01(\tBO\x92\x41\x1f\xca>\x1c\xfa\x02\x19\x63onnector_definition.name\xe2\x41\x01\x02\xfa\x41&\n$api.instill.tech/ConnectorDefinitionR\x04name\x12:\n\x04view\x18\x02 \x01(\x0e\x32\x1b.vdp.connector.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"\x7f\n\x1eGetConnectorDefinitionResponse\x12]\n\x14\x63onnector_definition\x18\x01 \x01(\x0b\x32*.vdp.connector.v1alpha.ConnectorDefinitionR\x13\x63onnectorDefinition\"\x90\x01\n%LookUpConnectorDefinitionAdminRequest\x12\"\n\tpermalink\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\tpermalink\x12:\n\x04view\x18\x02 \x01(\x0e\x32\x1b.vdp.connector.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"\x87\x01\n&LookUpConnectorDefinitionAdminResponse\x12]\n\x14\x63onnector_definition\x18\x01 \x01(\x0b\x32*.vdp.connector.v1alpha.ConnectorDefinitionR\x13\x63onnectorDefinition*;\n\x04View\x12\x14\n\x10VIEW_UNSPECIFIED\x10\x00\x12\x0e\n\nVIEW_BASIC\x10\x01\x12\r\n\tVIEW_FULL\x10\x02*\xd6\x01\n\rConnectorType\x12\x1e\n\x1a\x43ONNECTOR_TYPE_UNSPECIFIED\x10\x00\x12\x19\n\x15\x43ONNECTOR_TYPE_SOURCE\x10\x01\x12\x1e\n\x1a\x43ONNECTOR_TYPE_DESTINATION\x10\x02\x12\x15\n\x11\x43ONNECTOR_TYPE_AI\x10\x03\x12\x1d\n\x19\x43ONNECTOR_TYPE_BLOCKCHAIN\x10\x04\x12\x17\n\x13\x43ONNECTOR_TYPE_DATA\x10\x05\x12\x1b\n\x17\x43ONNECTOR_TYPE_OPERATOR\x10\x06\x42\xf5\x01\n\x19\x63om.vdp.connector.v1alphaB\x18\x43onnectorDefinitionProtoP\x01ZHgithub.com/instill-ai/protogen-go/vdp/connector/v1alpha;connectorv1alpha\xa2\x02\x03VCX\xaa\x02\x15Vdp.Connector.V1alpha\xca\x02\x15Vdp\\Connector\\V1alpha\xe2\x02!Vdp\\Connector\\V1alpha\\GPBMetadata\xea\x02\x17Vdp::Connector::V1alphab\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -69,10 +69,14 @@ _GETCONNECTORDEFINITIONREQUEST.fields_by_name['name']._serialized_options = b'\222A\037\312>\034\372\002\031connector_definition.name\342A\001\002\372A&\n$api.instill.tech/ConnectorDefinition' _GETCONNECTORDEFINITIONREQUEST.fields_by_name['view']._options = None _GETCONNECTORDEFINITIONREQUEST.fields_by_name['view']._serialized_options = b'\342A\001\001' - _globals['_VIEW']._serialized_start=1710 - _globals['_VIEW']._serialized_end=1769 - _globals['_CONNECTORTYPE']._serialized_start=1772 - _globals['_CONNECTORTYPE']._serialized_end=1986 + _LOOKUPCONNECTORDEFINITIONADMINREQUEST.fields_by_name['permalink']._options = None + _LOOKUPCONNECTORDEFINITIONADMINREQUEST.fields_by_name['permalink']._serialized_options = b'\342A\001\002' + _LOOKUPCONNECTORDEFINITIONADMINREQUEST.fields_by_name['view']._options = None + _LOOKUPCONNECTORDEFINITIONADMINREQUEST.fields_by_name['view']._serialized_options = b'\342A\001\001' + _globals['_VIEW']._serialized_start=1995 + _globals['_VIEW']._serialized_end=2054 + _globals['_CONNECTORTYPE']._serialized_start=2057 + _globals['_CONNECTORTYPE']._serialized_end=2271 _globals['_CONNECTORDEFINITION']._serialized_start=248 _globals['_CONNECTORDEFINITION']._serialized_end=908 _globals['_LISTCONNECTORDEFINITIONSREQUEST']._serialized_start=911 @@ -83,4 +87,8 @@ _globals['_GETCONNECTORDEFINITIONREQUEST']._serialized_end=1579 _globals['_GETCONNECTORDEFINITIONRESPONSE']._serialized_start=1581 _globals['_GETCONNECTORDEFINITIONRESPONSE']._serialized_end=1708 + _globals['_LOOKUPCONNECTORDEFINITIONADMINREQUEST']._serialized_start=1711 + _globals['_LOOKUPCONNECTORDEFINITIONADMINREQUEST']._serialized_end=1855 + _globals['_LOOKUPCONNECTORDEFINITIONADMINRESPONSE']._serialized_start=1858 + _globals['_LOOKUPCONNECTORDEFINITIONADMINRESPONSE']._serialized_end=1993 # @@protoc_insertion_point(module_scope) diff --git a/vdp/connector/v1alpha/connector_private_service_pb2.py b/vdp/connector/v1alpha/connector_private_service_pb2.py index cc2df3f..135e547 100644 --- a/vdp/connector/v1alpha/connector_private_service_pb2.py +++ b/vdp/connector/v1alpha/connector_private_service_pb2.py @@ -14,9 +14,10 @@ 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 vdp.connector.v1alpha import connector_pb2 as vdp_dot_connector_dot_v1alpha_dot_connector__pb2 +from vdp.connector.v1alpha import connector_definition_pb2 as vdp_dot_connector_dot_v1alpha_dot_connector__definition__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n5vdp/connector/v1alpha/connector_private_service.proto\x12\x15vdp.connector.v1alpha\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a%vdp/connector/v1alpha/connector.proto2\xc8\x04\n\x17\x43onnectorPrivateService\x12\x9f\x01\n\x13ListConnectorsAdmin\x12\x31.vdp.connector.v1alpha.ListConnectorsAdminRequest\x1a\x32.vdp.connector.v1alpha.ListConnectorsAdminResponse\"!\x82\xd3\xe4\x93\x02\x1b\x12\x19/v1alpha/admin/connectors\x12\xc3\x01\n\x14LookUpConnectorAdmin\x12\x32.vdp.connector.v1alpha.LookUpConnectorAdminRequest\x1a\x33.vdp.connector.v1alpha.LookUpConnectorAdminResponse\"B\xda\x41\tpermalink\x82\xd3\xe4\x93\x02\x30\x12./v1alpha/admin/{permalink=connectors/*}/lookUp\x12\xc4\x01\n\x0e\x43heckConnector\x12,.vdp.connector.v1alpha.CheckConnectorRequest\x1a-.vdp.connector.v1alpha.CheckConnectorResponse\"U\xda\x41\x13\x63onnector_permalink\x82\xd3\xe4\x93\x02\x39\x12\x37/v1alpha/admin/{connector_permalink=connectors/*}/checkB\xf9\x01\n\x19\x63om.vdp.connector.v1alphaB\x1c\x43onnectorPrivateServiceProtoP\x01ZHgithub.com/instill-ai/protogen-go/vdp/connector/v1alpha;connectorv1alpha\xa2\x02\x03VCX\xaa\x02\x15Vdp.Connector.V1alpha\xca\x02\x15Vdp\\Connector\\V1alpha\xe2\x02!Vdp\\Connector\\V1alpha\\GPBMetadata\xea\x02\x17Vdp::Connector::V1alphab\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n5vdp/connector/v1alpha/connector_private_service.proto\x12\x15vdp.connector.v1alpha\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a%vdp/connector/v1alpha/connector.proto\x1a\x30vdp/connector/v1alpha/connector_definition.proto2\xb7\x06\n\x17\x43onnectorPrivateService\x12\xec\x01\n\x1eLookUpConnectorDefinitionAdmin\x12<.vdp.connector.v1alpha.LookUpConnectorDefinitionAdminRequest\x1a=.vdp.connector.v1alpha.LookUpConnectorDefinitionAdminResponse\"M\xda\x41\tpermalink\x82\xd3\xe4\x93\x02;\x12\x39/v1alpha/admin/{permalink=connector-definitions/*}/lookUp\x12\x9f\x01\n\x13ListConnectorsAdmin\x12\x31.vdp.connector.v1alpha.ListConnectorsAdminRequest\x1a\x32.vdp.connector.v1alpha.ListConnectorsAdminResponse\"!\x82\xd3\xe4\x93\x02\x1b\x12\x19/v1alpha/admin/connectors\x12\xc3\x01\n\x14LookUpConnectorAdmin\x12\x32.vdp.connector.v1alpha.LookUpConnectorAdminRequest\x1a\x33.vdp.connector.v1alpha.LookUpConnectorAdminResponse\"B\xda\x41\tpermalink\x82\xd3\xe4\x93\x02\x30\x12./v1alpha/admin/{permalink=connectors/*}/lookUp\x12\xc4\x01\n\x0e\x43heckConnector\x12,.vdp.connector.v1alpha.CheckConnectorRequest\x1a-.vdp.connector.v1alpha.CheckConnectorResponse\"U\xda\x41\x13\x63onnector_permalink\x82\xd3\xe4\x93\x02\x39\x12\x37/v1alpha/admin/{connector_permalink=connectors/*}/checkB\xf9\x01\n\x19\x63om.vdp.connector.v1alphaB\x1c\x43onnectorPrivateServiceProtoP\x01ZHgithub.com/instill-ai/protogen-go/vdp/connector/v1alpha;connectorv1alpha\xa2\x02\x03VCX\xaa\x02\x15Vdp.Connector.V1alpha\xca\x02\x15Vdp\\Connector\\V1alpha\xe2\x02!Vdp\\Connector\\V1alpha\\GPBMetadata\xea\x02\x17Vdp::Connector::V1alphab\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -25,12 +26,14 @@ DESCRIPTOR._options = None DESCRIPTOR._serialized_options = b'\n\031com.vdp.connector.v1alphaB\034ConnectorPrivateServiceProtoP\001ZHgithub.com/instill-ai/protogen-go/vdp/connector/v1alpha;connectorv1alpha\242\002\003VCX\252\002\025Vdp.Connector.V1alpha\312\002\025Vdp\\Connector\\V1alpha\342\002!Vdp\\Connector\\V1alpha\\GPBMetadata\352\002\027Vdp::Connector::V1alpha' + _CONNECTORPRIVATESERVICE.methods_by_name['LookUpConnectorDefinitionAdmin']._options = None + _CONNECTORPRIVATESERVICE.methods_by_name['LookUpConnectorDefinitionAdmin']._serialized_options = b'\332A\tpermalink\202\323\344\223\002;\0229/v1alpha/admin/{permalink=connector-definitions/*}/lookUp' _CONNECTORPRIVATESERVICE.methods_by_name['ListConnectorsAdmin']._options = None _CONNECTORPRIVATESERVICE.methods_by_name['ListConnectorsAdmin']._serialized_options = b'\202\323\344\223\002\033\022\031/v1alpha/admin/connectors' _CONNECTORPRIVATESERVICE.methods_by_name['LookUpConnectorAdmin']._options = None _CONNECTORPRIVATESERVICE.methods_by_name['LookUpConnectorAdmin']._serialized_options = b'\332A\tpermalink\202\323\344\223\0020\022./v1alpha/admin/{permalink=connectors/*}/lookUp' _CONNECTORPRIVATESERVICE.methods_by_name['CheckConnector']._options = None _CONNECTORPRIVATESERVICE.methods_by_name['CheckConnector']._serialized_options = b'\332A\023connector_permalink\202\323\344\223\0029\0227/v1alpha/admin/{connector_permalink=connectors/*}/check' - _globals['_CONNECTORPRIVATESERVICE']._serialized_start=175 - _globals['_CONNECTORPRIVATESERVICE']._serialized_end=759 + _globals['_CONNECTORPRIVATESERVICE']._serialized_start=225 + _globals['_CONNECTORPRIVATESERVICE']._serialized_end=1048 # @@protoc_insertion_point(module_scope) diff --git a/vdp/connector/v1alpha/connector_private_service_pb2_grpc.py b/vdp/connector/v1alpha/connector_private_service_pb2_grpc.py index de9339d..8010959 100644 --- a/vdp/connector/v1alpha/connector_private_service_pb2_grpc.py +++ b/vdp/connector/v1alpha/connector_private_service_pb2_grpc.py @@ -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 @@ -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, @@ -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. @@ -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, @@ -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, diff --git a/vdp/pipeline/v1alpha/operator_definition_pb2.py b/vdp/pipeline/v1alpha/operator_definition_pb2.py new file mode 100644 index 0000000..588de3d --- /dev/null +++ b/vdp/pipeline/v1alpha/operator_definition_pb2.py @@ -0,0 +1,88 @@ +# -*- coding: utf-8 -*- +# Generated by the protocol buffer compiler. DO NOT EDIT! +# source: vdp/pipeline/v1alpha/operator_definition.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 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 google.protobuf import struct_pb2 as google_dot_protobuf_dot_struct__pb2 +from protoc_gen_openapiv2.options import annotations_pb2 as protoc__gen__openapiv2_dot_options_dot_annotations__pb2 +from vdp.pipeline.v1alpha import pipeline_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2 + + +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n.vdp/pipeline/v1alpha/operator_definition.proto\x12\x14vdp.pipeline.v1alpha\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a\x1cgoogle/protobuf/struct.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\x1a#vdp/pipeline/v1alpha/pipeline.proto\"^\n\x04Spec\x12V\n\x17\x63omponent_specification\x18\x01 \x01(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x02R\x16\x63omponentSpecification\"\xc8\x03\n\x12OperatorDefinition\x12\x18\n\x04name\x18\x01 \x01(\tB\x04\xe2\x41\x01\x03R\x04name\x12\x16\n\x03uid\x18\x02 \x01(\tB\x04\xe2\x41\x01\x03R\x03uid\x12\x14\n\x02id\x18\x03 \x01(\tB\x04\xe2\x41\x01\x05R\x02id\x12\x1a\n\x05title\x18\x04 \x01(\tB\x04\xe2\x41\x01\x03R\x05title\x12\x31\n\x11\x64ocumentation_url\x18\x05 \x01(\tB\x04\xe2\x41\x01\x03R\x10\x64ocumentationUrl\x12\x18\n\x04icon\x18\x06 \x01(\tB\x04\xe2\x41\x01\x03R\x04icon\x12\x34\n\x04spec\x18\x07 \x01(\x0b\x32\x1a.vdp.pipeline.v1alpha.SpecB\x04\xe2\x41\x01\x03R\x04spec\x12\"\n\ttombstone\x18\x08 \x01(\x08\x42\x04\xe2\x41\x01\x03R\ttombstone\x12\x1c\n\x06public\x18\t \x01(\x08\x42\x04\xe2\x41\x01\x03R\x06public\x12\x1c\n\x06\x63ustom\x18\n \x01(\x08\x42\x04\xe2\x41\x01\x03R\x06\x63ustom\x12\x1f\n\x08icon_url\x18\x0b \x01(\tB\x04\xe2\x41\x01\x03R\x07iconUrl:J\xea\x41G\n\x19\x61pi.instill.tech/Operator\x12*operator-definitions/{operator-definition}\"\x81\x02\n\x1eListOperatorDefinitionsRequest\x12&\n\tpage_size\x18\x01 \x01(\x03\x42\x04\xe2\x41\x01\x01H\x00R\x08pageSize\x88\x01\x01\x12(\n\npage_token\x18\x02 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\tpageToken\x88\x01\x01\x12\x39\n\x04view\x18\x03 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x02R\x04view\x88\x01\x01\x12!\n\x06\x66ilter\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x03R\x06\x66ilter\x88\x01\x01\x42\x0c\n\n_page_sizeB\r\n\x0b_page_tokenB\x07\n\x05_viewB\t\n\x07_filter\"\xc5\x01\n\x1fListOperatorDefinitionsResponse\x12[\n\x14operator_definitions\x18\x01 \x03(\x0b\x32(.vdp.pipeline.v1alpha.OperatorDefinitionR\x13operatorDefinitions\x12&\n\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x12\x1d\n\ntotal_size\x18\x03 \x01(\x03R\ttotalSize\"\xbb\x01\n\x1cGetOperatorDefinitionRequest\x12W\n\x04name\x18\x01 \x01(\tBC\x92\x41\x1e\xca>\x1b\xfa\x02\x18operator_definition.name\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/OperatorR\x04name\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"z\n\x1dGetOperatorDefinitionResponse\x12Y\n\x13operator_definition\x18\x01 \x01(\x0b\x32(.vdp.pipeline.v1alpha.OperatorDefinitionR\x12operatorDefinition\"\x8e\x01\n$LookUpOperatorDefinitionAdminRequest\x12\"\n\tpermalink\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\tpermalink\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"\x82\x01\n%LookUpOperatorDefinitionAdminResponse\x12Y\n\x13operator_definition\x18\x01 \x01(\x0b\x32(.vdp.pipeline.v1alpha.OperatorDefinitionR\x12operatorDefinitionB\xed\x01\n\x18\x63om.vdp.pipeline.v1alphaB\x17OperatorDefinitionProtoP\x01ZFgithub.com/instill-ai/protogen-go/vdp/pipeline/v1alpha;pipelinev1alpha\xa2\x02\x03VPX\xaa\x02\x14Vdp.Pipeline.V1alpha\xca\x02\x14Vdp\\Pipeline\\V1alpha\xe2\x02 Vdp\\Pipeline\\V1alpha\\GPBMetadata\xea\x02\x16Vdp::Pipeline::V1alphab\x06proto3') + +_globals = globals() +_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'vdp.pipeline.v1alpha.operator_definition_pb2', _globals) +if _descriptor._USE_C_DESCRIPTORS == False: + + DESCRIPTOR._options = None + DESCRIPTOR._serialized_options = b'\n\030com.vdp.pipeline.v1alphaB\027OperatorDefinitionProtoP\001ZFgithub.com/instill-ai/protogen-go/vdp/pipeline/v1alpha;pipelinev1alpha\242\002\003VPX\252\002\024Vdp.Pipeline.V1alpha\312\002\024Vdp\\Pipeline\\V1alpha\342\002 Vdp\\Pipeline\\V1alpha\\GPBMetadata\352\002\026Vdp::Pipeline::V1alpha' + _SPEC.fields_by_name['component_specification']._options = None + _SPEC.fields_by_name['component_specification']._serialized_options = b'\342A\001\002' + _OPERATORDEFINITION.fields_by_name['name']._options = None + _OPERATORDEFINITION.fields_by_name['name']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['uid']._options = None + _OPERATORDEFINITION.fields_by_name['uid']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['id']._options = None + _OPERATORDEFINITION.fields_by_name['id']._serialized_options = b'\342A\001\005' + _OPERATORDEFINITION.fields_by_name['title']._options = None + _OPERATORDEFINITION.fields_by_name['title']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['documentation_url']._options = None + _OPERATORDEFINITION.fields_by_name['documentation_url']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['icon']._options = None + _OPERATORDEFINITION.fields_by_name['icon']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['spec']._options = None + _OPERATORDEFINITION.fields_by_name['spec']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['tombstone']._options = None + _OPERATORDEFINITION.fields_by_name['tombstone']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['public']._options = None + _OPERATORDEFINITION.fields_by_name['public']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['custom']._options = None + _OPERATORDEFINITION.fields_by_name['custom']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION.fields_by_name['icon_url']._options = None + _OPERATORDEFINITION.fields_by_name['icon_url']._serialized_options = b'\342A\001\003' + _OPERATORDEFINITION._options = None + _OPERATORDEFINITION._serialized_options = b'\352AG\n\031api.instill.tech/Operator\022*operator-definitions/{operator-definition}' + _LISTOPERATORDEFINITIONSREQUEST.fields_by_name['page_size']._options = None + _LISTOPERATORDEFINITIONSREQUEST.fields_by_name['page_size']._serialized_options = b'\342A\001\001' + _LISTOPERATORDEFINITIONSREQUEST.fields_by_name['page_token']._options = None + _LISTOPERATORDEFINITIONSREQUEST.fields_by_name['page_token']._serialized_options = b'\342A\001\001' + _LISTOPERATORDEFINITIONSREQUEST.fields_by_name['view']._options = None + _LISTOPERATORDEFINITIONSREQUEST.fields_by_name['view']._serialized_options = b'\342A\001\001' + _LISTOPERATORDEFINITIONSREQUEST.fields_by_name['filter']._options = None + _LISTOPERATORDEFINITIONSREQUEST.fields_by_name['filter']._serialized_options = b'\342A\001\001' + _GETOPERATORDEFINITIONREQUEST.fields_by_name['name']._options = None + _GETOPERATORDEFINITIONREQUEST.fields_by_name['name']._serialized_options = b'\222A\036\312>\033\372\002\030operator_definition.name\342A\001\002\372A\033\n\031api.instill.tech/Operator' + _GETOPERATORDEFINITIONREQUEST.fields_by_name['view']._options = None + _GETOPERATORDEFINITIONREQUEST.fields_by_name['view']._serialized_options = b'\342A\001\001' + _LOOKUPOPERATORDEFINITIONADMINREQUEST.fields_by_name['permalink']._options = None + _LOOKUPOPERATORDEFINITIONADMINREQUEST.fields_by_name['permalink']._serialized_options = b'\342A\001\002' + _LOOKUPOPERATORDEFINITIONADMINREQUEST.fields_by_name['view']._options = None + _LOOKUPOPERATORDEFINITIONADMINREQUEST.fields_by_name['view']._serialized_options = b'\342A\001\001' + _globals['_SPEC']._serialized_start=247 + _globals['_SPEC']._serialized_end=341 + _globals['_OPERATORDEFINITION']._serialized_start=344 + _globals['_OPERATORDEFINITION']._serialized_end=800 + _globals['_LISTOPERATORDEFINITIONSREQUEST']._serialized_start=803 + _globals['_LISTOPERATORDEFINITIONSREQUEST']._serialized_end=1060 + _globals['_LISTOPERATORDEFINITIONSRESPONSE']._serialized_start=1063 + _globals['_LISTOPERATORDEFINITIONSRESPONSE']._serialized_end=1260 + _globals['_GETOPERATORDEFINITIONREQUEST']._serialized_start=1263 + _globals['_GETOPERATORDEFINITIONREQUEST']._serialized_end=1450 + _globals['_GETOPERATORDEFINITIONRESPONSE']._serialized_start=1452 + _globals['_GETOPERATORDEFINITIONRESPONSE']._serialized_end=1574 + _globals['_LOOKUPOPERATORDEFINITIONADMINREQUEST']._serialized_start=1577 + _globals['_LOOKUPOPERATORDEFINITIONADMINREQUEST']._serialized_end=1719 + _globals['_LOOKUPOPERATORDEFINITIONADMINRESPONSE']._serialized_start=1722 + _globals['_LOOKUPOPERATORDEFINITIONADMINRESPONSE']._serialized_end=1852 +# @@protoc_insertion_point(module_scope) diff --git a/vdp/pipeline/v1alpha/operator_definition_pb2_grpc.py b/vdp/pipeline/v1alpha/operator_definition_pb2_grpc.py new file mode 100644 index 0000000..2daafff --- /dev/null +++ b/vdp/pipeline/v1alpha/operator_definition_pb2_grpc.py @@ -0,0 +1,4 @@ +# 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/pipeline/v1alpha/pipeline_pb2.py b/vdp/pipeline/v1alpha/pipeline_pb2.py index bc3d938..cd12bbb 100644 --- a/vdp/pipeline/v1alpha/pipeline_pb2.py +++ b/vdp/pipeline/v1alpha/pipeline_pb2.py @@ -21,7 +21,7 @@ from protoc_gen_openapiv2.options import annotations_pb2 as protoc__gen__openapiv2_dot_options_dot_annotations__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n#vdp/pipeline/v1alpha/pipeline.proto\x12\x14vdp.pipeline.v1alpha\x1a,common/healthcheck/v1alpha/healthcheck.proto\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a#google/longrunning/operations.proto\x1a google/protobuf/field_mask.proto\x1a\x1cgoogle/protobuf/struct.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\"\x97\x01\n\x0fLivenessRequest\x12k\n\x14health_check_request\x18\x01 \x01(\x0b\x32..common.healthcheck.v1alpha.HealthCheckRequestB\x04\xe2\x41\x01\x01H\x00R\x12healthCheckRequest\x88\x01\x01\x42\x17\n\x15_health_check_request\"w\n\x10LivenessResponse\x12\x63\n\x15health_check_response\x18\x01 \x01(\x0b\x32/.common.healthcheck.v1alpha.HealthCheckResponseR\x13healthCheckResponse\"\x98\x01\n\x10ReadinessRequest\x12k\n\x14health_check_request\x18\x01 \x01(\x0b\x32..common.healthcheck.v1alpha.HealthCheckRequestB\x04\xe2\x41\x01\x01H\x00R\x12healthCheckRequest\x88\x01\x01\x42\x17\n\x15_health_check_request\"x\n\x11ReadinessResponse\x12\x63\n\x15health_check_response\x18\x01 \x01(\x0b\x32/.common.healthcheck.v1alpha.HealthCheckResponseR\x13healthCheckResponse\"\xf3\x01\n\tComponent\x12\x14\n\x02id\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\x02id\x12/\n\rresource_name\x18\x02 \x01(\tB\n\xe2\x41\x01\x02\xfa\x41\x03\n\x01*R\x0cresourceName\x12\x46\n\x0fresource_detail\x18\x03 \x01(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x03R\x0eresourceDetail\x12=\n\rconfiguration\x18\x04 \x01(\x0b\x32\x17.google.protobuf.StructR\rconfiguration\x12\x18\n\x04type\x18\x06 \x01(\tB\x04\xe2\x41\x01\x03R\x04type\"c\n\x06Recipe\x12\x18\n\x07version\x18\x01 \x01(\tR\x07version\x12?\n\ncomponents\x18\x02 \x03(\x0b\x32\x1f.vdp.pipeline.v1alpha.ComponentR\ncomponents\"\x9b\x05\n\x08Pipeline\x12\x18\n\x04name\x18\x01 \x01(\tB\x04\xe2\x41\x01\x03R\x04name\x12\x16\n\x03uid\x18\x02 \x01(\tB\x04\xe2\x41\x01\x03R\x03uid\x12\x14\n\x02id\x18\x03 \x01(\tB\x04\xe2\x41\x01\x05R\x02id\x12+\n\x0b\x64\x65scription\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\x0b\x64\x65scription\x88\x01\x01\x12:\n\x06recipe\x18\x05 \x01(\x0b\x32\x1c.vdp.pipeline.v1alpha.RecipeB\x04\xe2\x41\x01\x05R\x06recipe\x12@\n\x05state\x18\x07 \x01(\x0e\x32$.vdp.pipeline.v1alpha.Pipeline.StateB\x04\xe2\x41\x01\x03R\x05state\x12\x34\n\x04user\x18\x08 \x01(\tB\x1e\xe2\x41\x01\x03\xfa\x41\x17\n\x15\x61pi.instill.tech/UserH\x00R\x04user\x12:\n\x03org\x18\t \x01(\tB&\xe2\x41\x01\x03\xfa\x41\x1f\n\x1d\x61pi.instill.tech/OrganizationH\x00R\x03org\x12\x41\n\x0b\x63reate_time\x18\n \x01(\x0b\x32\x1a.google.protobuf.TimestampB\x04\xe2\x41\x01\x03R\ncreateTime\x12\x41\n\x0bupdate_time\x18\x0b \x01(\x0b\x32\x1a.google.protobuf.TimestampB\x04\xe2\x41\x01\x03R\nupdateTime\"U\n\x05State\x12\x15\n\x11STATE_UNSPECIFIED\x10\x00\x12\x12\n\x0eSTATE_INACTIVE\x10\x01\x12\x10\n\x0cSTATE_ACTIVE\x10\x02\x12\x0f\n\x0bSTATE_ERROR\x10\x03:4\xea\x41\x31\n\x19\x61pi.instill.tech/Pipeline\x12\x14pipelines/{pipeline}B\x07\n\x05ownerB\x0e\n\x0c_description\"Y\n\x15\x43reatePipelineRequest\x12@\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineB\x04\xe2\x41\x01\x02R\x08pipeline\"T\n\x16\x43reatePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"\xf7\x01\n\x14ListPipelinesRequest\x12&\n\tpage_size\x18\x01 \x01(\x03\x42\x04\xe2\x41\x01\x01H\x00R\x08pageSize\x88\x01\x01\x12(\n\npage_token\x18\x02 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\tpageToken\x88\x01\x01\x12\x39\n\x04view\x18\x03 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x02R\x04view\x88\x01\x01\x12!\n\x06\x66ilter\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x03R\x06\x66ilter\x88\x01\x01\x42\x0c\n\n_page_sizeB\r\n\x0b_page_tokenB\x07\n\x05_viewB\t\n\x07_filter\"\x9c\x01\n\x15ListPipelinesResponse\x12<\n\tpipelines\x18\x01 \x03(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\tpipelines\x12&\n\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x12\x1d\n\ntotal_size\x18\x03 \x01(\x03R\ttotalSize\"\xa6\x01\n\x12GetPipelineRequest\x12L\n\x04name\x18\x01 \x01(\tB8\x92\x41\x13\xca>\x10\xfa\x02\rpipeline.name\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"Q\n\x13GetPipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"\x9c\x01\n\x15UpdatePipelineRequest\x12@\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineB\x04\xe2\x41\x01\x02R\x08pipeline\x12\x41\n\x0bupdate_mask\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.FieldMaskB\x04\xe2\x41\x01\x02R\nupdateMask\"T\n\x16UpdatePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"e\n\x15\x44\x65letePipelineRequest\x12L\n\x04name\x18\x01 \x01(\tB8\x92\x41\x13\xca>\x10\xfa\x02\rpipeline.name\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\"\x18\n\x16\x44\x65letePipelineResponse\"\x7f\n\x15LookUpPipelineRequest\x12\"\n\tpermalink\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\tpermalink\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"T\n\x16LookUpPipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"Q\n\x17\x41\x63tivatePipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\"V\n\x18\x41\x63tivatePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"S\n\x19\x44\x65\x61\x63tivatePipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\"X\n\x1a\x44\x65\x61\x63tivatePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"}\n\x15RenamePipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12,\n\x0fnew_pipeline_id\x18\x02 \x01(\tB\x04\xe2\x41\x01\x02R\rnewPipelineId\"T\n\x16RenamePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"\x87\x01\n\x16TriggerPipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12\x35\n\x06inputs\x18\x02 \x03(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x02R\x06inputs\"L\n\x17TriggerPipelineResponse\x12\x31\n\x07outputs\x18\x01 \x03(\x0b\x32\x17.google.protobuf.StructR\x07outputs\"\x8c\x01\n\x1bTriggerAsyncPipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12\x35\n\x06inputs\x18\x02 \x03(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x02R\x06inputs\"a\n\x1cTriggerAsyncPipelineResponse\x12\x41\n\toperation\x18\x01 \x01(\x0b\x32\x1d.google.longrunning.OperationB\x04\xe2\x41\x01\x03R\toperation\"/\n\x13GetOperationRequest\x12\x18\n\x04name\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\x04name\"Y\n\x14GetOperationResponse\x12\x41\n\toperation\x18\x01 \x01(\x0b\x32\x1d.google.longrunning.OperationB\x04\xe2\x41\x01\x03R\toperation\"j\n\x14WatchPipelineRequest\x12R\n\x04name\x18\x01 \x01(\tB>\x92\x41\x19\xca>\x16\xfa\x02\x13pipeline.name/watch\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\"S\n\x15WatchPipelineResponse\x12:\n\x05state\x18\x01 \x01(\x0e\x32$.vdp.pipeline.v1alpha.Pipeline.StateR\x05state\"\xfc\x01\n\x19ListPipelinesAdminRequest\x12&\n\tpage_size\x18\x01 \x01(\x03\x42\x04\xe2\x41\x01\x01H\x00R\x08pageSize\x88\x01\x01\x12(\n\npage_token\x18\x02 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\tpageToken\x88\x01\x01\x12\x39\n\x04view\x18\x03 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x02R\x04view\x88\x01\x01\x12!\n\x06\x66ilter\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x03R\x06\x66ilter\x88\x01\x01\x42\x0c\n\n_page_sizeB\r\n\x0b_page_tokenB\x07\n\x05_viewB\t\n\x07_filter\"\xa1\x01\n\x1aListPipelinesAdminResponse\x12<\n\tpipelines\x18\x01 \x03(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\tpipelines\x12&\n\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x12\x1d\n\ntotal_size\x18\x03 \x01(\x03R\ttotalSize\"\xab\x01\n\x17GetPipelineAdminRequest\x12L\n\x04name\x18\x01 \x01(\tB8\x92\x41\x13\xca>\x10\xfa\x02\rpipeline.name\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"V\n\x18GetPipelineAdminResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"\x84\x01\n\x1aLookUpPipelineAdminRequest\x12\"\n\tpermalink\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\tpermalink\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"Y\n\x1bLookUpPipelineAdminResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline*;\n\x04View\x12\x14\n\x10VIEW_UNSPECIFIED\x10\x00\x12\x0e\n\nVIEW_BASIC\x10\x01\x12\r\n\tVIEW_FULL\x10\x02\x42\xe3\x01\n\x18\x63om.vdp.pipeline.v1alphaB\rPipelineProtoP\x01ZFgithub.com/instill-ai/protogen-go/vdp/pipeline/v1alpha;pipelinev1alpha\xa2\x02\x03VPX\xaa\x02\x14Vdp.Pipeline.V1alpha\xca\x02\x14Vdp\\Pipeline\\V1alpha\xe2\x02 Vdp\\Pipeline\\V1alpha\\GPBMetadata\xea\x02\x16Vdp::Pipeline::V1alphab\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n#vdp/pipeline/v1alpha/pipeline.proto\x12\x14vdp.pipeline.v1alpha\x1a,common/healthcheck/v1alpha/healthcheck.proto\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a#google/longrunning/operations.proto\x1a google/protobuf/field_mask.proto\x1a\x1cgoogle/protobuf/struct.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a.protoc-gen-openapiv2/options/annotations.proto\"\x97\x01\n\x0fLivenessRequest\x12k\n\x14health_check_request\x18\x01 \x01(\x0b\x32..common.healthcheck.v1alpha.HealthCheckRequestB\x04\xe2\x41\x01\x01H\x00R\x12healthCheckRequest\x88\x01\x01\x42\x17\n\x15_health_check_request\"w\n\x10LivenessResponse\x12\x63\n\x15health_check_response\x18\x01 \x01(\x0b\x32/.common.healthcheck.v1alpha.HealthCheckResponseR\x13healthCheckResponse\"\x98\x01\n\x10ReadinessRequest\x12k\n\x14health_check_request\x18\x01 \x01(\x0b\x32..common.healthcheck.v1alpha.HealthCheckRequestB\x04\xe2\x41\x01\x01H\x00R\x12healthCheckRequest\x88\x01\x01\x42\x17\n\x15_health_check_request\"x\n\x11ReadinessResponse\x12\x63\n\x15health_check_response\x18\x01 \x01(\x0b\x32/.common.healthcheck.v1alpha.HealthCheckResponseR\x13healthCheckResponse\"\xf0\x02\n\tComponent\x12\x14\n\x02id\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\x02id\x12+\n\rresource_name\x18\x02 \x01(\tB\x06\xfa\x41\x03\n\x01*R\x0cresourceName\x12\x46\n\x0fresource_detail\x18\x03 \x01(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x03R\x0eresourceDetail\x12=\n\rconfiguration\x18\x04 \x01(\x0b\x32\x17.google.protobuf.StructR\rconfiguration\x12\x18\n\x04type\x18\x06 \x01(\tB\x04\xe2\x41\x01\x03R\x04type\x12\x33\n\x0f\x64\x65\x66inition_name\x18\x07 \x01(\tB\n\xe2\x41\x01\x02\xfa\x41\x03\n\x01*R\x0e\x64\x65\x66initionName\x12J\n\x11\x64\x65\x66inition_detail\x18\x08 \x01(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x03R\x10\x64\x65\x66initionDetail\"c\n\x06Recipe\x12\x18\n\x07version\x18\x01 \x01(\tR\x07version\x12?\n\ncomponents\x18\x02 \x03(\x0b\x32\x1f.vdp.pipeline.v1alpha.ComponentR\ncomponents\"\x9b\x05\n\x08Pipeline\x12\x18\n\x04name\x18\x01 \x01(\tB\x04\xe2\x41\x01\x03R\x04name\x12\x16\n\x03uid\x18\x02 \x01(\tB\x04\xe2\x41\x01\x03R\x03uid\x12\x14\n\x02id\x18\x03 \x01(\tB\x04\xe2\x41\x01\x05R\x02id\x12+\n\x0b\x64\x65scription\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\x0b\x64\x65scription\x88\x01\x01\x12:\n\x06recipe\x18\x05 \x01(\x0b\x32\x1c.vdp.pipeline.v1alpha.RecipeB\x04\xe2\x41\x01\x05R\x06recipe\x12@\n\x05state\x18\x07 \x01(\x0e\x32$.vdp.pipeline.v1alpha.Pipeline.StateB\x04\xe2\x41\x01\x03R\x05state\x12\x34\n\x04user\x18\x08 \x01(\tB\x1e\xe2\x41\x01\x03\xfa\x41\x17\n\x15\x61pi.instill.tech/UserH\x00R\x04user\x12:\n\x03org\x18\t \x01(\tB&\xe2\x41\x01\x03\xfa\x41\x1f\n\x1d\x61pi.instill.tech/OrganizationH\x00R\x03org\x12\x41\n\x0b\x63reate_time\x18\n \x01(\x0b\x32\x1a.google.protobuf.TimestampB\x04\xe2\x41\x01\x03R\ncreateTime\x12\x41\n\x0bupdate_time\x18\x0b \x01(\x0b\x32\x1a.google.protobuf.TimestampB\x04\xe2\x41\x01\x03R\nupdateTime\"U\n\x05State\x12\x15\n\x11STATE_UNSPECIFIED\x10\x00\x12\x12\n\x0eSTATE_INACTIVE\x10\x01\x12\x10\n\x0cSTATE_ACTIVE\x10\x02\x12\x0f\n\x0bSTATE_ERROR\x10\x03:4\xea\x41\x31\n\x19\x61pi.instill.tech/Pipeline\x12\x14pipelines/{pipeline}B\x07\n\x05ownerB\x0e\n\x0c_description\"Y\n\x15\x43reatePipelineRequest\x12@\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineB\x04\xe2\x41\x01\x02R\x08pipeline\"T\n\x16\x43reatePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"\xf7\x01\n\x14ListPipelinesRequest\x12&\n\tpage_size\x18\x01 \x01(\x03\x42\x04\xe2\x41\x01\x01H\x00R\x08pageSize\x88\x01\x01\x12(\n\npage_token\x18\x02 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\tpageToken\x88\x01\x01\x12\x39\n\x04view\x18\x03 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x02R\x04view\x88\x01\x01\x12!\n\x06\x66ilter\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x03R\x06\x66ilter\x88\x01\x01\x42\x0c\n\n_page_sizeB\r\n\x0b_page_tokenB\x07\n\x05_viewB\t\n\x07_filter\"\x9c\x01\n\x15ListPipelinesResponse\x12<\n\tpipelines\x18\x01 \x03(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\tpipelines\x12&\n\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x12\x1d\n\ntotal_size\x18\x03 \x01(\x03R\ttotalSize\"\xa6\x01\n\x12GetPipelineRequest\x12L\n\x04name\x18\x01 \x01(\tB8\x92\x41\x13\xca>\x10\xfa\x02\rpipeline.name\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"Q\n\x13GetPipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"\x9c\x01\n\x15UpdatePipelineRequest\x12@\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineB\x04\xe2\x41\x01\x02R\x08pipeline\x12\x41\n\x0bupdate_mask\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.FieldMaskB\x04\xe2\x41\x01\x02R\nupdateMask\"T\n\x16UpdatePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"e\n\x15\x44\x65letePipelineRequest\x12L\n\x04name\x18\x01 \x01(\tB8\x92\x41\x13\xca>\x10\xfa\x02\rpipeline.name\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\"\x18\n\x16\x44\x65letePipelineResponse\"\x7f\n\x15LookUpPipelineRequest\x12\"\n\tpermalink\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\tpermalink\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"T\n\x16LookUpPipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"Q\n\x17\x41\x63tivatePipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\"V\n\x18\x41\x63tivatePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"S\n\x19\x44\x65\x61\x63tivatePipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\"X\n\x1a\x44\x65\x61\x63tivatePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"}\n\x15RenamePipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12,\n\x0fnew_pipeline_id\x18\x02 \x01(\tB\x04\xe2\x41\x01\x02R\rnewPipelineId\"T\n\x16RenamePipelineResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"\x87\x01\n\x16TriggerPipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12\x35\n\x06inputs\x18\x02 \x03(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x02R\x06inputs\"L\n\x17TriggerPipelineResponse\x12\x31\n\x07outputs\x18\x01 \x03(\x0b\x32\x17.google.protobuf.StructR\x07outputs\"\x8c\x01\n\x1bTriggerAsyncPipelineRequest\x12\x36\n\x04name\x18\x01 \x01(\tB\"\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12\x35\n\x06inputs\x18\x02 \x03(\x0b\x32\x17.google.protobuf.StructB\x04\xe2\x41\x01\x02R\x06inputs\"a\n\x1cTriggerAsyncPipelineResponse\x12\x41\n\toperation\x18\x01 \x01(\x0b\x32\x1d.google.longrunning.OperationB\x04\xe2\x41\x01\x03R\toperation\"/\n\x13GetOperationRequest\x12\x18\n\x04name\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\x04name\"Y\n\x14GetOperationResponse\x12\x41\n\toperation\x18\x01 \x01(\x0b\x32\x1d.google.longrunning.OperationB\x04\xe2\x41\x01\x03R\toperation\"j\n\x14WatchPipelineRequest\x12R\n\x04name\x18\x01 \x01(\tB>\x92\x41\x19\xca>\x16\xfa\x02\x13pipeline.name/watch\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\"S\n\x15WatchPipelineResponse\x12:\n\x05state\x18\x01 \x01(\x0e\x32$.vdp.pipeline.v1alpha.Pipeline.StateR\x05state\"\xfc\x01\n\x19ListPipelinesAdminRequest\x12&\n\tpage_size\x18\x01 \x01(\x03\x42\x04\xe2\x41\x01\x01H\x00R\x08pageSize\x88\x01\x01\x12(\n\npage_token\x18\x02 \x01(\tB\x04\xe2\x41\x01\x01H\x01R\tpageToken\x88\x01\x01\x12\x39\n\x04view\x18\x03 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x02R\x04view\x88\x01\x01\x12!\n\x06\x66ilter\x18\x04 \x01(\tB\x04\xe2\x41\x01\x01H\x03R\x06\x66ilter\x88\x01\x01\x42\x0c\n\n_page_sizeB\r\n\x0b_page_tokenB\x07\n\x05_viewB\t\n\x07_filter\"\xa1\x01\n\x1aListPipelinesAdminResponse\x12<\n\tpipelines\x18\x01 \x03(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\tpipelines\x12&\n\x0fnext_page_token\x18\x02 \x01(\tR\rnextPageToken\x12\x1d\n\ntotal_size\x18\x03 \x01(\x03R\ttotalSize\"\xab\x01\n\x17GetPipelineAdminRequest\x12L\n\x04name\x18\x01 \x01(\tB8\x92\x41\x13\xca>\x10\xfa\x02\rpipeline.name\xe2\x41\x01\x02\xfa\x41\x1b\n\x19\x61pi.instill.tech/PipelineR\x04name\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"V\n\x18GetPipelineAdminResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline\"\x84\x01\n\x1aLookUpPipelineAdminRequest\x12\"\n\tpermalink\x18\x01 \x01(\tB\x04\xe2\x41\x01\x02R\tpermalink\x12\x39\n\x04view\x18\x02 \x01(\x0e\x32\x1a.vdp.pipeline.v1alpha.ViewB\x04\xe2\x41\x01\x01H\x00R\x04view\x88\x01\x01\x42\x07\n\x05_view\"Y\n\x1bLookUpPipelineAdminResponse\x12:\n\x08pipeline\x18\x01 \x01(\x0b\x32\x1e.vdp.pipeline.v1alpha.PipelineR\x08pipeline*;\n\x04View\x12\x14\n\x10VIEW_UNSPECIFIED\x10\x00\x12\x0e\n\nVIEW_BASIC\x10\x01\x12\r\n\tVIEW_FULL\x10\x02\x42\xe3\x01\n\x18\x63om.vdp.pipeline.v1alphaB\rPipelineProtoP\x01ZFgithub.com/instill-ai/protogen-go/vdp/pipeline/v1alpha;pipelinev1alpha\xa2\x02\x03VPX\xaa\x02\x14Vdp.Pipeline.V1alpha\xca\x02\x14Vdp\\Pipeline\\V1alpha\xe2\x02 Vdp\\Pipeline\\V1alpha\\GPBMetadata\xea\x02\x16Vdp::Pipeline::V1alphab\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -37,11 +37,15 @@ _COMPONENT.fields_by_name['id']._options = None _COMPONENT.fields_by_name['id']._serialized_options = b'\342A\001\002' _COMPONENT.fields_by_name['resource_name']._options = None - _COMPONENT.fields_by_name['resource_name']._serialized_options = b'\342A\001\002\372A\003\n\001*' + _COMPONENT.fields_by_name['resource_name']._serialized_options = b'\372A\003\n\001*' _COMPONENT.fields_by_name['resource_detail']._options = None _COMPONENT.fields_by_name['resource_detail']._serialized_options = b'\342A\001\003' _COMPONENT.fields_by_name['type']._options = None _COMPONENT.fields_by_name['type']._serialized_options = b'\342A\001\003' + _COMPONENT.fields_by_name['definition_name']._options = None + _COMPONENT.fields_by_name['definition_name']._serialized_options = b'\342A\001\002\372A\003\n\001*' + _COMPONENT.fields_by_name['definition_detail']._options = None + _COMPONENT.fields_by_name['definition_detail']._serialized_options = b'\342A\001\003' _PIPELINE.fields_by_name['name']._options = None _PIPELINE.fields_by_name['name']._serialized_options = b'\342A\001\003' _PIPELINE.fields_by_name['uid']._options = None @@ -128,8 +132,8 @@ _LOOKUPPIPELINEADMINREQUEST.fields_by_name['permalink']._serialized_options = b'\342A\001\002' _LOOKUPPIPELINEADMINREQUEST.fields_by_name['view']._options = None _LOOKUPPIPELINEADMINREQUEST.fields_by_name['view']._serialized_options = b'\342A\001\001' - _globals['_VIEW']._serialized_start=5602 - _globals['_VIEW']._serialized_end=5661 + _globals['_VIEW']._serialized_start=5727 + _globals['_VIEW']._serialized_end=5786 _globals['_LIVENESSREQUEST']._serialized_start=350 _globals['_LIVENESSREQUEST']._serialized_end=501 _globals['_LIVENESSRESPONSE']._serialized_start=503 @@ -139,75 +143,75 @@ _globals['_READINESSRESPONSE']._serialized_start=779 _globals['_READINESSRESPONSE']._serialized_end=899 _globals['_COMPONENT']._serialized_start=902 - _globals['_COMPONENT']._serialized_end=1145 - _globals['_RECIPE']._serialized_start=1147 - _globals['_RECIPE']._serialized_end=1246 - _globals['_PIPELINE']._serialized_start=1249 - _globals['_PIPELINE']._serialized_end=1916 - _globals['_PIPELINE_STATE']._serialized_start=1752 - _globals['_PIPELINE_STATE']._serialized_end=1837 - _globals['_CREATEPIPELINEREQUEST']._serialized_start=1918 - _globals['_CREATEPIPELINEREQUEST']._serialized_end=2007 - _globals['_CREATEPIPELINERESPONSE']._serialized_start=2009 - _globals['_CREATEPIPELINERESPONSE']._serialized_end=2093 - _globals['_LISTPIPELINESREQUEST']._serialized_start=2096 - _globals['_LISTPIPELINESREQUEST']._serialized_end=2343 - _globals['_LISTPIPELINESRESPONSE']._serialized_start=2346 - _globals['_LISTPIPELINESRESPONSE']._serialized_end=2502 - _globals['_GETPIPELINEREQUEST']._serialized_start=2505 - _globals['_GETPIPELINEREQUEST']._serialized_end=2671 - _globals['_GETPIPELINERESPONSE']._serialized_start=2673 - _globals['_GETPIPELINERESPONSE']._serialized_end=2754 - _globals['_UPDATEPIPELINEREQUEST']._serialized_start=2757 - _globals['_UPDATEPIPELINEREQUEST']._serialized_end=2913 - _globals['_UPDATEPIPELINERESPONSE']._serialized_start=2915 - _globals['_UPDATEPIPELINERESPONSE']._serialized_end=2999 - _globals['_DELETEPIPELINEREQUEST']._serialized_start=3001 - _globals['_DELETEPIPELINEREQUEST']._serialized_end=3102 - _globals['_DELETEPIPELINERESPONSE']._serialized_start=3104 - _globals['_DELETEPIPELINERESPONSE']._serialized_end=3128 - _globals['_LOOKUPPIPELINEREQUEST']._serialized_start=3130 - _globals['_LOOKUPPIPELINEREQUEST']._serialized_end=3257 - _globals['_LOOKUPPIPELINERESPONSE']._serialized_start=3259 - _globals['_LOOKUPPIPELINERESPONSE']._serialized_end=3343 - _globals['_ACTIVATEPIPELINEREQUEST']._serialized_start=3345 - _globals['_ACTIVATEPIPELINEREQUEST']._serialized_end=3426 - _globals['_ACTIVATEPIPELINERESPONSE']._serialized_start=3428 - _globals['_ACTIVATEPIPELINERESPONSE']._serialized_end=3514 - _globals['_DEACTIVATEPIPELINEREQUEST']._serialized_start=3516 - _globals['_DEACTIVATEPIPELINEREQUEST']._serialized_end=3599 - _globals['_DEACTIVATEPIPELINERESPONSE']._serialized_start=3601 - _globals['_DEACTIVATEPIPELINERESPONSE']._serialized_end=3689 - _globals['_RENAMEPIPELINEREQUEST']._serialized_start=3691 - _globals['_RENAMEPIPELINEREQUEST']._serialized_end=3816 - _globals['_RENAMEPIPELINERESPONSE']._serialized_start=3818 - _globals['_RENAMEPIPELINERESPONSE']._serialized_end=3902 - _globals['_TRIGGERPIPELINEREQUEST']._serialized_start=3905 - _globals['_TRIGGERPIPELINEREQUEST']._serialized_end=4040 - _globals['_TRIGGERPIPELINERESPONSE']._serialized_start=4042 - _globals['_TRIGGERPIPELINERESPONSE']._serialized_end=4118 - _globals['_TRIGGERASYNCPIPELINEREQUEST']._serialized_start=4121 - _globals['_TRIGGERASYNCPIPELINEREQUEST']._serialized_end=4261 - _globals['_TRIGGERASYNCPIPELINERESPONSE']._serialized_start=4263 - _globals['_TRIGGERASYNCPIPELINERESPONSE']._serialized_end=4360 - _globals['_GETOPERATIONREQUEST']._serialized_start=4362 - _globals['_GETOPERATIONREQUEST']._serialized_end=4409 - _globals['_GETOPERATIONRESPONSE']._serialized_start=4411 - _globals['_GETOPERATIONRESPONSE']._serialized_end=4500 - _globals['_WATCHPIPELINEREQUEST']._serialized_start=4502 - _globals['_WATCHPIPELINEREQUEST']._serialized_end=4608 - _globals['_WATCHPIPELINERESPONSE']._serialized_start=4610 - _globals['_WATCHPIPELINERESPONSE']._serialized_end=4693 - _globals['_LISTPIPELINESADMINREQUEST']._serialized_start=4696 - _globals['_LISTPIPELINESADMINREQUEST']._serialized_end=4948 - _globals['_LISTPIPELINESADMINRESPONSE']._serialized_start=4951 - _globals['_LISTPIPELINESADMINRESPONSE']._serialized_end=5112 - _globals['_GETPIPELINEADMINREQUEST']._serialized_start=5115 - _globals['_GETPIPELINEADMINREQUEST']._serialized_end=5286 - _globals['_GETPIPELINEADMINRESPONSE']._serialized_start=5288 - _globals['_GETPIPELINEADMINRESPONSE']._serialized_end=5374 - _globals['_LOOKUPPIPELINEADMINREQUEST']._serialized_start=5377 - _globals['_LOOKUPPIPELINEADMINREQUEST']._serialized_end=5509 - _globals['_LOOKUPPIPELINEADMINRESPONSE']._serialized_start=5511 - _globals['_LOOKUPPIPELINEADMINRESPONSE']._serialized_end=5600 + _globals['_COMPONENT']._serialized_end=1270 + _globals['_RECIPE']._serialized_start=1272 + _globals['_RECIPE']._serialized_end=1371 + _globals['_PIPELINE']._serialized_start=1374 + _globals['_PIPELINE']._serialized_end=2041 + _globals['_PIPELINE_STATE']._serialized_start=1877 + _globals['_PIPELINE_STATE']._serialized_end=1962 + _globals['_CREATEPIPELINEREQUEST']._serialized_start=2043 + _globals['_CREATEPIPELINEREQUEST']._serialized_end=2132 + _globals['_CREATEPIPELINERESPONSE']._serialized_start=2134 + _globals['_CREATEPIPELINERESPONSE']._serialized_end=2218 + _globals['_LISTPIPELINESREQUEST']._serialized_start=2221 + _globals['_LISTPIPELINESREQUEST']._serialized_end=2468 + _globals['_LISTPIPELINESRESPONSE']._serialized_start=2471 + _globals['_LISTPIPELINESRESPONSE']._serialized_end=2627 + _globals['_GETPIPELINEREQUEST']._serialized_start=2630 + _globals['_GETPIPELINEREQUEST']._serialized_end=2796 + _globals['_GETPIPELINERESPONSE']._serialized_start=2798 + _globals['_GETPIPELINERESPONSE']._serialized_end=2879 + _globals['_UPDATEPIPELINEREQUEST']._serialized_start=2882 + _globals['_UPDATEPIPELINEREQUEST']._serialized_end=3038 + _globals['_UPDATEPIPELINERESPONSE']._serialized_start=3040 + _globals['_UPDATEPIPELINERESPONSE']._serialized_end=3124 + _globals['_DELETEPIPELINEREQUEST']._serialized_start=3126 + _globals['_DELETEPIPELINEREQUEST']._serialized_end=3227 + _globals['_DELETEPIPELINERESPONSE']._serialized_start=3229 + _globals['_DELETEPIPELINERESPONSE']._serialized_end=3253 + _globals['_LOOKUPPIPELINEREQUEST']._serialized_start=3255 + _globals['_LOOKUPPIPELINEREQUEST']._serialized_end=3382 + _globals['_LOOKUPPIPELINERESPONSE']._serialized_start=3384 + _globals['_LOOKUPPIPELINERESPONSE']._serialized_end=3468 + _globals['_ACTIVATEPIPELINEREQUEST']._serialized_start=3470 + _globals['_ACTIVATEPIPELINEREQUEST']._serialized_end=3551 + _globals['_ACTIVATEPIPELINERESPONSE']._serialized_start=3553 + _globals['_ACTIVATEPIPELINERESPONSE']._serialized_end=3639 + _globals['_DEACTIVATEPIPELINEREQUEST']._serialized_start=3641 + _globals['_DEACTIVATEPIPELINEREQUEST']._serialized_end=3724 + _globals['_DEACTIVATEPIPELINERESPONSE']._serialized_start=3726 + _globals['_DEACTIVATEPIPELINERESPONSE']._serialized_end=3814 + _globals['_RENAMEPIPELINEREQUEST']._serialized_start=3816 + _globals['_RENAMEPIPELINEREQUEST']._serialized_end=3941 + _globals['_RENAMEPIPELINERESPONSE']._serialized_start=3943 + _globals['_RENAMEPIPELINERESPONSE']._serialized_end=4027 + _globals['_TRIGGERPIPELINEREQUEST']._serialized_start=4030 + _globals['_TRIGGERPIPELINEREQUEST']._serialized_end=4165 + _globals['_TRIGGERPIPELINERESPONSE']._serialized_start=4167 + _globals['_TRIGGERPIPELINERESPONSE']._serialized_end=4243 + _globals['_TRIGGERASYNCPIPELINEREQUEST']._serialized_start=4246 + _globals['_TRIGGERASYNCPIPELINEREQUEST']._serialized_end=4386 + _globals['_TRIGGERASYNCPIPELINERESPONSE']._serialized_start=4388 + _globals['_TRIGGERASYNCPIPELINERESPONSE']._serialized_end=4485 + _globals['_GETOPERATIONREQUEST']._serialized_start=4487 + _globals['_GETOPERATIONREQUEST']._serialized_end=4534 + _globals['_GETOPERATIONRESPONSE']._serialized_start=4536 + _globals['_GETOPERATIONRESPONSE']._serialized_end=4625 + _globals['_WATCHPIPELINEREQUEST']._serialized_start=4627 + _globals['_WATCHPIPELINEREQUEST']._serialized_end=4733 + _globals['_WATCHPIPELINERESPONSE']._serialized_start=4735 + _globals['_WATCHPIPELINERESPONSE']._serialized_end=4818 + _globals['_LISTPIPELINESADMINREQUEST']._serialized_start=4821 + _globals['_LISTPIPELINESADMINREQUEST']._serialized_end=5073 + _globals['_LISTPIPELINESADMINRESPONSE']._serialized_start=5076 + _globals['_LISTPIPELINESADMINRESPONSE']._serialized_end=5237 + _globals['_GETPIPELINEADMINREQUEST']._serialized_start=5240 + _globals['_GETPIPELINEADMINREQUEST']._serialized_end=5411 + _globals['_GETPIPELINEADMINRESPONSE']._serialized_start=5413 + _globals['_GETPIPELINEADMINRESPONSE']._serialized_end=5499 + _globals['_LOOKUPPIPELINEADMINREQUEST']._serialized_start=5502 + _globals['_LOOKUPPIPELINEADMINREQUEST']._serialized_end=5634 + _globals['_LOOKUPPIPELINEADMINRESPONSE']._serialized_start=5636 + _globals['_LOOKUPPIPELINEADMINRESPONSE']._serialized_end=5725 # @@protoc_insertion_point(module_scope) diff --git a/vdp/pipeline/v1alpha/pipeline_private_service_pb2.py b/vdp/pipeline/v1alpha/pipeline_private_service_pb2.py index 5237d3b..2278335 100644 --- a/vdp/pipeline/v1alpha/pipeline_private_service_pb2.py +++ b/vdp/pipeline/v1alpha/pipeline_private_service_pb2.py @@ -13,10 +13,11 @@ 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 vdp.pipeline.v1alpha import operator_definition_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2 from vdp.pipeline.v1alpha import pipeline_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n3vdp/pipeline/v1alpha/pipeline_private_service.proto\x12\x14vdp.pipeline.v1alpha\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a#vdp/pipeline/v1alpha/pipeline.proto2\xf4\x02\n\x16PipelinePrivateService\x12\x99\x01\n\x12ListPipelinesAdmin\x12/.vdp.pipeline.v1alpha.ListPipelinesAdminRequest\x1a\x30.vdp.pipeline.v1alpha.ListPipelinesAdminResponse\" \x82\xd3\xe4\x93\x02\x1a\x12\x18/v1alpha/admin/pipelines\x12\xbd\x01\n\x13LookUpPipelineAdmin\x12\x30.vdp.pipeline.v1alpha.LookUpPipelineAdminRequest\x1a\x31.vdp.pipeline.v1alpha.LookUpPipelineAdminResponse\"A\xda\x41\tpermalink\x82\xd3\xe4\x93\x02/\x12-/v1alpha/admin/{permalink=pipelines/*}/lookUpB\xf1\x01\n\x18\x63om.vdp.pipeline.v1alphaB\x1bPipelinePrivateServiceProtoP\x01ZFgithub.com/instill-ai/protogen-go/vdp/pipeline/v1alpha;pipelinev1alpha\xa2\x02\x03VPX\xaa\x02\x14Vdp.Pipeline.V1alpha\xca\x02\x14Vdp\\Pipeline\\V1alpha\xe2\x02 Vdp\\Pipeline\\V1alpha\\GPBMetadata\xea\x02\x16Vdp::Pipeline::V1alphab\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n3vdp/pipeline/v1alpha/pipeline_private_service.proto\x12\x14vdp.pipeline.v1alpha\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a.vdp/pipeline/v1alpha/operator_definition.proto\x1a#vdp/pipeline/v1alpha/pipeline.proto2\xdd\x04\n\x16PipelinePrivateService\x12\x99\x01\n\x12ListPipelinesAdmin\x12/.vdp.pipeline.v1alpha.ListPipelinesAdminRequest\x1a\x30.vdp.pipeline.v1alpha.ListPipelinesAdminResponse\" \x82\xd3\xe4\x93\x02\x1a\x12\x18/v1alpha/admin/pipelines\x12\xbd\x01\n\x13LookUpPipelineAdmin\x12\x30.vdp.pipeline.v1alpha.LookUpPipelineAdminRequest\x1a\x31.vdp.pipeline.v1alpha.LookUpPipelineAdminResponse\"A\xda\x41\tpermalink\x82\xd3\xe4\x93\x02/\x12-/v1alpha/admin/{permalink=pipelines/*}/lookUp\x12\xe6\x01\n\x1dLookUpOperatorDefinitionAdmin\x12:.vdp.pipeline.v1alpha.LookUpOperatorDefinitionAdminRequest\x1a;.vdp.pipeline.v1alpha.LookUpOperatorDefinitionAdminResponse\"L\xda\x41\tpermalink\x82\xd3\xe4\x93\x02:\x12\x38/v1alpha/admin/{permalink=operator-definitions/*}/lookUpB\xf1\x01\n\x18\x63om.vdp.pipeline.v1alphaB\x1bPipelinePrivateServiceProtoP\x01ZFgithub.com/instill-ai/protogen-go/vdp/pipeline/v1alpha;pipelinev1alpha\xa2\x02\x03VPX\xaa\x02\x14Vdp.Pipeline.V1alpha\xca\x02\x14Vdp\\Pipeline\\V1alpha\xe2\x02 Vdp\\Pipeline\\V1alpha\\GPBMetadata\xea\x02\x16Vdp::Pipeline::V1alphab\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -29,6 +30,8 @@ _PIPELINEPRIVATESERVICE.methods_by_name['ListPipelinesAdmin']._serialized_options = b'\202\323\344\223\002\032\022\030/v1alpha/admin/pipelines' _PIPELINEPRIVATESERVICE.methods_by_name['LookUpPipelineAdmin']._options = None _PIPELINEPRIVATESERVICE.methods_by_name['LookUpPipelineAdmin']._serialized_options = b'\332A\tpermalink\202\323\344\223\002/\022-/v1alpha/admin/{permalink=pipelines/*}/lookUp' - _globals['_PIPELINEPRIVATESERVICE']._serialized_start=170 - _globals['_PIPELINEPRIVATESERVICE']._serialized_end=542 + _PIPELINEPRIVATESERVICE.methods_by_name['LookUpOperatorDefinitionAdmin']._options = None + _PIPELINEPRIVATESERVICE.methods_by_name['LookUpOperatorDefinitionAdmin']._serialized_options = b'\332A\tpermalink\202\323\344\223\002:\0228/v1alpha/admin/{permalink=operator-definitions/*}/lookUp' + _globals['_PIPELINEPRIVATESERVICE']._serialized_start=218 + _globals['_PIPELINEPRIVATESERVICE']._serialized_end=823 # @@protoc_insertion_point(module_scope) diff --git a/vdp/pipeline/v1alpha/pipeline_private_service_pb2_grpc.py b/vdp/pipeline/v1alpha/pipeline_private_service_pb2_grpc.py index 76f93b5..9d38633 100644 --- a/vdp/pipeline/v1alpha/pipeline_private_service_pb2_grpc.py +++ b/vdp/pipeline/v1alpha/pipeline_private_service_pb2_grpc.py @@ -2,6 +2,7 @@ """Client and server classes corresponding to protobuf-defined services.""" import grpc +from vdp.pipeline.v1alpha import operator_definition_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2 from vdp.pipeline.v1alpha import pipeline_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2 @@ -25,6 +26,11 @@ def __init__(self, channel): request_serializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.LookUpPipelineAdminRequest.SerializeToString, response_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.LookUpPipelineAdminResponse.FromString, ) + self.LookUpOperatorDefinitionAdmin = channel.unary_unary( + '/vdp.pipeline.v1alpha.PipelinePrivateService/LookUpOperatorDefinitionAdmin', + request_serializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.LookUpOperatorDefinitionAdminRequest.SerializeToString, + response_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.LookUpOperatorDefinitionAdminResponse.FromString, + ) class PipelinePrivateServiceServicer(object): @@ -47,6 +53,15 @@ def LookUpPipelineAdmin(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + def LookUpOperatorDefinitionAdmin(self, request, context): + """LookUpOperatorDefinitionAdmin method receives a + LookUpOperatorDefinitionAdminRequest message and returns a + LookUpOperatorDefinitionAdminResponse + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + def add_PipelinePrivateServiceServicer_to_server(servicer, server): rpc_method_handlers = { @@ -60,6 +75,11 @@ def add_PipelinePrivateServiceServicer_to_server(servicer, server): request_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.LookUpPipelineAdminRequest.FromString, response_serializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.LookUpPipelineAdminResponse.SerializeToString, ), + 'LookUpOperatorDefinitionAdmin': grpc.unary_unary_rpc_method_handler( + servicer.LookUpOperatorDefinitionAdmin, + request_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.LookUpOperatorDefinitionAdminRequest.FromString, + response_serializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.LookUpOperatorDefinitionAdminResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( 'vdp.pipeline.v1alpha.PipelinePrivateService', rpc_method_handlers) @@ -104,3 +124,20 @@ def LookUpPipelineAdmin(request, vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.LookUpPipelineAdminResponse.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def LookUpOperatorDefinitionAdmin(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.pipeline.v1alpha.PipelinePrivateService/LookUpOperatorDefinitionAdmin', + vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.LookUpOperatorDefinitionAdminRequest.SerializeToString, + vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.LookUpOperatorDefinitionAdminResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) diff --git a/vdp/pipeline/v1alpha/pipeline_public_service_pb2.py b/vdp/pipeline/v1alpha/pipeline_public_service_pb2.py index 85a8f3b..5b6f4af 100644 --- a/vdp/pipeline/v1alpha/pipeline_public_service_pb2.py +++ b/vdp/pipeline/v1alpha/pipeline_public_service_pb2.py @@ -13,10 +13,11 @@ 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 vdp.pipeline.v1alpha import operator_definition_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2 from vdp.pipeline.v1alpha import pipeline_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n2vdp/pipeline/v1alpha/pipeline_public_service.proto\x12\x14vdp.pipeline.v1alpha\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a#vdp/pipeline/v1alpha/pipeline.proto2\xae\x13\n\x15PipelinePublicService\x12\x92\x01\n\x08Liveness\x12%.vdp.pipeline.v1alpha.LivenessRequest\x1a&.vdp.pipeline.v1alpha.LivenessResponse\"7\x82\xd3\xe4\x93\x02\x31\x12\x13/v1alpha/__livenessZ\x1a\x12\x18/v1alpha/health/pipeline\x12z\n\tReadiness\x12&.vdp.pipeline.v1alpha.ReadinessRequest\x1a\'.vdp.pipeline.v1alpha.ReadinessResponse\"\x1c\x82\xd3\xe4\x93\x02\x16\x12\x14/v1alpha/__readiness\x12\x9c\x01\n\x0e\x43reatePipeline\x12+.vdp.pipeline.v1alpha.CreatePipelineRequest\x1a,.vdp.pipeline.v1alpha.CreatePipelineResponse\"/\xda\x41\x08pipeline\x82\xd3\xe4\x93\x02\x1e\"\x12/v1alpha/pipelines:\x08pipeline\x12\x84\x01\n\rListPipelines\x12*.vdp.pipeline.v1alpha.ListPipelinesRequest\x1a+.vdp.pipeline.v1alpha.ListPipelinesResponse\"\x1a\x82\xd3\xe4\x93\x02\x14\x12\x12/v1alpha/pipelines\x12\x8e\x01\n\x0bGetPipeline\x12(.vdp.pipeline.v1alpha.GetPipelineRequest\x1a).vdp.pipeline.v1alpha.GetPipelineResponse\"*\xda\x41\x04name\x82\xd3\xe4\x93\x02\x1d\x12\x1b/v1alpha/{name=pipelines/*}\x12\xba\x01\n\x0eUpdatePipeline\x12+.vdp.pipeline.v1alpha.UpdatePipelineRequest\x1a,.vdp.pipeline.v1alpha.UpdatePipelineResponse\"M\xda\x41\x14pipeline,update_mask\x82\xd3\xe4\x93\x02\x30\x32$/v1alpha/{pipeline.name=pipelines/*}:\x08pipeline\x12\x97\x01\n\x0e\x44\x65letePipeline\x12+.vdp.pipeline.v1alpha.DeletePipelineRequest\x1a,.vdp.pipeline.v1alpha.DeletePipelineResponse\"*\xda\x41\x04name\x82\xd3\xe4\x93\x02\x1d*\x1b/v1alpha/{name=pipelines/*}\x12\xa8\x01\n\x0eLookUpPipeline\x12+.vdp.pipeline.v1alpha.LookUpPipelineRequest\x1a,.vdp.pipeline.v1alpha.LookUpPipelineResponse\";\xda\x41\tpermalink\x82\xd3\xe4\x93\x02)\x12\'/v1alpha/{permalink=pipelines/*}/lookUp\x12\xa9\x01\n\x10\x41\x63tivatePipeline\x12-.vdp.pipeline.v1alpha.ActivatePipelineRequest\x1a..vdp.pipeline.v1alpha.ActivatePipelineResponse\"6\xda\x41\x04name\x82\xd3\xe4\x93\x02)\"$/v1alpha/{name=pipelines/*}/activate:\x01*\x12\xb1\x01\n\x12\x44\x65\x61\x63tivatePipeline\x12/.vdp.pipeline.v1alpha.DeactivatePipelineRequest\x1a\x30.vdp.pipeline.v1alpha.DeactivatePipelineResponse\"8\xda\x41\x04name\x82\xd3\xe4\x93\x02+\"&/v1alpha/{name=pipelines/*}/deactivate:\x01*\x12\xb1\x01\n\x0eRenamePipeline\x12+.vdp.pipeline.v1alpha.RenamePipelineRequest\x1a,.vdp.pipeline.v1alpha.RenamePipelineResponse\"D\xda\x41\x14name,new_pipeline_id\x82\xd3\xe4\x93\x02\'\"\"/v1alpha/{name=pipelines/*}/rename:\x01*\x12\xac\x01\n\x0fTriggerPipeline\x12,.vdp.pipeline.v1alpha.TriggerPipelineRequest\x1a-.vdp.pipeline.v1alpha.TriggerPipelineResponse\"<\xda\x41\x0bname,inputs\x82\xd3\xe4\x93\x02(\"#/v1alpha/{name=pipelines/*}/trigger:\x01*\x12\xc0\x01\n\x14TriggerAsyncPipeline\x12\x31.vdp.pipeline.v1alpha.TriggerAsyncPipelineRequest\x1a\x32.vdp.pipeline.v1alpha.TriggerAsyncPipelineResponse\"A\xda\x41\x0bname,inputs\x82\xd3\xe4\x93\x02-\"(/v1alpha/{name=pipelines/*}/triggerAsync:\x01*\x12\x9a\x01\n\rWatchPipeline\x12*.vdp.pipeline.v1alpha.WatchPipelineRequest\x1a+.vdp.pipeline.v1alpha.WatchPipelineResponse\"0\xda\x41\x04name\x82\xd3\xe4\x93\x02#\x12!/v1alpha/{name=pipelines/*}/watch\x12\x92\x01\n\x0cGetOperation\x12).vdp.pipeline.v1alpha.GetOperationRequest\x1a*.vdp.pipeline.v1alpha.GetOperationResponse\"+\xda\x41\x04name\x82\xd3\xe4\x93\x02\x1e\x12\x1c/v1alpha/{name=operations/*}\x1a\x13\xca\x41\x10\x61pi.instill.techB\xf0\x01\n\x18\x63om.vdp.pipeline.v1alphaB\x1aPipelinePublicServiceProtoP\x01ZFgithub.com/instill-ai/protogen-go/vdp/pipeline/v1alpha;pipelinev1alpha\xa2\x02\x03VPX\xaa\x02\x14Vdp.Pipeline.V1alpha\xca\x02\x14Vdp\\Pipeline\\V1alpha\xe2\x02 Vdp\\Pipeline\\V1alpha\\GPBMetadata\xea\x02\x16Vdp::Pipeline::V1alphab\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n2vdp/pipeline/v1alpha/pipeline_public_service.proto\x12\x14vdp.pipeline.v1alpha\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a.vdp/pipeline/v1alpha/operator_definition.proto\x1a#vdp/pipeline/v1alpha/pipeline.proto2\x98\x16\n\x15PipelinePublicService\x12\x92\x01\n\x08Liveness\x12%.vdp.pipeline.v1alpha.LivenessRequest\x1a&.vdp.pipeline.v1alpha.LivenessResponse\"7\x82\xd3\xe4\x93\x02\x31\x12\x13/v1alpha/__livenessZ\x1a\x12\x18/v1alpha/health/pipeline\x12z\n\tReadiness\x12&.vdp.pipeline.v1alpha.ReadinessRequest\x1a\'.vdp.pipeline.v1alpha.ReadinessResponse\"\x1c\x82\xd3\xe4\x93\x02\x16\x12\x14/v1alpha/__readiness\x12\xad\x01\n\x17ListOperatorDefinitions\x12\x34.vdp.pipeline.v1alpha.ListOperatorDefinitionsRequest\x1a\x35.vdp.pipeline.v1alpha.ListOperatorDefinitionsResponse\"%\x82\xd3\xe4\x93\x02\x1f\x12\x1d/v1alpha/operator-definitions\x12\xb7\x01\n\x15GetOperatorDefinition\x12\x32.vdp.pipeline.v1alpha.GetOperatorDefinitionRequest\x1a\x33.vdp.pipeline.v1alpha.GetOperatorDefinitionResponse\"5\xda\x41\x04name\x82\xd3\xe4\x93\x02(\x12&/v1alpha/{name=operator-definitions/*}\x12\x9c\x01\n\x0e\x43reatePipeline\x12+.vdp.pipeline.v1alpha.CreatePipelineRequest\x1a,.vdp.pipeline.v1alpha.CreatePipelineResponse\"/\xda\x41\x08pipeline\x82\xd3\xe4\x93\x02\x1e\"\x12/v1alpha/pipelines:\x08pipeline\x12\x84\x01\n\rListPipelines\x12*.vdp.pipeline.v1alpha.ListPipelinesRequest\x1a+.vdp.pipeline.v1alpha.ListPipelinesResponse\"\x1a\x82\xd3\xe4\x93\x02\x14\x12\x12/v1alpha/pipelines\x12\x8e\x01\n\x0bGetPipeline\x12(.vdp.pipeline.v1alpha.GetPipelineRequest\x1a).vdp.pipeline.v1alpha.GetPipelineResponse\"*\xda\x41\x04name\x82\xd3\xe4\x93\x02\x1d\x12\x1b/v1alpha/{name=pipelines/*}\x12\xba\x01\n\x0eUpdatePipeline\x12+.vdp.pipeline.v1alpha.UpdatePipelineRequest\x1a,.vdp.pipeline.v1alpha.UpdatePipelineResponse\"M\xda\x41\x14pipeline,update_mask\x82\xd3\xe4\x93\x02\x30\x32$/v1alpha/{pipeline.name=pipelines/*}:\x08pipeline\x12\x97\x01\n\x0e\x44\x65letePipeline\x12+.vdp.pipeline.v1alpha.DeletePipelineRequest\x1a,.vdp.pipeline.v1alpha.DeletePipelineResponse\"*\xda\x41\x04name\x82\xd3\xe4\x93\x02\x1d*\x1b/v1alpha/{name=pipelines/*}\x12\xa8\x01\n\x0eLookUpPipeline\x12+.vdp.pipeline.v1alpha.LookUpPipelineRequest\x1a,.vdp.pipeline.v1alpha.LookUpPipelineResponse\";\xda\x41\tpermalink\x82\xd3\xe4\x93\x02)\x12\'/v1alpha/{permalink=pipelines/*}/lookUp\x12\xa9\x01\n\x10\x41\x63tivatePipeline\x12-.vdp.pipeline.v1alpha.ActivatePipelineRequest\x1a..vdp.pipeline.v1alpha.ActivatePipelineResponse\"6\xda\x41\x04name\x82\xd3\xe4\x93\x02)\"$/v1alpha/{name=pipelines/*}/activate:\x01*\x12\xb1\x01\n\x12\x44\x65\x61\x63tivatePipeline\x12/.vdp.pipeline.v1alpha.DeactivatePipelineRequest\x1a\x30.vdp.pipeline.v1alpha.DeactivatePipelineResponse\"8\xda\x41\x04name\x82\xd3\xe4\x93\x02+\"&/v1alpha/{name=pipelines/*}/deactivate:\x01*\x12\xb1\x01\n\x0eRenamePipeline\x12+.vdp.pipeline.v1alpha.RenamePipelineRequest\x1a,.vdp.pipeline.v1alpha.RenamePipelineResponse\"D\xda\x41\x14name,new_pipeline_id\x82\xd3\xe4\x93\x02\'\"\"/v1alpha/{name=pipelines/*}/rename:\x01*\x12\xac\x01\n\x0fTriggerPipeline\x12,.vdp.pipeline.v1alpha.TriggerPipelineRequest\x1a-.vdp.pipeline.v1alpha.TriggerPipelineResponse\"<\xda\x41\x0bname,inputs\x82\xd3\xe4\x93\x02(\"#/v1alpha/{name=pipelines/*}/trigger:\x01*\x12\xc0\x01\n\x14TriggerAsyncPipeline\x12\x31.vdp.pipeline.v1alpha.TriggerAsyncPipelineRequest\x1a\x32.vdp.pipeline.v1alpha.TriggerAsyncPipelineResponse\"A\xda\x41\x0bname,inputs\x82\xd3\xe4\x93\x02-\"(/v1alpha/{name=pipelines/*}/triggerAsync:\x01*\x12\x9a\x01\n\rWatchPipeline\x12*.vdp.pipeline.v1alpha.WatchPipelineRequest\x1a+.vdp.pipeline.v1alpha.WatchPipelineResponse\"0\xda\x41\x04name\x82\xd3\xe4\x93\x02#\x12!/v1alpha/{name=pipelines/*}/watch\x12\x92\x01\n\x0cGetOperation\x12).vdp.pipeline.v1alpha.GetOperationRequest\x1a*.vdp.pipeline.v1alpha.GetOperationResponse\"+\xda\x41\x04name\x82\xd3\xe4\x93\x02\x1e\x12\x1c/v1alpha/{name=operations/*}\x1a\x13\xca\x41\x10\x61pi.instill.techB\xf0\x01\n\x18\x63om.vdp.pipeline.v1alphaB\x1aPipelinePublicServiceProtoP\x01ZFgithub.com/instill-ai/protogen-go/vdp/pipeline/v1alpha;pipelinev1alpha\xa2\x02\x03VPX\xaa\x02\x14Vdp.Pipeline.V1alpha\xca\x02\x14Vdp\\Pipeline\\V1alpha\xe2\x02 Vdp\\Pipeline\\V1alpha\\GPBMetadata\xea\x02\x16Vdp::Pipeline::V1alphab\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) @@ -31,6 +32,10 @@ _PIPELINEPUBLICSERVICE.methods_by_name['Liveness']._serialized_options = b'\202\323\344\223\0021\022\023/v1alpha/__livenessZ\032\022\030/v1alpha/health/pipeline' _PIPELINEPUBLICSERVICE.methods_by_name['Readiness']._options = None _PIPELINEPUBLICSERVICE.methods_by_name['Readiness']._serialized_options = b'\202\323\344\223\002\026\022\024/v1alpha/__readiness' + _PIPELINEPUBLICSERVICE.methods_by_name['ListOperatorDefinitions']._options = None + _PIPELINEPUBLICSERVICE.methods_by_name['ListOperatorDefinitions']._serialized_options = b'\202\323\344\223\002\037\022\035/v1alpha/operator-definitions' + _PIPELINEPUBLICSERVICE.methods_by_name['GetOperatorDefinition']._options = None + _PIPELINEPUBLICSERVICE.methods_by_name['GetOperatorDefinition']._serialized_options = b'\332A\004name\202\323\344\223\002(\022&/v1alpha/{name=operator-definitions/*}' _PIPELINEPUBLICSERVICE.methods_by_name['CreatePipeline']._options = None _PIPELINEPUBLICSERVICE.methods_by_name['CreatePipeline']._serialized_options = b'\332A\010pipeline\202\323\344\223\002\036\"\022/v1alpha/pipelines:\010pipeline' _PIPELINEPUBLICSERVICE.methods_by_name['ListPipelines']._options = None @@ -57,6 +62,6 @@ _PIPELINEPUBLICSERVICE.methods_by_name['WatchPipeline']._serialized_options = b'\332A\004name\202\323\344\223\002#\022!/v1alpha/{name=pipelines/*}/watch' _PIPELINEPUBLICSERVICE.methods_by_name['GetOperation']._options = None _PIPELINEPUBLICSERVICE.methods_by_name['GetOperation']._serialized_options = b'\332A\004name\202\323\344\223\002\036\022\034/v1alpha/{name=operations/*}' - _globals['_PIPELINEPUBLICSERVICE']._serialized_start=169 - _globals['_PIPELINEPUBLICSERVICE']._serialized_end=2647 + _globals['_PIPELINEPUBLICSERVICE']._serialized_start=217 + _globals['_PIPELINEPUBLICSERVICE']._serialized_end=3057 # @@protoc_insertion_point(module_scope) diff --git a/vdp/pipeline/v1alpha/pipeline_public_service_pb2_grpc.py b/vdp/pipeline/v1alpha/pipeline_public_service_pb2_grpc.py index 66fab8b..b83b30e 100644 --- a/vdp/pipeline/v1alpha/pipeline_public_service_pb2_grpc.py +++ b/vdp/pipeline/v1alpha/pipeline_public_service_pb2_grpc.py @@ -2,6 +2,7 @@ """Client and server classes corresponding to protobuf-defined services.""" import grpc +from vdp.pipeline.v1alpha import operator_definition_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2 from vdp.pipeline.v1alpha import pipeline_pb2 as vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2 @@ -25,6 +26,16 @@ def __init__(self, channel): request_serializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.ReadinessRequest.SerializeToString, response_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.ReadinessResponse.FromString, ) + self.ListOperatorDefinitions = channel.unary_unary( + '/vdp.pipeline.v1alpha.PipelinePublicService/ListOperatorDefinitions', + request_serializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.ListOperatorDefinitionsRequest.SerializeToString, + response_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.ListOperatorDefinitionsResponse.FromString, + ) + self.GetOperatorDefinition = channel.unary_unary( + '/vdp.pipeline.v1alpha.PipelinePublicService/GetOperatorDefinition', + request_serializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.GetOperatorDefinitionRequest.SerializeToString, + response_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.GetOperatorDefinitionResponse.FromString, + ) self.CreatePipeline = channel.unary_unary( '/vdp.pipeline.v1alpha.PipelinePublicService/CreatePipeline', request_serializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.CreatePipelineRequest.SerializeToString, @@ -114,6 +125,24 @@ def Readiness(self, request, context): context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!') + def ListOperatorDefinitions(self, request, context): + """ListOperatorDefinitions method receives a + ListOperatorDefinitionsRequest message and returns a + ListOperatorDefinitionsResponse message. + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + + def GetOperatorDefinition(self, request, context): + """GetOperatorDefinition method receives a + GetOperatorDefinitionRequest message and returns a + GetGetOperatorDefinitionResponse message. + """ + context.set_code(grpc.StatusCode.UNIMPLEMENTED) + context.set_details('Method not implemented!') + raise NotImplementedError('Method not implemented!') + def CreatePipeline(self, request, context): """CreatePipeline method receives a CreatePipelineRequest message and returns a CreatePipelineResponse message. @@ -238,6 +267,16 @@ def add_PipelinePublicServiceServicer_to_server(servicer, server): request_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.ReadinessRequest.FromString, response_serializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.ReadinessResponse.SerializeToString, ), + 'ListOperatorDefinitions': grpc.unary_unary_rpc_method_handler( + servicer.ListOperatorDefinitions, + request_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.ListOperatorDefinitionsRequest.FromString, + response_serializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.ListOperatorDefinitionsResponse.SerializeToString, + ), + 'GetOperatorDefinition': grpc.unary_unary_rpc_method_handler( + servicer.GetOperatorDefinition, + request_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.GetOperatorDefinitionRequest.FromString, + response_serializer=vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.GetOperatorDefinitionResponse.SerializeToString, + ), 'CreatePipeline': grpc.unary_unary_rpc_method_handler( servicer.CreatePipeline, request_deserializer=vdp_dot_pipeline_dot_v1alpha_dot_pipeline__pb2.CreatePipelineRequest.FromString, @@ -348,6 +387,40 @@ def Readiness(request, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + @staticmethod + def ListOperatorDefinitions(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.pipeline.v1alpha.PipelinePublicService/ListOperatorDefinitions', + vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.ListOperatorDefinitionsRequest.SerializeToString, + vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.ListOperatorDefinitionsResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + + @staticmethod + def GetOperatorDefinition(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.pipeline.v1alpha.PipelinePublicService/GetOperatorDefinition', + vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.GetOperatorDefinitionRequest.SerializeToString, + vdp_dot_pipeline_dot_v1alpha_dot_operator__definition__pb2.GetOperatorDefinitionResponse.FromString, + options, channel_credentials, + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + @staticmethod def CreatePipeline(request, target,