View Source Nebulex.Adapter.Queryable behaviour (Nebulex v2.6.4)

Specifies the query API required from adapters.

Query values

There are two types of query values. The ones shared and implemented by all adapters and the ones that are adapter specific.

Common queries

The following query values are shared and/or supported for all adapters:

  • nil - Matches all cached entries.

Adapter-specific queries

The query value depends entirely on the adapter implementation; it could any term. Therefore, it is highly recommended to see adapters' documentation for more information about building queries. For example, the built-in Nebulex.Adapters.Local adapter uses :ets.match_spec() for queries, as well as other pre-defined ones like :unexpired and :expired.

Summary

Types

Proxy type to the adapter meta

Proxy type to the cache options

Callbacks

Executes the query according to the given operation.

Streams the given query.

Types

@type adapter_meta() :: Nebulex.Adapter.adapter_meta()

Proxy type to the adapter meta

@type opts() :: Nebulex.Cache.opts()

Proxy type to the cache options

Callbacks

Link to this callback

execute(adapter_meta, operation, query, opts)

View Source
@callback execute(
  adapter_meta(),
  operation :: :all | :count_all | :delete_all,
  query :: term(),
  opts()
) :: [term()] | integer()

Executes the query according to the given operation.

Raises Nebulex.QueryError if query is invalid.

In the the adapter does not support the given operation, an ArgumentError exception should be raised.

Operations

  • :all - Returns a list with all entries from cache matching the given query.
  • :count_all - Returns the number of matched entries with the given query.
  • :delete_all - Deletes all entries matching the given query. It returns the number of deleted entries.

It is used on Nebulex.Cache.all/2, Nebulex.Cache.count_all/2, and Nebulex.Cache.delete_all/2.

Link to this callback

stream(adapter_meta, query, opts)

View Source
@callback stream(adapter_meta(), query :: term(), opts()) :: Enumerable.t()

Streams the given query.

Raises Nebulex.QueryError if query is invalid.

See Nebulex.Cache.stream/2.