mapping

Documentation

Index

• func GetDubboGoMetadata(dubboGoMetadata string) *structpb.Struct
• type ADSZClient
• type ADSZResponse
  • func (a *ADSZResponse) GetMap() map[string]string
• type InterfaceMapHandler
  • func NewInterfaceMapHandlerImpl(xdsClient client.XDSClient, istioTokenPath string, ...) InterfaceMapHandler
• type InterfaceMapHandlerImpl
  • func (i *InterfaceMapHandlerImpl) GetDubboGoMetadata() (map[string]string, error)
  • func (i *InterfaceMapHandlerImpl) GetHostAddrMap(serviceUniqueKey string) (string, error)
  • func (i *InterfaceMapHandlerImpl) Register(serviceUniqueKey string) error
  • func (i *InterfaceMapHandlerImpl) UnRegister(serviceUniqueKey string) error

Functions

func GetDubboGoMetadata

func GetDubboGoMetadata(dubboGoMetadata string) *structpb.Struct

GetDubboGoMetadata create metadata of dubbo-go-app and register to istiod

Types

type ADSZClient

type ADSZClient struct {
	Metadata map[string]interface{} `json:"metadata"`
}

type ADSZResponse

type ADSZResponse struct {
	Clients []ADSZClient `json:"clients"`
}

ADSZResponse is body got from istiod:8080/debug/adsz

func (*ADSZResponse) GetMap

func (a *ADSZResponse) GetMap() map[string]string

type InterfaceMapHandler

type InterfaceMapHandler interface {
	Register(string) error
	UnRegister(string) error
	GetHostAddrMap(string) (string, error)
	GetDubboGoMetadata() (map[string]string, error)
}

func NewInterfaceMapHandlerImpl

func NewInterfaceMapHandlerImpl(xdsClient client.XDSClient, istioTokenPath string, istioDebugAddr, hostAddr common.HostAddr, localDebugMode bool) InterfaceMapHandler

type InterfaceMapHandlerImpl

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

func (*InterfaceMapHandlerImpl) GetDubboGoMetadata

func (i *InterfaceMapHandlerImpl) GetDubboGoMetadata() (map[string]string, error)

func (*InterfaceMapHandlerImpl) GetHostAddrMap

func (i *InterfaceMapHandlerImpl) GetHostAddrMap(serviceUniqueKey string) (string, error)

func (*InterfaceMapHandlerImpl) Register

func (i *InterfaceMapHandlerImpl) Register(serviceUniqueKey string) error

func (*InterfaceMapHandlerImpl) UnRegister

func (i *InterfaceMapHandlerImpl) UnRegister(serviceUniqueKey string) error