serving

package
v0.5.1-dev Latest Latest
Warning

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

 Go to latest Published: May 21, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

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 (
	JobType_name = map[int32]string{
		0: "JOB_TYPE_INVALID",
		1: "JOB_TYPE_DOWNLOAD",
	}
	JobType_value = map[string]int32{
		"JOB_TYPE_INVALID":  0,
		"JOB_TYPE_DOWNLOAD": 1,
	}
)

Enum value maps for JobType.

View Source 
var (
	JobStatus_name = map[int32]string{
		0: "JOB_STATUS_INVALID",
		1: "JOB_STATUS_PENDING",
		2: "JOB_STATUS_RUNNING",
		3: "JOB_STATUS_DONE",
	}
	JobStatus_value = map[string]int32{
		"JOB_STATUS_INVALID": 0,
		"JOB_STATUS_PENDING": 1,
		"JOB_STATUS_RUNNING": 2,
		"JOB_STATUS_DONE":    3,
	}
)

Enum value maps for JobStatus.

View Source 
var (
	DataFormat_name = map[int32]string{
		0: "DATA_FORMAT_INVALID",
		1: "DATA_FORMAT_AVRO",
	}
	DataFormat_value = map[string]int32{
		"DATA_FORMAT_INVALID": 0,
		"DATA_FORMAT_AVRO":    1,
	}
)

Enum value maps for DataFormat.

View Source 
var File_feast_serving_ServingService_proto protoreflect.FileDescriptor

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

func (DataFormat) Descriptor() protoreflect.EnumDescriptor

func (DataFormat) Enum 

func (x DataFormat) Enum() *DataFormat

func (DataFormat) EnumDescriptor deprecated 

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

Deprecated: Use DataFormat.Descriptor instead.

func (DataFormat) Number 

func (x DataFormat) Number() protoreflect.EnumNumber

func (DataFormat) String 

func (x DataFormat) String() string

func (DataFormat) Type 

func (DataFormat) Type() protoreflect.EnumType

type DatasetSource 

type DatasetSource struct {

	// Types that are assignable to DatasetSource:
	//	*DatasetSource_FileSource_
	DatasetSource isDatasetSource_DatasetSource `protobuf_oneof:"dataset_source"`
	// contains filtered or unexported fields
}

func (*DatasetSource) Descriptor deprecated 

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

Deprecated: Use DatasetSource.ProtoReflect.Descriptor instead.

func (*DatasetSource) GetDatasetSource 

func (m *DatasetSource) GetDatasetSource() isDatasetSource_DatasetSource

func (*DatasetSource) GetFileSource 

func (x *DatasetSource) GetFileSource() *DatasetSource_FileSource

func (*DatasetSource) ProtoMessage 

func (*DatasetSource) ProtoMessage()

func (*DatasetSource) ProtoReflect 

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

func (*DatasetSource) Reset 

func (x *DatasetSource) Reset()

func (*DatasetSource) String 

func (x *DatasetSource) String() string

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"`
	// contains filtered or unexported fields
}

func (*DatasetSource_FileSource) Descriptor deprecated 

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

Deprecated: Use DatasetSource_FileSource.ProtoReflect.Descriptor instead.

func (*DatasetSource_FileSource) GetDataFormat 

func (x *DatasetSource_FileSource) GetDataFormat() DataFormat

func (*DatasetSource_FileSource) GetFileUris 

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

func (*DatasetSource_FileSource) ProtoMessage 

func (*DatasetSource_FileSource) ProtoMessage()

func (*DatasetSource_FileSource) ProtoReflect 

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

func (*DatasetSource_FileSource) Reset 

func (x *DatasetSource_FileSource) Reset()

func (*DatasetSource_FileSource) String 

func (x *DatasetSource_FileSource) String() string

type DatasetSource_FileSource_ 

type DatasetSource_FileSource_ struct {
	// File source to load the dataset from.
	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) Descriptor 

func (FeastServingType) Descriptor() protoreflect.EnumDescriptor

func (FeastServingType) Enum 

func (x FeastServingType) Enum() *FeastServingType

func (FeastServingType) EnumDescriptor deprecated 

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

Deprecated: Use FeastServingType.Descriptor instead.

func (FeastServingType) Number 

func (x FeastServingType) Number() protoreflect.EnumNumber

func (FeastServingType) String 

func (x FeastServingType) String() string

func (FeastServingType) Type 

func (FeastServingType) Type() protoreflect.EnumType

type FeatureReference 

type FeatureReference struct {

	// Project name. This field is optional, if unspecified will default to 'default'.
	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 set name specifying the feature set of this referenced feature.
	// This field is optional if the feature referenced is unique across the project
	// in which case the feature set would be automatically infered
	FeatureSet string `protobuf:"bytes,5,opt,name=feature_set,json=featureSet,proto3" json:"feature_set,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureReference) Descriptor deprecated 

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

Deprecated: Use FeatureReference.ProtoReflect.Descriptor instead.

func (*FeatureReference) GetFeatureSet 

func (x *FeatureReference) GetFeatureSet() string

func (*FeatureReference) GetName 

func (x *FeatureReference) GetName() string

func (*FeatureReference) GetProject 

func (x *FeatureReference) GetProject() string

func (*FeatureReference) ProtoMessage 

func (*FeatureReference) ProtoMessage()

func (*FeatureReference) ProtoReflect 

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

func (*FeatureReference) Reset 

func (x *FeatureReference) Reset()

func (*FeatureReference) String 

func (x *FeatureReference) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetBatchFeaturesRequest) Descriptor deprecated 

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

Deprecated: Use GetBatchFeaturesRequest.ProtoReflect.Descriptor instead.

func (*GetBatchFeaturesRequest) GetDatasetSource 

func (x *GetBatchFeaturesRequest) GetDatasetSource() *DatasetSource

func (*GetBatchFeaturesRequest) GetFeatures 

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

func (*GetBatchFeaturesRequest) ProtoMessage 

func (*GetBatchFeaturesRequest) ProtoMessage()

func (*GetBatchFeaturesRequest) ProtoReflect 

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

func (*GetBatchFeaturesRequest) Reset 

func (x *GetBatchFeaturesRequest) Reset()

func (*GetBatchFeaturesRequest) String 

func (x *GetBatchFeaturesRequest) String() string

type GetBatchFeaturesResponse 

type GetBatchFeaturesResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBatchFeaturesResponse) Descriptor deprecated 

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

Deprecated: Use GetBatchFeaturesResponse.ProtoReflect.Descriptor instead.

func (*GetBatchFeaturesResponse) GetJob 

func (x *GetBatchFeaturesResponse) GetJob() *Job

func (*GetBatchFeaturesResponse) ProtoMessage 

func (*GetBatchFeaturesResponse) ProtoMessage()

func (*GetBatchFeaturesResponse) ProtoReflect 

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

func (*GetBatchFeaturesResponse) Reset 

func (x *GetBatchFeaturesResponse) Reset()

func (*GetBatchFeaturesResponse) String 

func (x *GetBatchFeaturesResponse) String() string

type GetFeastServingInfoRequest 

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

func (*GetFeastServingInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetFeastServingInfoRequest.ProtoReflect.Descriptor instead.

func (*GetFeastServingInfoRequest) ProtoMessage 

func (*GetFeastServingInfoRequest) ProtoMessage()

func (*GetFeastServingInfoRequest) ProtoReflect 

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

func (*GetFeastServingInfoRequest) Reset 

func (x *GetFeastServingInfoRequest) Reset()

func (*GetFeastServingInfoRequest) String 

func (x *GetFeastServingInfoRequest) String() string

type GetFeastServingInfoResponse 

type GetFeastServingInfoResponse struct {

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

func (*GetFeastServingInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetFeastServingInfoResponse.ProtoReflect.Descriptor instead.

func (*GetFeastServingInfoResponse) GetJobStagingLocation 

func (x *GetFeastServingInfoResponse) GetJobStagingLocation() string

func (*GetFeastServingInfoResponse) GetType 

func (x *GetFeastServingInfoResponse) GetType() FeastServingType

func (*GetFeastServingInfoResponse) GetVersion 

func (x *GetFeastServingInfoResponse) GetVersion() string

func (*GetFeastServingInfoResponse) ProtoMessage 

func (*GetFeastServingInfoResponse) ProtoMessage()

func (*GetFeastServingInfoResponse) ProtoReflect 

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

func (*GetFeastServingInfoResponse) Reset 

func (x *GetFeastServingInfoResponse) Reset()

func (*GetFeastServingInfoResponse) String 

func (x *GetFeastServingInfoResponse) String() string

type GetJobRequest 

type GetJobRequest struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetJob 

func (x *GetJobRequest) GetJob() *Job

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect 

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

func (*GetJobRequest) Reset 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (x *GetJobRequest) String() string

type GetJobResponse 

type GetJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResponse) Descriptor deprecated 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob 

func (x *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect 

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

func (*GetJobResponse) Reset 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (x *GetJobResponse) String() string

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 */
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesRequest) Descriptor deprecated 

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

Deprecated: Use GetOnlineFeaturesRequest.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesRequest) GetEntityRows 

func (x *GetOnlineFeaturesRequest) GetEntityRows() []*GetOnlineFeaturesRequest_EntityRow

func (*GetOnlineFeaturesRequest) GetFeatures 

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

func (*GetOnlineFeaturesRequest) GetOmitEntitiesInResponse 

func (x *GetOnlineFeaturesRequest) GetOmitEntitiesInResponse() bool

func (*GetOnlineFeaturesRequest) ProtoMessage 

func (*GetOnlineFeaturesRequest) ProtoMessage()

func (*GetOnlineFeaturesRequest) ProtoReflect 

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

func (*GetOnlineFeaturesRequest) Reset 

func (x *GetOnlineFeaturesRequest) Reset()

func (*GetOnlineFeaturesRequest) String 

func (x *GetOnlineFeaturesRequest) String() string

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 */
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesRequest_EntityRow) Descriptor deprecated 

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

Deprecated: Use GetOnlineFeaturesRequest_EntityRow.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesRequest_EntityRow) GetEntityTimestamp 

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

func (*GetOnlineFeaturesRequest_EntityRow) GetFields 

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

func (*GetOnlineFeaturesRequest_EntityRow) ProtoMessage 

func (*GetOnlineFeaturesRequest_EntityRow) ProtoMessage()

func (*GetOnlineFeaturesRequest_EntityRow) ProtoReflect 

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

func (*GetOnlineFeaturesRequest_EntityRow) Reset 

func (x *GetOnlineFeaturesRequest_EntityRow) Reset()

func (*GetOnlineFeaturesRequest_EntityRow) String 

func (x *GetOnlineFeaturesRequest_EntityRow) String() string

type GetOnlineFeaturesResponse 

type GetOnlineFeaturesResponse struct {

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

func (*GetOnlineFeaturesResponse) Descriptor deprecated 

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

Deprecated: Use GetOnlineFeaturesResponse.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesResponse) GetFieldValues 

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

func (*GetOnlineFeaturesResponse) ProtoMessage 

func (*GetOnlineFeaturesResponse) ProtoMessage()

func (*GetOnlineFeaturesResponse) ProtoReflect 

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

func (*GetOnlineFeaturesResponse) Reset 

func (x *GetOnlineFeaturesResponse) Reset()

func (*GetOnlineFeaturesResponse) String 

func (x *GetOnlineFeaturesResponse) String() string

type GetOnlineFeaturesResponse_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 */
	// contains filtered or unexported fields
}

func (*GetOnlineFeaturesResponse_FieldValues) Descriptor deprecated 

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

Deprecated: Use GetOnlineFeaturesResponse_FieldValues.ProtoReflect.Descriptor instead.

func (*GetOnlineFeaturesResponse_FieldValues) GetFields 

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

func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage 

func (*GetOnlineFeaturesResponse_FieldValues) ProtoMessage()

func (*GetOnlineFeaturesResponse_FieldValues) ProtoReflect 

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

func (*GetOnlineFeaturesResponse_FieldValues) Reset 

func (x *GetOnlineFeaturesResponse_FieldValues) Reset()

func (*GetOnlineFeaturesResponse_FieldValues) String 

func (x *GetOnlineFeaturesResponse_FieldValues) String() string

type 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"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetDataFormat 

func (x *Job) GetDataFormat() DataFormat

func (*Job) GetError 

func (x *Job) GetError() string

func (*Job) GetFileUris 

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

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetStatus 

func (x *Job) GetStatus() JobStatus

func (*Job) GetType 

func (x *Job) GetType() JobType

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

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

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated 

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String 

func (x JobStatus) String() string

func (JobStatus) Type 

func (JobStatus) Type() protoreflect.EnumType

type JobType 

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

func (JobType) Descriptor 

func (JobType) Descriptor() protoreflect.EnumDescriptor

func (JobType) Enum 

func (x JobType) Enum() *JobType

func (JobType) EnumDescriptor deprecated 

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

Deprecated: Use JobType.Descriptor instead.

func (JobType) Number 

func (x JobType) Number() protoreflect.EnumNumber

func (JobType) String 

func (x JobType) String() string

func (JobType) Type 

func (JobType) Type() protoreflect.EnumType

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

func (*UnimplementedServingServiceServer) GetFeastServingInfo 

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

func (*UnimplementedServingServiceServer) GetJob 

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

func (*UnimplementedServingServiceServer) GetOnlineFeatures 

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