dht

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

type ConInstDir = int

type ConInstRxDataCallback func(conInst interface{}, pid uint32, msg interface{}) int

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

type Datastore interface {
	Put(key []byte, value DsValue, kt time.Duration) DhtErrno

	Get(key []byte) (eno DhtErrno, value DsValue)

	Delete(key []byte) DhtErrno

	Close() DhtErrno
}

type DhtCallback func(mgr interface{}, mid int, msg interface{}) int

type DhtDatastoreRecord struct {
	Key   []byte // key
	Value []byte // value
	Extra []byte // extra info
}

type DhtErrno int

type DhtKey = []byte

type DhtMessage struct {
	Mid            uint32          // message identity
	Handshake      *Handshake      // handshake message
	FindNode       *FindNode       // find node message
	Neighbors      *Neighbors      // neighbors message
	PutValue       *PutValue       // put value message
	GetValueReq    *GetValueReq    // get value request message
	GetValueRsp    *GetValueRsp    // get value response message
	PutProvider    *PutProvider    // put provider message
	GetProviderReq *GetProviderReq // get provider request message
	GetProviderRsp *GetProviderRsp // get provider response message
	Ping           *Ping           // ping message
	Pong           *Pong           // pong message
}

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

type DhtPackage struct {
	Pid           uint32 // protocol identity
	PayloadLength uint32 // payload length
	Payload       []byte // payload
}

type DhtProtocol struct {
	Pid uint32              // protocol identity
	Ver [DhtProtoBytes]byte // protocol version: M.m0.m1.m2
}

type DhtProvider struct {
	Key   DhtKey         // key of provider
	Nodes []*config.Node // node of provider
	Extra interface{}    // extra inforamtion
}

type DhtProviderStoreRecord struct {
	Key       []byte         // key
	Providers []*config.Node // providers
	Extra     []byte         // extra info
}

type DhtVal = []byte

type DhtValue struct {
	Key   DhtKey      // key of value
	Val   DhtVal      // value
	Extra interface{} // extra inforamtion
}

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

type DiffTimerCallback func(interface{}) error

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

type DsKey = config.DsKey

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

type DsQuery = interface{}

type DsQueryResult = interface{}

type DsRecord struct {
	Key   DsKey   // record key
	Value DsValue // record value
}

type DsValue = interface{}

type FileDatastore struct{}

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

type FindNode struct {
	From   config.Node  // source node
	To     config.Node  // destination node
	Target config.DsKey // target node identity
	Id     int64        // message identity
	Extra  []byte       // extra info
}

type GetProviderReq struct {
	From  config.Node // source node
	To    config.Node // destination node
	Key   DhtKey      // key wanted
	Id    int64       // message identity
	Extra []byte      // extra info
}

type GetProviderRsp struct {
	From     config.Node    // source node
	To       config.Node    // destination node
	Provider *DhtProvider   // provider
	Key      DhtKey         // key
	Nodes    []*config.Node // neighbor nodes
	Pcs      []int          // peer connection status
	Id       int64          // message identity
	Extra    []byte         // extra info
}

type GetValueReq struct {
	From  config.Node // source node
	To    config.Node // destination node
	Key   DhtKey      // keys requested
	Id    int64       // message identity
	Extra []byte      // extra info
}

type GetValueRsp struct {
	From  config.Node    // source node
	To    config.Node    // destination node
	Value *DhtValue      // values
	Key   DhtKey         // keys requested
	Nodes []*config.Node // neighbor nodes
	Pcs   []int          // peer connection status
	Id    int64          // message identity
	Extra []byte         // extra info
}

type Handshake struct {
	ChainId   uint32        // chain identity
	Dir       int           // direct
	NodeId    config.NodeID // node identity
	IP        net.IP        // ip address
	UDP       uint32        // udp port number
	TCP       uint32        // tcp port number
	ProtoNum  uint32        // number of protocols supported
	Protocols []DhtProtocol // version of protocol
	Extra     []byte        // extra info
}

type Hash [HashByteLength]byte

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

type LeveldbDatastoreConfig struct {
	Path                   string
	OpenFilesCacheCapacity int
	BlockCacheCapacity     int
	BlockSize              int
	FilterBits             int
}

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

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

type Neighbors struct {
	From  config.Node    // source node
	To    config.Node    // destination node
	Nodes []*config.Node // neighbor nodes
	Pcs   []int          // peer connection status
	Id    int64          // message identity
	Extra []byte         // extra info
}

type Ping struct {
	From  config.Node // from whom
	To    config.Node // to whom
	Seq   int64       // sequence
	Extra []byte      // extra info
}

type Pong struct {
	From  config.Node // from whom
	To    config.Node // to whom
	Seq   int64       // sequence
	Extra []byte      // extra info
}

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

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

type PsRecord struct {
	Key   DsKey         // provider record key
	Value DsValue       // provider record value
	KT    time.Duration // duratio to keep this [key, val] pair
}

type PutProvider struct {
	From     config.Node  // source node
	To       config.Node  // destination node
	Provider *DhtProvider // providers
	Pcs      []int        // prividers connection status
	Id       int64        // message identity
	Extra    []byte       // extra info
}

type PutValue struct {
	From   config.Node   // source node
	To     config.Node   // destination node
	Values []DhtValue    // values
	Id     int64         // message identity
	KT     time.Duration // duration to keep this [key, val] pair
	Extra  []byte        // extra info
}

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

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

type QryStatus = int

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

type TimerCallback = func(el *list.Element, data interface{}) interface{}

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