- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for watchContext (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
} func (s *store) RequestWatchProgress(ctx context.Context) error { // Use watchContext to match ctx metadata provided when creating the watch. // In best case scenario we would use the same context that watch was created, but there is no way access it from watchCache. return s.client.RequestProgress(s.watchContext(ctx)) } type objState struct { obj runtime.Object meta *storage.ResponseMeta rev int64
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/rc_patch.go
continue } if commonConditionMatch(patchContext, rp) && routeConfigurationMatch(patchContext, routeConfiguration, rp, portMap) { merge.Merge(routeConfiguration, rp.Value) IncrementEnvoyFilterMetric(rp.Key(), Route, true) } else { IncrementEnvoyFilterMetric(rp.Key(), Route, false) } } patchVirtualHosts(patchContext, efw.Patches, routeConfiguration, portMap) return routeConfiguration
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 13K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/listener_patch.go
if lp.Match.Context == networking.EnvoyFilter_ANY && patchContext != networking.EnvoyFilter_SIDECAR_OUTBOUND && patchContext != networking.EnvoyFilter_GATEWAY { continue } if !commonConditionMatch(patchContext, lp) { IncrementEnvoyFilterMetric(lp.Key(), Listener, false) continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 15:39:29 UTC 2024 - 26.7K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/rc_patch_test.go
type args struct { rc *route.RouteConfiguration patchContext networking.EnvoyFilter_PatchContext cp *model.EnvoyFilterConfigPatchWrapper portMap model.GatewayPortMap } tests := []struct { name string args args want bool }{ { name: "nil route match", args: args{ patchContext: networking.EnvoyFilter_SIDECAR_OUTBOUND,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 32.4K bytes - Viewed (0) -
pilot/pkg/networking/core/envoyfilter/cluster_patch_test.go
output := []*cluster.Cluster{} for _, c := range tc.input { if ShouldKeepCluster(tc.patchContext, efw, c, []host.Name{host.Name(tc.host)}) { pc := ApplyClusterMerge(tc.patchContext, efw, c, []host.Name{host.Name(tc.host)}) output = append(output, pc) } } output = append(output, InsertedClusters(tc.patchContext, efw)...) if diff := cmp.Diff(tc.output, output, protocmp.Transform()); diff != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 20.7K bytes - Viewed (0)