rpcx

Documentation

Overview

@Title @Description @Author Wangwengang 2021/8/19 下午4:58 @Update Wangwengang 2021/8/19 下午4:58

@Title @Description @Author Wangwengang 2021/8/19 下午5:22 @Update Wangwengang 2021/8/19 下午5:22

Index

• type RpcxClients
  • func (rc *RpcxClients) GetXClient(servicePath string) (xc client.XClient, err error)
  • func (rc *RpcxClients) NewXClient(servicePath string) (xc client.XClient, err error)
  • func (rc *RpcxClients) SetFailMode(mode client.FailMode)
  • func (rc *RpcxClients) SetOption(option client.Option)
  • func (rc *RpcxClients) SetSelectMode(selectMode client.SelectMode)
  • func (rc *RpcxClients) SetupServiceDiscovery()
• type RpcxServer
  • func (s *RpcxServer) RegisterName(name string, rcvr interface{}, metadata string)
  • func (s *RpcxServer) Serve()
• type Server
  • func NewRpcxServer() Server

Types

type RpcxClients

type RpcxClients struct {
	FailMode   client.FailMode
	SelectMode client.SelectMode
	Option     client.Option

	ServiceDiscovery client.ServiceDiscovery
	// contains filtered or unexported fields
}

var (
	RpcxClientsObj *RpcxClients
)

func (*RpcxClients) GetXClient

func (rc *RpcxClients) GetXClient(servicePath string) (xc client.XClient, err error)

func (*RpcxClients) NewXClient

func (rc *RpcxClients) NewXClient(servicePath string) (xc client.XClient, err error)

func (*RpcxClients) SetFailMode

func (rc *RpcxClients) SetFailMode(mode client.FailMode)

func (*RpcxClients) SetOption

func (rc *RpcxClients) SetOption(option client.Option)

func (*RpcxClients) SetSelectMode

func (rc *RpcxClients) SetSelectMode(selectMode client.SelectMode)

func (*RpcxClients) SetupServiceDiscovery

func (rc *RpcxClients) SetupServiceDiscovery()

type RpcxServer

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

func (*RpcxServer) RegisterName

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

func (*RpcxServer) Serve

func (s *RpcxServer) Serve()

type Server

type Server interface {
	RegisterName(name string, rcvr interface{}, metadata string)
	Serve()
}

func NewRpcxServer

func NewRpcxServer() Server