Versions in this module Expand all Collapse all v1 v1.0.0 Jul 24, 2018 Changes in this version + func NewServerDefaults() (*server.Config, error) + type EndpointsAccessor interface + EndpointsByHostnameIP func(ip string) ([]*api.Endpoints, error) + HasSynced func() bool + func NewCachedEndpointsAccessor(endpointsInformer kcoreinformers.EndpointsInformer) (EndpointsAccessor, error) + type FallbackFunc func(name string, exact bool) (string, bool) + type Server struct + Config *server.Config + Endpoints EndpointsAccessor + MetricsName string + Services ServiceAccessor + func NewServer(config *server.Config, services ServiceAccessor, endpoints EndpointsAccessor, ...) *Server + func (s *Server) ListenAndServe(stopCh <-chan struct{}) error + type ServiceAccessor interface + HasSynced func() bool + ServiceByClusterIP func(ip string) (*api.Service, error) + func NewCachedServiceAccessor(serviceInformer kcoreinformers.ServiceInformer) (ServiceAccessor, error) + type ServiceResolver struct + func NewServiceResolver(config *server.Config, accessor ServiceAccessor, endpoints EndpointsAccessor, ...) *ServiceResolver + func (b *ServiceResolver) Records(dnsName string, exact bool) ([]msg.Service, error) + func (b *ServiceResolver) ReverseRecord(name string) (*msg.Service, error) + type SimpleEndpointsAccessor struct + func (a SimpleEndpointsAccessor) EndpointsByHostnameIP(_ string) ([]*api.Endpoints, error) + func (a SimpleEndpointsAccessor) HasSynced() bool
Go to main page