Function Test_resolveConflicts

pkg/ring/model_test.go:749–825

(t *testing.T)

}

func Test_resolveConflicts(t *testing.T) {
	tests := []struct {
		name string
		args map[string]InstanceDesc
		want map[string]InstanceDesc
	}{
		{
			name: "Empty input",
			args: map[string]InstanceDesc{},
			want: map[string]InstanceDesc{},
		},
		{
			name: "No conflicts",
			args: map[string]InstanceDesc{
				"ing1": {State: ACTIVE, Tokens: []uint32{1, 2, 3}},
				"ing2": {State: ACTIVE, Tokens: []uint32{4, 5, 6}},
			},
			want: map[string]InstanceDesc{
				"ing1": {State: ACTIVE, Tokens: []uint32{1, 2, 3}},
				"ing2": {State: ACTIVE, Tokens: []uint32{4, 5, 6}},
			},
		},
		{
			name: "Conflict resolution with LEFT state",
			args: map[string]InstanceDesc{
				"ing1": {State: ACTIVE, Tokens: []uint32{1, 2, 3}},
				"ing2": {State: LEFT, Tokens: []uint32{1, 2, 3, 4}},
			},
			want: map[string]InstanceDesc{
				"ing1": {State: ACTIVE, Tokens: []uint32{1, 2, 3}},
				"ing2": {State: LEFT, Tokens: nil},
			},
		},
		{
			name: "Conflict resolution with LEAVING state",
			args: map[string]InstanceDesc{
				"ing1": {State: LEAVING, Tokens: []uint32{1, 2, 3}},
				"ing2": {State: PENDING, Tokens: []uint32{1, 2, 3, 4}},
			},
			want: map[string]InstanceDesc{
				"ing1": {State: LEAVING, Tokens: nil},
				"ing2": {State: PENDING, Tokens: []uint32{1, 2, 3, 4}},
			},
		},
		{
			name: "Conflict resolution with JOINING state",
			args: map[string]InstanceDesc{
				"ing1": {State: ACTIVE, Tokens: []uint32{1, 2, 3}},
				"ing2": {State: JOINING, Tokens: []uint32{1, 2, 3, 4}},
			},
			want: map[string]InstanceDesc{
				"ing1": {State: ACTIVE, Tokens: []uint32{1, 2, 3}},
				"ing2": {State: JOINING, Tokens: []uint32{4}},
			},
		},
		{
			name: "Conflict resolution with same state",
			args: map[string]InstanceDesc{