func (m *MockUpstream) IsConnectedTo(arg0 []byte) bool {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "IsConnectedTo", arg0)
	ret0, _ := ret[0].(bool)
	return ret0
}
IsConnectedTo mocks base method
package mocks
import (
	reflect "reflect"
	time "time"
	gomock "github.com/golang/mock/gomock"
	blockdigest "github.com/bitmark-inc/bitmarkd/blockdigest"
	util "github.com/bitmark-inc/bitmarkd/util"
	zmqutil "github.com/bitmark-inc/bitmarkd/zmqutil"
)
type MockUpstream struct {
	ctrl     *gomock.Controller
	recorder *MockUpstreamMockRecorder
}
type MockUpstreamMockRecorder struct {
	mock *MockUpstream
}
func NewMockUpstream(ctrl *gomock.Controller) *MockUpstream {
	mock := &MockUpstream{ctrl: ctrl}
	mock.recorder = &MockUpstreamMockRecorder{mock}
	return mock
}
func (m *MockUpstream) EXPECT() *MockUpstreamMockRecorder {
	return m.recorder
}
func (m *MockUpstream) ActiveInThePast(arg0 time.Duration) bool {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ActiveInThePast", arg0)
	ret0, _ := ret[0].(bool)
	return ret0
}
func (mr *MockUpstreamMockRecorder) ActiveInThePast(arg0 interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ActiveInThePast", reflect.TypeOf((*MockUpstream)(nil).ActiveInThePast), arg0)
}
func (m *MockUpstream) CachedRemoteDigestOfLocalHeight() blockdigest.Digest {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CachedRemoteDigestOfLocalHeight")
	ret0, _ := ret[0].(blockdigest.Digest)
	return ret0
}
func (mr *MockUpstreamMockRecorder) CachedRemoteDigestOfLocalHeight() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CachedRemoteDigestOfLocalHeight", reflect.TypeOf((*MockUpstream)(nil).CachedRemoteDigestOfLocalHeight))
}
func (m *MockUpstream) CachedRemoteHeight() uint64 {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CachedRemoteHeight")
	ret0, _ := ret[0].(uint64)
	return ret0
}
func (mr *MockUpstreamMockRecorder) CachedRemoteHeight() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CachedRemoteHeight", reflect.TypeOf((*MockUpstream)(nil).CachedRemoteHeight))
}
func (m *MockUpstream) Connect(arg0 *util.Connection, arg1 []byte) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Connect", arg0, arg1)
	ret0, _ := ret[0].(error)
	return ret0
}
func (mr *MockUpstreamMockRecorder) Connect(arg0, arg1 interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Connect", reflect.TypeOf((*MockUpstream)(nil).Connect), arg0, arg1)
}
func (m *MockUpstream) ConnectedTo() *zmqutil.Connected {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ConnectedTo")
	ret0, _ := ret[0].(*zmqutil.Connected)
	return ret0
}
func (mr *MockUpstreamMockRecorder) ConnectedTo() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ConnectedTo", reflect.TypeOf((*MockUpstream)(nil).ConnectedTo))
}
func (m *MockUpstream) Destroy() {
	m.ctrl.T.Helper()
	m.ctrl.Call(m, "Destroy")
}
func (mr *MockUpstreamMockRecorder) Destroy() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Destroy", reflect.TypeOf((*MockUpstream)(nil).Destroy))
}
func (m *MockUpstream) GetBlockData(arg0 uint64) ([]byte, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetBlockData", arg0)
	ret0, _ := ret[0].([]byte)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}
func (mr *MockUpstreamMockRecorder) GetBlockData(arg0 interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetBlockData", reflect.TypeOf((*MockUpstream)(nil).GetBlockData), arg0)
}
func (m *MockUpstream) IsConnected() bool {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "IsConnected")
	ret0, _ := ret[0].(bool)
	return ret0
}
func (mr *MockUpstreamMockRecorder) IsConnected() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "IsConnected", reflect.TypeOf((*MockUpstream)(nil).IsConnected))
}