common

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

Functions

func ConstructServiceEntryName

func ConstructServiceEntryName(service string) string

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 CopyMap

func CopyMap(m map[string]string) map[string]string

CopyMap deep copy a map

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