[feature] pubsub framework for scalability protocol