sevenhill/QSfera
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add circuit breakers

Browse Source
This commit is contained in:
A.Unger
2021-02-23 11:56:03 +01:00
parent f280e98897
commit 97271d51bc
18 changed files with 184 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ocis-pkg/service/grpc/service.go
+10 -2
View File
@@ -6,14 +6,22 @@ import (
mgrpcc "github.com/asim/go-micro/plugins/client/grpc/v3"
mgrpcs "github.com/asim/go-micro/plugins/server/grpc/v3"
mbreaker "github.com/asim/go-micro/plugins/wrapper/breaker/gobreaker/v3"
"github.com/asim/go-micro/plugins/wrapper/monitoring/prometheus/v3"
"github.com/asim/go-micro/plugins/wrapper/trace/opencensus/v3"
"github.com/asim/go-micro/v3"
"github.com/asim/go-micro/v3/client"
"github.com/owncloud/ocis/ocis-pkg/registry"
)
// DefaultClient is a custom ocis grpc configured client.
var DefaultClient = mgrpcc.NewClient()
// DefaultClient is a custom oCIS grpc configured client.
var DefaultClient = getDefaultGrpcClient()
func getDefaultGrpcClient() client.Client {
return mgrpcc.NewClient(
client.Wrap(mbreaker.NewClientWrapper()),
)
}
// Service simply wraps the go-micro grpc service.
type Service struct {