- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 120 for Implementation (0.37 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)