Skip to content

Commit e20115c

Browse files
authored
Replace usage of utils.Err with errors.Join (#3167)
Signed-off-by: Joshua Kim <20001595+joshua-kim@users.noreply.github.com>
1 parent deeab24 commit e20115c

File tree

55 files changed

+114
-139
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

55 files changed

+114
-139
lines changed

api/server/metrics.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,12 +4,11 @@
44
package server
55

66
import (
7+
"errors"
78
"net/http"
89
"time"
910

1011
"github.com/prometheus/client_golang/prometheus"
11-
12-
"github.com/ava-labs/avalanchego/utils"
1312
)
1413

1514
type metrics struct {
@@ -43,7 +42,7 @@ func newMetrics(registerer prometheus.Registerer) (*metrics, error) {
4342
),
4443
}
4544

46-
err := utils.Err(
45+
err := errors.Join(
4746
registerer.Register(m.numProcessing),
4847
registerer.Register(m.numCalls),
4948
registerer.Register(m.totalDuration),

cache/metercacher/metrics.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,9 @@
44
package metercacher
55

66
import (
7-
"github.com/prometheus/client_golang/prometheus"
7+
"errors"
88

9-
"github.com/ava-labs/avalanchego/utils"
9+
"github.com/prometheus/client_golang/prometheus"
1010
)
1111

1212
const (
@@ -78,7 +78,7 @@ func newMetrics(
7878
Help: "fraction of cache filled",
7979
}),
8080
}
81-
return m, utils.Err(
81+
return m, errors.Join(
8282
reg.Register(m.getCount),
8383
reg.Register(m.getTime),
8484
reg.Register(m.putCount),

database/leveldb/metrics.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,12 +4,11 @@
44
package leveldb
55

66
import (
7+
"errors"
78
"strconv"
89

910
"github.com/prometheus/client_golang/prometheus"
1011
"github.com/syndtr/goleveldb/leveldb"
11-
12-
"github.com/ava-labs/avalanchego/utils"
1312
)
1413

1514
var levelLabels = []string{"level"}
@@ -161,7 +160,7 @@ func newMetrics(reg prometheus.Registerer) (metrics, error) {
161160
currentStats: &leveldb.DBStats{},
162161
}
163162

164-
err := utils.Err(
163+
err := errors.Join(
165164
reg.Register(m.writesDelayedCount),
166165
reg.Register(m.writesDelayedDuration),
167166
reg.Register(m.writeIsDelayed),

database/meterdb/db.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,12 +5,12 @@ package meterdb
55

66
import (
77
"context"
8+
"errors"
89
"time"
910

1011
"github.com/prometheus/client_golang/prometheus"
1112

1213
"github.com/ava-labs/avalanchego/database"
13-
"github.com/ava-labs/avalanchego/utils"
1414
)
1515

1616
const methodLabel = "method"
@@ -125,7 +125,7 @@ func New(
125125
methodLabels,
126126
),
127127
}
128-
return meterDB, utils.Err(
128+
return meterDB, errors.Join(
129129
reg.Register(meterDB.calls),
130130
reg.Register(meterDB.duration),
131131
reg.Register(meterDB.size),

genesis/config.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -177,7 +177,7 @@ func init() {
177177
unparsedFujiConfig := UnparsedConfig{}
178178
unparsedLocalConfig := UnparsedConfig{}
179179

180-
err := utils.Err(
180+
err := errors.Join(
181181
json.Unmarshal(mainnetGenesisConfigJSON, &unparsedMainnetConfig),
182182
json.Unmarshal(fujiGenesisConfigJSON, &unparsedFujiConfig),
183183
json.Unmarshal(localGenesisConfigJSON, &unparsedLocalConfig),

indexer/index.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@ import (
1515
"github.com/ava-labs/avalanchego/database/versiondb"
1616
"github.com/ava-labs/avalanchego/ids"
1717
"github.com/ava-labs/avalanchego/snow"
18-
"github.com/ava-labs/avalanchego/utils"
1918
"github.com/ava-labs/avalanchego/utils/logging"
2019
"github.com/ava-labs/avalanchego/utils/timer/mockable"
2120
)
@@ -99,7 +98,7 @@ func newIndex(
9998

10099
// Close this index
101100
func (i *index) Close() error {
102-
return utils.Err(
101+
return errors.Join(
103102
i.indexToContainer.Close(),
104103
i.containerToIndex.Close(),
105104
i.vDB.Close(),

message/messages.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@ import (
1313

1414
"github.com/ava-labs/avalanchego/ids"
1515
"github.com/ava-labs/avalanchego/proto/pb/p2p"
16-
"github.com/ava-labs/avalanchego/utils"
1716
"github.com/ava-labs/avalanchego/utils/compression"
1817
"github.com/ava-labs/avalanchego/utils/constants"
1918
"github.com/ava-labs/avalanchego/utils/logging"
@@ -178,7 +177,7 @@ func newMsgBuilder(
178177

179178
maxMessageTimeout: maxMessageTimeout,
180179
}
181-
return mb, utils.Err(
180+
return mb, errors.Join(
182181
metrics.Register(mb.count),
183182
metrics.Register(mb.duration),
184183
)

network/ip_tracker.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,14 +5,14 @@ package network
55

66
import (
77
"crypto/rand"
8+
"errors"
89
"sync"
910

1011
"github.com/prometheus/client_golang/prometheus"
1112
"go.uber.org/zap"
1213

1314
"github.com/ava-labs/avalanchego/ids"
1415
"github.com/ava-labs/avalanchego/snow/validators"
15-
"github.com/ava-labs/avalanchego/utils"
1616
"github.com/ava-labs/avalanchego/utils/bloom"
1717
"github.com/ava-labs/avalanchego/utils/crypto/bls"
1818
"github.com/ava-labs/avalanchego/utils/ips"
@@ -63,7 +63,7 @@ func newIPTracker(
6363
connected: make(map[ids.NodeID]*ips.ClaimedIPPort),
6464
gossipableIndices: make(map[ids.NodeID]int),
6565
}
66-
err = utils.Err(
66+
err = errors.Join(
6767
registerer.Register(tracker.numTrackedIPs),
6868
registerer.Register(tracker.numGossipableIPs),
6969
)

network/metrics.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,14 +4,14 @@
44
package network
55

66
import (
7+
"errors"
78
"sync"
89
"time"
910

1011
"github.com/prometheus/client_golang/prometheus"
1112

1213
"github.com/ava-labs/avalanchego/ids"
1314
"github.com/ava-labs/avalanchego/network/peer"
14-
"github.com/ava-labs/avalanchego/utils"
1515
"github.com/ava-labs/avalanchego/utils/set"
1616
)
1717

@@ -135,7 +135,7 @@ func newMetrics(
135135
peerConnectedStartTimes: make(map[ids.NodeID]float64),
136136
}
137137

138-
err := utils.Err(
138+
err := errors.Join(
139139
registerer.Register(m.numTracked),
140140
registerer.Register(m.numPeers),
141141
registerer.Register(m.numSubnetPeers),

network/p2p/gossip/gossip.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,6 @@ import (
1717
"github.com/ava-labs/avalanchego/ids"
1818
"github.com/ava-labs/avalanchego/network/p2p"
1919
"github.com/ava-labs/avalanchego/snow/engine/common"
20-
"github.com/ava-labs/avalanchego/utils"
2120
"github.com/ava-labs/avalanchego/utils/bloom"
2221
"github.com/ava-labs/avalanchego/utils/buffer"
2322
"github.com/ava-labs/avalanchego/utils/logging"
@@ -150,7 +149,7 @@ func NewMetrics(
150149
typeLabels,
151150
),
152151
}
153-
err := utils.Err(
152+
err := errors.Join(
154153
metrics.Register(m.count),
155154
metrics.Register(m.bytes),
156155
metrics.Register(m.tracking),

0 commit comments

Comments
 (0)