embedded

Documentation

Index

• type DataTable
• type LoggingOptions
• type OnlineFeatureService
  • func NewOnlineFeatureService(conf *OnlineFeatureServiceConfig, ...) *OnlineFeatureService
  • func (s *OnlineFeatureService) CheckForInstantiationError() error
  • func (s *OnlineFeatureService) GetEntityTypesMap(featureRefs []string) (map[string]int32, error)
  • func (s *OnlineFeatureService) GetEntityTypesMapByFeatureService(featureServiceName string) (map[string]int32, error)
  • func (s *OnlineFeatureService) GetOnlineFeatures(featureRefs []string, featureServiceName string, entities DataTable, ...) error
  • func (s *OnlineFeatureService) StartGprcServer(host string, port int) error
  • func (s *OnlineFeatureService) StartGprcServerWithLogging(host string, port int, ...) error
  • func (s *OnlineFeatureService) StartGprcServerWithLoggingDefaultOpts(host string, port int, ...) error
  • func (s *OnlineFeatureService) StartHttpServer(host string, port int) error
  • func (s *OnlineFeatureService) StartHttpServerWithLogging(host string, port int, ...) error
  • func (s *OnlineFeatureService) StartHttpServerWithLoggingDefaultOpts(host string, port int, ...) error
  • func (s *OnlineFeatureService) StopGrpcServer()
  • func (s *OnlineFeatureService) StopHttpServer()
• type OnlineFeatureServiceConfig

Types

type DataTable

type DataTable struct {
	DataPtr   uintptr
	SchemaPtr uintptr
}

type LoggingOptions

type LoggingOptions struct {
	ChannelCapacity int
	EmitTimeout     time.Duration
	WriteInterval   time.Duration
	FlushInterval   time.Duration
}

LoggingOptions is a public (embedded) copy of logging.LoggingOptions struct. See logging.LoggingOptions for properties description

type OnlineFeatureService

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

func NewOnlineFeatureService

func NewOnlineFeatureService(conf *OnlineFeatureServiceConfig, transformationCallback transformation.TransformationCallback) *OnlineFeatureService

func (*OnlineFeatureService) CheckForInstantiationError

func (s *OnlineFeatureService) CheckForInstantiationError() error

func (*OnlineFeatureService) GetEntityTypesMap

func (s *OnlineFeatureService) GetEntityTypesMap(featureRefs []string) (map[string]int32, error)

func (*OnlineFeatureService) GetEntityTypesMapByFeatureService

func (s *OnlineFeatureService) GetEntityTypesMapByFeatureService(featureServiceName string) (map[string]int32, error)

func (*OnlineFeatureService) GetOnlineFeatures

func (s *OnlineFeatureService) GetOnlineFeatures(
	featureRefs []string,
	featureServiceName string,
	entities DataTable,
	requestData DataTable,
	fullFeatureNames bool,
	output DataTable) error

func (*OnlineFeatureService) StartGprcServer

func (s *OnlineFeatureService) StartGprcServer(host string, port int) error

StartGprcServer starts gRPC server with disabled feature logging and blocks the thread

func (*OnlineFeatureService) StartGprcServerWithLogging

func (s *OnlineFeatureService) StartGprcServerWithLogging(host string, port int, writeLoggedFeaturesCallback logging.OfflineStoreWriteCallback, loggingOpts LoggingOptions) error

StartGprcServerWithLogging starts gRPC server with enabled feature logging Caller of this function must provide Python callback to flush buffered logs as well as logging configuration (loggingOpts)

func (*OnlineFeatureService) StartGprcServerWithLoggingDefaultOpts

func (s *OnlineFeatureService) StartGprcServerWithLoggingDefaultOpts(host string, port int, writeLoggedFeaturesCallback logging.OfflineStoreWriteCallback) error

StartGprcServerWithLoggingDefaultOpts starts gRPC server with enabled feature logging but default configuration for logging Caller of this function must provide Python callback to flush buffered logs

func (*OnlineFeatureService) StartHttpServer

func (s *OnlineFeatureService) StartHttpServer(host string, port int) error

StartHttpServer starts HTTP server with disabled feature logging and blocks the thread

func (*OnlineFeatureService) StartHttpServerWithLogging

func (s *OnlineFeatureService) StartHttpServerWithLogging(host string, port int, writeLoggedFeaturesCallback logging.OfflineStoreWriteCallback, loggingOpts LoggingOptions) error

StartHttpServerWithLogging starts HTTP server with enabled feature logging Caller of this function must provide Python callback to flush buffered logs as well as logging configuration (loggingOpts)

func (*OnlineFeatureService) StartHttpServerWithLoggingDefaultOpts

func (s *OnlineFeatureService) StartHttpServerWithLoggingDefaultOpts(host string, port int, writeLoggedFeaturesCallback logging.OfflineStoreWriteCallback) error

StartHttpServerWithLoggingDefaultOpts starts HTTP server with enabled feature logging but default configuration for logging Caller of this function must provide Python callback to flush buffered logs

func (*OnlineFeatureService) StopGrpcServer

func (s *OnlineFeatureService) StopGrpcServer()

func (*OnlineFeatureService) StopHttpServer

func (s *OnlineFeatureService) StopHttpServer()

type OnlineFeatureServiceConfig

type OnlineFeatureServiceConfig struct {
	RepoPath   string
	RepoConfig string
}