Packages

t

com.avsystem.commons.redis

RedisConnectionExecutor

trait RedisConnectionExecutor extends RedisNodeExecutor

Marker subtype of RedisExecutor which guarantees ability to execute all commands implemented by the driver, including the ones that change or access connection state.

Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RedisConnectionExecutor
  2. RedisNodeExecutor
  3. RedisOpExecutor
  4. RedisKeyedExecutor
  5. RedisExecutor
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def executeBatch[A](batch: RedisBatch[A], config: ExecutionConfig = ExecutionConfig.Default): commons.Future[A]

    Executes a RedisBatch.

    Executes a RedisBatch. Redis client implementations (e.g. RedisNodeClient) implement this method by actually sending the batch to Redis server and receving and decoding the response.

    WARNING: Even though the signature of this method indicates that any batch can be executed, every client type supports only a subset of commands. For example, you can't execute CLIENT SETNAME (clientSetname) on a RedisNodeClient because it's a connection state changing command and RedisNodeClient uses a pool of reusable connections. If you try to do this, you'll get a ForbiddenCommandException.

    Definition Classes
    RedisExecutor
  2. abstract def executeOp[A](op: RedisOp[A], executionConfig: ExecutionConfig = ExecutionConfig.Default): commons.Future[A]

    Executes a RedisOp, i.e.

    Executes a RedisOp, i.e. a sequence of RedisBatches where each batch may be created based on a result of previous batch and may use WATCH and UNWATCH commands for the purpose of performing transactions with optimistic locking. Redis client implementations (e.g. RedisNodeClient) implement execution of RedisOp by reserving a single connection so that entire RedisOp is executed on that single connection without any other concurrent commands executing in between. This is necessary for WATCH and UNWATCH commands to work as expected.

    Definition Classes
    RedisOpExecutor
  3. implicit abstract def executionContext: commons.ExecutionContext
    Definition Classes
    RedisExecutor