memory

Documentation

Index

• type Registry
  • func NewRegistry(services ...*model.Service) *Registry
  • func (r *Registry) AddInstance(name string, instances ...*model.ServiceInstance)
  • func (r *Registry) DeleteInstance(name string, instances ...*model.ServiceInstance)
  • func (r *Registry) Deregister(name string) bool
  • func (r *Registry) Get(name string) (*model.Service, error)
  • func (r *Registry) List() ([]string, error)
  • func (r *Registry) Register(service *model.Service)
  • func (r *Registry) Run(ctx context.Context)

Types

type Registry

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

Registry is an implementation of model.ServiceRegistry.

func NewRegistry

func NewRegistry(services ...*model.Service) *Registry

NewRegistry creates a memory service registry. NOTE: It is designed for unit tests, all methods aren't goroutine-safe.

func (*Registry) AddInstance

func (r *Registry) AddInstance(name string, instances ...*model.ServiceInstance)

AddInstance adds some instances to the specified service.

func (*Registry) DeleteInstance

func (r *Registry) DeleteInstance(name string, instances ...*model.ServiceInstance)

DeleteInstance deletes some instances from the specified service.

func (*Registry) Deregister

func (r *Registry) Deregister(name string) bool

Deregister deregisters a service.

func (*Registry) Get

func (r *Registry) Get(name string) (*model.Service, error)

Get gets the service info with the given name.

func (*Registry) List

func (r *Registry) List() ([]string, error)

List returns all registered service names.

func (*Registry) Register

func (r *Registry) Register(service *model.Service)

Register registers a service.

func (*Registry) Run

func (r *Registry) Run(ctx context.Context)

Run runs the registry.