MCPcopy Create free account

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

Functions562 in github.com/alphazero/Go-Redis

⨍ Functions 562◇ Types & classes 70
↓ 68 callersMethodServiceRequest
(cmd *Command, args [][]byte)
connection.go:164
↓ 67 callersMethodQueueRequest
(cmd *Command, args [][]byte)
connection.go:175
↓ 19 callersMethodError
()
error.go:108
↓ 16 callersFunctionappendAndConvert
REVU - use this instead of concatAndGetBytes TODO - for asynch
synchclient.go:644
↓ 16 callersFunctionnewSystemErrorWithCause
(msg string, cause error)
error.go:62
↓ 15 callersMethodGet
Redis GET command.
redis.go:120
↓ 15 callersMethodGetMultiBulkData
()
protocol.go:177
↓ 15 callersMethodSet
Redis SET command.
redis.go:126
↓ 14 callersMethodQuit
Redis QUIT command.
redis.go:117
↓ 13 callersMethodGetBooleanValue
()
protocol.go:173
↓ 13 callersMethodGetNumberValue
()
protocol.go:174
↓ 13 callersFunctionNewClient
(t *testing.T)
test/support.go:80
↓ 12 callersMethodGetBulkData
()
protocol.go:176
↓ 12 callersFunctionflushAndQuitOnCompletion
(t *testing.T, client redis.Client)
test/sync_test.go:10
↓ 11 callersMethodFlushdb
Redis FLUSHDB command.
redis.go:300
↓ 11 callersMethodset
onError (Error);
future.go:173
↓ 10 callersMethodPassword
Sets the password for connection spec and returns the reference Note that you should not this after you have already connected.
connection.go:139
↓ 10 callersFunctionnewSystemErrorf
(format string, args ...interface{})
error.go:58
↓ 10 callersFunctionsend
creates a result struct using the provided references and sends it on the specified channel.
future.go:40
↓ 9 callersFunctionassertCtlByte
panics on error (with redis.Error)
protocol.go:262
↓ 9 callersFunctionreport
(cmd string, delta time.Duration, cnt int)
bench/synchclient.go:90
↓ 7 callersMethodDb
Sets the db for connection spec and returns the reference Note that you should not this after you have already connected.
connection.go:118
↓ 7 callersFunctiongetTestConnSpec
Test ConnectionSpec uses redis db 13 and assumes AUTH password go-redis
test/support.go:89
↓ 7 callersFunctionnewSystemError
(msg string)
error.go:55
↓ 5 callersMethodLpush
Redis LPUSH command.
redis.go:192
↓ 5 callersMethodPing
Redis PING command.
redis.go:147
↓ 5 callersMethodTryGet
(timeoutnano time.Duration)
future.go:175
↓ 5 callersFunction_test_compareByteArrays
(got, expected []byte)
test/0data_test.go:115
↓ 5 callersFunctionassertNotError
panics on error (with redis.Error)
protocol.go:269
↓ 5 callersFunctionreceive
blocks on the channel until a result is received. If the received result reference's e (error) field is not null, it will return it.
future.go:48
↓ 5 callersFunctiontryReceive
using a timer blocks on the channel until a result is received. or timeout period expires. if timedout, returns timedout==true. otherwise, If the rece
future.go:68
↓ 4 callersMethodLpop
Redis LPOP command.
redis.go:213
↓ 4 callersMethodString
()
connection.go:471
↓ 4 callersMethodType
Redis TYPE command.
redis.go:123
↓ 4 callersMethodconnect
connect event handler will issue AUTH/SELECT on new connection if required. panics on error (with error)
connection.go:283
↓ 4 callersFunctionnewFutureBool
()
future.go:179
↓ 4 callersFunctionnewFutureBytes
()
future.go:119
↓ 4 callersFunctionreadToCRLF
---------------------------------------------------------------------------- protocol i/o ------------------------------------------------------------
protocol.go:402
↓ 4 callersMethodspec
()
connection.go:475
↓ 4 callersMethodworker
This could find a happy home in a generalized worker package ... TODO
connection.go:715
↓ 3 callersFunctionBtof64
(buff []byte)
synchclient.go:801
↓ 3 callersFunctionCreateRequestBytes
---------------------------------------------------------------------------- Services ----------------------------------------------------------------
protocol.go:60
↓ 3 callersFunctionDefaultSpec
Creates a ConnectionSpec using default settings. using the DefaultXXX consts of redis package.
connection.go:97
↓ 3 callersMethodGet
()
redisfutures.go:22
↓ 3 callersMethodGet
()
future.go:230
↓ 3 callersFunctionGetKeyType
Returns KeyType by name
specification.go:47
↓ 3 callersMethodIncr
Redis INCR command.
redis.go:159
↓ 3 callersMethodString
()
protocol.go:311
↓ 3 callersMethodTryGet
(timeoutnano time.Duration)
redisfutures.go:23
↓ 3 callersFunctioncompareByteArrays
(got, expected []byte)
test/support.go:9
↓ 3 callersFunctiondebug
TEMP: should default to false
redis.go:642
↓ 3 callersFunctionisSystemError
(e interface{})
error.go:135
↓ 3 callersFunctionparseInfo
(buff []byte)
synchclient.go:191
↓ 3 callersFunctionreadBulkData
Reads a multibulk response of given expected elements. panics on errors (with redis.Error)
protocol.go:423
↓ 3 callersFunctiontestspec_ft
create the test spec (test data for now)
future_test.go:21
↓ 2 callersMethodDecr
Redis DECR command.
redis.go:165
↓ 2 callersMethodExists
Redis EXISTS command.
redis.go:138
↓ 2 callersMethodGet
()
future.go:142
↓ 2 callersMethodGet
()
future.go:174
↓ 2 callersMethodGetMessage
()
protocol.go:172
↓ 2 callersFunctionGetResponse
---------------------------------------------------------------------------- response processing -----------------------------------------------------
protocol.go:209
↓ 2 callersMethodGetStringValue
()
protocol.go:175
↓ 2 callersMethodIsError
()
protocol.go:171
↓ 2 callersMethodKeys
Redis KEYS command.
redis.go:135
↓ 2 callersMethodMget
Redis MGET command.
redis.go:156
↓ 2 callersMethodMget
Redis MGET command.
redis.go:377
↓ 2 callersMethodProtocol
return the address as string.
connection.go:151
↓ 2 callersMethodPublish
Redis PUBLISH command. Publishes a message to the named channels. This is a blocking call. Returns the number of PubSub subscribers that received th
redis.go:319
↓ 2 callersMethodRpop
Redis RPOP command.
redis.go:219
↓ 2 callersMethodRpush
Redis RPUSH command.
redis.go:189
↓ 2 callersMethodSadd
Redis SADD command.
redis.go:231
↓ 2 callersMethodServiceRequest
Implementation of SyncConnection.ServiceRequest.
connection.go:335
↓ 2 callersMethodSet
Redis SET command.
redis.go:347
↓ 2 callersFunctionSetFutureResult
Sets the type specific result value from the response for the future reference based on the command type.
protocol.go:115
↓ 2 callersMethodSetnx
Redis SETNX command.
redis.go:150
↓ 2 callersMethodString
Returns minimal info string for logging, etc
connection.go:218
↓ 2 callersMethodSubscriptions
return the subscribed channel ids, whether specificly named, or pattern based.
redis.go:591
↓ 2 callersFunctionanalyzeAndReport
Get the defined methods for the specified client type and report compliance
compliance/compliance.go:71
↓ 2 callersFunctionanyClientNilResultValueSpec
spec.NoNilResultValue Specs MethodSpec.NoNilResultValue - client type invariant
specification.go:259
↓ 2 callersFunctionanyClientRedisErrSpec
spec.NoRedisErr Specs MethodSpec.NoRedisErr - client type invariant
specification.go:246
↓ 2 callersFunctionconvAndSplit
(buff []byte)
synchclient.go:136
↓ 2 callersFunctionnewAsyncConnHdl
Creates a new asyncConnHdl with a new connHdl as its delegated 'super'. Note it does not start the processing goroutines for the channels. REVU - Pub
connection.go:483
↓ 2 callersFunctionnewConnHdl
Creates and opens a new connection to server per ConnectionSpec. The new connection is wrapped by a new connHdl with its bufio.Reader delegating to th
connection.go:227
↓ 2 callersFunctionnewPubSubAck
(Type PubSubMType, topic string, scnt int)
protocol.go:328
↓ 2 callersFunctionnewRedisError
(msg string)
error.go:98
↓ 2 callersMethodonError
(Error)
future.go:106
↓ 2 callersFunctiononRecover
---------------------------------------------------------------------- error handling helper functions -----------------------------------------------
error.go:116
↓ 2 callersMethodprocessAsyncRequest
---------------------------------------------------------------------------- asyncConnHdl internal ops -----------------------------------------------
connection.go:1017
↓ 2 callersFunctionquickConfAll
(method string)
test/support.go:46
↓ 2 callersFunctionreadMultiBulkData
Reads a multibulk response of given expected elements. The initial *num\r\n is assumed to have been consumed. panics on errors (with redis.Error)
protocol.go:443
↓ 2 callersFunctionsendRequest
---------------------------------------------------------------------------- request processing ------------------------------------------------------
protocol.go:146
↓ 2 callersMethodstartup
responsible for managing the various moving parts of the asyncConnHdl
connection.go:681
↓ 1 callersMethodAllKeys
Redis KEYS command using "*" wildcard
redis.go:132
↓ 1 callersMethodCause
()
error.go:46
↓ 1 callersFunctionCreateFuture
Creates a specific Future type for the given Redis command and returns it as a generic reference.
protocol.go:92
↓ 1 callersFunctionFlushAsyncClient
(t *testing.T, client redis.AsyncClient)
test/support.go:108
↓ 1 callersFunctionFlushClient
(t *testing.T, client redis.Client)
test/support.go:122
↓ 1 callersFunctionGetPubSubResponse
---------------------------------------------------------------------------- PubSub message processing -----------------------------------------------
protocol.go:349
↓ 1 callersMethodGetset
Redis GETSET command.
redis.go:153
↓ 1 callersMethodHost
Sets the host for connection spec and returns the reference Note that you should not this after you have already connected.
connection.go:125
next →1–100 of 562, ranked by callers