Documentation

Index

Constants

This section is empty.

Variables

View Source
var DataFormat_name = map[int32]string{
	0: "DATA_FORMAT_INVALID",
	1: "DATA_FORMAT_AVRO",
}
View Source
var DataFormat_value = map[string]int32{
	"DATA_FORMAT_INVALID": 0,
	"DATA_FORMAT_AVRO":    1,
}
View Source
var FeastServingType_name = map[int32]string{
	0: "FEAST_SERVING_TYPE_INVALID",
	1: "FEAST_SERVING_TYPE_ONLINE",
	2: "FEAST_SERVING_TYPE_BATCH",
}
View Source
var FeastServingType_value = map[string]int32{
	"FEAST_SERVING_TYPE_INVALID": 0,
	"FEAST_SERVING_TYPE_ONLINE":  1,
	"FEAST_SERVING_TYPE_BATCH":   2,
}
View Source
var JobStatus_name = map[int32]string{
	0: "JOB_STATUS_INVALID",
	1: "JOB_STATUS_PENDING",
	2: "JOB_STATUS_RUNNING",
	3: "JOB_STATUS_DONE",
}
View Source
var JobStatus_value = map[string]int32{
	"JOB_STATUS_INVALID": 0,
	"JOB_STATUS_PENDING": 1,
	"JOB_STATUS_RUNNING": 2,
	"JOB_STATUS_DONE":    3,
}
View Source
var JobType_name = map[int32]string{
	0: "JOB_TYPE_INVALID",
	1: "JOB_TYPE_DOWNLOAD",
}
View Source
var JobType_value = map[string]int32{
	"JOB_TYPE_INVALID":  0,
	"JOB_TYPE_DOWNLOAD": 1,
}

Functions

func RegisterServingServiceServer

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

Types

type DataFormat

type DataFormat int32
const (
	DataFormat_DATA_FORMAT_INVALID DataFormat = 0
	DataFormat_DATA_FORMAT_AVRO    DataFormat = 1
)

func (DataFormat) EnumDescriptor

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

func (DataFormat) String

func (x DataFormat) String() string

type DatasetSource

type DatasetSource struct {
	// Types that are valid to be assigned to DatasetSource:
	//	*DatasetSource_FileSource_
	DatasetSource        isDatasetSource_DatasetSource `protobuf_oneof:"dataset_source"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*DatasetSource) Descriptor

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

func (*DatasetSource) GetDatasetSource

func (m *DatasetSource) GetDatasetSource() isDatasetSource_DatasetSource

func (*DatasetSource) GetFileSource

func (m *DatasetSource) GetFileSource() *DatasetSource_FileSource

func (*DatasetSource) ProtoMessage

func (*DatasetSource) ProtoMessage()

func (*DatasetSource) Reset

func (m *DatasetSource) Reset()

func (*DatasetSource) String

func (m *DatasetSource) String() string

func (*DatasetSource) XXX_DiscardUnknown

func (m *DatasetSource) XXX_DiscardUnknown()

func (*DatasetSource) XXX_Marshal

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

func (*DatasetSource) XXX_Merge

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

func (*DatasetSource) XXX_OneofWrappers

func (*DatasetSource) XXX_OneofWrappers() []interface{}

    XXX_OneofWrappers is for the internal use of the proto package.

    func (*DatasetSource) XXX_Size

    func (m *DatasetSource) XXX_Size() int

    func (*DatasetSource) XXX_Unmarshal

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

    type DatasetSource_FileSource

    type DatasetSource_FileSource struct {
    	// URIs to retrieve the dataset from, e.g. gs://bucket/directory/object.csv. Wildcards are
    	// supported. This data must be compatible to be uploaded to the serving store, and also be
    	// accessible by this serving instance.
    	FileUris []string `protobuf:"bytes,1,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"`
    	// Format of the data. Currently only avro is supported.
    	DataFormat           DataFormat `protobuf:"varint,2,opt,name=data_format,json=dataFormat,proto3,enum=feast.serving.DataFormat" json:"data_format,omitempty"`
    	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    	XXX_unrecognized     []byte     `json:"-"`
    	XXX_sizecache        int32      `json:"-"`
    }

    func (*DatasetSource_FileSource) Descriptor

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

    func (*DatasetSource_FileSource) GetDataFormat

    func (m *DatasetSource_FileSource) GetDataFormat() DataFormat

    func (*DatasetSource_FileSource) GetFileUris

    func (m *DatasetSource_FileSource) GetFileUris() []string

    func (*DatasetSource_FileSource) ProtoMessage

    func (*DatasetSource_FileSource) ProtoMessage()

    func (*DatasetSource_FileSource) Reset

    func (m *DatasetSource_FileSource) Reset()

    func (*DatasetSource_FileSource) String

    func (m *DatasetSource_FileSource) String() string

    func (*DatasetSource_FileSource) XXX_DiscardUnknown

    func (m *DatasetSource_FileSource) XXX_DiscardUnknown()

    func (*DatasetSource_FileSource) XXX_Marshal

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

    func (*DatasetSource_FileSource) XXX_Merge

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

    func (*DatasetSource_FileSource) XXX_Size

    func (m *DatasetSource_FileSource) XXX_Size() int

    func (*DatasetSource_FileSource) XXX_Unmarshal

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

    type DatasetSource_FileSource_

    type DatasetSource_FileSource_ struct {
    	FileSource *DatasetSource_FileSource `protobuf:"bytes,1,opt,name=file_source,json=fileSource,proto3,oneof"`
    }

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

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

    func (FeastServingType) String

    func (x FeastServingType) String() string

    type FeatureReference

    type FeatureReference struct {
    	// Project name
    	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
    	// Feature name
    	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
    	// Feature version
    	Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
    	// The features will be retrieved if:
    	// entity_timestamp - max_age  <= event_timestamp <= entity_timestamp
    	//
    	// If unspecified the default max_age specified in FeatureSetSpec will
    	// be used.
    	MaxAge               *duration.Duration `protobuf:"bytes,4,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`
    	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    	XXX_unrecognized     []byte             `json:"-"`
    	XXX_sizecache        int32              `json:"-"`
    }

    func (*FeatureReference) Descriptor

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

    func (*FeatureReference) GetMaxAge

    func (m *FeatureReference) GetMaxAge() *duration.Duration

    func (*FeatureReference) GetName

    func (m *FeatureReference) GetName() string

    func (*FeatureReference) GetProject

    func (m *FeatureReference) GetProject() string

    func (*FeatureReference) GetVersion

    func (m *FeatureReference) GetVersion() int32

    func (*FeatureReference) ProtoMessage

    func (*FeatureReference) ProtoMessage()

    func (*FeatureReference) Reset

    func (m *FeatureReference) Reset()

    func (*FeatureReference) String

    func (m *FeatureReference) String() string

    func (*FeatureReference) XXX_DiscardUnknown

    func (m *FeatureReference) XXX_DiscardUnknown()

    func (*FeatureReference) XXX_Marshal

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

    func (*FeatureReference) XXX_Merge

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

    func (*FeatureReference) XXX_Size

    func (m *FeatureReference) XXX_Size() int

    func (*FeatureReference) XXX_Unmarshal

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

    type GetBatchFeaturesRequest

    type GetBatchFeaturesRequest struct {
    	// List of features that are being retrieved
    	Features []*FeatureReference `protobuf:"bytes,3,rep,name=features,proto3" json:"features,omitempty"`
    	// Source of the entity dataset containing the timestamps and entity keys to retrieve
    	// features for.
    	DatasetSource        *DatasetSource `protobuf:"bytes,2,opt,name=dataset_source,json=datasetSource,proto3" json:"dataset_source,omitempty"`
    	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    	XXX_unrecognized     []byte         `json:"-"`
    	XXX_sizecache        int32          `json:"-"`
    }

    func (*GetBatchFeaturesRequest) Descriptor

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

    func (*GetBatchFeaturesRequest) GetDatasetSource

    func (m *GetBatchFeaturesRequest) GetDatasetSource() *DatasetSource

    func (*GetBatchFeaturesRequest) GetFeatures

    func (m *GetBatchFeaturesRequest) GetFeatures() []*FeatureReference

    func (*GetBatchFeaturesRequest) ProtoMessage

    func (*GetBatchFeaturesRequest) ProtoMessage()

    func (*GetBatchFeaturesRequest) Reset

    func (m *GetBatchFeaturesRequest) Reset()

    func (*GetBatchFeaturesRequest) String

    func (m *GetBatchFeaturesRequest) String() string

    func (*GetBatchFeaturesRequest) XXX_DiscardUnknown

    func (m *GetBatchFeaturesRequest) XXX_DiscardUnknown()

    func (*GetBatchFeaturesRequest) XXX_Marshal

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

    func (*GetBatchFeaturesRequest) XXX_Merge

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

    func (*GetBatchFeaturesRequest) XXX_Size

    func (m *GetBatchFeaturesRequest) XXX_Size() int

    func (*GetBatchFeaturesRequest) XXX_Unmarshal

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

    type GetBatchFeaturesResponse

    type GetBatchFeaturesResponse struct {
    	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
    	XXX_unrecognized     []byte   `json:"-"`
    	XXX_sizecache        int32    `json:"-"`
    }

    func (*GetBatchFeaturesResponse) Descriptor

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

    func (*GetBatchFeaturesResponse) GetJob

    func (m *GetBatchFeaturesResponse) GetJob() *Job

    func (*GetBatchFeaturesResponse) ProtoMessage

    func (*GetBatchFeaturesResponse) ProtoMessage()

    func (*GetBatchFeaturesResponse) Reset

    func (m *GetBatchFeaturesResponse) Reset()

    func (*GetBatchFeaturesResponse) String

    func (m *GetBatchFeaturesResponse) String() string

    func (*GetBatchFeaturesResponse) XXX_DiscardUnknown

    func (m *GetBatchFeaturesResponse) XXX_DiscardUnknown()

    func (*GetBatchFeaturesResponse) XXX_Marshal

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

    func (*GetBatchFeaturesResponse) XXX_Merge

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

    func (*GetBatchFeaturesResponse) XXX_Size

    func (m *GetBatchFeaturesResponse) XXX_Size() int

    func (*GetBatchFeaturesResponse) XXX_Unmarshal

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

    type GetFeastServingInfoRequest

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

    func (*GetFeastServingInfoRequest) Descriptor

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

    func (*GetFeastServingInfoRequest) ProtoMessage

    func (*GetFeastServingInfoRequest) ProtoMessage()

    func (*GetFeastServingInfoRequest) Reset

    func (m *GetFeastServingInfoRequest) Reset()

    func (*GetFeastServingInfoRequest) String

    func (m *GetFeastServingInfoRequest) String() string

    func (*GetFeastServingInfoRequest) XXX_DiscardUnknown

    func (m *GetFeastServingInfoRequest) XXX_DiscardUnknown()

    func (*GetFeastServingInfoRequest) XXX_Marshal

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

    func (*GetFeastServingInfoRequest) XXX_Merge

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

    func (*GetFeastServingInfoRequest) XXX_Size

    func (m *GetFeastServingInfoRequest) XXX_Size() int

    func (*GetFeastServingInfoRequest) XXX_Unmarshal

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

    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"`
    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
    	XXX_unrecognized     []byte   `json:"-"`
    	XXX_sizecache        int32    `json:"-"`
    }

    func (*GetFeastServingInfoResponse) Descriptor

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

    func (*GetFeastServingInfoResponse) GetJobStagingLocation

    func (m *GetFeastServingInfoResponse) GetJobStagingLocation() string

    func (*GetFeastServingInfoResponse) GetType

    func (*GetFeastServingInfoResponse) GetVersion

    func (m *GetFeastServingInfoResponse) GetVersion() string

    func (*GetFeastServingInfoResponse) ProtoMessage

    func (*GetFeastServingInfoResponse) ProtoMessage()

    func (*GetFeastServingInfoResponse) Reset

    func (m *GetFeastServingInfoResponse) Reset()

    func (*GetFeastServingInfoResponse) String

    func (m *GetFeastServingInfoResponse) String() string

    func (*GetFeastServingInfoResponse) XXX_DiscardUnknown

    func (m *GetFeastServingInfoResponse) XXX_DiscardUnknown()

    func (*GetFeastServingInfoResponse) XXX_Marshal

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

    func (*GetFeastServingInfoResponse) XXX_Merge

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

    func (*GetFeastServingInfoResponse) XXX_Size

    func (m *GetFeastServingInfoResponse) XXX_Size() int

    func (*GetFeastServingInfoResponse) XXX_Unmarshal

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

    type GetJobRequest

    type GetJobRequest struct {
    	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
    	XXX_unrecognized     []byte   `json:"-"`
    	XXX_sizecache        int32    `json:"-"`
    }

    func (*GetJobRequest) Descriptor

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

    func (*GetJobRequest) GetJob

    func (m *GetJobRequest) GetJob() *Job

    func (*GetJobRequest) ProtoMessage

    func (*GetJobRequest) ProtoMessage()

    func (*GetJobRequest) Reset

    func (m *GetJobRequest) Reset()

    func (*GetJobRequest) String

    func (m *GetJobRequest) String() string

    func (*GetJobRequest) XXX_DiscardUnknown

    func (m *GetJobRequest) XXX_DiscardUnknown()

    func (*GetJobRequest) XXX_Marshal

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

    func (*GetJobRequest) XXX_Merge

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

    func (*GetJobRequest) XXX_Size

    func (m *GetJobRequest) XXX_Size() int

    func (*GetJobRequest) XXX_Unmarshal

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

    type GetJobResponse

    type GetJobResponse struct {
    	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
    	XXX_NoUnkeyedLiteral struct{} `json:"-"`
    	XXX_unrecognized     []byte   `json:"-"`
    	XXX_sizecache        int32    `json:"-"`
    }

    func (*GetJobResponse) Descriptor

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

    func (*GetJobResponse) GetJob

    func (m *GetJobResponse) GetJob() *Job

    func (*GetJobResponse) ProtoMessage

    func (*GetJobResponse) ProtoMessage()

    func (*GetJobResponse) Reset

    func (m *GetJobResponse) Reset()

    func (*GetJobResponse) String

    func (m *GetJobResponse) String() string

    func (*GetJobResponse) XXX_DiscardUnknown

    func (m *GetJobResponse) XXX_DiscardUnknown()

    func (*GetJobResponse) XXX_Marshal

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

    func (*GetJobResponse) XXX_Merge

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

    func (*GetJobResponse) XXX_Size

    func (m *GetJobResponse) XXX_Size() int

    func (*GetJobResponse) XXX_Unmarshal

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

    type GetOnlineFeaturesRequest

    type GetOnlineFeaturesRequest struct {
    	// List of features that are being retrieved
    	Features []*FeatureReference `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 []*GetOnlineFeaturesRequest_EntityRow `protobuf:"bytes,2,rep,name=entity_rows,json=entityRows,proto3" json:"entity_rows,omitempty"`
    	// Option to omit entities from the response. If true, only feature
    	// values will be returned.
    	OmitEntitiesInResponse bool     `` /* 132-byte string literal not displayed */
    	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
    	XXX_unrecognized       []byte   `json:"-"`
    	XXX_sizecache          int32    `json:"-"`
    }

    func (*GetOnlineFeaturesRequest) Descriptor

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

    func (*GetOnlineFeaturesRequest) GetEntityRows

    func (*GetOnlineFeaturesRequest) GetFeatures

    func (m *GetOnlineFeaturesRequest) GetFeatures() []*FeatureReference

    func (*GetOnlineFeaturesRequest) GetOmitEntitiesInResponse

    func (m *GetOnlineFeaturesRequest) GetOmitEntitiesInResponse() bool

    func (*GetOnlineFeaturesRequest) ProtoMessage

    func (*GetOnlineFeaturesRequest) ProtoMessage()

    func (*GetOnlineFeaturesRequest) Reset

    func (m *GetOnlineFeaturesRequest) Reset()

    func (*GetOnlineFeaturesRequest) String

    func (m *GetOnlineFeaturesRequest) String() string

    func (*GetOnlineFeaturesRequest) XXX_DiscardUnknown

    func (m *GetOnlineFeaturesRequest) XXX_DiscardUnknown()

    func (*GetOnlineFeaturesRequest) XXX_Marshal

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

    func (*GetOnlineFeaturesRequest) XXX_Merge

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

    func (*GetOnlineFeaturesRequest) XXX_Size

    func (m *GetOnlineFeaturesRequest) XXX_Size() int

    func (*GetOnlineFeaturesRequest) XXX_Unmarshal

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

    type GetOnlineFeaturesRequest_EntityRow

    type GetOnlineFeaturesRequest_EntityRow struct {
    	// Request timestamp of this row. This value will be used, together with maxAge,
    	// to determine feature staleness.
    	EntityTimestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=entity_timestamp,json=entityTimestamp,proto3" json:"entity_timestamp,omitempty"`
    	// Map containing mapping of entity name to entity value.
    	Fields               map[string]*types.Value `` /* 153-byte string literal not displayed */
    	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
    	XXX_unrecognized     []byte                  `json:"-"`
    	XXX_sizecache        int32                   `json:"-"`
    }

    func (*GetOnlineFeaturesRequest_EntityRow) Descriptor

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

    func (*GetOnlineFeaturesRequest_EntityRow) GetEntityTimestamp

    func (m *GetOnlineFeaturesRequest_EntityRow) GetEntityTimestamp() *timestamp.Timestamp

    func (*GetOnlineFeaturesRequest_EntityRow) GetFields

    func (*GetOnlineFeaturesRequest_EntityRow) ProtoMessage

    func (*GetOnlineFeaturesRequest_EntityRow) ProtoMessage()

    func (*GetOnlineFeaturesRequest_EntityRow) Reset

    func (*GetOnlineFeaturesRequest_EntityRow) String

    func (*GetOnlineFeaturesRequest_EntityRow) XXX_DiscardUnknown

    func (m *GetOnlineFeaturesRequest_EntityRow) XXX_DiscardUnknown()

    func (*GetOnlineFeaturesRequest_EntityRow) XXX_Marshal

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

    func (*GetOnlineFeaturesRequest_EntityRow) XXX_Merge

    func (*GetOnlineFeaturesRequest_EntityRow) XXX_Size

    func (*GetOnlineFeaturesRequest_EntityRow) XXX_Unmarshal

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

    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"`
    	XXX_NoUnkeyedLiteral struct{}                                 `json:"-"`
    	XXX_unrecognized     []byte                                   `json:"-"`
    	XXX_sizecache        int32                                    `json:"-"`
    }

    func (*GetOnlineFeaturesResponse) Descriptor

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

    func (*GetOnlineFeaturesResponse) GetFieldValues

    func (*GetOnlineFeaturesResponse) ProtoMessage

    func (*GetOnlineFeaturesResponse) ProtoMessage()

    func (*GetOnlineFeaturesResponse) Reset

    func (m *GetOnlineFeaturesResponse) Reset()

    func (*GetOnlineFeaturesResponse) String

    func (m *GetOnlineFeaturesResponse) String() string

    func (*GetOnlineFeaturesResponse) XXX_DiscardUnknown

    func (m *GetOnlineFeaturesResponse) XXX_DiscardUnknown()

    func (*GetOnlineFeaturesResponse) XXX_Marshal

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

    func (*GetOnlineFeaturesResponse) XXX_Merge

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

    func (*GetOnlineFeaturesResponse) XXX_Size

    func (m *GetOnlineFeaturesResponse) XXX_Size() int

    func (*GetOnlineFeaturesResponse) XXX_Unmarshal

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

    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 */
    	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
    	XXX_unrecognized     []byte                  `json:"-"`
    	XXX_sizecache        int32                   `json:"-"`
    }

    func (*GetOnlineFeaturesResponse_FieldValues) Descriptor

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

    func (*GetOnlineFeaturesResponse_FieldValues) GetFields

    func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage

    func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage()

    func (*GetOnlineFeaturesResponse_FieldValues) Reset

    func (*GetOnlineFeaturesResponse_FieldValues) String

    func (*GetOnlineFeaturesResponse_FieldValues) XXX_DiscardUnknown

    func (m *GetOnlineFeaturesResponse_FieldValues) XXX_DiscardUnknown()

    func (*GetOnlineFeaturesResponse_FieldValues) XXX_Marshal

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

    func (*GetOnlineFeaturesResponse_FieldValues) XXX_Merge

    func (*GetOnlineFeaturesResponse_FieldValues) XXX_Size

    func (*GetOnlineFeaturesResponse_FieldValues) XXX_Unmarshal

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

    type Job

    type Job struct {
    	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
    	// Output only. The type of the job.
    	Type JobType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.serving.JobType" json:"type,omitempty"`
    	// Output only. Current state of the job.
    	Status JobStatus `protobuf:"varint,3,opt,name=status,proto3,enum=feast.serving.JobStatus" json:"status,omitempty"`
    	// Output only. If not empty, the job has failed with this error message.
    	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
    	// Output only. The list of URIs for the files to be downloaded or
    	// uploaded (depends on the job type) for this particular job.
    	FileUris []string `protobuf:"bytes,5,rep,name=file_uris,json=fileUris,proto3" json:"file_uris,omitempty"`
    	// Output only. The data format for all the files.
    	// For CSV format, the files contain both feature values and a column header.
    	DataFormat           DataFormat `protobuf:"varint,6,opt,name=data_format,json=dataFormat,proto3,enum=feast.serving.DataFormat" json:"data_format,omitempty"`
    	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
    	XXX_unrecognized     []byte     `json:"-"`
    	XXX_sizecache        int32      `json:"-"`
    }

    func (*Job) Descriptor

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

    func (*Job) GetDataFormat

    func (m *Job) GetDataFormat() DataFormat

    func (*Job) GetError

    func (m *Job) GetError() string

    func (*Job) GetFileUris

    func (m *Job) GetFileUris() []string

    func (*Job) GetId

    func (m *Job) GetId() string

    func (*Job) GetStatus

    func (m *Job) GetStatus() JobStatus

    func (*Job) GetType

    func (m *Job) GetType() JobType

    func (*Job) ProtoMessage

    func (*Job) ProtoMessage()

    func (*Job) Reset

    func (m *Job) Reset()

    func (*Job) String

    func (m *Job) String() string

    func (*Job) XXX_DiscardUnknown

    func (m *Job) XXX_DiscardUnknown()

    func (*Job) XXX_Marshal

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

    func (*Job) XXX_Merge

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

    func (*Job) XXX_Size

    func (m *Job) XXX_Size() int

    func (*Job) XXX_Unmarshal

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

    type JobStatus

    type JobStatus int32
    const (
    	JobStatus_JOB_STATUS_INVALID JobStatus = 0
    	JobStatus_JOB_STATUS_PENDING JobStatus = 1
    	JobStatus_JOB_STATUS_RUNNING JobStatus = 2
    	JobStatus_JOB_STATUS_DONE    JobStatus = 3
    )

    func (JobStatus) EnumDescriptor

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

    func (JobStatus) String

    func (x JobStatus) String() string

    type JobType

    type JobType int32
    const (
    	JobType_JOB_TYPE_INVALID  JobType = 0
    	JobType_JOB_TYPE_DOWNLOAD JobType = 1
    )

    func (JobType) EnumDescriptor

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

    func (JobType) String

    func (x JobType) 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 synchronously.
    	GetOnlineFeatures(ctx context.Context, in *GetOnlineFeaturesRequest, opts ...grpc.CallOption) (*GetOnlineFeaturesResponse, error)
    	// Get batch features asynchronously.
    	//
    	// The client should check the status of the returned job periodically by
    	// calling ReloadJob to determine if the job has completed successfully
    	// or with an error. If the job completes successfully i.e.
    	// status = JOB_STATUS_DONE with no error, then the client can check
    	// the file_uris for the location to download feature values data.
    	// The client is assumed to have access to these file URIs.
    	GetBatchFeatures(ctx context.Context, in *GetBatchFeaturesRequest, opts ...grpc.CallOption) (*GetBatchFeaturesResponse, error)
    	// Get the latest job status for batch feature retrieval.
    	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, 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.ClientConn) ServingServiceClient

      type ServingServiceServer

      type ServingServiceServer interface {
      	// Get information about this Feast serving.
      	GetFeastServingInfo(context.Context, *GetFeastServingInfoRequest) (*GetFeastServingInfoResponse, error)
      	// Get online features synchronously.
      	GetOnlineFeatures(context.Context, *GetOnlineFeaturesRequest) (*GetOnlineFeaturesResponse, error)
      	// Get batch features asynchronously.
      	//
      	// The client should check the status of the returned job periodically by
      	// calling ReloadJob to determine if the job has completed successfully
      	// or with an error. If the job completes successfully i.e.
      	// status = JOB_STATUS_DONE with no error, then the client can check
      	// the file_uris for the location to download feature values data.
      	// The client is assumed to have access to these file URIs.
      	GetBatchFeatures(context.Context, *GetBatchFeaturesRequest) (*GetBatchFeaturesResponse, error)
      	// Get the latest job status for batch feature retrieval.
      	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, 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) GetBatchFeatures

          func (*UnimplementedServingServiceServer) GetFeastServingInfo

          func (*UnimplementedServingServiceServer) GetJob

          func (*UnimplementedServingServiceServer) GetOnlineFeatures