nacos

README

Nacos Config

import (
	kconfig "github.com/fengleng/mars/config"
	"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 ...Option) config.Source
• type Config
  • func (c *Config) Load() ([]*config.KeyValue, error)
  • func (c *Config) Watch() (config.Watcher, error)
• type Option
  • func WithDataID(dataID string) Option
  • func WithGroup(group string) Option
• 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 ...Option) 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) Watch

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

type Option

type Option func(*options)

func WithDataID

func WithDataID(dataID string) Option

WithDataID With nacos config data id.

func WithGroup

func WithGroup(group string) Option

WithGroup With nacos config group.

type Watcher

type Watcher struct {
	// 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