- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for QueueWorkloadEntryHealth (0.31 sec)
-
tests/fuzz/autoregistration_controller_fuzzer.go
// up a workloadentry controller with a proxy with // pseudo-random values. // The fuzzer then uses the controller to test: // 1: OnConnect // 2: OnDisconnect // 3: QueueWorkloadEntryHealth func FuzzWE(data []byte) int { f := fuzz.NewConsumer(data) proxy := &model.Proxy{} err := f.GenerateStruct(proxy) if err != nil { return 0 } if !proxy.FuzzValidate() { return 0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.4K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/health/controller.go
return c } func (c *Controller) Run(stop <-chan struct{}) { c.healthCondition.Run(stop) } // QueueWorkloadEntryHealth enqueues the associated WorkloadEntries health status. func (c *Controller) QueueWorkloadEntryHealth(proxy *model.Proxy, event HealthEvent) { // we assume that the workload entry exists // if auto registration does not exist, try looking // up in NodeMetadata
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.4K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
ig.OnConnect(makeConn(p, time.Now())) t.Run("auto registered healthy health", func(t *testing.T) { ig.QueueWorkloadEntryHealth(p, HealthEvent{ Healthy: true, }) checkHealthOrFail(t, store, p, true) }) t.Run("auto registered unhealthy health", func(t *testing.T) { ig.QueueWorkloadEntryHealth(p, HealthEvent{ Healthy: false, Message: "lol health bad", }) checkHealthOrFail(t, store, p, false)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
return nil }, features.WorkloadEntryCleanupGracePeriod) return nil } // QueueWorkloadEntryHealth enqueues the associated WorkloadEntries health status. func (c *Controller) QueueWorkloadEntryHealth(proxy *model.Proxy, event HealthEvent) { if !features.WorkloadEntryHealthChecks { return } c.healthController.QueueWorkloadEntryHealth(proxy, event) } // periodicWorkloadEntryCleanup checks lists all WorkloadEntry
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
event := autoregistration.HealthEvent{} event.Healthy = req.ErrorDetail == nil if !event.Healthy { event.Message = req.ErrorDetail.Message } s.WorkloadEntryController.QueueWorkloadEntryHealth(proxy, event) } } // DeltaAggregatedResources is not implemented. // Instead, Generators may send only updates/add, with Delete indicated by an empty spec.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0)