• 插件开发
    • Server Plugin
    • Client Plugin

    插件开发

    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.