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@a3fd95f
  • Loading branch information
droplet-bot committed Oct 24, 2024
1 parent d810fc1 commit 81e81c3
Show file tree
Hide file tree
Showing 7 changed files with 181 additions and 73 deletions.
106 changes: 55 additions & 51 deletions artifact/artifact/v1alpha/artifact_pb2.py

Large diffs are not rendered by default.

64 changes: 64 additions & 0 deletions artifact/artifact/v1alpha/artifact_pb2.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -670,6 +670,70 @@ class GetObjectURLResponse(google.protobuf.message.Message):

global___GetObjectURLResponse = GetObjectURLResponse

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

DESCRIPTOR: google.protobuf.descriptor.Descriptor

UID_FIELD_NUMBER: builtins.int
SIZE_FIELD_NUMBER: builtins.int
TYPE_FIELD_NUMBER: builtins.int
IS_UPLOADED_FIELD_NUMBER: builtins.int
LAST_MODIFIED_TIME_FIELD_NUMBER: builtins.int
uid: builtins.str
"""object uid"""
size: builtins.int
"""size"""
type: builtins.str
"""type"""
is_uploaded: builtins.bool
"""is upload"""
@property
def last_modified_time(self) -> google.protobuf.timestamp_pb2.Timestamp:
"""last modified time"""
def __init__(
self,
*,
uid: builtins.str = ...,
size: builtins.int | None = ...,
type: builtins.str | None = ...,
is_uploaded: builtins.bool | None = ...,
last_modified_time: google.protobuf.timestamp_pb2.Timestamp | None = ...,
) -> None: ...
def HasField(self, field_name: typing_extensions.Literal["_is_uploaded", b"_is_uploaded", "_last_modified_time", b"_last_modified_time", "_size", b"_size", "_type", b"_type", "is_uploaded", b"is_uploaded", "last_modified_time", b"last_modified_time", "size", b"size", "type", b"type"]) -> builtins.bool: ...
def ClearField(self, field_name: typing_extensions.Literal["_is_uploaded", b"_is_uploaded", "_last_modified_time", b"_last_modified_time", "_size", b"_size", "_type", b"_type", "is_uploaded", b"is_uploaded", "last_modified_time", b"last_modified_time", "size", b"size", "type", b"type", "uid", b"uid"]) -> None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing_extensions.Literal["_is_uploaded", b"_is_uploaded"]) -> typing_extensions.Literal["is_uploaded"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing_extensions.Literal["_last_modified_time", b"_last_modified_time"]) -> typing_extensions.Literal["last_modified_time"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing_extensions.Literal["_size", b"_size"]) -> typing_extensions.Literal["size"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing_extensions.Literal["_type", b"_type"]) -> typing_extensions.Literal["type"] | None: ...

global___UpdateObjectRequest = UpdateObjectRequest

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

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___UpdateObjectResponse = UpdateObjectResponse

@typing_extensions.final
class Catalog(google.protobuf.message.Message):
"""Catalog represents a catalog."""
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.

34 changes: 34 additions & 0 deletions artifact/artifact/v1alpha/artifact_private_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,11 @@ def __init__(self, channel):
request_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectURLRequest.SerializeToString,
response_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectURLResponse.FromString,
)
self.UpdateObject = channel.unary_unary(
'/artifact.artifact.v1alpha.ArtifactPrivateService/UpdateObject',
request_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.UpdateObjectRequest.SerializeToString,
response_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.UpdateObjectResponse.FromString,
)


class ArtifactPrivateServiceServicer(object):
Expand Down Expand Up @@ -104,6 +109,13 @@ def GetObjectURL(self, request, context):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

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


def add_ArtifactPrivateServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
Expand Down Expand Up @@ -137,6 +149,11 @@ def add_ArtifactPrivateServiceServicer_to_server(servicer, server):
request_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectURLRequest.FromString,
response_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectURLResponse.SerializeToString,
),
'UpdateObject': grpc.unary_unary_rpc_method_handler(
servicer.UpdateObject,
request_deserializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.UpdateObjectRequest.FromString,
response_serializer=artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.UpdateObjectResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'artifact.artifact.v1alpha.ArtifactPrivateService', rpc_method_handlers)
Expand Down Expand Up @@ -250,3 +267,20 @@ def GetObjectURL(request,
artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.GetObjectURLResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@staticmethod
def UpdateObject(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/UpdateObject',
artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.UpdateObjectRequest.SerializeToString,
artifact_dot_artifact_dot_v1alpha_dot_artifact__pb2.UpdateObjectResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
17 changes: 17 additions & 0 deletions artifact/artifact/v1alpha/artifact_private_service_pb2_grpc.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -64,6 +64,11 @@ class ArtifactPrivateServiceStub:
artifact.artifact.v1alpha.artifact_pb2.GetObjectURLResponse,
]
"""Get Object URL"""
UpdateObject: grpc.UnaryUnaryMultiCallable[
artifact.artifact.v1alpha.artifact_pb2.UpdateObjectRequest,
artifact.artifact.v1alpha.artifact_pb2.UpdateObjectResponse,
]
"""Update Object"""

class ArtifactPrivateServiceAsyncStub:
"""ArtifactPrivateService exposes the private endpoints that allow clients to
Expand Down Expand Up @@ -111,6 +116,11 @@ class ArtifactPrivateServiceAsyncStub:
artifact.artifact.v1alpha.artifact_pb2.GetObjectURLResponse,
]
"""Get Object URL"""
UpdateObject: grpc.aio.UnaryUnaryMultiCallable[
artifact.artifact.v1alpha.artifact_pb2.UpdateObjectRequest,
artifact.artifact.v1alpha.artifact_pb2.UpdateObjectResponse,
]
"""Update Object"""

class ArtifactPrivateServiceServicer(metaclass=abc.ABCMeta):
"""ArtifactPrivateService exposes the private endpoints that allow clients to
Expand Down Expand Up @@ -170,5 +180,12 @@ class ArtifactPrivateServiceServicer(metaclass=abc.ABCMeta):
context: _ServicerContext,
) -> typing.Union[artifact.artifact.v1alpha.artifact_pb2.GetObjectURLResponse, collections.abc.Awaitable[artifact.artifact.v1alpha.artifact_pb2.GetObjectURLResponse]]:
"""Get Object URL"""
@abc.abstractmethod
def UpdateObject(
self,
request: artifact.artifact.v1alpha.artifact_pb2.UpdateObjectRequest,
context: _ServicerContext,
) -> typing.Union[artifact.artifact.v1alpha.artifact_pb2.UpdateObjectResponse, collections.abc.Awaitable[artifact.artifact.v1alpha.artifact_pb2.UpdateObjectResponse]]:
"""Update Object"""

def add_ArtifactPrivateServiceServicer_to_server(servicer: ArtifactPrivateServiceServicer, server: typing.Union[grpc.Server, grpc.aio.Server]) -> None: ...
12 changes: 5 additions & 7 deletions artifact/artifact/v1alpha/object_pb2.py

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

Loading

0 comments on commit 81e81c3

Please sign in to comment.