-
Notifications
You must be signed in to change notification settings - Fork 175
/
local_gossip_sub_router_metrics.go
105 lines (82 loc) · 3.69 KB
/
local_gossip_sub_router_metrics.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
// Code generated by mockery v2.21.4. DO NOT EDIT.
package mock
import mock "github.com/stretchr/testify/mock"
// LocalGossipSubRouterMetrics is an autogenerated mock type for the LocalGossipSubRouterMetrics type
type LocalGossipSubRouterMetrics struct {
mock.Mock
}
// OnLocalMeshSizeUpdated provides a mock function with given fields: topic, size
func (_m *LocalGossipSubRouterMetrics) OnLocalMeshSizeUpdated(topic string, size int) {
_m.Called(topic, size)
}
// OnLocalPeerJoinedTopic provides a mock function with given fields:
func (_m *LocalGossipSubRouterMetrics) OnLocalPeerJoinedTopic() {
_m.Called()
}
// OnLocalPeerLeftTopic provides a mock function with given fields:
func (_m *LocalGossipSubRouterMetrics) OnLocalPeerLeftTopic() {
_m.Called()
}
// OnMessageDeliveredToAllSubscribers provides a mock function with given fields: size
func (_m *LocalGossipSubRouterMetrics) OnMessageDeliveredToAllSubscribers(size int) {
_m.Called(size)
}
// OnMessageDuplicate provides a mock function with given fields: size
func (_m *LocalGossipSubRouterMetrics) OnMessageDuplicate(size int) {
_m.Called(size)
}
// OnMessageEnteredValidation provides a mock function with given fields: size
func (_m *LocalGossipSubRouterMetrics) OnMessageEnteredValidation(size int) {
_m.Called(size)
}
// OnMessageRejected provides a mock function with given fields: size, reason
func (_m *LocalGossipSubRouterMetrics) OnMessageRejected(size int, reason string) {
_m.Called(size, reason)
}
// OnOutboundRpcDropped provides a mock function with given fields:
func (_m *LocalGossipSubRouterMetrics) OnOutboundRpcDropped() {
_m.Called()
}
// OnPeerAddedToProtocol provides a mock function with given fields: protocol
func (_m *LocalGossipSubRouterMetrics) OnPeerAddedToProtocol(protocol string) {
_m.Called(protocol)
}
// OnPeerGraftTopic provides a mock function with given fields: topic
func (_m *LocalGossipSubRouterMetrics) OnPeerGraftTopic(topic string) {
_m.Called(topic)
}
// OnPeerPruneTopic provides a mock function with given fields: topic
func (_m *LocalGossipSubRouterMetrics) OnPeerPruneTopic(topic string) {
_m.Called(topic)
}
// OnPeerRemovedFromProtocol provides a mock function with given fields:
func (_m *LocalGossipSubRouterMetrics) OnPeerRemovedFromProtocol() {
_m.Called()
}
// OnPeerThrottled provides a mock function with given fields:
func (_m *LocalGossipSubRouterMetrics) OnPeerThrottled() {
_m.Called()
}
// OnRpcReceived provides a mock function with given fields: msgCount, iHaveCount, iWantCount, graftCount, pruneCount
func (_m *LocalGossipSubRouterMetrics) OnRpcReceived(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int) {
_m.Called(msgCount, iHaveCount, iWantCount, graftCount, pruneCount)
}
// OnRpcSent provides a mock function with given fields: msgCount, iHaveCount, iWantCount, graftCount, pruneCount
func (_m *LocalGossipSubRouterMetrics) OnRpcSent(msgCount int, iHaveCount int, iWantCount int, graftCount int, pruneCount int) {
_m.Called(msgCount, iHaveCount, iWantCount, graftCount, pruneCount)
}
// OnUndeliveredMessage provides a mock function with given fields:
func (_m *LocalGossipSubRouterMetrics) OnUndeliveredMessage() {
_m.Called()
}
type mockConstructorTestingTNewLocalGossipSubRouterMetrics interface {
mock.TestingT
Cleanup(func())
}
// NewLocalGossipSubRouterMetrics creates a new instance of LocalGossipSubRouterMetrics. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func NewLocalGossipSubRouterMetrics(t mockConstructorTestingTNewLocalGossipSubRouterMetrics) *LocalGossipSubRouterMetrics {
mock := &LocalGossipSubRouterMetrics{}
mock.Mock.Test(t)
t.Cleanup(func() { mock.AssertExpectations(t) })
return mock
}