nacos

Documentation

Overview

Package nacos is registered as a service using nacos.

Index

• func NewRegistry(nacosIPAddr string, nacosPort int, nacosNamespaceID string, id string, ...) (registry.Registry, *registry.ServiceInstance, error)
• type Option
  • func WithCluster(cluster string) Option
  • func WithDefaultKind(kind string) Option
  • func WithGroup(group string) Option
  • func WithPrefix(prefix string) Option
  • func WithWeight(weight float64) Option
• type Registry
  • func New(cli naming_client.INamingClient, opts ...Option) (r *Registry)
  • func (r *Registry) Deregister(_ context.Context, service *registry.ServiceInstance) error
  • func (r *Registry) GetService(_ context.Context, serviceName string) ([]*registry.ServiceInstance, error)
  • func (r *Registry) Register(_ context.Context, si *registry.ServiceInstance) error
  • func (r *Registry) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)

Functions

func NewRegistry

func NewRegistry(nacosIPAddr string, nacosPort int, nacosNamespaceID string,
	id string, instanceName string, instanceEndpoints []string,
	opts ...nacoscli.Option) (registry.Registry, *registry.ServiceInstance, error)

NewRegistry instantiating the nacos registry

Types

type Option

type Option func(o *options)

Option is nacos option.

func WithCluster

func WithCluster(cluster string) Option

WithCluster with cluster option.

func WithDefaultKind

func WithDefaultKind(kind string) Option

WithDefaultKind with default kind option.

func WithGroup

func WithGroup(group string) Option

WithGroup with group option.

func WithPrefix

func WithPrefix(prefix string) Option

WithPrefix with prefix path.

func WithWeight

func WithWeight(weight float64) Option

WithWeight with weight option.

type Registry

type Registry struct {
	NacosClient naming_client.INamingClient
	// contains filtered or unexported fields
}

Registry is nacos registry.

func New

func New(cli naming_client.INamingClient, opts ...Option) (r *Registry)

New new a nacos registry.

func (*Registry) Deregister

func (r *Registry) Deregister(_ context.Context, service *registry.ServiceInstance) error

Deregister the registration.

func (*Registry) GetService

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

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

func (*Registry) Register

func (r *Registry) Register(_ context.Context, si *registry.ServiceInstance) error

Register the registration.

func (*Registry) Watch

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

Watch creates a watcher according to the service name.