- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 883 for errorea (0.15 sec)
-
cmd/erasure-server-pool-rebalance.go
} if len(data) <= 4 { return fmt.Errorf("rebalanceMeta: no data") } // Read header switch binary.LittleEndian.Uint16(data[0:2]) { case rebalMetaFmt: default: return fmt.Errorf("rebalanceMeta: unknown format: %d", binary.LittleEndian.Uint16(data[0:2])) } switch binary.LittleEndian.Uint16(data[2:4]) { case rebalMetaVer: default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
} } var ( errDecommissionAlreadyRunning = errors.New("decommission is already in progress") errDecommissionComplete = errors.New("decommission is complete, please remove the servers from command-line") errDecommissionNotStarted = errors.New("decommission is not in progress") ) func (p *poolMeta) Decommission(idx int, pi poolSpaceInfo) error { // Return an error when there is decommission on going - the user needs
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/update.go
func releaseTagToReleaseTime(releaseTag string) (releaseTime time.Time, err error) { fields := strings.Split(releaseTag, ".") if len(fields) < 2 || len(fields) > 4 { return releaseTime, fmt.Errorf("%s is not a valid release tag", releaseTag) } if fields[0] != "RELEASE" { return releaseTime, fmt.Errorf("%s is not a valid release tag", releaseTag) } return time.Parse(MinioReleaseTagTimeLayout, fields[1]) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
tests/associations_has_many_test.go
} if count := tx.Model(&item).Association("Contents").Count(); count != 3 { t.Errorf("expected %d contents, got %d", 3, count) } var contents []ItemContent if err := tx.Find(&contents).Error; err != nil { t.Errorf("failed to find contents, got error: %v", err) } if len(contents) != 3 { t.Errorf("expected %d contents, got %d", 3, len(contents)) } // test delete
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Dec 15 08:36:08 GMT 2023 - 15.6K bytes - Viewed (0) -
internal/grid/grid_test.go
// Single requests should have remote errors. _, err := remoteConn.Request(context.Background(), handlerTest, []byte(testPayload)) if v, ok := err.(*RemoteErr); !ok || v.Error() != "Invalid Handler for type" { t.Fatalf("Unexpected error: %v, %T", err, err) } // Streams should not be able to set up until registered. // Thus, the error is a local error.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/muxclient.go
return } select { case m.outBlock <- struct{}{}: default: gridLogIf(m.ctx, errors.New("output unblocked overflow")) } } func (m *muxClient) pong(msg pongMsg) { if msg.NotFound || msg.Err != nil { err := errors.New("remote terminated call") if msg.Err != nil { err = fmt.Errorf("remove pong failed: %v", &msg.Err) } m.addResponse(Response{Err: err}) return }
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
online closed ) // NetworkError - error type in case of errors related to http/transport // for ex. connection refused, connection reset, dns resolution failure etc. // All errors returned by storage-rest-server (ex errFileNotFound, errDiskNotFound) are not considered to be network errors. type NetworkError struct { Err error } func (n *NetworkError) Error() string { return n.Err.Error() }
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) -
tests/preload_test.go
t.Errorf("failed to query, got error %v, account: %#v", err, user4.Account) } if err := DB.Preload(clause.Associations, func(tx *gorm.DB) *gorm.DB { return tx.Unscoped() }).Take(&user4, "id = ?", users3[0].ID).Error; err != nil || user4.Account.ID == 0 { t.Errorf("failed to query, got error %v, account: %#v", err, user4.Account) } }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Apr 25 12:21:03 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/iam-object-store.go
// server). // // The "policy not found" error is ignored because the STS account may // not have a policy mapped via its parent (for e.g. in // OIDC/AssumeRoleWithCustomToken/AssumeRoleWithCertificate). err := iamOS.loadMappedPolicy(ctx, svcParent, stsUser, false, cache.iamSTSPolicyMap) if err != nil && !errors.Is(err, errNoSuchPolicy) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
internal/event/target/postgresql.go
if p.Port == "" { return fmt.Errorf("unspecified port") } if _, err := strconv.Atoi(p.Port); err != nil { return fmt.Errorf("invalid port") } if p.Database == "" { return fmt.Errorf("database unspecified") } } if p.QueueDir != "" { if !filepath.IsAbs(p.QueueDir) { return errors.New("queueDir path should be absolute") } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0)