- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for index (0.05 sec)
-
pkg/controller/job/success_policy.go
if !feature.DefaultFeatureGate.Enabled(features.JobSuccessPolicy) || successPolicy == nil || len(succeededIndexes) == 0 { return "", false } rulesMatchedMsg := "Matched rules at index" for index, rule := range successPolicy.Rules { if rule.SucceededIndexes != nil { requiredIndexes := parseIndexesFromString(logger, *rule.SucceededIndexes, int(completions))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/selection_predicate.go
func (s *SelectionPredicate) Empty() bool { return s.Label.Empty() && s.Field.Empty() } // For any index defined by IndexFields, if a matcher can match only (a subset) // of objects that return <value> for a given index, a pair (<index name>, <value>) // wil be returned. func (s *SelectionPredicate) MatcherIndex(ctx context.Context) []MatchValue { var result []MatchValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/revisions/tag_watcher.go
type TagHandler func(sets.String) type tagWatcher struct { revision string handlers []TagHandler queue controllers.Queue webhooks kclient.Client[*admissionregistrationv1.MutatingWebhookConfiguration] index *kclient.Index[string, *admissionregistrationv1.MutatingWebhookConfiguration] } func NewTagWatcher(client kube.Client, revision string) TagWatcher { p := &tagWatcher{ revision: revision, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/controller/job/backoff_utils.go
} // getRemainingTimePerIndex returns the remaining time left for a given index to // create the replacement pods. The number of consecutive pod failures for the // index is retrieved from the `job-index-failure-count` annotation of the // last failed pod within the index (represented by `lastFailedPod`). // The last failed pod is also used to determine the time of the last failure.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/test/framework/components/cluster/topology.go
PrimaryClusterName: config.PrimaryClusterName, ConfigClusterName: config.ConfigClusterName, ClusterProxyKubectlOnly: config.ProxyKubectlOnly, AllClusters: allClusters, Index: len(allClusters), ConfigMetadata: config.Meta, } } // Topology gives information about the relationship between clusters.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
"istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/schema/kind" "istio.io/istio/pkg/kube/krt" "istio.io/istio/pkg/log" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/workloadapi" ) func (a *index) ServicesCollection( Services krt.Collection[*v1.Service], ServiceEntries krt.Collection[*networkingclient.ServiceEntry], Waypoints krt.Collection[Waypoint], Namespaces krt.Collection[*v1.Namespace],
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
internal/grid/debugmsg_string.go
// Code generated by "stringer -type=debugMsg debug.go"; DO NOT EDIT. package grid import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[debugShutdown-0] _ = x[debugKillInbound-1] _ = x[debugKillOutbound-2] _ = x[debugWaitForExit-3] _ = x[debugSetConnPingDuration-4]
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go
endIndex int // indexer is meant to inject behaviour for how an event must // be retrieved from the underlying source given an index. indexer indexerFunc // indexValidator is used to check if a given index is still // valid perspective. If it is deemed that the index is not // valid, then this interval can no longer be used to serve // events. Use of indexValidator is warranted only in cases
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 8.2K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/issues_test.go
"package p; var _ = T{@f(1, 2, 3): 0}", "package p; var _ = T{@a + f(b) + <-ch: 0}", } for _, src := range tests { // identify column position of @ and remove it from src i := strings.Index(src, "@") if i < 0 { t.Errorf("%s: invalid test case (missing @)", src) continue } src = src[:i] + src[i+1:] want := colbase + uint(i) f, err := Parse(nil, strings.NewReader(src), nil, nil, 0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 17:49:19 UTC 2024 - 1.2K bytes - Viewed (0) -
src/cmd/compile/internal/syntax/positions.go
m = n.Value case *FuncLit: m = n.Body case *ParenExpr: m = n.X case *SelectorExpr: m = n.Sel case *IndexExpr: m = n.Index case *SliceExpr: for i := len(n.Index) - 1; i >= 0; i-- { if x := n.Index[i]; x != nil { m = x continue } } m = n.X case *AssertExpr: m = n.Type case *TypeSwitchGuard: m = n.X
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 17:49:19 UTC 2024 - 6.5K bytes - Viewed (0)