chore: auto-gen by protobufs

triggered by commit: instill-ai/protobufs@18b352e

core/mgmt/v1beta/mgmt_pb2.pyi

@@ -2087,3 +2087,221 @@ class DeleteOrganizationMembershipResponse(google.protobuf.message.Message):
     ) -> None: ...
 
 global___DeleteOrganizationMembershipResponse = DeleteOrganizationMembershipResponse
+
+@typing_extensions.final
+class Subscription(google.protobuf.message.Message):
+    """Subscription"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    @typing_extensions.final
+    class Quota(google.protobuf.message.Message):
+        """Quota"""
+
+        DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+        @typing_extensions.final
+        class PipelineTrigger(google.protobuf.message.Message):
+            """PipelineTrigger"""
+
+            DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+            QUOTA_FIELD_NUMBER: builtins.int
+            USED_FIELD_NUMBER: builtins.int
+            REMAIN_FIELD_NUMBER: builtins.int
+            quota: builtins.int
+            """quota"""
+            used: builtins.int
+            """used"""
+            remain: builtins.int
+            """remain"""
+            def __init__(
+                self,
+                *,
+                quota: builtins.int = ...,
+                used: builtins.int = ...,
+                remain: builtins.int = ...,
+            ) -> None: ...
+            def ClearField(self, field_name: typing_extensions.Literal["quota", b"quota", "remain", b"remain", "used", b"used"]) -> None: ...
+
+        PIPELINE_TRIGGER_FIELD_NUMBER: builtins.int
+        @property
+        def pipeline_trigger(self) -> global___Subscription.Quota.PipelineTrigger:
+            """pipeline"""
+        def __init__(
+            self,
+            *,
+            pipeline_trigger: global___Subscription.Quota.PipelineTrigger | None = ...,
+        ) -> None: ...
+        def HasField(self, field_name: typing_extensions.Literal["pipeline_trigger", b"pipeline_trigger"]) -> builtins.bool: ...
+        def ClearField(self, field_name: typing_extensions.Literal["pipeline_trigger", b"pipeline_trigger"]) -> None: ...
+
+    PLAN_FIELD_NUMBER: builtins.int
+    QUOTA_FIELD_NUMBER: builtins.int
+    plan: builtins.str
+    """plan"""
+    @property
+    def quota(self) -> global___Subscription.Quota:
+        """plan"""
+    def __init__(
+        self,
+        *,
+        plan: builtins.str = ...,
+        quota: global___Subscription.Quota | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["quota", b"quota"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["plan", b"plan", "quota", b"quota"]) -> None: ...
+
+global___Subscription = Subscription
+
+@typing_extensions.final
+class GetUserSubscriptionRequest(google.protobuf.message.Message):
+    """GetUserSubscriptionRequest"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    PARENT_FIELD_NUMBER: builtins.int
+    parent: builtins.str
+    """parent"""
+    def __init__(
+        self,
+        *,
+        parent: builtins.str = ...,
+    ) -> None: ...
+    def ClearField(self, field_name: typing_extensions.Literal["parent", b"parent"]) -> None: ...
+
+global___GetUserSubscriptionRequest = GetUserSubscriptionRequest
+
+@typing_extensions.final
+class GetUserSubscriptionResponse(google.protobuf.message.Message):
+    """GetUserSubscriptionResponse"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    SUBSCRIPTION_FIELD_NUMBER: builtins.int
+    @property
+    def subscription(self) -> global___Subscription:
+        """Subscription"""
+    def __init__(
+        self,
+        *,
+        subscription: global___Subscription | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["subscription", b"subscription"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["subscription", b"subscription"]) -> None: ...
+
+global___GetUserSubscriptionResponse = GetUserSubscriptionResponse
+
+@typing_extensions.final
+class GetOrganizationSubscriptionRequest(google.protobuf.message.Message):
+    """GetOrganizationSubscriptionRequest"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    PARENT_FIELD_NUMBER: builtins.int
+    parent: builtins.str
+    """parent"""
+    def __init__(
+        self,
+        *,
+        parent: builtins.str = ...,
+    ) -> None: ...
+    def ClearField(self, field_name: typing_extensions.Literal["parent", b"parent"]) -> None: ...
+
+global___GetOrganizationSubscriptionRequest = GetOrganizationSubscriptionRequest
+
+@typing_extensions.final
+class GetOrganizationSubscriptionResponse(google.protobuf.message.Message):
+    """GetOrganizationSubscriptionResponse"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    SUBSCRIPTION_FIELD_NUMBER: builtins.int
+    @property
+    def subscription(self) -> global___Subscription:
+        """Subscription"""
+    def __init__(
+        self,
+        *,
+        subscription: global___Subscription | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["subscription", b"subscription"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["subscription", b"subscription"]) -> None: ...
+
+global___GetOrganizationSubscriptionResponse = GetOrganizationSubscriptionResponse
+
+@typing_extensions.final
+class GetUserSubscriptionAdminRequest(google.protobuf.message.Message):
+    """GetUserSubscriptionAdminRequest"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    PARENT_FIELD_NUMBER: builtins.int
+    parent: builtins.str
+    """parent"""
+    def __init__(
+        self,
+        *,
+        parent: builtins.str = ...,
+    ) -> None: ...
+    def ClearField(self, field_name: typing_extensions.Literal["parent", b"parent"]) -> None: ...
+
+global___GetUserSubscriptionAdminRequest = GetUserSubscriptionAdminRequest
+
+@typing_extensions.final
+class GetUserSubscriptionAdminResponse(google.protobuf.message.Message):
+    """GetUserSubscriptionAdminResponse"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    SUBSCRIPTION_FIELD_NUMBER: builtins.int
+    @property
+    def subscription(self) -> global___Subscription:
+        """Subscription"""
+    def __init__(
+        self,
+        *,
+        subscription: global___Subscription | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["subscription", b"subscription"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["subscription", b"subscription"]) -> None: ...
+
+global___GetUserSubscriptionAdminResponse = GetUserSubscriptionAdminResponse
+
+@typing_extensions.final
+class GetOrganizationSubscriptionAdminRequest(google.protobuf.message.Message):
+    """GetOrganizationSubscriptionAdminRequest"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    PARENT_FIELD_NUMBER: builtins.int
+    parent: builtins.str
+    """parent"""
+    def __init__(
+        self,
+        *,
+        parent: builtins.str = ...,
+    ) -> None: ...
+    def ClearField(self, field_name: typing_extensions.Literal["parent", b"parent"]) -> None: ...
+
+global___GetOrganizationSubscriptionAdminRequest = GetOrganizationSubscriptionAdminRequest
+
+@typing_extensions.final
+class GetOrganizationSubscriptionAdminResponse(google.protobuf.message.Message):
+    """GetOrganizationSubscriptionAdminResponse"""
+
+    DESCRIPTOR: google.protobuf.descriptor.Descriptor
+
+    SUBSCRIPTION_FIELD_NUMBER: builtins.int
+    @property
+    def subscription(self) -> global___Subscription:
+        """Subscription"""
+    def __init__(
+        self,
+        *,
+        subscription: global___Subscription | None = ...,
+    ) -> None: ...
+    def HasField(self, field_name: typing_extensions.Literal["subscription", b"subscription"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing_extensions.Literal["subscription", b"subscription"]) -> None: ...
+
+global___GetOrganizationSubscriptionAdminResponse = GetOrganizationSubscriptionAdminResponse

core/mgmt/v1beta/mgmt_private_service_pb2_grpc.py

@@ -45,6 +45,16 @@ def __init__(self, channel):
                 request_serializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.LookUpOrganizationAdminRequest.SerializeToString,
                 response_deserializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.LookUpOrganizationAdminResponse.FromString,
                 )
+        self.GetUserSubscriptionAdmin = channel.unary_unary(
+                '/core.mgmt.v1beta.MgmtPrivateService/GetUserSubscriptionAdmin',
+                request_serializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetUserSubscriptionAdminRequest.SerializeToString,
+                response_deserializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetUserSubscriptionAdminResponse.FromString,
+                )
+        self.GetOrganizationSubscriptionAdmin = channel.unary_unary(
+                '/core.mgmt.v1beta.MgmtPrivateService/GetOrganizationSubscriptionAdmin',
+                request_serializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetOrganizationSubscriptionAdminRequest.SerializeToString,
+                response_deserializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetOrganizationSubscriptionAdminResponse.FromString,
+                )
 
 
 class MgmtPrivateServiceServicer(object):
@@ -99,6 +109,20 @@ def LookUpOrganizationAdmin(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def GetUserSubscriptionAdmin(self, request, context):
+        """GetUserSubscriptionAdmin
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
+    def GetOrganizationSubscriptionAdmin(self, request, context):
+        """GetOrganizationSubscriptionAdmin
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
 
 def add_MgmtPrivateServiceServicer_to_server(servicer, server):
     rpc_method_handlers = {
@@ -132,6 +156,16 @@ def add_MgmtPrivateServiceServicer_to_server(servicer, server):
                     request_deserializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.LookUpOrganizationAdminRequest.FromString,
                     response_serializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.LookUpOrganizationAdminResponse.SerializeToString,
             ),
+            'GetUserSubscriptionAdmin': grpc.unary_unary_rpc_method_handler(
+                    servicer.GetUserSubscriptionAdmin,
+                    request_deserializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetUserSubscriptionAdminRequest.FromString,
+                    response_serializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetUserSubscriptionAdminResponse.SerializeToString,
+            ),
+            'GetOrganizationSubscriptionAdmin': grpc.unary_unary_rpc_method_handler(
+                    servicer.GetOrganizationSubscriptionAdmin,
+                    request_deserializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetOrganizationSubscriptionAdminRequest.FromString,
+                    response_serializer=core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetOrganizationSubscriptionAdminResponse.SerializeToString,
+            ),
     }
     generic_handler = grpc.method_handlers_generic_handler(
             'core.mgmt.v1beta.MgmtPrivateService', rpc_method_handlers)
@@ -244,3 +278,37 @@ def LookUpOrganizationAdmin(request,
             core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.LookUpOrganizationAdminResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def GetUserSubscriptionAdmin(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, '/core.mgmt.v1beta.MgmtPrivateService/GetUserSubscriptionAdmin',
+            core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetUserSubscriptionAdminRequest.SerializeToString,
+            core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetUserSubscriptionAdminResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def GetOrganizationSubscriptionAdmin(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, '/core.mgmt.v1beta.MgmtPrivateService/GetOrganizationSubscriptionAdmin',
+            core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetOrganizationSubscriptionAdminRequest.SerializeToString,
+            core_dot_mgmt_dot_v1beta_dot_mgmt__pb2.GetOrganizationSubscriptionAdminResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)