nacos

Documentation

Index

• type ClientConfig
• type Nacos
  • func NewNacos(s []ServerConfig, c ClientConfig) (*Nacos, error)
  • func (n Nacos) Deregister(serverName string) (bool, error)
  • func (n Nacos) GetConfig(id, group string) (string, error)
  • func (n Nacos) GetOneServer(serverName string) (ip string, port uint64, err error)
  • func (n Nacos) Listen(id, group string, callbackFunc func(data string) error) error
  • func (n Nacos) Register(c RegisterConfig) (bool, error)
• type RegisterConfig
• type RegisterInstance
• type ServerConfig

Types

type ClientConfig

type ClientConfig struct {
	NamespaceId         string `json:"namespaceId" mapstructure:"namespaceId"`
	TimeoutMs           uint64 `json:"timeoutMs" mapstructure:"timeoutMs"`
	NotLoadCacheAtStart bool   `json:"notLoadCacheAtStart" mapstructure:"notLoadCacheAtStart"`
	LogDir              string `json:"logDir" mapstructure:"logDir"`
	CacheDir            string `json:"cacheDir" mapstructure:"cacheDir"`
	LogLevel            string `json:"logLevel" mapstructure:"logLevel"`
}

type Nacos

type Nacos struct {
	ClientConfig     ClientConfig
	ServerConfigs    []ServerConfig
	RegisterInstance RegisterInstance // 已注册服务的配置
	NamingClient     naming_client.INamingClient
	ConfigClient     config_client.IConfigClient
}

func NewNacos

func NewNacos(s []ServerConfig, c ClientConfig) (*Nacos, error)

NewNacos 实例化nacos

func (Nacos) Deregister

func (n Nacos) Deregister(serverName string) (bool, error)

Deregister 服务注销

func (Nacos) GetConfig

func (n Nacos) GetConfig(id, group string) (string, error)

GetConfig 获取配置

func (Nacos) GetOneServer

func (n Nacos) GetOneServer(serverName string) (ip string, port uint64, err error)

GetOneServer 获取有效的服务信息

func (Nacos) Listen

func (n Nacos) Listen(id, group string, callbackFunc func(data string) error) error

Listen 监听配置

func (Nacos) Register

func (n Nacos) Register(c RegisterConfig) (bool, error)

Register 服务注册

type RegisterConfig

type RegisterConfig vo.RegisterInstanceParam

type RegisterInstance

type RegisterInstance map[string]vo.RegisterInstanceParam

type ServerConfig

type ServerConfig struct {
	Scheme      string `json:"scheme" mapstructure:"scheme"`
	ContextPath string `json:"contextPath" mapstructure:"contextPath"`
	IpAddr      string `json:"ipAddr" mapstructure:"ipAddr"`
	Port        uint64 `json:"port" mapstructure:"port"`
}