serving

package
v0.9.4 Latest Latest
Warning

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

Go to latest
Published: May 17, 2022 License: Apache-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for FieldStatus.

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 File_feast_serving_ServingService_proto protoreflect.FileDescriptor
View Source
var ServingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "feast.serving.ServingService",
	HandlerType: (*ServingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFeastServingInfo",
			Handler:    _ServingService_GetFeastServingInfo_Handler,
		},
		{
			MethodName: "GetOnlineFeaturesV2",
			Handler:    _ServingService_GetOnlineFeaturesV2_Handler,
		},
		{
			MethodName: "GetOnlineFeatures",
			Handler:    _ServingService_GetOnlineFeatures_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "feast/serving/ServingService.proto",
}

ServingService_ServiceDesc is the grpc.ServiceDesc for ServingService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterServingServiceServer

func RegisterServingServiceServer(s grpc.ServiceRegistrar, 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) Enum

func (FeastServingType) EnumDescriptor deprecated

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

Deprecated: Use FeastServingType.Descriptor instead.

func (FeastServingType) Number

func (FeastServingType) String

func (x FeastServingType) String() string

func (FeastServingType) Type

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 FieldList added in v0.9.4

type FieldList struct {
	Val []string `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*FieldList) Descriptor deprecated added in v0.9.4

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

Deprecated: Use FieldList.ProtoReflect.Descriptor instead.

func (*FieldList) GetVal added in v0.9.4

func (x *FieldList) GetVal() []string

func (*FieldList) ProtoMessage added in v0.9.4

func (*FieldList) ProtoMessage()

func (*FieldList) ProtoReflect added in v0.9.4

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

func (*FieldList) Reset added in v0.9.4

func (x *FieldList) Reset()

func (*FieldList) String added in v0.9.4

func (x *FieldList) String() string

type FieldStatus added in v0.9.4

type FieldStatus int32
const (
	// Status is unset for this field.
	FieldStatus_INVALID FieldStatus = 0
	// Field value is present for this field and age is within max age.
	FieldStatus_PRESENT 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.
	FieldStatus_NULL_VALUE 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.
	FieldStatus_NOT_FOUND FieldStatus = 3
	// Values could be found for entity key, but field values are outside the maximum
	// allowable range.
	FieldStatus_OUTSIDE_MAX_AGE FieldStatus = 4
	// Values could be found for entity key, but are null and is due to ingestion failures
	FieldStatus_INGESTION_FAILURE FieldStatus = 5
)

func (FieldStatus) Descriptor added in v0.9.4

func (FieldStatus) Enum added in v0.9.4

func (x FieldStatus) Enum() *FieldStatus

func (FieldStatus) EnumDescriptor deprecated added in v0.9.4

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

Deprecated: Use FieldStatus.Descriptor instead.

func (FieldStatus) Number added in v0.9.4

func (x FieldStatus) Number() protoreflect.EnumNumber

func (FieldStatus) String added in v0.9.4

func (x FieldStatus) String() string

func (FieldStatus) Type added in v0.9.4

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 (*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 (*GetFeastServingInfoResponse) GetVersion

func (x *GetFeastServingInfoResponse) GetVersion() string

func (*GetFeastServingInfoResponse) ProtoMessage

func (*GetFeastServingInfoResponse) ProtoMessage()

func (*GetFeastServingInfoResponse) ProtoReflect

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 (*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 (*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 *timestamppb.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 (*GetOnlineFeaturesRequestV2_EntityRow) GetTimestamp added in v0.8.0

func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoMessage added in v0.8.0

func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoMessage()

func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoReflect added in v0.8.0

func (*GetOnlineFeaturesRequestV2_EntityRow) Reset added in v0.8.0

func (*GetOnlineFeaturesRequestV2_EntityRow) String added in v0.8.0

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 (*GetOnlineFeaturesResponse) ProtoMessage

func (*GetOnlineFeaturesResponse) ProtoMessage()

func (*GetOnlineFeaturesResponse) ProtoReflect

func (*GetOnlineFeaturesResponse) Reset

func (x *GetOnlineFeaturesResponse) Reset()

func (*GetOnlineFeaturesResponse) String

func (x *GetOnlineFeaturesResponse) String() string

type GetOnlineFeaturesResponseMetadata added in v0.9.4

type GetOnlineFeaturesResponseMetadata struct {
	FieldNames *FieldList `protobuf:"bytes,1,opt,name=field_names,json=fieldNames,proto3" json:"field_names,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesResponseMetadata) Descriptor deprecated added in v0.9.4

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

Deprecated: Use GetOnlineFeaturesResponseMetadata.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesResponseMetadata) GetFieldNames added in v0.9.4

func (x *GetOnlineFeaturesResponseMetadata) GetFieldNames() *FieldList

func (*GetOnlineFeaturesResponseMetadata) ProtoMessage added in v0.9.4

func (*GetOnlineFeaturesResponseMetadata) ProtoMessage()

func (*GetOnlineFeaturesResponseMetadata) ProtoReflect added in v0.9.4

func (*GetOnlineFeaturesResponseMetadata) Reset added in v0.9.4

func (*GetOnlineFeaturesResponseMetadata) String added in v0.9.4

type GetOnlineFeaturesResponseV2 added in v0.9.4

type GetOnlineFeaturesResponseV2 struct {
	Metadata *GetOnlineFeaturesResponseMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Length of "results" array should match length of requested features and entities.
	// We also preserve the same order of features here as in metadata.field_names
	Results []*GetOnlineFeaturesResponseV2_FieldVector `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesResponseV2) Descriptor deprecated added in v0.9.4

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

Deprecated: Use GetOnlineFeaturesResponseV2.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesResponseV2) GetMetadata added in v0.9.4

func (*GetOnlineFeaturesResponseV2) GetResults added in v0.9.4

func (*GetOnlineFeaturesResponseV2) ProtoMessage added in v0.9.4

func (*GetOnlineFeaturesResponseV2) ProtoMessage()

func (*GetOnlineFeaturesResponseV2) ProtoReflect added in v0.9.4

func (*GetOnlineFeaturesResponseV2) Reset added in v0.9.4

func (x *GetOnlineFeaturesResponseV2) Reset()

func (*GetOnlineFeaturesResponseV2) String added in v0.9.4

func (x *GetOnlineFeaturesResponseV2) String() string

type GetOnlineFeaturesResponseV2_FieldVector added in v0.9.4

type GetOnlineFeaturesResponseV2_FieldVector struct {
	Values   []*types.Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	Statuses []FieldStatus  `protobuf:"varint,2,rep,packed,name=statuses,proto3,enum=feast.serving.FieldStatus" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesResponseV2_FieldVector) Descriptor deprecated added in v0.9.4

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

Deprecated: Use GetOnlineFeaturesResponseV2_FieldVector.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesResponseV2_FieldVector) GetStatuses added in v0.9.4

func (*GetOnlineFeaturesResponseV2_FieldVector) GetValues added in v0.9.4

func (*GetOnlineFeaturesResponseV2_FieldVector) ProtoMessage added in v0.9.4

func (*GetOnlineFeaturesResponseV2_FieldVector) ProtoReflect added in v0.9.4

func (*GetOnlineFeaturesResponseV2_FieldVector) Reset added in v0.9.4

func (*GetOnlineFeaturesResponseV2_FieldVector) String added in v0.9.4

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]FieldStatus `` /* 189-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 (*GetOnlineFeaturesResponse_FieldValues) GetStatuses added in v0.6.2

func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage

func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage()

func (*GetOnlineFeaturesResponse_FieldValues) ProtoReflect

func (*GetOnlineFeaturesResponse_FieldValues) Reset

func (*GetOnlineFeaturesResponse_FieldValues) 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)
	// Get online features using optimized response message.
	GetOnlineFeatures(ctx context.Context, in *GetOnlineFeaturesRequestV2, opts ...grpc.CallOption) (*GetOnlineFeaturesResponseV2, error)
}

ServingServiceClient is the client API for ServingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

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)
	// Get online features using optimized response message.
	GetOnlineFeatures(context.Context, *GetOnlineFeaturesRequestV2) (*GetOnlineFeaturesResponseV2, error)
	// contains filtered or unexported methods
}

ServingServiceServer is the server API for ServingService service. All implementations must embed UnimplementedServingServiceServer for forward compatibility

type UnimplementedServingServiceServer

type UnimplementedServingServiceServer struct {
}

UnimplementedServingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServingServiceServer) GetFeastServingInfo

func (UnimplementedServingServiceServer) GetOnlineFeaturesV2 added in v0.8.0

type UnsafeServingServiceServer added in v0.9.4

type UnsafeServingServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeServingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServingServiceServer will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL