Versions in this module Expand all Collapse all v0 v0.2.0 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 v0.1.0 Oct 31, 2017
Go to main page