zk

Documentation

Index

• type ProviderWatcher
  • func NewProviderWatcher(ic *istioclient.Clientset, conn *zk.Conn, service string, registryName string) *ProviderWatcher
  • func (w *ProviderWatcher) Run(stop <-chan struct{})
• type ServiceWatcher
  • func NewServiceWatcher(conn *zk.Conn, clientset *istioclient.Clientset, registryName string) *ServiceWatcher
  • func (w *ServiceWatcher) Run(stop <-chan struct{})

Types

type ProviderWatcher

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

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

func NewProviderWatcher

func NewProviderWatcher(ic *istioclient.Clientset, conn *zk.Conn, service string, registryName string) *ProviderWatcher

NewProviderWatcher 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 channel This method blocks the caller

type ServiceWatcher

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

ServiceWatcher watches for newly created dubbo services and creates a providerWatcher for each service

func NewServiceWatcher

func NewServiceWatcher(conn *zk.Conn, clientset *istioclient.Clientset, registryName string) *ServiceWatcher

NewServiceWatcher 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 channel. This method blocks the caller