|
10 | 10 | from cs3.identity.group.v1beta1 import group_api_pb2 as cs3_dot_identity_dot_group_dot_v1beta1_dot_group__api__pb2 |
11 | 11 | from cs3.identity.tenant.v1beta1 import tenant_api_pb2 as cs3_dot_identity_dot_tenant_dot_v1beta1_dot_tenant__api__pb2 |
12 | 12 | from cs3.identity.user.v1beta1 import user_api_pb2 as cs3_dot_identity_dot_user_dot_v1beta1_dot_user__api__pb2 |
| 13 | +from cs3.labels.v1beta1 import label_api_pb2 as cs3_dot_labels_dot_v1beta1_dot_label__api__pb2 |
13 | 14 | from cs3.ocm.core.v1beta1 import ocm_core_api_pb2 as cs3_dot_ocm_dot_core_dot_v1beta1_dot_ocm__core__api__pb2 |
14 | 15 | from cs3.ocm.incoming.v1beta1 import ocm_incoming_api_pb2 as cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2 |
15 | 16 | from cs3.ocm.invite.v1beta1 import invite_api_pb2 as cs3_dot_ocm_dot_invite_dot_v1beta1_dot_invite__api__pb2 |
@@ -228,16 +229,6 @@ def __init__(self, channel): |
228 | 229 | request_serializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_spaces__api__pb2.DeleteStorageSpaceRequest.SerializeToString, |
229 | 230 | response_deserializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_spaces__api__pb2.DeleteStorageSpaceResponse.FromString, |
230 | 231 | ) |
231 | | - self.AddLabel = channel.unary_unary( |
232 | | - '/cs3.gateway.v1beta1.GatewayAPI/AddLabel', |
233 | | - request_serializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.AddLabelRequest.SerializeToString, |
234 | | - response_deserializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.AddLabelResponse.FromString, |
235 | | - ) |
236 | | - self.RemoveLabel = channel.unary_unary( |
237 | | - '/cs3.gateway.v1beta1.GatewayAPI/RemoveLabel', |
238 | | - request_serializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.RemoveLabelRequest.SerializeToString, |
239 | | - response_deserializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.RemoveLabelResponse.FromString, |
240 | | - ) |
241 | 232 | self.OpenInApp = channel.unary_unary( |
242 | 233 | '/cs3.gateway.v1beta1.GatewayAPI/OpenInApp', |
243 | 234 | request_serializer=cs3_dot_gateway_dot_v1beta1_dot_gateway__api__pb2.OpenInAppRequest.SerializeToString, |
@@ -303,6 +294,26 @@ def __init__(self, channel): |
303 | 294 | request_serializer=cs3_dot_preferences_dot_v1beta1_dot_preferences__api__pb2.GetKeyRequest.SerializeToString, |
304 | 295 | response_deserializer=cs3_dot_preferences_dot_v1beta1_dot_preferences__api__pb2.GetKeyResponse.FromString, |
305 | 296 | ) |
| 297 | + self.AddLabel = channel.unary_unary( |
| 298 | + '/cs3.gateway.v1beta1.GatewayAPI/AddLabel', |
| 299 | + request_serializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.AddLabelRequest.SerializeToString, |
| 300 | + response_deserializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.AddLabelResponse.FromString, |
| 301 | + ) |
| 302 | + self.RemoveLabel = channel.unary_unary( |
| 303 | + '/cs3.gateway.v1beta1.GatewayAPI/RemoveLabel', |
| 304 | + request_serializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.RemoveLabelRequest.SerializeToString, |
| 305 | + response_deserializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.RemoveLabelResponse.FromString, |
| 306 | + ) |
| 307 | + self.ListLabels = channel.unary_unary( |
| 308 | + '/cs3.gateway.v1beta1.GatewayAPI/ListLabels', |
| 309 | + request_serializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListLabelsRequest.SerializeToString, |
| 310 | + response_deserializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListLabelsResponse.FromString, |
| 311 | + ) |
| 312 | + self.ListResourcesForLabel = channel.unary_unary( |
| 313 | + '/cs3.gateway.v1beta1.GatewayAPI/ListResourcesForLabel', |
| 314 | + request_serializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListResourcesForLabelRequest.SerializeToString, |
| 315 | + response_deserializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListResourcesForLabelResponse.FromString, |
| 316 | + ) |
306 | 317 | self.CreatePublicShare = channel.unary_unary( |
307 | 318 | '/cs3.gateway.v1beta1.GatewayAPI/CreatePublicShare', |
308 | 319 | request_serializer=cs3_dot_sharing_dot_link_dot_v1beta1_dot_link__api__pb2.CreatePublicShareRequest.SerializeToString, |
@@ -919,20 +930,6 @@ def UpdateStorageSpace(self, request, context): |
919 | 930 |
|
920 | 931 | def DeleteStorageSpace(self, request, context): |
921 | 932 | """Deletes a storage space. |
922 | | - """ |
923 | | - context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
924 | | - context.set_details('Method not implemented!') |
925 | | - raise NotImplementedError('Method not implemented!') |
926 | | - |
927 | | - def AddLabel(self, request, context): |
928 | | - """Attach a label to a resource for a user. |
929 | | - """ |
930 | | - context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
931 | | - context.set_details('Method not implemented!') |
932 | | - raise NotImplementedError('Method not implemented!') |
933 | | - |
934 | | - def RemoveLabel(self, request, context): |
935 | | - """Removes a label from a resource for a user. |
936 | 933 | *****************************************************************/ |
937 | 934 | ************************ APP PROVIDER ********************/ |
938 | 935 | *****************************************************************/ |
@@ -1049,16 +1046,49 @@ def SetKey(self, request, context): |
1049 | 1046 | def GetKey(self, request, context): |
1050 | 1047 | """Returns the value associated with the |
1051 | 1048 | requested key. |
| 1049 | + """ |
| 1050 | + context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
| 1051 | + context.set_details('Method not implemented!') |
| 1052 | + raise NotImplementedError('Method not implemented!') |
| 1053 | + |
| 1054 | + def AddLabel(self, request, context): |
| 1055 | + """*****************************************************************/ |
| 1056 | + *************************** LABELS ******************************/ |
1052 | 1057 | *****************************************************************/ |
1053 | | - ************************ PUBLIC SHARE ***************************/ |
1054 | | - *****************************************************************/ |
| 1058 | +
|
| 1059 | + Attach a label to a resource for a user. |
| 1060 | + """ |
| 1061 | + context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
| 1062 | + context.set_details('Method not implemented!') |
| 1063 | + raise NotImplementedError('Method not implemented!') |
| 1064 | + |
| 1065 | + def RemoveLabel(self, request, context): |
| 1066 | + """Removes a label from a resource for a user. |
| 1067 | + """ |
| 1068 | + context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
| 1069 | + context.set_details('Method not implemented!') |
| 1070 | + raise NotImplementedError('Method not implemented!') |
| 1071 | + |
| 1072 | + def ListLabels(self, request, context): |
| 1073 | + """List the unique labels that a user has attached to resources |
| 1074 | + """ |
| 1075 | + context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
| 1076 | + context.set_details('Method not implemented!') |
| 1077 | + raise NotImplementedError('Method not implemented!') |
| 1078 | + |
| 1079 | + def ListResourcesForLabel(self, request, context): |
| 1080 | + """List the resources which have a given label attached for a given user |
1055 | 1081 | """ |
1056 | 1082 | context.set_code(grpc.StatusCode.UNIMPLEMENTED) |
1057 | 1083 | context.set_details('Method not implemented!') |
1058 | 1084 | raise NotImplementedError('Method not implemented!') |
1059 | 1085 |
|
1060 | 1086 | def CreatePublicShare(self, request, context): |
1061 | | - """Creates a new share. |
| 1087 | + """*****************************************************************/ |
| 1088 | + ************************ PUBLIC SHARE ***************************/ |
| 1089 | + *****************************************************************/ |
| 1090 | +
|
| 1091 | + Creates a new share. |
1062 | 1092 | MUST return CODE_NOT_FOUND if the resource reference does not exist. |
1063 | 1093 | MUST return CODE_ALREADY_EXISTS if the share already exists for the 4-tuple consisting of |
1064 | 1094 | (owner, shared_resource, grantee). |
@@ -1709,16 +1739,6 @@ def add_GatewayAPIServicer_to_server(servicer, server): |
1709 | 1739 | request_deserializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_spaces__api__pb2.DeleteStorageSpaceRequest.FromString, |
1710 | 1740 | response_serializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_spaces__api__pb2.DeleteStorageSpaceResponse.SerializeToString, |
1711 | 1741 | ), |
1712 | | - 'AddLabel': grpc.unary_unary_rpc_method_handler( |
1713 | | - servicer.AddLabel, |
1714 | | - request_deserializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.AddLabelRequest.FromString, |
1715 | | - response_serializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.AddLabelResponse.SerializeToString, |
1716 | | - ), |
1717 | | - 'RemoveLabel': grpc.unary_unary_rpc_method_handler( |
1718 | | - servicer.RemoveLabel, |
1719 | | - request_deserializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.RemoveLabelRequest.FromString, |
1720 | | - response_serializer=cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.RemoveLabelResponse.SerializeToString, |
1721 | | - ), |
1722 | 1742 | 'OpenInApp': grpc.unary_unary_rpc_method_handler( |
1723 | 1743 | servicer.OpenInApp, |
1724 | 1744 | request_deserializer=cs3_dot_gateway_dot_v1beta1_dot_gateway__api__pb2.OpenInAppRequest.FromString, |
@@ -1784,6 +1804,26 @@ def add_GatewayAPIServicer_to_server(servicer, server): |
1784 | 1804 | request_deserializer=cs3_dot_preferences_dot_v1beta1_dot_preferences__api__pb2.GetKeyRequest.FromString, |
1785 | 1805 | response_serializer=cs3_dot_preferences_dot_v1beta1_dot_preferences__api__pb2.GetKeyResponse.SerializeToString, |
1786 | 1806 | ), |
| 1807 | + 'AddLabel': grpc.unary_unary_rpc_method_handler( |
| 1808 | + servicer.AddLabel, |
| 1809 | + request_deserializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.AddLabelRequest.FromString, |
| 1810 | + response_serializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.AddLabelResponse.SerializeToString, |
| 1811 | + ), |
| 1812 | + 'RemoveLabel': grpc.unary_unary_rpc_method_handler( |
| 1813 | + servicer.RemoveLabel, |
| 1814 | + request_deserializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.RemoveLabelRequest.FromString, |
| 1815 | + response_serializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.RemoveLabelResponse.SerializeToString, |
| 1816 | + ), |
| 1817 | + 'ListLabels': grpc.unary_unary_rpc_method_handler( |
| 1818 | + servicer.ListLabels, |
| 1819 | + request_deserializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListLabelsRequest.FromString, |
| 1820 | + response_serializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListLabelsResponse.SerializeToString, |
| 1821 | + ), |
| 1822 | + 'ListResourcesForLabel': grpc.unary_unary_rpc_method_handler( |
| 1823 | + servicer.ListResourcesForLabel, |
| 1824 | + request_deserializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListResourcesForLabelRequest.FromString, |
| 1825 | + response_serializer=cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListResourcesForLabelResponse.SerializeToString, |
| 1826 | + ), |
1787 | 1827 | 'CreatePublicShare': grpc.unary_unary_rpc_method_handler( |
1788 | 1828 | servicer.CreatePublicShare, |
1789 | 1829 | request_deserializer=cs3_dot_sharing_dot_link_dot_v1beta1_dot_link__api__pb2.CreatePublicShareRequest.FromString, |
@@ -2699,40 +2739,6 @@ def DeleteStorageSpace(request, |
2699 | 2739 | options, channel_credentials, |
2700 | 2740 | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |
2701 | 2741 |
|
2702 | | - @staticmethod |
2703 | | - def AddLabel(request, |
2704 | | - target, |
2705 | | - options=(), |
2706 | | - channel_credentials=None, |
2707 | | - call_credentials=None, |
2708 | | - insecure=False, |
2709 | | - compression=None, |
2710 | | - wait_for_ready=None, |
2711 | | - timeout=None, |
2712 | | - metadata=None): |
2713 | | - return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/AddLabel', |
2714 | | - cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.AddLabelRequest.SerializeToString, |
2715 | | - cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.AddLabelResponse.FromString, |
2716 | | - options, channel_credentials, |
2717 | | - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |
2718 | | - |
2719 | | - @staticmethod |
2720 | | - def RemoveLabel(request, |
2721 | | - target, |
2722 | | - options=(), |
2723 | | - channel_credentials=None, |
2724 | | - call_credentials=None, |
2725 | | - insecure=False, |
2726 | | - compression=None, |
2727 | | - wait_for_ready=None, |
2728 | | - timeout=None, |
2729 | | - metadata=None): |
2730 | | - return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/RemoveLabel', |
2731 | | - cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.RemoveLabelRequest.SerializeToString, |
2732 | | - cs3_dot_storage_dot_provider_dot_v1beta1_dot_provider__api__pb2.RemoveLabelResponse.FromString, |
2733 | | - options, channel_credentials, |
2734 | | - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |
2735 | | - |
2736 | 2742 | @staticmethod |
2737 | 2743 | def OpenInApp(request, |
2738 | 2744 | target, |
@@ -2954,6 +2960,74 @@ def GetKey(request, |
2954 | 2960 | options, channel_credentials, |
2955 | 2961 | insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |
2956 | 2962 |
|
| 2963 | + @staticmethod |
| 2964 | + def AddLabel(request, |
| 2965 | + target, |
| 2966 | + options=(), |
| 2967 | + channel_credentials=None, |
| 2968 | + call_credentials=None, |
| 2969 | + insecure=False, |
| 2970 | + compression=None, |
| 2971 | + wait_for_ready=None, |
| 2972 | + timeout=None, |
| 2973 | + metadata=None): |
| 2974 | + return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/AddLabel', |
| 2975 | + cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.AddLabelRequest.SerializeToString, |
| 2976 | + cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.AddLabelResponse.FromString, |
| 2977 | + options, channel_credentials, |
| 2978 | + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |
| 2979 | + |
| 2980 | + @staticmethod |
| 2981 | + def RemoveLabel(request, |
| 2982 | + target, |
| 2983 | + options=(), |
| 2984 | + channel_credentials=None, |
| 2985 | + call_credentials=None, |
| 2986 | + insecure=False, |
| 2987 | + compression=None, |
| 2988 | + wait_for_ready=None, |
| 2989 | + timeout=None, |
| 2990 | + metadata=None): |
| 2991 | + return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/RemoveLabel', |
| 2992 | + cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.RemoveLabelRequest.SerializeToString, |
| 2993 | + cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.RemoveLabelResponse.FromString, |
| 2994 | + options, channel_credentials, |
| 2995 | + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |
| 2996 | + |
| 2997 | + @staticmethod |
| 2998 | + def ListLabels(request, |
| 2999 | + target, |
| 3000 | + options=(), |
| 3001 | + channel_credentials=None, |
| 3002 | + call_credentials=None, |
| 3003 | + insecure=False, |
| 3004 | + compression=None, |
| 3005 | + wait_for_ready=None, |
| 3006 | + timeout=None, |
| 3007 | + metadata=None): |
| 3008 | + return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/ListLabels', |
| 3009 | + cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListLabelsRequest.SerializeToString, |
| 3010 | + cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListLabelsResponse.FromString, |
| 3011 | + options, channel_credentials, |
| 3012 | + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |
| 3013 | + |
| 3014 | + @staticmethod |
| 3015 | + def ListResourcesForLabel(request, |
| 3016 | + target, |
| 3017 | + options=(), |
| 3018 | + channel_credentials=None, |
| 3019 | + call_credentials=None, |
| 3020 | + insecure=False, |
| 3021 | + compression=None, |
| 3022 | + wait_for_ready=None, |
| 3023 | + timeout=None, |
| 3024 | + metadata=None): |
| 3025 | + return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/ListResourcesForLabel', |
| 3026 | + cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListResourcesForLabelRequest.SerializeToString, |
| 3027 | + cs3_dot_labels_dot_v1beta1_dot_label__api__pb2.ListResourcesForLabelResponse.FromString, |
| 3028 | + options, channel_credentials, |
| 3029 | + insecure, call_credentials, compression, wait_for_ready, timeout, metadata) |
| 3030 | + |
2957 | 3031 | @staticmethod |
2958 | 3032 | def CreatePublicShare(request, |
2959 | 3033 | target, |
|
0 commit comments