Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 1,387 for funcs (0.03 sec)

  1. src/bytes/reader.go

    // slice.
    func (r *Reader) Len() int {
    	if r.i >= int64(len(r.s)) {
    		return 0
    	}
    	return int(int64(len(r.s)) - r.i)
    }
    
    // Size returns the original length of the underlying byte slice.
    // Size is the number of bytes available for reading via [Reader.ReadAt].
    // The result is unaffected by any method calls except [Reader.Reset].
    func (r *Reader) Size() int64 { return int64(len(r.s)) }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. src/bytes/bytes.go

    // all leading UTF-8-encoded code points c that satisfy f(c).
    func TrimLeftFunc(s []byte, f func(r rune) bool) []byte {
    	i := indexFunc(s, f, false)
    	if i == -1 {
    		return nil
    	}
    	return s[i:]
    }
    
    // TrimRightFunc returns a subslice of s by slicing off all trailing
    // UTF-8-encoded code points c that satisfy f(c).
    func TrimRightFunc(s []byte, f func(r rune) bool) []byte {
    	i := lastIndexFunc(s, f, false)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 35.6K bytes
    - Viewed (0)
  3. cmd/common-main.go

    // This can be used for goroutines that live beyond the parent context.
    func bgContext(parent context.Context) context.Context {
    	return bgCtx{parent: parent}
    }
    
    type bgCtx struct {
    	parent context.Context
    }
    
    func (a bgCtx) Done() <-chan struct{} {
    	return nil
    }
    
    func (a bgCtx) Err() error {
    	return nil
    }
    
    func (a bgCtx) Deadline() (deadline time.Time, ok bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    //
    //msgp:ignore versionsSorter
    type versionsSorter []FileInfo
    
    func (v versionsSorter) reverse() {
    	sort.Slice(v, func(i, j int) bool {
    		return v[i].ModTime.Before(v[j].ModTime)
    	})
    }
    
    func (set *erasureObjects) listObjectsToDecommission(ctx context.Context, bi decomBucketInfo, fn func(entry metaCacheEntry)) error {
    	disks, _ := set.getOnlineDisksWithHealing(false)
    	if len(disks) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  5. finisher_api.go

    func (db *DB) Create(value interface{}) (tx *DB) {
    	if db.CreateBatchSize > 0 {
    		return db.CreateInBatches(value, db.CreateBatchSize)
    	}
    
    	tx = db.getInstance()
    	tx.Statement.Dest = value
    	return tx.callbacks.Create().Execute(tx)
    }
    
    // CreateInBatches inserts value in batches of batchSize
    func (db *DB) CreateInBatches(value interface{}, batchSize int) (tx *DB) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  6. internal/ringbuffer/ring_buffer.go

    // A goroutine will be started and run until the provided context is canceled.
    func (r *RingBuffer) WithCancel(ctx context.Context) *RingBuffer {
    	go func() {
    		select {
    		case <-ctx.Done():
    			r.CloseWithError(ctx.Err())
    		}
    	}()
    	return r
    }
    
    func (r *RingBuffer) setErr(err error, locked bool) error {
    	if !locked {
    		r.mu.Lock()
    		defer r.mu.Unlock()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. callbacks/associations.go

    package callbacks
    
    import (
    	"reflect"
    	"strings"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/clause"
    	"gorm.io/gorm/schema"
    	"gorm.io/gorm/utils"
    )
    
    func SaveBeforeAssociations(create bool) func(db *gorm.DB) {
    	return func(db *gorm.DB) {
    		if db.Error == nil && db.Statement.Schema != nil {
    			selectColumns, restricted := db.Statement.SelectAndOmitColumns(create, !create)
    
    			// Save Belongs To associations
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Apr 11 03:06:13 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  8. istioctl/pkg/kubeinject/kubeinject.go

    // This is forked from  polymorphichelpers.GetFirstPod to not watch and instead return an error if no pods are found
    func GetFirstPod(client v1.CoreV1Interface, namespace string, selector string) (*corev1.Pod, error) {
    	options := metav1.ListOptions{LabelSelector: selector}
    
    	sortBy := func(pods []*corev1.Pod) sort.Interface { return sort.Reverse(podutils.ActivePods(pods)) }
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  9. internal/bucket/object/lock/lock.go

    	// RetCompliance - compliance mode.
    	RetCompliance RetMode = "COMPLIANCE"
    )
    
    // Valid - returns if retention mode is valid
    func (r RetMode) Valid() bool {
    	switch r {
    	case RetGovernance, RetCompliance:
    		return true
    	}
    	return false
    }
    
    func parseRetMode(modeStr string) (mode RetMode) {
    	switch strings.ToUpper(modeStr) {
    	case "GOVERNANCE":
    		mode = RetGovernance
    	case "COMPLIANCE":
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  10. cni/pkg/plugin/plugin_dryrun_test.go

    type mockNetNs struct {
    	path string
    }
    
    func (ns *mockNetNs) Do(toRun func(ns.NetNS) error) error {
    	return toRun(ns)
    }
    
    func (*mockNetNs) Set() error {
    	return nil
    }
    
    func (ns *mockNetNs) Path() string {
    	return ns.path
    }
    
    func (*mockNetNs) Fd() uintptr {
    	return 0
    }
    
    func (*mockNetNs) Close() error {
    	return nil
    }
    
    type netNsFunc func(nspath string) (ns.NetNS, error)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Aug 27 16:44:45 UTC 2024
    - 8.5K bytes
    - Viewed (0)
Back to top