Functions — github.com/alphazero/Go-Redis

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

Functions562 in github.com/alphazero/Go-Redis

⨍ Functions 562◇ Types & classes 70

↓ 1 callersMethodKeys

Redis KEYS command.

synchclient.go:119

↓ 1 callersMethodKeys

Redis KEYS command.

asynchclient.go:125

↓ 1 callersFunctionNewAsyncClient

---------------------------------------------------------------------- Client factories --------------------------------------------------------------

test/support.go:68

↓ 1 callersFunctionNewAsyncClientWithSpec

(t *testing.T, spec *redis.ConnectionSpec)

test/support.go:72

↓ 1 callersFunctionNewAsynchClientWithSpec

Create a new asynClient and connects to the Redis server using the specified ConnectionSpec.

asynchclient.go:42

↓ 1 callersFunctionNewAsynchConnection

Creates and opens a new AsyncConnection and starts the goroutines for request and response processing interaction with redis (AUTH &| SELECT)

connection.go:524

↓ 1 callersFunctionNewPubSubClientWithSpec

(spec *ConnectionSpec)

pubsubclient.go:32

↓ 1 callersFunctionNewPubSubConnection

(spec *ConnectionSpec)

connection.go:541

↓ 1 callersFunctionNewSyncConnection

Creates a new SyncConnection using the provided ConnectionSpec. Note that this function will also connect to the specified redis server.

connection.go:320

↓ 1 callersFunctionNewSynchClientWithSpec

Create a new syncClient and connects to the Redis server using the specified ConnectionSpec.

synchclient.go:52

↓ 1 callersMethodPort

Sets the port for connection spec and returns the reference Note that you should not this after you have already connected.

connection.go:132

↓ 1 callersFunctionQuitAsyncClient

(t *testing.T, client redis.AsyncClient)

test/support.go:130

↓ 1 callersFunctionQuitClient

(t *testing.T, client redis.Client)

test/support.go:144

↓ 1 callersMethodRename

Redis RENAME command.

redis.go:141

↓ 1 callersMethodSave

Redis SAVE command.

redis.go:129

↓ 1 callersMethodSubscriptions

()

pubsubclient.go:65

↓ 1 callersMethodZadd

Redis ZADD command.

redis.go:270

↓ 1 callersFunctionasyncClientMethodSpec

(defspec *MethodSpec, method string)

specification.go:281

↓ 1 callersFunctionasyncFlushAndQuitOnCompletion

(t *testing.T, client redis.AsyncClient)

test/async_test.go:14

↓ 1 callersFunctionasyncPublish

(spec *redis.ConnectionSpec, channel string)

examples/publisher.go:77

↓ 1 callersFunctionbenchTask

(taskspec taskSpec, iterations int, workers int, printReport bool)

bench/gosynchclient.go:72

↓ 1 callersFunctionbenchTask

Use a single redis.AsyncClient with specified number of workers to bench concurrent load on the async client

bench/asyncbench.go:70

↓ 1 callersFunctioncleanup

(data []byte)

test/gen/generate.go:84

↓ 1 callersFunctionconfigureConn

(conn net.Conn, spec *ConnectionSpec)

connection.go:266

↓ 1 callersMethoddisconnect

disconnects from net connections and sets connected state to false panics on net error (with error)

connection.go:305

↓ 1 callersFunctiondoGet

(client redis.Client, cnt int)

bench/synchclient.go:127

↓ 1 callersFunctiondoIncr

(client redis.Client, cnt int)

bench/synchclient.go:106

↓ 1 callersFunctiondoLpop

(client redis.Client, cnt int)

bench/synchclient.go:168

↓ 1 callersFunctiondoLpush

(client redis.Client, cnt int)

bench/synchclient.go:148

↓ 1 callersFunctiondoOne

(cnt int)

bench/synchclient.go:40

↓ 1 callersFunctiondoPing

(client redis.Client, cnt int)

bench/synchclient.go:97

↓ 1 callersFunctiondoRpop

(client redis.Client, cnt int)

bench/synchclient.go:177

↓ 1 callersFunctiondoRpush

(client redis.Client, cnt int)

bench/synchclient.go:158

↓ 1 callersFunctiondoSadd

(client redis.Client, cnt int)

bench/synchclient.go:137

↓ 1 callersFunctiondoSet

(client redis.Client, cnt int)

bench/synchclient.go:116

↓ 1 callersFunctionfailedTest

(msg string)

bench/synchclient.go:29

↓ 1 callersFunctionfuncmap

()

test/gen/generate.go:208

↓ 1 callersFunctiongetDefinedMethods

Reflect over the methods defined in redis.Client and send back as []string (tolowercase) TOOD get rid of redundant code in switch (REVU: needs minor u

compliance/compliance.go:118

↓ 1 callersFunctiongetMethodInArgs

(m reflect.Method)

test/gen/generate.go:133

↓ 1 callersFunctiongetMethodOutArgs

(m reflect.Method)

test/gen/generate.go:142

↓ 1 callersFunctiongetMethodOutArgsWIP

(m reflect.Method)

test/gen/generate.go:152

↓ 1 callersFunctiongetSpecFileName

Reads the spec file to use for the check csmetafile is the name of the expected prop file and should contain just the name of another file.

compliance/compliance.go:156

↓ 1 callersFunctiongetSubjects

()

test/gen/generate.go:201

↓ 1 callersFunctiongetTestReaderAndMessages

()

test/protocol_test.go:76

↓ 1 callersFunctiongofmt

(path string)

test/gen/generate.go:64

↓ 1 callersFunctionisGenericError

(e interface{})

error.go:129

↓ 1 callersFunctionisNetError

(e interface{})

error.go:148

↓ 1 callersFunctionisRedisError

(e interface{})

error.go:142

↓ 1 callersFunctionloadMethodTestTemplate

(subject reflect.Type)

test/gen/generate.go:94

↓ 1 callersFunctionmakeConcurrentClients

(workers int)

bench/gosynchclient.go:98

↓ 1 callersFunctionnewFutureBytesArray

()

future.go:147

↓ 1 callersFunctionnewFutureFloat64

(future FutureBytes)

future.go:263

↓ 1 callersFunctionnewFutureInfo

(future FutureBytes)

redisfutures.go:58

↓ 1 callersFunctionnewFutureInt64

()

future.go:235

↓ 1 callersFunctionnewFutureKeyType

(future FutureString)

redisfutures.go:87

↓ 1 callersFunctionnewFutureKeys

(future FutureBytes)

redisfutures.go:29

↓ 1 callersFunctionnewFutureString

()

future.go:207

↓ 1 callersFunctionnewMessage

(topic string, Body []byte)

protocol.go:320

↓ 1 callersFunctionnewSubcribeAck

(topic string, scnt int)

protocol.go:336

↓ 1 callersFunctionnewUnsubcribeAck

(topic string, scnt int)

protocol.go:340

↓ 1 callersMethodnextId

request id needs to be unique in context of associated connection only one goroutine calls this so no need to provide concurrency guards

connection.go:1050

↓ 1 callersFunctiononError

(msg string, e error)

bench/synchclient.go:25

↓ 1 callersFunctionpubsubClientMethodSpec

(defspec *MethodSpec, method string)

specification.go:291

↓ 1 callersFunctionreadCommandsFromSpecFile

Fully reads the file named (specfile) and converts content to a []string. It is expected that the file is a simple list of redis commands, each on a

compliance/compliance.go:99

↓ 1 callersFunctionrenderFeatureTest

(w io.Writer, ctype reflect.Type, m reflect.Method, t *template.Template)

test/gen/generate.go:185

↓ 1 callersFunctionreport

(cmd string, delta time.Duration, cnt int)

bench/gosynchclient.go:112

↓ 1 callersFunctionreport

(cmd string, workers int, delta time.Duration, cnt int)

bench/asyncbench.go:122

↓ 1 callersFunctionreportCompliance

check method name map against spec'd method names and report undefined methods

compliance/compliance.go:82

↓ 1 callersFunctionsetup

(client redis.AsyncClient)

bench/asyncbench.go:107

↓ 1 callersFunctionsyncClientMethodSpec

(defspec *MethodSpec, method string)

specification.go:271

↓ 1 callersFunctionsyncPublish

(spec *redis.ConnectionSpec, channel string)

examples/publisher.go:56

↓ 1 callersFunctionverifyMessage

verifies obtained message against expected Note: func uses t.Errorf and NOT Fatalf.

test/protocol_test.go:47

↓ 1 callersFunctionverifyOrCreateDir

(ctype reflect.Type)

test/gen/generate.go:77

↓ 1 callersFunctionwithError

---------------------------------------------------------------------- temp legacy junk --------------------------------------------------------------

error.go:169

↓ 1 callersFunctionwriteTestFile

(path string, data []byte, subject reflect.Type, method reflect.Method)

test/gen/generate.go:106

MethodAllKeys

Redis KEYS command using "*" wildcard

Redis BGSAVE command.

redis.go:309

MethodBgsave

Redis BGSAVE command.

redis.go:512

MethodBgsave

Redis BGSAVE command.

synchclient.go:918

MethodBgsave

Redis BGSAVE command.

Redis BRPOPLPUSH command.

redis.go:228

MethodBrpoplpush

Redis BRPOPLPUSH command.

synchclient.go:548

MethodBrpoplpush

Redis BRPOPLPUSH command.

Redis DBSIZE command.

redis.go:180

MethodDbsize

Redis DBSIZE command.

redis.go:401

MethodDbsize

Redis DBSIZE command.

synchclient.go:347

MethodDbsize

Redis DBSIZE command.

Redis DECRBY command.

redis.go:168

← previous next →101–200 of 562, ranked by callers