- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 320 for append (0.14 sec)
-
docs/debugging/s3-check-md5/main.go
if debug { s3Client.TraceOn(os.Stderr) } var buckets []string if bucket != "" { buckets = append(buckets, bucket) } else { bucketsInfo, err := s3Client.ListBuckets(context.Background()) if err != nil { log.Fatalln(err) } for _, b := range bucketsInfo { buckets = append(buckets, b.Name) } } for _, bucket := range buckets { opts := minio.ListObjectsOptions{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Feb 17 01:15:57 GMT 2024 - 6.3K bytes - Viewed (0) -
docs/debugging/xl-meta/main.go
var files []string for _, pattern := range args { if pattern == "-" { files = append(files, pattern) continue } found, err := filepathx.Glob(pattern) if err != nil { return err } if len(found) == 0 { return fmt.Errorf("unable to find file %v", pattern) } files = append(files, found...) } if len(files) == 0 { return fmt.Errorf("no files found") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:56:22 GMT 2024 - 20.2K bytes - Viewed (1) -
internal/config/identity/openid/openid.go
} else { kvsrc.Value = "off" } } res = append(res, madmin.IDPCfgInfo{ Key: kvsrc.Key, Value: kvsrc.Value, IsCfg: true, IsEnv: kvsrc.Src == config.ValueSourceEnv, }) } if provCfg, exists := r.ProviderCfgs[cfgName]; exists && provCfg.RolePolicy != "" { // Append roleARN res = append(res, madmin.IDPCfgInfo{ Key: "roleARN", Value: provCfg.roleArn.String(),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 16 04:42:31 GMT 2023 - 16.5K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// Data blocks can vary per pool, but parity is same. for i, setDriveCount := range z.SetDriveCounts() { b.StandardSCData = append(b.StandardSCData, setDriveCount-scParity) b.RRSCData = append(b.RRSCData, setDriveCount-rrSCParity) b.DrivesPerSet = append(b.DrivesPerSet, setDriveCount) b.TotalSets = append(b.TotalSets, z.serverPools[i].setCount) } b.StandardSCParity = scParity b.RRSCParity = rrSCParity return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/s3select/sql/jsonpath.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 3.4K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
if list == nil { return []Target{} } list.RLock() defer list.RUnlock() targets := make([]Target, 0, len(list.targets)) for _, tgt := range list.targets { targets = append(targets, tgt) } return targets } // Empty returns true if targetList is empty. func (list *TargetList) Empty() bool { list.RLock() defer list.RUnlock() return len(list.targets) == 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 4.3K bytes - Viewed (0) -
internal/s3select/sql/stringfuncs.go
s := []rune{} prev := runeZero hasLeadingPercent := false patLen := len([]rune(pattern)) for i, r := range pattern { if i > 0 && prev == escape { switch r { case percent, escape, underscore: s = append(s, r) prev = r if r == escape { prev = runeZero } default: return false, errMalformedEscapeSequence } continue } prev = r var ok bool switch r {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 4.2K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux.go
if strings.HasPrefix(mpath, ppath) { // At this point if the mount point has a common prefix two conditions can happen. // - mount.Path matches exact with `path` means we can proceed no error here. // - mount.Path doesn't match (means cross-device mount), should error out. if mount.Path != path { crossMounts = append(crossMounts, mount) } } }
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/bucket-targets.go
defer hcTimer.Stop() for { select { case <-hcTimer.C: sys.hMutex.RLock() eps := make([]madmin.ServerProperties, 0, len(sys.hc)) for _, ep := range sys.hc { eps = append(eps, madmin.ServerProperties{Endpoint: ep.Endpoint, Scheme: ep.Scheme}) } sys.hMutex.RUnlock() if len(eps) > 0 { cctx, cancel := context.WithTimeout(ctx, 30*time.Second)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
eventName, err := event.ParseName(s) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } mask.MergeMaskable(eventName) eventNames = append(eventNames, eventName) } if bucketName != "" { if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0)