controllers

Documentation

Index

• Constants
• func DetermineWorkloadType(ctx context.Context, log logr.Logger, r client.Reader, ...) ([]*unstructured.Unstructured, error)
• func ServiceInjector(ctx context.Context, t *corev1alpha2.IngressTrait, obj oam.Object) (*corev1.Service, *corev1alpha2.InternalBackend, error)
• type IngressTraitReconciler
  • func (r *IngressTraitReconciler) IngressInjector(ctx context.Context, trait oam.Trait, obj oam.Object, ...) (*corev1.Service, *v1beta1.Ingress, error)
  • func (r *IngressTraitReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *IngressTraitReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	LabelKey        = "ingresstrait.oam.crossplane.io"
	KindStatefulSet = "StatefulSet"
	KindDeployment  = "Deployment"
)

const (
	KindIngress = "Ingress"
	KindService = "Service"
)

Functions

func DetermineWorkloadType

func DetermineWorkloadType(ctx context.Context, log logr.Logger, r client.Reader,
	workload *unstructured.Unstructured) ([]*unstructured.Unstructured, error)

Determine whether the workload is K8S native resources or oam WorkloadDefinition

func ServiceInjector

func ServiceInjector(ctx context.Context, t *corev1alpha2.IngressTrait, obj oam.Object) (*corev1.Service, *corev1alpha2.InternalBackend, error)

Types

type IngressTraitReconciler

type IngressTraitReconciler struct {
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

IngressTraitReconciler reconciles a IngressTrait object

func (*IngressTraitReconciler) IngressInjector

func (r *IngressTraitReconciler) IngressInjector(ctx context.Context, trait oam.Trait,
	obj oam.Object, svcInfo *corev1alpha2.InternalBackend) (*corev1.Service, *v1beta1.Ingress, error)

IngressInjector adds a Ingress object for the resources observed in a workload translation.

func (*IngressTraitReconciler) Reconcile

func (r *IngressTraitReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*IngressTraitReconciler) SetupWithManager

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