yql_stat_uploader.h 730 B

123456789101112131415161718192021222324252627282930313233343536373839
  1. #pragma once
  2. #include <library/cpp/threading/future/future.h>
  3. #include <util/generic/ptr.h>
  4. #include <util/generic/string.h>
  5. #include <util/generic/vector.h>
  6. namespace NYql {
  7. struct TStatUploadOptions {
  8. TString ProviderName;
  9. TString SessionId;
  10. ui32 PublicId;
  11. TString Cluster;
  12. TString Table;
  13. TString Scale;
  14. TVector<TString> ReplaceMask;
  15. TString YtServer;
  16. TString YtTable;
  17. TString YtTx;
  18. TString YtToken;
  19. TMaybe<TString> YtPool;
  20. };
  21. class IStatUploader : public TThrRefBase {
  22. public:
  23. using TPtr = TIntrusivePtr<IStatUploader>;
  24. virtual NThreading::TFuture<void> Upload(TStatUploadOptions&& options) = 0;
  25. virtual ~IStatUploader() = default;
  26. };
  27. } // namespace NYql