logic

type MessageGateway interface {
	Send(peer transport.PeerID, envelope *protobuf.NetworkMessage)
	Broadcast(envelope *protobuf.NetworkMessage)
}

type MockMessageGateway struct {
	// contains filtered or unexported fields
}

type MockMessageGatewayMockRecorder struct {
	// contains filtered or unexported fields
}

type MockPeerOmnihashQueue struct {
	// contains filtered or unexported fields
}

type MockPeerOmnihashQueueMockRecorder struct {
	// contains filtered or unexported fields
}

type MockProtocol struct {
	// contains filtered or unexported fields
}

type MockProtocolMockRecorder struct {
	// contains filtered or unexported fields
}

type MockmessageSender struct {
	// contains filtered or unexported fields
}

type MockmessageSenderMockRecorder struct {
	// contains filtered or unexported fields
}

type MockmissingPayloadCollector struct {
	// contains filtered or unexported fields
}

type MockmissingPayloadCollectorMockRecorder struct {
	// contains filtered or unexported fields
}

type PeerOmnihash struct {
	// Peer holds the ID of the peer we got the hash from.
	Peer transport.PeerID
	// Hash holds the actual hash.
	Hash hash.SHA256Hash
}

type PeerOmnihashQueue interface {
	// Get blocks until there's an PeerOmnihash available and returns it.
	Get() *PeerOmnihash
}

type Protocol interface {
	core.Diagnosable
	// Configure configures the Protocol. Must be called before Start().
	Configure(advertHashesInterval time.Duration, advertDiagnosticsInterval time.Duration, collectMissingPayloadsInterval time.Duration, peerID transport.PeerID)
	// Start the Protocol (sending and receiving of messages).
	Start()
	// Stop the Protocol.
	Stop()
	// PeerDiagnostics returns a map containing diagnostic information of the node's peers. The key contains the remote peer's ID.
	PeerDiagnostics() map[transport.PeerID]transport.Diagnostics
	// Handle handles a received message.
	Handle(peer transport.Peer, envelope interface{}) error
}