Serialized Form

Package ai.pipeline.connector.intake.entity

Class ai.pipeline.connector.intake.entity.CrawlDocument.CrawlDocumentId

class CrawlDocumentId extends Object implements Serializable

Serialized Fields

crawlSessionId

String crawlSessionId

Crawl session identifier (UUID of the session that processed the document).

sourceId

String sourceId

Source-system unique identifier for the document (e.g., external ID or path).

Package ai.pipestream.connector.intake.v1

Class ai.pipestream.connector.intake.v1.ConnectorConfig

class ConnectorConfig extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

accountId_

Object accountId_

defaultMetadata_

com.google.protobuf.MapField<String,String> defaultMetadata_

maxFileSize_

long maxFileSize_

memoizedIsInitialized

byte memoizedIsInitialized

rateLimitPerMinute_

long rateLimitPerMinute_

s3BasePath_

Object s3BasePath_

s3Bucket_

Object s3Bucket_

Class ai.pipestream.connector.intake.v1.ConnectorRegistration

class ConnectorRegistration extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

accountId_

Object accountId_

active_

boolean active_

apiKey_

Object apiKey_

bitField0_

int bitField0_

connectorId_

Object connectorId_

connectorName_

Object connectorName_

connectorType_

Object connectorType_

created_

com.google.protobuf.Timestamp created_

defaultMetadata_

com.google.protobuf.MapField<String,String> defaultMetadata_

maxFileSize_

long maxFileSize_

memoizedIsInitialized

byte memoizedIsInitialized

rateLimitPerMinute_

long rateLimitPerMinute_

s3BasePath_

Object s3BasePath_

s3Bucket_

Object s3Bucket_

updated_

com.google.protobuf.Timestamp updated_

Class ai.pipestream.connector.intake.v1.CrawlMetadata

class CrawlMetadata extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

connectorType_

Object connectorType_

connectorVersion_

Object connectorVersion_

crawlStarted_

com.google.protobuf.Timestamp crawlStarted_

memoizedIsInitialized

byte memoizedIsInitialized

parameters_

com.google.protobuf.MapField<String,String> parameters_

sourceSystem_

Object sourceSystem_

Class ai.pipestream.connector.intake.v1.CrawlSessionSummary

class CrawlSessionSummary extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

bytesProcessed_

long bytesProcessed_

completedAt_

com.google.protobuf.Timestamp completedAt_

crawlId_

Object crawlId_

documentsFailed_

int documentsFailed_

documentsFound_

int documentsFound_

documentsProcessed_

int documentsProcessed_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

com.google.protobuf.MapField<String,String> metadata_

sessionId_

Object sessionId_

startedAt_

com.google.protobuf.Timestamp startedAt_

status_

Object status_

Class ai.pipestream.connector.intake.v1.CrawlSummary

class CrawlSummary extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

bytesProcessed_

long bytesProcessed_

completed_

com.google.protobuf.Timestamp completed_

documentsFailed_

int documentsFailed_

documentsFound_

int documentsFound_

documentsProcessed_

int documentsProcessed_

documentsSkipped_

int documentsSkipped_

memoizedIsInitialized

byte memoizedIsInitialized

started_

com.google.protobuf.Timestamp started_

statistics_

com.google.protobuf.MapField<String,String> statistics_

Class ai.pipestream.connector.intake.v1.DeleteConnectorRequest

class DeleteConnectorRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

connectorId_

Object connectorId_

hardDelete_

boolean hardDelete_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.DeleteConnectorResponse

class DeleteConnectorResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

crawlSessionsDeleted_

int crawlSessionsDeleted_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.EndCrawlSessionRequest

class EndCrawlSessionRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

crawlId_

Object crawlId_

memoizedIsInitialized

byte memoizedIsInitialized

sessionId_

Object sessionId_

summary_

CrawlSummary summary_

Class ai.pipestream.connector.intake.v1.EndCrawlSessionResponse

class EndCrawlSessionResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

orphansDeleted_

int orphansDeleted_

orphansFound_

int orphansFound_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.GetConnectorRequest

class GetConnectorRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

connectorId_

Object connectorId_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.GetConnectorResponse

class GetConnectorResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

connector_

ConnectorRegistration connector_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.GetCrawlHistoryRequest

class GetCrawlHistoryRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

connectorId_

Object connectorId_

limit_

int limit_

memoizedIsInitialized

byte memoizedIsInitialized

pageToken_

Object pageToken_

Class ai.pipestream.connector.intake.v1.GetCrawlHistoryResponse

class GetCrawlHistoryResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

nextPageToken_

Object nextPageToken_

sessions_

List<CrawlSessionSummary> sessions_

Class ai.pipestream.connector.intake.v1.GetUploadProgressRequest

class GetUploadProgressRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

fileId_

Object fileId_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.GetUploadProgressResponse

class GetUploadProgressResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

chunksReceived_

int chunksReceived_

chunksUploadedToS3_

int chunksUploadedToS3_

complete_

boolean complete_

fileId_

Object fileId_

memoizedIsInitialized

byte memoizedIsInitialized

result_

UploadResult result_

totalChunks_

int totalChunks_

Class ai.pipestream.connector.intake.v1.HeartbeatRequest

class HeartbeatRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

crawlId_

Object crawlId_

documentsProcessing_

int documentsProcessing_

documentsQueued_

int documentsQueued_

memoizedIsInitialized

byte memoizedIsInitialized

metrics_

com.google.protobuf.MapField<String,String> metrics_

sessionId_

Object sessionId_

Class ai.pipestream.connector.intake.v1.HeartbeatResponse

class HeartbeatResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

command_

int command_

configUpdates_

com.google.protobuf.MapField<String,String> configUpdates_

memoizedIsInitialized

byte memoizedIsInitialized

sessionValid_

boolean sessionValid_

Class ai.pipestream.connector.intake.v1.ListConnectorsRequest

class ListConnectorsRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

accountId_

Object accountId_

includeInactive_

boolean includeInactive_

memoizedIsInitialized

byte memoizedIsInitialized

pageSize_

int pageSize_

pageToken_

Object pageToken_

Class ai.pipestream.connector.intake.v1.ListConnectorsResponse

class ListConnectorsResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

connectors_

List<ConnectorRegistration> connectors_

memoizedIsInitialized

byte memoizedIsInitialized

nextPageToken_

Object nextPageToken_

totalCount_

int totalCount_

Class ai.pipestream.connector.intake.v1.RegisterConnectorRequest

class RegisterConnectorRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

accountId_

Object accountId_

connectorName_

Object connectorName_

connectorType_

Object connectorType_

defaultMetadata_

com.google.protobuf.MapField<String,String> defaultMetadata_

maxFileSize_

long maxFileSize_

memoizedIsInitialized

byte memoizedIsInitialized

rateLimitPerMinute_

long rateLimitPerMinute_

s3BasePath_

Object s3BasePath_

s3Bucket_

Object s3Bucket_

Class ai.pipestream.connector.intake.v1.RegisterConnectorResponse

class RegisterConnectorResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

apiKey_

Object apiKey_

connectorId_

Object connectorId_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.RotateApiKeyRequest

class RotateApiKeyRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

connectorId_

Object connectorId_

invalidateOldImmediately_

boolean invalidateOldImmediately_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.RotateApiKeyResponse

class RotateApiKeyResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

newApiKey_

Object newApiKey_

oldKeyExpires_

com.google.protobuf.Timestamp oldKeyExpires_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.SetConnectorStatusRequest

class SetConnectorStatusRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

active_

boolean active_

connectorId_

Object connectorId_

memoizedIsInitialized

byte memoizedIsInitialized

reason_

Object reason_

Class ai.pipestream.connector.intake.v1.SetConnectorStatusResponse

class SetConnectorStatusResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.StartCrawlSessionRequest

class StartCrawlSessionRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

apiKey_

Object apiKey_

bitField0_

int bitField0_

connectorId_

Object connectorId_

crawlId_

Object crawlId_

deleteOrphans_

boolean deleteOrphans_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

CrawlMetadata metadata_

trackDocuments_

boolean trackDocuments_

Class ai.pipestream.connector.intake.v1.StartCrawlSessionResponse

class StartCrawlSessionResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

crawlId_

Object crawlId_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

sessionId_

Object sessionId_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.StreamUploadProgressRequest

class StreamUploadProgressRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

fileId_

Object fileId_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.StreamUploadProgressResponse

class StreamUploadProgressResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

chunksReceived_

int chunksReceived_

chunksUploadedToS3_

int chunksUploadedToS3_

complete_

boolean complete_

fileId_

Object fileId_

memoizedIsInitialized

byte memoizedIsInitialized

result_

UploadResult result_

totalChunks_

int totalChunks_

Class ai.pipestream.connector.intake.v1.UpdateConnectorRequest

class UpdateConnectorRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

connectorId_

Object connectorId_

connectorName_

Object connectorName_

defaultMetadata_

com.google.protobuf.MapField<String,String> defaultMetadata_

maxFileSize_

long maxFileSize_

memoizedIsInitialized

byte memoizedIsInitialized

rateLimitPerMinute_

long rateLimitPerMinute_

s3BasePath_

Object s3BasePath_

s3Bucket_

Object s3Bucket_

Class ai.pipestream.connector.intake.v1.UpdateConnectorResponse

class UpdateConnectorResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

connector_

ConnectorRegistration connector_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.UploadBlobRequest

class UploadBlobRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

apiKey_

Object apiKey_

connectorId_

Object connectorId_

content_

com.google.protobuf.ByteString content_

filename_

Object filename_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

com.google.protobuf.MapField<String,String> metadata_

mimeType_

Object mimeType_

path_

Object path_

sessionId_

Object sessionId_

Class ai.pipestream.connector.intake.v1.UploadBlobResponse

class UploadBlobResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

docId_

Object docId_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.UploadChunkRequest

class UploadChunkRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

chunkNumber_

int chunkNumber_

crawlId_

Object crawlId_

data_

com.google.protobuf.ByteString data_

fileId_

Object fileId_

filename_

Object filename_

fileSize_

long fileSize_

isLast_

boolean isLast_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

com.google.protobuf.MapField<String,String> metadata_

mimeType_

Object mimeType_

path_

Object path_

totalChunks_

int totalChunks_

Class ai.pipestream.connector.intake.v1.UploadChunkResponse

class UploadChunkResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

chunkNumber_

int chunkNumber_

fileId_

Object fileId_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

result_

UploadResult result_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.UploadPipeDocRequest

class UploadPipeDocRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

apiKey_

Object apiKey_

bitField0_

int bitField0_

connectorId_

Object connectorId_

memoizedIsInitialized

byte memoizedIsInitialized

pipeDoc_

ai.pipestream.data.v1.PipeDoc pipeDoc_

sessionId_

Object sessionId_

Class ai.pipestream.connector.intake.v1.UploadPipeDocResponse

class UploadPipeDocResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

docId_

Object docId_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.UploadResult

class UploadResult extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

checksum_

Object checksum_

fileId_

Object fileId_

memoizedIsInitialized

byte memoizedIsInitialized

s3Etag_

Object s3Etag_

s3Key_

Object s3Key_

size_

long size_

Class ai.pipestream.connector.intake.v1.ValidateApiKeyRequest

class ValidateApiKeyRequest extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

apiKey_

Object apiKey_

connectorId_

Object connectorId_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.ValidateApiKeyResponse

class ValidateApiKeyResponse extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

connector_

ConnectorRegistration connector_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

valid_

boolean valid_