policer

type MetricsCollector interface {
	// SetPolicerConsistency must update [Policer] consistency metric
	// based on background check progress. `true` is for the consistent
	// state, `false` for the opposite one.
	SetPolicerConsistency(bool)
	// SetPolicerOptimalPlacement must update [Policer] optimal placement
	// metric based on background check progress. `true` is for the
	// optimal placement, `false` for the opposite one.
	SetPolicerOptimalPlacement(bool)
	// IncPolicerCycleCount increments number of completed policer cycles.
	IncPolicerCycleCount()
	// IncPolicerObjectProcessed increments processed objects counter.
	IncPolicerObjectProcessed(isEC bool)
	// IncPolicerObjectReplicated increments replicated objects counter.
	IncPolicerObjectReplicated(isEC bool)
	// IncPolicerObjectDeleted increments deleted objects counter.
	IncPolicerObjectDeleted(isEC bool)
}

type Network interface {
	// IsLocalNodeInNetmap checks whether the local node belongs to the current
	// network map. If it is impossible to check this fact, IsLocalNodeInNetmap
	// returns false.
	IsLocalNodeInNetmap() bool
	// GetNodesForObject returns descriptors of storage nodes matching storage
	// policy of the referenced object for now. Nodes are identified by their public
	// keys and can be repeated in different lists. First len(repRules) lists relate
	// to replication, the rest len(ecRules) - to EC.
	//
	// repRules specifies replication rules: the number (N) of primary object
	// holders for each list (L) so:
	//  - size of each L >= N;
	//  - first N nodes of each L are primary data holders while others (if any)
	//    are backup.
	//
	// ecRules specifies erasure coding rules for all objects in the container: each
	// object is split into [iec.Rule.DataPartNum] data and [iec.Rule.ParityPartNum]
	// parity parts. Each i-th part most expected to be located on SN described by
	// i-th list element. In general, list len is a multiple of CBF, and the part is
	// expected on N with index M*i, M in [0,CBF). Then part is expected on SN
	// for i+1-th part and so on.
	//
	// GetNodesForObject callers do not change resulting slices and their elements.
	//
	// Returns [apistatus.ErrContainerNotFound] if requested container is missing in
	// the network.
	GetNodesForObject(oid.Address) (nodeLists [][]netmapsdk.NodeInfo, repRules []uint, ecRules []iec.Rule, err error)
	// IsLocalNodePublicKey checks whether given binary-encoded public key is
	// assigned in the network map to a local storage node running [Policer].
	IsLocalNodePublicKey([]byte) bool
}

type Option func(*cfg)

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