Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.