- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for fs (0.14 sec)
-
cni/pkg/nodeagent/podcgroupns_other.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 781 bytes - Viewed (0) -
cni/pkg/repair/netns.go
wantID, err := findNetworkIDByIP(pod.Status.PodIP) if err != nil { return "", fmt.Errorf("network id: %v", err) } fs, err := procfs.NewFS("/host/proc") if err != nil { return "", fmt.Errorf("read procfs: %v", err) } procs, err := fs.AllProcs() if err != nil { return "", fmt.Errorf("read procs: %v", err) } oldest := uint64(math.MaxUint64) best := ""
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), "", ).Return(nil) server := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } fs.Start(ctx) handlers := setupHandlers(ctx, client, server, "istio-system")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
manifests/manifest.go
package manifests import ( "embed" "io/fs" "os" ) // FS embeds the manifests // //go:embed all:charts/* profiles/* var FS embed.FS // BuiltinOrDir returns a FS for the provided directory. If no directory is passed, the compiled in // FS will be used func BuiltinOrDir(dir string) fs.FS { if dir == "" { return FS } return os.DirFS(dir)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 15 02:30:16 GMT 2023 - 935 bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_linux.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "fmt" "io/fs" "syscall" ) func GetInode(fi fs.FileInfo) (uint64, error) { if stat, ok := fi.Sys().(*syscall.Stat_t); ok { return stat.Ino, nil } return 0, fmt.Errorf("unable to get inode")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 814 bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
return nil } func fakeFs() fs.FS { subFs, err := fs.Sub(fakeProc, "testdata") if err != nil { panic(err) } subFs, err = fs.Sub(subFs, "cgroupns") if err != nil { panic(err) } return &fakeFsWithFakeFds{ReadDirFS: subFs.(fs.ReadDirFS)} } type fakeFsWithFakeFds struct { fs.ReadDirFS } type fakeFileFakeFds struct { fs.File fd uintptr }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
type PodNetnsEntry struct { uid types.UID netns fs.File netnsfd uintptr inode uint64 } func (p *PodNetnsProcFinder) processEntry(proc fs.FS, netnsObserved sets.Set[uint64], filter sets.Set[types.UID], entry fs.DirEntry) (*PodNetnsEntry, error) { if !isProcess(entry) { return nil, nil } netnsName := path.Join(entry.Name(), "ns", "net") fi, err := fs.Stat(proc, netnsName) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), valid.Netns, ).Return(nil) dpServer := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, dpServer, "istio-system")
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
// See the License for the specific language governing permissions and // limitations under the License. package mesh import ( "archive/tar" "compress/gzip" "encoding/json" "fmt" "io" "io/fs" "os" "path" "path/filepath" "reflect" "strings" "testing" "github.com/google/go-cmp/cmp" . "github.com/onsi/gomega" v1 "k8s.io/api/admissionregistration/v1"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0)