nacos

README

Nacos Registry

example

server

package main

import (
	"log"

	"github.com/nacos-group/nacos-sdk-go/clients"
	"github.com/nacos-group/nacos-sdk-go/common/constant"
	"github.com/nacos-group/nacos-sdk-go/vo"

	"github.com/go-kratos/kratos/contrib/registry/nacos/v2"
	"github.com/zhiyunliu/glue"
)

func main() {
	sc := []constant.ServerConfig{
		*constant.NewServerConfig("127.0.0.1", 8848),
	}
	

	client, err := clients.NewNamingClient(
		vo.NacosClientParam{
			ServerConfigs: sc,
		},
	)

	if err != nil {
		log.Panic(err)
	}

	r := nacos.New(client)

	// server
	app := kratos.New(
		kratos.Name("helloworld"),
		kratos.Registrar(r),
	)
	if err := app.Run(); err != nil {
		log.Fatal(err)
	}
}

client

package main

import (
	"context"
	"log"

	"github.com/nacos-group/nacos-sdk-go/clients"
	"github.com/nacos-group/nacos-sdk-go/common/constant"
	"github.com/nacos-group/nacos-sdk-go/vo"

	"github.com/go-kratos/kratos/contrib/registry/nacos/v2"
	"github.com/zhiyunliu/glue/transport/grpc"
)

func main() {

	cc := constant.ClientConfig{
		NamespaceId: "public",
		TimeoutMs:   5000,
	}

	client, err := clients.NewNamingClient(
		vo.NacosClientParam{
			ClientConfig: &cc,
		},
	)

	if err != nil {
		log.Panic(err)
	}

	r := nacos.New(client)

	// client
	conn, err := grpc.DialInsecure(
		context.Background(),
		grpc.WithEndpoint("discovery:///helloworld"),
		grpc.WithDiscovery(r),
	)
	defer conn.Close()
}

Documentation

Index

• type Registry
  • func New(cli naming_client.INamingClient, ncp *vo.NacosClientParam, opts *options) (r *Registry)
  • func (r Registry) Deregister(_ context.Context, service *registry.ServiceInstance) error
  • func (r Registry) GetAllServicesInfo(ctx context.Context) (list registry.ServiceList, err error)
  • func (r Registry) GetImpl() any
  • func (r Registry) GetService(_ context.Context, serviceName string) ([]*registry.ServiceInstance, error)
  • func (r Registry) Name() string
  • func (r Registry) Register(_ context.Context, si *registry.ServiceInstance) error
  • func (r Registry) ServerConfigs() string
  • func (r Registry) Watch(ctx context.Context, serviceName string) (registry.Watcher, error)
• type ServiceCatalogInfo

Types

type Registry

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

Registry is nacos registry.

func New

func New(cli naming_client.INamingClient, ncp *vo.NacosClientParam, opts *options) (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) GetAllServicesInfo

func (r Registry) GetAllServicesInfo(ctx context.Context) (list registry.ServiceList, err error)

func (Registry) GetImpl

func (r Registry) GetImpl() any

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) Name

func (r Registry) Name() string

Register the registration.

func (Registry) Register

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

Register the registration.

func (Registry) ServerConfigs

func (r Registry) ServerConfigs() string

func (Registry) Watch

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

Watch creates a watcher according to the service name.

type ServiceCatalogInfo

type ServiceCatalogInfo struct {
	NamespaceId      string            `json:"namespaceId"`
	GroupName        string            `json:"groupName"`
	Name             string            `json:"name"`
	ProtectThreshold float64           `json:"protectThreshold"`
	Metadata         map[string]string `json:"metadata"`
}