Package org.apache.nifi.redis.util

Class RedisUtils

java.lang.Object
org.apache.nifi.redis.util.RedisUtils
public class RedisUtils extends Object

  • Field Details

    • LOGGER

      private static final org.slf4j.Logger LOGGER

    • REDIS_CONNECTION_POOL

      public static final org.apache.nifi.components.PropertyDescriptor REDIS_CONNECTION_POOL

    • TTL

      public static final org.apache.nifi.components.PropertyDescriptor TTL

    • REDIS_MODE_STANDALONE

      public static final org.apache.nifi.components.AllowableValue REDIS_MODE_STANDALONE

    • REDIS_MODE_SENTINEL

      public static final org.apache.nifi.components.AllowableValue REDIS_MODE_SENTINEL

    • REDIS_MODE_CLUSTER

      public static final org.apache.nifi.components.AllowableValue REDIS_MODE_CLUSTER

    • REDIS_MODE

      public static final org.apache.nifi.components.PropertyDescriptor REDIS_MODE

    • CONNECTION_STRING

      public static final org.apache.nifi.components.PropertyDescriptor CONNECTION_STRING

    • DATABASE

      public static final org.apache.nifi.components.PropertyDescriptor DATABASE

    • COMMUNICATION_TIMEOUT

      public static final org.apache.nifi.components.PropertyDescriptor COMMUNICATION_TIMEOUT

    • CLUSTER_MAX_REDIRECTS

      public static final org.apache.nifi.components.PropertyDescriptor CLUSTER_MAX_REDIRECTS

    • SENTINEL_MASTER

      public static final org.apache.nifi.components.PropertyDescriptor SENTINEL_MASTER

    • USERNAME

      public static final org.apache.nifi.components.PropertyDescriptor USERNAME

    • PASSWORD

      public static final org.apache.nifi.components.PropertyDescriptor PASSWORD

    • SENTINEL_USERNAME

      public static final org.apache.nifi.components.PropertyDescriptor SENTINEL_USERNAME

    • SENTINEL_PASSWORD

      public static final org.apache.nifi.components.PropertyDescriptor SENTINEL_PASSWORD

    • POOL_MAX_TOTAL

      public static final org.apache.nifi.components.PropertyDescriptor POOL_MAX_TOTAL

    • POOL_MAX_IDLE

      public static final org.apache.nifi.components.PropertyDescriptor POOL_MAX_IDLE

    • POOL_MIN_IDLE

      public static final org.apache.nifi.components.PropertyDescriptor POOL_MIN_IDLE

    • POOL_BLOCK_WHEN_EXHAUSTED

      public static final org.apache.nifi.components.PropertyDescriptor POOL_BLOCK_WHEN_EXHAUSTED

    • POOL_MAX_WAIT_TIME

      public static final org.apache.nifi.components.PropertyDescriptor POOL_MAX_WAIT_TIME

    • POOL_MIN_EVICTABLE_IDLE_TIME

      public static final org.apache.nifi.components.PropertyDescriptor POOL_MIN_EVICTABLE_IDLE_TIME

    • POOL_TIME_BETWEEN_EVICTION_RUNS

      public static final org.apache.nifi.components.PropertyDescriptor POOL_TIME_BETWEEN_EVICTION_RUNS

    • POOL_NUM_TESTS_PER_EVICTION_RUN

      public static final org.apache.nifi.components.PropertyDescriptor POOL_NUM_TESTS_PER_EVICTION_RUN

    • POOL_TEST_ON_CREATE

      public static final org.apache.nifi.components.PropertyDescriptor POOL_TEST_ON_CREATE

    • POOL_TEST_ON_BORROW

      public static final org.apache.nifi.components.PropertyDescriptor POOL_TEST_ON_BORROW

    • POOL_TEST_ON_RETURN

      public static final org.apache.nifi.components.PropertyDescriptor POOL_TEST_ON_RETURN

    • POOL_TEST_WHILE_IDLE

      public static final org.apache.nifi.components.PropertyDescriptor POOL_TEST_WHILE_IDLE

    • SSL_CONTEXT_SERVICE

      public static final org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT_SERVICE

    • REDIS_CONNECTION_PROPERTY_DESCRIPTORS

      public static final List<org.apache.nifi.components.PropertyDescriptor> REDIS_CONNECTION_PROPERTY_DESCRIPTORS

  • Constructor Details

    • RedisUtils

      public RedisUtils()

  • Method Details

    • createRedisConfig

      public static RedisConfig createRedisConfig(org.apache.nifi.context.PropertyContext context)

    • createConnectionFactory

      public static org.springframework.data.redis.connection.jedis.JedisConnectionFactory createConnectionFactory(org.apache.nifi.context.PropertyContext context, SSLContext sslContext)

    • createConnectionFactory

      public static org.springframework.data.redis.connection.jedis.JedisConnectionFactory createConnectionFactory(RedisConfig redisConfig, SSLContext sslContext)

    • getTrimmedValues

      private static List<String> getTrimmedValues(String[] values)

    • enrichRedisConfiguration

      private static void enrichRedisConfiguration(org.springframework.data.redis.connection.RedisConfiguration redisConfiguration, Integer dbIndex, @Nullable String username, @Nullable String password, @Nullable String sentinelUsername, @Nullable String sentinelPassword)

    • createJedisPoolConfig

      private static redis.clients.jedis.JedisPoolConfig createJedisPoolConfig(RedisConfig redisConfig)

    • validate

      public static List<org.apache.nifi.components.ValidationResult> validate(org.apache.nifi.components.ValidationContext validationContext)

    • isInteger

      private static boolean isInteger(String number)

    • createRedisTemplateForStreams

      public static org.springframework.data.redis.core.RedisTemplate<String,String> createRedisTemplateForStreams(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

    • createRedisTemplateForStreams

      public static org.springframework.data.redis.core.RedisTemplate<String,String> createRedisTemplateForStreams(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamMessageListenerContainerOptions<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,byte[]>> containerOptions)

    • createRedisTemplateForKeyValues

      public static org.springframework.data.redis.core.RedisTemplate<String,String> createRedisTemplateForKeyValues(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

    • createRedisTemplateForPubSub

      public static org.springframework.data.redis.core.RedisTemplate<String,byte[]> createRedisTemplateForPubSub(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)