Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 121 for Implementation (0.33 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/feature/feature_support_checker_test.go

    	clientv3 "go.etcd.io/etcd/client/v3"
    	"k8s.io/apiserver/pkg/storage"
    )
    
    type mockEndpointVersion struct {
    	Endpoint string
    	Version  string
    	Error    error
    }
    
    // MockEtcdClient is a mock implementation of the EtcdClientInterface interface.
    type MockEtcdClient struct {
    	EndpointVersion []mockEndpointVersion
    }
    
    func (m MockEtcdClient) getEndpoints() []string {
    	var endpoints []string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/util/intstr/intstr.go

    		}
    	}
    	return value, nil
    }
    
    // getIntOrPercentValue is a legacy function and only meant to be called by GetValueFromIntOrPercent
    // For a more correct implementation call getIntOrPercentSafely
    func getIntOrPercentValue(intOrStr *IntOrString) (int, bool, error) {
    	switch intOrStr.Type {
    	case Int:
    		return intOrStr.IntValue(), false, nil
    	case String:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:09 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_container_windows.go

    		//      resolution of 1-10000, so it's higher resolution than option a.
    		//      src: https://github.com/moby/moby/blob/10866714412aea1bb587d1ad14b2ce1ba4cf4308/daemon/oci_windows.go#L426
    		// Part three - CRI & ContainerD's implementation
    		//   The kubelet sets these directly on CGroups in Linux, but needs to pass them across CRI on Windows.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. staging/src/k8s.io/api/discovery/v1/types.go

    	//   * 'kubernetes.io/wss' - WebSocket over TLS as described in https://www.rfc-editor.org/rfc/rfc6455
    	//
    	// * Other protocols should use implementation-defined prefixed names such as
    	// mycompany.com/my-custom-protocol.
    	// +optional
    	AppProtocol *string `json:"appProtocol,omitempty" protobuf:"bytes,4,name=appProtocol"`
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 23 17:42:49 UTC 2024
    - 9.5K 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