controllers/

Dec 3, 2021

Changes in this version

+ func CreateDerivedServiceStruct(svcImport *v1alpha1.ServiceImport, importedSvcPorts []*model.Port) *v1.Service

+ func CreateEndpointForSlice(svc *v1.Service, ip string) discovery.Endpoint

+ func CreateEndpointSliceStruct(svc *v1.Service, svcImportName string) *discovery.EndpointSlice

+ func CreateServiceImportStruct(namespace string, name string, servicePorts []*model.Port) *v1alpha1.ServiceImport

+ func ExtractEndpointPorts(endpoints []*model.Endpoint) (endpointPorts []*model.Port)

+ func ExtractServicePorts(endpoints []*model.Endpoint) (servicePorts []*model.Port)

+ func PortToServiceImportPort(port model.Port) v1alpha1.ServicePort

+ func PortsEqualIgnoreOrder(a, b []*model.Port) (equal bool)

+ func ServiceImportPortToPort(svcPort v1alpha1.ServicePort) model.Port

type CloudMapReconciler

+ Client client.Client

+ Log common.Logger

+ type EndpointSliceChanges struct

+ Create []*discovery.EndpointSlice

+ Delete []*discovery.EndpointSlice

+ Unmodified []*discovery.EndpointSlice

+ Update []*discovery.EndpointSlice

+ type EndpointSlicePlan struct

+ Current []*discovery.EndpointSlice

+ Desired []*model.Endpoint

+ Service *v1.Service

+ ServiceImportName string

+ func (p *EndpointSlicePlan) CalculateChanges() EndpointSliceChanges

type ServiceExportReconciler

+ Client client.Client

Nov 19, 2021

Changes in this version

+ const EndpointSliceServiceLabel

+ const K8sVersionAttr

+ const ServiceExportFinalizer

+ 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 ServiceExportReconciler

+ CloudMap cloudmap.ServiceDiscoveryClient

Nov 6, 2021

Changes in this version

+ const LabelServiceImportName

Oct 8, 2021

Changes in this version

+ const DerivedServiceAnnotation

+ func DerivedName(namespace string, name string) string

+ type CloudMapReconciler struct

+ Cloudmap cloudmap.ServiceDiscoveryClient

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

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

+ type ServiceExportReconciler struct

+ Cloudmap cloudmap.ServiceDiscoveryClient

+ Log logr.Logger

+ Scheme *runtime.Scheme

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

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