registry

type ConsulNode struct {
	Node        string
	NodeId      string
	NodeAddress string
	NodePort    int
}

type ConsulRegistry struct {
	Address string
	Client  *consul.Client
	// contains filtered or unexported fields
}

type ConsulService struct {
	ServiceName  string
	ServiceNodes []*ConsulNode
}

type ConsulWatcher struct {
	Registry *ConsulRegistry
	// contains filtered or unexported fields
}

type KubernetesNode struct {
	NodeId      string
	NodeAddress string
	NodePort    int
}

type KubernetesRegistry struct {
	Client    *k8s.Client
	Namespace string
	// contains filtered or unexported fields
}

type KubernetesService struct {
	ServiceName  string
	ServiceNodes []*KubernetesNode
}

type KubernetesWatcher struct {
	Registry *KubernetesRegistry
}

type Node interface {
	Id() string
	Address() string
	Port() int
}

type Registry interface {
	Register(Service) error
	Deregister(Service) error
	GetService(string) (Service, error)
	ListServices() ([]Service, error)
	NewService(string, ...Node) Service
	NewNode(string, string, int) Node
}

type Service interface {
	Name() string
	Nodes() []Node
}