datahub

package

v2.6.2 Latest Latest Go to latest Published: Dec 2, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/alibaba/pairec

Links

Open Source Insights

Documentation ¶

Index ¶

func FeatureLogToDatahub(datahubName string, f FeatureLogDatahubFunc)
func Load(config *recconf.RecommendConfig)
func RegisterDatahub(name string, dh *Datahub)
func RemoveDatahub(name string)
type AklessAccount
- func NewAklessAccount() (*AklessAccount, error)
type DataType
type Datahub
- func GetDatahub(name string) (*Datahub, error)
- func NewDatahub(accessId, accessKey, endpoint, project, topic string, ...) *Datahub
type FeatureLogDatahubFunc
type SyncLogDatahubItem
- func NewSyncLogDatahubItem(data map[string]any) *SyncLogDatahubItem
- func (s *SyncLogDatahubItem) Format() []byte
- func (s *SyncLogDatahubItem) Parse(data []byte) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 AklessAccount ¶ added in v2.4.9

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

func NewAklessAccount ¶ added in v2.4.9

func NewAklessAccount() (*AklessAccount, error)

func (*AklessAccount) GetAccountId ¶ added in v2.4.9

func (a *AklessAccount) GetAccountId() string

GetAccountId implements datahub.Account.

func (*AklessAccount) GetAccountKey ¶ added in v2.4.9

func (a *AklessAccount) GetAccountKey() string

GetAccountKey implements datahub.Account.

func (*AklessAccount) GetSecurityToken ¶ added in v2.4.9

func (a *AklessAccount) GetSecurityToken() string

GetSecurityToken implements datahub.Account.

func (*AklessAccount) String ¶ added in v2.4.9

func (a *AklessAccount) String() string

String implements datahub.Account.

type DataType ¶ added in v2.4.8

type DataType int8

const (
	INT DataType = iota + 1
	INT64
	FLOAT32
	FLOAT64
	STRING
	BOOL
)

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)

type SyncLogDatahubItem ¶ added in v2.4.8

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

func NewSyncLogDatahubItem ¶ added in v2.4.8

func NewSyncLogDatahubItem(data map[string]any) *SyncLogDatahubItem

func (*SyncLogDatahubItem) Format ¶ added in v2.4.8

func (s *SyncLogDatahubItem) Format() []byte

func (*SyncLogDatahubItem) Parse ¶ added in v2.4.8

func (s *SyncLogDatahubItem) Parse(data []byte) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL