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

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

                    Types

                    type ApplyEntityRequest

                    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

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

                      Deprecated: Use ApplyEntityRequest.ProtoReflect.Descriptor instead.

                      func (*ApplyEntityRequest) GetProject

                      func (x *ApplyEntityRequest) GetProject() string

                      func (*ApplyEntityRequest) GetSpec

                      func (x *ApplyEntityRequest) GetSpec() *EntitySpecV2

                      func (*ApplyEntityRequest) ProtoMessage

                      func (*ApplyEntityRequest) ProtoMessage()

                      func (*ApplyEntityRequest) ProtoReflect

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

                      func (*ApplyEntityRequest) Reset

                      func (x *ApplyEntityRequest) Reset()

                      func (*ApplyEntityRequest) String

                      func (x *ApplyEntityRequest) String() string

                      type ApplyEntityResponse

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

                      func (*ApplyEntityResponse) Descriptor

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

                        Deprecated: Use ApplyEntityResponse.ProtoReflect.Descriptor instead.

                        func (*ApplyEntityResponse) GetEntity

                        func (x *ApplyEntityResponse) GetEntity() *Entity

                        func (*ApplyEntityResponse) ProtoMessage

                        func (*ApplyEntityResponse) ProtoMessage()

                        func (*ApplyEntityResponse) ProtoReflect

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

                        func (*ApplyEntityResponse) Reset

                        func (x *ApplyEntityResponse) Reset()

                        func (*ApplyEntityResponse) String

                        func (x *ApplyEntityResponse) String() string

                        type ApplyFeatureTableRequest

                        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

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

                          Deprecated: Use ApplyFeatureTableRequest.ProtoReflect.Descriptor instead.

                          func (*ApplyFeatureTableRequest) GetProject

                          func (x *ApplyFeatureTableRequest) GetProject() string

                          func (*ApplyFeatureTableRequest) GetTableSpec

                          func (x *ApplyFeatureTableRequest) GetTableSpec() *FeatureTableSpec

                          func (*ApplyFeatureTableRequest) ProtoMessage

                          func (*ApplyFeatureTableRequest) ProtoMessage()

                          func (*ApplyFeatureTableRequest) ProtoReflect

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

                          func (*ApplyFeatureTableRequest) Reset

                          func (x *ApplyFeatureTableRequest) Reset()

                          func (*ApplyFeatureTableRequest) String

                          func (x *ApplyFeatureTableRequest) String() string

                          type ApplyFeatureTableResponse

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

                          func (*ApplyFeatureTableResponse) Descriptor

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

                            Deprecated: Use ApplyFeatureTableResponse.ProtoReflect.Descriptor instead.

                            func (*ApplyFeatureTableResponse) GetTable

                            func (x *ApplyFeatureTableResponse) GetTable() *FeatureTable

                            func (*ApplyFeatureTableResponse) ProtoMessage

                            func (*ApplyFeatureTableResponse) ProtoMessage()

                            func (*ApplyFeatureTableResponse) ProtoReflect

                            func (*ApplyFeatureTableResponse) Reset

                            func (x *ApplyFeatureTableResponse) Reset()

                            func (*ApplyFeatureTableResponse) String

                            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

                              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

                                  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

                                    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

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

                                      Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

                                      func (*CancelJobRequest) GetJobId

                                      func (x *CancelJobRequest) GetJobId() string

                                      func (*CancelJobRequest) ProtoMessage

                                      func (*CancelJobRequest) ProtoMessage()

                                      func (*CancelJobRequest) ProtoReflect

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

                                      func (*CancelJobRequest) Reset

                                      func (x *CancelJobRequest) Reset()

                                      func (*CancelJobRequest) String

                                      func (x *CancelJobRequest) String() string

                                      type CancelJobResponse

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

                                      func (*CancelJobResponse) Descriptor

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

                                        Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.

                                        func (*CancelJobResponse) ProtoMessage

                                        func (*CancelJobResponse) ProtoMessage()

                                        func (*CancelJobResponse) ProtoReflect

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

                                        func (*CancelJobResponse) Reset

                                        func (x *CancelJobResponse) Reset()

                                        func (*CancelJobResponse) String

                                        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.

                                          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

                                              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

                                                  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

                                                    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

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

                                                        Deprecated: Use DataSource.ProtoReflect.Descriptor instead.

                                                        func (*DataSource) GetBigqueryOptions

                                                        func (x *DataSource) GetBigqueryOptions() *DataSource_BigQueryOptions

                                                        func (*DataSource) GetCreatedTimestampColumn

                                                        func (x *DataSource) GetCreatedTimestampColumn() string

                                                        func (*DataSource) GetDatePartitionColumn

                                                        func (x *DataSource) GetDatePartitionColumn() string

                                                        func (*DataSource) GetEventTimestampColumn

                                                        func (x *DataSource) GetEventTimestampColumn() string

                                                        func (*DataSource) GetFieldMapping

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

                                                        func (*DataSource) GetFileOptions

                                                        func (x *DataSource) GetFileOptions() *DataSource_FileOptions

                                                        func (*DataSource) GetKafkaOptions

                                                        func (x *DataSource) GetKafkaOptions() *DataSource_KafkaOptions

                                                        func (*DataSource) GetKinesisOptions

                                                        func (x *DataSource) GetKinesisOptions() *DataSource_KinesisOptions

                                                        func (*DataSource) GetOptions

                                                        func (m *DataSource) GetOptions() isDataSource_Options

                                                        func (*DataSource) GetType

                                                        func (x *DataSource) GetType() DataSource_SourceType

                                                        func (*DataSource) ProtoMessage

                                                        func (*DataSource) ProtoMessage()

                                                        func (*DataSource) ProtoReflect

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

                                                        func (*DataSource) Reset

                                                        func (x *DataSource) Reset()

                                                        func (*DataSource) String

                                                        func (x *DataSource) String() string

                                                        type DataSource_BigQueryOptions

                                                        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

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

                                                            Deprecated: Use DataSource_BigQueryOptions.ProtoReflect.Descriptor instead.

                                                            func (*DataSource_BigQueryOptions) GetTableRef

                                                            func (x *DataSource_BigQueryOptions) GetTableRef() string

                                                            func (*DataSource_BigQueryOptions) ProtoMessage

                                                            func (*DataSource_BigQueryOptions) ProtoMessage()

                                                            func (*DataSource_BigQueryOptions) ProtoReflect

                                                            func (*DataSource_BigQueryOptions) Reset

                                                            func (x *DataSource_BigQueryOptions) Reset()

                                                            func (*DataSource_BigQueryOptions) String

                                                            func (x *DataSource_BigQueryOptions) String() string

                                                            type DataSource_BigqueryOptions

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

                                                            type DataSource_FileOptions

                                                            type DataSource_FileOptions struct {
                                                            	FileFormat *FileFormat `protobuf:"bytes,1,opt,name=file_format,json=fileFormat,proto3" json:"file_format,omitempty"`
                                                            	// Target URL of file to retrieve and source features from.
                                                            	// s3://path/to/file for AWS S3 storage
                                                            	// gs://path/to/file for GCP GCS storage
                                                            	// file:///path/to/file for local storage
                                                            	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

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

                                                                Deprecated: Use DataSource_FileOptions.ProtoReflect.Descriptor instead.

                                                                func (*DataSource_FileOptions) GetFileFormat

                                                                func (x *DataSource_FileOptions) GetFileFormat() *FileFormat

                                                                func (*DataSource_FileOptions) GetFileUrl

                                                                func (x *DataSource_FileOptions) GetFileUrl() string

                                                                func (*DataSource_FileOptions) ProtoMessage

                                                                func (*DataSource_FileOptions) ProtoMessage()

                                                                func (*DataSource_FileOptions) ProtoReflect

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

                                                                func (*DataSource_FileOptions) Reset

                                                                func (x *DataSource_FileOptions) Reset()

                                                                func (*DataSource_FileOptions) String

                                                                func (x *DataSource_FileOptions) String() string

                                                                type DataSource_FileOptions_

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

                                                                type DataSource_KafkaOptions

                                                                type DataSource_KafkaOptions struct {
                                                                
                                                                	// Comma separated list of Kafka bootstrap servers. Used for feature tables without a defined source host[:port]]
                                                                	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

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

                                                                    Deprecated: Use DataSource_KafkaOptions.ProtoReflect.Descriptor instead.

                                                                    func (*DataSource_KafkaOptions) GetBootstrapServers

                                                                    func (x *DataSource_KafkaOptions) GetBootstrapServers() string

                                                                    func (*DataSource_KafkaOptions) GetMessageFormat

                                                                    func (x *DataSource_KafkaOptions) GetMessageFormat() *StreamFormat

                                                                    func (*DataSource_KafkaOptions) GetTopic

                                                                    func (x *DataSource_KafkaOptions) GetTopic() string

                                                                    func (*DataSource_KafkaOptions) ProtoMessage

                                                                    func (*DataSource_KafkaOptions) ProtoMessage()

                                                                    func (*DataSource_KafkaOptions) ProtoReflect

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

                                                                    func (*DataSource_KafkaOptions) Reset

                                                                    func (x *DataSource_KafkaOptions) Reset()

                                                                    func (*DataSource_KafkaOptions) String

                                                                    func (x *DataSource_KafkaOptions) String() string

                                                                    type DataSource_KafkaOptions_

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

                                                                    type DataSource_KinesisOptions

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

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

                                                                      func (*DataSource_KinesisOptions) Descriptor

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

                                                                        Deprecated: Use DataSource_KinesisOptions.ProtoReflect.Descriptor instead.

                                                                        func (*DataSource_KinesisOptions) GetRecordFormat

                                                                        func (x *DataSource_KinesisOptions) GetRecordFormat() *StreamFormat

                                                                        func (*DataSource_KinesisOptions) GetRegion

                                                                        func (x *DataSource_KinesisOptions) GetRegion() string

                                                                        func (*DataSource_KinesisOptions) GetStreamName

                                                                        func (x *DataSource_KinesisOptions) GetStreamName() string

                                                                        func (*DataSource_KinesisOptions) ProtoMessage

                                                                        func (*DataSource_KinesisOptions) ProtoMessage()

                                                                        func (*DataSource_KinesisOptions) ProtoReflect

                                                                        func (*DataSource_KinesisOptions) Reset

                                                                        func (x *DataSource_KinesisOptions) Reset()

                                                                        func (*DataSource_KinesisOptions) String

                                                                        func (x *DataSource_KinesisOptions) String() string

                                                                        type DataSource_KinesisOptions_

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

                                                                        type DataSource_SourceType

                                                                        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

                                                                          func (DataSource_SourceType) Enum

                                                                          func (DataSource_SourceType) EnumDescriptor

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

                                                                            Deprecated: Use DataSource_SourceType.Descriptor instead.

                                                                            func (DataSource_SourceType) Number

                                                                            func (DataSource_SourceType) String

                                                                            func (x DataSource_SourceType) String() string

                                                                            func (DataSource_SourceType) Type

                                                                            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

                                                                            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

                                                                              func (x *DataflowRunnerConfigOptions) GetDiskSizeGb() int32

                                                                              func (*DataflowRunnerConfigOptions) GetEnableStreamingEngine

                                                                              func (x *DataflowRunnerConfigOptions) GetEnableStreamingEngine() bool

                                                                              func (*DataflowRunnerConfigOptions) GetKafkaConsumerProperties

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

                                                                              func (*DataflowRunnerConfigOptions) GetLabels

                                                                              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

                                                                              func (x *DataflowRunnerConfigOptions) GetWorkerDiskType() string

                                                                              func (*DataflowRunnerConfigOptions) GetWorkerMachineType

                                                                              func (x *DataflowRunnerConfigOptions) GetWorkerMachineType() string

                                                                              func (*DataflowRunnerConfigOptions) GetWorkerZone

                                                                              func (x *DataflowRunnerConfigOptions) GetWorkerZone() string

                                                                              func (*DataflowRunnerConfigOptions) ProtoMessage

                                                                              func (*DataflowRunnerConfigOptions) ProtoMessage()

                                                                              func (*DataflowRunnerConfigOptions) ProtoReflect

                                                                              func (*DataflowRunnerConfigOptions) Reset

                                                                              func (x *DataflowRunnerConfigOptions) Reset()

                                                                              func (*DataflowRunnerConfigOptions) String

                                                                              func (x *DataflowRunnerConfigOptions) String() string

                                                                              type DeleteFeatureTableRequest

                                                                              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

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

                                                                                Deprecated: Use DeleteFeatureTableRequest.ProtoReflect.Descriptor instead.

                                                                                func (*DeleteFeatureTableRequest) GetName

                                                                                func (x *DeleteFeatureTableRequest) GetName() string

                                                                                func (*DeleteFeatureTableRequest) GetProject

                                                                                func (x *DeleteFeatureTableRequest) GetProject() string

                                                                                func (*DeleteFeatureTableRequest) ProtoMessage

                                                                                func (*DeleteFeatureTableRequest) ProtoMessage()

                                                                                func (*DeleteFeatureTableRequest) ProtoReflect

                                                                                func (*DeleteFeatureTableRequest) Reset

                                                                                func (x *DeleteFeatureTableRequest) Reset()

                                                                                func (*DeleteFeatureTableRequest) String

                                                                                func (x *DeleteFeatureTableRequest) String() string

                                                                                type DeleteFeatureTableResponse

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

                                                                                func (*DeleteFeatureTableResponse) Descriptor

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

                                                                                  Deprecated: Use DeleteFeatureTableResponse.ProtoReflect.Descriptor instead.

                                                                                  func (*DeleteFeatureTableResponse) ProtoMessage

                                                                                  func (*DeleteFeatureTableResponse) ProtoMessage()

                                                                                  func (*DeleteFeatureTableResponse) ProtoReflect

                                                                                  func (*DeleteFeatureTableResponse) Reset

                                                                                  func (x *DeleteFeatureTableResponse) Reset()

                                                                                  func (*DeleteFeatureTableResponse) String

                                                                                  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

                                                                                  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

                                                                                    func (x *DirectRunnerConfigOptions) GetTempLocation() string

                                                                                    func (*DirectRunnerConfigOptions) ProtoMessage

                                                                                    func (*DirectRunnerConfigOptions) ProtoMessage()

                                                                                    func (*DirectRunnerConfigOptions) ProtoReflect

                                                                                    func (*DirectRunnerConfigOptions) Reset

                                                                                    func (x *DirectRunnerConfigOptions) Reset()

                                                                                    func (*DirectRunnerConfigOptions) String

                                                                                    func (x *DirectRunnerConfigOptions) String() string

                                                                                    type Entity

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

                                                                                    func (*Entity) Descriptor

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

                                                                                      Deprecated: Use Entity.ProtoReflect.Descriptor instead.

                                                                                      func (*Entity) GetMeta

                                                                                      func (x *Entity) GetMeta() *EntityMeta

                                                                                      func (*Entity) GetSpec

                                                                                      func (x *Entity) GetSpec() *EntitySpecV2

                                                                                      func (*Entity) ProtoMessage

                                                                                      func (*Entity) ProtoMessage()

                                                                                      func (*Entity) ProtoReflect

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

                                                                                      func (*Entity) Reset

                                                                                      func (x *Entity) Reset()

                                                                                      func (*Entity) String

                                                                                      func (x *Entity) String() string

                                                                                      type EntityMeta

                                                                                      type EntityMeta struct {
                                                                                      	CreatedTimestamp     *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

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

                                                                                        Deprecated: Use EntityMeta.ProtoReflect.Descriptor instead.

                                                                                        func (*EntityMeta) GetCreatedTimestamp

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

                                                                                        func (*EntityMeta) GetLastUpdatedTimestamp

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

                                                                                        func (*EntityMeta) ProtoMessage

                                                                                        func (*EntityMeta) ProtoMessage()

                                                                                        func (*EntityMeta) ProtoReflect

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

                                                                                        func (*EntityMeta) Reset

                                                                                        func (x *EntityMeta) Reset()

                                                                                        func (*EntityMeta) String

                                                                                        func (x *EntityMeta) String() string

                                                                                        type 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

                                                                                        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

                                                                                          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

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

                                                                                            Deprecated: Use EntitySpecV2.ProtoReflect.Descriptor instead.

                                                                                            func (*EntitySpecV2) GetDescription

                                                                                            func (x *EntitySpecV2) GetDescription() string

                                                                                            func (*EntitySpecV2) GetLabels

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

                                                                                            func (*EntitySpecV2) GetName

                                                                                            func (x *EntitySpecV2) GetName() string

                                                                                            func (*EntitySpecV2) GetValueType

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

                                                                                            func (*EntitySpecV2) ProtoMessage

                                                                                            func (*EntitySpecV2) ProtoMessage()

                                                                                            func (*EntitySpecV2) ProtoReflect

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

                                                                                            func (*EntitySpecV2) Reset

                                                                                            func (x *EntitySpecV2) Reset()

                                                                                            func (*EntitySpecV2) String

                                                                                            func (x *EntitySpecV2) String() string

                                                                                            type 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

                                                                                            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

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

                                                                                              func (FeatureSetJobDeliveryStatus) Descriptor

                                                                                              func (FeatureSetJobDeliveryStatus) Enum

                                                                                              func (FeatureSetJobDeliveryStatus) EnumDescriptor

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

                                                                                                Deprecated: Use FeatureSetJobDeliveryStatus.Descriptor instead.

                                                                                                func (FeatureSetJobDeliveryStatus) Number

                                                                                                func (FeatureSetJobDeliveryStatus) String

                                                                                                func (FeatureSetJobDeliveryStatus) Type

                                                                                                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

                                                                                                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

                                                                                                    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

                                                                                                      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

                                                                                                        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

                                                                                                        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

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

                                                                                                          Deprecated: Use FeatureSetSpecAck.ProtoReflect.Descriptor instead.

                                                                                                          func (*FeatureSetSpecAck) GetFeatureSetReference

                                                                                                          func (x *FeatureSetSpecAck) GetFeatureSetReference() string

                                                                                                          func (*FeatureSetSpecAck) GetFeatureSetVersion

                                                                                                          func (x *FeatureSetSpecAck) GetFeatureSetVersion() int32

                                                                                                          func (*FeatureSetSpecAck) GetJobName

                                                                                                          func (x *FeatureSetSpecAck) GetJobName() string

                                                                                                          func (*FeatureSetSpecAck) ProtoMessage

                                                                                                          func (*FeatureSetSpecAck) ProtoMessage()

                                                                                                          func (*FeatureSetSpecAck) ProtoReflect

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

                                                                                                          func (*FeatureSetSpecAck) Reset

                                                                                                          func (x *FeatureSetSpecAck) Reset()

                                                                                                          func (*FeatureSetSpecAck) String

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

                                                                                                          func (FeatureSetStatus) EnumDescriptor

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

                                                                                                            Deprecated: Use FeatureSetStatus.Descriptor instead.

                                                                                                            func (FeatureSetStatus) Number

                                                                                                            func (FeatureSetStatus) String

                                                                                                            func (x FeatureSetStatus) String() string

                                                                                                            func (FeatureSetStatus) Type

                                                                                                            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

                                                                                                            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

                                                                                                              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

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

                                                                                                                Deprecated: Use FeatureSpecV2.ProtoReflect.Descriptor instead.

                                                                                                                func (*FeatureSpecV2) GetLabels

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

                                                                                                                func (*FeatureSpecV2) GetName

                                                                                                                func (x *FeatureSpecV2) GetName() string

                                                                                                                func (*FeatureSpecV2) GetValueType

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

                                                                                                                func (*FeatureSpecV2) ProtoMessage

                                                                                                                func (*FeatureSpecV2) ProtoMessage()

                                                                                                                func (*FeatureSpecV2) ProtoReflect

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

                                                                                                                func (*FeatureSpecV2) Reset

                                                                                                                func (x *FeatureSpecV2) Reset()

                                                                                                                func (*FeatureSpecV2) String

                                                                                                                func (x *FeatureSpecV2) String() string

                                                                                                                type 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

                                                                                                                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

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

                                                                                                                  Deprecated: Use FeatureTable.ProtoReflect.Descriptor instead.

                                                                                                                  func (*FeatureTable) GetMeta

                                                                                                                  func (x *FeatureTable) GetMeta() *FeatureTableMeta

                                                                                                                  func (*FeatureTable) GetSpec

                                                                                                                  func (x *FeatureTable) GetSpec() *FeatureTableSpec

                                                                                                                  func (*FeatureTable) ProtoMessage

                                                                                                                  func (*FeatureTable) ProtoMessage()

                                                                                                                  func (*FeatureTable) ProtoReflect

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

                                                                                                                  func (*FeatureTable) Reset

                                                                                                                  func (x *FeatureTable) Reset()

                                                                                                                  func (*FeatureTable) String

                                                                                                                  func (x *FeatureTable) String() string

                                                                                                                  type FeatureTableMeta

                                                                                                                  type FeatureTableMeta struct {
                                                                                                                  
                                                                                                                  	// Time where this Feature Table is created
                                                                                                                  	CreatedTimestamp *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

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

                                                                                                                    Deprecated: Use FeatureTableMeta.ProtoReflect.Descriptor instead.

                                                                                                                    func (*FeatureTableMeta) GetCreatedTimestamp

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

                                                                                                                    func (*FeatureTableMeta) GetHash

                                                                                                                    func (x *FeatureTableMeta) GetHash() string

                                                                                                                    func (*FeatureTableMeta) GetLastUpdatedTimestamp

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

                                                                                                                    func (*FeatureTableMeta) GetRevision

                                                                                                                    func (x *FeatureTableMeta) GetRevision() int64

                                                                                                                    func (*FeatureTableMeta) ProtoMessage

                                                                                                                    func (*FeatureTableMeta) ProtoMessage()

                                                                                                                    func (*FeatureTableMeta) ProtoReflect

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

                                                                                                                    func (*FeatureTableMeta) Reset

                                                                                                                    func (x *FeatureTableMeta) Reset()

                                                                                                                    func (*FeatureTableMeta) String

                                                                                                                    func (x *FeatureTableMeta) String() string

                                                                                                                    type FeatureTableSpec

                                                                                                                    type FeatureTableSpec struct {
                                                                                                                    
                                                                                                                    	// Name of the feature table. Must be unique. Not updated.
                                                                                                                    	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
                                                                                                                    	// 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

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

                                                                                                                      Deprecated: Use FeatureTableSpec.ProtoReflect.Descriptor instead.

                                                                                                                      func (*FeatureTableSpec) GetBatchSource

                                                                                                                      func (x *FeatureTableSpec) GetBatchSource() *DataSource

                                                                                                                      func (*FeatureTableSpec) GetEntities

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

                                                                                                                      func (*FeatureTableSpec) GetFeatures

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

                                                                                                                      func (*FeatureTableSpec) GetLabels

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

                                                                                                                      func (*FeatureTableSpec) GetMaxAge

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

                                                                                                                      func (*FeatureTableSpec) GetName

                                                                                                                      func (x *FeatureTableSpec) GetName() string

                                                                                                                      func (*FeatureTableSpec) GetStreamSource

                                                                                                                      func (x *FeatureTableSpec) GetStreamSource() *DataSource

                                                                                                                      func (*FeatureTableSpec) ProtoMessage

                                                                                                                      func (*FeatureTableSpec) ProtoMessage()

                                                                                                                      func (*FeatureTableSpec) ProtoReflect

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

                                                                                                                      func (*FeatureTableSpec) Reset

                                                                                                                      func (x *FeatureTableSpec) Reset()

                                                                                                                      func (*FeatureTableSpec) String

                                                                                                                      func (x *FeatureTableSpec) String() string

                                                                                                                      type FileFormat

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

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

                                                                                                                        func (*FileFormat) Descriptor

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

                                                                                                                          Deprecated: Use FileFormat.ProtoReflect.Descriptor instead.

                                                                                                                          func (*FileFormat) GetFormat

                                                                                                                          func (m *FileFormat) GetFormat() isFileFormat_Format

                                                                                                                          func (*FileFormat) GetParquetFormat

                                                                                                                          func (x *FileFormat) GetParquetFormat() *FileFormat_ParquetFormat

                                                                                                                          func (*FileFormat) ProtoMessage

                                                                                                                          func (*FileFormat) ProtoMessage()

                                                                                                                          func (*FileFormat) ProtoReflect

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

                                                                                                                          func (*FileFormat) Reset

                                                                                                                          func (x *FileFormat) Reset()

                                                                                                                          func (*FileFormat) String

                                                                                                                          func (x *FileFormat) String() string

                                                                                                                          type FileFormat_ParquetFormat

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

                                                                                                                            Defines options for the Parquet data format

                                                                                                                            func (*FileFormat_ParquetFormat) Descriptor

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

                                                                                                                              Deprecated: Use FileFormat_ParquetFormat.ProtoReflect.Descriptor instead.

                                                                                                                              func (*FileFormat_ParquetFormat) ProtoMessage

                                                                                                                              func (*FileFormat_ParquetFormat) ProtoMessage()

                                                                                                                              func (*FileFormat_ParquetFormat) ProtoReflect

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

                                                                                                                              func (*FileFormat_ParquetFormat) Reset

                                                                                                                              func (x *FileFormat_ParquetFormat) Reset()

                                                                                                                              func (*FileFormat_ParquetFormat) String

                                                                                                                              func (x *FileFormat_ParquetFormat) String() string

                                                                                                                              type FileFormat_ParquetFormat_

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

                                                                                                                              type GetEntityRequest

                                                                                                                              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

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

                                                                                                                                  Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.

                                                                                                                                  func (*GetEntityRequest) GetName

                                                                                                                                  func (x *GetEntityRequest) GetName() string

                                                                                                                                  func (*GetEntityRequest) GetProject

                                                                                                                                  func (x *GetEntityRequest) GetProject() string

                                                                                                                                  func (*GetEntityRequest) ProtoMessage

                                                                                                                                  func (*GetEntityRequest) ProtoMessage()

                                                                                                                                  func (*GetEntityRequest) ProtoReflect

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

                                                                                                                                  func (*GetEntityRequest) Reset

                                                                                                                                  func (x *GetEntityRequest) Reset()

                                                                                                                                  func (*GetEntityRequest) String

                                                                                                                                  func (x *GetEntityRequest) String() string

                                                                                                                                  type GetEntityResponse

                                                                                                                                  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

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

                                                                                                                                      Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.

                                                                                                                                      func (*GetEntityResponse) GetEntity

                                                                                                                                      func (x *GetEntityResponse) GetEntity() *Entity

                                                                                                                                      func (*GetEntityResponse) ProtoMessage

                                                                                                                                      func (*GetEntityResponse) ProtoMessage()

                                                                                                                                      func (*GetEntityResponse) ProtoReflect

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

                                                                                                                                      func (*GetEntityResponse) Reset

                                                                                                                                      func (x *GetEntityResponse) Reset()

                                                                                                                                      func (*GetEntityResponse) String

                                                                                                                                      func (x *GetEntityResponse) String() string

                                                                                                                                      type GetFeastCoreVersionRequest

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

                                                                                                                                      func (*GetFeastCoreVersionRequest) Descriptor

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

                                                                                                                                        Deprecated: Use GetFeastCoreVersionRequest.ProtoReflect.Descriptor instead.

                                                                                                                                        func (*GetFeastCoreVersionRequest) ProtoMessage

                                                                                                                                        func (*GetFeastCoreVersionRequest) ProtoMessage()

                                                                                                                                        func (*GetFeastCoreVersionRequest) ProtoReflect

                                                                                                                                        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

                                                                                                                                        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 (*GetFeastCoreVersionResponse) Reset

                                                                                                                                          func (x *GetFeastCoreVersionResponse) Reset()

                                                                                                                                          func (*GetFeastCoreVersionResponse) String

                                                                                                                                          func (x *GetFeastCoreVersionResponse) String() string

                                                                                                                                          type GetFeatureTableRequest

                                                                                                                                          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

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

                                                                                                                                            Deprecated: Use GetFeatureTableRequest.ProtoReflect.Descriptor instead.

                                                                                                                                            func (*GetFeatureTableRequest) GetName

                                                                                                                                            func (x *GetFeatureTableRequest) GetName() string

                                                                                                                                            func (*GetFeatureTableRequest) GetProject

                                                                                                                                            func (x *GetFeatureTableRequest) GetProject() string

                                                                                                                                            func (*GetFeatureTableRequest) ProtoMessage

                                                                                                                                            func (*GetFeatureTableRequest) ProtoMessage()

                                                                                                                                            func (*GetFeatureTableRequest) ProtoReflect

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

                                                                                                                                            func (*GetFeatureTableRequest) Reset

                                                                                                                                            func (x *GetFeatureTableRequest) Reset()

                                                                                                                                            func (*GetFeatureTableRequest) String

                                                                                                                                            func (x *GetFeatureTableRequest) String() string

                                                                                                                                            type GetFeatureTableResponse

                                                                                                                                            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

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

                                                                                                                                              Deprecated: Use GetFeatureTableResponse.ProtoReflect.Descriptor instead.

                                                                                                                                              func (*GetFeatureTableResponse) GetTable

                                                                                                                                              func (x *GetFeatureTableResponse) GetTable() *FeatureTable

                                                                                                                                              func (*GetFeatureTableResponse) ProtoMessage

                                                                                                                                              func (*GetFeatureTableResponse) ProtoMessage()

                                                                                                                                              func (*GetFeatureTableResponse) ProtoReflect

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

                                                                                                                                              func (*GetFeatureTableResponse) Reset

                                                                                                                                              func (x *GetFeatureTableResponse) Reset()

                                                                                                                                              func (*GetFeatureTableResponse) String

                                                                                                                                              func (x *GetFeatureTableResponse) String() string

                                                                                                                                              type GetHistoricalFeaturesRequest

                                                                                                                                              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

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

                                                                                                                                                Deprecated: Use GetHistoricalFeaturesRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                func (*GetHistoricalFeaturesRequest) GetEntitySource

                                                                                                                                                func (x *GetHistoricalFeaturesRequest) GetEntitySource() *DataSource

                                                                                                                                                func (*GetHistoricalFeaturesRequest) GetFeatureRefs

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

                                                                                                                                                func (*GetHistoricalFeaturesRequest) GetOutputFormat

                                                                                                                                                func (x *GetHistoricalFeaturesRequest) GetOutputFormat() string

                                                                                                                                                func (*GetHistoricalFeaturesRequest) GetOutputLocation

                                                                                                                                                func (x *GetHistoricalFeaturesRequest) GetOutputLocation() string

                                                                                                                                                func (*GetHistoricalFeaturesRequest) GetProject

                                                                                                                                                func (x *GetHistoricalFeaturesRequest) GetProject() string

                                                                                                                                                func (*GetHistoricalFeaturesRequest) ProtoMessage

                                                                                                                                                func (*GetHistoricalFeaturesRequest) ProtoMessage()

                                                                                                                                                func (*GetHistoricalFeaturesRequest) ProtoReflect

                                                                                                                                                func (*GetHistoricalFeaturesRequest) Reset

                                                                                                                                                func (x *GetHistoricalFeaturesRequest) Reset()

                                                                                                                                                func (*GetHistoricalFeaturesRequest) String

                                                                                                                                                type GetHistoricalFeaturesResponse

                                                                                                                                                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

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

                                                                                                                                                  Deprecated: Use GetHistoricalFeaturesResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                  func (*GetHistoricalFeaturesResponse) GetId

                                                                                                                                                  func (*GetHistoricalFeaturesResponse) GetOutputFileUri

                                                                                                                                                  func (x *GetHistoricalFeaturesResponse) GetOutputFileUri() string

                                                                                                                                                  func (*GetHistoricalFeaturesResponse) ProtoMessage

                                                                                                                                                  func (*GetHistoricalFeaturesResponse) ProtoMessage()

                                                                                                                                                  func (*GetHistoricalFeaturesResponse) ProtoReflect

                                                                                                                                                  func (*GetHistoricalFeaturesResponse) Reset

                                                                                                                                                  func (x *GetHistoricalFeaturesResponse) Reset()

                                                                                                                                                  func (*GetHistoricalFeaturesResponse) String

                                                                                                                                                  type GetJobRequest

                                                                                                                                                  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

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

                                                                                                                                                    Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                    func (*GetJobRequest) GetJobId

                                                                                                                                                    func (x *GetJobRequest) GetJobId() string

                                                                                                                                                    func (*GetJobRequest) ProtoMessage

                                                                                                                                                    func (*GetJobRequest) ProtoMessage()

                                                                                                                                                    func (*GetJobRequest) ProtoReflect

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

                                                                                                                                                    func (*GetJobRequest) Reset

                                                                                                                                                    func (x *GetJobRequest) Reset()

                                                                                                                                                    func (*GetJobRequest) String

                                                                                                                                                    func (x *GetJobRequest) String() string

                                                                                                                                                    type GetJobResponse

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

                                                                                                                                                    func (*GetJobResponse) Descriptor

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

                                                                                                                                                      Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                      func (*GetJobResponse) GetJob

                                                                                                                                                      func (x *GetJobResponse) GetJob() *Job

                                                                                                                                                      func (*GetJobResponse) ProtoMessage

                                                                                                                                                      func (*GetJobResponse) ProtoMessage()

                                                                                                                                                      func (*GetJobResponse) ProtoReflect

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

                                                                                                                                                      func (*GetJobResponse) Reset

                                                                                                                                                      func (x *GetJobResponse) Reset()

                                                                                                                                                      func (*GetJobResponse) String

                                                                                                                                                      func (x *GetJobResponse) String() string

                                                                                                                                                      type 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

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

                                                                                                                                                          Deprecated: Use IngestionJob.ProtoReflect.Descriptor instead.

                                                                                                                                                          func (*IngestionJob) GetExternalId

                                                                                                                                                          func (x *IngestionJob) GetExternalId() string

                                                                                                                                                          func (*IngestionJob) GetFeatureSetReferences

                                                                                                                                                          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

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

                                                                                                                                                            func (IngestionJobStatus) EnumDescriptor

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

                                                                                                                                                              Deprecated: Use IngestionJobStatus.Descriptor instead.

                                                                                                                                                              func (IngestionJobStatus) Number

                                                                                                                                                              func (IngestionJobStatus) String

                                                                                                                                                              func (x IngestionJobStatus) String() string

                                                                                                                                                              func (IngestionJobStatus) Type

                                                                                                                                                              type Job

                                                                                                                                                              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

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

                                                                                                                                                                Deprecated: Use Job.ProtoReflect.Descriptor instead.

                                                                                                                                                                func (*Job) GetBatchIngestion

                                                                                                                                                                func (x *Job) GetBatchIngestion() *Job_OfflineToOnlineMeta

                                                                                                                                                                func (*Job) GetHash

                                                                                                                                                                func (x *Job) GetHash() string

                                                                                                                                                                func (*Job) GetId

                                                                                                                                                                func (x *Job) GetId() string

                                                                                                                                                                func (*Job) GetMeta

                                                                                                                                                                func (m *Job) GetMeta() isJob_Meta

                                                                                                                                                                func (*Job) GetRetrieval

                                                                                                                                                                func (x *Job) GetRetrieval() *Job_RetrievalJobMeta

                                                                                                                                                                func (*Job) GetStatus

                                                                                                                                                                func (x *Job) GetStatus() JobStatus

                                                                                                                                                                func (*Job) GetStreamIngestion

                                                                                                                                                                func (x *Job) GetStreamIngestion() *Job_StreamToOnlineMeta

                                                                                                                                                                func (*Job) GetType

                                                                                                                                                                func (x *Job) GetType() JobType

                                                                                                                                                                func (*Job) ProtoMessage

                                                                                                                                                                func (*Job) ProtoMessage()

                                                                                                                                                                func (*Job) ProtoReflect

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

                                                                                                                                                                func (*Job) Reset

                                                                                                                                                                func (x *Job) Reset()

                                                                                                                                                                func (*Job) String

                                                                                                                                                                func (x *Job) String() string

                                                                                                                                                                type JobServiceClient

                                                                                                                                                                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.

                                                                                                                                                                  type JobServiceServer

                                                                                                                                                                  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

                                                                                                                                                                    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

                                                                                                                                                                    func (JobStatus) Descriptor() protoreflect.EnumDescriptor

                                                                                                                                                                    func (JobStatus) Enum

                                                                                                                                                                    func (x JobStatus) Enum() *JobStatus

                                                                                                                                                                    func (JobStatus) EnumDescriptor

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

                                                                                                                                                                      Deprecated: Use JobStatus.Descriptor instead.

                                                                                                                                                                      func (JobStatus) Number

                                                                                                                                                                      func (x JobStatus) Number() protoreflect.EnumNumber

                                                                                                                                                                      func (JobStatus) String

                                                                                                                                                                      func (x JobStatus) String() string

                                                                                                                                                                      func (JobStatus) Type

                                                                                                                                                                      type JobType

                                                                                                                                                                      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

                                                                                                                                                                      func (JobType) Descriptor() protoreflect.EnumDescriptor

                                                                                                                                                                      func (JobType) Enum

                                                                                                                                                                      func (x JobType) Enum() *JobType

                                                                                                                                                                      func (JobType) EnumDescriptor

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

                                                                                                                                                                        Deprecated: Use JobType.Descriptor instead.

                                                                                                                                                                        func (JobType) Number

                                                                                                                                                                        func (x JobType) Number() protoreflect.EnumNumber

                                                                                                                                                                        func (JobType) String

                                                                                                                                                                        func (x JobType) String() string

                                                                                                                                                                        func (JobType) Type

                                                                                                                                                                        func (JobType) Type() protoreflect.EnumType

                                                                                                                                                                        type Job_BatchIngestion

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

                                                                                                                                                                        type Job_OfflineToOnlineMeta

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

                                                                                                                                                                        func (*Job_OfflineToOnlineMeta) Descriptor

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

                                                                                                                                                                          Deprecated: Use Job_OfflineToOnlineMeta.ProtoReflect.Descriptor instead.

                                                                                                                                                                          func (*Job_OfflineToOnlineMeta) ProtoMessage

                                                                                                                                                                          func (*Job_OfflineToOnlineMeta) ProtoMessage()

                                                                                                                                                                          func (*Job_OfflineToOnlineMeta) ProtoReflect

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

                                                                                                                                                                          func (*Job_OfflineToOnlineMeta) Reset

                                                                                                                                                                          func (x *Job_OfflineToOnlineMeta) Reset()

                                                                                                                                                                          func (*Job_OfflineToOnlineMeta) String

                                                                                                                                                                          func (x *Job_OfflineToOnlineMeta) String() string

                                                                                                                                                                          type Job_Retrieval

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

                                                                                                                                                                          type Job_RetrievalJobMeta

                                                                                                                                                                          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

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

                                                                                                                                                                            Deprecated: Use Job_RetrievalJobMeta.ProtoReflect.Descriptor instead.

                                                                                                                                                                            func (*Job_RetrievalJobMeta) GetOutputLocation

                                                                                                                                                                            func (x *Job_RetrievalJobMeta) GetOutputLocation() string

                                                                                                                                                                            func (*Job_RetrievalJobMeta) ProtoMessage

                                                                                                                                                                            func (*Job_RetrievalJobMeta) ProtoMessage()

                                                                                                                                                                            func (*Job_RetrievalJobMeta) ProtoReflect

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

                                                                                                                                                                            func (*Job_RetrievalJobMeta) Reset

                                                                                                                                                                            func (x *Job_RetrievalJobMeta) Reset()

                                                                                                                                                                            func (*Job_RetrievalJobMeta) String

                                                                                                                                                                            func (x *Job_RetrievalJobMeta) String() string

                                                                                                                                                                            type Job_StreamIngestion

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

                                                                                                                                                                            type Job_StreamToOnlineMeta

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

                                                                                                                                                                            func (*Job_StreamToOnlineMeta) Descriptor

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

                                                                                                                                                                              Deprecated: Use Job_StreamToOnlineMeta.ProtoReflect.Descriptor instead.

                                                                                                                                                                              func (*Job_StreamToOnlineMeta) ProtoMessage

                                                                                                                                                                              func (*Job_StreamToOnlineMeta) ProtoMessage()

                                                                                                                                                                              func (*Job_StreamToOnlineMeta) ProtoReflect

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

                                                                                                                                                                              func (*Job_StreamToOnlineMeta) Reset

                                                                                                                                                                              func (x *Job_StreamToOnlineMeta) Reset()

                                                                                                                                                                              func (*Job_StreamToOnlineMeta) String

                                                                                                                                                                              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

                                                                                                                                                                              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

                                                                                                                                                                                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

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

                                                                                                                                                                                    Deprecated: Use ListEntitiesRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                    func (*ListEntitiesRequest) GetFilter

                                                                                                                                                                                    func (*ListEntitiesRequest) ProtoMessage

                                                                                                                                                                                    func (*ListEntitiesRequest) ProtoMessage()

                                                                                                                                                                                    func (*ListEntitiesRequest) ProtoReflect

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

                                                                                                                                                                                    func (*ListEntitiesRequest) Reset

                                                                                                                                                                                    func (x *ListEntitiesRequest) Reset()

                                                                                                                                                                                    func (*ListEntitiesRequest) String

                                                                                                                                                                                    func (x *ListEntitiesRequest) String() string

                                                                                                                                                                                    type ListEntitiesRequest_Filter

                                                                                                                                                                                    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

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

                                                                                                                                                                                      Deprecated: Use ListEntitiesRequest_Filter.ProtoReflect.Descriptor instead.

                                                                                                                                                                                      func (*ListEntitiesRequest_Filter) GetLabels

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

                                                                                                                                                                                      func (*ListEntitiesRequest_Filter) GetProject

                                                                                                                                                                                      func (x *ListEntitiesRequest_Filter) GetProject() string

                                                                                                                                                                                      func (*ListEntitiesRequest_Filter) ProtoMessage

                                                                                                                                                                                      func (*ListEntitiesRequest_Filter) ProtoMessage()

                                                                                                                                                                                      func (*ListEntitiesRequest_Filter) ProtoReflect

                                                                                                                                                                                      func (*ListEntitiesRequest_Filter) Reset

                                                                                                                                                                                      func (x *ListEntitiesRequest_Filter) Reset()

                                                                                                                                                                                      func (*ListEntitiesRequest_Filter) String

                                                                                                                                                                                      func (x *ListEntitiesRequest_Filter) String() string

                                                                                                                                                                                      type ListEntitiesResponse

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

                                                                                                                                                                                      func (*ListEntitiesResponse) Descriptor

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

                                                                                                                                                                                        Deprecated: Use ListEntitiesResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                        func (*ListEntitiesResponse) GetEntities

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

                                                                                                                                                                                        func (*ListEntitiesResponse) ProtoMessage

                                                                                                                                                                                        func (*ListEntitiesResponse) ProtoMessage()

                                                                                                                                                                                        func (*ListEntitiesResponse) ProtoReflect

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

                                                                                                                                                                                        func (*ListEntitiesResponse) Reset

                                                                                                                                                                                        func (x *ListEntitiesResponse) Reset()

                                                                                                                                                                                        func (*ListEntitiesResponse) String

                                                                                                                                                                                        func (x *ListEntitiesResponse) String() string

                                                                                                                                                                                        type ListFeatureTablesRequest

                                                                                                                                                                                        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

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

                                                                                                                                                                                          Deprecated: Use ListFeatureTablesRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                          func (*ListFeatureTablesRequest) GetFilter

                                                                                                                                                                                          func (*ListFeatureTablesRequest) ProtoMessage

                                                                                                                                                                                          func (*ListFeatureTablesRequest) ProtoMessage()

                                                                                                                                                                                          func (*ListFeatureTablesRequest) ProtoReflect

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

                                                                                                                                                                                          func (*ListFeatureTablesRequest) Reset

                                                                                                                                                                                          func (x *ListFeatureTablesRequest) Reset()

                                                                                                                                                                                          func (*ListFeatureTablesRequest) String

                                                                                                                                                                                          func (x *ListFeatureTablesRequest) String() string

                                                                                                                                                                                          type ListFeatureTablesRequest_Filter

                                                                                                                                                                                          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

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

                                                                                                                                                                                            Deprecated: Use ListFeatureTablesRequest_Filter.ProtoReflect.Descriptor instead.

                                                                                                                                                                                            func (*ListFeatureTablesRequest_Filter) GetLabels

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

                                                                                                                                                                                            func (*ListFeatureTablesRequest_Filter) GetProject

                                                                                                                                                                                            func (x *ListFeatureTablesRequest_Filter) GetProject() string

                                                                                                                                                                                            func (*ListFeatureTablesRequest_Filter) ProtoMessage

                                                                                                                                                                                            func (*ListFeatureTablesRequest_Filter) ProtoMessage()

                                                                                                                                                                                            func (*ListFeatureTablesRequest_Filter) ProtoReflect

                                                                                                                                                                                            func (*ListFeatureTablesRequest_Filter) Reset

                                                                                                                                                                                            func (*ListFeatureTablesRequest_Filter) String

                                                                                                                                                                                            type ListFeatureTablesResponse

                                                                                                                                                                                            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

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

                                                                                                                                                                                              Deprecated: Use ListFeatureTablesResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                              func (*ListFeatureTablesResponse) GetTables

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

                                                                                                                                                                                              func (*ListFeatureTablesResponse) ProtoMessage

                                                                                                                                                                                              func (*ListFeatureTablesResponse) ProtoMessage()

                                                                                                                                                                                              func (*ListFeatureTablesResponse) ProtoReflect

                                                                                                                                                                                              func (*ListFeatureTablesResponse) Reset

                                                                                                                                                                                              func (x *ListFeatureTablesResponse) Reset()

                                                                                                                                                                                              func (*ListFeatureTablesResponse) String

                                                                                                                                                                                              func (x *ListFeatureTablesResponse) String() string

                                                                                                                                                                                              type ListFeaturesRequest

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

                                                                                                                                                                                              func (*ListFeaturesRequest) Descriptor

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

                                                                                                                                                                                                Deprecated: Use ListFeaturesRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                func (*ListFeaturesRequest) GetFilter

                                                                                                                                                                                                func (*ListFeaturesRequest) ProtoMessage

                                                                                                                                                                                                func (*ListFeaturesRequest) ProtoMessage()

                                                                                                                                                                                                func (*ListFeaturesRequest) ProtoReflect

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

                                                                                                                                                                                                func (*ListFeaturesRequest) Reset

                                                                                                                                                                                                func (x *ListFeaturesRequest) Reset()

                                                                                                                                                                                                func (*ListFeaturesRequest) String

                                                                                                                                                                                                func (x *ListFeaturesRequest) String() string

                                                                                                                                                                                                type ListFeaturesRequest_Filter

                                                                                                                                                                                                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

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

                                                                                                                                                                                                  Deprecated: Use ListFeaturesRequest_Filter.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                  func (*ListFeaturesRequest_Filter) GetEntities

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

                                                                                                                                                                                                  func (*ListFeaturesRequest_Filter) GetLabels

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

                                                                                                                                                                                                  func (*ListFeaturesRequest_Filter) GetProject

                                                                                                                                                                                                  func (x *ListFeaturesRequest_Filter) GetProject() string

                                                                                                                                                                                                  func (*ListFeaturesRequest_Filter) ProtoMessage

                                                                                                                                                                                                  func (*ListFeaturesRequest_Filter) ProtoMessage()

                                                                                                                                                                                                  func (*ListFeaturesRequest_Filter) ProtoReflect

                                                                                                                                                                                                  func (*ListFeaturesRequest_Filter) Reset

                                                                                                                                                                                                  func (x *ListFeaturesRequest_Filter) Reset()

                                                                                                                                                                                                  func (*ListFeaturesRequest_Filter) String

                                                                                                                                                                                                  func (x *ListFeaturesRequest_Filter) String() string

                                                                                                                                                                                                  type ListFeaturesResponse

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

                                                                                                                                                                                                  func (*ListFeaturesResponse) Descriptor

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

                                                                                                                                                                                                    Deprecated: Use ListFeaturesResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                    func (*ListFeaturesResponse) GetFeatures

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

                                                                                                                                                                                                    func (*ListFeaturesResponse) ProtoMessage

                                                                                                                                                                                                    func (*ListFeaturesResponse) ProtoMessage()

                                                                                                                                                                                                    func (*ListFeaturesResponse) ProtoReflect

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

                                                                                                                                                                                                    func (*ListFeaturesResponse) Reset

                                                                                                                                                                                                    func (x *ListFeaturesResponse) Reset()

                                                                                                                                                                                                    func (*ListFeaturesResponse) String

                                                                                                                                                                                                    func (x *ListFeaturesResponse) String() string

                                                                                                                                                                                                    type ListJobsRequest

                                                                                                                                                                                                    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

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

                                                                                                                                                                                                      Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                      func (*ListJobsRequest) GetIncludeTerminated

                                                                                                                                                                                                      func (x *ListJobsRequest) GetIncludeTerminated() bool

                                                                                                                                                                                                      func (*ListJobsRequest) ProtoMessage

                                                                                                                                                                                                      func (*ListJobsRequest) ProtoMessage()

                                                                                                                                                                                                      func (*ListJobsRequest) ProtoReflect

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

                                                                                                                                                                                                      func (*ListJobsRequest) Reset

                                                                                                                                                                                                      func (x *ListJobsRequest) Reset()

                                                                                                                                                                                                      func (*ListJobsRequest) String

                                                                                                                                                                                                      func (x *ListJobsRequest) String() string

                                                                                                                                                                                                      type ListJobsResponse

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

                                                                                                                                                                                                      func (*ListJobsResponse) Descriptor

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

                                                                                                                                                                                                        Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                        func (*ListJobsResponse) GetJobs

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

                                                                                                                                                                                                        func (*ListJobsResponse) ProtoMessage

                                                                                                                                                                                                        func (*ListJobsResponse) ProtoMessage()

                                                                                                                                                                                                        func (*ListJobsResponse) ProtoReflect

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

                                                                                                                                                                                                        func (*ListJobsResponse) Reset

                                                                                                                                                                                                        func (x *ListJobsResponse) Reset()

                                                                                                                                                                                                        func (*ListJobsResponse) String

                                                                                                                                                                                                        func (x *ListJobsResponse) String() string

                                                                                                                                                                                                        type ListProjectsRequest

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

                                                                                                                                                                                                          Request for listing of projects

                                                                                                                                                                                                          func (*ListProjectsRequest) Descriptor

                                                                                                                                                                                                          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

                                                                                                                                                                                                              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

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

                                                                                                                                                                                                                  Deprecated: Use ListStoresRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                  func (*ListStoresRequest) GetFilter

                                                                                                                                                                                                                  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

                                                                                                                                                                                                                  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

                                                                                                                                                                                                                    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

                                                                                                                                                                                                                      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

                                                                                                                                                                                                                        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

                                                                                                                                                                                                                          type Source_KafkaSourceConfig

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

                                                                                                                                                                                                                          type SpecsStreamingUpdateConfig

                                                                                                                                                                                                                          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

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

                                                                                                                                                                                                                              Deprecated: Use SpecsStreamingUpdateConfig.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                              func (*SpecsStreamingUpdateConfig) GetAck

                                                                                                                                                                                                                              func (*SpecsStreamingUpdateConfig) GetSource

                                                                                                                                                                                                                              func (*SpecsStreamingUpdateConfig) ProtoMessage

                                                                                                                                                                                                                              func (*SpecsStreamingUpdateConfig) ProtoMessage()

                                                                                                                                                                                                                              func (*SpecsStreamingUpdateConfig) ProtoReflect

                                                                                                                                                                                                                              func (*SpecsStreamingUpdateConfig) Reset

                                                                                                                                                                                                                              func (x *SpecsStreamingUpdateConfig) Reset()

                                                                                                                                                                                                                              func (*SpecsStreamingUpdateConfig) String

                                                                                                                                                                                                                              func (x *SpecsStreamingUpdateConfig) String() string

                                                                                                                                                                                                                              type StartOfflineToOnlineIngestionJobRequest

                                                                                                                                                                                                                              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

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

                                                                                                                                                                                                                                  Deprecated: Use StartOfflineToOnlineIngestionJobRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                                  func (*StartOfflineToOnlineIngestionJobRequest) GetEndDate

                                                                                                                                                                                                                                  func (*StartOfflineToOnlineIngestionJobRequest) GetProject

                                                                                                                                                                                                                                  func (*StartOfflineToOnlineIngestionJobRequest) GetStartDate

                                                                                                                                                                                                                                  func (*StartOfflineToOnlineIngestionJobRequest) GetTableName

                                                                                                                                                                                                                                  func (*StartOfflineToOnlineIngestionJobRequest) ProtoMessage

                                                                                                                                                                                                                                  func (*StartOfflineToOnlineIngestionJobRequest) ProtoReflect

                                                                                                                                                                                                                                  func (*StartOfflineToOnlineIngestionJobRequest) Reset

                                                                                                                                                                                                                                  func (*StartOfflineToOnlineIngestionJobRequest) String

                                                                                                                                                                                                                                  type StartOfflineToOnlineIngestionJobResponse

                                                                                                                                                                                                                                  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

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

                                                                                                                                                                                                                                    Deprecated: Use StartOfflineToOnlineIngestionJobResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                                    func (*StartOfflineToOnlineIngestionJobResponse) GetId

                                                                                                                                                                                                                                    func (*StartOfflineToOnlineIngestionJobResponse) ProtoMessage

                                                                                                                                                                                                                                    func (*StartOfflineToOnlineIngestionJobResponse) ProtoReflect

                                                                                                                                                                                                                                    func (*StartOfflineToOnlineIngestionJobResponse) Reset

                                                                                                                                                                                                                                    func (*StartOfflineToOnlineIngestionJobResponse) String

                                                                                                                                                                                                                                    type StartStreamToOnlineIngestionJobRequest

                                                                                                                                                                                                                                    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

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

                                                                                                                                                                                                                                      Deprecated: Use StartStreamToOnlineIngestionJobRequest.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                                      func (*StartStreamToOnlineIngestionJobRequest) GetProject

                                                                                                                                                                                                                                      func (*StartStreamToOnlineIngestionJobRequest) GetTableName

                                                                                                                                                                                                                                      func (*StartStreamToOnlineIngestionJobRequest) ProtoMessage

                                                                                                                                                                                                                                      func (*StartStreamToOnlineIngestionJobRequest) ProtoReflect

                                                                                                                                                                                                                                      func (*StartStreamToOnlineIngestionJobRequest) Reset

                                                                                                                                                                                                                                      func (*StartStreamToOnlineIngestionJobRequest) String

                                                                                                                                                                                                                                      type StartStreamToOnlineIngestionJobResponse

                                                                                                                                                                                                                                      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

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

                                                                                                                                                                                                                                        Deprecated: Use StartStreamToOnlineIngestionJobResponse.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                                        func (*StartStreamToOnlineIngestionJobResponse) GetId

                                                                                                                                                                                                                                        func (*StartStreamToOnlineIngestionJobResponse) ProtoMessage

                                                                                                                                                                                                                                        func (*StartStreamToOnlineIngestionJobResponse) ProtoReflect

                                                                                                                                                                                                                                        func (*StartStreamToOnlineIngestionJobResponse) Reset

                                                                                                                                                                                                                                        func (*StartStreamToOnlineIngestionJobResponse) 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

                                                                                                                                                                                                                                          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

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

                                                                                                                                                                                                                                              Deprecated: Use Store_RedisClusterConfig.ProtoReflect.Descriptor instead.

                                                                                                                                                                                                                                              func (*Store_RedisClusterConfig) GetConnectionString

                                                                                                                                                                                                                                              func (x *Store_RedisClusterConfig) GetConnectionString() string

                                                                                                                                                                                                                                              func (*Store_RedisClusterConfig) GetEnableFallback

                                                                                                                                                                                                                                              func (x *Store_RedisClusterConfig) GetEnableFallback() bool

                                                                                                                                                                                                                                              func (*Store_RedisClusterConfig) GetFallbackPrefix

                                                                                                                                                                                                                                              func (x *Store_RedisClusterConfig) GetFallbackPrefix() string

                                                                                                                                                                                                                                              func (*Store_RedisClusterConfig) GetFlushFrequencySeconds

                                                                                                                                                                                                                                              func (x *Store_RedisClusterConfig) GetFlushFrequencySeconds() int32

                                                                                                                                                                                                                                              func (*Store_RedisClusterConfig) GetInitialBackoffMs

                                                                                                                                                                                                                                              func (x *Store_RedisClusterConfig) GetInitialBackoffMs() int32

                                                                                                                                                                                                                                              func (*Store_RedisClusterConfig) GetKeyPrefix

                                                                                                                                                                                                                                              func (x *Store_RedisClusterConfig) GetKeyPrefix() string

                                                                                                                                                                                                                                              func (*Store_RedisClusterConfig) GetMaxRetries

                                                                                                                                                                                                                                              func (x *Store_RedisClusterConfig) GetMaxRetries() int32

                                                                                                                                                                                                                                              func (*Store_RedisClusterConfig) 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 defau