Function TestPool_Status

pkg/core/pool_test.go:262–295

TestPool_Status 测试获取 Agent 状态

(t *testing.T)

// TestPool_Status 测试获取 Agent 状态
func TestPool_Status(t *testing.T) {
	deps := createTestDeps(t)
	pool := NewPool(&PoolOptions{
		Dependencies: deps,
		MaxAgents:    5,
	})
	defer func() {
		if err := pool.Shutdown(); err != nil {
			t.Errorf("Shutdown failed: %v", err)
		}
	}()

	ctx := context.Background()
	config := createTestConfig("test-agent")

	_, err := pool.Create(ctx, config)
	if err != nil {
		t.Fatalf("Failed to create agent: %v", err)
	}

	// 获取状态
	status, err := pool.Status("test-agent")
	if err != nil {
		t.Fatalf("Failed to get status: %v", err)
	}

	if status == nil {
		t.Fatal("Status is nil")
	}

	if status.AgentID != "test-agent" {
		t.Errorf("Expected AgentID 'test-agent', got '%s'", status.AgentID)
	}
}

// TestPool_ConcurrentAccess 测试并发访问
func TestPool_ConcurrentAccess(t *testing.T) {