rpc

README

XuperOS RPC服务

新一代更易用、更简洁的RPC接口和命令行工具还在研发中，欢迎大家提issue讨论或者贡献。

XuperOS目前只提供了xuper3的适配RPC接口，完全适配xuper3。

Documentation

Index

• type RpcServ
  • func NewRpcServ(engine ecom.Engine, log logs.Logger) *RpcServ
  • func (t *RpcServ) CheckAlive(gctx context.Context, req *pb.BaseReq) (*pb.BaseResp, error)
  • func (t *RpcServ) UnaryInterceptor() grpc.UnaryServerInterceptor
• type RpcServMG
  • func NewRpcServMG(scfg *sconf.ServConf, engine engines.BCEngine) (*RpcServMG, error)
  • func (t *RpcServMG) Exit()
  • func (t *RpcServMG) Run() error

Types

type RpcServ

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

func NewRpcServ

func NewRpcServ(engine ecom.Engine, log logs.Logger) *RpcServ

func (*RpcServ) CheckAlive

func (t *RpcServ) CheckAlive(gctx context.Context, req *pb.BaseReq) (*pb.BaseResp, error)

示例接口

func (*RpcServ) UnaryInterceptor

func (t *RpcServ) UnaryInterceptor() grpc.UnaryServerInterceptor

UnaryInterceptor provides a hook to intercept the execution of a unary RPC on the server.

type RpcServMG

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

rpc server启停控制管理

func NewRpcServMG

func NewRpcServMG(scfg *sconf.ServConf, engine engines.BCEngine) (*RpcServMG, error)

func (*RpcServMG) Exit

func (t *RpcServMG) Exit()

退出rpc服务，释放相关资源，需要幂等

func (*RpcServMG) Run

func (t *RpcServMG) Run() error

启动rpc服务