pex

type DestPeer struct {
	*MemberMeta
	PeerID string
}

type InitialMember = memberlist.Node

type InitialMemberLister interface {
	List() ([]*InitialMember, error)
}

type MemberMeta struct {
	HostID    string
	IP        string
	RPCPort   int32
	ProxyPort int32
	// contains filtered or unexported fields
}

type PeerExchangeMember interface {
	FindMember(hostID string) (*MemberMeta, error)
	Register(member *MemberMeta, sr PeerMetadataSendReceiveCloser) error
	UnRegister(member *MemberMeta)
	UnRegisterByHostID(hostID string)
}

type PeerExchangeRPC interface {
	PeerExchange(exchangeServer dfdaemonv1.Daemon_PeerExchangeServer) error
}

type PeerExchangeServer interface {
	Serve(localMember *MemberMeta) error
	Stop() error

	PeerSearchBroadcaster() PeerSearchBroadcaster
	PeerExchangeRPC() PeerExchangeRPC
}

type PeerExchangeSynchronizer interface {
	Sync(nodeMeta *MemberMeta, peer *dfdaemonv1.PeerExchangeData)
}

type PeerMetadataSendReceiveCloser interface {
	PeerMetadataSendReceiver
	Close() error
}

type PeerMetadataSendReceiver interface {
	Send(*dfdaemonv1.PeerExchangeData) error
	Recv() (*dfdaemonv1.PeerExchangeData, error)
}

type PeerSearchBroadcaster interface {
	SearchPeer(task string) SearchPeerResult
	BroadcastPeer(data *dfdaemonv1.PeerMetadata)
	BroadcastPeers(data *dfdaemonv1.PeerExchangeData)
}

type ReclaimFunc func(task, peer string) error

type SearchPeerResult struct {
	Type  SearchPeerResultType
	Peers []*DestPeer
}

type SearchPeerResultType int