install

package
v0.0.1-rc-fa5fa73 Latest Latest
Warning

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

Go to latest
Published: May 9, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AdditionalLabels

func AdditionalLabels(label map[string]string) map[string]string

func AllLabels

func AllLabels(name string, labelMaps ...map[string]string) map[string]string

func GenerateChecksumConfig

func GenerateChecksumConfig(data []byte) string

func GetConfigFilename

func GetConfigFilename(name string) string

func GetConfigName

func GetConfigName(name string) string

func IdentityLabel

func IdentityLabel(name string) map[string]string

func ImageString

func ImageString(image installv1alpha1.Image) string

ImageString generates a docker image.

func MergeMaps

func MergeMaps[M ~map[K]V, K comparable, V any](src ...M) M

MergeMaps is a utility for merging maps. Annotations and Labels need to be merged from existing maps.

Types

type AppConfig

type AppConfig struct {
	Pulsar PulsarConfig
}

AppConfig is used for scanning the appconfig to find particular values

type ArmadaInit

type ArmadaInit struct {
	Enabled    bool
	Image      Image
	BrokerHost string
	Protocol   string
	AdminPort  int
	Port       int
}

ArmadaInit used to initialize pulsar

type ArmadaServerReconciler

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

ArmadaServerReconciler reconciles a ArmadaServer object

func (*ArmadaServerReconciler) Reconcile

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

func (*ArmadaServerReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type BinocularsReconciler

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

BinocularsReconciler reconciles a Binoculars object

func (*BinocularsReconciler) Reconcile

func (r *BinocularsReconciler) 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. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile

func (*BinocularsReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type CommonComponents

type CommonComponents struct {
	Deployment          *appsv1.Deployment
	IngressGrpc         *networkingv1.Ingress
	IngressHttp         *networkingv1.Ingress
	Service             *corev1.Service
	ServiceAccount      *corev1.ServiceAccount
	Secret              *corev1.Secret
	ClusterRole         *rbacv1.ClusterRole
	ClusterRoleBindings []*rbacv1.ClusterRoleBinding
	PriorityClasses     []*schedulingv1.PriorityClass
	PrometheusRule      *monitoringv1.PrometheusRule
	ServiceMonitor      *monitoringv1.ServiceMonitor
	PodDisruptionBudget *policyv1.PodDisruptionBudget
	Jobs                []*batchv1.Job
	CronJob             *batchv1.CronJob
}

CommonComponents are the base components for all of the Armada services

func (*CommonComponents) DeepCopy

func (cc *CommonComponents) DeepCopy() *CommonComponents

DeepCopy will deep copy values from the receiver and return a new reference

func (*CommonComponents) ReconcileComponents

func (oldComponents *CommonComponents) ReconcileComponents(newComponents *CommonComponents)

ReconcileComponents will copy values from newComponents to the receiver

type ConnectionConfig

type ConnectionConfig struct {
	Host     string
	Port     string
	User     string
	Password string
	Dbname   string
}

ConnectionConfig is used for scanning connection section of postgres config

type EventIngesterReconciler

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

EventIngesterReconciler reconciles a EventIngester object

func (*EventIngesterReconciler) Reconcile

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

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile

func (*EventIngesterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type ExecutorReconciler

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

ExecutorReconciler reconciles a Executor object

func (*ExecutorReconciler) Reconcile

func (r *ExecutorReconciler) 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 Executor 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.13.0/pkg/reconcile

func (*ExecutorReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type Image

type Image struct {
	Repository string
	Tag        string
}

Image represents a docker image

type LookoutConfig

type LookoutConfig struct {
	Postgres PostgresConfig
}

type LookoutIngesterReconciler

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

LookoutIngesterReconciler reconciles a LookoutIngester object

func (*LookoutIngesterReconciler) Reconcile

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*LookoutIngesterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type LookoutReconciler

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

LookoutReconciler reconciles a Lookout object

func (*LookoutReconciler) Reconcile

func (r *LookoutReconciler) 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. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile

func (*LookoutReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type PostgresConfig

type PostgresConfig struct {
	Connection ConnectionConfig
}

PostgresConfig is used for scanning postgres section of application config

type PulsarConfig

type PulsarConfig struct {
	ArmadaInit            ArmadaInit
	AuthenticationEnabled bool
	TlsEnabled            bool
	AuthenticationSecret  string
	Cacert                string
}

PulsarConfig is used for scanning pulsar section of application config

func ExtractPulsarConfig

func ExtractPulsarConfig(config runtime.RawExtension) (PulsarConfig, error)

ExtractPulsarConfig will unmarshal the appconfig and return the PulsarConfig portion

type SchedulerConfig

type SchedulerConfig struct {
	Postgres PostgresConfig
}

type SchedulerIngesterReconciler

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

SchedulerIngesterReconciler reconciles a SchedulerIngester object

func (*SchedulerIngesterReconciler) Reconcile

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile

func (*SchedulerIngesterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type SchedulerReconciler

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

SchedulerReconciler reconciles a Scheduler object

func (*SchedulerReconciler) Reconcile

func (r *SchedulerReconciler) 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. For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.13.0/pkg/reconcile

func (*SchedulerReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

Jump to

Keyboard shortcuts

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