Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for to_bytes (0.2 sec)

  1. internal/s3select/sql/value.go

    	return
    }
    
    // ToTimestamp returns the timestamp value if present.
    func (v Value) ToTimestamp() (t time.Time, ok bool) {
    	t, ok = v.value.(time.Time)
    	return
    }
    
    // ToBytes returns the value if byte-slice.
    func (v Value) ToBytes() (val []byte, ok bool) {
    	val, ok = v.value.([]byte)
    	return
    }
    
    // ToArray returns the value if it is a slice of values.
    func (v Value) ToArray() (val []Value, ok bool) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 20.2K bytes
    - Viewed (0)
  2. cmd/admin-bucket-handlers.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	tgtBytes, err := json.Marshal(&targets)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrAdminConfigBadJSON, err), r.URL)
    		return
    	}
    	if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketTargetsFile, tgtBytes); err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 32.5K bytes
    - Viewed (0)
  3. cmd/bucket-replication-stats.go

    	defer r.qCache.Unlock()
    	v, ok := r.qCache.bucketStats[bucket]
    	if !ok {
    		v = newInQueueStats(r.registry, bucket)
    	}
    	atomic.AddInt64(&v.nowBytes, sz)
    	atomic.AddInt64(&v.nowCount, 1)
    	r.qCache.bucketStats[bucket] = v
    	atomic.AddInt64(&r.qCache.srQueueStats.nowBytes, sz)
    	atomic.AddInt64(&r.qCache.srQueueStats.nowCount, 1)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.4K bytes
    - Viewed (0)
  4. cmd/metrics-resource.go

    				updateResourceMetrics(interfaceSubsystem, interfaceRxErrors, float64(stats.RxErrors), labels, true)
    				updateResourceMetrics(interfaceSubsystem, interfaceTxBytes, float64(stats.TxBytes), labels, true)
    				updateResourceMetrics(interfaceSubsystem, interfaceTxErrors, float64(stats.TxErrors), labels, true)
    			}
    			if hm.Mem != nil && len(hm.Mem.Info.Addr) > 0 {
    				labels := map[string]string{}
    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)
  5. cmd/bucket-replication-handlers.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	tgtBytes, err := json.Marshal(&targets)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErrWithErr(ErrAdminConfigBadJSON, err), r.URL)
    		return
    	}
    	if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketTargetsFile, tgtBytes); err != nil {
    		writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 28 04:08:53 GMT 2023
    - 23.2K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    		t.Fatalf("part.1 not healed correctly")
    	}
    
    	// Test 2, Corrupt part.1
    	err = firstDisk.WriteAll(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte("foobytes"))
    	if err != nil {
    		t.Fatalf("Failed to write a file - %v", err)
    	}
    
    	_, err = objLayer.HealObject(ctx, bucket, object, "", madmin.HealOpts{ScanMode: madmin.HealNormalScan})
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  7. cmd/bucket-replication-metrics.go

    	v := q.srQueueStats
    	return InQueueMetric{
    		Curr: QStat{Bytes: float64(v.nowBytes), Count: float64(v.nowCount)},
    		Max:  QStat{Bytes: float64(v.histBytes.Max()), Count: float64(v.histCounts.Max())},
    		Avg:  QStat{Bytes: v.histBytes.Mean(), Count: v.histCounts.Mean()},
    	}
    }
    
    // InQueueStats holds queue stats for replication
    type InQueueStats struct {
    	nowBytes   int64 `json:"-"`
    	nowCount   int64 `json:"-"`
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 14.2K bytes
    - Viewed (0)
Back to top