Function TestPagination

plugin/plugin_test/kv_storage_test.go:250–298

Test pagination in GetByGroup

(t *testing.T)

// Test pagination in GetByGroup
func TestPagination(t *testing.T) {
	setupTestEnvironment()
	kv := testPlugin.operator
	ctx := context.Background()
	totalItems := 25

	for i := range totalItems {
		mustSet(t, kv, ctx, "pagination", fmt.Sprintf("key%d", i), fmt.Sprintf("value%d", i))
	}

	// Test pagination
	page1, err := kv.GetByGroup(ctx, plugin.KVParams{Group: "pagination", Page: 1, PageSize: 10})
	if err != nil {
		t.Fatalf("Failed to get page 1: %v", err)
	}
	if len(page1) != 10 {
		t.Errorf("Page 1: expected 10 items, got %d", len(page1))
	}

	page2, err := kv.GetByGroup(ctx, plugin.KVParams{Group: "pagination", Page: 2, PageSize: 10})
	if err != nil {
		t.Fatalf("Failed to get page 2: %v", err)
	}
	if len(page2) != 10 {
		t.Errorf("Page 2: expected 10 items, got %d", len(page2))
	}

	page3, err := kv.GetByGroup(ctx, plugin.KVParams{Group: "pagination", Page: 3, PageSize: 10})
	if err != nil {
		t.Fatalf("Failed to get page 3: %v", err)
	}
	if len(page3) != 5 {
		t.Errorf("Page 3: expected 5 items, got %d", len(page3))
	}

	// Verify different keys on different pages
	for i := range 10 {
		key := fmt.Sprintf("key%d", i)
		if _, ok := page1[key]; !ok {
			t.Errorf("Pagination test failed, key %s should be on page 1", key)
		}
	}
	for i := range 10 {
		key := fmt.Sprintf("key%d", i+10)
		if _, ok := page2[key]; !ok {
			t.Errorf("Pagination test failed, key %s should be on page 2", key)
		}
	}
}

// Test concurrent operations and performance
func TestConcurrency(t *testing.T) {