Add adds a new key/value pair to Config

LockWithTimeout sets a lock for the given key. If the lock is still unreleased the end of given period of time, it automatically releases the lock. Ac

New returns a Config with sane defaults. If you change a configuration parameter, please run Sanitize and Validate functions respectively. New takes

Owners loads the partition owners from atomic.Value and returns.

Subscribe a connection to PubSub

Delete deletes the value for the given key. Delete will not return error if key doesn't exist. It's thread-safe. It is safe to modify the contents of

NewEngine initializes Engine with sane defaults. Olric will set its own storage engine implementation and related configuration, if there is no other

put controls every write operation in Olric. It redirects the requests to its owner, if the key belongs to another host.

Ok will return true if this log level is enabled, guarded by the value of verbosity level.

Timestamp returns the current timestamp for an entry.

GetMembers returns a full list of known alive nodes.

New creates a new Locker

NewClient returns a new configuration object for clients.

PartitionOwnersByHKey loads the partition owners list for a given hkey.

Read reads data into the provided byte slice, updates the read bytes counter, and returns the number of bytes read.

GetPut atomically sets the key to value and returns the old value stored at key. It returns nil if there is no previous value.

GetTTL extracts TTL of an entry.

NewEntry returns a new Entry interface implemented by the current storage engine implementation.

OwnerCount returns the current Owner count of a partition.

Start can be used to run background services before starting operation.

ToAddress is a PubSubOption for using a specific cluster member to publish messages to a channel.

Unlock takes key and token and tries to unlock the key. It redirects the request to the partition owner, if required.

Check returns true, if the key exists.

Decr atomically decrements the key by delta. The return value is the new value after being decremented or an error.

GetLastAccess extracts LastAccess of an entry.

Incr atomically increments the key by delta. The return value is the new value after being incremented or an error.

IncrByFloat atomically increments the key by delta. The return value is the new value after being incremented or an error.

IsCoordinator returns true if the caller is the coordinator node.

Lease sets or updates the timeout of the acquired lock for the given key. It returns ErrNoSuchLock if there is no lock for the given key.

ListenAndServe starts the TCP server, initializes internal components, and begins accepting connections.

NewConfig returns a new Config

NewPubSub returns a new PubSub client with the given options.

Sanitize sets default values to empty configuration variables, if it's possible.

ScanRegexMatch is the same with the Scan method, but it supports regular expressions on keys.

Write sends data over the underlying connection and updates the total written bytes counter. It returns the number of bytes written and any error enco

Expire updates the expiry for the given key. It returns ErrKeyNotFound if the DB does not contain the key. It's thread-safe.

GetKey extracts key of an entry.

Join is used to take an existing Memberlist and attempt to Join a cluster by contacting all the given hosts and performing a state sync. Initially, th

NX only sets the key if it does not already exist.

Name exposes name of the DMap.