- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 56 for Krause (0.2 sec)
-
docs/kms/IAM.md
the vast majority of deployments in any negative way. > Will an upgrade of an existing MinIO cluster impact the SLA of the cluster or will it even cause downtime? No, an upgrade should not cause any downtime. However, on the first startup - since MinIO will attempt to migrate any existing IAM data - the boot process may take slightly longer, but may not be visibly noticeable. Once the migration has
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.3K bytes - Viewed (0) -
cmd/metacache.go
// metacacheSharePrefix controls whether prefixes on dirty paths are always shared. // This will make `test/a` and `test/b` share listings if they are concurrent. // Enabling this will make cache sharing more likely and cause less IO, // but may cause additional latency to some calls. metacacheSharePrefix = false ) //go:generate msgp -file $GOFILE -unexported // metacache contains a tracked cache entry. type metacache struct {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0) -
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) -
cmd/admin-handlers-users-race_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. //go:build !race // +build !race // Tests in this file are not run under the `-race` flag as they are too slow // and cause context deadline errors. package cmd import ( "context" "fmt" "runtime" "testing" "time" "github.com/minio/madmin-go/v3" minio "github.com/minio/minio-go/v7"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.9K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
close(r.decoded) readCloser.Close() for range r.input { // Read until EOF trickles through. // Otherwise, we risk the decoder hanging. } r.readerWg.Done() } // We cannot reuse as we are sending parsed objects elsewhere. simdjson.ParseNDStream(readCloser, r.input, nil) r.readerWg.Add(1) go r.startReader() return &r } // NewElementReader - creates new JSON reader using readCloser.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K 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 28 19:28:10 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 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 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/grid/connection.go
if err != nil { return nil, err } cl.subroute = &c.subID return cl, nil } // Request allows to do a single remote request. // 'req' will not be used after the call and caller can reuse. // If no deadline is set on ctx, a 1-minute deadline will be added. func (c *Connection) Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error) { if !h.valid() { return nil, ErrUnknownHandler }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/grid/handlers.go
s.callReuseReq = true } return &s } // PutResponse will accept a response for reuse. // This can be used by a caller to recycle a response after receiving it from a Call. func (h *SingleHandler[Req, Resp]) PutResponse(r Resp) { h.recycleResp(r) } // AllowCallRequestPool indicates it is safe to reuse the request // on the client side, meaning the request is recycled/pooled when a request is sent.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 26.9K bytes - Viewed (0)