Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

grpc: fix static code detection error #7

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open

grpc: fix static code detection error #7

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions grpc/examples/clients/grpc/go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
module trpc.group/trpc-go/trpc-codec/grpc/examples/clients/grpc_unary

go 1.17
go 1.18

replace trpc.group/trpc-go/trpc-codec/grpc => ../../../../grpc

Expand All @@ -18,9 +18,9 @@ require (
github.com/go-logr/stdr v1.2.2 // indirect
github.com/golang/protobuf v1.5.2 // indirect
go.opentelemetry.io/otel/trace v1.4.1 // indirect
golang.org/x/net v0.8.0 // indirect
golang.org/x/net v0.17.0 // indirect
golang.org/x/sys v0.13.0 // indirect
golang.org/x/text v0.8.0 // indirect
golang.org/x/text v0.13.0 // indirect
google.golang.org/genproto v0.0.0-20211019152133-63b7e35f4404 // indirect
google.golang.org/protobuf v1.31.0 // indirect
)
115 changes: 7 additions & 108 deletions grpc/examples/clients/grpc/go.sum
View file
Open in desktop

Large diffs are not rendered by default.

94 changes: 47 additions & 47 deletions grpc/examples/clients/grpc/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,63 +11,63 @@
//
//

// Package main 发起 gRPC 协议的 tRPC 请求
// Package main initiates tRPC requests using the gRPC protocol.
package main

import (
"context"
"fmt"
"log"
"context"
"fmt"
"log"

"go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc"
"go.opentelemetry.io/otel"
stdout "go.opentelemetry.io/otel/exporters/stdout/stdouttrace"
"go.opentelemetry.io/otel/propagation"
sdktrace "go.opentelemetry.io/otel/sdk/trace"
"google.golang.org/grpc"
"google.golang.org/grpc/metadata"
"trpc.group/trpc-go/trpc-codec/grpc/testdata/protocols/common"
pb "trpc.group/trpc-go/trpc-codec/grpc/testdata/protocols/grpc"
"go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc"
"go.opentelemetry.io/otel"
stdout "go.opentelemetry.io/otel/exporters/stdout/stdouttrace"
"go.opentelemetry.io/otel/propagation"
sdktrace "go.opentelemetry.io/otel/sdk/trace"
"google.golang.org/grpc"
"google.golang.org/grpc/metadata"
"trpc.group/trpc-go/trpc-codec/grpc/testdata/protocols/common"
pb "trpc.group/trpc-go/trpc-codec/grpc/testdata/protocols/grpc"
)

func main() {
// create a client connection
conn, err := grpc.Dial("127.0.0.1:5051", grpc.WithInsecure())
if err != nil {
panic(err)
}
defer conn.Close()
// create a client connection
conn, err := grpc.Dial("127.0.0.1:5051", grpc.WithInsecure())
if err != nil {
panic(err)
}
defer conn.Close()

// creates an Exporter
exporter, err := stdout.New(stdout.WithPrettyPrint())
if err != nil {
log.Fatal(err)
}
// generate TracerProvider
tp := sdktrace.NewTracerProvider(
sdktrace.WithSampler(sdktrace.AlwaysSample()),
sdktrace.WithBatcher(exporter),
)
// register TracerProvider
otel.SetTracerProvider(tp)
otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))
tracer := otel.GetTracerProvider().Tracer("grpc-client")
ctx, span := tracer.Start(context.Background(), "hello")
defer span.End()
// creates an Exporter
exporter, err := stdout.New(stdout.WithPrettyPrint())
if err != nil {
log.Fatal(err)
}
// generate TracerProvider
tp := sdktrace.NewTracerProvider(
sdktrace.WithSampler(sdktrace.AlwaysSample()),
sdktrace.WithBatcher(exporter),
)
// register TracerProvider
otel.SetTracerProvider(tp)
otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))
tracer := otel.GetTracerProvider().Tracer("grpc-client")
ctx, span := tracer.Start(context.Background(), "hello")
defer span.End()

// injects correlation context and span context into the gRPC
md := metadata.MD{}
otelgrpc.Inject(ctx, &md)
// injects correlation context and span context into the gRPC
md := metadata.MD{}
otelgrpc.Inject(ctx, &md)

// creates a new context with outgoing md attached
ctx = metadata.NewOutgoingContext(ctx, md)
// creates a new context with outgoing md attached
ctx = metadata.NewOutgoingContext(ctx, md)

c := pb.NewGreeterClient(conn)
// send rpc request
if rsp, err := c.Hello(ctx, &common.HelloReq{Msg: "abc"}); err != nil {
panic(err)
} else {
fmt.Print(rsp)
}
c := pb.NewGreeterClient(conn)
// send rpc request
if rsp, err := c.Hello(ctx, &common.HelloReq{Msg: "abc"}); err != nil {
panic(err)
} else {
fmt.Print(rsp)
}

}
48 changes: 24 additions & 24 deletions grpc/examples/clients/tgrpc_stream/go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,46 +12,46 @@ require (
go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.4.1
go.opentelemetry.io/otel/sdk v1.4.1
google.golang.org/grpc v1.44.0
trpc.group/trpc-go/trpc-codec/grpc v0.0.0-20220310022029-c3698a0fe1f5
trpc.group/trpc-go/trpc-codec/grpc/testdata/protocols/streams v0.0.0-00010101000000-000000000000
trpc.group/trpc-go/trpc-go v0.2.1-0.20230425082614-dbb64a2f7248
trpc.group/trpc-go/trpc-codec/grpc v1.0.0
trpc.group/trpc-go/trpc-codec/grpc/testdata/protocols/streams v1.0.0
trpc.group/trpc-go/trpc-go v1.0.1
)

require (
github.com/BurntSushi/toml v0.3.1 // indirect
github.com/andybalholm/brotli v1.0.4 // indirect
github.com/fsnotify/fsnotify v1.4.9 // indirect
github.com/BurntSushi/toml v1.3.2 // indirect
github.com/andybalholm/brotli v1.0.6 // indirect
github.com/fsnotify/fsnotify v1.6.0 // indirect
github.com/go-logr/logr v1.2.2 // indirect
github.com/go-logr/stdr v1.2.2 // indirect
github.com/go-playground/form/v4 v4.2.0 // indirect
github.com/golang/protobuf v1.5.2 // indirect
github.com/golang/snappy v0.0.3 // indirect
github.com/google/flatbuffers v2.0.0+incompatible // indirect
github.com/hashicorp/errwrap v1.0.0 // indirect
github.com/golang/snappy v0.0.4 // indirect
github.com/google/flatbuffers v23.5.26+incompatible // indirect
github.com/hashicorp/errwrap v1.1.0 // indirect
github.com/hashicorp/go-multierror v1.1.1 // indirect
github.com/json-iterator/go v1.1.12 // indirect
github.com/klauspost/compress v1.15.9 // indirect
github.com/klauspost/compress v1.17.1 // indirect
github.com/lestrrat-go/strftime v1.0.6 // indirect
github.com/mitchellh/mapstructure v1.5.0 // indirect
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
github.com/modern-go/reflect2 v1.0.2 // indirect
github.com/panjf2000/ants/v2 v2.4.6 // indirect
github.com/panjf2000/ants/v2 v2.8.2 // indirect
github.com/pkg/errors v0.9.1 // indirect
github.com/spf13/cast v1.3.1 // indirect
github.com/spf13/cast v1.5.1 // indirect
github.com/valyala/bytebufferpool v1.0.0 // indirect
github.com/valyala/fasthttp v1.43.0 // indirect
github.com/valyala/fasthttp v1.50.0 // indirect
go.opentelemetry.io/otel/trace v1.4.1 // indirect
go.uber.org/atomic v1.9.0 // indirect
go.uber.org/automaxprocs v1.3.0 // indirect
go.uber.org/multierr v1.6.0 // indirect
go.uber.org/zap v1.24.0 // indirect
golang.org/x/net v0.5.0 // indirect
golang.org/x/sys v0.4.0 // indirect
golang.org/x/text v0.6.0 // indirect
go.uber.org/atomic v1.11.0 // indirect
go.uber.org/automaxprocs v1.5.3 // indirect
go.uber.org/multierr v1.11.0 // indirect
go.uber.org/zap v1.26.0 // indirect
golang.org/x/net v0.17.0 // indirect
golang.org/x/sync v0.4.0 // indirect
golang.org/x/sys v0.13.0 // indirect
golang.org/x/text v0.13.0 // indirect
google.golang.org/genproto v0.0.0-20211019152133-63b7e35f4404 // indirect
google.golang.org/protobuf v1.28.0 // indirect
google.golang.org/protobuf v1.31.0 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
trpc.group/trpc-go/go_reuseport v1.7.1-0.20230423021710-f5eeff5d87a3 // indirect
trpc.group/trpc-go/jce v0.0.0-20230424070841-15a24b5c5646 // indirect
trpc.group/trpc-go/tnet v0.0.12-0.20230423031524-5eb1cc42f225 // indirect
trpc.group/trpc-go/tnet v1.0.0 // indirect
trpc.group/trpc/trpc-protocol/pb/go/trpc v1.0.0 // indirect
)
Loading