Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 1,214 for Func (0.05 sec)

  1. internal/logger/console.go

    	}
    	fmt.Fprintln(Output, string(logJSON))
    }
    
    func (i infoMsg) quiet(msg string, args ...interface{}) {
    }
    
    func (i infoMsg) pretty(msg string, args ...interface{}) {
    	if msg == "" {
    		fmt.Fprintln(Output, args...)
    	} else {
    		fmt.Fprintf(Output, `INFO: `+msg, args...)
    	}
    }
    
    type errorMsg struct{}
    
    var errorMessage errorMsg
    
    func (i errorMsg) json(msg string, args ...interface{}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 7.5K 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. internal/pubsub/mask.go

    func (t Mask) SingleType() bool {
    	return bits.OnesCount64(uint64(t)) == 1
    }
    
    // FromUint64 will set a mask to the uint64 value.
    func (t *Mask) FromUint64(m uint64) {
    	*t = Mask(m)
    }
    
    // Merge will merge other into t.
    func (t *Mask) Merge(other Mask) {
    	*t |= other
    }
    
    // MergeMaskable will merge other into t.
    func (t *Mask) MergeMaskable(other Maskable) {
    	*t |= Mask(other.Mask())
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 05 21:45:49 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  4. cmd/object-api-utils.go

    	// idempotent.
    	g.once.Do(func() {
    		for i := len(g.cleanUpFns) - 1; i >= 0; i-- {
    			g.cleanUpFns[i]()
    		}
    	})
    	return nil
    }
    
    // compressionIndexEncrypter returns a function that will read data from input,
    // encrypt it using the provided key and return the result.
    func compressionIndexEncrypter(key crypto.ObjectKey, input func() []byte) func() []byte {
    	var data []byte
    	var fetched bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  5. internal/bucket/lifecycle/lifecycle.go

    	ActionCount
    )
    
    // DeleteRestored - Returns true if action demands delete on restored objects
    func (a Action) DeleteRestored() bool {
    	return a == DeleteRestoredAction || a == DeleteRestoredVersionAction
    }
    
    // DeleteVersioned - Returns true if action demands delete on a versioned object
    func (a Action) DeleteVersioned() bool {
    	return a == DeleteVersionAction || a == DeleteRestoredVersionAction
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K 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. tests/serializer_test.go

    	}
    	return nil
    }
    
    func (es EncryptedString) Value(ctx context.Context, field *schema.Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    	return "hello" + string(es), nil
    }
    
    type CustomSerializer struct {
    	prefix []byte
    }
    
    func NewCustomSerializer(prefix string) *CustomSerializer {
    	return &CustomSerializer{prefix: []byte(prefix)}
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Apr 21 14:09:38 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  8. internal/store/batch_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package store
    
    import (
    	"context"
    	"sync"
    	"testing"
    	"time"
    )
    
    func TestBatchCommit(t *testing.T) {
    	defer func() {
    		if err := tearDownQueueStore(); err != nil {
    			t.Fatalf("Failed to tear down store; %v", err)
    		}
    	}()
    	store, err := setUpQueueStore(queueDir, 100)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  9. cmd/erasure-healing-common.go

    		return checkPartDiskNotFound
    	default:
    		return checkPartUnknown
    	}
    }
    
    func partNeedsHealing(partErrs []int) bool {
    	return slices.IndexFunc(partErrs, func(i int) bool { return i != checkPartSuccess && i != checkPartUnknown }) > -1
    }
    
    func hasPartErr(partErrs []int) bool {
    	return slices.IndexFunc(partErrs, func(i int) bool { return i != checkPartSuccess }) > -1
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. cmd/metrics-v2_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgMetricDescription(b *testing.B) {
    	v := MetricDescription{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgMetricDescription(b *testing.B) {
    	v := MetricDescription{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 4.7K bytes
    - Viewed (0)
Back to top