- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 121 for Implementation (0.18 sec)
-
cmd/kubeadm/app/util/dryrun/dryrun.go
} fmt.Fprintf(w, "[dryrun] Would write file %q with content:\n", outputFilePath) apiclient.PrintBytesWithLinePrefix(w, fileBytes, "\t") } return errorsutil.NewAggregate(errs) } // Waiter is an implementation of apiclient.Waiter that should be used for dry-running type Waiter struct{} // NewWaiter returns a new Waiter object that talks to the given Kubernetes cluster func NewWaiter() apiclient.Waiter { return &Waiter{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 6.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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)