- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,387 for funcs (0.02 sec)
-
internal/grid/types.go
} // NewArrayOf returns a new ArrayOf. // You must provide a function that returns a new instance of T. func NewArrayOf[T RoundTripper](newFn func() T) *ArrayOf[T] { return &ArrayOf[T]{ ePool: sync.Pool{New: func() any { return newFn() }}, } } // New returns a new empty Array. func (p *ArrayOf[T]) New() *Array[T] { return &Array[T]{ p: p, } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 15.5K bytes - Viewed (0) -
internal/color/color.go
return fmt.Sprint }() RedBoldf = func() func(format string, a ...interface{}) string { if IsTerminal() { return color.New(color.FgRed, color.Bold).SprintfFunc() } return fmt.Sprintf }() Red = func() func(format string, a ...interface{}) string { if IsTerminal() { return color.New(color.FgRed).SprintfFunc() } return fmt.Sprintf }() Blue = func() func(format string, a ...interface{}) string {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 01 17:57:52 UTC 2024 - 3.8K bytes - Viewed (0) -
cmd/data-usage-cache_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgallTierStats(b *testing.B) { v := allTierStats{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgallTierStats(b *testing.B) { v := allTierStats{} bts := make([]byte, 0, v.Msgsize())
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 19K bytes - Viewed (0) -
cmd/logging.go
} func rebalanceLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "rebalance", err, errKind...) } func rebalanceLogEvent(ctx context.Context, msg string, args ...interface{}) { logger.Event(ctx, "rebalance", msg, args...) } func adminLogIf(ctx context.Context, err error, errKind ...interface{}) { logger.LogIf(ctx, "admin", err, errKind...) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 03 18:49:48 UTC 2024 - 7.1K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
hammerRWMutex(t, 10, 5, n) } // Borrowed from rwmutex_test.go func TestUnlockPanic(t *testing.T) { defer func() { if recover() == nil { t.Fatalf("unlock of unlocked RWMutex did not panic") } }() mu := NewDRWMutex(ds, "test") mu.Unlock(context.Background()) } // Borrowed from rwmutex_test.go func TestUnlockPanic2(t *testing.T) { mu := NewDRWMutex(ds, "test-unlock-panic-2")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 9.7K bytes - Viewed (0) -
cmd/batch-replicate_gen_test.go
} if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBatchJobReplicateCredentials(b *testing.B) { v := BatchJobReplicateCredentials{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgBatchJobReplicateCredentials(b *testing.B) { v := BatchJobReplicateCredentials{}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 29 18:27:23 UTC 2023 - 14.2K bytes - Viewed (0) -
internal/dsync/dsync_test.go
<-c } } func BenchmarkMutexUncontended(b *testing.B) { b.ResetTimer() b.ReportAllocs() type PaddedMutex struct { *DRWMutex } b.RunParallel(func(pb *testing.PB) { mu := PaddedMutex{NewDRWMutex(ds, "")} for pb.Next() { mu.Lock(id, source) mu.Unlock(context.Background()) } }) } func benchmarkMutex(b *testing.B, slack, work bool) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 14:35:19 UTC 2024 - 11.1K bytes - Viewed (0) -
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) -
cni/pkg/iptables/iptables_test.go
dep "istio.io/istio/tools/istio-iptables/pkg/dependencies" ) func TestIptables(t *testing.T) { cases := []struct { name string config func(cfg *Config) ingressMode bool }{ { name: "default", config: func(cfg *Config) { cfg.RedirectDNS = true }, }, { name: "tproxy", config: func(cfg *Config) { cfg.TPROXYRedirection = true cfg.RedirectDNS = true
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Oct 15 15:39:28 UTC 2024 - 4.1K bytes - Viewed (0) -
api/go1.7.txt
pkg bytes, func ContainsAny([]uint8, string) bool pkg bytes, func ContainsRune([]uint8, int32) bool pkg bytes, method (*Reader) Reset([]uint8) pkg compress/flate, const HuffmanOnly = -2 pkg compress/flate, const HuffmanOnly ideal-int pkg context, func Background() Context pkg context, func TODO() Context pkg context, func WithCancel(Context) (Context, CancelFunc) pkg context, func WithDeadline(Context, time.Time) (Context, CancelFunc)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Jun 28 15:08:11 UTC 2016 - 13.6K bytes - Viewed (0)