-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat: add docs (README, comment in examples)
- Loading branch information
1 parent
72f2e9f
commit f8fada1
Showing
8 changed files
with
269 additions
and
26 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,81 @@ | ||
| # Kyber Trace GO Lib | ||
|
|
||
| ## Overview | ||
| This is a library that makes it easier to integrate with Kyber's self-hosted open tracing | ||
|
|
||
| ## Add this lib to your project | ||
| - Step 1: | ||
| ``` | ||
| $ export GOPRIVATE=github.com/KyberNetwork/kyber-trace-go | ||
| ``` | ||
| - Step 2: Add file `tools/tools.go` with content: | ||
| ``` | ||
| package tools | ||
| import ( | ||
| _ "github.com/KyberNetwork/kyber-trace-go/tools" | ||
| ) | ||
| ``` | ||
| - Step 3: | ||
| ``` | ||
| $ go mod tidy | ||
| $ go mod vendor | ||
| ``` | ||
|
|
||
| ## Update to latest version | ||
| ``` | ||
| $ go get -u github.com/KyberNetwork/kyber-trace-go | ||
| $ go mod vendor | ||
| ``` | ||
|
|
||
| ## Docker build | ||
| Please adjust your `RUN go mod download` statement in your Dockerfile to `RUN GO111MODULE=on GOPRIVATE=github.com/KyberNetwork/kybers-trace-error go mod download` | ||
|
|
||
| ## How to use | ||
|
|
||
| ### Init global `TracerProvider` | ||
| In order to push spans and traces to Kyber's self-hosted agent, you have to initialize a TracerProvider. When you add the following statement into your code: `import _ "github.com/KyberNetwork/kyber-trace-go/pkg/tracer"`, `kyber-trace-go` will initialize a new TraceProvider, set it to global TracerProvider of `otel` package. Whenever you want to get the Tracer to start (or get) a span, just use the function `tracer.Tracer()` (refer the example at https://github.com/KyberNetwork/kyber-trace-go/blob/main/example/tracer.go for more details). | ||
| ### Init global `MeterProvider` | ||
| In order to push customized metrics to Kyber's self-hosted agent, you have to initialize a MeterProvider. When you add the following statement into your code: `import _ "github.com/KyberNetwork/kyber-trace-go/pkg/metric"`, `kyber-trace-go` will initialize a new MeterProvider, set it to global MeterProvider of `otel` package. Whenever you want to get the Meter to push customized metrics, just use the function `metric.Meter()` (refer the example at https://github.com/KyberNetwork/kyber-trace-go/blob/main/example/meter.go for more details). | ||
| ### Configurations | ||
| When initializing the global TracerProvider and global MeterProvider, `kyber-trace-go` loads configurations from the following environment variables: | ||
| - OTEL_ENABLED: `kyber-trace-go` only initializes global `TracerProvider` and global `MeterProvider` if `OTEL_ENABLED = true` | ||
| - OTEL_AGENT_HOST: The host of the agent where traces, spans, customized metrics will be sent to. If you are using helm chart with dependency `base-service` version `0.5.15` or later, this environment variable will be injected via helm chart, and you don't need to set it in your `values.yaml` in kyber-application. Otherwise, you have to set it yourself. | ||
| - OTEL_METRIC_AGENT_GRPC_PORT: The gRPC port of the agent where customized metrics will be sent to. If you are using helm chart with dependency `base-service` version `0.5.15` or later, this environment variable will be injected via helm chart, and you don't need to set it in your `values.yaml` in kyber-application. Otherwise, you have to set it yourself. | ||
| - OTEL_METRIC_AGENT_HTTP_PORT: The HTTP port of the agent where customized metrics will be sent to. If you are using helm chart with dependency `base-service` version `0.5.15` or later, this environment variable will be injected via helm chart, and you don't need to set it in your `values.yaml` in kyber-application. Otherwise, you have to set it yourself. | ||
| - OTEL_TRACE_AGENT_GRPC_PORT: The gRPC port of the agent where traces, spans will be sent to. If you are using helm chart with dependency `base-service` version `0.5.15` or later, this environment variable will be injected via helm chart, and you don't need to set it in your `values.yaml` in kyber-application. Otherwise, you have to set it yourself. | ||
| - OTEL_TRACE_AGENT_HTTP_PORT: The HTTP port of the agent where traces, spans will be sent to. If you are using helm chart with dependency `base-service` version `0.5.15` or later, this environment variable will be injected via helm chart, and you don't need to set it in your `values.yaml` in kyber-application. Otherwise, you have to set it yourself. | ||
| - OTEL_INSECURE: Disables client transport security for HTTP/gRPC connection when connecting to agent. If you are using helm chart with dependency `base-service` version `0.5.15` or later, this environment variable will be set to `true` automatically. | ||
| - OTEL_PROTOCOL: Specify which protocol will be used to connect to the agent. Enum: `grpc`, `http`. The default value is `grpc`. Only add this environment variable to your `value.yaml` in kyber-application when you want to use `http`. | ||
| - OTEL_SERVICE_NAME: Name of your service which can be used in your query in grafana jaeger. If you are using helm chart with dependency `base-service` version `0.5.15` or later, this environment variable will be injected via helm chart, and you don't need to set it in your `values.yaml` in `kyber-application`. Otherwise, you have to set it yourself. | ||
| - OTEL_SERVICE_VERSION: The current version of your service. If you are using helm chart with dependency `base-service` version `0.5.15` or later, this environment variable will be injected via helm chart, and you don't need to set it in your `values.yaml` in `kyber-application`. Otherwise, you have to set it to your current image tag. | ||
| - OTEL_TRACE_SAMPLE_RATE: The default value is `0.5`. If you want your all traces and spans will be recorded, set `OTEL_TRACE_SAMPLE_RATE = 1` | ||
|
|
||
| ### For gin framework | ||
| If your application is using gin framework, you can use [this package](https://pkg.go.dev/go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin) to trace requests to your application automatically. You can see the example at https://github.com/KyberNetwork/kyber-trace-go/blob/main/example/gin.go | ||
|
|
||
| ### For GORM | ||
| OpenTelemetry GORM is designed is easy to use and provides a simple API for instrumenting GORM applications, making it possible for developers to quickly add observability to their applications without having to write a lot of code. To instrument GORM, you need to install the plugin provided by otelgorm: | ||
| ``` | ||
| import ( | ||
| "github.com/uptrace/opentelemetry-go-extra/otelgorm" | ||
| "gorm.io/driver/sqlite" | ||
| "gorm.io/gorm" | ||
| ) | ||
| db, err := gorm.Open(sqlite.Open("file::memory:?cache=shared"), &gorm.Config{}) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| if err := db.Use(otelgorm.NewPlugin()); err != nil { | ||
| panic(err) | ||
| } | ||
| ``` | ||
| And then use db.WithContext(ctx) to propagate the active span via context: | ||
| ``` | ||
| var num int | ||
| if err := db.WithContext(ctx).Raw("SELECT 42").Scan(&num).Error; err != nil { | ||
| panic(err) | ||
| } | ||
| ``` |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,47 @@ | ||
| package example | ||
|
|
||
| import ( | ||
| "net/http" | ||
| "os" | ||
|
|
||
| _ "github.com/KyberNetwork/kyber-trace-go/tools" // this is important | ||
| "github.com/gin-gonic/gin" | ||
| "go.opentelemetry.io/contrib/instrumentation/github.com/gin-gonic/gin/otelgin" | ||
| ) | ||
|
|
||
| func GinFramework() { | ||
| // Please port forward collector from develop environment to local then set environment variables before run this example: | ||
| // kubectl -n observability port-forward daemonset/opentelemetry-collector-agent 4317:4317 4315:4315 | ||
| // export OTEL_ENABLED=true | ||
| // export OTEL_AGENT_HOST=127.0.0.1 | ||
| // export OTEL_SERVICE_NAME=your_service_name | ||
| // export OTEL_SERVICE_VERSION=0.1.0 | ||
| // export OTEL_TRACE_SAMPLE_RATE=1 | ||
| // export OTEL_TRACE_AGENT_GRPC_PORT=4317 | ||
| // export OTEL_METRIC_AGENT_GRPC_PORT=4315 | ||
| // export OTEL_INSECURE=true | ||
|
|
||
| // When you deploy your service using helm chart with base-service from version 0.5.15, the following variables will be injected directly via helm chart: | ||
| // OTEL_AGENT_HOST, OTEL_SERVICE_NAME, OTEL_SERVICE_VERSION, OTEL_TRACE_AGENT_GRPC_PORT, OTEL_METRIC_AGENT_GRPC_PORT, OTEL_INSECURE | ||
| // You just need to set OTEL_ENABLED, OTEL_TRACE_SAMPLE_RATE. | ||
|
|
||
| server := newServer() | ||
| err := server.Run() | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| } | ||
|
|
||
| func newServer() *gin.Engine { | ||
| server := gin.New() | ||
| if os.Getenv("OTEL_ENABLED") == "true" { | ||
| server.Use(otelgin.Middleware( | ||
| os.Getenv("OTEL_SERVICE_NAME"), | ||
| )) | ||
| } | ||
| rg := server.Group("/api/v1") | ||
| rg.GET("/greeting", func(c *gin.Context) { | ||
| c.AbortWithStatusJSON(http.StatusOK, "Hello World") | ||
| }) | ||
| return server | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.