MCPcopy Create free account

hub / github.com/olric-data/olric / functions

Functions1,316 in github.com/olric-data/olric

⨍ Functions 1,316◇ Types & classes 192
↓ 3 callersFunctionParseDestroyCommand
(cmd redcon.Command)
internal/protocol/dmap.go:509
↓ 3 callersFunctionParseFloat
(b []byte, bitSize int)
internal/util/strconv.go:43
↓ 3 callersFunctionParseGetCommand
(cmd redcon.Command)
internal/protocol/dmap.go:244
↓ 3 callersFunctionParseGetEntryCommand
(cmd redcon.Command)
internal/protocol/dmap.go:295
↓ 3 callersFunctionParseGetPutCommand
(cmd redcon.Command)
internal/protocol/dmap.go:740
↓ 3 callersFunctionParseLengthOfPartCommand
(cmd redcon.Command)
internal/protocol/system.go:144
↓ 3 callersFunctionParsePingCommand
(cmd redcon.Command)
internal/protocol/system.go:49
↓ 3 callersFunctionParsePubSubChannelsCommand
(cmd redcon.Command)
internal/protocol/pubsub.go:177
↓ 3 callersFunctionParseStatsCommand
(cmd redcon.Command)
internal/protocol/system.go:188
↓ 3 callersFunctionPass
()
internal/checkpoint/checkpoint.go:28
↓ 3 callersMethodPing
Ping sends a ping message to an Olric node. Returns PONG if a message is empty, otherwise return a copy of the message as bulk. This command is often
cluster_client.go:506
↓ 3 callersMethodPsubscribe
Psubscribe a connection to PubSub
internal/pubsub/pubsub.go:53
↓ 3 callersMethodPubSubChannels
(ctx context.Context, pattern string)
pubsub.go:70
↓ 3 callersMethodRoutingTable
RoutingTable returns the latest version of the routing table.
cluster_client.go:527
↓ 3 callersMethodSetCoefficient
(cf uint64)
internal/kvstore/table/table.go:89
↓ 3 callersMethodSetLevel
SetLevel sets verbosity level.
pkg/flog/flog.go:70
↓ 3 callersMethodSetLocal
()
internal/protocol/dmap.go:494
↓ 3 callersMethodSetTTL
(ttl int64)
internal/kvstore/entry/entry.go:58
↓ 3 callersMethodSetupNetworkConfig
SetupNetworkConfig tries to find an appropriate bindIP to bind and propagate.
config/network.go:134
↓ 3 callersMethodShowLineNumber
ShowLineNumber enables line number support if show is bigger than zero.
pkg/flog/flog.go:78
↓ 3 callersMethodStats
Stats returns stats.Stats with the given options.
cluster_client.go:552
↓ 3 callersMethodUint
()
get_response.go:92
↓ 3 callersMethodValue
()
internal/kvstore/entry/entry.go:54
↓ 3 callersMethodatomicIncrDecr
(cmd string, e *env, delta int)
internal/dmap/atomic.go:48
↓ 3 callersFunctionbkey
(i int)
internal/kvstore/table/pack_test.go:27
↓ 3 callersMethodbreakLoop
(sign uint64)
internal/cluster/balancer/balancer.go:128
↓ 3 callersFunctioncheckBackupOwnership
(e *environment.Environment)
internal/cluster/balancer/balancer_test.go:193
↓ 3 callersFunctiondefaultRedisOptions
(c *Config)
internal/server/server_test.go:93
↓ 3 callersMethoddeleteKeys
(ctx context.Context, keys ...string)
internal/dmap/delete.go:142
↓ 3 callersMethoddeleteOnCluster
deleteOnCluster is not a thread-safe function
internal/dmap/delete.go:92
↓ 3 callersMethodfetchRoutingTable
fetchRoutingTable updates the cluster routing table by fetching the latest version from the cluster. It initializes the partition count if it's the fi
cluster_client.go:757
↓ 3 callersMethodjanitorWorker
()
internal/dmap/janitor.go:82
↓ 3 callersMethodload
(dc *config.DMaps, name string)
internal/dmap/config.go:35
↓ 3 callersMethodmakeGetResponse
(cmd *redis.StringCmd)
cluster_client.go:168
↓ 3 callersFunctionmapToRoutingTable
(slice []interface{})
cluster.go:33
↓ 3 callersFunctionnewMockCluster
(t *testing.T)
internal/cluster/balancer/balancer_test.go:77
↓ 3 callersFunctionnewServerWithPreConditionFunc
(t *testing.T, precond func(conn redcon.Conn, cmd redcon.Command) bool)
internal/server/server_test.go:50
↓ 3 callersMethodping
(ctx context.Context, addr, message string)
ping.go:27
↓ 3 callersMethodremoveScannedOwner
(idx int)
cluster_iterator.go:129
↓ 3 callersFunctionresetPubSubStats
()
stats_test.go:32
↓ 3 callersFunctionrespEcho
(t *testing.T, s *Server)
internal/server/handler_test.go:29
↓ 3 callersMethodshutdown
()
internal/cluster/balancer/balancer_test.go:142
↓ 3 callersMethodtryWithInterval
(ctx context.Context, interval time.Duration, f func() error)
internal/cluster/routingtable/discovery.go:77
↓ 3 callersMethodupdateIterator
(keys []string, cursor uint64, owner string)
cluster_iterator.go:104
↓ 3 callersMethodupdateRouting
()
internal/cluster/routingtable/routingtable.go:235
↓ 3 callersMethodvalidateFragmentPack
(fp *fragmentPack)
internal/dmap/balance.go:82
↓ 3 callersMethodvalueToVersion
(value storage.Entry)
internal/dmap/get.go:108
↓ 2 callersFunctionAllPassed
()
internal/checkpoint/checkpoint.go:32
↓ 2 callersFunctionCollectRuntime
CollectRuntime is a StatsOption for collecting Go runtime statistics from a cluster member.
client.go:263
↓ 2 callersMethodCommand
(ctx context.Context)
internal/protocol/pubsub.go:168
↓ 2 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:233
↓ 2 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:284
↓ 2 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:369
↓ 2 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:499
↓ 2 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:728
↓ 2 callersMethodCommand
(ctx context.Context)
internal/protocol/system.go:134
↓ 2 callersFunctionDecode
(data []byte)
internal/kvstore/table/pack.go:55
↓ 2 callersMethodDestroy
Destroy flushes the given DMap on the cluster. You should know that there is no global lock on DMaps. So if you call Put, Put with EX and Destroy meth
internal/dmap/destroy.go:72
↓ 2 callersMethodDrop
Drop drops a table with its index from the storage engine instance and frees allocated resources.
pkg/storage/engine.go:47
↓ 2 callersFunctionEX
EX sets the specified expire time, in seconds.
client.go:72
↓ 2 callersFunctionEXAT
EXAT sets the specified Unix time at which the key will expire, in seconds.
client.go:88
↓ 2 callersFunctionEncode
(t *Table)
internal/kvstore/table/pack.go:34
↓ 2 callersMethodEncode
()
events/cluster_events.go:92
↓ 2 callersMethodEncode
()
events/cluster_events.go:115
↓ 2 callersMethodFloat64
()
get_response.go:146
↓ 2 callersFunctionGetError
(prefix string)
internal/protocol/errors.go:55
↓ 2 callersFunctionGetPrefix
(err error)
internal/protocol/errors.go:70
↓ 2 callersMethodGetRawKey
(hkey uint64)
internal/kvstore/table/table.go:212
↓ 2 callersMethodHandle
Handle registers the handler for the given command. If a handler already exists for command, Handle panics.
internal/server/mux.go:62
↓ 2 callersMethodImport
Import imports an encoded table of the storage engine implementation and calls f for every Entry item in that table.
pkg/storage/engine.go:106
↓ 2 callersMethodIncr
Incr atomically increments key by delta. The return value is the new value after being incremented or an error.
internal/dmap/atomic.go:97
↓ 2 callersMethodInt64
()
get_response.go:83
↓ 2 callersMethodLength
()
internal/cluster/partitions/partition.go:81
↓ 2 callersFunctionLoad
Load reads and loads Olric configuration.
config/load.go:259
↓ 2 callersMethodMarshalBinary
()
internal/resp/encoder_test.go:17
↓ 2 callersFunctionMemberID
(name string, birthdate int64)
internal/discovery/member.go:60
↓ 2 callersFunctionNew
New creates a new Olric instance, otherwise returns an error.
olric.go:195
↓ 2 callersFunctionNewAuth
NewAuth creates and returns a new Auth instance initialized with the given password.
internal/protocol/system.go:212
↓ 2 callersFunctionNewConnContext
NewConnContext initializes and returns a new instance of ConnContext for managing connection states like authentication.
internal/server/server.go:65
↓ 2 callersMethodNewDMap
NewDMap creates and returns a new DMap instance. It checks member count quorum and bootstrapping status before creating a new DMap.
internal/dmap/dmap.go:67
↓ 2 callersFunctionNewEngineConfig
(t *testing.T)
internal/testutil/testutil.go:57
↓ 2 callersFunctionNewMemberlistConfig
NewMemberlistConfig returns a new memberlist.Config for a given environment. It takes an env parameter: local, lan and wan. local: DefaultLocalConfi
config/memberlist.go:60
↓ 2 callersFunctionNewPSubscribe
(patterns ...string)
internal/protocol/pubsub.go:125
↓ 2 callersFunctionNewPubSubNumpat
()
internal/protocol/pubsub.go:191
↓ 2 callersFunctionNewPubSubNumsub
(channels ...string)
internal/protocol/pubsub.go:213
↓ 2 callersFunctionNewPublish
(channel, message string)
internal/protocol/pubsub.go:30
↓ 2 callersFunctionNewSubscribe
(channels ...string)
internal/protocol/pubsub.go:91
↓ 2 callersFunctionPXAT
PXAT sets the specified Unix time at which the key will expire, in milliseconds.
client.go:96
↓ 2 callersFunctionParseDecrCommand
(cmd redcon.Command)
internal/protocol/dmap.go:691
↓ 2 callersFunctionParseDelCommand
(cmd redcon.Command)
internal/protocol/dmap.go:339
↓ 2 callersFunctionParseExpireCommand
(cmd redcon.Command)
internal/protocol/dmap.go:465
↓ 2 callersFunctionParseIncrByFloatCommand
(cmd redcon.Command)
internal/protocol/dmap.go:785
↓ 2 callersFunctionParseIncrCommand
(cmd redcon.Command)
internal/protocol/dmap.go:658
↓ 2 callersFunctionParseLockLeaseCommand
(cmd redcon.Command)
internal/protocol/dmap.go:953
↓ 2 callersFunctionParseMoveFragmentCommand
(cmd redcon.Command)
internal/protocol/system.go:78
↓ 2 callersFunctionParsePExpireCommand
(cmd redcon.Command)
internal/protocol/dmap.go:424
↓ 2 callersFunctionParsePLockLeaseCommand
(cmd redcon.Command)
internal/protocol/dmap.go:997
↓ 2 callersFunctionParsePSubscribeCommand
(cmd redcon.Command)
internal/protocol/pubsub.go:140
↓ 2 callersFunctionParsePubSubNumpatCommand
(cmd redcon.Command)
internal/protocol/pubsub.go:201
↓ 2 callersFunctionParsePubSubNumsubCommand
(cmd redcon.Command)
internal/protocol/pubsub.go:228
← previousnext →301–400 of 1,316, ranked by callers