Query API is used to query Timeplus streaming, expecially those streams of pulsebot for better observability
