v1alpha1

package

Go to main page

Versions in this module

v0

v0.10.2

Jul 24, 2026

v0.10.1

Jul 6, 2026

v0.10.0

Jul 6, 2026

Changes in this version

+ const DefaultChunkOverlap

+ const DefaultChunkSize

+ const DefaultChunkingStrategy

+ const DefaultDocumentProcessorType

+ const DefaultEmbeddingBatchSize

+ const DefaultEmbeddingModelName

+ const DefaultImageExportMode

+ const DefaultImagesScale

+ const DefaultOCRPreset

+ const DefaultPDFBackend

+ const DefaultPipeline

+ const DefaultTableMode

type ChunksGeneratorConfig

+ func (c *ChunksGeneratorConfig) SetDefaults()

type DoclingConfig

+ DoChartExtraction bool

+ DoCodeEnrichment bool

+ DoFormulaEnrichment bool

+ DoPictureClassification bool

+ DoPictureDescription bool

+ DoTableStructure *bool

+ DocumentTimeout string

+ ImagesScale string

+ IncludeImages *bool

+ MdPageBreakPlaceholder string

+ OCRPreset string

+ PageRange []int

+ PictureDescriptionAreaThreshold string

+ Pipeline string

+ TableCellMatching *bool

+ func (c *DoclingConfig) SetDefaults()

type DocumentProcessorConfig

+ func (c *DocumentProcessorConfig) SetDefaults()

type VectorEmbeddingsGeneratorConfig

+ func (c *VectorEmbeddingsGeneratorConfig) SetDefaults()

v0.9.1

Jul 5, 2026

v0.9.0

Jul 5, 2026

Changes in this version

type VectorEmbeddingsGeneratorConfig

+ BatchSize int

v0.8.0

Jul 2, 2026

Changes in this version

+ const DestinationSyncerCondition

+ const SourceCrawlerCondition

+ const TypeGoogleDrive

+ const UnstructuredDataPipelineCondition

+ func ConditionTypeForStage(t StageType) string

+ func ValidateStages(stages []PipelineStage) error

type ChunksGenerator

+ func (c *ChunksGenerator) GetFilesProcessed() int64

type ChunksGeneratorSpec

+ DependsOn []StageDependency

+ StageName string

type ChunksGeneratorStatus

+ FilesProcessed int64

type ControllerConfigSpec

+ CacheDirectory string

+ DataStorageBucket string

+ DoclingServeURL string

+ GoogleDriveConfig *GoogleDriveControllerConfig

+ LDAPConfig *LDAPConfig

+ MaxConcurrentDoclingTasks int

+ MaxConcurrentLangchainTasks int

+ SecretRef string

+ UnstructuredDataPipelineResyncInterval *int

+ type DestinationSyncer struct

+ Spec DestinationSyncerSpec

+ Status DestinationSyncerStatus

+ func (d *DestinationSyncer) GetFilesProcessed() int64

+ func (d *DestinationSyncer) SetWaiting()

+ func (d *DestinationSyncer) UpdateStatus(message string, err error)

+ func (in *DestinationSyncer) DeepCopy() *DestinationSyncer

+ func (in *DestinationSyncer) DeepCopyInto(out *DestinationSyncer)

+ func (in *DestinationSyncer) DeepCopyObject() runtime.Object

+ type DestinationSyncerConfig struct

+ S3DestinationConfig S3Config

+ Type UnstructuredDataType

+ func (in *DestinationSyncerConfig) DeepCopy() *DestinationSyncerConfig

+ func (in *DestinationSyncerConfig) DeepCopyInto(out *DestinationSyncerConfig)

+ type DestinationSyncerList struct

+ Items []DestinationSyncer

+ func (in *DestinationSyncerList) DeepCopy() *DestinationSyncerList

+ func (in *DestinationSyncerList) DeepCopyInto(out *DestinationSyncerList)

+ func (in *DestinationSyncerList) DeepCopyObject() runtime.Object

+ type DestinationSyncerSpec struct

+ DependsOn []StageDependency

+ DestinationSyncerConfig DestinationSyncerConfig

+ SecretRef string

+ StageName string

+ func (in *DestinationSyncerSpec) DeepCopy() *DestinationSyncerSpec

+ func (in *DestinationSyncerSpec) DeepCopyInto(out *DestinationSyncerSpec)

+ type DestinationSyncerStatus struct

+ Conditions []metav1.Condition

+ FilesProcessed int64

+ LastAppliedGeneration int64

+ func (in *DestinationSyncerStatus) DeepCopy() *DestinationSyncerStatus

+ func (in *DestinationSyncerStatus) DeepCopyInto(out *DestinationSyncerStatus)

type DocumentProcessor

+ func (d *DocumentProcessor) GetFilesProcessed() int64

type DocumentProcessorSpec

+ DependsOn []StageDependency

+ StageName string

type DocumentProcessorStatus

+ FilesProcessed int64

+ type GoogleDriveConfig struct

+ Folders []GoogleDriveFolders

+ SkipFolders []SkipFolders

+ func (in *GoogleDriveConfig) DeepCopy() *GoogleDriveConfig

+ func (in *GoogleDriveConfig) DeepCopyInto(out *GoogleDriveConfig)

+ type GoogleDriveControllerConfig struct

+ ConcurrentDownloads int

+ ConcurrentFolders int

+ MaxRetries int

+ func (in *GoogleDriveControllerConfig) DeepCopy() *GoogleDriveControllerConfig

+ func (in *GoogleDriveControllerConfig) DeepCopyInto(out *GoogleDriveControllerConfig)

+ type GoogleDriveFolders struct

+ URL string

+ func (in *GoogleDriveFolders) DeepCopy() *GoogleDriveFolders

+ func (in *GoogleDriveFolders) DeepCopyInto(out *GoogleDriveFolders)

type Job

+ FileIdentifier string

+ type LDAPConfig struct

+ Attributes []string

+ BaseUserDN string

+ EmailAttribute string

+ GroupDN string

+ Server string

+ UserDN string

+ UserSearchFilter string

+ func (in *LDAPConfig) DeepCopy() *LDAPConfig

+ func (in *LDAPConfig) DeepCopyInto(out *LDAPConfig)

+ type PipelineStage struct

+ ChunksGeneratorConfig *ChunksGeneratorConfig

+ DependsOn []StageDependency

+ DestinationSyncerConfig *DestinationSyncerConfig

+ DocumentProcessorConfig *DocumentProcessorConfig

+ Name string

+ QueryConfig *QueryConfig

+ SourceCrawlerConfig *SourceCrawlerConfig

+ Type StageType

+ VectorEmbeddingsGeneratorConfig *VectorEmbeddingsGeneratorConfig

+ func (in *PipelineStage) DeepCopy() *PipelineStage

+ func (in *PipelineStage) DeepCopyInto(out *PipelineStage)

+ type QueryConfig struct

+ Snowflake *SnowflakeQueryConfig

+ Type QueryEndpointType

+ func (in *QueryConfig) DeepCopy() *QueryConfig

+ func (in *QueryConfig) DeepCopyInto(out *QueryConfig)

+ type QueryEndpointType string

+ const QueryEndpointTypeSnowflake

type S3Config

+ SQSQueueURL string

+ type SkipFolders struct

+ Pattern string

+ func (in *SkipFolders) DeepCopy() *SkipFolders

+ func (in *SkipFolders) DeepCopyInto(out *SkipFolders)

+ type SnowflakeQueryConfig struct

+ Account string

+ Database string

+ Schema string

+ Table string

+ func (in *SnowflakeQueryConfig) DeepCopy() *SnowflakeQueryConfig

+ func (in *SnowflakeQueryConfig) DeepCopyInto(out *SnowflakeQueryConfig)

+ type SourceCrawler struct

+ Spec SourceCrawlerSpec

+ Status SourceCrawlerStatus

+ func (c *SourceCrawler) GetFilesProcessed() int64

+ func (c *SourceCrawler) SetWaiting()

+ func (c *SourceCrawler) UpdateStatus(message string, err error)

+ func (in *SourceCrawler) DeepCopy() *SourceCrawler

+ func (in *SourceCrawler) DeepCopyInto(out *SourceCrawler)

+ func (in *SourceCrawler) DeepCopyObject() runtime.Object

+ type SourceCrawlerConfig struct

+ GoogleDriveConfig *GoogleDriveConfig

+ S3Config S3Config

+ Type UnstructuredDataType

+ func (in *SourceCrawlerConfig) DeepCopy() *SourceCrawlerConfig

+ func (in *SourceCrawlerConfig) DeepCopyInto(out *SourceCrawlerConfig)

+ type SourceCrawlerList struct

+ Items []SourceCrawler

+ func (in *SourceCrawlerList) DeepCopy() *SourceCrawlerList

+ func (in *SourceCrawlerList) DeepCopyInto(out *SourceCrawlerList)

+ func (in *SourceCrawlerList) DeepCopyObject() runtime.Object

+ type SourceCrawlerSpec struct

+ DependsOn []StageDependency

+ SecretRef string

+ SourceCrawlerConfig SourceCrawlerConfig

+ StageName string

+ func (in *SourceCrawlerSpec) DeepCopy() *SourceCrawlerSpec

+ func (in *SourceCrawlerSpec) DeepCopyInto(out *SourceCrawlerSpec)

+ type SourceCrawlerStatus struct

+ Conditions []metav1.Condition

+ FilesProcessed int64

+ LastAppliedGeneration int64

+ func (in *SourceCrawlerStatus) DeepCopy() *SourceCrawlerStatus

+ func (in *SourceCrawlerStatus) DeepCopyInto(out *SourceCrawlerStatus)

+ type StageCreationStatus struct

+ Created bool

+ Name string

+ func (in *StageCreationStatus) DeepCopy() *StageCreationStatus

+ func (in *StageCreationStatus) DeepCopyInto(out *StageCreationStatus)

+ type StageDependency struct

+ Name string

+ func (in *StageDependency) DeepCopy() *StageDependency

+ func (in *StageDependency) DeepCopyInto(out *StageDependency)

+ type StageMapping struct

+ Object client.Object

+ ObjectList client.ObjectList

+ Type StageType

+ func ListStages() []StageMapping

+ type StageType string

+ const StageTypeChunksGenerator

+ const StageTypeDestinationSyncer

+ const StageTypeDocumentProcessor

+ const StageTypeSourceCrawler

+ const StageTypeVectorEmbeddingsGenerator

+ type UnstructuredDataPipeline struct

+ Spec UnstructuredDataPipelineSpec

+ Status UnstructuredDataPipelineStatus

+ func (in *UnstructuredDataPipeline) DeepCopy() *UnstructuredDataPipeline

+ func (in *UnstructuredDataPipeline) DeepCopyInto(out *UnstructuredDataPipeline)

+ func (in *UnstructuredDataPipeline) DeepCopyObject() runtime.Object

+ func (u *UnstructuredDataPipeline) SetWaiting()

+ func (u *UnstructuredDataPipeline) UpdateStatus(message string, err error)

+ type UnstructuredDataPipelineList struct

+ Items []UnstructuredDataPipeline

+ func (in *UnstructuredDataPipelineList) DeepCopy() *UnstructuredDataPipelineList

+ func (in *UnstructuredDataPipelineList) DeepCopyInto(out *UnstructuredDataPipelineList)

+ func (in *UnstructuredDataPipelineList) DeepCopyObject() runtime.Object

+ type UnstructuredDataPipelineSpec struct

+ Description string

+ SecretRef string

+ Stages []PipelineStage

+ func (in *UnstructuredDataPipelineSpec) DeepCopy() *UnstructuredDataPipelineSpec

+ func (in *UnstructuredDataPipelineSpec) DeepCopyInto(out *UnstructuredDataPipelineSpec)

+ type UnstructuredDataPipelineStatus struct

+ Conditions []metav1.Condition

+ LastAppliedGeneration int64

+ Stages []StageCreationStatus

+ func (in *UnstructuredDataPipelineStatus) DeepCopy() *UnstructuredDataPipelineStatus

+ func (in *UnstructuredDataPipelineStatus) DeepCopyInto(out *UnstructuredDataPipelineStatus)

type VectorEmbeddingsGenerator

+ func (c *VectorEmbeddingsGenerator) GetFilesProcessed() int64

type VectorEmbeddingsGeneratorSpec

+ DependsOn []StageDependency

+ StageName string

type VectorEmbeddingsGeneratorStatus

+ FilesProcessed int64

v0.6.2

May 29, 2026

v0.6.1

May 7, 2026

v0.6.0

Apr 23, 2026

v0.5.0

Apr 13, 2026

v0.4.0

Mar 25, 2026

v0.3.0

Mar 24, 2026

v0.2.0

Mar 19, 2026

Changes in this version

+ const SQSInformerCondition

+ const TypeS3

+ const VectorEmbeddingGenerationConditionType

type ControllerConfigSpec

+ UnstructuredSecret string

type DestinationConfig

+ S3DestinationConfig S3Config

+ type EmbeddingProvider string

+ type NomicEmbedTextV15Config struct

+ EncodingFormat string

+ func (in *NomicEmbedTextV15Config) DeepCopy() *NomicEmbedTextV15Config

+ func (in *NomicEmbedTextV15Config) DeepCopyInto(out *NomicEmbedTextV15Config)

+ type SQSInformer struct

+ Spec SQSInformerSpec

+ Status SQSInformerStatus

+ func (c *SQSInformer) SetWaiting()

+ func (c *SQSInformer) UpdateStatus(message string, err error)

+ func (in *SQSInformer) DeepCopy() *SQSInformer

+ func (in *SQSInformer) DeepCopyInto(out *SQSInformer)

+ func (in *SQSInformer) DeepCopyObject() runtime.Object

+ type SQSInformerList struct

+ Items []SQSInformer

+ func (in *SQSInformerList) DeepCopy() *SQSInformerList

+ func (in *SQSInformerList) DeepCopyInto(out *SQSInformerList)

+ func (in *SQSInformerList) DeepCopyObject() runtime.Object

+ type SQSInformerSpec struct

+ QueueURL string

+ func (in *SQSInformerSpec) DeepCopy() *SQSInformerSpec

+ func (in *SQSInformerSpec) DeepCopyInto(out *SQSInformerSpec)

+ type SQSInformerStatus struct

+ Conditions []metav1.Condition

+ LastAppliedGeneration int64

+ func (in *SQSInformerStatus) DeepCopy() *SQSInformerStatus

+ func (in *SQSInformerStatus) DeepCopyInto(out *SQSInformerStatus)

type UnstructuredDataProductSpec

+ VectorEmbeddingsGeneratorConfig VectorEmbeddingsGeneratorConfig

+ type UnstructuredDataType string

+ type VectorEmbeddingsGenerator struct

+ Spec VectorEmbeddingsGeneratorSpec

+ Status VectorEmbeddingsGeneratorStatus

+ func (c *VectorEmbeddingsGenerator) SetWaiting()

+ func (c *VectorEmbeddingsGenerator) UpdateStatus(message string, err error)

+ func (in *VectorEmbeddingsGenerator) DeepCopy() *VectorEmbeddingsGenerator

+ func (in *VectorEmbeddingsGenerator) DeepCopyInto(out *VectorEmbeddingsGenerator)

+ func (in *VectorEmbeddingsGenerator) DeepCopyObject() runtime.Object

+ type VectorEmbeddingsGeneratorConfig struct

+ ModelName string

+ NomicEmbedTextV15Config NomicEmbedTextV15Config

+ func (in *VectorEmbeddingsGeneratorConfig) DeepCopy() *VectorEmbeddingsGeneratorConfig

+ func (in *VectorEmbeddingsGeneratorConfig) DeepCopyInto(out *VectorEmbeddingsGeneratorConfig)

+ type VectorEmbeddingsGeneratorList struct

+ Items []VectorEmbeddingsGenerator

+ func (in *VectorEmbeddingsGeneratorList) DeepCopy() *VectorEmbeddingsGeneratorList

+ func (in *VectorEmbeddingsGeneratorList) DeepCopyInto(out *VectorEmbeddingsGeneratorList)

+ func (in *VectorEmbeddingsGeneratorList) DeepCopyObject() runtime.Object

+ type VectorEmbeddingsGeneratorSpec struct

+ DataProduct string

+ VectorEmbeddingsGeneratorConfig VectorEmbeddingsGeneratorConfig

+ func (in *VectorEmbeddingsGeneratorSpec) DeepCopy() *VectorEmbeddingsGeneratorSpec

+ func (in *VectorEmbeddingsGeneratorSpec) DeepCopyInto(out *VectorEmbeddingsGeneratorSpec)

+ type VectorEmbeddingsGeneratorStatus struct

+ Conditions []metav1.Condition

+ LastAppliedGeneration int64

+ func (in *VectorEmbeddingsGeneratorStatus) DeepCopy() *VectorEmbeddingsGeneratorStatus

+ func (in *VectorEmbeddingsGeneratorStatus) DeepCopyInto(out *VectorEmbeddingsGeneratorStatus)

v0.1.0

Mar 5, 2026

Changes in this version

+ const ChunkingStrategyMarkdown

+ const ChunkingStrategyRecursiveCharacter

+ const ChunkingStrategyToken

+ const ChunksGeneratorCondition

+ const ConfigCondition

+ const DestinationTypeInternalStage

+ const DocumentProcessorCondition

+ const ReconcileFailed

+ const SQSConsumerCondition

+ const SourceTypeS3

+ const SuccessfullyReconciled

+ const UnstructuredDataProductCondition

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type ChunkingStrategy string

+ type ChunksGenerator struct

+ Spec ChunksGeneratorSpec

+ Status ChunksGeneratorStatus

+ func (c *ChunksGenerator) SetWaiting()

+ func (c *ChunksGenerator) UpdateStatus(message string, err error)

+ func (in *ChunksGenerator) DeepCopy() *ChunksGenerator

+ func (in *ChunksGenerator) DeepCopyInto(out *ChunksGenerator)

+ func (in *ChunksGenerator) DeepCopyObject() runtime.Object

+ type ChunksGeneratorConfig struct

+ MarkdownSplitterConfig MarkdownSplitterConfig

+ RecursiveCharacterSplitterConfig RecursiveCharacterSplitterConfig

+ Strategy ChunkingStrategy

+ TokenSplitterConfig TokenSplitterConfig

+ func (in *ChunksGeneratorConfig) DeepCopy() *ChunksGeneratorConfig

+ func (in *ChunksGeneratorConfig) DeepCopyInto(out *ChunksGeneratorConfig)

+ type ChunksGeneratorList struct

+ Items []ChunksGenerator

+ func (in *ChunksGeneratorList) DeepCopy() *ChunksGeneratorList

+ func (in *ChunksGeneratorList) DeepCopyInto(out *ChunksGeneratorList)

+ func (in *ChunksGeneratorList) DeepCopyObject() runtime.Object

+ type ChunksGeneratorSpec struct

+ ChunksGeneratorConfig ChunksGeneratorConfig

+ DataProduct string

+ func (in *ChunksGeneratorSpec) DeepCopy() *ChunksGeneratorSpec

+ func (in *ChunksGeneratorSpec) DeepCopyInto(out *ChunksGeneratorSpec)

+ type ChunksGeneratorStatus struct

+ Conditions []metav1.Condition

+ LastAppliedGeneration int64

+ func (in *ChunksGeneratorStatus) DeepCopy() *ChunksGeneratorStatus

+ func (in *ChunksGeneratorStatus) DeepCopyInto(out *ChunksGeneratorStatus)

+ type ControllerConfig struct

+ Spec ControllerConfigSpec

+ Status ControllerConfigStatus

+ func (c *ControllerConfig) IsHealthy() bool

+ func (c *ControllerConfig) SetWaiting()

+ func (c *ControllerConfig) UpdateStatus(err error)

+ func (in *ControllerConfig) DeepCopy() *ControllerConfig

+ func (in *ControllerConfig) DeepCopyInto(out *ControllerConfig)

+ func (in *ControllerConfig) DeepCopyObject() runtime.Object

+ type ControllerConfigList struct

+ Items []ControllerConfig

+ func (in *ControllerConfigList) DeepCopy() *ControllerConfigList

+ func (in *ControllerConfigList) DeepCopyInto(out *ControllerConfigList)

+ func (in *ControllerConfigList) DeepCopyObject() runtime.Object

+ type ControllerConfigSpec struct

+ AWSSecret string

+ SnowflakeConfig SnowflakeConfig

+ UnstructuredDataProcessingConfig UnstructuredDataProcessingConfigSpec

+ func (in *ControllerConfigSpec) DeepCopy() *ControllerConfigSpec

+ func (in *ControllerConfigSpec) DeepCopyInto(out *ControllerConfigSpec)

+ type ControllerConfigStatus struct

+ Conditions []metav1.Condition

+ LastAppliedGeneration int64

+ func (in *ControllerConfigStatus) DeepCopy() *ControllerConfigStatus

+ func (in *ControllerConfigStatus) DeepCopyInto(out *ControllerConfigStatus)

+ type DestinationConfig struct

+ SnowflakeInternalStageConfig SnowflakeInternalStageConfig

+ Type UnstructuredDataDestinationType

+ func (in *DestinationConfig) DeepCopy() *DestinationConfig

+ func (in *DestinationConfig) DeepCopyInto(out *DestinationConfig)

+ type DoclingConfig struct

+ AbortOnError bool

+ DoOCR bool

+ ForceOCR bool

+ FromFormats []string

+ ImageExportMode string

+ OCREngine string

+ OCRLang []string

+ PDFBackend string

+ TableMode string

+ ToFormats []string

+ func (in *DoclingConfig) DeepCopy() *DoclingConfig

+ func (in *DoclingConfig) DeepCopyInto(out *DoclingConfig)

+ type DocumentProcessor struct

+ Spec DocumentProcessorSpec

+ Status DocumentProcessorStatus

+ func (d *DocumentProcessor) AddOrUpdateJob(newJob Job)

+ func (d *DocumentProcessor) AddPermanentlyFailingFile(filePath string)

+ func (d *DocumentProcessor) DeleteJobByFilePath(filePath string)

+ func (d *DocumentProcessor) GetJobByFilePath(filePath string) *Job

+ func (d *DocumentProcessor) IsFilePermanentlyFailing(filePath string) bool

+ func (d *DocumentProcessor) SetWaiting()

+ func (d *DocumentProcessor) UpdateStatus(message string, err error)

+ func (in *DocumentProcessor) DeepCopy() *DocumentProcessor

+ func (in *DocumentProcessor) DeepCopyInto(out *DocumentProcessor)

+ func (in *DocumentProcessor) DeepCopyObject() runtime.Object

+ type DocumentProcessorConfig struct

+ DoclingConfig DoclingConfig

+ Type string

+ func (in *DocumentProcessorConfig) DeepCopy() *DocumentProcessorConfig

+ func (in *DocumentProcessorConfig) DeepCopyInto(out *DocumentProcessorConfig)

+ type DocumentProcessorList struct

+ Items []DocumentProcessor

+ func (in *DocumentProcessorList) DeepCopy() *DocumentProcessorList

+ func (in *DocumentProcessorList) DeepCopyInto(out *DocumentProcessorList)

+ func (in *DocumentProcessorList) DeepCopyObject() runtime.Object

+ type DocumentProcessorSpec struct

+ DataProduct string

+ DocumentProcessorConfig DocumentProcessorConfig

+ func (in *DocumentProcessorSpec) DeepCopy() *DocumentProcessorSpec

+ func (in *DocumentProcessorSpec) DeepCopyInto(out *DocumentProcessorSpec)

+ type DocumentProcessorStatus struct

+ Conditions []metav1.Condition

+ Jobs []Job

+ LastAppliedGeneration int64

+ PermanentlyFailingFiles []string

+ func (in *DocumentProcessorStatus) DeepCopy() *DocumentProcessorStatus

+ func (in *DocumentProcessorStatus) DeepCopyInto(out *DocumentProcessorStatus)

+ type Job struct

+ Attempts int

+ CreatedOn string

+ DoclingConfig DoclingConfig

+ DocumentConverter string

+ FilePath string

+ Status string

+ TaskID string

+ func (in *Job) DeepCopy() *Job

+ func (in *Job) DeepCopyInto(out *Job)

+ type MarkdownSplitterConfig struct

+ ChunkOverlap int

+ ChunkSize int

+ CodeBlocks bool

+ HeadingHierarchy bool

+ JoinTableRows bool

+ ReferenceLinks bool

+ func (in *MarkdownSplitterConfig) DeepCopy() *MarkdownSplitterConfig

+ func (in *MarkdownSplitterConfig) DeepCopyInto(out *MarkdownSplitterConfig)

+ type RecursiveCharacterSplitterConfig struct

+ ChunkOverlap int

+ ChunkSize int

+ KeepSeparator bool

+ Separators []string

+ func (in *RecursiveCharacterSplitterConfig) DeepCopy() *RecursiveCharacterSplitterConfig

+ func (in *RecursiveCharacterSplitterConfig) DeepCopyInto(out *RecursiveCharacterSplitterConfig)

+ type S3Config struct

+ Bucket string

+ Prefix string

+ func (in *S3Config) DeepCopy() *S3Config

+ func (in *S3Config) DeepCopyInto(out *S3Config)

+ type SQSConsumer struct

+ Spec SQSConsumerSpec

+ Status SQSConsumerStatus

+ func (c *SQSConsumer) SetWaiting()

+ func (c *SQSConsumer) UpdateStatus(message string, err error)

+ func (in *SQSConsumer) DeepCopy() *SQSConsumer

+ func (in *SQSConsumer) DeepCopyInto(out *SQSConsumer)

+ func (in *SQSConsumer) DeepCopyObject() runtime.Object

+ type SQSConsumerList struct

+ Items []SQSConsumer

+ func (in *SQSConsumerList) DeepCopy() *SQSConsumerList

+ func (in *SQSConsumerList) DeepCopyInto(out *SQSConsumerList)

+ func (in *SQSConsumerList) DeepCopyObject() runtime.Object

+ type SQSConsumerSpec struct

+ QueueURL string

+ func (in *SQSConsumerSpec) DeepCopy() *SQSConsumerSpec

+ func (in *SQSConsumerSpec) DeepCopyInto(out *SQSConsumerSpec)

+ type SQSConsumerStatus struct

+ Conditions []metav1.Condition

+ LastAppliedGeneration int64

+ func (in *SQSConsumerStatus) DeepCopy() *SQSConsumerStatus

+ func (in *SQSConsumerStatus) DeepCopyInto(out *SQSConsumerStatus)

+ type SnowflakeConfig struct

+ Account string

+ Name string

+ PrivateKeySecret string

+ Region string

+ Role string

+ User string

+ Warehouse string

+ func (in *SnowflakeConfig) DeepCopy() *SnowflakeConfig

+ func (in *SnowflakeConfig) DeepCopyInto(out *SnowflakeConfig)

+ type SnowflakeInternalStageConfig struct

+ Database string

+ Schema string

+ Stage string

+ func (in *SnowflakeInternalStageConfig) DeepCopy() *SnowflakeInternalStageConfig

+ func (in *SnowflakeInternalStageConfig) DeepCopyInto(out *SnowflakeInternalStageConfig)

+ type SourceConfig struct

+ S3Config S3Config

+ Type UnstructuredDataSourceType

+ func (in *SourceConfig) DeepCopy() *SourceConfig

+ func (in *SourceConfig) DeepCopyInto(out *SourceConfig)

+ type TokenSplitterConfig struct

+ AllowedSpecial []string

+ ChunkOverlap int

+ ChunkSize int

+ DisallowedSpecial []string

+ EncodingName string

+ ModelName string

+ func (in *TokenSplitterConfig) DeepCopy() *TokenSplitterConfig

+ func (in *TokenSplitterConfig) DeepCopyInto(out *TokenSplitterConfig)

+ type UnstructuredDataDestinationType string

+ type UnstructuredDataProcessingConfigSpec struct

+ CacheDirectory string

+ DataStorageBucket string

+ DoclingSecret string

+ DoclingServeURL string

+ IngestionBucket string

+ MaxConcurrentDoclingTasks int

+ MaxConcurrentLangchainTasks int

+ func (in *UnstructuredDataProcessingConfigSpec) DeepCopy() *UnstructuredDataProcessingConfigSpec

+ func (in *UnstructuredDataProcessingConfigSpec) DeepCopyInto(out *UnstructuredDataProcessingConfigSpec)

+ type UnstructuredDataProduct struct

+ Spec UnstructuredDataProductSpec

+ Status UnstructuredDataProductStatus

+ func (in *UnstructuredDataProduct) DeepCopy() *UnstructuredDataProduct

+ func (in *UnstructuredDataProduct) DeepCopyInto(out *UnstructuredDataProduct)

+ func (in *UnstructuredDataProduct) DeepCopyObject() runtime.Object

+ func (u *UnstructuredDataProduct) SetWaiting()

+ func (u *UnstructuredDataProduct) UpdateStatus(message string, err error)

+ type UnstructuredDataProductList struct

+ Items []UnstructuredDataProduct

+ func (in *UnstructuredDataProductList) DeepCopy() *UnstructuredDataProductList

+ func (in *UnstructuredDataProductList) DeepCopyInto(out *UnstructuredDataProductList)

+ func (in *UnstructuredDataProductList) DeepCopyObject() runtime.Object

+ type UnstructuredDataProductSpec struct

+ ChunksGeneratorConfig ChunksGeneratorConfig

+ DestinationConfig DestinationConfig

+ DocumentProcessorConfig DocumentProcessorConfig

+ SourceConfig SourceConfig

+ func (in *UnstructuredDataProductSpec) DeepCopy() *UnstructuredDataProductSpec

+ func (in *UnstructuredDataProductSpec) DeepCopyInto(out *UnstructuredDataProductSpec)

+ type UnstructuredDataProductStatus struct

+ Conditions []metav1.Condition

+ LastAppliedGeneration int64

+ func (in *UnstructuredDataProductStatus) DeepCopy() *UnstructuredDataProductStatus

+ func (in *UnstructuredDataProductStatus) DeepCopyInto(out *UnstructuredDataProductStatus)

+ type UnstructuredDataSourceType string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL