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 ServiceExposeReconciler
  • func (r *ServiceExposeReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *ServiceExposeReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

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

const (
	KindService = "Service"
)

const LabelKey = "serviceexpose.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 ServiceExposeReconciler

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

ServiceExposeReconciler reconciles a ServiceExpose object

func (*ServiceExposeReconciler) Reconcile

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

func (*ServiceExposeReconciler) SetupWithManager

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