eureka

Documentation

Index

• type ProviderWatcher
  • func NewProviderWatcher(ic *istioclient.Clientset, conn *eureka.Client, ekName string) *ProviderWatcher
  • func (w *ProviderWatcher) Run(stop <-chan struct{})
• type ServiceWatcher
  • func NewServiceWatcher(conn *eureka.Client, clientset *istioclient.Clientset, eurekaName string) *ServiceWatcher
  • func (w *ServiceWatcher) Run(stop <-chan struct{})

Types

type ProviderWatcher

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

ProviderWatcher watches changes on spring cloud eureka service providers and synchronize the changed spring cloud eureka providers to the Istio control plane via service entries

func NewProviderWatcher

func NewProviderWatcher(ic *istioclient.Clientset, conn *eureka.Client, ekName string) *ProviderWatcher

NewWatcher creates a ProviderWatcher

func (*ProviderWatcher) Run

func (w *ProviderWatcher) Run(stop <-chan struct{})

Run starts the ProviderWatcher until it receives a message over the stop chanel This method blocks the caller

type ServiceWatcher

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

ServiceWatcher watches for newly created spring cloud eureka services and creates a providerWatcher for each service

func NewServiceWatcher

func NewServiceWatcher(conn *eureka.Client, clientset *istioclient.Clientset, eurekaName string) *ServiceWatcher

NewWatcher creates a ServiceWatcher

func (*ServiceWatcher) Run

func (w *ServiceWatcher) Run(stop <-chan struct{})

Run starts the ServiceWatcher until it receives a message over the stop chanel This method blocks the caller