Signed-off-by: Anton Nikiforov <an.nikiforov@yadro.com>

@@ -0,0 +12,4 @@
+)
+
+type Metric interface {
+	CalculateValue(*netmap.NodeInfo, *netmap.NodeInfo) []byte

@@ -0,0 +22,4 @@
+	return errors.New("unsupported priority metric")
+}
+
+func ParseMetric(raw string) Metric {

@@ -0,0 +46,4 @@
+}
+
+func NewAttributeMetric(raw string) Metric {
+	attr, _ := strings.CutPrefix(raw, attrPrefix)

@@ -55,1 +68,3 @@
-const invalidOptsMsg = "invalid traverser options"
+const (
+	invalidOptsMsg = "invalid traverser options"
+	uint16Bytes    = 2

@@ -160,0 +208,4 @@
+		for _, m := range cfg.metrics {
+			metrics[i] = append(metrics[i], m.CalculateValue(&node, &unsortedVector[i])...)
+		}
+		binary.LittleEndian.PutUint16(b, uint16(i))

@@ -160,0 +209,4 @@
+			metrics[i] = append(metrics[i], m.CalculateValue(&node, &unsortedVector[i])...)
+		}
+		binary.LittleEndian.PutUint16(b, uint16(i))
+		metrics[i] = append(metrics[i], b...)

@@ -277,1 +280,4 @@
 }
+
+type nodeState struct {
+	node *netmapAPI.NodeInfo

@@ -278,0 +324,4 @@
+		next := tr.Next()
+		require.NotNil(t, next)
+		require.Equal(t, 3, len(next))
+		require.Equal(t, "/ip4/0.0.0.0/tcp/2", string(next[0].PublicKey()))

@@ -160,0 +209,4 @@
+			metrics[i] = append(metrics[i], m.CalculateValue(&node, &unsortedVector[i])...)
+		}
+		binary.LittleEndian.PutUint16(b, uint16(i))
+		metrics[i] = append(metrics[i], b...)

@@ -103,0 +123,4 @@
+			unsortedVector = append(unsortedVector, ns[i][:rem[i]]...)
+			regularVector = append(regularVector, ns[i][rem[i]:]...)
+		}
+		rem = make([]int, 2)

@@ -101,2 +117,3 @@
 	var rem []int
-	if cfg.flatSuccess != nil {
+	if len(cfg.metrics) > 0 {
+		rem = defaultCopiesVector(cfg.policy)

@@ -278,0 +316,4 @@
+			}),
+			WithoutSuccessTracking(),
+			WithPriorityMetrics(m),
+			WithNodeState(&nodeState{

@@ -324,1 +380,4 @@
 }
+
+// WithPriorityMetrics use provided priority metrics to sort nodes.
+func WithPriorityMetrics(m []Metric) Option {

@@ -53,3 +63,3 @@
 }
 
-const invalidOptsMsg = "invalid traverser options"
+const (

@@ -0,0 +32,4 @@
+func (am *attributeMetric) CalculateValue(from *netmap.NodeInfo, to *netmap.NodeInfo) int {
+	fromAttr := from.Attribute(am.attribute)
+	toAttr := to.Attribute(am.attribute)
+	if len(fromAttr) > 0 && len(toAttr) > 0 && fromAttr == toAttr {

@@ -278,0 +330,4 @@
+		)
+		require.NoError(t, err)
+
+		// Without priority metric `ClusterName` the order will be:

@@ -41,3 +43,3 @@
 }
 
-func testPlacement(ss, rs []int) ([][]netmap.NodeInfo, container.Container) {
+func testPlacement(ss []int, rs [][]int) ([][]netmap.NodeInfo, container.Container) {