controllers

Documentation

Index

• Constants
• func DetermineWorkloadType(ctx context.Context, log logr.Logger, r client.Reader, ...) ([]*unstructured.Unstructured, error)
• func ServiceInjector(ctx context.Context, trait oam.Trait, objs []oam.Object) ([]oam.Object, error)
• type ServiceTraitReconciler
  • func (r *ServiceTraitReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *ServiceTraitReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	KindStatefulSet = "StatefulSet"
	KindDeployment  = "Deployment"
)

const (
	KindService = "Service"
)

const LabelKey = "servicetrait.oam.crossplane.io"

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, trait oam.Trait, objs []oam.Object) ([]oam.Object, error)

ServiceInjector adds a Service object for the workload the trait is pointing to

Types

type ServiceTraitReconciler

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

ServiceTraitReconciler reconciles a ServiceTrait object

func (*ServiceTraitReconciler) Reconcile

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

func (*ServiceTraitReconciler) SetupWithManager

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