proxy

Documentation

Index

• type Option
  • func BasePath(s string) Option
  • func RegistryAddr(s string) Option
  • func RegistryType(s string) Option
  • func SelectMode(s string) Option
• type Options
• type Proxy
  • func NewProxy(opts ...Option) *Proxy
  • func (r *Proxy) Call(nodeName string, servicePath string, serviceMethod string, ...) error
  • func (r *Proxy) Go(nodeName string, servicePath string, serviceMethod string, ...)
  • func (r *Proxy) OnDestroy()
  • func (r *Proxy) OnInit(s component.ServerImpl)
  • func (r *Proxy) OnRun(closeSig chan bool)
  • func (r *Proxy) Register(rcvr interface{})
  • func (r *Proxy) SetRpcFilter(f filter.Filter)

Types

type Option

type Option func(*Options)

func BasePath

func BasePath(s string) Option

Base path of service

func RegistryAddr

func RegistryAddr(s string) Option

Address of register service

func RegistryType

func RegistryType(s string) Option

Register service type. option is consul, etcd, etcdv3, zookeeper.

func SelectMode

func SelectMode(s string) Option

Select mode of service. options is "RandomSelect","RoundRobin","WeightedRoundRobin", "WeightedICMP","ConsistentHash","Closest".

type Options

type Options struct {
	RegistryType string
	RegistryAddr string
	BasePath     string
	SelectMode   string
}

type Proxy

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

It is deprecated. Use RpcClientService instead

func NewProxy

func NewProxy(opts ...Option) *Proxy

func (*Proxy) Call

func (r *Proxy) Call(nodeName string, servicePath string, serviceMethod string, session protocol.ISession, args *rpc.Args, reply interface{}) error

func (*Proxy) Go

func (r *Proxy) Go(nodeName string, servicePath string, serviceMethod string, session protocol.ISession, args *rpc.Args, reply interface{}, chanRet chan *client.Call)

func (*Proxy) OnDestroy

func (r *Proxy) OnDestroy()

func (*Proxy) OnInit

func (r *Proxy) OnInit(s component.ServerImpl)

func (*Proxy) OnRun

func (r *Proxy) OnRun(closeSig chan bool)

func (*Proxy) Register

func (r *Proxy) Register(rcvr interface{})

func (*Proxy) SetRpcFilter

func (r *Proxy) SetRpcFilter(f filter.Filter)

Set a filter for rpc