ktable

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

type CommandReturn[T any] interface {
	Command
	Query[T]
}

type DropAddr struct {
	Addr   netip.Addr
	Reason error
}

type DropNode struct {
	ID     ID
	Reason error
}

type FilterKnownAddrs struct {
	Addrs []netip.Addr
}

type GetClosestPeers struct {
	ID ID
}

type GetHashOrClosestNodes struct {
	ID ID
}

type GetHashOrClosestNodesResult struct {
	Hash         Hash
	ClosestNodes []Node
	Found        bool
}

type GetNodesForSampleInfoHashes struct {
	N int
}

type GetOldestPeers struct {
	Cutoff time.Time
	N      int
}

type Hash interface {
	Peers() []HashPeer
	Dropped() bool
	// contains filtered or unexported methods
}

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

type HashPeer struct {
	Addr netip.AddrPort
}

type ID = protocol.ID

type Node interface {
	Addr() netip.AddrPort
	Time() time.Time
	Dropped() bool
	IsSampleInfoHashesCandidate() bool
	// contains filtered or unexported methods
}

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

type Params struct {
	fx.In
	NodeID ID `name:"dht_node_id"`
}

type PutHash struct {
	ID      ID
	Peers   []HashPeer
	Options []HashOption
}

type PutNode struct {
	ID      ID
	Addr    netip.AddrPort
	Options []NodeOption
}

type Query[T any] interface {
	// contains filtered or unexported methods
}

type Result struct {
	fx.Out
	Table                Table
	NodesCountGauge      prometheus.Collector `group:"prometheus_collectors"`
	NodesAddedCounter    prometheus.Collector `group:"prometheus_collectors"`
	NodesDroppedCounter  prometheus.Collector `group:"prometheus_collectors"`
	HashesCountGauge     prometheus.Collector `group:"prometheus_collectors"`
	HashesAddedCounter   prometheus.Collector `group:"prometheus_collectors"`
	HashesDroppedCounter prometheus.Collector `group:"prometheus_collectors"`
}

type SampleHashesAndNodes struct{}

type SampleHashesAndNodesResult struct {
	Hashes      []Hash
	Nodes       []Node
	TotalHashes int
}

type Table interface {
	TableOrigin
	TableCommand
	TableQuery
	BatchCommand(commands ...Command)
}

type TableCommand interface {
	PutNode(id ID, addr netip.AddrPort, options ...NodeOption) btree.PutResult
	DropNode(id ID, reason error) bool
	PutHash(id ID, peers []HashPeer, options ...HashOption) btree.PutResult
}

type TableOrigin interface {
	Origin() ID
}

type TableQuery interface {
	GetClosestNodes(id ID) []Node
	GetOldestNodes(cutoff time.Time, n int) []Node
	GetNodesForSampleInfoHashes(n int) []Node
	FilterKnownAddrs(addrs []netip.Addr) []netip.Addr
	GetHashOrClosestNodes(id ID) GetHashOrClosestNodesResult
	// SampleHashesAndNodes returns a random sample of up to 8 hashes and nodes, and the total hashes count.
	SampleHashesAndNodes() SampleHashesAndNodesResult
}