code: func (as *AgentServer) Cleanup(ctx context.Context, cleanupRequest *pb.CleanupRequest) (*pb.CleanupResponse, error) {
  
  	log.Println("cleaning up", cleanupRequest.GetFlowHashCode())
  	dir := path.Join(*as.Option.Dir, fmt.Sprintf("%d", cleanupRequest.GetFlowHashCode()))
  	os.RemoveAll(dir)
  
  	return &pb.CleanupResponse{}, nil
  }
docs: // Cleanup remove all files related to a particular flow