testscommon

Index ¶

• Variables
• func NewHttpTestEchoHandler() *httptest.Server
• type ConnectionsHandlerStub
• • func (stub *ConnectionsHandlerStub) Addresses() []string
  • func (stub *ConnectionsHandlerStub) Bootstrap() error
  • func (stub *ConnectionsHandlerStub) Close() error
  • func (stub *ConnectionsHandlerStub) ConnectToPeer(address string) error
  • func (stub *ConnectionsHandlerStub) ConnectedAddresses() []string
  • func (stub *ConnectionsHandlerStub) ConnectedPeers() []core.PeerID
  • func (stub *ConnectionsHandlerStub) ConnectedPeersOnTopic(topic string) []core.PeerID
  • func (stub *ConnectionsHandlerStub) GetConnectedPeersInfo() *p2p.ConnectedPeersInfo
  • func (stub *ConnectionsHandlerStub) IsConnected(peerID core.PeerID) bool
  • func (stub *ConnectionsHandlerStub) IsConnectedToTheNetwork() bool
  • func (stub *ConnectionsHandlerStub) IsInterfaceNil() bool
  • func (stub *ConnectionsHandlerStub) PeerAddresses(pid core.PeerID) []string
  • func (stub *ConnectionsHandlerStub) Peers() []core.PeerID
  • func (stub *ConnectionsHandlerStub) SetPeerDenialEvaluator(handler p2p.PeerDenialEvaluator) error
  • func (stub *ConnectionsHandlerStub) SetPeerShardResolver(peerShardResolver p2p.PeerShardResolver) error
  • func (stub *ConnectionsHandlerStub) SetThresholdMinConnectedPeers(minConnectedPeers int) error
  • func (stub *ConnectionsHandlerStub) ThresholdMinConnectedPeers() int
  • func (stub *ConnectionsHandlerStub) WaitForConnections(maxWaitingTime time.Duration, minNumOfPeers uint32)
• type HttpServerStub
• • func (h *HttpServerStub) ListenAndServe() error
  • func (h *HttpServerStub) Shutdown(ctx context.Context) error
• type LoggerMock
• • func (c LoggerMock) Debug(message string, args ...interface{})
  • func (c LoggerMock) Error(message string, args ...interface{})
  • func (c LoggerMock) Info(message string, args ...interface{})
  • func (c LoggerMock) IsInterfaceNil() bool
  • func (c LoggerMock) LogIfError(err error, args ...interface{})
  • func (c LoggerMock) Trace(message string, args ...interface{})
  • func (c LoggerMock) Warn(message string, args ...interface{})
• type LoggerStub
• • func (stub *LoggerStub) Debug(message string, args ...interface{})
  • func (stub *LoggerStub) Error(message string, args ...interface{})
  • func (stub *LoggerStub) GetLevel() logger.LogLevel
  • func (stub *LoggerStub) Info(message string, args ...interface{})
  • func (stub *LoggerStub) IsInterfaceNil() bool
  • func (stub *LoggerStub) LogIfError(err error, args ...interface{})
  • func (stub *LoggerStub) Trace(message string, args ...interface{})
  • func (stub *LoggerStub) Warn(message string, args ...interface{})
• type MarshallerMock
• • func (mm *MarshallerMock) IsInterfaceNil() bool
  • func (mm *MarshallerMock) Marshal(obj interface{}) ([]byte, error)
  • func (mm *MarshallerMock) Unmarshal(obj interface{}, buff []byte) error
• type MarshallerStub
• • func (ms *MarshallerStub) IsInterfaceNil() bool
  • func (ms *MarshallerStub) Marshal(obj interface{}) ([]byte, error)
  • func (ms *MarshallerStub) Unmarshal(obj interface{}, buff []byte) error
• type PayloadHandlerStub
• • func (ph *PayloadHandlerStub) Close() error
  • func (ph *PayloadHandlerStub) IsInterfaceNil() bool
  • func (ph *PayloadHandlerStub) ProcessPayload(payload []byte, topic string, version uint32) error
• type ProtoMarshallerMock
• • func (pmm *ProtoMarshallerMock) IsInterfaceNil() bool
  • func (pmm *ProtoMarshallerMock) Marshal(obj interface{}) ([]byte, error)
  • func (pmm *ProtoMarshallerMock) Unmarshal(obj interface{}, buff []byte) error
• type WebsocketConnectionStub
• • func (w *WebsocketConnectionStub) Close() error
  • func (w *WebsocketConnectionStub) GetID() string
  • func (w *WebsocketConnectionStub) IsInterfaceNil() bool
  • func (w *WebsocketConnectionStub) IsOpen() bool
  • func (w *WebsocketConnectionStub) OpenConnection(url string) error
  • func (w *WebsocketConnectionStub) ReadMessage() (messageType int, payload []byte, err error)
  • func (w *WebsocketConnectionStub) WriteMessage(messageType int, data []byte) error