- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Retriever (0.31 sec)
-
internal/config/dns/operator_dns.go
func (c *OperatorDNS) DeleteRecord(record SrvRecord) error { return ErrNotImplemented } // Close closes the internal http client func (c *OperatorDNS) Close() error { return nil } // List - Retrieves list of DNS entries for the domain. // This is a No Op for Operator because, there is no intent to enforce global // namespace at MinIO level with this DNS entry. The global namespace in // enforced by the Kubernetes Operator
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 6.6K bytes - Viewed (0) -
cmd/api-utils.go
if strings.ToLower(encodingType) == "url" { return s3URLEncode(name) } return name } // getHandlerName returns the name of the handler function. It takes the type // name as a string to clean up the name retrieved via reflection. This function // only works correctly when the type is present in the cmd package. func getHandlerName(f http.HandlerFunc, cmdType string) string { name := runtime.FuncForPC(reflect.ValueOf(f).Pointer()).Name()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/handlers/proxy.go
protoRegex = regexp.MustCompile(`(?i)^(;|,| )+(?:proto=)(https|http)`) ) // GetSourceScheme retrieves the scheme from the X-Forwarded-Proto and RFC7239 // Forwarded headers (in that order). func GetSourceScheme(r *http.Request) string { var scheme string // Retrieve the scheme from X-Forwarded-Proto. if proto := r.Header.Get(xForwardedProto); proto != "" { scheme = strings.ToLower(proto)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:55 GMT 2023 - 5.1K bytes - Viewed (0) -
internal/bpool/bpool_test.go
} // Check with width cap if bufPool.WidthCap() != capWidth { t.Fatalf("bytepool capWidth invalid: got %v want %v", bufPool.WidthCap(), capWidth) } // Check that retrieved buffer are of the expected width b := bufPool.Get() if len(b) != width { t.Fatalf("bytepool length invalid: got %v want %v", len(b), width) } if cap(b) != capWidth {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 19:13:27 GMT 2024 - 2.6K bytes - Viewed (0) -
docs/site-replication/gen-oidc-sts-cred.go
STSEndpoint: endpoint, GetWebIDTokenExpiry: func() (*cr.WebIdentityToken, error) { return &cr.WebIdentityToken{ Token: oidcToken, }, nil }, RoleARN: roleARN, } value, err := webID.Retrieve() if err != nil { log.Fatalf("Expected to generate credentials: %v", err) } // Print credentials separated by colons: fmt.Printf("%s:%s:%s\n", value.AccessKeyID, value.SecretAccessKey, value.SessionToken)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 2.3K bytes - Viewed (0) -
docs/ftp/README.md
- LDAP/AD users and their respective service accounts - OpenID/OIDC service accounts - On versioned buckets, FTP/SFTP only operates on latest objects, if you need to retrieve an older version you must use an `S3 API client` such as [`mc`](https://github.com/minio/mc). - All features currently used by your buckets will work as is without any changes - SSE (Server Side Encryption)
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:15:45 GMT 2024 - 7.1K bytes - Viewed (0) -
cmd/bucket-quota.go
if len(dui.BucketsUsage) > 0 { internalLogOnceIf(GlobalContext, fmt.Errorf("unable to retrieve usage information for bucket: %s, relying on older value cached in-memory: err(%v)", bucket, err), "bucket-usage-cache-"+bucket) } else { internalLogOnceIf(GlobalContext, errors.New("unable to retrieve usage information for bucket: %s, no reliable usage value available - quota will not be enforced"), "bucket-usage-empty-"+bucket) }
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) -
cmd/etcd.go
timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() resp, err := client.Get(timeoutCtx, key) if err != nil { etcdLogOnceIf(ctx, err, "etcd-retrieve-keys") return nil, etcdErrToErr(err, client.Endpoints()) } if resp.Count == 0 { return nil, errConfigNotFound } for _, ev := range resp.Kvs { if string(ev.Key) == key { return ev.Value, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.9K bytes - Viewed (0) -
internal/config/cache/cache.go
// Config represents the subnet related configuration type Config struct { // Flag indicating whether cache is enabled. Enable bool `json:"enable"` // Endpoint for caching uses remote mcache server to // store and retrieve pre-condition check entities such as // Etag and ModTime of an object + version Endpoint string `json:"endpoint"` // BlockSize indicates the maximum object size below which
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/kms/status-manager.go
"context" "github.com/minio/kms-go/kes" ) // StatusManager is the generic interface that handles KMS status operations type StatusManager interface { // Version retrieves version information Version(ctx context.Context) (string, error) // APIs retrieves a list of supported API endpoints APIs(ctx context.Context) ([]kes.API, error)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 1.1K bytes - Viewed (0)