nacos

type Client interface {
	Naming() NamingClient
	Config() ConfigClient
	Logger() Logger
}

type Config struct {
	Scheme      string
	Hosts       []string
	ContextPath string
	AppName     string
	Namespace   string
	Endpoint    string
	Username    string
	Password    string
	AccessKey   string
	SecretKey   string
	Metadata    map[string]string
	HttpClient  *http.Client
	CacheDir    string
	LogDir      string
	LogLevel    LogLevel
}

type ConfigClient interface {
	GetConfig(dataID, group string) string

	GetConfigAndSignListener(dataID, group string, listener EventListener) string

	AddListener(dataID, group string, listener EventListener)

	PublishConfig(dataID, group, content string)

	RemoveConfig(dataID, group string)

	RemoveListener(dataID, group string)

	GetServerStatus() string

	Shutdown()
}

type EventListener interface {
	OnEvent(*ServiceInfo)
}

type Instance struct {
	GroupName   string
	ServiceName string
	ClusterName string
	InstanceID  string
	IP          string
	Port        int
	Weight      float64
	Healthy     bool
	Enable      bool
	Ephemeral   bool
	Metadata    *Metadata
}

type InstanceQueryOptions struct {
	ServiceName string
	GroupName   string
	ClusterName []string
	Subscribe   bool
	Healthy     bool
}

type LogLevel int

type Logger interface {
	Error(format string, args ...interface{})
	Warn(format string, args ...interface{})
	Info(format string, args ...interface{})
	Debug(format string, args ...interface{})
	IsDebugEnable() bool
	IsInfoEnable() bool
	IsErrorEnable() bool
	IsWarnEnable() bool
}

type Metadata struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type NamingClient interface {
	SelectServices(ServiceQueryOptions) (*ServiceList, error)

	SelectService(ServiceQueryOptions) (*Service, error)

	CreateService(ServiceOptions) (*Response, error)

	DeleteService(ServiceOptions) (*Response, error)

	UpdateService(ServiceOptions) (*Response, error)

	RegisterInstance(*Instance) (*Response, error)

	DeRegisterInstance(serviceName, groupName, clusterName, ip string, port int, ephemeral bool) (*Response, error)

	SelectInstance(InstanceQueryOptions) []*Instance

	Subscribe(serviceName, groupName string, clusters []string, listener EventListener)

	Unsubscribe(serviceName, groupName string, clusters []string, listener EventListener)

	Shutdown()
}

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

type Response struct {
	Code    int    `json:"code"`
	Message string `json:"message,omitempty"`
	Data    string `json:"data"`
}

type Selector struct {
	Type SelectorType `json:"type"`
}

type SelectorType string

type Service struct {
	Name             string
	GroupName        string
	AppName          string
	Metadata         map[string]string
	ProtectThreshold float64
}

type ServiceInfo struct {
	Name           string
	GroupName      string
	Clusters       string
	JsonFromServer string
	CacheMillis    int64
	Hosts          []*Instance
	LastRefTime    int64
	Checksum       string
	AllIPs         bool
}

type ServiceList struct {
	Service []string `json:"doms"`
	Count   int      `json:"count"`
}

type ServiceOptions struct {
	// name of service
	ServiceName string
	// group of service
	GroupName string
	// expression of selector
	Expression string
	// protectThreshold of service
	ProtectThreshold float64
	// metadata of service
	Metadata *Metadata
	Selector *Selector
}

type ServiceQueryOptions struct {
	Page        int
	Size        int
	GroupName   string
	ServiceName string
	Selector    Selector
}