domain

package
v2.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 8, 2025 License: MIT Imports: 13 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BaseFeatureView added in v2.0.5 

type BaseFeatureView struct {
	*api.FeatureView
	Project       *Project
	FeatureEntity *FeatureEntity
	// contains filtered or unexported fields
}

func NewBaseFeatureView added in v2.0.5 

func NewBaseFeatureView(view *api.FeatureView, p *Project, entity *FeatureEntity) *BaseFeatureView

func (*BaseFeatureView) GetBehaviorFeatures added in v2.2.9 

func (f *BaseFeatureView) GetBehaviorFeatures(userIds []interface{}, events []interface{}, features []string) ([]map[string]interface{}, error)

func (*BaseFeatureView) GetFeatureEntityName added in v2.0.5 

func (f *BaseFeatureView) GetFeatureEntityName() string

func (*BaseFeatureView) GetFields added in v2.2.3 

func (f *BaseFeatureView) GetFields() []api.FeatureViewFields

func (*BaseFeatureView) GetIsWriteToFeatureDB added in v2.2.3 

func (f *BaseFeatureView) GetIsWriteToFeatureDB() bool

func (*BaseFeatureView) GetName added in v2.0.5 

func (f *BaseFeatureView) GetName() string

func (*BaseFeatureView) GetOnlineFeatures added in v2.0.5 

func (f *BaseFeatureView) GetOnlineFeatures(joinIds []interface{}, features []string, alias map[string]string) ([]map[string]interface{}, error)

func (*BaseFeatureView) GetTTL added in v2.2.9 

func (f *BaseFeatureView) GetTTL() int

func (*BaseFeatureView) GetType added in v2.0.5 

func (f *BaseFeatureView) GetType() string

func (*BaseFeatureView) Offline2Online added in v2.0.5 

func (f *BaseFeatureView) Offline2Online(input string) string

func (*BaseFeatureView) RowCount added in v2.2.9 

func (f *BaseFeatureView) RowCount(expr string) int

func (*BaseFeatureView) RowCountIds added in v2.3.1 

func (f *BaseFeatureView) RowCountIds(expr string) ([]string, int, error)

RowCountIds implements FeatureView.

type FeatureDBOnlineStore added in v2.0.7 

type FeatureDBOnlineStore struct {
	*api.Datasource
}

func (*FeatureDBOnlineStore) GetDatasourceName added in v2.0.7 

func (s *FeatureDBOnlineStore) GetDatasourceName() string

func (*FeatureDBOnlineStore) GetSeqOfflineTableName added in v2.0.7 

func (s *FeatureDBOnlineStore) GetSeqOfflineTableName(seqFeatureView *SequenceFeatureView) string

func (*FeatureDBOnlineStore) GetSeqOnlineTableName added in v2.0.7 

func (s *FeatureDBOnlineStore) GetSeqOnlineTableName(sequenceFeatureView *SequenceFeatureView) string

func (*FeatureDBOnlineStore) GetTableName added in v2.0.7 

func (s *FeatureDBOnlineStore) GetTableName(featureView *BaseFeatureView) string

type FeatureEntity 

type FeatureEntity struct {
	*api.FeatureEntity
}

func NewFeatureEntity 

func NewFeatureEntity(entity *api.FeatureEntity) *FeatureEntity

type FeatureSelector 

type FeatureSelector struct {
	FeatureEntity string
	FeatureView   string
	Features      []string
	Alias         map[string]string
}

type FeatureView 

type FeatureView interface {
	GetOnlineFeatures(joinIds []interface{}, features []string, alias map[string]string) ([]map[string]interface{}, error)
	GetBehaviorFeatures(userIds []interface{}, events []interface{}, features []string) ([]map[string]interface{}, error)
	GetName() string
	GetFeatureEntityName() string
	GetType() string
	Offline2Online(input string) string
	GetFields() []api.FeatureViewFields
	GetIsWriteToFeatureDB() bool
	GetTTL() int

	// RowCount gets the count filter by the given expression
	RowCount(string) int

	//RowCountIds gets the primary key list and  count filter by the given expression
	RowCountIds(expr string) ([]string, int, error)
}

func NewFeatureView 

func NewFeatureView(view *api.FeatureView, p *Project, entity *FeatureEntity) FeatureView

type HologresOnlineStore 

type HologresOnlineStore struct {
	*api.Datasource
}

func (*HologresOnlineStore) GetDatasourceName 

func (s *HologresOnlineStore) GetDatasourceName() string

func (*HologresOnlineStore) GetSeqOfflineTableName added in v2.0.5 

func (s *HologresOnlineStore) GetSeqOfflineTableName(seqFeatureView *SequenceFeatureView) string

func (*HologresOnlineStore) GetSeqOnlineTableName added in v2.0.5 

func (s *HologresOnlineStore) GetSeqOnlineTableName(sequenceFeatureView *SequenceFeatureView) string

func (*HologresOnlineStore) GetTableName 

func (s *HologresOnlineStore) GetTableName(featureView *BaseFeatureView) string

type IGraphOnlineStore 

type IGraphOnlineStore struct {
	*api.Datasource
}

func (*IGraphOnlineStore) GetDatasourceName 

func (s *IGraphOnlineStore) GetDatasourceName() string

func (*IGraphOnlineStore) GetSeqOfflineTableName added in v2.0.5 

func (s *IGraphOnlineStore) GetSeqOfflineTableName(sequenceFeatureView *SequenceFeatureView) string

func (*IGraphOnlineStore) GetSeqOnlineTableName added in v2.0.5 

func (s *IGraphOnlineStore) GetSeqOnlineTableName(sequenceFeatureView *SequenceFeatureView) string

func (*IGraphOnlineStore) GetTableName 

func (s *IGraphOnlineStore) GetTableName(featureView *BaseFeatureView) string

type Model 

type Model struct {
	*api.Model
	// contains filtered or unexported fields
}

func NewModel 

func NewModel(model *api.Model, p *Project) *Model

func (*Model) GetLabelPriorityLevel added in v2.2.4 

func (m *Model) GetLabelPriorityLevel() int

func (*Model) GetOnlineFeatures 

func (m *Model) GetOnlineFeatures(joinIds map[string][]interface{}) ([]map[string]interface{}, error)

func (*Model) GetOnlineFeaturesWithEntity 

func (m *Model) GetOnlineFeaturesWithEntity(joinIds map[string][]interface{}, featureEntityName string) ([]map[string]interface{}, error)

type OnlineStore 

type OnlineStore interface {
	GetTableName(featureView *BaseFeatureView) string
	GetDatasourceName() string
	GetSeqOfflineTableName(seqFeatureView *SequenceFeatureView) string
	GetSeqOnlineTableName(seqFeatureView *SequenceFeatureView) string
}

type Project 

type Project struct {
	*api.Project
	OnlineStore      OnlineStore
	FeatureViewMap   map[string]FeatureView
	FeatureEntityMap map[string]*FeatureEntity
	ModelMap         map[string]*Model
}

func NewProject 

func NewProject(p *api.Project, isInitClient bool) *Project

func (*Project) GetFeatureEntity 

func (p *Project) GetFeatureEntity(name string) *FeatureEntity

func (*Project) GetFeatureView 

func (p *Project) GetFeatureView(name string) FeatureView

func (*Project) GetModel 

func (p *Project) GetModel(name string) *Model

func (*Project) GetModelFeature 

func (p *Project) GetModelFeature(name string) *Model

type SequenceFeatureView added in v2.0.5 

type SequenceFeatureView struct {
	*api.FeatureView
	Project       *Project
	FeatureEntity *FeatureEntity
	// contains filtered or unexported fields
}

func NewSequenceFeatureView added in v2.0.5 

func NewSequenceFeatureView(view *api.FeatureView, p *Project, entity *FeatureEntity) *SequenceFeatureView

func (*SequenceFeatureView) GetBehaviorFeatures added in v2.2.9 

func (f *SequenceFeatureView) GetBehaviorFeatures(userIds []interface{}, events []interface{}, features []string) ([]map[string]interface{}, error)

func (*SequenceFeatureView) GetFeatureEntityName added in v2.0.5 

func (f *SequenceFeatureView) GetFeatureEntityName() string

func (*SequenceFeatureView) GetFields added in v2.2.3 

func (f *SequenceFeatureView) GetFields() []api.FeatureViewFields

func (*SequenceFeatureView) GetIsWriteToFeatureDB added in v2.2.3 

func (f *SequenceFeatureView) GetIsWriteToFeatureDB() bool

func (*SequenceFeatureView) GetName added in v2.0.5 

func (f *SequenceFeatureView) GetName() string

func (*SequenceFeatureView) GetOnlineFeatures added in v2.0.5 

func (f *SequenceFeatureView) GetOnlineFeatures(joinIds []interface{}, features []string, alias map[string]string) ([]map[string]interface{}, error)

func (*SequenceFeatureView) GetTTL added in v2.2.9 

func (f *SequenceFeatureView) GetTTL() int

func (*SequenceFeatureView) GetType added in v2.0.5 

func (f *SequenceFeatureView) GetType() string

func (*SequenceFeatureView) Offline2Online added in v2.0.5 

func (f *SequenceFeatureView) Offline2Online(input string) string

func (*SequenceFeatureView) RowCount added in v2.2.9 

func (f *SequenceFeatureView) RowCount(string) int

func (*SequenceFeatureView) RowCountIds added in v2.3.1 

func (f *SequenceFeatureView) RowCountIds(string) ([]string, int, error)

type TableStoreOnlineStore added in v2.0.5 

type TableStoreOnlineStore struct {
	*api.Datasource
}

func (*TableStoreOnlineStore) GetDatasourceName added in v2.0.5 

func (s *TableStoreOnlineStore) GetDatasourceName() string

func (*TableStoreOnlineStore) GetSeqOfflineTableName added in v2.0.5 

func (s *TableStoreOnlineStore) GetSeqOfflineTableName(sequenceFeatureView *SequenceFeatureView) string

func (*TableStoreOnlineStore) GetSeqOnlineTableName added in v2.0.5 

func (s *TableStoreOnlineStore) GetSeqOnlineTableName(sequenceFeatureView *SequenceFeatureView) string

func (*TableStoreOnlineStore) GetTableName added in v2.0.5 

func (s *TableStoreOnlineStore) GetTableName(featureView *BaseFeatureView) string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.