#include "components/enterprise/browser/reporting/real_time_uploader.h"
#include <queue>
#include "base/memory/ptr_util.h"
#include "base/metrics/histogram_functions.h"
#include "base/task/bind_post_task.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "build/build_config.h"
#include "components/prefs/pref_service.h"
namespace enterprise_reporting {
std::unique_ptr<RealTimeUploader> RealTimeUploader::Create(
const std::string& dm_token,
reporting::Destination destination,
reporting::Priority priority) { … }
RealTimeUploader::RealTimeUploader(reporting::Priority priority)
: … { … }
RealTimeUploader::~RealTimeUploader() = default;
void RealTimeUploader::Upload(
std::unique_ptr<google::protobuf::MessageLite> report,
EnqueueCallback callback) { … }
reporting::ReportQueue* RealTimeUploader::GetReportQueue() const { … }
void RealTimeUploader::CreateReportQueue(const std::string& dm_token,
reporting::Destination destination) { … }
void RealTimeUploader::OnReportEnqueued(EnqueueCallback callback,
reporting::Status status) { … }
}