serving

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 11, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RequestType_name = map[int32]string{
	0: "LAST",
	1: "LIST",
}
View Source 
var RequestType_value = map[string]int32{
	"LAST": 0,
	"LIST": 1,
}

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]*FeatureValueList `` /* 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]*FeatureValueList

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 (dst *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 FeatureValueList 

type FeatureValueList struct {
	// list of feature value
	// if "type" in "requestDetail" is "LAST", then the length will always be 1.
	// if "type" in "requestDetail" is "LIST", then the length is <= "limit".
	ValueList *types.ValueList `protobuf:"bytes,1,opt,name=valueList,proto3" json:"valueList,omitempty"`
	// list of timestamp of the value.
	// the i-th timestamps correspond to the i-th value.
	TimestampList        *types.TimestampList `protobuf:"bytes,2,opt,name=timestampList,proto3" json:"timestampList,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*FeatureValueList) Descriptor 

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

func (*FeatureValueList) GetTimestampList 

func (m *FeatureValueList) GetTimestampList() *types.TimestampList

func (*FeatureValueList) GetValueList 

func (m *FeatureValueList) GetValueList() *types.ValueList

func (*FeatureValueList) ProtoMessage 

func (*FeatureValueList) ProtoMessage()

func (*FeatureValueList) Reset 

func (m *FeatureValueList) Reset()

func (*FeatureValueList) String 

func (m *FeatureValueList) String() string

func (*FeatureValueList) XXX_DiscardUnknown 

func (m *FeatureValueList) XXX_DiscardUnknown()

func (*FeatureValueList) XXX_Marshal 

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

func (*FeatureValueList) XXX_Merge 

func (dst *FeatureValueList) XXX_Merge(src proto.Message)

func (*FeatureValueList) XXX_Size 

func (m *FeatureValueList) XXX_Size() int

func (*FeatureValueList) XXX_Unmarshal 

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

type QueryFeatures 

type QueryFeatures struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryFeatures) Descriptor 

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

func (*QueryFeatures) ProtoMessage 

func (*QueryFeatures) ProtoMessage()

func (*QueryFeatures) Reset 

func (m *QueryFeatures) Reset()

func (*QueryFeatures) String 

func (m *QueryFeatures) String() string

func (*QueryFeatures) XXX_DiscardUnknown 

func (m *QueryFeatures) XXX_DiscardUnknown()

func (*QueryFeatures) XXX_Marshal 

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

func (*QueryFeatures) XXX_Merge 

func (dst *QueryFeatures) XXX_Merge(src proto.Message)

func (*QueryFeatures) XXX_Size 

func (m *QueryFeatures) XXX_Size() int

func (*QueryFeatures) XXX_Unmarshal 

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

type QueryFeatures_Request 

type QueryFeatures_Request 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 request details, contains: featureId, type of query, and limit.
	RequestDetails []*RequestDetail `protobuf:"bytes,3,rep,name=requestDetails,proto3" json:"requestDetails,omitempty"`
	// Filter specifying only to retrieve features having timestamp within this range.
	TimestampRange       *TimestampRange `protobuf:"bytes,4,opt,name=timestampRange,proto3" json:"timestampRange,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*QueryFeatures_Request) Descriptor 

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

func (*QueryFeatures_Request) GetEntityId 

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

func (*QueryFeatures_Request) GetEntityName 

func (m *QueryFeatures_Request) GetEntityName() string

func (*QueryFeatures_Request) GetRequestDetails 

func (m *QueryFeatures_Request) GetRequestDetails() []*RequestDetail

func (*QueryFeatures_Request) GetTimestampRange 

func (m *QueryFeatures_Request) GetTimestampRange() *TimestampRange

func (*QueryFeatures_Request) ProtoMessage 

func (*QueryFeatures_Request) ProtoMessage()

func (*QueryFeatures_Request) Reset 

func (m *QueryFeatures_Request) Reset()

func (*QueryFeatures_Request) String 

func (m *QueryFeatures_Request) String() string

func (*QueryFeatures_Request) XXX_DiscardUnknown 

func (m *QueryFeatures_Request) XXX_DiscardUnknown()

func (*QueryFeatures_Request) XXX_Marshal 

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

func (*QueryFeatures_Request) XXX_Merge 

func (dst *QueryFeatures_Request) XXX_Merge(src proto.Message)

func (*QueryFeatures_Request) XXX_Size 

func (m *QueryFeatures_Request) XXX_Size() int

func (*QueryFeatures_Request) XXX_Unmarshal 

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

type QueryFeatures_Response 

type QueryFeatures_Response struct {
	// e.g. "driver", "customer", "city".
	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 (*QueryFeatures_Response) Descriptor 

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

func (*QueryFeatures_Response) GetEntities 

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

func (*QueryFeatures_Response) GetEntityName 

func (m *QueryFeatures_Response) GetEntityName() string

func (*QueryFeatures_Response) ProtoMessage 

func (*QueryFeatures_Response) ProtoMessage()

func (*QueryFeatures_Response) Reset 

func (m *QueryFeatures_Response) Reset()

func (*QueryFeatures_Response) String 

func (m *QueryFeatures_Response) String() string

func (*QueryFeatures_Response) XXX_DiscardUnknown 

func (m *QueryFeatures_Response) XXX_DiscardUnknown()

func (*QueryFeatures_Response) XXX_Marshal 

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

func (*QueryFeatures_Response) XXX_Merge 

func (dst *QueryFeatures_Response) XXX_Merge(src proto.Message)

func (*QueryFeatures_Response) XXX_Size 

func (m *QueryFeatures_Response) XXX_Size() int

func (*QueryFeatures_Response) XXX_Unmarshal 

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

type RequestDetail 

type RequestDetail struct {
	// feature ID to be included in the query.
	// feature ID is in the form of [entity_name].[granularity].[feature_name]
	// e.g: "driver.day.total_accepted_booking"
	// all requested feature ID shall have same entity name.
	FeatureId string `protobuf:"bytes,1,opt,name=featureId,proto3" json:"featureId,omitempty"`
	// request type either LAST or LIST.
	// LAST : return only the latest value based on timestamp.
	// LIST : return list of historical data sorted by timestamp.
	Type RequestType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.serving.RequestType" json:"type,omitempty"`
	// only applicable to LIST.
	// length of the returned list <= limit.
	// default = 0
	Limit                int32    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestDetail) Descriptor 

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

func (*RequestDetail) GetFeatureId 

func (m *RequestDetail) GetFeatureId() string

func (*RequestDetail) GetLimit 

func (m *RequestDetail) GetLimit() int32

func (*RequestDetail) GetType 

func (m *RequestDetail) GetType() RequestType

func (*RequestDetail) ProtoMessage 

func (*RequestDetail) ProtoMessage()

func (*RequestDetail) Reset 

func (m *RequestDetail) Reset()

func (*RequestDetail) String 

func (m *RequestDetail) String() string

func (*RequestDetail) XXX_DiscardUnknown 

func (m *RequestDetail) XXX_DiscardUnknown()

func (*RequestDetail) XXX_Marshal 

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

func (*RequestDetail) XXX_Merge 

func (dst *RequestDetail) XXX_Merge(src proto.Message)

func (*RequestDetail) XXX_Size 

func (m *RequestDetail) XXX_Size() int

func (*RequestDetail) XXX_Unmarshal 

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

type RequestType 

type RequestType int32
const (
	// LAST : return only the latest value based on timestamp. (default)
	RequestType_LAST RequestType = 0
	// LIST : return list of historical data sorted by timestamp.
	RequestType_LIST RequestType = 1
)

func (RequestType) EnumDescriptor 

func (RequestType) EnumDescriptor() ([]byte, []int)

func (RequestType) String 

func (x RequestType) String() string

type ServingAPIClient 

type ServingAPIClient interface {
	// Query features from Feast
	QueryFeatures(ctx context.Context, in *QueryFeatures_Request, opts ...grpc.CallOption) (*QueryFeatures_Response, 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
	QueryFeatures(context.Context, *QueryFeatures_Request) (*QueryFeatures_Response, error)
}

ServingAPIServer is the server API for ServingAPI service.

type TimestampRange 

type TimestampRange struct {
	// start time of the range query.
	Start *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	// end time of the range query.
	End                  *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

range of timestamp for querying valid timestamp range is having start <= end

func (*TimestampRange) Descriptor 

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

func (*TimestampRange) GetEnd 

func (m *TimestampRange) GetEnd() *timestamp.Timestamp

func (*TimestampRange) GetStart 

func (m *TimestampRange) GetStart() *timestamp.Timestamp

func (*TimestampRange) ProtoMessage 

func (*TimestampRange) ProtoMessage()

func (*TimestampRange) Reset 

func (m *TimestampRange) Reset()

func (*TimestampRange) String 

func (m *TimestampRange) String() string

func (*TimestampRange) XXX_DiscardUnknown 

func (m *TimestampRange) XXX_DiscardUnknown()

func (*TimestampRange) XXX_Marshal 

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

func (*TimestampRange) XXX_Merge 

func (dst *TimestampRange) XXX_Merge(src proto.Message)

func (*TimestampRange) XXX_Size 

func (m *TimestampRange) XXX_Size() int

func (*TimestampRange) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.