Documentation
¶
Overview ¶
Package ingress provides a read-only view of Kubernetes ingress resources as an ingress rule configuration type store
Index ¶
- Constants
- Variables
- func ConvertIngressV1alpha3(ingress knetworking.Ingress, mesh *meshconfig.MeshConfig, domainSuffix string) config.Config
- func ConvertIngressVirtualService(ingress knetworking.Ingress, domainSuffix string, ...)
- func EncodeIngressRuleName(ingressName string, ruleNum, pathNum int) string
- func NewController(client kube.Client, meshWatcher mesh.Holder, options kubecontroller.Options) model.ConfigStoreController
- type StatusSyncer
Constants ¶
View Source
const (
IstioIngressController = "istio.io/ingress-controller"
)
Variables ¶
View Source
var IngressNamespace = env.Register("K8S_INGRESS_NS", constants.IstioIngressNamespace, "").Get()
Functions ¶
func ConvertIngressV1alpha3 ¶
func ConvertIngressV1alpha3(ingress knetworking.Ingress, mesh *meshconfig.MeshConfig, domainSuffix string) config.Config
ConvertIngressV1alpha3 converts from ingress spec to Istio Gateway
func ConvertIngressVirtualService ¶
func ConvertIngressVirtualService(ingress knetworking.Ingress, domainSuffix string, ingressByHost map[string]*config.Config, services kclient.Client[*corev1.Service], )
ConvertIngressVirtualService converts from ingress spec to Istio VirtualServices
func EncodeIngressRuleName ¶
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 kube.Client, meshWatcher mesh.Holder, options kubecontroller.Options, ) model.ConfigStoreController
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(meshHolder mesh.Watcher, kc kubelib.Client) *StatusSyncer
NewStatusSyncer creates a new instance
func (*StatusSyncer) Reconcile ¶
func (s *StatusSyncer) Reconcile(key types.NamespacedName) error
func (*StatusSyncer) Run ¶
func (s *StatusSyncer) Run(stopCh <-chan struct{})
Run the syncer until stopCh is closed
Source Files
Click to show internal directories.
Click to hide internal directories.