Documentation ¶
Index ¶
- Constants
- Variables
- 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 AsyncCallback
- type AsyncCallbackService
- type CallbackResponse
- type MethodType
- type Node
- type RPCService
- type RoleType
- type Service
- type URL
- func (c *URL) AddParam(key string, value string)
- func (c *URL) Clone() *URL
- func (c URL) Context() context.Context
- func (c *URL) EncodedServiceKey() 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) GetParam(s string, d string) string
- func (c URL) GetParamAndDecoded(key string) (string, error)
- func (c URL) GetParamBool(s string, d bool) bool
- func (c URL) GetParamInt(s string, d int64) int64
- func (c URL) GetParams() url.Values
- func (c URL) GetRawParam(key string) string
- func (c URL) Key() string
- func (c *URL) RangeParams(f func(key, value string) bool)
- func (c *URL) RemoveParams(set *gxset.HashSet)
- 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
Constants ¶
View Source
const ( CONSUMER = iota CONFIGURATOR ROUTER PROVIDER )
View Source
const METHOD_MAPPER = "MethodMapper"
for lowercase func
func MethodMapper() map[string][string] { return map[string][string]{} }
Variables ¶
View Source
var ( DubboNodes = [...]string{"consumers", "configurators", "routers", "providers"} DubboRole = [...]string{"consumer", "", "", "provider"} )
View Source
var ( // todo: lowerecas? ServiceMap = &serviceMap{ serviceMap: make(map[string]map[string]*Service), } )
Functions ¶
func WithLocation ¶ added in v1.2.0
func WithLocation(location string) option
func WithMethods ¶
func WithMethods(methods []string) option
func WithParams ¶
func WithParamsValue ¶
func WithParamsValue(key, val string) option
func WithPassword ¶
func WithPassword(pwd string) option
func WithProtocol ¶
func WithProtocol(proto string) option
func WithUsername ¶
func WithUsername(username string) option
Types ¶
type AsyncCallback ¶ added in v1.3.0
type AsyncCallback func(response CallbackResponse)
AsyncCallback async callback method
type AsyncCallbackService ¶ added in v1.3.0
type AsyncCallbackService interface {
CallBack(response CallbackResponse) // callback
}
AsyncCallbackService callback interface for async
type CallbackResponse ¶ added in v1.3.0
type CallbackResponse interface { }
CallbackResponse for different protocol
type MethodType ¶
type MethodType struct {
// contains filtered or unexported fields
}
func (*MethodType) ArgsType ¶
func (m *MethodType) ArgsType() []reflect.Type
func (*MethodType) CtxType ¶
func (m *MethodType) CtxType() reflect.Type
func (*MethodType) Method ¶
func (m *MethodType) Method() reflect.Method
func (*MethodType) ReplyType ¶
func (m *MethodType) ReplyType() reflect.Type
func (*MethodType) SuiteContext ¶
func (m *MethodType) SuiteContext(ctx context.Context) reflect.Value
type RPCService ¶
type RPCService interface {
Reference() string // rpc service id or reference id
}
rpc service interface
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func (*Service) Method ¶
func (s *Service) Method() map[string]*MethodType
type URL ¶
type URL struct { Path string // like /com.ikurento.dubbo.UserProvider3 Username string Password string Methods []string //special for registry SubURL *URL // contains filtered or unexported fields }
func NewURLWithOptions ¶
func NewURLWithOptions(opts ...option) *URL
func (*URL) EncodedServiceKey ¶ added in v1.2.0
func (URL) GetMethodParamBool ¶ added in v1.3.0
func (URL) GetMethodParamInt ¶
func (URL) GetMethodParamInt64 ¶
func (URL) GetRawParam ¶
func (*URL) RangeParams ¶ added in v1.2.0
func (*URL) RemoveParams ¶ added in v1.2.0
func (URL) ServiceKey ¶
Click to show internal directories.
Click to hide internal directories.