Class SessionManager

java.lang.Object

ai.pipestream.connector.intake.service.SessionManager

@ApplicationScoped
public class SessionManager
extends Object

Service for managing crawl session lifecycle.

Constructor Summary

Constructors

Constructor	Description
SessionManager()

Method Summary

Modifier and Type	Method	Description
void	addBytesProcessed(String sessionId, long bytes)
void	completeSession(String sessionId, String state)
String	createSession(String datasourceId, String crawlId, String accountId, String connectorType, String sourceSystem, String metadata, boolean trackDocuments, boolean deleteOrphans)
CrawlSession	getSession(String sessionId)
void	incrementDocumentsFailed(String sessionId)
void	incrementDocumentsFound(String sessionId)
void	incrementDocumentsProcessed(String sessionId)
void	incrementDocumentsSkipped(String sessionId)
void	updateHeartbeat(String sessionId)

Methods inherited from class Object

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

Constructor Details

SessionManager

public SessionManager()

Method Details

createSession

public String createSession(String datasourceId,
 String crawlId,
 String accountId,
 String connectorType,
 String sourceSystem,
 String metadata,
 boolean trackDocuments,
 boolean deleteOrphans)

getSession

public CrawlSession getSession(String sessionId)

updateHeartbeat

public void updateHeartbeat(String sessionId)

completeSession

public void completeSession(String sessionId,
 String state)

incrementDocumentsFound

public void incrementDocumentsFound(String sessionId)

incrementDocumentsProcessed

public void incrementDocumentsProcessed(String sessionId)

incrementDocumentsFailed

public void incrementDocumentsFailed(String sessionId)

incrementDocumentsSkipped

public void incrementDocumentsSkipped(String sessionId)

addBytesProcessed

public void addBytesProcessed(String sessionId,
 long bytes)