Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 210 for Kata (0.2 sec)

  1. docs/extensions/s3zip/examples/boto3/main.py

    # List zip contents
    response = s3.list_objects_v2(Bucket="your-bucket", Prefix="path/to/file.zip/")
    print(response)
    
    # Download data.csv stored in the zip file
    Python
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Aug 04 21:15:45 GMT 2021
    - 771 bytes
    - Viewed (0)
  2. cmd/erasure-heal_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		data := make([]byte, test.size)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 7.9K bytes
    - Viewed (0)
  3. cmd/tier-journal.go

    	// write journal version header if active journal is empty
    	fi, err := jd.file.Stat()
    	if err != nil {
    		return err
    	}
    	if fi.Size() == 0 {
    		var data [tierJournalHdrLen]byte
    		binary.LittleEndian.PutUint16(data[:], tierJournalVersion)
    		_, err = jd.file.Write(data[:])
    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    func (jd *tierDiskJournal) OpenRO() (io.ReadCloser, error) {
    Go
    - Registered: Sun Feb 25 19:28:16 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.4K bytes
    - Viewed (0)
  4. cmd/storage-errors.go

    // errLessData - returned when less data available than what was requested.
    var errLessData = StorageErr("less data available than what was requested")
    
    // errMoreData = returned when more data was sent by the caller than what it was supposed to.
    var errMoreData = StorageErr("more data was sent than what was advertised")
    
    // indicates readDirFn to return without further applying the fn()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  5. cmd/erasure-common.go

    				}
    				quorum++
    				if toAdd.Modtime.After(gotFile.Modtime) || len(gotFile.Data) < len(toAdd.Data) {
    					// Pick latest, or largest to avoid possible truncated entries.
    					continue
    				}
    				toAdd = gotFile
    			}
    		}
    		if quorum < readQuorum {
    			toAdd.Exists = false
    			toAdd.Error = errErasureReadQuorum.Error()
    			toAdd.Data = nil
    		}
    		dataArray = append(dataArray, toAdd)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  6. internal/s3select/simdj/record.go

    		return err
    	}
    	if n != len(b) {
    		return io.ErrShortWrite
    	}
    	return nil
    }
    
    // Replace the underlying buffer of json data.
    func (r *Record) Replace(k interface{}) error {
    	v, ok := k.(simdjson.Object)
    	if !ok {
    		return fmt.Errorf("cannot replace internal data in simd json record with type %T", k)
    	}
    	r.object = v
    	return nil
    }
    
    // NewRecord - creates new empty JSON record.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  7. cmd/tier-handlers.go

    	if objAPI == nil {
    		return
    	}
    
    	tiers := globalTierConfigMgr.ListTiers()
    	data, err := json.Marshal(tiers)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	w.Header().Set(tierCfgRefreshAtHdr, globalTierConfigMgr.refreshedAt().String())
    	writeSuccessResponseJSON(w, data)
    }
    
    func (api adminAPIHandlers) EditTierHandler(w http.ResponseWriter, r *http.Request) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 19:52:44 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  8. buildscripts/minio-iam-ldap-upgrade-import-test.sh

    		export _MINIO_LDAP_TEST_SERVER=localhost:1389
    		echo "Using default LDAP endpoint: $_MINIO_LDAP_TEST_SERVER"
    	fi
    
    	rm -rf /tmp/data
    }
    
    create_iam_content_in_old_minio() {
    	echo "Creating IAM content in old minio instance."
    
    	MINIO_CI_CD=1 ./minio.${OLD_VERSION} server /tmp/data/{1...4} &
    	sleep 5
    
    	set -x
    	mc alias set old-minio http://localhost:9000 minioadmin minioadmin
    	mc idp ldap add old-minio \
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:49:53 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  9. internal/bucket/replication/sourceselectioncriteria.go

    	if (s == SourceSelectionCriteria{}) {
    		return nil
    	}
    	if !s.IsValid() {
    		return errInvalidSourceSelectionCriteria
    	}
    	return nil
    }
    
    // UnmarshalXML - decodes XML data.
    func (s *SourceSelectionCriteria) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type sourceSelectionCriteria SourceSelectionCriteria
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  10. buildscripts/verify-build.sh

    export MINT_MODE=core
    export MINT_DATA_DIR="$WORK_DIR/data"
    export SERVER_ENDPOINT="127.0.0.1:9000"
    export ACCESS_KEY="minio"
    export SECRET_KEY="minio123"
    export ENABLE_HTTPS=0
    export GO111MODULE=on
    export GOGC=25
    export ENABLE_ADMIN=1
    
    export MINIO_CI_CD=1
    
    MINIO_CONFIG_DIR="$WORK_DIR/.minio"
    MINIO=("$PWD/minio" --config-dir "$MINIO_CONFIG_DIR")
    
    FILE_1_MB="$MINT_DATA_DIR/datafile-1-MB"
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 26 05:07:25 GMT 2023
    - 6.5K bytes
    - Viewed (0)
Back to top