add ability to get *redis.Client #110
							
								
								
									
										4
									
								
								redis.go
									
									
									
									
									
								
							
							
						
						
									
										4
									
								
								redis.go
									
									
									
									
									
								
							| @@ -42,6 +42,10 @@ func (r *Store) Init(opts ...store.Option) error { | ||||
| 	return r.configure() | ||||
| } | ||||
|  | ||||
| func (r *Store) Redis() *redis.Client { | ||||
| 	return r.cli.(*redis.Client) | ||||
| } | ||||
|  | ||||
| func (r *Store) Disconnect(ctx context.Context) error { | ||||
| 	return r.cli.Close() | ||||
| } | ||||
|   | ||||
| @@ -71,11 +71,11 @@ func Test_rkv_configure(t *testing.T) { | ||||
| 	} | ||||
| 	for _, tt := range tests { | ||||
| 		t.Run(tt.name, func(t *testing.T) { | ||||
| 			r := &rkv{ | ||||
| 			rc := &Store{ | ||||
| 				opts: tt.fields.options, | ||||
| 				cli:  tt.fields.Client, | ||||
| 			} | ||||
| 			err := r.configure() | ||||
| 			err := rc.configure() | ||||
| 			if (err != nil) != tt.wantErr { | ||||
| 				t.Errorf("configure() error = %v, wantErr %v", err, tt.wantErr) | ||||
| 				return | ||||
|   | ||||
		Reference in New Issue
	
	Block a user