Module lease

Structs§

alive_datanodes: Find all alive datanodes
alive_flownodes: Find all alive flownodes
build_lease_filter 🔒
filter
find_datanode_lease_value: Returns the lease value of the given datanode id, if the datanode is not found, returns None.
is_datanode_accept_ingest_workload: Returns true if the datanode can accept ingest workload based on its workload types.
lookup_datanode_peer: look up [Peer] given [ClusterId] and DatanodeId, will only return if it’s alive under given lease_secs
lookup_flownode_peer: look up [Peer] given [ClusterId] and DatanodeId, only return if it’s alive under given lease_secs