#pragma once #include #include #include #include #include namespace DB { class ASTStorage; struct NATSSettingsImpl; /// List of available types supported in NATSSettings object #define NATS_SETTINGS_SUPPORTED_TYPES(CLASS_NAME, M) \ M(CLASS_NAME, ArrowCompression) \ M(CLASS_NAME, Bool) \ M(CLASS_NAME, CapnProtoEnumComparingMode) \ M(CLASS_NAME, Char) \ M(CLASS_NAME, DateTimeInputFormat) \ M(CLASS_NAME, DateTimeOutputFormat) \ M(CLASS_NAME, DateTimeOverflowBehavior) \ M(CLASS_NAME, Double) \ M(CLASS_NAME, EscapingRule) \ M(CLASS_NAME, Float) \ M(CLASS_NAME, IdentifierQuotingRule) \ M(CLASS_NAME, IdentifierQuotingStyle) \ M(CLASS_NAME, Int64) \ M(CLASS_NAME, IntervalOutputFormat) \ M(CLASS_NAME, MsgPackUUIDRepresentation) \ M(CLASS_NAME, Milliseconds) \ M(CLASS_NAME, ORCCompression) \ M(CLASS_NAME, ParquetCompression) \ M(CLASS_NAME, ParquetVersion) \ M(CLASS_NAME, SchemaInferenceMode) \ M(CLASS_NAME, StreamingHandleErrorMode) \ M(CLASS_NAME, String) \ M(CLASS_NAME, UInt64) \ M(CLASS_NAME, UInt64Auto) \ M(CLASS_NAME, URI) NATS_SETTINGS_SUPPORTED_TYPES(NATSSettings, DECLARE_SETTING_TRAIT) struct NATSSettings { NATSSettings(); NATSSettings(const NATSSettings & settings); NATSSettings(NATSSettings && settings) noexcept; ~NATSSettings(); NATS_SETTINGS_SUPPORTED_TYPES(NATSSettings, DECLARE_SETTING_SUBSCRIPT_OPERATOR) void loadFromQuery(ASTStorage & storage_def); void loadFromNamedCollection(const MutableNamedCollectionPtr & named_collection); SettingsChanges getFormatSettings() const; private: std::unique_ptr impl; }; }