Documentation ¶
Index ¶
- Variables
- func RegisterCoreServiceServer(s *grpc.Server, srv CoreServiceServer)
- func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)
- type ApplyEntityRequest
- func (*ApplyEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyEntityRequest) GetProject() string
- func (x *ApplyEntityRequest) GetSpec() *EntitySpecV2
- func (*ApplyEntityRequest) ProtoMessage()
- func (x *ApplyEntityRequest) ProtoReflect() protoreflect.Message
- func (x *ApplyEntityRequest) Reset()
- func (x *ApplyEntityRequest) String() string
- type ApplyEntityResponse
- func (*ApplyEntityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyEntityResponse) GetEntity() *Entity
- func (*ApplyEntityResponse) ProtoMessage()
- func (x *ApplyEntityResponse) ProtoReflect() protoreflect.Message
- func (x *ApplyEntityResponse) Reset()
- func (x *ApplyEntityResponse) String() string
- type ApplyFeatureTableRequest
- func (*ApplyFeatureTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyFeatureTableRequest) GetProject() string
- func (x *ApplyFeatureTableRequest) GetTableSpec() *FeatureTableSpec
- func (*ApplyFeatureTableRequest) ProtoMessage()
- func (x *ApplyFeatureTableRequest) ProtoReflect() protoreflect.Message
- func (x *ApplyFeatureTableRequest) Reset()
- func (x *ApplyFeatureTableRequest) String() string
- type ApplyFeatureTableResponse
- func (*ApplyFeatureTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ApplyFeatureTableResponse) GetTable() *FeatureTable
- func (*ApplyFeatureTableResponse) ProtoMessage()
- func (x *ApplyFeatureTableResponse) ProtoReflect() protoreflect.Message
- func (x *ApplyFeatureTableResponse) Reset()
- func (x *ApplyFeatureTableResponse) String() string
- type ArchiveProjectRequest
- func (*ArchiveProjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ArchiveProjectRequest) GetName() string
- func (*ArchiveProjectRequest) ProtoMessage()
- func (x *ArchiveProjectRequest) ProtoReflect() protoreflect.Message
- func (x *ArchiveProjectRequest) Reset()
- func (x *ArchiveProjectRequest) String() string
- type ArchiveProjectResponse
- type CancelJobRequest
- type CancelJobResponse
- type CoreServiceClient
- type CoreServiceServer
- type CreateProjectRequest
- func (*CreateProjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateProjectRequest) GetName() string
- func (*CreateProjectRequest) ProtoMessage()
- func (x *CreateProjectRequest) ProtoReflect() protoreflect.Message
- func (x *CreateProjectRequest) Reset()
- func (x *CreateProjectRequest) String() string
- type CreateProjectResponse
- type DataSource
- func (*DataSource) Descriptor() ([]byte, []int)deprecated
- func (x *DataSource) GetBigqueryOptions() *DataSource_BigQueryOptions
- func (x *DataSource) GetCreatedTimestampColumn() string
- func (x *DataSource) GetDatePartitionColumn() string
- func (x *DataSource) GetEventTimestampColumn() string
- func (x *DataSource) GetFieldMapping() map[string]string
- func (x *DataSource) GetFileOptions() *DataSource_FileOptions
- func (x *DataSource) GetKafkaOptions() *DataSource_KafkaOptions
- func (x *DataSource) GetKinesisOptions() *DataSource_KinesisOptions
- func (m *DataSource) GetOptions() isDataSource_Options
- func (x *DataSource) GetType() DataSource_SourceType
- func (*DataSource) ProtoMessage()
- func (x *DataSource) ProtoReflect() protoreflect.Message
- func (x *DataSource) Reset()
- func (x *DataSource) String() string
- type DataSource_BigQueryOptions
- func (*DataSource_BigQueryOptions) Descriptor() ([]byte, []int)deprecated
- func (x *DataSource_BigQueryOptions) GetTableRef() string
- func (*DataSource_BigQueryOptions) ProtoMessage()
- func (x *DataSource_BigQueryOptions) ProtoReflect() protoreflect.Message
- func (x *DataSource_BigQueryOptions) Reset()
- func (x *DataSource_BigQueryOptions) String() string
- type DataSource_BigqueryOptions
- type DataSource_FileOptions
- func (*DataSource_FileOptions) Descriptor() ([]byte, []int)deprecated
- func (x *DataSource_FileOptions) GetFileFormat() *FileFormat
- func (x *DataSource_FileOptions) GetFileUrl() string
- func (*DataSource_FileOptions) ProtoMessage()
- func (x *DataSource_FileOptions) ProtoReflect() protoreflect.Message
- func (x *DataSource_FileOptions) Reset()
- func (x *DataSource_FileOptions) String() string
- type DataSource_FileOptions_
- type DataSource_KafkaOptions
- func (*DataSource_KafkaOptions) Descriptor() ([]byte, []int)deprecated
- func (x *DataSource_KafkaOptions) GetBootstrapServers() string
- func (x *DataSource_KafkaOptions) GetMessageFormat() *StreamFormat
- func (x *DataSource_KafkaOptions) GetTopic() string
- func (*DataSource_KafkaOptions) ProtoMessage()
- func (x *DataSource_KafkaOptions) ProtoReflect() protoreflect.Message
- func (x *DataSource_KafkaOptions) Reset()
- func (x *DataSource_KafkaOptions) String() string
- type DataSource_KafkaOptions_
- type DataSource_KinesisOptions
- func (*DataSource_KinesisOptions) Descriptor() ([]byte, []int)deprecated
- func (x *DataSource_KinesisOptions) GetRecordFormat() *StreamFormat
- func (x *DataSource_KinesisOptions) GetRegion() string
- func (x *DataSource_KinesisOptions) GetStreamName() string
- func (*DataSource_KinesisOptions) ProtoMessage()
- func (x *DataSource_KinesisOptions) ProtoReflect() protoreflect.Message
- func (x *DataSource_KinesisOptions) Reset()
- func (x *DataSource_KinesisOptions) String() string
- type DataSource_KinesisOptions_
- type DataSource_SourceType
- func (DataSource_SourceType) Descriptor() protoreflect.EnumDescriptor
- func (x DataSource_SourceType) Enum() *DataSource_SourceType
- func (DataSource_SourceType) EnumDescriptor() ([]byte, []int)deprecated
- func (x DataSource_SourceType) Number() protoreflect.EnumNumber
- func (x DataSource_SourceType) String() string
- func (DataSource_SourceType) Type() protoreflect.EnumType
- type DataflowRunnerConfigOptions
- func (*DataflowRunnerConfigOptions) Descriptor() ([]byte, []int)deprecated
- func (x *DataflowRunnerConfigOptions) GetAutoscalingAlgorithm() string
- func (x *DataflowRunnerConfigOptions) GetDeadLetterTableSpec() string
- func (x *DataflowRunnerConfigOptions) GetDiskSizeGb() int32
- func (x *DataflowRunnerConfigOptions) GetEnableStreamingEngine() bool
- func (x *DataflowRunnerConfigOptions) GetKafkaConsumerProperties() map[string]string
- func (x *DataflowRunnerConfigOptions) GetLabels() map[string]string
- func (x *DataflowRunnerConfigOptions) GetMaxNumWorkers() int32
- func (x *DataflowRunnerConfigOptions) GetNetwork() string
- func (x *DataflowRunnerConfigOptions) GetProject() string
- func (x *DataflowRunnerConfigOptions) GetRegion() string
- func (x *DataflowRunnerConfigOptions) GetServiceAccount() string
- func (x *DataflowRunnerConfigOptions) GetSubnetwork() string
- func (x *DataflowRunnerConfigOptions) GetTempLocation() string
- func (x *DataflowRunnerConfigOptions) GetUsePublicIps() bool
- func (x *DataflowRunnerConfigOptions) GetWorkerDiskType() string
- func (x *DataflowRunnerConfigOptions) GetWorkerMachineType() string
- func (x *DataflowRunnerConfigOptions) GetWorkerZone() string
- func (*DataflowRunnerConfigOptions) ProtoMessage()
- func (x *DataflowRunnerConfigOptions) ProtoReflect() protoreflect.Message
- func (x *DataflowRunnerConfigOptions) Reset()
- func (x *DataflowRunnerConfigOptions) String() string
- type DeleteFeatureTableRequest
- func (*DeleteFeatureTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteFeatureTableRequest) GetName() string
- func (x *DeleteFeatureTableRequest) GetProject() string
- func (*DeleteFeatureTableRequest) ProtoMessage()
- func (x *DeleteFeatureTableRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteFeatureTableRequest) Reset()
- func (x *DeleteFeatureTableRequest) String() string
- type DeleteFeatureTableResponse
- type DirectRunnerConfigOptions
- func (*DirectRunnerConfigOptions) Descriptor() ([]byte, []int)deprecated
- func (x *DirectRunnerConfigOptions) GetDeadLetterTableSpec() string
- func (x *DirectRunnerConfigOptions) GetTargetParallelism() int32
- func (x *DirectRunnerConfigOptions) GetTempLocation() string
- func (*DirectRunnerConfigOptions) ProtoMessage()
- func (x *DirectRunnerConfigOptions) ProtoReflect() protoreflect.Message
- func (x *DirectRunnerConfigOptions) Reset()
- func (x *DirectRunnerConfigOptions) String() string
- type Entity
- type EntityMeta
- func (*EntityMeta) Descriptor() ([]byte, []int)deprecated
- func (x *EntityMeta) GetCreatedTimestamp() *timestamppb.Timestamp
- func (x *EntityMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp
- func (*EntityMeta) ProtoMessage()
- func (x *EntityMeta) ProtoReflect() protoreflect.Message
- func (x *EntityMeta) Reset()
- func (x *EntityMeta) String() string
- type EntitySpec
- func (*EntitySpec) Descriptor() ([]byte, []int)deprecated
- func (x *EntitySpec) GetName() string
- func (x *EntitySpec) GetValueType() types.ValueType_Enum
- func (*EntitySpec) ProtoMessage()
- func (x *EntitySpec) ProtoReflect() protoreflect.Message
- func (x *EntitySpec) Reset()
- func (x *EntitySpec) String() string
- type EntitySpecV2
- func (*EntitySpecV2) Descriptor() ([]byte, []int)deprecated
- func (x *EntitySpecV2) GetDescription() string
- func (x *EntitySpecV2) GetLabels() map[string]string
- func (x *EntitySpecV2) GetName() string
- func (x *EntitySpecV2) GetValueType() types.ValueType_Enum
- func (*EntitySpecV2) ProtoMessage()
- func (x *EntitySpecV2) ProtoReflect() protoreflect.Message
- func (x *EntitySpecV2) Reset()
- func (x *EntitySpecV2) String() string
- type FeatureSet
- func (*FeatureSet) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureSet) GetMeta() *FeatureSetMeta
- func (x *FeatureSet) GetSpec() *FeatureSetSpec
- func (*FeatureSet) ProtoMessage()
- func (x *FeatureSet) ProtoReflect() protoreflect.Message
- func (x *FeatureSet) Reset()
- func (x *FeatureSet) String() string
- type FeatureSetJobDeliveryStatus
- func (FeatureSetJobDeliveryStatus) Descriptor() protoreflect.EnumDescriptor
- func (x FeatureSetJobDeliveryStatus) Enum() *FeatureSetJobDeliveryStatus
- func (FeatureSetJobDeliveryStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x FeatureSetJobDeliveryStatus) Number() protoreflect.EnumNumber
- func (x FeatureSetJobDeliveryStatus) String() string
- func (FeatureSetJobDeliveryStatus) Type() protoreflect.EnumType
- type FeatureSetMeta
- func (*FeatureSetMeta) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureSetMeta) GetCreatedTimestamp() *timestamp.Timestamp
- func (x *FeatureSetMeta) GetStatus() FeatureSetStatus
- func (*FeatureSetMeta) ProtoMessage()
- func (x *FeatureSetMeta) ProtoReflect() protoreflect.Message
- func (x *FeatureSetMeta) Reset()
- func (x *FeatureSetMeta) String() string
- type FeatureSetReference
- func (*FeatureSetReference) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureSetReference) GetName() string
- func (x *FeatureSetReference) GetProject() string
- func (*FeatureSetReference) ProtoMessage()
- func (x *FeatureSetReference) ProtoReflect() protoreflect.Message
- func (x *FeatureSetReference) Reset()
- func (x *FeatureSetReference) String() string
- type FeatureSetSpec
- func (*FeatureSetSpec) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureSetSpec) GetEntities() []*EntitySpec
- func (x *FeatureSetSpec) GetFeatures() []*FeatureSpec
- func (x *FeatureSetSpec) GetLabels() map[string]string
- func (x *FeatureSetSpec) GetMaxAge() *duration.Duration
- func (x *FeatureSetSpec) GetName() string
- func (x *FeatureSetSpec) GetProject() string
- func (x *FeatureSetSpec) GetSource() *Source
- func (x *FeatureSetSpec) GetVersion() int32
- func (*FeatureSetSpec) ProtoMessage()
- func (x *FeatureSetSpec) ProtoReflect() protoreflect.Message
- func (x *FeatureSetSpec) Reset()
- func (x *FeatureSetSpec) String() string
- type FeatureSetSpecAck
- func (*FeatureSetSpecAck) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureSetSpecAck) GetFeatureSetReference() string
- func (x *FeatureSetSpecAck) GetFeatureSetVersion() int32
- func (x *FeatureSetSpecAck) GetJobName() string
- func (*FeatureSetSpecAck) ProtoMessage()
- func (x *FeatureSetSpecAck) ProtoReflect() protoreflect.Message
- func (x *FeatureSetSpecAck) Reset()
- func (x *FeatureSetSpecAck) String() string
- type FeatureSetStatus
- func (FeatureSetStatus) Descriptor() protoreflect.EnumDescriptor
- func (x FeatureSetStatus) Enum() *FeatureSetStatus
- func (FeatureSetStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x FeatureSetStatus) Number() protoreflect.EnumNumber
- func (x FeatureSetStatus) String() string
- func (FeatureSetStatus) Type() protoreflect.EnumType
- type FeatureSpec
- func (*FeatureSpec) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureSpec) GetBoolDomain() *v0.BoolDomain
- func (x *FeatureSpec) GetDomain() string
- func (m *FeatureSpec) GetDomainInfo() isFeatureSpec_DomainInfo
- func (x *FeatureSpec) GetFloatDomain() *v0.FloatDomain
- func (x *FeatureSpec) GetGroupPresence() *v0.FeaturePresenceWithinGroup
- func (x *FeatureSpec) GetImageDomain() *v0.ImageDomain
- func (x *FeatureSpec) GetIntDomain() *v0.IntDomain
- func (x *FeatureSpec) GetLabels() map[string]string
- func (x *FeatureSpec) GetMidDomain() *v0.MIDDomain
- func (x *FeatureSpec) GetName() string
- func (x *FeatureSpec) GetNaturalLanguageDomain() *v0.NaturalLanguageDomain
- func (x *FeatureSpec) GetPresence() *v0.FeaturePresence
- func (m *FeatureSpec) GetPresenceConstraints() isFeatureSpec_PresenceConstraints
- func (x *FeatureSpec) GetShape() *v0.FixedShape
- func (m *FeatureSpec) GetShapeType() isFeatureSpec_ShapeType
- func (x *FeatureSpec) GetStringDomain() *v0.StringDomain
- func (x *FeatureSpec) GetStructDomain() *v0.StructDomain
- func (x *FeatureSpec) GetTimeDomain() *v0.TimeDomain
- func (x *FeatureSpec) GetTimeOfDayDomain() *v0.TimeOfDayDomain
- func (x *FeatureSpec) GetUrlDomain() *v0.URLDomain
- func (x *FeatureSpec) GetValueCount() *v0.ValueCount
- func (x *FeatureSpec) GetValueType() types.ValueType_Enum
- func (*FeatureSpec) ProtoMessage()
- func (x *FeatureSpec) ProtoReflect() protoreflect.Message
- func (x *FeatureSpec) Reset()
- func (x *FeatureSpec) String() string
- type FeatureSpecV2
- func (*FeatureSpecV2) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureSpecV2) GetLabels() map[string]string
- func (x *FeatureSpecV2) GetName() string
- func (x *FeatureSpecV2) GetValueType() types.ValueType_Enum
- func (*FeatureSpecV2) ProtoMessage()
- func (x *FeatureSpecV2) ProtoReflect() protoreflect.Message
- func (x *FeatureSpecV2) Reset()
- func (x *FeatureSpecV2) String() string
- type FeatureSpec_BoolDomain
- type FeatureSpec_Domain
- type FeatureSpec_FloatDomain
- type FeatureSpec_GroupPresence
- type FeatureSpec_ImageDomain
- type FeatureSpec_IntDomain
- type FeatureSpec_MidDomain
- type FeatureSpec_NaturalLanguageDomain
- type FeatureSpec_Presence
- type FeatureSpec_Shape
- type FeatureSpec_StringDomain
- type FeatureSpec_StructDomain
- type FeatureSpec_TimeDomain
- type FeatureSpec_TimeOfDayDomain
- type FeatureSpec_UrlDomain
- type FeatureSpec_ValueCount
- type FeatureTable
- func (*FeatureTable) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureTable) GetMeta() *FeatureTableMeta
- func (x *FeatureTable) GetSpec() *FeatureTableSpec
- func (*FeatureTable) ProtoMessage()
- func (x *FeatureTable) ProtoReflect() protoreflect.Message
- func (x *FeatureTable) Reset()
- func (x *FeatureTable) String() string
- type FeatureTableMeta
- func (*FeatureTableMeta) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureTableMeta) GetCreatedTimestamp() *timestamppb.Timestamp
- func (x *FeatureTableMeta) GetHash() string
- func (x *FeatureTableMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp
- func (x *FeatureTableMeta) GetRevision() int64
- func (*FeatureTableMeta) ProtoMessage()
- func (x *FeatureTableMeta) ProtoReflect() protoreflect.Message
- func (x *FeatureTableMeta) Reset()
- func (x *FeatureTableMeta) String() string
- type FeatureTableSpec
- func (*FeatureTableSpec) Descriptor() ([]byte, []int)deprecated
- func (x *FeatureTableSpec) GetBatchSource() *DataSource
- func (x *FeatureTableSpec) GetEntities() []string
- func (x *FeatureTableSpec) GetFeatures() []*FeatureSpecV2
- func (x *FeatureTableSpec) GetLabels() map[string]string
- func (x *FeatureTableSpec) GetMaxAge() *durationpb.Duration
- func (x *FeatureTableSpec) GetName() string
- func (x *FeatureTableSpec) GetStreamSource() *DataSource
- func (*FeatureTableSpec) ProtoMessage()
- func (x *FeatureTableSpec) ProtoReflect() protoreflect.Message
- func (x *FeatureTableSpec) Reset()
- func (x *FeatureTableSpec) String() string
- type FileFormat
- func (*FileFormat) Descriptor() ([]byte, []int)deprecated
- func (m *FileFormat) GetFormat() isFileFormat_Format
- func (x *FileFormat) GetParquetFormat() *FileFormat_ParquetFormat
- func (*FileFormat) ProtoMessage()
- func (x *FileFormat) ProtoReflect() protoreflect.Message
- func (x *FileFormat) Reset()
- func (x *FileFormat) String() string
- type FileFormat_ParquetFormat
- type FileFormat_ParquetFormat_
- type GetEntityRequest
- func (*GetEntityRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityRequest) GetName() string
- func (x *GetEntityRequest) GetProject() string
- func (*GetEntityRequest) ProtoMessage()
- func (x *GetEntityRequest) ProtoReflect() protoreflect.Message
- func (x *GetEntityRequest) Reset()
- func (x *GetEntityRequest) String() string
- type GetEntityResponse
- type GetFeastCoreVersionRequest
- type GetFeastCoreVersionResponse
- func (*GetFeastCoreVersionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetFeastCoreVersionResponse) GetVersion() string
- func (*GetFeastCoreVersionResponse) ProtoMessage()
- func (x *GetFeastCoreVersionResponse) ProtoReflect() protoreflect.Message
- func (x *GetFeastCoreVersionResponse) Reset()
- func (x *GetFeastCoreVersionResponse) String() string
- type GetFeatureTableRequest
- func (*GetFeatureTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetFeatureTableRequest) GetName() string
- func (x *GetFeatureTableRequest) GetProject() string
- func (*GetFeatureTableRequest) ProtoMessage()
- func (x *GetFeatureTableRequest) ProtoReflect() protoreflect.Message
- func (x *GetFeatureTableRequest) Reset()
- func (x *GetFeatureTableRequest) String() string
- type GetFeatureTableResponse
- func (*GetFeatureTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetFeatureTableResponse) GetTable() *FeatureTable
- func (*GetFeatureTableResponse) ProtoMessage()
- func (x *GetFeatureTableResponse) ProtoReflect() protoreflect.Message
- func (x *GetFeatureTableResponse) Reset()
- func (x *GetFeatureTableResponse) String() string
- type GetHistoricalFeaturesRequest
- func (*GetHistoricalFeaturesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetHistoricalFeaturesRequest) GetEntitySource() *DataSource
- func (x *GetHistoricalFeaturesRequest) GetFeatureRefs() []string
- func (x *GetHistoricalFeaturesRequest) GetOutputFormat() string
- func (x *GetHistoricalFeaturesRequest) GetOutputLocation() string
- func (x *GetHistoricalFeaturesRequest) GetProject() string
- func (*GetHistoricalFeaturesRequest) ProtoMessage()
- func (x *GetHistoricalFeaturesRequest) ProtoReflect() protoreflect.Message
- func (x *GetHistoricalFeaturesRequest) Reset()
- func (x *GetHistoricalFeaturesRequest) String() string
- type GetHistoricalFeaturesResponse
- func (*GetHistoricalFeaturesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetHistoricalFeaturesResponse) GetId() string
- func (x *GetHistoricalFeaturesResponse) GetJobStartTime() *timestamppb.Timestamp
- func (x *GetHistoricalFeaturesResponse) GetLogUri() string
- func (x *GetHistoricalFeaturesResponse) GetOutputFileUri() string
- func (*GetHistoricalFeaturesResponse) ProtoMessage()
- func (x *GetHistoricalFeaturesResponse) ProtoReflect() protoreflect.Message
- func (x *GetHistoricalFeaturesResponse) Reset()
- func (x *GetHistoricalFeaturesResponse) String() string
- type GetJobRequest
- type GetJobResponse
- type IngestionJob
- func (*IngestionJob) Descriptor() ([]byte, []int)deprecated
- func (x *IngestionJob) GetExternalId() string
- func (x *IngestionJob) GetFeatureSetReferences() []*FeatureSetReference
- func (x *IngestionJob) GetId() string
- func (x *IngestionJob) GetSource() *Source
- func (x *IngestionJob) GetStatus() IngestionJobStatus
- func (x *IngestionJob) GetStores() []*Store
- func (*IngestionJob) ProtoMessage()
- func (x *IngestionJob) ProtoReflect() protoreflect.Message
- func (x *IngestionJob) Reset()
- func (x *IngestionJob) String() string
- type IngestionJobStatus
- func (IngestionJobStatus) Descriptor() protoreflect.EnumDescriptor
- func (x IngestionJobStatus) Enum() *IngestionJobStatus
- func (IngestionJobStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x IngestionJobStatus) Number() protoreflect.EnumNumber
- func (x IngestionJobStatus) String() string
- func (IngestionJobStatus) Type() protoreflect.EnumType
- type Job
- func (*Job) Descriptor() ([]byte, []int)deprecated
- func (x *Job) GetBatchIngestion() *Job_OfflineToOnlineMeta
- func (x *Job) GetHash() string
- func (x *Job) GetId() string
- func (x *Job) GetLogUri() string
- func (m *Job) GetMeta() isJob_Meta
- func (x *Job) GetRetrieval() *Job_RetrievalJobMeta
- func (x *Job) GetStartTime() *timestamppb.Timestamp
- func (x *Job) GetStatus() JobStatus
- func (x *Job) GetStreamIngestion() *Job_StreamToOnlineMeta
- func (x *Job) GetType() JobType
- func (*Job) ProtoMessage()
- func (x *Job) ProtoReflect() protoreflect.Message
- func (x *Job) Reset()
- func (x *Job) String() string
- type JobServiceClient
- type JobServiceServer
- type JobStatus
- type JobType
- type Job_BatchIngestion
- type Job_OfflineToOnlineMeta
- func (*Job_OfflineToOnlineMeta) Descriptor() ([]byte, []int)deprecated
- func (x *Job_OfflineToOnlineMeta) GetTableName() string
- func (*Job_OfflineToOnlineMeta) ProtoMessage()
- func (x *Job_OfflineToOnlineMeta) ProtoReflect() protoreflect.Message
- func (x *Job_OfflineToOnlineMeta) Reset()
- func (x *Job_OfflineToOnlineMeta) String() string
- type Job_Retrieval
- type Job_RetrievalJobMeta
- func (*Job_RetrievalJobMeta) Descriptor() ([]byte, []int)deprecated
- func (x *Job_RetrievalJobMeta) GetOutputLocation() string
- func (*Job_RetrievalJobMeta) ProtoMessage()
- func (x *Job_RetrievalJobMeta) ProtoReflect() protoreflect.Message
- func (x *Job_RetrievalJobMeta) Reset()
- func (x *Job_RetrievalJobMeta) String() string
- type Job_StreamIngestion
- type Job_StreamToOnlineMeta
- func (*Job_StreamToOnlineMeta) Descriptor() ([]byte, []int)deprecated
- func (x *Job_StreamToOnlineMeta) GetTableName() string
- func (*Job_StreamToOnlineMeta) ProtoMessage()
- func (x *Job_StreamToOnlineMeta) ProtoReflect() protoreflect.Message
- func (x *Job_StreamToOnlineMeta) Reset()
- func (x *Job_StreamToOnlineMeta) String() string
- type KafkaSourceConfig
- func (*KafkaSourceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *KafkaSourceConfig) GetBootstrapServers() string
- func (x *KafkaSourceConfig) GetPartitions() int32
- func (x *KafkaSourceConfig) GetReplicationFactor() int32
- func (x *KafkaSourceConfig) GetTopic() string
- func (*KafkaSourceConfig) ProtoMessage()
- func (x *KafkaSourceConfig) ProtoReflect() protoreflect.Message
- func (x *KafkaSourceConfig) Reset()
- func (x *KafkaSourceConfig) String() string
- type ListEntitiesRequest
- func (*ListEntitiesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListEntitiesRequest) GetFilter() *ListEntitiesRequest_Filter
- func (*ListEntitiesRequest) ProtoMessage()
- func (x *ListEntitiesRequest) ProtoReflect() protoreflect.Message
- func (x *ListEntitiesRequest) Reset()
- func (x *ListEntitiesRequest) String() string
- type ListEntitiesRequest_Filter
- func (*ListEntitiesRequest_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *ListEntitiesRequest_Filter) GetLabels() map[string]string
- func (x *ListEntitiesRequest_Filter) GetProject() string
- func (*ListEntitiesRequest_Filter) ProtoMessage()
- func (x *ListEntitiesRequest_Filter) ProtoReflect() protoreflect.Message
- func (x *ListEntitiesRequest_Filter) Reset()
- func (x *ListEntitiesRequest_Filter) String() string
- type ListEntitiesResponse
- func (*ListEntitiesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListEntitiesResponse) GetEntities() []*Entity
- func (*ListEntitiesResponse) ProtoMessage()
- func (x *ListEntitiesResponse) ProtoReflect() protoreflect.Message
- func (x *ListEntitiesResponse) Reset()
- func (x *ListEntitiesResponse) String() string
- type ListFeatureTablesRequest
- func (*ListFeatureTablesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListFeatureTablesRequest) GetFilter() *ListFeatureTablesRequest_Filter
- func (*ListFeatureTablesRequest) ProtoMessage()
- func (x *ListFeatureTablesRequest) ProtoReflect() protoreflect.Message
- func (x *ListFeatureTablesRequest) Reset()
- func (x *ListFeatureTablesRequest) String() string
- type ListFeatureTablesRequest_Filter
- func (*ListFeatureTablesRequest_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *ListFeatureTablesRequest_Filter) GetLabels() map[string]string
- func (x *ListFeatureTablesRequest_Filter) GetProject() string
- func (*ListFeatureTablesRequest_Filter) ProtoMessage()
- func (x *ListFeatureTablesRequest_Filter) ProtoReflect() protoreflect.Message
- func (x *ListFeatureTablesRequest_Filter) Reset()
- func (x *ListFeatureTablesRequest_Filter) String() string
- type ListFeatureTablesResponse
- func (*ListFeatureTablesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListFeatureTablesResponse) GetTables() []*FeatureTable
- func (*ListFeatureTablesResponse) ProtoMessage()
- func (x *ListFeatureTablesResponse) ProtoReflect() protoreflect.Message
- func (x *ListFeatureTablesResponse) Reset()
- func (x *ListFeatureTablesResponse) String() string
- type ListFeaturesRequest
- func (*ListFeaturesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListFeaturesRequest) GetFilter() *ListFeaturesRequest_Filter
- func (*ListFeaturesRequest) ProtoMessage()
- func (x *ListFeaturesRequest) ProtoReflect() protoreflect.Message
- func (x *ListFeaturesRequest) Reset()
- func (x *ListFeaturesRequest) String() string
- type ListFeaturesRequest_Filter
- func (*ListFeaturesRequest_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *ListFeaturesRequest_Filter) GetEntities() []string
- func (x *ListFeaturesRequest_Filter) GetLabels() map[string]string
- func (x *ListFeaturesRequest_Filter) GetProject() string
- func (*ListFeaturesRequest_Filter) ProtoMessage()
- func (x *ListFeaturesRequest_Filter) ProtoReflect() protoreflect.Message
- func (x *ListFeaturesRequest_Filter) Reset()
- func (x *ListFeaturesRequest_Filter) String() string
- type ListFeaturesResponse
- func (*ListFeaturesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListFeaturesResponse) GetFeatures() map[string]*FeatureSpecV2
- func (*ListFeaturesResponse) ProtoMessage()
- func (x *ListFeaturesResponse) ProtoReflect() protoreflect.Message
- func (x *ListFeaturesResponse) Reset()
- func (x *ListFeaturesResponse) String() string
- type ListJobsRequest
- func (*ListJobsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListJobsRequest) GetIncludeTerminated() bool
- func (x *ListJobsRequest) GetTableName() string
- func (*ListJobsRequest) ProtoMessage()
- func (x *ListJobsRequest) ProtoReflect() protoreflect.Message
- func (x *ListJobsRequest) Reset()
- func (x *ListJobsRequest) String() string
- type ListJobsResponse
- type ListProjectsRequest
- type ListProjectsResponse
- func (*ListProjectsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListProjectsResponse) GetProjects() []string
- func (*ListProjectsResponse) ProtoMessage()
- func (x *ListProjectsResponse) ProtoReflect() protoreflect.Message
- func (x *ListProjectsResponse) Reset()
- func (x *ListProjectsResponse) String() string
- type ListStoresRequest
- func (*ListStoresRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListStoresRequest) GetFilter() *ListStoresRequest_Filter
- func (*ListStoresRequest) ProtoMessage()
- func (x *ListStoresRequest) ProtoReflect() protoreflect.Message
- func (x *ListStoresRequest) Reset()
- func (x *ListStoresRequest) String() string
- type ListStoresRequest_Filter
- func (*ListStoresRequest_Filter) Descriptor() ([]byte, []int)deprecated
- func (x *ListStoresRequest_Filter) GetName() string
- func (*ListStoresRequest_Filter) ProtoMessage()
- func (x *ListStoresRequest_Filter) ProtoReflect() protoreflect.Message
- func (x *ListStoresRequest_Filter) Reset()
- func (x *ListStoresRequest_Filter) String() string
- type ListStoresResponse
- func (*ListStoresResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListStoresResponse) GetStore() []*Store
- func (*ListStoresResponse) ProtoMessage()
- func (x *ListStoresResponse) ProtoReflect() protoreflect.Message
- func (x *ListStoresResponse) Reset()
- func (x *ListStoresResponse) String() string
- type Source
- func (*Source) Descriptor() ([]byte, []int)deprecated
- func (x *Source) GetKafkaSourceConfig() *KafkaSourceConfig
- func (m *Source) GetSourceConfig() isSource_SourceConfig
- func (x *Source) GetType() SourceType
- func (*Source) ProtoMessage()
- func (x *Source) ProtoReflect() protoreflect.Message
- func (x *Source) Reset()
- func (x *Source) String() string
- type SourceType
- type Source_KafkaSourceConfig
- type SpecsStreamingUpdateConfig
- func (*SpecsStreamingUpdateConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SpecsStreamingUpdateConfig) GetAck() *KafkaSourceConfig
- func (x *SpecsStreamingUpdateConfig) GetSource() *KafkaSourceConfig
- func (*SpecsStreamingUpdateConfig) ProtoMessage()
- func (x *SpecsStreamingUpdateConfig) ProtoReflect() protoreflect.Message
- func (x *SpecsStreamingUpdateConfig) Reset()
- func (x *SpecsStreamingUpdateConfig) String() string
- type StartOfflineToOnlineIngestionJobRequest
- func (*StartOfflineToOnlineIngestionJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartOfflineToOnlineIngestionJobRequest) GetEndDate() *timestamppb.Timestamp
- func (x *StartOfflineToOnlineIngestionJobRequest) GetProject() string
- func (x *StartOfflineToOnlineIngestionJobRequest) GetStartDate() *timestamppb.Timestamp
- func (x *StartOfflineToOnlineIngestionJobRequest) GetTableName() string
- func (*StartOfflineToOnlineIngestionJobRequest) ProtoMessage()
- func (x *StartOfflineToOnlineIngestionJobRequest) ProtoReflect() protoreflect.Message
- func (x *StartOfflineToOnlineIngestionJobRequest) Reset()
- func (x *StartOfflineToOnlineIngestionJobRequest) String() string
- type StartOfflineToOnlineIngestionJobResponse
- func (*StartOfflineToOnlineIngestionJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartOfflineToOnlineIngestionJobResponse) GetId() string
- func (x *StartOfflineToOnlineIngestionJobResponse) GetJobStartTime() *timestamppb.Timestamp
- func (x *StartOfflineToOnlineIngestionJobResponse) GetLogUri() string
- func (x *StartOfflineToOnlineIngestionJobResponse) GetTableName() string
- func (*StartOfflineToOnlineIngestionJobResponse) ProtoMessage()
- func (x *StartOfflineToOnlineIngestionJobResponse) ProtoReflect() protoreflect.Message
- func (x *StartOfflineToOnlineIngestionJobResponse) Reset()
- func (x *StartOfflineToOnlineIngestionJobResponse) String() string
- type StartStreamToOnlineIngestionJobRequest
- func (*StartStreamToOnlineIngestionJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartStreamToOnlineIngestionJobRequest) GetProject() string
- func (x *StartStreamToOnlineIngestionJobRequest) GetTableName() string
- func (*StartStreamToOnlineIngestionJobRequest) ProtoMessage()
- func (x *StartStreamToOnlineIngestionJobRequest) ProtoReflect() protoreflect.Message
- func (x *StartStreamToOnlineIngestionJobRequest) Reset()
- func (x *StartStreamToOnlineIngestionJobRequest) String() string
- type StartStreamToOnlineIngestionJobResponse
- func (*StartStreamToOnlineIngestionJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StartStreamToOnlineIngestionJobResponse) GetId() string
- func (x *StartStreamToOnlineIngestionJobResponse) GetJobStartTime() *timestamppb.Timestamp
- func (x *StartStreamToOnlineIngestionJobResponse) GetLogUri() string
- func (x *StartStreamToOnlineIngestionJobResponse) GetTableName() string
- func (*StartStreamToOnlineIngestionJobResponse) ProtoMessage()
- func (x *StartStreamToOnlineIngestionJobResponse) ProtoReflect() protoreflect.Message
- func (x *StartStreamToOnlineIngestionJobResponse) Reset()
- func (x *StartStreamToOnlineIngestionJobResponse) String() string
- type Store
- func (*Store) Descriptor() ([]byte, []int)deprecated
- func (m *Store) GetConfig() isStore_Config
- func (x *Store) GetName() string
- func (x *Store) GetRedisClusterConfig() *Store_RedisClusterConfig
- func (x *Store) GetRedisConfig() *Store_RedisConfig
- func (x *Store) GetSubscriptions() []*Store_Subscription
- func (x *Store) GetType() Store_StoreType
- func (*Store) ProtoMessage()
- func (x *Store) ProtoReflect() protoreflect.Message
- func (x *Store) Reset()
- func (x *Store) String() string
- type Store_RedisClusterConfig
- func (*Store_RedisClusterConfig) Descriptor() ([]byte, []int)deprecated
- func (x *Store_RedisClusterConfig) GetConnectionString() string
- func (x *Store_RedisClusterConfig) GetEnableFallback() bool
- func (x *Store_RedisClusterConfig) GetFallbackPrefix() string
- func (x *Store_RedisClusterConfig) GetFlushFrequencySeconds() int32
- func (x *Store_RedisClusterConfig) GetInitialBackoffMs() int32
- func (x *Store_RedisClusterConfig) GetKeyPrefix() string
- func (x *Store_RedisClusterConfig) GetMaxRetries() int32
- func (x *Store_RedisClusterConfig) GetReadFrom() Store_RedisClusterConfig_ReadFrom
- func (x *Store_RedisClusterConfig) GetTimeout() *durationpb.Duration
- func (*Store_RedisClusterConfig) ProtoMessage()
- func (x *Store_RedisClusterConfig) ProtoReflect() protoreflect.Message
- func (x *Store_RedisClusterConfig) Reset()
- func (x *Store_RedisClusterConfig) String() string
- type Store_RedisClusterConfig_
- type Store_RedisClusterConfig_ReadFrom
- func (Store_RedisClusterConfig_ReadFrom) Descriptor() protoreflect.EnumDescriptor
- func (x Store_RedisClusterConfig_ReadFrom) Enum() *Store_RedisClusterConfig_ReadFrom
- func (Store_RedisClusterConfig_ReadFrom) EnumDescriptor() ([]byte, []int)deprecated
- func (x Store_RedisClusterConfig_ReadFrom) Number() protoreflect.EnumNumber
- func (x Store_RedisClusterConfig_ReadFrom) String() string
- func (Store_RedisClusterConfig_ReadFrom) Type() protoreflect.EnumType
- type Store_RedisConfig
- func (*Store_RedisConfig) Descriptor() ([]byte, []int)deprecated
- func (x *Store_RedisConfig) GetFlushFrequencySeconds() int32
- func (x *Store_RedisConfig) GetHost() string
- func (x *Store_RedisConfig) GetInitialBackoffMs() int32
- func (x *Store_RedisConfig) GetMaxRetries() int32
- func (x *Store_RedisConfig) GetPort() int32
- func (x *Store_RedisConfig) GetSsl() bool
- func (*Store_RedisConfig) ProtoMessage()
- func (x *Store_RedisConfig) ProtoReflect() protoreflect.Message
- func (x *Store_RedisConfig) Reset()
- func (x *Store_RedisConfig) String() string
- type Store_RedisConfig_
- type Store_StoreType
- func (Store_StoreType) Descriptor() protoreflect.EnumDescriptor
- func (x Store_StoreType) Enum() *Store_StoreType
- func (Store_StoreType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Store_StoreType) Number() protoreflect.EnumNumber
- func (x Store_StoreType) String() string
- func (Store_StoreType) Type() protoreflect.EnumType
- type Store_Subscription
- func (*Store_Subscription) Descriptor() ([]byte, []int)deprecated
- func (x *Store_Subscription) GetExclude() bool
- func (x *Store_Subscription) GetName() string
- func (x *Store_Subscription) GetProject() string
- func (*Store_Subscription) ProtoMessage()
- func (x *Store_Subscription) ProtoReflect() protoreflect.Message
- func (x *Store_Subscription) Reset()
- func (x *Store_Subscription) String() string
- type StreamFormat
- func (*StreamFormat) Descriptor() ([]byte, []int)deprecated
- func (x *StreamFormat) GetAvroFormat() *StreamFormat_AvroFormat
- func (m *StreamFormat) GetFormat() isStreamFormat_Format
- func (x *StreamFormat) GetProtoFormat() *StreamFormat_ProtoFormat
- func (*StreamFormat) ProtoMessage()
- func (x *StreamFormat) ProtoReflect() protoreflect.Message
- func (x *StreamFormat) Reset()
- func (x *StreamFormat) String() string
- type StreamFormat_AvroFormat
- func (*StreamFormat_AvroFormat) Descriptor() ([]byte, []int)deprecated
- func (x *StreamFormat_AvroFormat) GetSchemaJson() string
- func (*StreamFormat_AvroFormat) ProtoMessage()
- func (x *StreamFormat_AvroFormat) ProtoReflect() protoreflect.Message
- func (x *StreamFormat_AvroFormat) Reset()
- func (x *StreamFormat_AvroFormat) String() string
- type StreamFormat_AvroFormat_
- type StreamFormat_ProtoFormat
- func (*StreamFormat_ProtoFormat) Descriptor() ([]byte, []int)deprecated
- func (x *StreamFormat_ProtoFormat) GetClassPath() string
- func (*StreamFormat_ProtoFormat) ProtoMessage()
- func (x *StreamFormat_ProtoFormat) ProtoReflect() protoreflect.Message
- func (x *StreamFormat_ProtoFormat) Reset()
- func (x *StreamFormat_ProtoFormat) String() string
- type StreamFormat_ProtoFormat_
- type UnimplementedCoreServiceServer
- func (*UnimplementedCoreServiceServer) ApplyEntity(context.Context, *ApplyEntityRequest) (*ApplyEntityResponse, error)
- func (*UnimplementedCoreServiceServer) ApplyFeatureTable(context.Context, *ApplyFeatureTableRequest) (*ApplyFeatureTableResponse, error)
- func (*UnimplementedCoreServiceServer) ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)
- func (*UnimplementedCoreServiceServer) CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)
- func (*UnimplementedCoreServiceServer) DeleteFeatureTable(context.Context, *DeleteFeatureTableRequest) (*DeleteFeatureTableResponse, error)
- func (*UnimplementedCoreServiceServer) GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)
- func (*UnimplementedCoreServiceServer) GetFeastCoreVersion(context.Context, *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error)
- func (*UnimplementedCoreServiceServer) GetFeatureTable(context.Context, *GetFeatureTableRequest) (*GetFeatureTableResponse, error)
- func (*UnimplementedCoreServiceServer) ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)
- func (*UnimplementedCoreServiceServer) ListFeatureTables(context.Context, *ListFeatureTablesRequest) (*ListFeatureTablesResponse, error)
- func (*UnimplementedCoreServiceServer) ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)
- func (*UnimplementedCoreServiceServer) ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
- func (*UnimplementedCoreServiceServer) ListStores(context.Context, *ListStoresRequest) (*ListStoresResponse, error)
- func (*UnimplementedCoreServiceServer) UpdateStore(context.Context, *UpdateStoreRequest) (*UpdateStoreResponse, error)
- type UnimplementedJobServiceServer
- func (*UnimplementedJobServiceServer) CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
- func (*UnimplementedJobServiceServer) GetHistoricalFeatures(context.Context, *GetHistoricalFeaturesRequest) (*GetHistoricalFeaturesResponse, error)
- func (*UnimplementedJobServiceServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
- func (*UnimplementedJobServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
- func (*UnimplementedJobServiceServer) StartOfflineToOnlineIngestionJob(context.Context, *StartOfflineToOnlineIngestionJobRequest) (*StartOfflineToOnlineIngestionJobResponse, error)
- func (*UnimplementedJobServiceServer) StartStreamToOnlineIngestionJob(context.Context, *StartStreamToOnlineIngestionJobRequest) (*StartStreamToOnlineIngestionJobResponse, error)
- type UpdateFeatureSetStatusResponse
- func (*UpdateFeatureSetStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (*UpdateFeatureSetStatusResponse) ProtoMessage()
- func (x *UpdateFeatureSetStatusResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateFeatureSetStatusResponse) Reset()
- func (x *UpdateFeatureSetStatusResponse) String() string
- type UpdateStoreRequest
- func (*UpdateStoreRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateStoreRequest) GetStore() *Store
- func (*UpdateStoreRequest) ProtoMessage()
- func (x *UpdateStoreRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateStoreRequest) Reset()
- func (x *UpdateStoreRequest) String() string
- type UpdateStoreResponse
- func (*UpdateStoreResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateStoreResponse) GetStatus() UpdateStoreResponse_Status
- func (x *UpdateStoreResponse) GetStore() *Store
- func (*UpdateStoreResponse) ProtoMessage()
- func (x *UpdateStoreResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateStoreResponse) Reset()
- func (x *UpdateStoreResponse) String() string
- type UpdateStoreResponse_Status
- func (UpdateStoreResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x UpdateStoreResponse_Status) Enum() *UpdateStoreResponse_Status
- func (UpdateStoreResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x UpdateStoreResponse_Status) Number() protoreflect.EnumNumber
- func (x UpdateStoreResponse_Status) String() string
- func (UpdateStoreResponse_Status) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
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.
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.
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.
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.
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.
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.
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.
var ( SourceType_name = map[int32]string{ 0: "INVALID", 1: "KAFKA", } SourceType_value = map[string]int32{ "INVALID": 0, "KAFKA": 1, } )
Enum value maps for SourceType.
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.
var ( Store_RedisClusterConfig_ReadFrom_name = map[int32]string{ 0: "MASTER", 1: "MASTER_PREFERRED", 2: "REPLICA", 3: "REPLICA_PREFERRED", } Store_RedisClusterConfig_ReadFrom_value = map[string]int32{ "MASTER": 0, "MASTER_PREFERRED": 1, "REPLICA": 2, "REPLICA_PREFERRED": 3, } )
Enum value maps for Store_RedisClusterConfig_ReadFrom.
var File_feast_core_CoreService_proto protoreflect.FileDescriptor
var File_feast_core_DataFormat_proto protoreflect.FileDescriptor
var File_feast_core_DataSource_proto protoreflect.FileDescriptor
var File_feast_core_Entity_proto protoreflect.FileDescriptor
var File_feast_core_FeatureSetReference_proto protoreflect.FileDescriptor
var File_feast_core_FeatureSet_proto protoreflect.FileDescriptor
var File_feast_core_FeatureTable_proto protoreflect.FileDescriptor
var File_feast_core_Feature_proto protoreflect.FileDescriptor
var File_feast_core_IngestionJob_proto protoreflect.FileDescriptor
var File_feast_core_JobService_proto protoreflect.FileDescriptor
var File_feast_core_Runner_proto protoreflect.FileDescriptor
var File_feast_core_Source_proto protoreflect.FileDescriptor
var File_feast_core_Store_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCoreServiceServer ¶
func RegisterCoreServiceServer(s *grpc.Server, srv CoreServiceServer)
func RegisterJobServiceServer ¶ added in v0.9.0
func RegisterJobServiceServer(s *grpc.Server, srv JobServiceServer)
Types ¶
type ApplyEntityRequest ¶ added in v0.8.0
type ApplyEntityRequest struct { // If project is unspecified, will default to 'default' project. // If project specified does not exist, the project would be automatically created. Spec *EntitySpecV2 `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Name of project that this entity belongs to. Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"` // contains filtered or unexported fields }
func (*ApplyEntityRequest) Descriptor
deprecated
added in
v0.8.0
func (*ApplyEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyEntityRequest.ProtoReflect.Descriptor instead.
func (*ApplyEntityRequest) GetProject ¶ added in v0.8.0
func (x *ApplyEntityRequest) GetProject() string
func (*ApplyEntityRequest) GetSpec ¶ added in v0.8.0
func (x *ApplyEntityRequest) GetSpec() *EntitySpecV2
func (*ApplyEntityRequest) ProtoMessage ¶ added in v0.8.0
func (*ApplyEntityRequest) ProtoMessage()
func (*ApplyEntityRequest) ProtoReflect ¶ added in v0.8.0
func (x *ApplyEntityRequest) ProtoReflect() protoreflect.Message
func (*ApplyEntityRequest) Reset ¶ added in v0.8.0
func (x *ApplyEntityRequest) Reset()
func (*ApplyEntityRequest) String ¶ added in v0.8.0
func (x *ApplyEntityRequest) String() string
type ApplyEntityResponse ¶ added in v0.8.0
type ApplyEntityResponse struct { Entity *Entity `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"` // contains filtered or unexported fields }
func (*ApplyEntityResponse) Descriptor
deprecated
added in
v0.8.0
func (*ApplyEntityResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApplyEntityResponse.ProtoReflect.Descriptor instead.
func (*ApplyEntityResponse) GetEntity ¶ added in v0.8.0
func (x *ApplyEntityResponse) GetEntity() *Entity
func (*ApplyEntityResponse) ProtoMessage ¶ added in v0.8.0
func (*ApplyEntityResponse) ProtoMessage()
func (*ApplyEntityResponse) ProtoReflect ¶ added in v0.8.0
func (x *ApplyEntityResponse) ProtoReflect() protoreflect.Message
func (*ApplyEntityResponse) Reset ¶ added in v0.8.0
func (x *ApplyEntityResponse) Reset()
func (*ApplyEntityResponse) String ¶ added in v0.8.0
func (x *ApplyEntityResponse) String() string
type ApplyFeatureTableRequest ¶ added in v0.8.0
type ApplyFeatureTableRequest struct { // Optional. Name of the Project to apply the Feature Table to. // If unspecified, will apply FeatureTable to the default project. Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // Feature Table specification to apply TableSpec *FeatureTableSpec `protobuf:"bytes,2,opt,name=table_spec,json=tableSpec,proto3" json:"table_spec,omitempty"` // contains filtered or unexported fields }
func (*ApplyFeatureTableRequest) Descriptor
deprecated
added in
v0.8.0
func (*ApplyFeatureTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use ApplyFeatureTableRequest.ProtoReflect.Descriptor instead.
func (*ApplyFeatureTableRequest) GetProject ¶ added in v0.8.0
func (x *ApplyFeatureTableRequest) GetProject() string
func (*ApplyFeatureTableRequest) GetTableSpec ¶ added in v0.8.0
func (x *ApplyFeatureTableRequest) GetTableSpec() *FeatureTableSpec
func (*ApplyFeatureTableRequest) ProtoMessage ¶ added in v0.8.0
func (*ApplyFeatureTableRequest) ProtoMessage()
func (*ApplyFeatureTableRequest) ProtoReflect ¶ added in v0.8.0
func (x *ApplyFeatureTableRequest) ProtoReflect() protoreflect.Message
func (*ApplyFeatureTableRequest) Reset ¶ added in v0.8.0
func (x *ApplyFeatureTableRequest) Reset()
func (*ApplyFeatureTableRequest) String ¶ added in v0.8.0
func (x *ApplyFeatureTableRequest) String() string
type ApplyFeatureTableResponse ¶ added in v0.8.0
type ApplyFeatureTableResponse struct { Table *FeatureTable `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` // contains filtered or unexported fields }
func (*ApplyFeatureTableResponse) Descriptor
deprecated
added in
v0.8.0
func (*ApplyFeatureTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use ApplyFeatureTableResponse.ProtoReflect.Descriptor instead.
func (*ApplyFeatureTableResponse) GetTable ¶ added in v0.8.0
func (x *ApplyFeatureTableResponse) GetTable() *FeatureTable
func (*ApplyFeatureTableResponse) ProtoMessage ¶ added in v0.8.0
func (*ApplyFeatureTableResponse) ProtoMessage()
func (*ApplyFeatureTableResponse) ProtoReflect ¶ added in v0.8.0
func (x *ApplyFeatureTableResponse) ProtoReflect() protoreflect.Message
func (*ApplyFeatureTableResponse) Reset ¶ added in v0.8.0
func (x *ApplyFeatureTableResponse) Reset()
func (*ApplyFeatureTableResponse) String ¶ added in v0.8.0
func (x *ApplyFeatureTableResponse) String() string
type ArchiveProjectRequest ¶
type ArchiveProjectRequest struct { // Name of project to be archived Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request for the archival of a project
func (*ArchiveProjectRequest) Descriptor
deprecated
func (*ArchiveProjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use ArchiveProjectRequest.ProtoReflect.Descriptor instead.
func (*ArchiveProjectRequest) GetName ¶
func (x *ArchiveProjectRequest) GetName() string
func (*ArchiveProjectRequest) ProtoMessage ¶
func (*ArchiveProjectRequest) ProtoMessage()
func (*ArchiveProjectRequest) ProtoReflect ¶
func (x *ArchiveProjectRequest) ProtoReflect() protoreflect.Message
func (*ArchiveProjectRequest) Reset ¶
func (x *ArchiveProjectRequest) Reset()
func (*ArchiveProjectRequest) String ¶
func (x *ArchiveProjectRequest) String() string
type ArchiveProjectResponse ¶
type ArchiveProjectResponse struct {
// contains filtered or unexported fields
}
Response for archival of a project
func (*ArchiveProjectResponse) Descriptor
deprecated
func (*ArchiveProjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use ArchiveProjectResponse.ProtoReflect.Descriptor instead.
func (*ArchiveProjectResponse) ProtoMessage ¶
func (*ArchiveProjectResponse) ProtoMessage()
func (*ArchiveProjectResponse) ProtoReflect ¶
func (x *ArchiveProjectResponse) ProtoReflect() protoreflect.Message
func (*ArchiveProjectResponse) Reset ¶
func (x *ArchiveProjectResponse) Reset()
func (*ArchiveProjectResponse) String ¶
func (x *ArchiveProjectResponse) String() string
type CancelJobRequest ¶ added in v0.9.0
type CancelJobRequest struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // contains filtered or unexported fields }
func (*CancelJobRequest) Descriptor
deprecated
added in
v0.9.0
func (*CancelJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.
func (*CancelJobRequest) GetJobId ¶ added in v0.9.0
func (x *CancelJobRequest) GetJobId() string
func (*CancelJobRequest) ProtoMessage ¶ added in v0.9.0
func (*CancelJobRequest) ProtoMessage()
func (*CancelJobRequest) ProtoReflect ¶ added in v0.9.0
func (x *CancelJobRequest) ProtoReflect() protoreflect.Message
func (*CancelJobRequest) Reset ¶ added in v0.9.0
func (x *CancelJobRequest) Reset()
func (*CancelJobRequest) String ¶ added in v0.9.0
func (x *CancelJobRequest) String() string
type CancelJobResponse ¶ added in v0.9.0
type CancelJobResponse struct {
// contains filtered or unexported fields
}
func (*CancelJobResponse) Descriptor
deprecated
added in
v0.9.0
func (*CancelJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.
func (*CancelJobResponse) ProtoMessage ¶ added in v0.9.0
func (*CancelJobResponse) ProtoMessage()
func (*CancelJobResponse) ProtoReflect ¶ added in v0.9.0
func (x *CancelJobResponse) ProtoReflect() protoreflect.Message
func (*CancelJobResponse) Reset ¶ added in v0.9.0
func (x *CancelJobResponse) Reset()
func (*CancelJobResponse) String ¶ added in v0.9.0
func (x *CancelJobResponse) String() string
type CoreServiceClient ¶
type CoreServiceClient interface { // Retrieve version information about this Feast deployment GetFeastCoreVersion(ctx context.Context, in *GetFeastCoreVersionRequest, opts ...grpc.CallOption) (*GetFeastCoreVersionResponse, error) // Returns a specific entity GetEntity(ctx context.Context, in *GetEntityRequest, opts ...grpc.CallOption) (*GetEntityResponse, error) // Returns all feature references and respective features matching that filter. If none are found // an empty map will be returned // If no filter is provided in the request, the response will contain all the features // currently stored in the default project. ListFeatures(ctx context.Context, in *ListFeaturesRequest, opts ...grpc.CallOption) (*ListFeaturesResponse, error) // Retrieve store details given a filter. // // Returns all stores matching that filter. If none are found, an empty list will be returned. // If no filter is provided in the request, the response will contain all the stores currently // stored in the registry. ListStores(ctx context.Context, in *ListStoresRequest, opts ...grpc.CallOption) (*ListStoresResponse, error) // Create or update and existing entity. // // This function is idempotent - it will not create a new entity if schema does not change. // Schema changes will update the entity if the changes are valid. // Following changes are not valid: // - Changes to name // - Changes to type ApplyEntity(ctx context.Context, in *ApplyEntityRequest, opts ...grpc.CallOption) (*ApplyEntityResponse, error) // Returns all entity references and respective entities matching that filter. If none are found // an empty map will be returned // If no filter is provided in the request, the response will contain all the entities // currently stored in the default project. ListEntities(ctx context.Context, in *ListEntitiesRequest, opts ...grpc.CallOption) (*ListEntitiesResponse, error) // Updates core with the configuration of the store. // // If the changes are valid, core will return the given store configuration in response, and // start or update the necessary feature population jobs for the updated store. UpdateStore(ctx context.Context, in *UpdateStoreRequest, opts ...grpc.CallOption) (*UpdateStoreResponse, error) // Creates a project. Projects serve as namespaces within which resources like features will be // created. Feature table names as must be unique within a project while field (Feature/Entity) names // must be unique within a Feature Table. Project names themselves must be globally unique. CreateProject(ctx context.Context, in *CreateProjectRequest, opts ...grpc.CallOption) (*CreateProjectResponse, error) // Archives a project. Archived projects will continue to exist and function, but won't be visible // through the Core API. Any existing ingestion or serving requests will continue to function, // but will result in warning messages being logged. It is not possible to unarchive a project // through the Core API ArchiveProject(ctx context.Context, in *ArchiveProjectRequest, opts ...grpc.CallOption) (*ArchiveProjectResponse, error) // Lists all projects active projects. ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error) // Create or update an existing feature table. // This function is idempotent - it will not create a new feature table if the schema does not change. // Schema changes will update the feature table if the changes are valid. // All changes except the following are valid: // - Changes to feature table name. // - Changes to entities // - Changes to feature name and type ApplyFeatureTable(ctx context.Context, in *ApplyFeatureTableRequest, opts ...grpc.CallOption) (*ApplyFeatureTableResponse, error) // List feature tables that match a given filter. // Returns the references of the Feature Tables matching that filter. If none are found, // an empty list will be returned. // If no filter is provided in the request, the response will match all the feature // tables currently stored in the registry. ListFeatureTables(ctx context.Context, in *ListFeatureTablesRequest, opts ...grpc.CallOption) (*ListFeatureTablesResponse, error) // Returns a specific feature table GetFeatureTable(ctx context.Context, in *GetFeatureTableRequest, opts ...grpc.CallOption) (*GetFeatureTableResponse, error) // Delete a specific feature table DeleteFeatureTable(ctx context.Context, in *DeleteFeatureTableRequest, opts ...grpc.CallOption) (*DeleteFeatureTableResponse, error) }
CoreServiceClient is the client API for CoreService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCoreServiceClient ¶
func NewCoreServiceClient(cc grpc.ClientConnInterface) CoreServiceClient
type CoreServiceServer ¶
type CoreServiceServer interface { // Retrieve version information about this Feast deployment GetFeastCoreVersion(context.Context, *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error) // Returns a specific entity GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error) // Returns all feature references and respective features matching that filter. If none are found // an empty map will be returned // If no filter is provided in the request, the response will contain all the features // currently stored in the default project. ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error) // Retrieve store details given a filter. // // Returns all stores matching that filter. If none are found, an empty list will be returned. // If no filter is provided in the request, the response will contain all the stores currently // stored in the registry. ListStores(context.Context, *ListStoresRequest) (*ListStoresResponse, error) // Create or update and existing entity. // // This function is idempotent - it will not create a new entity if schema does not change. // Schema changes will update the entity if the changes are valid. // Following changes are not valid: // - Changes to name // - Changes to type ApplyEntity(context.Context, *ApplyEntityRequest) (*ApplyEntityResponse, error) // Returns all entity references and respective entities matching that filter. If none are found // an empty map will be returned // If no filter is provided in the request, the response will contain all the entities // currently stored in the default project. ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error) // Updates core with the configuration of the store. // // If the changes are valid, core will return the given store configuration in response, and // start or update the necessary feature population jobs for the updated store. UpdateStore(context.Context, *UpdateStoreRequest) (*UpdateStoreResponse, error) // Creates a project. Projects serve as namespaces within which resources like features will be // created. Feature table names as must be unique within a project while field (Feature/Entity) names // must be unique within a Feature Table. Project names themselves must be globally unique. CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error) // Archives a project. Archived projects will continue to exist and function, but won't be visible // through the Core API. Any existing ingestion or serving requests will continue to function, // but will result in warning messages being logged. It is not possible to unarchive a project // through the Core API ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error) // Lists all projects active projects. ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error) // Create or update an existing feature table. // This function is idempotent - it will not create a new feature table if the schema does not change. // Schema changes will update the feature table if the changes are valid. // All changes except the following are valid: // - Changes to feature table name. // - Changes to entities // - Changes to feature name and type ApplyFeatureTable(context.Context, *ApplyFeatureTableRequest) (*ApplyFeatureTableResponse, error) // List feature tables that match a given filter. // Returns the references of the Feature Tables matching that filter. If none are found, // an empty list will be returned. // If no filter is provided in the request, the response will match all the feature // tables currently stored in the registry. ListFeatureTables(context.Context, *ListFeatureTablesRequest) (*ListFeatureTablesResponse, error) // Returns a specific feature table GetFeatureTable(context.Context, *GetFeatureTableRequest) (*GetFeatureTableResponse, error) // Delete a specific feature table DeleteFeatureTable(context.Context, *DeleteFeatureTableRequest) (*DeleteFeatureTableResponse, error) }
CoreServiceServer is the server API for CoreService service.
type CreateProjectRequest ¶
type CreateProjectRequest struct { // Name of project (required) Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Request to create a project
func (*CreateProjectRequest) Descriptor
deprecated
func (*CreateProjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateProjectRequest.ProtoReflect.Descriptor instead.
func (*CreateProjectRequest) GetName ¶
func (x *CreateProjectRequest) GetName() string
func (*CreateProjectRequest) ProtoMessage ¶
func (*CreateProjectRequest) ProtoMessage()
func (*CreateProjectRequest) ProtoReflect ¶
func (x *CreateProjectRequest) ProtoReflect() protoreflect.Message
func (*CreateProjectRequest) Reset ¶
func (x *CreateProjectRequest) Reset()
func (*CreateProjectRequest) String ¶
func (x *CreateProjectRequest) String() string
type CreateProjectResponse ¶
type CreateProjectResponse struct {
// contains filtered or unexported fields
}
Response for creation of a project
func (*CreateProjectResponse) Descriptor
deprecated
func (*CreateProjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateProjectResponse.ProtoReflect.Descriptor instead.
func (*CreateProjectResponse) ProtoMessage ¶
func (*CreateProjectResponse) ProtoMessage()
func (*CreateProjectResponse) ProtoReflect ¶
func (x *CreateProjectResponse) ProtoReflect() protoreflect.Message
func (*CreateProjectResponse) Reset ¶
func (x *CreateProjectResponse) Reset()
func (*CreateProjectResponse) String ¶
func (x *CreateProjectResponse) String() string
type DataSource ¶ added in v0.8.0
type DataSource struct { Type DataSource_SourceType `protobuf:"varint,1,opt,name=type,proto3,enum=feast.core.DataSource_SourceType" json:"type,omitempty"` // Defines mapping between fields in the sourced data // and fields in parent FeatureTable. FieldMapping map[string]string `` /* 185-byte string literal not displayed */ // Must specify event timestamp column name EventTimestampColumn string `protobuf:"bytes,3,opt,name=event_timestamp_column,json=eventTimestampColumn,proto3" json:"event_timestamp_column,omitempty"` // (Optional) Specify partition column // useful for file sources DatePartitionColumn string `protobuf:"bytes,4,opt,name=date_partition_column,json=datePartitionColumn,proto3" json:"date_partition_column,omitempty"` // Must specify creation timestamp column name CreatedTimestampColumn string `` /* 129-byte string literal not displayed */ // DataSource options. // // Types that are assignable to Options: // *DataSource_FileOptions_ // *DataSource_BigqueryOptions // *DataSource_KafkaOptions_ // *DataSource_KinesisOptions_ Options isDataSource_Options `protobuf_oneof:"options"` // contains filtered or unexported fields }
Defines a Data Source that can be used source Feature data
func (*DataSource) Descriptor
deprecated
added in
v0.8.0
func (*DataSource) Descriptor() ([]byte, []int)
Deprecated: Use DataSource.ProtoReflect.Descriptor instead.
func (*DataSource) GetBigqueryOptions ¶ added in v0.8.0
func (x *DataSource) GetBigqueryOptions() *DataSource_BigQueryOptions
func (*DataSource) GetCreatedTimestampColumn ¶ added in v0.8.0
func (x *DataSource) GetCreatedTimestampColumn() string
func (*DataSource) GetDatePartitionColumn ¶ added in v0.8.0
func (x *DataSource) GetDatePartitionColumn() string
func (*DataSource) GetEventTimestampColumn ¶ added in v0.8.0
func (x *DataSource) GetEventTimestampColumn() string
func (*DataSource) GetFieldMapping ¶ added in v0.8.0
func (x *DataSource) GetFieldMapping() map[string]string
func (*DataSource) GetFileOptions ¶ added in v0.8.0
func (x *DataSource) GetFileOptions() *DataSource_FileOptions
func (*DataSource) GetKafkaOptions ¶ added in v0.8.0
func (x *DataSource) GetKafkaOptions() *DataSource_KafkaOptions
func (*DataSource) GetKinesisOptions ¶ added in v0.8.0
func (x *DataSource) GetKinesisOptions() *DataSource_KinesisOptions
func (*DataSource) GetOptions ¶ added in v0.8.0
func (m *DataSource) GetOptions() isDataSource_Options
func (*DataSource) GetType ¶ added in v0.8.0
func (x *DataSource) GetType() DataSource_SourceType
func (*DataSource) ProtoMessage ¶ added in v0.8.0
func (*DataSource) ProtoMessage()
func (*DataSource) ProtoReflect ¶ added in v0.8.0
func (x *DataSource) ProtoReflect() protoreflect.Message
func (*DataSource) Reset ¶ added in v0.8.0
func (x *DataSource) Reset()
func (*DataSource) String ¶ added in v0.8.0
func (x *DataSource) String() string
type DataSource_BigQueryOptions ¶ added in v0.8.0
type DataSource_BigQueryOptions struct { // Full table reference in the form of [project:dataset.table] TableRef string `protobuf:"bytes,1,opt,name=table_ref,json=tableRef,proto3" json:"table_ref,omitempty"` // contains filtered or unexported fields }
Defines options for DataSource that sources features from a BigQuery Query
func (*DataSource_BigQueryOptions) Descriptor
deprecated
added in
v0.8.0
func (*DataSource_BigQueryOptions) Descriptor() ([]byte, []int)
Deprecated: Use DataSource_BigQueryOptions.ProtoReflect.Descriptor instead.
func (*DataSource_BigQueryOptions) GetTableRef ¶ added in v0.8.0
func (x *DataSource_BigQueryOptions) GetTableRef() string
func (*DataSource_BigQueryOptions) ProtoMessage ¶ added in v0.8.0
func (*DataSource_BigQueryOptions) ProtoMessage()
func (*DataSource_BigQueryOptions) ProtoReflect ¶ added in v0.8.0
func (x *DataSource_BigQueryOptions) ProtoReflect() protoreflect.Message
func (*DataSource_BigQueryOptions) Reset ¶ added in v0.8.0
func (x *DataSource_BigQueryOptions) Reset()
func (*DataSource_BigQueryOptions) String ¶ added in v0.8.0
func (x *DataSource_BigQueryOptions) String() string
type DataSource_BigqueryOptions ¶ added in v0.8.0
type DataSource_BigqueryOptions struct {
BigqueryOptions *DataSource_BigQueryOptions `protobuf:"bytes,12,opt,name=bigquery_options,json=bigqueryOptions,proto3,oneof"`
}
type DataSource_FileOptions ¶ added in v0.8.0
type DataSource_FileOptions struct { FileFormat *FileFormat `protobuf:"bytes,1,opt,name=file_format,json=fileFormat,proto3" json:"file_format,omitempty"` // Target URL of file to retrieve and source features from. // s3://path/to/file for AWS S3 storage // gs://path/to/file for GCP GCS storage // file:///path/to/file for local storage FileUrl string `protobuf:"bytes,2,opt,name=file_url,json=fileUrl,proto3" json:"file_url,omitempty"` // contains filtered or unexported fields }
Defines options for DataSource that sources features from a file
func (*DataSource_FileOptions) Descriptor
deprecated
added in
v0.8.0
func (*DataSource_FileOptions) Descriptor() ([]byte, []int)
Deprecated: Use DataSource_FileOptions.ProtoReflect.Descriptor instead.
func (*DataSource_FileOptions) GetFileFormat ¶ added in v0.8.0
func (x *DataSource_FileOptions) GetFileFormat() *FileFormat
func (*DataSource_FileOptions) GetFileUrl ¶ added in v0.8.0
func (x *DataSource_FileOptions) GetFileUrl() string
func (*DataSource_FileOptions) ProtoMessage ¶ added in v0.8.0
func (*DataSource_FileOptions) ProtoMessage()
func (*DataSource_FileOptions) ProtoReflect ¶ added in v0.8.0
func (x *DataSource_FileOptions) ProtoReflect() protoreflect.Message
func (*DataSource_FileOptions) Reset ¶ added in v0.8.0
func (x *DataSource_FileOptions) Reset()
func (*DataSource_FileOptions) String ¶ added in v0.8.0
func (x *DataSource_FileOptions) String() string
type DataSource_FileOptions_ ¶ added in v0.8.0
type DataSource_FileOptions_ struct {
FileOptions *DataSource_FileOptions `protobuf:"bytes,11,opt,name=file_options,json=fileOptions,proto3,oneof"`
}
type DataSource_KafkaOptions ¶ added in v0.8.0
type DataSource_KafkaOptions struct { // Comma separated list of Kafka bootstrap servers. Used for feature tables without a defined source host[:port]] BootstrapServers string `protobuf:"bytes,1,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"` // Kafka topic to collect feature data from. Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` // Defines the stream data format encoding feature/entity data in Kafka messages. MessageFormat *StreamFormat `protobuf:"bytes,3,opt,name=message_format,json=messageFormat,proto3" json:"message_format,omitempty"` // contains filtered or unexported fields }
Defines options for DataSource that sources features from Kafka messages. Each message should be a Protobuf that can be decoded with the generated Java Protobuf class at the given class path
func (*DataSource_KafkaOptions) Descriptor
deprecated
added in
v0.8.0
func (*DataSource_KafkaOptions) Descriptor() ([]byte, []int)
Deprecated: Use DataSource_KafkaOptions.ProtoReflect.Descriptor instead.
func (*DataSource_KafkaOptions) GetBootstrapServers ¶ added in v0.8.0
func (x *DataSource_KafkaOptions) GetBootstrapServers() string
func (*DataSource_KafkaOptions) GetMessageFormat ¶ added in v0.8.0
func (x *DataSource_KafkaOptions) GetMessageFormat() *StreamFormat
func (*DataSource_KafkaOptions) GetTopic ¶ added in v0.8.0
func (x *DataSource_KafkaOptions) GetTopic() string
func (*DataSource_KafkaOptions) ProtoMessage ¶ added in v0.8.0
func (*DataSource_KafkaOptions) ProtoMessage()
func (*DataSource_KafkaOptions) ProtoReflect ¶ added in v0.8.0
func (x *DataSource_KafkaOptions) ProtoReflect() protoreflect.Message
func (*DataSource_KafkaOptions) Reset ¶ added in v0.8.0
func (x *DataSource_KafkaOptions) Reset()
func (*DataSource_KafkaOptions) String ¶ added in v0.8.0
func (x *DataSource_KafkaOptions) String() string
type DataSource_KafkaOptions_ ¶ added in v0.8.0
type DataSource_KafkaOptions_ struct {
KafkaOptions *DataSource_KafkaOptions `protobuf:"bytes,13,opt,name=kafka_options,json=kafkaOptions,proto3,oneof"`
}
type DataSource_KinesisOptions ¶ added in v0.8.0
type DataSource_KinesisOptions struct { // AWS region of the Kinesis stream Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"` // Name of the Kinesis stream to obtain feature data from. StreamName string `protobuf:"bytes,2,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"` // Defines the data format encoding the feature/entity data in Kinesis records. // Kinesis Data Sources support Avro and Proto as data formats. RecordFormat *StreamFormat `protobuf:"bytes,3,opt,name=record_format,json=recordFormat,proto3" json:"record_format,omitempty"` // contains filtered or unexported fields }
Defines options for DataSource that sources features from Kinesis records. Each record should be a Protobuf that can be decoded with the generated Java Protobuf class at the given class path
func (*DataSource_KinesisOptions) Descriptor
deprecated
added in
v0.8.0
func (*DataSource_KinesisOptions) Descriptor() ([]byte, []int)
Deprecated: Use DataSource_KinesisOptions.ProtoReflect.Descriptor instead.
func (*DataSource_KinesisOptions) GetRecordFormat ¶ added in v0.8.0
func (x *DataSource_KinesisOptions) GetRecordFormat() *StreamFormat
func (*DataSource_KinesisOptions) GetRegion ¶ added in v0.8.0
func (x *DataSource_KinesisOptions) GetRegion() string
func (*DataSource_KinesisOptions) GetStreamName ¶ added in v0.8.0
func (x *DataSource_KinesisOptions) GetStreamName() string
func (*DataSource_KinesisOptions) ProtoMessage ¶ added in v0.8.0
func (*DataSource_KinesisOptions) ProtoMessage()
func (*DataSource_KinesisOptions) ProtoReflect ¶ added in v0.8.0
func (x *DataSource_KinesisOptions) ProtoReflect() protoreflect.Message
func (*DataSource_KinesisOptions) Reset ¶ added in v0.8.0
func (x *DataSource_KinesisOptions) Reset()
func (*DataSource_KinesisOptions) String ¶ added in v0.8.0
func (x *DataSource_KinesisOptions) String() string
type DataSource_KinesisOptions_ ¶ added in v0.8.0
type DataSource_KinesisOptions_ struct {
KinesisOptions *DataSource_KinesisOptions `protobuf:"bytes,14,opt,name=kinesis_options,json=kinesisOptions,proto3,oneof"`
}
type DataSource_SourceType ¶ added in v0.8.0
type DataSource_SourceType int32
Type of Data Source.
const ( DataSource_INVALID DataSource_SourceType = 0 DataSource_BATCH_FILE DataSource_SourceType = 1 DataSource_BATCH_BIGQUERY DataSource_SourceType = 2 DataSource_STREAM_KAFKA DataSource_SourceType = 3 DataSource_STREAM_KINESIS DataSource_SourceType = 4 )
func (DataSource_SourceType) Descriptor ¶ added in v0.8.0
func (DataSource_SourceType) Descriptor() protoreflect.EnumDescriptor
func (DataSource_SourceType) Enum ¶ added in v0.8.0
func (x DataSource_SourceType) Enum() *DataSource_SourceType
func (DataSource_SourceType) EnumDescriptor
deprecated
added in
v0.8.0
func (DataSource_SourceType) EnumDescriptor() ([]byte, []int)
Deprecated: Use DataSource_SourceType.Descriptor instead.
func (DataSource_SourceType) Number ¶ added in v0.8.0
func (x DataSource_SourceType) Number() protoreflect.EnumNumber
func (DataSource_SourceType) String ¶ added in v0.8.0
func (x DataSource_SourceType) String() string
func (DataSource_SourceType) Type ¶ added in v0.8.0
func (DataSource_SourceType) Type() protoreflect.EnumType
type DataflowRunnerConfigOptions ¶
type DataflowRunnerConfigOptions struct { // Project id to use when launching jobs. Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // The Google Compute Engine region for creating Dataflow jobs. Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"` // GCP availability zone for operations. WorkerZone string `protobuf:"bytes,3,opt,name=workerZone,proto3" json:"workerZone,omitempty"` // Run the job as a specific service account, instead of the default GCE robot. ServiceAccount string `protobuf:"bytes,4,opt,name=serviceAccount,proto3" json:"serviceAccount,omitempty"` // GCE network for launching workers. Network string `protobuf:"bytes,5,opt,name=network,proto3" json:"network,omitempty"` // GCE subnetwork for launching workers. e.g. regions/asia-east1/subnetworks/mysubnetwork Subnetwork string `protobuf:"bytes,6,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"` // Machine type to create Dataflow worker VMs as. WorkerMachineType string `protobuf:"bytes,7,opt,name=workerMachineType,proto3" json:"workerMachineType,omitempty"` // The autoscaling algorithm to use for the workerpool. AutoscalingAlgorithm string `protobuf:"bytes,8,opt,name=autoscalingAlgorithm,proto3" json:"autoscalingAlgorithm,omitempty"` // Specifies whether worker pools should be started with public IP addresses. UsePublicIps bool `protobuf:"varint,9,opt,name=usePublicIps,proto3" json:"usePublicIps,omitempty"` // A pipeline level default location for storing temporary files. Support Google Cloud Storage locations, // e.g. gs://bucket/object TempLocation string `protobuf:"bytes,10,opt,name=tempLocation,proto3" json:"tempLocation,omitempty"` // The maximum number of workers to use for the workerpool. MaxNumWorkers int32 `protobuf:"varint,11,opt,name=maxNumWorkers,proto3" json:"maxNumWorkers,omitempty"` // BigQuery table specification, e.g. PROJECT_ID:DATASET_ID.PROJECT_ID DeadLetterTableSpec string `protobuf:"bytes,12,opt,name=deadLetterTableSpec,proto3" json:"deadLetterTableSpec,omitempty"` // Labels to apply to the dataflow job Labels map[string]string `` /* 154-byte string literal not displayed */ // Disk size to use on each remote Compute Engine worker instance DiskSizeGb int32 `protobuf:"varint,14,opt,name=diskSizeGb,proto3" json:"diskSizeGb,omitempty"` // Run job on Dataflow Streaming Engine instead of creating worker VMs EnableStreamingEngine bool `protobuf:"varint,15,opt,name=enableStreamingEngine,proto3" json:"enableStreamingEngine,omitempty"` // Type of persistent disk to be used by workers WorkerDiskType string `protobuf:"bytes,16,opt,name=workerDiskType,proto3" json:"workerDiskType,omitempty"` // Kafka consumer configuration properties KafkaConsumerProperties map[string]string `` /* 188-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DataflowRunnerConfigOptions) Descriptor
deprecated
func (*DataflowRunnerConfigOptions) Descriptor() ([]byte, []int)
Deprecated: Use DataflowRunnerConfigOptions.ProtoReflect.Descriptor instead.
func (*DataflowRunnerConfigOptions) GetAutoscalingAlgorithm ¶
func (x *DataflowRunnerConfigOptions) GetAutoscalingAlgorithm() string
func (*DataflowRunnerConfigOptions) GetDeadLetterTableSpec ¶
func (x *DataflowRunnerConfigOptions) GetDeadLetterTableSpec() string
func (*DataflowRunnerConfigOptions) GetDiskSizeGb ¶ added in v0.8.0
func (x *DataflowRunnerConfigOptions) GetDiskSizeGb() int32
func (*DataflowRunnerConfigOptions) GetEnableStreamingEngine ¶ added in v0.8.0
func (x *DataflowRunnerConfigOptions) GetEnableStreamingEngine() bool
func (*DataflowRunnerConfigOptions) GetKafkaConsumerProperties ¶ added in v0.8.0
func (x *DataflowRunnerConfigOptions) GetKafkaConsumerProperties() map[string]string
func (*DataflowRunnerConfigOptions) GetLabels ¶ added in v0.6.2
func (x *DataflowRunnerConfigOptions) GetLabels() map[string]string
func (*DataflowRunnerConfigOptions) GetMaxNumWorkers ¶
func (x *DataflowRunnerConfigOptions) GetMaxNumWorkers() int32
func (*DataflowRunnerConfigOptions) GetNetwork ¶
func (x *DataflowRunnerConfigOptions) GetNetwork() string
func (*DataflowRunnerConfigOptions) GetProject ¶
func (x *DataflowRunnerConfigOptions) GetProject() string
func (*DataflowRunnerConfigOptions) GetRegion ¶
func (x *DataflowRunnerConfigOptions) GetRegion() string
func (*DataflowRunnerConfigOptions) GetServiceAccount ¶
func (x *DataflowRunnerConfigOptions) GetServiceAccount() string
func (*DataflowRunnerConfigOptions) GetSubnetwork ¶
func (x *DataflowRunnerConfigOptions) GetSubnetwork() string
func (*DataflowRunnerConfigOptions) GetTempLocation ¶
func (x *DataflowRunnerConfigOptions) GetTempLocation() string
func (*DataflowRunnerConfigOptions) GetUsePublicIps ¶
func (x *DataflowRunnerConfigOptions) GetUsePublicIps() bool
func (*DataflowRunnerConfigOptions) GetWorkerDiskType ¶ added in v0.8.0
func (x *DataflowRunnerConfigOptions) GetWorkerDiskType() string
func (*DataflowRunnerConfigOptions) GetWorkerMachineType ¶
func (x *DataflowRunnerConfigOptions) GetWorkerMachineType() string
func (*DataflowRunnerConfigOptions) GetWorkerZone ¶ added in v0.8.0
func (x *DataflowRunnerConfigOptions) GetWorkerZone() string
func (*DataflowRunnerConfigOptions) ProtoMessage ¶
func (*DataflowRunnerConfigOptions) ProtoMessage()
func (*DataflowRunnerConfigOptions) ProtoReflect ¶
func (x *DataflowRunnerConfigOptions) ProtoReflect() protoreflect.Message
func (*DataflowRunnerConfigOptions) Reset ¶
func (x *DataflowRunnerConfigOptions) Reset()
func (*DataflowRunnerConfigOptions) String ¶
func (x *DataflowRunnerConfigOptions) String() string
type DeleteFeatureTableRequest ¶ added in v0.9.0
type DeleteFeatureTableRequest struct { // Optional. Name of the Project to delete the Feature Table from. // If unspecified, will delete FeatureTable from the default project. Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // Name of the FeatureTable to delete. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*DeleteFeatureTableRequest) Descriptor
deprecated
added in
v0.9.0
func (*DeleteFeatureTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteFeatureTableRequest.ProtoReflect.Descriptor instead.
func (*DeleteFeatureTableRequest) GetName ¶ added in v0.9.0
func (x *DeleteFeatureTableRequest) GetName() string
func (*DeleteFeatureTableRequest) GetProject ¶ added in v0.9.0
func (x *DeleteFeatureTableRequest) GetProject() string
func (*DeleteFeatureTableRequest) ProtoMessage ¶ added in v0.9.0
func (*DeleteFeatureTableRequest) ProtoMessage()
func (*DeleteFeatureTableRequest) ProtoReflect ¶ added in v0.9.0
func (x *DeleteFeatureTableRequest) ProtoReflect() protoreflect.Message
func (*DeleteFeatureTableRequest) Reset ¶ added in v0.9.0
func (x *DeleteFeatureTableRequest) Reset()
func (*DeleteFeatureTableRequest) String ¶ added in v0.9.0
func (x *DeleteFeatureTableRequest) String() string
type DeleteFeatureTableResponse ¶ added in v0.9.0
type DeleteFeatureTableResponse struct {
// contains filtered or unexported fields
}
func (*DeleteFeatureTableResponse) Descriptor
deprecated
added in
v0.9.0
func (*DeleteFeatureTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteFeatureTableResponse.ProtoReflect.Descriptor instead.
func (*DeleteFeatureTableResponse) ProtoMessage ¶ added in v0.9.0
func (*DeleteFeatureTableResponse) ProtoMessage()
func (*DeleteFeatureTableResponse) ProtoReflect ¶ added in v0.9.0
func (x *DeleteFeatureTableResponse) ProtoReflect() protoreflect.Message
func (*DeleteFeatureTableResponse) Reset ¶ added in v0.9.0
func (x *DeleteFeatureTableResponse) Reset()
func (*DeleteFeatureTableResponse) String ¶ added in v0.9.0
func (x *DeleteFeatureTableResponse) String() string
type DirectRunnerConfigOptions ¶
type DirectRunnerConfigOptions struct { //* // Controls the amount of target parallelism the DirectRunner will use. // Defaults to the greater of the number of available processors and 3. Must be a value // greater than zero. TargetParallelism int32 `protobuf:"varint,1,opt,name=targetParallelism,proto3" json:"targetParallelism,omitempty"` // BigQuery table specification, e.g. PROJECT_ID:DATASET_ID.PROJECT_ID DeadLetterTableSpec string `protobuf:"bytes,2,opt,name=deadLetterTableSpec,proto3" json:"deadLetterTableSpec,omitempty"` // A pipeline level default location for storing temporary files. // Support Google Cloud Storage locations or local path TempLocation string `protobuf:"bytes,3,opt,name=tempLocation,proto3" json:"tempLocation,omitempty"` // contains filtered or unexported fields }
func (*DirectRunnerConfigOptions) Descriptor
deprecated
func (*DirectRunnerConfigOptions) Descriptor() ([]byte, []int)
Deprecated: Use DirectRunnerConfigOptions.ProtoReflect.Descriptor instead.
func (*DirectRunnerConfigOptions) GetDeadLetterTableSpec ¶
func (x *DirectRunnerConfigOptions) GetDeadLetterTableSpec() string
func (*DirectRunnerConfigOptions) GetTargetParallelism ¶
func (x *DirectRunnerConfigOptions) GetTargetParallelism() int32
func (*DirectRunnerConfigOptions) GetTempLocation ¶ added in v0.6.2
func (x *DirectRunnerConfigOptions) GetTempLocation() string
func (*DirectRunnerConfigOptions) ProtoMessage ¶
func (*DirectRunnerConfigOptions) ProtoMessage()
func (*DirectRunnerConfigOptions) ProtoReflect ¶
func (x *DirectRunnerConfigOptions) ProtoReflect() protoreflect.Message
func (*DirectRunnerConfigOptions) Reset ¶
func (x *DirectRunnerConfigOptions) Reset()
func (*DirectRunnerConfigOptions) String ¶
func (x *DirectRunnerConfigOptions) String() string
type Entity ¶ added in v0.8.0
type Entity struct { // User-specified specifications of this entity. Spec *EntitySpecV2 `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // System-populated metadata for this entity. Meta *EntityMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*Entity) Descriptor
deprecated
added in
v0.8.0
func (*Entity) GetMeta ¶ added in v0.8.0
func (x *Entity) GetMeta() *EntityMeta
func (*Entity) GetSpec ¶ added in v0.8.0
func (x *Entity) GetSpec() *EntitySpecV2
func (*Entity) ProtoMessage ¶ added in v0.8.0
func (*Entity) ProtoMessage()
func (*Entity) ProtoReflect ¶ added in v0.8.0
func (x *Entity) ProtoReflect() protoreflect.Message
type EntityMeta ¶ added in v0.8.0
type EntityMeta struct { CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"` LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"` // contains filtered or unexported fields }
func (*EntityMeta) Descriptor
deprecated
added in
v0.8.0
func (*EntityMeta) Descriptor() ([]byte, []int)
Deprecated: Use EntityMeta.ProtoReflect.Descriptor instead.
func (*EntityMeta) GetCreatedTimestamp ¶ added in v0.8.0
func (x *EntityMeta) GetCreatedTimestamp() *timestamppb.Timestamp
func (*EntityMeta) GetLastUpdatedTimestamp ¶ added in v0.8.0
func (x *EntityMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp
func (*EntityMeta) ProtoMessage ¶ added in v0.8.0
func (*EntityMeta) ProtoMessage()
func (*EntityMeta) ProtoReflect ¶ added in v0.8.0
func (x *EntityMeta) ProtoReflect() protoreflect.Message
func (*EntityMeta) Reset ¶ added in v0.8.0
func (x *EntityMeta) Reset()
func (*EntityMeta) String ¶ added in v0.8.0
func (x *EntityMeta) String() string
type EntitySpec ¶
type EntitySpec struct { // Name of the entity. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Value type of the entity. ValueType types.ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"` // contains filtered or unexported fields }
func (*EntitySpec) Descriptor
deprecated
func (*EntitySpec) Descriptor() ([]byte, []int)
Deprecated: Use EntitySpec.ProtoReflect.Descriptor instead.
func (*EntitySpec) GetName ¶
func (x *EntitySpec) GetName() string
func (*EntitySpec) GetValueType ¶
func (x *EntitySpec) GetValueType() types.ValueType_Enum
func (*EntitySpec) ProtoMessage ¶
func (*EntitySpec) ProtoMessage()
func (*EntitySpec) ProtoReflect ¶
func (x *EntitySpec) ProtoReflect() protoreflect.Message
func (*EntitySpec) Reset ¶
func (x *EntitySpec) Reset()
func (*EntitySpec) String ¶
func (x *EntitySpec) String() string
type EntitySpecV2 ¶ added in v0.8.0
type EntitySpecV2 struct { // Name of the entity. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Type of the entity. ValueType types.ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"` // Description of the entity. Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"` // User defined metadata Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EntitySpecV2) Descriptor
deprecated
added in
v0.8.0
func (*EntitySpecV2) Descriptor() ([]byte, []int)
Deprecated: Use EntitySpecV2.ProtoReflect.Descriptor instead.
func (*EntitySpecV2) GetDescription ¶ added in v0.8.0
func (x *EntitySpecV2) GetDescription() string
func (*EntitySpecV2) GetLabels ¶ added in v0.8.0
func (x *EntitySpecV2) GetLabels() map[string]string
func (*EntitySpecV2) GetName ¶ added in v0.8.0
func (x *EntitySpecV2) GetName() string
func (*EntitySpecV2) GetValueType ¶ added in v0.8.0
func (x *EntitySpecV2) GetValueType() types.ValueType_Enum
func (*EntitySpecV2) ProtoMessage ¶ added in v0.8.0
func (*EntitySpecV2) ProtoMessage()
func (*EntitySpecV2) ProtoReflect ¶ added in v0.8.0
func (x *EntitySpecV2) ProtoReflect() protoreflect.Message
func (*EntitySpecV2) Reset ¶ added in v0.8.0
func (x *EntitySpecV2) Reset()
func (*EntitySpecV2) String ¶ added in v0.8.0
func (x *EntitySpecV2) String() string
type FeatureSet ¶
type FeatureSet struct { // User-specified specifications of this feature set. Spec *FeatureSetSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // System-populated metadata for this feature set. Meta *FeatureSetMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*FeatureSet) Descriptor
deprecated
func (*FeatureSet) Descriptor() ([]byte, []int)
Deprecated: Use FeatureSet.ProtoReflect.Descriptor instead.
func (*FeatureSet) GetMeta ¶
func (x *FeatureSet) GetMeta() *FeatureSetMeta
func (*FeatureSet) GetSpec ¶
func (x *FeatureSet) GetSpec() *FeatureSetSpec
func (*FeatureSet) ProtoMessage ¶
func (*FeatureSet) ProtoMessage()
func (*FeatureSet) ProtoReflect ¶
func (x *FeatureSet) ProtoReflect() protoreflect.Message
func (*FeatureSet) Reset ¶
func (x *FeatureSet) Reset()
func (*FeatureSet) String ¶
func (x *FeatureSet) String() string
type FeatureSetJobDeliveryStatus ¶ added in v0.6.2
type FeatureSetJobDeliveryStatus int32
const ( FeatureSetJobDeliveryStatus_STATUS_IN_PROGRESS FeatureSetJobDeliveryStatus = 0 FeatureSetJobDeliveryStatus_STATUS_DELIVERED FeatureSetJobDeliveryStatus = 1 )
func (FeatureSetJobDeliveryStatus) Descriptor ¶ added in v0.6.2
func (FeatureSetJobDeliveryStatus) Descriptor() protoreflect.EnumDescriptor
func (FeatureSetJobDeliveryStatus) Enum ¶ added in v0.6.2
func (x FeatureSetJobDeliveryStatus) Enum() *FeatureSetJobDeliveryStatus
func (FeatureSetJobDeliveryStatus) EnumDescriptor
deprecated
added in
v0.6.2
func (FeatureSetJobDeliveryStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use FeatureSetJobDeliveryStatus.Descriptor instead.
func (FeatureSetJobDeliveryStatus) Number ¶ added in v0.6.2
func (x FeatureSetJobDeliveryStatus) Number() protoreflect.EnumNumber
func (FeatureSetJobDeliveryStatus) String ¶ added in v0.6.2
func (x FeatureSetJobDeliveryStatus) String() string
func (FeatureSetJobDeliveryStatus) Type ¶ added in v0.6.2
func (FeatureSetJobDeliveryStatus) Type() protoreflect.EnumType
type FeatureSetMeta ¶
type FeatureSetMeta struct { // Created timestamp of this specific feature set. CreatedTimestamp *timestamp.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"` // Status of the feature set. // Used to indicate whether the feature set is ready for consumption or ingestion. // Currently supports 2 states: // 1) STATUS_PENDING - A feature set is in pending state if Feast has not spun up the jobs // necessary to push rows for this feature set to stores subscribing to this feature set. // 2) STATUS_READY - Feature set is ready for consumption or ingestion Status FeatureSetStatus `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.FeatureSetStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*FeatureSetMeta) Descriptor
deprecated
func (*FeatureSetMeta) Descriptor() ([]byte, []int)
Deprecated: Use FeatureSetMeta.ProtoReflect.Descriptor instead.
func (*FeatureSetMeta) GetCreatedTimestamp ¶
func (x *FeatureSetMeta) GetCreatedTimestamp() *timestamp.Timestamp
func (*FeatureSetMeta) GetStatus ¶
func (x *FeatureSetMeta) GetStatus() FeatureSetStatus
func (*FeatureSetMeta) ProtoMessage ¶
func (*FeatureSetMeta) ProtoMessage()
func (*FeatureSetMeta) ProtoReflect ¶
func (x *FeatureSetMeta) ProtoReflect() protoreflect.Message
func (*FeatureSetMeta) Reset ¶
func (x *FeatureSetMeta) Reset()
func (*FeatureSetMeta) String ¶
func (x *FeatureSetMeta) String() string
type FeatureSetReference ¶
type FeatureSetReference struct { // Name of the project Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // Name of the FeatureSet Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
Defines a composite key that refers to a unique FeatureSet
func (*FeatureSetReference) Descriptor
deprecated
func (*FeatureSetReference) Descriptor() ([]byte, []int)
Deprecated: Use FeatureSetReference.ProtoReflect.Descriptor instead.
func (*FeatureSetReference) GetName ¶
func (x *FeatureSetReference) GetName() string
func (*FeatureSetReference) GetProject ¶
func (x *FeatureSetReference) GetProject() string
func (*FeatureSetReference) ProtoMessage ¶
func (*FeatureSetReference) ProtoMessage()
func (*FeatureSetReference) ProtoReflect ¶
func (x *FeatureSetReference) ProtoReflect() protoreflect.Message
func (*FeatureSetReference) Reset ¶
func (x *FeatureSetReference) Reset()
func (*FeatureSetReference) String ¶
func (x *FeatureSetReference) String() string
type FeatureSetSpec ¶
type FeatureSetSpec struct { // Name of project that this feature set belongs to. Project string `protobuf:"bytes,7,opt,name=project,proto3" json:"project,omitempty"` // Name of the feature set. Must be unique. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // List of entities contained within this featureSet. // This allows the feature to be used during joins between feature sets. // If the featureSet is ingested into a store that supports keys, this value // will be made a key. Entities []*EntitySpec `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"` // List of features contained within this featureSet. Features []*FeatureSpec `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"` // Features in this feature set will only be retrieved if they are found // after [time - max_age]. Missing or older feature values will be returned // as nulls and indicated to end user MaxAge *duration.Duration `protobuf:"bytes,5,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"` // Optional. Source on which feature rows can be found. // If not set, source will be set to the default value configured in Feast Core. Source *Source `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"` // User defined metadata Labels map[string]string `` /* 153-byte string literal not displayed */ // Read-only self-incrementing version that increases monotonically // when changes are made to a feature set Version int32 `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*FeatureSetSpec) Descriptor
deprecated
func (*FeatureSetSpec) Descriptor() ([]byte, []int)
Deprecated: Use FeatureSetSpec.ProtoReflect.Descriptor instead.
func (*FeatureSetSpec) GetEntities ¶
func (x *FeatureSetSpec) GetEntities() []*EntitySpec
func (*FeatureSetSpec) GetFeatures ¶
func (x *FeatureSetSpec) GetFeatures() []*FeatureSpec
func (*FeatureSetSpec) GetLabels ¶
func (x *FeatureSetSpec) GetLabels() map[string]string
func (*FeatureSetSpec) GetMaxAge ¶
func (x *FeatureSetSpec) GetMaxAge() *duration.Duration
func (*FeatureSetSpec) GetName ¶
func (x *FeatureSetSpec) GetName() string
func (*FeatureSetSpec) GetProject ¶
func (x *FeatureSetSpec) GetProject() string
func (*FeatureSetSpec) GetSource ¶
func (x *FeatureSetSpec) GetSource() *Source
func (*FeatureSetSpec) GetVersion ¶ added in v0.6.2
func (x *FeatureSetSpec) GetVersion() int32
func (*FeatureSetSpec) ProtoMessage ¶
func (*FeatureSetSpec) ProtoMessage()
func (*FeatureSetSpec) ProtoReflect ¶
func (x *FeatureSetSpec) ProtoReflect() protoreflect.Message
func (*FeatureSetSpec) Reset ¶
func (x *FeatureSetSpec) Reset()
func (*FeatureSetSpec) String ¶
func (x *FeatureSetSpec) String() string
type FeatureSetSpecAck ¶ added in v0.6.2
type FeatureSetSpecAck struct { FeatureSetReference string `protobuf:"bytes,1,opt,name=feature_set_reference,json=featureSetReference,proto3" json:"feature_set_reference,omitempty"` FeatureSetVersion int32 `protobuf:"varint,2,opt,name=feature_set_version,json=featureSetVersion,proto3" json:"feature_set_version,omitempty"` JobName string `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"` // contains filtered or unexported fields }
func (*FeatureSetSpecAck) Descriptor
deprecated
added in
v0.6.2
func (*FeatureSetSpecAck) Descriptor() ([]byte, []int)
Deprecated: Use FeatureSetSpecAck.ProtoReflect.Descriptor instead.
func (*FeatureSetSpecAck) GetFeatureSetReference ¶ added in v0.6.2
func (x *FeatureSetSpecAck) GetFeatureSetReference() string
func (*FeatureSetSpecAck) GetFeatureSetVersion ¶ added in v0.6.2
func (x *FeatureSetSpecAck) GetFeatureSetVersion() int32
func (*FeatureSetSpecAck) GetJobName ¶ added in v0.6.2
func (x *FeatureSetSpecAck) GetJobName() string
func (*FeatureSetSpecAck) ProtoMessage ¶ added in v0.6.2
func (*FeatureSetSpecAck) ProtoMessage()
func (*FeatureSetSpecAck) ProtoReflect ¶ added in v0.6.2
func (x *FeatureSetSpecAck) ProtoReflect() protoreflect.Message
func (*FeatureSetSpecAck) Reset ¶ added in v0.6.2
func (x *FeatureSetSpecAck) Reset()
func (*FeatureSetSpecAck) String ¶ added in v0.6.2
func (x *FeatureSetSpecAck) String() string
type FeatureSetStatus ¶
type FeatureSetStatus int32
const ( FeatureSetStatus_STATUS_INVALID FeatureSetStatus = 0 FeatureSetStatus_STATUS_PENDING FeatureSetStatus = 1 FeatureSetStatus_STATUS_JOB_STARTING FeatureSetStatus = 3 FeatureSetStatus_STATUS_READY FeatureSetStatus = 2 )
func (FeatureSetStatus) Descriptor ¶
func (FeatureSetStatus) Descriptor() protoreflect.EnumDescriptor
func (FeatureSetStatus) Enum ¶
func (x FeatureSetStatus) Enum() *FeatureSetStatus
func (FeatureSetStatus) EnumDescriptor
deprecated
func (FeatureSetStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use FeatureSetStatus.Descriptor instead.
func (FeatureSetStatus) Number ¶
func (x FeatureSetStatus) Number() protoreflect.EnumNumber
func (FeatureSetStatus) String ¶
func (x FeatureSetStatus) String() string
func (FeatureSetStatus) Type ¶
func (FeatureSetStatus) Type() protoreflect.EnumType
type FeatureSpec ¶
type FeatureSpec struct { // Name of the feature. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Value type of the feature. ValueType types.ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"` // Labels for user defined metadata on a feature Labels map[string]string `` /* 154-byte string literal not displayed */ // Types that are assignable to PresenceConstraints: // *FeatureSpec_Presence // *FeatureSpec_GroupPresence PresenceConstraints isFeatureSpec_PresenceConstraints `protobuf_oneof:"presence_constraints"` // The shape of the feature which governs the number of values that appear in // each example. // // Types that are assignable to ShapeType: // *FeatureSpec_Shape // *FeatureSpec_ValueCount ShapeType isFeatureSpec_ShapeType `protobuf_oneof:"shape_type"` // Domain for the values of the feature. // // Types that are assignable to DomainInfo: // *FeatureSpec_Domain // *FeatureSpec_IntDomain // *FeatureSpec_FloatDomain // *FeatureSpec_StringDomain // *FeatureSpec_BoolDomain // *FeatureSpec_StructDomain // *FeatureSpec_NaturalLanguageDomain // *FeatureSpec_ImageDomain // *FeatureSpec_MidDomain // *FeatureSpec_UrlDomain // *FeatureSpec_TimeDomain // *FeatureSpec_TimeOfDayDomain DomainInfo isFeatureSpec_DomainInfo `protobuf_oneof:"domain_info"` // contains filtered or unexported fields }
func (*FeatureSpec) Descriptor
deprecated
func (*FeatureSpec) Descriptor() ([]byte, []int)
Deprecated: Use FeatureSpec.ProtoReflect.Descriptor instead.
func (*FeatureSpec) GetBoolDomain ¶
func (x *FeatureSpec) GetBoolDomain() *v0.BoolDomain
func (*FeatureSpec) GetDomain ¶
func (x *FeatureSpec) GetDomain() string
func (*FeatureSpec) GetDomainInfo ¶
func (m *FeatureSpec) GetDomainInfo() isFeatureSpec_DomainInfo
func (*FeatureSpec) GetFloatDomain ¶
func (x *FeatureSpec) GetFloatDomain() *v0.FloatDomain
func (*FeatureSpec) GetGroupPresence ¶
func (x *FeatureSpec) GetGroupPresence() *v0.FeaturePresenceWithinGroup
func (*FeatureSpec) GetImageDomain ¶
func (x *FeatureSpec) GetImageDomain() *v0.ImageDomain
func (*FeatureSpec) GetIntDomain ¶
func (x *FeatureSpec) GetIntDomain() *v0.IntDomain
func (*FeatureSpec) GetLabels ¶
func (x *FeatureSpec) GetLabels() map[string]string
func (*FeatureSpec) GetMidDomain ¶
func (x *FeatureSpec) GetMidDomain() *v0.MIDDomain
func (*FeatureSpec) GetName ¶
func (x *FeatureSpec) GetName() string
func (*FeatureSpec) GetNaturalLanguageDomain ¶
func (x *FeatureSpec) GetNaturalLanguageDomain() *v0.NaturalLanguageDomain
func (*FeatureSpec) GetPresence ¶
func (x *FeatureSpec) GetPresence() *v0.FeaturePresence
func (*FeatureSpec) GetPresenceConstraints ¶
func (m *FeatureSpec) GetPresenceConstraints() isFeatureSpec_PresenceConstraints
func (*FeatureSpec) GetShape ¶
func (x *FeatureSpec) GetShape() *v0.FixedShape
func (*FeatureSpec) GetShapeType ¶
func (m *FeatureSpec) GetShapeType() isFeatureSpec_ShapeType
func (*FeatureSpec) GetStringDomain ¶
func (x *FeatureSpec) GetStringDomain() *v0.StringDomain
func (*FeatureSpec) GetStructDomain ¶
func (x *FeatureSpec) GetStructDomain() *v0.StructDomain
func (*FeatureSpec) GetTimeDomain ¶
func (x *FeatureSpec) GetTimeDomain() *v0.TimeDomain
func (*FeatureSpec) GetTimeOfDayDomain ¶
func (x *FeatureSpec) GetTimeOfDayDomain() *v0.TimeOfDayDomain
func (*FeatureSpec) GetUrlDomain ¶
func (x *FeatureSpec) GetUrlDomain() *v0.URLDomain
func (*FeatureSpec) GetValueCount ¶
func (x *FeatureSpec) GetValueCount() *v0.ValueCount
func (*FeatureSpec) GetValueType ¶
func (x *FeatureSpec) GetValueType() types.ValueType_Enum
func (*FeatureSpec) ProtoMessage ¶
func (*FeatureSpec) ProtoMessage()
func (*FeatureSpec) ProtoReflect ¶
func (x *FeatureSpec) ProtoReflect() protoreflect.Message
func (*FeatureSpec) Reset ¶
func (x *FeatureSpec) Reset()
func (*FeatureSpec) String ¶
func (x *FeatureSpec) String() string
type FeatureSpecV2 ¶ added in v0.8.0
type FeatureSpecV2 struct { // Name of the feature. Not updatable. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Value type of the feature. Not updatable. ValueType types.ValueType_Enum `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=feast.types.ValueType_Enum" json:"value_type,omitempty"` // Labels for user defined metadata on a feature Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*FeatureSpecV2) Descriptor
deprecated
added in
v0.8.0
func (*FeatureSpecV2) Descriptor() ([]byte, []int)
Deprecated: Use FeatureSpecV2.ProtoReflect.Descriptor instead.
func (*FeatureSpecV2) GetLabels ¶ added in v0.8.0
func (x *FeatureSpecV2) GetLabels() map[string]string
func (*FeatureSpecV2) GetName ¶ added in v0.8.0
func (x *FeatureSpecV2) GetName() string
func (*FeatureSpecV2) GetValueType ¶ added in v0.8.0
func (x *FeatureSpecV2) GetValueType() types.ValueType_Enum
func (*FeatureSpecV2) ProtoMessage ¶ added in v0.8.0
func (*FeatureSpecV2) ProtoMessage()
func (*FeatureSpecV2) ProtoReflect ¶ added in v0.8.0
func (x *FeatureSpecV2) ProtoReflect() protoreflect.Message
func (*FeatureSpecV2) Reset ¶ added in v0.8.0
func (x *FeatureSpecV2) Reset()
func (*FeatureSpecV2) String ¶ added in v0.8.0
func (x *FeatureSpecV2) String() string
type FeatureSpec_BoolDomain ¶
type FeatureSpec_BoolDomain struct {
BoolDomain *v0.BoolDomain `protobuf:"bytes,38,opt,name=bool_domain,json=boolDomain,proto3,oneof"`
}
type FeatureSpec_Domain ¶
type FeatureSpec_Domain struct { // Reference to a domain defined at the schema level. Domain string `protobuf:"bytes,34,opt,name=domain,proto3,oneof"` }
type FeatureSpec_FloatDomain ¶
type FeatureSpec_FloatDomain struct {
FloatDomain *v0.FloatDomain `protobuf:"bytes,36,opt,name=float_domain,json=floatDomain,proto3,oneof"`
}
type FeatureSpec_GroupPresence ¶
type FeatureSpec_GroupPresence struct { // Only used in the context of a "group" context, e.g., inside a sequence. GroupPresence *v0.FeaturePresenceWithinGroup `protobuf:"bytes,31,opt,name=group_presence,json=groupPresence,proto3,oneof"` }
type FeatureSpec_ImageDomain ¶
type FeatureSpec_ImageDomain struct {
ImageDomain *v0.ImageDomain `protobuf:"bytes,41,opt,name=image_domain,json=imageDomain,proto3,oneof"`
}
type FeatureSpec_IntDomain ¶
type FeatureSpec_MidDomain ¶
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_ValueCount ¶
type FeatureSpec_ValueCount struct { // The feature doesn't have a well defined shape. All we know are limits on // the minimum and maximum number of values. ValueCount *v0.ValueCount `protobuf:"bytes,33,opt,name=value_count,json=valueCount,proto3,oneof"` }
type FeatureTable ¶ added in v0.8.0
type FeatureTable struct { // User-specified specifications of this feature table. Spec *FeatureTableSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // System-populated metadata for this feature table. Meta *FeatureTableMeta `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*FeatureTable) Descriptor
deprecated
added in
v0.8.0
func (*FeatureTable) Descriptor() ([]byte, []int)
Deprecated: Use FeatureTable.ProtoReflect.Descriptor instead.
func (*FeatureTable) GetMeta ¶ added in v0.8.0
func (x *FeatureTable) GetMeta() *FeatureTableMeta
func (*FeatureTable) GetSpec ¶ added in v0.8.0
func (x *FeatureTable) GetSpec() *FeatureTableSpec
func (*FeatureTable) ProtoMessage ¶ added in v0.8.0
func (*FeatureTable) ProtoMessage()
func (*FeatureTable) ProtoReflect ¶ added in v0.8.0
func (x *FeatureTable) ProtoReflect() protoreflect.Message
func (*FeatureTable) Reset ¶ added in v0.8.0
func (x *FeatureTable) Reset()
func (*FeatureTable) String ¶ added in v0.8.0
func (x *FeatureTable) String() string
type FeatureTableMeta ¶ added in v0.8.0
type FeatureTableMeta struct { // Time where this Feature Table is created CreatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_timestamp,json=createdTimestamp,proto3" json:"created_timestamp,omitempty"` // Time where this Feature Table is last updated LastUpdatedTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated_timestamp,json=lastUpdatedTimestamp,proto3" json:"last_updated_timestamp,omitempty"` // Auto incrementing revision no. of this Feature Table Revision int64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"` // Hash entities, features, batch_source and stream_source to inform JobService if // jobs should be restarted should hash change Hash string `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*FeatureTableMeta) Descriptor
deprecated
added in
v0.8.0
func (*FeatureTableMeta) Descriptor() ([]byte, []int)
Deprecated: Use FeatureTableMeta.ProtoReflect.Descriptor instead.
func (*FeatureTableMeta) GetCreatedTimestamp ¶ added in v0.8.0
func (x *FeatureTableMeta) GetCreatedTimestamp() *timestamppb.Timestamp
func (*FeatureTableMeta) GetHash ¶ added in v0.9.0
func (x *FeatureTableMeta) GetHash() string
func (*FeatureTableMeta) GetLastUpdatedTimestamp ¶ added in v0.8.0
func (x *FeatureTableMeta) GetLastUpdatedTimestamp() *timestamppb.Timestamp
func (*FeatureTableMeta) GetRevision ¶ added in v0.8.0
func (x *FeatureTableMeta) GetRevision() int64
func (*FeatureTableMeta) ProtoMessage ¶ added in v0.8.0
func (*FeatureTableMeta) ProtoMessage()
func (*FeatureTableMeta) ProtoReflect ¶ added in v0.8.0
func (x *FeatureTableMeta) ProtoReflect() protoreflect.Message
func (*FeatureTableMeta) Reset ¶ added in v0.8.0
func (x *FeatureTableMeta) Reset()
func (*FeatureTableMeta) String ¶ added in v0.8.0
func (x *FeatureTableMeta) String() string
type FeatureTableSpec ¶ added in v0.8.0
type FeatureTableSpec struct { // Name of the feature table. Must be unique. Not updated. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // List names of entities to associate with the Features defined in this // Feature Table. Not updatable. Entities []string `protobuf:"bytes,3,rep,name=entities,proto3" json:"entities,omitempty"` // List of features specifications for each feature defined with this feature table. Features []*FeatureSpecV2 `protobuf:"bytes,4,rep,name=features,proto3" json:"features,omitempty"` // User defined metadata Labels map[string]string `` /* 153-byte string literal not displayed */ // Features in this feature table can only be retrieved from online serving // younger than max age. Age is measured as the duration of time between // the feature's event timestamp and when the feature is retrieved // Feature values outside max age will be returned as unset values and indicated to end user MaxAge *durationpb.Duration `protobuf:"bytes,6,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"` // Batch/Offline DataSource to source batch/offline feature data. // Only batch DataSource can be specified // (ie source type should start with 'BATCH_') BatchSource *DataSource `protobuf:"bytes,7,opt,name=batch_source,json=batchSource,proto3" json:"batch_source,omitempty"` // Stream/Online DataSource to source stream/online feature data. // Only stream DataSource can be specified // (ie source type should start with 'STREAM_') StreamSource *DataSource `protobuf:"bytes,8,opt,name=stream_source,json=streamSource,proto3" json:"stream_source,omitempty"` // contains filtered or unexported fields }
func (*FeatureTableSpec) Descriptor
deprecated
added in
v0.8.0
func (*FeatureTableSpec) Descriptor() ([]byte, []int)
Deprecated: Use FeatureTableSpec.ProtoReflect.Descriptor instead.
func (*FeatureTableSpec) GetBatchSource ¶ added in v0.8.0
func (x *FeatureTableSpec) GetBatchSource() *DataSource
func (*FeatureTableSpec) GetEntities ¶ added in v0.8.0
func (x *FeatureTableSpec) GetEntities() []string
func (*FeatureTableSpec) GetFeatures ¶ added in v0.8.0
func (x *FeatureTableSpec) GetFeatures() []*FeatureSpecV2
func (*FeatureTableSpec) GetLabels ¶ added in v0.8.0
func (x *FeatureTableSpec) GetLabels() map[string]string
func (*FeatureTableSpec) GetMaxAge ¶ added in v0.8.0
func (x *FeatureTableSpec) GetMaxAge() *durationpb.Duration
func (*FeatureTableSpec) GetName ¶ added in v0.8.0
func (x *FeatureTableSpec) GetName() string
func (*FeatureTableSpec) GetStreamSource ¶ added in v0.8.0
func (x *FeatureTableSpec) GetStreamSource() *DataSource
func (*FeatureTableSpec) ProtoMessage ¶ added in v0.8.0
func (*FeatureTableSpec) ProtoMessage()
func (*FeatureTableSpec) ProtoReflect ¶ added in v0.8.0
func (x *FeatureTableSpec) ProtoReflect() protoreflect.Message
func (*FeatureTableSpec) Reset ¶ added in v0.8.0
func (x *FeatureTableSpec) Reset()
func (*FeatureTableSpec) String ¶ added in v0.8.0
func (x *FeatureTableSpec) String() string
type FileFormat ¶ added in v0.8.0
type FileFormat struct { // Types that are assignable to Format: // *FileFormat_ParquetFormat_ Format isFileFormat_Format `protobuf_oneof:"format"` // contains filtered or unexported fields }
Defines the file format encoding the features/entity data in files
func (*FileFormat) Descriptor
deprecated
added in
v0.8.0
func (*FileFormat) Descriptor() ([]byte, []int)
Deprecated: Use FileFormat.ProtoReflect.Descriptor instead.
func (*FileFormat) GetFormat ¶ added in v0.8.0
func (m *FileFormat) GetFormat() isFileFormat_Format
func (*FileFormat) GetParquetFormat ¶ added in v0.8.0
func (x *FileFormat) GetParquetFormat() *FileFormat_ParquetFormat
func (*FileFormat) ProtoMessage ¶ added in v0.8.0
func (*FileFormat) ProtoMessage()
func (*FileFormat) ProtoReflect ¶ added in v0.8.0
func (x *FileFormat) ProtoReflect() protoreflect.Message
func (*FileFormat) Reset ¶ added in v0.8.0
func (x *FileFormat) Reset()
func (*FileFormat) String ¶ added in v0.8.0
func (x *FileFormat) String() string
type FileFormat_ParquetFormat ¶ added in v0.8.0
type FileFormat_ParquetFormat struct {
// contains filtered or unexported fields
}
Defines options for the Parquet data format
func (*FileFormat_ParquetFormat) Descriptor
deprecated
added in
v0.8.0
func (*FileFormat_ParquetFormat) Descriptor() ([]byte, []int)
Deprecated: Use FileFormat_ParquetFormat.ProtoReflect.Descriptor instead.
func (*FileFormat_ParquetFormat) ProtoMessage ¶ added in v0.8.0
func (*FileFormat_ParquetFormat) ProtoMessage()
func (*FileFormat_ParquetFormat) ProtoReflect ¶ added in v0.8.0
func (x *FileFormat_ParquetFormat) ProtoReflect() protoreflect.Message
func (*FileFormat_ParquetFormat) Reset ¶ added in v0.8.0
func (x *FileFormat_ParquetFormat) Reset()
func (*FileFormat_ParquetFormat) String ¶ added in v0.8.0
func (x *FileFormat_ParquetFormat) String() string
type FileFormat_ParquetFormat_ ¶ added in v0.8.0
type FileFormat_ParquetFormat_ struct {
ParquetFormat *FileFormat_ParquetFormat `protobuf:"bytes,1,opt,name=parquet_format,json=parquetFormat,proto3,oneof"`
}
type GetEntityRequest ¶ added in v0.8.0
type GetEntityRequest struct { // Name of entity (required). Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of project the entity belongs to. If omitted will default to 'default' project. Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"` // contains filtered or unexported fields }
Request for a single entity
func (*GetEntityRequest) Descriptor
deprecated
added in
v0.8.0
func (*GetEntityRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityRequest.ProtoReflect.Descriptor instead.
func (*GetEntityRequest) GetName ¶ added in v0.8.0
func (x *GetEntityRequest) GetName() string
func (*GetEntityRequest) GetProject ¶ added in v0.8.0
func (x *GetEntityRequest) GetProject() string
func (*GetEntityRequest) ProtoMessage ¶ added in v0.8.0
func (*GetEntityRequest) ProtoMessage()
func (*GetEntityRequest) ProtoReflect ¶ added in v0.8.0
func (x *GetEntityRequest) ProtoReflect() protoreflect.Message
func (*GetEntityRequest) Reset ¶ added in v0.8.0
func (x *GetEntityRequest) Reset()
func (*GetEntityRequest) String ¶ added in v0.8.0
func (x *GetEntityRequest) String() string
type GetEntityResponse ¶ added in v0.8.0
type GetEntityResponse struct { Entity *Entity `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity,omitempty"` // contains filtered or unexported fields }
Response containing a single entity
func (*GetEntityResponse) Descriptor
deprecated
added in
v0.8.0
func (*GetEntityResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityResponse.ProtoReflect.Descriptor instead.
func (*GetEntityResponse) GetEntity ¶ added in v0.8.0
func (x *GetEntityResponse) GetEntity() *Entity
func (*GetEntityResponse) ProtoMessage ¶ added in v0.8.0
func (*GetEntityResponse) ProtoMessage()
func (*GetEntityResponse) ProtoReflect ¶ added in v0.8.0
func (x *GetEntityResponse) ProtoReflect() protoreflect.Message
func (*GetEntityResponse) Reset ¶ added in v0.8.0
func (x *GetEntityResponse) Reset()
func (*GetEntityResponse) String ¶ added in v0.8.0
func (x *GetEntityResponse) String() string
type GetFeastCoreVersionRequest ¶
type GetFeastCoreVersionRequest struct {
// contains filtered or unexported fields
}
func (*GetFeastCoreVersionRequest) Descriptor
deprecated
func (*GetFeastCoreVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetFeastCoreVersionRequest.ProtoReflect.Descriptor instead.
func (*GetFeastCoreVersionRequest) ProtoMessage ¶
func (*GetFeastCoreVersionRequest) ProtoMessage()
func (*GetFeastCoreVersionRequest) ProtoReflect ¶
func (x *GetFeastCoreVersionRequest) ProtoReflect() protoreflect.Message
func (*GetFeastCoreVersionRequest) Reset ¶
func (x *GetFeastCoreVersionRequest) Reset()
func (*GetFeastCoreVersionRequest) String ¶
func (x *GetFeastCoreVersionRequest) String() string
type GetFeastCoreVersionResponse ¶
type GetFeastCoreVersionResponse struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*GetFeastCoreVersionResponse) Descriptor
deprecated
func (*GetFeastCoreVersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetFeastCoreVersionResponse.ProtoReflect.Descriptor instead.
func (*GetFeastCoreVersionResponse) GetVersion ¶
func (x *GetFeastCoreVersionResponse) GetVersion() string
func (*GetFeastCoreVersionResponse) ProtoMessage ¶
func (*GetFeastCoreVersionResponse) ProtoMessage()
func (*GetFeastCoreVersionResponse) ProtoReflect ¶
func (x *GetFeastCoreVersionResponse) ProtoReflect() protoreflect.Message
func (*GetFeastCoreVersionResponse) Reset ¶
func (x *GetFeastCoreVersionResponse) Reset()
func (*GetFeastCoreVersionResponse) String ¶
func (x *GetFeastCoreVersionResponse) String() string
type GetFeatureTableRequest ¶ added in v0.8.0
type GetFeatureTableRequest struct { // Optional. Name of the Project to retrieve the Feature Table from. // If unspecified, will apply FeatureTable to the default project. Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // Name of the FeatureTable to retrieve. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetFeatureTableRequest) Descriptor
deprecated
added in
v0.8.0
func (*GetFeatureTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetFeatureTableRequest.ProtoReflect.Descriptor instead.
func (*GetFeatureTableRequest) GetName ¶ added in v0.8.0
func (x *GetFeatureTableRequest) GetName() string
func (*GetFeatureTableRequest) GetProject ¶ added in v0.8.0
func (x *GetFeatureTableRequest) GetProject() string
func (*GetFeatureTableRequest) ProtoMessage ¶ added in v0.8.0
func (*GetFeatureTableRequest) ProtoMessage()
func (*GetFeatureTableRequest) ProtoReflect ¶ added in v0.8.0
func (x *GetFeatureTableRequest) ProtoReflect() protoreflect.Message
func (*GetFeatureTableRequest) Reset ¶ added in v0.8.0
func (x *GetFeatureTableRequest) Reset()
func (*GetFeatureTableRequest) String ¶ added in v0.8.0
func (x *GetFeatureTableRequest) String() string
type GetFeatureTableResponse ¶ added in v0.8.0
type GetFeatureTableResponse struct { // The Feature Table retrieved. Table *FeatureTable `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` // contains filtered or unexported fields }
func (*GetFeatureTableResponse) Descriptor
deprecated
added in
v0.8.0
func (*GetFeatureTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetFeatureTableResponse.ProtoReflect.Descriptor instead.
func (*GetFeatureTableResponse) GetTable ¶ added in v0.8.0
func (x *GetFeatureTableResponse) GetTable() *FeatureTable
func (*GetFeatureTableResponse) ProtoMessage ¶ added in v0.8.0
func (*GetFeatureTableResponse) ProtoMessage()
func (*GetFeatureTableResponse) ProtoReflect ¶ added in v0.8.0
func (x *GetFeatureTableResponse) ProtoReflect() protoreflect.Message
func (*GetFeatureTableResponse) Reset ¶ added in v0.8.0
func (x *GetFeatureTableResponse) Reset()
func (*GetFeatureTableResponse) String ¶ added in v0.8.0
func (x *GetFeatureTableResponse) String() string
type GetHistoricalFeaturesRequest ¶ added in v0.9.0
type GetHistoricalFeaturesRequest struct { // List of feature references that are being retrieved FeatureRefs []string `protobuf:"bytes,1,rep,name=feature_refs,json=featureRefs,proto3" json:"feature_refs,omitempty"` // Batch DataSource that can be used to obtain entity values for historical retrieval. // For each entity value, a feature value will be retrieved for that value/timestamp // Only 'BATCH_*' source types are supported. // Currently only BATCH_FILE source type is supported. EntitySource *DataSource `protobuf:"bytes,2,opt,name=entity_source,json=entitySource,proto3" json:"entity_source,omitempty"` // Optional field to specify project name override. If specified, uses the // given project for retrieval. Overrides the projects specified in // Feature References if both are specified. Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"` // Specifies the path in a bucket to write the exported feature data files // Export to AWS S3 - s3://path/to/features // Export to GCP GCS - gs://path/to/features OutputLocation string `protobuf:"bytes,4,opt,name=output_location,json=outputLocation,proto3" json:"output_location,omitempty"` // Specify format name for output, eg. parquet OutputFormat string `protobuf:"bytes,5,opt,name=output_format,json=outputFormat,proto3" json:"output_format,omitempty"` // contains filtered or unexported fields }
func (*GetHistoricalFeaturesRequest) Descriptor
deprecated
added in
v0.9.0
func (*GetHistoricalFeaturesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetHistoricalFeaturesRequest.ProtoReflect.Descriptor instead.
func (*GetHistoricalFeaturesRequest) GetEntitySource ¶ added in v0.9.0
func (x *GetHistoricalFeaturesRequest) GetEntitySource() *DataSource
func (*GetHistoricalFeaturesRequest) GetFeatureRefs ¶ added in v0.9.0
func (x *GetHistoricalFeaturesRequest) GetFeatureRefs() []string
func (*GetHistoricalFeaturesRequest) GetOutputFormat ¶ added in v0.9.0
func (x *GetHistoricalFeaturesRequest) GetOutputFormat() string
func (*GetHistoricalFeaturesRequest) GetOutputLocation ¶ added in v0.9.0
func (x *GetHistoricalFeaturesRequest) GetOutputLocation() string
func (*GetHistoricalFeaturesRequest) GetProject ¶ added in v0.9.0
func (x *GetHistoricalFeaturesRequest) GetProject() string
func (*GetHistoricalFeaturesRequest) ProtoMessage ¶ added in v0.9.0
func (*GetHistoricalFeaturesRequest) ProtoMessage()
func (*GetHistoricalFeaturesRequest) ProtoReflect ¶ added in v0.9.0
func (x *GetHistoricalFeaturesRequest) ProtoReflect() protoreflect.Message
func (*GetHistoricalFeaturesRequest) Reset ¶ added in v0.9.0
func (x *GetHistoricalFeaturesRequest) Reset()
func (*GetHistoricalFeaturesRequest) String ¶ added in v0.9.0
func (x *GetHistoricalFeaturesRequest) String() string
type GetHistoricalFeaturesResponse ¶ added in v0.9.0
type GetHistoricalFeaturesResponse struct { // Export Job with ID assigned by Feast Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Uri to the join result output file OutputFileUri string `protobuf:"bytes,2,opt,name=output_file_uri,json=outputFileUri,proto3" json:"output_file_uri,omitempty"` // Job start time JobStartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=job_start_time,json=jobStartTime,proto3" json:"job_start_time,omitempty"` // Path to Spark job logs, if available LogUri string `protobuf:"bytes,4,opt,name=log_uri,json=logUri,proto3" json:"log_uri,omitempty"` // contains filtered or unexported fields }
func (*GetHistoricalFeaturesResponse) Descriptor
deprecated
added in
v0.9.0
func (*GetHistoricalFeaturesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetHistoricalFeaturesResponse.ProtoReflect.Descriptor instead.
func (*GetHistoricalFeaturesResponse) GetId ¶ added in v0.9.0
func (x *GetHistoricalFeaturesResponse) GetId() string
func (*GetHistoricalFeaturesResponse) GetJobStartTime ¶ added in v0.9.3
func (x *GetHistoricalFeaturesResponse) GetJobStartTime() *timestamppb.Timestamp
func (*GetHistoricalFeaturesResponse) GetLogUri ¶ added in v0.9.3
func (x *GetHistoricalFeaturesResponse) GetLogUri() string
func (*GetHistoricalFeaturesResponse) GetOutputFileUri ¶ added in v0.9.0
func (x *GetHistoricalFeaturesResponse) GetOutputFileUri() string
func (*GetHistoricalFeaturesResponse) ProtoMessage ¶ added in v0.9.0
func (*GetHistoricalFeaturesResponse) ProtoMessage()
func (*GetHistoricalFeaturesResponse) ProtoReflect ¶ added in v0.9.0
func (x *GetHistoricalFeaturesResponse) ProtoReflect() protoreflect.Message
func (*GetHistoricalFeaturesResponse) Reset ¶ added in v0.9.0
func (x *GetHistoricalFeaturesResponse) Reset()
func (*GetHistoricalFeaturesResponse) String ¶ added in v0.9.0
func (x *GetHistoricalFeaturesResponse) String() string
type GetJobRequest ¶ added in v0.9.0
type GetJobRequest struct { JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"` // contains filtered or unexported fields }
func (*GetJobRequest) Descriptor
deprecated
added in
v0.9.0
func (*GetJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.
func (*GetJobRequest) GetJobId ¶ added in v0.9.0
func (x *GetJobRequest) GetJobId() string
func (*GetJobRequest) ProtoMessage ¶ added in v0.9.0
func (*GetJobRequest) ProtoMessage()
func (*GetJobRequest) ProtoReflect ¶ added in v0.9.0
func (x *GetJobRequest) ProtoReflect() protoreflect.Message
func (*GetJobRequest) Reset ¶ added in v0.9.0
func (x *GetJobRequest) Reset()
func (*GetJobRequest) String ¶ added in v0.9.0
func (x *GetJobRequest) String() string
type GetJobResponse ¶ added in v0.9.0
type GetJobResponse struct { Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"` // contains filtered or unexported fields }
func (*GetJobResponse) Descriptor
deprecated
added in
v0.9.0
func (*GetJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.
func (*GetJobResponse) GetJob ¶ added in v0.9.0
func (x *GetJobResponse) GetJob() *Job
func (*GetJobResponse) ProtoMessage ¶ added in v0.9.0
func (*GetJobResponse) ProtoMessage()
func (*GetJobResponse) ProtoReflect ¶ added in v0.9.0
func (x *GetJobResponse) ProtoReflect() protoreflect.Message
func (*GetJobResponse) Reset ¶ added in v0.9.0
func (x *GetJobResponse) Reset()
func (*GetJobResponse) String ¶ added in v0.9.0
func (x *GetJobResponse) String() string
type IngestionJob ¶
type IngestionJob struct { // Job ID assigned by Feast Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // External job ID specific to the runner. // For DirectRunner jobs, this is identical to id. For DataflowRunner jobs, this refers to the Dataflow job ID. ExternalId string `protobuf:"bytes,2,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` Status IngestionJobStatus `protobuf:"varint,3,opt,name=status,proto3,enum=feast.core.IngestionJobStatus" json:"status,omitempty"` // Source this job is reading from. Source *Source `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"` // Store this job is writing to. Stores []*Store `protobuf:"bytes,6,rep,name=stores,proto3" json:"stores,omitempty"` // List of Feature Set References FeatureSetReferences []*FeatureSetReference `protobuf:"bytes,7,rep,name=feature_set_references,json=featureSetReferences,proto3" json:"feature_set_references,omitempty"` // contains filtered or unexported fields }
Represents Feast Injestion Job
func (*IngestionJob) Descriptor
deprecated
func (*IngestionJob) Descriptor() ([]byte, []int)
Deprecated: Use IngestionJob.ProtoReflect.Descriptor instead.
func (*IngestionJob) GetExternalId ¶
func (x *IngestionJob) GetExternalId() string
func (*IngestionJob) GetFeatureSetReferences ¶ added in v0.8.0
func (x *IngestionJob) GetFeatureSetReferences() []*FeatureSetReference
func (*IngestionJob) GetId ¶
func (x *IngestionJob) GetId() string
func (*IngestionJob) GetSource ¶
func (x *IngestionJob) GetSource() *Source
func (*IngestionJob) GetStatus ¶
func (x *IngestionJob) GetStatus() IngestionJobStatus
func (*IngestionJob) GetStores ¶ added in v0.8.0
func (x *IngestionJob) GetStores() []*Store
func (*IngestionJob) ProtoMessage ¶
func (*IngestionJob) ProtoMessage()
func (*IngestionJob) ProtoReflect ¶
func (x *IngestionJob) ProtoReflect() protoreflect.Message
func (*IngestionJob) Reset ¶
func (x *IngestionJob) Reset()
func (*IngestionJob) String ¶
func (x *IngestionJob) String() string
type IngestionJobStatus ¶
type IngestionJobStatus int32
Status of a Feast Ingestion Job
const ( // Job status is not known. IngestionJobStatus_UNKNOWN IngestionJobStatus = 0 // Import job is submitted to runner and currently pending for executing IngestionJobStatus_PENDING IngestionJobStatus = 1 // Import job is currently running in the runner IngestionJobStatus_RUNNING IngestionJobStatus = 2 // Runner's reported the import job has completed (applicable to batch job) IngestionJobStatus_COMPLETED IngestionJobStatus = 3 // When user sent abort command, but it's still running IngestionJobStatus_ABORTING IngestionJobStatus = 4 // User initiated abort job IngestionJobStatus_ABORTED IngestionJobStatus = 5 // Runner's reported that the import job failed to run or there is a failure during job IngestionJobStatus_ERROR IngestionJobStatus = 6 // job has been suspended and waiting for cleanup IngestionJobStatus_SUSPENDING IngestionJobStatus = 7 // job has been suspended IngestionJobStatus_SUSPENDED IngestionJobStatus = 8 )
func (IngestionJobStatus) Descriptor ¶
func (IngestionJobStatus) Descriptor() protoreflect.EnumDescriptor
func (IngestionJobStatus) Enum ¶
func (x IngestionJobStatus) Enum() *IngestionJobStatus
func (IngestionJobStatus) EnumDescriptor
deprecated
func (IngestionJobStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use IngestionJobStatus.Descriptor instead.
func (IngestionJobStatus) Number ¶
func (x IngestionJobStatus) Number() protoreflect.EnumNumber
func (IngestionJobStatus) String ¶
func (x IngestionJobStatus) String() string
func (IngestionJobStatus) Type ¶
func (IngestionJobStatus) Type() protoreflect.EnumType
type Job ¶ added in v0.9.0
type Job struct { // Identifier of the Job Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Type of the Job Type JobType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.core.JobType" json:"type,omitempty"` // Current job status Status JobStatus `protobuf:"varint,3,opt,name=status,proto3,enum=feast.core.JobStatus" json:"status,omitempty"` // Deterministic hash of the Job Hash string `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"` // Start time of the Job StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,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"` // Path to Spark job logs, if available LogUri string `protobuf:"bytes,9,opt,name=log_uri,json=logUri,proto3" json:"log_uri,omitempty"` // contains filtered or unexported fields }
func (*Job) Descriptor
deprecated
added in
v0.9.0
func (*Job) GetBatchIngestion ¶ added in v0.9.0
func (x *Job) GetBatchIngestion() *Job_OfflineToOnlineMeta
func (*Job) GetRetrieval ¶ added in v0.9.0
func (x *Job) GetRetrieval() *Job_RetrievalJobMeta
func (*Job) GetStartTime ¶ added in v0.9.3
func (x *Job) GetStartTime() *timestamppb.Timestamp
func (*Job) GetStreamIngestion ¶ added in v0.9.0
func (x *Job) GetStreamIngestion() *Job_StreamToOnlineMeta
func (*Job) ProtoMessage ¶ added in v0.9.0
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶ added in v0.9.0
func (x *Job) ProtoReflect() protoreflect.Message
type JobServiceClient ¶ added in v0.9.0
type JobServiceClient interface { // Start job to ingest data from offline store into online store StartOfflineToOnlineIngestionJob(ctx context.Context, in *StartOfflineToOnlineIngestionJobRequest, opts ...grpc.CallOption) (*StartOfflineToOnlineIngestionJobResponse, error) // Produce a training dataset, return a job id that will provide a file reference GetHistoricalFeatures(ctx context.Context, in *GetHistoricalFeaturesRequest, opts ...grpc.CallOption) (*GetHistoricalFeaturesResponse, error) // Start job to ingest data from stream into online store StartStreamToOnlineIngestionJob(ctx context.Context, in *StartStreamToOnlineIngestionJobRequest, opts ...grpc.CallOption) (*StartStreamToOnlineIngestionJobResponse, error) // List all types of jobs ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error) // Cancel a single job CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error) // Get details of a single job GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error) }
JobServiceClient is the client API for JobService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewJobServiceClient ¶ added in v0.9.0
func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient
type JobServiceServer ¶ added in v0.9.0
type JobServiceServer interface { // Start job to ingest data from offline store into online store StartOfflineToOnlineIngestionJob(context.Context, *StartOfflineToOnlineIngestionJobRequest) (*StartOfflineToOnlineIngestionJobResponse, error) // Produce a training dataset, return a job id that will provide a file reference GetHistoricalFeatures(context.Context, *GetHistoricalFeaturesRequest) (*GetHistoricalFeaturesResponse, error) // Start job to ingest data from stream into online store StartStreamToOnlineIngestionJob(context.Context, *StartStreamToOnlineIngestionJobRequest) (*StartStreamToOnlineIngestionJobResponse, error) // List all types of jobs ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error) // Cancel a single job CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error) // Get details of a single job GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error) }
JobServiceServer is the server API for JobService service.
type JobStatus ¶ added in v0.9.0
type JobStatus int32
const ( JobStatus_JOB_STATUS_INVALID JobStatus = 0 // The Job has be registered and waiting to get scheduled to run JobStatus_JOB_STATUS_PENDING JobStatus = 1 // The Job is currently processing its task JobStatus_JOB_STATUS_RUNNING JobStatus = 2 // The Job has successfully completed its task JobStatus_JOB_STATUS_DONE JobStatus = 3 // The Job has encountered an error while processing its task JobStatus_JOB_STATUS_ERROR JobStatus = 4 )
func (JobStatus) Descriptor ¶ added in v0.9.0
func (JobStatus) Descriptor() protoreflect.EnumDescriptor
func (JobStatus) EnumDescriptor
deprecated
added in
v0.9.0
func (JobStatus) Number ¶ added in v0.9.0
func (x JobStatus) Number() protoreflect.EnumNumber
func (JobStatus) Type ¶ added in v0.9.0
func (JobStatus) Type() protoreflect.EnumType
type JobType ¶ added in v0.9.0
type JobType int32
func (JobType) Descriptor ¶ added in v0.9.0
func (JobType) Descriptor() protoreflect.EnumDescriptor
func (JobType) EnumDescriptor
deprecated
added in
v0.9.0
func (JobType) Number ¶ added in v0.9.0
func (x JobType) Number() protoreflect.EnumNumber
func (JobType) Type ¶ added in v0.9.0
func (JobType) Type() protoreflect.EnumType
type Job_BatchIngestion ¶ added in v0.9.0
type Job_BatchIngestion struct {
BatchIngestion *Job_OfflineToOnlineMeta `protobuf:"bytes,7,opt,name=batch_ingestion,json=batchIngestion,proto3,oneof"`
}
type Job_OfflineToOnlineMeta ¶ added in v0.9.0
type Job_OfflineToOnlineMeta struct { TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // contains filtered or unexported fields }
func (*Job_OfflineToOnlineMeta) Descriptor
deprecated
added in
v0.9.0
func (*Job_OfflineToOnlineMeta) Descriptor() ([]byte, []int)
Deprecated: Use Job_OfflineToOnlineMeta.ProtoReflect.Descriptor instead.
func (*Job_OfflineToOnlineMeta) GetTableName ¶ added in v0.9.3
func (x *Job_OfflineToOnlineMeta) GetTableName() string
func (*Job_OfflineToOnlineMeta) ProtoMessage ¶ added in v0.9.0
func (*Job_OfflineToOnlineMeta) ProtoMessage()
func (*Job_OfflineToOnlineMeta) ProtoReflect ¶ added in v0.9.0
func (x *Job_OfflineToOnlineMeta) ProtoReflect() protoreflect.Message
func (*Job_OfflineToOnlineMeta) Reset ¶ added in v0.9.0
func (x *Job_OfflineToOnlineMeta) Reset()
func (*Job_OfflineToOnlineMeta) String ¶ added in v0.9.0
func (x *Job_OfflineToOnlineMeta) String() string
type Job_Retrieval ¶ added in v0.9.0
type Job_Retrieval struct {
Retrieval *Job_RetrievalJobMeta `protobuf:"bytes,6,opt,name=retrieval,proto3,oneof"`
}
type Job_RetrievalJobMeta ¶ added in v0.9.0
type Job_RetrievalJobMeta struct { OutputLocation string `protobuf:"bytes,1,opt,name=output_location,json=outputLocation,proto3" json:"output_location,omitempty"` // contains filtered or unexported fields }
func (*Job_RetrievalJobMeta) Descriptor
deprecated
added in
v0.9.0
func (*Job_RetrievalJobMeta) Descriptor() ([]byte, []int)
Deprecated: Use Job_RetrievalJobMeta.ProtoReflect.Descriptor instead.
func (*Job_RetrievalJobMeta) GetOutputLocation ¶ added in v0.9.0
func (x *Job_RetrievalJobMeta) GetOutputLocation() string
func (*Job_RetrievalJobMeta) ProtoMessage ¶ added in v0.9.0
func (*Job_RetrievalJobMeta) ProtoMessage()
func (*Job_RetrievalJobMeta) ProtoReflect ¶ added in v0.9.0
func (x *Job_RetrievalJobMeta) ProtoReflect() protoreflect.Message
func (*Job_RetrievalJobMeta) Reset ¶ added in v0.9.0
func (x *Job_RetrievalJobMeta) Reset()
func (*Job_RetrievalJobMeta) String ¶ added in v0.9.0
func (x *Job_RetrievalJobMeta) String() string
type Job_StreamIngestion ¶ added in v0.9.0
type Job_StreamIngestion struct {
StreamIngestion *Job_StreamToOnlineMeta `protobuf:"bytes,8,opt,name=stream_ingestion,json=streamIngestion,proto3,oneof"`
}
type Job_StreamToOnlineMeta ¶ added in v0.9.0
type Job_StreamToOnlineMeta struct { TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // contains filtered or unexported fields }
func (*Job_StreamToOnlineMeta) Descriptor
deprecated
added in
v0.9.0
func (*Job_StreamToOnlineMeta) Descriptor() ([]byte, []int)
Deprecated: Use Job_StreamToOnlineMeta.ProtoReflect.Descriptor instead.
func (*Job_StreamToOnlineMeta) GetTableName ¶ added in v0.9.3
func (x *Job_StreamToOnlineMeta) GetTableName() string
func (*Job_StreamToOnlineMeta) ProtoMessage ¶ added in v0.9.0
func (*Job_StreamToOnlineMeta) ProtoMessage()
func (*Job_StreamToOnlineMeta) ProtoReflect ¶ added in v0.9.0
func (x *Job_StreamToOnlineMeta) ProtoReflect() protoreflect.Message
func (*Job_StreamToOnlineMeta) Reset ¶ added in v0.9.0
func (x *Job_StreamToOnlineMeta) Reset()
func (*Job_StreamToOnlineMeta) String ¶ added in v0.9.0
func (x *Job_StreamToOnlineMeta) String() string
type KafkaSourceConfig ¶
type KafkaSourceConfig struct { // Comma separated list of Kafka bootstrap servers. Used for feature sets without a defined source host[:port]] BootstrapServers string `protobuf:"bytes,1,opt,name=bootstrap_servers,json=bootstrapServers,proto3" json:"bootstrap_servers,omitempty"` // Kafka topic to use for feature sets without user defined topics Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` // Number of Kafka partitions to to use for managed feature stream. Partitions int32 `protobuf:"varint,3,opt,name=partitions,proto3" json:"partitions,omitempty"` // Defines the number of copies of managed feature stream Kafka. ReplicationFactor int32 `protobuf:"varint,4,opt,name=replicationFactor,proto3" json:"replicationFactor,omitempty"` // contains filtered or unexported fields }
func (*KafkaSourceConfig) Descriptor
deprecated
func (*KafkaSourceConfig) Descriptor() ([]byte, []int)
Deprecated: Use KafkaSourceConfig.ProtoReflect.Descriptor instead.
func (*KafkaSourceConfig) GetBootstrapServers ¶
func (x *KafkaSourceConfig) GetBootstrapServers() string
func (*KafkaSourceConfig) GetPartitions ¶
func (x *KafkaSourceConfig) GetPartitions() int32
func (*KafkaSourceConfig) GetReplicationFactor ¶
func (x *KafkaSourceConfig) GetReplicationFactor() int32
func (*KafkaSourceConfig) GetTopic ¶
func (x *KafkaSourceConfig) GetTopic() string
func (*KafkaSourceConfig) ProtoMessage ¶
func (*KafkaSourceConfig) ProtoMessage()
func (*KafkaSourceConfig) ProtoReflect ¶
func (x *KafkaSourceConfig) ProtoReflect() protoreflect.Message
func (*KafkaSourceConfig) Reset ¶
func (x *KafkaSourceConfig) Reset()
func (*KafkaSourceConfig) String ¶
func (x *KafkaSourceConfig) String() string
type ListEntitiesRequest ¶ added in v0.8.0
type ListEntitiesRequest struct { Filter *ListEntitiesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
Retrieves details for all versions of a specific entity
func (*ListEntitiesRequest) Descriptor
deprecated
added in
v0.8.0
func (*ListEntitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListEntitiesRequest.ProtoReflect.Descriptor instead.
func (*ListEntitiesRequest) GetFilter ¶ added in v0.8.0
func (x *ListEntitiesRequest) GetFilter() *ListEntitiesRequest_Filter
func (*ListEntitiesRequest) ProtoMessage ¶ added in v0.8.0
func (*ListEntitiesRequest) ProtoMessage()
func (*ListEntitiesRequest) ProtoReflect ¶ added in v0.8.0
func (x *ListEntitiesRequest) ProtoReflect() protoreflect.Message
func (*ListEntitiesRequest) Reset ¶ added in v0.8.0
func (x *ListEntitiesRequest) Reset()
func (*ListEntitiesRequest) String ¶ added in v0.8.0
func (x *ListEntitiesRequest) String() string
type ListEntitiesRequest_Filter ¶ added in v0.8.0
type ListEntitiesRequest_Filter struct { // Optional. Specifies the name of the project to list Entities in. // It is NOT possible to provide an asterisk with a string in order to do pattern matching. // If unspecified, this field will default to the default project 'default'. Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"` // Optional. User defined metadata for entity. // Entities with all matching labels will be returned. Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ListEntitiesRequest_Filter) Descriptor
deprecated
added in
v0.8.0
func (*ListEntitiesRequest_Filter) Descriptor() ([]byte, []int)
Deprecated: Use ListEntitiesRequest_Filter.ProtoReflect.Descriptor instead.
func (*ListEntitiesRequest_Filter) GetLabels ¶ added in v0.8.0
func (x *ListEntitiesRequest_Filter) GetLabels() map[string]string
func (*ListEntitiesRequest_Filter) GetProject ¶ added in v0.8.0
func (x *ListEntitiesRequest_Filter) GetProject() string
func (*ListEntitiesRequest_Filter) ProtoMessage ¶ added in v0.8.0
func (*ListEntitiesRequest_Filter) ProtoMessage()
func (*ListEntitiesRequest_Filter) ProtoReflect ¶ added in v0.8.0
func (x *ListEntitiesRequest_Filter) ProtoReflect() protoreflect.Message
func (*ListEntitiesRequest_Filter) Reset ¶ added in v0.8.0
func (x *ListEntitiesRequest_Filter) Reset()
func (*ListEntitiesRequest_Filter) String ¶ added in v0.8.0
func (x *ListEntitiesRequest_Filter) String() string
type ListEntitiesResponse ¶ added in v0.8.0
type ListEntitiesResponse struct { Entities []*Entity `protobuf:"bytes,1,rep,name=entities,proto3" json:"entities,omitempty"` // contains filtered or unexported fields }
func (*ListEntitiesResponse) Descriptor
deprecated
added in
v0.8.0
func (*ListEntitiesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListEntitiesResponse.ProtoReflect.Descriptor instead.
func (*ListEntitiesResponse) GetEntities ¶ added in v0.8.0
func (x *ListEntitiesResponse) GetEntities() []*Entity
func (*ListEntitiesResponse) ProtoMessage ¶ added in v0.8.0
func (*ListEntitiesResponse) ProtoMessage()
func (*ListEntitiesResponse) ProtoReflect ¶ added in v0.8.0
func (x *ListEntitiesResponse) ProtoReflect() protoreflect.Message
func (*ListEntitiesResponse) Reset ¶ added in v0.8.0
func (x *ListEntitiesResponse) Reset()
func (*ListEntitiesResponse) String ¶ added in v0.8.0
func (x *ListEntitiesResponse) String() string
type ListFeatureTablesRequest ¶ added in v0.8.0
type ListFeatureTablesRequest struct { // Filter used when listing Feature Tables Filter *ListFeatureTablesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListFeatureTablesRequest) Descriptor
deprecated
added in
v0.8.0
func (*ListFeatureTablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListFeatureTablesRequest.ProtoReflect.Descriptor instead.
func (*ListFeatureTablesRequest) GetFilter ¶ added in v0.8.0
func (x *ListFeatureTablesRequest) GetFilter() *ListFeatureTablesRequest_Filter
func (*ListFeatureTablesRequest) ProtoMessage ¶ added in v0.8.0
func (*ListFeatureTablesRequest) ProtoMessage()
func (*ListFeatureTablesRequest) ProtoReflect ¶ added in v0.8.0
func (x *ListFeatureTablesRequest) ProtoReflect() protoreflect.Message
func (*ListFeatureTablesRequest) Reset ¶ added in v0.8.0
func (x *ListFeatureTablesRequest) Reset()
func (*ListFeatureTablesRequest) String ¶ added in v0.8.0
func (x *ListFeatureTablesRequest) String() string
type ListFeatureTablesRequest_Filter ¶ added in v0.8.0
type ListFeatureTablesRequest_Filter struct { // Optional. Specifies the name of the project to list Feature Tables in. // If unspecified would list Feature Tables in the default project. Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` // Optional. Feature Tables with all matching labels will be returned. // If unspecified would list Feature Tables without filtering by labels. Labels map[string]string `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ListFeatureTablesRequest_Filter) Descriptor
deprecated
added in
v0.8.0
func (*ListFeatureTablesRequest_Filter) Descriptor() ([]byte, []int)
Deprecated: Use ListFeatureTablesRequest_Filter.ProtoReflect.Descriptor instead.
func (*ListFeatureTablesRequest_Filter) GetLabels ¶ added in v0.8.0
func (x *ListFeatureTablesRequest_Filter) GetLabels() map[string]string
func (*ListFeatureTablesRequest_Filter) GetProject ¶ added in v0.8.0
func (x *ListFeatureTablesRequest_Filter) GetProject() string
func (*ListFeatureTablesRequest_Filter) ProtoMessage ¶ added in v0.8.0
func (*ListFeatureTablesRequest_Filter) ProtoMessage()
func (*ListFeatureTablesRequest_Filter) ProtoReflect ¶ added in v0.8.0
func (x *ListFeatureTablesRequest_Filter) ProtoReflect() protoreflect.Message
func (*ListFeatureTablesRequest_Filter) Reset ¶ added in v0.8.0
func (x *ListFeatureTablesRequest_Filter) Reset()
func (*ListFeatureTablesRequest_Filter) String ¶ added in v0.8.0
func (x *ListFeatureTablesRequest_Filter) String() string
type ListFeatureTablesResponse ¶ added in v0.8.0
type ListFeatureTablesResponse struct { // List of matching Feature Tables Tables []*FeatureTable `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` // contains filtered or unexported fields }
func (*ListFeatureTablesResponse) Descriptor
deprecated
added in
v0.8.0
func (*ListFeatureTablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListFeatureTablesResponse.ProtoReflect.Descriptor instead.
func (*ListFeatureTablesResponse) GetTables ¶ added in v0.8.0
func (x *ListFeatureTablesResponse) GetTables() []*FeatureTable
func (*ListFeatureTablesResponse) ProtoMessage ¶ added in v0.8.0
func (*ListFeatureTablesResponse) ProtoMessage()
func (*ListFeatureTablesResponse) ProtoReflect ¶ added in v0.8.0
func (x *ListFeatureTablesResponse) ProtoReflect() protoreflect.Message
func (*ListFeatureTablesResponse) Reset ¶ added in v0.8.0
func (x *ListFeatureTablesResponse) Reset()
func (*ListFeatureTablesResponse) String ¶ added in v0.8.0
func (x *ListFeatureTablesResponse) String() string
type ListFeaturesRequest ¶ added in v0.6.2
type ListFeaturesRequest struct { Filter *ListFeaturesRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListFeaturesRequest) Descriptor
deprecated
added in
v0.6.2
func (*ListFeaturesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListFeaturesRequest.ProtoReflect.Descriptor instead.
func (*ListFeaturesRequest) GetFilter ¶ added in v0.6.2
func (x *ListFeaturesRequest) GetFilter() *ListFeaturesRequest_Filter
func (*ListFeaturesRequest) ProtoMessage ¶ added in v0.6.2
func (*ListFeaturesRequest) ProtoMessage()
func (*ListFeaturesRequest) ProtoReflect ¶ added in v0.6.2
func (x *ListFeaturesRequest) ProtoReflect() protoreflect.Message
func (*ListFeaturesRequest) Reset ¶ added in v0.6.2
func (x *ListFeaturesRequest) Reset()
func (*ListFeaturesRequest) String ¶ added in v0.6.2
func (x *ListFeaturesRequest) String() string
type ListFeaturesRequest_Filter ¶ added in v0.6.2
type ListFeaturesRequest_Filter struct { // User defined metadata for feature. // Features with all matching labels will be returned. Labels map[string]string `` /* 153-byte string literal not displayed */ // List of entities contained within the featureSet that the feature belongs to. // Only feature tables with these entities will be searched for features. Entities []string `protobuf:"bytes,2,rep,name=entities,proto3" json:"entities,omitempty"` // Name of project that the feature tables belongs to. Filtering on projects is disabled. // It is NOT possible to provide an asterisk with a string in order to do pattern matching. // If unspecified this field will default to the default project 'default'. Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"` // contains filtered or unexported fields }
func (*ListFeaturesRequest_Filter) Descriptor
deprecated
added in
v0.6.2
func (*ListFeaturesRequest_Filter) Descriptor() ([]byte, []int)
Deprecated: Use ListFeaturesRequest_Filter.ProtoReflect.Descriptor instead.
func (*ListFeaturesRequest_Filter) GetEntities ¶ added in v0.6.2
func (x *ListFeaturesRequest_Filter) GetEntities() []string
func (*ListFeaturesRequest_Filter) GetLabels ¶ added in v0.6.2
func (x *ListFeaturesRequest_Filter) GetLabels() map[string]string
func (*ListFeaturesRequest_Filter) GetProject ¶ added in v0.6.2
func (x *ListFeaturesRequest_Filter) GetProject() string
func (*ListFeaturesRequest_Filter) ProtoMessage ¶ added in v0.6.2
func (*ListFeaturesRequest_Filter) ProtoMessage()
func (*ListFeaturesRequest_Filter) ProtoReflect ¶ added in v0.6.2
func (x *ListFeaturesRequest_Filter) ProtoReflect() protoreflect.Message
func (*ListFeaturesRequest_Filter) Reset ¶ added in v0.6.2
func (x *ListFeaturesRequest_Filter) Reset()
func (*ListFeaturesRequest_Filter) String ¶ added in v0.6.2
func (x *ListFeaturesRequest_Filter) String() string
type ListFeaturesResponse ¶ added in v0.6.2
type ListFeaturesResponse struct { Features map[string]*FeatureSpecV2 `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ListFeaturesResponse) Descriptor
deprecated
added in
v0.6.2
func (*ListFeaturesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListFeaturesResponse.ProtoReflect.Descriptor instead.
func (*ListFeaturesResponse) GetFeatures ¶ added in v0.6.2
func (x *ListFeaturesResponse) GetFeatures() map[string]*FeatureSpecV2
func (*ListFeaturesResponse) ProtoMessage ¶ added in v0.6.2
func (*ListFeaturesResponse) ProtoMessage()
func (*ListFeaturesResponse) ProtoReflect ¶ added in v0.6.2
func (x *ListFeaturesResponse) ProtoReflect() protoreflect.Message
func (*ListFeaturesResponse) Reset ¶ added in v0.6.2
func (x *ListFeaturesResponse) Reset()
func (*ListFeaturesResponse) String ¶ added in v0.6.2
func (x *ListFeaturesResponse) String() string
type ListJobsRequest ¶ added in v0.9.0
type ListJobsRequest struct { IncludeTerminated bool `protobuf:"varint,1,opt,name=include_terminated,json=includeTerminated,proto3" json:"include_terminated,omitempty"` TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // contains filtered or unexported fields }
func (*ListJobsRequest) Descriptor
deprecated
added in
v0.9.0
func (*ListJobsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListJobsRequest.ProtoReflect.Descriptor instead.
func (*ListJobsRequest) GetIncludeTerminated ¶ added in v0.9.0
func (x *ListJobsRequest) GetIncludeTerminated() bool
func (*ListJobsRequest) GetTableName ¶ added in v0.9.3
func (x *ListJobsRequest) GetTableName() string
func (*ListJobsRequest) ProtoMessage ¶ added in v0.9.0
func (*ListJobsRequest) ProtoMessage()
func (*ListJobsRequest) ProtoReflect ¶ added in v0.9.0
func (x *ListJobsRequest) ProtoReflect() protoreflect.Message
func (*ListJobsRequest) Reset ¶ added in v0.9.0
func (x *ListJobsRequest) Reset()
func (*ListJobsRequest) String ¶ added in v0.9.0
func (x *ListJobsRequest) String() string
type ListJobsResponse ¶ added in v0.9.0
type ListJobsResponse struct { Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"` // contains filtered or unexported fields }
func (*ListJobsResponse) Descriptor
deprecated
added in
v0.9.0
func (*ListJobsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListJobsResponse.ProtoReflect.Descriptor instead.
func (*ListJobsResponse) GetJobs ¶ added in v0.9.0
func (x *ListJobsResponse) GetJobs() []*Job
func (*ListJobsResponse) ProtoMessage ¶ added in v0.9.0
func (*ListJobsResponse) ProtoMessage()
func (*ListJobsResponse) ProtoReflect ¶ added in v0.9.0
func (x *ListJobsResponse) ProtoReflect() protoreflect.Message
func (*ListJobsResponse) Reset ¶ added in v0.9.0
func (x *ListJobsResponse) Reset()
func (*ListJobsResponse) String ¶ added in v0.9.0
func (x *ListJobsResponse) String() string
type ListProjectsRequest ¶
type ListProjectsRequest struct {
// contains filtered or unexported fields
}
Request for listing of projects
func (*ListProjectsRequest) Descriptor
deprecated
func (*ListProjectsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListProjectsRequest.ProtoReflect.Descriptor instead.
func (*ListProjectsRequest) ProtoMessage ¶
func (*ListProjectsRequest) ProtoMessage()
func (*ListProjectsRequest) ProtoReflect ¶
func (x *ListProjectsRequest) ProtoReflect() protoreflect.Message
func (*ListProjectsRequest) Reset ¶
func (x *ListProjectsRequest) Reset()
func (*ListProjectsRequest) String ¶
func (x *ListProjectsRequest) String() string
type ListProjectsResponse ¶
type ListProjectsResponse struct { // List of project names (archived projects are filtered out) Projects []string `protobuf:"bytes,1,rep,name=projects,proto3" json:"projects,omitempty"` // contains filtered or unexported fields }
Response for listing of projects
func (*ListProjectsResponse) Descriptor
deprecated
func (*ListProjectsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListProjectsResponse.ProtoReflect.Descriptor instead.
func (*ListProjectsResponse) GetProjects ¶
func (x *ListProjectsResponse) GetProjects() []string
func (*ListProjectsResponse) ProtoMessage ¶
func (*ListProjectsResponse) ProtoMessage()
func (*ListProjectsResponse) ProtoReflect ¶
func (x *ListProjectsResponse) ProtoReflect() protoreflect.Message
func (*ListProjectsResponse) Reset ¶
func (x *ListProjectsResponse) Reset()
func (*ListProjectsResponse) String ¶
func (x *ListProjectsResponse) String() string
type ListStoresRequest ¶
type ListStoresRequest struct { Filter *ListStoresRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListStoresRequest) Descriptor
deprecated
func (*ListStoresRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListStoresRequest.ProtoReflect.Descriptor instead.
func (*ListStoresRequest) GetFilter ¶
func (x *ListStoresRequest) GetFilter() *ListStoresRequest_Filter
func (*ListStoresRequest) ProtoMessage ¶
func (*ListStoresRequest) ProtoMessage()
func (*ListStoresRequest) ProtoReflect ¶
func (x *ListStoresRequest) ProtoReflect() protoreflect.Message
func (*ListStoresRequest) Reset ¶
func (x *ListStoresRequest) Reset()
func (*ListStoresRequest) String ¶
func (x *ListStoresRequest) String() string
type ListStoresRequest_Filter ¶
type ListStoresRequest_Filter struct { // Name of desired store. Regex is not supported in this query. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*ListStoresRequest_Filter) Descriptor
deprecated
func (*ListStoresRequest_Filter) Descriptor() ([]byte, []int)
Deprecated: Use ListStoresRequest_Filter.ProtoReflect.Descriptor instead.
func (*ListStoresRequest_Filter) GetName ¶
func (x *ListStoresRequest_Filter) GetName() string
func (*ListStoresRequest_Filter) ProtoMessage ¶
func (*ListStoresRequest_Filter) ProtoMessage()
func (*ListStoresRequest_Filter) ProtoReflect ¶
func (x *ListStoresRequest_Filter) ProtoReflect() protoreflect.Message
func (*ListStoresRequest_Filter) Reset ¶
func (x *ListStoresRequest_Filter) Reset()
func (*ListStoresRequest_Filter) String ¶
func (x *ListStoresRequest_Filter) String() string
type ListStoresResponse ¶
type ListStoresResponse struct { Store []*Store `protobuf:"bytes,1,rep,name=store,proto3" json:"store,omitempty"` // contains filtered or unexported fields }
func (*ListStoresResponse) Descriptor
deprecated
func (*ListStoresResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListStoresResponse.ProtoReflect.Descriptor instead.
func (*ListStoresResponse) GetStore ¶
func (x *ListStoresResponse) GetStore() []*Store
func (*ListStoresResponse) ProtoMessage ¶
func (*ListStoresResponse) ProtoMessage()
func (*ListStoresResponse) ProtoReflect ¶
func (x *ListStoresResponse) ProtoReflect() protoreflect.Message
func (*ListStoresResponse) Reset ¶
func (x *ListStoresResponse) Reset()
func (*ListStoresResponse) String ¶
func (x *ListStoresResponse) String() string
type Source ¶
type Source struct { // The kind of data source Feast should connect to in order to retrieve FeatureRow value Type SourceType `protobuf:"varint,1,opt,name=type,proto3,enum=feast.core.SourceType" json:"type,omitempty"` // Source specific configuration // // Types that are assignable to SourceConfig: // *Source_KafkaSourceConfig SourceConfig isSource_SourceConfig `protobuf_oneof:"source_config"` // contains filtered or unexported fields }
func (*Source) Descriptor
deprecated
func (*Source) 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
type SourceType ¶
type SourceType int32
const ( SourceType_INVALID SourceType = 0 SourceType_KAFKA SourceType = 1 )
func (SourceType) Descriptor ¶
func (SourceType) Descriptor() protoreflect.EnumDescriptor
func (SourceType) Enum ¶
func (x SourceType) Enum() *SourceType
func (SourceType) EnumDescriptor
deprecated
func (SourceType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SourceType.Descriptor instead.
func (SourceType) Number ¶
func (x SourceType) Number() protoreflect.EnumNumber
func (SourceType) String ¶
func (x SourceType) String() string
func (SourceType) Type ¶
func (SourceType) Type() protoreflect.EnumType
type Source_KafkaSourceConfig ¶
type Source_KafkaSourceConfig struct {
KafkaSourceConfig *KafkaSourceConfig `protobuf:"bytes,2,opt,name=kafka_source_config,json=kafkaSourceConfig,proto3,oneof"`
}
type SpecsStreamingUpdateConfig ¶ added in v0.6.2
type SpecsStreamingUpdateConfig struct { // out-channel for publishing new FeatureSetSpecs (by Core). // IngestionJob use it as source of existing FeatureSetSpecs and new real-time updates Source *KafkaSourceConfig `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` // ack-channel for sending acknowledgments when new FeatureSetSpecs is installed in Job Ack *KafkaSourceConfig `protobuf:"bytes,2,opt,name=ack,proto3" json:"ack,omitempty"` // contains filtered or unexported fields }
Config for bi-directional communication channel between Core Service and Ingestion Job
func (*SpecsStreamingUpdateConfig) Descriptor
deprecated
added in
v0.6.2
func (*SpecsStreamingUpdateConfig) Descriptor() ([]byte, []int)
Deprecated: Use SpecsStreamingUpdateConfig.ProtoReflect.Descriptor instead.
func (*SpecsStreamingUpdateConfig) GetAck ¶ added in v0.6.2
func (x *SpecsStreamingUpdateConfig) GetAck() *KafkaSourceConfig
func (*SpecsStreamingUpdateConfig) GetSource ¶ added in v0.6.2
func (x *SpecsStreamingUpdateConfig) GetSource() *KafkaSourceConfig
func (*SpecsStreamingUpdateConfig) ProtoMessage ¶ added in v0.6.2
func (*SpecsStreamingUpdateConfig) ProtoMessage()
func (*SpecsStreamingUpdateConfig) ProtoReflect ¶ added in v0.6.2
func (x *SpecsStreamingUpdateConfig) ProtoReflect() protoreflect.Message
func (*SpecsStreamingUpdateConfig) Reset ¶ added in v0.6.2
func (x *SpecsStreamingUpdateConfig) Reset()
func (*SpecsStreamingUpdateConfig) String ¶ added in v0.6.2
func (x *SpecsStreamingUpdateConfig) String() string
type StartOfflineToOnlineIngestionJobRequest ¶ added in v0.9.0
type StartOfflineToOnlineIngestionJobRequest struct { // Feature table to ingest Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Start of time range for source data from offline store StartDate *timestamppb.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 *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"` // contains filtered or unexported fields }
Ingest data from offline store into online store
func (*StartOfflineToOnlineIngestionJobRequest) Descriptor
deprecated
added in
v0.9.0
func (*StartOfflineToOnlineIngestionJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartOfflineToOnlineIngestionJobRequest.ProtoReflect.Descriptor instead.
func (*StartOfflineToOnlineIngestionJobRequest) GetEndDate ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobRequest) GetEndDate() *timestamppb.Timestamp
func (*StartOfflineToOnlineIngestionJobRequest) GetProject ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobRequest) GetProject() string
func (*StartOfflineToOnlineIngestionJobRequest) GetStartDate ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobRequest) GetStartDate() *timestamppb.Timestamp
func (*StartOfflineToOnlineIngestionJobRequest) GetTableName ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobRequest) GetTableName() string
func (*StartOfflineToOnlineIngestionJobRequest) ProtoMessage ¶ added in v0.9.0
func (*StartOfflineToOnlineIngestionJobRequest) ProtoMessage()
func (*StartOfflineToOnlineIngestionJobRequest) ProtoReflect ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobRequest) ProtoReflect() protoreflect.Message
func (*StartOfflineToOnlineIngestionJobRequest) Reset ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobRequest) Reset()
func (*StartOfflineToOnlineIngestionJobRequest) String ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobRequest) String() string
type StartOfflineToOnlineIngestionJobResponse ¶ added in v0.9.0
type StartOfflineToOnlineIngestionJobResponse struct { // Job ID assigned by Feast Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Job start time JobStartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=job_start_time,json=jobStartTime,proto3" json:"job_start_time,omitempty"` // Feature table associated with the job TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Path to Spark job logs, if available LogUri string `protobuf:"bytes,4,opt,name=log_uri,json=logUri,proto3" json:"log_uri,omitempty"` // contains filtered or unexported fields }
func (*StartOfflineToOnlineIngestionJobResponse) Descriptor
deprecated
added in
v0.9.0
func (*StartOfflineToOnlineIngestionJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartOfflineToOnlineIngestionJobResponse.ProtoReflect.Descriptor instead.
func (*StartOfflineToOnlineIngestionJobResponse) GetId ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobResponse) GetId() string
func (*StartOfflineToOnlineIngestionJobResponse) GetJobStartTime ¶ added in v0.9.3
func (x *StartOfflineToOnlineIngestionJobResponse) GetJobStartTime() *timestamppb.Timestamp
func (*StartOfflineToOnlineIngestionJobResponse) GetLogUri ¶ added in v0.9.3
func (x *StartOfflineToOnlineIngestionJobResponse) GetLogUri() string
func (*StartOfflineToOnlineIngestionJobResponse) GetTableName ¶ added in v0.9.3
func (x *StartOfflineToOnlineIngestionJobResponse) GetTableName() string
func (*StartOfflineToOnlineIngestionJobResponse) ProtoMessage ¶ added in v0.9.0
func (*StartOfflineToOnlineIngestionJobResponse) ProtoMessage()
func (*StartOfflineToOnlineIngestionJobResponse) ProtoReflect ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobResponse) ProtoReflect() protoreflect.Message
func (*StartOfflineToOnlineIngestionJobResponse) Reset ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobResponse) Reset()
func (*StartOfflineToOnlineIngestionJobResponse) String ¶ added in v0.9.0
func (x *StartOfflineToOnlineIngestionJobResponse) String() string
type StartStreamToOnlineIngestionJobRequest ¶ added in v0.9.0
type StartStreamToOnlineIngestionJobRequest struct { // Feature table to ingest Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"` TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // contains filtered or unexported fields }
func (*StartStreamToOnlineIngestionJobRequest) Descriptor
deprecated
added in
v0.9.0
func (*StartStreamToOnlineIngestionJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartStreamToOnlineIngestionJobRequest.ProtoReflect.Descriptor instead.
func (*StartStreamToOnlineIngestionJobRequest) GetProject ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobRequest) GetProject() string
func (*StartStreamToOnlineIngestionJobRequest) GetTableName ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobRequest) GetTableName() string
func (*StartStreamToOnlineIngestionJobRequest) ProtoMessage ¶ added in v0.9.0
func (*StartStreamToOnlineIngestionJobRequest) ProtoMessage()
func (*StartStreamToOnlineIngestionJobRequest) ProtoReflect ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobRequest) ProtoReflect() protoreflect.Message
func (*StartStreamToOnlineIngestionJobRequest) Reset ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobRequest) Reset()
func (*StartStreamToOnlineIngestionJobRequest) String ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobRequest) String() string
type StartStreamToOnlineIngestionJobResponse ¶ added in v0.9.0
type StartStreamToOnlineIngestionJobResponse struct { // Job ID assigned by Feast Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Job start time JobStartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=job_start_time,json=jobStartTime,proto3" json:"job_start_time,omitempty"` // Feature table associated with the job TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // Path to Spark job logs, if available LogUri string `protobuf:"bytes,4,opt,name=log_uri,json=logUri,proto3" json:"log_uri,omitempty"` // contains filtered or unexported fields }
func (*StartStreamToOnlineIngestionJobResponse) Descriptor
deprecated
added in
v0.9.0
func (*StartStreamToOnlineIngestionJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartStreamToOnlineIngestionJobResponse.ProtoReflect.Descriptor instead.
func (*StartStreamToOnlineIngestionJobResponse) GetId ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobResponse) GetId() string
func (*StartStreamToOnlineIngestionJobResponse) GetJobStartTime ¶ added in v0.9.3
func (x *StartStreamToOnlineIngestionJobResponse) GetJobStartTime() *timestamppb.Timestamp
func (*StartStreamToOnlineIngestionJobResponse) GetLogUri ¶ added in v0.9.3
func (x *StartStreamToOnlineIngestionJobResponse) GetLogUri() string
func (*StartStreamToOnlineIngestionJobResponse) GetTableName ¶ added in v0.9.3
func (x *StartStreamToOnlineIngestionJobResponse) GetTableName() string
func (*StartStreamToOnlineIngestionJobResponse) ProtoMessage ¶ added in v0.9.0
func (*StartStreamToOnlineIngestionJobResponse) ProtoMessage()
func (*StartStreamToOnlineIngestionJobResponse) ProtoReflect ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobResponse) ProtoReflect() protoreflect.Message
func (*StartStreamToOnlineIngestionJobResponse) Reset ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobResponse) Reset()
func (*StartStreamToOnlineIngestionJobResponse) String ¶ added in v0.9.0
func (x *StartStreamToOnlineIngestionJobResponse) String() string
type Store ¶
type Store struct { // Name of the store. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Type of store. Type Store_StoreType `protobuf:"varint,2,opt,name=type,proto3,enum=feast.core.Store_StoreType" json:"type,omitempty"` // Feature sets to subscribe to. Subscriptions []*Store_Subscription `protobuf:"bytes,4,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // Configuration to connect to the store. Required. // // Types that are assignable to Config: // *Store_RedisConfig_ // *Store_RedisClusterConfig_ Config isStore_Config `protobuf_oneof:"config"` // contains filtered or unexported fields }
Store provides a location where Feast reads and writes feature values. Feature values will be written to the Store in the form of FeatureRow elements. The way FeatureRow is encoded and decoded when it is written to and read from the Store depends on the type of the Store.
func (*Store) Descriptor
deprecated
func (*Store) 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
type Store_RedisClusterConfig ¶
type Store_RedisClusterConfig struct { // List of Redis Uri for all the nodes in Redis Cluster, comma separated. Eg. host1:6379, host2:6379 ConnectionString string `protobuf:"bytes,1,opt,name=connection_string,json=connectionString,proto3" json:"connection_string,omitempty"` InitialBackoffMs int32 `protobuf:"varint,2,opt,name=initial_backoff_ms,json=initialBackoffMs,proto3" json:"initial_backoff_ms,omitempty"` MaxRetries int32 `protobuf:"varint,3,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"` // Optional. How often flush data to redis FlushFrequencySeconds int32 `` /* 127-byte string literal not displayed */ // Optional. Append a prefix to the Redis Key KeyPrefix string `protobuf:"bytes,5,opt,name=key_prefix,json=keyPrefix,proto3" json:"key_prefix,omitempty"` // Optional. Enable fallback to another key prefix if the original key is not present. // Useful for migrating key prefix without re-ingestion. Disabled by default. EnableFallback bool `protobuf:"varint,6,opt,name=enable_fallback,json=enableFallback,proto3" json:"enable_fallback,omitempty"` // Optional. This would be the fallback prefix to use if enable_fallback is true. FallbackPrefix string `protobuf:"bytes,7,opt,name=fallback_prefix,json=fallbackPrefix,proto3" json:"fallback_prefix,omitempty"` ReadFrom Store_RedisClusterConfig_ReadFrom `` /* 136-byte string literal not displayed */ // Optional. Timeout on waiting response from redis node Timeout *durationpb.Duration `protobuf:"bytes,9,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*Store_RedisClusterConfig) Descriptor
deprecated
func (*Store_RedisClusterConfig) Descriptor() ([]byte, []int)
Deprecated: Use Store_RedisClusterConfig.ProtoReflect.Descriptor instead.
func (*Store_RedisClusterConfig) GetConnectionString ¶
func (x *Store_RedisClusterConfig) GetConnectionString() string
func (*Store_RedisClusterConfig) GetEnableFallback ¶ added in v0.8.0
func (x *Store_RedisClusterConfig) GetEnableFallback() bool
func (*Store_RedisClusterConfig) GetFallbackPrefix ¶ added in v0.8.0
func (x *Store_RedisClusterConfig) GetFallbackPrefix() string
func (*Store_RedisClusterConfig) GetFlushFrequencySeconds ¶ added in v0.8.0
func (x *Store_RedisClusterConfig) GetFlushFrequencySeconds() int32
func (*Store_RedisClusterConfig) GetInitialBackoffMs ¶
func (x *Store_RedisClusterConfig) GetInitialBackoffMs() int32
func (*Store_RedisClusterConfig) GetKeyPrefix ¶ added in v0.8.0
func (x *Store_RedisClusterConfig) GetKeyPrefix() string
func (*Store_RedisClusterConfig) GetMaxRetries ¶
func (x *Store_RedisClusterConfig) GetMaxRetries() int32
func (*Store_RedisClusterConfig) GetReadFrom ¶ added in v0.9.3
func (x *Store_RedisClusterConfig) GetReadFrom() Store_RedisClusterConfig_ReadFrom
func (*Store_RedisClusterConfig) GetTimeout ¶ added in v0.9.3
func (x *Store_RedisClusterConfig) GetTimeout() *durationpb.Duration
func (*Store_RedisClusterConfig) ProtoMessage ¶
func (*Store_RedisClusterConfig) ProtoMessage()
func (*Store_RedisClusterConfig) ProtoReflect ¶
func (x *Store_RedisClusterConfig) ProtoReflect() protoreflect.Message
func (*Store_RedisClusterConfig) Reset ¶
func (x *Store_RedisClusterConfig) Reset()
func (*Store_RedisClusterConfig) String ¶
func (x *Store_RedisClusterConfig) String() string
type Store_RedisClusterConfig_ ¶
type Store_RedisClusterConfig_ struct {
RedisClusterConfig *Store_RedisClusterConfig `protobuf:"bytes,14,opt,name=redis_cluster_config,json=redisClusterConfig,proto3,oneof"`
}
type Store_RedisClusterConfig_ReadFrom ¶ added in v0.9.3
type Store_RedisClusterConfig_ReadFrom int32
Optional. Priority of nodes when reading from cluster
const ( Store_RedisClusterConfig_MASTER Store_RedisClusterConfig_ReadFrom = 0 Store_RedisClusterConfig_MASTER_PREFERRED Store_RedisClusterConfig_ReadFrom = 1 Store_RedisClusterConfig_REPLICA Store_RedisClusterConfig_ReadFrom = 2 Store_RedisClusterConfig_REPLICA_PREFERRED Store_RedisClusterConfig_ReadFrom = 3 )
func (Store_RedisClusterConfig_ReadFrom) Descriptor ¶ added in v0.9.3
func (Store_RedisClusterConfig_ReadFrom) Descriptor() protoreflect.EnumDescriptor
func (Store_RedisClusterConfig_ReadFrom) Enum ¶ added in v0.9.3
func (x Store_RedisClusterConfig_ReadFrom) Enum() *Store_RedisClusterConfig_ReadFrom
func (Store_RedisClusterConfig_ReadFrom) EnumDescriptor
deprecated
added in
v0.9.3
func (Store_RedisClusterConfig_ReadFrom) EnumDescriptor() ([]byte, []int)
Deprecated: Use Store_RedisClusterConfig_ReadFrom.Descriptor instead.
func (Store_RedisClusterConfig_ReadFrom) Number ¶ added in v0.9.3
func (x Store_RedisClusterConfig_ReadFrom) Number() protoreflect.EnumNumber
func (Store_RedisClusterConfig_ReadFrom) String ¶ added in v0.9.3
func (x Store_RedisClusterConfig_ReadFrom) String() string
func (Store_RedisClusterConfig_ReadFrom) Type ¶ added in v0.9.3
func (Store_RedisClusterConfig_ReadFrom) Type() protoreflect.EnumType
type Store_RedisConfig ¶
type Store_RedisConfig struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // Optional. The number of milliseconds to wait before retrying failed Redis connection. // By default, Feast uses exponential backoff policy and "initial_backoff_ms" sets the initial wait duration. InitialBackoffMs int32 `protobuf:"varint,3,opt,name=initial_backoff_ms,json=initialBackoffMs,proto3" json:"initial_backoff_ms,omitempty"` // Optional. Maximum total number of retries for connecting to Redis. Default to zero retries. MaxRetries int32 `protobuf:"varint,4,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"` // Optional. How often flush data to redis FlushFrequencySeconds int32 `` /* 127-byte string literal not displayed */ // Optional. Connect over SSL. Ssl bool `protobuf:"varint,6,opt,name=ssl,proto3" json:"ssl,omitempty"` // contains filtered or unexported fields }
func (*Store_RedisConfig) Descriptor
deprecated
func (*Store_RedisConfig) Descriptor() ([]byte, []int)
Deprecated: Use Store_RedisConfig.ProtoReflect.Descriptor instead.
func (*Store_RedisConfig) GetFlushFrequencySeconds ¶ added in v0.8.0
func (x *Store_RedisConfig) GetFlushFrequencySeconds() int32
func (*Store_RedisConfig) GetHost ¶
func (x *Store_RedisConfig) GetHost() string
func (*Store_RedisConfig) GetInitialBackoffMs ¶
func (x *Store_RedisConfig) GetInitialBackoffMs() int32
func (*Store_RedisConfig) GetMaxRetries ¶
func (x *Store_RedisConfig) GetMaxRetries() int32
func (*Store_RedisConfig) GetPort ¶
func (x *Store_RedisConfig) GetPort() int32
func (*Store_RedisConfig) GetSsl ¶ added in v0.9.0
func (x *Store_RedisConfig) GetSsl() bool
func (*Store_RedisConfig) ProtoMessage ¶
func (*Store_RedisConfig) ProtoMessage()
func (*Store_RedisConfig) ProtoReflect ¶
func (x *Store_RedisConfig) ProtoReflect() protoreflect.Message
func (*Store_RedisConfig) Reset ¶
func (x *Store_RedisConfig) Reset()
func (*Store_RedisConfig) String ¶
func (x *Store_RedisConfig) String() string
type Store_RedisConfig_ ¶
type Store_RedisConfig_ struct {
RedisConfig *Store_RedisConfig `protobuf:"bytes,11,opt,name=redis_config,json=redisConfig,proto3,oneof"`
}
type Store_StoreType ¶
type Store_StoreType int32
const ( Store_INVALID Store_StoreType = 0 // Redis stores a FeatureRow element as a key, value pair. // // The Redis data types used (https://redis.io/topics/data-types): // - key: STRING // - value: STRING // // Encodings: // - key: byte array of RedisKey (refer to feast.storage.RedisKeyV2) // - value: Redis hashmap // Store_REDIS Store_StoreType = 1 Store_REDIS_CLUSTER Store_StoreType = 4 )
func (Store_StoreType) Descriptor ¶
func (Store_StoreType) Descriptor() protoreflect.EnumDescriptor
func (Store_StoreType) Enum ¶
func (x Store_StoreType) Enum() *Store_StoreType
func (Store_StoreType) EnumDescriptor
deprecated
func (Store_StoreType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Store_StoreType.Descriptor instead.
func (Store_StoreType) Number ¶
func (x Store_StoreType) Number() protoreflect.EnumNumber
func (Store_StoreType) String ¶
func (x Store_StoreType) String() string
func (Store_StoreType) Type ¶
func (Store_StoreType) Type() protoreflect.EnumType
type Store_Subscription ¶
type Store_Subscription struct { // Name of project that the feature sets belongs to. This can be one of // - [project_name] // - * // If an asterisk is provided, filtering on projects will be disabled. All projects will // be matched. It is NOT possible to provide an asterisk with a string in order to do // pattern matching. Project string `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"` // Name of the desired feature set. Asterisks can be used as wildcards in the name. // Matching on names is only permitted if a specific project is defined. It is disallowed // If the project name is set to "*" // e.g. // - * can be used to match all feature sets // - my-feature-set* can be used to match all features prefixed by "my-feature-set" // - my-feature-set-6 can be used to select a single feature set Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // All matches with exclude enabled will be filtered out instead of added Exclude bool `protobuf:"varint,4,opt,name=exclude,proto3" json:"exclude,omitempty"` // contains filtered or unexported fields }
func (*Store_Subscription) Descriptor
deprecated
func (*Store_Subscription) Descriptor() ([]byte, []int)
Deprecated: Use Store_Subscription.ProtoReflect.Descriptor instead.
func (*Store_Subscription) GetExclude ¶ added in v0.6.2
func (x *Store_Subscription) GetExclude() bool
func (*Store_Subscription) GetName ¶
func (x *Store_Subscription) GetName() string
func (*Store_Subscription) GetProject ¶
func (x *Store_Subscription) GetProject() string
func (*Store_Subscription) ProtoMessage ¶
func (*Store_Subscription) ProtoMessage()
func (*Store_Subscription) ProtoReflect ¶
func (x *Store_Subscription) ProtoReflect() protoreflect.Message
func (*Store_Subscription) Reset ¶
func (x *Store_Subscription) Reset()
func (*Store_Subscription) String ¶
func (x *Store_Subscription) String() string
type StreamFormat ¶ added in v0.8.0
type StreamFormat struct { // Specifies the data format and format specific options // // Types that are assignable to Format: // *StreamFormat_AvroFormat_ // *StreamFormat_ProtoFormat_ Format isStreamFormat_Format `protobuf_oneof:"format"` // contains filtered or unexported fields }
Defines the data format encoding features/entity data in data streams
func (*StreamFormat) Descriptor
deprecated
added in
v0.8.0
func (*StreamFormat) Descriptor() ([]byte, []int)
Deprecated: Use StreamFormat.ProtoReflect.Descriptor instead.
func (*StreamFormat) GetAvroFormat ¶ added in v0.8.0
func (x *StreamFormat) GetAvroFormat() *StreamFormat_AvroFormat
func (*StreamFormat) GetFormat ¶ added in v0.8.0
func (m *StreamFormat) GetFormat() isStreamFormat_Format
func (*StreamFormat) GetProtoFormat ¶ added in v0.8.0
func (x *StreamFormat) GetProtoFormat() *StreamFormat_ProtoFormat
func (*StreamFormat) ProtoMessage ¶ added in v0.8.0
func (*StreamFormat) ProtoMessage()
func (*StreamFormat) ProtoReflect ¶ added in v0.8.0
func (x *StreamFormat) ProtoReflect() protoreflect.Message
func (*StreamFormat) Reset ¶ added in v0.8.0
func (x *StreamFormat) Reset()
func (*StreamFormat) String ¶ added in v0.8.0
func (x *StreamFormat) String() string
type StreamFormat_AvroFormat ¶ added in v0.8.0
type StreamFormat_AvroFormat struct { // Optional if used in a File DataSource as schema is embedded in avro file. // Specifies the schema of the Avro message as JSON string. SchemaJson string `protobuf:"bytes,1,opt,name=schema_json,json=schemaJson,proto3" json:"schema_json,omitempty"` // contains filtered or unexported fields }
Defines options for the avro data format
func (*StreamFormat_AvroFormat) Descriptor
deprecated
added in
v0.8.0
func (*StreamFormat_AvroFormat) Descriptor() ([]byte, []int)
Deprecated: Use StreamFormat_AvroFormat.ProtoReflect.Descriptor instead.
func (*StreamFormat_AvroFormat) GetSchemaJson ¶ added in v0.8.0
func (x *StreamFormat_AvroFormat) GetSchemaJson() string
func (*StreamFormat_AvroFormat) ProtoMessage ¶ added in v0.8.0
func (*StreamFormat_AvroFormat) ProtoMessage()
func (*StreamFormat_AvroFormat) ProtoReflect ¶ added in v0.8.0
func (x *StreamFormat_AvroFormat) ProtoReflect() protoreflect.Message
func (*StreamFormat_AvroFormat) Reset ¶ added in v0.8.0
func (x *StreamFormat_AvroFormat) Reset()
func (*StreamFormat_AvroFormat) String ¶ added in v0.8.0
func (x *StreamFormat_AvroFormat) String() string
type StreamFormat_AvroFormat_ ¶ added in v0.8.0
type StreamFormat_AvroFormat_ struct {
AvroFormat *StreamFormat_AvroFormat `protobuf:"bytes,1,opt,name=avro_format,json=avroFormat,proto3,oneof"`
}
type StreamFormat_ProtoFormat ¶ added in v0.8.0
type StreamFormat_ProtoFormat struct { // Classpath to the generated Java Protobuf class that can be used to decode // Feature data from the obtained stream message ClassPath string `protobuf:"bytes,1,opt,name=class_path,json=classPath,proto3" json:"class_path,omitempty"` // contains filtered or unexported fields }
Defines options for the protobuf data format
func (*StreamFormat_ProtoFormat) Descriptor
deprecated
added in
v0.8.0
func (*StreamFormat_ProtoFormat) Descriptor() ([]byte, []int)
Deprecated: Use StreamFormat_ProtoFormat.ProtoReflect.Descriptor instead.
func (*StreamFormat_ProtoFormat) GetClassPath ¶ added in v0.8.0
func (x *StreamFormat_ProtoFormat) GetClassPath() string
func (*StreamFormat_ProtoFormat) ProtoMessage ¶ added in v0.8.0
func (*StreamFormat_ProtoFormat) ProtoMessage()
func (*StreamFormat_ProtoFormat) ProtoReflect ¶ added in v0.8.0
func (x *StreamFormat_ProtoFormat) ProtoReflect() protoreflect.Message
func (*StreamFormat_ProtoFormat) Reset ¶ added in v0.8.0
func (x *StreamFormat_ProtoFormat) Reset()
func (*StreamFormat_ProtoFormat) String ¶ added in v0.8.0
func (x *StreamFormat_ProtoFormat) String() string
type StreamFormat_ProtoFormat_ ¶ added in v0.8.0
type StreamFormat_ProtoFormat_ struct {
ProtoFormat *StreamFormat_ProtoFormat `protobuf:"bytes,2,opt,name=proto_format,json=protoFormat,proto3,oneof"`
}
type UnimplementedCoreServiceServer ¶
type UnimplementedCoreServiceServer struct { }
UnimplementedCoreServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedCoreServiceServer) ApplyEntity ¶ added in v0.8.0
func (*UnimplementedCoreServiceServer) ApplyEntity(context.Context, *ApplyEntityRequest) (*ApplyEntityResponse, error)
func (*UnimplementedCoreServiceServer) ApplyFeatureTable ¶ added in v0.8.0
func (*UnimplementedCoreServiceServer) ApplyFeatureTable(context.Context, *ApplyFeatureTableRequest) (*ApplyFeatureTableResponse, error)
func (*UnimplementedCoreServiceServer) ArchiveProject ¶
func (*UnimplementedCoreServiceServer) ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)
func (*UnimplementedCoreServiceServer) CreateProject ¶
func (*UnimplementedCoreServiceServer) CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)
func (*UnimplementedCoreServiceServer) DeleteFeatureTable ¶ added in v0.9.0
func (*UnimplementedCoreServiceServer) DeleteFeatureTable(context.Context, *DeleteFeatureTableRequest) (*DeleteFeatureTableResponse, error)
func (*UnimplementedCoreServiceServer) GetEntity ¶ added in v0.8.0
func (*UnimplementedCoreServiceServer) GetEntity(context.Context, *GetEntityRequest) (*GetEntityResponse, error)
func (*UnimplementedCoreServiceServer) GetFeastCoreVersion ¶
func (*UnimplementedCoreServiceServer) GetFeastCoreVersion(context.Context, *GetFeastCoreVersionRequest) (*GetFeastCoreVersionResponse, error)
func (*UnimplementedCoreServiceServer) GetFeatureTable ¶ added in v0.8.0
func (*UnimplementedCoreServiceServer) GetFeatureTable(context.Context, *GetFeatureTableRequest) (*GetFeatureTableResponse, error)
func (*UnimplementedCoreServiceServer) ListEntities ¶ added in v0.8.0
func (*UnimplementedCoreServiceServer) ListEntities(context.Context, *ListEntitiesRequest) (*ListEntitiesResponse, error)
func (*UnimplementedCoreServiceServer) ListFeatureTables ¶ added in v0.8.0
func (*UnimplementedCoreServiceServer) ListFeatureTables(context.Context, *ListFeatureTablesRequest) (*ListFeatureTablesResponse, error)
func (*UnimplementedCoreServiceServer) ListFeatures ¶ added in v0.6.2
func (*UnimplementedCoreServiceServer) ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)
func (*UnimplementedCoreServiceServer) ListProjects ¶
func (*UnimplementedCoreServiceServer) ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
func (*UnimplementedCoreServiceServer) ListStores ¶
func (*UnimplementedCoreServiceServer) ListStores(context.Context, *ListStoresRequest) (*ListStoresResponse, error)
func (*UnimplementedCoreServiceServer) UpdateStore ¶
func (*UnimplementedCoreServiceServer) UpdateStore(context.Context, *UpdateStoreRequest) (*UpdateStoreResponse, error)
type UnimplementedJobServiceServer ¶ added in v0.9.0
type UnimplementedJobServiceServer struct { }
UnimplementedJobServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedJobServiceServer) CancelJob ¶ added in v0.9.0
func (*UnimplementedJobServiceServer) CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
func (*UnimplementedJobServiceServer) GetHistoricalFeatures ¶ added in v0.9.0
func (*UnimplementedJobServiceServer) GetHistoricalFeatures(context.Context, *GetHistoricalFeaturesRequest) (*GetHistoricalFeaturesResponse, error)
func (*UnimplementedJobServiceServer) GetJob ¶ added in v0.9.0
func (*UnimplementedJobServiceServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
func (*UnimplementedJobServiceServer) ListJobs ¶ added in v0.9.0
func (*UnimplementedJobServiceServer) ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
func (*UnimplementedJobServiceServer) StartOfflineToOnlineIngestionJob ¶ added in v0.9.0
func (*UnimplementedJobServiceServer) StartOfflineToOnlineIngestionJob(context.Context, *StartOfflineToOnlineIngestionJobRequest) (*StartOfflineToOnlineIngestionJobResponse, error)
func (*UnimplementedJobServiceServer) StartStreamToOnlineIngestionJob ¶ added in v0.9.0
func (*UnimplementedJobServiceServer) StartStreamToOnlineIngestionJob(context.Context, *StartStreamToOnlineIngestionJobRequest) (*StartStreamToOnlineIngestionJobResponse, error)
type UpdateFeatureSetStatusResponse ¶ added in v0.8.0
type UpdateFeatureSetStatusResponse struct {
// contains filtered or unexported fields
}
func (*UpdateFeatureSetStatusResponse) Descriptor
deprecated
added in
v0.8.0
func (*UpdateFeatureSetStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateFeatureSetStatusResponse.ProtoReflect.Descriptor instead.
func (*UpdateFeatureSetStatusResponse) ProtoMessage ¶ added in v0.8.0
func (*UpdateFeatureSetStatusResponse) ProtoMessage()
func (*UpdateFeatureSetStatusResponse) ProtoReflect ¶ added in v0.8.0
func (x *UpdateFeatureSetStatusResponse) ProtoReflect() protoreflect.Message
func (*UpdateFeatureSetStatusResponse) Reset ¶ added in v0.8.0
func (x *UpdateFeatureSetStatusResponse) Reset()
func (*UpdateFeatureSetStatusResponse) String ¶ added in v0.8.0
func (x *UpdateFeatureSetStatusResponse) String() string
type UpdateStoreRequest ¶
type UpdateStoreRequest struct { Store *Store `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"` // contains filtered or unexported fields }
func (*UpdateStoreRequest) Descriptor
deprecated
func (*UpdateStoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateStoreRequest.ProtoReflect.Descriptor instead.
func (*UpdateStoreRequest) GetStore ¶
func (x *UpdateStoreRequest) GetStore() *Store
func (*UpdateStoreRequest) ProtoMessage ¶
func (*UpdateStoreRequest) ProtoMessage()
func (*UpdateStoreRequest) ProtoReflect ¶
func (x *UpdateStoreRequest) ProtoReflect() protoreflect.Message
func (*UpdateStoreRequest) Reset ¶
func (x *UpdateStoreRequest) Reset()
func (*UpdateStoreRequest) String ¶
func (x *UpdateStoreRequest) String() string
type UpdateStoreResponse ¶
type UpdateStoreResponse struct { Store *Store `protobuf:"bytes,1,opt,name=store,proto3" json:"store,omitempty"` Status UpdateStoreResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=feast.core.UpdateStoreResponse_Status" json:"status,omitempty"` // contains filtered or unexported fields }
func (*UpdateStoreResponse) Descriptor
deprecated
func (*UpdateStoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateStoreResponse.ProtoReflect.Descriptor instead.
func (*UpdateStoreResponse) GetStatus ¶
func (x *UpdateStoreResponse) GetStatus() UpdateStoreResponse_Status
func (*UpdateStoreResponse) GetStore ¶
func (x *UpdateStoreResponse) GetStore() *Store
func (*UpdateStoreResponse) ProtoMessage ¶
func (*UpdateStoreResponse) ProtoMessage()
func (*UpdateStoreResponse) ProtoReflect ¶
func (x *UpdateStoreResponse) ProtoReflect() protoreflect.Message
func (*UpdateStoreResponse) Reset ¶
func (x *UpdateStoreResponse) Reset()
func (*UpdateStoreResponse) String ¶
func (x *UpdateStoreResponse) String() string
type UpdateStoreResponse_Status ¶
type UpdateStoreResponse_Status int32
const ( // Existing store config matching the given store id is identical to the given store config. UpdateStoreResponse_NO_CHANGE UpdateStoreResponse_Status = 0 // New store created or existing config updated. UpdateStoreResponse_UPDATED UpdateStoreResponse_Status = 1 )
func (UpdateStoreResponse_Status) Descriptor ¶
func (UpdateStoreResponse_Status) Descriptor() protoreflect.EnumDescriptor
func (UpdateStoreResponse_Status) Enum ¶
func (x UpdateStoreResponse_Status) Enum() *UpdateStoreResponse_Status
func (UpdateStoreResponse_Status) EnumDescriptor
deprecated
func (UpdateStoreResponse_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use UpdateStoreResponse_Status.Descriptor instead.
func (UpdateStoreResponse_Status) Number ¶
func (x UpdateStoreResponse_Status) Number() protoreflect.EnumNumber
func (UpdateStoreResponse_Status) String ¶
func (x UpdateStoreResponse_Status) String() string
func (UpdateStoreResponse_Status) Type ¶
func (UpdateStoreResponse_Status) Type() protoreflect.EnumType