- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,387 for funcs (0.06 sec)
-
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) -
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) -
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) -
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/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) -
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) -
cmd/erasure.go
setIndex int poolIndex int // getDisks returns list of storageAPIs. getDisks func() []StorageAPI // getLockers returns list of remote and local lockers. getLockers func() ([]dsync.NetLocker, string) // getEndpoints returns list of endpoint belonging this set. // some may be local and some remote. getEndpoints func() []Endpoint // getEndpoints returns list of endpoint strings belonging this set.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 16.1K 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/muxserver.go
RecvSeq: msg.Seq + 1, SendSeq: msg.Seq, ctx: ctx, cancel: cancel, parent: c, LastPing: time.Now().Unix(), BaseFlags: c.baseFlags, } go func() { // TODO: Handle }() return &m } func newMuxStream(ctx context.Context, msg message, c *Connection, handler StreamHandler) *muxServer { var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if len(handler.Subroute) > 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K 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)