MCPcopy Create free account

hub / github.com/cloudflare/golibs / functions

Functions305 in github.com/cloudflare/golibs

MethodLen
()
spacesaving/srate.go:24
MethodLen
()
spacesaving/tools/perfect.go:21
MethodLen
()
lrucache/priorityqueue.go:9
MethodLen
New returns an initialized list. func New() *list { return new(list).Init() } Len returns the number of elements of list l. The complexity is O(1).
lrucache/list.go:99
MethodLength
Length of the buffer
circularbuffer/circularbuffer.go:179
MethodLess
(i, j int)
spacesaving/rate.go:46
MethodLess
(i, j int)
spacesaving/rate.go:168
MethodLess
(i, j int)
spacesaving/srate.go:26
MethodLess
(i, j int)
spacesaving/tools/perfect.go:23
MethodLess
(i, j int)
lrucache/priorityqueue.go:13
MethodMatchPrefix
(ctx context.Context, key string, maxrecords int64)
kt/kt_metrics.go:144
MethodMoveAfter
MoveAfter moves element e to its new position after mark. If e is not an element of l, or e == mark, the list is not modified.
lrucache/list.go:217
MethodMoveBefore
MoveBefore moves element e to its new position before mark. If e is not an element of l, or e == mark, the list is not modified.
lrucache/list.go:208
MethodMoveToBack
MoveToBack moves element e to the back of list l. If e is not an element of l, the list is not modified.
lrucache/list.go:198
MethodNBOptionalPush
Non-blocking push. Wil put item in the buffer only if there is free space.
circularbuffer/circularbuffer.go:34
MethodNBPush
Non-blocking push. Will evict items from the cache if there isn't enough space available.
circularbuffer/circularbuffer.go:30
FunctionNew
New creates a new token bucket filter with num buckets, accruing tokens at rate per second. The depth specifies the depth of the bucket.
tokenbucket/bucket.go:27
FunctionNewClientWithTLS
NewClientWithTLS creates a TLS enabled connection. This method allows a custom path for the Root CA, and the Certificate and Key.
kt/kt.go:255
FunctionNewConnTLS
NewConnTLS creates a TLS enabled connection to a Kyoto Tycoon endpoing
kt/kt.go:233
FunctionNewTrackedConn
NewTrackedConn creates a new connection to a Kyoto Tycoon endpoint, and tracks operations made to it using prometheus metrics. All supported operation
kt/kt_metrics.go:34
FunctionNewTrackedConnFromConn
NewTrackedConnFromConn returns a tracked connection that simply wraps the given database connection.
kt/kt_metrics.go:48
MethodPop
()
spacesaving/rate.go:44
MethodPop
()
spacesaving/srate.go:43
MethodPop
()
lrucache/priorityqueue.go:30
MethodPop
Blocking pop an item from the end of the stack (newest), blocking.
circularbuffer/circularbuffer.go:44
MethodPopElementFront
()
lrucache/list_extension.go:15
MethodPopFront
()
lrucache/list_extension.go:21
MethodPush
(x interface{})
spacesaving/rate.go:43
MethodPushBack
PushBack inserts a new element e with value v at the back of list l and returns e.
lrucache/list.go:162
MethodPushBackList
PushBackList inserts a copy of an other list at the back of list l. The lists l and other may be the same.
lrucache/list.go:226
MethodPushFront
PushFront inserts a new element e with value v at the front of list l and returns e.
lrucache/list.go:157
MethodPushFrontList
PushFrontList inserts a copy of an other list at the front of list l. The lists l and other may be the same.
lrucache/list.go:234
MethodRemove
(ctx context.Context, key string)
kt/kt_metrics.go:64
MethodRemoveBulk
(ctx context.Context, keys []string)
kt/kt_metrics.go:134
MethodReset
()
spacesaving/count.go:84
MethodRetryCount
RetryCount is the number of retries performed due to the remote end closing idle connections. The value increases monotonically, until it wraps to 0.
kt/kt.go:345
MethodSet
(key, value string)
lrucache/benchmark/vcache.go:35
MethodSet
(key, value string)
lrucache/benchmark/mcache.go:42
MethodSetExpireGracePeriod
Set the stale expiry grace period for each cache in the multicache instance.
lrucache/multilru.go:27
MethodSize
()
lrucache/benchmark/vcache.go:23
MethodSwap
(i, j int)
spacesaving/rate.go:76
MethodSwap
(i, j int)
spacesaving/rate.go:167
MethodSwap
(i, j int)
spacesaving/srate.go:30
MethodSwap
(i, j int)
spacesaving/tools/perfect.go:22
MethodSwap
(i, j int)
lrucache/priorityqueue.go:17
FunctionTestASyncPop
(t *testing.T)
circularbuffer/circularbuffer_test.go:109
FunctionTestAsyncGet
(t *testing.T)
circularbuffer/circularbuffer_test.go:67
FunctionTestBasicExpiry
(t *testing.T)
lrucache/lrucache_test.go:10
FunctionTestBasicNoExpiry
(t *testing.T)
lrucache/lrucache_test.go:95
FunctionTestBucketDepth
(t *testing.T)
tokenbucket/bucket_test.go:18
FunctionTestConcurrentGet
(t *testing.T)
lrucache/lrucache_test.go:288
FunctionTestConcurrentSet
(t *testing.T)
lrucache/lrucache_test.go:308
FunctionTestCount
(t *testing.T)
kt/kt_base_test.go:96
FunctionTestDrain
(t *testing.T)
bytepool/bytepool_test.go:76
FunctionTestEject
(t *testing.T)
circularbuffer/circularbuffer_test.go:191
FunctionTestEwma
(t *testing.T)
ewma/ewma_test.go:59
FunctionTestEwmaCoverErrors
(t *testing.T)
ewma/ewma_test.go:82
FunctionTestExtra
(t *testing.T)
lrucache/lrucache_test.go:238
FunctionTestGetBulk
(t *testing.T)
kt/kt_base_test.go:198
FunctionTestGetBulkBytes
(t *testing.T)
kt/kt_base_test.go:304
FunctionTestGetBulkBytesLargeValue
(t *testing.T)
kt/kt_base_test.go:376
FunctionTestGetBytes
(t *testing.T)
kt/kt_base_test.go:428
FunctionTestGetBytesUnix
(t *testing.T)
kt/kt_base_test.go:443
FunctionTestGetSet
(t *testing.T)
kt/kt_base_test.go:114
FunctionTestInvalidBurst
(t *testing.T)
tokenbucket/bucket_test.go:9
FunctionTestIsError
(t *testing.T)
kt/kt_base_test.go:469
FunctionTestLimits
(t *testing.T)
bytepool/bytepool_test.go:90
FunctionTestMatchPrefix
(t *testing.T)
kt/kt_base_test.go:133
FunctionTestMath
(t *testing.T)
bytepool/bytepool_test.go:29
FunctionTestMultiLRUBasic
(t *testing.T)
lrucache/multilru_test.go:11
FunctionTestNil
(t *testing.T)
lrucache/lrucache_test.go:160
FunctionTestOptionalPush
(t *testing.T)
circularbuffer/circularbuffer_test.go:214
FunctionTestPanicByValue
(t *testing.T)
lrucache/lrucache_test.go:198
FunctionTestPool
(t *testing.T)
pool/pool_test.go:16
FunctionTestPool
(t *testing.T)
bytepool/bytepool_test.go:40
FunctionTestPoolGC
Test that Pool does not hold pointers to previously cached resources
pool/pool_test.go:65
FunctionTestPoolNew
(t *testing.T)
pool/pool_test.go:40
FunctionTestPoolStress
(t *testing.T)
pool/pool_test.go:91
FunctionTestRate
(t *testing.T)
spacesaving/rate_test.go:73
FunctionTestRate
(t *testing.T)
tokenbucket/bucket_test.go:42
FunctionTestRate
(t *testing.T)
ewma/rate_test.go:64
FunctionTestRateCoverErrors
(t *testing.T)
ewma/rate_test.go:82
FunctionTestRateGetAll
(t *testing.T)
spacesaving/rate_test.go:104
FunctionTestRateGetAllCover
(t *testing.T)
spacesaving/rate_test.go:141
FunctionTestSetGetRemoveBulk
(t *testing.T)
kt/kt_base_test.go:255
FunctionTestSyncGet
(t *testing.T)
circularbuffer/circularbuffer_test.go:22
FunctionTestSyncOverflow
(t *testing.T)
circularbuffer/circularbuffer_test.go:41
FunctionTestSyncOverflowEvictCallback
(t *testing.T)
circularbuffer/circularbuffer_test.go:131
FunctionTestSyncPop
(t *testing.T)
circularbuffer/circularbuffer_test.go:89
FunctionTestZeroLength
(t *testing.T)
lrucache/lrucache_test.go:222
MethodTouch
(key string)
spacesaving/count.go:24
MethodTouch
(key string, nowTs time.Time)
spacesaving/srate.go:85
Functionbase64Decode
Base64 decode each of the field
kt/kt.go:856
FunctionidentityDecode
Don't do anything, this is pure TSV
kt/kt.go:851
Functioninit
()
kt/kt.go:38
Functionmain
()
spacesaving/tools/topdns.go:29
Functionmain
()
spacesaving/tools/readpcap.go:29
Functionmain
()
spacesaving/tools/perfect.go:28
Functionmain
()
spacesaving/tools/main.go:17
Functionmain
()
lrucache/benchmark/main.go:26
← previousnext →201–300 of 305, ranked by callers