dao

Documentation

Index

• func ColumnValues(columns []*sql.ColumnType) []interface{}
• func Md5(msg string) string
• func ParseColumnValues(value interface{}) interface{}
• type DaoConfig
• type FeatureViewDao
  • func NewFeatureViewDao(config DaoConfig) FeatureViewDao
• type FeatureViewHologresDao
  • func NewFeatureViewHologresDao(config DaoConfig) *FeatureViewHologresDao
  • func (d *FeatureViewHologresDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
• type FeatureViewIGraphDao
  • func NewFeatureViewIGraphDao(config DaoConfig) *FeatureViewIGraphDao
  • func (d *FeatureViewIGraphDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
• type FeatureViewMysqlDao
  • func NewFeatureViewMysqlDao(config DaoConfig) *FeatureViewMysqlDao
  • func (d *FeatureViewMysqlDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
• type FeatureViewOTSDao
  • func NewFeatureViewOTSDao(config DaoConfig) *FeatureViewOTSDao
  • func (d *FeatureViewOTSDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
• type FeatureViewRedisDao
  • func NewFeatureViewRedisDao(config DaoConfig) *FeatureViewRedisDao
  • func (d *FeatureViewRedisDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

Functions

func ColumnValues

func ColumnValues(columns []*sql.ColumnType) []interface{}

ColumnValues return dynamic column values by the sql.ColumnType

func Md5

func Md5(msg string) string

func ParseColumnValues

func ParseColumnValues(value interface{}) interface{}

ParseColumnValues return true value of column value. Retrun nil if the column value is not valid, like nullable.

Types

type DaoConfig

type DaoConfig struct {
	DatasourceType      string
	RedisName           string
	RedisPrefix         string
	RedisDefaultKey     string
	RedisValueDelimeter string
	MysqlName           string
	MysqlTableName      string
	Config              string
	TableStoreName      string
	TableStoreTableName string
	HBasePrefix         string
	HBaseName           string
	HBaseTable          string
	ColumnFamily        string
	Qualifier           string

	PrimaryKeyField string
	EventTimeField  string
	TTL             int

	// hologres
	HologresName      string
	HologresTableName string

	//ots
	OtsName      string
	OtsTableName string

	// clickhouse
	ClickHouseName      string
	ClickHouseTableName string

	// be engine
	BeName               string
	BizName              string
	BeTableName          string
	BeExposureUserIdName string
	BeExposureItemIdName string

	// igraph
	IGraphName        string
	GroupName         string
	LabelName         string
	SaveOriginalField bool

	FieldMap map[string]string
	// redis, ots
	FieldTypeMap map[string]constants.FSType

	// redis
	Fields []string
}

type FeatureViewDao

type FeatureViewDao interface {
	GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)
}

func NewFeatureViewDao

func NewFeatureViewDao(config DaoConfig) FeatureViewDao

type FeatureViewHologresDao

type FeatureViewHologresDao struct {
	// contains filtered or unexported fields
}

func NewFeatureViewHologresDao

func NewFeatureViewHologresDao(config DaoConfig) *FeatureViewHologresDao

func (*FeatureViewHologresDao) GetFeatures

func (d *FeatureViewHologresDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

type FeatureViewIGraphDao

type FeatureViewIGraphDao struct {
	// contains filtered or unexported fields
}

func NewFeatureViewIGraphDao

func NewFeatureViewIGraphDao(config DaoConfig) *FeatureViewIGraphDao

func (*FeatureViewIGraphDao) GetFeatures

func (d *FeatureViewIGraphDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

type FeatureViewMysqlDao

type FeatureViewMysqlDao struct {
	// contains filtered or unexported fields
}

func NewFeatureViewMysqlDao

func NewFeatureViewMysqlDao(config DaoConfig) *FeatureViewMysqlDao

func (*FeatureViewMysqlDao) GetFeatures

func (d *FeatureViewMysqlDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

type FeatureViewOTSDao

type FeatureViewOTSDao struct {
	// contains filtered or unexported fields
}

func NewFeatureViewOTSDao

func NewFeatureViewOTSDao(config DaoConfig) *FeatureViewOTSDao

func (*FeatureViewOTSDao) GetFeatures

func (d *FeatureViewOTSDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)

type FeatureViewRedisDao

type FeatureViewRedisDao struct {
	// contains filtered or unexported fields
}

func NewFeatureViewRedisDao

func NewFeatureViewRedisDao(config DaoConfig) *FeatureViewRedisDao

func (*FeatureViewRedisDao) GetFeatures

func (d *FeatureViewRedisDao) GetFeatures(keys []interface{}, selectFields []string) ([]map[string]interface{}, error)