@@ -11,6 +11,7 @@ import (
11
11
12
12
type redisContainer struct {
13
13
testcontainers.Container
14
+ config * RedisContainerConfiguration
14
15
}
15
16
16
17
func StartContainer (ctx context.Context , config * RedisContainerConfiguration ) (* redisContainer , error ) {
@@ -26,30 +27,21 @@ func StartContainer(ctx context.Context, config *RedisContainerConfiguration) (*
26
27
if err != nil {
27
28
return nil , err
28
29
}
30
+ return & redisContainer {container , config }, nil
31
+ }
29
32
30
- mappedPort , err := container .MappedPort (ctx )
33
+ func (container * redisContainer ) Url (ctx context.Context ) (string , error ) {
34
+ mappedPort , err := container .MappedPort (ctx , nat .Port (fmt .Sprint (container .config .port )))
31
35
if err != nil {
32
- return nil , err
36
+ return "" , err
33
37
}
34
38
35
39
hostIP , err := container .Host (ctx )
36
40
if err != nil {
37
- return nil , err
41
+ return "" , err
38
42
}
39
43
40
44
uri := fmt .Sprintf ("redis://%s:%s" , hostIP , mappedPort .Port ())
41
45
42
- return & redisContainer {Container : container , URI : uri }, nil
43
- }
44
-
45
- func (container * redisContainer ) Url (ctx context.Context ) (string , error ) {
46
- host , err := container .Host (ctx )
47
- if err != nil {
48
- return "" , err
49
- }
50
- port , err := container .MappedPort (ctx , nat .Port (fmt .Sprint (container .config .port )))
51
- if err != nil {
52
- return "" , err
53
- }
54
- return fmt .Sprintf ("mongodb://%s:%s" , host , port .Port ()), nil
46
+ return uri , nil
55
47
}
0 commit comments