(opts *redis.Options, index string)
| 556 | } |
| 557 | |
| 558 | func getRedisearchClient(opts *redis.Options, index string) *redisearch.Client { |
| 559 | pool := &redigoredis.Pool{Dial: func() (redigoredis.Conn, error) { |
| 560 | return redigoredis.Dial("tcp", opts.Addr, redigoredis.DialPassword(opts.Password)) |
| 561 | }} |
| 562 | |
| 563 | return redisearch.NewClientFromPool(pool, index) |
| 564 | } |
| 565 | |
| 566 | func createIndex(r *redisearch.Client, ns string) error { |
| 567 | // Create a schema for the index |