ingress

Documentation

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.