registry

Documentation

Index

• Variables
• func Deregister(ctx context.Context, service *registry.ServiceInstance) error
• func GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)
• func Register(ctx context.Context, service *registry.ServiceInstance) error
• func Watch(ctx context.Context, serviceName string) (registry.Watcher, error)
• type RegisterDiscover
  • func GetRegisterDiscover() (RegisterDiscover, error)
  • func NewRegistry(regCfg *registryv1.Registry) (RegisterDiscover, error)

Variables

var (
	ErrNotInitRegisterInstance = errors.New("registry instance not assigned")
	ErrUnknownRegisterInfo     = errors.New("register info unknown")
)

Functions

func Deregister

func Deregister(ctx context.Context, service *registry.ServiceInstance) error

Deregister the registration.

func GetService

func GetService(ctx context.Context, serviceName string) ([]*registry.ServiceInstance, error)

GetService return the service instances in memory according to the service name.

func Register

func Register(ctx context.Context, service *registry.ServiceInstance) error

Register the registration.

func Watch

func Watch(ctx context.Context, serviceName string) (registry.Watcher, error)

Watch creates a watcher according to the service name.

Types

type RegisterDiscover

type RegisterDiscover interface {
	registry.Registrar
	registry.Discovery
}

func GetRegisterDiscover

func GetRegisterDiscover() (RegisterDiscover, error)

func NewRegistry

func NewRegistry(regCfg *registryv1.Registry) (RegisterDiscover, error)