include/paimon_ftindex.h

#ifndef PAIMON_FTINDEX_H
#define PAIMON_FTINDEX_H

#include <stdint.h>
#include <stddef.h>

#ifdef __cplusplus
extern "C" {
#endif

typedef struct PaimonFtindexWriterHandle PaimonFtindexWriterHandle;
typedef struct PaimonFtindexReaderHandle PaimonFtindexReaderHandle;

typedef struct {
    void *ctx;
    int (*write_fn)(void *ctx, const uint8_t *buf, size_t len);
    int (*flush_fn)(void *ctx);
} PaimonFtindexOutputFile;

typedef struct {
    void *ctx;
    int (*read_at_fn)(void *ctx, uint64_t pos, uint8_t *buf, size_t len);
} PaimonFtindexInputFile;

const char *paimon_ftindex_last_error(void);

PaimonFtindexWriterHandle *paimon_ftindex_writer_open(
    const char **keys,
    const char **values,
    size_t len);

int paimon_ftindex_writer_add_document(
    PaimonFtindexWriterHandle *writer,
    int64_t row_id,
    const char *text);

int paimon_ftindex_writer_write_index(
    PaimonFtindexWriterHandle *writer,
    PaimonFtindexOutputFile output);

void paimon_ftindex_writer_free(PaimonFtindexWriterHandle *writer);

PaimonFtindexReaderHandle *paimon_ftindex_reader_open(PaimonFtindexInputFile input);

int paimon_ftindex_reader_search_json(
    PaimonFtindexReaderHandle *reader,
    const char *query_json,
    size_t limit,
    int64_t *row_ids,
    float *scores,
    size_t capacity,
    size_t *result_len);

void paimon_ftindex_reader_free(PaimonFtindexReaderHandle *reader);

#ifdef __cplusplus
}
#endif

#endif