- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 107 for Walker (0.18 sec)
-
cmd/erasure-server-pool.go
var loi ListObjectsInfo opts := listPathOptions{ V1: v1, Bucket: bucket, Prefix: prefix, Separator: delimiter, Limit: maxKeysPlusOne(maxKeys, marker != ""), Marker: marker, InclDeleted: false,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 77.8K bytes - Viewed (0) -
cmd/metacache-marker.go
import ( "context" "fmt" "strconv" "strings" ) // markerTagVersion is the marker version. // Should not need to be updated unless a fundamental change is made to the marker format. const markerTagVersion = "v2" // parseMarker will parse a marker possibly encoded with encodeMarker func (o *listPathOptions) parseMarker() { s := o.Marker if !strings.Contains(s, "[minio_cache:"+markerTagVersion) { return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/erasure-object.go
// Bucket is versioned and no version was explicitly // mentioned for deletes, create a delete marker instead. vr.ModTime = UTCNow() vr.Deleted = true // Versioning suspended means that we add a `null` version // delete marker, if not add a new version for this delete // marker. if versioned { vr.VersionID = mustGetUUID() } } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 76.3K bytes - Viewed (2) -
cmd/metacache-set_gen.go
} case "FilterPrefix": z.FilterPrefix, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "FilterPrefix") return } case "Marker": z.Marker, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "Marker") return } case "Limit": z.Limit, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "Limit") return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/grid/README.md
out <- []byte("response") // Return the request for reuse grid.PutByteBuffer(req) } } // out is closed by the caller and should never be closed by the handler. return nil } err := manager.RegisterStreamingHandler(grid.HandlerDiskInfo, StreamHandler{ Handle: handler, Subroute: "asubroute",
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/object-api-errors.go
return "Bucket exists: " + e.Bucket } // InvalidUploadIDKeyCombination - invalid upload id and key marker combination. type InvalidUploadIDKeyCombination struct { UploadIDMarker, KeyMarker string } func (e InvalidUploadIDKeyCombination) Error() string { return fmt.Sprintf("Invalid combination of uploadID marker '%s' and marker '%s'", e.UploadIDMarker, e.KeyMarker) } // BucketPolicyNotFound - no bucket policy found.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/storage-errors.go
// errLessData - returned when less data available than what was requested. var errLessData = StorageErr("less data available than what was requested") // errMoreData = returned when more data was sent by the caller than what it was supposed to. var errMoreData = StorageErr("more data was sent than what was advertised") // indicates readDirFn to return without further applying the fn() var errDoneForNow = errors.New("done for now")
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
docs/debugging/s3-check-md5/main.go
continue } if !minModTime.IsZero() && object.LastModified.Before(minModTime) { continue } if object.IsDeleteMarker { log.Println("SKIPPED: DELETE marker object:", objFullPath(object)) continue } if _, ok := object.UserMetadata["X-Amz-Server-Side-Encryption-Customer-Algorithm"]; ok {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Feb 17 01:15:57 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/update.go
// CRI-O, Containerd etc.. // Fallback to our container specific ENVs if they are set. return env.IsSet("MINIO_ACCESS_KEY_FILE") } // Log error, as we will not propagate it to caller internalLogIf(GlobalContext, err) return err == nil } // IsDCOS returns true if minio is running in DCOS. func IsDCOS() bool { // http://mesos.apache.org/documentation/latest/docker-containerizer/
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/signature-v4-utils.go
// client did not calculate sha256 of the payload and there is a trailer. const unsignedPayloadTrailer = "STREAMING-UNSIGNED-PAYLOAD-TRAILER" // skipContentSha256Cksum returns true if caller needs to skip // payload checksum, false if not. func skipContentSha256Cksum(r *http.Request) bool { var ( v []string ok bool ) if isRequestPresignedSignatureV4(r) {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0)