Skip to content

Commit

Permalink
promgrpc update to version 0.8.0
Browse files Browse the repository at this point in the history
  • Loading branch information
piotrkowalczuk committed Aug 10, 2017
1 parent f5e9ce8 commit c668f71
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 14 deletions.
6 changes: 3 additions & 3 deletions glide.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion glide.yaml
Expand Up @@ -31,7 +31,7 @@ import:
- metadata
- peer
- package: github.com/piotrkowalczuk/promgrpc
version: ~0.7.0
version: ~0.8.0
- package: go.uber.org/zap
version: ^1.3.0
testImport:
Expand Down
15 changes: 5 additions & 10 deletions mnemosyned/daemon.go
Expand Up @@ -138,15 +138,7 @@ func (d *Daemon) Run() (err error) {
return
}

interceptor := promgrpc.NewInterceptor(promgrpc.InterceptorOpts{
SkipPreallocate: d.opts.IsTest,
Registerer: func() prometheus.Registerer {
if d.opts.IsTest {
return prometheus.NewRegistry()
}
return prometheus.DefaultRegisterer
}(),
})
interceptor := promgrpc.NewInterceptor(promgrpc.InterceptorOpts{})

d.clientOptions = []grpc.DialOption{
grpc.WithTimeout(10 * time.Second),
Expand Down Expand Up @@ -193,7 +185,10 @@ func (d *Daemon) Run() (err error) {
return err
}
mnemosynerpc.RegisterSessionManagerServer(gRPCServer, mnemosyneServer)
promgrpc.RegisterInterceptor(gRPCServer, interceptor)
if !d.opts.IsTest {
prometheus.DefaultRegisterer.Register(interceptor)
promgrpc.RegisterInterceptor(gRPCServer, interceptor)
}

if err = cl.Connect(d.clientOptions...); err != nil {
return err
Expand Down

0 comments on commit c668f71

Please sign in to comment.