types

Documentation

Index

• Constants
• type IConsensusEngine
• type IPeerInfo
• type PeerInfo
  • func NewPeerInfo(peer *p2p.Peer, rw p2p.MsgReadWriter) *PeerInfo
  • func (pi *PeerInfo) Equal(pi2 IPeerInfo) bool
  • func (pi *PeerInfo) GetMsgRW() p2p.MsgReadWriter
  • func (pi *PeerInfo) ID() string
  • func (pi *PeerInfo) IP() string

Constants

const (
	Solo = iota
	Pbft
)

Types

type IConsensusEngine

type IConsensusEngine interface {
	Run(key *secp256k1.PrivateKey) (*types.Block, error)
	ReceiveMsg(peer *PeerInfo, t uint64, buf []byte)
}

type IPeerInfo

type IPeerInfo interface {
	GetMsgRW() p2p.MsgReadWriter
	//String() string
	IP() string
	Equal(ipeer IPeerInfo) bool
	ID() string
}

type PeerInfo

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

业务层peer

func NewPeerInfo

func NewPeerInfo(peer *p2p.Peer, rw p2p.MsgReadWriter) *PeerInfo

func (*PeerInfo) Equal

func (pi *PeerInfo) Equal(pi2 IPeerInfo) bool

func (*PeerInfo) GetMsgRW

func (pi *PeerInfo) GetMsgRW() p2p.MsgReadWriter

获取读写句柄

func (*PeerInfo) ID

func (pi *PeerInfo) ID() string

func (*PeerInfo) IP

func (pi *PeerInfo) IP() string