@@ -4,14 +4,12 @@ import org.testcontainers.milvus.{MilvusContainer => JavaMilvusIOContainer}
44import org .testcontainers .utility .DockerImageName
55
66case 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
109) extends SingleContainer [JavaMilvusIOContainer ] {
1110
1211 override val container : JavaMilvusIOContainer = {
1312 val c = new JavaMilvusIOContainer (dockerImageName)
14- c.withExposedPorts(httpPort, MilvusContainer .managementPort)
1513 etcdEndpoint.foreach(c.withEtcdEndpoint)
1614 c
1715 }
@@ -21,19 +19,18 @@ case class MilvusContainer(
2119
2220object MilvusContainer {
2321
24- val defaultImage = " milvusdb/milvus"
25- val defaultTag = " v2.4.4"
22+ val defaultImage = " milvusdb/milvus"
23+ val defaultTag = " v2.4.4"
2624 val defaultDockerImageName = s " $defaultImage: $defaultTag"
2725
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 {
3330 override type Container = MilvusContainer
3431
3532 override def createContainer (): MilvusContainer = {
36- new MilvusContainer (dockerImageName, port )
33+ new MilvusContainer (dockerImageName, etcdEndpoint )
3734 }
3835 }
39- }
36+ }
0 commit comments