Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 113 for index (0.04 sec)

  1. 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)
  2. pkg/kubelet/userns/userns_manager.go

    	}
    
    	_, err = m.parseUserNsFileAndRecord(pod, content)
    	return err
    }
    
    // isSet checks if the specified index is already set.
    func (m *UsernsManager) isSet(v uint32) bool {
    	index := int(v/userNsLength) - m.off
    	if index < 0 || index >= m.len {
    		return true
    	}
    	return m.used.Has(index)
    }
    
    // allocateOne finds a free user namespace and allocate it to the specified pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  3. 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)
  4. callbacks/preload.go

    				tx.AddError(rel.Field.Set(tx.Statement.Context, reflectValue.Index(i), reflect.MakeSlice(rel.Field.IndirectFieldType, 0, 10).Interface()))
    			default:
    				tx.AddError(rel.Field.Set(tx.Statement.Context, reflectValue.Index(i), reflect.New(rel.Field.FieldType).Interface()))
    			}
    		}
    	}
    
    	for i := 0; i < reflectResults.Len(); i++ {
    		elem := reflectResults.Index(i)
    		for idx, field := range relForeignFields {
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Wed Jun 12 10:52:33 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go

    	return Workloads
    }
    
    func (a *index) workloadEntryWorkloadBuilder(
    	MeshConfig krt.Singleton[MeshConfig],
    	AuthorizationPolicies krt.Collection[model.WorkloadAuthorization],
    	PeerAuths krt.Collection[*securityclient.PeerAuthentication],
    	Waypoints krt.Collection[Waypoint],
    	WorkloadServices krt.Collection[model.ServiceInfo],
    	WorkloadServicesNamespaceIndex *krt.Index[model.ServiceInfo, string],
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  9. 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)
  10. staging/src/k8s.io/api/batch/v1/types.go

    	// Specifies the limit for the number of retries within an
    	// index before marking this index as failed. When enabled the number of
    	// failures per index is kept in the pod's
    	// batch.kubernetes.io/job-index-failure-count annotation. It can only
    	// be set when Job's completionMode=Indexed, and the Pod's restart
    	// policy is Never. The field is immutable.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 18:37:07 UTC 2024
    - 40.6K bytes
    - Viewed (0)
Back to top