common

package

v1.4.0-rc8 Latest Latest Go to latest Published: Apr 9, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/mosn/dubbo-go

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
- 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
type RPCService
type RoleType
- func (t RoleType) Role() string
- func (t RoleType) String() string
type Service
- func (s *Service) Method() map[string]*MethodType
- func (s *Service) Rcvr() reflect.Value
- func (s *Service) RcvrType() reflect.Type
type URL
- 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) Clone() *URL
- func (c *URL) ColonSeparatedKey() string
- 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 ...
	CONSUMER = iota
	// CONFIGURATOR ...
	CONFIGURATOR
	// ROUTER ...
	ROUTER
	// PROVIDER ...
	PROVIDER
)

role constant

View Source

const (
	// METHOD_MAPPER ...
	METHOD_MAPPER = "MethodMapper"
)

for lowercase func

func MethodMapper() map[string][string] {
    return map[string][string]{}
}

Variables ¶

View Source

var (
	// DubboNodes ...
	DubboNodes = [...]string{"consumers", "configurators", "routers", "providers"}
	// DubboRole Dubbo service role
	DubboRole = [...]string{"consumer", "", "routers", "provider"}
)

View Source

var (

	// ServiceMap ...
	// todo: lowerecas?
	ServiceMap = &serviceMap{
		serviceMap: make(map[string]map[string]*Service),
	}
)

Functions ¶

func WithIp ¶

func WithIp(ip string) option

WithIp ...

func WithLocation ¶

func WithLocation(location string) option

WithLocation ...

func WithMethods ¶

func WithMethods(methods []string) option

WithMethods ...

func WithParams ¶

func WithParams(params url.Values) option

WithParams ...

func WithParamsValue ¶

func WithParamsValue(key, val string) option

WithParamsValue ...

func WithPassword ¶

func WithPassword(pwd string) option

WithPassword ...

func WithPath ¶

func WithPath(path string) option

WithPath ...

func WithPort ¶

func WithPort(port string) option

WithPort ...

func WithProtocol ¶

func WithProtocol(proto string) option

WithProtocol ...

func WithToken ¶

func WithToken(token string) option

WithToken ...

func WithUsername ¶

func WithUsername(username string) option

WithUsername ...

Types ¶

type AsyncCallback ¶

type AsyncCallback func(response CallbackResponse)

AsyncCallback async callback method

type AsyncCallbackService ¶

type AsyncCallbackService interface {
	// Callback: callback
	CallBack(response CallbackResponse)
}

AsyncCallbackService callback interface for async

type CallbackResponse ¶

type CallbackResponse interface{}

CallbackResponse for different protocol

type MethodType ¶

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

MethodType ...

func (*MethodType) ArgsType ¶

func (m *MethodType) ArgsType() []reflect.Type

ArgsType ...

func (*MethodType) CtxType ¶

func (m *MethodType) CtxType() reflect.Type

CtxType ...

func (*MethodType) Method ¶

func (m *MethodType) Method() reflect.Method

Method ...

func (*MethodType) ReplyType ¶

func (m *MethodType) ReplyType() reflect.Type

ReplyType ...

func (*MethodType) SuiteContext ¶

func (m *MethodType) SuiteContext(ctx context.Context) reflect.Value

SuiteContext ...

type Node ¶

type Node interface {
	GetUrl() URL
	IsAvailable() bool
	Destroy()
}

Node ...

type RPCService ¶

type RPCService interface {
	// Reference:
	// rpc service id or reference id
	Reference() string
}

RPCService rpc service interface

type RoleType ¶

type RoleType int

RoleType ...

func (RoleType) Role ¶

func (t RoleType) Role() string

Role ...

func (RoleType) String ¶

func (t RoleType) String() string

type Service ¶

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

Service ...

func (*Service) Method ¶

func (s *Service) Method() map[string]*MethodType

Method ...

func (*Service) Rcvr ¶

func (s *Service) Rcvr() reflect.Value

Rcvr ...

func (*Service) RcvrType ¶

func (s *Service) RcvrType() reflect.Type

RcvrType ...

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
}

URL ...

func MergeUrl ¶

func MergeUrl(serviceUrl *URL, referenceUrl *URL) *URL

MergeUrl ...

func NewURL ¶

func NewURL(urlString string, opts ...option) (URL, error)

NewURL will create a new url the urlString should not be empty

func NewURLWithOptions ¶

func NewURLWithOptions(opts ...option) *URL

NewURLWithOptions ...

func (*URL) AddParam ¶

func (c *URL) AddParam(key string, value string)

AddParam ...

func (*URL) Clone ¶

func (c *URL) Clone() *URL

Clone ...

func (*URL) ColonSeparatedKey ¶

func (c *URL) ColonSeparatedKey() string

ColonSeparatedKey The format is "{interface}:[version]:[group]"

func (*URL) EncodedServiceKey ¶

func (c *URL) EncodedServiceKey() string

EncodedServiceKey ...

func (URL) GetMethodParam ¶

func (c URL) GetMethodParam(method string, key string, d string) string

GetMethodParam ...

func (URL) GetMethodParamBool ¶

func (c URL) GetMethodParamBool(method string, key string, d bool) bool

GetMethodParamBool ...

func (URL) GetMethodParamInt ¶

func (c URL) GetMethodParamInt(method string, key string, d int64) int64

GetMethodParamInt ...

func (URL) GetMethodParamInt64 ¶

func (c URL) GetMethodParamInt64(method string, key string, d int64) int64

GetMethodParamInt64 ...

func (URL) GetParam ¶

func (c URL) GetParam(s string, d string) string

GetParam ...

func (URL) GetParamAndDecoded ¶

func (c URL) GetParamAndDecoded(key string) (string, error)

GetParamAndDecoded ...

func (URL) GetParamBool ¶

func (c URL) GetParamBool(s string, d bool) bool

GetParamBool ...

func (URL) GetParamInt ¶

func (c URL) GetParamInt(s string, d int64) int64

GetParamInt ...

func (URL) GetParams ¶

func (c URL) GetParams() url.Values

GetParams ...

func (URL) GetRawParam ¶

func (c URL) GetRawParam(key string) string

GetRawParam ...

func (URL) Key ¶

func (c URL) Key() string

Key ...

func (*URL) RangeParams ¶

func (c *URL) RangeParams(f func(key, value string) bool)

RangeParams ...

func (*URL) RemoveParams ¶

func (c *URL) RemoveParams(set *gxset.HashSet)

RemoveParams ...

func (URL) Service ¶

func (c URL) Service() string

Service ...

func (URL) ServiceKey ¶

func (c URL) ServiceKey() string

ServiceKey ...

func (*URL) SetParam ¶

func (c *URL) SetParam(key string, value string)

SetParam ...

func (*URL) SetParams ¶

func (c *URL) SetParams(m url.Values)

SetParams ...

func (URL) String ¶

func (c URL) String() string

func (URL) ToMap ¶

func (c URL) ToMap() map[string]string

ToMap transfer URL to Map

func (URL) URLEqual ¶

func (c URL) URLEqual(url URL) bool

URLEqual ...

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
config
constant
extension
logger
proxy
proxy_factory
yaml

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL