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.Connector

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

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

connectorId_

Object connectorId_

connectorType_

Object connectorType_

createdAt_

com.google.protobuf.Timestamp createdAt_

description_

Object description_

managementType_

int managementType_

memoizedIsInitialized

byte memoizedIsInitialized

name_

Object name_

updatedAt_

com.google.protobuf.Timestamp updatedAt_

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.CreateDataSourceRequest

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

serialVersionUID:

0L

Serialized Fields

accountId_

Object accountId_

connectorId_

Object connectorId_

driveName_

Object driveName_

maxFileSize_

long maxFileSize_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

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

name_

Object name_

rateLimitPerMinute_

long rateLimitPerMinute_

Class ai.pipestream.connector.intake.v1.CreateDataSourceResponse

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

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

datasource_

DataSource datasource_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

success_

boolean success_

Class ai.pipestream.connector.intake.v1.DataSource

class DataSource 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_

createdAt_

com.google.protobuf.Timestamp createdAt_

datasourceId_

Object datasourceId_

driveName_

Object driveName_

maxFileSize_

long maxFileSize_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

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

name_

Object name_

rateLimitPerMinute_

long rateLimitPerMinute_

updatedAt_

com.google.protobuf.Timestamp updatedAt_

Class ai.pipestream.connector.intake.v1.DataSourceConfig

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

serialVersionUID:

0L

Serialized Fields

accountId_

Object accountId_

connectorId_

Object connectorId_

datasourceId_

Object datasourceId_

driveName_

Object driveName_

maxFileSize_

long maxFileSize_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

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

rateLimitPerMinute_

long rateLimitPerMinute_

Class ai.pipestream.connector.intake.v1.DeleteDataSourceRequest

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

serialVersionUID:

0L

Serialized Fields

datasourceId_

Object datasourceId_

hardDelete_

boolean hardDelete_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.DeleteDataSourceResponse

class DeleteDataSourceResponse 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.GetConnectorTypeRequest

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

serialVersionUID:

0L

Serialized Fields

connectorId_

Object connectorId_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.GetConnectorTypeResponse

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

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

connector_

Connector connector_

memoizedIsInitialized

byte memoizedIsInitialized

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

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

serialVersionUID:

0L

Serialized Fields

datasourceId_

Object datasourceId_

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.GetDataSourceRequest

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

serialVersionUID:

0L

Serialized Fields

datasourceId_

Object datasourceId_

memoizedIsInitialized

byte memoizedIsInitialized

Class ai.pipestream.connector.intake.v1.GetDataSourceResponse

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

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

datasource_

DataSource datasource_

memoizedIsInitialized

byte memoizedIsInitialized

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.ListConnectorTypesRequest

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

serialVersionUID:

0L

Serialized Fields

managementType_

int managementType_

memoizedIsInitialized

byte memoizedIsInitialized

pageSize_

int pageSize_

pageToken_

Object pageToken_

Class ai.pipestream.connector.intake.v1.ListConnectorTypesResponse

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

serialVersionUID:

0L

Serialized Fields

connectors_

List<Connector> connectors_

memoizedIsInitialized

byte memoizedIsInitialized

nextPageToken_

Object nextPageToken_

totalCount_

int totalCount_

Class ai.pipestream.connector.intake.v1.ListDataSourcesRequest

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

serialVersionUID:

0L

Serialized Fields

accountId_

Object accountId_

connectorId_

Object connectorId_

includeInactive_

boolean includeInactive_

memoizedIsInitialized

byte memoizedIsInitialized

pageSize_

int pageSize_

pageToken_

Object pageToken_

Class ai.pipestream.connector.intake.v1.ListDataSourcesResponse

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

serialVersionUID:

0L

Serialized Fields

datasources_

List<DataSource> datasources_

memoizedIsInitialized

byte memoizedIsInitialized

nextPageToken_

Object nextPageToken_

totalCount_

int totalCount_

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

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

serialVersionUID:

0L

Serialized Fields

datasourceId_

Object datasourceId_

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.SetDataSourceStatusRequest

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

serialVersionUID:

0L

Serialized Fields

active_

boolean active_

datasourceId_

Object datasourceId_

memoizedIsInitialized

byte memoizedIsInitialized

reason_

Object reason_

Class ai.pipestream.connector.intake.v1.SetDataSourceStatusResponse

class SetDataSourceStatusResponse 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_

crawlId_

Object crawlId_

datasourceId_

Object datasourceId_

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.UpdateDataSourceRequest

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

serialVersionUID:

0L

Serialized Fields

datasourceId_

Object datasourceId_

driveName_

Object driveName_

maxFileSize_

long maxFileSize_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

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

name_

Object name_

rateLimitPerMinute_

long rateLimitPerMinute_

Class ai.pipestream.connector.intake.v1.UpdateDataSourceResponse

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

serialVersionUID:

0L

Serialized Fields

bitField0_

int bitField0_

datasource_

DataSource datasource_

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_

content_

com.google.protobuf.ByteString content_

datasourceId_

Object datasourceId_

filename_

Object filename_

memoizedIsInitialized

byte memoizedIsInitialized

metadata_

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

mimeType_

Object mimeType_

path_

Object path_

sessionId_

Object sessionId_

sourceDocId_

Object sourceDocId_

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_

datasourceId_

Object datasourceId_

memoizedIsInitialized

byte memoizedIsInitialized

pipeDoc_

ai.pipestream.data.v1.PipeDoc pipeDoc_

sessionId_

Object sessionId_

sourceDocId_

Object sourceDocId_

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_

datasourceId_

Object datasourceId_

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_

config_

DataSourceConfig config_

memoizedIsInitialized

byte memoizedIsInitialized

message_

Object message_

valid_

boolean valid_