- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 5,546 for utilfs (0.13 sec)
-
pkg/volume/flexvolume/fake_watcher.go
*/ package flexvolume import ( "github.com/fsnotify/fsnotify" utilfs "k8s.io/kubernetes/pkg/util/filesystem" ) // Mock filesystem watcher type fakeWatcher struct { watches []string // List of watches added by the prober, ordered from least recent to most recent. eventHandler utilfs.FSEventHandler } var _ utilfs.FSWatcher = &fakeWatcher{} func newFakeWatcher() *fakeWatcher { return &fakeWatcher{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 20 17:33:45 UTC 2018 - 1.4K bytes - Viewed (0) -
pkg/kubelet/kubeletconfig/util/files/files.go
package files import ( "fmt" "os" "path/filepath" utilfs "k8s.io/kubernetes/pkg/util/filesystem" ) const ( defaultPerm = 0755 tmpTag = "tmp_" // additional prefix to prevent accidental collisions ) // FileExists returns true if a regular file exists at `path`, false if `path` does not exist, otherwise an error func FileExists(fs utilfs.Filesystem, path string) (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 01:02:46 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/kubelet/util/store/filestore.go
// Absolute path to the base directory for storing data files. directoryPath string // filesystem to use. filesystem utilfs.Filesystem } // NewFileStore returns an instance of FileStore. func NewFileStore(path string, fs utilfs.Filesystem) (Store, error) { if err := fs.MkdirAll(path, 0755); err != nil { return nil, err } return &FileStore{directoryPath: path, filesystem: fs}, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 18 15:08:27 UTC 2022 - 3.9K bytes - Viewed (0) -
pkg/kubelet/kubeletconfig/configfiles/configfiles.go
kubeletconfig "k8s.io/kubernetes/pkg/kubelet/apis/config" kubeletscheme "k8s.io/kubernetes/pkg/kubelet/apis/config/scheme" utilcodec "k8s.io/kubernetes/pkg/kubelet/kubeletconfig/util/codec" utilfs "k8s.io/kubernetes/pkg/util/filesystem" ) // Loader loads configuration from a storage layer type Loader interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/volume/flexvolume/probe.go
import ( "fmt" "os" "path/filepath" "strings" "sync" "github.com/fsnotify/fsnotify" "k8s.io/apimachinery/pkg/util/errors" "k8s.io/klog/v2" utilfs "k8s.io/kubernetes/pkg/util/filesystem" "k8s.io/kubernetes/pkg/volume" "k8s.io/utils/exec" utilstrings "k8s.io/utils/strings" ) type flexVolumeProber struct { mutex sync.Mutex pluginDir string // Flexvolume driver directory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 28 11:14:00 UTC 2023 - 9K bytes - Viewed (0) -
pkg/kubelet/kubeletconfig/configfiles/configfiles_test.go
kubeletconfig "k8s.io/kubernetes/pkg/kubelet/apis/config" kubeletscheme "k8s.io/kubernetes/pkg/kubelet/apis/config/scheme" utilfiles "k8s.io/kubernetes/pkg/kubelet/kubeletconfig/util/files" utiltest "k8s.io/kubernetes/pkg/kubelet/kubeletconfig/util/test" utilfs "k8s.io/kubernetes/pkg/util/filesystem" ) const configDir = "/test-config-dir" const relativePath = "relative/path/test" const kubeletFile = "kubelet" func TestLoad(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 18 12:18:41 UTC 2023 - 7.2K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher.go
"github.com/fsnotify/fsnotify" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/kubelet/pluginmanager/cache" "k8s.io/kubernetes/pkg/kubelet/util" utilfs "k8s.io/kubernetes/pkg/util/filesystem" ) // Watcher is the plugin watcher type Watcher struct { path string fs utilfs.Filesystem fsWatcher *fsnotify.Watcher desiredStateOfWorld cache.DesiredStateOfWorld }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 01 00:26:37 UTC 2023 - 6.1K bytes - Viewed (0) -
pkg/kubelet/checkpointmanager/checkpoint_manager.go
limitations under the License. */ package checkpointmanager import ( "fmt" "sync" "k8s.io/kubernetes/pkg/kubelet/checkpointmanager/errors" utilstore "k8s.io/kubernetes/pkg/kubelet/util/store" utilfs "k8s.io/kubernetes/pkg/util/filesystem" ) // Checkpoint provides the process checkpoint data type Checkpoint interface { MarshalCheckpoint() ([]byte, error) UnmarshalCheckpoint(blob []byte) error VerifyChecksum() error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 24 13:51:34 UTC 2021 - 3.5K bytes - Viewed (0) -
pkg/volume/flexvolume/flexvolume_test.go
"os" "path/filepath" goruntime "runtime" "testing" "text/template" "k8s.io/api/core/v1" utiltesting "k8s.io/client-go/util/testing" utilfs "k8s.io/kubernetes/pkg/util/filesystem" "k8s.io/kubernetes/pkg/volume" volumetest "k8s.io/kubernetes/pkg/volume/testing" "k8s.io/utils/exec" ) const execScriptTempl1 = `#!/usr/bin/env bash if [ "$1" == "init" -a $# -eq 1 ]; then echo -n '{ "status": "Success"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 6.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/experimental/tac/common/utils.cc
#include "tensorflow/compiler/mlir/lite/experimental/tac/common/utils.h" #include "llvm/Support/Casting.h" #include "mlir/IR/OpDefinition.h" // from @llvm-project #include "tensorflow/compiler/mlir/lite/experimental/tac/common/targets.h" #include "tensorflow/compiler/mlir/lite/ir/tfl_ops.h" #include "tensorflow/compiler/mlir/lite/utils/utils.h" namespace mlir { namespace TFL { namespace tac {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Mar 06 05:37:07 UTC 2024 - 2.3K bytes - Viewed (0)