Get gets the value for the given key. It returns ErrKeyNotFound if the DB does not contain the key. It's thread-safe. It is safe to modify the content

Put sets the value for the given key. It overwrites any previous value for that key, and it's thread-safe. The key has to be a string. value type is a

Printf calls v.f.logger.Printf to print to the logger. Arguments are handled in the manner of fmt.Printf.

V reports whether verbosity at the call site is at least the requested level. The returned value is a struct of type Verbose, which implements Printf

Lock sets a lock for the given key. Acquired lock is only for the key in this dmap. It returns immediately if it acquires the lock for the given key.

Unlock releases an acquired lock for the given key. It returns ErrNoSuchLock if there is no lock for the given key.

NewDMap returns a new DMap client with the given options.

NewClusterClient creates a new Client instance. It needs one node address at least to discover the whole cluster.

Close stops background routines and frees allocated resources.

String returns the member name.

PartitionByID returns the partition for the given HKey

Key returns a key name from the distributed map.

Read returns the current value of gauge.

processProtocolError processes protocol-related errors and translates them into defined application-level errors.

Put sets the value for the given key. It overwrites any previous value for that key, and it's thread-safe. The key has to be a string. value type is a

Get gets the value for the given key. It returns ErrKeyNotFound if the DB does not contain the key. It's thread-safe. It is safe to modify the content

NewEmbeddedClient creates and returns a new EmbeddedClient instance.

HandleFunc registers the handler function for the given command.

NewDMap returns a new DMap client with the given options.

Encode encodes an entry into a binary form and returns the result.

Value returns the value as a byte slice.

Add adds a new item to the Round-Robin scheduler.

Scan parses bytes `b` to `v` with appropriate type. nolint:gocyclo

Reset sets zero to the underlying gauge.

SetKey accepts strings as a key and inserts the key into the underlying data structure.

SetTTL sets TTL to an entry.

SetValue accepts a byte slice as a value and inserts the value into the underlying data structure.

Close stops background routines and frees allocated resources.

CompareByID returns true if two members denote the same member in the cluster.

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

Result returns a response for the pipelined Put command.

Increase increases the gauge by delta.

TTL returns the current TTL for an entry.

Range implements a loop over the storage engine

Sanitize methods should be used to set defaults.

Lock prepares a token and env, then calls tryLock

getOrCreate is a shortcut function to create a new DMap or get an already initialized DMap instance.

GetCoordinator returns the oldest node in the memberlist.

Owner returns partition Owner. It's not thread-safe.

SetTimestamp sets the current timestamp to an entry.

Validate method should be used to find configuration errors.

NewInt64Counter returns a new Int64Counter

Pipeline is a mechanism to realise Redis Pipeline technique. Pipelining is a technique to extremely speed up processing by packing operations to batc

Length returns the count of items

Next returns true if there is more key in the iterator implementation. Otherwise, it returns false.

Scan returns an iterator to loop over the keys. Available scan options: * Count * Match

CompareByName returns true if the two members has the same name in the cluster. This function is intended to redirect the requests to the partition ow

Exec executes all queued commands using one client-server roundtrip per partition.

PartitionByHKey returns the partition for the given HKey

Publish a message to subscribers