- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 52 for Stause (0.15 sec)
-
cmd/admin-server-info.go
gcStats.PauseEnd = gcStats.PauseEnd[len(gcStats.PauseEnd)-5:] } if len(gcStats.Pause) > 5 { gcStats.Pause = gcStats.Pause[len(gcStats.Pause)-5:] } props := madmin.ServerProperties{ Endpoint: addr, Uptime: UTCNow().Unix() - globalBootTime.Unix(), Version: Version, CommitID: CommitID, Network: network, MemStats: madmin.MemStats{ Alloc: memstats.Alloc, TotalAlloc: memstats.TotalAlloc,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.8K bytes - Viewed (0) -
internal/s3select/parquet/errors.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package parquet type s3Error struct { code string message string statusCode int cause error } func (err *s3Error) Cause() error { return err.cause } func (err *s3Error) ErrorCode() string { return err.code } func (err *s3Error) ErrorMessage() string { return err.message }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.4K bytes - Viewed (0) -
internal/grid/stream.go
// Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed. // Canceling the context will cause the context cancellation error to be returned. responses <-chan Response cancel context.CancelCauseFunc // Requests sent to the server. // If the handler is defined with 0 incoming capacity this will be nil.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/grid/muxclient.go
} return v.Msg, v.Err case <-ctx.Done(): if debugReqs { return nil, fmt.Errorf("%d %s ERR: %w", m.MuxID, m.parent.String(), context.Cause(ctx)) } return nil, context.Cause(ctx) } } // send the message. msg.Seq and msg.MuxID will be set func (m *muxClient) send(msg message) error { m.respMu.Lock() defer m.respMu.Unlock() if m.closed {
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/s3select/sql/utils.go
} ps := jpath.String() if idx := strings.LastIndex(ps, "."); idx >= 0 { // Get last part of path string. ps = ps[idx+1:] } return ps, true } // HasKeypath returns if the from clause has a key path - // e.g. S3object[*].id func (from *TableExpression) HasKeypath() bool { return len(from.Table.PathExpr) > 1
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Nov 10 16:12:50 GMT 2021 - 3.6K bytes - Viewed (0) -
cmd/iam-store.go
userType = svcUser } else if cred.IsTemp() { userType = stsUser } ui := newUserIdentity(cred) // Overwrite the user identity here. As store should be // atomic, it shouldn't cause any corruption. if err := store.saveUserIdentity(ctx, cred.AccessKey, userType, ui); err != nil { return err } return cache.updateUserWithClaims(cred.AccessKey, ui) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
internal/s3select/errors.go
type SelectError interface { Cause() error ErrorCode() string ErrorMessage() string HTTPStatusCode() int Error() string } type s3Error struct { code string message string statusCode int cause error } func (err *s3Error) Cause() error { return err.cause } func (err *s3Error) ErrorCode() string { return err.code }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 14 16:48:36 GMT 2022 - 4.3K bytes - Viewed (0) -
.github/PULL_REQUEST_TEMPLATE.md
- [ ] Bug fix (non-breaking change which fixes an issue) - [ ] New feature (non-breaking change which adds functionality) - [ ] Optimization (provides speedup with no functional changes) - [ ] Breaking change (fix or feature that would cause existing functionality to change) ## Checklist: - [ ] Fixes a regression (If yes, please add `commit-id` or `PR #` here) - [ ] Unit tests added/updated - [ ] Internal documentation updated
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 14 17:29:11 GMT 2023 - 1K bytes - Viewed (0) -
internal/bucket/lifecycle/error.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 1.3K bytes - Viewed (0) -
cmd/site-replication.go
Cause: errors.New("site replication resync is already in progress"), Code: ErrSiteReplicationInvalidRequest, } errSRResyncCanceled = SRError{ Cause: errors.New("site replication resync is already canceled"), Code: ErrSiteReplicationInvalidRequest, } errSRNoResync = SRError{ Cause: errors.New("no resync in progress"), Code: ErrSiteReplicationInvalidRequest, } errSRResyncToSelf = SRError{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1)