memory

Documentation

Index

• func NewServerDiscovery(serviceName string, serviceList []string, port uint64) servicediscovery.IServiceDiscovery
• type MemoryCache
  • func (memoryCache *MemoryCache) GetService(serviceName string) (*servicediscovery.Service, error)
  • func (memoryCache *MemoryCache) Stop()
• type Registrar
  • func (registrar *Registrar) Destroy() error
  • func (registrar *Registrar) GetAllInstances(serviceName string) []servicediscovery.ServiceInstance
  • func (registrar *Registrar) GetAllServices() ([]*servicediscovery.Service, error)
  • func (registrar *Registrar) GetHealthyInstances(serviceName string) []servicediscovery.ServiceInstance
  • func (registrar *Registrar) GetName() string
  • func (registrar *Registrar) Register() error
  • func (registrar *Registrar) Unregister() error
  • func (registrar *Registrar) Update() error
  • func (registrar *Registrar) Watch(opts ...servicediscovery.WatchOption) (servicediscovery.Watcher, error)
• type Watcher
  • func NewWatcher() *Watcher
  • func (m *Watcher) Next() (*servicediscovery.Result, error)
  • func (m *Watcher) Stop()

Functions

func NewServerDiscovery

func NewServerDiscovery(serviceName string, serviceList []string, port uint64) servicediscovery.IServiceDiscovery

Types

type MemoryCache

type MemoryCache struct {
	Services []string
	Port     uint64
}

func (*MemoryCache) GetService

func (memoryCache *MemoryCache) GetService(serviceName string) (*servicediscovery.Service, error)

func (*MemoryCache) Stop

func (memoryCache *MemoryCache) Stop()

type Registrar

type Registrar struct {
	// contains filtered or unexported fields
}

func (*Registrar) Destroy

func (registrar *Registrar) Destroy() error

func (*Registrar) GetAllInstances

func (registrar *Registrar) GetAllInstances(serviceName string) []servicediscovery.ServiceInstance

func (*Registrar) GetAllServices

func (registrar *Registrar) GetAllServices() ([]*servicediscovery.Service, error)

func (*Registrar) GetHealthyInstances

func (registrar *Registrar) GetHealthyInstances(serviceName string) []servicediscovery.ServiceInstance

func (*Registrar) GetName

func (registrar *Registrar) GetName() string

func (*Registrar) Register

func (registrar *Registrar) Register() error

func (*Registrar) Unregister

func (registrar *Registrar) Unregister() error

func (*Registrar) Update

func (registrar *Registrar) Update() error

func (*Registrar) Watch

func (registrar *Registrar) Watch(opts ...servicediscovery.WatchOption) (servicediscovery.Watcher, error)

type Watcher

type Watcher struct {
	Res chan *servicediscovery.Result
	// contains filtered or unexported fields
}

func NewWatcher

func NewWatcher() *Watcher

func (*Watcher) Next

func (m *Watcher) Next() (*servicediscovery.Result, error)

func (*Watcher) Stop

func (m *Watcher) Stop()