Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cloudflare/golibs
/ functions
Functions
305 in github.com/cloudflare/golibs
⨍
Functions
305
◇
Types & classes
46
Method
Len
()
spacesaving/srate.go:24
Method
Len
()
spacesaving/tools/perfect.go:21
Method
Len
()
lrucache/priorityqueue.go:9
Method
Len
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
Method
Length
Length of the buffer
circularbuffer/circularbuffer.go:179
Method
Less
(i, j int)
spacesaving/rate.go:46
Method
Less
(i, j int)
spacesaving/rate.go:168
Method
Less
(i, j int)
spacesaving/srate.go:26
Method
Less
(i, j int)
spacesaving/tools/perfect.go:23
Method
Less
(i, j int)
lrucache/priorityqueue.go:13
Method
MatchPrefix
(ctx context.Context, key string, maxrecords int64)
kt/kt_metrics.go:144
Method
MoveAfter
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
Method
MoveBefore
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
Method
MoveToBack
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
Method
NBOptionalPush
Non-blocking push. Wil put item in the buffer only if there is free space.
circularbuffer/circularbuffer.go:34
Method
NBPush
Non-blocking push. Will evict items from the cache if there isn't enough space available.
circularbuffer/circularbuffer.go:30
Function
New
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
Function
NewClientWithTLS
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
Function
NewConnTLS
NewConnTLS creates a TLS enabled connection to a Kyoto Tycoon endpoing
kt/kt.go:233
Function
NewTrackedConn
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
Function
NewTrackedConnFromConn
NewTrackedConnFromConn returns a tracked connection that simply wraps the given database connection.
kt/kt_metrics.go:48
Method
Pop
()
spacesaving/rate.go:44
Method
Pop
()
spacesaving/srate.go:43
Method
Pop
()
lrucache/priorityqueue.go:30
Method
Pop
Blocking pop an item from the end of the stack (newest), blocking.
circularbuffer/circularbuffer.go:44
Method
PopElementFront
()
lrucache/list_extension.go:15
Method
PopFront
()
lrucache/list_extension.go:21
Method
Push
(x interface{})
spacesaving/rate.go:43
Method
PushBack
PushBack inserts a new element e with value v at the back of list l and returns e.
lrucache/list.go:162
Method
PushBackList
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
Method
PushFront
PushFront inserts a new element e with value v at the front of list l and returns e.
lrucache/list.go:157
Method
PushFrontList
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
Method
Remove
(ctx context.Context, key string)
kt/kt_metrics.go:64
Method
RemoveBulk
(ctx context.Context, keys []string)
kt/kt_metrics.go:134
Method
Reset
()
spacesaving/count.go:84
Method
RetryCount
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
Method
Set
(key, value string)
lrucache/benchmark/vcache.go:35
Method
Set
(key, value string)
lrucache/benchmark/mcache.go:42
Method
SetExpireGracePeriod
Set the stale expiry grace period for each cache in the multicache instance.
lrucache/multilru.go:27
Method
Size
()
lrucache/benchmark/vcache.go:23
Method
Swap
(i, j int)
spacesaving/rate.go:76
Method
Swap
(i, j int)
spacesaving/rate.go:167
Method
Swap
(i, j int)
spacesaving/srate.go:30
Method
Swap
(i, j int)
spacesaving/tools/perfect.go:22
Method
Swap
(i, j int)
lrucache/priorityqueue.go:17
Function
TestASyncPop
(t *testing.T)
circularbuffer/circularbuffer_test.go:109
Function
TestAsyncGet
(t *testing.T)
circularbuffer/circularbuffer_test.go:67
Function
TestBasicExpiry
(t *testing.T)
lrucache/lrucache_test.go:10
Function
TestBasicNoExpiry
(t *testing.T)
lrucache/lrucache_test.go:95
Function
TestBucketDepth
(t *testing.T)
tokenbucket/bucket_test.go:18
Function
TestConcurrentGet
(t *testing.T)
lrucache/lrucache_test.go:288
Function
TestConcurrentSet
(t *testing.T)
lrucache/lrucache_test.go:308
Function
TestCount
(t *testing.T)
kt/kt_base_test.go:96
Function
TestDrain
(t *testing.T)
bytepool/bytepool_test.go:76
Function
TestEject
(t *testing.T)
circularbuffer/circularbuffer_test.go:191
Function
TestEwma
(t *testing.T)
ewma/ewma_test.go:59
Function
TestEwmaCoverErrors
(t *testing.T)
ewma/ewma_test.go:82
Function
TestExtra
(t *testing.T)
lrucache/lrucache_test.go:238
Function
TestGetBulk
(t *testing.T)
kt/kt_base_test.go:198
Function
TestGetBulkBytes
(t *testing.T)
kt/kt_base_test.go:304
Function
TestGetBulkBytesLargeValue
(t *testing.T)
kt/kt_base_test.go:376
Function
TestGetBytes
(t *testing.T)
kt/kt_base_test.go:428
Function
TestGetBytesUnix
(t *testing.T)
kt/kt_base_test.go:443
Function
TestGetSet
(t *testing.T)
kt/kt_base_test.go:114
Function
TestInvalidBurst
(t *testing.T)
tokenbucket/bucket_test.go:9
Function
TestIsError
(t *testing.T)
kt/kt_base_test.go:469
Function
TestLimits
(t *testing.T)
bytepool/bytepool_test.go:90
Function
TestMatchPrefix
(t *testing.T)
kt/kt_base_test.go:133
Function
TestMath
(t *testing.T)
bytepool/bytepool_test.go:29
Function
TestMultiLRUBasic
(t *testing.T)
lrucache/multilru_test.go:11
Function
TestNil
(t *testing.T)
lrucache/lrucache_test.go:160
Function
TestOptionalPush
(t *testing.T)
circularbuffer/circularbuffer_test.go:214
Function
TestPanicByValue
(t *testing.T)
lrucache/lrucache_test.go:198
Function
TestPool
(t *testing.T)
pool/pool_test.go:16
Function
TestPool
(t *testing.T)
bytepool/bytepool_test.go:40
Function
TestPoolGC
Test that Pool does not hold pointers to previously cached resources
pool/pool_test.go:65
Function
TestPoolNew
(t *testing.T)
pool/pool_test.go:40
Function
TestPoolStress
(t *testing.T)
pool/pool_test.go:91
Function
TestRate
(t *testing.T)
spacesaving/rate_test.go:73
Function
TestRate
(t *testing.T)
tokenbucket/bucket_test.go:42
Function
TestRate
(t *testing.T)
ewma/rate_test.go:64
Function
TestRateCoverErrors
(t *testing.T)
ewma/rate_test.go:82
Function
TestRateGetAll
(t *testing.T)
spacesaving/rate_test.go:104
Function
TestRateGetAllCover
(t *testing.T)
spacesaving/rate_test.go:141
Function
TestSetGetRemoveBulk
(t *testing.T)
kt/kt_base_test.go:255
Function
TestSyncGet
(t *testing.T)
circularbuffer/circularbuffer_test.go:22
Function
TestSyncOverflow
(t *testing.T)
circularbuffer/circularbuffer_test.go:41
Function
TestSyncOverflowEvictCallback
(t *testing.T)
circularbuffer/circularbuffer_test.go:131
Function
TestSyncPop
(t *testing.T)
circularbuffer/circularbuffer_test.go:89
Function
TestZeroLength
(t *testing.T)
lrucache/lrucache_test.go:222
Method
Touch
(key string)
spacesaving/count.go:24
Method
Touch
(key string, nowTs time.Time)
spacesaving/srate.go:85
Function
base64Decode
Base64 decode each of the field
kt/kt.go:856
Function
identityDecode
Don't do anything, this is pure TSV
kt/kt.go:851
Function
init
()
kt/kt.go:38
Function
main
()
spacesaving/tools/topdns.go:29
Function
main
()
spacesaving/tools/readpcap.go:29
Function
main
()
spacesaving/tools/perfect.go:28
Function
main
()
spacesaving/tools/main.go:17
Function
main
()
lrucache/benchmark/main.go:26
← previous
next →
201–300 of 305, ranked by callers