// Code generated by moq; DO NOT EDIT. // github.com/matryer/moq package sentry import ( context "context" types "github.com/ledgerwatch/erigon-lib/gointerfaces/types" grpc "google.golang.org/grpc" emptypb "google.golang.org/protobuf/types/known/emptypb" sync "sync" ) // Ensure, that SentryServerMock does implement SentryServer. // If this is not the case, regenerate this file with moq. var _ SentryServer = &SentryServerMock{} // SentryServerMock is a mock implementation of SentryServer. // // func TestSomethingThatUsesSentryServer(t *testing.T) { // // // make and configure a mocked SentryServer // mockedSentryServer := &SentryServerMock{ // AddPeerFunc: func(contextMoqParam context.Context, addPeerRequest *AddPeerRequest) (*AddPeerReply, error) { // panic("mock out the AddPeer method") // }, // HandShakeFunc: func(contextMoqParam context.Context, empty *emptypb.Empty) (*HandShakeReply, error) { // panic("mock out the HandShake method") // }, // MessagesFunc: func(messagesRequest *MessagesRequest, sentry_MessagesServer Sentry_MessagesServer) error { // panic("mock out the Messages method") // }, // NodeInfoFunc: func(contextMoqParam context.Context, empty *emptypb.Empty) (*types.NodeInfoReply, error) { // panic("mock out the NodeInfo method") // }, // PeerByIdFunc: func(contextMoqParam context.Context, peerByIdRequest *PeerByIdRequest) (*PeerByIdReply, error) { // panic("mock out the PeerById method") // }, // PeerCountFunc: func(contextMoqParam context.Context, peerCountRequest *PeerCountRequest) (*PeerCountReply, error) { // panic("mock out the PeerCount method") // }, // PeerEventsFunc: func(peerEventsRequest *PeerEventsRequest, sentry_PeerEventsServer Sentry_PeerEventsServer) error { // panic("mock out the PeerEvents method") // }, // PeerMinBlockFunc: func(contextMoqParam context.Context, peerMinBlockRequest *PeerMinBlockRequest) (*emptypb.Empty, error) { // panic("mock out the PeerMinBlock method") // }, // PeersFunc: func(contextMoqParam context.Context, empty *emptypb.Empty) (*PeersReply, error) { // panic("mock out the Peers method") // }, // PenalizePeerFunc: func(contextMoqParam context.Context, penalizePeerRequest *PenalizePeerRequest) (*emptypb.Empty, error) { // panic("mock out the PenalizePeer method") // }, // SendMessageByIdFunc: func(contextMoqParam context.Context, sendMessageByIdRequest *SendMessageByIdRequest) (*SentPeers, error) { // panic("mock out the SendMessageById method") // }, // SendMessageByMinBlockFunc: func(contextMoqParam context.Context, sendMessageByMinBlockRequest *SendMessageByMinBlockRequest) (*SentPeers, error) { // panic("mock out the SendMessageByMinBlock method") // }, // SendMessageToAllFunc: func(contextMoqParam context.Context, outboundMessageData *OutboundMessageData) (*SentPeers, error) { // panic("mock out the SendMessageToAll method") // }, // SendMessageToRandomPeersFunc: func(contextMoqParam context.Context, sendMessageToRandomPeersRequest *SendMessageToRandomPeersRequest) (*SentPeers, error) { // panic("mock out the SendMessageToRandomPeers method") // }, // SetStatusFunc: func(contextMoqParam context.Context, statusData *StatusData) (*SetStatusReply, error) { // panic("mock out the SetStatus method") // }, // mustEmbedUnimplementedSentryServerFunc: func() { // panic("mock out the mustEmbedUnimplementedSentryServer method") // }, // } // // // use mockedSentryServer in code that requires SentryServer // // and then make assertions. // // } type SentryServerMock struct { // AddPeerFunc mocks the AddPeer method. AddPeerFunc func(contextMoqParam context.Context, addPeerRequest *AddPeerRequest) (*AddPeerReply, error) // HandShakeFunc mocks the HandShake method. HandShakeFunc func(contextMoqParam context.Context, empty *emptypb.Empty) (*HandShakeReply, error) // MessagesFunc mocks the Messages method. MessagesFunc func(messagesRequest *MessagesRequest, sentry_MessagesServer Sentry_MessagesServer) error // NodeInfoFunc mocks the NodeInfo method. NodeInfoFunc func(contextMoqParam context.Context, empty *emptypb.Empty) (*types.NodeInfoReply, error) // PeerByIdFunc mocks the PeerById method. PeerByIdFunc func(contextMoqParam context.Context, peerByIdRequest *PeerByIdRequest) (*PeerByIdReply, error) // PeerCountFunc mocks the PeerCount method. PeerCountFunc func(contextMoqParam context.Context, peerCountRequest *PeerCountRequest) (*PeerCountReply, error) // PeerEventsFunc mocks the PeerEvents method. PeerEventsFunc func(peerEventsRequest *PeerEventsRequest, sentry_PeerEventsServer Sentry_PeerEventsServer) error // PeerMinBlockFunc mocks the PeerMinBlock method. PeerMinBlockFunc func(contextMoqParam context.Context, peerMinBlockRequest *PeerMinBlockRequest) (*emptypb.Empty, error) // PeersFunc mocks the Peers method. PeersFunc func(contextMoqParam context.Context, empty *emptypb.Empty) (*PeersReply, error) // PenalizePeerFunc mocks the PenalizePeer method. PenalizePeerFunc func(contextMoqParam context.Context, penalizePeerRequest *PenalizePeerRequest) (*emptypb.Empty, error) // SendMessageByIdFunc mocks the SendMessageById method. SendMessageByIdFunc func(contextMoqParam context.Context, sendMessageByIdRequest *SendMessageByIdRequest) (*SentPeers, error) // SendMessageByMinBlockFunc mocks the SendMessageByMinBlock method. SendMessageByMinBlockFunc func(contextMoqParam context.Context, sendMessageByMinBlockRequest *SendMessageByMinBlockRequest) (*SentPeers, error) // SendMessageToAllFunc mocks the SendMessageToAll method. SendMessageToAllFunc func(contextMoqParam context.Context, outboundMessageData *OutboundMessageData) (*SentPeers, error) // SendMessageToRandomPeersFunc mocks the SendMessageToRandomPeers method. SendMessageToRandomPeersFunc func(contextMoqParam context.Context, sendMessageToRandomPeersRequest *SendMessageToRandomPeersRequest) (*SentPeers, error) // SetStatusFunc mocks the SetStatus method. SetStatusFunc func(contextMoqParam context.Context, statusData *StatusData) (*SetStatusReply, error) // mustEmbedUnimplementedSentryServerFunc mocks the mustEmbedUnimplementedSentryServer method. mustEmbedUnimplementedSentryServerFunc func() // calls tracks calls to the methods. calls struct { // AddPeer holds details about calls to the AddPeer method. AddPeer []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // AddPeerRequest is the addPeerRequest argument value. AddPeerRequest *AddPeerRequest } // HandShake holds details about calls to the HandShake method. HandShake []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // Empty is the empty argument value. Empty *emptypb.Empty } // Messages holds details about calls to the Messages method. Messages []struct { // MessagesRequest is the messagesRequest argument value. MessagesRequest *MessagesRequest // Sentry_MessagesServer is the sentry_MessagesServer argument value. Sentry_MessagesServer Sentry_MessagesServer } // NodeInfo holds details about calls to the NodeInfo method. NodeInfo []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // Empty is the empty argument value. Empty *emptypb.Empty } // PeerById holds details about calls to the PeerById method. PeerById []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // PeerByIdRequest is the peerByIdRequest argument value. PeerByIdRequest *PeerByIdRequest } // PeerCount holds details about calls to the PeerCount method. PeerCount []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // PeerCountRequest is the peerCountRequest argument value. PeerCountRequest *PeerCountRequest } // PeerEvents holds details about calls to the PeerEvents method. PeerEvents []struct { // PeerEventsRequest is the peerEventsRequest argument value. PeerEventsRequest *PeerEventsRequest // Sentry_PeerEventsServer is the sentry_PeerEventsServer argument value. Sentry_PeerEventsServer Sentry_PeerEventsServer } // PeerMinBlock holds details about calls to the PeerMinBlock method. PeerMinBlock []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // PeerMinBlockRequest is the peerMinBlockRequest argument value. PeerMinBlockRequest *PeerMinBlockRequest } // Peers holds details about calls to the Peers method. Peers []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // Empty is the empty argument value. Empty *emptypb.Empty } // PenalizePeer holds details about calls to the PenalizePeer method. PenalizePeer []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // PenalizePeerRequest is the penalizePeerRequest argument value. PenalizePeerRequest *PenalizePeerRequest } // SendMessageById holds details about calls to the SendMessageById method. SendMessageById []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // SendMessageByIdRequest is the sendMessageByIdRequest argument value. SendMessageByIdRequest *SendMessageByIdRequest } // SendMessageByMinBlock holds details about calls to the SendMessageByMinBlock method. SendMessageByMinBlock []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // SendMessageByMinBlockRequest is the sendMessageByMinBlockRequest argument value. SendMessageByMinBlockRequest *SendMessageByMinBlockRequest } // SendMessageToAll holds details about calls to the SendMessageToAll method. SendMessageToAll []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // OutboundMessageData is the outboundMessageData argument value. OutboundMessageData *OutboundMessageData } // SendMessageToRandomPeers holds details about calls to the SendMessageToRandomPeers method. SendMessageToRandomPeers []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // SendMessageToRandomPeersRequest is the sendMessageToRandomPeersRequest argument value. SendMessageToRandomPeersRequest *SendMessageToRandomPeersRequest } // SetStatus holds details about calls to the SetStatus method. SetStatus []struct { // ContextMoqParam is the contextMoqParam argument value. ContextMoqParam context.Context // StatusData is the statusData argument value. StatusData *StatusData } // mustEmbedUnimplementedSentryServer holds details about calls to the mustEmbedUnimplementedSentryServer method. mustEmbedUnimplementedSentryServer []struct { } } lockAddPeer sync.RWMutex lockHandShake sync.RWMutex lockMessages sync.RWMutex lockNodeInfo sync.RWMutex lockPeerById sync.RWMutex lockPeerCount sync.RWMutex lockPeerEvents sync.RWMutex lockPeerMinBlock sync.RWMutex lockPeers sync.RWMutex lockPenalizePeer sync.RWMutex lockSendMessageById sync.RWMutex lockSendMessageByMinBlock sync.RWMutex lockSendMessageToAll sync.RWMutex lockSendMessageToRandomPeers sync.RWMutex lockSetStatus sync.RWMutex lockmustEmbedUnimplementedSentryServer sync.RWMutex } // AddPeer calls AddPeerFunc. func (mock *SentryServerMock) AddPeer(contextMoqParam context.Context, addPeerRequest *AddPeerRequest) (*AddPeerReply, error) { callInfo := struct { ContextMoqParam context.Context AddPeerRequest *AddPeerRequest }{ ContextMoqParam: contextMoqParam, AddPeerRequest: addPeerRequest, } mock.lockAddPeer.Lock() mock.calls.AddPeer = append(mock.calls.AddPeer, callInfo) mock.lockAddPeer.Unlock() if mock.AddPeerFunc == nil { var ( addPeerReplyOut *AddPeerReply errOut error ) return addPeerReplyOut, errOut } return mock.AddPeerFunc(contextMoqParam, addPeerRequest) } // AddPeerCalls gets all the calls that were made to AddPeer. // Check the length with: // // len(mockedSentryServer.AddPeerCalls()) func (mock *SentryServerMock) AddPeerCalls() []struct { ContextMoqParam context.Context AddPeerRequest *AddPeerRequest } { var calls []struct { ContextMoqParam context.Context AddPeerRequest *AddPeerRequest } mock.lockAddPeer.RLock() calls = mock.calls.AddPeer mock.lockAddPeer.RUnlock() return calls } // HandShake calls HandShakeFunc. func (mock *SentryServerMock) HandShake(contextMoqParam context.Context, empty *emptypb.Empty) (*HandShakeReply, error) { callInfo := struct { ContextMoqParam context.Context Empty *emptypb.Empty }{ ContextMoqParam: contextMoqParam, Empty: empty, } mock.lockHandShake.Lock() mock.calls.HandShake = append(mock.calls.HandShake, callInfo) mock.lockHandShake.Unlock() if mock.HandShakeFunc == nil { var ( handShakeReplyOut *HandShakeReply errOut error ) return handShakeReplyOut, errOut } return mock.HandShakeFunc(contextMoqParam, empty) } // HandShakeCalls gets all the calls that were made to HandShake. // Check the length with: // // len(mockedSentryServer.HandShakeCalls()) func (mock *SentryServerMock) HandShakeCalls() []struct { ContextMoqParam context.Context Empty *emptypb.Empty } { var calls []struct { ContextMoqParam context.Context Empty *emptypb.Empty } mock.lockHandShake.RLock() calls = mock.calls.HandShake mock.lockHandShake.RUnlock() return calls } // Messages calls MessagesFunc. func (mock *SentryServerMock) Messages(messagesRequest *MessagesRequest, sentry_MessagesServer Sentry_MessagesServer) error { callInfo := struct { MessagesRequest *MessagesRequest Sentry_MessagesServer Sentry_MessagesServer }{ MessagesRequest: messagesRequest, Sentry_MessagesServer: sentry_MessagesServer, } mock.lockMessages.Lock() mock.calls.Messages = append(mock.calls.Messages, callInfo) mock.lockMessages.Unlock() if mock.MessagesFunc == nil { var ( errOut error ) return errOut } return mock.MessagesFunc(messagesRequest, sentry_MessagesServer) } // MessagesCalls gets all the calls that were made to Messages. // Check the length with: // // len(mockedSentryServer.MessagesCalls()) func (mock *SentryServerMock) MessagesCalls() []struct { MessagesRequest *MessagesRequest Sentry_MessagesServer Sentry_MessagesServer } { var calls []struct { MessagesRequest *MessagesRequest Sentry_MessagesServer Sentry_MessagesServer } mock.lockMessages.RLock() calls = mock.calls.Messages mock.lockMessages.RUnlock() return calls } // NodeInfo calls NodeInfoFunc. func (mock *SentryServerMock) NodeInfo(contextMoqParam context.Context, empty *emptypb.Empty) (*types.NodeInfoReply, error) { callInfo := struct { ContextMoqParam context.Context Empty *emptypb.Empty }{ ContextMoqParam: contextMoqParam, Empty: empty, } mock.lockNodeInfo.Lock() mock.calls.NodeInfo = append(mock.calls.NodeInfo, callInfo) mock.lockNodeInfo.Unlock() if mock.NodeInfoFunc == nil { var ( nodeInfoReplyOut *types.NodeInfoReply errOut error ) return nodeInfoReplyOut, errOut } return mock.NodeInfoFunc(contextMoqParam, empty) } // NodeInfoCalls gets all the calls that were made to NodeInfo. // Check the length with: // // len(mockedSentryServer.NodeInfoCalls()) func (mock *SentryServerMock) NodeInfoCalls() []struct { ContextMoqParam context.Context Empty *emptypb.Empty } { var calls []struct { ContextMoqParam context.Context Empty *emptypb.Empty } mock.lockNodeInfo.RLock() calls = mock.calls.NodeInfo mock.lockNodeInfo.RUnlock() return calls } // PeerById calls PeerByIdFunc. func (mock *SentryServerMock) PeerById(contextMoqParam context.Context, peerByIdRequest *PeerByIdRequest) (*PeerByIdReply, error) { callInfo := struct { ContextMoqParam context.Context PeerByIdRequest *PeerByIdRequest }{ ContextMoqParam: contextMoqParam, PeerByIdRequest: peerByIdRequest, } mock.lockPeerById.Lock() mock.calls.PeerById = append(mock.calls.PeerById, callInfo) mock.lockPeerById.Unlock() if mock.PeerByIdFunc == nil { var ( peerByIdReplyOut *PeerByIdReply errOut error ) return peerByIdReplyOut, errOut } return mock.PeerByIdFunc(contextMoqParam, peerByIdRequest) } // PeerByIdCalls gets all the calls that were made to PeerById. // Check the length with: // // len(mockedSentryServer.PeerByIdCalls()) func (mock *SentryServerMock) PeerByIdCalls() []struct { ContextMoqParam context.Context PeerByIdRequest *PeerByIdRequest } { var calls []struct { ContextMoqParam context.Context PeerByIdRequest *PeerByIdRequest } mock.lockPeerById.RLock() calls = mock.calls.PeerById mock.lockPeerById.RUnlock() return calls } // PeerCount calls PeerCountFunc. func (mock *SentryServerMock) PeerCount(contextMoqParam context.Context, peerCountRequest *PeerCountRequest) (*PeerCountReply, error) { callInfo := struct { ContextMoqParam context.Context PeerCountRequest *PeerCountRequest }{ ContextMoqParam: contextMoqParam, PeerCountRequest: peerCountRequest, } mock.lockPeerCount.Lock() mock.calls.PeerCount = append(mock.calls.PeerCount, callInfo) mock.lockPeerCount.Unlock() if mock.PeerCountFunc == nil { var ( peerCountReplyOut *PeerCountReply errOut error ) return peerCountReplyOut, errOut } return mock.PeerCountFunc(contextMoqParam, peerCountRequest) } // PeerCountCalls gets all the calls that were made to PeerCount. // Check the length with: // // len(mockedSentryServer.PeerCountCalls()) func (mock *SentryServerMock) PeerCountCalls() []struct { ContextMoqParam context.Context PeerCountRequest *PeerCountRequest } { var calls []struct { ContextMoqParam context.Context PeerCountRequest *PeerCountRequest } mock.lockPeerCount.RLock() calls = mock.calls.PeerCount mock.lockPeerCount.RUnlock() return calls } // PeerEvents calls PeerEventsFunc. func (mock *SentryServerMock) PeerEvents(peerEventsRequest *PeerEventsRequest, sentry_PeerEventsServer Sentry_PeerEventsServer) error { callInfo := struct { PeerEventsRequest *PeerEventsRequest Sentry_PeerEventsServer Sentry_PeerEventsServer }{ PeerEventsRequest: peerEventsRequest, Sentry_PeerEventsServer: sentry_PeerEventsServer, } mock.lockPeerEvents.Lock() mock.calls.PeerEvents = append(mock.calls.PeerEvents, callInfo) mock.lockPeerEvents.Unlock() if mock.PeerEventsFunc == nil { var ( errOut error ) return errOut } return mock.PeerEventsFunc(peerEventsRequest, sentry_PeerEventsServer) } // PeerEventsCalls gets all the calls that were made to PeerEvents. // Check the length with: // // len(mockedSentryServer.PeerEventsCalls()) func (mock *SentryServerMock) PeerEventsCalls() []struct { PeerEventsRequest *PeerEventsRequest Sentry_PeerEventsServer Sentry_PeerEventsServer } { var calls []struct { PeerEventsRequest *PeerEventsRequest Sentry_PeerEventsServer Sentry_PeerEventsServer } mock.lockPeerEvents.RLock() calls = mock.calls.PeerEvents mock.lockPeerEvents.RUnlock() return calls } // PeerMinBlock calls PeerMinBlockFunc. func (mock *SentryServerMock) PeerMinBlock(contextMoqParam context.Context, peerMinBlockRequest *PeerMinBlockRequest) (*emptypb.Empty, error) { callInfo := struct { ContextMoqParam context.Context PeerMinBlockRequest *PeerMinBlockRequest }{ ContextMoqParam: contextMoqParam, PeerMinBlockRequest: peerMinBlockRequest, } mock.lockPeerMinBlock.Lock() mock.calls.PeerMinBlock = append(mock.calls.PeerMinBlock, callInfo) mock.lockPeerMinBlock.Unlock() if mock.PeerMinBlockFunc == nil { var ( emptyOut *emptypb.Empty errOut error ) return emptyOut, errOut } return mock.PeerMinBlockFunc(contextMoqParam, peerMinBlockRequest) } // PeerMinBlockCalls gets all the calls that were made to PeerMinBlock. // Check the length with: // // len(mockedSentryServer.PeerMinBlockCalls()) func (mock *SentryServerMock) PeerMinBlockCalls() []struct { ContextMoqParam context.Context PeerMinBlockRequest *PeerMinBlockRequest } { var calls []struct { ContextMoqParam context.Context PeerMinBlockRequest *PeerMinBlockRequest } mock.lockPeerMinBlock.RLock() calls = mock.calls.PeerMinBlock mock.lockPeerMinBlock.RUnlock() return calls } // Peers calls PeersFunc. func (mock *SentryServerMock) Peers(contextMoqParam context.Context, empty *emptypb.Empty) (*PeersReply, error) { callInfo := struct { ContextMoqParam context.Context Empty *emptypb.Empty }{ ContextMoqParam: contextMoqParam, Empty: empty, } mock.lockPeers.Lock() mock.calls.Peers = append(mock.calls.Peers, callInfo) mock.lockPeers.Unlock() if mock.PeersFunc == nil { var ( peersReplyOut *PeersReply errOut error ) return peersReplyOut, errOut } return mock.PeersFunc(contextMoqParam, empty) } // PeersCalls gets all the calls that were made to Peers. // Check the length with: // // len(mockedSentryServer.PeersCalls()) func (mock *SentryServerMock) PeersCalls() []struct { ContextMoqParam context.Context Empty *emptypb.Empty } { var calls []struct { ContextMoqParam context.Context Empty *emptypb.Empty } mock.lockPeers.RLock() calls = mock.calls.Peers mock.lockPeers.RUnlock() return calls } // PenalizePeer calls PenalizePeerFunc. func (mock *SentryServerMock) PenalizePeer(contextMoqParam context.Context, penalizePeerRequest *PenalizePeerRequest) (*emptypb.Empty, error) { callInfo := struct { ContextMoqParam context.Context PenalizePeerRequest *PenalizePeerRequest }{ ContextMoqParam: contextMoqParam, PenalizePeerRequest: penalizePeerRequest, } mock.lockPenalizePeer.Lock() mock.calls.PenalizePeer = append(mock.calls.PenalizePeer, callInfo) mock.lockPenalizePeer.Unlock() if mock.PenalizePeerFunc == nil { var ( emptyOut *emptypb.Empty errOut error ) return emptyOut, errOut } return mock.PenalizePeerFunc(contextMoqParam, penalizePeerRequest) } // PenalizePeerCalls gets all the calls that were made to PenalizePeer. // Check the length with: // // len(mockedSentryServer.PenalizePeerCalls()) func (mock *SentryServerMock) PenalizePeerCalls() []struct { ContextMoqParam context.Context PenalizePeerRequest *PenalizePeerRequest } { var calls []struct { ContextMoqParam context.Context PenalizePeerRequest *PenalizePeerRequest } mock.lockPenalizePeer.RLock() calls = mock.calls.PenalizePeer mock.lockPenalizePeer.RUnlock() return calls } // SendMessageById calls SendMessageByIdFunc. func (mock *SentryServerMock) SendMessageById(contextMoqParam context.Context, sendMessageByIdRequest *SendMessageByIdRequest) (*SentPeers, error) { callInfo := struct { ContextMoqParam context.Context SendMessageByIdRequest *SendMessageByIdRequest }{ ContextMoqParam: contextMoqParam, SendMessageByIdRequest: sendMessageByIdRequest, } mock.lockSendMessageById.Lock() mock.calls.SendMessageById = append(mock.calls.SendMessageById, callInfo) mock.lockSendMessageById.Unlock() if mock.SendMessageByIdFunc == nil { var ( sentPeersOut *SentPeers errOut error ) return sentPeersOut, errOut } return mock.SendMessageByIdFunc(contextMoqParam, sendMessageByIdRequest) } // SendMessageByIdCalls gets all the calls that were made to SendMessageById. // Check the length with: // // len(mockedSentryServer.SendMessageByIdCalls()) func (mock *SentryServerMock) SendMessageByIdCalls() []struct { ContextMoqParam context.Context SendMessageByIdRequest *SendMessageByIdRequest } { var calls []struct { ContextMoqParam context.Context SendMessageByIdRequest *SendMessageByIdRequest } mock.lockSendMessageById.RLock() calls = mock.calls.SendMessageById mock.lockSendMessageById.RUnlock() return calls } // SendMessageByMinBlock calls SendMessageByMinBlockFunc. func (mock *SentryServerMock) SendMessageByMinBlock(contextMoqParam context.Context, sendMessageByMinBlockRequest *SendMessageByMinBlockRequest) (*SentPeers, error) { callInfo := struct { ContextMoqParam context.Context SendMessageByMinBlockRequest *SendMessageByMinBlockRequest }{ ContextMoqParam: contextMoqParam, SendMessageByMinBlockRequest: sendMessageByMinBlockRequest, } mock.lockSendMessageByMinBlock.Lock() mock.calls.SendMessageByMinBlock = append(mock.calls.SendMessageByMinBlock, callInfo) mock.lockSendMessageByMinBlock.Unlock() if mock.SendMessageByMinBlockFunc == nil { var ( sentPeersOut *SentPeers errOut error ) return sentPeersOut, errOut } return mock.SendMessageByMinBlockFunc(contextMoqParam, sendMessageByMinBlockRequest) } // SendMessageByMinBlockCalls gets all the calls that were made to SendMessageByMinBlock. // Check the length with: // // len(mockedSentryServer.SendMessageByMinBlockCalls()) func (mock *SentryServerMock) SendMessageByMinBlockCalls() []struct { ContextMoqParam context.Context SendMessageByMinBlockRequest *SendMessageByMinBlockRequest } { var calls []struct { ContextMoqParam context.Context SendMessageByMinBlockRequest *SendMessageByMinBlockRequest } mock.lockSendMessageByMinBlock.RLock() calls = mock.calls.SendMessageByMinBlock mock.lockSendMessageByMinBlock.RUnlock() return calls } // SendMessageToAll calls SendMessageToAllFunc. func (mock *SentryServerMock) SendMessageToAll(contextMoqParam context.Context, outboundMessageData *OutboundMessageData) (*SentPeers, error) { callInfo := struct { ContextMoqParam context.Context OutboundMessageData *OutboundMessageData }{ ContextMoqParam: contextMoqParam, OutboundMessageData: outboundMessageData, } mock.lockSendMessageToAll.Lock() mock.calls.SendMessageToAll = append(mock.calls.SendMessageToAll, callInfo) mock.lockSendMessageToAll.Unlock() if mock.SendMessageToAllFunc == nil { var ( sentPeersOut *SentPeers errOut error ) return sentPeersOut, errOut } return mock.SendMessageToAllFunc(contextMoqParam, outboundMessageData) } // SendMessageToAllCalls gets all the calls that were made to SendMessageToAll. // Check the length with: // // len(mockedSentryServer.SendMessageToAllCalls()) func (mock *SentryServerMock) SendMessageToAllCalls() []struct { ContextMoqParam context.Context OutboundMessageData *OutboundMessageData } { var calls []struct { ContextMoqParam context.Context OutboundMessageData *OutboundMessageData } mock.lockSendMessageToAll.RLock() calls = mock.calls.SendMessageToAll mock.lockSendMessageToAll.RUnlock() return calls } // SendMessageToRandomPeers calls SendMessageToRandomPeersFunc. func (mock *SentryServerMock) SendMessageToRandomPeers(contextMoqParam context.Context, sendMessageToRandomPeersRequest *SendMessageToRandomPeersRequest) (*SentPeers, error) { callInfo := struct { ContextMoqParam context.Context SendMessageToRandomPeersRequest *SendMessageToRandomPeersRequest }{ ContextMoqParam: contextMoqParam, SendMessageToRandomPeersRequest: sendMessageToRandomPeersRequest, } mock.lockSendMessageToRandomPeers.Lock() mock.calls.SendMessageToRandomPeers = append(mock.calls.SendMessageToRandomPeers, callInfo) mock.lockSendMessageToRandomPeers.Unlock() if mock.SendMessageToRandomPeersFunc == nil { var ( sentPeersOut *SentPeers errOut error ) return sentPeersOut, errOut } return mock.SendMessageToRandomPeersFunc(contextMoqParam, sendMessageToRandomPeersRequest) } // SendMessageToRandomPeersCalls gets all the calls that were made to SendMessageToRandomPeers. // Check the length with: // // len(mockedSentryServer.SendMessageToRandomPeersCalls()) func (mock *SentryServerMock) SendMessageToRandomPeersCalls() []struct { ContextMoqParam context.Context SendMessageToRandomPeersRequest *SendMessageToRandomPeersRequest } { var calls []struct { ContextMoqParam context.Context SendMessageToRandomPeersRequest *SendMessageToRandomPeersRequest } mock.lockSendMessageToRandomPeers.RLock() calls = mock.calls.SendMessageToRandomPeers mock.lockSendMessageToRandomPeers.RUnlock() return calls } // SetStatus calls SetStatusFunc. func (mock *SentryServerMock) SetStatus(contextMoqParam context.Context, statusData *StatusData) (*SetStatusReply, error) { callInfo := struct { ContextMoqParam context.Context StatusData *StatusData }{ ContextMoqParam: contextMoqParam, StatusData: statusData, } mock.lockSetStatus.Lock() mock.calls.SetStatus = append(mock.calls.SetStatus, callInfo) mock.lockSetStatus.Unlock() if mock.SetStatusFunc == nil { var ( setStatusReplyOut *SetStatusReply errOut error ) return setStatusReplyOut, errOut } return mock.SetStatusFunc(contextMoqParam, statusData) } // SetStatusCalls gets all the calls that were made to SetStatus. // Check the length with: // // len(mockedSentryServer.SetStatusCalls()) func (mock *SentryServerMock) SetStatusCalls() []struct { ContextMoqParam context.Context StatusData *StatusData } { var calls []struct { ContextMoqParam context.Context StatusData *StatusData } mock.lockSetStatus.RLock() calls = mock.calls.SetStatus mock.lockSetStatus.RUnlock() return calls } // mustEmbedUnimplementedSentryServer calls mustEmbedUnimplementedSentryServerFunc. func (mock *SentryServerMock) mustEmbedUnimplementedSentryServer() { callInfo := struct { }{} mock.lockmustEmbedUnimplementedSentryServer.Lock() mock.calls.mustEmbedUnimplementedSentryServer = append(mock.calls.mustEmbedUnimplementedSentryServer, callInfo) mock.lockmustEmbedUnimplementedSentryServer.Unlock() if mock.mustEmbedUnimplementedSentryServerFunc == nil { return } mock.mustEmbedUnimplementedSentryServerFunc() } // mustEmbedUnimplementedSentryServerCalls gets all the calls that were made to mustEmbedUnimplementedSentryServer. // Check the length with: // // len(mockedSentryServer.mustEmbedUnimplementedSentryServerCalls()) func (mock *SentryServerMock) mustEmbedUnimplementedSentryServerCalls() []struct { } { var calls []struct { } mock.lockmustEmbedUnimplementedSentryServer.RLock() calls = mock.calls.mustEmbedUnimplementedSentryServer mock.lockmustEmbedUnimplementedSentryServer.RUnlock() return calls } // Ensure, that SentryClientMock does implement SentryClient. // If this is not the case, regenerate this file with moq. var _ SentryClient = &SentryClientMock{} // SentryClientMock is a mock implementation of SentryClient. // // func TestSomethingThatUsesSentryClient(t *testing.T) { // // // make and configure a mocked SentryClient // mockedSentryClient := &SentryClientMock{ // AddPeerFunc: func(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) { // panic("mock out the AddPeer method") // }, // HandShakeFunc: func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HandShakeReply, error) { // panic("mock out the HandShake method") // }, // MessagesFunc: func(ctx context.Context, in *MessagesRequest, opts ...grpc.CallOption) (Sentry_MessagesClient, error) { // panic("mock out the Messages method") // }, // NodeInfoFunc: func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.NodeInfoReply, error) { // panic("mock out the NodeInfo method") // }, // PeerByIdFunc: func(ctx context.Context, in *PeerByIdRequest, opts ...grpc.CallOption) (*PeerByIdReply, error) { // panic("mock out the PeerById method") // }, // PeerCountFunc: func(ctx context.Context, in *PeerCountRequest, opts ...grpc.CallOption) (*PeerCountReply, error) { // panic("mock out the PeerCount method") // }, // PeerEventsFunc: func(ctx context.Context, in *PeerEventsRequest, opts ...grpc.CallOption) (Sentry_PeerEventsClient, error) { // panic("mock out the PeerEvents method") // }, // PeerMinBlockFunc: func(ctx context.Context, in *PeerMinBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { // panic("mock out the PeerMinBlock method") // }, // PeersFunc: func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersReply, error) { // panic("mock out the Peers method") // }, // PenalizePeerFunc: func(ctx context.Context, in *PenalizePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { // panic("mock out the PenalizePeer method") // }, // SendMessageByIdFunc: func(ctx context.Context, in *SendMessageByIdRequest, opts ...grpc.CallOption) (*SentPeers, error) { // panic("mock out the SendMessageById method") // }, // SendMessageByMinBlockFunc: func(ctx context.Context, in *SendMessageByMinBlockRequest, opts ...grpc.CallOption) (*SentPeers, error) { // panic("mock out the SendMessageByMinBlock method") // }, // SendMessageToAllFunc: func(ctx context.Context, in *OutboundMessageData, opts ...grpc.CallOption) (*SentPeers, error) { // panic("mock out the SendMessageToAll method") // }, // SendMessageToRandomPeersFunc: func(ctx context.Context, in *SendMessageToRandomPeersRequest, opts ...grpc.CallOption) (*SentPeers, error) { // panic("mock out the SendMessageToRandomPeers method") // }, // SetStatusFunc: func(ctx context.Context, in *StatusData, opts ...grpc.CallOption) (*SetStatusReply, error) { // panic("mock out the SetStatus method") // }, // } // // // use mockedSentryClient in code that requires SentryClient // // and then make assertions. // // } type SentryClientMock struct { // AddPeerFunc mocks the AddPeer method. AddPeerFunc func(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) // HandShakeFunc mocks the HandShake method. HandShakeFunc func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HandShakeReply, error) // MessagesFunc mocks the Messages method. MessagesFunc func(ctx context.Context, in *MessagesRequest, opts ...grpc.CallOption) (Sentry_MessagesClient, error) // NodeInfoFunc mocks the NodeInfo method. NodeInfoFunc func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.NodeInfoReply, error) // PeerByIdFunc mocks the PeerById method. PeerByIdFunc func(ctx context.Context, in *PeerByIdRequest, opts ...grpc.CallOption) (*PeerByIdReply, error) // PeerCountFunc mocks the PeerCount method. PeerCountFunc func(ctx context.Context, in *PeerCountRequest, opts ...grpc.CallOption) (*PeerCountReply, error) // PeerEventsFunc mocks the PeerEvents method. PeerEventsFunc func(ctx context.Context, in *PeerEventsRequest, opts ...grpc.CallOption) (Sentry_PeerEventsClient, error) // PeerMinBlockFunc mocks the PeerMinBlock method. PeerMinBlockFunc func(ctx context.Context, in *PeerMinBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // PeersFunc mocks the Peers method. PeersFunc func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersReply, error) // PenalizePeerFunc mocks the PenalizePeer method. PenalizePeerFunc func(ctx context.Context, in *PenalizePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // SendMessageByIdFunc mocks the SendMessageById method. SendMessageByIdFunc func(ctx context.Context, in *SendMessageByIdRequest, opts ...grpc.CallOption) (*SentPeers, error) // SendMessageByMinBlockFunc mocks the SendMessageByMinBlock method. SendMessageByMinBlockFunc func(ctx context.Context, in *SendMessageByMinBlockRequest, opts ...grpc.CallOption) (*SentPeers, error) // SendMessageToAllFunc mocks the SendMessageToAll method. SendMessageToAllFunc func(ctx context.Context, in *OutboundMessageData, opts ...grpc.CallOption) (*SentPeers, error) // SendMessageToRandomPeersFunc mocks the SendMessageToRandomPeers method. SendMessageToRandomPeersFunc func(ctx context.Context, in *SendMessageToRandomPeersRequest, opts ...grpc.CallOption) (*SentPeers, error) // SetStatusFunc mocks the SetStatus method. SetStatusFunc func(ctx context.Context, in *StatusData, opts ...grpc.CallOption) (*SetStatusReply, error) // calls tracks calls to the methods. calls struct { // AddPeer holds details about calls to the AddPeer method. AddPeer []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *AddPeerRequest // Opts is the opts argument value. Opts []grpc.CallOption } // HandShake holds details about calls to the HandShake method. HandShake []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *emptypb.Empty // Opts is the opts argument value. Opts []grpc.CallOption } // Messages holds details about calls to the Messages method. Messages []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *MessagesRequest // Opts is the opts argument value. Opts []grpc.CallOption } // NodeInfo holds details about calls to the NodeInfo method. NodeInfo []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *emptypb.Empty // Opts is the opts argument value. Opts []grpc.CallOption } // PeerById holds details about calls to the PeerById method. PeerById []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *PeerByIdRequest // Opts is the opts argument value. Opts []grpc.CallOption } // PeerCount holds details about calls to the PeerCount method. PeerCount []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *PeerCountRequest // Opts is the opts argument value. Opts []grpc.CallOption } // PeerEvents holds details about calls to the PeerEvents method. PeerEvents []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *PeerEventsRequest // Opts is the opts argument value. Opts []grpc.CallOption } // PeerMinBlock holds details about calls to the PeerMinBlock method. PeerMinBlock []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *PeerMinBlockRequest // Opts is the opts argument value. Opts []grpc.CallOption } // Peers holds details about calls to the Peers method. Peers []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *emptypb.Empty // Opts is the opts argument value. Opts []grpc.CallOption } // PenalizePeer holds details about calls to the PenalizePeer method. PenalizePeer []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *PenalizePeerRequest // Opts is the opts argument value. Opts []grpc.CallOption } // SendMessageById holds details about calls to the SendMessageById method. SendMessageById []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *SendMessageByIdRequest // Opts is the opts argument value. Opts []grpc.CallOption } // SendMessageByMinBlock holds details about calls to the SendMessageByMinBlock method. SendMessageByMinBlock []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *SendMessageByMinBlockRequest // Opts is the opts argument value. Opts []grpc.CallOption } // SendMessageToAll holds details about calls to the SendMessageToAll method. SendMessageToAll []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *OutboundMessageData // Opts is the opts argument value. Opts []grpc.CallOption } // SendMessageToRandomPeers holds details about calls to the SendMessageToRandomPeers method. SendMessageToRandomPeers []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *SendMessageToRandomPeersRequest // Opts is the opts argument value. Opts []grpc.CallOption } // SetStatus holds details about calls to the SetStatus method. SetStatus []struct { // Ctx is the ctx argument value. Ctx context.Context // In is the in argument value. In *StatusData // Opts is the opts argument value. Opts []grpc.CallOption } } lockAddPeer sync.RWMutex lockHandShake sync.RWMutex lockMessages sync.RWMutex lockNodeInfo sync.RWMutex lockPeerById sync.RWMutex lockPeerCount sync.RWMutex lockPeerEvents sync.RWMutex lockPeerMinBlock sync.RWMutex lockPeers sync.RWMutex lockPenalizePeer sync.RWMutex lockSendMessageById sync.RWMutex lockSendMessageByMinBlock sync.RWMutex lockSendMessageToAll sync.RWMutex lockSendMessageToRandomPeers sync.RWMutex lockSetStatus sync.RWMutex } // AddPeer calls AddPeerFunc. func (mock *SentryClientMock) AddPeer(ctx context.Context, in *AddPeerRequest, opts ...grpc.CallOption) (*AddPeerReply, error) { callInfo := struct { Ctx context.Context In *AddPeerRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockAddPeer.Lock() mock.calls.AddPeer = append(mock.calls.AddPeer, callInfo) mock.lockAddPeer.Unlock() if mock.AddPeerFunc == nil { var ( addPeerReplyOut *AddPeerReply errOut error ) return addPeerReplyOut, errOut } return mock.AddPeerFunc(ctx, in, opts...) } // AddPeerCalls gets all the calls that were made to AddPeer. // Check the length with: // // len(mockedSentryClient.AddPeerCalls()) func (mock *SentryClientMock) AddPeerCalls() []struct { Ctx context.Context In *AddPeerRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *AddPeerRequest Opts []grpc.CallOption } mock.lockAddPeer.RLock() calls = mock.calls.AddPeer mock.lockAddPeer.RUnlock() return calls } // HandShake calls HandShakeFunc. func (mock *SentryClientMock) HandShake(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HandShakeReply, error) { callInfo := struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockHandShake.Lock() mock.calls.HandShake = append(mock.calls.HandShake, callInfo) mock.lockHandShake.Unlock() if mock.HandShakeFunc == nil { var ( handShakeReplyOut *HandShakeReply errOut error ) return handShakeReplyOut, errOut } return mock.HandShakeFunc(ctx, in, opts...) } // HandShakeCalls gets all the calls that were made to HandShake. // Check the length with: // // len(mockedSentryClient.HandShakeCalls()) func (mock *SentryClientMock) HandShakeCalls() []struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption } mock.lockHandShake.RLock() calls = mock.calls.HandShake mock.lockHandShake.RUnlock() return calls } // Messages calls MessagesFunc. func (mock *SentryClientMock) Messages(ctx context.Context, in *MessagesRequest, opts ...grpc.CallOption) (Sentry_MessagesClient, error) { callInfo := struct { Ctx context.Context In *MessagesRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockMessages.Lock() mock.calls.Messages = append(mock.calls.Messages, callInfo) mock.lockMessages.Unlock() if mock.MessagesFunc == nil { var ( sentry_MessagesClientOut Sentry_MessagesClient errOut error ) return sentry_MessagesClientOut, errOut } return mock.MessagesFunc(ctx, in, opts...) } // MessagesCalls gets all the calls that were made to Messages. // Check the length with: // // len(mockedSentryClient.MessagesCalls()) func (mock *SentryClientMock) MessagesCalls() []struct { Ctx context.Context In *MessagesRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *MessagesRequest Opts []grpc.CallOption } mock.lockMessages.RLock() calls = mock.calls.Messages mock.lockMessages.RUnlock() return calls } // NodeInfo calls NodeInfoFunc. func (mock *SentryClientMock) NodeInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*types.NodeInfoReply, error) { callInfo := struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockNodeInfo.Lock() mock.calls.NodeInfo = append(mock.calls.NodeInfo, callInfo) mock.lockNodeInfo.Unlock() if mock.NodeInfoFunc == nil { var ( nodeInfoReplyOut *types.NodeInfoReply errOut error ) return nodeInfoReplyOut, errOut } return mock.NodeInfoFunc(ctx, in, opts...) } // NodeInfoCalls gets all the calls that were made to NodeInfo. // Check the length with: // // len(mockedSentryClient.NodeInfoCalls()) func (mock *SentryClientMock) NodeInfoCalls() []struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption } mock.lockNodeInfo.RLock() calls = mock.calls.NodeInfo mock.lockNodeInfo.RUnlock() return calls } // PeerById calls PeerByIdFunc. func (mock *SentryClientMock) PeerById(ctx context.Context, in *PeerByIdRequest, opts ...grpc.CallOption) (*PeerByIdReply, error) { callInfo := struct { Ctx context.Context In *PeerByIdRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockPeerById.Lock() mock.calls.PeerById = append(mock.calls.PeerById, callInfo) mock.lockPeerById.Unlock() if mock.PeerByIdFunc == nil { var ( peerByIdReplyOut *PeerByIdReply errOut error ) return peerByIdReplyOut, errOut } return mock.PeerByIdFunc(ctx, in, opts...) } // PeerByIdCalls gets all the calls that were made to PeerById. // Check the length with: // // len(mockedSentryClient.PeerByIdCalls()) func (mock *SentryClientMock) PeerByIdCalls() []struct { Ctx context.Context In *PeerByIdRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *PeerByIdRequest Opts []grpc.CallOption } mock.lockPeerById.RLock() calls = mock.calls.PeerById mock.lockPeerById.RUnlock() return calls } // PeerCount calls PeerCountFunc. func (mock *SentryClientMock) PeerCount(ctx context.Context, in *PeerCountRequest, opts ...grpc.CallOption) (*PeerCountReply, error) { callInfo := struct { Ctx context.Context In *PeerCountRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockPeerCount.Lock() mock.calls.PeerCount = append(mock.calls.PeerCount, callInfo) mock.lockPeerCount.Unlock() if mock.PeerCountFunc == nil { var ( peerCountReplyOut *PeerCountReply errOut error ) return peerCountReplyOut, errOut } return mock.PeerCountFunc(ctx, in, opts...) } // PeerCountCalls gets all the calls that were made to PeerCount. // Check the length with: // // len(mockedSentryClient.PeerCountCalls()) func (mock *SentryClientMock) PeerCountCalls() []struct { Ctx context.Context In *PeerCountRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *PeerCountRequest Opts []grpc.CallOption } mock.lockPeerCount.RLock() calls = mock.calls.PeerCount mock.lockPeerCount.RUnlock() return calls } // PeerEvents calls PeerEventsFunc. func (mock *SentryClientMock) PeerEvents(ctx context.Context, in *PeerEventsRequest, opts ...grpc.CallOption) (Sentry_PeerEventsClient, error) { callInfo := struct { Ctx context.Context In *PeerEventsRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockPeerEvents.Lock() mock.calls.PeerEvents = append(mock.calls.PeerEvents, callInfo) mock.lockPeerEvents.Unlock() if mock.PeerEventsFunc == nil { var ( sentry_PeerEventsClientOut Sentry_PeerEventsClient errOut error ) return sentry_PeerEventsClientOut, errOut } return mock.PeerEventsFunc(ctx, in, opts...) } // PeerEventsCalls gets all the calls that were made to PeerEvents. // Check the length with: // // len(mockedSentryClient.PeerEventsCalls()) func (mock *SentryClientMock) PeerEventsCalls() []struct { Ctx context.Context In *PeerEventsRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *PeerEventsRequest Opts []grpc.CallOption } mock.lockPeerEvents.RLock() calls = mock.calls.PeerEvents mock.lockPeerEvents.RUnlock() return calls } // PeerMinBlock calls PeerMinBlockFunc. func (mock *SentryClientMock) PeerMinBlock(ctx context.Context, in *PeerMinBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { callInfo := struct { Ctx context.Context In *PeerMinBlockRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockPeerMinBlock.Lock() mock.calls.PeerMinBlock = append(mock.calls.PeerMinBlock, callInfo) mock.lockPeerMinBlock.Unlock() if mock.PeerMinBlockFunc == nil { var ( emptyOut *emptypb.Empty errOut error ) return emptyOut, errOut } return mock.PeerMinBlockFunc(ctx, in, opts...) } // PeerMinBlockCalls gets all the calls that were made to PeerMinBlock. // Check the length with: // // len(mockedSentryClient.PeerMinBlockCalls()) func (mock *SentryClientMock) PeerMinBlockCalls() []struct { Ctx context.Context In *PeerMinBlockRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *PeerMinBlockRequest Opts []grpc.CallOption } mock.lockPeerMinBlock.RLock() calls = mock.calls.PeerMinBlock mock.lockPeerMinBlock.RUnlock() return calls } // Peers calls PeersFunc. func (mock *SentryClientMock) Peers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PeersReply, error) { callInfo := struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockPeers.Lock() mock.calls.Peers = append(mock.calls.Peers, callInfo) mock.lockPeers.Unlock() if mock.PeersFunc == nil { var ( peersReplyOut *PeersReply errOut error ) return peersReplyOut, errOut } return mock.PeersFunc(ctx, in, opts...) } // PeersCalls gets all the calls that were made to Peers. // Check the length with: // // len(mockedSentryClient.PeersCalls()) func (mock *SentryClientMock) PeersCalls() []struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *emptypb.Empty Opts []grpc.CallOption } mock.lockPeers.RLock() calls = mock.calls.Peers mock.lockPeers.RUnlock() return calls } // PenalizePeer calls PenalizePeerFunc. func (mock *SentryClientMock) PenalizePeer(ctx context.Context, in *PenalizePeerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) { callInfo := struct { Ctx context.Context In *PenalizePeerRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockPenalizePeer.Lock() mock.calls.PenalizePeer = append(mock.calls.PenalizePeer, callInfo) mock.lockPenalizePeer.Unlock() if mock.PenalizePeerFunc == nil { var ( emptyOut *emptypb.Empty errOut error ) return emptyOut, errOut } return mock.PenalizePeerFunc(ctx, in, opts...) } // PenalizePeerCalls gets all the calls that were made to PenalizePeer. // Check the length with: // // len(mockedSentryClient.PenalizePeerCalls()) func (mock *SentryClientMock) PenalizePeerCalls() []struct { Ctx context.Context In *PenalizePeerRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *PenalizePeerRequest Opts []grpc.CallOption } mock.lockPenalizePeer.RLock() calls = mock.calls.PenalizePeer mock.lockPenalizePeer.RUnlock() return calls } // SendMessageById calls SendMessageByIdFunc. func (mock *SentryClientMock) SendMessageById(ctx context.Context, in *SendMessageByIdRequest, opts ...grpc.CallOption) (*SentPeers, error) { callInfo := struct { Ctx context.Context In *SendMessageByIdRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockSendMessageById.Lock() mock.calls.SendMessageById = append(mock.calls.SendMessageById, callInfo) mock.lockSendMessageById.Unlock() if mock.SendMessageByIdFunc == nil { var ( sentPeersOut *SentPeers errOut error ) return sentPeersOut, errOut } return mock.SendMessageByIdFunc(ctx, in, opts...) } // SendMessageByIdCalls gets all the calls that were made to SendMessageById. // Check the length with: // // len(mockedSentryClient.SendMessageByIdCalls()) func (mock *SentryClientMock) SendMessageByIdCalls() []struct { Ctx context.Context In *SendMessageByIdRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *SendMessageByIdRequest Opts []grpc.CallOption } mock.lockSendMessageById.RLock() calls = mock.calls.SendMessageById mock.lockSendMessageById.RUnlock() return calls } // SendMessageByMinBlock calls SendMessageByMinBlockFunc. func (mock *SentryClientMock) SendMessageByMinBlock(ctx context.Context, in *SendMessageByMinBlockRequest, opts ...grpc.CallOption) (*SentPeers, error) { callInfo := struct { Ctx context.Context In *SendMessageByMinBlockRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockSendMessageByMinBlock.Lock() mock.calls.SendMessageByMinBlock = append(mock.calls.SendMessageByMinBlock, callInfo) mock.lockSendMessageByMinBlock.Unlock() if mock.SendMessageByMinBlockFunc == nil { var ( sentPeersOut *SentPeers errOut error ) return sentPeersOut, errOut } return mock.SendMessageByMinBlockFunc(ctx, in, opts...) } // SendMessageByMinBlockCalls gets all the calls that were made to SendMessageByMinBlock. // Check the length with: // // len(mockedSentryClient.SendMessageByMinBlockCalls()) func (mock *SentryClientMock) SendMessageByMinBlockCalls() []struct { Ctx context.Context In *SendMessageByMinBlockRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *SendMessageByMinBlockRequest Opts []grpc.CallOption } mock.lockSendMessageByMinBlock.RLock() calls = mock.calls.SendMessageByMinBlock mock.lockSendMessageByMinBlock.RUnlock() return calls } // SendMessageToAll calls SendMessageToAllFunc. func (mock *SentryClientMock) SendMessageToAll(ctx context.Context, in *OutboundMessageData, opts ...grpc.CallOption) (*SentPeers, error) { callInfo := struct { Ctx context.Context In *OutboundMessageData Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockSendMessageToAll.Lock() mock.calls.SendMessageToAll = append(mock.calls.SendMessageToAll, callInfo) mock.lockSendMessageToAll.Unlock() if mock.SendMessageToAllFunc == nil { var ( sentPeersOut *SentPeers errOut error ) return sentPeersOut, errOut } return mock.SendMessageToAllFunc(ctx, in, opts...) } // SendMessageToAllCalls gets all the calls that were made to SendMessageToAll. // Check the length with: // // len(mockedSentryClient.SendMessageToAllCalls()) func (mock *SentryClientMock) SendMessageToAllCalls() []struct { Ctx context.Context In *OutboundMessageData Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *OutboundMessageData Opts []grpc.CallOption } mock.lockSendMessageToAll.RLock() calls = mock.calls.SendMessageToAll mock.lockSendMessageToAll.RUnlock() return calls } // SendMessageToRandomPeers calls SendMessageToRandomPeersFunc. func (mock *SentryClientMock) SendMessageToRandomPeers(ctx context.Context, in *SendMessageToRandomPeersRequest, opts ...grpc.CallOption) (*SentPeers, error) { callInfo := struct { Ctx context.Context In *SendMessageToRandomPeersRequest Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockSendMessageToRandomPeers.Lock() mock.calls.SendMessageToRandomPeers = append(mock.calls.SendMessageToRandomPeers, callInfo) mock.lockSendMessageToRandomPeers.Unlock() if mock.SendMessageToRandomPeersFunc == nil { var ( sentPeersOut *SentPeers errOut error ) return sentPeersOut, errOut } return mock.SendMessageToRandomPeersFunc(ctx, in, opts...) } // SendMessageToRandomPeersCalls gets all the calls that were made to SendMessageToRandomPeers. // Check the length with: // // len(mockedSentryClient.SendMessageToRandomPeersCalls()) func (mock *SentryClientMock) SendMessageToRandomPeersCalls() []struct { Ctx context.Context In *SendMessageToRandomPeersRequest Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *SendMessageToRandomPeersRequest Opts []grpc.CallOption } mock.lockSendMessageToRandomPeers.RLock() calls = mock.calls.SendMessageToRandomPeers mock.lockSendMessageToRandomPeers.RUnlock() return calls } // SetStatus calls SetStatusFunc. func (mock *SentryClientMock) SetStatus(ctx context.Context, in *StatusData, opts ...grpc.CallOption) (*SetStatusReply, error) { callInfo := struct { Ctx context.Context In *StatusData Opts []grpc.CallOption }{ Ctx: ctx, In: in, Opts: opts, } mock.lockSetStatus.Lock() mock.calls.SetStatus = append(mock.calls.SetStatus, callInfo) mock.lockSetStatus.Unlock() if mock.SetStatusFunc == nil { var ( setStatusReplyOut *SetStatusReply errOut error ) return setStatusReplyOut, errOut } return mock.SetStatusFunc(ctx, in, opts...) } // SetStatusCalls gets all the calls that were made to SetStatus. // Check the length with: // // len(mockedSentryClient.SetStatusCalls()) func (mock *SentryClientMock) SetStatusCalls() []struct { Ctx context.Context In *StatusData Opts []grpc.CallOption } { var calls []struct { Ctx context.Context In *StatusData Opts []grpc.CallOption } mock.lockSetStatus.RLock() calls = mock.calls.SetStatus mock.lockSetStatus.RUnlock() return calls }