Benchmark grafana plugin queries

cmd/backend/hermes.json

@@ -0,0 +1,172 @@
+[
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "127.0.0.1",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    },
+    {
+        "name": "TimescaleDB",
+        "provider": "TimescaleDB",
+        "settings": {
+            "host": "localhost",
+            "user": "postgres",
+            "password": "password",
+            "database": "hermes"
+        }
+    }
+]

lib/python/hermes_pb2_grpc.py

@@ -176,11 +176,21 @@ def __init__(self, channel):
                 request_serializer=bus__pb2.BusFilter.SerializeToString,
                 response_deserializer=bus__pb2.SourcedEvent.FromString,
                 _registered_method=True)
+        self.EmitEvent = channel.stream_unary(
+                '/Api/EmitEvent',
+                request_serializer=bus__pb2.SourcedEvent.SerializeToString,
+                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
+                _registered_method=True)
         self.SubTelemetry = channel.unary_stream(
                 '/Api/SubTelemetry',
                 request_serializer=bus__pb2.BusFilter.SerializeToString,
                 response_deserializer=bus__pb2.SourcedTelemetry.FromString,
                 _registered_method=True)
+        self.EmitTelemetry = channel.stream_unary(
+                '/Api/EmitTelemetry',
+                request_serializer=bus__pb2.SourcedTelemetry.SerializeToString,
+                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
+                _registered_method=True)
         self.SubFileDownlink = channel.unary_stream(
                 '/Api/SubFileDownlink',
                 request_serializer=bus__pb2.BusFilter.SerializeToString,
@@ -452,13 +462,27 @@ def SubEvent(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def EmitEvent(self, request_iterator, context):
+        """Emit to the event message bus
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def SubTelemetry(self, request, context):
         """Subscribe to the telemetry message bus
         """
         context.set_code(grpc.StatusCode.UNIMPLEMENTED)
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def EmitTelemetry(self, request_iterator, context):
+        """Emit to the telemetry message bus
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def SubFileDownlink(self, request, context):
         """Subscribe to the file downlink message bus
         """
@@ -618,11 +642,21 @@ def add_ApiServicer_to_server(servicer, server):
                     request_deserializer=bus__pb2.BusFilter.FromString,
                     response_serializer=bus__pb2.SourcedEvent.SerializeToString,
             ),
+            'EmitEvent': grpc.stream_unary_rpc_method_handler(
+                    servicer.EmitEvent,
+                    request_deserializer=bus__pb2.SourcedEvent.FromString,
+                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
+            ),
             'SubTelemetry': grpc.unary_stream_rpc_method_handler(
                     servicer.SubTelemetry,
                     request_deserializer=bus__pb2.BusFilter.FromString,
                     response_serializer=bus__pb2.SourcedTelemetry.SerializeToString,
             ),
+            'EmitTelemetry': grpc.stream_unary_rpc_method_handler(
+                    servicer.EmitTelemetry,
+                    request_deserializer=bus__pb2.SourcedTelemetry.FromString,
+                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
+            ),
             'SubFileDownlink': grpc.unary_stream_rpc_method_handler(
                     servicer.SubFileDownlink,
                     request_deserializer=bus__pb2.BusFilter.FromString,
@@ -1379,6 +1413,33 @@ def SubEvent(request,
             metadata,
             _registered_method=True)
 
+    @staticmethod
+    def EmitEvent(request_iterator,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.stream_unary(
+            request_iterator,
+            target,
+            '/Api/EmitEvent',
+            bus__pb2.SourcedEvent.SerializeToString,
+            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
+
     @staticmethod
     def SubTelemetry(request,
             target,
@@ -1406,6 +1467,33 @@ def SubTelemetry(request,
             metadata,
             _registered_method=True)
 
+    @staticmethod
+    def EmitTelemetry(request_iterator,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.stream_unary(
+            request_iterator,
+            target,
+            '/Api/EmitTelemetry',
+            bus__pb2.SourcedTelemetry.SerializeToString,
+            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
+
     @staticmethod
     def SubFileDownlink(request,
             target,

nasa-hermes-datasource/go.mod

@@ -6,6 +6,9 @@ require (
 	github.com/DATA-DOG/go-sqlmock v1.5.2
 	github.com/grafana/grafana-plugin-sdk-go v0.292.2
 	github.com/lib/pq v1.12.3
+	github.com/nasa/hermes v0.0.0
+	google.golang.org/grpc v1.81.1
+	google.golang.org/protobuf v1.36.11
 )
 
 require (
@@ -76,6 +79,7 @@ require (
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.44.0 // indirect
 	go.opentelemetry.io/otel/metric v1.44.0 // indirect
 	go.opentelemetry.io/otel/sdk v1.44.0 // indirect
+	go.opentelemetry.io/otel/sdk/metric v1.44.0 // indirect
 	go.opentelemetry.io/otel/trace v1.44.0 // indirect
 	go.opentelemetry.io/proto/otlp v1.10.0 // indirect
 	go.yaml.in/yaml/v2 v2.4.4 // indirect
@@ -84,7 +88,7 @@ require (
 	golang.org/x/sys v0.45.0 // indirect
 	golang.org/x/text v0.37.0 // indirect
 	google.golang.org/genproto v0.0.0-20210630183607-d20f26d13c79 // indirect
-	google.golang.org/grpc v1.81.1 // indirect
-	google.golang.org/protobuf v1.36.11 // indirect
 	gopkg.in/fsnotify/fsnotify.v1 v1.4.7 // indirect
 )
+
+replace github.com/nasa/hermes => ../