Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 1,214 for Func (0.03 sec)

  1. tests/scanner_valuer_test.go

    }
    
    type ExampleStruct struct {
    	Name string
    	Val  string
    }
    
    func (ExampleStruct) GormDataType() string {
    	return "bytes"
    }
    
    func (s ExampleStruct) Value() (driver.Value, error) {
    	if len(s.Name) == 0 {
    		return nil, nil
    	}
    	// for test, has no practical meaning
    	s.Name = ""
    	return json.Marshal(s)
    }
    
    func (s *ExampleStruct) Scan(src interface{}) error {
    	switch value := src.(type) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 07 07:02:07 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  2. src/archive/tar/format.go

    func (h *headerV7) name() []byte     { return h[000:][:100] }
    func (h *headerV7) mode() []byte     { return h[100:][:8] }
    func (h *headerV7) uid() []byte      { return h[108:][:8] }
    func (h *headerV7) gid() []byte      { return h[116:][:8] }
    func (h *headerV7) size() []byte     { return h[124:][:12] }
    func (h *headerV7) modTime() []byte  { return h[136:][:12] }
    func (h *headerV7) chksum() []byte   { return h[148:][:8] }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  3. internal/logger/targets.go

    	list []Target
    	mu   sync.RWMutex
    }
    
    func newTargetsList() *targetsList {
    	return &targetsList{}
    }
    
    func (tl *targetsList) get() []Target {
    	tl.mu.RLock()
    	defer tl.mu.RUnlock()
    
    	return tl.list
    }
    
    func (tl *targetsList) add(t Target) {
    	tl.mu.Lock()
    	defer tl.mu.Unlock()
    
    	tl.list = append(tl.list, t)
    }
    
    func (tl *targetsList) set(tgts []Target) {
    	tl.mu.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  4. misc/cgo/gmp/gmp.go

    func (z *Int) Len() int {
    	z.doinit()
    	return int(C.mpz_sizeinbase(&z.i[0], 2))
    }
    
    // Set sets z = x and returns z.
    func (z *Int) Set(x *Int) *Int {
    	z.doinit()
    	C.mpz_set(&z.i[0], &x.i[0])
    	return z
    }
    
    // SetBytes interprets b as the bytes of a big-endian integer
    // and sets z to that value.
    func (z *Int) SetBytes(b []byte) *Int {
    	z.doinit()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Apr 11 16:34:30 UTC 2022
    - 9.5K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    func (p *xlStorageDiskIDCheck) IsLocal() bool {
    	return p.storage.IsLocal()
    }
    
    func (p *xlStorageDiskIDCheck) Endpoint() Endpoint {
    	return p.storage.Endpoint()
    }
    
    func (p *xlStorageDiskIDCheck) Hostname() string {
    	return p.storage.Hostname()
    }
    
    func (p *xlStorageDiskIDCheck) Healing() *healingTracker {
    	return p.storage.Healing()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  6. internal/grid/grid.go

    type ConnDialer func(ctx context.Context, address string) (net.Conn, error)
    
    // ConnectWSWithRoutePath is like ConnectWS but with a custom grid route path.
    func ConnectWSWithRoutePath(dial ContextDialer, auth AuthFn, tls *tls.Config, routePath string) func(ctx context.Context, remote string) (net.Conn, error) {
    	return func(ctx context.Context, remote string) (net.Conn, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. cmd/bucket-metadata-sys.go

    	group       *singleflight.Group
    	metadataMap map[string]BucketMetadata
    }
    
    // Count returns number of bucket metadata map entries.
    func (sys *BucketMetadataSys) Count() int {
    	sys.RLock()
    	defer sys.RUnlock()
    
    	return len(sys.metadataMap)
    }
    
    // Remove bucket metadata from memory.
    func (sys *BucketMetadataSys) Remove(buckets ...string) {
    	sys.Lock()
    	for _, bucket := range buckets {
    		sys.group.Forget(bucket)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  8. internal/s3select/jstream/scanner_test.go

    		t.Fatalf("expected null byte, got %v", c)
    	}
    }
    
    func BenchmarkBufioScanner(b *testing.B) {
    	b.Run("small", func(b *testing.B) {
    		for i := 0; i < b.N; i++ {
    			benchmarkBufioScanner(smallInput)
    		}
    	})
    	b.Run("medium", func(b *testing.B) {
    		for i := 0; i < b.N; i++ {
    			benchmarkBufioScanner(mediumInput)
    		}
    	})
    	b.Run("large", func(b *testing.B) {
    		for i := 0; i < b.N; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. cmd/erasure.go

    	setIndex  int
    	poolIndex int
    
    	// getDisks returns list of storageAPIs.
    	getDisks func() []StorageAPI
    
    	// getLockers returns list of remote and local lockers.
    	getLockers func() ([]dsync.NetLocker, string)
    
    	// getEndpoints returns list of endpoint belonging this set.
    	// some may be local and some remote.
    	getEndpoints func() []Endpoint
    
    	// getEndpoints returns list of endpoint strings belonging this set.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  10. internal/grid/muxserver.go

    		RecvSeq:   msg.Seq + 1,
    		SendSeq:   msg.Seq,
    		ctx:       ctx,
    		cancel:    cancel,
    		parent:    c,
    		LastPing:  time.Now().Unix(),
    		BaseFlags: c.baseFlags,
    	}
    	go func() {
    		// TODO: Handle
    	}()
    
    	return &m
    }
    
    func newMuxStream(ctx context.Context, msg message, c *Connection, handler StreamHandler) *muxServer {
    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if len(handler.Subroute) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top