rpcClientService

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 RpcClientService
  • func GetRpcClientService() *RpcClientService
  • func (r *RpcClientService) Call(servicePath string, serviceMethod string, args interface{}, reply interface{}) error
  • func (r *RpcClientService) Go(servicePath string, serviceMethod string, args interface{}, reply interface{}, ...)
  • func (r *RpcClientService) Initialize(opts ...Option)
  • func (r *RpcClientService) 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 RpcClientService

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

func GetRpcClientService

func GetRpcClientService() *RpcClientService

func (*RpcClientService) Call

func (r *RpcClientService) Call(servicePath string, serviceMethod string, args interface{}, reply interface{}) error

func (*RpcClientService) Go

func (r *RpcClientService) Go(servicePath string, serviceMethod string, args interface{}, reply interface{}, chanRet chan *client.Call)

func (*RpcClientService) Initialize

func (r *RpcClientService) Initialize(opts ...Option)

func (*RpcClientService) SetRpcFilter

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

Set a filter for rpc