Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterServingAPIServer

func RegisterServingAPIServer(s *grpc.Server, srv ServingAPIServer)

Types

type Entity

type Entity struct {
	// map of feature ID and its feature value.
	Features             map[string]*FeatureValue `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*Entity) Descriptor

func (*Entity) Descriptor() ([]byte, []int)

func (*Entity) GetFeatures

func (m *Entity) GetFeatures() map[string]*FeatureValue

func (*Entity) ProtoMessage

func (*Entity) ProtoMessage()

func (*Entity) Reset

func (m *Entity) Reset()

func (*Entity) String

func (m *Entity) String() string

func (*Entity) XXX_DiscardUnknown

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal

func (m *Entity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Entity) XXX_Merge

func (m *Entity) XXX_Merge(src proto.Message)

func (*Entity) XXX_Size

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal

func (m *Entity) XXX_Unmarshal(b []byte) error

type FeatureValue

type FeatureValue struct {
	// value of feature
	Value *types.Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// timestamp of the feature
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*FeatureValue) Descriptor

func (*FeatureValue) Descriptor() ([]byte, []int)

func (*FeatureValue) GetTimestamp

func (m *FeatureValue) GetTimestamp() *timestamp.Timestamp

func (*FeatureValue) GetValue

func (m *FeatureValue) GetValue() *types.Value

func (*FeatureValue) ProtoMessage

func (*FeatureValue) ProtoMessage()

func (*FeatureValue) Reset

func (m *FeatureValue) Reset()

func (*FeatureValue) String

func (m *FeatureValue) String() string

func (*FeatureValue) XXX_DiscardUnknown

func (m *FeatureValue) XXX_DiscardUnknown()

func (*FeatureValue) XXX_Marshal

func (m *FeatureValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeatureValue) XXX_Merge

func (m *FeatureValue) XXX_Merge(src proto.Message)

func (*FeatureValue) XXX_Size

func (m *FeatureValue) XXX_Size() int

func (*FeatureValue) XXX_Unmarshal

func (m *FeatureValue) XXX_Unmarshal(b []byte) error

type QueryFeaturesRequest

type QueryFeaturesRequest struct {
	// e.g. "driver", "customer", "city".
	EntityName string `protobuf:"bytes,1,opt,name=entityName,proto3" json:"entityName,omitempty"`
	// List of entity ID.
	EntityId []string `protobuf:"bytes,2,rep,name=entityId,proto3" json:"entityId,omitempty"`
	// List of feature ID.
	// feature ID is in the form of [entity_name].[feature_name]
	// e.g: "driver.day.total_accepted_booking"
	// all requested feature ID shall have same entity name.
	FeatureId            []string `protobuf:"bytes,3,rep,name=featureId,proto3" json:"featureId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryFeaturesRequest) Descriptor

func (*QueryFeaturesRequest) Descriptor() ([]byte, []int)

func (*QueryFeaturesRequest) GetEntityId

func (m *QueryFeaturesRequest) GetEntityId() []string

func (*QueryFeaturesRequest) GetEntityName

func (m *QueryFeaturesRequest) GetEntityName() string

func (*QueryFeaturesRequest) GetFeatureId

func (m *QueryFeaturesRequest) GetFeatureId() []string

func (*QueryFeaturesRequest) ProtoMessage

func (*QueryFeaturesRequest) ProtoMessage()

func (*QueryFeaturesRequest) Reset

func (m *QueryFeaturesRequest) Reset()

func (*QueryFeaturesRequest) String

func (m *QueryFeaturesRequest) String() string

func (*QueryFeaturesRequest) XXX_DiscardUnknown

func (m *QueryFeaturesRequest) XXX_DiscardUnknown()

func (*QueryFeaturesRequest) XXX_Marshal

func (m *QueryFeaturesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryFeaturesRequest) XXX_Merge

func (m *QueryFeaturesRequest) XXX_Merge(src proto.Message)

func (*QueryFeaturesRequest) XXX_Size

func (m *QueryFeaturesRequest) XXX_Size() int

func (*QueryFeaturesRequest) XXX_Unmarshal

func (m *QueryFeaturesRequest) XXX_Unmarshal(b []byte) error

type QueryFeaturesResponse

type QueryFeaturesResponse struct {
	// Entity name of the response
	EntityName string `protobuf:"bytes,1,opt,name=entityName,proto3" json:"entityName,omitempty"`
	// map of entity ID and its entity's properties.
	Entities             map[string]*Entity `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*QueryFeaturesResponse) Descriptor

func (*QueryFeaturesResponse) Descriptor() ([]byte, []int)

func (*QueryFeaturesResponse) GetEntities

func (m *QueryFeaturesResponse) GetEntities() map[string]*Entity

func (*QueryFeaturesResponse) GetEntityName

func (m *QueryFeaturesResponse) GetEntityName() string

func (*QueryFeaturesResponse) ProtoMessage

func (*QueryFeaturesResponse) ProtoMessage()

func (*QueryFeaturesResponse) Reset

func (m *QueryFeaturesResponse) Reset()

func (*QueryFeaturesResponse) String

func (m *QueryFeaturesResponse) String() string

func (*QueryFeaturesResponse) XXX_DiscardUnknown

func (m *QueryFeaturesResponse) XXX_DiscardUnknown()

func (*QueryFeaturesResponse) XXX_Marshal

func (m *QueryFeaturesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryFeaturesResponse) XXX_Merge

func (m *QueryFeaturesResponse) XXX_Merge(src proto.Message)

func (*QueryFeaturesResponse) XXX_Size

func (m *QueryFeaturesResponse) XXX_Size() int

func (*QueryFeaturesResponse) XXX_Unmarshal

func (m *QueryFeaturesResponse) XXX_Unmarshal(b []byte) error

type ServingAPIClient

type ServingAPIClient interface {
	// Query features from Feast serving storage
	QueryFeatures(ctx context.Context, in *QueryFeaturesRequest, opts ...grpc.CallOption) (*QueryFeaturesResponse, error)
}

    ServingAPIClient is the client API for ServingAPI service.

    For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

    func NewServingAPIClient

    func NewServingAPIClient(cc *grpc.ClientConn) ServingAPIClient

    type ServingAPIServer

    type ServingAPIServer interface {
    	// Query features from Feast serving storage
    	QueryFeatures(context.Context, *QueryFeaturesRequest) (*QueryFeaturesResponse, error)
    }

      ServingAPIServer is the server API for ServingAPI service.

      type UnimplementedServingAPIServer

      type UnimplementedServingAPIServer struct {
      }

        UnimplementedServingAPIServer can be embedded to have forward compatible implementations.

        func (*UnimplementedServingAPIServer) QueryFeatures

        Source Files