Bump versions and add experimental support for local ollama mode

Author: pbernet

build.sbt

@@ -150,13 +150,15 @@ libraryDependencies ++= Seq(
   "dev.langchain4j" % "langchain4j" % langchain4jVersion,
   "dev.langchain4j" % "langchain4j-open-ai" % langchain4jVersion,
   "dev.langchain4j" % "langchain4j-anthropic" % langchain4jVersion,
+  "dev.langchain4j" % "langchain4j-ollama" % langchain4jVersion,
+
 
   // LangChain4j PgVector extension
-  "dev.langchain4j" % "langchain4j-pgvector" % "1.2.0-beta8",
+  "dev.langchain4j" % "langchain4j-pgvector" % "1.4.0-beta10",
 
   // LangChain4j embedding models
-  "dev.langchain4j" % "langchain4j-embeddings-bge-small-en-v15-q" % "1.2.0-beta8",
-  "dev.langchain4j" % "langchain4j-embeddings-all-minilm-l6-v2-q" % "1.2.0-beta8",
+  "dev.langchain4j" % "langchain4j-embeddings-bge-small-en-v15-q" % "1.4.0-beta10",
+  "dev.langchain4j" % "langchain4j-embeddings-all-minilm-l6-v2-q" % "1.4.0-beta10",
 
   // Beautiful CLI output formatting
   "xyz.matthieucourt" %% "layoutz" % "0.1.0",

src/main/scala/alpakka/sse_to_elasticsearch/OllamaContainer.java

@@ -0,0 +1,38 @@
+package alpakka.sse_to_elasticsearch;
+
+import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.wait.strategy.Wait;
+
+import java.time.Duration;
+
+public class OllamaContainer extends GenericContainer<OllamaContainer> {
+    private static final int DEFAULT_PORT = 11434;
+    private static final String DEFAULT_IMAGE = "sysnet4admin/ollama-llama3.2:1b";
+    private static final String DEFAULT_TAG = "latest";
+
+    public static void main(String[] args) throws InterruptedException {
+        OllamaContainer ollamaContainer = new OllamaContainer();
+        ollamaContainer.start();
+        Thread.sleep(100000000);
+    }
+
+    public OllamaContainer() {
+        this(DEFAULT_IMAGE + ":" + DEFAULT_TAG);
+    }
+
+    public OllamaContainer(String image) {
+        super(image == null ? DEFAULT_IMAGE + ":" + DEFAULT_TAG : image);
+        addExposedPort(DEFAULT_PORT);
+        waitingFor(Wait.forHttp("/api/tags")
+                .forPort(DEFAULT_PORT)
+                .withStartupTimeout(Duration.ofMinutes(5)));
+    }
+
+    public String getHostAddress() {
+        return getHost() + ":" + getMappedPort(DEFAULT_PORT);
+    }
+
+    public String getBaseUrl() {
+        return "http://" + getHostAddress();
+    }
+}