Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 741 - 750 of 1,039 for take (0.01 seconds)

  1. cmd/xl-storage-free-version.go

    		}
    		freeEntry := xlMetaV2Version{Type: DeleteType, WrittenByVersion: globalVersionUnix}
    		freeEntry.DeleteMarker = &xlMetaV2DeleteMarker{
    			VersionID: vID,
    			ModTime:   j.ModTime, // fi.ModTime may be empty
    			MetaSys:   make(map[string][]byte),
    		}
    
    		freeEntry.DeleteMarker.MetaSys[ReservedMetadataPrefixLower+freeVersion] = []byte{}
    		tierKey := ReservedMetadataPrefixLower + TransitionTier
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 3.4K bytes
    - Click Count (0)
  2. internal/event/target/kafka_scram_client_contrib.go

    	x.Client, err = x.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  3. internal/dsync/lock-args_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "Resources")
    				return
    			}
    			if cap(z.Resources) >= int(zb0002) {
    				z.Resources = (z.Resources)[:zb0002]
    			} else {
    				z.Resources = make([]string, zb0002)
    			}
    			for za0001 := range z.Resources {
    				z.Resources[za0001], err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "Resources", za0001)
    					return
    				}
    			}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  4. cmd/background-newdisks-heal-ops_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "QueuedBuckets")
    				return
    			}
    			if cap(z.QueuedBuckets) >= int(zb0002) {
    				z.QueuedBuckets = (z.QueuedBuckets)[:zb0002]
    			} else {
    				z.QueuedBuckets = make([]string, zb0002)
    			}
    			for za0001 := range z.QueuedBuckets {
    				z.QueuedBuckets[za0001], err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "QueuedBuckets", za0001)
    					return
    				}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 24.6K bytes
    - Click Count (0)
  5. internal/disk/directio_unsupported.go

    func DisableDirectIO(f *os.File) error {
    	return nil
    }
    
    // AlignedBlock simply returns an unaligned buffer
    // for systems that do not support DirectIO.
    func AlignedBlock(blockSize int) []byte {
    	return make([]byte, blockSize)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 2.6K bytes
    - Click Count (0)
  6. docs/sts/etcd.md

    ### 3. Setup MinIO with etcd
    
    MinIO server expects environment variable for etcd as `MINIO_ETCD_ENDPOINTS`, this environment variable takes many comma separated entries.
    
    ```
    export MINIO_ETCD_ENDPOINTS=http://localhost:2379
    minio server /data
    ```
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  7. internal/crypto/sse-s3.go

    	}
    
    	if len(metadata) != len(buckets) || len(metadata) != len(objects) {
    		return nil, Errorf("invalid metadata/object count: %d != %d != %d", len(metadata), len(buckets), len(objects))
    	}
    	keys := make([]ObjectKey, 0, len(metadata))
    	for i := range metadata {
    		key, err := s3.UnsealObjectKey(k, metadata[i], buckets[i], objects[i])
    		if err != nil {
    			return nil, err
    		}
    		keys = append(keys, key)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 07 23:55:37 GMT 2024
    - 7.6K bytes
    - Click Count (0)
  8. internal/store/queuestore.go

    	if limit == 0 {
    		limit = defaultLimit
    	}
    
    	if ext == "" {
    		ext = defaultExt
    	}
    
    	return &QueueStore[I]{
    		directory:  directory,
    		entryLimit: limit,
    		fileExt:    ext,
    		entries:    make(map[string]int64, limit),
    	}
    }
    
    // Open - Creates the directory if not present.
    func (store *QueueStore[_]) Open() error {
    	store.Lock()
    	defer store.Unlock()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  9. ci/official/containers/ml_build/builder.devtoolset/build_devtoolset.sh

          --with-default-libstdcxx-abi=${LIBSTDCXX_ABI} \
          --with-gcc-major-version-only \
          --with-linker-hash-style="gnu" \
          --with-tune="generic" \
          && \
        make -j 42 && \
        make install
    
    
    # Create the devtoolset libstdc++ linkerscript that links dynamically against
    # the system libstdc++ 4.4 and provides all other symbols statically.
    case "${VERSION}" in
    devtoolset-7)
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Tue Sep 24 20:45:58 GMT 2024
    - 8K bytes
    - Click Count (0)
  10. cmd/iam.go

    	// Map of LDAP user (internal representation) to list of active credential objects
    	parentUserToCredsMap := make(map[string][]auth.Credentials)
    	// DN to ldap username mapping for each LDAP user
    	actualDNToLDAPUsernameMap := make(map[string]string)
    	// External (actual) LDAP DN to internal normalized representation
    	actualDNToParentUserMap := make(map[string]string)
    	for _, cred := range allCreds {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 76.5K bytes
    - Click Count (0)
Back to Top