- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 89 for could (0.26 sec)
-
cmd/tier-sweeper.go
package cmd import ( "context" "github.com/minio/minio/internal/bucket/lifecycle" ) // objSweeper determines if a transitioned object needs to be removed from the remote tier. // A typical usage would be like, // os := newObjSweeper(bucket, object) // // Perform a ObjectLayer.GetObjectInfo to fetch object version information // goiOpts := os.GetOpts() // gerr := objAPI.GetObjectInfo(ctx, bucket, object, goiOpts) //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/grid/muxclient.go
return false } m.RecvSeq++ return true } // response will send handleIncoming response to client. // may never block. // Should return whether the next call would block. func (m *muxClient) response(seq uint32, r Response) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "RESP") } if debugPrint {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
internal/rest/client.go
if c.TraceOutput != nil && resp.StatusCode != http.StatusOK { c.dumpHTTP(req, resp) } if resp.StatusCode != http.StatusOK { // If server returns 412 pre-condition failed, it would // mean that authentication succeeded, but another // side-channel check has failed, we shall take // the client offline in such situations. // generally all implementations should simply return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/metacache-server-pool.go
o.BaseDir = baseDirFromPrefix(o.Prefix) } o.Transient = o.Transient || isReservedOrInvalidBucket(o.Bucket, false) o.SetFilter() if o.Transient { o.Create = false } // We have 2 cases: // 1) Cold listing, just list. // 2) Returning, but with no id. Start async listing. // 3) Returning, with ID, stream from list. // // If we don't have a list id we must ask the server if it has a cache or create a new.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/storage-datatypes.go
_, ok := fi.Metadata[ReservedMetadataPrefixLower+"inline-data"] // Earlier MinIO versions didn't reset "x-minio-internal-inline-data" // from fi.Metadata when the object was tiered. So, tiered objects // would return true for InlineData() in these versions even though the // object isn't inlined in xl.meta return ok && !fi.IsRemote() } // SetInlineData marks object (version) as inline.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/storage-rest-client.go
} // Wrapper to restClient.Call to handle network errors, in case of network error the connection is disconnected // and a healthcheck routine gets invoked that would reconnect. func (client *storageRESTClient) call(ctx context.Context, method string, values url.Values, body io.Reader, length int64) (io.ReadCloser, error) { if values == nil { values = make(url.Values) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/config-current.go
} sKey, err := manager.HMAC(GlobalContext, stat.DefaultKey, []byte("root secret key")) if err != nil { // Here, we must have permission. Otherwise, we would have failed earlier. logger.Fatal(err, "Unable to generate root secret key using KMS") } accessKey, err := auth.GenerateAccessKey(20, bytes.NewReader(aKey)) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
internal/s3select/sql/funceval.go
if !ok { return 0, errCastFailure("could not parse as int") } return res, nil case []byte: // Parse as number, truncate floating point if // needed. // String might contain trimming spaces, which // needs to be trimmed. res, ok := strToInt(strings.TrimSpace(string(x))) if !ok { return 0, errCastFailure("could not parse as int") } return res, nil default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 13.2K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
err = client.MakeBucket(ctx, getRandomBucketName(), minio.MakeBucketOptions{}) if err != nil { c.Fatalf("user could not create bucket: %v", err) } // 4. Check that user can be disabled and verify it. err = s.adm.SetUserStatus(ctx, accessKey, madmin.AccountDisabled) if err != nil { c.Fatalf("could not set user account to disabled") } usersMap, err = s.adm.ListUsers(ctx) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0) -
internal/event/target/nats_contrib_test.go
Address: xnet.Host{ Name: "localhost", Port: (xnet.Port(opts.Port)), IsPortSet: true, }, Subject: "test", } con, err := clientConfig.connectNats() if err != nil { t.Errorf("Could not connect to nats: %v", err) } defer con.Close() } func TestNatsConnUserPass(t *testing.T) { opts := natsserver.DefaultTestOptions opts.Port = 14223 opts.Username = "testminio"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.3K bytes - Viewed (0)