ingress

Documentation

Overview

Package ingress provides a read-only view of Kubernetes ingress resources as an ingress rule configuration type store

Index

• func ConvertIngressV1alpha3(ingress v1beta1.Ingress, domainSuffix string) model.Config
• func ConvertIngressVirtualService(ingress v1beta1.Ingress, domainSuffix string, ...)
• func EncodeIngressRuleName(ingressName string, ruleNum, pathNum int) string
• func NewController(client kubernetes.Interface, mrc controller2.MemberRollController, ...) model.ConfigStoreCache
• type StatusSyncer
  • func NewStatusSyncer(mesh *meshconfig.MeshConfig, client kubernetes.Interface, ...) (*StatusSyncer, error)
  • func (s *StatusSyncer) Run(stopCh <-chan struct{})

Functions

func ConvertIngressV1alpha3

func ConvertIngressV1alpha3(ingress v1beta1.Ingress, domainSuffix string) model.Config

ConvertIngressV1alpha3 converts from ingress spec to Istio Gateway

func ConvertIngressVirtualService

func ConvertIngressVirtualService(ingress v1beta1.Ingress, domainSuffix string, ingressByHost map[string]*model.Config)

ConvertIngressVirtualService converts from ingress spec to Istio VirtualServices

func EncodeIngressRuleName

func EncodeIngressRuleName(ingressName string, ruleNum, pathNum int) string

EncodeIngressRuleName encodes an ingress rule name for a given ingress resource name, as well as the position of the rule and path specified within it, counting from 1. ruleNum == pathNum == 0 indicates the default backend specified for an ingress.

func NewController

func NewController(client kubernetes.Interface, mrc controller2.MemberRollController, mesh *meshconfig.MeshConfig,
	options kube.ControllerOptions) model.ConfigStoreCache

NewController creates a new Kubernetes controller

Types

type StatusSyncer

type StatusSyncer struct {
	// contains filtered or unexported fields
}

StatusSyncer keeps the status IP in each Ingress resource updated

func NewStatusSyncer

func NewStatusSyncer(mesh *meshconfig.MeshConfig,
	client kubernetes.Interface,
	mrc controller2.MemberRollController,
	pilotNamespace string,
	options kube.ControllerOptions) (*StatusSyncer, error)

NewStatusSyncer creates a new instance

func (*StatusSyncer) Run

func (s *StatusSyncer) Run(stopCh <-chan struct{})

Run the syncer until stopCh is closed