Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for XdsUpdater (0.35 sec)

  1. pilot/test/xds/fake.go

    			s.ConfigUpdate(&model.PushRequest{
    				Full:   true,
    				Reason: model.NewReasonStats(model.NetworksTrigger),
    			})
    		})
    	}
    	var xdsUpdater model.XDSUpdater = s
    	if opts.EnableFakeXDSUpdater {
    		xdsUpdater = xdsfake.NewWithDelegate(s)
    	}
    	mc := multicluster.NewFakeController()
    	creds := kubesecrets.NewMulticluster(opts.DefaultClusterName, mc)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 10 16:08:52 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  2. pilot/pkg/xds/delta_test.go

    	}
    	if len(resp.RemovedResources) != 0 {
    		t.Fatalf("received unexpected removed eds resource %v", resp.RemovedResources)
    	}
    
    	// simulate a svc update
    	s.XdsUpdater.ConfigUpdate(&model.PushRequest{
    		ConfigsUpdated: sets.New(model.ConfigKey{
    			Kind: kind.Address, Name: svcA.ResourceName(), Namespace: svcA.Namespace,
    		}),
    	})
    
    	resp = ads.ExpectResponse()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  3. pilot/pkg/model/endpointshards.go

    type EndpointIndexUpdater struct {
    	Index *EndpointIndex
    	// Optional; if set, we will trigger ConfigUpdates in response to EDS updates as appropriate
    	ConfigUpdateFunc func(req *PushRequest)
    }
    
    var _ XDSUpdater = &EndpointIndexUpdater{}
    
    func NewEndpointIndexUpdater(ei *EndpointIndex) *EndpointIndexUpdater {
    	return &EndpointIndexUpdater{Index: ei}
    }
    
    func (f *EndpointIndexUpdater) ConfigUpdate(*PushRequest) {}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 15.6K bytes
    - Viewed (0)
Back to top