Versions in this module Expand all Collapse all v0 v0.3.1 Dec 9, 2022 v0.3.0 Sep 15, 2022 Changes in this version + const DerivedServiceAnnotation + const LabelDerivedServiceOriginatingName + const LabelEndpointSliceManagedBy + const LabelServiceImportName + const LabelSourceCluster + const ServiceExportFinalizer + const ValueEndpointSliceManagedBy + func CreateDerivedServiceAnnotation(namespace string, name string, clusterIds []string) string + func CreateDerivedServiceStruct(svcImport *multiclusterv1alpha1.ServiceImport, importedSvcPorts []*model.Port, ...) *v1.Service + func CreateEndpointForSlice(svc *v1.Service, endpoint *model.Endpoint) discovery.Endpoint + func CreateEndpointSliceStruct(svc *v1.Service, svcImportName string, clusterId string) *discovery.EndpointSlice + func CreateServiceImportStruct(svc *model.Service, clusterIds []string, servicePorts []*model.Port) *multiclusterv1alpha1.ServiceImport + func DerivedName(namespace string, name string, clusterId string) string + func EndpointPortToPort(port discovery.EndpointPort) model.Port + func ExtractEndpointPorts(endpoints []*model.Endpoint) (endpointPorts []*model.Port) + func ExtractServicePorts(endpoints []*model.Endpoint) (servicePorts []*model.Port) + func ExtractServiceType(svc *v1.Service) model.ServiceType + func GetClusterIpsFromServices(services []*v1.Service) []string + func IPsEqualIgnoreOrder(a, b []string) (equal bool) + func PortToEndpointPort(port model.Port) discovery.EndpointPort + func PortToServiceImportPort(port model.Port) multiclusterv1alpha1.ServicePort + func PortToServicePort(port model.Port) v1.ServicePort + func PortsEqualIgnoreOrder(a, b []*model.Port) (equal bool) + func ServiceImportPortToPort(svcPort multiclusterv1alpha1.ServicePort) model.Port + func ServicePortToPort(svcPort v1.ServicePort) model.Port + func ServiceTypetoServiceImportType(serviceType model.ServiceType) multiclusterv1alpha1.ServiceImportType + type CloudMapReconciler struct + Client client.Client + Cloudmap cloudmap.ServiceDiscoveryClient + ClusterUtils model.ClusterUtils + Log common.Logger + func (r *CloudMapReconciler) DeleteDerivedServiceAndEndpointSlices(ctx context.Context, derivedService *v1.Service) error + func (r *CloudMapReconciler) Reconcile(ctx context.Context) error + func (r *CloudMapReconciler) Start(ctx context.Context) error + type EndpointSliceChanges struct + Create []*discovery.EndpointSlice + Delete []*discovery.EndpointSlice + Unmodified []*discovery.EndpointSlice + Update []*discovery.EndpointSlice + type EndpointSlicePlan struct + ClusterId string + Current []*discovery.EndpointSlice + Desired []*model.Endpoint + Service *v1.Service + ServiceImportName string + func (p *EndpointSlicePlan) CalculateChanges() EndpointSliceChanges + type ServiceExportReconciler struct + Client client.Client + CloudMap cloudmap.ServiceDiscoveryClient + ClusterUtils model.ClusterUtils + Log common.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