- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 187 for Implementation (0.19 sec)
-
staging/src/k8s.io/api/node/v1alpha1/types_swagger_doc_generated.go
"runtimeHandler": "runtimeHandler 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...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 22 00:51:25 UTC 2023 - 5K bytes - Viewed (0) -
pkg/volume/flexvolume/mounter-defaults.go
*/ package flexvolume import ( "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/volume" ) type mounterDefaults flexVolumeMounter // SetUpAt is part of the volume.Mounter interface. // This implementation relies on the attacher's device mount path and does a bind mount to dir. func (f *mounterDefaults) SetUpAt(dir string, mounterArgs volume.MounterArgs) error { klog.Warning(logPrefix(f.plugin), "using default SetUpAt to ", dir)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 24 15:56:30 UTC 2022 - 1.5K bytes - Viewed (0) -
pkg/proxy/util/testing/fake.go
return &FakeNetwork{ NetworkInterfaces: make([]net.Interface, 0), Address: make(map[string][]net.Addr), } } // AddInterfaceAddr create an interface and its associated addresses for FakeNetwork implementation. func (f *FakeNetwork) AddInterfaceAddr(intf *net.Interface, addrs []net.Addr) { f.NetworkInterfaces = append(f.NetworkInterfaces, *intf) f.Address[intf.Name] = addrs }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 05 08:08:19 UTC 2021 - 1.5K bytes - Viewed (0) -
pkg/util/node/node.go
NodeUnreachablePodMessage = "Node %v which was running pod %v is unresponsive" ) // NoMatchError is a typed implementation of the error interface. It indicates a failure to get a matching Node. type NoMatchError struct { addresses []v1.NodeAddress } // Error is the implementation of the conventional interface for // representing an error condition, with the nil value representing no error.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 23:24:38 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/proxy/util/localdetector.go
import ( netutils "k8s.io/utils/net" ) // LocalTrafficDetector generates iptables or nftables rules to detect traffic from local pods. type LocalTrafficDetector interface { // IsImplemented returns true if the implementation does something, false // otherwise. You should not call the other methods if IsImplemented() returns // false. IsImplemented() bool // IfLocal returns iptables arguments that will match traffic from a local pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 15:34:37 UTC 2024 - 3.6K bytes - Viewed (0) -
pkg/volume/util/device_util.go
FindDevicesForISCSILun(targetIqn string, lun int) ([]string, error) } type deviceHandler struct { getIo IoUtil } // NewDeviceHandler Create a new IoHandler implementation func NewDeviceHandler(io IoUtil) DeviceUtil { return &deviceHandler{getIo: io}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 1.1K bytes - Viewed (0) -
pkg/kubelet/util/ioutils/ioutils.go
import "io" // LimitWriter is a copy of the standard library ioutils.LimitReader, // applied to the writer interface. // LimitWriter returns a Writer that writes to w // but stops with EOF after n bytes. // The underlying implementation is a *LimitedWriter. func LimitWriter(w io.Writer, n int64) io.Writer { return &LimitedWriter{w, n} } // A LimitedWriter writes to W but limits the amount of // data returned to just N bytes. Each call to Write
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 12:00:49 UTC 2023 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/audit/union.go
"fmt" "strings" "k8s.io/apimachinery/pkg/util/errors" auditinternal "k8s.io/apiserver/pkg/apis/audit" ) // Union returns an audit Backend which logs events to a set of backends. The returned // Sink implementation blocks in turn for each call to ProcessEvents. func Union(backends ...Backend) Backend { if len(backends) == 1 { return backends[0] } return union{backends} } type union struct { backends []Backend
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 20 09:51:25 UTC 2022 - 1.8K bytes - Viewed (0) -
pkg/kubelet/container/container_gc.go
MaxPerPodContainer int // Max number of total dead containers, less than zero for no limit. MaxContainers int } // GC manages garbage collection of dead containers. // // Implementation is thread-compatible. type GC interface { // Garbage collect containers. GarbageCollect(ctx context.Context) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/fifo_list.go
// walkFunc may remove the given request from the fifo, // but may not mutate the fifo in any othe way. type walkFunc func(*request) (ok bool) // Internal interface to abstract out the implementation details // of the underlying list used to maintain the requests. // // Note that a fifo, including the removeFromFIFOFuncs returned from Enqueue, // is not safe for concurrent use by multiple goroutines.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 16:05:53 UTC 2021 - 3.9K bytes - Viewed (0)