Redis Dart Connection Pool

Redis Dart Connection Pool

library db.redis;

import 'dart:async';
import 'package:redis_client/redis_client.dart';
import 'package:connection_pool/connection_pool.dart';

class Redis {

  static Future<RedisClient> getRedis() async {
    ManagedConnection managedConnection = await new RedisPool().getConnection();
    return managedConnection.conn;
  }
}


/// Redis pool to manage connections
class RedisPool extends ConnectionPool<RedisClient> {
  static int poolSize = 10;
  static var connectionString = "";

  @override
  void closeConnection(RedisClient conn) {
    print("recycle connection");
    conn.close();
  }

  @override
  Future<RedisClient> openNewConnection() async{
    print("new connection");
    RedisClient r = await RedisClient.connect(connectionString);
    return r;
  }

  static final RedisPool _singleton = new RedisPool._internal();

  factory RedisPool() {
    return _singleton;
  }

  RedisPool._internal() : super(poolSize);

}