Documentation
¶
Index ¶
- type OomStore
- func (s *OomStore) Close() error
- func (s *OomStore) CreateBatchFeature(ctx context.Context, opt types.CreateFeatureOpt) (int, error)
- func (s *OomStore) CreateEntity(ctx context.Context, opt types.CreateEntityOpt) (int, error)
- func (s *OomStore) CreateGroup(ctx context.Context, opt types.CreateGroupOpt) (int, error)
- func (s *OomStore) Export(ctx context.Context, opt types.ExportOpt) ([]string, <-chan *types.RawFeatureValueRecord, error)
- func (s *OomStore) GetEntity(ctx context.Context, id int) (*types.Entity, error)
- func (s *OomStore) GetEntityByName(ctx context.Context, name string) (*types.Entity, error)
- func (s *OomStore) GetFeature(ctx context.Context, id int) (*types.Feature, error)
- func (s *OomStore) GetFeatureByName(ctx context.Context, name string) (*types.Feature, error)
- func (s *OomStore) GetGroup(ctx context.Context, id int) (*types.Group, error)
- func (s *OomStore) GetGroupByName(ctx context.Context, name string) (*types.Group, error)
- func (s *OomStore) GetRevision(ctx context.Context, id int) (*types.Revision, error)
- func (s *OomStore) GetRevisionBy(ctx context.Context, groupID int, revision int64) (*types.Revision, error)
- func (s *OomStore) Import(ctx context.Context, opt types.ImportOpt) (int, error)
- func (s *OomStore) Join(ctx context.Context, opt types.JoinOpt) (*types.JoinResult, error)
- func (s *OomStore) ListEntity(ctx context.Context) types.EntityList
- func (s *OomStore) ListFeature(ctx context.Context, opt types.ListFeatureOpt) (types.FeatureList, error)
- func (s *OomStore) ListGroup(ctx context.Context, entityID *int) types.GroupList
- func (s *OomStore) ListRevision(ctx context.Context, groupID *int) types.RevisionList
- func (s *OomStore) OnlineGet(ctx context.Context, opt types.OnlineGetOpt) (*types.FeatureValues, error)
- func (s *OomStore) OnlineMultiGet(ctx context.Context, opt types.OnlineMultiGetOpt) (types.FeatureDataSet, error)
- func (s *OomStore) Sync(ctx context.Context, opt types.SyncOpt) error
- func (s *OomStore) UpdateEntity(ctx context.Context, opt types.UpdateEntityOpt) error
- func (s *OomStore) UpdateFeature(ctx context.Context, opt types.UpdateFeatureOpt) error
- func (s *OomStore) UpdateGroup(ctx context.Context, opt types.UpdateGroupOpt) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OomStore ¶
type OomStore struct {
// contains filtered or unexported fields
}
Combine online store, offline store, and metadata store instances in one place.
func Open ¶
Return an OomStore instance given the configuration. Under the hood, it setups connections to the underlying databases. You should always use this method to create a new OomStore instance in code.
func TEST__New ¶ added in v0.0.3
Return an OomStore instance for internal test purpose ONLY. You should NOT use this method directly in any of your code.
func (*OomStore) CreateBatchFeature ¶
Create metadata of a batch feature.
func (*OomStore) CreateEntity ¶
Create metadata for an entity.
func (*OomStore) CreateGroup ¶ added in v0.0.3
Create meetadata of a feature group.
func (*OomStore) Export ¶ added in v0.0.4
func (s *OomStore) Export(ctx context.Context, opt types.ExportOpt) ([]string, <-chan *types.RawFeatureValueRecord, error)
Export feature values of a particular revision.
func (*OomStore) GetEntityByName ¶ added in v0.0.2
Get metadata of an entity by name.
func (*OomStore) GetFeature ¶
Get metadata of a feature by ID.
func (*OomStore) GetFeatureByName ¶ added in v0.0.2
Get metadata of a feature by name.
func (*OomStore) GetGroupByName ¶ added in v0.0.3
Get metadata of a feature group by name.
func (*OomStore) GetRevision ¶
Get metadata of a revision by ID.
func (*OomStore) GetRevisionBy ¶ added in v0.0.2
func (s *OomStore) GetRevisionBy(ctx context.Context, groupID int, revision int64) (*types.Revision, error)
Get metadata of a revision by group ID and revision.
func (*OomStore) Import ¶ added in v0.0.3
Import a CSV data source into the feature store as a new revision. In the future we want to support more diverse data sources.
func (*OomStore) Join ¶ added in v0.0.3
Get point-in-time correct feature values for each entity row. Currently, this API only supports batch features.
func (*OomStore) ListEntity ¶
func (s *OomStore) ListEntity(ctx context.Context) types.EntityList
List metadata of all entities.
func (*OomStore) ListFeature ¶
func (s *OomStore) ListFeature(ctx context.Context, opt types.ListFeatureOpt) (types.FeatureList, error)
List metadata of features meeting particular criteria.
func (*OomStore) ListRevision ¶
List metadata of revisions of a same group.
func (*OomStore) OnlineGet ¶ added in v0.0.3
func (s *OomStore) OnlineGet(ctx context.Context, opt types.OnlineGetOpt) (*types.FeatureValues, error)
Get online features of a particular entity instance.
func (*OomStore) OnlineMultiGet ¶ added in v0.0.3
func (s *OomStore) OnlineMultiGet(ctx context.Context, opt types.OnlineMultiGetOpt) (types.FeatureDataSet, error)
Get online features of multiple entity instances.
func (*OomStore) Sync ¶ added in v0.0.2
Sync a particular revision of a feature group from offline to online store. It is a streaming process - it writes to online store while reading from offline store. This helps get rid of unwanted out-of-memory errors, where size of the particular revision outgrows memory limit of your machine.
func (*OomStore) UpdateEntity ¶
Update metadata for an entity.
func (*OomStore) UpdateFeature ¶
Update metadata of a feature.
func (*OomStore) UpdateGroup ¶ added in v0.0.3
Update metadata of a feature group.
Source Files
Directories