Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type MockBroadcast
- type MockBroadcastMockRecorder
- type MockConn
- func (m *MockConn) Close() error
- func (m *MockConn) EXPECT() *MockConnMockRecorder
- func (m *MockConn) LocalAddr() net.Addr
- func (m *MockConn) Read(b []byte) (int, error)
- func (m *MockConn) RemoteAddr() net.Addr
- func (m *MockConn) SetDeadline(t time.Time) error
- func (m *MockConn) SetReadDeadline(t time.Time) error
- func (m *MockConn) SetWriteDeadline(t time.Time) error
- func (m *MockConn) Write(b []byte) (int, error)
- type MockConnMockRecorder
- func (mr *MockConnMockRecorder) Close() *gomock.Call
- func (mr *MockConnMockRecorder) LocalAddr() *gomock.Call
- func (mr *MockConnMockRecorder) Read(b interface{}) *gomock.Call
- func (mr *MockConnMockRecorder) RemoteAddr() *gomock.Call
- func (mr *MockConnMockRecorder) SetDeadline(t interface{}) *gomock.Call
- func (mr *MockConnMockRecorder) SetReadDeadline(t interface{}) *gomock.Call
- func (mr *MockConnMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call
- func (mr *MockConnMockRecorder) Write(b interface{}) *gomock.Call
- type MockIDNSClient
- type MockIDNSClientMockRecorder
- type MockIMemberlist
- func (m *MockIMemberlist) AdvertiseAddr() string
- func (m *MockIMemberlist) Config() *memberlist.Config
- func (m *MockIMemberlist) EXPECT() *MockIMemberlistMockRecorder
- func (m *MockIMemberlist) GetHealthScore() int
- func (m *MockIMemberlist) Join(existing []string) (int, error)
- func (m *MockIMemberlist) Leave(timeout time.Duration) error
- func (m *MockIMemberlist) LocalNode() *memberlist.Node
- func (m *MockIMemberlist) Members() []*memberlist.Node
- func (m *MockIMemberlist) NumMembers() int
- func (m *MockIMemberlist) Ping(node string, addr net.Addr) (time.Duration, error)
- func (m *MockIMemberlist) ProtocolVersion() uint8
- func (m *MockIMemberlist) SendBestEffort(to *memberlist.Node, msg []byte) error
- func (m *MockIMemberlist) SendReliable(to *memberlist.Node, msg []byte) error
- func (m *MockIMemberlist) SendToAddress(a memberlist.Address, msg []byte) error
- func (m *MockIMemberlist) Shutdown() error
- func (m *MockIMemberlist) UpdateNode(timeout time.Duration) error
- type MockIMemberlistMockRecorder
- func (mr *MockIMemberlistMockRecorder) AdvertiseAddr() *gomock.Call
- func (mr *MockIMemberlistMockRecorder) Config() *gomock.Call
- func (mr *MockIMemberlistMockRecorder) GetHealthScore() *gomock.Call
- func (mr *MockIMemberlistMockRecorder) Join(existing interface{}) *gomock.Call
- func (mr *MockIMemberlistMockRecorder) Leave(timeout interface{}) *gomock.Call
- func (mr *MockIMemberlistMockRecorder) LocalNode() *gomock.Call
- func (mr *MockIMemberlistMockRecorder) Members() *gomock.Call
- func (mr *MockIMemberlistMockRecorder) NumMembers() *gomock.Call
- func (mr *MockIMemberlistMockRecorder) Ping(node, addr interface{}) *gomock.Call
- func (mr *MockIMemberlistMockRecorder) ProtocolVersion() *gomock.Call
- func (mr *MockIMemberlistMockRecorder) SendBestEffort(to, msg interface{}) *gomock.Call
- func (mr *MockIMemberlistMockRecorder) SendReliable(to, msg interface{}) *gomock.Call
- func (mr *MockIMemberlistMockRecorder) SendToAddress(a, msg interface{}) *gomock.Call
- func (mr *MockIMemberlistMockRecorder) Shutdown() *gomock.Call
- func (mr *MockIMemberlistMockRecorder) UpdateNode(timeout interface{}) *gomock.Call
- type MockIngestionAwareTransport
- type MockIngestionAwareTransportMockRecorder
- type MockNamedBroadcast
- type MockNamedBroadcastMockRecorder
- type MockNodeAwareTransport
- func (m *MockNodeAwareTransport) DialAddressTimeout(addr memberlist.Address, timeout time.Duration) (net.Conn, error)
- func (m *MockNodeAwareTransport) DialTimeout(addr string, timeout time.Duration) (net.Conn, error)
- func (m *MockNodeAwareTransport) EXPECT() *MockNodeAwareTransportMockRecorder
- func (m *MockNodeAwareTransport) FinalAdvertiseAddr(ip string, port int) (string, int, error)
- func (m *MockNodeAwareTransport) PacketCh() <-chan *memberlist.Packet
- func (m *MockNodeAwareTransport) Shutdown() error
- func (m *MockNodeAwareTransport) StreamCh() <-chan net.Conn
- func (m *MockNodeAwareTransport) WriteTo(b []byte, addr string) (time.Time, error)
- func (m *MockNodeAwareTransport) WriteToAddress(b []byte, addr memberlist.Address) (time.Time, error)
- type MockNodeAwareTransportMockRecorder
- func (mr *MockNodeAwareTransportMockRecorder) DialAddressTimeout(addr, timeout interface{}) *gomock.Call
- func (mr *MockNodeAwareTransportMockRecorder) DialTimeout(addr, timeout interface{}) *gomock.Call
- func (mr *MockNodeAwareTransportMockRecorder) FinalAdvertiseAddr(ip, port interface{}) *gomock.Call
- func (mr *MockNodeAwareTransportMockRecorder) PacketCh() *gomock.Call
- func (mr *MockNodeAwareTransportMockRecorder) Shutdown() *gomock.Call
- func (mr *MockNodeAwareTransportMockRecorder) StreamCh() *gomock.Call
- func (mr *MockNodeAwareTransportMockRecorder) WriteTo(b, addr interface{}) *gomock.Call
- func (mr *MockNodeAwareTransportMockRecorder) WriteToAddress(b, addr interface{}) *gomock.Call
- type MockTransport
- func (m *MockTransport) DialTimeout(addr string, timeout time.Duration) (net.Conn, error)
- func (m *MockTransport) EXPECT() *MockTransportMockRecorder
- func (m *MockTransport) FinalAdvertiseAddr(ip string, port int) (string, int, error)
- func (m *MockTransport) PacketCh() <-chan *memberlist.Packet
- func (m *MockTransport) Shutdown() error
- func (m *MockTransport) StreamCh() <-chan net.Conn
- func (m *MockTransport) WriteTo(b []byte, addr string) (time.Time, error)
- type MockTransportMockRecorder
- func (mr *MockTransportMockRecorder) DialTimeout(addr, timeout interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) FinalAdvertiseAddr(ip, port interface{}) *gomock.Call
- func (mr *MockTransportMockRecorder) PacketCh() *gomock.Call
- func (mr *MockTransportMockRecorder) Shutdown() *gomock.Call
- func (mr *MockTransportMockRecorder) StreamCh() *gomock.Call
- func (mr *MockTransportMockRecorder) WriteTo(b, addr interface{}) *gomock.Call
- type MockUniqueBroadcast
- type MockUniqueBroadcastMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockBroadcast ¶
type MockBroadcast struct {
// contains filtered or unexported fields
}
MockBroadcast is a mock of Broadcast interface.
func NewMockBroadcast ¶
func NewMockBroadcast(ctrl *gomock.Controller) *MockBroadcast
NewMockBroadcast creates a new mock instance.
func (*MockBroadcast) EXPECT ¶
func (m *MockBroadcast) EXPECT() *MockBroadcastMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockBroadcast) Invalidates ¶
func (m *MockBroadcast) Invalidates(b memberlist.Broadcast) bool
Invalidates mocks base method.
type MockBroadcastMockRecorder ¶
type MockBroadcastMockRecorder struct {
// contains filtered or unexported fields
}
MockBroadcastMockRecorder is the mock recorder for MockBroadcast.
func (*MockBroadcastMockRecorder) Finished ¶
func (mr *MockBroadcastMockRecorder) Finished() *gomock.Call
Finished indicates an expected call of Finished.
func (*MockBroadcastMockRecorder) Invalidates ¶
func (mr *MockBroadcastMockRecorder) Invalidates(b interface{}) *gomock.Call
Invalidates indicates an expected call of Invalidates.
func (*MockBroadcastMockRecorder) Message ¶
func (mr *MockBroadcastMockRecorder) Message() *gomock.Call
Message indicates an expected call of Message.
type MockConn ¶
type MockConn struct {
// contains filtered or unexported fields
}
MockConn is a mock of Conn interface.
func NewMockConn ¶
func NewMockConn(ctrl *gomock.Controller) *MockConn
NewMockConn creates a new mock instance.
func (*MockConn) EXPECT ¶
func (m *MockConn) EXPECT() *MockConnMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConn) RemoteAddr ¶
RemoteAddr mocks base method.
func (*MockConn) SetDeadline ¶
SetDeadline mocks base method.
func (*MockConn) SetReadDeadline ¶
SetReadDeadline mocks base method.
func (*MockConn) SetWriteDeadline ¶
SetWriteDeadline mocks base method.
type MockConnMockRecorder ¶
type MockConnMockRecorder struct {
// contains filtered or unexported fields
}
MockConnMockRecorder is the mock recorder for MockConn.
func (*MockConnMockRecorder) Close ¶
func (mr *MockConnMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockConnMockRecorder) LocalAddr ¶
func (mr *MockConnMockRecorder) LocalAddr() *gomock.Call
LocalAddr indicates an expected call of LocalAddr.
func (*MockConnMockRecorder) Read ¶
func (mr *MockConnMockRecorder) Read(b interface{}) *gomock.Call
Read indicates an expected call of Read.
func (*MockConnMockRecorder) RemoteAddr ¶
func (mr *MockConnMockRecorder) RemoteAddr() *gomock.Call
RemoteAddr indicates an expected call of RemoteAddr.
func (*MockConnMockRecorder) SetDeadline ¶
func (mr *MockConnMockRecorder) SetDeadline(t interface{}) *gomock.Call
SetDeadline indicates an expected call of SetDeadline.
func (*MockConnMockRecorder) SetReadDeadline ¶
func (mr *MockConnMockRecorder) SetReadDeadline(t interface{}) *gomock.Call
SetReadDeadline indicates an expected call of SetReadDeadline.
func (*MockConnMockRecorder) SetWriteDeadline ¶
func (mr *MockConnMockRecorder) SetWriteDeadline(t interface{}) *gomock.Call
SetWriteDeadline indicates an expected call of SetWriteDeadline.
func (*MockConnMockRecorder) Write ¶
func (mr *MockConnMockRecorder) Write(b interface{}) *gomock.Call
Write indicates an expected call of Write.
type MockIDNSClient ¶
type MockIDNSClient struct {
// contains filtered or unexported fields
}
MockIDNSClient is a mock of IDNSClient interface.
func NewMockIDNSClient ¶
func NewMockIDNSClient(ctrl *gomock.Controller) *MockIDNSClient
NewMockIDNSClient creates a new mock instance.
func (*MockIDNSClient) EXPECT ¶
func (m *MockIDNSClient) EXPECT() *MockIDNSClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockIDNSClientMockRecorder ¶
type MockIDNSClientMockRecorder struct {
// contains filtered or unexported fields
}
MockIDNSClientMockRecorder is the mock recorder for MockIDNSClient.
func (*MockIDNSClientMockRecorder) Exchange ¶
func (mr *MockIDNSClientMockRecorder) Exchange(m, address interface{}) *gomock.Call
Exchange indicates an expected call of Exchange.
type MockIMemberlist ¶
type MockIMemberlist struct {
// contains filtered or unexported fields
}
MockIMemberlist is a mock of IMemberlist interface.
func NewMockIMemberlist ¶
func NewMockIMemberlist(ctrl *gomock.Controller) *MockIMemberlist
NewMockIMemberlist creates a new mock instance.
func (*MockIMemberlist) AdvertiseAddr ¶
func (m *MockIMemberlist) AdvertiseAddr() string
AdvertiseAddr mocks base method.
func (*MockIMemberlist) Config ¶
func (m *MockIMemberlist) Config() *memberlist.Config
Config mocks base method.
func (*MockIMemberlist) EXPECT ¶
func (m *MockIMemberlist) EXPECT() *MockIMemberlistMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIMemberlist) GetHealthScore ¶
func (m *MockIMemberlist) GetHealthScore() int
GetHealthScore mocks base method.
func (*MockIMemberlist) Join ¶
func (m *MockIMemberlist) Join(existing []string) (int, error)
Join mocks base method.
func (*MockIMemberlist) Leave ¶
func (m *MockIMemberlist) Leave(timeout time.Duration) error
Leave mocks base method.
func (*MockIMemberlist) LocalNode ¶
func (m *MockIMemberlist) LocalNode() *memberlist.Node
LocalNode mocks base method.
func (*MockIMemberlist) Members ¶
func (m *MockIMemberlist) Members() []*memberlist.Node
Members mocks base method.
func (*MockIMemberlist) NumMembers ¶
func (m *MockIMemberlist) NumMembers() int
NumMembers mocks base method.
func (*MockIMemberlist) ProtocolVersion ¶
func (m *MockIMemberlist) ProtocolVersion() uint8
ProtocolVersion mocks base method.
func (*MockIMemberlist) SendBestEffort ¶
func (m *MockIMemberlist) SendBestEffort(to *memberlist.Node, msg []byte) error
SendBestEffort mocks base method.
func (*MockIMemberlist) SendReliable ¶
func (m *MockIMemberlist) SendReliable(to *memberlist.Node, msg []byte) error
SendReliable mocks base method.
func (*MockIMemberlist) SendToAddress ¶
func (m *MockIMemberlist) SendToAddress(a memberlist.Address, msg []byte) error
SendToAddress mocks base method.
func (*MockIMemberlist) Shutdown ¶
func (m *MockIMemberlist) Shutdown() error
Shutdown mocks base method.
func (*MockIMemberlist) UpdateNode ¶
func (m *MockIMemberlist) UpdateNode(timeout time.Duration) error
UpdateNode mocks base method.
type MockIMemberlistMockRecorder ¶
type MockIMemberlistMockRecorder struct {
// contains filtered or unexported fields
}
MockIMemberlistMockRecorder is the mock recorder for MockIMemberlist.
func (*MockIMemberlistMockRecorder) AdvertiseAddr ¶
func (mr *MockIMemberlistMockRecorder) AdvertiseAddr() *gomock.Call
AdvertiseAddr indicates an expected call of AdvertiseAddr.
func (*MockIMemberlistMockRecorder) Config ¶
func (mr *MockIMemberlistMockRecorder) Config() *gomock.Call
Config indicates an expected call of Config.
func (*MockIMemberlistMockRecorder) GetHealthScore ¶
func (mr *MockIMemberlistMockRecorder) GetHealthScore() *gomock.Call
GetHealthScore indicates an expected call of GetHealthScore.
func (*MockIMemberlistMockRecorder) Join ¶
func (mr *MockIMemberlistMockRecorder) Join(existing interface{}) *gomock.Call
Join indicates an expected call of Join.
func (*MockIMemberlistMockRecorder) Leave ¶
func (mr *MockIMemberlistMockRecorder) Leave(timeout interface{}) *gomock.Call
Leave indicates an expected call of Leave.
func (*MockIMemberlistMockRecorder) LocalNode ¶
func (mr *MockIMemberlistMockRecorder) LocalNode() *gomock.Call
LocalNode indicates an expected call of LocalNode.
func (*MockIMemberlistMockRecorder) Members ¶
func (mr *MockIMemberlistMockRecorder) Members() *gomock.Call
Members indicates an expected call of Members.
func (*MockIMemberlistMockRecorder) NumMembers ¶
func (mr *MockIMemberlistMockRecorder) NumMembers() *gomock.Call
NumMembers indicates an expected call of NumMembers.
func (*MockIMemberlistMockRecorder) Ping ¶
func (mr *MockIMemberlistMockRecorder) Ping(node, addr interface{}) *gomock.Call
Ping indicates an expected call of Ping.
func (*MockIMemberlistMockRecorder) ProtocolVersion ¶
func (mr *MockIMemberlistMockRecorder) ProtocolVersion() *gomock.Call
ProtocolVersion indicates an expected call of ProtocolVersion.
func (*MockIMemberlistMockRecorder) SendBestEffort ¶
func (mr *MockIMemberlistMockRecorder) SendBestEffort(to, msg interface{}) *gomock.Call
SendBestEffort indicates an expected call of SendBestEffort.
func (*MockIMemberlistMockRecorder) SendReliable ¶
func (mr *MockIMemberlistMockRecorder) SendReliable(to, msg interface{}) *gomock.Call
SendReliable indicates an expected call of SendReliable.
func (*MockIMemberlistMockRecorder) SendToAddress ¶
func (mr *MockIMemberlistMockRecorder) SendToAddress(a, msg interface{}) *gomock.Call
SendToAddress indicates an expected call of SendToAddress.
func (*MockIMemberlistMockRecorder) Shutdown ¶
func (mr *MockIMemberlistMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*MockIMemberlistMockRecorder) UpdateNode ¶
func (mr *MockIMemberlistMockRecorder) UpdateNode(timeout interface{}) *gomock.Call
UpdateNode indicates an expected call of UpdateNode.
type MockIngestionAwareTransport ¶
type MockIngestionAwareTransport struct {
// contains filtered or unexported fields
}
MockIngestionAwareTransport is a mock of IngestionAwareTransport interface.
func NewMockIngestionAwareTransport ¶
func NewMockIngestionAwareTransport(ctrl *gomock.Controller) *MockIngestionAwareTransport
NewMockIngestionAwareTransport creates a new mock instance.
func (*MockIngestionAwareTransport) EXPECT ¶
func (m *MockIngestionAwareTransport) EXPECT() *MockIngestionAwareTransportMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIngestionAwareTransport) IngestPacket ¶
func (m *MockIngestionAwareTransport) IngestPacket(conn net.Conn, addr net.Addr, now time.Time, shouldClose bool) error
IngestPacket mocks base method.
func (*MockIngestionAwareTransport) IngestStream ¶
func (m *MockIngestionAwareTransport) IngestStream(conn net.Conn) error
IngestStream mocks base method.
type MockIngestionAwareTransportMockRecorder ¶
type MockIngestionAwareTransportMockRecorder struct {
// contains filtered or unexported fields
}
MockIngestionAwareTransportMockRecorder is the mock recorder for MockIngestionAwareTransport.
func (*MockIngestionAwareTransportMockRecorder) IngestPacket ¶
func (mr *MockIngestionAwareTransportMockRecorder) IngestPacket(conn, addr, now, shouldClose interface{}) *gomock.Call
IngestPacket indicates an expected call of IngestPacket.
func (*MockIngestionAwareTransportMockRecorder) IngestStream ¶
func (mr *MockIngestionAwareTransportMockRecorder) IngestStream(conn interface{}) *gomock.Call
IngestStream indicates an expected call of IngestStream.
type MockNamedBroadcast ¶
type MockNamedBroadcast struct {
// contains filtered or unexported fields
}
MockNamedBroadcast is a mock of NamedBroadcast interface.
func NewMockNamedBroadcast ¶
func NewMockNamedBroadcast(ctrl *gomock.Controller) *MockNamedBroadcast
NewMockNamedBroadcast creates a new mock instance.
func (*MockNamedBroadcast) EXPECT ¶
func (m *MockNamedBroadcast) EXPECT() *MockNamedBroadcastMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockNamedBroadcast) Finished ¶
func (m *MockNamedBroadcast) Finished()
Finished mocks base method.
func (*MockNamedBroadcast) Invalidates ¶
func (m *MockNamedBroadcast) Invalidates(b memberlist.Broadcast) bool
Invalidates mocks base method.
func (*MockNamedBroadcast) Message ¶
func (m *MockNamedBroadcast) Message() []byte
Message mocks base method.
func (*MockNamedBroadcast) Name ¶
func (m *MockNamedBroadcast) Name() string
Name mocks base method.
type MockNamedBroadcastMockRecorder ¶
type MockNamedBroadcastMockRecorder struct {
// contains filtered or unexported fields
}
MockNamedBroadcastMockRecorder is the mock recorder for MockNamedBroadcast.
func (*MockNamedBroadcastMockRecorder) Finished ¶
func (mr *MockNamedBroadcastMockRecorder) Finished() *gomock.Call
Finished indicates an expected call of Finished.
func (*MockNamedBroadcastMockRecorder) Invalidates ¶
func (mr *MockNamedBroadcastMockRecorder) Invalidates(b interface{}) *gomock.Call
Invalidates indicates an expected call of Invalidates.
func (*MockNamedBroadcastMockRecorder) Message ¶
func (mr *MockNamedBroadcastMockRecorder) Message() *gomock.Call
Message indicates an expected call of Message.
func (*MockNamedBroadcastMockRecorder) Name ¶
func (mr *MockNamedBroadcastMockRecorder) Name() *gomock.Call
Name indicates an expected call of Name.
type MockNodeAwareTransport ¶
type MockNodeAwareTransport struct {
// contains filtered or unexported fields
}
MockNodeAwareTransport is a mock of NodeAwareTransport interface.
func NewMockNodeAwareTransport ¶
func NewMockNodeAwareTransport(ctrl *gomock.Controller) *MockNodeAwareTransport
NewMockNodeAwareTransport creates a new mock instance.
func (*MockNodeAwareTransport) DialAddressTimeout ¶
func (m *MockNodeAwareTransport) DialAddressTimeout(addr memberlist.Address, timeout time.Duration) (net.Conn, error)
DialAddressTimeout mocks base method.
func (*MockNodeAwareTransport) DialTimeout ¶
DialTimeout mocks base method.
func (*MockNodeAwareTransport) EXPECT ¶
func (m *MockNodeAwareTransport) EXPECT() *MockNodeAwareTransportMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockNodeAwareTransport) FinalAdvertiseAddr ¶
FinalAdvertiseAddr mocks base method.
func (*MockNodeAwareTransport) PacketCh ¶
func (m *MockNodeAwareTransport) PacketCh() <-chan *memberlist.Packet
PacketCh mocks base method.
func (*MockNodeAwareTransport) Shutdown ¶
func (m *MockNodeAwareTransport) Shutdown() error
Shutdown mocks base method.
func (*MockNodeAwareTransport) StreamCh ¶
func (m *MockNodeAwareTransport) StreamCh() <-chan net.Conn
StreamCh mocks base method.
func (*MockNodeAwareTransport) WriteToAddress ¶
func (m *MockNodeAwareTransport) WriteToAddress(b []byte, addr memberlist.Address) (time.Time, error)
WriteToAddress mocks base method.
type MockNodeAwareTransportMockRecorder ¶
type MockNodeAwareTransportMockRecorder struct {
// contains filtered or unexported fields
}
MockNodeAwareTransportMockRecorder is the mock recorder for MockNodeAwareTransport.
func (*MockNodeAwareTransportMockRecorder) DialAddressTimeout ¶
func (mr *MockNodeAwareTransportMockRecorder) DialAddressTimeout(addr, timeout interface{}) *gomock.Call
DialAddressTimeout indicates an expected call of DialAddressTimeout.
func (*MockNodeAwareTransportMockRecorder) DialTimeout ¶
func (mr *MockNodeAwareTransportMockRecorder) DialTimeout(addr, timeout interface{}) *gomock.Call
DialTimeout indicates an expected call of DialTimeout.
func (*MockNodeAwareTransportMockRecorder) FinalAdvertiseAddr ¶
func (mr *MockNodeAwareTransportMockRecorder) FinalAdvertiseAddr(ip, port interface{}) *gomock.Call
FinalAdvertiseAddr indicates an expected call of FinalAdvertiseAddr.
func (*MockNodeAwareTransportMockRecorder) PacketCh ¶
func (mr *MockNodeAwareTransportMockRecorder) PacketCh() *gomock.Call
PacketCh indicates an expected call of PacketCh.
func (*MockNodeAwareTransportMockRecorder) Shutdown ¶
func (mr *MockNodeAwareTransportMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*MockNodeAwareTransportMockRecorder) StreamCh ¶
func (mr *MockNodeAwareTransportMockRecorder) StreamCh() *gomock.Call
StreamCh indicates an expected call of StreamCh.
func (*MockNodeAwareTransportMockRecorder) WriteTo ¶
func (mr *MockNodeAwareTransportMockRecorder) WriteTo(b, addr interface{}) *gomock.Call
WriteTo indicates an expected call of WriteTo.
func (*MockNodeAwareTransportMockRecorder) WriteToAddress ¶
func (mr *MockNodeAwareTransportMockRecorder) WriteToAddress(b, addr interface{}) *gomock.Call
WriteToAddress indicates an expected call of WriteToAddress.
type MockTransport ¶
type MockTransport struct {
// contains filtered or unexported fields
}
MockTransport is a mock of Transport interface.
func NewMockTransport ¶
func NewMockTransport(ctrl *gomock.Controller) *MockTransport
NewMockTransport creates a new mock instance.
func (*MockTransport) DialTimeout ¶
DialTimeout mocks base method.
func (*MockTransport) EXPECT ¶
func (m *MockTransport) EXPECT() *MockTransportMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTransport) FinalAdvertiseAddr ¶
FinalAdvertiseAddr mocks base method.
func (*MockTransport) PacketCh ¶
func (m *MockTransport) PacketCh() <-chan *memberlist.Packet
PacketCh mocks base method.
func (*MockTransport) Shutdown ¶
func (m *MockTransport) Shutdown() error
Shutdown mocks base method.
func (*MockTransport) StreamCh ¶
func (m *MockTransport) StreamCh() <-chan net.Conn
StreamCh mocks base method.
type MockTransportMockRecorder ¶
type MockTransportMockRecorder struct {
// contains filtered or unexported fields
}
MockTransportMockRecorder is the mock recorder for MockTransport.
func (*MockTransportMockRecorder) DialTimeout ¶
func (mr *MockTransportMockRecorder) DialTimeout(addr, timeout interface{}) *gomock.Call
DialTimeout indicates an expected call of DialTimeout.
func (*MockTransportMockRecorder) FinalAdvertiseAddr ¶
func (mr *MockTransportMockRecorder) FinalAdvertiseAddr(ip, port interface{}) *gomock.Call
FinalAdvertiseAddr indicates an expected call of FinalAdvertiseAddr.
func (*MockTransportMockRecorder) PacketCh ¶
func (mr *MockTransportMockRecorder) PacketCh() *gomock.Call
PacketCh indicates an expected call of PacketCh.
func (*MockTransportMockRecorder) Shutdown ¶
func (mr *MockTransportMockRecorder) Shutdown() *gomock.Call
Shutdown indicates an expected call of Shutdown.
func (*MockTransportMockRecorder) StreamCh ¶
func (mr *MockTransportMockRecorder) StreamCh() *gomock.Call
StreamCh indicates an expected call of StreamCh.
func (*MockTransportMockRecorder) WriteTo ¶
func (mr *MockTransportMockRecorder) WriteTo(b, addr interface{}) *gomock.Call
WriteTo indicates an expected call of WriteTo.
type MockUniqueBroadcast ¶
type MockUniqueBroadcast struct {
// contains filtered or unexported fields
}
MockUniqueBroadcast is a mock of UniqueBroadcast interface.
func NewMockUniqueBroadcast ¶
func NewMockUniqueBroadcast(ctrl *gomock.Controller) *MockUniqueBroadcast
NewMockUniqueBroadcast creates a new mock instance.
func (*MockUniqueBroadcast) EXPECT ¶
func (m *MockUniqueBroadcast) EXPECT() *MockUniqueBroadcastMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockUniqueBroadcast) Finished ¶
func (m *MockUniqueBroadcast) Finished()
Finished mocks base method.
func (*MockUniqueBroadcast) Invalidates ¶
func (m *MockUniqueBroadcast) Invalidates(b memberlist.Broadcast) bool
Invalidates mocks base method.
func (*MockUniqueBroadcast) Message ¶
func (m *MockUniqueBroadcast) Message() []byte
Message mocks base method.
func (*MockUniqueBroadcast) UniqueBroadcast ¶
func (m *MockUniqueBroadcast) UniqueBroadcast()
UniqueBroadcast mocks base method.
type MockUniqueBroadcastMockRecorder ¶
type MockUniqueBroadcastMockRecorder struct {
// contains filtered or unexported fields
}
MockUniqueBroadcastMockRecorder is the mock recorder for MockUniqueBroadcast.
func (*MockUniqueBroadcastMockRecorder) Finished ¶
func (mr *MockUniqueBroadcastMockRecorder) Finished() *gomock.Call
Finished indicates an expected call of Finished.
func (*MockUniqueBroadcastMockRecorder) Invalidates ¶
func (mr *MockUniqueBroadcastMockRecorder) Invalidates(b interface{}) *gomock.Call
Invalidates indicates an expected call of Invalidates.
func (*MockUniqueBroadcastMockRecorder) Message ¶
func (mr *MockUniqueBroadcastMockRecorder) Message() *gomock.Call
Message indicates an expected call of Message.
func (*MockUniqueBroadcastMockRecorder) UniqueBroadcast ¶
func (mr *MockUniqueBroadcastMockRecorder) UniqueBroadcast() *gomock.Call
UniqueBroadcast indicates an expected call of UniqueBroadcast.