From b15be60e0ceb8f518eaff877bdeb550c93ebe681 Mon Sep 17 00:00:00 2001 From: 0007 <0007@qq.com> Date: Wed, 27 Aug 2025 19:57:55 +0800 Subject: [PATCH] Add File --- .../OpenSearchVectorStoreConfig.java | 85 +++++++++++++++++++ 1 file changed, 85 insertions(+) create mode 100644 agents-flex-store/agents-flex-store-opensearch/src/main/java/com/agentsflex/store/opensearch/OpenSearchVectorStoreConfig.java diff --git a/agents-flex-store/agents-flex-store-opensearch/src/main/java/com/agentsflex/store/opensearch/OpenSearchVectorStoreConfig.java b/agents-flex-store/agents-flex-store-opensearch/src/main/java/com/agentsflex/store/opensearch/OpenSearchVectorStoreConfig.java new file mode 100644 index 0000000..2f7adaf --- /dev/null +++ b/agents-flex-store/agents-flex-store-opensearch/src/main/java/com/agentsflex/store/opensearch/OpenSearchVectorStoreConfig.java @@ -0,0 +1,85 @@ +/* + * Copyright (c) 2023-2025, Agents-Flex (fuhai999@gmail.com). + *

+ * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + *

+ * http://www.apache.org/licenses/LICENSE-2.0 + *

+ * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.agentsflex.store.opensearch; + +import com.agentsflex.core.store.DocumentStoreConfig; +import com.agentsflex.core.util.StringUtil; + +/** + * 连接 open search 配置:opensearch-java + * + * @author songyinyin + * @since 2024/8/10 下午8:39 + */ +public class OpenSearchVectorStoreConfig implements DocumentStoreConfig { + + private String serverUrl = "https://localhost:9200"; + + private String apiKey; + + private String username; + + private String password; + + private String defaultIndexName = "agents-flex-default"; + + public String getServerUrl() { + return serverUrl; + } + + public void setServerUrl(String serverUrl) { + this.serverUrl = serverUrl; + } + + public String getApiKey() { + return apiKey; + } + + public void setApiKey(String apiKey) { + this.apiKey = apiKey; + } + + public String getUsername() { + return username; + } + + public void setUsername(String username) { + this.username = username; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } + + public String getDefaultIndexName() { + return defaultIndexName; + } + + public void setDefaultIndexName(String defaultIndexName) { + this.defaultIndexName = defaultIndexName; + } + + + @Override + public boolean checkAvailable() { + return StringUtil.hasText(this.serverUrl, this.apiKey) + || StringUtil.hasText(this.serverUrl, this.username, this.password); + } +}