nacos

package module

v0.1.1 Latest Latest Go to latest Published: Sep 3, 2025 License: MIT Imports: 16 Imported by: 1

Details

This section is empty.

View Source

var ErrServiceInstanceNameEmpty = errors.New("kratos/nacos: ServiceInstance.Name can not be empty")

This section is empty.

type Option func(o *options)

Option is nacos option.

func WithCluster(cluster string) Option

WithCluster with a cluster option.

func WithDefaultKind(kind string) Option

WithDefaultKind with a default kind option.

func WithGroup(group string) Option

WithGroup with a group option.

func WithPrefix(prefix string) Option

WithPrefix with a prefix path.

func WithWeight(weight float64) Option

WithWeight with a weight option.

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

Registry is nacos registry.

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

New a nacos registry.

func NewRegistry(c *conf.Registry) *Registry

NewRegistry 创建一个注册发现客户端 - Nacos

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

Deregister the registration.

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

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

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

Register the registration.

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

Watch creates a watcher according to the service name.