xjrpc

Documentation

Index

• Variables
• type Client
  • func (this *Client) Call(basePath, servicePath string, args interface{}, reply interface{}) (err error)
  • func (this *Client) EtcdList(key string) []string
  • func (this *Client) GetAddress(basePath string) string
  • func (this *Client) GetAddress2(basePath string) string
• type EtcdRegister
• type Server
  • func NewServer() *Server
  • func (s *Server) EtcdRegister(etcdRegister EtcdRegister)
  • func (s *Server) RegisterName(name string, rcvr interface{}, metadata string) error
  • func (s *Server) Serve(network, address string) (err error)

Variables

var (
	EtcdServers []string
)

Types

type Client

type Client struct {
	EtcdEndpoints []string
}

func (*Client) Call

func (this *Client) Call(basePath, servicePath string, args interface{}, reply interface{}) (err error)

func (*Client) EtcdList

func (this *Client) EtcdList(key string) []string

func (*Client) GetAddress

func (this *Client) GetAddress(basePath string) string

func (*Client) GetAddress2

func (this *Client) GetAddress2(basePath string) string

type EtcdRegister

type EtcdRegister struct {
	// service address, for example, tcp@127.0.0.1:8972, quic@127.0.0.1:1234
	ServiceAddress string
	// etcd addresses
	EtcdServers []string
	// base path for rpcx server, for example com/example/rpcx
	BasePath string
	Metrics  metrics.Registry
	// Registered services
	Services []string

	UpdateInterval time.Duration
	LeaseTime      int
	ServiceReg     *xjregister.ServiceReg
	RpcAddress     string

	Options *store.Config
	// contains filtered or unexported fields
}

type Server

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

func NewServer

func NewServer() *Server

func (*Server) EtcdRegister

func (s *Server) EtcdRegister(etcdRegister EtcdRegister)

func (*Server) RegisterName

func (s *Server) RegisterName(name string, rcvr interface{}, metadata string) error

func (*Server) Serve

func (s *Server) Serve(network, address string) (err error)