controller

package
v0.0.0-...-9865871 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	EventDeleted  = "deleted"
	EventDeployed = "deployed"
	EventFailed   = "failed"
	EventUpdated  = "updated"
)

TODO use enum

Variables

This section is empty.

Functions

func Capitalize 

func Capitalize(word string) string

func GetService 

func GetService(serviceComponent *llov1alpha1.ServiceComponentK8s) (string, error)

func GetServiceComponentEntityId 

func GetServiceComponentEntityId(serviceComponent string, service string) (string, error)

Types

type ServiceComponentK8sReconciler 

type ServiceComponentK8sReconciler struct {
	client.Client
	Scheme              *runtime.Scheme
	CbClient            *contextbroker.ContextBroker
	Config              *config.Config
	IotaClient          *iotatangle.IotaClient
	NotificationsClient *notifications.NotificationClient
}

ServiceComponentK8sReconciler reconciles a ServiceComponentK8s object

func (*ServiceComponentK8sReconciler) CreateContextBrokerCondition 

func (r *ServiceComponentK8sReconciler) CreateContextBrokerCondition(serviceComponent *llov1alpha1.ServiceComponentK8s)

func (*ServiceComponentK8sReconciler) CreateContextBrokerFailedCondition 

func (r *ServiceComponentK8sReconciler) CreateContextBrokerFailedCondition(serviceComponent *llov1alpha1.ServiceComponentK8s)

func (*ServiceComponentK8sReconciler) CreateInitializedCondition 

func (r *ServiceComponentK8sReconciler) CreateInitializedCondition(serviceComponent *llov1alpha1.ServiceComponentK8s)

? create a condition for deployment and service

func (*ServiceComponentK8sReconciler) CreateNetworkingConfigurationCondition 

func (r *ServiceComponentK8sReconciler) CreateNetworkingConfigurationCondition(serviceComponent *llov1alpha1.ServiceComponentK8s)

func (*ServiceComponentK8sReconciler) CreateUpdatedCondition 

func (r *ServiceComponentK8sReconciler) CreateUpdatedCondition(serviceComponent *llov1alpha1.ServiceComponentK8s)

func (*ServiceComponentK8sReconciler) HandleCreate 

func (r *ServiceComponentK8sReconciler) HandleCreate(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s) (ctrl.Result, error)

func (*ServiceComponentK8sReconciler) HandleDelete 

func (r *ServiceComponentK8sReconciler) HandleDelete(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s) (ctrl.Result, error)

func (*ServiceComponentK8sReconciler) HandleDeploymentCreation 

func (r *ServiceComponentK8sReconciler) HandleDeploymentCreation(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s, customLabels resources.CustomLabels, scEntityId string, registryCredentials *corev1.Secret, wgClientConfig *corev1.ConfigMap) (err error)

func (*ServiceComponentK8sReconciler) HandleDeploymentUpdate 

func (r *ServiceComponentK8sReconciler) HandleDeploymentUpdate(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s, customLabels resources.CustomLabels, scEntityId string, registryCredentials *corev1.Secret, wgClientConfig *corev1.ConfigMap) (err error)

func (*ServiceComponentK8sReconciler) HandleNetworkOverlay 

func (r *ServiceComponentK8sReconciler) HandleNetworkOverlay(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s, customLabels resources.CustomLabels, scEntityId string) (wgClientConfig *corev1.ConfigMap, err error)

func (*ServiceComponentK8sReconciler) HandleNetworkOverlayInUpdate 

func (r *ServiceComponentK8sReconciler) HandleNetworkOverlayInUpdate(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s, customLabels resources.CustomLabels, scEntityId string) (wgClientConfig *corev1.ConfigMap, err error)

func (*ServiceComponentK8sReconciler) HandlePrivateRegistry 

func (r *ServiceComponentK8sReconciler) HandlePrivateRegistry(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s, scEntityId string) (registryCredentials *corev1.Secret, err error)

func (*ServiceComponentK8sReconciler) HandlePrivateRegistryInUpdate 

func (r *ServiceComponentK8sReconciler) HandlePrivateRegistryInUpdate(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s, scEntityId string) (registryCredentials *corev1.Secret, err error)

func (*ServiceComponentK8sReconciler) HandleServiceCreation 

func (r *ServiceComponentK8sReconciler) HandleServiceCreation(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s, customLabels resources.CustomLabels, scEntityId string) (err error)

func (*ServiceComponentK8sReconciler) HandleServiceUpdate 

func (r *ServiceComponentK8sReconciler) HandleServiceUpdate(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s, customLabels resources.CustomLabels, scEntityId string) (err error)

func (*ServiceComponentK8sReconciler) HandleUpdate 

func (r *ServiceComponentK8sReconciler) HandleUpdate(ctx context.Context, serviceComponent *llov1alpha1.ServiceComponentK8s) (ctrl.Result, error)

func (*ServiceComponentK8sReconciler) IsNewInstance 

func (r *ServiceComponentK8sReconciler) IsNewInstance(serviceComponent *llov1alpha1.ServiceComponentK8s) bool

func (*ServiceComponentK8sReconciler) Reconcile 

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

func (*ServiceComponentK8sReconciler) SendNotifications 

func (r *ServiceComponentK8sReconciler) SendNotifications(serviceComponent *llov1alpha1.ServiceComponentK8s, event string, log logr.Logger) (err error)

Send Portal and IOTA notifications using predefined messages

func (*ServiceComponentK8sReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

func (*ServiceComponentK8sReconciler) ShowServiceComponentLogs 

func (r *ServiceComponentK8sReconciler) ShowServiceComponentLogs(serviceComponent *llov1alpha1.ServiceComponentK8s, log logr.Logger)

Source Files

View all Source files

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.