Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/olric-data/olric
/ functions
Functions
1,316 in github.com/olric-data/olric
⨍
Functions
1,316
◇
Types & classes
192
↓ 5 callers
Method
Name
()
internal/cluster/partitions/fragment.go:23
↓ 5 callers
Function
New
(c *storage.Config)
internal/kvstore/kvstore.go:59
↓ 5 callers
Function
NewDefaultHasher
NewDefaultHasher returns an instance of xxhash package which implements the 64-bit variant of xxHash (XXH64) as described at http://cyan4973.github.io
hasher/hasher.go:21
↓ 5 callers
Function
NewExpire
(dmap, key string, seconds time.Duration)
internal/protocol/dmap.go:448
↓ 5 callers
Function
NewGetEntry
(dmap, key string)
internal/protocol/dmap.go:272
↓ 5 callers
Function
NewIncrByFloat
(dmap, key string, delta float64)
internal/protocol/dmap.go:768
↓ 5 callers
Function
NewLengthOfPart
(partID uint64)
internal/protocol/system.go:123
↓ 5 callers
Function
NewLockLease
(dmap, key, token string, timeout float64)
internal/protocol/dmap.go:934
↓ 5 callers
Function
NewPutEntry
(dmap, key string, value []byte)
internal/protocol/dmap.go:186
↓ 5 callers
Function
NewStats
()
internal/protocol/system.go:170
↓ 5 callers
Function
ParseUint
(b []byte, base int, bitSize int)
internal/util/strconv.go:39
↓ 5 callers
Method
Sanitize
Sanitize sets default values to empty configuration variables, if it's possible.
config/config.go:392
↓ 5 callers
Method
SetEX
(ex float64)
internal/protocol/dmap.go:50
↓ 5 callers
Method
SetKey
(key string)
internal/kvstore/entry/entry.go:42
↓ 5 callers
Method
Stats
Stats exposes some useful metrics to monitor an Olric node.
embedded_client.go:316
↓ 5 callers
Method
Subscribe
(ctx context.Context, channels ...string)
pubsub.go:58
↓ 5 callers
Method
UpdateTTL
UpdateTTL updates TTL of an entry. It returns ErrKeyNotFound, if the key doesn't exist.
pkg/storage/engine.go:99
↓ 5 callers
Method
Validate
Validate finds errors in the current configuration.
config/config.go:326
↓ 5 callers
Method
count
count gets the current number of waiters
internal/locker/locker.go:50
↓ 5 callers
Method
evictKeys
()
internal/dmap/eviction.go:102
↓ 5 callers
Method
makeTable
()
internal/kvstore/kvstore.go:85
↓ 5 callers
Method
shutdown
()
internal/cluster/routingtable/routingtable_test.go:113
↓ 5 callers
Method
uint
(n uint64)
internal/resp/encoder.go:126
↓ 4 callers
Method
Byte
()
get_response.go:182
↓ 4 callers
Method
CheckMemberCountQuorum
()
internal/cluster/routingtable/routingtable.go:173
↓ 4 callers
Method
Command
(ctx context.Context)
internal/protocol/system.go:40
↓ 4 callers
Method
Command
(ctx context.Context)
internal/protocol/system.go:179
↓ 4 callers
Method
Decode
Decode decodes a byte slice into an Entry.
pkg/storage/entry.go:53
↓ 4 callers
Function
DefaultConfig
()
internal/kvstore/kvstore.go:52
↓ 4 callers
Method
Enabled
Enabled checks if authentication is enabled by verifying if the password is set and returns true if it is configured.
config/authentication.go:36
↓ 4 callers
Method
Fill
()
internal/testutil/mockfragment/mockfragment.go:76
↓ 4 callers
Method
FindMemberByName
FindMemberByName finds and returns an alive member.
internal/discovery/discovery.go:232
↓ 4 callers
Method
GetRaw
GetRaw reads an encoded entry from the storage engine.
pkg/storage/engine.go:80
↓ 4 callers
Method
Join
()
internal/cluster/routingtable/routingtable.go:349
↓ 4 callers
Method
Key
()
internal/kvstore/entry/entry.go:46
↓ 4 callers
Function
Match
Match is used for using regular expressions on keys. See https://pkg.go.dev/regexp
client.go:146
↓ 4 callers
Method
Members
Members returns a thread-safe list of cluster members.
client.go:303
↓ 4 callers
Function
New
()
internal/testutil/mockfragment/mockfragment.go:39
↓ 4 callers
Function
New
(e *environment.Environment)
internal/cluster/routingtable/routingtable.go:88
↓ 4 callers
Function
NewInt64Gauge
NewInt64Gauge returns a new Int64Gauge
internal/stats/stats.go:52
↓ 4 callers
Function
NewUpdateRouting
(payload []byte, coordinatorID uint64)
internal/protocol/system.go:91
↓ 4 callers
Method
NumMembers
()
internal/cluster/routingtable/routingtable.go:142
↓ 4 callers
Function
ParseLockCommand
(cmd redcon.Command)
internal/protocol/dmap.go:849
↓ 4 callers
Method
PartitionOwnersByID
PartitionOwnersByID loads the partition owners list for a given hkey.
internal/cluster/partitions/partitions.go:86
↓ 4 callers
Method
Publish
(ctx context.Context, channel string, message interface{})
pubsub.go:66
↓ 4 callers
Method
PutRaw
PutRaw inserts an encoded entry into the storage engine.
pkg/storage/engine.go:74
↓ 4 callers
Method
SetCollectRuntime
()
internal/protocol/system.go:174
↓ 4 callers
Method
SetEXAT
(exat float64)
internal/protocol/dmap.go:60
↓ 4 callers
Function
SetHashFunc
(h hasher.Hasher)
internal/cluster/partitions/hkey.go:29
↓ 4 callers
Method
SetMessage
(m string)
internal/protocol/system.go:35
↓ 4 callers
Method
SetNX
()
internal/protocol/dmap.go:70
↓ 4 callers
Method
SetPXAT
(pxat int64)
internal/protocol/dmap.go:65
↓ 4 callers
Method
SetState
(s State)
internal/kvstore/table/table.go:97
↓ 4 callers
Method
SetTimestamp
(timestamp int64)
internal/kvstore/entry/entry.go:66
↓ 4 callers
Method
SetValue
(value []byte)
internal/kvstore/entry/entry.go:50
↓ 4 callers
Method
SetXX
()
internal/protocol/dmap.go:75
↓ 4 callers
Function
WithPassword
WithPassword configures a cluster client with the specified password for authentication.
cluster_client.go:740
↓ 4 callers
Function
encodeEvent
encodeEvents encodes given interface to its JSON representation and preserves the order in fields slice.
events/cluster_events.go:41
↓ 4 callers
Function
newRoutingTableForTest
(c *config.Config, srv *server.Server)
internal/cluster/routingtable/routingtable_test.go:36
↓ 4 callers
Method
putEntryOnFragment
putOnFragment calls underlying storage engine's Put method to store the key/value pair. It's not thread-safe.
internal/dmap/put.go:68
↓ 4 callers
Function
scanIntegrationTestCommon
(t *testing.T, embedded bool, keyFunc func(i int) string, options ...ScanOption)
integration_test.go:433
↓ 4 callers
Function
toMember
(member discovery.Member)
stats.go:33
↓ 3 callers
Function
Add
()
internal/checkpoint/checkpoint.go:24
↓ 3 callers
Method
Bool
()
get_response.go:155
↓ 3 callers
Method
CheckBootstrap
CheckBootstrap is called for every request and checks whether the node is bootstrapped. It has to be very fast for a smooth operation.
internal/cluster/routingtable/routingtable.go:194
↓ 3 callers
Method
Close
Close stops background routines and frees allocated resources.
embedded_client.go:357
↓ 3 callers
Method
Coefficient
()
internal/kvstore/table/table.go:93
↓ 3 callers
Method
Command
(ctx context.Context)
internal/protocol/dmap.go:828
↓ 3 callers
Method
Copy
Copy creates a thread-safe copy of the existing Config struct.
pkg/storage/config.go:64
↓ 3 callers
Method
Decode
(buf []byte)
internal/kvstore/entry/entry.go:120
↓ 3 callers
Method
Decrease
Decrease decreases the counter by delta.
internal/stats/stats.go:62
↓ 3 callers
Method
Destroy
Destroy flushes the given DMap on the cluster. You should know that there is no global lock on DMaps. So if you call Put/PutEx and Destroy methods con
client.go:226
↓ 3 callers
Method
Destroy
()
internal/cluster/partitions/fragment.go:27
↓ 3 callers
Method
Expire
Expire updates the expiry for the given key. It returns ErrKeyNotFound if the DB does not contain the key. It's thread-safe.
internal/dmap/expire.go:24
↓ 3 callers
Method
Export
Export encodes a table and returns result. This encoded table can be moved to another Olric node.
pkg/storage/engine.go:44
↓ 3 callers
Method
FindMemberByID
FindMemberByID finds and returns an alive member.
internal/discovery/discovery.go:243
↓ 3 callers
Method
Fork
Fork creates an empty instance of an online engine by using the current configuration.
pkg/storage/engine.go:71
↓ 3 callers
Method
Get
Get loads a configuration variable with its key, otherwise it returns an error.
pkg/storage/config.go:46
↓ 3 callers
Method
IsAuthenticated
IsAuthenticated checks if the connection is authenticated. It is thread-safe and returns true if authenticated.
internal/server/server.go:78
↓ 3 callers
Method
Lease
Lease takes key and token and tries to update the expiry with duration. It redirects the request to the partition owner, if required.
internal/dmap/lock.go:207
↓ 3 callers
Method
LocalNode
LocalNode is used to return the local Node
internal/discovery/discovery.go:269
↓ 3 callers
Method
Members
Members returns a thread-safe list of cluster members.
cluster_client.go:587
↓ 3 callers
Function
New
New returns a new Logger
pkg/flog/flog.go:63
↓ 3 callers
Function
New
New creates a new BufPool.
internal/bufpool/bufpool.go:28
↓ 3 callers
Function
New
New returns a new RoundRobin instance.
internal/roundrobin/round_robin.go:37
↓ 3 callers
Function
New
New initializes and returns a new Server configured with the specified Config and Logger.
internal/server/server.go:156
↓ 3 callers
Function
New
New creates a new memberlist with a proper configuration and returns a new Discovery instance along with it.
internal/discovery/discovery.go:82
↓ 3 callers
Function
New
(e *environment.Environment)
internal/cluster/balancer/balancer.go:45
↓ 3 callers
Function
NewClusterMembers
()
internal/protocol/cluster.go:47
↓ 3 callers
Function
NewMemberFromMetadata
(metadata []byte)
internal/discovery/member.go:54
↓ 3 callers
Function
NewMoveFragment
(payload []byte)
internal/protocol/system.go:65
↓ 3 callers
Function
NewPExpire
(dmap, key string, milliseconds time.Duration)
internal/protocol/dmap.go:407
↓ 3 callers
Function
NewPLockLease
(dmap, key, token string, timeout int64)
internal/protocol/dmap.go:978
↓ 3 callers
Function
NewPubSubChannels
()
internal/protocol/pubsub.go:159
↓ 3 callers
Function
NewPublishInternal
(channel, message string)
internal/protocol/pubsub.go:61
↓ 3 callers
Function
PX
PX sets the specified expire time, in milliseconds.
client.go:80
↓ 3 callers
Function
ParseAuthCommand
ParseAuthCommand parses a redcon.Command to create an Auth instance and validates command arguments.
internal/protocol/system.go:229
↓ 3 callers
Function
ParseClusterMembers
(cmd redcon.Command)
internal/protocol/cluster.go:57
↓ 3 callers
Function
ParseClusterRoutingTable
(cmd redcon.Command)
internal/protocol/cluster.go:36
↓ 3 callers
Function
ParseDelEntryCommand
(cmd redcon.Command)
internal/protocol/dmap.go:379
← previous
next →
201–300 of 1,316, ranked by callers