Langfuse Java Client

<dependency>
    <groupId>com.langfuse</groupId>
    <artifactId>langfuse-java</artifactId>
    <version>0.1.0</version>
</dependency>

import com.langfuse.client.LangfuseClient;
import com.langfuse.client.core.LangfuseClientApiException;

// Prompts
import com.langfuse.client.resources.prompts.types.*;

// Traces and observations
import com.langfuse.client.resources.trace.types.*;
import com.langfuse.client.resources.observations.types.*;

// Ingestion (primary tracing API)
import com.langfuse.client.resources.ingestion.types.*;

// Common types
import com.langfuse.client.resources.commons.types.*;

import com.langfuse.client.LangfuseClient;
import com.langfuse.client.core.LangfuseClientApiException;
import com.langfuse.client.resources.prompts.types.PromptMetaListResponse;

public class LangfuseExample {
    public static void main(String[] args) {
        // Initialize client with credentials
        LangfuseClient client = LangfuseClient.builder()
            .url("https://cloud.langfuse.com")  // EU data region
            // .url("https://us.cloud.langfuse.com")  // US data region
            // .url("http://localhost:3000")  // Local deployment
            .credentials("pk-lf-...", "sk-lf-...")
            .build();

        // Make API requests
        try {
            PromptMetaListResponse prompts = client.prompts().list();
            System.out.println("Prompts: " + prompts);
        } catch (LangfuseClientApiException error) {
            System.err.println("Error: " + error.statusCode());
            System.err.println("Body: " + error.body());
        }
    }
}

// Builder interface
public static LangfuseClientBuilder builder();

// Build configured client
public LangfuseClient build();

/**
 * Batch ingestion for Langfuse tracing
 * Supports event deduplication, handles multiple event types
 * Batch sizes limited to 3.5 MB
 * Returns 207 status with error details instead of 4xx for input errors
 */
IngestionResponse batch(IngestionRequest request);
IngestionResponse batch(IngestionRequest request, RequestOptions requestOptions);

// Get a specific trace with full details
TraceWithFullDetails get(String traceId);

// List traces with filters
Traces list();
Traces list(GetTracesRequest request);

// Delete trace(s)
DeleteTraceResponse delete(String traceId);
DeleteTraceResponse deleteMultiple(DeleteTracesRequest request);

// Get a specific observation
ObservationsView get(String observationId);

// List observations with filters
ObservationsViews getMany();
ObservationsViews getMany(GetObservationsRequest request);

// Get prompt by name with optional version/label
Prompt get(String promptName);
Prompt get(String promptName, GetPromptRequest request);

// List all prompts with metadata
PromptMetaListResponse list();

// Create new prompt version
Prompt create(CreatePromptRequest request);

// List datasets
PaginatedDatasets list();

// Get dataset
Dataset get(String datasetName);

// Create dataset
Dataset create(CreateDatasetRequest request);

// Get dataset run with items
DatasetRunWithItems getRun(String datasetName, String runName);

// Create score
CreateScoreResponse create(CreateScoreRequest request);

// Get scores with extensive filtering (v2 API)
GetScoresResponse get();
GetScoresResponse get(GetScoresRequest request);

// Delete score
void delete(String scoreId);

// List sessions
PaginatedSessions list();
PaginatedSessions list(GetSessionsRequest request);

// Get session with all traces
SessionWithTraces get(String sessionId);

// Create model
Model create(CreateModelRequest request);

// List models
PaginatedModels list();

// Get model
Model get(String id);

// Delete model
void delete(String id);

MetricsResponse metrics(GetMetricsRequest request);

// Create comment
CreateCommentResponse create(CreateCommentRequest request);

// Get comments
GetCommentsResponse get();

// Manage annotation queues
PaginatedAnnotationQueues listQueues();
AnnotationQueue getQueue(String queueId);

// Get projects
Projects get();

// Create project (requires org-scoped key)
Project create(CreateProjectRequest request);

// Manage API keys (requires org-scoped key)
ApiKeyList getApiKeys(String projectId);
ApiKeyResponse createApiKey(String projectId, CreateApiKeyRequest request);

// List users
ScimUsersListResponse listUsers();
ScimUsersListResponse listUsers(ListUsersRequest request);

// Create user
ScimUser createUser(CreateUserRequest request);

// Get user
ScimUser getUser(String userId);

// Get media record
GetMediaResponse get(String mediaId);

// Get presigned upload URL
GetMediaUploadUrlResponse getUploadUrl(GetMediaUploadUrlRequest request);

HealthResponse health();