Versions in this module Expand all Collapse all v1 v1.0.4 Nov 30, 2023 v1.0.3 Oct 24, 2023 Changes in this version type CallBackConfig + RawFeaturesRate int v1.0.2 Sep 21, 2023 v1.0.1 Sep 15, 2023 v1.0.0 Sep 15, 2023 Changes in this version + const BE_RecallType_MultiMerge + const BE_RecallType_Vector + const BE_RecallType_X2I + const DaoConf_Adapter_HBase + const DaoConf_Adapter_Hologres + const DaoConf_Adapter_Mysql + const DaoConf_Adapter_Redis + const DaoConf_Adapter_TableStore + const DataSource_Type_BE + const DataSource_Type_ClickHouse + const DataSource_Type_Datahub + const DataSource_Type_FeatureStore + const DataSource_Type_HBase_Thrift + const DataSource_Type_Kafka + const DataSource_Type_Lindorm + const Datasource_Type_Graph + var WithKey = func(key string) ParseOp + func CopyConfig(src, dst *RecommendConfig, filters ...func(string) bool) + func LoadConfig(filePath string) error + func ParseUserDefineConfs(ops ...ParseOp) (T, error) + func Subscribe() <-chan *RecommendConfig + func UpdateConf(conf *RecommendConfig) + type ABTestConfig struct + Host string + Token string + type ActionConfig struct + ActionName string + ActionType string + type AdjustCountConfig struct + Count int + RecallName string + Type string + type AlgoConfig struct + EasConf EasConfig + LookupConf LookupConfig + MilvusConf MilvusConfig + Name string + SeldonConf SeldonConfig + TFservingConf TFservingConfig + Type string + VectorConf VectorConfig + type BEConfig struct + Endpoint string + Password string + ReleaseType string + Username string + type BeConfig struct + BeABParams map[string]interface{} + BeFilterNames []string + BeName string + BeRecallParams []BeRecallParam + BeRecallType string + BizName string + Count int + RecallNameMapping map[string]RecallNameMappingConfig + type BeFilterConfig struct + type BeRTCntFieldConfig struct + Alias string + Delims []string + FieldNames []string + type BeRecallParam struct + Count int + CustomParams map[string]interface{} + DiversityParam string + ItemIdName string + Priority int + RecallName string + RecallTableName string + RecallType string + ScorerClause string + TriggerIdName string + TriggerParam BeTriggerParam + TriggerType string + TriggerValue string + UserCollaborativeDaoConf UserCollaborativeDaoConfig + UserEmbeddingO2OTrigger UserEmbeddingO2OTriggerConfig + UserRealtimeEmbeddingTrigger UserRealtimeEmbeddingTriggerConfig + UserTriggerDaoConf UserTriggerDaoConfig + UserTriggerRulesConf UserTriggerRulesConfig + UserTriggers []TriggerConfig + UserVectorTrigger UserVectorTriggerConfig + type BeTriggerParam struct + BizName string + FieldName string + type BeVectorConfig struct + BizName string + VectorEmbeddingField string + VectorKeyField string + type BoostScoreByWeightDaoConfig struct + ItemFieldName string + WeightFieldName string + type BoostScoreCondition struct + Conditions []FilterParamConfig + Expression string + type CallBackConfig struct + DataSource DataSourceConfig + RankConf RankConfig + RawFeatures bool + type CategoryConfig struct + RecallNames []string + type ClickHouseConfig struct + DSN string + type ColdStartDaoConfig struct + TimeInterval int + type ColdStartGeneralRankConfig struct + RecallNames []string + type ColdStartRankConfig struct + AlgoName string + OnlyEmbeddingFeature bool + RecallName string + type DPPSortConfig struct + Alpha float64 + CacheTimeInMinutes int + DaoConf DaoConfig + EmbMissedThreshold float64 + EmbeddingColumn string + EmbeddingHookNames []string + EmbeddingSeparator string + EnsurePositiveSim string + FilterRetrieveIds []string + Name string + NormalizeEmb string + TableName string + TablePKey string + TableSuffixParam string + WindowSize int + type DaoConfig struct + Adapter string + AdapterType string + BeExposureItemIdName string + BeExposureUserIdName string + BeName string + BeRecallName string + BeTableName string + BizName string + ClickHouseName string + ClickHouseTableName string + ColumnFamily string + Config string + Edge string + FeatureStoreEntityName string + FeatureStoreModelName string + FeatureStoreName string + GraphName string + HBaseName string + HBasePrefix string + HBaseTable string + HologresName string + HologresTableName string + InstanceId string + ItemNode string + LindormName string + LindormTableName string + MysqlName string + MysqlTable string + Qualifier string + RedisDataType string + RedisDefaultKey string + RedisFieldType string + RedisName string + RedisPrefix string + RedisValueDelimeter string + TableName string + TableStoreName string + TableStoreTableName string + UserNode string + type DataSourceConfig struct + Name string + Type string + type DatahubConfig struct + AccessId string + AccessKey string + Endpoint string + ProjectName string + Schemas []DatahubTopicSchema + TopicName string + type DatahubTopicSchema struct + Field string + Type string + type DebugConfig struct + DatahubName string + DebugUsers []string + FilePath string + MaxFileNum int + OutputType string + Rate int + type DistinctIdCondition struct + Conditions []FilterParamConfig + DistinctId int + type DiversityDaoConfig struct + CacheTimeInMinutes int + DistinctFields []string + ItemKeyField string + type DiversityRuleConfig struct + Dimensions []string + FrequencySize int + IntervalSize int + WindowSize int + type EasConfig struct + Auth string + EndpointType string + ModelName string + Outputs []string + Processor string + ResponseFuncName string + RetryTimes int + SignatureName string + Timeout int + Url string + type FeatureConfig struct + Expression string + FeatureName string + FeatureSource string + FeatureStore string + FeatureType string + FeatureValue string + Normalizer string + RemoveFeatureSource bool + type FeatureDaoConfig struct + BeEventFeatureKeyName string + BeIsHomeField string + BeItemFeatureKeyName string + BePlayTimeFeatureKeyName string + BeRTCntFieldInfo []BeRTCntFieldConfig + BeRTCntFields string + BeRTTable string + BeTimestampFeatureKeyName string + CacheFeaturesName string + EventFeatureKeyName string + FeatureAsyncLoad bool + FeatureKey string + FeatureStore string + FeatureType string + ItemFeatureKeyName string + ItemSelectFields string + LoadFromCacheFeaturesName string + NoUsePlayTimeField bool + OutEventName string + OutHomeRTCntFeaPattern string + OutRTCntFeaPattern string + OutRTCntFieldAlias string + OutRTCntWinNames string + PlayTimeFeatureKeyName string + RTCntMaxKey int + RTCntWinDelay int + RTCntWins string + SequenceDelim string + SequenceDimFields string + SequenceEvent string + SequenceLength int + SequenceName string + SequenceOfflineTableName string + SequencePlayTime string + TimestampFeatureKeyName string + TsFeatureKeyName string + UserFeatureKeyName string + UserSelectFields string + type FeatureLoadConfig struct + FeatureDaoConf FeatureDaoConfig + Features []FeatureConfig + type FeatureStoreConfig struct + Host string + ProjectName string + Token string + type FilterConfig struct + AdjustCountConfs []AdjustCountConfig + ClearLogIfNotEnoughScene string + DaoConf DaoConfig + Dimension string + DiversityDaoConf DiversityDaoConfig + DiversityMinCount int + EnsureDiversity bool + FilterEvaluableExpression string + FilterParams []FilterParamConfig + FilterType string + FilterVal FilterValue + GenerateItemDataFuncName string + GroupMaxNum int + GroupMinNum int + GroupWeightDimensionLimit map[string]int + GroupWeightStrategy string + ItemStateDaoConf ItemStateDaoConfig + MaxItems int + Name string + RetainNum int + ScoreWeight float64 + ShuffleItem bool + TimeInterval int + WriteLog bool + WriteLogExcludeScenes []string + type FilterParamConfig struct + Domain string + Name string + Operator string + Type string + Value interface{} + type FilterValue struct + SelectCol string + WhereClause string + type GeneralRankConfig struct + ActionConfs []ActionConfig + FeatureLoadConfs []FeatureLoadConfig + RankConf RankConfig + type GraphConf struct + GraphName string + ItemId string + Params []string + QueryString string + type GraphConfig struct + Host string + Passwd string + UserName string + type HBaseConfig struct + ZKQuorum string + type HBaseThriftConfig struct + Host string + Password string + User string + type Ha3EngineConfig struct + Endpoint string + InstanceId string + Password string + Username string + type HologresConfig struct + DSN string + type HologresVectorConfig struct + HologresName string + TimeInterval int + VectorEmbeddingField string + VectorKeyField string + VectorTable string + WhereClause string + type ItemCollaborativeDaoConfig struct + Item2ItemTable string + type ItemStateDaoConfig struct + ItemFieldName string + SelectFields string + WhereClause string + type KafkaConfig struct + BootstrapServers string + Topic string + type LindormConfig struct + Database string + Password string + Url string + User string + type ListenConfig struct + HttpAddr string + HttpPort int + type LogConfig struct + DiskSize int + LogLevel string + Output string + RetensionDays int + SLSName string + type LookupConfig struct + FieldName string + type MilvusConfig struct + ServerAddress string + Timeout int64 + type MilvusVectorConfig struct + CollectionName string + MetricType string + SearchParams map[string]interface{} + VectorEmbeddingField string + VectorKeyField string + type MixSortConfig struct + Conditions []FilterParamConfig + MixStrategy string + Number int + NumberRate float64 + PositionField string + Positions []int + RecallNames []string + type MysqlConfig struct + DSN string + type OperatorValueConfig struct + From string + Name string + Type string + type PIDControllerConfig struct + AllocateExperimentWise bool + BoostScoreConditions []BoostScoreCondition + DefaultKd float32 + DefaultKi float32 + DefaultKp float32 + HologresName string + LoadItemFeature bool + MaxItemCacheSize int + MaxItemCacheTime int + PreloadItemFeature bool + RedisKeyPrefix string + RedisName string + SampleTime float32 + SyncPIDStatus bool + TestTimestamp int64 + type ParseOp func(setting *parseSetting) + type PipelineConfig struct + ColdStartRankConf ColdStartRankConfig + FeatureLoadConfs []FeatureLoadConfig + FilterNames []string + GeneralRankConf GeneralRankConfig + Name string + RankConf RankConfig + RecallNames []string + SortNames []string + type PrometheusConfig struct + Enable bool + Job string + PushGatewayURL string + PushIntervalSecs int + ReqDurBuckets []float64 + ReqSizeBuckets []float64 + RespSizeBuckets []float64 + Subsystem string + type RankConfig struct + BatchCount int + ContextFeatures []string + Processor string + RankAlgoList []string + RankScore string + ScoreRewrite map[string]string + type RealTimeUser2ItemDaoConfig struct + Item2ItemTable string + UserTriggerDaoConf UserTriggerDaoConfig + type RecallConfig struct + BeConf BeConfig + BeVectorConf BeVectorConfig + CacheAdapter string + CacheConfig string + CachePrefix string + CacheTime int + ColdStartDaoConf ColdStartDaoConfig + DaoConf DaoConfig + GraphConf GraphConf + HologresVectorConf HologresVectorConfig + ItemCollaborativeDaoConf ItemCollaborativeDaoConfig + ItemType string + MilvusVectorConf MilvusVectorConfig + Name string + RealTimeUser2ItemDaoConf RealTimeUser2ItemDaoConfig + RecallAlgo string + RecallCount int + RecallType string + Triggers []TriggerConfig + User2ItemDaoConf User2ItemDaoConfig + UserCollaborativeDaoConf UserCollaborativeDaoConfig + UserFeatureConfs []FeatureLoadConfig + UserTopicDaoConf UserTopicDaoConfig + VectorDaoConf VectorDaoConfig + type RecallNameMappingConfig struct + Fields []string + Format string + type RecommendConfig struct + ABTestConf ABTestConfig + AlgoConfs []AlgoConfig + BEConfs map[string]BEConfig + BeFilterConfs []BeFilterConfig + CallBackConfs map[string]CallBackConfig + ClickHouseConfs map[string]ClickHouseConfig + ColdStartGeneralRankConfs map[string]ColdStartGeneralRankConfig + ColdStartRankConfs map[string]ColdStartRankConfig + DPPConf []DPPSortConfig + DatahubConfs map[string]DatahubConfig + DebugConfs map[string]DebugConfig + FeatureConfs map[string]SceneFeatureConfig + FeatureStoreConfs map[string]FeatureStoreConfig + FilterConfs []FilterConfig + FilterNames map[string][]string + GeneralRankConfs map[string]GeneralRankConfig + GraphConfs map[string]GraphConfig + HBaseConfs map[string]HBaseConfig + HBaseThriftConfs map[string]HBaseThriftConfig + Ha3EngineConfs map[string]Ha3EngineConfig + HologresConfs map[string]HologresConfig + KafkaConfs map[string]KafkaConfig + LindormConfs map[string]LindormConfig + ListenConf ListenConfig + LogConf LogConfig + MysqlConfs map[string]MysqlConfig + PipelineConfs map[string][]PipelineConfig + PrometheusConfig PrometheusConfig + RankConf map[string]RankConfig + RecallConfs []RecallConfig + RedisConfs map[string]RedisConfig + Region string + RunMode string + SceneConfs map[string]map[string]CategoryConfig + SlsConfs map[string]SlsConfig + SortConfs []SortConfig + SortNames map[string][]string + TableStoreConfs map[string]TableStoreConfig + UserDefineConfs json.RawMessage + UserFeatureConfs map[string]SceneFeatureConfig + var Config *RecommendConfig + type RedisConfig struct + ConnectTimeout int + DbNum int + Host string + MaxIdle int + Password string + Port int + ReadTimeout int + WriteTimeout int + type SceneConfig struct + Categories []string + type SceneFeatureConfig struct + AsynLoadFeature bool + FeatureLoadConfs []FeatureLoadConfig + type SeldonConfig struct + ResponseFuncName string + Url string + type SlsConfig struct + AccessKeyId string + AccessKeySecret string + EndPoint string + LogstoreName string + ProjectName string + type SortConfig struct + BoostScoreByWeightDao BoostScoreByWeightDaoConfig + BoostScoreConditions []BoostScoreCondition + BoostScoreConditionsFilterAll bool + Conditions []FilterParamConfig + DPPConf DPPSortConfig + Debug bool + DistinctIdConditions []DistinctIdCondition + DiversityRules []DiversityRuleConfig + DiversitySize int + ExcludeRecalls []string + MixSortRules []MixSortConfig + Name string + PIDConf PIDControllerConfig + RemainItem bool + Size int + SortByField string + SortType string + SwitchThreshold float64 + TimeInterval int + type SqlDaoConfig struct + Limit int + PrimaryKey string + SelectFields string + WhereClause string + type TFservingConfig struct + Outputs []string + ResponseFuncName string + RetryTimes int + SignatureName string + Timeout int + Url string + type TableStoreConfig struct + AccessKeyId string + AccessKeySecret string + EndPoint string + InstanceName string + RoleArn string + type TriggerConfig struct + Boundaries []int + DefaultValue string + TriggerKey string + type TriggerDiversityRuleConfig struct + Dimensions []string + Size int + type User2ItemDaoConfig struct + Item2ItemTable string + User2ItemTable string + type UserCollaborativeDaoConfig struct + Item2ItemTable string + Normalization string + User2ItemTable string + type UserEmbeddingO2OTriggerConfig struct + BeName string + BizName string + MultiValueDelimiter string + RecallName string + SeqDelimiter string + UserFeatureConfs []FeatureLoadConfig + type UserRealtimeEmbeddingTriggerConfig struct + Debug bool + DebugLogDatahub string + DistinctParamName string + DistinctParamValue string + EmbeddingNum int + RecallAlgo string + UserFeatureConfs []FeatureLoadConfig + type UserTopicDaoConfig struct + IndexName string + TopicItemTable string + UserTopicTable string + type UserTriggerDaoConfig struct + BeEventFeatureKeyName string + BeItemFeatureKeyName string + BePlayTimeFeatureKeyName string + BeTimestampFeatureKeyName string + DiversityRules []TriggerDiversityRuleConfig + EventPlayTime string + EventWeight string + ItemCount int + NoUsePlayTimeField bool + PropertyFields []string + TriggerCount int + WeightExpression string + WeightMode string + type UserTriggerRulesConfig struct + DefaultValue int + TriggerCounts []int + type UserVectorTriggerConfig struct + CachePrefix string + CacheTime int + RecallAlgo string + UserFeatureConfs []FeatureLoadConfig + type VectorConfig struct + ServerAddress string + Timeout int64 + type VectorDaoConfig struct + EmbeddingField string + KeyField string + PartitionInfoField string + PartitionInfoTable string Other modules containing this package github.com/alibaba/pairec/v2