servicediscovery

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

type EndpointsWithExtraInfo struct {
	Address string
	Zone    string
}

type IServiceDiscoveryAgent interface {
	//RegisterService will register the service given the name, ip and port
	//It returns the ID of the service
	RegisterService(name, ipAddress, port, healthCheckPort string, checkFunction func() (bool, error), isDockerType bool, tags []string, metadata map[string]string) (string, error)
	//DeregisterService will deregister the service given the ID
	DeregisterService(serviceID string)
	//GetHealthyService will give a list of all the instances of the module
	GetHealthyService(moduleName string, k8sNamespace string) ([]string, error)
	//GetHealthyServiceWithZoneInfo will give a list of all the instances of the module along with other infor like zones for all the pods
	GetHealthyServiceWithZoneInfo(moduleName string, k8sNamespace string) ([]EndpointsWithExtraInfo, error)
}

type K8SOptions func(k *k8sClient)

type Options func(c *ConsulAgent)