- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 288 for watcher (0.15 sec)
-
pilot/pkg/networking/core/accesslog_test.go
}, }, Disabled: wrapperspb.Bool(true), }, }, }, }) env := model.NewEnvironment() env.ServiceDiscovery = serviceDiscovery env.ConfigStore = configStore env.Watcher = mesh.NewFixedWatcher(meshConfig) pushContext := model.NewPushContext() env.Init() pushContext.InitContext(env, nil, nil) env.SetPushContext(pushContext) return env } var (
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 19.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
func (c *Controller) onNetworkChange() { // the network for endpoints are computed when we process the events; this will fix the cache // NOTE: this must run before the other network watcher handler that creates a force push if err := c.syncPods(); err != nil { log.Errorf("one or more errors force-syncing pods: %v", err) } if err := c.endpoints.initializeNamespace(metav1.NamespaceAll, true); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
filter kclient.Filter want kubetypes.InformerOptions }{ { name: "watch pods in the foo namespace", gvr: gvr.Pod, filter: kclient.Filter{ Namespace: "foo", }, want: kubetypes.InformerOptions{ Namespace: "foo", Cluster: c.ClusterID(), }, }, { name: "watch pods in the InformerWatchNamespace", gvr: gvr.Pod, want: kubetypes.InformerOptions{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
// Controller is a collection of synchronized resource watchers // Caches are thread-safe type Controller struct { opts Options client kubelib.Client queue queue.Instance namespaces kclient.Client[*v1.Namespace] services kclient.Client[*v1.Service] endpoints *endpointSliceController // Used to watch node accessible from remote cluster.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/model/authentication_test.go
t.Run(tc.name, func(t *testing.T) { matcher := PolicyMatcherFor(tc.workloadNamespace, tc.workloadLabels, tc.isWaypoint) if got := policies.GetJwtPoliciesForWorkload(matcher); !reflect.DeepEqual(tc.wantRequestAuthn, got) { t.Fatalf("want %+v\n, but got %+v\n", printConfigs(tc.wantRequestAuthn), printConfigs(got)) } if got := policies.GetPeerAuthenticationsForWorkload(matcher); !reflect.DeepEqual(tc.wantPeerAuthn, got) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 45.1K bytes - Viewed (0) -
cmd/iam.go
} const maxDurationSecondsForLog = 5 func (sys *IAMSys) periodicRoutines(ctx context.Context, baseInterval time.Duration) { // Watch for IAM config changes for iamStorageWatcher. watcher, isWatcher := sys.store.IAMStorageAPI.(iamStorageWatcher) if isWatcher { go func() { ch := watcher.watch(ctx, iamConfigPrefix) for event := range ch { if err := sys.loadWatchedEvent(ctx, event); err != nil { // we simply log errors
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
} m := mesh.DefaultMeshConfig() m.ExtensionProviders = append(m.ExtensionProviders, jsonTextProvider, textFormattersProvider, jsonFormattersProvider) environment := &Environment{ ConfigStore: store, Watcher: mesh.NewFixedWatcher(m), } telemetries := getTelemetries(environment) ctx := NewPushContext() ctx.Mesh = m return telemetries, ctx }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
// annotation is already set, nothing to do return claim, nil } // The volume from method args can be pointing to watcher cache. We must not // modify these, therefore create a copy. claimClone := claim.DeepCopy() // TODO: remove the beta storage provisioner anno after the deprecation period logger := klog.FromContext(ctx)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
if err != nil { t.Fatalf("Unexpected error: %v", err) } podCreated := objCreated.(*example.Pod) watcher, err := registry.WatchPredicate(testContext, matchPodName("foo"), podCreated.ResourceVersion, nil) if err != nil { t.Fatalf("Unexpected error: %v", err) } defer watcher.Stop()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
// PluginHandler is the plugin registration handler interface passed to the // pluginwatcher module in kubelet var PluginHandler = &RegistrationHandler{} // ValidatePlugin is called by kubelet's plugin watcher upon detection // of a new registration socket opened by CSI Driver registrar side car. func (h *RegistrationHandler) ValidatePlugin(pluginName string, endpoint string, versions []string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0)