- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Pods (0.48 sec)
-
pkg/controller/job/backoff_utils.go
backoff.lastFailureTime = &failedTime } backoff.failuresAfterLastSuccess += 1 } return *backoff } } func sortByFinishedTime(pods []*v1.Pod) { sort.Slice(pods, func(i, j int) bool { p1 := pods[i] p2 := pods[j] p1FinishTime := getFinishedTime(p1) p2FinishTime := getFinishedTime(p2) return p1FinishTime.Before(p2FinishTime) }) }
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/kubelet/secret/secret_manager.go
} } // NewWatchingSecretManager creates a manager that keeps a cache of all secrets // necessary for registered pods. // It implements the following logic: // - whenever a pod is created or updated, we start individual watches for all // referenced objects that aren't referenced from other registered pods // - every GetObject() returns a value from local cache propagated via watches
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/kubelet/configmap/configmap_manager.go
} } // NewWatchingConfigMapManager creates a manager that keeps a cache of all configmaps // necessary for registered pods. // It implements the following logic: // - whenever a pod is created or updated, we start individual watches for all // referenced objects that aren't referenced from other registered pods // - every GetObject() returns a value from local cache propagated via watches
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.5K bytes - Viewed (0) -
manifests/charts/gateway/values.yaml
# A list of `Volumes` added into the Gateway Pods. See # https://kubernetes.io/docs/concepts/storage/volumes/. volumes: [] # A list of `VolumeMounts` added into the Gateway Pods. See # https://kubernetes.io/docs/concepts/storage/volumes/. volumeMounts: [] # Configure this to a higher priority class in order to make sure your Istio gateway pods # will not be killed because of low priority class.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 16:51:35 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/test/framework/components/ambient/waypoint.go
fetchFn := testKube.NewSinglePodFetch(cls, ns.Name(), fmt.Sprintf("%s=%s", constants.GatewayNameLabel, name)) pods, err := testKube.WaitUntilPodsAreReady(fetchFn) if err != nil { return nil, err } pod := pods[0] inbound, err := cls.NewPortForwarder(pod.Name, pod.Namespace, "", 0, 15008) if err != nil { return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/config/analysis/analyzers/gateway/gateway.go
// not report a problem if *any* selecting service exposes the Gateway's port. servicePorts := map[uint32]bool{} portMapping := map[uint32]uint32{} // svc port -> svc targetPort mapping gwSelectorMatches := 0 // For pods selected by gw.Selector, find Services that select them and remember those ports gwSelector := klabels.SelectorFromSet(gw.Selector) c.ForEach(gvk.Pod, func(rPod *resource.Instance) bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 04 08:48:06 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/events.go
ForceActivate = "ForceActivate" // PodUpdate is the event when a pod is updated PodUpdate = "PodUpdate" ) var ( // AssignedPodAdd is the event when a pod is added that causes pods with matching affinity terms // to be more schedulable. AssignedPodAdd = framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.Add, Label: "AssignedPodAdd"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 6.4K bytes - Viewed (0) -
manifests/addons/values-grafana.yaml
# Avoid creating a bunch of RBAC rules for features we are not enabling rbac: create: false pspEnabled: false # Disable test pods testFramework: enabled: false podLabels: sidecar.istio.io/inject: "false" # Demo only, so we will have no authentication admin: existingSecret: "" ldap: existingSecret: true env: GF_SECURITY_ADMIN_USER: "admin" GF_SECURITY_ADMIN_PASSWORD: "admin"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
fetchFn := testKube.NewSinglePodFetch(cls, cfg.TelemetryNamespace, fmt.Sprintf("app.kubernetes.io/name=%s", appName)) pods, err := testKube.WaitUntilPodsAreReady(fetchFn) if err != nil { return nil, err } pod := pods[0] svc, err := cls.Kube().CoreV1().Services(cfg.TelemetryNamespace).Get(context.TODO(), serviceName, metav1.GetOptions{}) if err != nil { return nil, err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/selection_predicate.go
if value, ok := s.Field.RequiresExactMatch(field); ok { result = append(result, MatchValue{IndexName: FieldIndex(field), Value: value}) } else if field == "metadata.namespace" { // list pods in the namespace. i.e. /api/v1/namespaces/default/pods if namespace, isNamespaceScope := isNamespaceScopedRequest(ctx); isNamespaceScope { result = append(result, MatchValue{IndexName: FieldIndex(field), Value: namespace}) } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 5.6K bytes - Viewed (0)