configuration

May 10, 2024

Changes in this version

+ type Chooser struct

+ func (chs Chooser) Pick() model.Instance

+ type DiscoverOptionFunc func(*discoverOptions)

+ func WithChoose(choose IChooseFunc) DiscoverOptionFunc

+ func WithCluster(cluster string) DiscoverOptionFunc

+ func WithGroup(group string) DiscoverOptionFunc

+ func WithService(service string) DiscoverOptionFunc

+ func WithVersion(version string) DiscoverOptionFunc

+ type IChooseFunc func(instances ...model.Instance) model.Instance

+ type InstanceSlice []model.Instance

+ func (a InstanceSlice) Len() int

+ func (a InstanceSlice) Less(i, j int) bool

+ func (a InstanceSlice) Swap(i, j int)

type NacosCenter

+ func (n *NacosCenter) Discover(options ...DiscoverOptionFunc) ([]model.Instance, error)

+ func (n *NacosCenter) DiscoverOne(options ...DiscoverOptionFunc) (model.Instance, error)

Apr 24, 2024

Changes in this version

type ConfigName

+ ExtConfigFile string

type IConfigCenter

+ GetConfigClient func() config_client.IConfigClient

type IConfigurationCenter

+ GetServiceInfo func() ServiceInfo

type IDiscoverCenter

+ GetNamingClient func() naming_client.INamingClient

type NacosCenter

+ func (n *NacosCenter) GetConfigClient() config_client.IConfigClient

+ func (n *NacosCenter) GetNamingClient() naming_client.INamingClient

+ func (n *NacosCenter) GetServiceInfo() ServiceInfo

type ServiceInfo

+ Sentinel ConfigName

Apr 20, 2024

Changes in this version

type IRegisterCenter

+ GetIP func() string

type NacosCenter

+ func (n *NacosCenter) GetIP() string

Oct 16, 2023

Changes in this version

type IRegisterCenter

+ DeRegisterServ func(srvname string, port uint64) error

+ GetServiceName func() string

+ RegisterServ func(meta map[string]string, srvname string, port uint64) error

type NacosCenter

+ func (n *NacosCenter) DeRegisterServ(srvname string, port uint64) error

+ func (n *NacosCenter) GetServiceName() string

+ func (n *NacosCenter) RegisterServ(meta map[string]string, srvname string, port uint64) error

+ func (n *NacosCenter) UpdateServ(srvname string, port uint64) error

Jul 25, 2023

Changes in this version

+ type ConfigName struct

+ GroupName string

+ ServiceName string

type ServiceInfo

+ Others []ConfigName

Jul 25, 2023

Changes in this version

type ServiceInfo

+ OtherConfigs map[string][]string

May 17, 2023

Changes in this version

+ func SetILogger(log ILogger)

May 17, 2023

Changes in this version

type IConfigurationCenter

+ SetILogger func(log ILogger)

type NacosCenter

+ func (n *NacosCenter) SetILogger(log ILogger)

Apr 9, 2023

Changes in this version

+ const KEY_TMP_PORT_PATH

Apr 9, 2023

Changes in this version

+ type IConfigCenter interface

+ AddConfigListener func(id, group string) error

+ Get func(key string) interface{}

+ GetByID func(group, id, key string) interface{}

+ type IDiscoverCenter interface

+ DiscoverInstanceOne func(group, service string, clusters ...string) (string, error)

+ type IRegisterCenter interface

+ DeRegisterMine func() error

+ GetPort func() uint64

+ RegisterMine func() error

+ SetRealPort func(port int)

type NacosCenter

+ func (n *NacosCenter) DiscoverInstanceOne(group, service string, clusters ...string) (string, error)

Apr 8, 2023

Changes in this version

+ const KEY_IS_REMOTE

+ func Get(key string) interface

+ func GetIP() (string, error)

+ func GetIPX() string

+ func Init() error

+ func IsRemote() bool

+ func LoadConfig(configPath string) error

+ type Config vo.NacosClientParam

+ type DefaultLogger struct

+ func (l *DefaultLogger) DebugCtx(_ context.Context, msg string)

+ func (l *DefaultLogger) ErrorCtx(_ context.Context, msg string)

+ func (l *DefaultLogger) InfoCtx(_ context.Context, msg string)

+ func (l *DefaultLogger) WarnCtx(_ context.Context, msg string)

+ type IConfigurationCenter interface

+ AddConfigListener func(id, group string) error

+ DeRegisterMine func() error

+ Get func(key string) interface{}

+ GetByID func(group, id, key string) interface{}

+ GetPort func() uint64

+ RegisterMine func() error

+ SetRealPort func(port int)

+ var DefaultCenter IConfigurationCenter

+ func NewNacos(param vo.NacosClientParam, serv ServiceInfo) (IConfigurationCenter, error)

+ func NewSimpleNacos(cfg *SimpleConfig) (IConfigurationCenter, error)

+ type ILogger interface

+ DebugCtx func(ctx context.Context, msg string)

+ ErrorCtx func(ctx context.Context, msg string)

+ InfoCtx func(ctx context.Context, msg string)

+ WarnCtx func(ctx context.Context, msg string)

+ type NacosCenter struct

+ ConfigClient config_client.IConfigClient

+ NamingClient naming_client.INamingClient

+ RealPort int

+ func (n *NacosCenter) AddConfigListener(id, group string) error

+ func (n *NacosCenter) BatchRegisterService(param vo.BatchRegisterInstanceParam)

+ func (n *NacosCenter) DeRegisterMine() error

+ func (n *NacosCenter) DeRegisterService(param vo.DeregisterInstanceParam) (bool, error)

+ func (n *NacosCenter) Get(key string) interface{}

+ func (n *NacosCenter) GetAllService(param vo.GetAllServiceInfoParam)

+ func (n *NacosCenter) GetByID(group, id, key string) interface{}

+ func (n *NacosCenter) GetContent(id, group string) (string, error)

+ func (n *NacosCenter) GetPort() uint64

+ func (n *NacosCenter) GetService(param vo.GetServiceParam)

+ func (n *NacosCenter) ListenContent(id, group string, f func(namespace, group, dataId, data string)) error

+ func (n *NacosCenter) RegisterMine() error

+ func (n *NacosCenter) RegisterService(param vo.RegisterInstanceParam) (bool, error)

+ func (n *NacosCenter) SelectAllInstances(param vo.SelectAllInstancesParam)

+ func (n *NacosCenter) SelectInstances(param vo.SelectInstancesParam)

+ func (n *NacosCenter) SelectOneHealthyInstance(param vo.SelectOneHealthInstanceParam)

+ func (n *NacosCenter) SetConfig(namespace, group, dataId, data string) error

+ func (n *NacosCenter) SetRealPort(port int)

+ func (n *NacosCenter) Subscribe(param *vo.SubscribeParam)

+ func (n *NacosCenter) UnSubscribe(param *vo.SubscribeParam)

+ func (n *NacosCenter) UpdateMine() error

+ func (n *NacosCenter) UpdateService(param vo.UpdateInstanceParam) (bool, error)

+ type ServiceInfo struct

+ ClusterName string

+ Enable bool

+ Ephemeral bool

+ GroupName string

+ Healthy bool

+ IP string

+ Port uint64

+ ServiceName string

+ Weight float64

+ type SimpleClientConfig struct

+ AppName string

+ Endpoint string

+ NamespaceId string

+ Password string

+ Username string

+ func (c *SimpleClientConfig) ToOption() ([]constant.ClientOption, error)

+ type SimpleConfig struct

+ ClientConfig *SimpleClientConfig

+ ServerConfigs []SimpleServerConfig

+ Service ServiceInfo

+ func (c *SimpleConfig) ToParam() (vo.NacosClientParam, error)

+ type SimpleServerConfig struct

+ GrpcPort uint64

+ IpAddr string

+ Port uint64

+ func (c *SimpleServerConfig) ToNacosServerConfig() constant.ServerConfig