provider

type ChangeFunc func() error

type DiscoveryResult struct {
	Target string            // hostname:port (from config TargetOptions.Target, or discovery service name)
	Weight uint32            // target-level weight
	Tags   map[string]string // target-level tags
	Nodes  []Instancer       // resolved instances for this target
}

type GetInstanceOptions struct {
	Namespace string
	Name      string
	Group     string
}

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

type Instancer interface {
	Address() net.Addr
	Weight() uint32
	Tag(key string) (value string, exist bool)
	Tags() map[string]string
}

type Provider interface {
	Watch() error
	SetOnChanged(f ChangeFunc)
}

type ServiceDiscovery interface {
	GetInstances(ctx context.Context, options GetInstanceOptions) ([]DiscoveryResult, error)
	Watch(ctx context.Context, options GetInstanceOptions) (<-chan []DiscoveryResult, error)
	Close() error
}