- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 30 for Implementation (0.15 sec)
-
pkg/controller/volume/persistentvolume/volume_host.go
"k8s.io/apimachinery/pkg/types" clientset "k8s.io/client-go/kubernetes" "k8s.io/client-go/tools/record" vol "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/util/subpath" ) // VolumeHost interface implementation for PersistentVolumeController. var _ vol.VolumeHost = &PersistentVolumeController{} func (ctrl *PersistentVolumeController) GetPluginDir(pluginName string) string { return "" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/proxy/util/nfacct/handler.go
type request interface { Serialize() []byte AddData(data nl.NetlinkRequestData) AddRawData(data []byte) Execute(sockType int, resType uint16) ([][]byte, error) } // netlinkHandler is an implementation of the handler interface. It maintains a netlink socket // for communication with the NFAcct subsystem. type netlinkHandler struct { socket *nl.NetlinkSocket }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 06:47:50 UTC 2024 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/api/node/v1/types.go
// +optional metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` // handler specifies the underlying runtime and configuration that the CRI // implementation will use to handle pods of this class. The possible values // are specific to the node & CRI configuration. It is assumed that all // handlers are available on every node, and handlers of the same name are
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/plugin.go
func Register(plugins *admission.Plugins) { plugins.Register(PluginName, func(configFile io.Reader) (admission.Interface, error) { return NewPlugin(configFile), nil }) } // Plugin is an implementation of admission.Interface. type Policy = v1.ValidatingAdmissionPolicy type PolicyBinding = v1.ValidatingAdmissionPolicyBinding type PolicyEvaluator = Validator
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kubelet/cm/dra/state/state_checkpoint.go
// CDIDevices is a map of DriverName --> CDI devices returned by the // GRPC API call NodePrepareResource CDIDevices map[string][]string } // ClaimInfoStateWithoutResourceHandles is an old implementation of the ClaimInfoState // TODO: remove in Beta type ClaimInfoStateWithoutResourceHandles struct { // Name of the DRA driver DriverName string // ClassName is a resource class of the claim ClassName string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:27 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/registry/core/serviceaccount/storage/storage_test.go
// Currently this getter only panics as the only test case doesn't actually need the getters to function. // When more test cases are added, this getter will need extending/replacing to have a real test implementation. type panicGetter struct{} func (f panicGetter) Get(ctx context.Context, name string, options *metav1.GetOptions) (runtime.Object, error) { panic("not implemented") } var _ rest.Getter = panicGetter{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 6.7K bytes - Viewed (0) -
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) -
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)