Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewEndpointIndexUpdater (0.24 sec)

  1. pilot/pkg/networking/core/fake.go

    		m = mesh.DefaultMeshConfig()
    	}
    
    	env := model.NewEnvironment()
    	env.Watcher = mesh.NewFixedWatcher(m)
    
    	xdsUpdater := opts.XDSUpdater
    	if xdsUpdater == nil {
    		xdsUpdater = model.NewEndpointIndexUpdater(env.EndpointIndex)
    	}
    
    	serviceDiscovery := aggregate.NewController(aggregate.Options{})
    	se := serviceentry.NewController(
    		configController,
    		xdsUpdater,
    		env.Watcher,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  2. pilot/pkg/model/endpointshards.go

    	// 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