Documentation
¶
Index ¶
- func FilterRawFilePaths(filePaths []string) []string
- func MetadataPath(rawFilePath string) string
- func PermissionsPath(rawFilePath string) string
- func RemapToOutputDir(filePath, inputDir, outputDir string) string
- func StagePath(pipelineName, stageName string) string
- type Chunker
- type ChunkingTool
- type Chunks
- type ChunksDocument
- type ChunksFile
- type ChunksFileMetadata
- type Content
- type ConvertedDocument
- type ConvertedFile
- type ConvertedFileMetadata
- type DataSource
- type Destination
- type DocumentConverter
- type EmbeddingDocument
- type EmbeddingFileMetadata
- type Embeddings
- type EmbeddingsFile
- type GDriveSource
- type MarkdownSplitter
- type RawFileMetadata
- type RecursiveCharacterSplitter
- type S3BucketSource
- type S3Destination
- type TokenSplitter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FilterRawFilePaths ¶
func MetadataPath ¶ added in v0.8.0
func PermissionsPath ¶ added in v0.8.0
func RemapToOutputDir ¶ added in v0.8.0
RemapToOutputDir maps a file from an input stage directory to the output stage directory. e.g. ("stages/crawl/f.pdf", "stages/crawl/", "stages/convert/") => "stages/convert/f.pdf"
Types ¶
type ChunkingTool ¶
type ChunkingTool string
const (
LangchainChunkingTool ChunkingTool = "langchain"
)
type ChunksDocument ¶
type ChunksDocument struct {
Metadata *ChunksFileMetadata `json:"metadata"`
Chunks *Chunks `json:"chunks"`
}
type ChunksFile ¶
type ChunksFile struct {
ConvertedDocument *ConvertedDocument `json:"convertedDocument"`
ChunksDocument *ChunksDocument `json:"chunksDocument"`
}
type ChunksFileMetadata ¶
type ChunksFileMetadata struct {
ConvertedFileMetadata *ConvertedFileMetadata `json:"convertedFileMetadata"`
ChunkingTool ChunkingTool `json:"chunkingTool"`
ChunksGeneratorConfig v1alpha1.ChunksGeneratorConfig `json:"chunksGeneratorConfig"`
}
func (*ChunksFileMetadata) Equal ¶
func (c *ChunksFileMetadata) Equal(other *ChunksFileMetadata) bool
type ConvertedDocument ¶
type ConvertedDocument struct {
Metadata *ConvertedFileMetadata `json:"metadata"`
Content *Content `json:"content"`
}
type ConvertedFile ¶
type ConvertedFile struct {
ConvertedDocument *ConvertedDocument `json:"convertedDocument"`
}
type ConvertedFileMetadata ¶
type ConvertedFileMetadata struct {
RawFilePath string `json:"rawFilePath"`
FileIdentifier string `json:"fileIdentifier"`
DocumentConverter DocumentConverter `json:"documentConverter"`
DoclingConfig v1alpha1.DoclingConfig `json:"doclingConfig"`
}
func (*ConvertedFileMetadata) Equal ¶
func (c *ConvertedFileMetadata) Equal(other *ConvertedFileMetadata) bool
type DataSource ¶
type Destination ¶
type DocumentConverter ¶
type DocumentConverter string
const (
DocumentConverterDocling DocumentConverter = "docling"
)
type EmbeddingDocument ¶ added in v0.2.0
type EmbeddingDocument struct {
Metadata *EmbeddingFileMetadata `json:"metadata"`
Embeddings []*Embeddings `json:"embeddings"`
}
type EmbeddingFileMetadata ¶ added in v0.2.0
type EmbeddingFileMetadata struct {
ConvertedFileMetadata *ConvertedFileMetadata `json:"convertedFileMetadata"`
ChunkFileMetadata *ChunksFileMetadata `json:"chunkFileMetadata"`
ModelName string `json:"modelName"`
NomicEmbedTextV15Config v1alpha1.NomicEmbedTextV15Config `json:"nomicEmbedTextV15Config,omitempty"`
}
func (*EmbeddingFileMetadata) Equal ¶ added in v0.2.0
func (c *EmbeddingFileMetadata) Equal(other *EmbeddingFileMetadata) bool
type Embeddings ¶ added in v0.2.0
type EmbeddingsFile ¶ added in v0.2.0
type EmbeddingsFile struct {
ConvertedDocument *ConvertedDocument `json:"convertedDocument"`
ChunksDocument *ChunksDocument `json:"chunksDocument"`
EmbeddingDocument *EmbeddingDocument `json:"embeddingDocument"`
}
type GDriveSource ¶ added in v0.8.0
type GDriveSource struct {
GDriveClient *gdrive.Client
FolderIDs []string
SkipFolderNames []string
MaxRetries int
ConcurrentFolders int
ConcurrentDownloads int
OutputDir string
}
GDriveSource implements DataSource for Google Drive folders.
func (*GDriveSource) Close ¶ added in v0.8.0
func (g *GDriveSource) Close()
Close releases resources held by the underlying clients.
func (*GDriveSource) SyncFilesToFilestore ¶ added in v0.8.0
func (g *GDriveSource) SyncFilesToFilestore(ctx context.Context, fs *filestore.FileStore) ([]RawFileMetadata, error)
type MarkdownSplitter ¶
type MarkdownSplitter struct {
LangchainClient *langchain.Client
Config *textsplitter.Options
}
type RawFileMetadata ¶
type RecursiveCharacterSplitter ¶
type RecursiveCharacterSplitter struct {
LangchainClient *langchain.Client
Config *textsplitter.Options
}
type S3BucketSource ¶
func (*S3BucketSource) SyncFilesToFilestore ¶
func (s *S3BucketSource) SyncFilesToFilestore(ctx context.Context, fs *filestore.FileStore) ([]RawFileMetadata, error)
type S3Destination ¶ added in v0.2.0
S3Destination syncs files to an S3 bucket at prefix/stages/<stageName>/.
func (*S3Destination) SyncFilesToDestination ¶ added in v0.2.0
type TokenSplitter ¶
type TokenSplitter struct {
LangchainClient *langchain.Client
Config *textsplitter.Options
}
Click to show internal directories.
Click to hide internal directories.