Function TestStaleCacheOnError

registry/cache/cache_test.go:178–220

TestStaleCacheOnError verifies that stale cache is returned when registry fails

(t *testing.T)

// TestStaleCacheOnError verifies that stale cache is returned when registry fails
func TestStaleCacheOnError(t *testing.T) {
	mock := &mockRegistry{
		services: []*registry.Service{
			{
				Name:    "test.service",
				Version: "1.0.0",
				Nodes: []*registry.Node{
					{Id: "node1", Address: "localhost:9090"},
				},
			},
		},
	}

	// Type assertion to *cache is necessary to access internal state for verification
	c := New(mock, func(o *Options) {
		o.TTL = 100 * time.Millisecond // Short TTL for testing
		o.Logger = logger.DefaultLogger
	}).(*cache)

	// First request - should populate cache
	services, err := c.GetService("test.service")
	if err != nil {
		t.Fatalf("First request failed: %v", err)
	}
	if len(services) != 1 {
		t.Fatalf("Expected 1 service, got %d", len(services))
	}

	// Wait for cache to expire
	time.Sleep(150 * time.Millisecond)

	// Configure mock to fail
	mock.err = errors.New("etcd unavailable")

	// Second request - should return stale cache despite error
	services, err = c.GetService("test.service")
	if err != nil {
		t.Errorf("Should have returned stale cache, got error: %v", err)
	}
	if len(services) != 1 {
		t.Errorf("Expected stale cache with 1 service, got %d", len(services))
	}
}

// TestCachePenetrationPrevention verifies the complete flow:
// 1. Cache populated