rpcx_request_plugin.go 260 B

123456789101112131415
  1. package micro
  2. import (
  3. "context"
  4. "fmt"
  5. "github.com/smallnest/rpcx/protocol"
  6. )
  7. type RpcxRequestPlugin struct {
  8. }
  9. func (plugin RpcxRequestPlugin) PostReadRequest(ctx context.Context, r *protocol.Message, e error) error {
  10. fmt.Println(111111)
  11. return nil
  12. }