- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for tmp (0.11 sec)
-
cni/pkg/install/kubeconfig_test.go
kubeCAFilepath = "testdata/kube-ca.crt" saToken = "service_account_token_string" ) func TestCreateValidKubeconfigFile(t *testing.T) { tmp := t.TempDir() os.WriteFile(filepath.Join(tmp, "token"), []byte(saToken), 0o644) constants.ServiceAccountPath = tmp cases := []struct { name string expectedFailure bool k8sServiceProtocol string k8sServiceHost string k8sServicePort string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 03:52:24 GMT 2024 - 5.1K bytes - Viewed (0) -
cmd/os_unix.go
var nameStr string if typ.IsRegular() { nameStr = string(name) } else if typ.IsDir() { // Use temp buffer to append a slash to avoid string concat. tmp = tmp[:len(name)+1] copy(tmp, name) tmp[len(tmp)-1] = '/' // SlashSeparator nameStr = string(tmp) } count-- entries = append(entries, nameStr) } return } func globalSync() { defer globalOSMetrics.time(osMetricSync)()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/storage-datatypes_test.go
v := DiskInfo{ Total: 1000, Free: 1000, Used: 1000, FSType: "xfs", RootDisk: true, Healing: true, Endpoint: "http://localhost:9001/tmp/drive1", MountPath: "/tmp/drive1", ID: "uuid", Error: "", } var buf bytes.Buffer msgp.Encode(&buf, &v) rd := msgp.NewEndlessReader(buf.Bytes(), b) dc := msgp.NewReader(rd)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 9.4K bytes - Viewed (0) -
internal/s3select/simdj/record.go
csvRecord := make([]string, 0, 10) var tmp simdjson.Iter obj := r.object allElems: for { _, typ, err := obj.NextElement(&tmp) if err != nil { return err } var columnValue string switch typ { case simdjson.TypeNull, simdjson.TypeFloat, simdjson.TypeUint, simdjson.TypeInt, simdjson.TypeBool, simdjson.TypeString: val, err := tmp.StringCvt() if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 5.4K bytes - Viewed (0) -
internal/http/server.go
return nil } // Write all running goroutines. tmp, err := os.CreateTemp("", "minio-goroutines-*.txt") if err == nil { _ = pprof.Lookup("goroutine").WriteTo(tmp, 1) tmp.Close() return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name()) } return errors.New("timed out. some connections are still active") case <-timer.C:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux.go
} var crossMounts mountInfos for _, mount := range mts { // Add a separator to indicate that this is a proper mount-point. // This is to avoid a situation where prefix is '/tmp/fsmount' // and mount path is /tmp/fs. In such a scenario we need to check for // `/tmp/fs/` to be a common prefix amount other mounts. mpath := strings.TrimSuffix(mount.Path, "/") + "/" ppath := strings.TrimSuffix(path, "/") + "/"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.7K bytes - Viewed (0) -
cmd/mrf.go
// No MRF needed for temporary objects if wildcard.Match("buckets/*/.metacache/*", u.object) { continue } if wildcard.Match("tmp/*", u.object) { continue } if wildcard.Match("multipart/*", u.object) { continue } if wildcard.Match("tmp-old/*", u.object) { continue } } now := time.Now() if now.Sub(u.queued) < time.Second {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
docs/debugging/inspect/export.go
tmp := struct { VersionID string ModTime time.Time Signature string Type uint8 Flags uint8 }{ VersionID: hex.EncodeToString(z.VersionID[:]), ModTime: time.Unix(0, z.ModTime), Signature: hex.EncodeToString(z.Signature[:]), Type: z.Type, Flags: z.Flags, } return json.Marshal(tmp)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 08 15:58:02 GMT 2022 - 9.1K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
netServer: fs, } handlers := setupHandlers(ctx, client, dpServer, "istio-system") // We are not going to start the server, so the sockpath is irrelevant pluginServer := startCniPluginServer(ctx, "/tmp/test.sock", handlers, dpServer) // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`, constants.DataplaneModeLabel, constants.DataplaneModeAmbient))
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) -
cmd/xl-storage-format-v1.go
if bts, err := c.MarshalMsg(metaDataPoolGet()); err == nil { crc ^= xxhash.Sum64(bts) metaDataPoolPut(bts) } // Combine upper and lower part var tmp [4]byte binary.LittleEndian.PutUint32(tmp[:], uint32(crc^(crc>>32))) return tmp } // XL metadata constants. const ( // XL meta version. xlMetaVersion101 = "1.0.1" // XL meta version. xlMetaVersion100 = "1.0.0"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8.2K bytes - Viewed (0)