core

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DataSource_SourceType_name = map[int32]string{
		0:  "INVALID",
		1:  "BATCH_FILE",
		8:  "BATCH_SNOWFLAKE",
		2:  "BATCH_BIGQUERY",
		5:  "BATCH_REDSHIFT",
		3:  "STREAM_KAFKA",
		4:  "STREAM_KINESIS",
		6:  "CUSTOM_SOURCE",
		7:  "REQUEST_SOURCE",
		9:  "PUSH_SOURCE",
		10: "BATCH_TRINO",
		11: "BATCH_SPARK",
		12: "BATCH_ATHENA",
	}
	DataSource_SourceType_value = map[string]int32{
		"INVALID":         0,
		"BATCH_FILE":      1,
		"BATCH_SNOWFLAKE": 8,
		"BATCH_BIGQUERY":  2,
		"BATCH_REDSHIFT":  5,
		"STREAM_KAFKA":    3,
		"STREAM_KINESIS":  4,
		"CUSTOM_SOURCE":   6,
		"REQUEST_SOURCE":  7,
		"PUSH_SOURCE":     9,
		"BATCH_TRINO":     10,
		"BATCH_SPARK":     11,
		"BATCH_ATHENA":    12,
	}
)

Enum value maps for DataSource_SourceType.

View Source 
var (
	Store_StoreType_name = map[int32]string{
		0: "INVALID",
		1: "REDIS",
		4: "REDIS_CLUSTER",
	}
	Store_StoreType_value = map[string]int32{
		"INVALID":       0,
		"REDIS":         1,
		"REDIS_CLUSTER": 4,
	}
)

Enum value maps for Store_StoreType.

View Source 
var (
	Store_RedisClusterConfig_ReadFrom_name = map[int32]string{
		0: "MASTER",
		1: "MASTER_PREFERRED",
		2: "REPLICA",
		3: "REPLICA_PREFERRED",
	}
	Store_RedisClusterConfig_ReadFrom_value = map[string]int32{
		"MASTER":            0,
		"MASTER_PREFERRED":  1,
		"REPLICA":           2,
		"REPLICA_PREFERRED": 3,
	}
)

Enum value maps for Store_RedisClusterConfig_ReadFrom.

View Source 
var File_protos_feast_core_Aggregation_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_DataFormat_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_DataSource_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_DatastoreTable_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_DynamoDBTable_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_Entity_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_FeatureService_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_FeatureTable_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_FeatureViewProjection_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_FeatureView_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_Feature_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_InfraObject_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_OnDemandFeatureView_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_Registry_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_RequestFeatureView_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_SavedDataset_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_SqliteTable_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_Store_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_StreamFeatureView_proto protoreflect.FileDescriptor
View Source 
var File_protos_feast_core_ValidationProfile_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Aggregation 

type Aggregation struct {
	Column        string               `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
	Function      string               `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	TimeWindow    *durationpb.Duration `protobuf:"bytes,3,opt,name=time_window,json=timeWindow,proto3" json:"time_window,omitempty"`
	SlideInterval *durationpb.Duration `protobuf:"bytes,4,opt,name=slide_interval,json=slideInterval,proto3" json:"slide_interval,omitempty"`
	// contains filtered or unexported fields
}

func (*Aggregation) Descriptor deprecated 

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

Deprecated: Use Aggregation.ProtoReflect.Descriptor instead.

func (*Aggregation) GetColumn 

func (x *Aggregation) GetColumn() string

func (*Aggregation) GetFunction 

func (x *Aggregation) GetFunction() string

func (*Aggregation) GetSlideInterval 

func (x *Aggregation) GetSlideInterval() *durationpb.Duration

func (*Aggregation) GetTimeWindow 

func (x *Aggregation) GetTimeWindow() *durationpb.Duration

func (*Aggregation) ProtoMessage 

func (*Aggregation) ProtoMessage()

func (*Aggregation) ProtoReflect 

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

func (*Aggregation) Reset 

func (x *Aggregation) Reset()

func (*Aggregation) String 

func (x *Aggregation) String() string

type DataSource 

type DataSource struct {

	// Unique name of data source within the project
	Name string `protobuf:"bytes,20,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this data source belongs to.
	Project     string                `protobuf:"bytes,21,opt,name=project,proto3" json:"project,omitempty"`
	Description string                `protobuf:"bytes,23,opt,name=description,proto3" json:"description,omitempty"`
	Tags        map[string]string     `` /* 150-byte string literal not displayed */
	Owner       string                `protobuf:"bytes,25,opt,name=owner,proto3" json:"owner,omitempty"`
	Type        DataSource_SourceType `protobuf:"varint,1,opt,name=type,proto3,enum=feast.core.DataSource_SourceType" json:"type,omitempty"`
	// Defines mapping between fields in the sourced data
	// and fields in parent FeatureTable.
	FieldMapping map[string]string `` /* 185-byte string literal not displayed */
	// Must specify event timestamp column name
	TimestampField string `protobuf:"bytes,3,opt,name=timestamp_field,json=timestampField,proto3" json:"timestamp_field,omitempty"`
	// (Optional) Specify partition column
	// useful for file sources
	DatePartitionColumn string `protobuf:"bytes,4,opt,name=date_partition_column,json=datePartitionColumn,proto3" json:"date_partition_column,omitempty"`
	// Must specify creation timestamp column name
	CreatedTimestampColumn string `` /* 129-byte string literal not displayed */
	// This is an internal field that is represents the python class for the data source object a proto object represents.
	// This should be set by feast, and not by users.
	// The field is used primarily by custom data sources and is mandatory for them to set. Feast may set it for
	// first party sources as well.
	DataSourceClassType string `protobuf:"bytes,17,opt,name=data_source_class_type,json=dataSourceClassType,proto3" json:"data_source_class_type,omitempty"`
	// Optional batch source for streaming sources for historical features and materialization.
	BatchSource *DataSource            `protobuf:"bytes,26,opt,name=batch_source,json=batchSource,proto3" json:"batch_source,omitempty"`
	Meta        *DataSource_SourceMeta `protobuf:"bytes,50,opt,name=meta,proto3" json:"meta,omitempty"`
	// DataSource options.
	//
	// Types that are assignable to Options:
	//	*DataSource_FileOptions_
	//	*DataSource_BigqueryOptions
	//	*DataSource_KafkaOptions_
	//	*DataSource_KinesisOptions_
	//	*DataSource_RedshiftOptions_
	//	*DataSource_RequestDataOptions_
	//	*DataSource_CustomOptions
	//	*DataSource_SnowflakeOptions_
	//	*DataSource_PushOptions_
	//	*DataSource_SparkOptions_
	//	*DataSource_TrinoOptions_
	//	*DataSource_AthenaOptions_
	Options isDataSource_Options `protobuf_oneof:"options"`
	// contains filtered or unexported fields
}

Defines a Data Source that can be used source Feature data Next available id: 28

func (*DataSource) Descriptor deprecated 

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

Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

func (*DataSource) GetAthenaOptions 

func (x *DataSource) GetAthenaOptions() *DataSource_AthenaOptions

func (*DataSource) GetBatchSource 

func (x *DataSource) GetBatchSource() *DataSource

func (*DataSource) GetBigqueryOptions 

func (x *DataSource) GetBigqueryOptions() *DataSource_BigQueryOptions

func (*DataSource) GetCreatedTimestampColumn 

func (x *DataSource) GetCreatedTimestampColumn() string

func (*DataSource) GetCustomOptions 

func (x *DataSource) GetCustomOptions() *DataSource_CustomSourceOptions

func (*DataSource) GetDataSourceClassType 

func (x *DataSource) GetDataSourceClassType() string

func (*DataSource) GetDatePartitionColumn 

func (x *DataSource) GetDatePartitionColumn() string

func (*DataSource) GetDescription 

func (x *DataSource) GetDescription() string

func (*DataSource) GetFieldMapping 

func (x *DataSource) GetFieldMapping() map[string]string

func (*DataSource) GetFileOptions 

func (x *DataSource) GetFileOptions() *DataSource_FileOptions

func (*DataSource) GetKafkaOptions 

func (x *DataSource) GetKafkaOptions() *DataSource_KafkaOptions

func (*DataSource) GetKinesisOptions 

func (x *DataSource) GetKinesisOptions() *DataSource_KinesisOptions

func (*DataSource) GetMeta 

func (x *DataSource) GetMeta() *DataSource_SourceMeta

func (*DataSource) GetName 

func (x *DataSource) GetName() string

func (*DataSource) GetOptions 

func (m *DataSource) GetOptions() isDataSource_Options

func (*DataSource) GetOwner 

func (x *DataSource) GetOwner() string

func (*DataSource) GetProject 

func (x *DataSource) GetProject() string

func (*DataSource) GetPushOptions 

func (x *DataSource) GetPushOptions() *DataSource_PushOptions

func (*DataSource) GetRedshiftOptions 

func (x *DataSource) GetRedshiftOptions() *DataSource_RedshiftOptions

func (*DataSource) GetRequestDataOptions 

func (x *DataSource) GetRequestDataOptions() *DataSource_RequestDataOptions

func (*DataSource) GetSnowflakeOptions 

func (x *DataSource) GetSnowflakeOptions() *DataSource_SnowflakeOptions

func (*DataSource) GetSparkOptions 

func (x *DataSource) GetSparkOptions() *DataSource_SparkOptions

func (*DataSource) GetTags 

func (x *DataSource) GetTags() map[string]string

func (*DataSource) GetTimestampField 

func (x *DataSource) GetTimestampField() string

func (*DataSource) GetTrinoOptions 

func (x *DataSource) GetTrinoOptions() *DataSource_TrinoOptions

func (*DataSource) GetType 

func (x *DataSource) GetType() DataSource_SourceType

func (*DataSource) ProtoMessage 

func (*DataSource) ProtoMessage()

func (*DataSource) ProtoReflect 

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

func (*DataSource) Reset 

func (x *DataSource) Reset()

func (*DataSource) String 

func (x *DataSource) String() string

type DataSource_AthenaOptions 

type DataSource_AthenaOptions struct {

	// Athena table name
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// SQL query that returns a table containing feature data. Must contain an event_timestamp column, and respective
	// entity columns
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Athena database name
	Database string `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	// Athena schema name
	DataSource string `protobuf:"bytes,4,opt,name=data_source,json=dataSource,proto3" json:"data_source,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a Athena Query

func (*DataSource_AthenaOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_AthenaOptions.ProtoReflect.Descriptor instead.

func (*DataSource_AthenaOptions) GetDataSource 

func (x *DataSource_AthenaOptions) GetDataSource() string

func (*DataSource_AthenaOptions) GetDatabase 

func (x *DataSource_AthenaOptions) GetDatabase() string

func (*DataSource_AthenaOptions) GetQuery 

func (x *DataSource_AthenaOptions) GetQuery() string

func (*DataSource_AthenaOptions) GetTable 

func (x *DataSource_AthenaOptions) GetTable() string

func (*DataSource_AthenaOptions) ProtoMessage 

func (*DataSource_AthenaOptions) ProtoMessage()

func (*DataSource_AthenaOptions) ProtoReflect 

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

func (*DataSource_AthenaOptions) Reset 

func (x *DataSource_AthenaOptions) Reset()

func (*DataSource_AthenaOptions) String 

func (x *DataSource_AthenaOptions) String() string

type DataSource_AthenaOptions_ 

type DataSource_AthenaOptions_ struct {
	AthenaOptions *DataSource_AthenaOptions `protobuf:"bytes,35,opt,name=athena_options,json=athenaOptions,proto3,oneof"`
}

type DataSource_BigQueryOptions 

type DataSource_BigQueryOptions struct {

	// Full table reference in the form of [project:dataset.table]
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// SQL query that returns a table containing feature data. Must contain an event_timestamp column, and respective
	// entity columns
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a BigQuery Query

func (*DataSource_BigQueryOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_BigQueryOptions.ProtoReflect.Descriptor instead.

func (*DataSource_BigQueryOptions) GetQuery 

func (x *DataSource_BigQueryOptions) GetQuery() string

func (*DataSource_BigQueryOptions) GetTable 

func (x *DataSource_BigQueryOptions) GetTable() string

func (*DataSource_BigQueryOptions) ProtoMessage 

func (*DataSource_BigQueryOptions) ProtoMessage()

func (*DataSource_BigQueryOptions) ProtoReflect 

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

func (*DataSource_BigQueryOptions) Reset 

func (x *DataSource_BigQueryOptions) Reset()

func (*DataSource_BigQueryOptions) String 

func (x *DataSource_BigQueryOptions) String() string

type DataSource_BigqueryOptions 

type DataSource_BigqueryOptions struct {
	BigqueryOptions *DataSource_BigQueryOptions `protobuf:"bytes,12,opt,name=bigquery_options,json=bigqueryOptions,proto3,oneof"`
}

type DataSource_CustomOptions 

type DataSource_CustomOptions struct {
	CustomOptions *DataSource_CustomSourceOptions `protobuf:"bytes,16,opt,name=custom_options,json=customOptions,proto3,oneof"`
}

type DataSource_CustomSourceOptions 

type DataSource_CustomSourceOptions struct {

	// Serialized configuration information for the data source. The implementer of the custom data source is
	// responsible for serializing and deserializing data from bytes
	Configuration []byte `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

Defines configuration for custom third-party data sources.

func (*DataSource_CustomSourceOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_CustomSourceOptions.ProtoReflect.Descriptor instead.

func (*DataSource_CustomSourceOptions) GetConfiguration 

func (x *DataSource_CustomSourceOptions) GetConfiguration() []byte

func (*DataSource_CustomSourceOptions) ProtoMessage 

func (*DataSource_CustomSourceOptions) ProtoMessage()

func (*DataSource_CustomSourceOptions) ProtoReflect 

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

func (*DataSource_CustomSourceOptions) Reset 

func (x *DataSource_CustomSourceOptions) Reset()

func (*DataSource_CustomSourceOptions) String 

func (x *DataSource_CustomSourceOptions) String() string

type DataSource_FileOptions 

type DataSource_FileOptions struct {
	FileFormat *FileFormat `protobuf:"bytes,1,opt,name=file_format,json=fileFormat,proto3" json:"file_format,omitempty"`
	// Target URL of file to retrieve and source features from.
	// s3://path/to/file for AWS S3 storage
	// gs://path/to/file for GCP GCS storage
	// file:///path/to/file for local storage
	Uri string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
	// override AWS S3 storage endpoint with custom S3 endpoint
	S3EndpointOverride string `protobuf:"bytes,3,opt,name=s3_endpoint_override,json=s3EndpointOverride,proto3" json:"s3_endpoint_override,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a file

func (*DataSource_FileOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_FileOptions.ProtoReflect.Descriptor instead.

func (*DataSource_FileOptions) GetFileFormat 

func (x *DataSource_FileOptions) GetFileFormat() *FileFormat

func (*DataSource_FileOptions) GetS3EndpointOverride 

func (x *DataSource_FileOptions) GetS3EndpointOverride() string

func (*DataSource_FileOptions) GetUri 

func (x *DataSource_FileOptions) GetUri() string

func (*DataSource_FileOptions) ProtoMessage 

func (*DataSource_FileOptions) ProtoMessage()

func (*DataSource_FileOptions) ProtoReflect 

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

func (*DataSource_FileOptions) Reset 

func (x *DataSource_FileOptions) Reset()

func (*DataSource_FileOptions) String 

func (x *DataSource_FileOptions) String() string

type DataSource_FileOptions_ 

type DataSource_FileOptions_ struct {
	FileOptions *DataSource_FileOptions `protobuf:"bytes,11,opt,name=file_options,json=fileOptions,proto3,oneof"`
}

type DataSource_KafkaOptions 

type DataSource_KafkaOptions struct {

	// Comma separated list of Kafka bootstrap servers. Used for feature tables without a defined source host[:port]]
	KafkaBootstrapServers string `` /* 126-byte string literal not displayed */
	// Kafka topic to collect feature data from.
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Defines the stream data format encoding feature/entity data in Kafka messages.
	MessageFormat *StreamFormat `protobuf:"bytes,3,opt,name=message_format,json=messageFormat,proto3" json:"message_format,omitempty"`
	// Watermark delay threshold for stream data
	WatermarkDelayThreshold *durationpb.Duration `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from Kafka messages. Each message should be a Protobuf that can be decoded with the generated Java Protobuf class at the given class path

func (*DataSource_KafkaOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_KafkaOptions.ProtoReflect.Descriptor instead.

func (*DataSource_KafkaOptions) GetKafkaBootstrapServers 

func (x *DataSource_KafkaOptions) GetKafkaBootstrapServers() string

func (*DataSource_KafkaOptions) GetMessageFormat 

func (x *DataSource_KafkaOptions) GetMessageFormat() *StreamFormat

func (*DataSource_KafkaOptions) GetTopic 

func (x *DataSource_KafkaOptions) GetTopic() string

func (*DataSource_KafkaOptions) GetWatermarkDelayThreshold 

func (x *DataSource_KafkaOptions) GetWatermarkDelayThreshold() *durationpb.Duration

func (*DataSource_KafkaOptions) ProtoMessage 

func (*DataSource_KafkaOptions) ProtoMessage()

func (*DataSource_KafkaOptions) ProtoReflect 

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

func (*DataSource_KafkaOptions) Reset 

func (x *DataSource_KafkaOptions) Reset()

func (*DataSource_KafkaOptions) String 

func (x *DataSource_KafkaOptions) String() string

type DataSource_KafkaOptions_ 

type DataSource_KafkaOptions_ struct {
	KafkaOptions *DataSource_KafkaOptions `protobuf:"bytes,13,opt,name=kafka_options,json=kafkaOptions,proto3,oneof"`
}

type DataSource_KinesisOptions 

type DataSource_KinesisOptions struct {

	// AWS region of the Kinesis stream
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// Name of the Kinesis stream to obtain feature data from.
	StreamName string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// Defines the data format encoding the feature/entity data in Kinesis records.
	// Kinesis Data Sources support Avro and Proto as data formats.
	RecordFormat *StreamFormat `protobuf:"bytes,3,opt,name=record_format,json=recordFormat,proto3" json:"record_format,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from Kinesis records. Each record should be a Protobuf that can be decoded with the generated Java Protobuf class at the given class path

func (*DataSource_KinesisOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_KinesisOptions.ProtoReflect.Descriptor instead.

func (*DataSource_KinesisOptions) GetRecordFormat 

func (x *DataSource_KinesisOptions) GetRecordFormat() *StreamFormat

func (*DataSource_KinesisOptions) GetRegion 

func (x *DataSource_KinesisOptions) GetRegion() string

func (*DataSource_KinesisOptions) GetStreamName 

func (x *DataSource_KinesisOptions) GetStreamName() string

func (*DataSource_KinesisOptions) ProtoMessage 

func (*DataSource_KinesisOptions) ProtoMessage()

func (*DataSource_KinesisOptions) ProtoReflect 

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

func (*DataSource_KinesisOptions) Reset 

func (x *DataSource_KinesisOptions) Reset()

func (*DataSource_KinesisOptions) String 

func (x *DataSource_KinesisOptions) String() string

type DataSource_KinesisOptions_ 

type DataSource_KinesisOptions_ struct {
	KinesisOptions *DataSource_KinesisOptions `protobuf:"bytes,14,opt,name=kinesis_options,json=kinesisOptions,proto3,oneof"`
}

type DataSource_PushOptions 

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

Defines options for DataSource that supports pushing data to it. This allows data to be pushed to the online store on-demand, such as by stream consumers.

func (*DataSource_PushOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_PushOptions.ProtoReflect.Descriptor instead.

func (*DataSource_PushOptions) ProtoMessage 

func (*DataSource_PushOptions) ProtoMessage()

func (*DataSource_PushOptions) ProtoReflect 

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

func (*DataSource_PushOptions) Reset 

func (x *DataSource_PushOptions) Reset()

func (*DataSource_PushOptions) String 

func (x *DataSource_PushOptions) String() string

type DataSource_PushOptions_ 

type DataSource_PushOptions_ struct {
	PushOptions *DataSource_PushOptions `protobuf:"bytes,22,opt,name=push_options,json=pushOptions,proto3,oneof"`
}

type DataSource_RedshiftOptions 

type DataSource_RedshiftOptions struct {

	// Redshift table name
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// SQL query that returns a table containing feature data. Must contain an event_timestamp column, and respective
	// entity columns
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Redshift schema name
	Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// Redshift database name
	Database string `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a Redshift Query

func (*DataSource_RedshiftOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_RedshiftOptions.ProtoReflect.Descriptor instead.

func (*DataSource_RedshiftOptions) GetDatabase 

func (x *DataSource_RedshiftOptions) GetDatabase() string

func (*DataSource_RedshiftOptions) GetQuery 

func (x *DataSource_RedshiftOptions) GetQuery() string

func (*DataSource_RedshiftOptions) GetSchema 

func (x *DataSource_RedshiftOptions) GetSchema() string

func (*DataSource_RedshiftOptions) GetTable 

func (x *DataSource_RedshiftOptions) GetTable() string

func (*DataSource_RedshiftOptions) ProtoMessage 

func (*DataSource_RedshiftOptions) ProtoMessage()

func (*DataSource_RedshiftOptions) ProtoReflect 

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

func (*DataSource_RedshiftOptions) Reset 

func (x *DataSource_RedshiftOptions) Reset()

func (*DataSource_RedshiftOptions) String 

func (x *DataSource_RedshiftOptions) String() string

type DataSource_RedshiftOptions_ 

type DataSource_RedshiftOptions_ struct {
	RedshiftOptions *DataSource_RedshiftOptions `protobuf:"bytes,15,opt,name=redshift_options,json=redshiftOptions,proto3,oneof"`
}

type DataSource_RequestDataOptions 

type DataSource_RequestDataOptions struct {

	// Mapping of feature name to type
	DeprecatedSchema map[string]types.ValueType_Enum `` /* 230-byte string literal not displayed */
	Schema           []*FeatureSpecV2                `protobuf:"bytes,3,rep,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from request data

func (*DataSource_RequestDataOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_RequestDataOptions.ProtoReflect.Descriptor instead.

func (*DataSource_RequestDataOptions) GetDeprecatedSchema 

func (x *DataSource_RequestDataOptions) GetDeprecatedSchema() map[string]types.ValueType_Enum

func (*DataSource_RequestDataOptions) GetSchema 

func (x *DataSource_RequestDataOptions) GetSchema() []*FeatureSpecV2

func (*DataSource_RequestDataOptions) ProtoMessage 

func (*DataSource_RequestDataOptions) ProtoMessage()

func (*DataSource_RequestDataOptions) ProtoReflect 

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

func (*DataSource_RequestDataOptions) Reset 

func (x *DataSource_RequestDataOptions) Reset()

func (*DataSource_RequestDataOptions) String 

func (x *DataSource_RequestDataOptions) String() string

type DataSource_RequestDataOptions_ 

type DataSource_RequestDataOptions_ struct {
	RequestDataOptions *DataSource_RequestDataOptions `protobuf:"bytes,18,opt,name=request_data_options,json=requestDataOptions,proto3,oneof"`
}

type DataSource_SnowflakeOptions 

type DataSource_SnowflakeOptions struct {

	// Snowflake table name
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// SQL query that returns a table containing feature data. Must contain an event_timestamp column, and respective
	// entity columns
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Snowflake schema name
	Schema string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// Snowflake schema name
	Database string `protobuf:"bytes,4,opt,name=database,proto3" json:"database,omitempty"`
	// Snowflake warehouse name
	Warehouse string `protobuf:"bytes,5,opt,name=warehouse,proto3" json:"warehouse,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a Snowflake Query

func (*DataSource_SnowflakeOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_SnowflakeOptions.ProtoReflect.Descriptor instead.

func (*DataSource_SnowflakeOptions) GetDatabase 

func (x *DataSource_SnowflakeOptions) GetDatabase() string

func (*DataSource_SnowflakeOptions) GetQuery 

func (x *DataSource_SnowflakeOptions) GetQuery() string

func (*DataSource_SnowflakeOptions) GetSchema 

func (x *DataSource_SnowflakeOptions) GetSchema() string

func (*DataSource_SnowflakeOptions) GetTable 

func (x *DataSource_SnowflakeOptions) GetTable() string

func (*DataSource_SnowflakeOptions) GetWarehouse 

func (x *DataSource_SnowflakeOptions) GetWarehouse() string

func (*DataSource_SnowflakeOptions) ProtoMessage 

func (*DataSource_SnowflakeOptions) ProtoMessage()

func (*DataSource_SnowflakeOptions) ProtoReflect 

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

func (*DataSource_SnowflakeOptions) Reset 

func (x *DataSource_SnowflakeOptions) Reset()

func (*DataSource_SnowflakeOptions) String 

func (x *DataSource_SnowflakeOptions) String() string

type DataSource_SnowflakeOptions_ 

type DataSource_SnowflakeOptions_ struct {
	SnowflakeOptions *DataSource_SnowflakeOptions `protobuf:"bytes,19,opt,name=snowflake_options,json=snowflakeOptions,proto3,oneof"`
}

type DataSource_SourceMeta 

type DataSource_SourceMeta struct {
	EarliestEventTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=earliestEventTimestamp,proto3" json:"earliestEventTimestamp,omitempty"`
	LatestEventTimestamp   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=latestEventTimestamp,proto3" json:"latestEventTimestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*DataSource_SourceMeta) Descriptor deprecated 

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

Deprecated: Use DataSource_SourceMeta.ProtoReflect.Descriptor instead.

func (*DataSource_SourceMeta) GetEarliestEventTimestamp 

func (x *DataSource_SourceMeta) GetEarliestEventTimestamp() *timestamppb.Timestamp

func (*DataSource_SourceMeta) GetLatestEventTimestamp 

func (x *DataSource_SourceMeta) GetLatestEventTimestamp() *timestamppb.Timestamp

func (*DataSource_SourceMeta) ProtoMessage 

func (*DataSource_SourceMeta) ProtoMessage()

func (*DataSource_SourceMeta) ProtoReflect 

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

func (*DataSource_SourceMeta) Reset 

func (x *DataSource_SourceMeta) Reset()

func (*DataSource_SourceMeta) String 

func (x *DataSource_SourceMeta) String() string

type DataSource_SourceType 

type DataSource_SourceType int32

Type of Data Source. Next available id: 12 

const (
	DataSource_INVALID         DataSource_SourceType = 0
	DataSource_BATCH_FILE      DataSource_SourceType = 1
	DataSource_BATCH_SNOWFLAKE DataSource_SourceType = 8
	DataSource_BATCH_BIGQUERY  DataSource_SourceType = 2
	DataSource_BATCH_REDSHIFT  DataSource_SourceType = 5
	DataSource_STREAM_KAFKA    DataSource_SourceType = 3
	DataSource_STREAM_KINESIS  DataSource_SourceType = 4
	DataSource_CUSTOM_SOURCE   DataSource_SourceType = 6
	DataSource_REQUEST_SOURCE  DataSource_SourceType = 7
	DataSource_PUSH_SOURCE     DataSource_SourceType = 9
	DataSource_BATCH_TRINO     DataSource_SourceType = 10
	DataSource_BATCH_SPARK     DataSource_SourceType = 11
	DataSource_BATCH_ATHENA    DataSource_SourceType = 12
)

func (DataSource_SourceType) Descriptor 

func (DataSource_SourceType) Descriptor() protoreflect.EnumDescriptor

func (DataSource_SourceType) Enum 

func (x DataSource_SourceType) Enum() *DataSource_SourceType

func (DataSource_SourceType) EnumDescriptor deprecated 

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

Deprecated: Use DataSource_SourceType.Descriptor instead.

func (DataSource_SourceType) Number 

func (x DataSource_SourceType) Number() protoreflect.EnumNumber

func (DataSource_SourceType) String 

func (x DataSource_SourceType) String() string

func (DataSource_SourceType) Type 

func (DataSource_SourceType) Type() protoreflect.EnumType

type DataSource_SparkOptions 

type DataSource_SparkOptions struct {

	// Table name
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Spark SQl query that returns the table, this is an alternative to `table`
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Path from which spark can read the table, this is an alternative to `table`
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// Format of files at `path` (e.g. parquet, avro, etc)
	FileFormat string `protobuf:"bytes,4,opt,name=file_format,json=fileFormat,proto3" json:"file_format,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a spark table/query

func (*DataSource_SparkOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_SparkOptions.ProtoReflect.Descriptor instead.

func (*DataSource_SparkOptions) GetFileFormat 

func (x *DataSource_SparkOptions) GetFileFormat() string

func (*DataSource_SparkOptions) GetPath 

func (x *DataSource_SparkOptions) GetPath() string

func (*DataSource_SparkOptions) GetQuery 

func (x *DataSource_SparkOptions) GetQuery() string

func (*DataSource_SparkOptions) GetTable 

func (x *DataSource_SparkOptions) GetTable() string

func (*DataSource_SparkOptions) ProtoMessage 

func (*DataSource_SparkOptions) ProtoMessage()

func (*DataSource_SparkOptions) ProtoReflect 

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

func (*DataSource_SparkOptions) Reset 

func (x *DataSource_SparkOptions) Reset()

func (*DataSource_SparkOptions) String 

func (x *DataSource_SparkOptions) String() string

type DataSource_SparkOptions_ 

type DataSource_SparkOptions_ struct {
	SparkOptions *DataSource_SparkOptions `protobuf:"bytes,27,opt,name=spark_options,json=sparkOptions,proto3,oneof"`
}

type DataSource_TrinoOptions 

type DataSource_TrinoOptions struct {

	// Full table reference in the form of [project:dataset.table]
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// SQL query that returns a table containing feature data. Must contain an event_timestamp column, and respective
	// entity columns
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

Defines options for DataSource that sources features from a Trino Query

func (*DataSource_TrinoOptions) Descriptor deprecated 

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

Deprecated: Use DataSource_TrinoOptions.ProtoReflect.Descriptor instead.

func (*DataSource_TrinoOptions) GetQuery 

func (x *DataSource_TrinoOptions) GetQuery() string

func (*DataSource_TrinoOptions) GetTable 

func (x *DataSource_TrinoOptions) GetTable() string

func (*DataSource_TrinoOptions) ProtoMessage 

func (*DataSource_TrinoOptions) ProtoMessage()

func (*DataSource_TrinoOptions) ProtoReflect 

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

func (*DataSource_TrinoOptions) Reset 

func (x *DataSource_TrinoOptions) Reset()

func (*DataSource_TrinoOptions) String 

func (x *DataSource_TrinoOptions) String() string

type DataSource_TrinoOptions_ 

type DataSource_TrinoOptions_ struct {
	TrinoOptions *DataSource_TrinoOptions `protobuf:"bytes,30,opt,name=trino_options,json=trinoOptions,proto3,oneof"`
}

type DatastoreTable 

type DatastoreTable struct {

	// Feast project of the table
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the table
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// GCP project id
	ProjectId *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// Datastore namespace
	Namespace *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

Represents a Datastore table

func (*DatastoreTable) Descriptor deprecated 

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

Deprecated: Use DatastoreTable.ProtoReflect.Descriptor instead.

func (*DatastoreTable) GetName 

func (x *DatastoreTable) GetName() string

func (*DatastoreTable) GetNamespace 

func (x *DatastoreTable) GetNamespace() *wrapperspb.StringValue

func (*DatastoreTable) GetProject 

func (x *DatastoreTable) GetProject() string

func (*DatastoreTable) GetProjectId 

func (x *DatastoreTable) GetProjectId() *wrapperspb.StringValue

func (*DatastoreTable) ProtoMessage 

func (*DatastoreTable) ProtoMessage()

func (*DatastoreTable) ProtoReflect 

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

func (*DatastoreTable) Reset 

func (x *DatastoreTable) Reset()

func (*DatastoreTable) String 

func (x *DatastoreTable) String() string

type DynamoDBTable 

type DynamoDBTable struct {

	// Name of the table
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Region of the table
	Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// contains filtered or unexported fields
}

Represents a DynamoDB table

func (*DynamoDBTable) Descriptor deprecated 

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

Deprecated: Use DynamoDBTable.ProtoReflect.Descriptor instead.

func (*DynamoDBTable) GetName 

func (x *DynamoDBTable) GetName() string

func (*DynamoDBTable) GetRegion 

func (x *DynamoDBTable) GetRegion() string

func (*DynamoDBTable) ProtoMessage 

func (*DynamoDBTable) ProtoMessage()

func (*DynamoDBTable) ProtoReflect 

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

func (*DynamoDBTable) Reset 

func (x *DynamoDBTable) Reset()

func (*DynamoDBTable) String 

func (x *DynamoDBTable) String() string

type Entity 

type Entity struct {

	// User-specified specifications of this entity.
	Spec *EntitySpecV2 `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// System-populated metadata for this entity.
	Meta *EntityMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*Entity) Descriptor deprecated 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetMeta 

func (x *Entity) GetMeta() *EntityMeta

func (*Entity) GetSpec 

func (x *Entity) GetSpec() *EntitySpecV2

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect 

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

func (*Entity) Reset 

func (x *Entity) Reset()

func (*Entity) String 

func (x *Entity) String() string

type EntityMeta 

type EntityMeta struct {
	CreatedTimestamp     *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*EntityMeta) Descriptor deprecated 

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

Deprecated: Use EntityMeta.ProtoReflect.Descriptor instead.

func (*EntityMeta) GetCreatedTimestamp 

func (x *EntityMeta) GetCreatedTimestamp() *timestamppb.Timestamp

func (*EntityMeta) GetLastUpdatedTimestamp 

func (x *EntityMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp

func (*EntityMeta) ProtoMessage 

func (*EntityMeta) ProtoMessage()

func (*EntityMeta) ProtoReflect 

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

func (*EntityMeta) Reset 

func (x *EntityMeta) Reset()

func (*EntityMeta) String 

func (x *EntityMeta) String() string

type EntitySpecV2 

type EntitySpecV2 struct {

	// Name of the entity.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this feature table belongs to.
	Project string `protobuf:"bytes,9,opt,name=project,proto3" json:"project,omitempty"`
	// Type of the entity.
	ValueType types.ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"`
	// Description of the entity.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Join key for the entity (i.e. name of the column the entity maps to).
	JoinKey string `protobuf:"bytes,4,opt,name=join_key,json=joinKey,proto3" json:"join_key,omitempty"`
	// User defined metadata
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Owner of the entity.
	Owner string `protobuf:"bytes,10,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*EntitySpecV2) Descriptor deprecated 

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

Deprecated: Use EntitySpecV2.ProtoReflect.Descriptor instead.

func (*EntitySpecV2) GetDescription 

func (x *EntitySpecV2) GetDescription() string

func (*EntitySpecV2) GetJoinKey 

func (x *EntitySpecV2) GetJoinKey() string

func (*EntitySpecV2) GetName 

func (x *EntitySpecV2) GetName() string

func (*EntitySpecV2) GetOwner 

func (x *EntitySpecV2) GetOwner() string

func (*EntitySpecV2) GetProject 

func (x *EntitySpecV2) GetProject() string

func (*EntitySpecV2) GetTags 

func (x *EntitySpecV2) GetTags() map[string]string

func (*EntitySpecV2) GetValueType 

func (x *EntitySpecV2) GetValueType() types.ValueType_Enum

func (*EntitySpecV2) ProtoMessage 

func (*EntitySpecV2) ProtoMessage()

func (*EntitySpecV2) ProtoReflect 

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

func (*EntitySpecV2) Reset 

func (x *EntitySpecV2) Reset()

func (*EntitySpecV2) String 

func (x *EntitySpecV2) String() string

type FeatureService 

type FeatureService struct {

	// User-specified specifications of this feature service.
	Spec *FeatureServiceSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// System-populated metadata for this feature service.
	Meta *FeatureServiceMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureService) Descriptor deprecated 

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

Deprecated: Use FeatureService.ProtoReflect.Descriptor instead.

func (*FeatureService) GetMeta 

func (x *FeatureService) GetMeta() *FeatureServiceMeta

func (*FeatureService) GetSpec 

func (x *FeatureService) GetSpec() *FeatureServiceSpec

func (*FeatureService) ProtoMessage 

func (*FeatureService) ProtoMessage()

func (*FeatureService) ProtoReflect 

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

func (*FeatureService) Reset 

func (x *FeatureService) Reset()

func (*FeatureService) String 

func (x *FeatureService) String() string

type FeatureServiceMeta 

type FeatureServiceMeta struct {

	// Time where this Feature Service is created
	CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Time where this Feature Service is last updated
	LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureServiceMeta) Descriptor deprecated 

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

Deprecated: Use FeatureServiceMeta.ProtoReflect.Descriptor instead.

func (*FeatureServiceMeta) GetCreatedTimestamp 

func (x *FeatureServiceMeta) GetCreatedTimestamp() *timestamppb.Timestamp

func (*FeatureServiceMeta) GetLastUpdatedTimestamp 

func (x *FeatureServiceMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp

func (*FeatureServiceMeta) ProtoMessage 

func (*FeatureServiceMeta) ProtoMessage()

func (*FeatureServiceMeta) ProtoReflect 

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

func (*FeatureServiceMeta) Reset 

func (x *FeatureServiceMeta) Reset()

func (*FeatureServiceMeta) String 

func (x *FeatureServiceMeta) String() string

type FeatureServiceSpec 

type FeatureServiceSpec struct {

	// Name of the Feature Service. Must be unique. Not updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this Feature Service belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Represents a projection that's to be applied on top of the FeatureView.
	// Contains data such as the features to use from a FeatureView.
	Features []*FeatureViewProjection `protobuf:"bytes,3,rep,name=features,proto3" json:"features,omitempty"`
	// User defined metadata
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Description of the feature service.
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// Owner of the feature service.
	Owner string `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	// (optional) if provided logging will be enabled for this feature service.
	LoggingConfig *LoggingConfig `protobuf:"bytes,7,opt,name=logging_config,json=loggingConfig,proto3" json:"logging_config,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureServiceSpec) Descriptor deprecated 

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

Deprecated: Use FeatureServiceSpec.ProtoReflect.Descriptor instead.

func (*FeatureServiceSpec) GetDescription 

func (x *FeatureServiceSpec) GetDescription() string

func (*FeatureServiceSpec) GetFeatures 

func (x *FeatureServiceSpec) GetFeatures() []*FeatureViewProjection

func (*FeatureServiceSpec) GetLoggingConfig 

func (x *FeatureServiceSpec) GetLoggingConfig() *LoggingConfig

func (*FeatureServiceSpec) GetName 

func (x *FeatureServiceSpec) GetName() string

func (*FeatureServiceSpec) GetOwner 

func (x *FeatureServiceSpec) GetOwner() string

func (*FeatureServiceSpec) GetProject 

func (x *FeatureServiceSpec) GetProject() string

func (*FeatureServiceSpec) GetTags 

func (x *FeatureServiceSpec) GetTags() map[string]string

func (*FeatureServiceSpec) ProtoMessage 

func (*FeatureServiceSpec) ProtoMessage()

func (*FeatureServiceSpec) ProtoReflect 

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

func (*FeatureServiceSpec) Reset 

func (x *FeatureServiceSpec) Reset()

func (*FeatureServiceSpec) String 

func (x *FeatureServiceSpec) String() string

type FeatureSpecV2 

type FeatureSpecV2 struct {

	// Name of the feature. Not updatable.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value type of the feature. Not updatable.
	ValueType types.ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"`
	// Tags for user defined metadata on a feature
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeatureSpecV2) Descriptor deprecated 

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

Deprecated: Use FeatureSpecV2.ProtoReflect.Descriptor instead.

func (*FeatureSpecV2) GetName 

func (x *FeatureSpecV2) GetName() string

func (*FeatureSpecV2) GetTags 

func (x *FeatureSpecV2) GetTags() map[string]string

func (*FeatureSpecV2) GetValueType 

func (x *FeatureSpecV2) GetValueType() types.ValueType_Enum

func (*FeatureSpecV2) ProtoMessage 

func (*FeatureSpecV2) ProtoMessage()

func (*FeatureSpecV2) ProtoReflect 

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

func (*FeatureSpecV2) Reset 

func (x *FeatureSpecV2) Reset()

func (*FeatureSpecV2) String 

func (x *FeatureSpecV2) String() string

type FeatureTable 

type FeatureTable struct {

	// User-specified specifications of this feature table.
	Spec *FeatureTableSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// System-populated metadata for this feature table.
	Meta *FeatureTableMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureTable) Descriptor deprecated 

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

Deprecated: Use FeatureTable.ProtoReflect.Descriptor instead.

func (*FeatureTable) GetMeta 

func (x *FeatureTable) GetMeta() *FeatureTableMeta

func (*FeatureTable) GetSpec 

func (x *FeatureTable) GetSpec() *FeatureTableSpec

func (*FeatureTable) ProtoMessage 

func (*FeatureTable) ProtoMessage()

func (*FeatureTable) ProtoReflect 

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

func (*FeatureTable) Reset 

func (x *FeatureTable) Reset()

func (*FeatureTable) String 

func (x *FeatureTable) String() string

type FeatureTableMeta 

type FeatureTableMeta struct {

	// Time where this Feature Table is created
	CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Time where this Feature Table is last updated
	LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"`
	// Auto incrementing revision no. of this Feature Table
	Revision int64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"`
	// Hash entities, features, batch_source and stream_source to inform JobService if
	// jobs should be restarted should hash change
	Hash string `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureTableMeta) Descriptor deprecated 

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

Deprecated: Use FeatureTableMeta.ProtoReflect.Descriptor instead.

func (*FeatureTableMeta) GetCreatedTimestamp 

func (x *FeatureTableMeta) GetCreatedTimestamp() *timestamppb.Timestamp

func (*FeatureTableMeta) GetHash 

func (x *FeatureTableMeta) GetHash() string

func (*FeatureTableMeta) GetLastUpdatedTimestamp 

func (x *FeatureTableMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp

func (*FeatureTableMeta) GetRevision 

func (x *FeatureTableMeta) GetRevision() int64

func (*FeatureTableMeta) ProtoMessage 

func (*FeatureTableMeta) ProtoMessage()

func (*FeatureTableMeta) ProtoReflect 

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

func (*FeatureTableMeta) Reset 

func (x *FeatureTableMeta) Reset()

func (*FeatureTableMeta) String 

func (x *FeatureTableMeta) String() string

type FeatureTableSpec 

type FeatureTableSpec struct {

	// Name of the feature table. Must be unique. Not updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this feature table belongs to.
	Project string `protobuf:"bytes,9,opt,name=project,proto3" json:"project,omitempty"`
	// List names of entities to associate with the Features defined in this
	// Feature Table. Not updatable.
	Entities []string `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"`
	// List of features specifications for each feature defined with this feature table.
	Features []*FeatureSpecV2 `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"`
	// User defined metadata
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Features in this feature table can only be retrieved from online serving
	// younger than max age. Age is measured as the duration of time between
	// the feature's event timestamp and when the feature is retrieved
	// Feature values outside max age will be returned as unset values and indicated to end user
	MaxAge *durationpb.Duration `protobuf:"bytes,6,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`
	// Batch/Offline DataSource to source batch/offline feature data.
	// Only batch DataSource can be specified
	// (ie source type should start with 'BATCH_')
	BatchSource *DataSource `protobuf:"bytes,7,opt,name=batch_source,json=batchSource,proto3" json:"batch_source,omitempty"`
	// Stream/Online DataSource to source stream/online feature data.
	// Only stream DataSource can be specified
	// (ie source type should start with 'STREAM_')
	StreamSource *DataSource `protobuf:"bytes,8,opt,name=stream_source,json=streamSource,proto3" json:"stream_source,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureTableSpec) Descriptor deprecated 

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

Deprecated: Use FeatureTableSpec.ProtoReflect.Descriptor instead.

func (*FeatureTableSpec) GetBatchSource 

func (x *FeatureTableSpec) GetBatchSource() *DataSource

func (*FeatureTableSpec) GetEntities 

func (x *FeatureTableSpec) GetEntities() []string

func (*FeatureTableSpec) GetFeatures 

func (x *FeatureTableSpec) GetFeatures() []*FeatureSpecV2

func (*FeatureTableSpec) GetLabels 

func (x *FeatureTableSpec) GetLabels() map[string]string

func (*FeatureTableSpec) GetMaxAge 

func (x *FeatureTableSpec) GetMaxAge() *durationpb.Duration

func (*FeatureTableSpec) GetName 

func (x *FeatureTableSpec) GetName() string

func (*FeatureTableSpec) GetProject 

func (x *FeatureTableSpec) GetProject() string

func (*FeatureTableSpec) GetStreamSource 

func (x *FeatureTableSpec) GetStreamSource() *DataSource

func (*FeatureTableSpec) ProtoMessage 

func (*FeatureTableSpec) ProtoMessage()

func (*FeatureTableSpec) ProtoReflect 

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

func (*FeatureTableSpec) Reset 

func (x *FeatureTableSpec) Reset()

func (*FeatureTableSpec) String 

func (x *FeatureTableSpec) String() string

type FeatureView 

type FeatureView struct {

	// User-specified specifications of this feature view.
	Spec *FeatureViewSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// System-populated metadata for this feature view.
	Meta *FeatureViewMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureView) Descriptor deprecated 

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

Deprecated: Use FeatureView.ProtoReflect.Descriptor instead.

func (*FeatureView) GetMeta 

func (x *FeatureView) GetMeta() *FeatureViewMeta

func (*FeatureView) GetSpec 

func (x *FeatureView) GetSpec() *FeatureViewSpec

func (*FeatureView) ProtoMessage 

func (*FeatureView) ProtoMessage()

func (*FeatureView) ProtoReflect 

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

func (*FeatureView) Reset 

func (x *FeatureView) Reset()

func (*FeatureView) String 

func (x *FeatureView) String() string

type FeatureViewMeta 

type FeatureViewMeta struct {

	// Time where this Feature View is created
	CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Time where this Feature View is last updated
	LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"`
	// List of pairs (start_time, end_time) for which this feature view has been materialized.
	MaterializationIntervals []*MaterializationInterval `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeatureViewMeta) Descriptor deprecated 

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

Deprecated: Use FeatureViewMeta.ProtoReflect.Descriptor instead.

func (*FeatureViewMeta) GetCreatedTimestamp 

func (x *FeatureViewMeta) GetCreatedTimestamp() *timestamppb.Timestamp

func (*FeatureViewMeta) GetLastUpdatedTimestamp 

func (x *FeatureViewMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp

func (*FeatureViewMeta) GetMaterializationIntervals 

func (x *FeatureViewMeta) GetMaterializationIntervals() []*MaterializationInterval

func (*FeatureViewMeta) ProtoMessage 

func (*FeatureViewMeta) ProtoMessage()

func (*FeatureViewMeta) ProtoReflect 

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

func (*FeatureViewMeta) Reset 

func (x *FeatureViewMeta) Reset()

func (*FeatureViewMeta) String 

func (x *FeatureViewMeta) String() string

type FeatureViewProjection 

type FeatureViewProjection struct {

	// The feature view name
	FeatureViewName string `protobuf:"bytes,1,opt,name=feature_view_name,json=featureViewName,proto3" json:"feature_view_name,omitempty"`
	// Alias for feature view name
	FeatureViewNameAlias string `protobuf:"bytes,3,opt,name=feature_view_name_alias,json=featureViewNameAlias,proto3" json:"feature_view_name_alias,omitempty"`
	// The features of the feature view that are a part of the feature reference.
	FeatureColumns []*FeatureSpecV2 `protobuf:"bytes,2,rep,name=feature_columns,json=featureColumns,proto3" json:"feature_columns,omitempty"`
	// Map for entity join_key overrides of feature data entity join_key to entity data join_key
	JoinKeyMap map[string]string `` /* 181-byte string literal not displayed */
	// contains filtered or unexported fields
}

A projection to be applied on top of a FeatureView. Contains the modifications to a FeatureView such as the features subset to use.

func (*FeatureViewProjection) Descriptor deprecated 

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

Deprecated: Use FeatureViewProjection.ProtoReflect.Descriptor instead.

func (*FeatureViewProjection) GetFeatureColumns 

func (x *FeatureViewProjection) GetFeatureColumns() []*FeatureSpecV2

func (*FeatureViewProjection) GetFeatureViewName 

func (x *FeatureViewProjection) GetFeatureViewName() string

func (*FeatureViewProjection) GetFeatureViewNameAlias 

func (x *FeatureViewProjection) GetFeatureViewNameAlias() string

func (*FeatureViewProjection) GetJoinKeyMap 

func (x *FeatureViewProjection) GetJoinKeyMap() map[string]string

func (*FeatureViewProjection) ProtoMessage 

func (*FeatureViewProjection) ProtoMessage()

func (*FeatureViewProjection) ProtoReflect 

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

func (*FeatureViewProjection) Reset 

func (x *FeatureViewProjection) Reset()

func (*FeatureViewProjection) String 

func (x *FeatureViewProjection) String() string

type FeatureViewSpec 

type FeatureViewSpec struct {

	// Name of the feature view. Must be unique. Not updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this feature view belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// List of names of entities associated with this feature view.
	Entities []string `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"`
	// List of specifications for each feature defined as part of this feature view.
	Features []*FeatureSpecV2 `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"`
	// List of specifications for each entity defined as part of this feature view.
	EntityColumns []*FeatureSpecV2 `protobuf:"bytes,12,rep,name=entity_columns,json=entityColumns,proto3" json:"entity_columns,omitempty"`
	// Description of the feature view.
	Description string `protobuf:"bytes,10,opt,name=description,proto3" json:"description,omitempty"`
	// User defined metadata
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Owner of the feature view.
	Owner string `protobuf:"bytes,11,opt,name=owner,proto3" json:"owner,omitempty"`
	// Features in this feature view can only be retrieved from online serving
	// younger than ttl. Ttl is measured as the duration of time between
	// the feature's event timestamp and when the feature is retrieved
	// Feature values outside ttl will be returned as unset values and indicated to end user
	Ttl *durationpb.Duration `protobuf:"bytes,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Batch/Offline DataSource where this view can retrieve offline feature data.
	BatchSource *DataSource `protobuf:"bytes,7,opt,name=batch_source,json=batchSource,proto3" json:"batch_source,omitempty"`
	// Streaming DataSource from where this view can consume "online" feature data.
	StreamSource *DataSource `protobuf:"bytes,9,opt,name=stream_source,json=streamSource,proto3" json:"stream_source,omitempty"`
	// Whether these features should be served online or not
	Online bool `protobuf:"varint,8,opt,name=online,proto3" json:"online,omitempty"`
	// contains filtered or unexported fields
}

Next available id: 13 TODO(adchia): refactor common fields from this and ODFV into separate metadata proto

func (*FeatureViewSpec) Descriptor deprecated 

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

Deprecated: Use FeatureViewSpec.ProtoReflect.Descriptor instead.

func (*FeatureViewSpec) GetBatchSource 

func (x *FeatureViewSpec) GetBatchSource() *DataSource

func (*FeatureViewSpec) GetDescription 

func (x *FeatureViewSpec) GetDescription() string

func (*FeatureViewSpec) GetEntities 

func (x *FeatureViewSpec) GetEntities() []string

func (*FeatureViewSpec) GetEntityColumns 

func (x *FeatureViewSpec) GetEntityColumns() []*FeatureSpecV2

func (*FeatureViewSpec) GetFeatures 

func (x *FeatureViewSpec) GetFeatures() []*FeatureSpecV2

func (*FeatureViewSpec) GetName 

func (x *FeatureViewSpec) GetName() string

func (*FeatureViewSpec) GetOnline 

func (x *FeatureViewSpec) GetOnline() bool

func (*FeatureViewSpec) GetOwner 

func (x *FeatureViewSpec) GetOwner() string

func (*FeatureViewSpec) GetProject 

func (x *FeatureViewSpec) GetProject() string

func (*FeatureViewSpec) GetStreamSource 

func (x *FeatureViewSpec) GetStreamSource() *DataSource

func (*FeatureViewSpec) GetTags 

func (x *FeatureViewSpec) GetTags() map[string]string

func (*FeatureViewSpec) GetTtl 

func (x *FeatureViewSpec) GetTtl() *durationpb.Duration

func (*FeatureViewSpec) ProtoMessage 

func (*FeatureViewSpec) ProtoMessage()

func (*FeatureViewSpec) ProtoReflect 

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

func (*FeatureViewSpec) Reset 

func (x *FeatureViewSpec) Reset()

func (*FeatureViewSpec) String 

func (x *FeatureViewSpec) String() string

type FileFormat 

type FileFormat struct {

	// Types that are assignable to Format:
	//	*FileFormat_ParquetFormat_
	Format isFileFormat_Format `protobuf_oneof:"format"`
	// contains filtered or unexported fields
}

Defines the file format encoding the features/entity data in files

func (*FileFormat) Descriptor deprecated 

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

Deprecated: Use FileFormat.ProtoReflect.Descriptor instead.

func (*FileFormat) GetFormat 

func (m *FileFormat) GetFormat() isFileFormat_Format

func (*FileFormat) GetParquetFormat 

func (x *FileFormat) GetParquetFormat() *FileFormat_ParquetFormat

func (*FileFormat) ProtoMessage 

func (*FileFormat) ProtoMessage()

func (*FileFormat) ProtoReflect 

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

func (*FileFormat) Reset 

func (x *FileFormat) Reset()

func (*FileFormat) String 

func (x *FileFormat) String() string

type FileFormat_ParquetFormat 

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

Defines options for the Parquet data format

func (*FileFormat_ParquetFormat) Descriptor deprecated 

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

Deprecated: Use FileFormat_ParquetFormat.ProtoReflect.Descriptor instead.

func (*FileFormat_ParquetFormat) ProtoMessage 

func (*FileFormat_ParquetFormat) ProtoMessage()

func (*FileFormat_ParquetFormat) ProtoReflect 

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

func (*FileFormat_ParquetFormat) Reset 

func (x *FileFormat_ParquetFormat) Reset()

func (*FileFormat_ParquetFormat) String 

func (x *FileFormat_ParquetFormat) String() string

type FileFormat_ParquetFormat_ 

type FileFormat_ParquetFormat_ struct {
	ParquetFormat *FileFormat_ParquetFormat `protobuf:"bytes,1,opt,name=parquet_format,json=parquetFormat,proto3,oneof"`
}

type GEValidationProfile 

type GEValidationProfile struct {

	// JSON-serialized ExpectationSuite object
	ExpectationSuite []byte `protobuf:"bytes,1,opt,name=expectation_suite,json=expectationSuite,proto3" json:"expectation_suite,omitempty"`
	// contains filtered or unexported fields
}

func (*GEValidationProfile) Descriptor deprecated 

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

Deprecated: Use GEValidationProfile.ProtoReflect.Descriptor instead.

func (*GEValidationProfile) GetExpectationSuite 

func (x *GEValidationProfile) GetExpectationSuite() []byte

func (*GEValidationProfile) ProtoMessage 

func (*GEValidationProfile) ProtoMessage()

func (*GEValidationProfile) ProtoReflect 

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

func (*GEValidationProfile) Reset 

func (x *GEValidationProfile) Reset()

func (*GEValidationProfile) String 

func (x *GEValidationProfile) String() string

type GEValidationProfiler 

type GEValidationProfiler struct {
	Profiler *GEValidationProfiler_UserDefinedProfiler `protobuf:"bytes,1,opt,name=profiler,proto3" json:"profiler,omitempty"`
	// contains filtered or unexported fields
}

func (*GEValidationProfiler) Descriptor deprecated 

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

Deprecated: Use GEValidationProfiler.ProtoReflect.Descriptor instead.

func (*GEValidationProfiler) GetProfiler 

func (x *GEValidationProfiler) GetProfiler() *GEValidationProfiler_UserDefinedProfiler

func (*GEValidationProfiler) ProtoMessage 

func (*GEValidationProfiler) ProtoMessage()

func (*GEValidationProfiler) ProtoReflect 

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

func (*GEValidationProfiler) Reset 

func (x *GEValidationProfiler) Reset()

func (*GEValidationProfiler) String 

func (x *GEValidationProfiler) String() string

type GEValidationProfiler_UserDefinedProfiler 

type GEValidationProfiler_UserDefinedProfiler struct {

	// The python-syntax function body (serialized by dill)
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*GEValidationProfiler_UserDefinedProfiler) Descriptor deprecated 

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

Deprecated: Use GEValidationProfiler_UserDefinedProfiler.ProtoReflect.Descriptor instead.

func (*GEValidationProfiler_UserDefinedProfiler) GetBody 

func (x *GEValidationProfiler_UserDefinedProfiler) GetBody() []byte

func (*GEValidationProfiler_UserDefinedProfiler) ProtoMessage 

func (*GEValidationProfiler_UserDefinedProfiler) ProtoMessage()

func (*GEValidationProfiler_UserDefinedProfiler) ProtoReflect 

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

func (*GEValidationProfiler_UserDefinedProfiler) Reset 

func (x *GEValidationProfiler_UserDefinedProfiler) Reset()

func (*GEValidationProfiler_UserDefinedProfiler) String 

func (x *GEValidationProfiler_UserDefinedProfiler) String() string

type Infra 

type Infra struct {

	// List of infrastructure objects managed by Feast
	InfraObjects []*InfraObject `protobuf:"bytes,1,rep,name=infra_objects,json=infraObjects,proto3" json:"infra_objects,omitempty"`
	// contains filtered or unexported fields
}

Represents a set of infrastructure objects managed by Feast

func (*Infra) Descriptor deprecated 

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

Deprecated: Use Infra.ProtoReflect.Descriptor instead.

func (*Infra) GetInfraObjects 

func (x *Infra) GetInfraObjects() []*InfraObject

func (*Infra) ProtoMessage 

func (*Infra) ProtoMessage()

func (*Infra) ProtoReflect 

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

func (*Infra) Reset 

func (x *Infra) Reset()

func (*Infra) String 

func (x *Infra) String() string

type InfraObject 

type InfraObject struct {

	// Represents the Python class for the infrastructure object
	InfraObjectClassType string `protobuf:"bytes,1,opt,name=infra_object_class_type,json=infraObjectClassType,proto3" json:"infra_object_class_type,omitempty"`
	// The infrastructure object
	//
	// Types that are assignable to InfraObject:
	//	*InfraObject_DynamodbTable
	//	*InfraObject_DatastoreTable
	//	*InfraObject_SqliteTable
	//	*InfraObject_CustomInfra_
	InfraObject isInfraObject_InfraObject `protobuf_oneof:"infra_object"`
	// contains filtered or unexported fields
}

Represents a single infrastructure object managed by Feast

func (*InfraObject) Descriptor deprecated 

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

Deprecated: Use InfraObject.ProtoReflect.Descriptor instead.

func (*InfraObject) GetCustomInfra 

func (x *InfraObject) GetCustomInfra() *InfraObject_CustomInfra

func (*InfraObject) GetDatastoreTable 

func (x *InfraObject) GetDatastoreTable() *DatastoreTable

func (*InfraObject) GetDynamodbTable 

func (x *InfraObject) GetDynamodbTable() *DynamoDBTable

func (*InfraObject) GetInfraObject 

func (m *InfraObject) GetInfraObject() isInfraObject_InfraObject

func (*InfraObject) GetInfraObjectClassType 

func (x *InfraObject) GetInfraObjectClassType() string

func (*InfraObject) GetSqliteTable 

func (x *InfraObject) GetSqliteTable() *SqliteTable

func (*InfraObject) ProtoMessage 

func (*InfraObject) ProtoMessage()

func (*InfraObject) ProtoReflect 

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

func (*InfraObject) Reset 

func (x *InfraObject) Reset()

func (*InfraObject) String 

func (x *InfraObject) String() string

type InfraObject_CustomInfra 

type InfraObject_CustomInfra struct {
	Field []byte `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

Allows for custom infra objects to be added

func (*InfraObject_CustomInfra) Descriptor deprecated 

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

Deprecated: Use InfraObject_CustomInfra.ProtoReflect.Descriptor instead.

func (*InfraObject_CustomInfra) GetField 

func (x *InfraObject_CustomInfra) GetField() []byte

func (*InfraObject_CustomInfra) ProtoMessage 

func (*InfraObject_CustomInfra) ProtoMessage()

func (*InfraObject_CustomInfra) ProtoReflect 

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

func (*InfraObject_CustomInfra) Reset 

func (x *InfraObject_CustomInfra) Reset()

func (*InfraObject_CustomInfra) String 

func (x *InfraObject_CustomInfra) String() string

type InfraObject_CustomInfra_ 

type InfraObject_CustomInfra_ struct {
	CustomInfra *InfraObject_CustomInfra `protobuf:"bytes,100,opt,name=custom_infra,json=customInfra,proto3,oneof"`
}

type InfraObject_DatastoreTable 

type InfraObject_DatastoreTable struct {
	DatastoreTable *DatastoreTable `protobuf:"bytes,3,opt,name=datastore_table,json=datastoreTable,proto3,oneof"`
}

type InfraObject_DynamodbTable 

type InfraObject_DynamodbTable struct {
	DynamodbTable *DynamoDBTable `protobuf:"bytes,2,opt,name=dynamodb_table,json=dynamodbTable,proto3,oneof"`
}

type InfraObject_SqliteTable 

type InfraObject_SqliteTable struct {
	SqliteTable *SqliteTable `protobuf:"bytes,4,opt,name=sqlite_table,json=sqliteTable,proto3,oneof"`
}

type LoggingConfig 

type LoggingConfig struct {
	SampleRate float32 `protobuf:"fixed32,1,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
	// Types that are assignable to Destination:
	//	*LoggingConfig_FileDestination_
	//	*LoggingConfig_BigqueryDestination
	//	*LoggingConfig_RedshiftDestination_
	//	*LoggingConfig_SnowflakeDestination_
	//	*LoggingConfig_CustomDestination_
	//	*LoggingConfig_AthenaDestination_
	Destination isLoggingConfig_Destination `protobuf_oneof:"destination"`
	// contains filtered or unexported fields
}

func (*LoggingConfig) Descriptor deprecated 

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

Deprecated: Use LoggingConfig.ProtoReflect.Descriptor instead.

func (*LoggingConfig) GetAthenaDestination 

func (x *LoggingConfig) GetAthenaDestination() *LoggingConfig_AthenaDestination

func (*LoggingConfig) GetBigqueryDestination 

func (x *LoggingConfig) GetBigqueryDestination() *LoggingConfig_BigQueryDestination

func (*LoggingConfig) GetCustomDestination 

func (x *LoggingConfig) GetCustomDestination() *LoggingConfig_CustomDestination

func (*LoggingConfig) GetDestination 

func (m *LoggingConfig) GetDestination() isLoggingConfig_Destination

func (*LoggingConfig) GetFileDestination 

func (x *LoggingConfig) GetFileDestination() *LoggingConfig_FileDestination

func (*LoggingConfig) GetRedshiftDestination 

func (x *LoggingConfig) GetRedshiftDestination() *LoggingConfig_RedshiftDestination

func (*LoggingConfig) GetSampleRate 

func (x *LoggingConfig) GetSampleRate() float32

func (*LoggingConfig) GetSnowflakeDestination 

func (x *LoggingConfig) GetSnowflakeDestination() *LoggingConfig_SnowflakeDestination

func (*LoggingConfig) ProtoMessage 

func (*LoggingConfig) ProtoMessage()

func (*LoggingConfig) ProtoReflect 

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

func (*LoggingConfig) Reset 

func (x *LoggingConfig) Reset()

func (*LoggingConfig) String 

func (x *LoggingConfig) String() string

type LoggingConfig_AthenaDestination 

type LoggingConfig_AthenaDestination struct {

	// Destination table name. data_source and database will be taken from an offline store config
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*LoggingConfig_AthenaDestination) Descriptor deprecated 

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

Deprecated: Use LoggingConfig_AthenaDestination.ProtoReflect.Descriptor instead.

func (*LoggingConfig_AthenaDestination) GetTableName 

func (x *LoggingConfig_AthenaDestination) GetTableName() string

func (*LoggingConfig_AthenaDestination) ProtoMessage 

func (*LoggingConfig_AthenaDestination) ProtoMessage()

func (*LoggingConfig_AthenaDestination) ProtoReflect 

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

func (*LoggingConfig_AthenaDestination) Reset 

func (x *LoggingConfig_AthenaDestination) Reset()

func (*LoggingConfig_AthenaDestination) String 

func (x *LoggingConfig_AthenaDestination) String() string

type LoggingConfig_AthenaDestination_ 

type LoggingConfig_AthenaDestination_ struct {
	AthenaDestination *LoggingConfig_AthenaDestination `protobuf:"bytes,8,opt,name=athena_destination,json=athenaDestination,proto3,oneof"`
}

type LoggingConfig_BigQueryDestination 

type LoggingConfig_BigQueryDestination struct {

	// Full table reference in the form of [project:dataset.table]
	TableRef string `protobuf:"bytes,1,opt,name=table_ref,json=tableRef,proto3" json:"table_ref,omitempty"`
	// contains filtered or unexported fields
}

func (*LoggingConfig_BigQueryDestination) Descriptor deprecated 

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

Deprecated: Use LoggingConfig_BigQueryDestination.ProtoReflect.Descriptor instead.

func (*LoggingConfig_BigQueryDestination) GetTableRef 

func (x *LoggingConfig_BigQueryDestination) GetTableRef() string

func (*LoggingConfig_BigQueryDestination) ProtoMessage 

func (*LoggingConfig_BigQueryDestination) ProtoMessage()

func (*LoggingConfig_BigQueryDestination) ProtoReflect 

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

func (*LoggingConfig_BigQueryDestination) Reset 

func (x *LoggingConfig_BigQueryDestination) Reset()

func (*LoggingConfig_BigQueryDestination) String 

func (x *LoggingConfig_BigQueryDestination) String() string

type LoggingConfig_BigqueryDestination 

type LoggingConfig_BigqueryDestination struct {
	BigqueryDestination *LoggingConfig_BigQueryDestination `protobuf:"bytes,4,opt,name=bigquery_destination,json=bigqueryDestination,proto3,oneof"`
}

type LoggingConfig_CustomDestination 

type LoggingConfig_CustomDestination struct {
	Kind   string            `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
	Config map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LoggingConfig_CustomDestination) Descriptor deprecated 

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

Deprecated: Use LoggingConfig_CustomDestination.ProtoReflect.Descriptor instead.

func (*LoggingConfig_CustomDestination) GetConfig 

func (x *LoggingConfig_CustomDestination) GetConfig() map[string]string

func (*LoggingConfig_CustomDestination) GetKind 

func (x *LoggingConfig_CustomDestination) GetKind() string

func (*LoggingConfig_CustomDestination) ProtoMessage 

func (*LoggingConfig_CustomDestination) ProtoMessage()

func (*LoggingConfig_CustomDestination) ProtoReflect 

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

func (*LoggingConfig_CustomDestination) Reset 

func (x *LoggingConfig_CustomDestination) Reset()

func (*LoggingConfig_CustomDestination) String 

func (x *LoggingConfig_CustomDestination) String() string

type LoggingConfig_CustomDestination_ 

type LoggingConfig_CustomDestination_ struct {
	CustomDestination *LoggingConfig_CustomDestination `protobuf:"bytes,7,opt,name=custom_destination,json=customDestination,proto3,oneof"`
}

type LoggingConfig_FileDestination 

type LoggingConfig_FileDestination struct {
	Path               string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	S3EndpointOverride string `protobuf:"bytes,2,opt,name=s3_endpoint_override,json=s3EndpointOverride,proto3" json:"s3_endpoint_override,omitempty"`
	// column names to use for partitioning
	PartitionBy []string `protobuf:"bytes,3,rep,name=partition_by,json=partitionBy,proto3" json:"partition_by,omitempty"`
	// contains filtered or unexported fields
}

func (*LoggingConfig_FileDestination) Descriptor deprecated 

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

Deprecated: Use LoggingConfig_FileDestination.ProtoReflect.Descriptor instead.

func (*LoggingConfig_FileDestination) GetPartitionBy 

func (x *LoggingConfig_FileDestination) GetPartitionBy() []string

func (*LoggingConfig_FileDestination) GetPath 

func (x *LoggingConfig_FileDestination) GetPath() string

func (*LoggingConfig_FileDestination) GetS3EndpointOverride 

func (x *LoggingConfig_FileDestination) GetS3EndpointOverride() string

func (*LoggingConfig_FileDestination) ProtoMessage 

func (*LoggingConfig_FileDestination) ProtoMessage()

func (*LoggingConfig_FileDestination) ProtoReflect 

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

func (*LoggingConfig_FileDestination) Reset 

func (x *LoggingConfig_FileDestination) Reset()

func (*LoggingConfig_FileDestination) String 

func (x *LoggingConfig_FileDestination) String() string

type LoggingConfig_FileDestination_ 

type LoggingConfig_FileDestination_ struct {
	FileDestination *LoggingConfig_FileDestination `protobuf:"bytes,3,opt,name=file_destination,json=fileDestination,proto3,oneof"`
}

type LoggingConfig_RedshiftDestination 

type LoggingConfig_RedshiftDestination struct {

	// Destination table name. ClusterId and database will be taken from an offline store config
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*LoggingConfig_RedshiftDestination) Descriptor deprecated 

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

Deprecated: Use LoggingConfig_RedshiftDestination.ProtoReflect.Descriptor instead.

func (*LoggingConfig_RedshiftDestination) GetTableName 

func (x *LoggingConfig_RedshiftDestination) GetTableName() string

func (*LoggingConfig_RedshiftDestination) ProtoMessage 

func (*LoggingConfig_RedshiftDestination) ProtoMessage()

func (*LoggingConfig_RedshiftDestination) ProtoReflect 

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

func (*LoggingConfig_RedshiftDestination) Reset 

func (x *LoggingConfig_RedshiftDestination) Reset()

func (*LoggingConfig_RedshiftDestination) String 

func (x *LoggingConfig_RedshiftDestination) String() string

type LoggingConfig_RedshiftDestination_ 

type LoggingConfig_RedshiftDestination_ struct {
	RedshiftDestination *LoggingConfig_RedshiftDestination `protobuf:"bytes,5,opt,name=redshift_destination,json=redshiftDestination,proto3,oneof"`
}

type LoggingConfig_SnowflakeDestination 

type LoggingConfig_SnowflakeDestination struct {

	// Destination table name. Schema and database will be taken from an offline store config
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*LoggingConfig_SnowflakeDestination) Descriptor deprecated 

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

Deprecated: Use LoggingConfig_SnowflakeDestination.ProtoReflect.Descriptor instead.

func (*LoggingConfig_SnowflakeDestination) GetTableName 

func (x *LoggingConfig_SnowflakeDestination) GetTableName() string

func (*LoggingConfig_SnowflakeDestination) ProtoMessage 

func (*LoggingConfig_SnowflakeDestination) ProtoMessage()

func (*LoggingConfig_SnowflakeDestination) ProtoReflect 

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

func (*LoggingConfig_SnowflakeDestination) Reset 

func (x *LoggingConfig_SnowflakeDestination) Reset()

func (*LoggingConfig_SnowflakeDestination) String 

func (x *LoggingConfig_SnowflakeDestination) String() string

type LoggingConfig_SnowflakeDestination_ 

type LoggingConfig_SnowflakeDestination_ struct {
	SnowflakeDestination *LoggingConfig_SnowflakeDestination `protobuf:"bytes,6,opt,name=snowflake_destination,json=snowflakeDestination,proto3,oneof"`
}

type MaterializationInterval 

type MaterializationInterval struct {
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*MaterializationInterval) Descriptor deprecated 

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

Deprecated: Use MaterializationInterval.ProtoReflect.Descriptor instead.

func (*MaterializationInterval) GetEndTime 

func (x *MaterializationInterval) GetEndTime() *timestamppb.Timestamp

func (*MaterializationInterval) GetStartTime 

func (x *MaterializationInterval) GetStartTime() *timestamppb.Timestamp

func (*MaterializationInterval) ProtoMessage 

func (*MaterializationInterval) ProtoMessage()

func (*MaterializationInterval) ProtoReflect 

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

func (*MaterializationInterval) Reset 

func (x *MaterializationInterval) Reset()

func (*MaterializationInterval) String 

func (x *MaterializationInterval) String() string

type OnDemandFeatureView 

type OnDemandFeatureView struct {

	// User-specified specifications of this feature view.
	Spec *OnDemandFeatureViewSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Meta *OnDemandFeatureViewMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*OnDemandFeatureView) Descriptor deprecated 

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

Deprecated: Use OnDemandFeatureView.ProtoReflect.Descriptor instead.

func (*OnDemandFeatureView) GetMeta 

func (x *OnDemandFeatureView) GetMeta() *OnDemandFeatureViewMeta

func (*OnDemandFeatureView) GetSpec 

func (x *OnDemandFeatureView) GetSpec() *OnDemandFeatureViewSpec

func (*OnDemandFeatureView) ProtoMessage 

func (*OnDemandFeatureView) ProtoMessage()

func (*OnDemandFeatureView) ProtoReflect 

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

func (*OnDemandFeatureView) Reset 

func (x *OnDemandFeatureView) Reset()

func (*OnDemandFeatureView) String 

func (x *OnDemandFeatureView) String() string

type OnDemandFeatureViewMeta 

type OnDemandFeatureViewMeta struct {

	// Time where this Feature View is created
	CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Time where this Feature View is last updated
	LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*OnDemandFeatureViewMeta) Descriptor deprecated 

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

Deprecated: Use OnDemandFeatureViewMeta.ProtoReflect.Descriptor instead.

func (*OnDemandFeatureViewMeta) GetCreatedTimestamp 

func (x *OnDemandFeatureViewMeta) GetCreatedTimestamp() *timestamppb.Timestamp

func (*OnDemandFeatureViewMeta) GetLastUpdatedTimestamp 

func (x *OnDemandFeatureViewMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp

func (*OnDemandFeatureViewMeta) ProtoMessage 

func (*OnDemandFeatureViewMeta) ProtoMessage()

func (*OnDemandFeatureViewMeta) ProtoReflect 

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

func (*OnDemandFeatureViewMeta) Reset 

func (x *OnDemandFeatureViewMeta) Reset()

func (*OnDemandFeatureViewMeta) String 

func (x *OnDemandFeatureViewMeta) String() string

type OnDemandFeatureViewSpec 

type OnDemandFeatureViewSpec struct {

	// Name of the feature view. Must be unique. Not updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this feature view belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// List of features specifications for each feature defined with this feature view.
	Features []*FeatureSpecV2 `protobuf:"bytes,3,rep,name=features,proto3" json:"features,omitempty"`
	// Map of sources for this feature view.
	Sources             map[string]*OnDemandSource `` /* 155-byte string literal not displayed */
	UserDefinedFunction *UserDefinedFunction       `protobuf:"bytes,5,opt,name=user_defined_function,json=userDefinedFunction,proto3" json:"user_defined_function,omitempty"`
	// Description of the on demand feature view.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// User defined metadata.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Owner of the on demand feature view.
	Owner string `protobuf:"bytes,8,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

Next available id: 9

func (*OnDemandFeatureViewSpec) Descriptor deprecated 

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

Deprecated: Use OnDemandFeatureViewSpec.ProtoReflect.Descriptor instead.

func (*OnDemandFeatureViewSpec) GetDescription 

func (x *OnDemandFeatureViewSpec) GetDescription() string

func (*OnDemandFeatureViewSpec) GetFeatures 

func (x *OnDemandFeatureViewSpec) GetFeatures() []*FeatureSpecV2

func (*OnDemandFeatureViewSpec) GetName 

func (x *OnDemandFeatureViewSpec) GetName() string

func (*OnDemandFeatureViewSpec) GetOwner 

func (x *OnDemandFeatureViewSpec) GetOwner() string

func (*OnDemandFeatureViewSpec) GetProject 

func (x *OnDemandFeatureViewSpec) GetProject() string

func (*OnDemandFeatureViewSpec) GetSources 

func (x *OnDemandFeatureViewSpec) GetSources() map[string]*OnDemandSource

func (*OnDemandFeatureViewSpec) GetTags 

func (x *OnDemandFeatureViewSpec) GetTags() map[string]string

func (*OnDemandFeatureViewSpec) GetUserDefinedFunction 

func (x *OnDemandFeatureViewSpec) GetUserDefinedFunction() *UserDefinedFunction

func (*OnDemandFeatureViewSpec) ProtoMessage 

func (*OnDemandFeatureViewSpec) ProtoMessage()

func (*OnDemandFeatureViewSpec) ProtoReflect 

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

func (*OnDemandFeatureViewSpec) Reset 

func (x *OnDemandFeatureViewSpec) Reset()

func (*OnDemandFeatureViewSpec) String 

func (x *OnDemandFeatureViewSpec) String() string

type OnDemandSource 

type OnDemandSource struct {

	// Types that are assignable to Source:
	//	*OnDemandSource_FeatureView
	//	*OnDemandSource_FeatureViewProjection
	//	*OnDemandSource_RequestDataSource
	Source isOnDemandSource_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

func (*OnDemandSource) Descriptor deprecated 

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

Deprecated: Use OnDemandSource.ProtoReflect.Descriptor instead.

func (*OnDemandSource) GetFeatureView 

func (x *OnDemandSource) GetFeatureView() *FeatureView

func (*OnDemandSource) GetFeatureViewProjection 

func (x *OnDemandSource) GetFeatureViewProjection() *FeatureViewProjection

func (*OnDemandSource) GetRequestDataSource 

func (x *OnDemandSource) GetRequestDataSource() *DataSource

func (*OnDemandSource) GetSource 

func (m *OnDemandSource) GetSource() isOnDemandSource_Source

func (*OnDemandSource) ProtoMessage 

func (*OnDemandSource) ProtoMessage()

func (*OnDemandSource) ProtoReflect 

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

func (*OnDemandSource) Reset 

func (x *OnDemandSource) Reset()

func (*OnDemandSource) String 

func (x *OnDemandSource) String() string

type OnDemandSource_FeatureView 

type OnDemandSource_FeatureView struct {
	FeatureView *FeatureView `protobuf:"bytes,1,opt,name=feature_view,json=featureView,proto3,oneof"`
}

type OnDemandSource_FeatureViewProjection 

type OnDemandSource_FeatureViewProjection struct {
	FeatureViewProjection *FeatureViewProjection `protobuf:"bytes,3,opt,name=feature_view_projection,json=featureViewProjection,proto3,oneof"`
}

type OnDemandSource_RequestDataSource 

type OnDemandSource_RequestDataSource struct {
	RequestDataSource *DataSource `protobuf:"bytes,2,opt,name=request_data_source,json=requestDataSource,proto3,oneof"`
}

type ProjectMetadata 

type ProjectMetadata struct {
	Project     string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	ProjectUuid string `protobuf:"bytes,2,opt,name=project_uuid,json=projectUuid,proto3" json:"project_uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectMetadata) Descriptor deprecated 

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

Deprecated: Use ProjectMetadata.ProtoReflect.Descriptor instead.

func (*ProjectMetadata) GetProject 

func (x *ProjectMetadata) GetProject() string

func (*ProjectMetadata) GetProjectUuid 

func (x *ProjectMetadata) GetProjectUuid() string

func (*ProjectMetadata) ProtoMessage 

func (*ProjectMetadata) ProtoMessage()

func (*ProjectMetadata) ProtoReflect 

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

func (*ProjectMetadata) Reset 

func (x *ProjectMetadata) Reset()

func (*ProjectMetadata) String 

func (x *ProjectMetadata) String() string

type Registry 

type Registry struct {
	Entities             []*Entity              `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	FeatureTables        []*FeatureTable        `protobuf:"bytes,2,rep,name=feature_tables,json=featureTables,proto3" json:"feature_tables,omitempty"`
	FeatureViews         []*FeatureView         `protobuf:"bytes,6,rep,name=feature_views,json=featureViews,proto3" json:"feature_views,omitempty"`
	DataSources          []*DataSource          `protobuf:"bytes,12,rep,name=data_sources,json=dataSources,proto3" json:"data_sources,omitempty"`
	OnDemandFeatureViews []*OnDemandFeatureView `protobuf:"bytes,8,rep,name=on_demand_feature_views,json=onDemandFeatureViews,proto3" json:"on_demand_feature_views,omitempty"`
	RequestFeatureViews  []*RequestFeatureView  `protobuf:"bytes,9,rep,name=request_feature_views,json=requestFeatureViews,proto3" json:"request_feature_views,omitempty"`
	StreamFeatureViews   []*StreamFeatureView   `protobuf:"bytes,14,rep,name=stream_feature_views,json=streamFeatureViews,proto3" json:"stream_feature_views,omitempty"`
	FeatureServices      []*FeatureService      `protobuf:"bytes,7,rep,name=feature_services,json=featureServices,proto3" json:"feature_services,omitempty"`
	SavedDatasets        []*SavedDataset        `protobuf:"bytes,11,rep,name=saved_datasets,json=savedDatasets,proto3" json:"saved_datasets,omitempty"`
	ValidationReferences []*ValidationReference `protobuf:"bytes,13,rep,name=validation_references,json=validationReferences,proto3" json:"validation_references,omitempty"`
	Infra                *Infra                 `protobuf:"bytes,10,opt,name=infra,proto3" json:"infra,omitempty"`
	// Tracking metadata of Feast by project
	ProjectMetadata       []*ProjectMetadata `protobuf:"bytes,15,rep,name=project_metadata,json=projectMetadata,proto3" json:"project_metadata,omitempty"`
	RegistrySchemaVersion string             `` // to support migrations; incremented when schema is changed
	/* 126-byte string literal not displayed */
	VersionId   string                 `protobuf:"bytes,4,opt,name=version_id,json=versionId,proto3" json:"version_id,omitempty"` // version id, random string generated on each update of the data; now used only for debugging purposes
	LastUpdated *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	// contains filtered or unexported fields
}

Next id: 16

func (*Registry) Descriptor deprecated 

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

Deprecated: Use Registry.ProtoReflect.Descriptor instead.

func (*Registry) GetDataSources 

func (x *Registry) GetDataSources() []*DataSource

func (*Registry) GetEntities 

func (x *Registry) GetEntities() []*Entity

func (*Registry) GetFeatureServices 

func (x *Registry) GetFeatureServices() []*FeatureService

func (*Registry) GetFeatureTables 

func (x *Registry) GetFeatureTables() []*FeatureTable

func (*Registry) GetFeatureViews 

func (x *Registry) GetFeatureViews() []*FeatureView

func (*Registry) GetInfra 

func (x *Registry) GetInfra() *Infra

func (*Registry) GetLastUpdated 

func (x *Registry) GetLastUpdated() *timestamppb.Timestamp

func (*Registry) GetOnDemandFeatureViews 

func (x *Registry) GetOnDemandFeatureViews() []*OnDemandFeatureView

func (*Registry) GetProjectMetadata 

func (x *Registry) GetProjectMetadata() []*ProjectMetadata

func (*Registry) GetRegistrySchemaVersion 

func (x *Registry) GetRegistrySchemaVersion() string

func (*Registry) GetRequestFeatureViews 

func (x *Registry) GetRequestFeatureViews() []*RequestFeatureView

func (*Registry) GetSavedDatasets 

func (x *Registry) GetSavedDatasets() []*SavedDataset

func (*Registry) GetStreamFeatureViews 

func (x *Registry) GetStreamFeatureViews() []*StreamFeatureView

func (*Registry) GetValidationReferences 

func (x *Registry) GetValidationReferences() []*ValidationReference

func (*Registry) GetVersionId 

func (x *Registry) GetVersionId() string

func (*Registry) ProtoMessage 

func (*Registry) ProtoMessage()

func (*Registry) ProtoReflect 

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

func (*Registry) Reset 

func (x *Registry) Reset()

func (*Registry) String 

func (x *Registry) String() string

type RequestFeatureView 

type RequestFeatureView struct {

	// User-specified specifications of this feature view.
	Spec *RequestFeatureViewSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestFeatureView) Descriptor deprecated 

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

Deprecated: Use RequestFeatureView.ProtoReflect.Descriptor instead.

func (*RequestFeatureView) GetSpec 

func (x *RequestFeatureView) GetSpec() *RequestFeatureViewSpec

func (*RequestFeatureView) ProtoMessage 

func (*RequestFeatureView) ProtoMessage()

func (*RequestFeatureView) ProtoReflect 

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

func (*RequestFeatureView) Reset 

func (x *RequestFeatureView) Reset()

func (*RequestFeatureView) String 

func (x *RequestFeatureView) String() string

type RequestFeatureViewSpec 

type RequestFeatureViewSpec struct {

	// Name of the feature view. Must be unique. Not updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this feature view belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Request data which contains the underlying data schema and list of associated features
	RequestDataSource *DataSource `protobuf:"bytes,3,opt,name=request_data_source,json=requestDataSource,proto3" json:"request_data_source,omitempty"`
	// Description of the request feature view.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// User defined metadata.
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Owner of the request feature view.
	Owner string `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

Next available id: 7

func (*RequestFeatureViewSpec) Descriptor deprecated 

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

Deprecated: Use RequestFeatureViewSpec.ProtoReflect.Descriptor instead.

func (*RequestFeatureViewSpec) GetDescription 

func (x *RequestFeatureViewSpec) GetDescription() string

func (*RequestFeatureViewSpec) GetName 

func (x *RequestFeatureViewSpec) GetName() string

func (*RequestFeatureViewSpec) GetOwner 

func (x *RequestFeatureViewSpec) GetOwner() string

func (*RequestFeatureViewSpec) GetProject 

func (x *RequestFeatureViewSpec) GetProject() string

func (*RequestFeatureViewSpec) GetRequestDataSource 

func (x *RequestFeatureViewSpec) GetRequestDataSource() *DataSource

func (*RequestFeatureViewSpec) GetTags 

func (x *RequestFeatureViewSpec) GetTags() map[string]string

func (*RequestFeatureViewSpec) ProtoMessage 

func (*RequestFeatureViewSpec) ProtoMessage()

func (*RequestFeatureViewSpec) ProtoReflect 

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

func (*RequestFeatureViewSpec) Reset 

func (x *RequestFeatureViewSpec) Reset()

func (*RequestFeatureViewSpec) String 

func (x *RequestFeatureViewSpec) String() string

type SavedDataset 

type SavedDataset struct {
	Spec *SavedDatasetSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Meta *SavedDatasetMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*SavedDataset) Descriptor deprecated 

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

Deprecated: Use SavedDataset.ProtoReflect.Descriptor instead.

func (*SavedDataset) GetMeta 

func (x *SavedDataset) GetMeta() *SavedDatasetMeta

func (*SavedDataset) GetSpec 

func (x *SavedDataset) GetSpec() *SavedDatasetSpec

func (*SavedDataset) ProtoMessage 

func (*SavedDataset) ProtoMessage()

func (*SavedDataset) ProtoReflect 

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

func (*SavedDataset) Reset 

func (x *SavedDataset) Reset()

func (*SavedDataset) String 

func (x *SavedDataset) String() string

type SavedDatasetMeta 

type SavedDatasetMeta struct {

	// Time when this saved dataset is created
	CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Time when this saved dataset is last updated
	LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"`
	// Min timestamp in the dataset (needed for retrieval)
	MinEventTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=min_event_timestamp,json=minEventTimestamp,proto3" json:"min_event_timestamp,omitempty"`
	// Max timestamp in the dataset (needed for retrieval)
	MaxEventTimestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=max_event_timestamp,json=maxEventTimestamp,proto3" json:"max_event_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*SavedDatasetMeta) Descriptor deprecated 

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

Deprecated: Use SavedDatasetMeta.ProtoReflect.Descriptor instead.

func (*SavedDatasetMeta) GetCreatedTimestamp 

func (x *SavedDatasetMeta) GetCreatedTimestamp() *timestamppb.Timestamp

func (*SavedDatasetMeta) GetLastUpdatedTimestamp 

func (x *SavedDatasetMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp

func (*SavedDatasetMeta) GetMaxEventTimestamp 

func (x *SavedDatasetMeta) GetMaxEventTimestamp() *timestamppb.Timestamp

func (*SavedDatasetMeta) GetMinEventTimestamp 

func (x *SavedDatasetMeta) GetMinEventTimestamp() *timestamppb.Timestamp

func (*SavedDatasetMeta) ProtoMessage 

func (*SavedDatasetMeta) ProtoMessage()

func (*SavedDatasetMeta) ProtoReflect 

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

func (*SavedDatasetMeta) Reset 

func (x *SavedDatasetMeta) Reset()

func (*SavedDatasetMeta) String 

func (x *SavedDatasetMeta) String() string

type SavedDatasetSpec 

type SavedDatasetSpec struct {

	// Name of the dataset. Must be unique since it's possible to overwrite dataset by name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this Dataset belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// list of feature references with format "<view name>:<feature name>"
	Features []string `protobuf:"bytes,3,rep,name=features,proto3" json:"features,omitempty"`
	// entity columns + request columns from all feature views used during retrieval
	JoinKeys []string `protobuf:"bytes,4,rep,name=join_keys,json=joinKeys,proto3" json:"join_keys,omitempty"`
	// Whether full feature names are used in stored data
	FullFeatureNames bool                 `protobuf:"varint,5,opt,name=full_feature_names,json=fullFeatureNames,proto3" json:"full_feature_names,omitempty"`
	Storage          *SavedDatasetStorage `protobuf:"bytes,6,opt,name=storage,proto3" json:"storage,omitempty"`
	// Optional and only populated if generated from a feature service fetch
	FeatureServiceName string `protobuf:"bytes,8,opt,name=feature_service_name,json=featureServiceName,proto3" json:"feature_service_name,omitempty"`
	// User defined metadata
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SavedDatasetSpec) Descriptor deprecated 

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

Deprecated: Use SavedDatasetSpec.ProtoReflect.Descriptor instead.

func (*SavedDatasetSpec) GetFeatureServiceName 

func (x *SavedDatasetSpec) GetFeatureServiceName() string

func (*SavedDatasetSpec) GetFeatures 

func (x *SavedDatasetSpec) GetFeatures() []string

func (*SavedDatasetSpec) GetFullFeatureNames 

func (x *SavedDatasetSpec) GetFullFeatureNames() bool

func (*SavedDatasetSpec) GetJoinKeys 

func (x *SavedDatasetSpec) GetJoinKeys() []string

func (*SavedDatasetSpec) GetName 

func (x *SavedDatasetSpec) GetName() string

func (*SavedDatasetSpec) GetProject 

func (x *SavedDatasetSpec) GetProject() string

func (*SavedDatasetSpec) GetStorage 

func (x *SavedDatasetSpec) GetStorage() *SavedDatasetStorage

func (*SavedDatasetSpec) GetTags 

func (x *SavedDatasetSpec) GetTags() map[string]string

func (*SavedDatasetSpec) ProtoMessage 

func (*SavedDatasetSpec) ProtoMessage()

func (*SavedDatasetSpec) ProtoReflect 

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

func (*SavedDatasetSpec) Reset 

func (x *SavedDatasetSpec) Reset()

func (*SavedDatasetSpec) String 

func (x *SavedDatasetSpec) String() string

type SavedDatasetStorage 

type SavedDatasetStorage struct {

	// Types that are assignable to Kind:
	//	*SavedDatasetStorage_FileStorage
	//	*SavedDatasetStorage_BigqueryStorage
	//	*SavedDatasetStorage_RedshiftStorage
	//	*SavedDatasetStorage_SnowflakeStorage
	//	*SavedDatasetStorage_TrinoStorage
	//	*SavedDatasetStorage_SparkStorage
	//	*SavedDatasetStorage_CustomStorage
	//	*SavedDatasetStorage_AthenaStorage
	Kind isSavedDatasetStorage_Kind `protobuf_oneof:"kind"`
	// contains filtered or unexported fields
}

func (*SavedDatasetStorage) Descriptor deprecated 

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

Deprecated: Use SavedDatasetStorage.ProtoReflect.Descriptor instead.

func (*SavedDatasetStorage) GetAthenaStorage 

func (x *SavedDatasetStorage) GetAthenaStorage() *DataSource_AthenaOptions

func (*SavedDatasetStorage) GetBigqueryStorage 

func (x *SavedDatasetStorage) GetBigqueryStorage() *DataSource_BigQueryOptions

func (*SavedDatasetStorage) GetCustomStorage 

func (x *SavedDatasetStorage) GetCustomStorage() *DataSource_CustomSourceOptions

func (*SavedDatasetStorage) GetFileStorage 

func (x *SavedDatasetStorage) GetFileStorage() *DataSource_FileOptions

func (*SavedDatasetStorage) GetKind 

func (m *SavedDatasetStorage) GetKind() isSavedDatasetStorage_Kind

func (*SavedDatasetStorage) GetRedshiftStorage 

func (x *SavedDatasetStorage) GetRedshiftStorage() *DataSource_RedshiftOptions

func (*SavedDatasetStorage) GetSnowflakeStorage 

func (x *SavedDatasetStorage) GetSnowflakeStorage() *DataSource_SnowflakeOptions

func (*SavedDatasetStorage) GetSparkStorage 

func (x *SavedDatasetStorage) GetSparkStorage() *DataSource_SparkOptions

func (*SavedDatasetStorage) GetTrinoStorage 

func (x *SavedDatasetStorage) GetTrinoStorage() *DataSource_TrinoOptions

func (*SavedDatasetStorage) ProtoMessage 

func (*SavedDatasetStorage) ProtoMessage()

func (*SavedDatasetStorage) ProtoReflect 

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

func (*SavedDatasetStorage) Reset 

func (x *SavedDatasetStorage) Reset()

func (*SavedDatasetStorage) String 

func (x *SavedDatasetStorage) String() string

type SavedDatasetStorage_AthenaStorage 

type SavedDatasetStorage_AthenaStorage struct {
	AthenaStorage *DataSource_AthenaOptions `protobuf:"bytes,11,opt,name=athena_storage,json=athenaStorage,proto3,oneof"`
}

type SavedDatasetStorage_BigqueryStorage 

type SavedDatasetStorage_BigqueryStorage struct {
	BigqueryStorage *DataSource_BigQueryOptions `protobuf:"bytes,5,opt,name=bigquery_storage,json=bigqueryStorage,proto3,oneof"`
}

type SavedDatasetStorage_CustomStorage 

type SavedDatasetStorage_CustomStorage struct {
	CustomStorage *DataSource_CustomSourceOptions `protobuf:"bytes,10,opt,name=custom_storage,json=customStorage,proto3,oneof"`
}

type SavedDatasetStorage_FileStorage 

type SavedDatasetStorage_FileStorage struct {
	FileStorage *DataSource_FileOptions `protobuf:"bytes,4,opt,name=file_storage,json=fileStorage,proto3,oneof"`
}

type SavedDatasetStorage_RedshiftStorage 

type SavedDatasetStorage_RedshiftStorage struct {
	RedshiftStorage *DataSource_RedshiftOptions `protobuf:"bytes,6,opt,name=redshift_storage,json=redshiftStorage,proto3,oneof"`
}

type SavedDatasetStorage_SnowflakeStorage 

type SavedDatasetStorage_SnowflakeStorage struct {
	SnowflakeStorage *DataSource_SnowflakeOptions `protobuf:"bytes,7,opt,name=snowflake_storage,json=snowflakeStorage,proto3,oneof"`
}

type SavedDatasetStorage_SparkStorage 

type SavedDatasetStorage_SparkStorage struct {
	SparkStorage *DataSource_SparkOptions `protobuf:"bytes,9,opt,name=spark_storage,json=sparkStorage,proto3,oneof"`
}

type SavedDatasetStorage_TrinoStorage 

type SavedDatasetStorage_TrinoStorage struct {
	TrinoStorage *DataSource_TrinoOptions `protobuf:"bytes,8,opt,name=trino_storage,json=trinoStorage,proto3,oneof"`
}

type SqliteTable 

type SqliteTable struct {

	// Absolute path of the table
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Name of the table
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Represents a Sqlite table

func (*SqliteTable) Descriptor deprecated 

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

Deprecated: Use SqliteTable.ProtoReflect.Descriptor instead.

func (*SqliteTable) GetName 

func (x *SqliteTable) GetName() string

func (*SqliteTable) GetPath 

func (x *SqliteTable) GetPath() string

func (*SqliteTable) ProtoMessage 

func (*SqliteTable) ProtoMessage()

func (*SqliteTable) ProtoReflect 

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

func (*SqliteTable) Reset 

func (x *SqliteTable) Reset()

func (*SqliteTable) String 

func (x *SqliteTable) String() string

type Store 

type Store struct {

	// Name of the store.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of store.
	Type Store_StoreType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.core.Store_StoreType" json:"type,omitempty"`
	// Feature sets to subscribe to.
	Subscriptions []*Store_Subscription `protobuf:"bytes,4,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// Configuration to connect to the store. Required.
	//
	// Types that are assignable to Config:
	//	*Store_RedisConfig_
	//	*Store_RedisClusterConfig_
	Config isStore_Config `protobuf_oneof:"config"`
	// contains filtered or unexported fields
}

Store provides a location where Feast reads and writes feature values. Feature values will be written to the Store in the form of FeatureRow elements. The way FeatureRow is encoded and decoded when it is written to and read from the Store depends on the type of the Store.

func (*Store) Descriptor deprecated 

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

Deprecated: Use Store.ProtoReflect.Descriptor instead.

func (*Store) GetConfig 

func (m *Store) GetConfig() isStore_Config

func (*Store) GetName 

func (x *Store) GetName() string

func (*Store) GetRedisClusterConfig 

func (x *Store) GetRedisClusterConfig() *Store_RedisClusterConfig

func (*Store) GetRedisConfig 

func (x *Store) GetRedisConfig() *Store_RedisConfig

func (*Store) GetSubscriptions 

func (x *Store) GetSubscriptions() []*Store_Subscription

func (*Store) GetType 

func (x *Store) GetType() Store_StoreType

func (*Store) ProtoMessage 

func (*Store) ProtoMessage()

func (*Store) ProtoReflect 

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

func (*Store) Reset 

func (x *Store) Reset()

func (*Store) String 

func (x *Store) String() string

type Store_RedisClusterConfig 

type Store_RedisClusterConfig struct {

	// List of Redis Uri for all the nodes in Redis Cluster, comma separated. Eg. host1:6379, host2:6379
	ConnectionString string `protobuf:"bytes,1,opt,name=connection_string,json=connectionString,proto3" json:"connection_string,omitempty"`
	InitialBackoffMs int32  `protobuf:"varint,2,opt,name=initial_backoff_ms,json=initialBackoffMs,proto3" json:"initial_backoff_ms,omitempty"`
	MaxRetries       int32  `protobuf:"varint,3,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	// Optional. How often flush data to redis
	FlushFrequencySeconds int32 `` /* 127-byte string literal not displayed */
	// Optional. Append a prefix to the Redis Key
	KeyPrefix string `protobuf:"bytes,5,opt,name=key_prefix,json=keyPrefix,proto3" json:"key_prefix,omitempty"`
	// Optional. Enable fallback to another key prefix if the original key is not present.
	// Useful for migrating key prefix without re-ingestion. Disabled by default.
	EnableFallback bool `protobuf:"varint,6,opt,name=enable_fallback,json=enableFallback,proto3" json:"enable_fallback,omitempty"`
	// Optional. This would be the fallback prefix to use if enable_fallback is true.
	FallbackPrefix string                            `protobuf:"bytes,7,opt,name=fallback_prefix,json=fallbackPrefix,proto3" json:"fallback_prefix,omitempty"`
	ReadFrom       Store_RedisClusterConfig_ReadFrom `` /* 136-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Store_RedisClusterConfig) Descriptor deprecated 

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

Deprecated: Use Store_RedisClusterConfig.ProtoReflect.Descriptor instead.

func (*Store_RedisClusterConfig) GetConnectionString 

func (x *Store_RedisClusterConfig) GetConnectionString() string

func (*Store_RedisClusterConfig) GetEnableFallback 

func (x *Store_RedisClusterConfig) GetEnableFallback() bool

func (*Store_RedisClusterConfig) GetFallbackPrefix 

func (x *Store_RedisClusterConfig) GetFallbackPrefix() string

func (*Store_RedisClusterConfig) GetFlushFrequencySeconds 

func (x *Store_RedisClusterConfig) GetFlushFrequencySeconds() int32

func (*Store_RedisClusterConfig) GetInitialBackoffMs 

func (x *Store_RedisClusterConfig) GetInitialBackoffMs() int32

func (*Store_RedisClusterConfig) GetKeyPrefix 

func (x *Store_RedisClusterConfig) GetKeyPrefix() string

func (*Store_RedisClusterConfig) GetMaxRetries 

func (x *Store_RedisClusterConfig) GetMaxRetries() int32

func (*Store_RedisClusterConfig) GetReadFrom 

func (x *Store_RedisClusterConfig) GetReadFrom() Store_RedisClusterConfig_ReadFrom

func (*Store_RedisClusterConfig) ProtoMessage 

func (*Store_RedisClusterConfig) ProtoMessage()

func (*Store_RedisClusterConfig) ProtoReflect 

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

func (*Store_RedisClusterConfig) Reset 

func (x *Store_RedisClusterConfig) Reset()

func (*Store_RedisClusterConfig) String 

func (x *Store_RedisClusterConfig) String() string

type Store_RedisClusterConfig_ 

type Store_RedisClusterConfig_ struct {
	RedisClusterConfig *Store_RedisClusterConfig `protobuf:"bytes,14,opt,name=redis_cluster_config,json=redisClusterConfig,proto3,oneof"`
}

type Store_RedisClusterConfig_ReadFrom 

type Store_RedisClusterConfig_ReadFrom int32

Optional. Priority of nodes when reading from cluster 

const (
	Store_RedisClusterConfig_MASTER            Store_RedisClusterConfig_ReadFrom = 0
	Store_RedisClusterConfig_MASTER_PREFERRED  Store_RedisClusterConfig_ReadFrom = 1
	Store_RedisClusterConfig_REPLICA           Store_RedisClusterConfig_ReadFrom = 2
	Store_RedisClusterConfig_REPLICA_PREFERRED Store_RedisClusterConfig_ReadFrom = 3
)

func (Store_RedisClusterConfig_ReadFrom) Descriptor 

func (Store_RedisClusterConfig_ReadFrom) Descriptor() protoreflect.EnumDescriptor

func (Store_RedisClusterConfig_ReadFrom) Enum 

func (x Store_RedisClusterConfig_ReadFrom) Enum() *Store_RedisClusterConfig_ReadFrom

func (Store_RedisClusterConfig_ReadFrom) EnumDescriptor deprecated 

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

Deprecated: Use Store_RedisClusterConfig_ReadFrom.Descriptor instead.

func (Store_RedisClusterConfig_ReadFrom) Number 

func (x Store_RedisClusterConfig_ReadFrom) Number() protoreflect.EnumNumber

func (Store_RedisClusterConfig_ReadFrom) String 

func (x Store_RedisClusterConfig_ReadFrom) String() string

func (Store_RedisClusterConfig_ReadFrom) Type 

func (Store_RedisClusterConfig_ReadFrom) Type() protoreflect.EnumType

type Store_RedisConfig 

type Store_RedisConfig struct {
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// Optional. The number of milliseconds to wait before retrying failed Redis connection.
	// By default, Feast uses exponential backoff policy and "initial_backoff_ms" sets the initial wait duration.
	InitialBackoffMs int32 `protobuf:"varint,3,opt,name=initial_backoff_ms,json=initialBackoffMs,proto3" json:"initial_backoff_ms,omitempty"`
	// Optional. Maximum total number of retries for connecting to Redis. Default to zero retries.
	MaxRetries int32 `protobuf:"varint,4,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	// Optional. How often flush data to redis
	FlushFrequencySeconds int32 `` /* 127-byte string literal not displayed */
	// Optional. Connect over SSL.
	Ssl bool `protobuf:"varint,6,opt,name=ssl,proto3" json:"ssl,omitempty"`
	// contains filtered or unexported fields
}

func (*Store_RedisConfig) Descriptor deprecated 

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

Deprecated: Use Store_RedisConfig.ProtoReflect.Descriptor instead.

func (*Store_RedisConfig) GetFlushFrequencySeconds 

func (x *Store_RedisConfig) GetFlushFrequencySeconds() int32

func (*Store_RedisConfig) GetHost 

func (x *Store_RedisConfig) GetHost() string

func (*Store_RedisConfig) GetInitialBackoffMs 

func (x *Store_RedisConfig) GetInitialBackoffMs() int32

func (*Store_RedisConfig) GetMaxRetries 

func (x *Store_RedisConfig) GetMaxRetries() int32

func (*Store_RedisConfig) GetPort 

func (x *Store_RedisConfig) GetPort() int32

func (*Store_RedisConfig) GetSsl 

func (x *Store_RedisConfig) GetSsl() bool

func (*Store_RedisConfig) ProtoMessage 

func (*Store_RedisConfig) ProtoMessage()

func (*Store_RedisConfig) ProtoReflect 

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

func (*Store_RedisConfig) Reset 

func (x *Store_RedisConfig) Reset()

func (*Store_RedisConfig) String 

func (x *Store_RedisConfig) String() string

type Store_RedisConfig_ 

type Store_RedisConfig_ struct {
	RedisConfig *Store_RedisConfig `protobuf:"bytes,11,opt,name=redis_config,json=redisConfig,proto3,oneof"`
}

type Store_StoreType 

type Store_StoreType int32
const (
	Store_INVALID Store_StoreType = 0
	// Redis stores a FeatureRow element as a key, value pair.
	//
	// The Redis data types used (https://redis.io/topics/data-types):
	// - key: STRING
	// - value: STRING
	//
	// Encodings:
	// - key: byte array of RedisKey (refer to feast.storage.RedisKeyV2)
	// - value: Redis hashmap
	//
	Store_REDIS         Store_StoreType = 1
	Store_REDIS_CLUSTER Store_StoreType = 4
)

func (Store_StoreType) Descriptor 

func (Store_StoreType) Descriptor() protoreflect.EnumDescriptor

func (Store_StoreType) Enum 

func (x Store_StoreType) Enum() *Store_StoreType

func (Store_StoreType) EnumDescriptor deprecated 

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

Deprecated: Use Store_StoreType.Descriptor instead.

func (Store_StoreType) Number 

func (x Store_StoreType) Number() protoreflect.EnumNumber

func (Store_StoreType) String 

func (x Store_StoreType) String() string

func (Store_StoreType) Type 

func (Store_StoreType) Type() protoreflect.EnumType

type Store_Subscription 

type Store_Subscription struct {

	// Name of project that the feature sets belongs to. This can be one of
	// - [project_name]
	// - *
	// If an asterisk is provided, filtering on projects will be disabled. All projects will
	// be matched. It is NOT possible to provide an asterisk with a string in order to do
	// pattern matching.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the desired feature set. Asterisks can be used as wildcards in the name.
	// Matching on names is only permitted if a specific project is defined. It is disallowed
	// If the project name is set to "*"
	// e.g.
	// - * can be used to match all feature sets
	// - my-feature-set* can be used to match all features prefixed by "my-feature-set"
	// - my-feature-set-6 can be used to select a single feature set
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// All matches with exclude enabled will be filtered out instead of added
	Exclude bool `protobuf:"varint,4,opt,name=exclude,proto3" json:"exclude,omitempty"`
	// contains filtered or unexported fields
}

func (*Store_Subscription) Descriptor deprecated 

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

Deprecated: Use Store_Subscription.ProtoReflect.Descriptor instead.

func (*Store_Subscription) GetExclude 

func (x *Store_Subscription) GetExclude() bool

func (*Store_Subscription) GetName 

func (x *Store_Subscription) GetName() string

func (*Store_Subscription) GetProject 

func (x *Store_Subscription) GetProject() string

func (*Store_Subscription) ProtoMessage 

func (*Store_Subscription) ProtoMessage()

func (*Store_Subscription) ProtoReflect 

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

func (*Store_Subscription) Reset 

func (x *Store_Subscription) Reset()

func (*Store_Subscription) String 

func (x *Store_Subscription) String() string

type StreamFeatureView 

type StreamFeatureView struct {

	// User-specified specifications of this feature view.
	Spec *StreamFeatureViewSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	Meta *FeatureViewMeta       `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFeatureView) Descriptor deprecated 

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

Deprecated: Use StreamFeatureView.ProtoReflect.Descriptor instead.

func (*StreamFeatureView) GetMeta 

func (x *StreamFeatureView) GetMeta() *FeatureViewMeta

func (*StreamFeatureView) GetSpec 

func (x *StreamFeatureView) GetSpec() *StreamFeatureViewSpec

func (*StreamFeatureView) ProtoMessage 

func (*StreamFeatureView) ProtoMessage()

func (*StreamFeatureView) ProtoReflect 

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

func (*StreamFeatureView) Reset 

func (x *StreamFeatureView) Reset()

func (*StreamFeatureView) String 

func (x *StreamFeatureView) String() string

type StreamFeatureViewSpec 

type StreamFeatureViewSpec struct {

	// Name of the feature view. Must be unique. Not updated.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of Feast project that this feature view belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// List of names of entities associated with this feature view.
	Entities []string `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"`
	// List of specifications for each feature defined as part of this feature view.
	Features []*FeatureSpecV2 `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"`
	// List of specifications for each entity defined as part of this feature view.
	EntityColumns []*FeatureSpecV2 `protobuf:"bytes,5,rep,name=entity_columns,json=entityColumns,proto3" json:"entity_columns,omitempty"`
	// Description of the feature view.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// User defined metadata
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// Owner of the feature view.
	Owner string `protobuf:"bytes,8,opt,name=owner,proto3" json:"owner,omitempty"`
	// Features in this feature view can only be retrieved from online serving
	// younger than ttl. Ttl is measured as the duration of time between
	// the feature's event timestamp and when the feature is retrieved
	// Feature values outside ttl will be returned as unset values and indicated to end user
	Ttl *durationpb.Duration `protobuf:"bytes,9,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// Batch/Offline DataSource where this view can retrieve offline feature data.
	BatchSource *DataSource `protobuf:"bytes,10,opt,name=batch_source,json=batchSource,proto3" json:"batch_source,omitempty"`
	// Streaming DataSource from where this view can consume "online" feature data.
	StreamSource *DataSource `protobuf:"bytes,11,opt,name=stream_source,json=streamSource,proto3" json:"stream_source,omitempty"`
	// Whether these features should be served online or not
	Online bool `protobuf:"varint,12,opt,name=online,proto3" json:"online,omitempty"`
	// Serialized function that is encoded in the streamfeatureview
	UserDefinedFunction *UserDefinedFunction `protobuf:"bytes,13,opt,name=user_defined_function,json=userDefinedFunction,proto3" json:"user_defined_function,omitempty"`
	// Mode of execution
	Mode string `protobuf:"bytes,14,opt,name=mode,proto3" json:"mode,omitempty"`
	// Aggregation definitions
	Aggregations []*Aggregation `protobuf:"bytes,15,rep,name=aggregations,proto3" json:"aggregations,omitempty"`
	// Timestamp field for aggregation
	TimestampField string `protobuf:"bytes,16,opt,name=timestamp_field,json=timestampField,proto3" json:"timestamp_field,omitempty"`
	// contains filtered or unexported fields
}

Next available id: 17

func (*StreamFeatureViewSpec) Descriptor deprecated 

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

Deprecated: Use StreamFeatureViewSpec.ProtoReflect.Descriptor instead.

func (*StreamFeatureViewSpec) GetAggregations 

func (x *StreamFeatureViewSpec) GetAggregations() []*Aggregation

func (*StreamFeatureViewSpec) GetBatchSource 

func (x *StreamFeatureViewSpec) GetBatchSource() *DataSource

func (*StreamFeatureViewSpec) GetDescription 

func (x *StreamFeatureViewSpec) GetDescription() string

func (*StreamFeatureViewSpec) GetEntities 

func (x *StreamFeatureViewSpec) GetEntities() []string

func (*StreamFeatureViewSpec) GetEntityColumns 

func (x *StreamFeatureViewSpec) GetEntityColumns() []*FeatureSpecV2

func (*StreamFeatureViewSpec) GetFeatures 

func (x *StreamFeatureViewSpec) GetFeatures() []*FeatureSpecV2

func (*StreamFeatureViewSpec) GetMode 

func (x *StreamFeatureViewSpec) GetMode() string

func (*StreamFeatureViewSpec) GetName 

func (x *StreamFeatureViewSpec) GetName() string

func (*StreamFeatureViewSpec) GetOnline 

func (x *StreamFeatureViewSpec) GetOnline() bool

func (*StreamFeatureViewSpec) GetOwner 

func (x *StreamFeatureViewSpec) GetOwner() string

func (*StreamFeatureViewSpec) GetProject 

func (x *StreamFeatureViewSpec) GetProject() string

func (*StreamFeatureViewSpec) GetStreamSource 

func (x *StreamFeatureViewSpec) GetStreamSource() *DataSource

func (*StreamFeatureViewSpec) GetTags 

func (x *StreamFeatureViewSpec) GetTags() map[string]string

func (*StreamFeatureViewSpec) GetTimestampField 

func (x *StreamFeatureViewSpec) GetTimestampField() string

func (*StreamFeatureViewSpec) GetTtl 

func (x *StreamFeatureViewSpec) GetTtl() *durationpb.Duration

func (*StreamFeatureViewSpec) GetUserDefinedFunction 

func (x *StreamFeatureViewSpec) GetUserDefinedFunction() *UserDefinedFunction

func (*StreamFeatureViewSpec) ProtoMessage 

func (*StreamFeatureViewSpec) ProtoMessage()

func (*StreamFeatureViewSpec) ProtoReflect 

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

func (*StreamFeatureViewSpec) Reset 

func (x *StreamFeatureViewSpec) Reset()

func (*StreamFeatureViewSpec) String 

func (x *StreamFeatureViewSpec) String() string

type StreamFormat 

type StreamFormat struct {

	// Specifies the data format and format specific options
	//
	// Types that are assignable to Format:
	//	*StreamFormat_AvroFormat_
	//	*StreamFormat_ProtoFormat_
	//	*StreamFormat_JsonFormat_
	Format isStreamFormat_Format `protobuf_oneof:"format"`
	// contains filtered or unexported fields
}

Defines the data format encoding features/entity data in data streams

func (*StreamFormat) Descriptor deprecated 

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

Deprecated: Use StreamFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat) GetAvroFormat 

func (x *StreamFormat) GetAvroFormat() *StreamFormat_AvroFormat

func (*StreamFormat) GetFormat 

func (m *StreamFormat) GetFormat() isStreamFormat_Format

func (*StreamFormat) GetJsonFormat 

func (x *StreamFormat) GetJsonFormat() *StreamFormat_JsonFormat

func (*StreamFormat) GetProtoFormat 

func (x *StreamFormat) GetProtoFormat() *StreamFormat_ProtoFormat

func (*StreamFormat) ProtoMessage 

func (*StreamFormat) ProtoMessage()

func (*StreamFormat) ProtoReflect 

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

func (*StreamFormat) Reset 

func (x *StreamFormat) Reset()

func (*StreamFormat) String 

func (x *StreamFormat) String() string

type StreamFormat_AvroFormat 

type StreamFormat_AvroFormat struct {

	// Optional if used in a File DataSource as schema is embedded in avro file.
	// Specifies the schema of the Avro message as JSON string.
	SchemaJson string `protobuf:"bytes,1,opt,name=schema_json,json=schemaJson,proto3" json:"schema_json,omitempty"`
	// contains filtered or unexported fields
}

Defines options for the avro data format

func (*StreamFormat_AvroFormat) Descriptor deprecated 

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

Deprecated: Use StreamFormat_AvroFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat_AvroFormat) GetSchemaJson 

func (x *StreamFormat_AvroFormat) GetSchemaJson() string

func (*StreamFormat_AvroFormat) ProtoMessage 

func (*StreamFormat_AvroFormat) ProtoMessage()

func (*StreamFormat_AvroFormat) ProtoReflect 

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

func (*StreamFormat_AvroFormat) Reset 

func (x *StreamFormat_AvroFormat) Reset()

func (*StreamFormat_AvroFormat) String 

func (x *StreamFormat_AvroFormat) String() string

type StreamFormat_AvroFormat_ 

type StreamFormat_AvroFormat_ struct {
	AvroFormat *StreamFormat_AvroFormat `protobuf:"bytes,1,opt,name=avro_format,json=avroFormat,proto3,oneof"`
}

type StreamFormat_JsonFormat 

type StreamFormat_JsonFormat struct {
	SchemaJson string `protobuf:"bytes,1,opt,name=schema_json,json=schemaJson,proto3" json:"schema_json,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFormat_JsonFormat) Descriptor deprecated 

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

Deprecated: Use StreamFormat_JsonFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat_JsonFormat) GetSchemaJson 

func (x *StreamFormat_JsonFormat) GetSchemaJson() string

func (*StreamFormat_JsonFormat) ProtoMessage 

func (*StreamFormat_JsonFormat) ProtoMessage()

func (*StreamFormat_JsonFormat) ProtoReflect 

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

func (*StreamFormat_JsonFormat) Reset 

func (x *StreamFormat_JsonFormat) Reset()

func (*StreamFormat_JsonFormat) String 

func (x *StreamFormat_JsonFormat) String() string

type StreamFormat_JsonFormat_ 

type StreamFormat_JsonFormat_ struct {
	JsonFormat *StreamFormat_JsonFormat `protobuf:"bytes,3,opt,name=json_format,json=jsonFormat,proto3,oneof"`
}

type StreamFormat_ProtoFormat 

type StreamFormat_ProtoFormat struct {

	// Classpath to the generated Java Protobuf class that can be used to decode
	// Feature data from the obtained stream message
	ClassPath string `protobuf:"bytes,1,opt,name=class_path,json=classPath,proto3" json:"class_path,omitempty"`
	// contains filtered or unexported fields
}

Defines options for the protobuf data format

func (*StreamFormat_ProtoFormat) Descriptor deprecated 

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

Deprecated: Use StreamFormat_ProtoFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat_ProtoFormat) GetClassPath 

func (x *StreamFormat_ProtoFormat) GetClassPath() string

func (*StreamFormat_ProtoFormat) ProtoMessage 

func (*StreamFormat_ProtoFormat) ProtoMessage()

func (*StreamFormat_ProtoFormat) ProtoReflect 

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

func (*StreamFormat_ProtoFormat) Reset 

func (x *StreamFormat_ProtoFormat) Reset()

func (*StreamFormat_ProtoFormat) String 

func (x *StreamFormat_ProtoFormat) String() string

type StreamFormat_ProtoFormat_ 

type StreamFormat_ProtoFormat_ struct {
	ProtoFormat *StreamFormat_ProtoFormat `protobuf:"bytes,2,opt,name=proto_format,json=protoFormat,proto3,oneof"`
}

type UserDefinedFunction 

type UserDefinedFunction struct {

	// The function name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The python-syntax function body (serialized by dill)
	Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// The string representation of the udf
	BodyText string `protobuf:"bytes,3,opt,name=body_text,json=bodyText,proto3" json:"body_text,omitempty"`
	// contains filtered or unexported fields
}

Serialized representation of python function.

func (*UserDefinedFunction) Descriptor deprecated 

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

Deprecated: Use UserDefinedFunction.ProtoReflect.Descriptor instead.

func (*UserDefinedFunction) GetBody 

func (x *UserDefinedFunction) GetBody() []byte

func (*UserDefinedFunction) GetBodyText 

func (x *UserDefinedFunction) GetBodyText() string

func (*UserDefinedFunction) GetName 

func (x *UserDefinedFunction) GetName() string

func (*UserDefinedFunction) ProtoMessage 

func (*UserDefinedFunction) ProtoMessage()

func (*UserDefinedFunction) ProtoReflect 

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

func (*UserDefinedFunction) Reset 

func (x *UserDefinedFunction) Reset()

func (*UserDefinedFunction) String 

func (x *UserDefinedFunction) String() string

type ValidationReference 

type ValidationReference struct {

	// Unique name of validation reference within the project
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of saved dataset used as reference dataset
	ReferenceDatasetName string `protobuf:"bytes,2,opt,name=reference_dataset_name,json=referenceDatasetName,proto3" json:"reference_dataset_name,omitempty"`
	// Name of Feast project that this object source belongs to
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// Description of the validation reference
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// User defined metadata
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// validation profiler
	//
	// Types that are assignable to Profiler:
	//	*ValidationReference_GeProfiler
	Profiler isValidationReference_Profiler `protobuf_oneof:"profiler"`
	// (optional) cached validation profile (to avoid constant recalculation)
	//
	// Types that are assignable to CachedProfile:
	//	*ValidationReference_GeProfile
	CachedProfile isValidationReference_CachedProfile `protobuf_oneof:"cached_profile"`
	// contains filtered or unexported fields
}

func (*ValidationReference) Descriptor deprecated 

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

Deprecated: Use ValidationReference.ProtoReflect.Descriptor instead.

func (*ValidationReference) GetCachedProfile 

func (m *ValidationReference) GetCachedProfile() isValidationReference_CachedProfile

func (*ValidationReference) GetDescription 

func (x *ValidationReference) GetDescription() string

func (*ValidationReference) GetGeProfile 

func (x *ValidationReference) GetGeProfile() *GEValidationProfile

func (*ValidationReference) GetGeProfiler 

func (x *ValidationReference) GetGeProfiler() *GEValidationProfiler

func (*ValidationReference) GetName 

func (x *ValidationReference) GetName() string

func (*ValidationReference) GetProfiler 

func (m *ValidationReference) GetProfiler() isValidationReference_Profiler

func (*ValidationReference) GetProject 

func (x *ValidationReference) GetProject() string

func (*ValidationReference) GetReferenceDatasetName 

func (x *ValidationReference) GetReferenceDatasetName() string

func (*ValidationReference) GetTags 

func (x *ValidationReference) GetTags() map[string]string

func (*ValidationReference) ProtoMessage 

func (*ValidationReference) ProtoMessage()

func (*ValidationReference) ProtoReflect 

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

func (*ValidationReference) Reset 

func (x *ValidationReference) Reset()

func (*ValidationReference) String 

func (x *ValidationReference) String() string

type ValidationReference_GeProfile 

type ValidationReference_GeProfile struct {
	GeProfile *GEValidationProfile `protobuf:"bytes,7,opt,name=ge_profile,json=geProfile,proto3,oneof"`
}

type ValidationReference_GeProfiler 

type ValidationReference_GeProfiler struct {
	GeProfiler *GEValidationProfiler `protobuf:"bytes,6,opt,name=ge_profiler,json=geProfiler,proto3,oneof"`
}

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.