discovery

Documentation

Index

• type Discovery
  • func NewKubernetesDiscovery(namespace, portName string, serviceLabels map[string]string) Discovery
  • func NewMdnsDiscovery(serviceName string) Discovery
  • func NewStaticDiscovery(peers []string) Discovery

Types

type Discovery

type Discovery interface {
	// Name gives the name of the discovery.
	Name() string

	// Start is about to start the discovery method
	// it returns a channel where the node will consume node addresses ("IP:NodeRaftPort") until the channel gets closed
	Start(nodeID string, nodePort int) (chan string, error)

	// Stop should stop the discovery method and all of its goroutines, it should close discovery channel returned in Start
	Stop()

	Search() (dest []string, err error)
}

Discovery gives the interface to perform automatic Node discovery

func NewKubernetesDiscovery

func NewKubernetesDiscovery(namespace, portName string, serviceLabels map[string]string) Discovery

func NewMdnsDiscovery

func NewMdnsDiscovery(serviceName string) Discovery

func NewStaticDiscovery

func NewStaticDiscovery(peers []string) Discovery