Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/olric-data/olric
/ functions
Functions
1,316 in github.com/olric-data/olric
⨍
Functions
1,316
◇
Types & classes
192
↓ 1 callers
Method
BalanceEagerly
()
internal/cluster/balancer/balancer.go:203
↓ 1 callers
Method
Channels
()
internal/pubsub/pubsub.go:381
↓ 1 callers
Method
ChannelsWithPatterns
(pattern string)
internal/pubsub/pubsub.go:403
↓ 1 callers
Method
Clone
()
internal/environment/environment.go:49
↓ 1 callers
Method
Close
Close stops background routines and frees allocated resources.
client.go:310
↓ 1 callers
Method
Close
(addr string)
internal/server/client.go:113
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/pubsub.go:37
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/pubsub.go:68
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/pubsub.go:97
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/pubsub.go:131
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/pubsub.go:195
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/pubsub.go:219
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:194
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:329
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:415
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:456
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:649
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:685
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:776
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:906
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:943
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:987
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/cluster.go:30
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/cluster.go:51
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/system.go:71
↓ 1 callers
Method
Command
(ctx context.Context)
internal/protocol/system.go:98
↓ 1 callers
Method
Command
Command constructs a Redis AUTH command using the provided authentication password from the Auth instance.
internal/protocol/system.go:219
↓ 1 callers
Function
Count
(c int)
internal/dmap/scan_handlers.go:81
↓ 1 callers
Method
Decr
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 callers
Method
Delete
Delete deletes a configuration variable with its key.
pkg/storage/config.go:57
↓ 1 callers
Method
Delete
(hkey uint64)
internal/kvstore/table/table.go:334
↓ 1 callers
Method
DeleteByName
(other discovery.Member)
internal/cluster/routingtable/members.go:51
↓ 1 callers
Method
Deregister
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 callers
Method
Discard
Discard discards the pipelined commands and resets all internal states. A pipeline can be reused after calling Discard.
pipeline.go:556
↓ 1 callers
Method
DiscoverPeers
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 callers
Method
Encode
()
internal/discovery/member.go:50
↓ 1 callers
Method
Encode
()
events/cluster_events.go:143
↓ 1 callers
Method
Encode
()
events/cluster_events.go:184
↓ 1 callers
Method
Float32
()
get_response.go:137
↓ 1 callers
Method
Get
(key string)
internal/environment/environment.go:31
↓ 1 callers
Method
Get
(hkey uint64)
internal/kvstore/table/table.go:292
↓ 1 callers
Method
GetPut
GetPut atomically sets key to value and returns the old value stored at key.
internal/dmap/atomic.go:141
↓ 1 callers
Method
IncrByFloat
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 callers
Method
Increase
Increase increases the counter by delta.
internal/stats/stats.go:31
↓ 1 callers
Method
Initialize
Initialize prepares the service discovery plugin for use and ensures it is ready for further operations.
pkg/service_discovery/service_discovery.go:24
↓ 1 callers
Method
Int16
()
get_response.go:65
↓ 1 callers
Method
Int32
()
get_response.go:74
↓ 1 callers
Method
Int8
()
get_response.go:56
↓ 1 callers
Method
LastAccess
()
internal/kvstore/entry/entry.go:78
↓ 1 callers
Function
Match
(s string)
internal/dmap/scan_handlers.go:88
↓ 1 callers
Method
MemberAddr
()
internal/discovery/discovery.go:54
↓ 1 callers
Method
Members
Members returns a thread-safe list of cluster members.
embedded_client.go:378
↓ 1 callers
Method
Move
(*Partition, string, []discovery.Member)
internal/cluster/partitions/fragment.go:25
↓ 1 callers
Method
Name
Name exposes name of the DMap.
internal/dmap/dmap.go:45
↓ 1 callers
Function
New
New initializes a new OlricServer instance using the provided configuration and returns it or an error.
cmd/olric-server/server/server.go:41
↓ 1 callers
Function
New
New tries to read Olric configuration from a YAML file.
config/internal/loader/loader.go:141
↓ 1 callers
Method
NewPubSub
NewPubSub returns a new PubSub client with the given options.
embedded_client.go:397
↓ 1 callers
Function
NewServeMux
NewServeMux allocates and returns a new ServeMux.
internal/server/mux.go:44
↓ 1 callers
Function
NewService
(e *environment.Environment)
internal/dmap/service.go:73
↓ 1 callers
Function
NewService
(e *environment.Environment)
internal/pubsub/service.go:68
↓ 1 callers
Method
NumMembers
()
internal/discovery/discovery.go:227
↓ 1 callers
Method
Numpat
()
internal/pubsub/pubsub.go:425
↓ 1 callers
Method
Numsub
(channel string)
internal/pubsub/pubsub.go:447
↓ 1 callers
Method
Put
(key string, value interface{})
internal/testutil/mockfragment/mockfragment.go:58
↓ 1 callers
Method
PutRaw
PutRaw sets the raw value for the given key.
internal/kvstore/kvstore.go:183
↓ 1 callers
Method
Read
Read returns the current value of counter.
internal/stats/stats.go:36
↓ 1 callers
Method
RedisOptions
()
config/client.go:193
↓ 1 callers
Method
Register
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 callers
Method
RegisterHandlers
()
internal/dmap/handlers.go:21
↓ 1 callers
Method
RegisterHandlers
()
internal/pubsub/service.go:57
↓ 1 callers
Method
RegisterHandlers
()
internal/cluster/routingtable/handlers.go:21
↓ 1 callers
Method
Result
Result returns a response for the pipelined Get command.
pipeline.go:153
↓ 1 callers
Method
Result
Result returns a response for the pipelined GetPut command.
pipeline.go:384
↓ 1 callers
Method
RoutingTable
RoutingTable returns the latest version of the routing table.
client.go:300
↓ 1 callers
Method
Sanitize
Sanitize sets default values to empty configuration variables, if it's possible.
config/dmap.go:70
↓ 1 callers
Method
SetConfig
SetConfig sets the configuration for the service discovery plugin using the provided map of settings.
pkg/service_discovery/service_discovery.go:27
↓ 1 callers
Method
SetEX
(ex float64)
internal/protocol/dmap.go:818
↓ 1 callers
Method
SetLogger
SetLogger sets a logger. nil can be accepted, but it depends on the implementation.
pkg/storage/engine.go:57
↓ 1 callers
Method
SetLogger
SetLogger assigns a custom logger to the service discovery instance for logging operations.
pkg/service_discovery/service_discovery.go:30
↓ 1 callers
Method
SetPX
(px int64)
internal/protocol/dmap.go:823
↓ 1 callers
Method
Shutdown
()
internal/testcluster/testcluster.go:174
↓ 1 callers
Method
Shutdown
(ctx context.Context)
internal/server/client.go:130
↓ 1 callers
Method
Stats
Stats returns stats.Stats with the given options.
client.go:292
↓ 1 callers
Method
String
()
get_response.go:47
↓ 1 callers
Function
StringToBytes
(s string)
internal/util/safe.go:36
↓ 1 callers
Method
SubscribeNodeEvents
()
internal/discovery/events.go:55
↓ 1 callers
Method
TTL
()
get_response.go:191
↓ 1 callers
Method
TTL
()
internal/kvstore/entry/entry.go:62
↓ 1 callers
Method
Time
()
get_response.go:164
↓ 1 callers
Method
Timestamp
()
get_response.go:195
↓ 1 callers
Method
Timestamp
()
internal/kvstore/entry/entry.go:70
↓ 1 callers
Method
ToMap
ToMap casts Config to map[string]interface{} type.
pkg/storage/config.go:77
↓ 1 callers
Method
Uint16
()
get_response.go:110
↓ 1 callers
Method
Uint8
()
get_response.go:101
↓ 1 callers
Method
Validate
Validate finds errors in the current configuration.
config/dmap.go:96
↓ 1 callers
Method
Validate
Validate finds errors in the current configuration.
config/client.go:186
↓ 1 callers
Function
WithConfig
WithConfig applies a specified config.Client to the clusterClientConfig.
cluster_client.go:733
↓ 1 callers
Function
WithHasher
WithHasher sets a custom hasher implementation to the cluster client configuration.
cluster_client.go:719
↓ 1 callers
Function
WithLogger
WithLogger sets a custom logger for the cluster client configuration.
cluster_client.go:726
↓ 1 callers
Method
asyncPutOnBackup
(e *env, data []byte, owner discovery.Member)
internal/dmap/put.go:133
← previous
next →
501–600 of 1,316, ranked by callers