dubbo

Documentation

Index

• Constants
• Variables
• func InitDefaultDubboClient(dpc *DubboProxyConfig)
• type Client
  • func NewDubboClient() *Client
  • func SingletonDubboClient() *Client
  • func (dc *Client) Apply() error
  • func (dc *Client) Call(req *client.Request) (res interface{}, err error)
  • func (dc *Client) Close() error
  • func (dc *Client) Get(ir fc.IntegrationRequest) *generic.GenericService
  • func (dc *Client) MapParams(req *client.Request) (interface{}, error)
  • func (dc *Client) SetConfig(dpc *DubboProxyConfig)
• type DubboProxyConfig

Constants

const (
	JavaStringClassName = "java.lang.String"
	JavaLangClassName   = "java.lang.Long"
)

TODO java class name elem

Variables

var DefaultMapOption = client.MapOption{
	// contains filtered or unexported fields
}

DefaultMapOption default map opt

Functions

func InitDefaultDubboClient

func InitDefaultDubboClient(dpc *DubboProxyConfig)

InitDefaultDubboClient init default dubbo client

Types

type Client

type Client struct {
	GenericServicePool map[string]*generic.GenericService
	// contains filtered or unexported fields
}

Client client to generic invoke dubbo

func NewDubboClient

func NewDubboClient() *Client

NewDubboClient create dubbo client

func SingletonDubboClient

func SingletonDubboClient() *Client

SingletonDubboClient singleton dubbo clent

func (*Client) Apply

func (dc *Client) Apply() error

Apply init dubbo, config mapping can do here

func (*Client) Call

func (dc *Client) Call(req *client.Request) (res interface{}, err error)

Call invoke service

func (*Client) Close

func (dc *Client) Close() error

Close clear GenericServicePool.

func (*Client) Get

func (dc *Client) Get(ir fc.IntegrationRequest) *generic.GenericService

Get find a dubbo GenericService

func (*Client) MapParams

func (dc *Client) MapParams(req *client.Request) (interface{}, error)

MapParams params mapping to api.

func (*Client) SetConfig

func (dc *Client) SetConfig(dpc *DubboProxyConfig)

SetConfig set config

type DubboProxyConfig

type DubboProxyConfig struct {
	// Registries such as zk,nacos or etcd
	Registries map[string]model.Registry `yaml:"registries" json:"registries"`
	// Timeout
	Timeout *model.TimeoutConfig `yaml:"timeout_config" json:"timeout_config"`
	// IsDefaultMap whether to use DefaultMap role
	IsDefaultMap bool
	// AutoResolve whether to resolve api config from request
	AutoResolve bool `yaml:"auto_resolve" json:"auto_resolve,omitempty"`
	// Protoset path to load protoset files
	Protoset []string `yaml:"protoset" json:"protoset,omitempty"`
	// Load balance
	LoadBalance string `yaml:"load_balance"  json:"load_balance,omitempty"`
	// Retries number of retries
	Retries string `yaml:"retries" json:"retries,omitempty"`
}

DubboProxyConfig the config for dubbo proxy