Versions in this module Expand all Collapse all v1 v1.0.7 Apr 28, 2022 v1.0.6 Apr 11, 2022 v1.0.5 Mar 31, 2022 v1.0.4 Mar 29, 2022 Changes in this version + const CONFIGURATOR + const CONSUMER + const METHOD_MAPPER + const PROTOCOL + const PROVIDER + const ROUTER + var DubboNodes = [...]string + var DubboRole = [...]string + var IncludeKeys = gxset.NewSet(constant.ApplicationKey, constant.GroupKey, constant.TimestampKey, ...) + var ServiceMap = &serviceMap + func GetLocalIp() string + func GetReference(service RPCService) string + func IsEquals(left *URL, right *URL, excludes ...string) bool + func MatchKey(serviceKey string, protocol string) string + func ServiceKey(intf string, group string, version string) string + func SetCompareURLEqualFunc(f CompareURLEqualFunc) + type AsyncCallback func(response CallbackResponse) + type AsyncCallbackService interface + CallBack func(response CallbackResponse) + type CallbackResponse interface + type CompareURLEqualFunc func(l *URL, r *URL, excludeParam ...string) bool + func GetCompareURLEqualFunc() CompareURLEqualFunc + type MetadataInfo struct + App string + Reported bool + Revision string + Services map[string]*ServiceInfo + func NewMetadataInfWithApp(app string) *MetadataInfo + func NewMetadataInfo(app string, revision string, services map[string]*ServiceInfo) *MetadataInfo + func (mi *MetadataInfo) AddService(service *ServiceInfo) + func (mi *MetadataInfo) CalAndGetRevision() string + func (mi *MetadataInfo) HasReported() bool + func (mi *MetadataInfo) JavaClassName() string + func (mi *MetadataInfo) MarkReported() + func (mi *MetadataInfo) RemoveService(service *ServiceInfo) + type MethodType struct + func (m *MethodType) ArgsType() []reflect.Type + func (m *MethodType) CtxType() reflect.Type + func (m *MethodType) Method() reflect.Method + func (m *MethodType) ReplyType() reflect.Type + func (m *MethodType) SuiteContext(ctx context.Context) reflect.Value + type Node interface + Destroy func() + GetURL func() *URL + IsAvailable func() bool + type Option func(*URL) + func WithIp(ip string) Option + func WithLocation(location string) Option + func WithMethods(methods []string) Option + func WithParams(params url.Values) Option + func WithParamsValue(key, val string) Option + func WithPassword(pwd string) Option + func WithPath(path string) Option + func WithPort(port string) Option + func WithProtocol(proto string) Option + func WithToken(token string) Option + func WithUsername(username string) Option + type RPCService = interface + type ReferencedRPCService interface + Reference func() string + type RoleType int + func (t RoleType) Role() string + func (t RoleType) String() string + type Service struct + func (s *Service) Method() map[string]*MethodType + func (s *Service) Name() string + func (s *Service) Rcvr() reflect.Value + func (s *Service) RcvrType() reflect.Type + type ServiceInfo struct + Group string + MatchKey string + Name string + Params map[string]string + Path string + Protocol string + ServiceKey string + URL *URL + Version string + func NewServiceInfo(name, group, version, protocol, path string, params map[string]string) *ServiceInfo + func NewServiceInfoWithURL(url *URL) *ServiceInfo + func (si *ServiceInfo) GetMatchKey() string + func (si *ServiceInfo) GetMethods() []string + func (si *ServiceInfo) GetParams() url.Values + func (si *ServiceInfo) GetServiceKey() string + func (si *ServiceInfo) JavaClassName() string + type TriplePBService interface + XXX_InterfaceName func() string + type URL struct + Methods []string + Password string + Path string + SubURL *URL + Username string + func MergeURL(serviceURL *URL, referenceURL *URL) *URL + func NewURL(urlString string, opts ...Option) (*URL, error) + func NewURLWithOptions(opts ...Option) *URL + func (c *URL) AddParam(key string, value string) + func (c *URL) AddParamAvoidNil(key string, value string) + func (c *URL) Clone() *URL + func (c *URL) CloneExceptParams(excludeParams *gxset.HashSet) *URL + func (c *URL) CloneWithParams(reserveParams []string) *URL + func (c *URL) ColonSeparatedKey() string + func (c *URL) Compare(comp cm.Comparator) int + func (c *URL) DelParam(key string) + func (c *URL) EncodedServiceKey() string + func (c *URL) GetCacheInvokerMapKey() string + func (c *URL) GetMethodParam(method string, key string, d string) string + func (c *URL) GetMethodParamBool(method string, key string, d bool) bool + func (c *URL) GetMethodParamInt(method string, key string, d int64) int64 + func (c *URL) GetMethodParamInt64(method string, key string, d int64) int64 + func (c *URL) GetMethodParamIntValue(method string, key string, d int) int + func (c *URL) GetParam(s string, d string) string + func (c *URL) GetParamAndDecoded(key string) (string, error) + func (c *URL) GetParamBool(key string, d bool) bool + func (c *URL) GetParamByIntValue(key string, d int) int + func (c *URL) GetParamDuration(s string, d string) time.Duration + func (c *URL) GetParamInt(key string, d int64) int64 + func (c *URL) GetParamInt32(key string, d int32) int32 + func (c *URL) GetParams() url.Values + func (c *URL) GetRawParam(key string) string + func (c *URL) Group() string + func (c *URL) JavaClassName() string + func (c *URL) Key() string + func (c *URL) RangeParams(f func(key, value string) bool) + func (c *URL) ReplaceParams(param url.Values) + func (c *URL) Service() string + func (c *URL) ServiceKey() string + func (c *URL) SetParam(key string, value string) + func (c *URL) SetParams(m url.Values) + func (c *URL) String() string + func (c *URL) ToMap() map[string]string + func (c *URL) URLEqual(url *URL) bool + func (c *URL) Version() string + type URLSlice []*URL + func (s URLSlice) Len() int + func (s URLSlice) Less(i, j int) bool + func (s URLSlice) Swap(i, j int)