Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 231 - 240 of 961 for funcs (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/s3select/sql/utils.go

    	return e.strippedPathExpr
    }
    
    func (e *JSONPathElement) String() string {
    	switch {
    	case e.Key != nil:
    		return e.Key.String()
    	case e.Index != nil:
    		return fmt.Sprintf("[%d]", *e.Index)
    	case e.ObjectWildcard:
    		return ".*"
    	case e.ArrayWildcard:
    		return "[*]"
    	}
    	return ""
    }
    
    // String removes double quotes in quoted identifiers
    func (i *Identifier) String() string {
    	if i.Unquoted != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Nov 10 16:12:50 GMT 2021
    - 3.6K bytes
    - Click Count (0)
  2. src/archive/tar/writer_test.go

    }
    
    // failOnceWriter fails exactly once and then always reports success.
    type failOnceWriter bool
    
    func (w *failOnceWriter) Write(b []byte) (int, error) {
    	if !*w {
    		return 0, io.ErrShortWrite
    	}
    	*w = true
    	return len(b), nil
    }
    
    func TestWriterErrors(t *testing.T) {
    	t.Run("HeaderOnly", func(t *testing.T) {
    		tw := NewWriter(new(bytes.Buffer))
    		hdr := &Header{Name: "dir/", Typeflag: TypeDir}
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 40.2K bytes
    - Click Count (0)
  3. cmd/bucket-replication-metrics_gen.go

    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z ActiveWorkerStat) Msgsize() (s int) {
    	s = 1 + 5 + msgp.IntSize + 4 + msgp.Float32Size + 4 + msgp.IntSize
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *InQueueMetric) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33.3K bytes
    - Click Count (0)
  4. cmd/metrics-v2_gen.go

    func (z MetricName) Msgsize() (s int) {
    	s = msgp.StringPrefixSize + len(string(z))
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z MetricNamespace) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendString(o, string(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19K bytes
    - Click Count (0)
  5. cmd/background-newdisks-heal-ops_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsghealingTracker(b *testing.B) {
    	v := healingTracker{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsghealingTracker(b *testing.B) {
    	v := healingTracker{}
    	bts := make([]byte, 0, v.Msgsize())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.3K bytes
    - Click Count (0)
  6. internal/cachevalue/cache_test.go

    	"errors"
    	"testing"
    	"time"
    )
    
    func slowCaller(ctx context.Context) error {
    	sl := time.NewTimer(time.Second)
    	defer sl.Stop()
    
    	select {
    	case <-sl.C:
    	case <-ctx.Done():
    		return ctx.Err()
    	}
    
    	return nil
    }
    
    func TestCacheCtx(t *testing.T) {
    	cache := New[time.Time]()
    	t.Parallel()
    	cache.InitOnce(2*time.Second, Opts{},
    		func(ctx context.Context) (time.Time, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  7. internal/store/batch.go

    func (b *Batch[I]) Close() error {
    	defer func() {
    		close(b.quitCh)
    	}()
    
    	b.Lock()
    	defer b.Unlock()
    	return b.commit()
    }
    
    // NewBatch creates a new batch
    func NewBatch[I any](config BatchConfig[I]) *Batch[I] {
    	if config.CommitTimeout == 0 {
    		config.CommitTimeout = defaultCommitTimeout
    	}
    	quitCh := make(chan struct{})
    	batch := &Batch[I]{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  8. misc/ios/detect.go

    					matches++
    				}
    			}
    		}
    		if matches == len(udids) {
    			files = append(files, string(line))
    		}
    	}
    	return files
    }
    
    func parseMobileProvision(fname string) *exec.Cmd {
    	return exec.Command("security", "cms", "-D", "-i", string(fname))
    }
    
    func plistExtract(fname string, path string) ([]byte, error) {
    	out, err := exec.Command("/usr/libexec/PlistBuddy", "-c", "Print "+path, fname).CombinedOutput()
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Oct 19 23:33:30 GMT 2023
    - 3.2K bytes
    - Click Count (0)
  9. internal/bucket/replication/destination.go

    }
    
    func (d Destination) isValidStorageClass() bool {
    	if d.StorageClass == "" {
    		return true
    	}
    	return d.StorageClass == "STANDARD" || d.StorageClass == "REDUCED_REDUNDANCY"
    }
    
    // IsValid - checks whether Destination is valid or not.
    func (d Destination) IsValid() bool {
    	return d.Bucket != "" || !d.isValidStorageClass()
    }
    
    func (d Destination) String() string {
    	return d.ARN
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 4K bytes
    - Click Count (0)
  10. internal/hash/reader.go

    // not the actual SHA256 checksum of the content.
    func (r *Reader) SHA256() []byte {
    	return r.contentSHA256
    }
    
    // SHA256HexString returns a hex representation of the SHA256.
    func (r *Reader) SHA256HexString() string {
    	return hex.EncodeToString(r.contentSHA256)
    }
    
    // ContentCRCType returns the content checksum type.
    func (r *Reader) ContentCRCType() ChecksumType {
    	return r.contentHash.Type
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 11.8K bytes
    - Click Count (0)
Back to Top