connection

type BroadcastParams struct {
	ToNode      toNodeType
	ToShard     shard.Index
	IncludeSelf bool
}

type ConnPeer struct {
	// The following variables must only be used atomically
	CpFeeFilter int64

	*peer.Peer

	// The following chans are used to sync blockmanager and Server.
	ServerPeerHandle func(p peer.Reply, msg wire.Message, buf []byte)
	// contains filtered or unexported fields
}

type ConnServer struct {
	ConnectToEnoughPeers chan struct{}
	// contains filtered or unexported fields
}

type ConnectNodeMsg struct {
	Addr      string
	Permanent bool
	Reply     chan error
}

type Connector interface {
	UpdatePeerInfo([]shard.Index)
}

type DisconnectNodeMsg struct {
	Cmp   func(*ConnPeer) bool
	Reply chan error
}

type GetAddedNodesMsg struct {
	Reply chan []*ConnPeer
}

type GetConnCountMsg struct {
	Reply chan int32
}

type GetPeerShardCountMsg struct {
	Reply chan int32
}

type GetPeersMsg struct {
	Reply chan []*ConnPeer
}

type GetShardPeersAddrMsg struct {
	Shard []shard.Index
	Reply chan []string
}

type GetShardPeersCountMsg struct {
	Reply chan []int32
}

type GossipNode interface {
	BroadcastMessage(msg wire.Message, par *BroadcastParams)
	RegisterChannels(dispatch *MessagesAndReceiver)
	HandleMessage(msg wire.Message)
}

type MessageAndReply struct {
	Msg   wire.Message
	Reply peer.Reply
}

type MessagesAndReceiver struct {
	Tags     []Tag
	Channels chan *MessageAndReply
}

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

type NAT interface {
	// Get the external address from outside the NAT.
	GetExternalAddress() (addr net.IP, err error)
	// Add a port mapping for protocol ("udp" or "tcp") from external port to
	// internal port with description lasting for timeout.
	AddPortMapping(protocol string, externalPort, internalPort int, description string, timeout int) (mappedExternalPort int, err error)
	// Remove a previously added port mapping from external port to
	// internal port.
	DeletePortMapping(protocol string, externalPort, internalPort int) (err error)
}

type RemoveNodeMsg struct {
	Cmp   func(*ConnPeer) bool
	Reply chan error
}

type Tag struct {
	Msg   string
	Shard shard.Index
}