nodeutil - Code Search

pkg/kubelet/status/status_manager.go

	// See https://issues.k8s.io/108594 for more details.
	if podutil.IsPodPhaseTerminal(newPodStatus.Phase) {
		if podutil.IsPodReadyConditionTrue(newPodStatus) || podutil.IsContainersReadyConditionTrue(newPodStatus) {
			containersReadyCondition := generateContainersReadyConditionForTerminalPhase(newPodStatus.Phase)
			podutil.UpdatePodCondition(&newPodStatus, &containersReadyCondition)

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu May 02 16:27:19 UTC 2024

- 44.3K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/controller/util/node/controller_utils.go

func DeletePods(ctx context.Context, kubeClient clientset.Interface, pods []*v1.Pod, recorder record.EventRecorder, nodeName, nodeUID string, daemonStore appsv1listers.DaemonSetLister) (bool, error) {
	remaining := false
	var updateErrList []error
	logger := klog.FromContext(ctx)

	if len(pods) > 0 {
		RecordNodeEvent(ctx, recorder, nodeName, nodeUID, v1.EventTypeNormal, "DeletingAllPods", fmt.Sprintf("Deleting all Pods from Node %v.", nodeName))
	}

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed Jul 05 23:39:52 UTC 2023

- 10.6K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/documentation/docs/src/samples/incubating/build-organization/publishing-convention-plugins/groovy/convention-plugins/src/test/groovy/com/myorg/LibraryPluginTest.groovy

        new File(testProjectDir, 'src/main/java/com/myorg/Util.java') << """
            package com.myorg;

            public class Util {
                public static void someUtil() {
                }
            }
        """

        when:
        def result = runTask('publishLibraryPublicationToTestRepoRepository')

        then:

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Nov 27 17:53:42 UTC 2023

- 2.9K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/configmap/configmap_manager.go

limitations under the License.
*/

package configmap

import (
	"context"
	"fmt"
	"time"

	v1 "k8s.io/api/core/v1"
	clientset "k8s.io/client-go/kubernetes"
	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
	corev1 "k8s.io/kubernetes/pkg/apis/core/v1"
	"k8s.io/kubernetes/pkg/kubelet/util/manager"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Tue Jun 04 06:25:43 UTC 2024

- 5.5K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

pkg/kubelet/secret/secret_manager.go

limitations under the License.
*/

package secret

import (
	"context"
	"fmt"
	"time"

	v1 "k8s.io/api/core/v1"
	clientset "k8s.io/client-go/kubernetes"
	podutil "k8s.io/kubernetes/pkg/api/v1/pod"
	corev1 "k8s.io/kubernetes/pkg/apis/core/v1"
	"k8s.io/kubernetes/pkg/kubelet/util/manager"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Tue Jun 04 06:25:43 UTC 2024

- 5.3K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apiserver/pkg/authentication/serviceaccount/util.go

			info.Extra = make(map[string][]string)
		}
		info.Extra[NodeNameKey] = []string{sa.NodeName}
		// node UID is optional and will only be set if the node name is set
		if sa.NodeUID != "" {
			info.Extra[NodeUIDKey] = []string{sa.NodeUID}
		}
	}

	return info
}

// CredentialIDForJTI converts a given JTI string into a credential identifier for use in a
// users 'extra' info.

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Mon Feb 05 10:24:31 UTC 2024

- 8.1K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/documentation/docs/src/samples/build-organization/multi-project-with-convention-plugins/groovy/buildSrc/src/test/groovy/com/example/LibraryPluginTest.groovy

        new File(testProjectDir, 'src/main/java/com/example/Util.java') << """
            package com.example;

            public class Util {
                public static void someUtil() {
                }
            }
        """

        when:
        def result = runTask('publishLibraryPublicationToTestRepoRepository')

        then:

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Nov 27 17:53:42 UTC 2023

- 2.9K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/documentation/docs/src/samples/build-organization/publishing-convention-plugins/groovy/convention-plugins/src/test/groovy/com/myorg/LibraryPluginTest.groovy

        new File(testProjectDir, 'src/main/java/com/myorg/Util.java') << """
            package com.myorg;

            public class Util {
                public static void someUtil() {
                }
            }
        """

        when:
        def result = runTask('publishLibraryPublicationToTestRepoRepository')

        then:

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Nov 27 17:53:42 UTC 2023

- 2.9K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/HierarchicalNameSerializerTest.groovy

            "com.foo.bar.FooBarBazTest",
            "com/foo/bar/FooBarBazTest\$SomeUtility.java",
            "com.foo.bar.FooBarBazTest\$SomeUtility",
            "com.fizz.buzz.TestUtil",
            "com.fizz.buzz.SomeUtil",
            "com.google.common.collect.ImmutableSet",
            "com.google.common.collect.ImmutableSet",
            "com.google.common.collect.ImmutableSet",
            "com.google.common.collect.ImmutableSet",

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Apr 15 16:06:56 UTC 2024

- 2.6K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/documentation/docs/src/samples/incubating/build-organization/publishing-convention-plugins/kotlin/convention-plugins/src/test/kotlin/com/myorg/LibraryPluginTest.kt

        testProjectDir.newFile("src/main/java/com/myorg/Util.java").writeText("""
            package com.myorg;

            public class Util {
                public static void someUtil() {
                }
            }
        """)

        val result = runTask("publishLibraryPublicationToTestRepoRepository")

        assertEquals(TaskOutcome.SUCCESS, result.task(":jar")?.outcome)

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Nov 27 17:53:42 UTC 2023

- 3.3K bytes

- Viewed (0)

Search Options