add the methods that are not in the graphql resolver and the classes … (#1634)

* add the methods that are not in the graphql resolver and the classes that are not in the type, and resolve the StackOverFlowOver that starts the report.

* add license

* update file header

oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/resolver/AlarmQuery.java

@@ -30,7 +30,7 @@ public class AlarmQuery implements GraphQLQueryResolver {
         return new AlarmTrend();
     }
 
-    public Alarms getAlarm(final Duration duration, final Scope scope, final Pagination paging) {
+    public Alarms getAlarm(final Duration duration, final Scope scope,final String keyword, final Pagination paging) {
         return new Alarms();
     }
 }

oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/resolver/MetadataQuery.java

@@ -47,4 +47,9 @@ public class MetadataQuery implements GraphQLQueryResolver {
     public List<Endpoint> searchEndpoint(final String keyword, final String serviceId, final int limit) {
         return Collections.emptyList();
     }
+
+
+    public Service searchService(final Duration duration, final String serviceCode) {
+        return new Service();
+    }
 }

oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/resolver/MetricQuery.java

@@ -19,10 +19,7 @@
 package org.apache.skywalking.oap.query.graphql.resolver;
 
 import com.coxautodev.graphql.tools.GraphQLQueryResolver;
-import org.apache.skywalking.oap.query.graphql.type.Duration;
-import org.apache.skywalking.oap.query.graphql.type.LinearIntValues;
-import org.apache.skywalking.oap.query.graphql.type.MetricCondition;
-import org.apache.skywalking.oap.query.graphql.type.Thermodynamic;
+import org.apache.skywalking.oap.query.graphql.type.*;
 
 public class MetricQuery implements GraphQLQueryResolver {
     public LinearIntValues getLinearIntValues(final MetricCondition metric, final Duration duration) {
@@ -32,4 +29,8 @@ public class MetricQuery implements GraphQLQueryResolver {
     public Thermodynamic getThermodynamic(final MetricCondition metric, final Duration duration) {
         return new Thermodynamic();
     }
+
+    public LinearIntValues getValues(final BatchMetricConditions metric, final Duration duration) {
+        return new LinearIntValues();
+    }
 }

oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/type/AlarmMessage.java

@@ -22,4 +22,5 @@ public class AlarmMessage {
     private Scope scope;
     private String id;
     private String message;
+    private Long startTime;
 }

oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/type/BatchMetricConditions.java

@@ -0,0 +1,27 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package org.apache.skywalking.oap.query.graphql.type;
+
+import java.util.List;
+
+/**
+ *  @author liu-xinyuan
+ **/
+public class BatchMetricConditions {
+    private List<MetricCondition> metricConditions;
+}

oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/type/Span.java

@@ -37,4 +37,5 @@ public class Span {
     private String layer;
     private List<KeyValue> tags;
     private List<LogEntity> logs;
+    private String serviceCode;
 }

oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/SegmentParse.java

@@ -50,7 +50,7 @@ public class SegmentParse implements DataStreamReader.CallBack<UpstreamSegment>
         this.segmentCoreInfo = new SegmentCoreInfo();
         this.segmentCoreInfo.setStartTime(Long.MAX_VALUE);
         this.segmentCoreInfo.setEndTime(Long.MIN_VALUE);
-        this.standardizationWorker = new SegmentStandardizationWorker(moduleManager, listenerManager);
+        this.standardizationWorker = new SegmentStandardizationWorker(moduleManager, listenerManager,this);
     }
 
     @Override public void call(UpstreamSegment segment) {

oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/standardization/SegmentStandardizationWorker.java

@@ -20,6 +20,7 @@ package org.apache.skywalking.oap.server.receiver.trace.provider.parser.standard
 
 import java.io.IOException;
 import java.util.*;
+
 import org.apache.skywalking.apm.commons.datacarrier.DataCarrier;
 import org.apache.skywalking.apm.commons.datacarrier.consumer.IConsumer;
 import org.apache.skywalking.apm.network.language.agent.UpstreamSegment;
@@ -40,7 +41,7 @@ public class SegmentStandardizationWorker extends AbstractWorker<SegmentStandard
     private final BufferStream<UpstreamSegment> stream;
 
     public SegmentStandardizationWorker(ModuleManager moduleManager,
-        SegmentParserListenerManager listenerManager) throws IOException {
+                                        SegmentParserListenerManager listenerManager, SegmentParse segmentParse) throws IOException {
         super(9999);
         this.dataCarrier = new DataCarrier<>(1, 1024);
         this.dataCarrier.consume(new Consumer(this), 1);
@@ -51,13 +52,14 @@ public class SegmentStandardizationWorker extends AbstractWorker<SegmentStandard
         builder.dataFileMaxSize(50);
         builder.offsetFileMaxSize(10);
         builder.parser(UpstreamSegment.parser());
-        builder.callBack(new SegmentParse(moduleManager, listenerManager));
+        builder.callBack(segmentParse);
 
         stream = builder.build();
         stream.initialize();
     }
 
-    @Override public void in(SegmentStandardization standardization) {
+    @Override
+    public void in(SegmentStandardization standardization) {
         stream.write(standardization.getUpstreamSegment());
     }
 
@@ -69,10 +71,12 @@ public class SegmentStandardizationWorker extends AbstractWorker<SegmentStandard
             this.aggregator = aggregator;
         }
 
-        @Override public void init() {
+        @Override
+        public void init() {
         }
 
-        @Override public void consume(List<SegmentStandardization> data) {
+        @Override
+        public void consume(List<SegmentStandardization> data) {
             Iterator<SegmentStandardization> inputIterator = data.iterator();
 
             int i = 0;
@@ -86,11 +90,13 @@ public class SegmentStandardizationWorker extends AbstractWorker<SegmentStandard
             }
         }
 
-        @Override public void onError(List<SegmentStandardization> data, Throwable t) {
+        @Override
+        public void onError(List<SegmentStandardization> data, Throwable t) {
             logger.error(t.getMessage(), t);
         }
 
-        @Override public void onExit() {
+        @Override
+        public void onExit() {
         }
     }
 }