gcms

GcmsParserBase

 - bool _has_default{false}; - std::string _gcms_name; - DynamicStruct::Schema* _schema{nullptr};

virtual int32_t init(...);virtual int32_t parse(...) = 0;

GcmsInstance

int32_t id{0};GcmsCachePtr cache{nullptr};std::vector<std::string> cols;gcmssdk::Controller* cntl{nullptr};

licache::AbstractData 

GcmsService

GcmsInnerParser

std::string _key;std::vector<FieldAccessor> _fields;inline T* get_field(...);

virtual int32_t parse(...);virtual int32_t init();virtual int32_t init_default(...);

GcmsCacheBvar

bvar::Adder<int> gcms_data_exist_cnt;bvar::Maxer<int> pool_max_gap;bvar::IntRecorder pool_avg_capacity;bvar::IntRecorder pool_avg_size;bvar::IntRecorder pool_avg_gap;bvar::LatencyRecorder bvar_latency;

void expose(...);

VideoInfo

babylon::StaticMemoryPool pool {      ::baidu::feed::mlarch::babylon::StaticMemoryPool(256)};std::unique_ptr<DynamicStruct> ds{nullptr};

GcmsPlugin

int32_t initialize() noexcept;int32_t wireup(ApplicationContext& context) noexcept;int32_t get_data(...) const noexcept;int32_t parse_cache(...) noexcept;int32_t parse_instance(...) noexcept;int32_t init_db(...) noexcept;int32_t add_cache_parser(...) noexcept;

GcmsData

VideoInfoPool::PooledObject _pooled_video_info;VideoInfo* _video_info{nullptr};GcmsParser* _parser{nullptr};GcmsCacheBvar* _gcms_cache_bvar;

void parse_inner_json(...);void parse_json(..);const VideoInfo* video_info();const StaticMemoryPool& pool() const;

GcmsNodeTree

GcmsParserBase* add_parser(...);

MyClosure

bthread::Mutex* _async_lock;

 virtual void proc_data(ConstDataMap*)

gcmssdk::GenericGcmsClosure<uint64_t>

gcmssdk::AbstractDataParser

virtual licache::AbstractData* parse(...) = 0;

typedef ::baidu::feed::mlarch::babylon::FieldAccessor FieldAccessor;

GcmsMultiKeyParser

std::string _key;std::vector<std::string> _key_vec;  std::vector<std::vector<FieldAccessor>> _fields_vec;std::vector<Any> _default_vec; 

GcmsParser

GcmsCache* _cache{nullptr};VideoInfoPool* _s_pool{nullptr};

virtual licache::AbstractData* parse(const rapidjson::Value& doc);

gcmssdk::TypeBase<uint64_t>::ConstDataMap* data

GcmsCache

std::string name;uint32_t pool_size{0};int32_t max_size{0};int32_t shard_num{0};int32_t ttl_sec{0};GcmsNodeTree cols;std::vector<GcmsParserBase*> parsers_with_default;gcmssdk::GenericGcmsDB<uint64_t> db;GcmsParser* parser{nullptr};DynamicStruct::Schema* schema{nullptr};std::unique_ptr<VideoInfoPool> s_pool{nullptr};std::string post_parser_str;CustomGcmsPostParser* post_parser{nullptr};GcmsCacheBvar gcms_cache_bvar;

 void init_pool(const std::string& expose_name);