Add ut

Signed-off-by: Zhonghu Xu <xuzhonghu@huawei.com>

pkg/controller/workload/workload_processor.go

@@ -400,7 +400,7 @@ func (p *Processor) handleWorkload(workload *workloadapi.Workload) error {
 
 	deletedServices, newServices = p.WorkloadCache.AddOrUpdateWorkload(workload)
 
-	// Exlude the unhealthy workload, which means the workload is not ready
+	// Exclude the unhealthy workload, which means the workload is not ready
 	if workload.Status == workloadapi.WorkloadStatus_UNHEALTHY {
 		return nil
 	}

pkg/controller/workload/workload_processor_test.go

@@ -148,6 +148,27 @@ func Test_handleWorkload(t *testing.T) {
 	// 6.2 check service map contains service, but no waypoint address
 	checkServiceMap(t, p, svcID, wpSvc, 0)
 
+	// 5. add unhealthy workload
+	workload3 := createFakeWorkload("1.2.3.6")
+	workload3.Status = workloadapi.WorkloadStatus_UNHEALTHY
+	_ = p.handleWorkload(workload3)
+
+	addr, _ := netip.AddrFromSlice(workload3.Addresses[0])
+	networkAddress := cache.NetworkAddress{
+		Network: workload3.Network,
+		Address: addr,
+	}
+	got := p.WorkloadCache.GetWorkloadByAddr(networkAddress)
+	assert.NotNil(t, got)
+	assert.Equal(t, got.Status, workloadapi.WorkloadStatus_UNHEALTHY)
+
+	// 5.1 check unhealthy workload does not exists
+	var fk bpfcache.FrontendKey
+	var fv bpfcache.FrontendValue
+	nets.CopyIpByteFromSlice(&fk.Ip, workload3.Addresses[0])
+	err = p.bpf.FrontendLookup(&fk, &fv)
+	assert.ErrorContains(t, err, "key does not exist")
+
 	hashNameClean(p)
 }