- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 78 for updateDir (0.45 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.go
"k8s.io/apiserver/pkg/util/dryrun" "k8s.io/component-base/tracing" "k8s.io/klog/v2" ) // UpdateResource returns a function that will handle a resource update func UpdateResource(r rest.Updater, scope *RequestScope, admit admission.Interface) http.HandlerFunc { return func(w http.ResponseWriter, req *http.Request) { ctx := req.Context() // For performance tracking purposes.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:19:46 UTC 2023 - 11.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
} sd.handlers.NotifyServiceHandlers(nil, svc, model.EventDelete) sd.mutex.Unlock() } // AddInstance adds an in-memory instance and notifies the XDS updater func (sd *ServiceDiscovery) AddInstance(instance *model.ServiceInstance) { sd.mutex.Lock() defer sd.mutex.Unlock() service := instance.Service.Hostname svc := sd.services[service] if svc == nil { return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K 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/serviceregistry/kube/controller/serviceimportcache_test.go
return ic.serviceImports.Get(name.Name, name.Namespace) != nil } func (ic *serviceImportCacheImpl) checkXDS(t test.Failer) { t.Helper() ic.opts.XDSUpdater.(*xdsfake.Updater).MatchOrFail(t, xdsfake.Event{Type: "service", ID: serviceImportClusterSetHost.String()}) } func (ic *serviceImportCacheImpl) clusterLocalHost() host.Name {
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/serviceregistry/kube/controller/pod_test.go
// Prepare k8s. This can be used in multiple tests, to // avoid duplicating creation, which can be tricky. It can be used with the fake or // standalone apiserver. func initTestEnv(t *testing.T, ki kubernetes.Interface, fx *xdsfake.Updater) { cleanup(ki) for _, n := range []string{"nsa", "nsb"} { _, err := ki.CoreV1().Namespaces().Create(context.TODO(), &v1.Namespace{ ObjectMeta: metav1.ObjectMeta{ Name: n, Labels: map[string]string{
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/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) -
src/cmd/link/internal/loader/symbolbuilder.go
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 } // CreateSymForUpdate creates a symbol with given name and version,
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/endpointshards.go
serviceName, oldServiceAccount, serviceAccounts) return true } return false } // EndpointIndexUpdater is an updater that will keep an EndpointIndex in sync. This is intended for tests only. type EndpointIndexUpdater struct { Index *EndpointIndex // Optional; if set, we will trigger ConfigUpdates in response to EDS updates as appropriate
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/serviceentry/controller_test.go
if err != nil { t.Errorf("error occurred crearting ServiceEntry config: %v", err) } } } type Event = xdsfake.Event func initServiceDiscovery(t test.Failer) (model.ConfigStore, *Controller, *xdsfake.Updater) { return initServiceDiscoveryWithOpts(t, false) } // initServiceDiscoveryWithoutEvents initializes a test setup with no events. This avoids excessive attempts to push // EDS updates to a full queue
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K 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)