serving

package
v0.9.2 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2021 License: Apache-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FeastServingType_name = map[int32]string{
		0: "FEAST_SERVING_TYPE_INVALID",
		1: "FEAST_SERVING_TYPE_ONLINE",
		2: "FEAST_SERVING_TYPE_BATCH",
	}
	FeastServingType_value = map[string]int32{
		"FEAST_SERVING_TYPE_INVALID": 0,
		"FEAST_SERVING_TYPE_ONLINE":  1,
		"FEAST_SERVING_TYPE_BATCH":   2,
	}
)

Enum value maps for FeastServingType.

View Source 
var (
	GetOnlineFeaturesResponse_FieldStatus_name = map[int32]string{
		0: "INVALID",
		1: "PRESENT",
		2: "NULL_VALUE",
		3: "NOT_FOUND",
		4: "OUTSIDE_MAX_AGE",
	}
	GetOnlineFeaturesResponse_FieldStatus_value = map[string]int32{
		"INVALID":         0,
		"PRESENT":         1,
		"NULL_VALUE":      2,
		"NOT_FOUND":       3,
		"OUTSIDE_MAX_AGE": 4,
	}
)

Enum value maps for GetOnlineFeaturesResponse_FieldStatus.

View Source 
var File_feast_serving_ServingService_proto protoreflect.FileDescriptor

Functions

func RegisterServingServiceServer 

func RegisterServingServiceServer(s *grpc.Server, srv ServingServiceServer)

Types

type FeastServingType 

type FeastServingType int32
const (
	FeastServingType_FEAST_SERVING_TYPE_INVALID FeastServingType = 0
	// Online serving receives entity data directly and synchronously and will
	// respond immediately.
	FeastServingType_FEAST_SERVING_TYPE_ONLINE FeastServingType = 1
	// Batch serving receives entity data asynchronously and orchestrates the
	// retrieval through a staging location.
	FeastServingType_FEAST_SERVING_TYPE_BATCH FeastServingType = 2
)

func (FeastServingType) Descriptor 

func (FeastServingType) Descriptor() protoreflect.EnumDescriptor

func (FeastServingType) Enum 

func (x FeastServingType) Enum() *FeastServingType

func (FeastServingType) EnumDescriptor deprecated 

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

Deprecated: Use FeastServingType.Descriptor instead.

func (FeastServingType) Number 

func (x FeastServingType) Number() protoreflect.EnumNumber

func (FeastServingType) String 

func (x FeastServingType) String() string

func (FeastServingType) Type 

func (FeastServingType) Type() protoreflect.EnumType

type FeatureReferenceV2 added in v0.8.0 

type FeatureReferenceV2 struct {

	// Name of the Feature Table to retrieve the feature from.
	FeatureTable string `protobuf:"bytes,1,opt,name=feature_table,json=featureTable,proto3" json:"feature_table,omitempty"`
	// Name of the Feature to retrieve the feature from.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureReferenceV2) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use FeatureReferenceV2.ProtoReflect.Descriptor instead.

func (*FeatureReferenceV2) GetFeatureTable added in v0.8.0 

func (x *FeatureReferenceV2) GetFeatureTable() string

func (*FeatureReferenceV2) GetName added in v0.8.0 

func (x *FeatureReferenceV2) GetName() string

func (*FeatureReferenceV2) ProtoMessage added in v0.8.0 

func (*FeatureReferenceV2) ProtoMessage()

func (*FeatureReferenceV2) ProtoReflect added in v0.8.0 

func (x *FeatureReferenceV2) ProtoReflect() protoreflect.Message

func (*FeatureReferenceV2) Reset added in v0.8.0 

func (x *FeatureReferenceV2) Reset()

func (*FeatureReferenceV2) String added in v0.8.0 

func (x *FeatureReferenceV2) String() string

type GetFeastServingInfoRequest 

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

func (*GetFeastServingInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetFeastServingInfoRequest.ProtoReflect.Descriptor instead.

func (*GetFeastServingInfoRequest) ProtoMessage 

func (*GetFeastServingInfoRequest) ProtoMessage()

func (*GetFeastServingInfoRequest) ProtoReflect 

func (x *GetFeastServingInfoRequest) ProtoReflect() protoreflect.Message

func (*GetFeastServingInfoRequest) Reset 

func (x *GetFeastServingInfoRequest) Reset()

func (*GetFeastServingInfoRequest) String 

func (x *GetFeastServingInfoRequest) String() string

type GetFeastServingInfoResponse 

type GetFeastServingInfoResponse struct {

	// Feast version of this serving deployment.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Type of serving deployment, either ONLINE or BATCH. Different store types support different
	// feature retrieval methods.
	Type FeastServingType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.serving.FeastServingType" json:"type,omitempty"`
	// Note: Batch specific options start from 10.
	// Staging location for this serving store, if any.
	JobStagingLocation string `protobuf:"bytes,10,opt,name=job_staging_location,json=jobStagingLocation,proto3" json:"job_staging_location,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeastServingInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetFeastServingInfoResponse.ProtoReflect.Descriptor instead.

func (*GetFeastServingInfoResponse) GetJobStagingLocation 

func (x *GetFeastServingInfoResponse) GetJobStagingLocation() string

func (*GetFeastServingInfoResponse) GetType 

func (x *GetFeastServingInfoResponse) GetType() FeastServingType

func (*GetFeastServingInfoResponse) GetVersion 

func (x *GetFeastServingInfoResponse) GetVersion() string

func (*GetFeastServingInfoResponse) ProtoMessage 

func (*GetFeastServingInfoResponse) ProtoMessage()

func (*GetFeastServingInfoResponse) ProtoReflect 

func (x *GetFeastServingInfoResponse) ProtoReflect() protoreflect.Message

func (*GetFeastServingInfoResponse) Reset 

func (x *GetFeastServingInfoResponse) Reset()

func (*GetFeastServingInfoResponse) String 

func (x *GetFeastServingInfoResponse) String() string

type GetOnlineFeaturesRequestV2 added in v0.8.0 

type GetOnlineFeaturesRequestV2 struct {

	// List of features that are being retrieved
	Features []*FeatureReferenceV2 `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"`
	// List of entity rows, containing entity id and timestamp data.
	// Used during retrieval of feature rows and for joining feature
	// rows into a final dataset
	EntityRows []*GetOnlineFeaturesRequestV2_EntityRow `protobuf:"bytes,2,rep,name=entity_rows,json=entityRows,proto3" json:"entity_rows,omitempty"`
	// Optional field to specify project name override. If specified, uses the
	// given project for retrieval. Overrides the projects specified in
	// Feature References if both are specified.
	Project string `protobuf:"bytes,5,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesRequestV2) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use GetOnlineFeaturesRequestV2.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesRequestV2) GetEntityRows added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2) GetEntityRows() []*GetOnlineFeaturesRequestV2_EntityRow

func (*GetOnlineFeaturesRequestV2) GetFeatures added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2) GetFeatures() []*FeatureReferenceV2

func (*GetOnlineFeaturesRequestV2) GetProject added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2) GetProject() string

func (*GetOnlineFeaturesRequestV2) ProtoMessage added in v0.8.0 

func (*GetOnlineFeaturesRequestV2) ProtoMessage()

func (*GetOnlineFeaturesRequestV2) ProtoReflect added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2) ProtoReflect() protoreflect.Message

func (*GetOnlineFeaturesRequestV2) Reset added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2) Reset()

func (*GetOnlineFeaturesRequestV2) String added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2) String() string

type GetOnlineFeaturesRequestV2_EntityRow added in v0.8.0 

type GetOnlineFeaturesRequestV2_EntityRow struct {

	// Request timestamp of this row. This value will be used,
	// together with maxAge, to determine feature staleness.
	Timestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Map containing mapping of entity name to entity value.
	Fields map[string]*types.Value `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesRequestV2_EntityRow) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use GetOnlineFeaturesRequestV2_EntityRow.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesRequestV2_EntityRow) GetFields added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2_EntityRow) GetFields() map[string]*types.Value

func (*GetOnlineFeaturesRequestV2_EntityRow) GetTimestamp added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2_EntityRow) GetTimestamp() *timestamp.Timestamp

func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoMessage added in v0.8.0 

func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoMessage()

func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoReflect added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2_EntityRow) ProtoReflect() protoreflect.Message

func (*GetOnlineFeaturesRequestV2_EntityRow) Reset added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2_EntityRow) Reset()

func (*GetOnlineFeaturesRequestV2_EntityRow) String added in v0.8.0 

func (x *GetOnlineFeaturesRequestV2_EntityRow) String() string

type GetOnlineFeaturesResponse 

type GetOnlineFeaturesResponse struct {

	// Feature values retrieved from feast.
	FieldValues []*GetOnlineFeaturesResponse_FieldValues `protobuf:"bytes,1,rep,name=field_values,json=fieldValues,proto3" json:"field_values,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesResponse) Descriptor deprecated 

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

Deprecated: Use GetOnlineFeaturesResponse.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesResponse) GetFieldValues 

func (x *GetOnlineFeaturesResponse) GetFieldValues() []*GetOnlineFeaturesResponse_FieldValues

func (*GetOnlineFeaturesResponse) ProtoMessage 

func (*GetOnlineFeaturesResponse) ProtoMessage()

func (*GetOnlineFeaturesResponse) ProtoReflect 

func (x *GetOnlineFeaturesResponse) ProtoReflect() protoreflect.Message

func (*GetOnlineFeaturesResponse) Reset 

func (x *GetOnlineFeaturesResponse) Reset()

func (*GetOnlineFeaturesResponse) String 

func (x *GetOnlineFeaturesResponse) String() string

type GetOnlineFeaturesResponse_FieldStatus added in v0.6.2 

type GetOnlineFeaturesResponse_FieldStatus int32
const (
	// Status is unset for this field.
	GetOnlineFeaturesResponse_INVALID GetOnlineFeaturesResponse_FieldStatus = 0
	// Field value is present for this field and age is within max age.
	GetOnlineFeaturesResponse_PRESENT GetOnlineFeaturesResponse_FieldStatus = 1
	// Values could be found for entity key and age is within max age, but
	// this field value is assigned a value on ingestion into feast.
	GetOnlineFeaturesResponse_NULL_VALUE GetOnlineFeaturesResponse_FieldStatus = 2
	// Entity key did not return any values as they do not exist in Feast.
	// This could suggest that the feature values have not yet been ingested
	// into feast or the ingestion failed.
	GetOnlineFeaturesResponse_NOT_FOUND GetOnlineFeaturesResponse_FieldStatus = 3
	// Values could be found for entity key, but field values are outside the maximum
	// allowable range.
	GetOnlineFeaturesResponse_OUTSIDE_MAX_AGE GetOnlineFeaturesResponse_FieldStatus = 4
)

func (GetOnlineFeaturesResponse_FieldStatus) Descriptor added in v0.6.2 

func (GetOnlineFeaturesResponse_FieldStatus) Descriptor() protoreflect.EnumDescriptor

func (GetOnlineFeaturesResponse_FieldStatus) Enum added in v0.6.2 

func (x GetOnlineFeaturesResponse_FieldStatus) Enum() *GetOnlineFeaturesResponse_FieldStatus

func (GetOnlineFeaturesResponse_FieldStatus) EnumDescriptor deprecated added in v0.6.2 

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

Deprecated: Use GetOnlineFeaturesResponse_FieldStatus.Descriptor instead.

func (GetOnlineFeaturesResponse_FieldStatus) Number added in v0.6.2 

func (x GetOnlineFeaturesResponse_FieldStatus) Number() protoreflect.EnumNumber

func (GetOnlineFeaturesResponse_FieldStatus) String added in v0.6.2 

func (x GetOnlineFeaturesResponse_FieldStatus) String() string

func (GetOnlineFeaturesResponse_FieldStatus) Type added in v0.6.2 

func (GetOnlineFeaturesResponse_FieldStatus) Type() protoreflect.EnumType

type GetOnlineFeaturesResponse_FieldValues 

type GetOnlineFeaturesResponse_FieldValues struct {

	// Map of feature or entity name to feature/entity values.
	// Timestamps are not returned in this response.
	Fields map[string]*types.Value `` /* 153-byte string literal not displayed */
	// Map of feature or entity name to feature/entity statuses/metadata.
	Statuses map[string]GetOnlineFeaturesResponse_FieldStatus `` /* 215-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesResponse_FieldValues) Descriptor deprecated 

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

Deprecated: Use GetOnlineFeaturesResponse_FieldValues.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesResponse_FieldValues) GetFields 

func (x *GetOnlineFeaturesResponse_FieldValues) GetFields() map[string]*types.Value

func (*GetOnlineFeaturesResponse_FieldValues) GetStatuses added in v0.6.2 

func (x *GetOnlineFeaturesResponse_FieldValues) GetStatuses() map[string]GetOnlineFeaturesResponse_FieldStatus

func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage 

func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage()

func (*GetOnlineFeaturesResponse_FieldValues) ProtoReflect 

func (x *GetOnlineFeaturesResponse_FieldValues) ProtoReflect() protoreflect.Message

func (*GetOnlineFeaturesResponse_FieldValues) Reset 

func (x *GetOnlineFeaturesResponse_FieldValues) Reset()

func (*GetOnlineFeaturesResponse_FieldValues) String 

func (x *GetOnlineFeaturesResponse_FieldValues) String() string

type ServingServiceClient 

type ServingServiceClient interface {
	// Get information about this Feast serving.
	GetFeastServingInfo(ctx context.Context, in *GetFeastServingInfoRequest, opts ...grpc.CallOption) (*GetFeastServingInfoResponse, error)
	// Get online features (v2) synchronously.
	GetOnlineFeaturesV2(ctx context.Context, in *GetOnlineFeaturesRequestV2, opts ...grpc.CallOption) (*GetOnlineFeaturesResponse, error)
}

ServingServiceClient is the client API for ServingService service.

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

func NewServingServiceClient 

func NewServingServiceClient(cc grpc.ClientConnInterface) ServingServiceClient

type ServingServiceServer 

type ServingServiceServer interface {
	// Get information about this Feast serving.
	GetFeastServingInfo(context.Context, *GetFeastServingInfoRequest) (*GetFeastServingInfoResponse, error)
	// Get online features (v2) synchronously.
	GetOnlineFeaturesV2(context.Context, *GetOnlineFeaturesRequestV2) (*GetOnlineFeaturesResponse, error)
}

ServingServiceServer is the server API for ServingService service.

type UnimplementedServingServiceServer 

type UnimplementedServingServiceServer struct {
}

UnimplementedServingServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedServingServiceServer) GetFeastServingInfo 

func (*UnimplementedServingServiceServer) GetFeastServingInfo(context.Context, *GetFeastServingInfoRequest) (*GetFeastServingInfoResponse, error)

func (*UnimplementedServingServiceServer) GetOnlineFeaturesV2 added in v0.8.0 

func (*UnimplementedServingServiceServer) GetOnlineFeaturesV2(context.Context, *GetOnlineFeaturesRequestV2) (*GetOnlineFeaturesResponse, 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.