nacos

Documentation

Index

• func ToProviderInstance(nacosInstances []model.Instance) []provider.Instancer
• type File
• type NacosProvider
  • func NewProvider(options Options) (*NacosProvider, error)
  • func (p *NacosProvider) ConfigOpen() ([]*File, error)
  • func (p *NacosProvider) SetOnChanged(changeFunc provider.ChangeFunc)
  • func (p *NacosProvider) Watch() error
• type NacosServiceDiscovery
  • func NewNacosServiceDiscovery(options Options) (*NacosServiceDiscovery, error)
  • func (d *NacosServiceDiscovery) GetInstances(ctx context.Context, options provider.GetInstanceOptions) ([]provider.Instancer, error)
  • func (d *NacosServiceDiscovery) Watch(ctx context.Context, options provider.GetInstanceOptions) (<-chan []provider.Instancer, error)
• type Options

Functions

func ToProviderInstance

func ToProviderInstance(nacosInstances []model.Instance) []provider.Instancer

Types

type File

type File struct {
	DataID  string
	Group   string
	Content string
}

type NacosProvider

type NacosProvider struct {
	OnChanged provider.ChangeFunc
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider(options Options) (*NacosProvider, error)

func (*NacosProvider) ConfigOpen

func (p *NacosProvider) ConfigOpen() ([]*File, error)

func (*NacosProvider) SetOnChanged

func (p *NacosProvider) SetOnChanged(changeFunc provider.ChangeFunc)

func (*NacosProvider) Watch

func (p *NacosProvider) Watch() error

type NacosServiceDiscovery

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

func NewNacosServiceDiscovery

func NewNacosServiceDiscovery(options Options) (*NacosServiceDiscovery, error)

func (*NacosServiceDiscovery) GetInstances

func (d *NacosServiceDiscovery) GetInstances(ctx context.Context, options provider.GetInstanceOptions) ([]provider.Instancer, error)

func (*NacosServiceDiscovery) Watch

func (d *NacosServiceDiscovery) Watch(ctx context.Context, options provider.GetInstanceOptions) (<-chan []provider.Instancer, error)

type Options

type Options struct {
	Username    string
	Password    string
	NamespaceID string
	Prefix      string
	LogDir      string
	LogLevel    string // debug, info, warn, error
	CacheDir    string
	Endpoints   []string
	Files       []*File
	Timeout     time.Duration
	Watch       bool
}