-func createReplicaDbClient(host string) *DB {
- addr, port, _ := net.SplitHostPort(host)
- return createDbClient(addr, port, "", "", "", newRedisClient, subscribeNotifications, nil)
+func createReplicaDbClient(host string) (*DB, error) {
+ addr, port, err := net.SplitHostPort(host)
+ if err != nil {
+ return nil, err
+ }
+ return createDbClient(addr, port, "", "", "", newRedisClient, subscribeNotifications, nil), err