Function getPartitionRingFromStore

ring/partition_instance_lifecycler_test.go:410–415

(t *testing.T, store kv.Client, key string)

}

func getPartitionRingFromStore(t *testing.T, store kv.Client, key string) *PartitionRingDesc {
	in, err := store.Get(context.Background(), key)
	require.NoError(t, err)

	return GetOrCreatePartitionRingDesc(in)
}

func getPartitionStateFromStore(t *testing.T, store kv.Client, key string, partitionID int32) PartitionState {
	partition, ok := getPartitionRingFromStore(t, store, key).GetPartitions()[partitionID]