Skip to content

Commit

Permalink
Update version to v2.0.0-beta.9
Browse files Browse the repository at this point in the history
  • Loading branch information
github-actions[bot] committed Nov 22, 2023
1 parent f352fbc commit 6488723
Show file tree
Hide file tree
Showing 40 changed files with 372 additions and 115 deletions.
2 changes: 1 addition & 1 deletion API
Submodule API updated from 6c7a75 to 9c28d4
2 changes: 1 addition & 1 deletion aruna/api/dataproxy/services/v2/bundler_service_pb2.py

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

35 changes: 30 additions & 5 deletions aruna/api/dataproxy/services/v2/bundler_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,12 @@


class BundlerServiceStub(object):
"""Missing associated documentation comment in .proto file."""
"""BundlerService
Status: ALPHA
Dataproxy specific service for creating and deleting bundles.
"""

def __init__(self, channel):
"""Constructor.
Expand All @@ -27,16 +32,31 @@ def __init__(self, channel):


class BundlerServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
"""BundlerService
Status: ALPHA
Dataproxy specific service for creating and deleting bundles.
"""

def CreateBundle(self, request, context):
"""Missing associated documentation comment in .proto file."""
"""CreateBundle
Status: ALPHA
Creates a bundle with multiple resources, dataproxy only.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def DeleteBundle(self, request, context):
"""Missing associated documentation comment in .proto file."""
"""DeleteBundle
Status: ALPHA
Delete an existing bundle, dataproxy only.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
Expand All @@ -62,7 +82,12 @@ def add_BundlerServiceServicer_to_server(servicer, server):

# This class is part of an EXPERIMENTAL API.
class BundlerService(object):
"""Missing associated documentation comment in .proto file."""
"""BundlerService
Status: ALPHA
Dataproxy specific service for creating and deleting bundles.
"""

@staticmethod
def CreateBundle(request,
Expand Down
2 changes: 1 addition & 1 deletion aruna/api/dataproxy/services/v2/dataproxy_service_pb2.py

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

25 changes: 20 additions & 5 deletions aruna/api/dataproxy/services/v2/dataproxy_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,12 @@


class DataproxyServiceStub(object):
"""Missing associated documentation comment in .proto file."""
"""DataproxyService
Status: ALPHA
Service for data replication between data-proxies
"""

def __init__(self, channel):
"""Constructor.
Expand All @@ -27,12 +32,17 @@ def __init__(self, channel):


class DataproxyServiceServicer(object):
"""Missing associated documentation comment in .proto file."""
"""DataproxyService
Status: ALPHA
Service for data replication between data-proxies
"""

def RequestReplication(self, request, context):
"""RequestReplication
Status: BETA
Status: ALPHA
Creates a replication request
"""
Expand All @@ -43,7 +53,7 @@ def RequestReplication(self, request, context):
def InitReplication(self, request, context):
"""InitReplication
Status: BETA
Status: ALPHA
Provides the necessary url to init replication
"""
Expand Down Expand Up @@ -72,7 +82,12 @@ def add_DataproxyServiceServicer_to_server(servicer, server):

# This class is part of an EXPERIMENTAL API.
class DataproxyService(object):
"""Missing associated documentation comment in .proto file."""
"""DataproxyService
Status: ALPHA
Service for data replication between data-proxies
"""

@staticmethod
def RequestReplication(request,
Expand Down
2 changes: 1 addition & 1 deletion aruna/api/health/v2/health_pb2.py

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

2 changes: 1 addition & 1 deletion aruna/api/hooks/services/v2/hooks_service_pb2.py

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

43 changes: 37 additions & 6 deletions aruna/api/hooks/services/v2/hooks_service_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -60,38 +60,69 @@ class HooksServiceServicer(object):
"""

def CreateHook(self, request, context):
"""Created Hooks are always associated with the owner that creates the hook
"""CreateHook
Status: ALPHA
Creates a replication request
Hooks are always associated with the owner that created the hook
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def AddProjectsToHook(self, request, context):
"""Missing associated documentation comment in .proto file."""
"""AddProjectsToHook
Status: ALPHA
Assigns a hook to a project
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def ListProjectHooks(self, request, context):
"""Missing associated documentation comment in .proto file."""
"""ListProjectHooks
Status: ALPHA
List all hooks assigned to a project
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def ListOwnedHooks(self, request, context):
"""Missing associated documentation comment in .proto file."""
"""ListOwnedHooks
Status: ALPHA
List all hooks created by a user
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def DeleteHook(self, request, context):
"""Missing associated documentation comment in .proto file."""
"""DeleteHook
Status: ALPHA
Delete a hook by id
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')

def HookCallback(self, request, context):
"""Missing associated documentation comment in .proto file."""
"""Callback API
Status: ALPHA
Externally triggered hooks should respond to this endpoint to
signal completion or failure and to provide additional flags for the object
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
Expand Down

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

Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,9 @@
class EventNotificationServiceStub(object):
"""EventNotificationService
A service to receive events in the AOS storage
Status: BETA
A service to receive events for CRUD operations on resources (users, resources etc.)
"""

def __init__(self, channel):
Expand Down Expand Up @@ -47,12 +49,16 @@ def __init__(self, channel):
class EventNotificationServiceServicer(object):
"""EventNotificationService
A service to receive events in the AOS storage
Status: BETA
A service to receive events for CRUD operations on resources (users, resources etc.)
"""

def CreateStreamConsumer(self, request, context):
"""CreateStreamConsumer
Status: BETA
Creates a new event stream consumer.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
Expand All @@ -62,6 +68,8 @@ def CreateStreamConsumer(self, request, context):
def GetEventMessageBatch(self, request, context):
"""GetEventMessageBatch
Status: BETA
Reads a set of messages from a given stream group
Each message contains a separate acknowledgement message thatis protected by a salt and an hmac for verification.
The message can be send directly through the AcknowledgeMessageBatch call to acknowledge the message.
Expand All @@ -73,6 +81,8 @@ def GetEventMessageBatch(self, request, context):
def GetEventMessageStream(self, request, context):
"""GetEventMessageBatch
Status: BETA
Opens a stream which pushes each received notification individual and just-in-time.
Each message contains a separate acknowledgement message that is protected by a salt and an hmac for verification.
The message can be send directly through the AcknowledgeMessageBatch call to acknowledge the message.
Expand All @@ -84,6 +94,8 @@ def GetEventMessageStream(self, request, context):
def AcknowledgeMessageBatch(self, request, context):
"""AcknowledgeMessageBatch
Status: BETA
List of messages to acknowledge
Each reply is protected by a salt and and hmac that verifies the message
"""
Expand All @@ -94,6 +106,8 @@ def AcknowledgeMessageBatch(self, request, context):
def DeleteStreamConsumer(self, request, context):
"""DeleteEventStreamingGroup
Status: BETA
Deletes an existing event stream consumer by ID.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
Expand Down Expand Up @@ -138,7 +152,9 @@ def add_EventNotificationServiceServicer_to_server(servicer, server):
class EventNotificationService(object):
"""EventNotificationService
A service to receive events in the AOS storage
Status: BETA
A service to receive events for CRUD operations on resources (users, resources etc.)
"""

@staticmethod
Expand Down
Loading

0 comments on commit 6488723

Please sign in to comment.