Function getPartitionStateFromStore

ring/partition_instance_lifecycler_test.go:417–423

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

}

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

func createTestPartitionInstanceLifecyclerConfig(partitionID int32, instanceID string) PartitionInstanceLifecyclerConfig {
	return PartitionInstanceLifecyclerConfig{