core

type ApplyEntityRequest struct {

	// If project is unspecified, will default to 'default' project.
	// If project specified does not exist, the project would be automatically created.
	Spec *EntitySpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// Name of project that this entity belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

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

type ApplyFeatureTableRequest struct {

	// Optional. Name of the Project to apply the Feature Table to.
	// If unspecified, will apply FeatureTable to the default project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Feature Table specification to apply
	TableSpec *FeatureTableSpec `protobuf:"bytes,2,opt,name=table_spec,json=tableSpec,proto3" json:"table_spec,omitempty"`
	// contains filtered or unexported fields
}

type ApplyFeatureTableResponse struct {
	Table *FeatureTable `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

type ArchiveOnlineStoreRequest struct {

	// Name of online store to be archived
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

type ArchiveProjectRequest struct {

	// Name of project to be archived
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

type BoolList struct {
	Val []bool `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

type BytesList struct {
	Val [][]byte `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

type CoreServiceClient interface {
	// Retrieve version information about this Feast deployment
	GetFeastCoreVersion(ctx context.Context, in *GetFeastCoreVersionRequest, opts ...grpc.CallOption) (*GetFeastCoreVersionResponse, error)
	// Returns a specific entity
	GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error)
	// Returns all feature references and respective features matching that filter. If none are found
	// an empty map will be returned
	// If no filter is provided in the request, the response will contain all the features
	// currently stored in the default project.
	ListFeatures(ctx context.Context, in *ListFeaturesRequest, opts ...grpc.CallOption) (*ListFeaturesResponse, error)
	// Create or update and existing entity.
	//
	// This function is idempotent - it will not create a new entity if schema does not change.
	// Schema changes will update the entity if the changes are valid.
	// Following changes are not valid:
	// - Changes to name
	// - Changes to type
	ApplyEntity(ctx context.Context, in *ApplyEntityRequest, opts ...grpc.CallOption) (*ApplyEntityResponse, error)
	// Returns all entity references and respective entities matching that filter. If none are found
	// an empty map will be returned
	// If no filter is provided in the request, the response will contain all the entities
	// currently stored in the default project.
	ListEntities(ctx context.Context, in *ListEntitiesRequest, opts ...grpc.CallOption) (*ListEntitiesResponse, error)
	// Creates a project. Projects serve as namespaces within which resources like features will be
	// created. Feature table names as must be unique within a project while field (Feature/Entity) names
	// must be unique within a Feature Table. Project names themselves must be globally unique.
	CreateProject(ctx context.Context, in *CreateProjectRequest, opts ...grpc.CallOption) (*CreateProjectResponse, error)
	// Archives a project. Archived projects will continue to exist and function, but won't be visible
	// through the Core API. Any existing ingestion or serving requests will continue to function,
	// but will result in warning messages being logged. It is not possible to unarchive a project
	// through the Core API
	ArchiveProject(ctx context.Context, in *ArchiveProjectRequest, opts ...grpc.CallOption) (*ArchiveProjectResponse, error)
	// Lists all projects active projects.
	ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	// Create or update an existing feature table.
	// This function is idempotent - it will not create a new feature table if the schema does not change.
	// Schema changes will update the feature table if the changes are valid.
	// All changes except the following are valid:
	// - Changes to feature table name.
	// - Changes to entities
	// - Changes to feature name and type
	ApplyFeatureTable(ctx context.Context, in *ApplyFeatureTableRequest, opts ...grpc.CallOption) (*ApplyFeatureTableResponse, error)
	// List feature tables that match a given filter.
	// Returns the references of the Feature Tables matching that filter. If none are found,
	// an empty list will be returned.
	// If no filter is provided in the request, the response will match all the feature
	// tables currently stored in the registry.
	ListFeatureTables(ctx context.Context, in *ListFeatureTablesRequest, opts ...grpc.CallOption) (*ListFeatureTablesResponse, error)
	// Returns a specific feature table
	GetFeatureTable(ctx context.Context, in *GetFeatureTableRequest, opts ...grpc.CallOption) (*GetFeatureTableResponse, error)
	// Delete a specific feature table
	DeleteFeatureTable(ctx context.Context, in *DeleteFeatureTableRequest, opts ...grpc.CallOption) (*DeleteFeatureTableResponse, error)
	// Lists all online stores
	ListOnlineStores(ctx context.Context, in *ListOnlineStoresRequest, opts ...grpc.CallOption) (*ListOnlineStoresResponse, error)
	// Returns a specific online stores
	GetOnlineStore(ctx context.Context, in *GetOnlineStoreRequest, opts ...grpc.CallOption) (*GetOnlineStoreResponse, error)
	// Registers new online store to feast core
	// or updates properties for existing online store
	RegisterOnlineStore(ctx context.Context, in *RegisterOnlineStoreRequest, opts ...grpc.CallOption) (*RegisterOnlineStoreResponse, error)
	// Archives an online store to mark it deprecated
	ArchiveOnlineStore(ctx context.Context, in *ArchiveOnlineStoreRequest, opts ...grpc.CallOption) (*ArchiveOnlineStoreResponse, error)
}

type CoreServiceServer interface {
	// Retrieve version information about this Feast deployment
	GetFeastCoreVersion(context.Context, *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error)
	// Returns a specific entity
	GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)
	// Returns all feature references and respective features matching that filter. If none are found
	// an empty map will be returned
	// If no filter is provided in the request, the response will contain all the features
	// currently stored in the default project.
	ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)
	// Create or update and existing entity.
	//
	// This function is idempotent - it will not create a new entity if schema does not change.
	// Schema changes will update the entity if the changes are valid.
	// Following changes are not valid:
	// - Changes to name
	// - Changes to type
	ApplyEntity(context.Context, *ApplyEntityRequest) (*ApplyEntityResponse, error)
	// Returns all entity references and respective entities matching that filter. If none are found
	// an empty map will be returned
	// If no filter is provided in the request, the response will contain all the entities
	// currently stored in the default project.
	ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)
	// Creates a project. Projects serve as namespaces within which resources like features will be
	// created. Feature table names as must be unique within a project while field (Feature/Entity) names
	// must be unique within a Feature Table. Project names themselves must be globally unique.
	CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)
	// Archives a project. Archived projects will continue to exist and function, but won't be visible
	// through the Core API. Any existing ingestion or serving requests will continue to function,
	// but will result in warning messages being logged. It is not possible to unarchive a project
	// through the Core API
	ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)
	// Lists all projects active projects.
	ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
	// Create or update an existing feature table.
	// This function is idempotent - it will not create a new feature table if the schema does not change.
	// Schema changes will update the feature table if the changes are valid.
	// All changes except the following are valid:
	// - Changes to feature table name.
	// - Changes to entities
	// - Changes to feature name and type
	ApplyFeatureTable(context.Context, *ApplyFeatureTableRequest) (*ApplyFeatureTableResponse, error)
	// List feature tables that match a given filter.
	// Returns the references of the Feature Tables matching that filter. If none are found,
	// an empty list will be returned.
	// If no filter is provided in the request, the response will match all the feature
	// tables currently stored in the registry.
	ListFeatureTables(context.Context, *ListFeatureTablesRequest) (*ListFeatureTablesResponse, error)
	// Returns a specific feature table
	GetFeatureTable(context.Context, *GetFeatureTableRequest) (*GetFeatureTableResponse, error)
	// Delete a specific feature table
	DeleteFeatureTable(context.Context, *DeleteFeatureTableRequest) (*DeleteFeatureTableResponse, error)
	// Lists all online stores
	ListOnlineStores(context.Context, *ListOnlineStoresRequest) (*ListOnlineStoresResponse, error)
	// Returns a specific online stores
	GetOnlineStore(context.Context, *GetOnlineStoreRequest) (*GetOnlineStoreResponse, error)
	// Registers new online store to feast core
	// or updates properties for existing online store
	RegisterOnlineStore(context.Context, *RegisterOnlineStoreRequest) (*RegisterOnlineStoreResponse, error)
	// Archives an online store to mark it deprecated
	ArchiveOnlineStore(context.Context, *ArchiveOnlineStoreRequest) (*ArchiveOnlineStoreResponse, error)
}

type CreateProjectRequest struct {

	// Name of project (required)
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

type DataSource struct {
	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
	EventTimestampColumn string `protobuf:"bytes,3,opt,name=event_timestamp_column,json=eventTimestampColumn,proto3" json:"event_timestamp_column,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 */
	// DataSource options.
	//
	// Types that are assignable to Options:
	//	*DataSource_FileOptions_
	//	*DataSource_BigqueryOptions
	//	*DataSource_KafkaOptions_
	//	*DataSource_KinesisOptions_
	Options isDataSource_Options `protobuf_oneof:"options"`
	// contains filtered or unexported fields
}

type DataSource_BigQueryOptions 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
}

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

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
	FileUrl string `protobuf:"bytes,2,opt,name=file_url,json=fileUrl,proto3" json:"file_url,omitempty"`
	// contains filtered or unexported fields
}

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

type DataSource_KafkaOptions struct {

	// Comma separated list of Kafka bootstrap servers. Used for feature tables without a defined source host[:port]]
	BootstrapServers string `protobuf:"bytes,1,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"`
	// 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"`
	// contains filtered or unexported fields
}

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

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
}

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

type DataSource_SourceType int32

type DeleteFeatureTableRequest struct {

	// Optional. Name of the Project to delete the Feature Table from.
	// If unspecified, will delete FeatureTable from the default project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the FeatureTable to delete.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

type DoubleList struct {
	Val []float64 `protobuf:"fixed64,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

type Entity struct {

	// User-specified specifications of this entity.
	Spec *EntitySpec `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
}

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
}

type EntitySpec struct {

	// Name of the entity.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the entity.
	ValueType 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"`
	// User defined metadata
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type FeatureSpec 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 ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"`
	// Labels for user defined metadata on a feature
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

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
}

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
}

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"`
	// 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 []*FeatureSpec `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"`
	// Threshold to detect features that are close to be evicted.
	// Used by Feast Serving to indicate that feature is stale.
	// Must be less than max_age, since after max_age feature most probably will be garbage collected
	StalenessThreshold *durationpb.Duration `protobuf:"bytes,9,opt,name=staleness_threshold,json=stalenessThreshold,proto3" json:"staleness_threshold,omitempty"`
	// Database where features are stored for online serving
	OnlineStore *OnlineStore `protobuf:"bytes,10,opt,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	// contains filtered or unexported fields
}

type FileFormat struct {

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

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

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

type FloatList struct {
	Val []float32 `protobuf:"fixed32,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

type GetEntityRequest struct {

	// Name of entity (required).
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Name of project the entity belongs to. If omitted will default to 'default' project.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

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

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

type GetFeastCoreVersionResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type GetFeatureTableRequest struct {

	// Optional. Name of the Project to retrieve the Feature Table from.
	// If unspecified, will apply FeatureTable to the default project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the FeatureTable to retrieve.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetFeatureTableResponse struct {

	// The Feature Table retrieved.
	Table *FeatureTable `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

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

type GetOnlineStoreResponse struct {
	OnlineStore *OnlineStore                  `protobuf:"bytes,1,opt,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	Status      GetOnlineStoreResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.GetOnlineStoreResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type GetOnlineStoreResponse_Status int32

type Int32List struct {
	Val []int32 `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

type Int64List struct {
	Val []int64 `protobuf:"varint,1,rep,packed,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

type ListEntitiesRequest struct {
	Filter *ListEntitiesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListEntitiesRequest_Filter struct {

	// Optional. Specifies the name of the project to list Entities in.
	// It is NOT possible to provide an asterisk with a string in order to do pattern matching.
	// If unspecified, this field will default to the default project 'default'.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// Optional. User defined metadata for entity.
	// Entities with all matching labels will be returned.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ListEntitiesResponse struct {
	Entities []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"`
	// contains filtered or unexported fields
}

type ListFeatureTablesRequest struct {

	// Filter used when listing Feature Tables
	Filter *ListFeatureTablesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListFeatureTablesRequest_Filter struct {

	// Optional. Specifies the name of the project to list Feature Tables in.
	// If unspecified would list Feature Tables in the default project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Optional. Feature Tables with all matching labels will be returned.
	// If unspecified would list Feature Tables without filtering by labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ListFeatureTablesResponse struct {

	// List of matching Feature Tables
	Tables []*FeatureTable `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

type ListFeaturesRequest struct {
	Filter *ListFeaturesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

type ListFeaturesRequest_Filter struct {

	// User defined metadata for feature.
	// Features with all matching labels will be returned.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// List of entities contained within the featureSet that the feature belongs to.
	// Only feature tables with these entities will be searched for features.
	Entities []string `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"`
	// Name of project that the feature tables belongs to. Filtering on projects is disabled.
	// It is NOT possible to provide an asterisk with a string in order to do pattern matching.
	// If unspecified this field will default to the default project 'default'.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

type ListFeaturesResponse struct {
	Features map[string]*FeatureSpec `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type ListOnlineStoresResponse struct {
	OnlineStore []*OnlineStore `protobuf:"bytes,1,rep,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	// contains filtered or unexported fields
}

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

type ListProjectsResponse struct {

	// List of project names (archived projects are filtered out)
	Projects []string `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"`
	// contains filtered or unexported fields
}

type OnlineStore struct {

	// Name of the store.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of store.
	Type StoreType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.core.StoreType" json:"type,omitempty"`
	// Description.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type RegisterOnlineStoreRequest struct {
	OnlineStore *OnlineStore `protobuf:"bytes,1,opt,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	// contains filtered or unexported fields
}

type RegisterOnlineStoreResponse struct {
	OnlineStore *OnlineStore                       `protobuf:"bytes,1,opt,name=online_store,json=onlineStore,proto3" json:"online_store,omitempty"`
	Status      RegisterOnlineStoreResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.RegisterOnlineStoreResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type RegisterOnlineStoreResponse_Status int32

type StoreType int32

type StreamFormat struct {

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

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
}

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

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
}

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

type StringList struct {
	Val []string `protobuf:"bytes,1,rep,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedCoreServiceServer struct {
}

type UnsafeCoreServiceServer interface {
	// contains filtered or unexported methods
}

type Value struct {

	// ValueType is referenced by the metadata types, FeatureInfo and EntityInfo.
	// The enum values do not have to match the oneof val field ids, but they should.
	//
	// Types that are assignable to Val:
	//	*Value_BytesVal
	//	*Value_StringVal
	//	*Value_Int32Val
	//	*Value_Int64Val
	//	*Value_DoubleVal
	//	*Value_FloatVal
	//	*Value_BoolVal
	//	*Value_BytesListVal
	//	*Value_StringListVal
	//	*Value_Int32ListVal
	//	*Value_Int64ListVal
	//	*Value_DoubleListVal
	//	*Value_FloatListVal
	//	*Value_BoolListVal
	Val isValue_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}