p2p

type ChainProvider interface {
	GetChainData(kind string, key []byte) []byte
}

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

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

type Message struct {
	MsgType string
	From    string
	Key     []byte
	Data    []byte
}

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

type RecfgCommand struct {
	Validator      bool // is validator
	SubnetMaskBits int  // mask bits for sub network identity
}

type Service interface {
	Start() error
	Stop()
	Ready()

	Reconfig(reCfg *RecfgCommand) error
	BroadcastMessage(message Message) error
	//如果在多个子网，随机选一个。如果单一子网，直接发布。
	BroadcastMessageOsn(message Message) error
	Register(subscriber *Subscriber)
	UnRegister(subscriber *Subscriber)

	DhtGetValue(key []byte) ([]byte, error)
	DhtGetValues(keys [][]byte, out chan<- []byte, timeout time.Duration) error
	DhtSetValue(key []byte, value []byte) error

	// p2p service get chain data from provider
	RegChainProvider(cp ChainProvider)

	// ask peer for chain info
	GetChainInfo(kind string, key []byte) ([]byte, error)
}

type SingleSubnetDescriptor = sch.SingleSubnetDescriptor // single subnet descriptor

type SubnetDescriptor struct {
	SubNetKeyList      map[config.SubNetworkID]ecdsa.PrivateKey // keys for sub-node
	SubNetNodeList     map[config.SubNetworkID]config.Node      // sub-node identities
	SubNetMaxPeers     map[config.SubNetworkID]int              // max peers would be
	SubNetMaxOutbounds map[config.SubNetworkID]int              // max concurrency outbounds
	SubNetMaxInBounds  map[config.SubNetworkID]int              // max concurrency inbounds
	SubNetIdList       []config.SubNetworkID                    // sub network identity list
}

type Subscriber struct {
	ID      interface{}
	MsgChan chan Message
	MsgType string
}

type Transport interface {
}

type YeShellConfig struct {
	// Notice: in current stage, a simple configuration for p2p is applied, for total configuration
	// about p2p, see config.Config please.
	AppType           config.P2pAppType // application type
	Name              string            // node name, should be unique
	ChainId           uint32            // chain identity
	Validator         bool              // validator flag
	BootstrapNode     bool              // bootstrap node flag
	BootstrapNodes    []string          // bootstrap nodes
	DhtBootstrapNodes []string          // bootstrap nodes for dht
	LocalNodeIp       string            // local node ip for chain-peers
	LocalUdpPort      uint16            // local node udp port
	LocalTcpPort      uint16            // local node tcp port
	LocalDhtIp        string            // local dht ip
	LocalDhtPort      uint16            // local dht port
	NodeDataDir       string            // node data directory
	NodeDatabase      string            // node database
	SubNetMaskBits    int               // mask bits for sub network identity
	EvKeepTime        time.Duration     // duration for events kept by dht
	DedupTime         time.Duration     // duration for deduplication cleanup timer
	BootstrapTime     time.Duration     // duration for bootstrap blind connection
	NatType           string            // nat type, "none"/"pmp"/"upnp"
	GatewayIp         string            // gateway ip when nat type is "pmp"
	// contains filtered or unexported fields
}

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

type YesErrno int