- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 104 for parsers (0.41 sec)
-
internal/bucket/replication/rule.go
// Status represents Enabled/Disabled status type Status string // Supported status types const ( Enabled Status = "Enabled" Disabled Status = "Disabled" ) // DeleteMarkerReplication - whether delete markers are replicated - https://docs.aws.amazon.com/AmazonS3/latest/dev/replication-add-config.html type DeleteMarkerReplication struct { Status Status `xml:"Status"` // should be set to "Disabled" by default }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 24 23:22:20 GMT 2022 - 8.3K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
return true } return false // in progress or completed but expired } // parseRestoreObjStatus parses restoreHdr from AmzRestore header. If the value is valid it returns a // restoreObjStatus value with the status and expiry (if any). Otherwise returns // the empty value and an error indicating the parse failure. func parseRestoreObjStatus(restoreHdr string) (restoreObjStatus, error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/copy-part-range.go
return default: apiErr := errorCodes.ToAPIErr(ErrInvalidCopyPartRangeSource) apiErr.Description = err.Error() writeErrorResponse(ctx, w, apiErr, url) return } } // Parses x-amz-copy-source-range for CopyObjectPart API. Its behavior // is different from regular HTTP range header. It only supports the // form `bytes=first-last` where first and last are zero-based byte // offsets. See
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 18 03:27:04 GMT 2021 - 2.5K bytes - Viewed (0) -
docs/bucket/replication/setup_2site_existing_replication.sh
out=$(diff -qpruN /tmp/sitea_dirs.txt /tmp/siteb_dirs.txt) ret=$? if [ $ret -ne 0 ]; then echo "BUG: expected no 'diff' after replication: $out" exit 1 fi ## check if we don't create delete markers on the directory objects, its always permanent delete. ./mc mb sitea/bucket-version/directory/ sleep 2s ./mc rm -r --force sitea/bucket-version/ sleep 2s
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/net.go
return "", "", errors.New("unable to process empty address") } // Simplify the work of url.Parse() and always send a url with if !strings.HasPrefix(hostAddr, "http://") && !strings.HasPrefix(hostAddr, "https://") { hostAddr = "//" + hostAddr } // Parse address to extract host and scheme field u, err := url.Parse(hostAddr) if err != nil { return "", "", err } addr = u.Host scheme = u.Scheme
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/event/target/amqp.go
EnvAMQPQueueLimit = "MINIO_NOTIFY_AMQP_QUEUE_LIMIT" ) // Validate AMQP arguments func (a *AMQPArgs) Validate() error { if !a.Enable { return nil } if _, err := amqp091.ParseURI(a.URL.String()); err != nil { return err } if a.QueueDir != "" { if !filepath.IsAbs(a.QueueDir) { return errors.New("queueDir path should be absolute") } } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
cmd/handler-utils.go
xnet "github.com/minio/pkg/v2/net" "golang.org/x/exp/maps" "golang.org/x/exp/slices" ) const ( copyDirective = "COPY" replaceDirective = "REPLACE" accessDirective = "ACCESS" ) // Parses location constraint from the incoming reader. func parseLocationConstraint(r *http.Request) (location string, s3Error APIErrorCode) { // If the request has no body with content-length set to 0,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
internal/config/certs.go
// ParsePublicCertFile - parses public cert into its *x509.Certificate equivalent. func ParsePublicCertFile(certFile string) (x509Certs []*x509.Certificate, err error) { // Read certificate file. var data []byte if data, err = os.ReadFile(certFile); err != nil { return nil, err } // Trimming leading and tailing white spaces. data = bytes.TrimSpace(data) // Parse all certs in the chain. current := data
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/bucket-quota.go
} } if len(dui.BucketsUsage) > 0 { bui, ok := dui.BucketsUsage[bucket] if ok { return bui, nil } } return BucketUsageInfo{}, nil } // parseBucketQuota parses BucketQuota from json func parseBucketQuota(bucket string, data []byte) (quotaCfg *madmin.BucketQuota, err error) { quotaCfg = &madmin.BucketQuota{} if err = json.Unmarshal(data, quotaCfg); err != nil { return quotaCfg, err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.3K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_cluster_usage_objects_versions_count` | `gauge` | Total cluster object versions (including delete markers) count | | | `minio_cluster_usage_objects_delete_markers_count` | `gauge` | Total cluster delete markers count | |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 28.5K bytes - Viewed (0)