Skip to content

Commit

Permalink
build: regenerate proto
Browse files Browse the repository at this point in the history
  • Loading branch information
Double.Cloud Bot committed Jul 26, 2024
1 parent d2c9af9 commit 0178456
Show file tree
Hide file tree
Showing 152 changed files with 7,249 additions and 685 deletions.
2 changes: 1 addition & 1 deletion api
Submodule api updated 55 files
+23 −0 .mapping.json
+121 −0 doublecloud/access/v1/access.proto
+41 −0 doublecloud/clickhouse/v1/cluster.proto
+2 −0 doublecloud/clickhouse/v1/cluster_service.proto
+12 −5 doublecloud/clickhouse/v1/config.proto
+894 −0 doublecloud/clickhouse/v1/user.proto
+147 −0 doublecloud/clickhouse/v1/user_service.proto
+11 −0 doublecloud/kafka/v1/cluster.proto
+13 −0 doublecloud/kafka/v1/config.proto
+3 −0 doublecloud/kafka/v1/connector.proto
+1 −0 doublecloud/kafka/v1/connector_service.proto
+2 −0 doublecloud/kafka/v1/topic.proto
+64 −0 doublecloud/logs/v1/log.proto
+68 −0 doublecloud/logs/v1/log_export.proto
+46 −0 doublecloud/logs/v1/log_export_service.proto
+29 −0 doublecloud/logs/v1/log_service.proto
+18 −0 doublecloud/logs/v1/log_source.proto
+17 −0 doublecloud/logs/v1/operation_service.proto
+13 −9 doublecloud/network/v1/network.proto
+1 −0 doublecloud/network/v1/network_connection.proto
+1 −0 doublecloud/network/v1/network_connection_service.proto
+15 −1 doublecloud/network/v1/network_service.proto
+81 −0 doublecloud/organizationmanager/saml/v1/federation.proto
+132 −0 doublecloud/organizationmanager/saml/v1/federation_service.proto
+26 −0 doublecloud/organizationmanager/v1/group.proto
+22 −0 doublecloud/organizationmanager/v1/group_mapping.proto
+116 −0 doublecloud/organizationmanager/v1/group_mapping_service.proto
+222 −0 doublecloud/organizationmanager/v1/group_service.proto
+25 −7 doublecloud/transfer/v1/endpoint.proto
+13 −0 doublecloud/transfer/v1/endpoint/airbyte/dynamodb_source.proto
+1 −1 doublecloud/transfer/v1/endpoint/airbyte/facebook_marketing_source.proto
+5 −4 doublecloud/transfer/v1/endpoint/airbyte/google_ads_source.proto
+19 −0 doublecloud/transfer/v1/endpoint/airbyte/hubspot_source.proto
+21 −0 doublecloud/transfer/v1/endpoint/airbyte/jira_source.proto
+5 −0 doublecloud/transfer/v1/endpoint/airbyte/s3_source.proto
+2 −0 doublecloud/transfer/v1/endpoint/airbyte/snowflake_source.proto
+11 −0 doublecloud/transfer/v1/endpoint/bigquery.proto
+18 −5 doublecloud/transfer/v1/endpoint/clickhouse.proto
+22 −2 doublecloud/transfer/v1/endpoint/common.proto
+38 −0 doublecloud/transfer/v1/endpoint/coralogix.proto
+18 −0 doublecloud/transfer/v1/endpoint/datadog.proto
+1 −0 doublecloud/transfer/v1/endpoint/delta_lake.proto
+24 −3 doublecloud/transfer/v1/endpoint/kafka.proto
+16 −0 doublecloud/transfer/v1/endpoint/kinesis.proto
+22 −0 doublecloud/transfer/v1/endpoint/metrica.proto
+12 −1 doublecloud/transfer/v1/endpoint/mongo.proto
+14 −10 doublecloud/transfer/v1/endpoint/mysql.proto
+23 −4 doublecloud/transfer/v1/endpoint/object_storage.proto
+75 −0 doublecloud/transfer/v1/endpoint/parsers.proto
+13 −9 doublecloud/transfer/v1/endpoint/postgres.proto
+2 −0 doublecloud/transfer/v1/endpoint_service.proto
+277 −0 doublecloud/transfer/v1/transfer.proto
+14 −3 doublecloud/transfer/v1/transfer_service.proto
+8 −0 doublecloud/v1/cluster.proto
+13 −0 doublecloud/visualization/v1/workbook_service.proto
Empty file added doublecloud/access/__init__.py
Empty file.
Empty file.
57 changes: 57 additions & 0 deletions doublecloud/access/v1/access_pb2.py

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

92 changes: 92 additions & 0 deletions doublecloud/access/v1/access_pb2.pyi
Original file line number Diff line number Diff line change
@@ -0,0 +1,92 @@
from google.protobuf.internal import containers as _containers
from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union

DESCRIPTOR: _descriptor.FileDescriptor

class AccessBindingAction(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
__slots__ = ()
ACCESS_BINDING_ACTION_UNSPECIFIED: _ClassVar[AccessBindingAction]
ADD: _ClassVar[AccessBindingAction]
REMOVE: _ClassVar[AccessBindingAction]
ACCESS_BINDING_ACTION_UNSPECIFIED: AccessBindingAction
ADD: AccessBindingAction
REMOVE: AccessBindingAction

class Subject(_message.Message):
__slots__ = ("id", "type")
ID_FIELD_NUMBER: _ClassVar[int]
TYPE_FIELD_NUMBER: _ClassVar[int]
id: str
type: str
def __init__(self, id: _Optional[str] = ..., type: _Optional[str] = ...) -> None: ...

class AccessBinding(_message.Message):
__slots__ = ("role_id", "subject")
ROLE_ID_FIELD_NUMBER: _ClassVar[int]
SUBJECT_FIELD_NUMBER: _ClassVar[int]
role_id: str
subject: Subject
def __init__(self, role_id: _Optional[str] = ..., subject: _Optional[_Union[Subject, _Mapping]] = ...) -> None: ...

class ListAccessBindingsRequest(_message.Message):
__slots__ = ("resource_id", "page_size", "page_token")
RESOURCE_ID_FIELD_NUMBER: _ClassVar[int]
PAGE_SIZE_FIELD_NUMBER: _ClassVar[int]
PAGE_TOKEN_FIELD_NUMBER: _ClassVar[int]
resource_id: str
page_size: int
page_token: str
def __init__(self, resource_id: _Optional[str] = ..., page_size: _Optional[int] = ..., page_token: _Optional[str] = ...) -> None: ...

class ListAccessBindingsResponse(_message.Message):
__slots__ = ("access_bindings", "next_page_token")
ACCESS_BINDINGS_FIELD_NUMBER: _ClassVar[int]
NEXT_PAGE_TOKEN_FIELD_NUMBER: _ClassVar[int]
access_bindings: _containers.RepeatedCompositeFieldContainer[AccessBinding]
next_page_token: str
def __init__(self, access_bindings: _Optional[_Iterable[_Union[AccessBinding, _Mapping]]] = ..., next_page_token: _Optional[str] = ...) -> None: ...

class SetAccessBindingsRequest(_message.Message):
__slots__ = ("resource_id", "access_bindings")
RESOURCE_ID_FIELD_NUMBER: _ClassVar[int]
ACCESS_BINDINGS_FIELD_NUMBER: _ClassVar[int]
resource_id: str
access_bindings: _containers.RepeatedCompositeFieldContainer[AccessBinding]
def __init__(self, resource_id: _Optional[str] = ..., access_bindings: _Optional[_Iterable[_Union[AccessBinding, _Mapping]]] = ...) -> None: ...

class SetAccessBindingsMetadata(_message.Message):
__slots__ = ("resource_id",)
RESOURCE_ID_FIELD_NUMBER: _ClassVar[int]
resource_id: str
def __init__(self, resource_id: _Optional[str] = ...) -> None: ...

class UpdateAccessBindingsRequest(_message.Message):
__slots__ = ("resource_id", "access_binding_deltas")
RESOURCE_ID_FIELD_NUMBER: _ClassVar[int]
ACCESS_BINDING_DELTAS_FIELD_NUMBER: _ClassVar[int]
resource_id: str
access_binding_deltas: _containers.RepeatedCompositeFieldContainer[AccessBindingDelta]
def __init__(self, resource_id: _Optional[str] = ..., access_binding_deltas: _Optional[_Iterable[_Union[AccessBindingDelta, _Mapping]]] = ...) -> None: ...

class UpdateAccessBindingsMetadata(_message.Message):
__slots__ = ("resource_id",)
RESOURCE_ID_FIELD_NUMBER: _ClassVar[int]
resource_id: str
def __init__(self, resource_id: _Optional[str] = ...) -> None: ...

class AccessBindingDelta(_message.Message):
__slots__ = ("action", "access_binding")
ACTION_FIELD_NUMBER: _ClassVar[int]
ACCESS_BINDING_FIELD_NUMBER: _ClassVar[int]
action: AccessBindingAction
access_binding: AccessBinding
def __init__(self, action: _Optional[_Union[AccessBindingAction, str]] = ..., access_binding: _Optional[_Union[AccessBinding, _Mapping]] = ...) -> None: ...

class AccessBindingsOperationResult(_message.Message):
__slots__ = ("effective_deltas",)
EFFECTIVE_DELTAS_FIELD_NUMBER: _ClassVar[int]
effective_deltas: _containers.RepeatedCompositeFieldContainer[AccessBindingDelta]
def __init__(self, effective_deltas: _Optional[_Iterable[_Union[AccessBindingDelta, _Mapping]]] = ...) -> None: ...
4 changes: 4 additions & 0 deletions doublecloud/access/v1/access_pb2_grpc.py
Original file line number Diff line number Diff line change
@@ -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

12 changes: 11 additions & 1 deletion doublecloud/clickhouse/v1/backup_pb2.py

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

12 changes: 11 additions & 1 deletion doublecloud/clickhouse/v1/backup_service_pb2.py

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

73 changes: 57 additions & 16 deletions doublecloud/clickhouse/v1/backup_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,22 +20,22 @@ def __init__(self, channel):
'/doublecloud.clickhouse.v1.BackupService/Get',
request_serializer=doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.GetBackupRequest.SerializeToString,
response_deserializer=doublecloud_dot_clickhouse_dot_v1_dot_backup__pb2.Backup.FromString,
)
_registered_method=True)
self.List = channel.unary_unary(
'/doublecloud.clickhouse.v1.BackupService/List',
request_serializer=doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.ListBackupsRequest.SerializeToString,
response_deserializer=doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.ListBackupsResponse.FromString,
)
_registered_method=True)
self.Create = channel.unary_unary(
'/doublecloud.clickhouse.v1.BackupService/Create',
request_serializer=doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.CreateBackupRequest.SerializeToString,
response_deserializer=doublecloud_dot_v1_dot_operation__pb2.Operation.FromString,
)
_registered_method=True)
self.Delete = channel.unary_unary(
'/doublecloud.clickhouse.v1.BackupService/Delete',
request_serializer=doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.DeleteBackupRequest.SerializeToString,
response_deserializer=doublecloud_dot_v1_dot_operation__pb2.Operation.FromString,
)
_registered_method=True)


class BackupServiceServicer(object):
Expand Down Expand Up @@ -96,6 +96,7 @@ def add_BackupServiceServicer_to_server(servicer, server):
generic_handler = grpc.method_handlers_generic_handler(
'doublecloud.clickhouse.v1.BackupService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
server.add_registered_method_handlers('doublecloud.clickhouse.v1.BackupService', rpc_method_handlers)


# This class is part of an EXPERIMENTAL API.
Expand All @@ -113,11 +114,21 @@ def Get(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/doublecloud.clickhouse.v1.BackupService/Get',
return grpc.experimental.unary_unary(
request,
target,
'/doublecloud.clickhouse.v1.BackupService/Get',
doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.GetBackupRequest.SerializeToString,
doublecloud_dot_clickhouse_dot_v1_dot_backup__pb2.Backup.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def List(request,
Expand All @@ -130,11 +141,21 @@ def List(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/doublecloud.clickhouse.v1.BackupService/List',
return grpc.experimental.unary_unary(
request,
target,
'/doublecloud.clickhouse.v1.BackupService/List',
doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.ListBackupsRequest.SerializeToString,
doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.ListBackupsResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def Create(request,
Expand All @@ -147,11 +168,21 @@ def Create(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/doublecloud.clickhouse.v1.BackupService/Create',
return grpc.experimental.unary_unary(
request,
target,
'/doublecloud.clickhouse.v1.BackupService/Create',
doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.CreateBackupRequest.SerializeToString,
doublecloud_dot_v1_dot_operation__pb2.Operation.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)

@staticmethod
def Delete(request,
Expand All @@ -164,8 +195,18 @@ def Delete(request,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/doublecloud.clickhouse.v1.BackupService/Delete',
return grpc.experimental.unary_unary(
request,
target,
'/doublecloud.clickhouse.v1.BackupService/Delete',
doublecloud_dot_clickhouse_dot_v1_dot_backup__service__pb2.DeleteBackupRequest.SerializeToString,
doublecloud_dot_v1_dot_operation__pb2.Operation.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
_registered_method=True)
Loading

0 comments on commit 0178456

Please sign in to comment.