NewPubSub returns a new PubSub client with the given options.

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

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

Next returns true if there are more tables to Export in the storage instance. Otherwise, it returns false.

NodeMeta is used to retrieve meta-data about the current node when broadcasting an alive message. It's length is limited to the given byte size. This

NotifyMsg is called when a user-data message is received.

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

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

PipelineConcurrency is a PipelineOption controlling the number of concurrent goroutines.

Put queues a Put command. The parameters are identical to the DMap.Put, but it returns FuturePut to read the batched response.

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

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

Put inserts a new Entry into the storage engine.

Put resets the buffer and puts it back to the pool.

Put sets the value for the given key. It overwrites any previous value for that key

In-memory layout for entry: KEY-LENGTH(uint8) | KEY(bytes) | TTL(uint64) | TIMESTAMP(uint64) | LASTACCESS(uint64) | VALUE-LENGTH(uint64) | VALUE(byte

Range calls f sequentially for each key and value present in the map. If f returns false, range stops the iteration. Range may be O(N) with the number

RangeHKey calls f sequentially for each key present in the map. If f returns false, range stops the iteration. Range may be O(N) with the number of el

RefreshMetadata fetches a list of available members and the latest routing table version. It also closes stale clients, if there are any. EmbeddedClie

RefreshMetadata fetches a list of available members and the latest routing table version. It also closes stale clients, if there are any.

Reset sets zero to the underlying counter.

Result returns a response for the pipelined Delete command.

Result returns a response for the pipelined Expire command.

Result returns a response for the pipelined Incr command.

Result returns a response for the pipelined Decr command.

Result returns a response for the pipelined IncrByFloat command.

Sanitize ensures the Authentication configuration is pre-processed and prepared for use, with no changes currently applied.

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

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

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

Scan implements an iterator. The caller starts iterating from the cursor. "count" is the number of entries that will be returned during the iteration.

ServeRESP dispatches the command to the handler.

ServeRESP calls f(w, r)

SetConfig sets a storage engine configuration. nil can be accepted, but it depends on the implementation.

Shutdown stops background servers and leaves the cluster.

Shutdown will stop any background maintenance of network activity for this memberlist, causing it to appear "dead". A leave message will not be broadc

Shutdown gracefully stops the Olric server instance, releasing resources and ensuring a clean termination.

Start starts background servers and joins the cluster. You still must call Shutdown method if Start function returns an early error.

Start starts the distributed map service.

Start launches the Olric server instance and begins listening for incoming requests and termination signals.

Stats returns metrics for an online storage engine.

Stats is a function which provides memory allocation and garbage ratio of a storage instance.

StorageEntryImplementation sets and encoder/decoder implementation for your choice of storage engine.

StringToBytes converts string to byte slice.