apache / servicecomb-mesher / 512

Committed 16 Sep 2020 11:53AM UTC coverage: 76.18%. First build

Build # 512

Build Type

Pull #126

travis-ci

Committed by

web-flow

Commit Message

<a href="https://github.com/apache/servicecomb-mesher/commit/<a class=hub.com/apache/servicecomb-mesher/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/servicecomb-mesher/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/servicecomb-mesher/commit/33459334fa885d3f7382e220e7f8f53655793ad8">33459334f<a href="https://github.com/apache/servicecomb-mesher/commit/33459334fa885d3f7382e220e7f8f53655793ad8">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/apache/servicecomb-mesher/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/servicecomb-mesher/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/servicecomb-mesher/commit/33459334fa885d3f7382e220e7f8f53655793ad8&quot;&gt;33459334f&lt;/a&gt;&lt;a href=&quot;https://github.com/apache/servicecomb-mesher/commit/33459334fa885d3f7382e220e7f8f53655793ad8&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/apache/servicecomb-mesher/commit/33459334fa885d3f7382e220e7f8f536&lt;/a&gt;55793ad8&quot;>&quot;&gt;Merge &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/servicecomb-mesher/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/servicecomb-mesher/commit/<a class="double-link" href="https://github.com/apache/servicecomb-mesher/commit/fac0a84884d2d6d8271724f7cc8df2811fbb8c14">fac0a8488</a><a href="https://github.com/apache/servicecomb-mesher/commit/33459334fa885d3f7382e220e7f8f53655793ad8">&amp;quot;&amp;gt;fac0a8488&amp;lt;/a&amp;gt;&amp;quot;&amp;gt;fac0a8488&amp;lt;/a&amp;gt;&amp;lt;a href=&amp;quot;https://github.com/apache/servicecomb-mesher/commit/33459334fa885d3f7382e220e7f8f53655793&lt;/a&gt;ad8&quot;&gt; into &lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/servicecomb-mesher/commit/<a class="double-link" href="https://github.com/apache/servicecomb-mesher/commit/3e7ec967f">3e7ec967f">3e7ec967f</a>

Pull Request Pull Request #126: upgrade go chassis

Run Details

109 of 109 new or added lines in 29 files covered. (100.0%)

2437 of 3199 relevant lines covered (76.18%)

2.14 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

73.08

/proxy/pkg/skywalking/skywalking_manager.go

/*
 * 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 skywalking

import (
        "context"
        "fmt"
        "github.com/apache/servicecomb-mesher/proxy/config"
        gcconfig "github.com/go-chassis/go-chassis/v2/core/config"
        "github.com/go-chassis/go-chassis/v2/core/invocation"
        "github.com/go-chassis/openlog"
        "github.com/tetratelabs/go2sky"
        "github.com/tetratelabs/go2sky/reporter"
)

const (
        CrossProcessProtocolV2 = "Sw6"
        SkyWalkingConsumer     = "skywalking-consumer"
        SkyWalkingProvider     = "skywalking-provider"
        SkyWalkingName         = "skywalking"
        DeafaultSWServerURI    = "127.0.0.1:11800"
)

var r go2sky.Reporter
var tracer *go2sky.Tracer

//CreateEntrySpan use tracer to create and start an entry span for incoming request
func CreateEntrySpan(i *invocation.Invocation) (go2sky.Span, context.Context, error) {
        return tracer.CreateEntrySpan(i.Ctx, i.MicroServiceName+i.URLPathFormat, func() (string, error) {
                return i.Headers()[CrossProcessProtocolV2], nil
        })
}

//CreateExitSpan use tracer to create and start an exit span for client
func CreateExitSpan(ctx context.Context, i *invocation.Invocation) (go2sky.Span, error) {
        return tracer.CreateExitSpan(ctx, i.MicroServiceName+i.URLPathFormat, i.Endpoint+i.URLPathFormat, func(header string) error {
                i.SetHeader(CrossProcessProtocolV2, header)
                return nil
        })
}

//CreateLocalSpan use tracer to create and start a span for local usage
func CreateLocalSpan(ctx context.Context, opts ...go2sky.SpanOption) (go2sky.Span, context.Context, error) {
        return tracer.CreateLocalSpan(ctx, opts...)
}

//Init skywalking manager
func Init() {
        openlog.Debug(fmt.Sprintf("SkyWalking manager Init begin config:%#v", config.GetConfig().ServiceComb.APM))
        var err error
        serverURI := DeafaultSWServerURI
        if config.GetConfig().ServiceComb.APM.Tracing.ServerURI != "" && config.GetConfig().ServiceComb.APM.Tracing.Enable {
                serverURI = config.GetConfig().ServiceComb.APM.Tracing.ServerURI
        }
        r, err = reporter.NewGRPCReporter(serverURI)
        if err != nil {
                openlog.Error(fmt.Sprintf("NewGRPCReporter error:%s ", err.Error()))
        }
        tracer, err = go2sky.NewTracer(gcconfig.MicroserviceDefinition.Name, go2sky.WithReporter(r))
        if err != nil {
                openlog.Error(fmt.Sprintf("NewTracer error " + err.Error()))
        }
        //tracer.WaitUntilRegister()
        openlog.Debug(fmt.Sprintf("SkyWalking manager Init end"))
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17
18	package skywalking
19
20	import (
21	"context"
22	"fmt"
23	"github.com/apache/servicecomb-mesher/proxy/config"
24	gcconfig "github.com/go-chassis/go-chassis/v2/core/config"
25	"github.com/go-chassis/go-chassis/v2/core/invocation"
26	"github.com/go-chassis/openlog"
27	"github.com/tetratelabs/go2sky"
28	"github.com/tetratelabs/go2sky/reporter"
29	)
30
31	const (
32	CrossProcessProtocolV2 = "Sw6"
33	SkyWalkingConsumer = "skywalking-consumer"
34	SkyWalkingProvider = "skywalking-provider"
35	SkyWalkingName = "skywalking"
36	DeafaultSWServerURI = "127.0.0.1:11800"
37	)
38
39	var r go2sky.Reporter
40	var tracer *go2sky.Tracer
41
42	//CreateEntrySpan use tracer to create and start an entry span for incoming request
43	func CreateEntrySpan(i *invocation.Invocation) (go2sky.Span, context.Context, error) {	2✔
44	return tracer.CreateEntrySpan(i.Ctx, i.MicroServiceName+i.URLPathFormat, func() (string, error) {	2✔
45	return i.Headers()[CrossProcessProtocolV2], nil	×
46	})	×
47	}
48
49	//CreateExitSpan use tracer to create and start an exit span for client
50	func CreateExitSpan(ctx context.Context, i *invocation.Invocation) (go2sky.Span, error) {	1✔
51	return tracer.CreateExitSpan(ctx, i.MicroServiceName+i.URLPathFormat, i.Endpoint+i.URLPathFormat, func(header string) error {	1✔
52	i.SetHeader(CrossProcessProtocolV2, header)	×
53	return nil	×
54	})	×
55	}
56
57	//CreateLocalSpan use tracer to create and start a span for local usage
58	func CreateLocalSpan(ctx context.Context, opts ...go2sky.SpanOption) (go2sky.Span, context.Context, error) {	1✔
59	return tracer.CreateLocalSpan(ctx, opts...)	1✔
60	}	1✔
61
62	//Init skywalking manager
63	func Init() {	4✔
64	openlog.Debug(fmt.Sprintf("SkyWalking manager Init begin config:%#v", config.GetConfig().ServiceComb.APM))	4✔
65	var err error	4✔
66	serverURI := DeafaultSWServerURI	4✔
67	if config.GetConfig().ServiceComb.APM.Tracing.ServerURI != "" && config.GetConfig().ServiceComb.APM.Tracing.Enable {	8✔
68	serverURI = config.GetConfig().ServiceComb.APM.Tracing.ServerURI	4✔
69	}	4✔
70	r, err = reporter.NewGRPCReporter(serverURI)	4✔
71	if err != nil {	4✔
72	openlog.Error(fmt.Sprintf("NewGRPCReporter error:%s ", err.Error()))	×
73	}	×
74	tracer, err = go2sky.NewTracer(gcconfig.MicroserviceDefinition.Name, go2sky.WithReporter(r))	4✔
75	if err != nil {	4✔
76	openlog.Error(fmt.Sprintf("NewTracer error " + err.Error()))
77	}
78	//tracer.WaitUntilRegister()
79	openlog.Debug(fmt.Sprintf("SkyWalking manager Init end"))	4✔
80	}

apache / servicecomb-mesher / 512

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous