- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 156 for Lesage (0.14 sec)
-
internal/grid/benchmark_test.go
select { case <-ctx.Done(): return nil case out <- toSend: } } return nil }, Subroute: "some-subroute", OutCapacity: 1, // Only one message buffered. InCapacity: 0, })) errFatal(err) } const payloadSize = 512 rng := rand.New(rand.NewSource(time.Now().UnixNano())) payload := make([]byte, payloadSize) _, err = rng.Read(payload)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/warm-backend.go
} func errIsTierPermError(err error) bool { var tpErr tierPermErr return errors.As(err, &tpErr) } // remoteVersionID represents the version id of an object in the remote tier. // Its usage is remote tier cloud implementation specific. type remoteVersionID string // newWarmBackend instantiates the tier type specific WarmBackend, runs // checkWarmBackend on it.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0) -
cmd/api-response.go
// but accepts the error message directly (this allows messages to be // dynamically generated.) func writeCustomErrorResponseJSON(ctx context.Context, w http.ResponseWriter, err APIError, errBody string, reqURL *url.URL, ) { reqInfo := logger.GetReqInfo(ctx) errorResponse := APIErrorResponse{ Code: err.Code, Message: errBody, Resource: reqURL.Path,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
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) -
docs/debugging/inspect/main.go
if err != nil { fatalErr(err) } fatalErr(json.Unmarshal(got, &input)) inputFileName = input.File *keyHex = input.Key case len(flag.Args()) == 1: inputFileName = flag.Args()[0] default: flag.Usage() fatalIf(true, "Only 1 file can be decrypted") os.Exit(1) } // Calculate the output file name switch { case strings.HasSuffix(inputFileName, ".enc"):
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 4.8K bytes - Viewed (0) -
cmd/storage-datatypes.go
type DiskInfoOptions struct { DiskID string `msg:"id"` Metrics bool `msg:"m"` NoOp bool `msg:"np"` } // DiskInfo is an extended type which returns current // disk usage per path. // The above means that any added/deleted fields are incompatible. // // The above means that any added/deleted fields are incompatible. // //msgp:tuple DiskInfo type DiskInfo struct { Total uint64
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) -
internal/logger/target/kafka/kafka.go
} return nil } // IsOnline returns true if the target is online. func (h *Target) IsOnline(_ context.Context) bool { return atomic.LoadInt32(&h.status) == statusOnline } // Send log message 'e' to kafka target. func (h *Target) Send(ctx context.Context, entry interface{}) error { if h.store != nil { // save the entry to the queue store which will be replayed to the target. return h.store.Put(entry) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
docs/ftp/README.md
of restrictions are needed for a user. - No "admin:*" operations are needed for FTP/SFTP access to the bucket(s) and object(s), so you may skip them for restrictions. ## Usage Start MinIO in a distributed setup, with 'ftp/sftp' enabled. ``` minio server http://server{1...4}/disk{1...4} --ftp="address=:8021" --ftp="passive-port-range=30000-40000" \
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:15:45 GMT 2024 - 7.1K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
if filterLifecycle(bi.Name, version.Name, version) { continue } // `.usage-cache.bin` still exists, must be not readable ignore it. if bi.Name == minioMetaBucket && strings.Contains(version.Name, dataUsageCacheName) { // skipping bucket usage cache name, as its autogenerated. continue } versionsFound++ } }); err != nil {
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/admin-handlers-config-kv.go
// Tell the client that dynamic config was applied. w.Header().Set(madmin.ConfigAppliedHeader, madmin.ConfigAppliedTrue) } type badConfigErr struct { Err error } // Error - return the error message func (bce badConfigErr) Error() string { return bce.Err.Error() } // Unwrap the error to its underlying error. func (bce badConfigErr) Unwrap() error { return bce.Err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0)