yyc-pipeline/fn-opensearch/src/main/java/net/yaoyi/pipeline/opensearch/OpenSearchUtils.java

package net.yaoyi.pipeline.opensearch;

import com.aliyun.ha3engine.vector.Client;
import com.aliyun.ha3engine.vector.models.Config;

public class OpenSearchUtils {
    private OpenSearchUtils() {
    }

    private static final Client client;

    static {
        try {
            Config config = new Config();
            config.setInstanceId(Contents.INSTANCE_ID);
            config.setAccessUserName(Contents.ACCESS_USER_NAME);
            config.setAccessPassWord(Contents.ACCESS_PASS_WORD);
            config.setEndpoint(Contents.ENDPOINT);
            client = new Client(config);
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }

    public static Client getClient() {
        return client;
    }
}