- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 4,460 for Updater (0.22 sec)
-
pilot/pkg/serviceregistry/kube/controller/serviceimportcache_test.go
c, ic := newTestServiceImportCache(t) ic.createKubeService(t, c) ic.createServiceImport(t, mcsapi.ClusterSetIP, serviceImportVIPs) ic.checkServiceInstances(t) // Update the k8s service and verify that both services are updated. ic.updateKubeService(t) } func TestHeadlessServiceImported(t *testing.T) { // Create and run the controller. c, ic := newTestServiceImportCache(t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 15.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
} } return nil } // initInprocessAnalysisController spins up an instance of Galley which serves no purpose other than // running Analyzers for status updates. The Status Updater will eventually need to allow input from istiod // to support config distribution status as well. func (s *Server) initInprocessAnalysisController(args *PilotArgs) error { if s.statusManager == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
pilot/pkg/model/endpointshards.go
// ServiceAccounts has the concatenation of all service accounts seen so far in endpoints. // This is updated on push, based on shards. If the previous list is different than // current list, a full push will be forced, to trigger a secure naming update. // Due to the larger time, it is still possible that connection errors will occur while // CDS is updated. ServiceAccounts sets.String } // Keys gives a sorted list of keys for EndpointShards.Shards.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
} createPod("128.0.0.1", "pod1") assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), []types.NamespacedName{{Name: "pod1", Namespace: "ns"}}) events.WaitOrdered("pod1/add", "pod1/update") createPod("128.0.0.1", "pod2") events.WaitOrdered("pod2/add", "pod2/update") assert.Equal(t, sets.New(c.pods.getPodKeys("128.0.0.1")...), sets.New( types.NamespacedName{Name: "pod1", Namespace: "ns"}, types.NamespacedName{Name: "pod2", Namespace: "ns"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
) }) t.Run("update service entry host", func(t *testing.T) { updated := func() *config.Config { d := selector.DeepCopy() se := d.Spec.(*networking.ServiceEntry) se.Hosts = []string{"updated.com"} return &d }() instances := []*model.ServiceInstance{ makeInstanceWithServiceAccount(updated, "2.2.2.2", 444, updated.Spec.(*networking.ServiceEntry).Ports[0],
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
src/cmd/link/internal/loader/symbolbuilder.go
// version. func (l *Loader) MakeSymbolUpdater(symIdx Sym) *SymbolBuilder { if symIdx == 0 { panic("can't update the null symbol") } if !l.IsExternal(symIdx) { // Create a clone with the same name/version/kind etc. l.cloneToExternal(symIdx) } // Construct updater and return. sb := &SymbolBuilder{l: l, symIdx: symIdx} sb.extSymPayload = l.getPayload(symIdx) return sb }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 15:25:19 UTC 2023 - 13.9K bytes - Viewed (0) -
pilot/pkg/model/context.go
} // Create the cluster-local service registry. e.clusterLocalServices = NewClusterLocalProvider(e) } func (e *Environment) InitNetworksManager(updater XDSUpdater) (err error) { e.NetworkManager, err = NewNetworkManager(e, updater) return } func (e *Environment) ClusterLocal() ClusterLocalProvider { return e.clusterLocalServices } func (e *Environment) GetLedger() ledger.Ledger {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
pkg/controller/disruption/disruption_test.go
} } } // The fake kube client does not update ResourceVersion or check for conflicts. // Instead, we add a reactor that returns a conflict error on the first PDB // update and success after that. var failOnce sync.Once dc.coreClient.Fake.PrependReactor("update", "poddisruptionbudgets", func(a core.Action) (handled bool, obj runtime.Object, err error) { failOnce.Do(func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
setUp(parameters.first, parameters.second) val creator = cache.edit("k1")!! creator.setString(0, "A") creator.setString(1, "B") creator.commit() val updater = cache.edit("k1")!! updater.setString(0, "C") updater.commit() val snapshot = cache["k1"]!! snapshot.assertValue(0, "C") snapshot.assertValue(1, "B") snapshot.close() } @ParameterizedTest
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/upgrade/AdminUpgradeAction.java
return redirect(getClass()); } private void upgradeFrom13_0() { UpgradeUtil.addData(searchEngineClient, ".fess_config.scheduled_job", "label_updater",
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun May 26 05:52:29 UTC 2024 - 48.6K bytes - Viewed (0)