- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for setType (0.19 sec)
-
cmd/signature-v4-parser.go
c.scope.region, c.scope.service, c.scope.request, }, SlashSeparator) } func getReqAccessKeyV4(r *http.Request, region string, stype serviceType) (auth.Credentials, bool, APIErrorCode) { ch, s3Err := parseCredentialHeader("Credential="+r.Form.Get(xhttp.AmzCredential), region, stype) if s3Err != ErrNone { // Strip off the Algorithm prefix. v4Auth := strings.TrimPrefix(r.Header.Get("Authorization"), signV4Algorithm)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret_test.go
} if c.secType != SecretTypeConfig { c.secType = SecretTypeRemote } opts := RemoteSecretOptions{ ServiceAccountName: testServiceAccountName, AuthType: RemoteSecretAuthTypeBearerToken, // ClusterName: testCluster, KubeOptions: KubeOptions{ Namespace: testNamespace, }, Type: c.secType, SecretName: c.secretName, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 20.6K bytes - Viewed (0) -
cmd/auth-handler.go
} func reqSignatureV4Verify(r *http.Request, region string, stype serviceType) (s3Error APIErrorCode) { sha256sum := getContentSha256Cksum(r, stype) switch { case isRequestSignatureV4(r): return doesSignatureMatch(sha256sum, r, region, stype) case isRequestPresignedSignatureV4(r): return doesPresignedSignatureMatch(sha256sum, r, region, stype) default: return ErrAccessDenied } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26K bytes - Viewed (0) -
cmd/signature-v4-utils.go
return r.ContentLength > 0 && !globalServerCtxt.StrictS3Compat } return false } // Returns SHA256 for calculating canonical-request. func getContentSha256Cksum(r *http.Request, stype serviceType) string { if stype == serviceSTS { payload, err := io.ReadAll(io.LimitReader(r.Body, stsRequestBodyLimit)) if err != nil { logger.CriticalIf(GlobalContext, err) } sum256 := sha256.Sum256(payload)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 18:56:45 GMT 2024 - 9K bytes - Viewed (0) -
internal/s3select/select.go
const ( noneType CompressionType = "none" gzipType CompressionType = "GZIP" bzip2Type CompressionType = "BZIP2" zstdType CompressionType = "ZSTD" lz4Type CompressionType = "LZ4" s2Type CompressionType = "S2" snappyType CompressionType = "SNAPPY" ) const ( maxRecordSize = 1 << 20 // 1 MiB ) var parquetSupport bool func init() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/cluster.go
c.Name = fmt.Sprintf("cluster/%s", c.Name) _, _ = fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%s\t%s\n", c.Name, fqdn, port, subset, direction, c.GetType(), describeManagement(c.GetMetadata())) } else { _, _ = fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%s\t%s\n", fqdn, port, subset, direction, c.GetType(), describeManagement(c.GetMetadata())) } } else { if includeConfigType && len(c.Name) > 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 11 05:38:17 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/signature-v4.go
} // getSigningKey hmac seed to calculate final signature. func getSigningKey(secretKey string, t time.Time, region string, stype serviceType) []byte { date := sumHMAC([]byte("AWS4"+secretKey), []byte(t.Format(yyyymmdd))) regionBytes := sumHMAC(date, []byte(region)) service := sumHMAC(regionBytes, []byte(stype)) signingKey := sumHMAC(service, []byte("aws4_request")) return signingKey }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/batch-handlers.go
srcBucket := r.Source.Bucket tgtBucket := r.Target.Bucket tgtPrefix := r.Target.Prefix srcObject := srcObjInfo.Name s3Type := r.Target.Type == BatchJobReplicateResourceS3 || r.Source.Type == BatchJobReplicateResourceS3 if srcObjInfo.DeleteMarker || !srcObjInfo.VersionPurgeStatus.Empty() { if retry && !s3Type { if _, err := c.StatObject(ctx, tgtBucket, pathJoin(tgtPrefix, srcObject), miniogo.StatObjectOptions{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
internal/s3select/progress.go
if err != nil { return nil, errInvalidCompression(err, compType) } r = zr pr.closer = zr.IOReadCloser() case lz4Type: r = lz4.NewReader(scannedReader) case s2Type: r = s2.NewReader(scannedReader) case snappyType: r = s2.NewReader(scannedReader, s2.ReaderMaxBlockSize(64<<10)) default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:44:36 GMT 2021 - 4.2K bytes - Viewed (0)