-
Notifications
You must be signed in to change notification settings - Fork 211
/
publisher.go
134 lines (111 loc) · 4.29 KB
/
publisher.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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
// Code generated by MockGen. DO NOT EDIT.
// Source: ./pubsub.go
// Package mocks is a generated GoMock package.
package mocks
import (
context "context"
reflect "reflect"
gomock "github.com/golang/mock/gomock"
pubsub "github.com/spacemeshos/go-spacemesh/p2p/pubsub"
)
// MockPublisher is a mock of Publisher interface.
type MockPublisher struct {
ctrl *gomock.Controller
recorder *MockPublisherMockRecorder
}
// MockPublisherMockRecorder is the mock recorder for MockPublisher.
type MockPublisherMockRecorder struct {
mock *MockPublisher
}
// NewMockPublisher creates a new mock instance.
func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher {
mock := &MockPublisher{ctrl: ctrl}
mock.recorder = &MockPublisherMockRecorder{mock}
return mock
}
// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder {
return m.recorder
}
// Publish mocks base method.
func (m *MockPublisher) Publish(arg0 context.Context, arg1 string, arg2 []byte) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "Publish", arg0, arg1, arg2)
ret0, _ := ret[0].(error)
return ret0
}
// Publish indicates an expected call of Publish.
func (mr *MockPublisherMockRecorder) Publish(arg0, arg1, arg2 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Publish", reflect.TypeOf((*MockPublisher)(nil).Publish), arg0, arg1, arg2)
}
// MockSubscriber is a mock of Subscriber interface.
type MockSubscriber struct {
ctrl *gomock.Controller
recorder *MockSubscriberMockRecorder
}
// MockSubscriberMockRecorder is the mock recorder for MockSubscriber.
type MockSubscriberMockRecorder struct {
mock *MockSubscriber
}
// NewMockSubscriber creates a new mock instance.
func NewMockSubscriber(ctrl *gomock.Controller) *MockSubscriber {
mock := &MockSubscriber{ctrl: ctrl}
mock.recorder = &MockSubscriberMockRecorder{mock}
return mock
}
// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder {
return m.recorder
}
// Register mocks base method.
func (m *MockSubscriber) Register(arg0 string, arg1 pubsub.GossipHandler) {
m.ctrl.T.Helper()
m.ctrl.Call(m, "Register", arg0, arg1)
}
// Register indicates an expected call of Register.
func (mr *MockSubscriberMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Register", reflect.TypeOf((*MockSubscriber)(nil).Register), arg0, arg1)
}
// MockPublishSubsciber is a mock of PublishSubsciber interface.
type MockPublishSubsciber struct {
ctrl *gomock.Controller
recorder *MockPublishSubsciberMockRecorder
}
// MockPublishSubsciberMockRecorder is the mock recorder for MockPublishSubsciber.
type MockPublishSubsciberMockRecorder struct {
mock *MockPublishSubsciber
}
// NewMockPublishSubsciber creates a new mock instance.
func NewMockPublishSubsciber(ctrl *gomock.Controller) *MockPublishSubsciber {
mock := &MockPublishSubsciber{ctrl: ctrl}
mock.recorder = &MockPublishSubsciberMockRecorder{mock}
return mock
}
// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockPublishSubsciber) EXPECT() *MockPublishSubsciberMockRecorder {
return m.recorder
}
// Publish mocks base method.
func (m *MockPublishSubsciber) Publish(arg0 context.Context, arg1 string, arg2 []byte) error {
m.ctrl.T.Helper()
ret := m.ctrl.Call(m, "Publish", arg0, arg1, arg2)
ret0, _ := ret[0].(error)
return ret0
}
// Publish indicates an expected call of Publish.
func (mr *MockPublishSubsciberMockRecorder) Publish(arg0, arg1, arg2 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Publish", reflect.TypeOf((*MockPublishSubsciber)(nil).Publish), arg0, arg1, arg2)
}
// Register mocks base method.
func (m *MockPublishSubsciber) Register(arg0 string, arg1 pubsub.GossipHandler) {
m.ctrl.T.Helper()
m.ctrl.Call(m, "Register", arg0, arg1)
}
// Register indicates an expected call of Register.
func (mr *MockPublishSubsciberMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call {
mr.mock.ctrl.T.Helper()
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Register", reflect.TypeOf((*MockPublishSubsciber)(nil).Register), arg0, arg1)
}