Skip to content

Commit

Permalink
fix: remove test case
Browse files Browse the repository at this point in the history
  • Loading branch information
Makonike committed Aug 19, 2023
1 parent 4b68022 commit 236b86c
Show file tree
Hide file tree
Showing 5 changed files with 47 additions and 367 deletions.
76 changes: 47 additions & 29 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,48 +1,66 @@
# jaeger-middleware

An extensively configurable Go web middleware that integrates Jaeger for distributed tracing.

## Usage

### Installation

```bash
go get github.com/asoul-fanclub/jaeger-middleware
go get github.com/asoul-fanclub/jaeger-middleware@v0.0.4
```

### Example

#### Server

```go
package main

import (
"context"
"fmt"
"log"
"net"
"time"

"github.com/asoul-fanclub/jaeger-middleware/middleware"
"go.opentelemetry.io/otel"
"google.golang.org/grpc"

"test_jaeger/test"
"test_jaeger/test/proto"
)

func main() {
tp, _ := middleware.TracerProvider("http://localhost:14268/api/traces", false)
otel.SetTracerProvider(tp)
ctx, cancel := context.WithCancel(context.Background())
defer cancel()

// Cleanly shutdown and flush telemetry when the application exits.
defer func(ctx context.Context) {
// Do not make the application hang when it is shutdown.
ctx, cancel = context.WithTimeout(ctx, time.Second*5)
defer cancel()
if err := tp.Shutdown(ctx); err != nil {
fmt.Println("failed to shutdown TracerProvider: ", err)
}
}(ctx)

server := grpc.NewServer(
grpc.UnaryInterceptor(middleware.NewJaegerServerMiddleware().UnaryInterceptor),
grpc.StreamInterceptor(middleware.NewJaegerServerMiddleware().StreamInterceptor),
)
proto.RegisterTestServiceServer(server, new(test.UserService))
list, err := net.Listen("tcp", ":50055")
if err != nil {
log.Fatal(err)
}
err = server.Serve(list)
if err != nil {
log.Fatal(err)
}
tp, _ := middleware.TracerProvider("http://localhost:14268/api/traces", false)
otel.SetTracerProvider(tp)
ctx, cancel := context.WithCancel(context.Background())
defer cancel()

// Cleanly shutdown and flush telemetry when the application exits.
defer func(ctx context.Context) {
// Do not make the application hang when it is shutdown.
ctx, cancel = context.WithTimeout(ctx, time.Second*5)
defer cancel()
if err := tp.Shutdown(ctx); err != nil {
fmt.Println("failed to shutdown TracerProvider: ", err)
}
}(ctx)

server := grpc.NewServer(
grpc.UnaryInterceptor(middleware.NewJaegerServerMiddleware().UnaryInterceptor),
grpc.StreamInterceptor(middleware.NewJaegerServerMiddleware().StreamInterceptor),
)
proto.RegisterTestServiceServer(server, new(test.UserService))
list, err := net.Listen("tcp", ":50055")
if err != nil {
log.Fatal(err)
}
err = server.Serve(list)
if err != nil {
log.Fatal(err)
}
}
```

Expand Down
79 changes: 0 additions & 79 deletions middleware_test.go

This file was deleted.

204 changes: 0 additions & 204 deletions test/proto/user.pb.go

This file was deleted.

17 changes: 0 additions & 17 deletions test/proto/user.proto

This file was deleted.

Loading

0 comments on commit 236b86c

Please sign in to comment.