- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for Pods (0.06 sec)
-
pkg/kubelet/pod/testing/fake_mirror_client.go
"k8s.io/apimachinery/pkg/util/sets" kubecontainer "k8s.io/kubernetes/pkg/kubelet/container" ) type FakeMirrorClient struct { mirrorPodLock sync.RWMutex // Note that a real mirror manager does not store the mirror pods in // itself. This fake manager does this to track calls. mirrorPods sets.Set[string] createCounts map[string]int deleteCounts map[string]int } func NewFakeMirrorClient() *FakeMirrorClient {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 2.4K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager.go
data.object = object data.err = err data.lastUpdateTime = s.clock.Now() } } return data.object, data.err } // cacheBasedManager keeps a store with objects necessary // for registered pods. Different implementations of the store // may result in different semantics for freshness of objects // (e.g. ttl-based implementation vs watch-based implementation). type cacheBasedManager struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/tls_test.go
TrustedCAFile: caFile, TracerProvider: noopoteltrace.NewTracerProvider(), }, Codec: codec, } storage, destroyFunc, err := newETCD3Storage(*cfg.ForResource(schema.GroupResource{Resource: "pods"}), nil, nil, "") defer destroyFunc() if err != nil { t.Fatal(err) } err = storage.Create(context.TODO(), "/abc", &example.Pod{}, nil, 0) if err != nil { t.Fatalf("Create failed: %v", err) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 3.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go
// to determine whether a Pod's update makes the Pod schedulable or not. // https://github.com/kubernetes/kubernetes/pull/122234 return []framework.ClusterEventWithHint{ // Pods can be more schedulable once it's gates are removed {Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.Update}, QueueingHintFn: pl.isSchedulableAfterPodChange}, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.2K bytes - Viewed (0) -
manifests/charts/ztunnel/values.yaml
# Used to locate the XDS and CA, if caAddress or xdsAddress are not set explicitly. revision: "" # The customized CA address to retrieve certificates for the pods in the cluster. # CSR clients such as the Istio Agent and ingress gateways can use this to specify the CA endpoint. caAddress: "" # The customized XDS address to retrieve configuration.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:30 UTC 2024 - 3.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/policies.go
func PolicyCollections( AuthzPolicies krt.Collection[*securityclient.AuthorizationPolicy], PeerAuths krt.Collection[*securityclient.PeerAuthentication], MeshConfig krt.Singleton[MeshConfig], Waypoints krt.Collection[Waypoint], Pods krt.Collection[*v1.Pod], ) (krt.Collection[model.WorkloadAuthorization], krt.Collection[model.WorkloadAuthorization]) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/kubemark/hollow_kubelet.go
func GetHollowKubeletConfig(opt *HollowKubeletOptions) (*options.KubeletFlags, *kubeletconfig.KubeletConfiguration) { testRootDir := utils.MakeTempDirOrDie("hollow-kubelet.", "") podFilePath := utils.MakeTempDirOrDie("static-pods", testRootDir) podLogsPath := utils.MakeTempDirOrDie("pod-logs", testRootDir) klog.Infof("Using %s as root dir for hollow-kubelet", testRootDir) // Flags struct f := options.NewKubeletFlags()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:10:54 UTC 2024 - 7.8K bytes - Viewed (0)