dubbogo

README

Go2Sky with Dubbo-go

Installation

go get -u github.com/SkyAPM/go2sky-plugins/dubbo-go

Usage

Server:

import (
	"dubbo.apache.org/dubbo-go/v3/common/logger"
	"dubbo.apache.org/dubbo-go/v3/config"
	"github.com/SkyAPM/go2sky"
	"github.com/SkyAPM/go2sky/reporter"
	_ "dubbo.apache.org/dubbo-go/v3/imports"
	hessian "github.com/apache/dubbo-go-hessian2"

	dubbo_go "github.com/SkyAPM/go2sky-plugins/dubbo-go"
	"github.com/SkyAPM/go2sky-plugins/dubbo-go/test/server/pkg"
)

// set dubbogo configs ...

// setup reporter, use gRPC reporter for production
report, err := reporter.NewLogReporter()
if err != nil {
    log.Fatalf("new reporter error: %v \n", err)
}

// setup tracer
tracer, err := go2sky.NewTracer(serviceName, go2sky.WithReporter(report))
if err != nil {
    log.Fatalf("crate tracer error: %v \n", err)
}

// set dubbogo plugin server tracer
err = dubbo_go.SetServerTracer(tracer)
if err != nil {
    log.Fatalf("set tracer error: %v \n", err)
}

// set extra tags and report tags
dubbo_go.SetServerExtraTags("extra-tags", "server")
dubbo_go.SetServerReportTags("release")

Client:

import (
	"dubbo.apache.org/dubbo-go/v3/config"
	_ "dubbo.apache.org/dubbo-go/v3/imports"
	"github.com/SkyAPM/go2sky"
	"github.com/SkyAPM/go2sky/reporter"
	hessian "github.com/apache/dubbo-go-hessian2"

	dubbo_go "github.com/SkyAPM/go2sky-plugins/dubbo-go"
	"github.com/SkyAPM/go2sky-plugins/dubbo-go/test/client/pkg"
)

// set dubbogo configs ...

// setup reporter, use gRPC reporter for production
report, err := reporter.NewLogReporter()
if err != nil {
    log.Fatalf("new reporter error: %v \n", err)
}

// setup tracer
tracer, err := go2sky.NewTracer(serviceName, go2sky.WithReporter(report))
if err != nil {
    log.Fatalf("crate tracer error: %v \n", err)
}

// set dubbogo plugin client tracer
err = dubbo_go.SetClientTracer(tracer)
if err != nil {
    log.Fatalf("set tracer error: %v \n", err)
}

// set extra tags and report tags
dubbo_go.SetClientExtraTags("extra-tags", "client")
dubbo_go.SetClientReportTags("release")

Documentation

Index

• func GetClientTracingFilterSingleton() filter.Filter
• func GetServerTracingFilterSingleton() filter.Filter
• func SetClientExtraTags(key string, value string)
• func SetClientReportTags(tags ...string)
• func SetClientTracer(tracer *go2sky.Tracer) error
• func SetServerExtraTags(key string, value string)
• func SetServerReportTags(tags ...string)
• func SetServerTracer(tracer *go2sky.Tracer) error

Functions

func GetClientTracingFilterSingleton

func GetClientTracingFilterSingleton() filter.Filter

GetClientTracingFilterSingleton returns global filter for client side.

func GetServerTracingFilterSingleton

func GetServerTracingFilterSingleton() filter.Filter

GetServerTracingFilterSingleton returns global server filter for server side.

func SetClientExtraTags

func SetClientExtraTags(key string, value string)

SetClientExtraTags adds extra tag to client tracer spans.

func SetClientReportTags

func SetClientReportTags(tags ...string)

SetClientReportTags adds report tags to client tracer spans.

func SetClientTracer

func SetClientTracer(tracer *go2sky.Tracer) error

SetClientTracer set client tracer with user's tracer.

func SetServerExtraTags

func SetServerExtraTags(key string, value string)

SetServerExtraTags adds extra tag to server tracer spans.

func SetServerReportTags

func SetServerReportTags(tags ...string)

SetServerReportTags adds report tags to server tracer spans.

func SetServerTracer

func SetServerTracer(tracer *go2sky.Tracer) error

SetServerTracer set server tracer with user's tracer.