Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 467 for Uint64 (0.12 sec)

  1. internal/s3select/message.go

    }
    
    type messageWriter struct {
    	writer          http.ResponseWriter
    	getProgressFunc func() (int64, int64)
    	bytesReturned   int64
    
    	payloadBuffer      []byte
    	payloadBufferIndex int
    	payloadCh          chan *bytes.Buffer
    
    	finBytesScanned, finBytesProcessed int64
    
    	errCh  chan []byte
    	doneCh chan struct{}
    }
    
    func (writer *messageWriter) write(data []byte) bool {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    	}
    	return respBody, nil
    }
    
    // ReadFile - reads section of a file.
    func (client *storageRESTClient) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (int64, error) {
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTFilePath, path)
    	values.Set(storageRESTOffset, strconv.Itoa(int(offset)))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  3. internal/s3select/sql/statement.go

    	selectAST *Select
    
    	// Analysis result of the statement
    	selectQProp qProp
    
    	// Result of parsing the limit clause if one is present
    	// (otherwise -1)
    	limitValue int64
    
    	// Count of rows that have been output.
    	outputCount int64
    
    	// Table alias
    	tableAlias string
    }
    
    // ParseSelectStatement - parses a select query from the given string
    // and analyzes it.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  4. cmd/auth-handler_test.go

    		}
    	}
    }
    
    // Provides a fully populated http request instance, fails otherwise.
    func mustNewRequest(method string, urlStr string, contentLength int64, body io.ReadSeeker, t *testing.T) *http.Request {
    	req, err := newTestRequest(method, urlStr, contentLength, body)
    	if err != nil {
    		t.Fatalf("Unable to initialize new http request %s", err)
    	}
    	return req
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. internal/logger/target/types/types.go

    	QueueLength int
    
    	// TotalMessages is the total number of messages sent in the lifetime of the target
    	TotalMessages int64
    
    	// FailedMessages should log message count that failed to send.
    	FailedMessages int64
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  6. cmd/erasure-metadata_test.go

    	for _, partNum := range []int{1, 2, 4, 5, 7} {
    		partNumString := strconv.Itoa(partNum)
    		fi.AddObjectPart(partNum, "etag."+partNumString, int64(partNum+humanize.MiByte), ActualSize, UTCNow(), nil, nil)
    	}
    
    	testCases := []struct {
    		offset         int64
    		expectedIndex  int
    		expectedOffset int64
    		expectedErr    error
    	}{
    		{0, 0, 0, nil},
    		{1 * humanize.MiByte, 0, 1 * humanize.MiByte, nil},
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  7. cmd/naughty-disk_test.go

    func (d *naughtyDisk) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) {
    	if err := d.calcError(); err != nil {
    		return 0, err
    	}
    	return d.disk.ReadFile(ctx, volume, path, offset, buf, verifier)
    }
    
    func (d *naughtyDisk) ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error) {
    	if err := d.calcError(); err != nil {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  8. src/archive/tar/strconv_test.go

    // license that can be found in the LICENSE file.
    
    package tar
    
    import (
    	"math"
    	"strings"
    	"testing"
    	"time"
    )
    
    func TestFitsInBase256(t *testing.T) {
    	vectors := []struct {
    		in    int64
    		width int
    		ok    bool
    	}{
    		{+1, 8, true},
    		{0, 8, true},
    		{-1, 8, true},
    		{1 << 56, 8, false},
    		{(1 << 56) - 1, 8, true},
    		{-1 << 56, 8, true},
    		{(-1 << 56) - 1, 8, false},
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Feb 09 05:28:50 UTC 2021
    - 14K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom.go

    	Object string `json:"-" msg:"obj"`
    
    	// Verbose information
    	ItemsDecommissioned     int64 `json:"objectsDecommissioned" msg:"id"`
    	ItemsDecommissionFailed int64 `json:"objectsDecommissionedFailed" msg:"idf"`
    	BytesDone               int64 `json:"bytesDecommissioned" msg:"bd"`
    	BytesFailed             int64 `json:"bytesDecommissionedFailed" msg:"bf"`
    }
    
    // Clone make a copy of PoolDecommissionInfo
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (1)
  10. migrator/migrator.go

    	DB                          *gorm.DB
    	gorm.Dialector
    }
    
    type printSQLLogger struct {
    	logger.Interface
    }
    
    func (l *printSQLLogger) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) {
    	sql, _ := fc()
    	fmt.Println(sql + ";")
    	l.Interface.Trace(ctx, begin, fc, err)
    }
    
    // GormDataTypeInterface gorm data type interface
    type GormDataTypeInterface interface {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Fri Apr 26 07:15:49 UTC 2024
    - 29K bytes
    - Viewed (0)
Back to top