feat: add delegated routing metrics (#9354)
Gus Eggert committed
Oct 19, 2022 at 09:50 UTC
8c72ea909a2f9e4ea16941d94e1ba0eabf57340b
5 files changed
+12
-6
docs/examples/kubo-as-a-library/go.mod
+1
-1
@@ -68,7 +68,7 @@ require (
68
github.com/ipfs/go-cid v0.3.2 // indirect
69
github.com/ipfs/go-cidutil v0.1.0 // indirect
70
github.com/ipfs/go-datastore v0.6.0 // indirect
71
- github.com/ipfs/go-delegated-routing v0.6.0 // indirect
71
+ github.com/ipfs/go-delegated-routing v0.7.0 // indirect
72
github.com/ipfs/go-ds-badger v0.3.0 // indirect
73
github.com/ipfs/go-ds-flatfs v0.5.1 // indirect
74
github.com/ipfs/go-ds-leveldb v0.5.0 // indirect
docs/examples/kubo-as-a-library/go.sum
+2
-2
@@ -497,8 +497,8 @@ github.com/ipfs/go-datastore v0.5.0/go.mod h1:9zhEApYMTl17C8YDp7JmU7sQZi2/wqiYh7
497
github.com/ipfs/go-datastore v0.5.1/go.mod h1:9zhEApYMTl17C8YDp7JmU7sQZi2/wqiYh73hakZ90Bk=
498
github.com/ipfs/go-datastore v0.6.0 h1:JKyz+Gvz1QEZw0LsX1IBn+JFCJQH4SJVFtM4uWU0Myk=
499
github.com/ipfs/go-datastore v0.6.0/go.mod h1:rt5M3nNbSO/8q1t4LNkLyUwRs8HupMeN/8O4Vn9YAT8=
500
-github.com/ipfs/go-delegated-routing v0.6.0 h1:+M1siyTB2H4mHzEnbWjepQxlmKbapVWdbYLexSDODpg=
501
-github.com/ipfs/go-delegated-routing v0.6.0/go.mod h1:FJjhCChfcWK9z6OXo2jwKKJoxq1JlEWG7YTvwaA7UbI=
500
+github.com/ipfs/go-delegated-routing v0.7.0 h1:43FyMnKA+8XnyX68Fwg6aoGkqrf8NS5aG7p644s26PU=
501
+github.com/ipfs/go-delegated-routing v0.7.0/go.mod h1:u4zxjUWIe7APUW5ds9CfD0tJX3vM9JhIeNqA8kE4vHE=
502
github.com/ipfs/go-detect-race v0.0.1 h1:qX/xay2W3E4Q1U7d9lNs1sU9nvguX0a7319XbyQ6cOk=
503
github.com/ipfs/go-detect-race v0.0.1/go.mod h1:8BNT7shDZPo99Q74BpGMK+4D8Mn4j46UU0LZ723meps=
504
github.com/ipfs/go-ds-badger v0.0.2/go.mod h1:Y3QpeSFWQf6MopLTiZD+VT6IC1yZqaGmjvRcKeSGij8=
go.mod
+1
-1
@@ -116,7 +116,7 @@ require (
116
117
require (
118
github.com/benbjohnson/clock v1.3.0
119
- github.com/ipfs/go-delegated-routing v0.6.0
119
+ github.com/ipfs/go-delegated-routing v0.7.0
120
github.com/ipfs/go-ipfs-redirects-file v0.1.1
121
github.com/ipfs/go-log/v2 v2.5.1
122
)
go.sum
+2
-2
@@ -489,8 +489,8 @@ github.com/ipfs/go-datastore v0.4.5/go.mod h1:eXTcaaiN6uOlVCLS9GjJUJtlvJfM3xk23w
489
github.com/ipfs/go-datastore v0.5.0/go.mod h1:9zhEApYMTl17C8YDp7JmU7sQZi2/wqiYh73hakZ90Bk=
490
github.com/ipfs/go-datastore v0.6.0 h1:JKyz+Gvz1QEZw0LsX1IBn+JFCJQH4SJVFtM4uWU0Myk=
491
github.com/ipfs/go-datastore v0.6.0/go.mod h1:rt5M3nNbSO/8q1t4LNkLyUwRs8HupMeN/8O4Vn9YAT8=
492
-github.com/ipfs/go-delegated-routing v0.6.0 h1:+M1siyTB2H4mHzEnbWjepQxlmKbapVWdbYLexSDODpg=
493
-github.com/ipfs/go-delegated-routing v0.6.0/go.mod h1:FJjhCChfcWK9z6OXo2jwKKJoxq1JlEWG7YTvwaA7UbI=
492
+github.com/ipfs/go-delegated-routing v0.7.0 h1:43FyMnKA+8XnyX68Fwg6aoGkqrf8NS5aG7p644s26PU=
493
+github.com/ipfs/go-delegated-routing v0.7.0/go.mod h1:u4zxjUWIe7APUW5ds9CfD0tJX3vM9JhIeNqA8kE4vHE=
494
github.com/ipfs/go-detect-race v0.0.1 h1:qX/xay2W3E4Q1U7d9lNs1sU9nvguX0a7319XbyQ6cOk=
495
github.com/ipfs/go-detect-race v0.0.1/go.mod h1:8BNT7shDZPo99Q74BpGMK+4D8Mn4j46UU0LZ723meps=
496
github.com/ipfs/go-ds-badger v0.0.2/go.mod h1:Y3QpeSFWQf6MopLTiZD+VT6IC1yZqaGmjvRcKeSGij8=
routing/delegated.go
+6
@@ -23,6 +23,7 @@ import (
23
"github.com/libp2p/go-libp2p/core/routing"
24
ma "github.com/multiformats/go-multiaddr"
25
"github.com/multiformats/go-multicodec"
26
+ "go.opencensus.io/stats/view"
27
)
28
29
var log = logging.Logger("routing/delegated")
@@ -178,6 +179,11 @@ func reframeRoutingFromConfig(conf config.Router, extraReframe *ExtraReframePara
179
180
var c *drc.Client
181
182
+ err = view.Register(drc.DefaultViews...)
183
+ if err != nil {
184
+ return nil, fmt.Errorf("registering delegated routing views: %w", err)
185
+ }
186
+
187
// this path is for tests only
188
if extraReframe == nil {
189
c, err = drc.NewClient(dr, nil, nil)