bgrunner runs in the background and reads incoming commands from the detached client.

bootstrapCoordinator prepares the very first routing table and bootstraps the coordinator node.

callStartedCallback checks passed checkpoint count and calls the callback function.

eventLoop awaits for messages from memberlist and broadcasts them to event listeners.

fetchRoutingTablePeriodically periodically updates the routing table by invoking fetchRoutingTable at configured intervals. It stops gracefully when t

getFreePort copied from testutil package to prevent cycle import.

getOnCluster retrieves the storage.Entry for a given hashed key and key string from cluster nodes with read quorum. It ensures data consistency via re

getOnFragment retrieves an entry from the associated fragment based on the provided environment details. It returns the found entry or an error if the

increaseUptimeSeconds calls UptimeSeconds.Increase function every second.

leaseKey tries to update the expiry of the key by verifying token.

loadMemberlistConfig creates a new *memberlist.Config by parsing olric.yaml

lookupOnOwners collects versions of a key/value pair on the partition owner by including previous partition owners.

lookupOnPreviousOwner retrieves the version of a key from a previous owner in the cluster. It communicates with the specified owner node and decodes t

lookupOnReplicas retrieves data from replica nodes for the given hash key and key, returning a list of versioned entries.

lookupOnThisNode searches for a key's version on the current node, considering only the primary partition owner.

mapYamlToConfig maps a parsed YAML to related configuration struct.

newDelegate returns a new delegate instance.

newTestOlricWithConfig creates a new Olric instance with the given configuration. This function is intended for internal use. Please use testOlricClus

readRepair performs synchronization of inconsistent replicas by applying the winning version to out-of-sync nodes.

registerErrors registers application-specific errors with their corresponding prefixes in the error management system.

sanitizeAndSortVersions removes nil versions from the input slice and sorts the remaining versions by recency.

tryLock takes a deadline and env and sets a key-value pair by using Put with NX and PX commands. It tries to acquire the lock 100 times per second if

unlockKey tries to unlock the lock by verifying the lock with token.

waitForInterrupt waits for termination signals (SIGTERM, SIGINT) to gracefully shut down the Olric server instance.

writePutCommand constructs and returns a new protocol.Put command based on the provided key, value, and configuration options.

Accept waits for and returns the next connection to the ListenerWrapper, applying TCP keep-alive settings if specified.

BytesToString converts byte slice to string.

Check checks the key existence.