MCPcopy Create free account

hub / github.com/alphazero/Go-Redis / functions

Functions562 in github.com/alphazero/Go-Redis

MethodZrevrange
Redis ZREVRANGE command.
asynchclient.go:820
MethodZscore
Redis ZSCORE command.
redis.go:279
MethodZscore
Redis ZSCORE command.
redis.go:491
MethodZscore
Redis ZSCORE command.
synchclient.go:782
MethodZscore
Redis ZSCORE command.
asynchclient.go:791
Function_test_compareStringArrays
func _test_getDefaultSyncClient() (redis.Client, redis.Error) { spec := redis.DefaultSpec() spec.Db(13).Password("go-redis") return redis.NewSynchC
test/0data_test.go:95
Function_test_getDefConnSpec
---------------------------------------------------------------------- test data setup ---------------------------------------------------------------
test/0data_test.go:26
Function_test_reverseBytes
(in []byte)
test/0data_test.go:107
Functioncomma
(idx, cnt int)
test/gen/generate.go:235
FunctionconcatAndGetBytes
REVU - this is buggy in conjunction with callsite usage (when arr is nil) deprecated - TODO convert asynchclient.go to use appendAndConvert
synchclient.go:634
Methodconnect
---------------------------------------------------------------------------- asyncConnHdl internal ops -----------------------------------------------
connection.go:668
FunctiondbRspProcessingTask
Task: process one pending response at a time - can be interrupted while waiting on the pending responses queue - buffered reader takes care of minimiz
connection.go:863
Methoddisconnect
REVU - TODO opt 2 for Quit here panics
connection.go:674
FunctiondoDecr
(id string, signal chan int, client redis.Client, cnt int)
bench/gosynchclient.go:136
FunctiondoDecr
(id string, signal chan int, client redis.AsyncClient, cnt int)
bench/asyncbench.go:156
FunctiondoGet
(id string, signal chan int, client redis.Client, cnt int)
bench/gosynchclient.go:151
FunctiondoGet
(id string, signal chan int, client redis.AsyncClient, cnt int)
bench/asyncbench.go:173
FunctiondoIncr
(id string, signal chan int, client redis.Client, cnt int)
bench/gosynchclient.go:129
FunctiondoIncr
(id string, signal chan int, client redis.AsyncClient, cnt int)
bench/asyncbench.go:141
FunctiondoLpop
(id string, signal chan int, client redis.Client, cnt int)
bench/gosynchclient.go:166
FunctiondoLpop
(id string, signal chan int, client redis.AsyncClient, cnt int)
bench/asyncbench.go:188
FunctiondoLpush
(id string, signal chan int, client redis.Client, cnt int)
bench/gosynchclient.go:158
FunctiondoLpush
(id string, signal chan int, client redis.AsyncClient, cnt int)
bench/asyncbench.go:180
FunctiondoPing
---------------------------------------------------------------------------- redis tasks -------------------------------------------------------------
bench/gosynchclient.go:123
FunctiondoPing
---------------------------------------------------------------------------- redis tasks -------------------------------------------------------------
bench/asyncbench.go:133
FunctiondoRpop
(id string, signal chan int, client redis.Client, cnt int)
bench/gosynchclient.go:182
FunctiondoRpop
(id string, signal chan int, client redis.AsyncClient, cnt int)
bench/asyncbench.go:204
FunctiondoRpush
(id string, signal chan int, client redis.Client, cnt int)
bench/gosynchclient.go:174
FunctiondoRpush
(id string, signal chan int, client redis.AsyncClient, cnt int)
bench/asyncbench.go:196
FunctiondoSet
(id string, signal chan int, client redis.Client, cnt int)
bench/gosynchclient.go:143
FunctiondoSet
(id string, signal chan int, client redis.AsyncClient, cnt int)
bench/asyncbench.go:165
FunctionheartbeatTask
Task: "One PING only" after receiving a timed tick per ConnectionsSpec period - can be interrupted while waiting on ticker - uses TryGet on PING respo
connection.go:828
Functioninit
()
test/gen/generate.go:21
FunctionisFuture
(v string)
test/gen/generate.go:249
FunctionisQuit
(v string)
test/gen/generate.go:256
FunctionisRedisError
(v string)
test/gen/generate.go:242
Functionmain
()
test/gen/generate.go:37
Functionmain
PubSub - PubSub message publisher example demonstrates publishing messages via Redis PubSub's PUBLISH command. Both sync and async client examples a
examples/publisher.go:36
Functionmain
* hello world, redis style. */
examples/ciao.go:30
Functionmain
()
bench/gosynchclient.go:26
Functionmain
---------------------------------------------------------------------------- benchmarker -------------------------------------------------------------
bench/asyncbench.go:50
Functionmain
()
bench/synchclient.go:33
Functionmain
Checks Redis client interfaces' methods against a a list of canonical Redis methods obtained from a spec file and reports the missing methods
compliance/compliance.go:42
FunctionmanagementTask
---------------------------------------------------------------------------- asynchronous tasks (go routine/workers) ---------------------------------
connection.go:778
FunctionmsgProcessingTask
Task: process one incoming Redis PubSub message at a time - can be interrupted while waiting on the net read
connection.go:906
MethodonError
(e Error)
future.go:120
MethodonError
(e Error)
future.go:148
MethodonError
(e Error)
future.go:180
MethodonError
(e Error)
future.go:208
MethodonError
(e Error)
future.go:236
FunctionpackArrays
(a0 []byte, arr ...[]byte)
synchclient.go:652
FunctionreqProcessingTask
Pending further tests, this addresses bug in earlier version and can be interrupted
connection.go:958
Methodset
onError (Error);
future.go:113
Methodset
(v []byte)
future.go:121
Methodset
onError (Error);
future.go:141
Methodset
(v [][]byte)
future.go:151
Methodset
(v bool)
future.go:181
Methodset
onError (execErr Error);
future.go:201
Methodset
(v string)
future.go:209
Methodset
onError (execErr Error);
future.go:229
Methodset
(v int64)
future.go:237
FunctionzvTest
(tname string)
test/gen/generate.go:218
← previous501–562 of 562, ranked by callers