Skip to content

Commit

Permalink
chore: auto-gen by protobufs
Browse files Browse the repository at this point in the history
triggered by commit: instill-ai/protobufs@d74fca2
  • Loading branch information
droplet-bot committed Oct 24, 2024
1 parent bf270fd commit a183834
Show file tree
Hide file tree
Showing 5 changed files with 185 additions and 90 deletions.
171 changes: 88 additions & 83 deletions artifact/artifact/v1alpha/artifact_pb2.py

Large diffs are not rendered by default.

41 changes: 40 additions & 1 deletion artifact/artifact/v1alpha/artifact_pb2.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@
@generated by mypy-protobuf. Do not edit manually!
isort:skip_file
"""
import artifact.artifact.v1alpha.object_pb2
import builtins
import collections.abc
import common.healthcheck.v1beta.healthcheck_pb2
Expand Down Expand Up @@ -585,6 +586,44 @@ class ObjectURL(google.protobuf.message.Message):

global___ObjectURL = ObjectURL

@typing_extensions.final
class GetObjectRequest(google.protobuf.message.Message):
"""GetObjectRequest"""

DESCRIPTOR: google.protobuf.descriptor.Descriptor

UID_FIELD_NUMBER: builtins.int
uid: builtins.str
"""object uid"""
def __init__(
self,
*,
uid: builtins.str = ...,
) -> None: ...
def ClearField(self, field_name: typing_extensions.Literal["uid", b"uid"]) -> None: ...

global___GetObjectRequest = GetObjectRequest

@typing_extensions.final
class GetObjectResponse(google.protobuf.message.Message):
"""GetObjectResponse"""

DESCRIPTOR: google.protobuf.descriptor.Descriptor

OBJECT_FIELD_NUMBER: builtins.int
@property
def object(self) -> artifact.artifact.v1alpha.object_pb2.Object:
"""object"""
def __init__(
self,
*,
object: artifact.artifact.v1alpha.object_pb2.Object | None = ...,
) -> None: ...
def HasField(self, field_name: typing_extensions.Literal["object", b"object"]) -> builtins.bool: ...
def ClearField(self, field_name: typing_extensions.Literal["object", b"object"]) -> None: ...

global___GetObjectResponse = GetObjectResponse

@typing_extensions.final
class GetObjectURLRequest(google.protobuf.message.Message):
"""GetObjectURLRequest"""
Expand Down Expand Up @@ -612,7 +651,7 @@ class GetObjectURLResponse(google.protobuf.message.Message):
OBJECT_URL_FIELD_NUMBER: builtins.int
@property
def object_url(self) -> global___ObjectURL:
"""object upload url"""
"""object url"""
def __init__(
self,
*,
Expand Down
4 changes: 2 additions & 2 deletions artifact/artifact/v1alpha/artifact_private_service_pb2.py

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

36 changes: 35 additions & 1 deletion artifact/artifact/v1alpha/artifact_private_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,11 @@ def __init__(self, channel):
request_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.DeleteRepositoryTagRequest.SerializeToString,
response_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.DeleteRepositoryTagResponse.FromString,
)
self.GetObject = channel.unary_unary(
'/artifact.artifact.v1alpha.ArtifactPrivateService/GetObject',
request_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectRequest.SerializeToString,
response_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectResponse.FromString,
)
self.GetObjectURL = channel.unary_unary(
'/artifact.artifact.v1alpha.ArtifactPrivateService/GetObjectURL',
request_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectURLRequest.SerializeToString,
Expand Down Expand Up @@ -85,8 +90,15 @@ def DeleteRepositoryTag(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def GetObject(self, request, context):
"""Get Object
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def GetObjectURL(self, request, context):
"""Get Object Upload URL
"""Get Object URL
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
Expand Down Expand Up @@ -115,6 +127,11 @@ def add_ArtifactPrivateServiceServicer_to_server(servicer, server):
request_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.DeleteRepositoryTagRequest.FromString,
response_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.DeleteRepositoryTagResponse.SerializeToString,
),
'GetObject': grpc.unary_unary_rpc_method_handler(
servicer.GetObject,
request_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectRequest.FromString,
response_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectResponse.SerializeToString,
),
'GetObjectURL': grpc.unary_unary_rpc_method_handler(
servicer.GetObjectURL,
request_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectURLRequest.FromString,
Expand Down Expand Up @@ -200,6 +217,23 @@ def DeleteRepositoryTag(request,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def GetObject(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, '/artifact.artifact.v1alpha.ArtifactPrivateService/GetObject',
artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectRequest.SerializeToString,
artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def GetObjectURL(request,
target,
Expand Down
23 changes: 20 additions & 3 deletions artifact/artifact/v1alpha/artifact_private_service_pb2_grpc.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -54,11 +54,16 @@ class ArtifactPrivateServiceStub:
artifact.artifact.v1alpha.artifact_pb2.DeleteRepositoryTagResponse,
]
"""Delete a repository tag."""
GetObject: grpc.UnaryUnaryMultiCallable[
artifact.artifact.v1alpha.artifact_pb2.GetObjectRequest,
artifact.artifact.v1alpha.artifact_pb2.GetObjectResponse,
]
"""Get Object"""
GetObjectURL: grpc.UnaryUnaryMultiCallable[
artifact.artifact.v1alpha.artifact_pb2.GetObjectURLRequest,
artifact.artifact.v1alpha.artifact_pb2.GetObjectURLResponse,
]
"""Get Object Upload URL"""
"""Get Object URL"""

class ArtifactPrivateServiceAsyncStub:
"""ArtifactPrivateService exposes the private endpoints that allow clients to
Expand Down Expand Up @@ -96,11 +101,16 @@ class ArtifactPrivateServiceAsyncStub:
artifact.artifact.v1alpha.artifact_pb2.DeleteRepositoryTagResponse,
]
"""Delete a repository tag."""
GetObject: grpc.aio.UnaryUnaryMultiCallable[
artifact.artifact.v1alpha.artifact_pb2.GetObjectRequest,
artifact.artifact.v1alpha.artifact_pb2.GetObjectResponse,
]
"""Get Object"""
GetObjectURL: grpc.aio.UnaryUnaryMultiCallable[
artifact.artifact.v1alpha.artifact_pb2.GetObjectURLRequest,
artifact.artifact.v1alpha.artifact_pb2.GetObjectURLResponse,
]
"""Get Object Upload URL"""
"""Get Object URL"""

class ArtifactPrivateServiceServicer(metaclass=abc.ABCMeta):
"""ArtifactPrivateService exposes the private endpoints that allow clients to
Expand Down Expand Up @@ -147,11 +157,18 @@ class ArtifactPrivateServiceServicer(metaclass=abc.ABCMeta):
) -> typing.Union[artifact.artifact.v1alpha.artifact_pb2.DeleteRepositoryTagResponse, collections.abc.Awaitable[artifact.artifact.v1alpha.artifact_pb2.DeleteRepositoryTagResponse]]:
"""Delete a repository tag."""
@abc.abstractmethod
def GetObject(
self,
request: artifact.artifact.v1alpha.artifact_pb2.GetObjectRequest,
context: _ServicerContext,
) -> typing.Union[artifact.artifact.v1alpha.artifact_pb2.GetObjectResponse, collections.abc.Awaitable[artifact.artifact.v1alpha.artifact_pb2.GetObjectResponse]]:
"""Get Object"""
@abc.abstractmethod
def GetObjectURL(
self,
request: artifact.artifact.v1alpha.artifact_pb2.GetObjectURLRequest,
context: _ServicerContext,
) -> typing.Union[artifact.artifact.v1alpha.artifact_pb2.GetObjectURLResponse, collections.abc.Awaitable[artifact.artifact.v1alpha.artifact_pb2.GetObjectURLResponse]]:
"""Get Object Upload URL"""
"""Get Object URL"""

def add_ArtifactPrivateServiceServicer_to_server(servicer: ArtifactPrivateServiceServicer, server: typing.Union[grpc.Server, grpc.aio.Server]) -> None: ...

0 comments on commit a183834

Please sign in to comment.