(t *testing.T)
| 736 | } |
| 737 | |
| 738 | func TestBuildProgressRangeTree(t *testing.T) { |
| 739 | s := createBackupSuite(t) |
| 740 | ranges := []rtree.KeyRange{ |
| 741 | { |
| 742 | StartKey: []byte("aa"), |
| 743 | EndKey: []byte("b"), |
| 744 | }, |
| 745 | { |
| 746 | StartKey: []byte("c"), |
| 747 | EndKey: []byte("d"), |
| 748 | }, |
| 749 | { |
| 750 | StartKey: []byte("f"), |
| 751 | EndKey: []byte("g"), |
| 752 | }, |
| 753 | } |
| 754 | tree, err := s.backupClient.BuildProgressRangeTree(context.Background(), ranges, nil, func(backup.ProgressUnit) {}) |
| 755 | require.NoError(t, err) |
| 756 | |
| 757 | contained, err := tree.FindContained([]byte("a"), []byte("aa")) |
| 758 | require.Nil(t, contained) |
| 759 | require.NoError(t, err) |
| 760 | |
| 761 | contained, err = tree.FindContained([]byte("b"), []byte("ba")) |
| 762 | require.Nil(t, contained) |
| 763 | require.NoError(t, err) |
| 764 | |
| 765 | contained, err = tree.FindContained([]byte("e"), []byte("ea")) |
| 766 | require.Nil(t, contained) |
| 767 | require.NoError(t, err) |
| 768 | |
| 769 | contained, err = tree.FindContained([]byte("aa"), []byte("b")) |
| 770 | require.NotNil(t, contained) |
| 771 | require.Equal(t, []byte("aa"), contained.Origin.StartKey) |
| 772 | require.Equal(t, []byte("b"), contained.Origin.EndKey) |
| 773 | require.NoError(t, err) |
| 774 | |
| 775 | contained, err = tree.FindContained([]byte("cc"), []byte("e")) |
| 776 | require.Nil(t, contained) |
| 777 | require.Error(t, err) |
| 778 | |
| 779 | contained, err = tree.FindContained([]byte("e"), []byte("ff")) |
| 780 | require.Nil(t, contained) |
| 781 | require.NoError(t, err) |
| 782 | } |
| 783 | |
| 784 | func TestObserveStoreChangesAsync(t *testing.T) { |
| 785 | s := createBackupSuite(t) |
nothing calls this directly
no test coverage detected