Skip to content

N
nebula
Commit 7ff69403 authored by Sebastian Stammler's avatar Sebastian Stammler Committed by GitHub
Browse files
Options

ci-builder: bump go tool versions (#12159) 

* ci-builder: bump go tool versions

* update mocks after update of mockery

* bump cci ci-builder version to v0.53.0

* fix golangci-lint run --help | grep concurrency
parent ec80f9c7
Hide whitespace changes
Inline Side-by-side
Showing with 277 additions and 72 deletions
.circleci/config.yml
View file @ 7ff69403
......@@ -3,7 +3,7 @@ version: 2.1
parameters:
ci_builder_image:
type: string
default: us-docker.pkg.dev/oplabs-tools-artifacts/images/ci-builder:v0.51.0
default: us-docker.pkg.dev/oplabs-tools-artifacts/images/ci-builder:v0.53.0
ci_builder_rust_image:
type: string
default: us-docker.pkg.dev/oplabs-tools-artifacts/images/ci-builder-rust:latest
......@@ -791,7 +791,7 @@ jobs:
name: run Go linter
command: |
# Identify how many cores it defaults to
golangci-lint --help | grep concurrency
golangci-lint run --help | grep concurrency
make lint-go
working_directory: .
- save_cache:
......
op-node/p2p/gating/mocks/BlockingConnectionGater.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -33,6 +33,10 @@ func (_m *BlockingConnectionGater) EXPECT() *BlockingConnectionGater_Expecter {
func (_m *BlockingConnectionGater) BlockAddr(ip net.IP) error {
ret := _m.Called(ip)
if len(ret) == 0 {
panic("no return value specified for BlockAddr")
}
var r0 error
if rf, ok := ret.Get(0).(func(net.IP) error); ok {
r0 = rf(ip)
......@@ -75,6 +79,10 @@ func (_c *BlockingConnectionGater_BlockAddr_Call) RunAndReturn(run func(net.IP)
func (_m *BlockingConnectionGater) BlockPeer(p peer.ID) error {
ret := _m.Called(p)
if len(ret) == 0 {
panic("no return value specified for BlockPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(peer.ID) error); ok {
r0 = rf(p)
......@@ -117,6 +125,10 @@ func (_c *BlockingConnectionGater_BlockPeer_Call) RunAndReturn(run func(peer.ID)
func (_m *BlockingConnectionGater) BlockSubnet(ipnet *net.IPNet) error {
ret := _m.Called(ipnet)
if len(ret) == 0 {
panic("no return value specified for BlockSubnet")
}
var r0 error
if rf, ok := ret.Get(0).(func(*net.IPNet) error); ok {
r0 = rf(ipnet)
......@@ -159,6 +171,10 @@ func (_c *BlockingConnectionGater_BlockSubnet_Call) RunAndReturn(run func(*net.I
func (_m *BlockingConnectionGater) InterceptAccept(_a0 network.ConnMultiaddrs) bool {
ret := _m.Called(_a0)
if len(ret) == 0 {
panic("no return value specified for InterceptAccept")
}
var r0 bool
if rf, ok := ret.Get(0).(func(network.ConnMultiaddrs) bool); ok {
r0 = rf(_a0)
......@@ -201,6 +217,10 @@ func (_c *BlockingConnectionGater_InterceptAccept_Call) RunAndReturn(run func(ne
func (_m *BlockingConnectionGater) InterceptAddrDial(_a0 peer.ID, _a1 multiaddr.Multiaddr) bool {
ret := _m.Called(_a0, _a1)
if len(ret) == 0 {
panic("no return value specified for InterceptAddrDial")
}
var r0 bool
if rf, ok := ret.Get(0).(func(peer.ID, multiaddr.Multiaddr) bool); ok {
r0 = rf(_a0, _a1)
......@@ -244,6 +264,10 @@ func (_c *BlockingConnectionGater_InterceptAddrDial_Call) RunAndReturn(run func(
func (_m *BlockingConnectionGater) InterceptPeerDial(p peer.ID) bool {
ret := _m.Called(p)
if len(ret) == 0 {
panic("no return value specified for InterceptPeerDial")
}
var r0 bool
if rf, ok := ret.Get(0).(func(peer.ID) bool); ok {
r0 = rf(p)
......@@ -286,6 +310,10 @@ func (_c *BlockingConnectionGater_InterceptPeerDial_Call) RunAndReturn(run func(
func (_m *BlockingConnectionGater) InterceptSecured(_a0 network.Direction, _a1 peer.ID, _a2 network.ConnMultiaddrs) bool {
ret := _m.Called(_a0, _a1, _a2)
if len(ret) == 0 {
panic("no return value specified for InterceptSecured")
}
var r0 bool
if rf, ok := ret.Get(0).(func(network.Direction, peer.ID, network.ConnMultiaddrs) bool); ok {
r0 = rf(_a0, _a1, _a2)
......@@ -330,6 +358,10 @@ func (_c *BlockingConnectionGater_InterceptSecured_Call) RunAndReturn(run func(n
func (_m *BlockingConnectionGater) InterceptUpgraded(_a0 network.Conn) (bool, control.DisconnectReason) {
ret := _m.Called(_a0)
if len(ret) == 0 {
panic("no return value specified for InterceptUpgraded")
}
var r0 bool
var r1 control.DisconnectReason
if rf, ok := ret.Get(0).(func(network.Conn) (bool, control.DisconnectReason)); ok {
......@@ -382,6 +414,10 @@ func (_c *BlockingConnectionGater_InterceptUpgraded_Call) RunAndReturn(run func(
func (_m *BlockingConnectionGater) ListBlockedAddrs() []net.IP {
ret := _m.Called()
if len(ret) == 0 {
panic("no return value specified for ListBlockedAddrs")
}
var r0 []net.IP
if rf, ok := ret.Get(0).(func() []net.IP); ok {
r0 = rf()
......@@ -425,6 +461,10 @@ func (_c *BlockingConnectionGater_ListBlockedAddrs_Call) RunAndReturn(run func()
func (_m *BlockingConnectionGater) ListBlockedPeers() []peer.ID {
ret := _m.Called()
if len(ret) == 0 {
panic("no return value specified for ListBlockedPeers")
}
var r0 []peer.ID
if rf, ok := ret.Get(0).(func() []peer.ID); ok {
r0 = rf()
......@@ -468,6 +508,10 @@ func (_c *BlockingConnectionGater_ListBlockedPeers_Call) RunAndReturn(run func()
func (_m *BlockingConnectionGater) ListBlockedSubnets() []*net.IPNet {
ret := _m.Called()
if len(ret) == 0 {
panic("no return value specified for ListBlockedSubnets")
}
var r0 []*net.IPNet
if rf, ok := ret.Get(0).(func() []*net.IPNet); ok {
r0 = rf()
......@@ -511,6 +555,10 @@ func (_c *BlockingConnectionGater_ListBlockedSubnets_Call) RunAndReturn(run func
func (_m *BlockingConnectionGater) UnblockAddr(ip net.IP) error {
ret := _m.Called(ip)
if len(ret) == 0 {
panic("no return value specified for UnblockAddr")
}
var r0 error
if rf, ok := ret.Get(0).(func(net.IP) error); ok {
r0 = rf(ip)
......@@ -553,6 +601,10 @@ func (_c *BlockingConnectionGater_UnblockAddr_Call) RunAndReturn(run func(net.IP
func (_m *BlockingConnectionGater) UnblockPeer(p peer.ID) error {
ret := _m.Called(p)
if len(ret) == 0 {
panic("no return value specified for UnblockPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(peer.ID) error); ok {
r0 = rf(p)
......@@ -595,6 +647,10 @@ func (_c *BlockingConnectionGater_UnblockPeer_Call) RunAndReturn(run func(peer.I
func (_m *BlockingConnectionGater) UnblockSubnet(ipnet *net.IPNet) error {
ret := _m.Called(ipnet)
if len(ret) == 0 {
panic("no return value specified for UnblockSubnet")
}
var r0 error
if rf, ok := ret.Get(0).(func(*net.IPNet) error); ok {
r0 = rf(ipnet)
......@@ -633,13 +689,12 @@ func (_c *BlockingConnectionGater_UnblockSubnet_Call) RunAndReturn(run func(*net
return _c
}
type mockConstructorTestingTNewBlockingConnectionGater interface {
// NewBlockingConnectionGater creates a new instance of BlockingConnectionGater. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewBlockingConnectionGater(t interface {
mock.TestingT
Cleanup(func())
}
// NewBlockingConnectionGater creates a new instance of BlockingConnectionGater. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewBlockingConnectionGater(t mockConstructorTestingTNewBlockingConnectionGater) *BlockingConnectionGater {
}) *BlockingConnectionGater {
mock := &BlockingConnectionGater{}
mock.Mock.Test(t)
......
op-node/p2p/gating/mocks/ExpiryStore.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -29,6 +29,10 @@ func (_m *ExpiryStore) EXPECT() *ExpiryStore_Expecter {
func (_m *ExpiryStore) GetIPBanExpiration(ip net.IP) (time.Time, error) {
ret := _m.Called(ip)
if len(ret) == 0 {
panic("no return value specified for GetIPBanExpiration")
}
var r0 time.Time
var r1 error
if rf, ok := ret.Get(0).(func(net.IP) (time.Time, error)); ok {
......@@ -81,6 +85,10 @@ func (_c *ExpiryStore_GetIPBanExpiration_Call) RunAndReturn(run func(net.IP) (ti
func (_m *ExpiryStore) GetPeerBanExpiration(id peer.ID) (time.Time, error) {
ret := _m.Called(id)
if len(ret) == 0 {
panic("no return value specified for GetPeerBanExpiration")
}
var r0 time.Time
var r1 error
if rf, ok := ret.Get(0).(func(peer.ID) (time.Time, error)); ok {
......@@ -133,6 +141,10 @@ func (_c *ExpiryStore_GetPeerBanExpiration_Call) RunAndReturn(run func(peer.ID)
func (_m *ExpiryStore) SetIPBanExpiration(ip net.IP, expiry time.Time) error {
ret := _m.Called(ip, expiry)
if len(ret) == 0 {
panic("no return value specified for SetIPBanExpiration")
}
var r0 error
if rf, ok := ret.Get(0).(func(net.IP, time.Time) error); ok {
r0 = rf(ip, expiry)
......@@ -176,6 +188,10 @@ func (_c *ExpiryStore_SetIPBanExpiration_Call) RunAndReturn(run func(net.IP, tim
func (_m *ExpiryStore) SetPeerBanExpiration(id peer.ID, expiry time.Time) error {
ret := _m.Called(id, expiry)
if len(ret) == 0 {
panic("no return value specified for SetPeerBanExpiration")
}
var r0 error
if rf, ok := ret.Get(0).(func(peer.ID, time.Time) error); ok {
r0 = rf(id, expiry)
......@@ -215,13 +231,12 @@ func (_c *ExpiryStore_SetPeerBanExpiration_Call) RunAndReturn(run func(peer.ID,
return _c
}
type mockConstructorTestingTNewExpiryStore interface {
// NewExpiryStore creates a new instance of ExpiryStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewExpiryStore(t interface {
mock.TestingT
Cleanup(func())
}
// NewExpiryStore creates a new instance of ExpiryStore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewExpiryStore(t mockConstructorTestingTNewExpiryStore) *ExpiryStore {
}) *ExpiryStore {
mock := &ExpiryStore{}
mock.Mock.Test(t)
......
op-node/p2p/gating/mocks/Scores.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -24,6 +24,10 @@ func (_m *Scores) EXPECT() *Scores_Expecter {
func (_m *Scores) GetPeerScore(id peer.ID) (float64, error) {
ret := _m.Called(id)
if len(ret) == 0 {
panic("no return value specified for GetPeerScore")
}
var r0 float64
var r1 error
if rf, ok := ret.Get(0).(func(peer.ID) (float64, error)); ok {
......@@ -72,13 +76,12 @@ func (_c *Scores_GetPeerScore_Call) RunAndReturn(run func(peer.ID) (float64, err
return _c
}
type mockConstructorTestingTNewScores interface {
// NewScores creates a new instance of Scores. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewScores(t interface {
mock.TestingT
Cleanup(func())
}
// NewScores creates a new instance of Scores. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewScores(t mockConstructorTestingTNewScores) *Scores {
}) *Scores {
mock := &Scores{}
mock.Mock.Test(t)
......
op-node/p2p/mocks/API.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -32,6 +32,10 @@ func (_m *API) EXPECT() *API_Expecter {
func (_m *API) BlockAddr(ctx context.Context, ip net.IP) error {
ret := _m.Called(ctx, ip)
if len(ret) == 0 {
panic("no return value specified for BlockAddr")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, net.IP) error); ok {
r0 = rf(ctx, ip)
......@@ -75,6 +79,10 @@ func (_c *API_BlockAddr_Call) RunAndReturn(run func(context.Context, net.IP) err
func (_m *API) BlockPeer(ctx context.Context, p peer.ID) error {
ret := _m.Called(ctx, p)
if len(ret) == 0 {
panic("no return value specified for BlockPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, peer.ID) error); ok {
r0 = rf(ctx, p)
......@@ -118,6 +126,10 @@ func (_c *API_BlockPeer_Call) RunAndReturn(run func(context.Context, peer.ID) er
func (_m *API) BlockSubnet(ctx context.Context, ipnet *net.IPNet) error {
ret := _m.Called(ctx, ipnet)
if len(ret) == 0 {
panic("no return value specified for BlockSubnet")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, *net.IPNet) error); ok {
r0 = rf(ctx, ipnet)
......@@ -161,6 +173,10 @@ func (_c *API_BlockSubnet_Call) RunAndReturn(run func(context.Context, *net.IPNe
func (_m *API) ConnectPeer(ctx context.Context, addr string) error {
ret := _m.Called(ctx, addr)
if len(ret) == 0 {
panic("no return value specified for ConnectPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, string) error); ok {
r0 = rf(ctx, addr)
......@@ -204,6 +220,10 @@ func (_c *API_ConnectPeer_Call) RunAndReturn(run func(context.Context, string) e
func (_m *API) DisconnectPeer(ctx context.Context, id peer.ID) error {
ret := _m.Called(ctx, id)
if len(ret) == 0 {
panic("no return value specified for DisconnectPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, peer.ID) error); ok {
r0 = rf(ctx, id)
......@@ -247,6 +267,10 @@ func (_c *API_DisconnectPeer_Call) RunAndReturn(run func(context.Context, peer.I
func (_m *API) DiscoveryTable(ctx context.Context) ([]*enode.Node, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for DiscoveryTable")
}
var r0 []*enode.Node
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) ([]*enode.Node, error)); ok {
......@@ -301,6 +325,10 @@ func (_c *API_DiscoveryTable_Call) RunAndReturn(run func(context.Context) ([]*en
func (_m *API) ListBlockedAddrs(ctx context.Context) ([]net.IP, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for ListBlockedAddrs")
}
var r0 []net.IP
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) ([]net.IP, error)); ok {
......@@ -355,6 +383,10 @@ func (_c *API_ListBlockedAddrs_Call) RunAndReturn(run func(context.Context) ([]n
func (_m *API) ListBlockedPeers(ctx context.Context) ([]peer.ID, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for ListBlockedPeers")
}
var r0 []peer.ID
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) ([]peer.ID, error)); ok {
......@@ -409,6 +441,10 @@ func (_c *API_ListBlockedPeers_Call) RunAndReturn(run func(context.Context) ([]p
func (_m *API) ListBlockedSubnets(ctx context.Context) ([]*net.IPNet, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for ListBlockedSubnets")
}
var r0 []*net.IPNet
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) ([]*net.IPNet, error)); ok {
......@@ -463,6 +499,10 @@ func (_c *API_ListBlockedSubnets_Call) RunAndReturn(run func(context.Context) ([
func (_m *API) PeerStats(ctx context.Context) (*p2p.PeerStats, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for PeerStats")
}
var r0 *p2p.PeerStats
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) (*p2p.PeerStats, error)); ok {
......@@ -517,6 +557,10 @@ func (_c *API_PeerStats_Call) RunAndReturn(run func(context.Context) (*p2p.PeerS
func (_m *API) Peers(ctx context.Context, connected bool) (*p2p.PeerDump, error) {
ret := _m.Called(ctx, connected)
if len(ret) == 0 {
panic("no return value specified for Peers")
}
var r0 *p2p.PeerDump
var r1 error
if rf, ok := ret.Get(0).(func(context.Context, bool) (*p2p.PeerDump, error)); ok {
......@@ -572,6 +616,10 @@ func (_c *API_Peers_Call) RunAndReturn(run func(context.Context, bool) (*p2p.Pee
func (_m *API) ProtectPeer(ctx context.Context, p peer.ID) error {
ret := _m.Called(ctx, p)
if len(ret) == 0 {
panic("no return value specified for ProtectPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, peer.ID) error); ok {
r0 = rf(ctx, p)
......@@ -615,6 +663,10 @@ func (_c *API_ProtectPeer_Call) RunAndReturn(run func(context.Context, peer.ID)
func (_m *API) Self(ctx context.Context) (*p2p.PeerInfo, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for Self")
}
var r0 *p2p.PeerInfo
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) (*p2p.PeerInfo, error)); ok {
......@@ -669,6 +721,10 @@ func (_c *API_Self_Call) RunAndReturn(run func(context.Context) (*p2p.PeerInfo,
func (_m *API) UnblockAddr(ctx context.Context, ip net.IP) error {
ret := _m.Called(ctx, ip)
if len(ret) == 0 {
panic("no return value specified for UnblockAddr")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, net.IP) error); ok {
r0 = rf(ctx, ip)
......@@ -712,6 +768,10 @@ func (_c *API_UnblockAddr_Call) RunAndReturn(run func(context.Context, net.IP) e
func (_m *API) UnblockPeer(ctx context.Context, p peer.ID) error {
ret := _m.Called(ctx, p)
if len(ret) == 0 {
panic("no return value specified for UnblockPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, peer.ID) error); ok {
r0 = rf(ctx, p)
......@@ -755,6 +815,10 @@ func (_c *API_UnblockPeer_Call) RunAndReturn(run func(context.Context, peer.ID)
func (_m *API) UnblockSubnet(ctx context.Context, ipnet *net.IPNet) error {
ret := _m.Called(ctx, ipnet)
if len(ret) == 0 {
panic("no return value specified for UnblockSubnet")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, *net.IPNet) error); ok {
r0 = rf(ctx, ipnet)
......@@ -798,6 +862,10 @@ func (_c *API_UnblockSubnet_Call) RunAndReturn(run func(context.Context, *net.IP
func (_m *API) UnprotectPeer(ctx context.Context, p peer.ID) error {
ret := _m.Called(ctx, p)
if len(ret) == 0 {
panic("no return value specified for UnprotectPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(context.Context, peer.ID) error); ok {
r0 = rf(ctx, p)
......@@ -837,13 +905,12 @@ func (_c *API_UnprotectPeer_Call) RunAndReturn(run func(context.Context, peer.ID
return _c
}
type mockConstructorTestingTNewAPI interface {
// NewAPI creates a new instance of API. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewAPI(t interface {
mock.TestingT
Cleanup(func())
}
// NewAPI creates a new instance of API. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewAPI(t mockConstructorTestingTNewAPI) *API {
}) *API {
mock := &API{}
mock.Mock.Test(t)
......
op-node/p2p/mocks/GossipMetricer.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -14,13 +14,12 @@ func (_m *GossipMetricer) RecordGossipEvent(evType int32) {
_m.Called(evType)
}
type mockConstructorTestingTNewGossipMetricer interface {
// NewGossipMetricer creates a new instance of GossipMetricer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewGossipMetricer(t interface {
mock.TestingT
Cleanup(func())
}
// NewGossipMetricer creates a new instance of GossipMetricer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewGossipMetricer(t mockConstructorTestingTNewGossipMetricer) *GossipMetricer {
}) *GossipMetricer {
mock := &GossipMetricer{}
mock.Mock.Test(t)
......
op-node/p2p/mocks/Peerstore.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -19,6 +19,10 @@ type Peerstore struct {
func (_m *Peerstore) PeerInfo(_a0 peer.ID) peer.AddrInfo {
ret := _m.Called(_a0)
if len(ret) == 0 {
panic("no return value specified for PeerInfo")
}
var r0 peer.AddrInfo
if rf, ok := ret.Get(0).(func(peer.ID) peer.AddrInfo); ok {
r0 = rf(_a0)
......@@ -33,6 +37,10 @@ func (_m *Peerstore) PeerInfo(_a0 peer.ID) peer.AddrInfo {
func (_m *Peerstore) Peers() peer.IDSlice {
ret := _m.Called()
if len(ret) == 0 {
panic("no return value specified for Peers")
}
var r0 peer.IDSlice
if rf, ok := ret.Get(0).(func() peer.IDSlice); ok {
r0 = rf()
......@@ -49,6 +57,10 @@ func (_m *Peerstore) Peers() peer.IDSlice {
func (_m *Peerstore) SetScore(id peer.ID, diff store.ScoreDiff) (store.PeerScores, error) {
ret := _m.Called(id, diff)
if len(ret) == 0 {
panic("no return value specified for SetScore")
}
var r0 store.PeerScores
var r1 error
if rf, ok := ret.Get(0).(func(peer.ID, store.ScoreDiff) (store.PeerScores, error)); ok {
......@@ -69,13 +81,12 @@ func (_m *Peerstore) SetScore(id peer.ID, diff store.ScoreDiff) (store.PeerScore
return r0, r1
}
type mockConstructorTestingTNewPeerstore interface {
// NewPeerstore creates a new instance of Peerstore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewPeerstore(t interface {
mock.TestingT
Cleanup(func())
}
// NewPeerstore creates a new instance of Peerstore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewPeerstore(t mockConstructorTestingTNewPeerstore) *Peerstore {
}) *Peerstore {
mock := &Peerstore{}
mock.Mock.Test(t)
......
op-node/p2p/mocks/ScoreMetrics.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -18,13 +18,12 @@ func (_m *ScoreMetrics) SetPeerScores(_a0 []store.PeerScores) {
_m.Called(_a0)
}
type mockConstructorTestingTNewScoreMetrics interface {
// NewScoreMetrics creates a new instance of ScoreMetrics. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewScoreMetrics(t interface {
mock.TestingT
Cleanup(func())
}
// NewScoreMetrics creates a new instance of ScoreMetrics. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewScoreMetrics(t mockConstructorTestingTNewScoreMetrics) *ScoreMetrics {
}) *ScoreMetrics {
mock := &ScoreMetrics{}
mock.Mock.Test(t)
......
op-node/p2p/monitor/mocks/PeerManager.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -27,6 +27,10 @@ func (_m *PeerManager) EXPECT() *PeerManager_Expecter {
func (_m *PeerManager) BanPeer(_a0 peer.ID, _a1 time.Time) error {
ret := _m.Called(_a0, _a1)
if len(ret) == 0 {
panic("no return value specified for BanPeer")
}
var r0 error
if rf, ok := ret.Get(0).(func(peer.ID, time.Time) error); ok {
r0 = rf(_a0, _a1)
......@@ -70,6 +74,10 @@ func (_c *PeerManager_BanPeer_Call) RunAndReturn(run func(peer.ID, time.Time) er
func (_m *PeerManager) GetPeerScore(id peer.ID) (float64, error) {
ret := _m.Called(id)
if len(ret) == 0 {
panic("no return value specified for GetPeerScore")
}
var r0 float64
var r1 error
if rf, ok := ret.Get(0).(func(peer.ID) (float64, error)); ok {
......@@ -122,6 +130,10 @@ func (_c *PeerManager_GetPeerScore_Call) RunAndReturn(run func(peer.ID) (float64
func (_m *PeerManager) IsStatic(_a0 peer.ID) bool {
ret := _m.Called(_a0)
if len(ret) == 0 {
panic("no return value specified for IsStatic")
}
var r0 bool
if rf, ok := ret.Get(0).(func(peer.ID) bool); ok {
r0 = rf(_a0)
......@@ -164,6 +176,10 @@ func (_c *PeerManager_IsStatic_Call) RunAndReturn(run func(peer.ID) bool) *PeerM
func (_m *PeerManager) Peers() []peer.ID {
ret := _m.Called()
if len(ret) == 0 {
panic("no return value specified for Peers")
}
var r0 []peer.ID
if rf, ok := ret.Get(0).(func() []peer.ID); ok {
r0 = rf()
......@@ -203,13 +219,12 @@ func (_c *PeerManager_Peers_Call) RunAndReturn(run func() []peer.ID) *PeerManage
return _c
}
type mockConstructorTestingTNewPeerManager interface {
// NewPeerManager creates a new instance of PeerManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewPeerManager(t interface {
mock.TestingT
Cleanup(func())
}
// NewPeerManager creates a new instance of PeerManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewPeerManager(t mockConstructorTestingTNewPeerManager) *PeerManager {
}) *PeerManager {
mock := &PeerManager{}
mock.Mock.Test(t)
......
op-service/sources/mocks/BeaconClient.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -26,6 +26,10 @@ func (_m *BeaconClient) EXPECT() *BeaconClient_Expecter {
func (_m *BeaconClient) BeaconBlobSideCars(ctx context.Context, fetchAllSidecars bool, slot uint64, hashes []eth.IndexedBlobHash) (eth.APIGetBlobSidecarsResponse, error) {
ret := _m.Called(ctx, fetchAllSidecars, slot, hashes)
if len(ret) == 0 {
panic("no return value specified for BeaconBlobSideCars")
}
var r0 eth.APIGetBlobSidecarsResponse
var r1 error
if rf, ok := ret.Get(0).(func(context.Context, bool, uint64, []eth.IndexedBlobHash) (eth.APIGetBlobSidecarsResponse, error)); ok {
......@@ -81,6 +85,10 @@ func (_c *BeaconClient_BeaconBlobSideCars_Call) RunAndReturn(run func(context.Co
func (_m *BeaconClient) BeaconGenesis(ctx context.Context) (eth.APIGenesisResponse, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for BeaconGenesis")
}
var r0 eth.APIGenesisResponse
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) (eth.APIGenesisResponse, error)); ok {
......@@ -133,6 +141,10 @@ func (_c *BeaconClient_BeaconGenesis_Call) RunAndReturn(run func(context.Context
func (_m *BeaconClient) ConfigSpec(ctx context.Context) (eth.APIConfigResponse, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for ConfigSpec")
}
var r0 eth.APIConfigResponse
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) (eth.APIConfigResponse, error)); ok {
......@@ -185,6 +197,10 @@ func (_c *BeaconClient_ConfigSpec_Call) RunAndReturn(run func(context.Context) (
func (_m *BeaconClient) NodeVersion(ctx context.Context) (string, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for NodeVersion")
}
var r0 string
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) (string, error)); ok {
......@@ -233,13 +249,12 @@ func (_c *BeaconClient_NodeVersion_Call) RunAndReturn(run func(context.Context)
return _c
}
type mockConstructorTestingTNewBeaconClient interface {
// NewBeaconClient creates a new instance of BeaconClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewBeaconClient(t interface {
mock.TestingT
Cleanup(func())
}
// NewBeaconClient creates a new instance of BeaconClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewBeaconClient(t mockConstructorTestingTNewBeaconClient) *BeaconClient {
}) *BeaconClient {
mock := &BeaconClient{}
mock.Mock.Test(t)
......
op-service/sources/mocks/BlobSideCarsFetcher.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -26,6 +26,10 @@ func (_m *BlobSideCarsFetcher) EXPECT() *BlobSideCarsFetcher_Expecter {
func (_m *BlobSideCarsFetcher) BeaconBlobSideCars(ctx context.Context, fetchAllSidecars bool, slot uint64, hashes []eth.IndexedBlobHash) (eth.APIGetBlobSidecarsResponse, error) {
ret := _m.Called(ctx, fetchAllSidecars, slot, hashes)
if len(ret) == 0 {
panic("no return value specified for BeaconBlobSideCars")
}
var r0 eth.APIGetBlobSidecarsResponse
var r1 error
if rf, ok := ret.Get(0).(func(context.Context, bool, uint64, []eth.IndexedBlobHash) (eth.APIGetBlobSidecarsResponse, error)); ok {
......@@ -77,13 +81,12 @@ func (_c *BlobSideCarsFetcher_BeaconBlobSideCars_Call) RunAndReturn(run func(con
return _c
}
type mockConstructorTestingTNewBlobSideCarsFetcher interface {
// NewBlobSideCarsFetcher creates a new instance of BlobSideCarsFetcher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewBlobSideCarsFetcher(t interface {
mock.TestingT
Cleanup(func())
}
// NewBlobSideCarsFetcher creates a new instance of BlobSideCarsFetcher. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewBlobSideCarsFetcher(t mockConstructorTestingTNewBlobSideCarsFetcher) *BlobSideCarsFetcher {
}) *BlobSideCarsFetcher {
mock := &BlobSideCarsFetcher{}
mock.Mock.Test(t)
......
op-service/txmgr/mocks/TxManager.go
View file @ 7ff69403
// Code generated by mockery v2.28.1. DO NOT EDIT.
// Code generated by mockery v2.46.0. DO NOT EDIT.
package mocks
......@@ -26,6 +26,10 @@ type TxManager struct {
func (_m *TxManager) API() rpc.API {
ret := _m.Called()
if len(ret) == 0 {
panic("no return value specified for API")
}
var r0 rpc.API
if rf, ok := ret.Get(0).(func() rpc.API); ok {
r0 = rf()
......@@ -40,6 +44,10 @@ func (_m *TxManager) API() rpc.API {
func (_m *TxManager) BlockNumber(ctx context.Context) (uint64, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for BlockNumber")
}
var r0 uint64
var r1 error
if rf, ok := ret.Get(0).(func(context.Context) (uint64, error)); ok {
......@@ -69,6 +77,10 @@ func (_m *TxManager) Close() {
func (_m *TxManager) From() common.Address {
ret := _m.Called()
if len(ret) == 0 {
panic("no return value specified for From")
}
var r0 common.Address
if rf, ok := ret.Get(0).(func() common.Address); ok {
r0 = rf()
......@@ -85,6 +97,10 @@ func (_m *TxManager) From() common.Address {
func (_m *TxManager) IsClosed() bool {
ret := _m.Called()
if len(ret) == 0 {
panic("no return value specified for IsClosed")
}
var r0 bool
if rf, ok := ret.Get(0).(func() bool); ok {
r0 = rf()
......@@ -99,6 +115,10 @@ func (_m *TxManager) IsClosed() bool {
func (_m *TxManager) Send(ctx context.Context, candidate txmgr.TxCandidate) (*types.Receipt, error) {
ret := _m.Called(ctx, candidate)
if len(ret) == 0 {
panic("no return value specified for Send")
}
var r0 *types.Receipt
var r1 error
if rf, ok := ret.Get(0).(func(context.Context, txmgr.TxCandidate) (*types.Receipt, error)); ok {
......@@ -130,6 +150,10 @@ func (_m *TxManager) SendAsync(ctx context.Context, candidate txmgr.TxCandidate,
func (_m *TxManager) SuggestGasPriceCaps(ctx context.Context) (*big.Int, *big.Int, *big.Int, error) {
ret := _m.Called(ctx)
if len(ret) == 0 {
panic("no return value specified for SuggestGasPriceCaps")
}
var r0 *big.Int
var r1 *big.Int
var r2 *big.Int
......@@ -170,13 +194,12 @@ func (_m *TxManager) SuggestGasPriceCaps(ctx context.Context) (*big.Int, *big.In
return r0, r1, r2, r3
}
type mockConstructorTestingTNewTxManager interface {
// NewTxManager creates a new instance of TxManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewTxManager(t interface {
mock.TestingT
Cleanup(func())
}
// NewTxManager creates a new instance of TxManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewTxManager(t mockConstructorTestingTNewTxManager) *TxManager {
}) *TxManager {
mock := &TxManager{}
mock.Mock.Test(t)
......
ops/docker/ci-builder/Dockerfile
View file @ 7ff69403
......@@ -54,10 +54,10 @@ COPY ./versions.json ./versions.json
RUN go install github.com/ethereum/go-ethereum/cmd/abigen@$(jq -r .abigen < versions.json)
RUN go install github.com/ethereum/go-ethereum/cmd/geth@$(jq -r .geth < versions.json)
RUN go install gotest.tools/gotestsum@v1.11.0
RUN go install github.com/vektra/mockery/v2@v2.28.1
RUN go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.54.2
RUN go install github.com/mikefarah/yq/v4@v4.43.1
RUN go install gotest.tools/gotestsum@v1.12.0
RUN go install github.com/vektra/mockery/v2@v2.46.0
RUN go install github.com/golangci/golangci-lint/cmd/golangci-lint@v1.61.0
RUN go install github.com/mikefarah/yq/v4@v4.44.3
# Strip binaries to reduce size
RUN strip /go/bin/gotestsum && \
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment