- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,387 for funcs (0.05 sec)
-
istioctl/pkg/metrics/metrics_test.go
} func (client mockPromAPI) CleanTombstones(ctx context.Context) error { return nil } func (client mockPromAPI) Config(ctx context.Context) (promv1.ConfigResult, error) { return promv1.ConfigResult{}, nil } func (client mockPromAPI) DeleteSeries(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) error { return nil }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Aug 16 01:35:47 UTC 2024 - 8K bytes - Viewed (0) -
api/next/61901.txt
pkg bytes, func FieldsFuncSeq([]uint8, func(int32) bool) iter.Seq[[]uint8] #61901 pkg bytes, func FieldsSeq([]uint8) iter.Seq[[]uint8] #61901 pkg bytes, func Lines([]uint8) iter.Seq[[]uint8] #61901 pkg bytes, func SplitAfterSeq([]uint8, []uint8) iter.Seq[[]uint8] #61901 pkg bytes, func SplitSeq([]uint8, []uint8) iter.Seq[[]uint8] #61901 pkg strings, func FieldsFuncSeq(string, func(int32) bool) iter.Seq[string] #61901
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Aug 14 18:23:13 UTC 2024 - 676 bytes - Viewed (0) -
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) -
cni/pkg/ipset/nldeps_mock.go
type MockedIpsetDeps struct { mock.Mock } func FakeNLDeps() *MockedIpsetDeps { return &MockedIpsetDeps{} } func (m *MockedIpsetDeps) ipsetIPHashCreate(name string, v6 bool) error { args := m.Called(name, v6) return args.Error(0) } func (m *MockedIpsetDeps) destroySet(name string) error { args := m.Called(name) return args.Error(0) }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 1.8K bytes - Viewed (0) -
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) -
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) -
cmd/peer-rest-client.go
if err != nil { return } st.Results(func(b *grid.Bytes) error { select { case listenCh <- *b: default: // Do not block on slow receivers. b.Recycle() } return nil }) } // Listen - listen on peers. func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) { go func() { for { client.doListen(ctx, listenCh, v)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
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) -
cmd/storage-datatypes_gen_test.go
t.Fatal(err) } if len(left) > 0 { t.Errorf("%d bytes left over after Skip(): %q", len(left), left) } } func BenchmarkMarshalMsgBaseOptions(b *testing.B) { v := BaseOptions{} b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.MarshalMsg(nil) } } func BenchmarkAppendMsgBaseOptions(b *testing.B) { v := BaseOptions{} bts := make([]byte, 0, v.Msgsize()) bts, _ = v.MarshalMsg(bts[0:0])
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 73.9K bytes - Viewed (0) -
cmd/data-scanner-metric.go
func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) { initialPtr := unsafe.Pointer(&initial) tracker := ¤tPathTracker{ name: &initialPtr, } p.currentPaths.Store(disk, tracker) return func(path string) { atomic.StorePointer(tracker.name, unsafe.Pointer(&path)) }, func() { p.currentPaths.Delete(disk) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0)