go/kratos
1
0
Fork 0
mirror of https://github.com/go-kratos/kratos.git synced 2025-11-06 08:59:18 +02:00
Code Issues Releases Activity

fix: circuitbreaker use client context (#1679)

Browse Source
This commit is contained in:
china小宇
2021-12-09 23:20:46 +08:00
committed by GitHub
parent 8c9e70b47b
commit 83ebf53b93
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
middleware/circuitbreaker/circuitbreaker.go
View File

@@ -42,7 +42,7 @@ func Client(opts ...Option) middleware.Middleware {
}
return func(handler middleware.Handler) middleware.Handler {
return func(ctx context.Context, req interface{}) (interface{}, error) {
info, _ := transport.FromServerContext(ctx)
info, _ := transport.FromClientContext(ctx)
breaker := opt.group.Get(info.Operation()).(circuitbreaker.CircuitBreaker)
if err := breaker.Allow(); err != nil {
// rejected