Function TestNewRingsServiceDiscovery

ring/client/ring_service_discovery_test.go:58–142

(t *testing.T)

}

func TestNewRingsServiceDiscovery(t *testing.T) {
	tests := map[string]struct {
		rings         []*mockReadRing
		expectedAddrs []string
		expectedErr   error
	}{
		"no rings": {
			rings:         nil,
			expectedAddrs: nil,
		},
		"single ring with multiple instances": {
			rings: []*mockReadRing{
				{mockedReplicationSet: ring.ReplicationSet{Instances: []ring.InstanceDesc{
					{Addr: "1.1.1.1"},
					{Addr: "2.2.2.2"},
				}}},
			},
			expectedAddrs: []string{"1.1.1.1", "2.2.2.2"},
		},
		"multiple rings with disjoint instances": {
			rings: []*mockReadRing{
				{mockedReplicationSet: ring.ReplicationSet{Instances: []ring.InstanceDesc{
					{Addr: "1.1.1.1"},
					{Addr: "2.2.2.2"},
				}}},
				{mockedReplicationSet: ring.ReplicationSet{Instances: []ring.InstanceDesc{
					{Addr: "3.3.3.3"},
				}}},
			},
			expectedAddrs: []string{"1.1.1.1", "2.2.2.2", "3.3.3.3"},
		},
		"multiple rings with overlapping instances are deduplicated": {
			rings: []*mockReadRing{
				{mockedReplicationSet: ring.ReplicationSet{Instances: []ring.InstanceDesc{
					{Addr: "1.1.1.1"},
					{Addr: "2.2.2.2"},
				}}},
				{mockedReplicationSet: ring.ReplicationSet{Instances: []ring.InstanceDesc{
					{Addr: "2.2.2.2"},
					{Addr: "3.3.3.3"},
				}}},
			},
			expectedAddrs: []string{"1.1.1.1", "2.2.2.2", "3.3.3.3"},
		},
		"duplicate instances within a single ring are deduplicated": {
			rings: []*mockReadRing{
				{mockedReplicationSet: ring.ReplicationSet{Instances: []ring.InstanceDesc{
					{Addr: "1.1.1.1"},
					{Addr: "1.1.1.1"},
				}}},
			},
			expectedAddrs: []string{"1.1.1.1"},
		},
		"all rings are empty": {
			rings: []*mockReadRing{
				{mockedErr: ring.ErrEmptyRing},
				{mockedErr: ring.ErrEmptyRing},
			},