Documentation
¶
Index ¶
- type RedisDiscovery
- func NewRedisDiscovery(basePath string, servicePath string, redisAddr []string, options *store.Config) (*RedisDiscovery, error)
- func NewRedisDiscoveryStore(basePath string, kv store.Store) (*RedisDiscovery, error)
- func NewRedisDiscoveryTemplate(basePath string, redisAddr []string, options *store.Config) (*RedisDiscovery, error)
- func (d *RedisDiscovery) Clone(servicePath string) (client.ServiceDiscovery, error)
- func (d *RedisDiscovery) Close()
- func (d *RedisDiscovery) GetServices() []*client.KVPair
- func (d *RedisDiscovery) RemoveWatcher(ch chan []*client.KVPair)
- func (d *RedisDiscovery) SetFilter(filter client.ServiceDiscoveryFilter)
- func (d *RedisDiscovery) WatchService() chan []*client.KVPair
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisDiscovery ¶
type RedisDiscovery struct {
// -1 means it always retry to watch until zookeeper is ok, 0 means no retry.
RetriesAfterWatchFailed int
// contains filtered or unexported fields
}
RedisDiscovery is a redis service discovery. It always returns the registered servers in redis.
func NewRedisDiscovery ¶
func NewRedisDiscovery(basePath string, servicePath string, redisAddr []string, options *store.Config) (*RedisDiscovery, error)
NewRedisDiscovery returns a new RedisDiscovery.
func NewRedisDiscoveryStore ¶
func NewRedisDiscoveryStore(basePath string, kv store.Store) (*RedisDiscovery, error)
NewRedisDiscoveryStore return a new RedisDiscovery with specified store.
func NewRedisDiscoveryTemplate ¶
func NewRedisDiscoveryTemplate(basePath string, redisAddr []string, options *store.Config) (*RedisDiscovery, error)
NewRedisDiscoveryTemplate returns a new RedisDiscovery template.
func (*RedisDiscovery) Clone ¶
func (d *RedisDiscovery) Clone(servicePath string) (client.ServiceDiscovery, error)
Clone clones this ServiceDiscovery with new servicePath.
func (*RedisDiscovery) Close ¶
func (d *RedisDiscovery) Close()
func (*RedisDiscovery) GetServices ¶
func (d *RedisDiscovery) GetServices() []*client.KVPair
GetServices returns the servers
func (*RedisDiscovery) RemoveWatcher ¶
func (d *RedisDiscovery) RemoveWatcher(ch chan []*client.KVPair)
func (*RedisDiscovery) SetFilter ¶
func (d *RedisDiscovery) SetFilter(filter client.ServiceDiscoveryFilter)
SetFilter sets the filer.
func (*RedisDiscovery) WatchService ¶
func (d *RedisDiscovery) WatchService() chan []*client.KVPair
WatchService returns a nil chan.
Source Files
Click to show internal directories.
Click to hide internal directories.