Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 145 for Implementation (0.26 sec)

  1. staging/src/k8s.io/apimachinery/pkg/runtime/serializer/cbor/cbor_test.go

    limitations under the License.
    */
    
    // The tests in this package focus on the correctness of its implementation of
    // runtime.Serializer. The specific behavior of marshaling Go values to CBOR bytes and back is
    // tested in the ./internal/modes package, which is used both by the Serializer implementation and
    // the package-scoped Marshal/Unmarshal functions in the ./direct package.
    package cbor
    
    import (
    	"bytes"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 13 14:57:12 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  2. plugin/pkg/admission/imagepolicy/admission.go

    		newImagePolicyWebhook, err := NewImagePolicyWebhook(config)
    		if err != nil {
    			return nil, err
    		}
    		return newImagePolicyWebhook, nil
    	})
    }
    
    // Plugin is an implementation of admission.Interface.
    type Plugin struct {
    	*admission.Handler
    	webhook       *webhook.GenericWebhook
    	responseCache *cache.LRUExpireCache
    	allowTTL      time.Duration
    	denyTTL       time.Duration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 02 06:05:06 UTC 2023
    - 9.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go

    			workqueue.TypedRateLimitingQueueConfig[string]{Name: "DynamicServingCertificateController"},
    		),
    		eventRecorder: eventRecorder,
    	}
    
    	return c
    }
    
    // GetConfigForClient is an implementation of tls.Config.GetConfigForClient
    func (c *DynamicServingCertificateController) GetConfigForClient(clientHello *tls.ClientHelloInfo) (*tls.Config, error) {
    	uncastObj := c.currentServingTLSConfig.Load()
    	if uncastObj == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/options/etcd.go

    	}
    	return cacheSizes, nil
    }
    
    var _ serverstorage.StorageFactory = &SimpleStorageFactory{}
    
    // SimpleStorageFactory provides a StorageFactory implementation that should be used when different
    // resources essentially share the same storage config (as defined by the given storagebackend.Config).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 15:02:16 UTC 2024
    - 20K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/plugin/v1beta1/stub.go

    	"k8s.io/apimachinery/pkg/util/wait"
    	"k8s.io/klog/v2"
    	pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1"
    	watcherapi "k8s.io/kubelet/pkg/apis/pluginregistration/v1"
    )
    
    // Stub implementation for DevicePlugin.
    type Stub struct {
    	devs                       []*pluginapi.Device
    	socket                     string
    	resourceName               string
    	preStartContainerFlag      bool
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 11:19:10 UTC 2023
    - 11.5K bytes
    - Viewed (0)
  6. pkg/controller/testutil/test_utils.go

    	testingclock "k8s.io/utils/clock/testing"
    
    	jsonpatch "gopkg.in/evanphx/json-patch.v4"
    )
    
    var (
    	keyFunc = cache.DeletionHandlingMetaNamespaceKeyFunc
    )
    
    // FakeNodeHandler is a fake implementation of NodesInterface and NodeInterface. It
    // allows test cases to have fine-grained control over mock behaviors. We also need
    // PodsInterface and PodInterface to test list & delete pods, which is implemented in
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/interface.go

    //
    // Plugins that make pod unschedulable (PreEnqueue, PreFilter, Filter, Reserve, and Permit plugins) should implement this interface,
    // otherwise the default implementation will be used, which is less efficient in requeueing Pods rejected by the plugin.
    // And, if plugins other than above extension points support this interface, they are just ignored.
    type EnqueueExtensions interface {
    	Plugin
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/healthz/healthz_test.go

    		if err == nil {
    			t.Errorf("expected error, got: %v", err)
    		}
    	})
    }
    
    type cacheSyncWaiterStub struct {
    	startedByInformerType map[reflect.Type]bool
    }
    
    // WaitForCacheSync is a stub implementation of the corresponding func
    // that simply returns the value passed during stub initialization.
    func (s cacheSyncWaiterStub) WaitForCacheSync(_ <-chan struct{}) map[reflect.Type]bool {
    	return s.startedByInformerType
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 15 20:43:16 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  9. pkg/controlplane/reconcilers/lease.go

    }
    
    func (s *storageLeases) Destroy() {
    	s.destroyFn()
    }
    
    // NewLeases creates a new etcd-based Leases implementation.
    func NewLeases(config *storagebackend.ConfigForResource, baseKey string, leaseTime time.Duration) (Leases, error) {
    	// note that newFunc, newListFunc and resourcePrefix
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/policy/v1beta1/types.go

    	// UnhealthyPodEvictionPolicy defines the criteria for when unhealthy pods
    	// should be considered for eviction. Current implementation considers healthy pods,
    	// as pods that have status.conditions item with type="Ready",status="True".
    	//
    	// Valid policies are IfHealthyBudget and AlwaysAllow.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 07 20:44:13 UTC 2023
    - 11.1K bytes
    - Viewed (0)
Back to top