Documentation
¶
Index ¶
- Constants
- Variables
- func IsAWSClientNotInitializedError(err error) bool
- func IsConfigCRHealthy(ctx context.Context, kubeClient client.Client, namespace string) (bool, error)
- type ChunksGeneratorReconciler
- type ControllerConfigReconciler
- type DestinationSyncerReconciler
- type DocumentProcessorReconciler
- type SourceCrawlerReconciler
- type UnstructuredDataPipelineReconciler
- type VectorEmbeddingsGeneratorReconciler
Constants ¶
const ( UnstructuredDataPipelineControllerName = "UnstructuredDataPipeline" PipelineLabel = "operator.dataverse.redhat.com/unstructured-data-pipeline" )
const (
ChunksGeneratorControllerName = "ChunksGenerator"
)
const (
DestinationSyncerControllerName = "DestinationSyncer"
)
const (
DocumentProcessorControllerName = "DocumentProcessor"
)
const (
SourceCrawlerControllerName = "SourceCrawler"
)
const (
VectorEmbeddingsGeneratorControllerName = "VectorEmbeddingsGenerator"
)
Variables ¶
var ( UnstructuredDataPipelineResyncInterval *int LDAPClient ldap.Client CacheClient pkgcache.Cache GoogleDriveControllerCfg *operatorv1alpha1.GoogleDriveControllerConfig GlobalGoogleClient google.GoogleClient )
Functions ¶
func IsAWSClientNotInitializedError ¶ added in v0.2.0
IsAWSClientNotInitializedError returns true if err indicates an AWS client (S3, SQS, or presign) is not initialized yet. Used to requeue without error when ControllerConfig has not run yet at startup.
Types ¶
type ChunksGeneratorReconciler ¶
type ChunksGeneratorReconciler struct {
client.Client
Scheme *runtime.Scheme
// contains filtered or unexported fields
}
ChunksGeneratorReconciler reconciles a ChunksGenerator object
func (*ChunksGeneratorReconciler) Reconcile ¶
func (r *ChunksGeneratorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the ChunksGenerator object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.21.0/pkg/reconcile
func (*ChunksGeneratorReconciler) SetupWithManager ¶
func (r *ChunksGeneratorReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type ControllerConfigReconciler ¶
ControllerConfigReconciler reconciles a ControllerConfig object
func (*ControllerConfigReconciler) SetupWithManager ¶
func (r *ControllerConfigReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type DestinationSyncerReconciler ¶ added in v0.8.0
type DestinationSyncerReconciler struct {
client.Client
Scheme *runtime.Scheme
// contains filtered or unexported fields
}
DestinationSyncerReconciler reconciles a DestinationSyncer object
func (*DestinationSyncerReconciler) SetupWithManager ¶ added in v0.8.0
func (r *DestinationSyncerReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type DocumentProcessorReconciler ¶
type DocumentProcessorReconciler struct {
client.Client
Scheme *runtime.Scheme
// contains filtered or unexported fields
}
DocumentProcessorReconciler reconciles a DocumentProcessor object
func (*DocumentProcessorReconciler) SetupWithManager ¶
func (r *DocumentProcessorReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager. SetupWithManager registers this controller. Spec changes trigger via GenerationChangedPredicate. Watches on other stage types trigger reconcile when an upstream dependency's status changes.
type SourceCrawlerReconciler ¶ added in v0.8.0
type SourceCrawlerReconciler struct {
client.Client
Scheme *runtime.Scheme
// contains filtered or unexported fields
}
SourceCrawlerReconciler reconciles a SourceCrawler object
func (*SourceCrawlerReconciler) SetupWithManager ¶ added in v0.8.0
func (r *SourceCrawlerReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager registers watches on all downstream pipeline stages and secrets so that changes to any dependency trigger a reconcile of the owning SourceCrawler.
type UnstructuredDataPipelineReconciler ¶ added in v0.8.0
UnstructuredDataPipelineReconciler reconciles a UnstructuredDataPipeline object
func (*UnstructuredDataPipelineReconciler) SetupWithManager ¶ added in v0.8.0
func (r *UnstructuredDataPipelineReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type VectorEmbeddingsGeneratorReconciler ¶ added in v0.2.0
type VectorEmbeddingsGeneratorReconciler struct {
client.Client
Scheme *runtime.Scheme
// contains filtered or unexported fields
}
func (*VectorEmbeddingsGeneratorReconciler) SetupWithManager ¶ added in v0.2.0
func (r *VectorEmbeddingsGeneratorReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files
Directories