Documentation
¶
Index ¶
- func CreateHttpFilterChain(pathList []*IngressHttpInfo) *listener.FilterChain
- func CreateTlsHttpFilterChain(host string, pathList []*IngressHttpInfo) *listener.FilterChain
- func IngressName(host string) string
- func SortIngressHttpInfo(pathList []*IngressHttpInfo)
- type IngressHttpInfo
- type IngressListenerInfo
- type IngressListenersControlPlaneService
- func (cps *IngressListenersControlPlaneService) BuildResource(resourceMap map[string]common.EnvoyResource, version string, node *core.Node) (*envoy_api_v2.DiscoveryResponse, error)
- func (cps *IngressListenersControlPlaneService) IngressAdded(ingressInfo *kubernetes.IngressInfo)
- func (cps *IngressListenersControlPlaneService) IngressDeleted(ingressInfo *kubernetes.IngressInfo)
- func (cps *IngressListenersControlPlaneService) IngressUpdated(oldIngress, newIngress *kubernetes.IngressInfo)
- func (cps *IngressListenersControlPlaneService) IngressValid(ingressInfo *kubernetes.IngressInfo) bool
- func (cps *IngressListenersControlPlaneService) ServiceAdded(svc *kubernetes.ServiceInfo)
- func (cps *IngressListenersControlPlaneService) ServiceDeleted(svc *kubernetes.ServiceInfo)
- func (cps *IngressListenersControlPlaneService) ServiceUpdated(oldService, newService *kubernetes.ServiceInfo)
- func (cps *IngressListenersControlPlaneService) ServiceValid(svc *kubernetes.ServiceInfo) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateHttpFilterChain ¶
func CreateHttpFilterChain(pathList []*IngressHttpInfo) *listener.FilterChain
func CreateTlsHttpFilterChain ¶
func CreateTlsHttpFilterChain(host string, pathList []*IngressHttpInfo) *listener.FilterChain
func IngressName ¶
func SortIngressHttpInfo ¶
func SortIngressHttpInfo(pathList []*IngressHttpInfo)
Types ¶
type IngressHttpInfo ¶
type IngressHttpInfo struct { listener.HttpListenerConfigInfo Host string Path string Service string Namespace string Port uint32 Secret string }
func NewIngressHttpInfo ¶
func (*IngressHttpInfo) CreateRoute ¶
func (info *IngressHttpInfo) CreateRoute() *route.Route
func (*IngressHttpInfo) GetCluster ¶
func (info *IngressHttpInfo) GetCluster() string
func (*IngressHttpInfo) Name ¶
func (info *IngressHttpInfo) Name() string
func (*IngressHttpInfo) String ¶
func (info *IngressHttpInfo) String() string
func (*IngressHttpInfo) Type ¶
func (info *IngressHttpInfo) Type() string
type IngressListenerInfo ¶
type IngressListenerInfo interface { common.EnvoyResource }
type IngressListenersControlPlaneService ¶
type IngressListenersControlPlaneService struct { *common.ControlPlaneService // contains filtered or unexported fields }
func NewIngressListenersControlPlaneService ¶
func NewIngressListenersControlPlaneService(k8sManager *kubernetes.K8sResourceManager) *IngressListenersControlPlaneService
func (*IngressListenersControlPlaneService) BuildResource ¶
func (cps *IngressListenersControlPlaneService) BuildResource(resourceMap map[string]common.EnvoyResource, version string, node *core.Node) (*envoy_api_v2.DiscoveryResponse, error)
func (*IngressListenersControlPlaneService) IngressAdded ¶
func (cps *IngressListenersControlPlaneService) IngressAdded(ingressInfo *kubernetes.IngressInfo)
func (*IngressListenersControlPlaneService) IngressDeleted ¶
func (cps *IngressListenersControlPlaneService) IngressDeleted(ingressInfo *kubernetes.IngressInfo)
func (*IngressListenersControlPlaneService) IngressUpdated ¶
func (cps *IngressListenersControlPlaneService) IngressUpdated(oldIngress, newIngress *kubernetes.IngressInfo)
func (*IngressListenersControlPlaneService) IngressValid ¶
func (cps *IngressListenersControlPlaneService) IngressValid(ingressInfo *kubernetes.IngressInfo) bool
func (*IngressListenersControlPlaneService) ServiceAdded ¶
func (cps *IngressListenersControlPlaneService) ServiceAdded(svc *kubernetes.ServiceInfo)
func (*IngressListenersControlPlaneService) ServiceDeleted ¶
func (cps *IngressListenersControlPlaneService) ServiceDeleted(svc *kubernetes.ServiceInfo)
func (*IngressListenersControlPlaneService) ServiceUpdated ¶
func (cps *IngressListenersControlPlaneService) ServiceUpdated(oldService, newService *kubernetes.ServiceInfo)
func (*IngressListenersControlPlaneService) ServiceValid ¶
func (cps *IngressListenersControlPlaneService) ServiceValid(svc *kubernetes.ServiceInfo) bool
Click to show internal directories.
Click to hide internal directories.