MCPcopy Create free account

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

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

↓ 1 callersMethodBalanceEagerly
()
internal/cluster/balancer/balancer.go:203
↓ 1 callersMethodChannels
()
internal/pubsub/pubsub.go:381
↓ 1 callersMethodChannelsWithPatterns
(pattern string)
internal/pubsub/pubsub.go:403
↓ 1 callersMethodClone
()
internal/environment/environment.go:49
↓ 1 callersMethodClose
Close stops background routines and frees allocated resources.
client.go:310
↓ 1 callersMethodClose
(addr string)
internal/server/client.go:113
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/pubsub.go:37
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/pubsub.go:68
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/pubsub.go:97
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/pubsub.go:131
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/pubsub.go:195
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/pubsub.go:219
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:194
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:329
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:415
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:456
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:649
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:685
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:776
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:906
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:943
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/dmap.go:987
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/cluster.go:30
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/cluster.go:51
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/system.go:71
↓ 1 callersMethodCommand
(ctx context.Context)
internal/protocol/system.go:98
↓ 1 callersMethodCommand
Command constructs a Redis AUTH command using the provided authentication password from the Auth instance.
internal/protocol/system.go:219
↓ 1 callersFunctionCount
(c int)
internal/dmap/scan_handlers.go:81
↓ 1 callersMethodDecr
Decr atomically decrements key by delta. The return value is the new value after being decremented or an error.
internal/dmap/atomic.go:105
↓ 1 callersMethodDelete
Delete deletes a configuration variable with its key.
pkg/storage/config.go:57
↓ 1 callersMethodDelete
(hkey uint64)
internal/kvstore/table/table.go:334
↓ 1 callersMethodDeleteByName
(other discovery.Member)
internal/cluster/routingtable/members.go:51
↓ 1 callersMethodDeregister
Deregister removes the current node from the service discovery directory and stops its participation in the cluster.
pkg/service_discovery/service_discovery.go:36
↓ 1 callersMethodDiscard
Discard discards the pipelined commands and resets all internal states. A pipeline can be reused after calling Discard.
pipeline.go:556
↓ 1 callersMethodDiscoverPeers
DiscoverPeers retrieves a list of available peers in the cluster and returns their addresses or an error if any occurs.
pkg/service_discovery/service_discovery.go:39
↓ 1 callersMethodEncode
()
internal/discovery/member.go:50
↓ 1 callersMethodEncode
()
events/cluster_events.go:143
↓ 1 callersMethodEncode
()
events/cluster_events.go:184
↓ 1 callersMethodFloat32
()
get_response.go:137
↓ 1 callersMethodGet
(key string)
internal/environment/environment.go:31
↓ 1 callersMethodGet
(hkey uint64)
internal/kvstore/table/table.go:292
↓ 1 callersMethodGetPut
GetPut atomically sets key to value and returns the old value stored at key.
internal/dmap/atomic.go:141
↓ 1 callersMethodIncrByFloat
IncrByFloat atomically increments key by delta. The return value is the new value after being incremented or an error.
internal/dmap/atomic.go:223
↓ 1 callersMethodIncrease
Increase increases the counter by delta.
internal/stats/stats.go:31
↓ 1 callersMethodInitialize
Initialize prepares the service discovery plugin for use and ensures it is ready for further operations.
pkg/service_discovery/service_discovery.go:24
↓ 1 callersMethodInt16
()
get_response.go:65
↓ 1 callersMethodInt32
()
get_response.go:74
↓ 1 callersMethodInt8
()
get_response.go:56
↓ 1 callersMethodLastAccess
()
internal/kvstore/entry/entry.go:78
↓ 1 callersFunctionMatch
(s string)
internal/dmap/scan_handlers.go:88
↓ 1 callersMethodMemberAddr
()
internal/discovery/discovery.go:54
↓ 1 callersMethodMembers
Members returns a thread-safe list of cluster members.
embedded_client.go:378
↓ 1 callersMethodMove
(*Partition, string, []discovery.Member)
internal/cluster/partitions/fragment.go:25
↓ 1 callersMethodName
Name exposes name of the DMap.
internal/dmap/dmap.go:45
↓ 1 callersFunctionNew
New initializes a new OlricServer instance using the provided configuration and returns it or an error.
cmd/olric-server/server/server.go:41
↓ 1 callersFunctionNew
New tries to read Olric configuration from a YAML file.
config/internal/loader/loader.go:141
↓ 1 callersMethodNewPubSub
NewPubSub returns a new PubSub client with the given options.
embedded_client.go:397
↓ 1 callersFunctionNewServeMux
NewServeMux allocates and returns a new ServeMux.
internal/server/mux.go:44
↓ 1 callersFunctionNewService
(e *environment.Environment)
internal/dmap/service.go:73
↓ 1 callersFunctionNewService
(e *environment.Environment)
internal/pubsub/service.go:68
↓ 1 callersMethodNumMembers
()
internal/discovery/discovery.go:227
↓ 1 callersMethodNumpat
()
internal/pubsub/pubsub.go:425
↓ 1 callersMethodNumsub
(channel string)
internal/pubsub/pubsub.go:447
↓ 1 callersMethodPut
(key string, value interface{})
internal/testutil/mockfragment/mockfragment.go:58
↓ 1 callersMethodPutRaw
PutRaw sets the raw value for the given key.
internal/kvstore/kvstore.go:183
↓ 1 callersMethodRead
Read returns the current value of counter.
internal/stats/stats.go:36
↓ 1 callersMethodRedisOptions
()
config/client.go:193
↓ 1 callersMethodRegister
Register registers the current node in the service discovery directory, enabling it to participate in the cluster.
pkg/service_discovery/service_discovery.go:33
↓ 1 callersMethodRegisterHandlers
()
internal/dmap/handlers.go:21
↓ 1 callersMethodRegisterHandlers
()
internal/pubsub/service.go:57
↓ 1 callersMethodRegisterHandlers
()
internal/cluster/routingtable/handlers.go:21
↓ 1 callersMethodResult
Result returns a response for the pipelined Get command.
pipeline.go:153
↓ 1 callersMethodResult
Result returns a response for the pipelined GetPut command.
pipeline.go:384
↓ 1 callersMethodRoutingTable
RoutingTable returns the latest version of the routing table.
client.go:300
↓ 1 callersMethodSanitize
Sanitize sets default values to empty configuration variables, if it's possible.
config/dmap.go:70
↓ 1 callersMethodSetConfig
SetConfig sets the configuration for the service discovery plugin using the provided map of settings.
pkg/service_discovery/service_discovery.go:27
↓ 1 callersMethodSetEX
(ex float64)
internal/protocol/dmap.go:818
↓ 1 callersMethodSetLogger
SetLogger sets a logger. nil can be accepted, but it depends on the implementation.
pkg/storage/engine.go:57
↓ 1 callersMethodSetLogger
SetLogger assigns a custom logger to the service discovery instance for logging operations.
pkg/service_discovery/service_discovery.go:30
↓ 1 callersMethodSetPX
(px int64)
internal/protocol/dmap.go:823
↓ 1 callersMethodShutdown
()
internal/testcluster/testcluster.go:174
↓ 1 callersMethodShutdown
(ctx context.Context)
internal/server/client.go:130
↓ 1 callersMethodStats
Stats returns stats.Stats with the given options.
client.go:292
↓ 1 callersMethodString
()
get_response.go:47
↓ 1 callersFunctionStringToBytes
(s string)
internal/util/safe.go:36
↓ 1 callersMethodSubscribeNodeEvents
()
internal/discovery/events.go:55
↓ 1 callersMethodTTL
()
get_response.go:191
↓ 1 callersMethodTTL
()
internal/kvstore/entry/entry.go:62
↓ 1 callersMethodTime
()
get_response.go:164
↓ 1 callersMethodTimestamp
()
get_response.go:195
↓ 1 callersMethodTimestamp
()
internal/kvstore/entry/entry.go:70
↓ 1 callersMethodToMap
ToMap casts Config to map[string]interface{} type.
pkg/storage/config.go:77
↓ 1 callersMethodUint16
()
get_response.go:110
↓ 1 callersMethodUint8
()
get_response.go:101
↓ 1 callersMethodValidate
Validate finds errors in the current configuration.
config/dmap.go:96
↓ 1 callersMethodValidate
Validate finds errors in the current configuration.
config/client.go:186
↓ 1 callersFunctionWithConfig
WithConfig applies a specified config.Client to the clusterClientConfig.
cluster_client.go:733
↓ 1 callersFunctionWithHasher
WithHasher sets a custom hasher implementation to the cluster client configuration.
cluster_client.go:719
↓ 1 callersFunctionWithLogger
WithLogger sets a custom logger for the cluster client configuration.
cluster_client.go:726
↓ 1 callersMethodasyncPutOnBackup
(e *env, data []byte, owner discovery.Member)
internal/dmap/put.go:133
← previousnext →501–600 of 1,316, ranked by callers