oomstore

Documentation

Index

• type OomStore
  • func Create(ctx context.Context, opt types.OomStoreConfig) (*OomStore, error)
  • func Open(ctx context.Context, opt types.OomStoreConfig) (*OomStore, error)
  • func TEST__New(online online.Store, offline offline.Store, metadata metadata.Store) *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) 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) 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

Types

type OomStore

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

func Create

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

func Open

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

func TEST__New

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

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 types.CreateEntityOpt) (int, error)

func (*OomStore) CreateGroup

func (s *OomStore) CreateGroup(ctx context.Context, opt types.CreateGroupOpt) (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) GetGroup

func (s *OomStore) GetGroup(ctx context.Context, id int) (*types.Group, error)

func (*OomStore) GetGroupByName

func (s *OomStore) GetGroupByName(ctx context.Context, name string) (*types.Group, 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) Import

func (s *OomStore) Import(ctx context.Context, opt types.ImportOpt) (int, error)

func (*OomStore) Join

func (s *OomStore) Join(ctx context.Context, opt types.JoinOpt) (*types.JoinResult, error)

Join gets point-in-time 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

func (*OomStore) ListFeature

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

func (*OomStore) ListGroup

func (s *OomStore) ListGroup(ctx context.Context, entityID *int) types.GroupList

func (*OomStore) ListRevision

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

func (*OomStore) OnlineGet

func (s *OomStore) OnlineGet(ctx context.Context, opt types.OnlineGetOpt) (*types.FeatureValues, error)

func (*OomStore) OnlineMultiGet

func (s *OomStore) OnlineMultiGet(ctx context.Context, opt types.OnlineMultiGetOpt) (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 types.UpdateEntityOpt) error

func (*OomStore) UpdateFeature

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

func (*OomStore) UpdateGroup

func (s *OomStore) UpdateGroup(ctx context.Context, opt types.UpdateGroupOpt) error