model

type Address struct {
	IP   string `json:"ip"`
	Port uint64 `json:"port"`
}

type Controller interface {
	Run(<-chan struct{})
	HasSynced() bool
}

type Direction string

type Event int

type KubeClient interface {
	// KubeInformer returns an informer factory for kube client
	InformerFactory() informers.SharedInformerFactory

	Run(<-chan struct{})
}

type KubeOptions struct {
	KubeConfig string

	WatchedNamespace string
}

type NacosClient interface {
	RegisterService(ServiceInfo, []Address)

	UnregisterService(ServiceInfo)

	RegisterServiceInstances(serviceInfo ServiceInfo, addresses []Address)

	UnregisterServiceInstances(serviceInfo ServiceInfo, addresses []Address)
}

type NacosOptions struct {
	Namespace string

	// ServersIP are explicitly specified to be connected to nacos by client.
	ServersIP []string

	// ServerPort are explicitly specified to be used when the client connects to nacos.
	ServerPort uint64
}

type ServiceInfo struct {
	ServiceKey

	Port uint64

	Metadata map[string]string
}

type ServiceKey struct {
	ServiceName string

	Group string
}

type Task struct {
	Handler func() error
}