install

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2024 License: Apache-2.0 Imports: 31 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 CreateProbesWithScheme added in v0.5.0 

func CreateProbesWithScheme(scheme corev1.URIScheme) (*corev1.Probe, *corev1.Probe)

func GenerateChecksumConfig 

func GenerateChecksumConfig(data []byte) string

func GetConfigFilename 

func GetConfigFilename(name string) string

func GetConfigName 

func GetConfigName(name string) string

func GetServerScheme added in v0.5.0 

func GetServerScheme(tlsConfig builders.TLSConfig) corev1.URIScheme

GetServerScheme returns the URI scheme for the grpc server

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 BackendProtocol added in v0.4.1 

type BackendProtocol string
const (
	BackendProtocolGRPC BackendProtocol = "GRPC"
	BackendProtocolHTTP BackendProtocol = "HTTP"
)

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 CleanupFunc added in v0.4.0 

type CleanupFunc func(context.Context) error

CleanupFunc is a function that will clean up additional resources which are not deleted by owner references.

type CommonComponents 

type CommonComponents struct {
	Deployment          *appsv1.Deployment
	IngressGrpc         *networkingv1.Ingress
	IngressHttp         *networkingv1.Ingress
	IngressProfiling    *networkingv1.Ingress
	Service             *corev1.Service
	ServiceProfiling    *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 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 (cc *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 

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

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

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.