Class CrawlSession

java.lang.Object

io.quarkus.hibernate.orm.panache.PanacheEntityBase

ai.pipeline.connector.intake.entity.CrawlSession

@Entity
public class CrawlSession
extends io.quarkus.hibernate.orm.panache.PanacheEntityBase

Crawl session entity tracking document ingestion sessions.

Each crawl session represents a single ingestion run from a connector. Sessions track statistics, state, and metadata for monitoring and orphan detection.

Database Table: crawl_sessions

Field Summary

Fields

Modifier and Type	Field	Description
String	accountId	Account ID this connector belongs to.
Long	bytesProcessed	Total bytes processed.
OffsetDateTime	completedAt	Timestamp when session completed.
String	connectorType	Connector type identifier.
String	crawlId	Client-provided crawl ID.
String	datasourceId	DataSource ID that started this session.
Boolean	deleteOrphans	Whether to delete orphans at end of crawl.
Integer	documentsFailed	Number of documents that failed processing.
Integer	documentsFound	Number of documents found during crawl.
Integer	documentsProcessed	Number of documents successfully processed.
Integer	documentsSkipped	Number of documents skipped.
String	id	Unique session identifier (primary key).
OffsetDateTime	lastHeartbeat	Timestamp of last heartbeat.
String	metadata	Crawl metadata as JSON.
String	sourceSystem	Source system identifier.
OffsetDateTime	startedAt	Timestamp when session started.
String	state	Session state.
Boolean	trackDocuments	Whether to track documents for orphan detection.

Constructor Summary

Constructors

Constructor	Description
CrawlSession()	Default constructor for JPA.
CrawlSession(String id, String datasourceId, String crawlId, String accountId, String state)	Create a new crawl session.

Method Summary

Methods inherited from class io.quarkus.hibernate.orm.panache.PanacheEntityBase

count, count, count, count, delete, delete, delete, delete, deleteAll, deleteById, find, find, find, find, find, find, findAll, findAll, findById, findById, findByIdOptional, findByIdOptional, findByIds, flush, getEntityManager, getSession, isPersistent, list, list, list, list, list, list, listAll, listAll, persist, persist, persist, persist, persistAndFlush, stream, stream, stream, stream, stream, stream, streamAll, streamAll, update, update, update

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

id

public String id

Unique session identifier (primary key). Generated as UUID.

datasourceId

public String datasourceId

DataSource ID that started this session. References datasource-admin service (not enforced cross-DB).

crawlId

public String crawlId

Client-provided crawl ID. Unique per connector.

accountId

public String accountId

Account ID this connector belongs to. Copied from connector for efficient queries.

state

public String state

Session state. Values: RUNNING, COMPLETED, FAILED, TERMINATED

startedAt

public OffsetDateTime startedAt

Timestamp when session started.

completedAt

public OffsetDateTime completedAt

Timestamp when session completed. Null if session is still running.

lastHeartbeat

public OffsetDateTime lastHeartbeat

Timestamp of last heartbeat. Used for timeout detection.

documentsFound

public Integer documentsFound

Number of documents found during crawl.

documentsProcessed

public Integer documentsProcessed

Number of documents successfully processed.

documentsFailed

public Integer documentsFailed

Number of documents that failed processing.

documentsSkipped

public Integer documentsSkipped

Number of documents skipped.

bytesProcessed

public Long bytesProcessed

Total bytes processed.

trackDocuments

public Boolean trackDocuments

Whether to track documents for orphan detection.

deleteOrphans

public Boolean deleteOrphans

Whether to delete orphans at end of crawl.

connectorType

public String connectorType

Connector type identifier.

sourceSystem

public String sourceSystem

Source system identifier.

metadata

public String metadata

Crawl metadata as JSON.

Constructor Details

CrawlSession

public CrawlSession()

Default constructor for JPA.

CrawlSession

public CrawlSession(String id,
 String datasourceId,
 String crawlId,
 String accountId,
 String state)

Create a new crawl session.

Parameters:

id - Session ID (UUID)

datasourceId - DataSource ID

crawlId - Client-provided crawl ID

accountId - Account ID

state - Initial state