controller

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 19, 2026 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ChunksGeneratorControllerName = "ChunksGenerator"
)
View Source 
const (
	DocumentProcessorControllerName = "DocumentProcessor"
)
View Source 
const (
	SQSInformerControllerName = "SQSInformer"
)
View Source 
const (
	UnstructuredDataProductControllerName = "UnstructuredDataProduct"
)
View Source 
const (
	VectorEmbeddingsGeneratorControllerName = "VectorEmbeddingsGenerator"
)

Variables

This section is empty.

Functions

func IsAWSClientNotInitializedError added in v0.2.0 

func IsAWSClientNotInitializedError(err error) bool

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.

func IsConfigCRHealthy 

func IsConfigCRHealthy(ctx context.Context, kubeClient client.Client, namespace string) (bool, error)

func IsControllerConfigGlobalsSet added in v0.2.0 

func IsControllerConfigGlobalsSet(cacheDir, dataBucket string) bool

IsControllerConfigGlobalsSet returns true if the controller package globals (cacheDirectory, dataStorageBucket) have been set by ControllerConfig Reconcile. When false, filestore.New would be called with empty paths and fail before reaching GetS3Client(), so we requeue early.

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 

type ControllerConfigReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ControllerConfigReconciler reconciles a ControllerConfig object

func (*ControllerConfigReconciler) Reconcile 

func (r *ControllerConfigReconciler) 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 ControllerConfig 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 (*ControllerConfigReconciler) SetupWithManager 

func (r *ControllerConfigReconciler) 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) Reconcile 

func (r *DocumentProcessorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*DocumentProcessorReconciler) SetupWithManager 

func (r *DocumentProcessorReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type Model added in v0.2.0 

type Model string

type ModelCredentials added in v0.2.0 

type ModelCredentials struct {
	Endpoint string
	APIKey   string
}

type S3EventBucket 

type S3EventBucket struct {
	Name string `json:"name"`
	ARN  string `json:"arn"`
}

type S3EventData 

type S3EventData struct {
	Bucket S3EventBucket `json:"bucket"`
	Object S3EventObject `json:"object"`
}

S3EventData contains the S3-specific event data

type S3EventObject 

type S3EventObject struct {
	Key  string `json:"key"`
	Size int64  `json:"size"`
	ETag string `json:"etag"`
}

type S3EventRecord 

type S3EventRecord struct {
	AWSRegion    string              `json:"awsRegion"`
	EventName    string              `json:"eventName"`
	EventTime    string              `json:"eventTime"`
	UserIdentity S3EventUserIdentity `json:"userIdentity"`
	S3           S3EventData         `json:"s3"`
}

S3EventRecord represents a single S3 event record

type S3EventUserIdentity 

type S3EventUserIdentity struct {
	PrincipalID string `json:"principalId"`
}

type SQSInformerReconciler added in v0.2.0 

type SQSInformerReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

SQSInformerReconciler reconciles a SQSInformer object

func (*SQSInformerReconciler) Reconcile added in v0.2.0 

func (r *SQSInformerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*SQSInformerReconciler) SetupWithManager added in v0.2.0 

func (r *SQSInformerReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type SQSMessage 

type SQSMessage struct {
	Records []S3EventRecord `json:"Records"`
}

SQSMessage represents an S3 event notification received via SQS

type UnstructuredDataProductReconciler 

type UnstructuredDataProductReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

UnstructuredDataProductReconciler reconciles a UnstructuredDataProduct object

func (*UnstructuredDataProductReconciler) Reconcile 

func (r *UnstructuredDataProductReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*UnstructuredDataProductReconciler) SetupWithManager 

func (r *UnstructuredDataProductReconciler) 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) Reconcile added in v0.2.0 

func (r *VectorEmbeddingsGeneratorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.