serving

package
v0.4.7 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

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 (m *GetFeastServingInfoResponse) GetType() FeastServingType

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 (m *GetOnlineFeaturesRequest) GetEntityRows() []*GetOnlineFeaturesRequest_EntityRow

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 (m *GetOnlineFeaturesRequest_EntityRow) GetFields() map[string]*types.Value

func (*GetOnlineFeaturesRequest_EntityRow) ProtoMessage 

func (*GetOnlineFeaturesRequest_EntityRow) ProtoMessage()

func (*GetOnlineFeaturesRequest_EntityRow) Reset 

func (m *GetOnlineFeaturesRequest_EntityRow) Reset()

func (*GetOnlineFeaturesRequest_EntityRow) String 

func (m *GetOnlineFeaturesRequest_EntityRow) String() 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 (m *GetOnlineFeaturesRequest_EntityRow) XXX_Merge(src proto.Message)

func (*GetOnlineFeaturesRequest_EntityRow) XXX_Size 

func (m *GetOnlineFeaturesRequest_EntityRow) XXX_Size() int

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 (m *GetOnlineFeaturesResponse) GetFieldValues() []*GetOnlineFeaturesResponse_FieldValues

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 (m *GetOnlineFeaturesResponse_FieldValues) GetFields() map[string]*types.Value

func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage 

func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage()

func (*GetOnlineFeaturesResponse_FieldValues) Reset 

func (m *GetOnlineFeaturesResponse_FieldValues) Reset()

func (*GetOnlineFeaturesResponse_FieldValues) String 

func (m *GetOnlineFeaturesResponse_FieldValues) String() 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 (m *GetOnlineFeaturesResponse_FieldValues) XXX_Merge(src proto.Message)

func (*GetOnlineFeaturesResponse_FieldValues) XXX_Size 

func (m *GetOnlineFeaturesResponse_FieldValues) XXX_Size() int

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) GetBatchFeatures(ctx context.Context, req *GetBatchFeaturesRequest) (*GetBatchFeaturesResponse, error)

func (*UnimplementedServingServiceServer) GetFeastServingInfo 

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

func (*UnimplementedServingServiceServer) GetJob 

func (*UnimplementedServingServiceServer) GetJob(ctx context.Context, req *GetJobRequest) (*GetJobResponse, error)

func (*UnimplementedServingServiceServer) GetOnlineFeatures 

func (*UnimplementedServingServiceServer) GetOnlineFeatures(ctx context.Context, req *GetOnlineFeaturesRequest) (*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.