- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for utilpod (0.26 sec)
-
pkg/controller/util/node/controller_utils.go
"k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/record" v1 "k8s.io/api/core/v1" clientset "k8s.io/client-go/kubernetes" appsv1listers "k8s.io/client-go/listers/apps/v1" utilpod "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/kubelet/util/format" nodepkg "k8s.io/kubernetes/pkg/util/node" "k8s.io/klog/v2" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 05 23:39:52 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
apipod "k8s.io/kubernetes/pkg/api/v1/pod" "k8s.io/kubernetes/pkg/controller/podgc/metrics" "k8s.io/kubernetes/pkg/features" "k8s.io/kubernetes/pkg/kubelet/eviction" nodeutil "k8s.io/kubernetes/pkg/util/node" utilpod "k8s.io/kubernetes/pkg/util/pod" "k8s.io/kubernetes/pkg/util/taints" ) const ( // gcCheckPeriod defines frequency of running main controller loop gcCheckPeriod = 20 * time.Second
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
v1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper" "k8s.io/kubernetes/pkg/controller/tainteviction/metrics" controllerutil "k8s.io/kubernetes/pkg/controller/util/node" "k8s.io/kubernetes/pkg/features" utilpod "k8s.io/kubernetes/pkg/util/pod" ) const ( // TODO (k82cn): Figure out a reasonable number of workers/channels and propagate // the number of workers up making it a parameter of Run() function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
"k8s.io/kubernetes/pkg/kubelet/status" kubetypes "k8s.io/kubernetes/pkg/kubelet/types" "k8s.io/kubernetes/pkg/kubelet/util" utilfs "k8s.io/kubernetes/pkg/util/filesystem" utilkernel "k8s.io/kubernetes/pkg/util/kernel" utilpod "k8s.io/kubernetes/pkg/util/pod" volumeutil "k8s.io/kubernetes/pkg/volume/util" "k8s.io/kubernetes/pkg/volume/util/hostutil" "k8s.io/kubernetes/pkg/volume/util/subpath" "k8s.io/kubernetes/pkg/volume/util/volumepathhandler"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/scheduler/internal/cache/node_tree.go
} } } // updateNode updates a node in the NodeTree. func (nt *nodeTree) updateNode(logger klog.Logger, old, new *v1.Node) { var oldZone string if old != nil { oldZone = utilnode.GetZoneKey(old) } newZone := utilnode.GetZoneKey(new) // If the zone ID of the node has not changed, we don't need to do anything. Name of the node // cannot be changed in an update. if oldZone == newZone { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 4.5K bytes - Viewed (0) -
pkg/volume/projected/projected_test.go
defaultMode: utilptr.Int32Ptr(0644), fsGroup: utilptr.Int64Ptr(1000), path: "token", wantPayload: map[string]util.FileProjection{ "token": { Data: []byte("test_projected_namespace:foo:3600:[https://api]"), Mode: 0600, }, }, }, { name: "fsUser != nil && fsGroup != nil", defaultMode: utilptr.Int32Ptr(0644), fsGroup: utilptr.Int64Ptr(1000),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 40.5K bytes - Viewed (0) -
pkg/probe/http/http.go
res, err := client.Do(req) if err != nil { // Convert errors into failures to catch timeouts. return probe.Failure, err.Error(), nil } defer res.Body.Close() b, err := utilio.ReadAtMost(res.Body, maxRespBodyLength) if err != nil { if err == utilio.ErrLimitReached { klog.V(4).Infof("Non fatal body truncation for %s, Response: %v", url.String(), *res) } else { return probe.Failure, "", err } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 10 00:37:32 UTC 2023 - 5K bytes - Viewed (0) -
platforms/software/maven/src/integTest/groovy/org/gradle/api/publish/maven/MavenPublishIssuesIntegTest.groovy
then: def mainPom = mavenRepo.module('my.org', 'main', '1.0').parsedPom mainPom.scopes.compile.expectDependency('my.org:util:1.0') def utilPom = mavenRepo.module('my.org', 'util', '1.0').parsedPom utilPom.scopes.compile.expectDependency('org.gradle:dep:1.1') } @Issue("GRADLE-2945") def "maven-publish plugin adds excludes to pom"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Mar 07 19:31:52 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
return nil, fmt.Errorf("cannot get node: %v", err) } return utilnode.GetNodeHostIPs(node) } // getHostIPsAnyWay attempts to return the host IPs from kubelet's nodeInfo, or // the initialNode. func (kl *Kubelet) getHostIPsAnyWay() ([]net.IP, error) { node, err := kl.getNodeAnyWay() if err != nil { return nil, err } return utilnode.GetNodeHostIPs(node) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
v1apply "k8s.io/client-go/applyconfigurations/core/v1" "k8s.io/client-go/kubernetes/fake" v1core "k8s.io/client-go/kubernetes/typed/core/v1" "k8s.io/client-go/tools/cache" ref "k8s.io/client-go/tools/reference" utilnode "k8s.io/component-helpers/node/topology" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/api/legacyscheme" api "k8s.io/kubernetes/pkg/apis/core" "k8s.io/utils/clock" testingclock "k8s.io/utils/clock/testing"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 15.6K bytes - Viewed (0)