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
↓ 2 callersFunctionParsePublishInternalCommand
(cmd redcon.Command)
internal/protocol/pubsub.go:76
↓ 2 callersFunctionParsePutEntryCommand
(cmd redcon.Command)
internal/protocol/dmap.go:203
↓ 2 callersFunctionParseSubscribeCommand
(cmd redcon.Command)
internal/protocol/pubsub.go:106
↓ 2 callersFunctionParseUnlockCommand
(cmd redcon.Command)
internal/protocol/dmap.go:915
↓ 2 callersFunctionParseUpdateRoutingCommand
(cmd redcon.Command)
internal/protocol/system.go:106
↓ 2 callersMethodPartitionIDByHKey
PartitionIDByHKey returns partition ID for a given HKey.
internal/cluster/partitions/partitions.go:69
↓ 2 callersMethodPing
Ping sends a ping message to an Olric node. Returns PONG if message is empty, otherwise return a copy of the message as a bulk. This command is often
embedded_client.go:364
↓ 2 callersMethodPing
Ping sends a ping message to an Olric node. Returns PONG if message is empty, otherwise return a copy of the message as a bulk. This command is often
client.go:297
↓ 2 callersMethodPrintln
Println calls v.f.logger.Println to print to the logger. Arguments are handled in the manner of fmt.Println.
pkg/flog/flog.go:121
↓ 2 callersMethodPubSubNumPat
(ctx context.Context)
pubsub.go:78
↓ 2 callersMethodPubSubNumSub
(ctx context.Context, channels ...string)
pubsub.go:74
↓ 2 callersMethodRangeHKey
RangeHKey implements a loop for hashed keys(HKeys).
pkg/storage/engine.go:118
↓ 2 callersMethodRefreshMetadata
RefreshMetadata fetches a list of available members and the latest routing table version. It also closes stale clients if there are any.
cluster_client.go:628
↓ 2 callersMethodReset
()
internal/kvstore/table/table.go:436
↓ 2 callersMethodRoutingTable
RoutingTable returns the latest version of the routing table.
embedded_client.go:373
↓ 2 callersMethodSanitize
Sanitize sets default values to empty configuration variables, if it's possible.
config/engine.go:56
↓ 2 callersMethodSetAuthenticated
SetAuthenticated sets the authentication state of the connection to the specified value. It is thread-safe.
internal/server/server.go:70
↓ 2 callersMethodSetLastAccess
(int64)
pkg/storage/entry.go:45
↓ 2 callersMethodSetLastAccess
(lastAccess int64)
internal/kvstore/entry/entry.go:74
↓ 2 callersMethodSetPattern
(pattern string)
internal/protocol/pubsub.go:163
↓ 2 callersMethodSetPreConditionFunc
SetPreConditionFunc sets a precondition function to be executed before serving each command on the server.
internal/server/server.go:177
↓ 2 callersMethodSetRaw
()
internal/protocol/dmap.go:723
↓ 2 callersMethodSetReplica
()
internal/protocol/dmap.go:279
↓ 2 callersMethodSetReplica
()
internal/protocol/dmap.go:364
↓ 2 callersMethodSetReplica
()
internal/protocol/system.go:129
↓ 2 callersMethodShutdown
Shutdown gracefully shuts down the server without interrupting any active connections. Shutdown works by first closing all open listeners, then closin
internal/server/server.go:237
↓ 2 callersFunctionToClusterEvent
(e memberlist.NodeEvent)
internal/discovery/events.go:19
↓ 2 callersMethodTransferIterator
TransferIterator returns a new TransferIterator instance to the caller.
pkg/storage/engine.go:102
↓ 2 callersMethodUnmarshalBinary
(data []byte)
internal/resp/encoder_test.go:21
↓ 2 callersMethodValidate
Validate finds errors in the current configuration.
config/engine.go:48
↓ 2 callersFunctionXX
XX only sets the key if it already exists.
client.go:111
↓ 2 callersFunctionaddrParts
The following functions are mostly extracted from Serf. See setupAgent function in cmd/serf/command/agent/command.go Thanks for the extraordinary soft
config/network.go:31
↓ 2 callersMethodatomicIncrByFloat
(e *env, delta float64)
internal/dmap/atomic.go:171
↓ 2 callersMethodattemptToJoin
()
internal/cluster/routingtable/discovery.go:47
↓ 2 callersFunctionbval
(i int)
internal/kvstore/table/pack_test.go:31
↓ 2 callersMethodcheckPartitionOwnership
(part *partitions.Partition)
stats.go:76
↓ 2 callersMethodclientByPartID
(partID uint64)
cluster_client.go:110
↓ 2 callersMethodcollectPartitionMetrics
(partID uint64, part *partitions.Partition)
stats.go:49
↓ 2 callersFunctionconvertClusterError
(err error)
olric.go:303
↓ 2 callersMethoddec
dec decrements the number of waiters waiting on the lock
internal/locker/locker.go:45
↓ 2 callersMethoddeleteFromPreviousOwners
(key string, owners []discovery.Member)
internal/dmap/delete.go:54
↓ 2 callersMethoddestroyFragmentOnPartition
(part *partitions.Partition)
internal/dmap/destroy_handlers.go:26
↓ 2 callersMethoddestroyOnCluster
(ctx context.Context)
internal/dmap/destroy.go:27
↓ 2 callersMethodevictKeyWithLRU
(e *env)
internal/dmap/eviction.go:207
↓ 2 callersMethodfetchRoutingTable
()
cluster_iterator.go:282
↓ 2 callersMethodfillRoutingTable
()
cluster.go:127
↓ 2 callersMethodfillRoutingTable
()
internal/cluster/routingtable/routingtable.go:212
↓ 2 callersMethodfindCoefficient
(coefficient uint64)
internal/kvstore/kvstore.go:455
↓ 2 callersMethodfloat
(f float64)
internal/resp/encoder.go:136
↓ 2 callersMethodfragmentMergeFunction
(f *fragment, hkey uint64, entry storage.Entry)
internal/dmap/balance.go:38
↓ 2 callersMethodfragmentName
(name string)
internal/dmap/dmap.go:61
↓ 2 callersMethodget
(offset uint64)
internal/kvstore/table/table.go:257
↓ 2 callersFunctiongetBindIP
(ifname, address string)
config/network.go:68
↓ 2 callersMethodgetDMap
getDMap returns an initialized DMap instance, otherwise it returns ErrDMapNotFound.
internal/dmap/dmap.go:50
↓ 2 callersMethodgetOwners
()
cluster_iterator.go:114
↓ 2 callersFunctiongetPrefix
(err error)
internal/protocol/errors.go:62
↓ 2 callersMethodgetPut
(e *env)
internal/dmap/atomic.go:112
↓ 2 callersMethodgetRawKey
(offset uint64)
internal/kvstore/table/table.go:206
↓ 2 callersFunctiongetType
(data interface{})
internal/dmap/service.go:107
↓ 2 callersMethodinc
inc increments the number of waiters waiting for the lock
internal/locker/locker.go:40
↓ 2 callersMethodincrDecrCommon
(cmd, dmap, key string, delta int)
internal/dmap/atomic_handlers.go:24
↓ 2 callersMethodinitContexts
initContexts sets up chained contexts for the pipeline. The base is closedCtx, which is closed either in Close or Discard. ctx is a child of closedCtx
pipeline.go:632
↓ 2 callersMethodisAlive
()
internal/dmap/service.go:97
↓ 2 callersMethodisKeyIdleOnFragment
isKeyIdleOnFragment is not a thread-safe function. It accesses underlying fragment for the given hkey.
internal/dmap/eviction.go:32
↓ 2 callersMethodisOperable
isOperable controls bootstrapping status and cluster quorum to prevent split-brain syndrome.
olric.go:317
↓ 2 callersMethodjanitor
(part *partitions.Partition)
internal/dmap/janitor.go:40
↓ 2 callersMethodloadCurrentAtomicInt
(e *env)
internal/dmap/atomic.go:29
↓ 2 callersMethodloadCursor
(owner string)
cluster_iterator.go:90
↓ 2 callersMethodloadRoute
()
cluster_iterator.go:55
↓ 2 callersMethodmarkBootstrapped
()
internal/cluster/routingtable/routingtable.go:182
↓ 2 callersMethodnewFragment
()
internal/dmap/fragment.go:131
↓ 2 callersFunctionnewPubSub
(client *server.Client, options ...PubSubOption)
pubsub.go:31
↓ 2 callersFunctionpipelineStringValue
(cmd redis.Cmder)
pipeline.go:664
↓ 2 callersMethodpublishEvent
(e events.Event)
internal/dmap/service.go:115
↓ 2 callersMethodpublishNodeJoinEvent
(m *discovery.Member)
internal/cluster/routingtable/events.go:24
↓ 2 callersMethodpublishNodeLeftEvent
(m *discovery.Member)
internal/cluster/routingtable/events.go:45
↓ 2 callersFunctionpubsubTestRunner
(t *testing.T, ps *PubSub, kind, channel string)
pubsub_test.go:27
↓ 2 callersFunctionputPipelineCmdsIntoPool
(cmds []redis.Cmder)
pipeline.go:655
↓ 2 callersMethodresetPage
()
cluster_iterator.go:179
↓ 2 callersMethodroutingTable
(ctx context.Context)
cluster.go:144
↓ 2 callersMethodrunCallbacks
()
internal/cluster/routingtable/callback.go:24
↓ 2 callersMethodscanCommon
(cursor uint64, expr string, count int, f func(e storage.Entry) bool)
internal/kvstore/kvstore.go:469
↓ 2 callersMethodscanPartition
(sign uint64, part *partitions.Partition, owners ...discovery.Member)
internal/cluster/balancer/balancer.go:70
↓ 2 callersMethodsetNumMembers
setNumMembers assigns the current number of members in the cluster to a variable.
internal/cluster/routingtable/routingtable.go:131
↓ 2 callersMethodsetOrGetClusterClient
()
embedded_client.go:66
↓ 2 callersMethodsortVersions
(versions []*version)
internal/dmap/get.go:194
↓ 2 callersMethodstats
(cfg statsConfig)
stats.go:86
↓ 2 callersMethodstring
(s string)
internal/resp/encoder.go:122
↓ 2 callersMethodsubscribe
(conn redcon.Conn, pattern bool, channel string)
internal/pubsub/pubsub.go:253
↓ 2 callersFunctiontoMembers
(members []discovery.Member)
stats.go:41
↓ 2 callersMethodtriggerBalancer
()
internal/cluster/balancer/balancer.go:187
↓ 2 callersMethodunsubscribe
(conn redcon.Conn, pattern, all bool, channel string)
internal/pubsub/pubsub.go:314
↓ 2 callersMethodupdateRoutingTableOnCluster
()
internal/cluster/routingtable/update.go:72
↓ 2 callersFunctionusage
()
cmd/olric-server/main.go:33
↓ 2 callersFunctionwipeOutFragment
(part *partitions.Partition, name string, f *fragment)
internal/dmap/janitor.go:24
↓ 2 callersMethodwriteMessage
(pat bool, pchan, channel, msg string)
internal/pubsub/pubsub.go:106
↓ 2 callersMethodwritePutCommand
(e *env)
internal/dmap/put.go:337
↓ 1 callersMethodAddCallback
(f func())
internal/cluster/routingtable/callback.go:17
↓ 1 callersMethodAddresses
()
internal/server/client.go:51
↓ 1 callersFunctionAtoi
(b []byte)
internal/util/strconv.go:31
← previousnext →401–500 of 1,316, ranked by callers