@@ -4,14 +4,12 @@ import org.testcontainers.milvus.{MilvusContainer => JavaMilvusIOContainer}
4
4
import org .testcontainers .utility .DockerImageName
5
5
6
6
case class MilvusContainer (
7
- dockerImageName : DockerImageName = DockerImageName .parse(MilvusContainer .defaultDockerImageName),
8
- httpPort : Int = MilvusContainer .defaultPort,
9
- etcdEndpoint : Option [String ] = None
7
+ dockerImageName : DockerImageName = DockerImageName .parse(MilvusContainer .defaultDockerImageName),
8
+ etcdEndpoint : Option [String ] = None
10
9
) extends SingleContainer [JavaMilvusIOContainer ] {
11
10
12
11
override val container : JavaMilvusIOContainer = {
13
12
val c = new JavaMilvusIOContainer (dockerImageName)
14
- c.withExposedPorts(httpPort, MilvusContainer .managementPort)
15
13
etcdEndpoint.foreach(c.withEtcdEndpoint)
16
14
c
17
15
}
@@ -21,19 +19,18 @@ case class MilvusContainer(
21
19
22
20
object MilvusContainer {
23
21
24
- val defaultImage = " milvusdb/milvus"
25
- val defaultTag = " v2.4.4"
22
+ val defaultImage = " milvusdb/milvus"
23
+ val defaultTag = " v2.4.4"
26
24
val defaultDockerImageName = s " $defaultImage: $defaultTag"
27
25
28
- val defaultPort = 19530
29
- val managementPort = 9091
30
-
31
- case class Def (dockerImageName : DockerImageName = DockerImageName .parse(MilvusContainer .defaultDockerImageName),
32
- port : Int = MilvusContainer .defaultPort) extends ContainerDef {
26
+ case class Def (
27
+ dockerImageName : DockerImageName = DockerImageName .parse(MilvusContainer .defaultDockerImageName),
28
+ etcdEndpoint : Option [String ] = None
29
+ ) extends ContainerDef {
33
30
override type Container = MilvusContainer
34
31
35
32
override def createContainer (): MilvusContainer = {
36
- new MilvusContainer (dockerImageName, port )
33
+ new MilvusContainer (dockerImageName, etcdEndpoint )
37
34
}
38
35
}
39
- }
36
+ }
0 commit comments