oomstore

Documentation

Index

• type OomStore
  • func Create(ctx context.Context, opt types.OomStoreConfig) (*OomStore, error)
  • func NewOomStore(online online.Store, offline offline.Store, metadata metadata.Store) *OomStore
  • func Open(ctx context.Context, opt types.OomStoreConfig) (*OomStore, error)
  • 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 metadata.CreateEntityOpt) (int, error)
  • func (s *OomStore) CreateFeatureGroup(ctx context.Context, opt metadata.CreateFeatureGroupOpt) (int, error)
  • func (s *OomStore) ExportFeatureValues(ctx context.Context, opt types.ExportFeatureValuesOpt) ([]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) GetFeatureGroup(ctx context.Context, id int) (*types.FeatureGroup, error)
  • func (s *OomStore) GetFeatureGroupByName(ctx context.Context, name string) (*types.FeatureGroup, error)
  • func (s *OomStore) GetHistoricalFeatureValues(ctx context.Context, opt types.GetHistoricalFeatureValuesOpt) (*types.JoinResult, error)
  • func (s *OomStore) GetOnlineFeatureValues(ctx context.Context, opt types.GetOnlineFeatureValuesOpt) (*types.FeatureValues, 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) ImportBatchFeatures(ctx context.Context, opt types.ImportBatchFeaturesOpt) (int, error)
  • func (s *OomStore) ListEntity(ctx context.Context) types.EntityList
  • func (s *OomStore) ListFeature(ctx context.Context, opt metadata.ListFeatureOpt) types.FeatureList
  • func (s *OomStore) ListFeatureGroup(ctx context.Context, entityID *int) types.FeatureGroupList
  • func (s *OomStore) ListRevision(ctx context.Context, groupID *int) types.RevisionList
  • func (s *OomStore) MultiGetOnlineFeatureValues(ctx context.Context, opt types.MultiGetOnlineFeatureValuesOpt) (types.FeatureDataSet, error)
  • func (s *OomStore) Sync(ctx context.Context, opt types.SyncOpt) error
  • func (s *OomStore) UpdateEntity(ctx context.Context, opt metadata.UpdateEntityOpt) error
  • func (s *OomStore) UpdateFeature(ctx context.Context, opt types.UpdateFeatureOpt) error
  • func (s *OomStore) UpdateFeatureGroup(ctx context.Context, opt metadata.UpdateFeatureGroupOpt) error

Types

type OomStore

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

func Create

func Create(ctx context.Context, opt types.OomStoreConfig) (*OomStore, error)

func NewOomStore

func NewOomStore(online online.Store, offline offline.Store, metadata metadata.Store) *OomStore

func Open

func Open(ctx context.Context, opt types.OomStoreConfig) (*OomStore, error)

func (*OomStore) Close

func (s *OomStore) Close() error

func (*OomStore) CreateBatchFeature

func (s *OomStore) CreateBatchFeature(ctx context.Context, opt types.CreateFeatureOpt) (int, error)

func (*OomStore) CreateEntity

func (s *OomStore) CreateEntity(ctx context.Context, opt metadata.CreateEntityOpt) (int, error)

func (*OomStore) CreateFeatureGroup

func (s *OomStore) CreateFeatureGroup(ctx context.Context, opt metadata.CreateFeatureGroupOpt) (int, error)

func (*OomStore) ExportFeatureValues

func (s *OomStore) ExportFeatureValues(ctx context.Context, opt types.ExportFeatureValuesOpt) ([]string, <-chan *types.RawFeatureValueRecord, error)

func (*OomStore) GetEntity

func (s *OomStore) GetEntity(ctx context.Context, id int) (*types.Entity, error)

func (*OomStore) GetEntityByName

func (s *OomStore) GetEntityByName(ctx context.Context, name string) (*types.Entity, error)

func (*OomStore) GetFeature

func (s *OomStore) GetFeature(ctx context.Context, id int) (*types.Feature, error)

func (*OomStore) GetFeatureByName

func (s *OomStore) GetFeatureByName(ctx context.Context, name string) (*types.Feature, error)

func (*OomStore) GetFeatureGroup

func (s *OomStore) GetFeatureGroup(ctx context.Context, id int) (*types.FeatureGroup, error)

func (*OomStore) GetFeatureGroupByName

func (s *OomStore) GetFeatureGroupByName(ctx context.Context, name string) (*types.FeatureGroup, error)

func (*OomStore) GetHistoricalFeatureValues

func (s *OomStore) GetHistoricalFeatureValues(ctx context.Context, opt types.GetHistoricalFeatureValuesOpt) (*types.JoinResult, error)

GetHistoricalFeatureValues gets point-in-time feature values for each entity row; currently, this API only supports batch features.

func (*OomStore) GetOnlineFeatureValues

func (s *OomStore) GetOnlineFeatureValues(ctx context.Context, opt types.GetOnlineFeatureValuesOpt) (*types.FeatureValues, error)

func (*OomStore) GetRevision

func (s *OomStore) GetRevision(ctx context.Context, id int) (*types.Revision, error)

func (*OomStore) GetRevisionBy

func (s *OomStore) GetRevisionBy(ctx context.Context, groupID int, revision int64) (*types.Revision, error)

func (*OomStore) ImportBatchFeatures

func (s *OomStore) ImportBatchFeatures(ctx context.Context, opt types.ImportBatchFeaturesOpt) (int, error)

func (*OomStore) ListEntity

func (s *OomStore) ListEntity(ctx context.Context) types.EntityList

func (*OomStore) ListFeature

func (s *OomStore) ListFeature(ctx context.Context, opt metadata.ListFeatureOpt) types.FeatureList

func (*OomStore) ListFeatureGroup

func (s *OomStore) ListFeatureGroup(ctx context.Context, entityID *int) types.FeatureGroupList

func (*OomStore) ListRevision

func (s *OomStore) ListRevision(ctx context.Context, groupID *int) types.RevisionList

func (*OomStore) MultiGetOnlineFeatureValues

func (s *OomStore) MultiGetOnlineFeatureValues(ctx context.Context, opt types.MultiGetOnlineFeatureValuesOpt) (types.FeatureDataSet, error)

func (*OomStore) Sync

func (s *OomStore) Sync(ctx context.Context, opt types.SyncOpt) error

Move a certain feature group revision data from offline to online store

func (*OomStore) UpdateEntity

func (s *OomStore) UpdateEntity(ctx context.Context, opt metadata.UpdateEntityOpt) error

func (*OomStore) UpdateFeature

func (s *OomStore) UpdateFeature(ctx context.Context, opt types.UpdateFeatureOpt) error

func (*OomStore) UpdateFeatureGroup

func (s *OomStore) UpdateFeatureGroup(ctx context.Context, opt metadata.UpdateFeatureGroupOpt) error