Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 460 for Kata (0.13 sec)

  1. internal/event/name.go

    	}
    
    	*name = eventName
    	return nil
    }
    
    // MarshalJSON - encodes to JSON data.
    func (name Name) MarshalJSON() ([]byte, error) {
    	return json.Marshal(name.String())
    }
    
    // UnmarshalJSON - decodes JSON data.
    func (name *Name) UnmarshalJSON(data []byte) error {
    	var s string
    	if err := json.Unmarshal(data, &s); err != nil {
    		return err
    	}
    
    	eventName, err := ParseName(s)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. cmd/object_api_suite_test.go

    func newTestReaderEOF(data []byte) io.Reader {
    	return &testOneByteReadEOF{false, data}
    }
    
    // OneByteReadEOF - implements io.Reader which returns 1 byte along with io.EOF error.
    type testOneByteReadEOF struct {
    	eof  bool
    	data []byte
    }
    
    func (r *testOneByteReadEOF) Read(p []byte) (n int, err error) {
    	if r.eof {
    		return 0, io.EOF
    	}
    	n = copy(p, r.data)
    	r.eof = true
    	return n, io.EOF
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 32.3K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. cmd/xl-storage-disk-id-check.go

    		}
    		done(&err)
    	}()
    
    	// Copy inline data to a new buffer to function with deadlines.
    	if len(fi.Data) > 0 {
    		fi.Data = append(grid.GetByteBufferCap(len(fi.Data))[:0], fi.Data...)
    	}
    	return xioutil.WithDeadline[RenameDataResp](ctx, globalDriveConfig.GetMaxTimeout(), func(ctx context.Context) (res RenameDataResp, err error) {
    		if len(fi.Data) > 0 {
    			defer grid.PutByteBuffer(fi.Data)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
Back to top