- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for inspire (0.14 sec)
-
internal/s3select/select.go
Read(dst sql.Record) (sql.Record, error) Close() error } const ( csvFormat = "csv" jsonFormat = "json" parquetFormat = "parquet" ) // CompressionType - represents value inside <CompressionType/> in request XML. type CompressionType string const ( noneType CompressionType = "none" gzipType CompressionType = "GZIP" bzip2Type CompressionType = "BZIP2"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (1) -
cmd/is-dir-empty_linux.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "syscall" ) // Returns true if no error and there is no object or prefix inside this directory func isDirEmpty(dirname string, legacy bool) bool { if legacy { // On filesystems such as btrfs, nfs this is not true, so fallback // to performing readdir() instead. entries, err := readDirN(dirname, 1)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 15:17:08 GMT 2024 - 1.4K bytes - Viewed (0) -
cmd/license-update.go
func initLicenseUpdateJob(ctx context.Context, objAPI ObjectLayer) { go func() { r := rand.New(rand.NewSource(time.Now().UnixNano())) // Leader node (that successfully acquires the lock inside licenceUpdaterLoop) // will keep performing the license update. If the leader goes down for some // reason, the lock will be released and another node will acquire it and // take over because of this loop. for {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
internal/logger/console.go
pretty(msg string, args ...interface{}) } func consoleLog(console Logger, msg string, args ...interface{}) { switch { case jsonFlag: // Strip escape control characters from json message msg = ansiRE.ReplaceAllLiteralString(msg, "") console.json(msg, args...) case quietFlag: if len(msg) != 0 && len(args) == 0 { args = append(args, msg) msg = "%s" } console.quiet(msg+"\n", args...) default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/update.go
"/.dockerenv", "/run/.containerenv", } { _, err = os.Stat(envfile) if err == nil { return true } } if osIsNotExist(err) { // if none of the files are present we may be running inside // CRI-O, Containerd etc.. // Fallback to our container specific ENVs if they are set. return env.IsSet("MINIO_ACCESS_KEY_FILE") } // Log error, as we will not propagate it to caller
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) -
cmd/iam.go
// Persistence layer for IAM subsystem store *IAMStoreSys // configLoaded will be closed and remain so after first load. configLoaded chan struct{} } // IAMUserType represents a user type inside MinIO server type IAMUserType int const ( unknownIAMUserType IAMUserType = iota - 1 regUser stsUser svcUser ) // LoadGroup - loads a specific group from storage, and updates the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/erasure-object.go
} written, err := erasure.Decode(ctx, writer, readers, partOffset, partLength, partSize, prefer) // Note: we should not be defer'ing the following closeBitrotReaders() call as // we are inside a for loop i.e if we use defer, we would accumulate a lot of open files by the time // we return from this function. closeBitrotReaders(readers) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/metrics-v3-handler.go
for _, collectorPath := range h.metricsData.collectorPaths { if collectorPath.isDescendantOf(path) { gatherer := h.metricsData.mgGatherers[collectorPath] // For Bucket metrics we need to set the buckets argument inside the // metric group, so that it will affect collection. If no buckets // are provided, we will not return bucket metrics. if bmg, ok := h.metricsData.bucketMGMap[collectorPath]; ok { if len(buckets) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers_test.go
errorResponse APIErrorResponse shouldPass bool }, ) { for i, testCase := range testCases { // initialize httptest Recorder, this records any mutations to response writer inside the handler. rec := httptest.NewRecorder() // construct HTTP request req, err := newTestSignedRequestV4(testCase.method, getBucketLifecycleURL("", testCase.bucketName),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 13 20:52:33 GMT 2023 - 11.2K bytes - Viewed (0) -
cmd/metrics-resource.go
} func getResourceKey(name MetricName, labels map[string]string) string { // labels are used to uniquely identify a metric // e.g. reads_per_sec_{drive} inside the map sfx := "" for _, v := range labels { if len(sfx) > 0 { sfx += "_" } sfx += v } return string(name) + "_" + sfx }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0)