peerv2

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

type AllConnectionStatus struct {
	Status map[string][]ConnectionStatus `json:"status"`
}

type BlockGetter interface {
	StreamBlockByHeight(fromPool bool, req *proto.BlockByHeightRequest) chan interface{}
	StreamBlockByHash(fromPool bool, req *proto.BlockByHashRequest) chan interface{}
	GetShardBlockByHeight(height uint64, shardID byte) (map[common.Hash]*types.ShardBlock, error)
	GetShardBlockByHash(hash common.Hash) (*types.ShardBlock, uint64, error)
	GetBeaconBlockByHeight(height uint64) ([]*types.BeaconBlock, error)
	GetBeaconBlockByHash(beaconBlockHash common.Hash) (*types.BeaconBlock, uint64, error)
}

type BlockProvider struct {
	proto.UnimplementedHighwayServiceServer
	BlockGetter BlockGetter
}

type BlockRequester struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type ConnManager struct {
	LocalHost  *Host
	Subscriber ForcedSubscriber

	DiscoverPeersAddress []string
	IsMasterNode         bool

	Requester *BlockRequester
	Provider  *BlockProvider
	// contains filtered or unexported fields
}

type ConnectionStatus struct {
	URL         string `json:"url"`
	IsCurrentHW bool   `json:"iscurrenthw"`
	RTT         string `json:"rttmetric"`
}

type ConsensusData interface {
	GetValidators() []*consensus.Validator
	GetOneValidator() *consensus.Validator
	GetOneValidatorForEachConsensusProcess() map[int]*consensus.Validator
}

type Dispatcher struct {
	MessageListeners   *MessageListeners
	PublishableMessage []string
	BC                 *blockchain.BlockChain
	CurrentHWPeerID    libp2p.ID
}

type ForcedSubscriber interface {
	Subscribe(forced bool) error
	GetMsgToTopics() msgToTopics
	SetSyncMode(string)
}

type GRPCDialer interface {
	Dial(ctx context.Context, peerID peer.ID, dialOpts ...grpc.DialOption) (*grpc.ClientConn, error)
}

type HighwayDiscoverer interface {
	DiscoverHighway(discoverPeerAddress string, shardsStr []string) (map[string][]rpcclient.HighwayAddr, error)
}

type Host struct {
	Version  string
	Host     host.Host
	SelfPeer *Peer
	GRPC     *p2pgrpc.GRPCProtocol
}

type HostConfig struct {
	MaxConnection int
	PublicIP      string
	Port          int
	PrivateKey    crypto.PrivKey
}

type MessageListeners struct {
	OnTx             func(p *peer.PeerConn, msg *wire.MessageTx)
	OnTxPrivacyToken func(p *peer.PeerConn, msg *wire.MessageTxPrivacyToken)
	OnBlockShard     func(p *peer.PeerConn, msg *wire.MessageBlockShard)
	OnBlockBeacon    func(p *peer.PeerConn, msg *wire.MessageBlockBeacon)
	OnCrossShard     func(p *peer.PeerConn, msg *wire.MessageCrossShard)
	OnGetBlockBeacon func(p *peer.PeerConn, msg *wire.MessageGetBlockBeacon)
	OnGetBlockShard  func(p *peer.PeerConn, msg *wire.MessageGetBlockShard)
	OnGetCrossShard  func(p *peer.PeerConn, msg *wire.MessageGetCrossShard)
	OnVersion        func(p *peer.PeerConn, msg *wire.MessageVersion)
	OnVerAck         func(p *peer.PeerConn, msg *wire.MessageVerAck)
	OnGetAddr        func(p *peer.PeerConn, msg *wire.MessageGetAddr)
	OnAddr           func(p *peer.PeerConn, msg *wire.MessageAddr)

	//PBFT
	OnBFTMsg     func(p *peer.PeerConn, msg wire.Message)
	OnPeerState  func(p *peer.PeerConn, msg *wire.MessagePeerState)
	OnFinishSync func(p *peer.PeerConn, msg *wire.MessageFinishSync)
	OnFeatureMsg func(p *peer.PeerConn, msg *wire.MessageFeature)
}

type Peer struct {
	IP            string
	Port          int
	TargetAddress []core.Multiaddr
	PeerID        peer.ID
	PublicKey     crypto2.PublicKey
}

type PeerConn struct {
	RemotePeer *Peer
	RW         *bufio.ReadWriter
}

type Peerv2Logger struct {
	common.Logger
}

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

type Registerer interface {
	Register(context.Context, string, []string, []byte, peer.ID, string) ([]*proto.MessageTopicPair, *proto.UserRole, error)
	Target() string
	UpdateTarget(peer.ID)
}

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

type Subscriber interface {
	Subscribe(topic string, opts ...pubsub.SubOpt) (*pubsub.Subscription, error)
}

type Topic struct {
	Name string
	Sub  *pubsub.Subscription
	Act  proto.MessageTopicPair_Action
}