- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for Implementation (0.17 sec)
-
pkg/kubelet/configmap/configmap_manager.go
} // configMapManager keeps a cache of all configmaps necessary // for registered pods. Different implementation of the store // may result in different semantics for freshness of configmaps // (e.g. ttl-based implementation vs watch-based implementation). type configMapManager struct { manager manager.Manager }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/kubelet/secret/secret_manager.go
func (s *simpleSecretManager) UnregisterPod(pod *v1.Pod) { } // secretManager keeps a store with secrets necessary // for registered pods. Different implementations of the store // may result in different semantics for freshness of secrets // (e.g. ttl-based implementation vs watch-based implementation). type secretManager struct { manager manager.Manager } func (s *secretManager) GetSecret(namespace, name string) (*v1.Secret, error) {
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/util/manager/cache_based_manager.go
} } 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 { objectStore Store getReferencedObjects func(*v1.Pod) sets.Set[string]
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/apimachinery/pkg/runtime/serializer/cbor/internal/modes/decode.go
TimeTag: cbor.DecTagOptional, // Observed depth up to 16 in fuzzed batch/v1 CronJobList. JSON implementation limit // is 10000. MaxNestedLevels: 64, MaxArrayElements: 1024, MaxMapPairs: 1024, // Indefinite-length sequences aren't produced by this serializer, but other // implementations can. IndefLength: cbor.IndefLengthAllowed, // Accept inputs that contain CBOR tags.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 14:03:36 UTC 2024 - 3.9K bytes - Viewed (0) -
cmd/kubeadm/app/util/dryrun/dryrun.go
} fmt.Fprintf(w, "[dryrun] Would write file %q with content:\n", outputFilePath) apiclient.PrintBytesWithLinePrefix(w, fileBytes, "\t") } return errorsutil.NewAggregate(errs) } // Waiter is an implementation of apiclient.Waiter that should be used for dry-running type Waiter struct{} // NewWaiter returns a new Waiter object that talks to the given Kubernetes cluster func NewWaiter() apiclient.Waiter { return &Waiter{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 6.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval.go
// copied over. // // The source of events for the interval is typically either // the watchCache circular buffer, if events being retrieved // need to be for resource versions > 0 or the underlying // implementation of Store, if resource version = 0. // // Furthermore, an interval can be either valid or invalid at // any given point of time. The notion of validity makes sense // only in cases where the window of events in the underlying
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
WaitForKubelet(healthzAddress string, healthzPort int32) error // SetTimeout adjusts the timeout to the specified duration SetTimeout(timeout time.Duration) } // KubeWaiter is an implementation of Waiter that is backed by a Kubernetes client type KubeWaiter struct { client clientset.Interface timeout time.Duration writer io.Writer }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
ctx, store, _ := testSetup(t) storagetesting.RunTestCount(ctx, t, store) } // ======================================================================= // Implementation-specific tests are following. // The following tests are exercising the details of the implementation // not the actual user-facing contract of storage interface. // As such, they may focus e.g. on non-functional aspects like performance // impact.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
return store } func (c *objectCache) newStore() *cacheStore { // TODO: We may consider created a dedicated store keeping just a single // item, instead of using a generic store implementation for this purpose. // However, simple benchmarks show that memory overhead in that case is // decrease from ~600B to ~300B per object. So we are not optimizing it // until we will see a good reason for that.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/features/kube_features.go
// kep: https://kep.k8s.io/2364 // alpha: v1.23 // // Configures the Kubelet to use the CRI to populate pod and container stats, instead of supplimenting with stats from cAdvisor. // Requires the CRI implementation supports supplying the required stats. PodAndContainerStatsFromCRI featuregate.Feature = "PodAndContainerStatsFromCRI" // owner: @ahg-g // alpha: v1.21 // beta: v1.22 //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 22:51:23 UTC 2024 - 45.2K bytes - Viewed (0)