controllers

Documentation

Index

• Constants
• func DerivedName(namespace string, name string) string
• func EndpointPortToPort(port discovery.EndpointPort) model.Port
• func EndpointPortsAreEqualIgnoreOrder(a, b []discovery.EndpointPort) (equal bool)
• func PortToEndpointPort(port model.Port) discovery.EndpointPort
• func PortToServicePort(port model.Port) v1.ServicePort
• func ServicePortToPort(svcPort v1.ServicePort) model.Port
• type CloudMapReconciler
  • func (r *CloudMapReconciler) Reconcile(ctx context.Context) error
  • func (r *CloudMapReconciler) Start(ctx context.Context) error
• type ServiceExportReconciler
  • func (r *ServiceExportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ServiceExportReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (

	// DerivedServiceAnnotation annotates a ServiceImport with derived Service name
	DerivedServiceAnnotation = "multicluster.k8s.aws/derived-service"

	// LabelServiceImportName indicates the name of the multi-cluster service that an EndpointSlice belongs to.
	LabelServiceImportName = "multicluster.kubernetes.io/service-name"
)

const (
	K8sVersionAttr            = "K8S_CONTROLLER"
	ServiceExportFinalizer    = "multicluster.k8s.aws/service-export-finalizer"
	EndpointSliceServiceLabel = "kubernetes.io/service-name"
)

Functions

func DerivedName

func DerivedName(namespace string, name string) string

DerivedName computes the "placeholder" name for the imported service

func EndpointPortToPort

func EndpointPortToPort(port discovery.EndpointPort) model.Port

func EndpointPortsAreEqualIgnoreOrder

func EndpointPortsAreEqualIgnoreOrder(a, b []discovery.EndpointPort) (equal bool)

func PortToEndpointPort

func PortToEndpointPort(port model.Port) discovery.EndpointPort

func PortToServicePort

func PortToServicePort(port model.Port) v1.ServicePort

func ServicePortToPort

func ServicePortToPort(svcPort v1.ServicePort) model.Port

Types

type CloudMapReconciler

type CloudMapReconciler struct {
	client.Client
	Cloudmap cloudmap.ServiceDiscoveryClient
	logr.Logger
}

CloudMapReconciler reconciles state of Cloud Map services with local ServiceImport objects

func (*CloudMapReconciler) Reconcile

func (r *CloudMapReconciler) Reconcile(ctx context.Context) error

Reconcile triggers a single reconciliation round

func (*CloudMapReconciler) Start

func (r *CloudMapReconciler) Start(ctx context.Context) error

Start implements manager.Runnable

type ServiceExportReconciler

type ServiceExportReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	CloudMap cloudmap.ServiceDiscoveryClient
}

ServiceExportReconciler reconciles a ServiceExport object

func (*ServiceExportReconciler) Reconcile

func (r *ServiceExportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ServiceExportReconciler) SetupWithManager

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