ingress

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
  • func NewIngressHttpInfo(host string, path string, svc string, ns string, port uint32) *IngressHttpInfo
  • func (info *IngressHttpInfo) CreateRoute() *route.Route
  • func (info *IngressHttpInfo) GetCluster() string
  • func (info *IngressHttpInfo) Name() string
  • func (info *IngressHttpInfo) String() string
  • func (info *IngressHttpInfo) Type() string
• type IngressListenerInfo
• type IngressListenersControlPlaneService
  • func NewIngressListenersControlPlaneService(k8sManager *kubernetes.K8sResourceManager) *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

Functions

func CreateHttpFilterChain

func CreateHttpFilterChain(pathList []*IngressHttpInfo) *listener.FilterChain

func CreateTlsHttpFilterChain

func CreateTlsHttpFilterChain(host string, pathList []*IngressHttpInfo) *listener.FilterChain

func IngressName

func IngressName(host string) string

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 NewIngressHttpInfo(host string, path string, svc string, ns string, port uint32) *IngressHttpInfo

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