registry

Documentation

Index

• Variables
• type FileRegistryStore
  • func NewFileRegistryStore(config *RegistryConfig, repoPath string) *FileRegistryStore
  • func (r *FileRegistryStore) GetRegistryProto() (*core.Registry, error)
  • func (r *FileRegistryStore) Teardown() error
  • func (r *FileRegistryStore) UpdateRegistryProto(rp *core.Registry) error
• type Registry
  • func NewRegistry(registryConfig *RegistryConfig, repoPath string, project string) (*Registry, error)
  • func (r *Registry) GetEntity(project, entityName string) (*model.Entity, error)
  • func (r *Registry) GetFeatureService(project, featureServiceName string) (*model.FeatureService, error)
  • func (r *Registry) GetFeatureView(project, featureViewName string) (*model.FeatureView, error)
  • func (r *Registry) GetOnDemandFeatureView(project, onDemandFeatureViewName string) (*model.OnDemandFeatureView, error)
  • func (r *Registry) GetStreamFeatureView(project, streamFeatureViewName string) (*model.FeatureView, error)
  • func (r *Registry) InitializeRegistry() error
  • func (r *Registry) ListEntities(project string) ([]*model.Entity, error)
  • func (r *Registry) ListFeatureServices(project string) ([]*model.FeatureService, error)
  • func (r *Registry) ListFeatureViews(project string) ([]*model.FeatureView, error)
  • func (r *Registry) ListOnDemandFeatureViews(project string) ([]*model.OnDemandFeatureView, error)
  • func (r *Registry) ListStreamFeatureViews(project string) ([]*model.FeatureView, error)
  • func (r *Registry) RefreshRegistryOnInterval()
• type RegistryConfig
• type RegistryStore
• type RepoConfig
  • func NewRepoConfigFromFile(repoPath string) (*RepoConfig, error)
  • func NewRepoConfigFromJSON(repoPath, configJSON string) (*RepoConfig, error)
  • func (r *RepoConfig) GetLoggingOptions() (*logging.LoggingOptions, error)
  • func (r *RepoConfig) GetRegistryConfig() (*RegistryConfig, error)

Variables

var REGISTRY_SCHEMA_VERSION string = "1"

var REGISTRY_STORE_CLASS_FOR_SCHEME map[string]string = map[string]string{
	"gs":   "GCSRegistryStore",
	"s3":   "S3RegistryStore",
	"file": "FileRegistryStore",
	"":     "FileRegistryStore",
}

Types

type FileRegistryStore

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

A FileRegistryStore is a file-based implementation of the RegistryStore interface.

func NewFileRegistryStore

func NewFileRegistryStore(config *RegistryConfig, repoPath string) *FileRegistryStore

NewFileRegistryStore creates a FileRegistryStore with the given configuration and infers the file path from the repo path and registry path.

func (*FileRegistryStore) GetRegistryProto

func (r *FileRegistryStore) GetRegistryProto() (*core.Registry, error)

GetRegistryProto reads and parses the registry proto from the file path.

func (*FileRegistryStore) Teardown

func (r *FileRegistryStore) Teardown() error

func (*FileRegistryStore) UpdateRegistryProto

func (r *FileRegistryStore) UpdateRegistryProto(rp *core.Registry) error

type Registry

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

func NewRegistry

func NewRegistry(registryConfig *RegistryConfig, repoPath string, project string) (*Registry, error)

func (*Registry) GetEntity

func (r *Registry) GetEntity(project, entityName string) (*model.Entity, error)

func (*Registry) GetFeatureService

func (r *Registry) GetFeatureService(project, featureServiceName string) (*model.FeatureService, error)

func (*Registry) GetFeatureView

func (r *Registry) GetFeatureView(project, featureViewName string) (*model.FeatureView, error)

func (*Registry) GetOnDemandFeatureView

func (r *Registry) GetOnDemandFeatureView(project, onDemandFeatureViewName string) (*model.OnDemandFeatureView, error)

func (*Registry) GetStreamFeatureView

func (r *Registry) GetStreamFeatureView(project, streamFeatureViewName string) (*model.FeatureView, error)

func (*Registry) InitializeRegistry

func (r *Registry) InitializeRegistry() error

func (*Registry) ListEntities

func (r *Registry) ListEntities(project string) ([]*model.Entity, error)

func (*Registry) ListFeatureServices

func (r *Registry) ListFeatureServices(project string) ([]*model.FeatureService, error)

func (*Registry) ListFeatureViews

func (r *Registry) ListFeatureViews(project string) ([]*model.FeatureView, error)

func (*Registry) ListOnDemandFeatureViews

func (r *Registry) ListOnDemandFeatureViews(project string) ([]*model.OnDemandFeatureView, error)

func (*Registry) ListStreamFeatureViews

func (r *Registry) ListStreamFeatureViews(project string) ([]*model.FeatureView, error)

func (*Registry) RefreshRegistryOnInterval

func (r *Registry) RefreshRegistryOnInterval()

type RegistryConfig

type RegistryConfig struct {
	RegistryStoreType string `json:"registry_store_type"`
	Path              string `json:"path"`
	ClientId          string `json:"client_id" default:"Unknown"`
	CacheTtlSeconds   int64  `json:"cache_ttl_seconds" default:"600"`
}

type RegistryStore

type RegistryStore interface {
	GetRegistryProto() (*core.Registry, error)
	UpdateRegistryProto(*core.Registry) error
	Teardown() error
}

A RegistryStore is a storage backend for the Feast registry.

type RepoConfig

type RepoConfig struct {
	// Feast project name
	Project string `json:"project"`
	// Feast provider name
	Provider string `json:"provider"`
	// Path to the registry. Custom registry loaders are not yet supported
	// Registry string `json:"registry"`
	Registry interface{} `json:"registry"`
	// Online store config
	OnlineStore map[string]interface{} `json:"online_store"`
	// Offline store config
	OfflineStore map[string]interface{} `json:"offline_store"`
	// Feature server config (currently unrelated to Go server)
	FeatureServer map[string]interface{} `json:"feature_server"`
	// Feature flags for experimental features
	Flags map[string]interface{} `json:"flags"`
	// RepoPath
	RepoPath string `json:"repo_path"`
	// EntityKeySerializationVersion
	EntityKeySerializationVersion int64 `json:"entity_key_serialization_version"`
}

func NewRepoConfigFromFile

func NewRepoConfigFromFile(repoPath string) (*RepoConfig, error)

NewRepoConfigFromFile reads the `feature_store.yaml` file in the repo path and converts it into a RepoConfig struct.

func NewRepoConfigFromJSON

func NewRepoConfigFromJSON(repoPath, configJSON string) (*RepoConfig, error)

NewRepoConfigFromJSON converts a JSON string into a RepoConfig struct and also sets the repo path.

func (*RepoConfig) GetLoggingOptions

func (r *RepoConfig) GetLoggingOptions() (*logging.LoggingOptions, error)

func (*RepoConfig) GetRegistryConfig

func (r *RepoConfig) GetRegistryConfig() (*RegistryConfig, error)