Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 61 for Implementation (0.24 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go

    	storagetesting.RunWatchSemanticInitialEventsExtended(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: Wed Apr 24 18:25:29 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  2. pkg/controller/volume/expand/expand_controller.go

    	return nil, fmt.Errorf("NewWrapperMounter not supported by expand controller's VolumeHost implementation")
    }
    
    func (expc *expandController) NewWrapperUnmounter(volName string, spec volume.Spec, podUID types.UID) (volume.Unmounter, error) {
    	return nil, fmt.Errorf("NewWrapperUnmounter not supported by expand controller's VolumeHost implementation")
    }
    
    func (expc *expandController) GetMounter(pluginName string) mount.Interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. pkg/controller/nodeipam/ipam/range_allocator_test.go

    			t.Errorf("%v: failed to create CIDRRangeAllocator with error %v", tc.description, err)
    			return
    		}
    		rangeAllocator, ok := allocator.(*rangeAllocator)
    		if !ok {
    			t.Logf("%v: found non-default implementation of CIDRAllocator, skipping white-box test...", tc.description)
    			return
    		}
    		rangeAllocator.nodesSynced = test.AlwaysReady
    		rangeAllocator.recorder = testutil.NewFakeRecorder()
    		go allocator.Run(tCtx)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/cmd/certs.go

    			Use:   handler.Name,
    			Short: fmt.Sprintf("Renew the %s", handler.LongName),
    			Long:  fmt.Sprintf(genericCertRenewLongDesc, handler.LongName),
    		}
    		addRenewFlags(cmd, flags)
    		// get the implementation of renewing this certificate
    		renewalFunc := func(handler *renewal.CertificateRenewHandler) func() error {
    			return func() error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 16:01:49 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  5. pkg/controller/volume/attachdetach/attach_detach_controller.go

    	return nil, fmt.Errorf("NewWrapperMounter not supported by Attach/Detach controller's VolumeHost implementation")
    }
    
    func (adc *attachDetachController) NewWrapperUnmounter(volName string, spec volume.Spec, podUID types.UID) (volume.Unmounter, error) {
    	return nil, fmt.Errorf("NewWrapperUnmounter not supported by Attach/Detach controller's VolumeHost implementation")
    }
    
    func (adc *attachDetachController) GetMounter(pluginName string) mount.Interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top