controller

package
v0.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	ChunksGeneratorControllerName = "ChunksGenerator"
)
View Source 
const (
	DocumentProcessorControllerName = "DocumentProcessor"
)
View Source 
const (
	SQSConsumerControllerName = "SQSConsumer"
)
View Source 
const (
	UnstructuredDataProductControllerName = "UnstructuredDataProduct"
)

Variables

This section is empty.

Functions

func IsConfigCRHealthy 

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

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 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"`
	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 SQSConsumerReconciler 

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

SQSConsumerReconciler reconciles a SQSConsumer object

func (*SQSConsumerReconciler) Reconcile 

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

func (*SQSConsumerReconciler) SetupWithManager 

func (r *SQSConsumerReconciler) 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.

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.