Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for WorkloadEntryAutoRegistration (0.39 sec)

  1. pilot/pkg/autoregistration/controller.go

    // NewController create a controller which manages workload lifecycle and health status.
    func NewController(store model.ConfigStoreController, instanceID string, maxConnAge time.Duration) *Controller {
    	if !features.WorkloadEntryAutoRegistration && !features.WorkloadEntryHealthChecks {
    		return nil
    	}
    
    	if maxConnAge != math.MaxInt64 {
    		maxConnAge += maxConnAge / 2
    		// if overflow, set it to max int64
    		if maxConnAge < 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 00:00:36 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  2. pilot/pkg/features/pilot.go

    	).Get()
    
    	ALPNFilter = env.Register("PILOT_ENABLE_ALPN_FILTER", true,
    		"If true, pilot will add Istio ALPN filters, required for proper protocol sniffing.",
    	).Get()
    
    	WorkloadEntryAutoRegistration = env.Register("PILOT_ENABLE_WORKLOAD_ENTRY_AUTOREGISTRATION", true,
    		"Enables auto-registering WorkloadEntries based on associated WorkloadGroups upon XDS connection by the workload.").Get()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 17:48:28 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. pilot/pkg/autoregistration/controller_test.go

    	})
    	// TODO test garbage collection if pilot stops before disconnect meta is set (relies on heartbeat)
    }
    
    func TestAutoregistrationDisabled(t *testing.T) {
    	test.SetForTest(t, &features.WorkloadEntryAutoRegistration, false)
    	store := memory.NewController(memory.Make(collections.All))
    	createOrFail(t, store, weB)
    
    	stop := test.NewStop(t)
    
    	c := NewController(store, "pilot-x", keepalive.Infinity)
    	go c.Run(stop)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 00:00:36 UTC 2024
    - 31.4K bytes
    - Viewed (0)
Back to top