Documentation
¶
Index ¶
- func ConstructServiceEntryName(service string) string
- func ConvertServiceEntry(registryName string, instances []DubboServiceInstance) map[string]*v1alpha3.ServiceEntry
- func CopyMap(m map[string]string) map[string]string
- func NewNacosClisent(addr, namespace string) (naming_client.INamingClient, error)
- func SyncServices2IstioUntilMaxRetries(new *v1alpha3.ServiceEntry, registryName string, ic *istioclient.Clientset)
- type DubboServiceInstance
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConstructServiceEntryName ¶
ConstructServiceEntryName constructs the service entry name for a given dubbo service
func ConvertServiceEntry ¶
func ConvertServiceEntry(registryName string, instances []DubboServiceInstance) map[string]*v1alpha3.ServiceEntry
ConvertServiceEntry converts dubbo provider znode to a service entry
func NewNacosClisent ¶
func NewNacosClisent(addr, namespace string) (naming_client.INamingClient, error)
NewNacosClisent creates a Nacos client
func SyncServices2IstioUntilMaxRetries ¶
func SyncServices2IstioUntilMaxRetries(new *v1alpha3.ServiceEntry, registryName string, ic *istioclient.Clientset)
SyncServices2IstioUntilMaxRetries will try to synchronize service entries to the Istio until max retry number
Types ¶
type DubboServiceInstance ¶
type DubboServiceInstance struct {
IP string `json:"ip"`
Port uint32 `json:"port"`
Interface string `json:"interface"`
Namespace string `json:"namespace"`
Group string `json:"group"`
Metadata map[string]string `json:"metadata"`
}
DubboServiceInstance contains the information of a dubbo service instance
Source Files
Click to show internal directories.
Click to hide internal directories.