memory

Documentation

Index

• func New(m map[string]interface{}) registry.Registry
• func NewService(name string, nodes []interface{}) registry.Service
• type Registry
  • func (r *Registry) Add(svc registry.Service) error
  • func (r *Registry) GetService(name string) (registry.Service, error)

Functions

func New

func New(m map[string]interface{}) registry.Registry

New returns an implementation of the Registry interface.

func NewService

func NewService(name string, nodes []interface{}) registry.Service

NewService creates a new memory registry.Service.

Types

type Registry

type Registry struct {
	// m protects async access to the services map.
	sync.Mutex
	// contains filtered or unexported fields
}

Registry implements the Registry interface.

func (*Registry) Add

func (r *Registry) Add(svc registry.Service) error

Add implements the Registry interface. If the service is already known in this registry it will only update the nodes.

func (*Registry) GetService

func (r *Registry) GetService(name string) (registry.Service, error)

GetService implements the Registry interface. There is currently no load balance being done, but it should not be hard to add.