network

type BootstrapConfig struct {
	Addresses    []string      `toml:"addresses"`
	MinThreshold int           `toml:"min_threshold"`
	MaxThreshold int           `toml:"max_threshold"`
	Period       time.Duration `toml:"period"`
}

type BroadcastData struct {
	Data   []byte
	Target *lp2pcore.PeerID
}

type Config struct {
	Name        string           `toml:"name"`
	Listens     []string         `toml:"listens"`
	NodeKey     string           `toml:"node_key"`
	EnableDHT   bool             `toml:"enable_dht"`
	EnableNAT   bool             `toml:"enable_nat"`
	EnableRelay bool             `toml:"enable_relay"`
	EnablePing  bool             `toml:"enable_ping"`
	EnableMdns  bool             `toml:"enable_mdns"`
	Bootstrap   *BootstrapConfig `toml:"bootstrap"`
}

type Event interface {
	Type() EventType
}

type EventType int

type GossipMessage struct {
	Source lp2pcore.PeerID
	From   lp2pcore.PeerID
	Data   []byte
}

type MockNetwork struct {
	BroadcastCh chan BroadcastData
	EventCh     chan Event
	ID          peer.ID
	OtherNets   []*MockNetwork
}

type Network interface {
	Start() error
	Stop()
	EventChannel() <-chan Event
	Broadcast([]byte, TopicID) error
	SendTo([]byte, lp2pcore.PeerID) error
	JoinGeneralTopic() error
	JoinConsensusTopic() error
	CloseConnection(pid lp2pcore.PeerID)
	SelfID() lp2pcore.PeerID
	NumConnectedPeers() int
}

type StreamMessage struct {
	Source lp2pcore.PeerID
	Reader io.ReadCloser
}

type TopicID int