contour

Nov 19, 2018

Changes in this version

+ type ListenerVisitorConfig struct

+ HTTPAccessLog string

+ HTTPAddress string

+ HTTPPort int

+ HTTPSAccessLog string

+ HTTPSAddress string

+ HTTPSPort int

+ UseProxyProto bool

Sep 20, 2018

Changes in this version

+ const DEFAULT_HTTPS_ACCESS_LOG

+ const DEFAULT_HTTP_ACCESS_LOG

+ type CacheHandler struct

+ IngressRouteStatus *k8s.IngressRouteStatus

+ func (ch *CacheHandler) OnChange(b *dag.Builder)

type ClusterCache

+ func (c *ClusterCache) Register(ch chan int, last int)

+ func (c *ClusterCache) Update(v map[string]*v2.Cluster)

+ type EndpointsTranslator struct

+ func (c *EndpointsTranslator) Add(assignments ...*v2.ClusterLoadAssignment)

+ func (c *EndpointsTranslator) Remove(names ...string)

+ func (e *EndpointsTranslator) OnAdd(obj interface{})

+ func (e *EndpointsTranslator) OnDelete(obj interface{})

+ func (e *EndpointsTranslator) OnUpdate(oldObj, newObj interface{})

+ type HoldoffNotifier struct

+ func (hn *HoldoffNotifier) OnChange(builder *dag.Builder)

type ListenerCache

+ HTTPAccessLog string

+ HTTPSAccessLog string

+ func (c *ListenerCache) Register(ch chan int, last int)

+ func (c *ListenerCache) Update(v map[string]*v2.Listener)

+ type Notifier interface

+ OnChange func(*dag.Builder)

+ type ResourceEventHandler struct

+ IngressClass string

+ func (reh *ResourceEventHandler) OnAdd(obj interface{})

+ func (reh *ResourceEventHandler) OnDelete(obj interface{})

+ func (reh *ResourceEventHandler) OnUpdate(oldObj, newObj interface{})

+ type RouteCache struct

+ func (c *RouteCache) Register(ch chan int, last int)

+ func (c *RouteCache) Update(v map[string]*v2.RouteConfiguration)

+ func (c *RouteCache) Values(filter func(string) bool) []proto.Message

Mar 15, 2018

Changes in this version

+ const DEFAULT_INGRESS_CLASS

type Translator

+ IngressClass string

Jan 18, 2018

Changes in this version

+ const DEFAULT_HTTPS_LISTENER_ADDRESS

+ const DEFAULT_HTTPS_LISTENER_PORT

+ const DEFAULT_HTTP_LISTENER_ADDRESS

+ const DEFAULT_HTTP_LISTENER_PORT

+ const ENVOY_HTTPS_LISTENER

+ const ENVOY_HTTP_LISTENER

type ClusterCache

+ func (cc *ClusterCache) Add(clusters ...*v2.Cluster)

+ func (cc *ClusterCache) Remove(names ...string)

type ClusterLoadAssignmentCache

+ func (c *ClusterLoadAssignmentCache) Add(assignments ...*v2.ClusterLoadAssignment)

+ func (c *ClusterLoadAssignmentCache) Remove(names ...string)

+ type Cond struct

+ func (c *Cond) Notify()

+ func (c *Cond) Register(ch chan int, last int)

type ListenerCache

+ HTTPAddress string

+ HTTPPort int

+ HTTPSAddress string

+ HTTPSPort int

+ UseProxyProto bool

+ func (lc *ListenerCache) Add(listeners ...*v2.Listener)

+ func (lc *ListenerCache) Remove(names ...string)

+ type Translator struct

+ func (t *Translator) OnAdd(obj interface{})

+ func (t *Translator) OnDelete(obj interface{})

+ func (t *Translator) OnUpdate(oldObj, newObj interface{})

type VirtualHostCache

+ HTTP virtualHostCache

+ HTTPS virtualHostCache

Nov 28, 2017

Changes in this version

+ const ClusterType

+ const EndpointType

+ const ListenerType

+ const RouteType

+ func EndpointsToSDSHosts(e *v1.Endpoints, port int) ([]*envoy.SDSHost, error)

+ func IngressToVirtualHosts(i *v1beta1.Ingress) ([]*envoy.VirtualHost, error)

+ func NewGRPCAPI(l log.Logger, cc ClusterCache, ec ClusterLoadAssignmentCache, ...) *grpc.Server

+ func NewJSONAPI(l log.Logger, ds *DataSource) http.Handler

+ func ServiceToClusters(s *v1.Service) ([]envoy.Cluster, error)

+ type CDS struct

+ func (c *CDS) FetchClusters(_ context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ func (c *CDS) StreamClusters(srv v2.ClusterDiscoveryService_StreamClustersServer) error

+ type ClusterCache interface

+ Values func() []*v2.Cluster

+ type ClusterLoadAssignmentCache interface

+ Values func() []*v2.ClusterLoadAssignment

+ type DataSource struct

+ func (ds *DataSource) OnAdd(obj interface{})

+ func (ds *DataSource) OnDelete(obj interface{})

+ func (ds *DataSource) OnUpdate(_, newObj interface{})

+ type EDS struct

+ func (e *EDS) FetchEndpoints(_ context.Context, req *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ func (e *EDS) StreamEndpoints(srv v2.EndpointDiscoveryService_StreamEndpointsServer) error

+ func (e *EDS) StreamLoadStats(srv v2.EndpointDiscoveryService_StreamLoadStatsServer) error

+ type EndpointsCache struct

+ func (ec *EndpointsCache) AddEndpoints(e *v1.Endpoints)

+ func (ec *EndpointsCache) Each(fn func(*v1.Endpoints))

+ func (ec *EndpointsCache) RemoveEndpoints(e *v1.Endpoints)

+ type IngressCache struct

+ func (ic *IngressCache) AddIngress(i *v1beta1.Ingress)

+ func (ic *IngressCache) Each(fn func(*v1beta1.Ingress))

+ func (ic *IngressCache) RemoveIngress(i *v1beta1.Ingress)

+ type LDS struct

+ func (l *LDS) FetchListeners(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ func (l *LDS) StreamListeners(srv v2.ListenerDiscoveryService_StreamListenersServer) error

+ type ListenerCache interface

+ Values func() []*v2.Listener

+ type RDS struct

+ func (r *RDS) FetchRoutes(context.Context, *v2.DiscoveryRequest) (*v2.DiscoveryResponse, error)

+ func (r *RDS) StreamRoutes(srv v2.RouteDiscoveryService_StreamRoutesServer) error

+ type ServiceCache struct

+ func (sc *ServiceCache) AddService(s *v1.Service)

+ func (sc *ServiceCache) Each(fn func(*v1.Service))

+ func (sc *ServiceCache) RemoveService(s *v1.Service)

+ type VirtualHostCache interface

+ Values func() []*v2.VirtualHost