datahub

Documentation

Index

• func FeatureLogToDatahub(datahubName string, f FeatureLogDatahubFunc)
• func Load(config *recconf.RecommendConfig)
• func RegisterDatahub(name string, dh *Datahub)
• func RemoveDatahub(name string)
• type Datahub
  • func GetDatahub(name string) (*Datahub, error)
  • func NewDatahub(accessId, accessKey, endpoint, project, topic string, ...) *Datahub
  • func (d *Datahub) DataHubApi() alidatahub.DataHubApi
  • func (d *Datahub) Init() error
  • func (d *Datahub) SendMessage(messages []map[string]interface{})
  • func (d *Datahub) Shards() (ret []string)
  • func (d *Datahub) Stop()
  • func (d *Datahub) StopLoopListShards()
• type FeatureLogDatahubFunc

Functions

func FeatureLogToDatahub

func FeatureLogToDatahub(datahubName string, f FeatureLogDatahubFunc)

func Load

func Load(config *recconf.RecommendConfig)

func RegisterDatahub

func RegisterDatahub(name string, dh *Datahub)

func RemoveDatahub

func RemoveDatahub(name string)

Types

type Datahub

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

func GetDatahub

func GetDatahub(name string) (*Datahub, error)

func NewDatahub

func NewDatahub(accessId, accessKey, endpoint, project, topic string, schemas []recconf.DatahubTopicSchema) *Datahub

func (*Datahub) DataHubApi

func (d *Datahub) DataHubApi() alidatahub.DataHubApi

func (*Datahub) Init

func (d *Datahub) Init() error

func (*Datahub) SendMessage

func (d *Datahub) SendMessage(messages []map[string]interface{})

func (*Datahub) Shards

func (d *Datahub) Shards() (ret []string)

func (*Datahub) Stop

func (d *Datahub) Stop()

func (*Datahub) StopLoopListShards

func (d *Datahub) StopLoopListShards()

type FeatureLogDatahubFunc

type FeatureLogDatahubFunc func(*Datahub, *module.User, []*module.Item, *context.RecommendContext)