- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 364 for Implementation (0.2 sec)
-
pkg/volume/util/hostutil/hostutil_linux.go
return fmt.Errorf("failed to make %s rshared: %v", path, err) } return nil } // selinux.SELinuxEnabled implementation for unit tests type seLinuxEnabledFunc func() bool // GetSELinux is common implementation of GetSELinuxSupport on Linux. func GetSELinux(path string, mountInfoFilename string, selinuxEnabled seLinuxEnabledFunc) (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 23 08:36:44 UTC 2023 - 10K 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/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) -
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) -
pkg/proxy/conntrack/cleanup_test.go
// We need to construct a proxy.ServicePortMap to pass to CleanStaleEntries. // ServicePortMap is just map[string]proxy.ServicePort, but there are no public // constructors for any implementation of proxy.ServicePort, so we have to either // provide our own implementation of that interface, or else use a // proxy.ServiceChangeTracker to construct them and fill in the map for us. sct := proxy.NewServiceChangeTracker(nil, v1.IPv4Protocol, nil, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/warning/context.go
// text must be valid UTF-8, and must not contain control characters. AddWarning(agent, text string) } // WithWarningRecorder returns a new context that wraps the provided context and contains the provided Recorder implementation. // The returned context can be passed to AddWarning(). func WithWarningRecorder(ctx context.Context, recorder Recorder) context.Context { return context.WithValue(ctx, warningRecorderKey, recorder) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 24 16:37:53 UTC 2022 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/mutation/unstructured/typeref.go
*/ package unstructured import ( "github.com/google/cel-go/common/types" "github.com/google/cel-go/common/types/ref" "k8s.io/apiserver/pkg/cel/mutation/common" ) // TypeRef is the implementation of TypeRef for an unstructured object. // This is especially usefully when the schema is not known or available. type TypeRef struct { celObjectType *types.Type celTypeType *types.Type }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 24 00:01:35 UTC 2024 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/errors.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package cel // Error is an implementation of the 'error' interface, which represents a // XValidation error. type Error struct { Type ErrorType Detail string } var _ error = &Error{} // Error implements the error interface.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 10 22:05:55 UTC 2022 - 1.4K bytes - Viewed (0)