- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 395 for podutil (0.14 sec)
-
pkg/kubelet/kubelet_volumes.go
volumePaths, err := kl.getMountedVolumePathListFromDisk(podUID) if err != nil { klog.ErrorS(err, "Pod found, but error occurred during checking mounted volumes from disk", "podUID", podUID) return true } if len(volumePaths) > 0 { klog.V(4).InfoS("Pod found, but volumes are still mounted on disk", "podUID", podUID, "paths", volumePaths) return true } return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/certs/renewal/readwriter.go
"k8s.io/client-go/tools/clientcmd" clientcmdapi "k8s.io/client-go/tools/clientcmd/api" certutil "k8s.io/client-go/util/cert" "k8s.io/client-go/util/keyutil" "k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil" ) // certificateReadWriter defines the behavior of a component that // read or write a certificate stored/embedded in a file type certificateReadWriter interface { //Exists return true if the certificate exists
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 01 03:09:53 UTC 2024 - 8.4K bytes - Viewed (0) -
platforms/software/security/src/testFixtures/groovy/org/gradle/security/fixtures/SigningFixtures.groovy
import org.bouncycastle.openpgp.PGPSignatureSubpacketGenerator import org.bouncycastle.openpgp.PGPUserAttributeSubpacketVector import org.bouncycastle.openpgp.PGPUserAttributeSubpacketVectorGenerator import org.bouncycastle.openpgp.PGPUtil import org.bouncycastle.openpgp.bc.BcPGPPublicKeyRingCollection import org.bouncycastle.openpgp.bc.BcPGPSecretKeyRingCollection import org.bouncycastle.openpgp.operator.bc.BcKeyFingerprintCalculator
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Oct 11 12:16:09 UTC 2023 - 12.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes_linux_test.go
if err := tc.validateFunc(kubelet); err != nil { t.Errorf("%s failed validation: %v", name, err) } } }) } } func TestPodVolumesExistWithMount(t *testing.T) { poduid := types.UID("poduid") testCases := map[string]struct { prepareFunc func(kubelet *Kubelet) error expected bool }{ "noncsivolume-dir-not-exist": { prepareFunc: func(kubelet *Kubelet) error { return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 30 03:35:26 UTC 2022 - 8.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_checkpoint.go
} for containerID, cset := range src.Entries { podUID, containerName, err := sc.initialContainers.GetContainerRef(containerID) if err != nil { return fmt.Errorf("containerID '%v' not found in initial containers list", containerID) } if dst.Entries == nil { dst.Entries = make(map[string]map[string]string) } if _, exists := dst.Entries[podUID]; !exists { dst.Entries[podUID] = make(map[string]string) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 13 00:59:30 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/fake_topology_manager_test.go
name string containerName string podUID string expected TopologyHint }{ { name: "Case1", containerName: "nginx", podUID: "0aafa4c4-38e8-11e9-bcb1-a4bf01040474", expected: TopologyHint{}, }, } for _, tc := range tcases { fm := fakeManager{} actual := fm.GetAffinity(tc.podUID, tc.containerName) if !reflect.DeepEqual(actual, tc.expected) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 10 11:44:15 UTC 2021 - 2.8K bytes - Viewed (0) -
pkg/registry/core/persistentvolumeclaim/storage/storage.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package storage import ( "context" pvcutil "k8s.io/kubernetes/pkg/api/persistentvolumeclaim" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apiserver/pkg/registry/generic"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 18 09:21:19 UTC 2022 - 5.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
pod := buildConvincingPod(false) var podUID string = string(pod.ObjectMeta.UID) fakeIPSetDeps := ipset.FakeNLDeps() set := ipset.IPSet{V4Name: "foo-v4", Prefix: "foo", Deps: fakeIPSetDeps} ipProto := uint8(unix.IPPROTO_TCP) fakeIPSetDeps.On("addIP", "foo-v4", netip.MustParseAddr("99.9.9.9"), ipProto, podUID, false, ).Return(nil) fakeIPSetDeps.On("addIP",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubeconfig/kubeconfig.go
return kubeconfigutil.CreateWithCerts( spec.APIServer, clustername, spec.ClientName, pkiutil.EncodeCertPEM(spec.CACert), encodedClientKey, pkiutil.EncodeCertPEM(clientCert), ), nil } func newClientCertConfigFromKubeConfigSpec(spec *kubeConfigSpec) pkiutil.CertConfig { return pkiutil.CertConfig{ Config: certutil.Config{ CommonName: spec.ClientName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 27K bytes - Viewed (0) -
pkg/volume/projected/projected.go
&projectedVolume{ volName: volName, podUID: podUID, plugin: plugin, MetricsProvider: volume.NewCachedMetrics(volume.NewMetricsDu(getPath(podUID, volName, plugin.host))), }, }, nil } func (plugin *projectedPlugin) ConstructVolumeSpec(volumeName, mountPath string) (volume.ReconstructedVolume, error) { projectedVolume := &v1.Volume{ Name: volumeName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 12.8K bytes - Viewed (0)