discovery

Documentation

Index

• func NewKubeClient(kubeConfigPath string) *kubernetes.Clientset
• type KubeDiscoveryService
  • func NewKubeDiscoveryService(kubeClient kubernetes.Interface, ...) *KubeDiscoveryService
  • func (d *KubeDiscoveryService) GetClusterHealthcheckConfig()
  • func (d *KubeDiscoveryService) ReloadServiceConfigs(reloadQueue chan uuid.UUID, mgoRepo *db.MongoRepository)
  • func (d *KubeDiscoveryService) UpdateDeployments()
  • func (d *KubeDiscoveryService) WatchDeployments(namespaces []string)

Functions

func NewKubeClient

func NewKubeClient(kubeConfigPath string) *kubernetes.Clientset

NewKubeClient returns a KubeClient for in cluster or out of cluster operation depending on whether or not a kubeconfig file path is provided

Types

type KubeDiscoveryService

type KubeDiscoveryService struct {
	K8sClient      kubernetes.Interface
	K8sWatchEvents chan model.UpdateItem
	Namespaces     chan model.Namespace
	Services       chan model.Service
	ServicesState  map[model.ServicesStateKey]model.Service
	UpdatesQueue   chan model.UpdateItem
	Errors         chan error
}

KubeDiscoveryService is responsible for Kubernetes Namespace, Service and Deployment discovery

func NewKubeDiscoveryService

func NewKubeDiscoveryService(kubeClient kubernetes.Interface, state map[model.ServicesStateKey]model.Service, updatesQueue chan model.UpdateItem, errs chan error) *KubeDiscoveryService

NewKubeDiscoveryService created a new

func (*KubeDiscoveryService) GetClusterHealthcheckConfig

func (d *KubeDiscoveryService) GetClusterHealthcheckConfig()

GetClusterHealthcheckConfig method retrieves Namespace and Service annotations specific to health aggregator

func (*KubeDiscoveryService) ReloadServiceConfigs

func (d *KubeDiscoveryService) ReloadServiceConfigs(reloadQueue chan uuid.UUID, mgoRepo *db.MongoRepository)

ReloadServiceConfigs gets the latest Namespace and Service configs from k8s and persists them

func (*KubeDiscoveryService) UpdateDeployments

func (d *KubeDiscoveryService) UpdateDeployments()

UpdateDeployments processes model.UpdateItem before adding them to the UpdatesQueue

func (*KubeDiscoveryService) WatchDeployments

func (d *KubeDiscoveryService) WatchDeployments(namespaces []string)

WatchDeployments sets up Kubernetes API watchers which listen for changes to objects within a list of provided namespaces