network

type BizMessageID = [BizMessageIDLength]byte

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

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

type Conn struct {
	ID   string
	IP   string
	Port string
}

type DataType int32

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

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

type Group struct {
	ID string
	// contains filtered or unexported fields
}

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

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

type Message struct {
	ChainID uint16

	ProtocolVersion uint16

	Code uint32

	Body []byte
}

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

type MessageType int32

type MsgData struct {
	DataType             DataType `protobuf:"varint,1,opt,name=DataType,proto3,enum=network.DataType" json:"DataType,omitempty"`
	GroupID              string   `protobuf:"bytes,2,opt,name=GroupID,proto3" json:"GroupID,omitempty"`
	Expiration           uint64   `protobuf:"varint,3,opt,name=Expiration,proto3" json:"Expiration,omitempty"`
	MessageID            uint64   `protobuf:"varint,4,opt,name=MessageID,proto3" json:"MessageID,omitempty"`
	BizMessageID         []byte   `protobuf:"bytes,5,opt,name=BizMessageID,proto3" json:"BizMessageID,omitempty"`
	SrcNodeID            []byte   `protobuf:"bytes,6,opt,name=SrcNodeID,proto3" json:"SrcNodeID,omitempty"`
	Data                 []byte   `protobuf:"bytes,7,opt,name=Data,proto3" json:"Data,omitempty"`
	RelayCount           int32    `protobuf:"varint,8,opt,name=RelayCount,proto3" json:"RelayCount,omitempty"`
	MessageCode          uint32   `protobuf:"varint,9,opt,name=MessageCode,proto3" json:"MessageCode,omitempty"`
	MessageInfo          uint32   `protobuf:"varint,10,opt,name=MessageInfo,proto3" json:"MessageInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type MsgDigest []byte

type MsgFindNode struct {
	Target               []byte   `protobuf:"bytes,1,opt,name=Target,proto3" json:"Target,omitempty"`
	Expiration           uint64   `protobuf:"varint,2,opt,name=Expiration,proto3" json:"Expiration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type MsgHandler interface {
	Handle(sourceID string, msg Message) error
}

type MsgNeighbors struct {
	Nodes                []*RpcNode `protobuf:"bytes,1,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	Expiration           uint64     `protobuf:"varint,2,opt,name=Expiration,proto3" json:"Expiration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

type MsgPing struct {
	Version              int32        `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
	From                 *RpcEndPoint `protobuf:"bytes,2,opt,name=From,proto3" json:"From,omitempty"`
	To                   *RpcEndPoint `protobuf:"bytes,3,opt,name=To,proto3" json:"To,omitempty"`
	ChainID              uint32       `protobuf:"varint,4,opt,name=chainID,proto3" json:"chainID,omitempty"`
	Expiration           uint64       `protobuf:"varint,5,opt,name=Expiration,proto3" json:"Expiration,omitempty"`
	PK                   []byte       `protobuf:"bytes,6,opt,name=PK,proto3" json:"PK,omitempty"`
	Sign                 []byte       `protobuf:"bytes,7,opt,name=Sign,proto3" json:"Sign,omitempty"`
	CurTime              uint64       `protobuf:"varint,8,opt,name=CurTime,proto3" json:"CurTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

type MsgPong struct {
	Version              int32    `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
	VerifyResult         bool     `protobuf:"varint,2,opt,name=VerifyResult,proto3" json:"VerifyResult,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type NetCore struct {
	ID NodeID
	// contains filtered or unexported fields
}

type NetCoreConfig struct {
	ListenAddr         *net.UDPAddr
	ID                 NodeID
	Seeds              []*Node
	NatTraversalEnable bool

	NatPort         uint16
	NatIP           string
	ChainID         uint16
	ProtocolVersion uint16
}

type NetInterface interface {
	// contains filtered or unexported methods
}

type Network interface {
	//Send message to the node which id represents.If self doesn't connect to the node,
	// resolve the kad net to find the node and then send the message
	Send(id string, msg Message) error

	//Broadcast the message among the group which self belongs to
	SpreadAmongGroup(groupID string, msg Message) error

	//SpreadToGroup Broadcast the message to the group which self do not belong to
	SpreadToGroup(groupID string, groupMembers []string, msg Message, digest MsgDigest) error

	//TransmitToNeighbor Send message to neighbor nodes
	TransmitToNeighbor(msg Message, blacklist []string) error

	//Broadcast Send the message to all nodes it connects to and the node which receive the message also broadcast the message to their neighbor once
	Broadcast(msg Message) error

	//ConnInfo Return all connections self has
	ConnInfo() []Conn

	//BuildGroupNet build group network
	BuildGroupNet(groupID string, members []string)

	//DissolveGroupNet dissolve group network
	DissolveGroupNet(groupID string)

	//BuildProposerGroupNet build proposer group network
	BuildProposerGroupNet(proposers []*Proposer)

	//AddProposers add proposers to proposer group network
	AddProposers(proposers []*Proposer)
}

type NetworkConfig struct {
	NodeIDHex       string
	NatAddr         string
	NatPort         uint16
	SeedAddr        string
	ChainID         uint16 // Chain id
	ProtocolVersion uint16 // Protocol version
	TestMode        bool
	IsSuper         bool
	SeedIDs         []string
	PK              string
	SK              string
}

type Node struct {
	ID      NodeID
	IP      net.IP
	Port    int
	NatType int
	// contains filtered or unexported fields
}

type NodeID [NodeIDLength]byte

type Peer struct {
	ID NodeID

	IP   net.IP
	Port int
	// contains filtered or unexported fields
}

type PeerAuthContext struct {
	PK      []byte
	Sign    []byte
	CurTime uint64
}

type PeerIPSet struct {
	Limit uint // maximum number of IPs in each subnet
	// contains filtered or unexported fields
}

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

type PeerSource int32

type Proposer struct {
	ID    NodeID
	Stake uint64
}

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

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

type RpcEndPoint struct {
	IP                   string   `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"`
	Port                 int32    `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RpcNode struct {
	IP                   string   `protobuf:"bytes,1,opt,name=IP,proto3" json:"IP,omitempty"`
	Port                 int32    `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
	ID                   string   `protobuf:"bytes,3,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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

type SendPriorityType uint32

type Server struct {
	Self *Node
	// contains filtered or unexported fields
}