BrokerStats.java 文件源码

@GET
@Path("/destinations")
@ApiOperation(value = "Get all the destination stats by namesapce", response = OutputStream.class, responseContainer = "OutputStream") // https://github.com/swagger-api/swagger-ui/issues/558
                                                                                                                                       // map
                                                                                                                                       // support
                                                                                                                                       // missing
@ApiResponses(value = { @ApiResponse(code = 403, message = "Don't have admin permission") })
public StreamingOutput getDestinations2() throws Exception {
    // Ensure super user access only
    validateSuperUserAccess();
    return output -> pulsar().getBrokerService().getDimensionMetrics(statsBuf -> {
        try {
            output.write(statsBuf.array(), statsBuf.arrayOffset(), statsBuf.readableBytes());
        } catch (Exception e) {
            throw new WebApplicationException(e);
        }
    });
}