Versions in this module Expand all Collapse all v0 v0.4.2 Oct 29, 2014 v0.4.1 Oct 17, 2014 Changes in this version + type ConfigSourceEtcd struct + func NewConfigSourceEtcd(client *etcd.Client, serviceChannel chan ServiceUpdate, ...) ConfigSourceEtcd + func (s ConfigSourceEtcd) GetEndpoints(service string) (api.Endpoints, error) + func (s ConfigSourceEtcd) GetServices() ([]api.Service, []api.Endpoints, error) + func (s ConfigSourceEtcd) ProcessChange(response *etcd.Response) + func (s ConfigSourceEtcd) ProcessEndpointResponse(response *etcd.Response) + func (s ConfigSourceEtcd) Run() + func (s ConfigSourceEtcd) WatchForChanges() + type EndpointsConfig struct + func NewEndpointsConfig() *EndpointsConfig + func (c *EndpointsConfig) Channel(source string) chan EndpointsUpdate + func (c *EndpointsConfig) Config() map[string]map[string]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 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() map[string]map[string]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 SourceAPI struct + func NewSourceAPI(client Watcher, period time.Duration, services chan<- ServiceUpdate, ...) *SourceAPI + type Watcher interface + ListEndpoints func(ctx api.Context, label labels.Selector) (*api.EndpointsList, error) + ListServices func(ctx api.Context, label labels.Selector) (*api.ServiceList, error) + WatchEndpoints func(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error) + WatchServices func(ctx api.Context, label, field labels.Selector, resourceVersion string) (watch.Interface, error)
Go to main page