feast

Nov 11, 2020

Changes in this version

type GrpcClient

+ func NewSecureGrpcClientWithDialOptions(host string, port int, security SecurityConfig, opts ...grpc.DialOption) (*GrpcClient, error)

Dec 14, 2020

Changes in this version

type GrpcClient

+ func NewTraceableGrpcClient(host string, port int, tracer opentracing.Tracer) (*GrpcClient, error)

Sep 16, 2020

Changes in this version

+ type Credential struct

+ func NewGoogleCredential(audience string) (*Credential, error)

+ func NewOAuthCredential(audience string, clientId string, clientSecret string, endpointURL *url.URL) *Credential

+ func NewStaticCredential(token string) *Credential

+ func (provider *Credential) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)

+ func (provider *Credential) RequireTransportSecurity() bool

type GrpcClient

+ func NewSecureGrpcClient(host string, port int, security SecurityConfig) (*GrpcClient, error)

+ type SecurityConfig struct

+ Credential *Credential

+ EnableTLS bool

+ TLSCertPath string

Aug 24, 2020

Changes in this version

type OnlineFeaturesRequest

+ OmitEntities bool

type OnlineFeaturesResponse

+ func (r OnlineFeaturesResponse) Statuses() []map[string]serving.GetOnlineFeaturesResponse_FieldStatus

May 19, 2020

Changes in this version

+ var ErrFeatureNotFound = "Feature %s not found in response."

+ var ErrInvalidFeatureRef = ...

+ var ErrLengthMismatch = "Length mismatch; number of na values (%d) not equal to number of features requested (%d)."

+ var ErrTypeMismatch = "Requested output of type %s does not match type of feature value returned."

+ func BoolVal(val bool) *types.Value

+ func BytesVal(val []byte) *types.Value

+ func DoubleVal(val float64) *types.Value

+ func FloatVal(val float32) *types.Value

+ func Int32Val(val int32) *types.Value

+ func Int64Val(val int64) *types.Value

+ func StrVal(val string) *types.Value

+ type Client interface

+ Close func() error

+ GetFeastServingInfo func(ctx context.Context, in *serving.GetFeastServingInfoRequest) (*serving.GetFeastServingInfoResponse, error)

+ GetOnlineFeatures func(ctx context.Context, req *OnlineFeaturesRequest) (*OnlineFeaturesResponse, error)

+ type GrpcClient struct

+ func NewGrpcClient(host string, port int) (*GrpcClient, error)

+ func (fc *GrpcClient) Close() error

+ func (fc *GrpcClient) GetFeastServingInfo(ctx context.Context, in *serving.GetFeastServingInfoRequest) (*serving.GetFeastServingInfoResponse, error)

+ func (fc *GrpcClient) GetOnlineFeatures(ctx context.Context, req *OnlineFeaturesRequest) (*OnlineFeaturesResponse, error)

+ type OnlineFeaturesRequest struct

+ Entities []Row

+ Features []string

+ Project string

+ type OnlineFeaturesResponse struct

+ RawResponse *serving.GetOnlineFeaturesResponse

+ func (r OnlineFeaturesResponse) Float64Arrays(order []string, fillNa []float64) ([][]float64, error)

+ func (r OnlineFeaturesResponse) Int64Arrays(order []string, fillNa []int64) ([][]int64, error)

+ func (r OnlineFeaturesResponse) Rows() []Row

+ type Row map[string]*types.Value