Versions in this module Expand all Collapse all v0 v0.19.0 Jun 9, 2015 Changes in this version + type EndpointsConfig struct + func NewEndpointsConfig() *EndpointsConfig + func (c *EndpointsConfig) Channel(source string) chan EndpointsUpdate + func (c *EndpointsConfig) Config() []api.Endpoints + func (c *EndpointsConfig) RegisterHandler(handler EndpointsConfigHandler) + type EndpointsConfigHandler interface + OnUpdate func(endpoints []api.Endpoints) + type EndpointsUpdate struct + Endpoints []api.Endpoints + Op Operation + type EndpointsWatcher interface + List func(label labels.Selector) (*api.EndpointsList, error) + Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error) + type Operation int + const ADD + const REMOVE + const SET + type ServiceConfig struct + func NewServiceConfig() *ServiceConfig + func (c *ServiceConfig) Channel(source string) chan ServiceUpdate + func (c *ServiceConfig) Config() []api.Service + func (c *ServiceConfig) RegisterHandler(handler ServiceConfigHandler) + type ServiceConfigHandler interface + OnUpdate func(services []api.Service) + type ServiceUpdate struct + Op Operation + Services []api.Service + type ServicesWatcher interface + List func(label labels.Selector) (*api.ServiceList, error) + Watch func(label labels.Selector, field fields.Selector, resourceVersion string) (watch.Interface, error) + type SourceAPI struct + func NewSourceAPI(servicesWatcher ServicesWatcher, endpointsWatcher EndpointsWatcher, ...) *SourceAPI