插件开发

rpcx为服务器和客户端定义了几个插件接口，在一些处理点上可以调用插件。

Server Plugin

示例: trace

go doc

  1. type PostConnAcceptPlugin
  3. type PostConnAcceptPlugin interface {
  4.     HandleConnAccept(net.Conn) (net.Conn, bool)
  5. }
  8. type PostReadRequestPlugin
  10. type PostReadRequestPlugin interface {
  11.     PostReadRequest(ctx context.Context, r *protocol.Message, e error) error
  12. }
  14. PostReadRequestPlugin represents .
  15. type PostWriteResponsePlugin
  17. type PostWriteResponsePlugin interface {
  18.     PostWriteResponse(context.Context, *protocol.Message, *protocol.Message, error) error
  19. }
  21. PostWriteResponsePlugin represents .
  22. type PreReadRequestPlugin
  24. type PreReadRequestPlugin interface {
  25.     PreReadRequest(ctx context.Context) error
  26. }
  28. PreReadRequestPlugin represents .
  29. type PreWriteResponsePlugin
  31. type PreWriteResponsePlugin interface {
  32.     PreWriteResponse(context.Context, *protocol.Message) error
  33. }
  35. PreWriteResponsePlugin represents .

Client Plugin

go doc

  1. type PluginContainer
  3. type PluginContainer interface {
  4.     Add(plugin Plugin)
  5.     Remove(plugin Plugin)
  6.     All() []Plugin
  8.     DoPreCall(ctx context.Context, servicePath, serviceMethod string, args interface{}) error
  9.     DoPostCall(ctx context.Context, servicePath, serviceMethod string, args interface{}, reply interface{}, err error) error
  10. }
  12. type PostCallPlugin
  14. type PostCallPlugin interface {
  15.     DoPostCall(ctx context.Context, servicePath, serviceMethod string, args interface{}, reply interface{}, err error) error
  16. }
  18. PostCallPlugin is invoked after the client calls a server.
  19. type PreCallPlugin
  21. type PreCallPlugin interface {
  22.     DoPreCall(ctx context.Context, servicePath, serviceMethod string, args interface{}) error
  23. }
  25. PreCallPlugin is invoked before the client calls a server.