nacos

README

Nacos Config

import (
	"github.com/nacos-group/nacos-sdk-go/clients"
	"github.com/nacos-group/nacos-sdk-go/common/constant"
)


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

cc := &constant.ClientConfig{
	NamespaceId:         "public", //namespace id
	TimeoutMs:           5000,
	NotLoadCacheAtStart: true,
	LogDir:              "/tmp/nacos/log",
	CacheDir:            "/tmp/nacos/cache",
	RotateTime:          "1h",
	MaxAge:              3,
	LogLevel:            "debug",
}

// a more graceful way to create naming client
client, err := clients.NewConfigClient(
	vo.NacosClientParam{
		ClientConfig:  cc,
		ServerConfigs: sc,
	},
)
if err != nil {
	log.Panic(err)
}

Documentation

Index

• func NewConfigSource(client config_client.IConfigClient, opts options) config.Source
• type Config
  • func (c *Config) Load() ([]*config.KeyValue, error)
  • func (c *Config) Name() string
  • func (f *Config) Path() string
  • func (c *Config) Watch() (config.Watcher, error)
• type Watcher
  • func (w *Watcher) Close() error
  • func (w *Watcher) Next() ([]*config.KeyValue, error)
  • func (w *Watcher) Stop() error

Functions

func NewConfigSource

func NewConfigSource(client config_client.IConfigClient, opts options) config.Source

Types

type Config

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

func (*Config) Load

func (c *Config) Load() ([]*config.KeyValue, error)

func (*Config) Name

func (c *Config) Name() string

func (*Config) Path

func (f *Config) Path() string

func (*Config) Watch

func (c *Config) Watch() (config.Watcher, error)

type Watcher

type Watcher struct {
	context.Context
	// contains filtered or unexported fields
}

func (*Watcher) Close

func (w *Watcher) Close() error

func (*Watcher) Next

func (w *Watcher) Next() ([]*config.KeyValue, error)

func (*Watcher) Stop

func (w *Watcher) Stop() error