Documentation ¶
Index ¶
- Variables
- func GetComponentTemplate(name string, orchest *orchestv1alpha1.OrchestCluster) (*orchestv1alpha1.OrchestComponentTemplate, error)
- func GetOrchestComponents(ctx context.Context, orchest *orchestv1alpha1.OrchestCluster, ...) (map[string]*orchestv1alpha1.OrchestComponent, error)
- type ControllerConfig
- type OrchestClusterController
Constants ¶
This section is empty.
Variables ¶
View Source
var (
OrchestClusterKind = orchestv1alpha1.SchemeGroupVersion.WithKind("OrchestCluster")
)
Functions ¶
func GetComponentTemplate ¶
func GetComponentTemplate(name string, orchest *orchestv1alpha1.OrchestCluster) ( *orchestv1alpha1.OrchestComponentTemplate, error)
func GetOrchestComponents ¶
func GetOrchestComponents(ctx context.Context, orchest *orchestv1alpha1.OrchestCluster, lister orchestlisters.OrchestComponentLister) ( map[string]*orchestv1alpha1.OrchestComponent, error)
GetOrchestComponents returns all the components of the OrchestCluster
Types ¶
type ControllerConfig ¶
type ControllerConfig struct { // Postgres default image to use if not provided PostgresDefaultImage string // Rabbitmq default image to use if not provided RabbitmqDefaultImage string // Orchest Default version to use if not provided OrchestDefaultVersion string // celery-worker default image to use if not provided CeleryWorkerImageName string // orchest-api default image to use if not provided OrchestApiImageName string // orchest-webserver default image to use if not provided OrchestWebserverImageName string // auth-server default image to use if not provided AuthServerImageName string // Default storage class when not specified for a volume. DefaultStorageClass string // Orchest state default volume size if not specified. OrchestStateDefaultVolumeSize string // User-dir default volume size if not specified. UserdirDefaultVolumeSize string // build-dir volume size if not provided BuilddirDefaultVolumeSize string // default env vars for orchest services OrchestDefaultEnvVars map[string]string // default env vars for orchest-api OrchestApiDefaultEnvVars map[string]string // default env vars for orchest-webserver OrchestWebserverDefaultEnvVars map[string]string // default env vars for auth-server AuthServerDefaultEnvVars map[string]string // default env vars for celery-worker CeleryWorkerDefaultEnvVars map[string]string // default env vars for orchest-database OrchestDatabaseDefaultEnvVars map[string]string // default env vars for rabbitmq RabbitmqDefaultEnvVars map[string]string // default third-party applications DefaultApplications []orchestv1alpha1.ApplicationSpec Threadiness int InCluster bool DefaultPause bool }
func NewDefaultControllerConfig ¶
func NewDefaultControllerConfig() ControllerConfig
type OrchestClusterController ¶
type OrchestClusterController struct { *controller.Controller[*orchestv1alpha1.OrchestCluster] // contains filtered or unexported fields }
OrchestClusterController reconciles OrchestCluster CRD.
func NewOrchestClusterController ¶
func NewOrchestClusterController(kClient kubernetes.Interface, oClient versioned.Interface, gClient client.Client, scheme *runtime.Scheme, config ControllerConfig, k8sDistro utils.KubernetesDistros, oClusterInformer orchestinformers.OrchestClusterInformer, oComponentInformer orchestinformers.OrchestComponentInformer, addonManager *addons.AddonManager, ) *OrchestClusterController
NewOrchestClusterController returns a new *OrchestClusterController.
Click to show internal directories.
Click to hide internal directories.