Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for Implementation (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top