- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for Krause (0.16 sec)
-
internal/s3select/sql/evaluate.go
) var ( errInvalidASTNode = errors.New("invalid AST Node") errExpectedBool = errors.New("expected bool") errLikeNonStrArg = errors.New("LIKE clause requires string arguments") errLikeInvalidEscape = errors.New("LIKE clause has invalid ESCAPE character") errNotImplemented = errors.New("not implemented") ) // AST Node Evaluation functions //
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 12K bytes - Viewed (0) -
docs/LICENSE
and conditions of the license they choose before applying it. Licensors should also secure all rights necessary before applying our licenses so that the public can reuse the material as expected. Licensors should clearly mark any material not subject to the license. This includes other CC- licensed material, or material used under an exception or
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon May 10 16:50:06 GMT 2021 - 18.2K bytes - Viewed (0) -
cmd/metacache-walk.go
return convertAccessError(err, errVolumeAccessDenied) } } // Use a small block size to start sending quickly w := newMetacacheWriter(wr, 16<<10) w.reuseBlocks = true // We are not sharing results, so reuse buffers. defer w.Close() out, err := w.stream() if err != nil { return err } defer xioutil.SafeClose(out) var objsReturned int objReturned := func(metadata []byte) { if opts.Limit <= 0 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/erasure.go
state = madmin.DriveStatePermission case errors.Is(err, errFaultyDisk): state = madmin.DriveStateFaulty case err == nil: state = madmin.DriveStateOk default: state = fmt.Sprintf("%s (cause: %s)", madmin.DriveStateUnknown, err) } return } func getOnlineOfflineDisksStats(disksInfo []madmin.Disk) (onlineDisks, offlineDisks madmin.BackendDisks) { onlineDisks = make(madmin.BackendDisks)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 10:02:39 GMT 2024 - 16K bytes - Viewed (1) -
internal/s3select/sql/parser.go
// statement type SelectExpression struct { All bool `parser:" @\"*\""` Expressions []*AliasedExpression `parser:"| @@ { \",\" @@ }"` } // TableExpression represents the FROM clause type TableExpression struct { Table *JSONPath `parser:"@@"` As string `parser:"( \"AS\"? @Ident )?"` } // JSONPathElement represents a keypath component type JSONPathElement struct {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 12.9K bytes - Viewed (0) -
internal/s3select/unused-errors.go
statusCode: 400, cause: err, } } func errParseExpectedWhenClause(err error) *s3Error { return &s3Error{ code: "ParseExpectedWhenClause", message: "Did not find the expected WHEN clause in the SQL expression. CASE is not supported.", statusCode: 400, cause: err, } } func errParseUnsupportedToken(err error) *s3Error {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 17.5K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} // Close closer interface to close the underlying closer func (w *DeadlineWriter) Close() error { err := w.WriteCloser.Close() w.err = err if err == nil { w.err = errors.New("we are closed") // Avoids any reuse on the Write() side. } return err } // LimitWriter implements io.WriteCloser. // // This is implemented such that we want to restrict // an enscapsulated writer upto a certain length
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
cmd/metrics-v3-types.go
m.Set(name, metric.Value, labels...) } } // MetricsLoaderFn - represents a function to load metrics from the // metricsCache. // // Note that returning an error here will cause the Metrics handler to return a // 500 Internal Server Error. type MetricsLoaderFn func(context.Context, MetricValues, *metricsCache) error // JoinLoaders - joins multiple loaders into a single loader. The returned
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 14.6K bytes - Viewed (0) -
cmd/endpoint.go
return ep, fmt.Errorf("empty or root path is not supported in URL endpoint") } // On windows having a preceding SlashSeparator will cause problems, if the // command line already has C:/<export-folder/ in it. Final resulting // path on windows might become C:/C:/ this will cause problems // of starting minio server properly in distributed mode on windows. // As a special case make sure to trim the separator.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
type VersionPurgeStatusType string const ( // Pending - versioned delete replication is pending. Pending VersionPurgeStatusType = "PENDING" // Complete - versioned delete replication is now complete, erase version on disk. Complete VersionPurgeStatusType = "COMPLETE" // Failed - versioned delete replication failed. Failed VersionPurgeStatusType = "FAILED" ) // Empty returns true if purge status was not set.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0)