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) Enum

      func (FeastServingType) EnumDescriptor

      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

        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

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

          Deprecated: Use FeatureReferenceV2.ProtoReflect.Descriptor instead.

          func (*FeatureReferenceV2) GetFeatureTable

          func (x *FeatureReferenceV2) GetFeatureTable() string

          func (*FeatureReferenceV2) GetName

          func (x *FeatureReferenceV2) GetName() string

          func (*FeatureReferenceV2) ProtoMessage

          func (*FeatureReferenceV2) ProtoMessage()

          func (*FeatureReferenceV2) ProtoReflect

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

          func (*FeatureReferenceV2) Reset

          func (x *FeatureReferenceV2) Reset()

          func (*FeatureReferenceV2) String

          func (x *FeatureReferenceV2) String() string

          type GetFeastServingInfoRequest

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

          func (*GetFeastServingInfoRequest) Descriptor

          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

            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

              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

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

                Deprecated: Use GetOnlineFeaturesRequestV2.ProtoReflect.Descriptor instead.

                func (*GetOnlineFeaturesRequestV2) GetEntityRows

                func (*GetOnlineFeaturesRequestV2) GetFeatures

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

                func (*GetOnlineFeaturesRequestV2) GetProject

                func (x *GetOnlineFeaturesRequestV2) GetProject() string

                func (*GetOnlineFeaturesRequestV2) ProtoMessage

                func (*GetOnlineFeaturesRequestV2) ProtoMessage()

                func (*GetOnlineFeaturesRequestV2) ProtoReflect

                func (*GetOnlineFeaturesRequestV2) Reset

                func (x *GetOnlineFeaturesRequestV2) Reset()

                func (*GetOnlineFeaturesRequestV2) String

                func (x *GetOnlineFeaturesRequestV2) String() string

                type GetOnlineFeaturesRequestV2_EntityRow

                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

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

                  Deprecated: Use GetOnlineFeaturesRequestV2_EntityRow.ProtoReflect.Descriptor instead.

                  func (*GetOnlineFeaturesRequestV2_EntityRow) GetFields

                  func (*GetOnlineFeaturesRequestV2_EntityRow) GetTimestamp

                  func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoMessage

                  func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoMessage()

                  func (*GetOnlineFeaturesRequestV2_EntityRow) ProtoReflect

                  func (*GetOnlineFeaturesRequestV2_EntityRow) Reset

                  func (*GetOnlineFeaturesRequestV2_EntityRow) 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

                  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 GetOnlineFeaturesResponse_FieldStatus

                    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

                    func (GetOnlineFeaturesResponse_FieldStatus) Enum

                    func (GetOnlineFeaturesResponse_FieldStatus) EnumDescriptor

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

                      Deprecated: Use GetOnlineFeaturesResponse_FieldStatus.Descriptor instead.

                      func (GetOnlineFeaturesResponse_FieldStatus) Number

                      func (GetOnlineFeaturesResponse_FieldStatus) String

                      func (GetOnlineFeaturesResponse_FieldStatus) Type

                      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

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

                        Deprecated: Use GetOnlineFeaturesResponse_FieldValues.ProtoReflect.Descriptor instead.

                        func (*GetOnlineFeaturesResponse_FieldValues) GetFields

                        func (*GetOnlineFeaturesResponse_FieldValues) GetStatuses

                        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)
                        }

                          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.

                          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) GetOnlineFeaturesV2