- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for XdsUpdater (0.35 sec)
-
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) -
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) -
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)