Java SDK

mvn clean install

mvn clean deploy

<dependency>
  <groupId>ai.pairsys.goodmem</groupId>
  <artifactId>goodmem-client-java</artifactId>
  <version>1.0.0</version>
  <scope>compile</scope>
</dependency>

  repositories {
    mavenCentral()     // Needed if the 'goodmem-client-java' jar has been published to maven central.
    mavenLocal()       // Needed if the 'goodmem-client-java' jar has been published to the local maven repo.
  }

  dependencies {
     implementation "ai.pairsys.goodmem:goodmem-client-java:1.0.0"
  }

mvn clean package

// Import classes:
import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.ApiException;
import ai.pairsys.goodmem.client.Configuration;
import ai.pairsys.goodmem.client.auth.*;
import ai.pairsys.goodmem.client.model.*;
import ai.pairsys.goodmem.client.api.AdministrationApi;

public class Example {
  public static void main(String[] args) {
    ApiClient defaultClient = Configuration.getDefaultApiClient();
    defaultClient.setBasePath("http://localhost:8080");
    
    // Configure API key authorization: ApiKeyAuth
    ApiKeyAuth ApiKeyAuth = (ApiKeyAuth) defaultClient.getAuthentication("ApiKeyAuth");
    ApiKeyAuth.setApiKey("YOUR API KEY");
    // Uncomment the following line to set a prefix for the API key, e.g. "Token" (defaults to null)
    //ApiKeyAuth.setApiKeyPrefix("Token");

    AdministrationApi apiInstance = new AdministrationApi(defaultClient);
    AdminDrainRequest adminDrainRequest = new AdminDrainRequest(); // AdminDrainRequest | 
    try {
      AdminDrainResponse result = apiInstance.drainServer(adminDrainRequest);
      System.out.println(result);
    } catch (ApiException e) {
      System.err.println("Exception when calling AdministrationApi#drainServer");
      System.err.println("Status code: " + e.getCode());
      System.err.println("Reason: " + e.getResponseBody());
      System.err.println("Response headers: " + e.getResponseHeaders());
      e.printStackTrace();
    }
  }
}

import ai.pairsys.goodmem.client.ApiClient;
import ai.pairsys.goodmem.client.StreamingClient;
import ai.pairsys.goodmem.client.StreamingClient.*;

import java.util.List;
import java.util.stream.Stream;

// Configure client
ApiClient apiClient = new ApiClient();
apiClient.setBasePath("http://localhost:8080");
apiClient.setApiKey("your-api-key");

// Create streaming client
StreamingClient streamingClient = new StreamingClient(apiClient);

// Stream with ChatPostProcessor (NDJSON format)
Stream<MemoryStreamResponse> stream = streamingClient.retrieveMemoryStreamChat(
    "your search query",
    List.of("space-uuid"),
    10,                                           // requested size
    true,                                         // fetch memory
    false,                                        // fetch memory content
    StreamingFormat.NDJSON,                       // format (NDJSON or SSE)
    "llm-uuid",                                   // LLM ID
    "reranker-uuid",                              // reranker ID
    0.5,                                          // relevance threshold
    0.3,                                          // LLM temperature
    10,                                           // max results
    true                                          // chronological resort
);

// Process events
stream.forEach(event -> {
    if (event.getAbstractReply() != null) {
        System.out.println("Abstract: " + event.getAbstractReply().getText());
    } else if (event.getRetrievedItem() != null
            && event.getRetrievedItem().getMemory() != null) {
        System.out.println("Memory: " + event.getRetrievedItem().getMemory());
    }
});

import java.util.HashMap;
import java.util.Map;

// Create advanced request
AdvancedMemoryStreamRequest request = new AdvancedMemoryStreamRequest(
    "your search query",
    List.of("space-uuid")
);
request.setRequestedSize(10);
request.setFetchMemory(true);
request.setFormat(StreamingFormat.NDJSON);  // or StreamingFormat.SSE

// Configure custom post-processor
request.setPostProcessorName("com.goodmem.retrieval.postprocess.ChatPostProcessorFactory");

Map<String, Object> config = new HashMap<>();
config.put("llm_id", "llm-uuid");
config.put("reranker_id", "reranker-uuid");
config.put("relevance_threshold", 0.5);
config.put("llm_temp", 0.3);
config.put("max_results", 10);
config.put("chronological_resort", true);
request.setPostProcessorConfig(config);

// Execute streaming
Stream<MemoryStreamResponse> stream = streamingClient.retrieveMemoryStreamAdvanced(request);

// Process events
stream.forEach(event -> {
    if (event.getAbstractReply() != null) {
        System.out.println("Abstract: " + event.getAbstractReply().getText());
    } else if (event.getRetrievedItem() != null) {
        System.out.println("Retrieved: " + event.getRetrievedItem());
    }
});