orchestcluster

package
v0.0.0-...-560103a Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2023 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	OrchestClusterKind = orchestv1alpha1.SchemeGroupVersion.WithKind("OrchestCluster")
)

Functions

func GetOrchestComponents

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL