package ingress

import "k8s.io/kubernetes/federation/pkg/federation-controller/service/ingress"

Index ¶

• Constants
• func UpdateIngressAnnotation(service *v1.Service, ingress *FederatedServiceIngress) *v1.Service
• type FederatedServiceIngress
• func NewFederatedServiceIngress() *FederatedServiceIngress
• func ParseFederatedServiceIngress(service *v1.Service) (*FederatedServiceIngress, error)
• func (ingress *FederatedServiceIngress) AddClusterLoadBalancerIngresses(cluster string, loadbalancerIngresses []v1.LoadBalancerIngress)
• func (ingress *FederatedServiceIngress) AddEndpoints(cluster string, endpoints []string) *FederatedServiceIngress
• func (ingress *FederatedServiceIngress) GetClusterLoadBalancerIngresses(cluster string) []v1.LoadBalancerIngress
• func (ingress *FederatedServiceIngress) Len() int
• func (ingress *FederatedServiceIngress) Less(i, j int) bool
• func (ingress *FederatedServiceIngress) RemoveEndpoint(cluster string, endpoint string) *FederatedServiceIngress
• func (ingress *FederatedServiceIngress) String() string
• func (ingress *FederatedServiceIngress) Swap(i, j int)

Constants ¶

const (
	FederatedServiceIngressAnnotation = "federation.kubernetes.io/service-ingresses"
)

Functions ¶

func UpdateIngressAnnotation ¶

func UpdateIngressAnnotation(service *v1.Service, ingress *FederatedServiceIngress) *v1.Service

UpdateIngressAnnotation updates the federated service with service ingress annotation

Types ¶

type FederatedServiceIngress ¶

type FederatedServiceIngress struct {
	fedapi.FederatedServiceIngress
}

FederatedServiceIngress implements sort.Interface.

func NewFederatedServiceIngress ¶

func NewFederatedServiceIngress() *FederatedServiceIngress

func ParseFederatedServiceIngress ¶

func ParseFederatedServiceIngress(service *v1.Service) (*FederatedServiceIngress, error)

ParseFederatedServiceIngress extracts federated service ingresses from a federated service

func (*FederatedServiceIngress) AddClusterLoadBalancerIngresses ¶

func (ingress *FederatedServiceIngress) AddClusterLoadBalancerIngresses(cluster string, loadbalancerIngresses []v1.LoadBalancerIngress)

AddClusterLoadBalancerIngresses adds the ladbalancer ingresses for a given cluster to federated service ingress

func (*FederatedServiceIngress) AddEndpoints ¶

func (ingress *FederatedServiceIngress) AddEndpoints(cluster string, endpoints []string) *FederatedServiceIngress

AddEndpoints add one or more endpoints to federated service ingress. endpoints are federated cluster's loadbalancer ip/hostname for the service

func (*FederatedServiceIngress) GetClusterLoadBalancerIngresses ¶

func (ingress *FederatedServiceIngress) GetClusterLoadBalancerIngresses(cluster string) []v1.LoadBalancerIngress

GetClusterLoadBalancerIngresses returns loadbalancer ingresses for given cluster if exist otherwise returns an empty slice

func (*FederatedServiceIngress) Len ¶

func (ingress *FederatedServiceIngress) Len() int

Len is to satisfy of sort.Interface.

func (*FederatedServiceIngress) Less ¶

func (ingress *FederatedServiceIngress) Less(i, j int) bool

Less is to satisfy of sort.Interface.

func (*FederatedServiceIngress) RemoveEndpoint ¶

func (ingress *FederatedServiceIngress) RemoveEndpoint(cluster string, endpoint string) *FederatedServiceIngress

RemoveEndpoint removes a single endpoint (ip/hostname) from the federated service ingress

func (*FederatedServiceIngress) String ¶

func (ingress *FederatedServiceIngress) String() string

func (*FederatedServiceIngress) Swap ¶

func (ingress *FederatedServiceIngress) Swap(i, j int)

Swap is to satisfy of sort.Interface.

Source Files ¶

ingress.go