core

package
v0.9.2 Latest Latest
Warning

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

 Go to latest Published: Feb 1, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	UpdateStoreResponse_Status_name = map[int32]string{
		0: "NO_CHANGE",
		1: "UPDATED",
	}
	UpdateStoreResponse_Status_value = map[string]int32{
		"NO_CHANGE": 0,
		"UPDATED":   1,
	}
)

Enum value maps for UpdateStoreResponse_Status.

View Source 
var (
	DataSource_SourceType_name = map[int32]string{
		0: "INVALID",
		1: "BATCH_FILE",
		2: "BATCH_BIGQUERY",
		3: "STREAM_KAFKA",
		4: "STREAM_KINESIS",
	}
	DataSource_SourceType_value = map[string]int32{
		"INVALID":        0,
		"BATCH_FILE":     1,
		"BATCH_BIGQUERY": 2,
		"STREAM_KAFKA":   3,
		"STREAM_KINESIS": 4,
	}
)

Enum value maps for DataSource_SourceType.

View Source 
var (
	FeatureSetStatus_name = map[int32]string{
		0: "STATUS_INVALID",
		1: "STATUS_PENDING",
		3: "STATUS_JOB_STARTING",
		2: "STATUS_READY",
	}
	FeatureSetStatus_value = map[string]int32{
		"STATUS_INVALID":      0,
		"STATUS_PENDING":      1,
		"STATUS_JOB_STARTING": 3,
		"STATUS_READY":        2,
	}
)

Enum value maps for FeatureSetStatus.

View Source 
var (
	FeatureSetJobDeliveryStatus_name = map[int32]string{
		0: "STATUS_IN_PROGRESS",
		1: "STATUS_DELIVERED",
	}
	FeatureSetJobDeliveryStatus_value = map[string]int32{
		"STATUS_IN_PROGRESS": 0,
		"STATUS_DELIVERED":   1,
	}
)

Enum value maps for FeatureSetJobDeliveryStatus.

View Source 
var (
	IngestionJobStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "PENDING",
		2: "RUNNING",
		3: "COMPLETED",
		4: "ABORTING",
		5: "ABORTED",
		6: "ERROR",
		7: "SUSPENDING",
		8: "SUSPENDED",
	}
	IngestionJobStatus_value = map[string]int32{
		"UNKNOWN":    0,
		"PENDING":    1,
		"RUNNING":    2,
		"COMPLETED":  3,
		"ABORTING":   4,
		"ABORTED":    5,
		"ERROR":      6,
		"SUSPENDING": 7,
		"SUSPENDED":  8,
	}
)

Enum value maps for IngestionJobStatus.

View Source 
var (
	JobType_name = map[int32]string{
		0: "INVALID_JOB",
		1: "BATCH_INGESTION_JOB",
		2: "STREAM_INGESTION_JOB",
		4: "RETRIEVAL_JOB",
	}
	JobType_value = map[string]int32{
		"INVALID_JOB":          0,
		"BATCH_INGESTION_JOB":  1,
		"STREAM_INGESTION_JOB": 2,
		"RETRIEVAL_JOB":        4,
	}
)

Enum value maps for JobType.

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

Enum value maps for JobStatus.

View Source 
var (
	SourceType_name = map[int32]string{
		0: "INVALID",
		1: "KAFKA",
	}
	SourceType_value = map[string]int32{
		"INVALID": 0,
		"KAFKA":   1,
	}
)

Enum value maps for 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 File_feast_core_CoreService_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_DataFormat_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_DataSource_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_Entity_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_FeatureSetReference_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_FeatureSet_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_FeatureTable_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_Feature_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_IngestionJob_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_JobService_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_Runner_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_Source_proto protoreflect.FileDescriptor
View Source 
var File_feast_core_Store_proto protoreflect.FileDescriptor

Functions

func RegisterCoreServiceServer 

func RegisterCoreServiceServer(s *grpc.Server, srv CoreServiceServer)

func RegisterJobServiceServer added in v0.9.0 

func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)

Types

type ApplyEntityRequest added in v0.8.0 

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 *EntitySpecV2 `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
}

func (*ApplyEntityRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ApplyEntityRequest.ProtoReflect.Descriptor instead.

func (*ApplyEntityRequest) GetProject added in v0.8.0 

func (x *ApplyEntityRequest) GetProject() string

func (*ApplyEntityRequest) GetSpec added in v0.8.0 

func (x *ApplyEntityRequest) GetSpec() *EntitySpecV2

func (*ApplyEntityRequest) ProtoMessage added in v0.8.0 

func (*ApplyEntityRequest) ProtoMessage()

func (*ApplyEntityRequest) ProtoReflect added in v0.8.0 

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

func (*ApplyEntityRequest) Reset added in v0.8.0 

func (x *ApplyEntityRequest) Reset()

func (*ApplyEntityRequest) String added in v0.8.0 

func (x *ApplyEntityRequest) String() string

type ApplyEntityResponse added in v0.8.0 

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

func (*ApplyEntityResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ApplyEntityResponse.ProtoReflect.Descriptor instead.

func (*ApplyEntityResponse) GetEntity added in v0.8.0 

func (x *ApplyEntityResponse) GetEntity() *Entity

func (*ApplyEntityResponse) ProtoMessage added in v0.8.0 

func (*ApplyEntityResponse) ProtoMessage()

func (*ApplyEntityResponse) ProtoReflect added in v0.8.0 

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

func (*ApplyEntityResponse) Reset added in v0.8.0 

func (x *ApplyEntityResponse) Reset()

func (*ApplyEntityResponse) String added in v0.8.0 

func (x *ApplyEntityResponse) String() string

type ApplyFeatureTableRequest added in v0.8.0 

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
}

func (*ApplyFeatureTableRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ApplyFeatureTableRequest.ProtoReflect.Descriptor instead.

func (*ApplyFeatureTableRequest) GetProject added in v0.8.0 

func (x *ApplyFeatureTableRequest) GetProject() string

func (*ApplyFeatureTableRequest) GetTableSpec added in v0.8.0 

func (x *ApplyFeatureTableRequest) GetTableSpec() *FeatureTableSpec

func (*ApplyFeatureTableRequest) ProtoMessage added in v0.8.0 

func (*ApplyFeatureTableRequest) ProtoMessage()

func (*ApplyFeatureTableRequest) ProtoReflect added in v0.8.0 

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

func (*ApplyFeatureTableRequest) Reset added in v0.8.0 

func (x *ApplyFeatureTableRequest) Reset()

func (*ApplyFeatureTableRequest) String added in v0.8.0 

func (x *ApplyFeatureTableRequest) String() string

type ApplyFeatureTableResponse added in v0.8.0 

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

func (*ApplyFeatureTableResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ApplyFeatureTableResponse.ProtoReflect.Descriptor instead.

func (*ApplyFeatureTableResponse) GetTable added in v0.8.0 

func (x *ApplyFeatureTableResponse) GetTable() *FeatureTable

func (*ApplyFeatureTableResponse) ProtoMessage added in v0.8.0 

func (*ApplyFeatureTableResponse) ProtoMessage()

func (*ApplyFeatureTableResponse) ProtoReflect added in v0.8.0 

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

func (*ApplyFeatureTableResponse) Reset added in v0.8.0 

func (x *ApplyFeatureTableResponse) Reset()

func (*ApplyFeatureTableResponse) String added in v0.8.0 

func (x *ApplyFeatureTableResponse) String() string

type ArchiveProjectRequest 

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
}

Request for the archival of a project

func (*ArchiveProjectRequest) Descriptor deprecated 

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

Deprecated: Use ArchiveProjectRequest.ProtoReflect.Descriptor instead.

func (*ArchiveProjectRequest) GetName 

func (x *ArchiveProjectRequest) GetName() string

func (*ArchiveProjectRequest) ProtoMessage 

func (*ArchiveProjectRequest) ProtoMessage()

func (*ArchiveProjectRequest) ProtoReflect 

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

func (*ArchiveProjectRequest) Reset 

func (x *ArchiveProjectRequest) Reset()

func (*ArchiveProjectRequest) String 

func (x *ArchiveProjectRequest) String() string

type ArchiveProjectResponse 

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

Response for archival of a project

func (*ArchiveProjectResponse) Descriptor deprecated 

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

Deprecated: Use ArchiveProjectResponse.ProtoReflect.Descriptor instead.

func (*ArchiveProjectResponse) ProtoMessage 

func (*ArchiveProjectResponse) ProtoMessage()

func (*ArchiveProjectResponse) ProtoReflect 

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

func (*ArchiveProjectResponse) Reset 

func (x *ArchiveProjectResponse) Reset()

func (*ArchiveProjectResponse) String 

func (x *ArchiveProjectResponse) String() string

type CancelJobRequest added in v0.9.0 

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

func (*CancelJobRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetJobId added in v0.9.0 

func (x *CancelJobRequest) GetJobId() string

func (*CancelJobRequest) ProtoMessage added in v0.9.0 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect added in v0.9.0 

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

func (*CancelJobRequest) Reset added in v0.9.0 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String added in v0.9.0 

func (x *CancelJobRequest) String() string

type CancelJobResponse added in v0.9.0 

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

func (*CancelJobResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.

func (*CancelJobResponse) ProtoMessage added in v0.9.0 

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) ProtoReflect added in v0.9.0 

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

func (*CancelJobResponse) Reset added in v0.9.0 

func (x *CancelJobResponse) Reset()

func (*CancelJobResponse) String added in v0.9.0 

func (x *CancelJobResponse) String() string

type CoreServiceClient 

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)
	// Retrieve store details given a filter.
	//
	// Returns all stores matching that filter. If none are found, an empty list will be returned.
	// If no filter is provided in the request, the response will contain all the stores currently
	// stored in the registry.
	ListStores(ctx context.Context, in *ListStoresRequest, opts ...grpc.CallOption) (*ListStoresResponse, 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)
	// Updates core with the configuration of the store.
	//
	// If the changes are valid, core will return the given store configuration in response, and
	// start or update the necessary feature population jobs for the updated store.
	UpdateStore(ctx context.Context, in *UpdateStoreRequest, opts ...grpc.CallOption) (*UpdateStoreResponse, 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)
}

CoreServiceClient is the client API for CoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCoreServiceClient 

func NewCoreServiceClient(cc grpc.ClientConnInterface) CoreServiceClient

type CoreServiceServer 

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)
	// Retrieve store details given a filter.
	//
	// Returns all stores matching that filter. If none are found, an empty list will be returned.
	// If no filter is provided in the request, the response will contain all the stores currently
	// stored in the registry.
	ListStores(context.Context, *ListStoresRequest) (*ListStoresResponse, 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)
	// Updates core with the configuration of the store.
	//
	// If the changes are valid, core will return the given store configuration in response, and
	// start or update the necessary feature population jobs for the updated store.
	UpdateStore(context.Context, *UpdateStoreRequest) (*UpdateStoreResponse, 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)
}

CoreServiceServer is the server API for CoreService service.

type CreateProjectRequest 

type CreateProjectRequest struct {

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

Request to create a project

func (*CreateProjectRequest) Descriptor deprecated 

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

Deprecated: Use CreateProjectRequest.ProtoReflect.Descriptor instead.

func (*CreateProjectRequest) GetName 

func (x *CreateProjectRequest) GetName() string

func (*CreateProjectRequest) ProtoMessage 

func (*CreateProjectRequest) ProtoMessage()

func (*CreateProjectRequest) ProtoReflect 

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

func (*CreateProjectRequest) Reset 

func (x *CreateProjectRequest) Reset()

func (*CreateProjectRequest) String 

func (x *CreateProjectRequest) String() string

type CreateProjectResponse 

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

Response for creation of a project

func (*CreateProjectResponse) Descriptor deprecated 

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

Deprecated: Use CreateProjectResponse.ProtoReflect.Descriptor instead.

func (*CreateProjectResponse) ProtoMessage 

func (*CreateProjectResponse) ProtoMessage()

func (*CreateProjectResponse) ProtoReflect 

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

func (*CreateProjectResponse) Reset 

func (x *CreateProjectResponse) Reset()

func (*CreateProjectResponse) String 

func (x *CreateProjectResponse) String() string

type DataSource added in v0.8.0 

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
}

Defines a Data Source that can be used source Feature data

func (*DataSource) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

func (*DataSource) GetBigqueryOptions added in v0.8.0 

func (x *DataSource) GetBigqueryOptions() *DataSource_BigQueryOptions

func (*DataSource) GetCreatedTimestampColumn added in v0.8.0 

func (x *DataSource) GetCreatedTimestampColumn() string

func (*DataSource) GetDatePartitionColumn added in v0.8.0 

func (x *DataSource) GetDatePartitionColumn() string

func (*DataSource) GetEventTimestampColumn added in v0.8.0 

func (x *DataSource) GetEventTimestampColumn() string

func (*DataSource) GetFieldMapping added in v0.8.0 

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

func (*DataSource) GetFileOptions added in v0.8.0 

func (x *DataSource) GetFileOptions() *DataSource_FileOptions

func (*DataSource) GetKafkaOptions added in v0.8.0 

func (x *DataSource) GetKafkaOptions() *DataSource_KafkaOptions

func (*DataSource) GetKinesisOptions added in v0.8.0 

func (x *DataSource) GetKinesisOptions() *DataSource_KinesisOptions

func (*DataSource) GetOptions added in v0.8.0 

func (m *DataSource) GetOptions() isDataSource_Options

func (*DataSource) GetType added in v0.8.0 

func (x *DataSource) GetType() DataSource_SourceType

func (*DataSource) ProtoMessage added in v0.8.0 

func (*DataSource) ProtoMessage()

func (*DataSource) ProtoReflect added in v0.8.0 

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

func (*DataSource) Reset added in v0.8.0 

func (x *DataSource) Reset()

func (*DataSource) String added in v0.8.0 

func (x *DataSource) String() string

type DataSource_BigQueryOptions added in v0.8.0 

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
}

Defines options for DataSource that sources features from a BigQuery Query

func (*DataSource_BigQueryOptions) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use DataSource_BigQueryOptions.ProtoReflect.Descriptor instead.

func (*DataSource_BigQueryOptions) GetTableRef added in v0.8.0 

func (x *DataSource_BigQueryOptions) GetTableRef() string

func (*DataSource_BigQueryOptions) ProtoMessage added in v0.8.0 

func (*DataSource_BigQueryOptions) ProtoMessage()

func (*DataSource_BigQueryOptions) ProtoReflect added in v0.8.0 

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

func (*DataSource_BigQueryOptions) Reset added in v0.8.0 

func (x *DataSource_BigQueryOptions) Reset()

func (*DataSource_BigQueryOptions) String added in v0.8.0 

func (x *DataSource_BigQueryOptions) String() string

type DataSource_BigqueryOptions added in v0.8.0 

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

type DataSource_FileOptions added in v0.8.0 

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
}

Defines options for DataSource that sources features from a file

func (*DataSource_FileOptions) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use DataSource_FileOptions.ProtoReflect.Descriptor instead.

func (*DataSource_FileOptions) GetFileFormat added in v0.8.0 

func (x *DataSource_FileOptions) GetFileFormat() *FileFormat

func (*DataSource_FileOptions) GetFileUrl added in v0.8.0 

func (x *DataSource_FileOptions) GetFileUrl() string

func (*DataSource_FileOptions) ProtoMessage added in v0.8.0 

func (*DataSource_FileOptions) ProtoMessage()

func (*DataSource_FileOptions) ProtoReflect added in v0.8.0 

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

func (*DataSource_FileOptions) Reset added in v0.8.0 

func (x *DataSource_FileOptions) Reset()

func (*DataSource_FileOptions) String added in v0.8.0 

func (x *DataSource_FileOptions) String() string

type DataSource_FileOptions_ added in v0.8.0 

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

type DataSource_KafkaOptions added in v0.8.0 

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
}

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 added in v0.8.0 

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

Deprecated: Use DataSource_KafkaOptions.ProtoReflect.Descriptor instead.

func (*DataSource_KafkaOptions) GetBootstrapServers added in v0.8.0 

func (x *DataSource_KafkaOptions) GetBootstrapServers() string

func (*DataSource_KafkaOptions) GetMessageFormat added in v0.8.0 

func (x *DataSource_KafkaOptions) GetMessageFormat() *StreamFormat

func (*DataSource_KafkaOptions) GetTopic added in v0.8.0 

func (x *DataSource_KafkaOptions) GetTopic() string

func (*DataSource_KafkaOptions) ProtoMessage added in v0.8.0 

func (*DataSource_KafkaOptions) ProtoMessage()

func (*DataSource_KafkaOptions) ProtoReflect added in v0.8.0 

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

func (*DataSource_KafkaOptions) Reset added in v0.8.0 

func (x *DataSource_KafkaOptions) Reset()

func (*DataSource_KafkaOptions) String added in v0.8.0 

func (x *DataSource_KafkaOptions) String() string

type DataSource_KafkaOptions_ added in v0.8.0 

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

type DataSource_KinesisOptions added in v0.8.0 

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 added in v0.8.0 

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

Deprecated: Use DataSource_KinesisOptions.ProtoReflect.Descriptor instead.

func (*DataSource_KinesisOptions) GetRecordFormat added in v0.8.0 

func (x *DataSource_KinesisOptions) GetRecordFormat() *StreamFormat

func (*DataSource_KinesisOptions) GetRegion added in v0.8.0 

func (x *DataSource_KinesisOptions) GetRegion() string

func (*DataSource_KinesisOptions) GetStreamName added in v0.8.0 

func (x *DataSource_KinesisOptions) GetStreamName() string

func (*DataSource_KinesisOptions) ProtoMessage added in v0.8.0 

func (*DataSource_KinesisOptions) ProtoMessage()

func (*DataSource_KinesisOptions) ProtoReflect added in v0.8.0 

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

func (*DataSource_KinesisOptions) Reset added in v0.8.0 

func (x *DataSource_KinesisOptions) Reset()

func (*DataSource_KinesisOptions) String added in v0.8.0 

func (x *DataSource_KinesisOptions) String() string

type DataSource_KinesisOptions_ added in v0.8.0 

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

type DataSource_SourceType added in v0.8.0 

type DataSource_SourceType int32

Type of Data Source. 

const (
	DataSource_INVALID        DataSource_SourceType = 0
	DataSource_BATCH_FILE     DataSource_SourceType = 1
	DataSource_BATCH_BIGQUERY DataSource_SourceType = 2
	DataSource_STREAM_KAFKA   DataSource_SourceType = 3
	DataSource_STREAM_KINESIS DataSource_SourceType = 4
)

func (DataSource_SourceType) Descriptor added in v0.8.0 

func (DataSource_SourceType) Descriptor() protoreflect.EnumDescriptor

func (DataSource_SourceType) Enum added in v0.8.0 

func (x DataSource_SourceType) Enum() *DataSource_SourceType

func (DataSource_SourceType) EnumDescriptor deprecated added in v0.8.0 

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

Deprecated: Use DataSource_SourceType.Descriptor instead.

func (DataSource_SourceType) Number added in v0.8.0 

func (x DataSource_SourceType) Number() protoreflect.EnumNumber

func (DataSource_SourceType) String added in v0.8.0 

func (x DataSource_SourceType) String() string

func (DataSource_SourceType) Type added in v0.8.0 

func (DataSource_SourceType) Type() protoreflect.EnumType

type DataflowRunnerConfigOptions 

type DataflowRunnerConfigOptions struct {

	// Project id to use when launching jobs.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The Google Compute Engine region for creating Dataflow jobs.
	Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// GCP availability zone for operations.
	WorkerZone string `protobuf:"bytes,3,opt,name=workerZone,proto3" json:"workerZone,omitempty"`
	// Run the job as a specific service account, instead of the default GCE robot.
	ServiceAccount string `protobuf:"bytes,4,opt,name=serviceAccount,proto3" json:"serviceAccount,omitempty"`
	// GCE network for launching workers.
	Network string `protobuf:"bytes,5,opt,name=network,proto3" json:"network,omitempty"`
	// GCE subnetwork for launching workers. e.g. regions/asia-east1/subnetworks/mysubnetwork
	Subnetwork string `protobuf:"bytes,6,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"`
	//  Machine type to create Dataflow worker VMs as.
	WorkerMachineType string `protobuf:"bytes,7,opt,name=workerMachineType,proto3" json:"workerMachineType,omitempty"`
	// The autoscaling algorithm to use for the workerpool.
	AutoscalingAlgorithm string `protobuf:"bytes,8,opt,name=autoscalingAlgorithm,proto3" json:"autoscalingAlgorithm,omitempty"`
	// Specifies whether worker pools should be started with public IP addresses.
	UsePublicIps bool `protobuf:"varint,9,opt,name=usePublicIps,proto3" json:"usePublicIps,omitempty"`
	// A pipeline level default location for storing temporary files.  Support Google Cloud Storage locations,
	// e.g. gs://bucket/object
	TempLocation string `protobuf:"bytes,10,opt,name=tempLocation,proto3" json:"tempLocation,omitempty"`
	// The maximum number of workers to use for the workerpool.
	MaxNumWorkers int32 `protobuf:"varint,11,opt,name=maxNumWorkers,proto3" json:"maxNumWorkers,omitempty"`
	// BigQuery table specification, e.g. PROJECT_ID:DATASET_ID.PROJECT_ID
	DeadLetterTableSpec string `protobuf:"bytes,12,opt,name=deadLetterTableSpec,proto3" json:"deadLetterTableSpec,omitempty"`
	// Labels to apply to the dataflow job
	Labels map[string]string `` /* 154-byte string literal not displayed */
	// Disk size to use on each remote Compute Engine worker instance
	DiskSizeGb int32 `protobuf:"varint,14,opt,name=diskSizeGb,proto3" json:"diskSizeGb,omitempty"`
	// Run job on Dataflow Streaming Engine instead of creating worker VMs
	EnableStreamingEngine bool `protobuf:"varint,15,opt,name=enableStreamingEngine,proto3" json:"enableStreamingEngine,omitempty"`
	// Type of persistent disk to be used by workers
	WorkerDiskType string `protobuf:"bytes,16,opt,name=workerDiskType,proto3" json:"workerDiskType,omitempty"`
	// Kafka consumer configuration properties
	KafkaConsumerProperties map[string]string `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DataflowRunnerConfigOptions) Descriptor deprecated 

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

Deprecated: Use DataflowRunnerConfigOptions.ProtoReflect.Descriptor instead.

func (*DataflowRunnerConfigOptions) GetAutoscalingAlgorithm 

func (x *DataflowRunnerConfigOptions) GetAutoscalingAlgorithm() string

func (*DataflowRunnerConfigOptions) GetDeadLetterTableSpec 

func (x *DataflowRunnerConfigOptions) GetDeadLetterTableSpec() string

func (*DataflowRunnerConfigOptions) GetDiskSizeGb added in v0.8.0 

func (x *DataflowRunnerConfigOptions) GetDiskSizeGb() int32

func (*DataflowRunnerConfigOptions) GetEnableStreamingEngine added in v0.8.0 

func (x *DataflowRunnerConfigOptions) GetEnableStreamingEngine() bool

func (*DataflowRunnerConfigOptions) GetKafkaConsumerProperties added in v0.8.0 

func (x *DataflowRunnerConfigOptions) GetKafkaConsumerProperties() map[string]string

func (*DataflowRunnerConfigOptions) GetLabels added in v0.6.2 

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

func (*DataflowRunnerConfigOptions) GetMaxNumWorkers 

func (x *DataflowRunnerConfigOptions) GetMaxNumWorkers() int32

func (*DataflowRunnerConfigOptions) GetNetwork 

func (x *DataflowRunnerConfigOptions) GetNetwork() string

func (*DataflowRunnerConfigOptions) GetProject 

func (x *DataflowRunnerConfigOptions) GetProject() string

func (*DataflowRunnerConfigOptions) GetRegion 

func (x *DataflowRunnerConfigOptions) GetRegion() string

func (*DataflowRunnerConfigOptions) GetServiceAccount 

func (x *DataflowRunnerConfigOptions) GetServiceAccount() string

func (*DataflowRunnerConfigOptions) GetSubnetwork 

func (x *DataflowRunnerConfigOptions) GetSubnetwork() string

func (*DataflowRunnerConfigOptions) GetTempLocation 

func (x *DataflowRunnerConfigOptions) GetTempLocation() string

func (*DataflowRunnerConfigOptions) GetUsePublicIps 

func (x *DataflowRunnerConfigOptions) GetUsePublicIps() bool

func (*DataflowRunnerConfigOptions) GetWorkerDiskType added in v0.8.0 

func (x *DataflowRunnerConfigOptions) GetWorkerDiskType() string

func (*DataflowRunnerConfigOptions) GetWorkerMachineType 

func (x *DataflowRunnerConfigOptions) GetWorkerMachineType() string

func (*DataflowRunnerConfigOptions) GetWorkerZone added in v0.8.0 

func (x *DataflowRunnerConfigOptions) GetWorkerZone() string

func (*DataflowRunnerConfigOptions) ProtoMessage 

func (*DataflowRunnerConfigOptions) ProtoMessage()

func (*DataflowRunnerConfigOptions) ProtoReflect 

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

func (*DataflowRunnerConfigOptions) Reset 

func (x *DataflowRunnerConfigOptions) Reset()

func (*DataflowRunnerConfigOptions) String 

func (x *DataflowRunnerConfigOptions) String() string

type DeleteFeatureTableRequest added in v0.9.0 

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
}

func (*DeleteFeatureTableRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use DeleteFeatureTableRequest.ProtoReflect.Descriptor instead.

func (*DeleteFeatureTableRequest) GetName added in v0.9.0 

func (x *DeleteFeatureTableRequest) GetName() string

func (*DeleteFeatureTableRequest) GetProject added in v0.9.0 

func (x *DeleteFeatureTableRequest) GetProject() string

func (*DeleteFeatureTableRequest) ProtoMessage added in v0.9.0 

func (*DeleteFeatureTableRequest) ProtoMessage()

func (*DeleteFeatureTableRequest) ProtoReflect added in v0.9.0 

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

func (*DeleteFeatureTableRequest) Reset added in v0.9.0 

func (x *DeleteFeatureTableRequest) Reset()

func (*DeleteFeatureTableRequest) String added in v0.9.0 

func (x *DeleteFeatureTableRequest) String() string

type DeleteFeatureTableResponse added in v0.9.0 

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

func (*DeleteFeatureTableResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use DeleteFeatureTableResponse.ProtoReflect.Descriptor instead.

func (*DeleteFeatureTableResponse) ProtoMessage added in v0.9.0 

func (*DeleteFeatureTableResponse) ProtoMessage()

func (*DeleteFeatureTableResponse) ProtoReflect added in v0.9.0 

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

func (*DeleteFeatureTableResponse) Reset added in v0.9.0 

func (x *DeleteFeatureTableResponse) Reset()

func (*DeleteFeatureTableResponse) String added in v0.9.0 

func (x *DeleteFeatureTableResponse) String() string

type DirectRunnerConfigOptions 

type DirectRunnerConfigOptions struct {

	//*
	// Controls the amount of target parallelism the DirectRunner will use.
	// Defaults to the greater of the number of available processors and 3. Must be a value
	// greater than zero.
	TargetParallelism int32 `protobuf:"varint,1,opt,name=targetParallelism,proto3" json:"targetParallelism,omitempty"`
	// BigQuery table specification, e.g. PROJECT_ID:DATASET_ID.PROJECT_ID
	DeadLetterTableSpec string `protobuf:"bytes,2,opt,name=deadLetterTableSpec,proto3" json:"deadLetterTableSpec,omitempty"`
	// A pipeline level default location for storing temporary files.
	// Support Google Cloud Storage locations or local path
	TempLocation string `protobuf:"bytes,3,opt,name=tempLocation,proto3" json:"tempLocation,omitempty"`
	// contains filtered or unexported fields
}

func (*DirectRunnerConfigOptions) Descriptor deprecated 

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

Deprecated: Use DirectRunnerConfigOptions.ProtoReflect.Descriptor instead.

func (*DirectRunnerConfigOptions) GetDeadLetterTableSpec 

func (x *DirectRunnerConfigOptions) GetDeadLetterTableSpec() string

func (*DirectRunnerConfigOptions) GetTargetParallelism 

func (x *DirectRunnerConfigOptions) GetTargetParallelism() int32

func (*DirectRunnerConfigOptions) GetTempLocation added in v0.6.2 

func (x *DirectRunnerConfigOptions) GetTempLocation() string

func (*DirectRunnerConfigOptions) ProtoMessage 

func (*DirectRunnerConfigOptions) ProtoMessage()

func (*DirectRunnerConfigOptions) ProtoReflect 

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

func (*DirectRunnerConfigOptions) Reset 

func (x *DirectRunnerConfigOptions) Reset()

func (*DirectRunnerConfigOptions) String 

func (x *DirectRunnerConfigOptions) String() string

type Entity added in v0.8.0 

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 added in v0.8.0 

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

Deprecated: Use Entity.ProtoReflect.Descriptor instead.

func (*Entity) GetMeta added in v0.8.0 

func (x *Entity) GetMeta() *EntityMeta

func (*Entity) GetSpec added in v0.8.0 

func (x *Entity) GetSpec() *EntitySpecV2

func (*Entity) ProtoMessage added in v0.8.0 

func (*Entity) ProtoMessage()

func (*Entity) ProtoReflect added in v0.8.0 

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

func (*Entity) Reset added in v0.8.0 

func (x *Entity) Reset()

func (*Entity) String added in v0.8.0 

func (x *Entity) String() string

type EntityMeta added in v0.8.0 

type EntityMeta struct {
	CreatedTimestamp     *timestamp.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	LastUpdatedTimestamp *timestamp.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 added in v0.8.0 

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

Deprecated: Use EntityMeta.ProtoReflect.Descriptor instead.

func (*EntityMeta) GetCreatedTimestamp added in v0.8.0 

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

func (*EntityMeta) GetLastUpdatedTimestamp added in v0.8.0 

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

func (*EntityMeta) ProtoMessage added in v0.8.0 

func (*EntityMeta) ProtoMessage()

func (*EntityMeta) ProtoReflect added in v0.8.0 

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

func (*EntityMeta) Reset added in v0.8.0 

func (x *EntityMeta) Reset()

func (*EntityMeta) String added in v0.8.0 

func (x *EntityMeta) String() string

type EntitySpec 

type EntitySpec struct {

	// Name of the entity.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value 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"`
	// contains filtered or unexported fields
}

func (*EntitySpec) Descriptor deprecated 

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

Deprecated: Use EntitySpec.ProtoReflect.Descriptor instead.

func (*EntitySpec) GetName 

func (x *EntitySpec) GetName() string

func (*EntitySpec) GetValueType 

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

func (*EntitySpec) ProtoMessage 

func (*EntitySpec) ProtoMessage()

func (*EntitySpec) ProtoReflect 

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

func (*EntitySpec) Reset 

func (x *EntitySpec) Reset()

func (*EntitySpec) String 

func (x *EntitySpec) String() string

type EntitySpecV2 added in v0.8.0 

type EntitySpecV2 struct {

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

func (*EntitySpecV2) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use EntitySpecV2.ProtoReflect.Descriptor instead.

func (*EntitySpecV2) GetDescription added in v0.8.0 

func (x *EntitySpecV2) GetDescription() string

func (*EntitySpecV2) GetLabels added in v0.8.0 

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

func (*EntitySpecV2) GetName added in v0.8.0 

func (x *EntitySpecV2) GetName() string

func (*EntitySpecV2) GetValueType added in v0.8.0 

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

func (*EntitySpecV2) ProtoMessage added in v0.8.0 

func (*EntitySpecV2) ProtoMessage()

func (*EntitySpecV2) ProtoReflect added in v0.8.0 

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

func (*EntitySpecV2) Reset added in v0.8.0 

func (x *EntitySpecV2) Reset()

func (*EntitySpecV2) String added in v0.8.0 

func (x *EntitySpecV2) String() string

type FeatureSet 

type FeatureSet struct {

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

func (*FeatureSet) Descriptor deprecated 

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

Deprecated: Use FeatureSet.ProtoReflect.Descriptor instead.

func (*FeatureSet) GetMeta 

func (x *FeatureSet) GetMeta() *FeatureSetMeta

func (*FeatureSet) GetSpec 

func (x *FeatureSet) GetSpec() *FeatureSetSpec

func (*FeatureSet) ProtoMessage 

func (*FeatureSet) ProtoMessage()

func (*FeatureSet) ProtoReflect 

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

func (*FeatureSet) Reset 

func (x *FeatureSet) Reset()

func (*FeatureSet) String 

func (x *FeatureSet) String() string

type FeatureSetJobDeliveryStatus added in v0.6.2 

type FeatureSetJobDeliveryStatus int32
const (
	FeatureSetJobDeliveryStatus_STATUS_IN_PROGRESS FeatureSetJobDeliveryStatus = 0
	FeatureSetJobDeliveryStatus_STATUS_DELIVERED   FeatureSetJobDeliveryStatus = 1
)

func (FeatureSetJobDeliveryStatus) Descriptor added in v0.6.2 

func (FeatureSetJobDeliveryStatus) Descriptor() protoreflect.EnumDescriptor

func (FeatureSetJobDeliveryStatus) Enum added in v0.6.2 

func (x FeatureSetJobDeliveryStatus) Enum() *FeatureSetJobDeliveryStatus

func (FeatureSetJobDeliveryStatus) EnumDescriptor deprecated added in v0.6.2 

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

Deprecated: Use FeatureSetJobDeliveryStatus.Descriptor instead.

func (FeatureSetJobDeliveryStatus) Number added in v0.6.2 

func (x FeatureSetJobDeliveryStatus) Number() protoreflect.EnumNumber

func (FeatureSetJobDeliveryStatus) String added in v0.6.2 

func (x FeatureSetJobDeliveryStatus) String() string

func (FeatureSetJobDeliveryStatus) Type added in v0.6.2 

func (FeatureSetJobDeliveryStatus) Type() protoreflect.EnumType

type FeatureSetMeta 

type FeatureSetMeta struct {

	// Created timestamp of this specific feature set.
	CreatedTimestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Status of the feature set.
	// Used to indicate whether the feature set is ready for consumption or ingestion.
	// Currently supports 2 states:
	// 1) STATUS_PENDING - A feature set is in pending state if Feast has not spun up the jobs
	// necessary to push rows for this feature set to stores subscribing to this feature set.
	// 2) STATUS_READY - Feature set is ready for consumption or ingestion
	Status FeatureSetStatus `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.FeatureSetStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureSetMeta) Descriptor deprecated 

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

Deprecated: Use FeatureSetMeta.ProtoReflect.Descriptor instead.

func (*FeatureSetMeta) GetCreatedTimestamp 

func (x *FeatureSetMeta) GetCreatedTimestamp() *timestamp.Timestamp

func (*FeatureSetMeta) GetStatus 

func (x *FeatureSetMeta) GetStatus() FeatureSetStatus

func (*FeatureSetMeta) ProtoMessage 

func (*FeatureSetMeta) ProtoMessage()

func (*FeatureSetMeta) ProtoReflect 

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

func (*FeatureSetMeta) Reset 

func (x *FeatureSetMeta) Reset()

func (*FeatureSetMeta) String 

func (x *FeatureSetMeta) String() string

type FeatureSetReference 

type FeatureSetReference struct {

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

Defines a composite key that refers to a unique FeatureSet

func (*FeatureSetReference) Descriptor deprecated 

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

Deprecated: Use FeatureSetReference.ProtoReflect.Descriptor instead.

func (*FeatureSetReference) GetName 

func (x *FeatureSetReference) GetName() string

func (*FeatureSetReference) GetProject 

func (x *FeatureSetReference) GetProject() string

func (*FeatureSetReference) ProtoMessage 

func (*FeatureSetReference) ProtoMessage()

func (*FeatureSetReference) ProtoReflect 

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

func (*FeatureSetReference) Reset 

func (x *FeatureSetReference) Reset()

func (*FeatureSetReference) String 

func (x *FeatureSetReference) String() string

type FeatureSetSpec 

type FeatureSetSpec struct {

	// Name of project that this feature set belongs to.
	Project string `protobuf:"bytes,7,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the feature set. Must be unique.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// List of entities contained within this featureSet.
	// This allows the feature to be used during joins between feature sets.
	// If the featureSet is ingested into a store that supports keys, this value
	// will be made a key.
	Entities []*EntitySpec `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"`
	// List of features contained within this featureSet.
	Features []*FeatureSpec `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"`
	// Features in this feature set will only be retrieved if they are found
	// after [time - max_age]. Missing or older feature values will be returned
	// as nulls and indicated to end user
	MaxAge *duration.Duration `protobuf:"bytes,5,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`
	// Optional. Source on which feature rows can be found.
	// If not set, source will be set to the default value configured in Feast Core.
	Source *Source `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"`
	// User defined metadata
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Read-only self-incrementing version that increases monotonically
	// when changes are made to a feature set
	Version int32 `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureSetSpec) Descriptor deprecated 

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

Deprecated: Use FeatureSetSpec.ProtoReflect.Descriptor instead.

func (*FeatureSetSpec) GetEntities 

func (x *FeatureSetSpec) GetEntities() []*EntitySpec

func (*FeatureSetSpec) GetFeatures 

func (x *FeatureSetSpec) GetFeatures() []*FeatureSpec

func (*FeatureSetSpec) GetLabels 

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

func (*FeatureSetSpec) GetMaxAge 

func (x *FeatureSetSpec) GetMaxAge() *duration.Duration

func (*FeatureSetSpec) GetName 

func (x *FeatureSetSpec) GetName() string

func (*FeatureSetSpec) GetProject 

func (x *FeatureSetSpec) GetProject() string

func (*FeatureSetSpec) GetSource 

func (x *FeatureSetSpec) GetSource() *Source

func (*FeatureSetSpec) GetVersion added in v0.6.2 

func (x *FeatureSetSpec) GetVersion() int32

func (*FeatureSetSpec) ProtoMessage 

func (*FeatureSetSpec) ProtoMessage()

func (*FeatureSetSpec) ProtoReflect 

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

func (*FeatureSetSpec) Reset 

func (x *FeatureSetSpec) Reset()

func (*FeatureSetSpec) String 

func (x *FeatureSetSpec) String() string

type FeatureSetSpecAck added in v0.6.2 

type FeatureSetSpecAck struct {
	FeatureSetReference string `protobuf:"bytes,1,opt,name=feature_set_reference,json=featureSetReference,proto3" json:"feature_set_reference,omitempty"`
	FeatureSetVersion   int32  `protobuf:"varint,2,opt,name=feature_set_version,json=featureSetVersion,proto3" json:"feature_set_version,omitempty"`
	JobName             string `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	// contains filtered or unexported fields
}

func (*FeatureSetSpecAck) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use FeatureSetSpecAck.ProtoReflect.Descriptor instead.

func (*FeatureSetSpecAck) GetFeatureSetReference added in v0.6.2 

func (x *FeatureSetSpecAck) GetFeatureSetReference() string

func (*FeatureSetSpecAck) GetFeatureSetVersion added in v0.6.2 

func (x *FeatureSetSpecAck) GetFeatureSetVersion() int32

func (*FeatureSetSpecAck) GetJobName added in v0.6.2 

func (x *FeatureSetSpecAck) GetJobName() string

func (*FeatureSetSpecAck) ProtoMessage added in v0.6.2 

func (*FeatureSetSpecAck) ProtoMessage()

func (*FeatureSetSpecAck) ProtoReflect added in v0.6.2 

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

func (*FeatureSetSpecAck) Reset added in v0.6.2 

func (x *FeatureSetSpecAck) Reset()

func (*FeatureSetSpecAck) String added in v0.6.2 

func (x *FeatureSetSpecAck) String() string

type FeatureSetStatus 

type FeatureSetStatus int32
const (
	FeatureSetStatus_STATUS_INVALID      FeatureSetStatus = 0
	FeatureSetStatus_STATUS_PENDING      FeatureSetStatus = 1
	FeatureSetStatus_STATUS_JOB_STARTING FeatureSetStatus = 3
	FeatureSetStatus_STATUS_READY        FeatureSetStatus = 2
)

func (FeatureSetStatus) Descriptor 

func (FeatureSetStatus) Descriptor() protoreflect.EnumDescriptor

func (FeatureSetStatus) Enum 

func (x FeatureSetStatus) Enum() *FeatureSetStatus

func (FeatureSetStatus) EnumDescriptor deprecated 

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

Deprecated: Use FeatureSetStatus.Descriptor instead.

func (FeatureSetStatus) Number 

func (x FeatureSetStatus) Number() protoreflect.EnumNumber

func (FeatureSetStatus) String 

func (x FeatureSetStatus) String() string

func (FeatureSetStatus) Type 

func (FeatureSetStatus) Type() protoreflect.EnumType

type FeatureSpec 

type FeatureSpec struct {

	// Name of the feature.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Value type of the feature.
	ValueType types.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 `` /* 154-byte string literal not displayed */
	// Types that are assignable to PresenceConstraints:
	//	*FeatureSpec_Presence
	//	*FeatureSpec_GroupPresence
	PresenceConstraints isFeatureSpec_PresenceConstraints `protobuf_oneof:"presence_constraints"`
	// The shape of the feature which governs the number of values that appear in
	// each example.
	//
	// Types that are assignable to ShapeType:
	//	*FeatureSpec_Shape
	//	*FeatureSpec_ValueCount
	ShapeType isFeatureSpec_ShapeType `protobuf_oneof:"shape_type"`
	// Domain for the values of the feature.
	//
	// Types that are assignable to DomainInfo:
	//	*FeatureSpec_Domain
	//	*FeatureSpec_IntDomain
	//	*FeatureSpec_FloatDomain
	//	*FeatureSpec_StringDomain
	//	*FeatureSpec_BoolDomain
	//	*FeatureSpec_StructDomain
	//	*FeatureSpec_NaturalLanguageDomain
	//	*FeatureSpec_ImageDomain
	//	*FeatureSpec_MidDomain
	//	*FeatureSpec_UrlDomain
	//	*FeatureSpec_TimeDomain
	//	*FeatureSpec_TimeOfDayDomain
	DomainInfo isFeatureSpec_DomainInfo `protobuf_oneof:"domain_info"`
	// contains filtered or unexported fields
}

func (*FeatureSpec) Descriptor deprecated 

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

Deprecated: Use FeatureSpec.ProtoReflect.Descriptor instead.

func (*FeatureSpec) GetBoolDomain 

func (x *FeatureSpec) GetBoolDomain() *v0.BoolDomain

func (*FeatureSpec) GetDomain 

func (x *FeatureSpec) GetDomain() string

func (*FeatureSpec) GetDomainInfo 

func (m *FeatureSpec) GetDomainInfo() isFeatureSpec_DomainInfo

func (*FeatureSpec) GetFloatDomain 

func (x *FeatureSpec) GetFloatDomain() *v0.FloatDomain

func (*FeatureSpec) GetGroupPresence 

func (x *FeatureSpec) GetGroupPresence() *v0.FeaturePresenceWithinGroup

func (*FeatureSpec) GetImageDomain 

func (x *FeatureSpec) GetImageDomain() *v0.ImageDomain

func (*FeatureSpec) GetIntDomain 

func (x *FeatureSpec) GetIntDomain() *v0.IntDomain

func (*FeatureSpec) GetLabels 

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

func (*FeatureSpec) GetMidDomain 

func (x *FeatureSpec) GetMidDomain() *v0.MIDDomain

func (*FeatureSpec) GetName 

func (x *FeatureSpec) GetName() string

func (*FeatureSpec) GetNaturalLanguageDomain 

func (x *FeatureSpec) GetNaturalLanguageDomain() *v0.NaturalLanguageDomain

func (*FeatureSpec) GetPresence 

func (x *FeatureSpec) GetPresence() *v0.FeaturePresence

func (*FeatureSpec) GetPresenceConstraints 

func (m *FeatureSpec) GetPresenceConstraints() isFeatureSpec_PresenceConstraints

func (*FeatureSpec) GetShape 

func (x *FeatureSpec) GetShape() *v0.FixedShape

func (*FeatureSpec) GetShapeType 

func (m *FeatureSpec) GetShapeType() isFeatureSpec_ShapeType

func (*FeatureSpec) GetStringDomain 

func (x *FeatureSpec) GetStringDomain() *v0.StringDomain

func (*FeatureSpec) GetStructDomain 

func (x *FeatureSpec) GetStructDomain() *v0.StructDomain

func (*FeatureSpec) GetTimeDomain 

func (x *FeatureSpec) GetTimeDomain() *v0.TimeDomain

func (*FeatureSpec) GetTimeOfDayDomain 

func (x *FeatureSpec) GetTimeOfDayDomain() *v0.TimeOfDayDomain

func (*FeatureSpec) GetUrlDomain 

func (x *FeatureSpec) GetUrlDomain() *v0.URLDomain

func (*FeatureSpec) GetValueCount 

func (x *FeatureSpec) GetValueCount() *v0.ValueCount

func (*FeatureSpec) GetValueType 

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

func (*FeatureSpec) ProtoMessage 

func (*FeatureSpec) ProtoMessage()

func (*FeatureSpec) ProtoReflect 

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

func (*FeatureSpec) Reset 

func (x *FeatureSpec) Reset()

func (*FeatureSpec) String 

func (x *FeatureSpec) String() string

type FeatureSpecV2 added in v0.8.0 

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"`
	// Labels for user defined metadata on a feature
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeatureSpecV2) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use FeatureSpecV2.ProtoReflect.Descriptor instead.

func (*FeatureSpecV2) GetLabels added in v0.8.0 

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

func (*FeatureSpecV2) GetName added in v0.8.0 

func (x *FeatureSpecV2) GetName() string

func (*FeatureSpecV2) GetValueType added in v0.8.0 

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

func (*FeatureSpecV2) ProtoMessage added in v0.8.0 

func (*FeatureSpecV2) ProtoMessage()

func (*FeatureSpecV2) ProtoReflect added in v0.8.0 

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

func (*FeatureSpecV2) Reset added in v0.8.0 

func (x *FeatureSpecV2) Reset()

func (*FeatureSpecV2) String added in v0.8.0 

func (x *FeatureSpecV2) String() string

type FeatureSpec_BoolDomain 

type FeatureSpec_BoolDomain struct {
	BoolDomain *v0.BoolDomain `protobuf:"bytes,38,opt,name=bool_domain,json=boolDomain,proto3,oneof"`
}

type FeatureSpec_Domain 

type FeatureSpec_Domain struct {
	// Reference to a domain defined at the schema level.
	Domain string `protobuf:"bytes,34,opt,name=domain,proto3,oneof"`
}

type FeatureSpec_FloatDomain 

type FeatureSpec_FloatDomain struct {
	FloatDomain *v0.FloatDomain `protobuf:"bytes,36,opt,name=float_domain,json=floatDomain,proto3,oneof"`
}

type FeatureSpec_GroupPresence 

type FeatureSpec_GroupPresence struct {
	// Only used in the context of a "group" context, e.g., inside a sequence.
	GroupPresence *v0.FeaturePresenceWithinGroup `protobuf:"bytes,31,opt,name=group_presence,json=groupPresence,proto3,oneof"`
}

type FeatureSpec_ImageDomain 

type FeatureSpec_ImageDomain struct {
	ImageDomain *v0.ImageDomain `protobuf:"bytes,41,opt,name=image_domain,json=imageDomain,proto3,oneof"`
}

type FeatureSpec_IntDomain 

type FeatureSpec_IntDomain struct {
	// Inline definitions of domains.
	IntDomain *v0.IntDomain `protobuf:"bytes,35,opt,name=int_domain,json=intDomain,proto3,oneof"`
}

type FeatureSpec_MidDomain 

type FeatureSpec_MidDomain struct {
	MidDomain *v0.MIDDomain `protobuf:"bytes,42,opt,name=mid_domain,json=midDomain,proto3,oneof"`
}

type FeatureSpec_NaturalLanguageDomain 

type FeatureSpec_NaturalLanguageDomain struct {
	// Supported semantic domains.
	NaturalLanguageDomain *v0.NaturalLanguageDomain `protobuf:"bytes,40,opt,name=natural_language_domain,json=naturalLanguageDomain,proto3,oneof"`
}

type FeatureSpec_Presence 

type FeatureSpec_Presence struct {
	// Constraints on the presence of this feature in the examples.
	Presence *v0.FeaturePresence `protobuf:"bytes,30,opt,name=presence,proto3,oneof"`
}

type FeatureSpec_Shape 

type FeatureSpec_Shape struct {
	// The feature has a fixed shape corresponding to a multi-dimensional
	// tensor.
	Shape *v0.FixedShape `protobuf:"bytes,32,opt,name=shape,proto3,oneof"`
}

type FeatureSpec_StringDomain 

type FeatureSpec_StringDomain struct {
	StringDomain *v0.StringDomain `protobuf:"bytes,37,opt,name=string_domain,json=stringDomain,proto3,oneof"`
}

type FeatureSpec_StructDomain 

type FeatureSpec_StructDomain struct {
	StructDomain *v0.StructDomain `protobuf:"bytes,39,opt,name=struct_domain,json=structDomain,proto3,oneof"`
}

type FeatureSpec_TimeDomain 

type FeatureSpec_TimeDomain struct {
	TimeDomain *v0.TimeDomain `protobuf:"bytes,44,opt,name=time_domain,json=timeDomain,proto3,oneof"`
}

type FeatureSpec_TimeOfDayDomain 

type FeatureSpec_TimeOfDayDomain struct {
	TimeOfDayDomain *v0.TimeOfDayDomain `protobuf:"bytes,45,opt,name=time_of_day_domain,json=timeOfDayDomain,proto3,oneof"`
}

type FeatureSpec_UrlDomain 

type FeatureSpec_UrlDomain struct {
	UrlDomain *v0.URLDomain `protobuf:"bytes,43,opt,name=url_domain,json=urlDomain,proto3,oneof"`
}

type FeatureSpec_ValueCount 

type FeatureSpec_ValueCount struct {
	// The feature doesn't have a well defined shape. All we know are limits on
	// the minimum and maximum number of values.
	ValueCount *v0.ValueCount `protobuf:"bytes,33,opt,name=value_count,json=valueCount,proto3,oneof"`
}

type FeatureTable added in v0.8.0 

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 added in v0.8.0 

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

Deprecated: Use FeatureTable.ProtoReflect.Descriptor instead.

func (*FeatureTable) GetMeta added in v0.8.0 

func (x *FeatureTable) GetMeta() *FeatureTableMeta

func (*FeatureTable) GetSpec added in v0.8.0 

func (x *FeatureTable) GetSpec() *FeatureTableSpec

func (*FeatureTable) ProtoMessage added in v0.8.0 

func (*FeatureTable) ProtoMessage()

func (*FeatureTable) ProtoReflect added in v0.8.0 

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

func (*FeatureTable) Reset added in v0.8.0 

func (x *FeatureTable) Reset()

func (*FeatureTable) String added in v0.8.0 

func (x *FeatureTable) String() string

type FeatureTableMeta added in v0.8.0 

type FeatureTableMeta struct {

	// Time where this Feature Table is created
	CreatedTimestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"`
	// Time where this Feature Table is last updated
	LastUpdatedTimestamp *timestamp.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 added in v0.8.0 

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

Deprecated: Use FeatureTableMeta.ProtoReflect.Descriptor instead.

func (*FeatureTableMeta) GetCreatedTimestamp added in v0.8.0 

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

func (*FeatureTableMeta) GetHash added in v0.9.0 

func (x *FeatureTableMeta) GetHash() string

func (*FeatureTableMeta) GetLastUpdatedTimestamp added in v0.8.0 

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

func (*FeatureTableMeta) GetRevision added in v0.8.0 

func (x *FeatureTableMeta) GetRevision() int64

func (*FeatureTableMeta) ProtoMessage added in v0.8.0 

func (*FeatureTableMeta) ProtoMessage()

func (*FeatureTableMeta) ProtoReflect added in v0.8.0 

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

func (*FeatureTableMeta) Reset added in v0.8.0 

func (x *FeatureTableMeta) Reset()

func (*FeatureTableMeta) String added in v0.8.0 

func (x *FeatureTableMeta) String() string

type FeatureTableSpec added in v0.8.0 

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 []*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 *duration.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 added in v0.8.0 

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

Deprecated: Use FeatureTableSpec.ProtoReflect.Descriptor instead.

func (*FeatureTableSpec) GetBatchSource added in v0.8.0 

func (x *FeatureTableSpec) GetBatchSource() *DataSource

func (*FeatureTableSpec) GetEntities added in v0.8.0 

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

func (*FeatureTableSpec) GetFeatures added in v0.8.0 

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

func (*FeatureTableSpec) GetLabels added in v0.8.0 

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

func (*FeatureTableSpec) GetMaxAge added in v0.8.0 

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

func (*FeatureTableSpec) GetName added in v0.8.0 

func (x *FeatureTableSpec) GetName() string

func (*FeatureTableSpec) GetStreamSource added in v0.8.0 

func (x *FeatureTableSpec) GetStreamSource() *DataSource

func (*FeatureTableSpec) ProtoMessage added in v0.8.0 

func (*FeatureTableSpec) ProtoMessage()

func (*FeatureTableSpec) ProtoReflect added in v0.8.0 

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

func (*FeatureTableSpec) Reset added in v0.8.0 

func (x *FeatureTableSpec) Reset()

func (*FeatureTableSpec) String added in v0.8.0 

func (x *FeatureTableSpec) String() string

type FileFormat added in v0.8.0 

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 added in v0.8.0 

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

Deprecated: Use FileFormat.ProtoReflect.Descriptor instead.

func (*FileFormat) GetFormat added in v0.8.0 

func (m *FileFormat) GetFormat() isFileFormat_Format

func (*FileFormat) GetParquetFormat added in v0.8.0 

func (x *FileFormat) GetParquetFormat() *FileFormat_ParquetFormat

func (*FileFormat) ProtoMessage added in v0.8.0 

func (*FileFormat) ProtoMessage()

func (*FileFormat) ProtoReflect added in v0.8.0 

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

func (*FileFormat) Reset added in v0.8.0 

func (x *FileFormat) Reset()

func (*FileFormat) String added in v0.8.0 

func (x *FileFormat) String() string

type FileFormat_ParquetFormat added in v0.8.0 

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

Defines options for the Parquet data format

func (*FileFormat_ParquetFormat) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use FileFormat_ParquetFormat.ProtoReflect.Descriptor instead.

func (*FileFormat_ParquetFormat) ProtoMessage added in v0.8.0 

func (*FileFormat_ParquetFormat) ProtoMessage()

func (*FileFormat_ParquetFormat) ProtoReflect added in v0.8.0 

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

func (*FileFormat_ParquetFormat) Reset added in v0.8.0 

func (x *FileFormat_ParquetFormat) Reset()

func (*FileFormat_ParquetFormat) String added in v0.8.0 

func (x *FileFormat_ParquetFormat) String() string

type FileFormat_ParquetFormat_ added in v0.8.0 

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

type GetEntityRequest added in v0.8.0 

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
}

Request for a single entity

func (*GetEntityRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

func (*GetEntityRequest) GetName added in v0.8.0 

func (x *GetEntityRequest) GetName() string

func (*GetEntityRequest) GetProject added in v0.8.0 

func (x *GetEntityRequest) GetProject() string

func (*GetEntityRequest) ProtoMessage added in v0.8.0 

func (*GetEntityRequest) ProtoMessage()

func (*GetEntityRequest) ProtoReflect added in v0.8.0 

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

func (*GetEntityRequest) Reset added in v0.8.0 

func (x *GetEntityRequest) Reset()

func (*GetEntityRequest) String added in v0.8.0 

func (x *GetEntityRequest) String() string

type GetEntityResponse added in v0.8.0 

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

Response containing a single entity

func (*GetEntityResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.

func (*GetEntityResponse) GetEntity added in v0.8.0 

func (x *GetEntityResponse) GetEntity() *Entity

func (*GetEntityResponse) ProtoMessage added in v0.8.0 

func (*GetEntityResponse) ProtoMessage()

func (*GetEntityResponse) ProtoReflect added in v0.8.0 

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

func (*GetEntityResponse) Reset added in v0.8.0 

func (x *GetEntityResponse) Reset()

func (*GetEntityResponse) String added in v0.8.0 

func (x *GetEntityResponse) String() string

type GetFeastCoreVersionRequest 

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

func (*GetFeastCoreVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetFeastCoreVersionRequest.ProtoReflect.Descriptor instead.

func (*GetFeastCoreVersionRequest) ProtoMessage 

func (*GetFeastCoreVersionRequest) ProtoMessage()

func (*GetFeastCoreVersionRequest) ProtoReflect 

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

func (*GetFeastCoreVersionRequest) Reset 

func (x *GetFeastCoreVersionRequest) Reset()

func (*GetFeastCoreVersionRequest) String 

func (x *GetFeastCoreVersionRequest) String() string

type GetFeastCoreVersionResponse 

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

func (*GetFeastCoreVersionResponse) Descriptor deprecated 

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

Deprecated: Use GetFeastCoreVersionResponse.ProtoReflect.Descriptor instead.

func (*GetFeastCoreVersionResponse) GetVersion 

func (x *GetFeastCoreVersionResponse) GetVersion() string

func (*GetFeastCoreVersionResponse) ProtoMessage 

func (*GetFeastCoreVersionResponse) ProtoMessage()

func (*GetFeastCoreVersionResponse) ProtoReflect 

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

func (*GetFeastCoreVersionResponse) Reset 

func (x *GetFeastCoreVersionResponse) Reset()

func (*GetFeastCoreVersionResponse) String 

func (x *GetFeastCoreVersionResponse) String() string

type GetFeatureTableRequest added in v0.8.0 

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
}

func (*GetFeatureTableRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use GetFeatureTableRequest.ProtoReflect.Descriptor instead.

func (*GetFeatureTableRequest) GetName added in v0.8.0 

func (x *GetFeatureTableRequest) GetName() string

func (*GetFeatureTableRequest) GetProject added in v0.8.0 

func (x *GetFeatureTableRequest) GetProject() string

func (*GetFeatureTableRequest) ProtoMessage added in v0.8.0 

func (*GetFeatureTableRequest) ProtoMessage()

func (*GetFeatureTableRequest) ProtoReflect added in v0.8.0 

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

func (*GetFeatureTableRequest) Reset added in v0.8.0 

func (x *GetFeatureTableRequest) Reset()

func (*GetFeatureTableRequest) String added in v0.8.0 

func (x *GetFeatureTableRequest) String() string

type GetFeatureTableResponse added in v0.8.0 

type GetFeatureTableResponse struct {

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

func (*GetFeatureTableResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use GetFeatureTableResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureTableResponse) GetTable added in v0.8.0 

func (x *GetFeatureTableResponse) GetTable() *FeatureTable

func (*GetFeatureTableResponse) ProtoMessage added in v0.8.0 

func (*GetFeatureTableResponse) ProtoMessage()

func (*GetFeatureTableResponse) ProtoReflect added in v0.8.0 

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

func (*GetFeatureTableResponse) Reset added in v0.8.0 

func (x *GetFeatureTableResponse) Reset()

func (*GetFeatureTableResponse) String added in v0.8.0 

func (x *GetFeatureTableResponse) String() string

type GetHistoricalFeaturesRequest added in v0.9.0 

type GetHistoricalFeaturesRequest struct {

	// List of feature references that are being retrieved
	FeatureRefs []string `protobuf:"bytes,1,rep,name=feature_refs,json=featureRefs,proto3" json:"feature_refs,omitempty"`
	// Batch DataSource that can be used to obtain entity values for historical retrieval.
	// For each entity value, a feature value will be retrieved for that value/timestamp
	// Only 'BATCH_*' source types are supported.
	// Currently only BATCH_FILE source type is supported.
	EntitySource *DataSource `protobuf:"bytes,2,opt,name=entity_source,json=entitySource,proto3" json:"entity_source,omitempty"`
	// Optional field to specify project name override. If specified, uses the
	// given project for retrieval. Overrides the projects specified in
	// Feature References if both are specified.
	Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	// Specifies the path in a bucket to write the exported feature data files
	// Export to AWS S3 - s3://path/to/features
	// Export to GCP GCS -  gs://path/to/features
	OutputLocation string `protobuf:"bytes,4,opt,name=output_location,json=outputLocation,proto3" json:"output_location,omitempty"`
	// Specify format name for output, eg. parquet
	OutputFormat string `protobuf:"bytes,5,opt,name=output_format,json=outputFormat,proto3" json:"output_format,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHistoricalFeaturesRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetHistoricalFeaturesRequest.ProtoReflect.Descriptor instead.

func (*GetHistoricalFeaturesRequest) GetEntitySource added in v0.9.0 

func (x *GetHistoricalFeaturesRequest) GetEntitySource() *DataSource

func (*GetHistoricalFeaturesRequest) GetFeatureRefs added in v0.9.0 

func (x *GetHistoricalFeaturesRequest) GetFeatureRefs() []string

func (*GetHistoricalFeaturesRequest) GetOutputFormat added in v0.9.0 

func (x *GetHistoricalFeaturesRequest) GetOutputFormat() string

func (*GetHistoricalFeaturesRequest) GetOutputLocation added in v0.9.0 

func (x *GetHistoricalFeaturesRequest) GetOutputLocation() string

func (*GetHistoricalFeaturesRequest) GetProject added in v0.9.0 

func (x *GetHistoricalFeaturesRequest) GetProject() string

func (*GetHistoricalFeaturesRequest) ProtoMessage added in v0.9.0 

func (*GetHistoricalFeaturesRequest) ProtoMessage()

func (*GetHistoricalFeaturesRequest) ProtoReflect added in v0.9.0 

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

func (*GetHistoricalFeaturesRequest) Reset added in v0.9.0 

func (x *GetHistoricalFeaturesRequest) Reset()

func (*GetHistoricalFeaturesRequest) String added in v0.9.0 

func (x *GetHistoricalFeaturesRequest) String() string

type GetHistoricalFeaturesResponse added in v0.9.0 

type GetHistoricalFeaturesResponse struct {

	// Export Job with ID assigned by Feast
	Id            string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OutputFileUri string `protobuf:"bytes,2,opt,name=output_file_uri,json=outputFileUri,proto3" json:"output_file_uri,omitempty"`
	// contains filtered or unexported fields
}

func (*GetHistoricalFeaturesResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetHistoricalFeaturesResponse.ProtoReflect.Descriptor instead.

func (*GetHistoricalFeaturesResponse) GetId added in v0.9.0 

func (x *GetHistoricalFeaturesResponse) GetId() string

func (*GetHistoricalFeaturesResponse) GetOutputFileUri added in v0.9.0 

func (x *GetHistoricalFeaturesResponse) GetOutputFileUri() string

func (*GetHistoricalFeaturesResponse) ProtoMessage added in v0.9.0 

func (*GetHistoricalFeaturesResponse) ProtoMessage()

func (*GetHistoricalFeaturesResponse) ProtoReflect added in v0.9.0 

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

func (*GetHistoricalFeaturesResponse) Reset added in v0.9.0 

func (x *GetHistoricalFeaturesResponse) Reset()

func (*GetHistoricalFeaturesResponse) String added in v0.9.0 

func (x *GetHistoricalFeaturesResponse) String() string

type GetJobRequest added in v0.9.0 

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

func (*GetJobRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetJobId added in v0.9.0 

func (x *GetJobRequest) GetJobId() string

func (*GetJobRequest) ProtoMessage added in v0.9.0 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect added in v0.9.0 

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

func (*GetJobRequest) Reset added in v0.9.0 

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String added in v0.9.0 

func (x *GetJobRequest) String() string

type GetJobResponse added in v0.9.0 

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

func (*GetJobResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJob added in v0.9.0 

func (x *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage added in v0.9.0 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect added in v0.9.0 

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

func (*GetJobResponse) Reset added in v0.9.0 

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String added in v0.9.0 

func (x *GetJobResponse) String() string

type IngestionJob 

type IngestionJob struct {

	// Job ID assigned by Feast
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// External job ID specific to the runner.
	// For DirectRunner jobs, this is identical to id. For DataflowRunner jobs, this refers to the Dataflow job ID.
	ExternalId string             `protobuf:"bytes,2,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	Status     IngestionJobStatus `protobuf:"varint,3,opt,name=status,proto3,enum=feast.core.IngestionJobStatus" json:"status,omitempty"`
	// Source this job is reading from.
	Source *Source `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	// Store this job is writing to.
	Stores []*Store `protobuf:"bytes,6,rep,name=stores,proto3" json:"stores,omitempty"`
	// List of Feature Set References
	FeatureSetReferences []*FeatureSetReference `protobuf:"bytes,7,rep,name=feature_set_references,json=featureSetReferences,proto3" json:"feature_set_references,omitempty"`
	// contains filtered or unexported fields
}

Represents Feast Injestion Job

func (*IngestionJob) Descriptor deprecated 

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

Deprecated: Use IngestionJob.ProtoReflect.Descriptor instead.

func (*IngestionJob) GetExternalId 

func (x *IngestionJob) GetExternalId() string

func (*IngestionJob) GetFeatureSetReferences added in v0.8.0 

func (x *IngestionJob) GetFeatureSetReferences() []*FeatureSetReference

func (*IngestionJob) GetId 

func (x *IngestionJob) GetId() string

func (*IngestionJob) GetSource 

func (x *IngestionJob) GetSource() *Source

func (*IngestionJob) GetStatus 

func (x *IngestionJob) GetStatus() IngestionJobStatus

func (*IngestionJob) GetStores added in v0.8.0 

func (x *IngestionJob) GetStores() []*Store

func (*IngestionJob) ProtoMessage 

func (*IngestionJob) ProtoMessage()

func (*IngestionJob) ProtoReflect 

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

func (*IngestionJob) Reset 

func (x *IngestionJob) Reset()

func (*IngestionJob) String 

func (x *IngestionJob) String() string

type IngestionJobStatus 

type IngestionJobStatus int32

Status of a Feast Ingestion Job 

const (
	// Job status is not known.
	IngestionJobStatus_UNKNOWN IngestionJobStatus = 0
	// Import job is submitted to runner and currently pending for executing
	IngestionJobStatus_PENDING IngestionJobStatus = 1
	// Import job is currently running in the runner
	IngestionJobStatus_RUNNING IngestionJobStatus = 2
	// Runner's reported the import job has completed (applicable to batch job)
	IngestionJobStatus_COMPLETED IngestionJobStatus = 3
	// When user sent abort command, but it's still running
	IngestionJobStatus_ABORTING IngestionJobStatus = 4
	// User initiated abort job
	IngestionJobStatus_ABORTED IngestionJobStatus = 5
	// Runner's reported that the import job failed to run or there is a failure during job
	IngestionJobStatus_ERROR IngestionJobStatus = 6
	// job has been suspended and waiting for cleanup
	IngestionJobStatus_SUSPENDING IngestionJobStatus = 7
	// job has been suspended
	IngestionJobStatus_SUSPENDED IngestionJobStatus = 8
)

func (IngestionJobStatus) Descriptor 

func (IngestionJobStatus) Descriptor() protoreflect.EnumDescriptor

func (IngestionJobStatus) Enum 

func (x IngestionJobStatus) Enum() *IngestionJobStatus

func (IngestionJobStatus) EnumDescriptor deprecated 

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

Deprecated: Use IngestionJobStatus.Descriptor instead.

func (IngestionJobStatus) Number 

func (x IngestionJobStatus) Number() protoreflect.EnumNumber

func (IngestionJobStatus) String 

func (x IngestionJobStatus) String() string

func (IngestionJobStatus) Type 

func (IngestionJobStatus) Type() protoreflect.EnumType

type Job added in v0.9.0 

type Job struct {

	// Identifier of the Job
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Type of the Job
	Type JobType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.core.JobType" json:"type,omitempty"`
	// Current job status
	Status JobStatus `protobuf:"varint,3,opt,name=status,proto3,enum=feast.core.JobStatus" json:"status,omitempty"`
	// Deterministic hash of the Job
	Hash string `protobuf:"bytes,8,opt,name=hash,proto3" json:"hash,omitempty"`
	// JobType specific metadata on the job
	//
	// Types that are assignable to Meta:
	//	*Job_Retrieval
	//	*Job_BatchIngestion
	//	*Job_StreamIngestion
	Meta isJob_Meta `protobuf_oneof:"meta"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetBatchIngestion added in v0.9.0 

func (x *Job) GetBatchIngestion() *Job_OfflineToOnlineMeta

func (*Job) GetHash added in v0.9.0 

func (x *Job) GetHash() string

func (*Job) GetId added in v0.9.0 

func (x *Job) GetId() string

func (*Job) GetMeta added in v0.9.0 

func (m *Job) GetMeta() isJob_Meta

func (*Job) GetRetrieval added in v0.9.0 

func (x *Job) GetRetrieval() *Job_RetrievalJobMeta

func (*Job) GetStatus added in v0.9.0 

func (x *Job) GetStatus() JobStatus

func (*Job) GetStreamIngestion added in v0.9.0 

func (x *Job) GetStreamIngestion() *Job_StreamToOnlineMeta

func (*Job) GetType added in v0.9.0 

func (x *Job) GetType() JobType

func (*Job) ProtoMessage added in v0.9.0 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect added in v0.9.0 

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

func (*Job) Reset added in v0.9.0 

func (x *Job) Reset()

func (*Job) String added in v0.9.0 

func (x *Job) String() string

type JobServiceClient added in v0.9.0 

type JobServiceClient interface {
	// Start job to ingest data from offline store into online store
	StartOfflineToOnlineIngestionJob(ctx context.Context, in *StartOfflineToOnlineIngestionJobRequest, opts ...grpc.CallOption) (*StartOfflineToOnlineIngestionJobResponse, error)
	// Produce a training dataset, return a job id that will provide a file reference
	GetHistoricalFeatures(ctx context.Context, in *GetHistoricalFeaturesRequest, opts ...grpc.CallOption) (*GetHistoricalFeaturesResponse, error)
	// Start job to ingest data from stream into online store
	StartStreamToOnlineIngestionJob(ctx context.Context, in *StartStreamToOnlineIngestionJobRequest, opts ...grpc.CallOption) (*StartStreamToOnlineIngestionJobResponse, error)
	// List all types of jobs
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	// Cancel a single job
	CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error)
	// Get details of a single job
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
}

JobServiceClient is the client API for JobService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewJobServiceClient added in v0.9.0 

func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient

type JobServiceServer added in v0.9.0 

type JobServiceServer interface {
	// Start job to ingest data from offline store into online store
	StartOfflineToOnlineIngestionJob(context.Context, *StartOfflineToOnlineIngestionJobRequest) (*StartOfflineToOnlineIngestionJobResponse, error)
	// Produce a training dataset, return a job id that will provide a file reference
	GetHistoricalFeatures(context.Context, *GetHistoricalFeaturesRequest) (*GetHistoricalFeaturesResponse, error)
	// Start job to ingest data from stream into online store
	StartStreamToOnlineIngestionJob(context.Context, *StartStreamToOnlineIngestionJobRequest) (*StartStreamToOnlineIngestionJobResponse, error)
	// List all types of jobs
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	// Cancel a single job
	CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
	// Get details of a single job
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
}

JobServiceServer is the server API for JobService service.

type JobStatus added in v0.9.0 

type JobStatus int32
const (
	JobStatus_JOB_STATUS_INVALID JobStatus = 0
	// The Job has be registered and waiting to get scheduled to run
	JobStatus_JOB_STATUS_PENDING JobStatus = 1
	// The Job is currently processing its task
	JobStatus_JOB_STATUS_RUNNING JobStatus = 2
	// The Job has successfully completed its task
	JobStatus_JOB_STATUS_DONE JobStatus = 3
	// The Job has encountered an error while processing its task
	JobStatus_JOB_STATUS_ERROR JobStatus = 4
)

func (JobStatus) Descriptor added in v0.9.0 

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum added in v0.9.0 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number added in v0.9.0 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String added in v0.9.0 

func (x JobStatus) String() string

func (JobStatus) Type added in v0.9.0 

func (JobStatus) Type() protoreflect.EnumType

type JobType added in v0.9.0 

type JobType int32
const (
	JobType_INVALID_JOB          JobType = 0
	JobType_BATCH_INGESTION_JOB  JobType = 1
	JobType_STREAM_INGESTION_JOB JobType = 2
	JobType_RETRIEVAL_JOB        JobType = 4
)

func (JobType) Descriptor added in v0.9.0 

func (JobType) Descriptor() protoreflect.EnumDescriptor

func (JobType) Enum added in v0.9.0 

func (x JobType) Enum() *JobType

func (JobType) EnumDescriptor deprecated added in v0.9.0 

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

Deprecated: Use JobType.Descriptor instead.

func (JobType) Number added in v0.9.0 

func (x JobType) Number() protoreflect.EnumNumber

func (JobType) String added in v0.9.0 

func (x JobType) String() string

func (JobType) Type added in v0.9.0 

func (JobType) Type() protoreflect.EnumType

type Job_BatchIngestion added in v0.9.0 

type Job_BatchIngestion struct {
	BatchIngestion *Job_OfflineToOnlineMeta `protobuf:"bytes,6,opt,name=batch_ingestion,json=batchIngestion,proto3,oneof"`
}

type Job_OfflineToOnlineMeta added in v0.9.0 

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

func (*Job_OfflineToOnlineMeta) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Job_OfflineToOnlineMeta.ProtoReflect.Descriptor instead.

func (*Job_OfflineToOnlineMeta) ProtoMessage added in v0.9.0 

func (*Job_OfflineToOnlineMeta) ProtoMessage()

func (*Job_OfflineToOnlineMeta) ProtoReflect added in v0.9.0 

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

func (*Job_OfflineToOnlineMeta) Reset added in v0.9.0 

func (x *Job_OfflineToOnlineMeta) Reset()

func (*Job_OfflineToOnlineMeta) String added in v0.9.0 

func (x *Job_OfflineToOnlineMeta) String() string

type Job_Retrieval added in v0.9.0 

type Job_Retrieval struct {
	Retrieval *Job_RetrievalJobMeta `protobuf:"bytes,5,opt,name=retrieval,proto3,oneof"`
}

type Job_RetrievalJobMeta added in v0.9.0 

type Job_RetrievalJobMeta struct {
	OutputLocation string `protobuf:"bytes,4,opt,name=output_location,json=outputLocation,proto3" json:"output_location,omitempty"`
	// contains filtered or unexported fields
}

func (*Job_RetrievalJobMeta) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Job_RetrievalJobMeta.ProtoReflect.Descriptor instead.

func (*Job_RetrievalJobMeta) GetOutputLocation added in v0.9.0 

func (x *Job_RetrievalJobMeta) GetOutputLocation() string

func (*Job_RetrievalJobMeta) ProtoMessage added in v0.9.0 

func (*Job_RetrievalJobMeta) ProtoMessage()

func (*Job_RetrievalJobMeta) ProtoReflect added in v0.9.0 

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

func (*Job_RetrievalJobMeta) Reset added in v0.9.0 

func (x *Job_RetrievalJobMeta) Reset()

func (*Job_RetrievalJobMeta) String added in v0.9.0 

func (x *Job_RetrievalJobMeta) String() string

type Job_StreamIngestion added in v0.9.0 

type Job_StreamIngestion struct {
	StreamIngestion *Job_StreamToOnlineMeta `protobuf:"bytes,7,opt,name=stream_ingestion,json=streamIngestion,proto3,oneof"`
}

type Job_StreamToOnlineMeta added in v0.9.0 

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

func (*Job_StreamToOnlineMeta) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Job_StreamToOnlineMeta.ProtoReflect.Descriptor instead.

func (*Job_StreamToOnlineMeta) ProtoMessage added in v0.9.0 

func (*Job_StreamToOnlineMeta) ProtoMessage()

func (*Job_StreamToOnlineMeta) ProtoReflect added in v0.9.0 

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

func (*Job_StreamToOnlineMeta) Reset added in v0.9.0 

func (x *Job_StreamToOnlineMeta) Reset()

func (*Job_StreamToOnlineMeta) String added in v0.9.0 

func (x *Job_StreamToOnlineMeta) String() string

type KafkaSourceConfig 

type KafkaSourceConfig struct {

	// Comma separated list of Kafka bootstrap servers. Used for feature sets 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 use for feature sets without user defined topics
	Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Number of Kafka partitions to to use for managed feature stream.
	Partitions int32 `protobuf:"varint,3,opt,name=partitions,proto3" json:"partitions,omitempty"`
	// Defines the number of copies of managed feature stream Kafka.
	ReplicationFactor int32 `protobuf:"varint,4,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaSourceConfig) Descriptor deprecated 

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

Deprecated: Use KafkaSourceConfig.ProtoReflect.Descriptor instead.

func (*KafkaSourceConfig) GetBootstrapServers 

func (x *KafkaSourceConfig) GetBootstrapServers() string

func (*KafkaSourceConfig) GetPartitions 

func (x *KafkaSourceConfig) GetPartitions() int32

func (*KafkaSourceConfig) GetReplicationFactor 

func (x *KafkaSourceConfig) GetReplicationFactor() int32

func (*KafkaSourceConfig) GetTopic 

func (x *KafkaSourceConfig) GetTopic() string

func (*KafkaSourceConfig) ProtoMessage 

func (*KafkaSourceConfig) ProtoMessage()

func (*KafkaSourceConfig) ProtoReflect 

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

func (*KafkaSourceConfig) Reset 

func (x *KafkaSourceConfig) Reset()

func (*KafkaSourceConfig) String 

func (x *KafkaSourceConfig) String() string

type ListEntitiesRequest added in v0.8.0 

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

Retrieves details for all versions of a specific entity

func (*ListEntitiesRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ListEntitiesRequest.ProtoReflect.Descriptor instead.

func (*ListEntitiesRequest) GetFilter added in v0.8.0 

func (x *ListEntitiesRequest) GetFilter() *ListEntitiesRequest_Filter

func (*ListEntitiesRequest) ProtoMessage added in v0.8.0 

func (*ListEntitiesRequest) ProtoMessage()

func (*ListEntitiesRequest) ProtoReflect added in v0.8.0 

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

func (*ListEntitiesRequest) Reset added in v0.8.0 

func (x *ListEntitiesRequest) Reset()

func (*ListEntitiesRequest) String added in v0.8.0 

func (x *ListEntitiesRequest) String() string

type ListEntitiesRequest_Filter added in v0.8.0 

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
}

func (*ListEntitiesRequest_Filter) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ListEntitiesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListEntitiesRequest_Filter) GetLabels added in v0.8.0 

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

func (*ListEntitiesRequest_Filter) GetProject added in v0.8.0 

func (x *ListEntitiesRequest_Filter) GetProject() string

func (*ListEntitiesRequest_Filter) ProtoMessage added in v0.8.0 

func (*ListEntitiesRequest_Filter) ProtoMessage()

func (*ListEntitiesRequest_Filter) ProtoReflect added in v0.8.0 

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

func (*ListEntitiesRequest_Filter) Reset added in v0.8.0 

func (x *ListEntitiesRequest_Filter) Reset()

func (*ListEntitiesRequest_Filter) String added in v0.8.0 

func (x *ListEntitiesRequest_Filter) String() string

type ListEntitiesResponse added in v0.8.0 

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

func (*ListEntitiesResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ListEntitiesResponse.ProtoReflect.Descriptor instead.

func (*ListEntitiesResponse) GetEntities added in v0.8.0 

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

func (*ListEntitiesResponse) ProtoMessage added in v0.8.0 

func (*ListEntitiesResponse) ProtoMessage()

func (*ListEntitiesResponse) ProtoReflect added in v0.8.0 

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

func (*ListEntitiesResponse) Reset added in v0.8.0 

func (x *ListEntitiesResponse) Reset()

func (*ListEntitiesResponse) String added in v0.8.0 

func (x *ListEntitiesResponse) String() string

type ListFeatureTablesRequest added in v0.8.0 

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
}

func (*ListFeatureTablesRequest) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ListFeatureTablesRequest.ProtoReflect.Descriptor instead.

func (*ListFeatureTablesRequest) GetFilter added in v0.8.0 

func (x *ListFeatureTablesRequest) GetFilter() *ListFeatureTablesRequest_Filter

func (*ListFeatureTablesRequest) ProtoMessage added in v0.8.0 

func (*ListFeatureTablesRequest) ProtoMessage()

func (*ListFeatureTablesRequest) ProtoReflect added in v0.8.0 

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

func (*ListFeatureTablesRequest) Reset added in v0.8.0 

func (x *ListFeatureTablesRequest) Reset()

func (*ListFeatureTablesRequest) String added in v0.8.0 

func (x *ListFeatureTablesRequest) String() string

type ListFeatureTablesRequest_Filter added in v0.8.0 

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
}

func (*ListFeatureTablesRequest_Filter) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ListFeatureTablesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListFeatureTablesRequest_Filter) GetLabels added in v0.8.0 

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

func (*ListFeatureTablesRequest_Filter) GetProject added in v0.8.0 

func (x *ListFeatureTablesRequest_Filter) GetProject() string

func (*ListFeatureTablesRequest_Filter) ProtoMessage added in v0.8.0 

func (*ListFeatureTablesRequest_Filter) ProtoMessage()

func (*ListFeatureTablesRequest_Filter) ProtoReflect added in v0.8.0 

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

func (*ListFeatureTablesRequest_Filter) Reset added in v0.8.0 

func (x *ListFeatureTablesRequest_Filter) Reset()

func (*ListFeatureTablesRequest_Filter) String added in v0.8.0 

func (x *ListFeatureTablesRequest_Filter) String() string

type ListFeatureTablesResponse added in v0.8.0 

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
}

func (*ListFeatureTablesResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use ListFeatureTablesResponse.ProtoReflect.Descriptor instead.

func (*ListFeatureTablesResponse) GetTables added in v0.8.0 

func (x *ListFeatureTablesResponse) GetTables() []*FeatureTable

func (*ListFeatureTablesResponse) ProtoMessage added in v0.8.0 

func (*ListFeatureTablesResponse) ProtoMessage()

func (*ListFeatureTablesResponse) ProtoReflect added in v0.8.0 

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

func (*ListFeatureTablesResponse) Reset added in v0.8.0 

func (x *ListFeatureTablesResponse) Reset()

func (*ListFeatureTablesResponse) String added in v0.8.0 

func (x *ListFeatureTablesResponse) String() string

type ListFeaturesRequest added in v0.6.2 

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

func (*ListFeaturesRequest) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use ListFeaturesRequest.ProtoReflect.Descriptor instead.

func (*ListFeaturesRequest) GetFilter added in v0.6.2 

func (x *ListFeaturesRequest) GetFilter() *ListFeaturesRequest_Filter

func (*ListFeaturesRequest) ProtoMessage added in v0.6.2 

func (*ListFeaturesRequest) ProtoMessage()

func (*ListFeaturesRequest) ProtoReflect added in v0.6.2 

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

func (*ListFeaturesRequest) Reset added in v0.6.2 

func (x *ListFeaturesRequest) Reset()

func (*ListFeaturesRequest) String added in v0.6.2 

func (x *ListFeaturesRequest) String() string

type ListFeaturesRequest_Filter added in v0.6.2 

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
}

func (*ListFeaturesRequest_Filter) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use ListFeaturesRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListFeaturesRequest_Filter) GetEntities added in v0.6.2 

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

func (*ListFeaturesRequest_Filter) GetLabels added in v0.6.2 

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

func (*ListFeaturesRequest_Filter) GetProject added in v0.6.2 

func (x *ListFeaturesRequest_Filter) GetProject() string

func (*ListFeaturesRequest_Filter) ProtoMessage added in v0.6.2 

func (*ListFeaturesRequest_Filter) ProtoMessage()

func (*ListFeaturesRequest_Filter) ProtoReflect added in v0.6.2 

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

func (*ListFeaturesRequest_Filter) Reset added in v0.6.2 

func (x *ListFeaturesRequest_Filter) Reset()

func (*ListFeaturesRequest_Filter) String added in v0.6.2 

func (x *ListFeaturesRequest_Filter) String() string

type ListFeaturesResponse added in v0.6.2 

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

func (*ListFeaturesResponse) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use ListFeaturesResponse.ProtoReflect.Descriptor instead.

func (*ListFeaturesResponse) GetFeatures added in v0.6.2 

func (x *ListFeaturesResponse) GetFeatures() map[string]*FeatureSpecV2

func (*ListFeaturesResponse) ProtoMessage added in v0.6.2 

func (*ListFeaturesResponse) ProtoMessage()

func (*ListFeaturesResponse) ProtoReflect added in v0.6.2 

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

func (*ListFeaturesResponse) Reset added in v0.6.2 

func (x *ListFeaturesResponse) Reset()

func (*ListFeaturesResponse) String added in v0.6.2 

func (x *ListFeaturesResponse) String() string

type ListJobsRequest added in v0.9.0 

type ListJobsRequest struct {
	IncludeTerminated bool `protobuf:"varint,1,opt,name=include_terminated,json=includeTerminated,proto3" json:"include_terminated,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

func (*ListJobsRequest) GetIncludeTerminated added in v0.9.0 

func (x *ListJobsRequest) GetIncludeTerminated() bool

func (*ListJobsRequest) ProtoMessage added in v0.9.0 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) ProtoReflect added in v0.9.0 

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

func (*ListJobsRequest) Reset added in v0.9.0 

func (x *ListJobsRequest) Reset()

func (*ListJobsRequest) String added in v0.9.0 

func (x *ListJobsRequest) String() string

type ListJobsResponse added in v0.9.0 

type ListJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListJobsResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

func (*ListJobsResponse) GetJobs added in v0.9.0 

func (x *ListJobsResponse) GetJobs() []*Job

func (*ListJobsResponse) ProtoMessage added in v0.9.0 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) ProtoReflect added in v0.9.0 

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

func (*ListJobsResponse) Reset added in v0.9.0 

func (x *ListJobsResponse) Reset()

func (*ListJobsResponse) String added in v0.9.0 

func (x *ListJobsResponse) String() string

type ListProjectsRequest 

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

Request for listing of projects

func (*ListProjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListProjectsRequest.ProtoReflect.Descriptor instead.

func (*ListProjectsRequest) ProtoMessage 

func (*ListProjectsRequest) ProtoMessage()

func (*ListProjectsRequest) ProtoReflect 

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

func (*ListProjectsRequest) Reset 

func (x *ListProjectsRequest) Reset()

func (*ListProjectsRequest) String 

func (x *ListProjectsRequest) String() string

type ListProjectsResponse 

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
}

Response for listing of projects

func (*ListProjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListProjectsResponse.ProtoReflect.Descriptor instead.

func (*ListProjectsResponse) GetProjects 

func (x *ListProjectsResponse) GetProjects() []string

func (*ListProjectsResponse) ProtoMessage 

func (*ListProjectsResponse) ProtoMessage()

func (*ListProjectsResponse) ProtoReflect 

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

func (*ListProjectsResponse) Reset 

func (x *ListProjectsResponse) Reset()

func (*ListProjectsResponse) String 

func (x *ListProjectsResponse) String() string

type ListStoresRequest 

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

func (*ListStoresRequest) Descriptor deprecated 

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

Deprecated: Use ListStoresRequest.ProtoReflect.Descriptor instead.

func (*ListStoresRequest) GetFilter 

func (x *ListStoresRequest) GetFilter() *ListStoresRequest_Filter

func (*ListStoresRequest) ProtoMessage 

func (*ListStoresRequest) ProtoMessage()

func (*ListStoresRequest) ProtoReflect 

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

func (*ListStoresRequest) Reset 

func (x *ListStoresRequest) Reset()

func (*ListStoresRequest) String 

func (x *ListStoresRequest) String() string

type ListStoresRequest_Filter 

type ListStoresRequest_Filter struct {

	// Name of desired store. Regex is not supported in this query.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStoresRequest_Filter) Descriptor deprecated 

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

Deprecated: Use ListStoresRequest_Filter.ProtoReflect.Descriptor instead.

func (*ListStoresRequest_Filter) GetName 

func (x *ListStoresRequest_Filter) GetName() string

func (*ListStoresRequest_Filter) ProtoMessage 

func (*ListStoresRequest_Filter) ProtoMessage()

func (*ListStoresRequest_Filter) ProtoReflect 

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

func (*ListStoresRequest_Filter) Reset 

func (x *ListStoresRequest_Filter) Reset()

func (*ListStoresRequest_Filter) String 

func (x *ListStoresRequest_Filter) String() string

type ListStoresResponse 

type ListStoresResponse struct {
	Store []*Store `protobuf:"bytes,1,rep,name=store,proto3" json:"store,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStoresResponse) Descriptor deprecated 

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

Deprecated: Use ListStoresResponse.ProtoReflect.Descriptor instead.

func (*ListStoresResponse) GetStore 

func (x *ListStoresResponse) GetStore() []*Store

func (*ListStoresResponse) ProtoMessage 

func (*ListStoresResponse) ProtoMessage()

func (*ListStoresResponse) ProtoReflect 

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

func (*ListStoresResponse) Reset 

func (x *ListStoresResponse) Reset()

func (*ListStoresResponse) String 

func (x *ListStoresResponse) String() string

type Source 

type Source struct {

	// The kind of data source Feast should connect to in order to retrieve FeatureRow value
	Type SourceType `protobuf:"varint,1,opt,name=type,proto3,enum=feast.core.SourceType" json:"type,omitempty"`
	// Source specific configuration
	//
	// Types that are assignable to SourceConfig:
	//	*Source_KafkaSourceConfig
	SourceConfig isSource_SourceConfig `protobuf_oneof:"source_config"`
	// contains filtered or unexported fields
}

func (*Source) Descriptor deprecated 

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

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetKafkaSourceConfig 

func (x *Source) GetKafkaSourceConfig() *KafkaSourceConfig

func (*Source) GetSourceConfig 

func (m *Source) GetSourceConfig() isSource_SourceConfig

func (*Source) GetType 

func (x *Source) GetType() SourceType

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) ProtoReflect 

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

func (*Source) Reset 

func (x *Source) Reset()

func (*Source) String 

func (x *Source) String() string

type SourceType 

type SourceType int32
const (
	SourceType_INVALID SourceType = 0
	SourceType_KAFKA   SourceType = 1
)

func (SourceType) Descriptor 

func (SourceType) Descriptor() protoreflect.EnumDescriptor

func (SourceType) Enum 

func (x SourceType) Enum() *SourceType

func (SourceType) EnumDescriptor deprecated 

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

Deprecated: Use SourceType.Descriptor instead.

func (SourceType) Number 

func (x SourceType) Number() protoreflect.EnumNumber

func (SourceType) String 

func (x SourceType) String() string

func (SourceType) Type 

func (SourceType) Type() protoreflect.EnumType

type Source_KafkaSourceConfig 

type Source_KafkaSourceConfig struct {
	KafkaSourceConfig *KafkaSourceConfig `protobuf:"bytes,2,opt,name=kafka_source_config,json=kafkaSourceConfig,proto3,oneof"`
}

type SpecsStreamingUpdateConfig added in v0.6.2 

type SpecsStreamingUpdateConfig struct {

	// out-channel for publishing new FeatureSetSpecs (by Core).
	// IngestionJob use it as source of existing FeatureSetSpecs and new real-time updates
	Source *KafkaSourceConfig `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// ack-channel for sending acknowledgments when new FeatureSetSpecs is installed in Job
	Ack *KafkaSourceConfig `protobuf:"bytes,2,opt,name=ack,proto3" json:"ack,omitempty"`
	// contains filtered or unexported fields
}

Config for bi-directional communication channel between Core Service and Ingestion Job

func (*SpecsStreamingUpdateConfig) Descriptor deprecated added in v0.6.2 

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

Deprecated: Use SpecsStreamingUpdateConfig.ProtoReflect.Descriptor instead.

func (*SpecsStreamingUpdateConfig) GetAck added in v0.6.2 

func (x *SpecsStreamingUpdateConfig) GetAck() *KafkaSourceConfig

func (*SpecsStreamingUpdateConfig) GetSource added in v0.6.2 

func (x *SpecsStreamingUpdateConfig) GetSource() *KafkaSourceConfig

func (*SpecsStreamingUpdateConfig) ProtoMessage added in v0.6.2 

func (*SpecsStreamingUpdateConfig) ProtoMessage()

func (*SpecsStreamingUpdateConfig) ProtoReflect added in v0.6.2 

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

func (*SpecsStreamingUpdateConfig) Reset added in v0.6.2 

func (x *SpecsStreamingUpdateConfig) Reset()

func (*SpecsStreamingUpdateConfig) String added in v0.6.2 

func (x *SpecsStreamingUpdateConfig) String() string

type StartOfflineToOnlineIngestionJobRequest added in v0.9.0 

type StartOfflineToOnlineIngestionJobRequest struct {

	// Feature table to ingest
	Project   string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// Start of time range for source data from offline store
	StartDate *timestamp.Timestamp `protobuf:"bytes,3,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	// End of time range for source data from offline store
	EndDate *timestamp.Timestamp `protobuf:"bytes,4,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	// contains filtered or unexported fields
}

Ingest data from offline store into online store

func (*StartOfflineToOnlineIngestionJobRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StartOfflineToOnlineIngestionJobRequest.ProtoReflect.Descriptor instead.

func (*StartOfflineToOnlineIngestionJobRequest) GetEndDate added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobRequest) GetEndDate() *timestamp.Timestamp

func (*StartOfflineToOnlineIngestionJobRequest) GetProject added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobRequest) GetProject() string

func (*StartOfflineToOnlineIngestionJobRequest) GetStartDate added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobRequest) GetStartDate() *timestamp.Timestamp

func (*StartOfflineToOnlineIngestionJobRequest) GetTableName added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobRequest) GetTableName() string

func (*StartOfflineToOnlineIngestionJobRequest) ProtoMessage added in v0.9.0 

func (*StartOfflineToOnlineIngestionJobRequest) ProtoMessage()

func (*StartOfflineToOnlineIngestionJobRequest) ProtoReflect added in v0.9.0 

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

func (*StartOfflineToOnlineIngestionJobRequest) Reset added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobRequest) Reset()

func (*StartOfflineToOnlineIngestionJobRequest) String added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobRequest) String() string

type StartOfflineToOnlineIngestionJobResponse added in v0.9.0 

type StartOfflineToOnlineIngestionJobResponse struct {

	// Job ID assigned by Feast
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartOfflineToOnlineIngestionJobResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StartOfflineToOnlineIngestionJobResponse.ProtoReflect.Descriptor instead.

func (*StartOfflineToOnlineIngestionJobResponse) GetId added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobResponse) GetId() string

func (*StartOfflineToOnlineIngestionJobResponse) ProtoMessage added in v0.9.0 

func (*StartOfflineToOnlineIngestionJobResponse) ProtoMessage()

func (*StartOfflineToOnlineIngestionJobResponse) ProtoReflect added in v0.9.0 

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

func (*StartOfflineToOnlineIngestionJobResponse) Reset added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobResponse) Reset()

func (*StartOfflineToOnlineIngestionJobResponse) String added in v0.9.0 

func (x *StartOfflineToOnlineIngestionJobResponse) String() string

type StartStreamToOnlineIngestionJobRequest added in v0.9.0 

type StartStreamToOnlineIngestionJobRequest struct {

	// Feature table to ingest
	Project   string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StartStreamToOnlineIngestionJobRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StartStreamToOnlineIngestionJobRequest.ProtoReflect.Descriptor instead.

func (*StartStreamToOnlineIngestionJobRequest) GetProject added in v0.9.0 

func (x *StartStreamToOnlineIngestionJobRequest) GetProject() string

func (*StartStreamToOnlineIngestionJobRequest) GetTableName added in v0.9.0 

func (x *StartStreamToOnlineIngestionJobRequest) GetTableName() string

func (*StartStreamToOnlineIngestionJobRequest) ProtoMessage added in v0.9.0 

func (*StartStreamToOnlineIngestionJobRequest) ProtoMessage()

func (*StartStreamToOnlineIngestionJobRequest) ProtoReflect added in v0.9.0 

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

func (*StartStreamToOnlineIngestionJobRequest) Reset added in v0.9.0 

func (x *StartStreamToOnlineIngestionJobRequest) Reset()

func (*StartStreamToOnlineIngestionJobRequest) String added in v0.9.0 

func (x *StartStreamToOnlineIngestionJobRequest) String() string

type StartStreamToOnlineIngestionJobResponse added in v0.9.0 

type StartStreamToOnlineIngestionJobResponse struct {

	// Job ID assigned by Feast
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartStreamToOnlineIngestionJobResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use StartStreamToOnlineIngestionJobResponse.ProtoReflect.Descriptor instead.

func (*StartStreamToOnlineIngestionJobResponse) GetId added in v0.9.0 

func (x *StartStreamToOnlineIngestionJobResponse) GetId() string

func (*StartStreamToOnlineIngestionJobResponse) ProtoMessage added in v0.9.0 

func (*StartStreamToOnlineIngestionJobResponse) ProtoMessage()

func (*StartStreamToOnlineIngestionJobResponse) ProtoReflect added in v0.9.0 

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

func (*StartStreamToOnlineIngestionJobResponse) Reset added in v0.9.0 

func (x *StartStreamToOnlineIngestionJobResponse) Reset()

func (*StartStreamToOnlineIngestionJobResponse) String added in v0.9.0 

func (x *StartStreamToOnlineIngestionJobResponse) 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"`
	// 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 added in v0.8.0 

func (x *Store_RedisClusterConfig) GetEnableFallback() bool

func (*Store_RedisClusterConfig) GetFallbackPrefix added in v0.8.0 

func (x *Store_RedisClusterConfig) GetFallbackPrefix() string

func (*Store_RedisClusterConfig) GetFlushFrequencySeconds added in v0.8.0 

func (x *Store_RedisClusterConfig) GetFlushFrequencySeconds() int32

func (*Store_RedisClusterConfig) GetInitialBackoffMs 

func (x *Store_RedisClusterConfig) GetInitialBackoffMs() int32

func (*Store_RedisClusterConfig) GetKeyPrefix added in v0.8.0 

func (x *Store_RedisClusterConfig) GetKeyPrefix() string

func (*Store_RedisClusterConfig) GetMaxRetries 

func (x *Store_RedisClusterConfig) GetMaxRetries() int32

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_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 added in v0.8.0 

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 added in v0.9.0 

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 added in v0.6.2 

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 StreamFormat added in v0.8.0 

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
}

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

func (*StreamFormat) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use StreamFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat) GetAvroFormat added in v0.8.0 

func (x *StreamFormat) GetAvroFormat() *StreamFormat_AvroFormat

func (*StreamFormat) GetFormat added in v0.8.0 

func (m *StreamFormat) GetFormat() isStreamFormat_Format

func (*StreamFormat) GetProtoFormat added in v0.8.0 

func (x *StreamFormat) GetProtoFormat() *StreamFormat_ProtoFormat

func (*StreamFormat) ProtoMessage added in v0.8.0 

func (*StreamFormat) ProtoMessage()

func (*StreamFormat) ProtoReflect added in v0.8.0 

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

func (*StreamFormat) Reset added in v0.8.0 

func (x *StreamFormat) Reset()

func (*StreamFormat) String added in v0.8.0 

func (x *StreamFormat) String() string

type StreamFormat_AvroFormat added in v0.8.0 

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 added in v0.8.0 

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

Deprecated: Use StreamFormat_AvroFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat_AvroFormat) GetSchemaJson added in v0.8.0 

func (x *StreamFormat_AvroFormat) GetSchemaJson() string

func (*StreamFormat_AvroFormat) ProtoMessage added in v0.8.0 

func (*StreamFormat_AvroFormat) ProtoMessage()

func (*StreamFormat_AvroFormat) ProtoReflect added in v0.8.0 

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

func (*StreamFormat_AvroFormat) Reset added in v0.8.0 

func (x *StreamFormat_AvroFormat) Reset()

func (*StreamFormat_AvroFormat) String added in v0.8.0 

func (x *StreamFormat_AvroFormat) String() string

type StreamFormat_AvroFormat_ added in v0.8.0 

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

type StreamFormat_ProtoFormat added in v0.8.0 

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 added in v0.8.0 

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

Deprecated: Use StreamFormat_ProtoFormat.ProtoReflect.Descriptor instead.

func (*StreamFormat_ProtoFormat) GetClassPath added in v0.8.0 

func (x *StreamFormat_ProtoFormat) GetClassPath() string

func (*StreamFormat_ProtoFormat) ProtoMessage added in v0.8.0 

func (*StreamFormat_ProtoFormat) ProtoMessage()

func (*StreamFormat_ProtoFormat) ProtoReflect added in v0.8.0 

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

func (*StreamFormat_ProtoFormat) Reset added in v0.8.0 

func (x *StreamFormat_ProtoFormat) Reset()

func (*StreamFormat_ProtoFormat) String added in v0.8.0 

func (x *StreamFormat_ProtoFormat) String() string

type StreamFormat_ProtoFormat_ added in v0.8.0 

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

type UnimplementedCoreServiceServer 

type UnimplementedCoreServiceServer struct {
}

UnimplementedCoreServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCoreServiceServer) ApplyEntity added in v0.8.0 

func (*UnimplementedCoreServiceServer) ApplyEntity(context.Context, *ApplyEntityRequest) (*ApplyEntityResponse, error)

func (*UnimplementedCoreServiceServer) ApplyFeatureTable added in v0.8.0 

func (*UnimplementedCoreServiceServer) ApplyFeatureTable(context.Context, *ApplyFeatureTableRequest) (*ApplyFeatureTableResponse, error)

func (*UnimplementedCoreServiceServer) ArchiveProject 

func (*UnimplementedCoreServiceServer) ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)

func (*UnimplementedCoreServiceServer) CreateProject 

func (*UnimplementedCoreServiceServer) CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)

func (*UnimplementedCoreServiceServer) DeleteFeatureTable added in v0.9.0 

func (*UnimplementedCoreServiceServer) DeleteFeatureTable(context.Context, *DeleteFeatureTableRequest) (*DeleteFeatureTableResponse, error)

func (*UnimplementedCoreServiceServer) GetEntity added in v0.8.0 

func (*UnimplementedCoreServiceServer) GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)

func (*UnimplementedCoreServiceServer) GetFeastCoreVersion 

func (*UnimplementedCoreServiceServer) GetFeastCoreVersion(context.Context, *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error)

func (*UnimplementedCoreServiceServer) GetFeatureTable added in v0.8.0 

func (*UnimplementedCoreServiceServer) GetFeatureTable(context.Context, *GetFeatureTableRequest) (*GetFeatureTableResponse, error)

func (*UnimplementedCoreServiceServer) ListEntities added in v0.8.0 

func (*UnimplementedCoreServiceServer) ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)

func (*UnimplementedCoreServiceServer) ListFeatureTables added in v0.8.0 

func (*UnimplementedCoreServiceServer) ListFeatureTables(context.Context, *ListFeatureTablesRequest) (*ListFeatureTablesResponse, error)

func (*UnimplementedCoreServiceServer) ListFeatures added in v0.6.2 

func (*UnimplementedCoreServiceServer) ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)

func (*UnimplementedCoreServiceServer) ListProjects 

func (*UnimplementedCoreServiceServer) ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)

func (*UnimplementedCoreServiceServer) ListStores 

func (*UnimplementedCoreServiceServer) ListStores(context.Context, *ListStoresRequest) (*ListStoresResponse, error)

func (*UnimplementedCoreServiceServer) UpdateStore 

func (*UnimplementedCoreServiceServer) UpdateStore(context.Context, *UpdateStoreRequest) (*UpdateStoreResponse, error)

type UnimplementedJobServiceServer added in v0.9.0 

type UnimplementedJobServiceServer struct {
}

UnimplementedJobServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedJobServiceServer) CancelJob added in v0.9.0 

func (*UnimplementedJobServiceServer) CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)

func (*UnimplementedJobServiceServer) GetHistoricalFeatures added in v0.9.0 

func (*UnimplementedJobServiceServer) GetHistoricalFeatures(context.Context, *GetHistoricalFeaturesRequest) (*GetHistoricalFeaturesResponse, error)

func (*UnimplementedJobServiceServer) GetJob added in v0.9.0 

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

func (*UnimplementedJobServiceServer) ListJobs added in v0.9.0 

func (*UnimplementedJobServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)

func (*UnimplementedJobServiceServer) StartOfflineToOnlineIngestionJob added in v0.9.0 

func (*UnimplementedJobServiceServer) StartOfflineToOnlineIngestionJob(context.Context, *StartOfflineToOnlineIngestionJobRequest) (*StartOfflineToOnlineIngestionJobResponse, error)

func (*UnimplementedJobServiceServer) StartStreamToOnlineIngestionJob added in v0.9.0 

func (*UnimplementedJobServiceServer) StartStreamToOnlineIngestionJob(context.Context, *StartStreamToOnlineIngestionJobRequest) (*StartStreamToOnlineIngestionJobResponse, error)

type UpdateFeatureSetStatusResponse added in v0.8.0 

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

func (*UpdateFeatureSetStatusResponse) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use UpdateFeatureSetStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateFeatureSetStatusResponse) ProtoMessage added in v0.8.0 

func (*UpdateFeatureSetStatusResponse) ProtoMessage()

func (*UpdateFeatureSetStatusResponse) ProtoReflect added in v0.8.0 

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

func (*UpdateFeatureSetStatusResponse) Reset added in v0.8.0 

func (x *UpdateFeatureSetStatusResponse) Reset()

func (*UpdateFeatureSetStatusResponse) String added in v0.8.0 

func (x *UpdateFeatureSetStatusResponse) String() string

type UpdateStoreRequest 

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

func (*UpdateStoreRequest) Descriptor deprecated 

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

Deprecated: Use UpdateStoreRequest.ProtoReflect.Descriptor instead.

func (*UpdateStoreRequest) GetStore 

func (x *UpdateStoreRequest) GetStore() *Store

func (*UpdateStoreRequest) ProtoMessage 

func (*UpdateStoreRequest) ProtoMessage()

func (*UpdateStoreRequest) ProtoReflect 

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

func (*UpdateStoreRequest) Reset 

func (x *UpdateStoreRequest) Reset()

func (*UpdateStoreRequest) String 

func (x *UpdateStoreRequest) String() string

type UpdateStoreResponse 

type UpdateStoreResponse struct {
	Store  *Store                     `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"`
	Status UpdateStoreResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.UpdateStoreResponse_Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStoreResponse) Descriptor deprecated 

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

Deprecated: Use UpdateStoreResponse.ProtoReflect.Descriptor instead.

func (*UpdateStoreResponse) GetStatus 

func (x *UpdateStoreResponse) GetStatus() UpdateStoreResponse_Status

func (*UpdateStoreResponse) GetStore 

func (x *UpdateStoreResponse) GetStore() *Store

func (*UpdateStoreResponse) ProtoMessage 

func (*UpdateStoreResponse) ProtoMessage()

func (*UpdateStoreResponse) ProtoReflect 

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

func (*UpdateStoreResponse) Reset 

func (x *UpdateStoreResponse) Reset()

func (*UpdateStoreResponse) String 

func (x *UpdateStoreResponse) String() string

type UpdateStoreResponse_Status 

type UpdateStoreResponse_Status int32
const (
	// Existing store config matching the given store id is identical to the given store config.
	UpdateStoreResponse_NO_CHANGE UpdateStoreResponse_Status = 0
	// New store created or existing config updated.
	UpdateStoreResponse_UPDATED UpdateStoreResponse_Status = 1
)

func (UpdateStoreResponse_Status) Descriptor 

func (UpdateStoreResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (UpdateStoreResponse_Status) Enum 

func (x UpdateStoreResponse_Status) Enum() *UpdateStoreResponse_Status

func (UpdateStoreResponse_Status) EnumDescriptor deprecated 

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

Deprecated: Use UpdateStoreResponse_Status.Descriptor instead.

func (UpdateStoreResponse_Status) Number 

func (x UpdateStoreResponse_Status) Number() protoreflect.EnumNumber

func (UpdateStoreResponse_Status) String 

func (x UpdateStoreResponse_Status) String() string

func (UpdateStoreResponse_Status) Type 

func (UpdateStoreResponse_Status) Type() protoreflect.EnumType

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.