Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for QueueWorkloadEntryHealth (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top