Skip to content

Commit 25f44f9

Browse files
cs3org-botcs3org-bot
committed
1 parent 9ebb080 commit 25f44f9

File tree

7 files changed

+446
-93
lines changed

7 files changed

+446
-93
lines changed

‎cs3/gateway/v1beta1/gateway_api_pb2.py‎

Lines changed: 32 additions & 31 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎cs3/gateway/v1beta1/gateway_api_pb2_grpc.py‎

Lines changed: 107 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010
from cs3.identity.group.v1beta1 import group_api_pb2 as cs3_dot_identity_dot_group_dot_v1beta1_dot_group__api__pb2
1111
from cs3.identity.user.v1beta1 import user_api_pb2 as cs3_dot_identity_dot_user_dot_v1beta1_dot_user__api__pb2
1212
from cs3.ocm.core.v1beta1 import ocm_core_api_pb2 as cs3_dot_ocm_dot_core_dot_v1beta1_dot_ocm__core__api__pb2
13+
from cs3.ocm.incoming.v1beta1 import ocm_incoming_api_pb2 as cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2
1314
from cs3.ocm.invite.v1beta1 import invite_api_pb2 as cs3_dot_ocm_dot_invite_dot_v1beta1_dot_invite__api__pb2
1415
from cs3.ocm.provider.v1beta1 import provider_api_pb2 as cs3_dot_ocm_dot_provider_dot_v1beta1_dot_provider__api__pb2
1516
from cs3.permissions.v1beta1 import permissions_api_pb2 as cs3_dot_permissions_dot_v1beta1_dot_permissions__api__pb2
@@ -511,6 +512,21 @@ def __init__(self, channel):
511512
request_serializer=cs3_dot_ocm_dot_provider_dot_v1beta1_dot_provider__api__pb2.ListAllProvidersRequest.SerializeToString,
512513
response_deserializer=cs3_dot_ocm_dot_provider_dot_v1beta1_dot_provider__api__pb2.ListAllProvidersResponse.FromString,
513514
)
515+
self.CreateOCMIncomingShare = channel.unary_unary(
516+
'/cs3.gateway.v1beta1.GatewayAPI/CreateOCMIncomingShare',
517+
request_serializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.CreateOCMIncomingShareRequest.SerializeToString,
518+
response_deserializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.CreateOCMIncomingShareResponse.FromString,
519+
)
520+
self.UpdateOCMIncomingShare = channel.unary_unary(
521+
'/cs3.gateway.v1beta1.GatewayAPI/UpdateOCMIncomingShare',
522+
request_serializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.UpdateOCMIncomingShareRequest.SerializeToString,
523+
response_deserializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.UpdateOCMIncomingShareResponse.FromString,
524+
)
525+
self.DeleteOCMIncomingShare = channel.unary_unary(
526+
'/cs3.gateway.v1beta1.GatewayAPI/DeleteOCMIncomingShare',
527+
request_serializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.DeleteOCMIncomingShareRequest.SerializeToString,
528+
response_deserializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.DeleteOCMIncomingShareResponse.FromString,
529+
)
514530
self.CreateOCMCoreShare = channel.unary_unary(
515531
'/cs3.gateway.v1beta1.GatewayAPI/CreateOCMCoreShare',
516532
request_serializer=cs3_dot_ocm_dot_core_dot_v1beta1_dot_ocm__core__api__pb2.CreateOCMCoreShareRequest.SerializeToString,
@@ -1364,29 +1380,50 @@ def GetInfoByDomain(self, request, context):
13641380
def ListAllProviders(self, request, context):
13651381
"""Get the information of all the providers registered in the mesh.
13661382
*****************************************************************/
1367-
**************************** OCM CORE ***************************/
1383+
**************************** OCM INCOMING ***********************/
13681384
*****************************************************************/
13691385
"""
13701386
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
13711387
context.set_details('Method not implemented!')
13721388
raise NotImplementedError('Method not implemented!')
13731389

1390+
def CreateOCMIncomingShare(self, request, context):
1391+
"""Creates a new incoming OCM share.
1392+
"""
1393+
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
1394+
context.set_details('Method not implemented!')
1395+
raise NotImplementedError('Method not implemented!')
1396+
1397+
def UpdateOCMIncomingShare(self, request, context):
1398+
"""Updates an incoming OCM share.
1399+
"""
1400+
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
1401+
context.set_details('Method not implemented!')
1402+
raise NotImplementedError('Method not implemented!')
1403+
1404+
def DeleteOCMIncomingShare(self, request, context):
1405+
"""Deletes an incoming OCM share.
1406+
"""
1407+
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
1408+
context.set_details('Method not implemented!')
1409+
raise NotImplementedError('Method not implemented!')
1410+
13741411
def CreateOCMCoreShare(self, request, context):
1375-
"""Creates a new OCM share.
1412+
"""Deprecated. Creates a new OCM share.
13761413
"""
13771414
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
13781415
context.set_details('Method not implemented!')
13791416
raise NotImplementedError('Method not implemented!')
13801417

13811418
def UpdateOCMCoreShare(self, request, context):
1382-
"""Updates an OCM share.
1419+
"""Deprecated. Updates an OCM share.
13831420
"""
13841421
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
13851422
context.set_details('Method not implemented!')
13861423
raise NotImplementedError('Method not implemented!')
13871424

13881425
def DeleteOCMCoreShare(self, request, context):
1389-
"""Deletes an OCM share.
1426+
"""Deprecated. Deletes an OCM share.
13901427
*****************************************************************/
13911428
************************** FILE TRANSFER ************************/
13921429
*****************************************************************/
@@ -1903,6 +1940,21 @@ def add_GatewayAPIServicer_to_server(servicer, server):
19031940
request_deserializer=cs3_dot_ocm_dot_provider_dot_v1beta1_dot_provider__api__pb2.ListAllProvidersRequest.FromString,
19041941
response_serializer=cs3_dot_ocm_dot_provider_dot_v1beta1_dot_provider__api__pb2.ListAllProvidersResponse.SerializeToString,
19051942
),
1943+
'CreateOCMIncomingShare': grpc.unary_unary_rpc_method_handler(
1944+
servicer.CreateOCMIncomingShare,
1945+
request_deserializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.CreateOCMIncomingShareRequest.FromString,
1946+
response_serializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.CreateOCMIncomingShareResponse.SerializeToString,
1947+
),
1948+
'UpdateOCMIncomingShare': grpc.unary_unary_rpc_method_handler(
1949+
servicer.UpdateOCMIncomingShare,
1950+
request_deserializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.UpdateOCMIncomingShareRequest.FromString,
1951+
response_serializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.UpdateOCMIncomingShareResponse.SerializeToString,
1952+
),
1953+
'DeleteOCMIncomingShare': grpc.unary_unary_rpc_method_handler(
1954+
servicer.DeleteOCMIncomingShare,
1955+
request_deserializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.DeleteOCMIncomingShareRequest.FromString,
1956+
response_serializer=cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.DeleteOCMIncomingShareResponse.SerializeToString,
1957+
),
19061958
'CreateOCMCoreShare': grpc.unary_unary_rpc_method_handler(
19071959
servicer.CreateOCMCoreShare,
19081960
request_deserializer=cs3_dot_ocm_dot_core_dot_v1beta1_dot_ocm__core__api__pb2.CreateOCMCoreShareRequest.FromString,
@@ -3542,6 +3594,57 @@ def ListAllProviders(request,
35423594
options, channel_credentials,
35433595
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
35443596

3597+
@staticmethod
3598+
def CreateOCMIncomingShare(request,
3599+
target,
3600+
options=(),
3601+
channel_credentials=None,
3602+
call_credentials=None,
3603+
insecure=False,
3604+
compression=None,
3605+
wait_for_ready=None,
3606+
timeout=None,
3607+
metadata=None):
3608+
return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/CreateOCMIncomingShare',
3609+
cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.CreateOCMIncomingShareRequest.SerializeToString,
3610+
cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.CreateOCMIncomingShareResponse.FromString,
3611+
options, channel_credentials,
3612+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
3613+
3614+
@staticmethod
3615+
def UpdateOCMIncomingShare(request,
3616+
target,
3617+
options=(),
3618+
channel_credentials=None,
3619+
call_credentials=None,
3620+
insecure=False,
3621+
compression=None,
3622+
wait_for_ready=None,
3623+
timeout=None,
3624+
metadata=None):
3625+
return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/UpdateOCMIncomingShare',
3626+
cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.UpdateOCMIncomingShareRequest.SerializeToString,
3627+
cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.UpdateOCMIncomingShareResponse.FromString,
3628+
options, channel_credentials,
3629+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
3630+
3631+
@staticmethod
3632+
def DeleteOCMIncomingShare(request,
3633+
target,
3634+
options=(),
3635+
channel_credentials=None,
3636+
call_credentials=None,
3637+
insecure=False,
3638+
compression=None,
3639+
wait_for_ready=None,
3640+
timeout=None,
3641+
metadata=None):
3642+
return grpc.experimental.unary_unary(request, target, '/cs3.gateway.v1beta1.GatewayAPI/DeleteOCMIncomingShare',
3643+
cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.DeleteOCMIncomingShareRequest.SerializeToString,
3644+
cs3_dot_ocm_dot_incoming_dot_v1beta1_dot_ocm__incoming__api__pb2.DeleteOCMIncomingShareResponse.FromString,
3645+
options, channel_credentials,
3646+
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
3647+
35453648
@staticmethod
35463649
def CreateOCMCoreShare(request,
35473650
target,

‎cs3/ocm/core/v1beta1/ocm_core_api_pb2_grpc.py‎

Lines changed: 21 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -6,12 +6,13 @@
66

77

88
class OcmCoreAPIStub(object):
9-
"""OCM Core API
9+
"""OCM Core API (deprecated and to be removed, use cs3/ocm/incoming/v1beta1/incoming_api.proto instead)
1010
11-
the OCM Core API is the mapping for the local system of the OCM protocol,
12-
including multi-protocol shares. Implementations are expected to expose
13-
the `/ocm` endpoints according to the OCM API, and in response to those
14-
endpoints implement the following API.
11+
This API is the mapping for the local system of the Open Cloud Mesh
12+
(OCM) sharing protocol. Implementations are expected to expose the `/ocm`
13+
endpoints according to the OCM API, and in response to those endpoints call the
14+
following API. Support for multi-protocol shares is included, if the remote
15+
sender supplies a multi-protocol share.
1516
1617
The key words "MUST", "MUST NOT", "REQUIRED", "SHALL", "SHALL
1718
NOT", "SHOULD", "SHOULD NOT", "RECOMMENDED", "MAY", and
@@ -50,12 +51,13 @@ def __init__(self, channel):
5051

5152

5253
class OcmCoreAPIServicer(object):
53-
"""OCM Core API
54+
"""OCM Core API (deprecated and to be removed, use cs3/ocm/incoming/v1beta1/incoming_api.proto instead)
5455
55-
the OCM Core API is the mapping for the local system of the OCM protocol,
56-
including multi-protocol shares. Implementations are expected to expose
57-
the `/ocm` endpoints according to the OCM API, and in response to those
58-
endpoints implement the following API.
56+
This API is the mapping for the local system of the Open Cloud Mesh
57+
(OCM) sharing protocol. Implementations are expected to expose the `/ocm`
58+
endpoints according to the OCM API, and in response to those endpoints call the
59+
following API. Support for multi-protocol shares is included, if the remote
60+
sender supplies a multi-protocol share.
5961
6062
The key words "MUST", "MUST NOT", "REQUIRED", "SHALL", "SHALL
6163
NOT", "SHOULD", "SHOULD NOT", "RECOMMENDED", "MAY", and
@@ -71,24 +73,21 @@ class OcmCoreAPIServicer(object):
7173
"""
7274

7375
def CreateOCMCoreShare(self, request, context):
74-
"""Creates a new OCM share, in response to a call from remote to:
75-
https://cs3org.github.io/OCM-API/docs.html?branch=v1.2.0&repo=OCM-API&user=cs3org#/paths/~1shares/post
76+
"""Deprecated. Creates a new OCM share, in response to a call from the remote system
7677
"""
7778
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
7879
context.set_details('Method not implemented!')
7980
raise NotImplementedError('Method not implemented!')
8081

8182
def UpdateOCMCoreShare(self, request, context):
82-
"""Updates an OCM share, in response to a notification from the remote system to:
83-
https://cs3org.github.io/OCM-API/docs.html?branch=v1.2.0&repo=OCM-API&user=cs3org#/paths/~1notifications/post
83+
"""Deprecated. Updates an OCM share, in response to a notification from the remote system
8484
"""
8585
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
8686
context.set_details('Method not implemented!')
8787
raise NotImplementedError('Method not implemented!')
8888

8989
def DeleteOCMCoreShare(self, request, context):
90-
"""Deletes an OCM share, in response to a notification from the remote system to:
91-
https://cs3org.github.io/OCM-API/docs.html?branch=v1.2.0&repo=OCM-API&user=cs3org#/paths/~1notifications/post
90+
"""Deprecated. Deletes an OCM share, in response to a notification from the remote system
9291
"""
9392
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
9493
context.set_details('Method not implemented!')
@@ -120,12 +119,13 @@ def add_OcmCoreAPIServicer_to_server(servicer, server):
120119

121120
# This class is part of an EXPERIMENTAL API.
122121
class OcmCoreAPI(object):
123-
"""OCM Core API
122+
"""OCM Core API (deprecated and to be removed, use cs3/ocm/incoming/v1beta1/incoming_api.proto instead)
124123
125-
the OCM Core API is the mapping for the local system of the OCM protocol,
126-
including multi-protocol shares. Implementations are expected to expose
127-
the `/ocm` endpoints according to the OCM API, and in response to those
128-
endpoints implement the following API.
124+
This API is the mapping for the local system of the Open Cloud Mesh
125+
(OCM) sharing protocol. Implementations are expected to expose the `/ocm`
126+
endpoints according to the OCM API, and in response to those endpoints call the
127+
following API. Support for multi-protocol shares is included, if the remote
128+
sender supplies a multi-protocol share.
129129
130130
The key words "MUST", "MUST NOT", "REQUIRED", "SHALL", "SHALL
131131
NOT", "SHOULD", "SHOULD NOT", "RECOMMENDED", "MAY", and

0 commit comments

Comments
 (0)