Documentation
¶
Index ¶
- func GetCollection() string
- func GetDataSource() (ds entity.DataSource)
- func GetDataSourceType() string
- func GetDedupField() string
- func GetDedupMethod() string
- func GetIsDedup() string
- func GetTaskId() string
- func SaveItem(item entity.Item) (err error)
- func SaveItemElasticSearch(item entity.Item) error
- func SaveItemKafka(item entity.Item) error
- func SaveItemMongo(item entity.Item) (err error)
- func SaveItemSql(item entity.Item) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetCollection ¶
func GetCollection() string
func GetDataSource ¶
func GetDataSource() (ds entity.DataSource)
func GetDataSourceType ¶
func GetDataSourceType() string
func GetDedupField ¶
func GetDedupField() string
func GetDedupMethod ¶
func GetDedupMethod() string
func GetIsDedup ¶
func GetIsDedup() string
func SaveItemElasticSearch ¶
func SaveItemKafka ¶
func SaveItemMongo ¶
func SaveItemSql ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.