- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,333 for Kappen (0.19 sec)
-
internal/ioutil/append-file_nix.go
package ioutil import ( "io" "os" ) // AppendFile - appends the file "src" to the file "dst" func AppendFile(dst string, src string, osync bool) error { flags := os.O_WRONLY | os.O_APPEND | os.O_CREATE if osync { flags |= os.O_SYNC } appendFile, err := os.OpenFile(dst, flags, 0o666) if err != nil { return err } defer appendFile.Close() srcFile, err := os.Open(src)
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 1.3K bytes - Viewed (0) -
internal/ioutil/append-file_windows.go
"os" "github.com/minio/minio/internal/lock" ) // AppendFile - appends the file "src" to the file "dst" func AppendFile(dst string, src string, osync bool) error { appendFile, err := lock.Open(dst, os.O_WRONLY|os.O_APPEND|os.O_CREATE, 0o666) if err != nil { return err } defer appendFile.Close() srcFile, err := lock.Open(src, os.O_RDONLY, 0o666) if err != nil { return err } defer srcFile.Close()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 1.2K bytes - Viewed (0) -
cmd/iam-store.go
if _, ok := cache.iamUsersMap[u]; !ok { // This case can happen when a temporary account is // deleted or expired - remove it from userPolicyMap. delete(cache.iamUserPolicyMap, u) continue } } if pset.Contains(policy) { users = append(users, u) } } for g, mp := range cache.iamGroupPolicyMap { pset := mp.policySet()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Mar 21 17:19:50 GMT 2024 - 73.2K bytes - Viewed (2) -
cmd/speedtest.go
Err: errStr, }) totalUploadTimes = append(totalUploadTimes, throughputHighestResults[i].UploadTimes...) totalDownloadTimes = append(totalDownloadTimes, throughputHighestResults[i].DownloadTimes...) totalDownloadTTFB = append(totalDownloadTTFB, throughputHighestResults[i].DownloadTTFB...) } result.PUTStats.Response = totalUploadTimes.Measure() result.GETStats.Response = totalDownloadTimes.Measure()
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
cmd/bucket-policy.go
data, err := json.Marshal(bucketPolicy) if err != nil { // This should not happen because bucketPolicy is valid to convert to JSON data. return nil, err } var policyInfo miniogopolicy.BucketAccessPolicy json := jsoniter.ConfigCompatibleWithStandardLibrary if err = json.Unmarshal(data, &policyInfo); err != nil { // This should not happen because data is valid to JSON data. return nil, err }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Mon Feb 05 19:44:23 GMT 2024 - 7.9K bytes - Viewed (0) -
internal/store/batch.go
if !ok { err = fmt.Errorf("item not found for the key: %v; should not happen;", key) return } orderedItems = append(orderedItems, item) delete(b.items, key) } b.keys = b.keys[:0] return } // GetByKey will get the batch item by the provided key func (b *Batch[K, T]) GetByKey(key K) (T, bool) { b.Lock() defer b.Unlock() item, ok := b.items[key] return item, ok }
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 2.5K bytes - Viewed (0) -
tests/associations_many2many_test.go
languages := []Language{ {Code: "language-many2many-append-1-1", Name: "language-many2many-append-1-1"}, {Code: "language-many2many-append-2-1", Name: "language-many2many-append-2-1"}, } DB.Create(&languages) if err := DB.Model(&user2).Association("Languages").Append(&languages); err != nil { t.Fatalf("Error happened when append language, got %v", err) } user.Languages = append(user.Languages, languages...)
Go - Registered: Sun Mar 24 09:35:10 GMT 2024 - Last Modified: Sat Jun 10 13:05:19 GMT 2023 - 13.2K bytes - Viewed (0) -
cni/pkg/ambient/informers.go
case joinMesh: log.Debugf("Pod now matches, adding to mesh") s.podReconcileHandler.addPodToMesh(newPod) case meshedPodNotEnrolled: // This can happen if a node cleanup happens as part of a ztunnel recycle, // cleaning up the node-level ipset with all the pod IPs // If this happens we re-queue everything for reconciliation, and need to // make sure existing pods get re-added to the ipset if they aren't already there.
Go - Registered: Wed Jan 24 22:53:09 GMT 2024 - Last Modified: Fri Dec 01 02:50:22 GMT 2023 - 5.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
buf.append('"').append(StringEscapeUtils.escapeJson(format)).append('"'); } else if (value instanceof String[]) { final String json = Arrays.stream((String[]) value).map(s -> "\"" + StringEscapeUtils.escapeJson(s) + "\"") .collect(Collectors.joining(",")); buf.append('[').append(json).append(']'); } else if (value instanceof List) {
Java - Registered: Mon Mar 25 08:04:08 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 25.2K bytes - Viewed (0) -
tests/scanner_valuer_test.go
) func TestScannerValuer(t *testing.T) { DB.Migrator().DropTable(&ScannerValuerStruct{}) if err := DB.Migrator().AutoMigrate(&ScannerValuerStruct{}); err != nil { t.Fatalf("no error should happen when migrate scanner, valuer struct, got error %v", err) } data := ScannerValuerStruct{ Name: sql.NullString{String: "name", Valid: true}, Gender: &sql.NullString{String: "M", Valid: true},
Go - Registered: Sun Mar 24 09:35:10 GMT 2024 - Last Modified: Wed Jun 07 07:02:07 GMT 2023 - 10.6K bytes - Viewed (0)