Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 73 for Dapper (0.19 sec)

  1. internal/s3select/sql/funceval.go

    		return x, nil
    	case []byte:
    		return string(x), nil
    	case bool:
    		return fmt.Sprintf("%v", x), nil
    	case nil:
    		// FIXME: verify this case is correct
    		return "NULL", nil
    	}
    	// This does not happen
    	return "", errCastFailure(fmt.Sprintf("cannot cast %v to string type", v.GetTypeString()))
    }
    
    func timestampCast(v *Value) (t time.Time, _ error) {
    	switch x := v.value.(type) {
    	case string:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 13.2K bytes
    - Viewed (0)
  2. cmd/s3-zip-handlers.go

    func splitZipExtensionPath(input string) (zipPath, object string, err error) {
    	idx := strings.Index(input, archivePattern)
    	if idx < 0 {
    		// Should never happen
    		return "", "", errors.New("unable to parse zip path")
    	}
    	return input[:idx+len(archivePattern)-1], input[idx+len(archivePattern):], nil
    }
    
    // getObjectInArchiveFileHandler - GET Object in the archive file
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  3. docs/bigdata/README.md

    All access to MinIO object storage is via S3/SQL SELECT API. In addition to the compute nodes, MinIO containers are also managed by Kubernetes as stateful containers with local storage (JBOD/JBOF) mapped as persistent local volumes. This architecture enables multi-tenant MinIO, allowing isolation of data between customers.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 04:28:45 GMT 2022
    - 14.7K bytes
    - Viewed (0)
  4. cmd/iam-object-store.go

    	}
    
    	bootstrapTraceMsg("purging expired STS credentials")
    
    	iamListing, ok := iamOS.cachedIAMListing.Load().(map[string][]string)
    	if !ok {
    		// There has been no store yet. This should never happen!
    		iamLogIf(GlobalContext, errors.New("WARNING: no cached IAM listing found"))
    		return nil
    	}
    
    	// Scan STS users on disk and purge expired ones. We do not need to hold a
    	// lock with store.lock() here.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 05 21:26:41 GMT 2024
    - 19.9K bytes
    - Viewed (0)
  5. cmd/generic-handlers.go

    // such as ".." and "."
    func hasBadPathComponent(path string) bool {
    	if len(path) > 4096 {
    		// path cannot be greater than Linux PATH_MAX
    		// this is to avoid a busy loop, that can happen
    		// if the caller sends path of following style
    		// a/a/a/a/a/a/a/a...
    		return true
    	}
    	path = filepath.ToSlash(strings.TrimSpace(path)) // For windows '\' must be converted to '/'
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 01:08:52 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  6. cmd/metacache-set.go

    	// Remove leading and trailing slashes.
    	o.FilterPrefix = strings.Trim(o.FilterPrefix, slashSeparator)
    
    	if strings.Contains(o.FilterPrefix, slashSeparator) {
    		// Sanity check, should not happen.
    		o.FilterPrefix = ""
    	}
    }
    
    // filter will apply the options and return the number of objects requested by the limit.
    // Will return io.EOF if there are no more entries with the same filter.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  7. cmd/data-usage-cache.go

    			// spl interval: [1024B, 1MiB)
    			res[szInt.name] = splCount
    		case humanize.KiByte <= szInt.start && szInt.end <= humanize.MiByte-1:
    			// intervals that fall within the spl interval above; they
    			// appear earlier in this array of intervals, see
    			// ObjectsHistogramIntervals
    			splCount += count
    			fallthrough
    		default:
    			res[szInt.name] = count
    		}
    	}
    	return res
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  8. internal/config/config.go

    	if spc {
    		s.WriteString(KvDoubleQuote)
    	}
    	s.WriteString(kv.Value)
    	if spc {
    		s.WriteString(KvDoubleQuote)
    	}
    	return s.String()
    }
    
    // KVS - is a shorthand for some wrapper functions
    // to operate on list of key values.
    type KVS []KV
    
    // Empty - return if kv is empty
    func (kvs KVS) Empty() bool {
    	return len(kvs) == 0
    }
    
    // Clone - returns a copy of the KVS
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  9. cmd/notification.go

    }
    
    // ServiceFreeze freezes all S3 API calls when 'freeze' is true,
    // 'freeze' is 'false' would resume all S3 API calls again.
    // NOTE: once a tenant is frozen either two things needs to
    // happen before resuming normal operations.
    //   - Server needs to be restarted 'mc admin service restart'
    //   - 'freeze' should be set to 'false' for this call
    //     to resume normal operations.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  10. cmd/admin-handlers-users_test.go

    	var accessKeys []string
    	for _, item := range listResp.Accounts {
    		accessKeys = append(accessKeys, item.AccessKey)
    	}
    	if !set.CreateStringSet(accessKeys...).Contains(svcAK) {
    		c.Fatalf("service account did not appear in listing!")
    	}
    }
    
    func (c *check) assertSvcAccInfoQueryable(ctx context.Context, madmClient *madmin.AdminClient, parentAK, svcAK string, skipParentUserCheck bool) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 16:36:16 GMT 2024
    - 45.7K bytes
    - Viewed (0)
Back to top