v1alpha1

Jan 18, 2024

Changes in this version

type DataProduct

+ func (dataproduct *DataProduct) MarkNamespaceNotReady(reason string, message string)

+ func (dataproduct *DataProduct) MarkNamespaceReady()

+ func (dataproduct *DataProduct) MarkRbacNotReady(reason string, message string)

+ func (dataproduct *DataProduct) MarkRbacReady()

+ func (product *DataProduct) CreateOrUpdateCondition(cond metav1.Condition)

+ func (product DataProduct) DataProductRole() *rbacv1.Role

+ func (product DataProduct) DataProductRoleBinding() *rbacv1.RoleBinding

+ func (product DataProduct) DataProductServiceAccount() *v1.ServiceAccount

+ func (product DataProduct) GetCondition(t DataProductConditionType) metav1.Condition

+ func (product DataProduct) GetConditionIndex(t string) int

+ func (product DataProduct) NamespaceReady() bool

type DataProductConditionType

+ const DataProductNamespaceReady

+ const DataProductRbacReady

type DatasetSnapshotConditionType

+ const DatasetSnapshotSnapshotTaken

type DatasetSnapshotStatus

+ FeatureHistogramName *string

+ SampleLocation catalog.FileLocation

type DatasetSpec

+ LabName *string

type DatasetStatus

+ AvailableSnapshots catalog.RunReferenceList

type Delimiter

+ const DelimiterAuto

type EscapeChar

+ const AutoEscapeChar

type QuoteChar

+ const AutoQuote

Sep 21, 2023

Changes in this version

+ type ApprovalReviewStatus struct

+ ApprovedAt *metav1.Time

+ Notes string

+ Result ApprovalType

+ Reviewer string

+ func (*ApprovalReviewStatus) Descriptor() ([]byte, []int)

+ func (*ApprovalReviewStatus) ProtoMessage()

+ func (in *ApprovalReviewStatus) DeepCopy() *ApprovalReviewStatus

+ func (in *ApprovalReviewStatus) DeepCopyInto(out *ApprovalReviewStatus)

+ func (m *ApprovalReviewStatus) Marshal() (dAtA []byte, err error)

+ func (m *ApprovalReviewStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *ApprovalReviewStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ApprovalReviewStatus) Reset()

+ func (m *ApprovalReviewStatus) Size() (n int)

+ func (m *ApprovalReviewStatus) Unmarshal(dAtA []byte) error

+ func (m *ApprovalReviewStatus) XXX_DiscardUnknown()

+ func (m *ApprovalReviewStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ApprovalReviewStatus) XXX_Merge(src proto.Message)

+ func (m *ApprovalReviewStatus) XXX_Size() int

+ func (m *ApprovalReviewStatus) XXX_Unmarshal(b []byte) error

+ func (this *ApprovalReviewStatus) String() string

+ type ApprovalSpec struct

+ DecisionType *DecisionType

+ Enabled *bool

+ Reviewers []string

+ func (*ApprovalSpec) Descriptor() ([]byte, []int)

+ func (*ApprovalSpec) ProtoMessage()

+ func (in *ApprovalSpec) DeepCopy() *ApprovalSpec

+ func (in *ApprovalSpec) DeepCopyInto(out *ApprovalSpec)

+ func (m *ApprovalSpec) Marshal() (dAtA []byte, err error)

+ func (m *ApprovalSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ApprovalSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ApprovalSpec) Reset()

+ func (m *ApprovalSpec) Size() (n int)

+ func (m *ApprovalSpec) Unmarshal(dAtA []byte) error

+ func (m *ApprovalSpec) XXX_DiscardUnknown()

+ func (m *ApprovalSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ApprovalSpec) XXX_Merge(src proto.Message)

+ func (m *ApprovalSpec) XXX_Size() int

+ func (m *ApprovalSpec) XXX_Unmarshal(b []byte) error

+ func (this *ApprovalSpec) String() string

+ type ApprovalStatus struct

+ Reviews []ApprovalReviewStatus

+ Status ApprovalType

+ func (*ApprovalStatus) Descriptor() ([]byte, []int)

+ func (*ApprovalStatus) ProtoMessage()

+ func (in *ApprovalStatus) DeepCopy() *ApprovalStatus

+ func (in *ApprovalStatus) DeepCopyInto(out *ApprovalStatus)

+ func (m *ApprovalStatus) Marshal() (dAtA []byte, err error)

+ func (m *ApprovalStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *ApprovalStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ApprovalStatus) Reset()

+ func (m *ApprovalStatus) Size() (n int)

+ func (m *ApprovalStatus) Unmarshal(dAtA []byte) error

+ func (m *ApprovalStatus) XXX_DiscardUnknown()

+ func (m *ApprovalStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ApprovalStatus) XXX_Merge(src proto.Message)

+ func (m *ApprovalStatus) XXX_Size() int

+ func (m *ApprovalStatus) XXX_Unmarshal(b []byte) error

+ func (this *ApprovalStatus) String() string

type ApprovalType

+ const ApprovalTypeUnconfirmed

+ const DecisionTypeMajority

+ const DecisionTypeOneOrMore

+ const DecisionTypeUnanimous

type Correlation

+ X string

+ Y string

type DataOutputSpec

+ IncludeShapValues *bool

type DataPipeline

+ func (datapipeline *DataPipeline) SetObservedGeneration(generation int64)

+ func (datapipeline *DataPipeline) SetStatus(status interface{})

+ func (datapipeline *DataPipeline) SetUpdatedAt(time *metav1.Time)

+ func (datapipeline DataPipeline) GetObservedGeneration() int64

+ func (datapipeline DataPipeline) GetStatus() proto.Message

type DataPipelineRun

+ func (datapipelinerun *DataPipelineRun) SetObservedGeneration(generation int64)

+ func (datapipelinerun *DataPipelineRun) SetStatus(status interface{})

+ func (datapipelinerun *DataPipelineRun) SetUpdatedAt(time *metav1.Time)

+ func (datapipelinerun DataPipelineRun) GetObservedGeneration() int64

+ func (datapipelinerun DataPipelineRun) GetStatus() proto.Message

type DataProduct

+ func (dataproduct *DataProduct) SetObservedGeneration(generation int64)

+ func (dataproduct *DataProduct) SetStatus(status interface{})

+ func (dataproduct *DataProduct) SetUpdatedAt(time *metav1.Time)

+ func (dataproduct DataProduct) GetObservedGeneration() int64

+ func (dataproduct DataProduct) GetStatus() proto.Message

type DataProductSpec

+ Approval *ApprovalSpec

+ CacheBucketName string

+ DefaultBucketName *string

+ DefaultLabName *string

+ DefaultServingSiteName *string

type DataProductVersion

+ func (dataproductversion *DataProductVersion) SetObservedGeneration(generation int64)

+ func (dataproductversion *DataProductVersion) SetStatus(status interface{})

+ func (dataproductversion *DataProductVersion) SetUpdatedAt(time *metav1.Time)

+ func (dataproductversion DataProductVersion) GetObservedGeneration() int64

+ func (dataproductversion DataProductVersion) GetStatus() proto.Message

type DataSource

+ func ParseDataSourceYaml(content []byte) (*DataSource, error)

+ func (datasource *DataSource) SetObservedGeneration(generation int64)

+ func (datasource *DataSource) SetStatus(status interface{})

+ func (datasource *DataSource) SetUpdatedAt(time *metav1.Time)

+ func (datasource DataSource) GetObservedGeneration() int64

+ func (datasource DataSource) GetStatus() proto.Message

type Dataset

+ func (dataset *Dataset) CreateOrUpdateCondition(cond metav1.Condition)

+ func (dataset *Dataset) GetCondition(condType DatasetConditionType) metav1.Condition

+ func (dataset *Dataset) GetConditionIndex(t string) int

+ func (dataset *Dataset) GetObservedGeneration() int64

+ func (dataset *Dataset) GetStatus() proto.Message

+ func (dataset *Dataset) MarkNotSaved()

+ func (dataset *Dataset) SetObservedGeneration(generation int64)

+ func (dataset *Dataset) SetStatus(status interface{})

+ func (dataset *Dataset) SetUpdatedAt(time *metav1.Time)

+ func (dataset *Dataset) Validate(field string) ([]metav1.StatusCause, bool)

+ type DatasetSnapshot struct

+ Spec DatasetSnapshotSpec

+ Status DatasetSnapshotStatus

+ func ParseDatasetSnapshotYaml(content []byte) (*DatasetSnapshot, error)

+ func (*DatasetSnapshot) Descriptor() ([]byte, []int)

+ func (*DatasetSnapshot) ProtoMessage()

+ func (dataset *DatasetSnapshot) Aborted() bool

+ func (dataset *DatasetSnapshot) AddFinalizer()

+ func (dataset *DatasetSnapshot) CompletionAlert(notification catalog.NotificationSpec) *infra.Alert

+ func (dataset *DatasetSnapshot) ConstructFeatureHistogram() (*FeatureHistogram, error)

+ func (dataset *DatasetSnapshot) CreateOrUpdateCondition(cond metav1.Condition)

+ func (dataset *DatasetSnapshot) DataSourceManifestURI() string

+ func (dataset *DatasetSnapshot) DatasetManifestURI() string

+ func (dataset *DatasetSnapshot) Default()

+ func (dataset *DatasetSnapshot) Deleted() bool

+ func (dataset *DatasetSnapshot) DriftColumnNames() []string

+ func (dataset *DatasetSnapshot) ErrorAlert(notification catalog.NotificationSpec, err error) *infra.Alert

+ func (dataset *DatasetSnapshot) ExternalStatusUpdated() bool

+ func (dataset *DatasetSnapshot) Failed() bool

+ func (dataset *DatasetSnapshot) Generated() bool

+ func (dataset *DatasetSnapshot) GetColumn(name string) (*FeatureStatistics, error)

+ func (dataset *DatasetSnapshot) GetCondition(condType DatasetSnapshotConditionType) metav1.Condition

+ func (dataset *DatasetSnapshot) GetConditionIndex(t string) int

+ func (dataset *DatasetSnapshot) GetObservedGeneration() int64

+ func (dataset *DatasetSnapshot) GetStatus() proto.Message

+ func (dataset *DatasetSnapshot) GroupDataFile(keys []string) string

+ func (dataset *DatasetSnapshot) GroupDataFolder(keys []string) string

+ func (dataset *DatasetSnapshot) GroupFolder(keys []string) string

+ func (dataset *DatasetSnapshot) GroupForecastFile(keys []string) string

+ func (dataset *DatasetSnapshot) GroupProfileFolder(keys []string) string

+ func (dataset *DatasetSnapshot) GroupReportFile(keys []string) string

+ func (dataset *DatasetSnapshot) Grouped() bool

+ func (dataset *DatasetSnapshot) GroupsFolder() string

+ func (dataset *DatasetSnapshot) HasFinalizer() bool

+ func (dataset *DatasetSnapshot) HasScheduleTrigger() bool

+ func (dataset *DatasetSnapshot) IndexFileKey() string

+ func (dataset *DatasetSnapshot) ManifestURI() string

+ func (dataset *DatasetSnapshot) MarkAborted()

+ func (dataset *DatasetSnapshot) MarkExternalStatusNotUpdated()

+ func (dataset *DatasetSnapshot) MarkExternalStatusUpdated()

+ func (dataset *DatasetSnapshot) MarkGenerated()

+ func (dataset *DatasetSnapshot) MarkGeneratedFailed(reason string, msg string)

+ func (dataset *DatasetSnapshot) MarkGenerating()

+ func (dataset *DatasetSnapshot) MarkGroupFailed(reason string, msg string)

+ func (dataset *DatasetSnapshot) MarkGroupSuccess()

+ func (dataset *DatasetSnapshot) MarkGrouping()

+ func (dataset *DatasetSnapshot) MarkPrepareFailed(reason string, msg string)

+ func (dataset *DatasetSnapshot) MarkPrepareSuccess()

+ func (dataset *DatasetSnapshot) MarkPreparing()

+ func (dataset *DatasetSnapshot) MarkProfileFailed(reason string, err string)

+ func (dataset *DatasetSnapshot) MarkProfiled(profileLocation catalog.FileLocation)

+ func (dataset *DatasetSnapshot) MarkProfiling()

+ func (dataset *DatasetSnapshot) MarkReady()

+ func (dataset *DatasetSnapshot) MarkReadyFailed(reason string, err string)

+ func (dataset *DatasetSnapshot) MarkReportFailed(reason string, msg string)

+ func (dataset *DatasetSnapshot) MarkReported()

+ func (dataset *DatasetSnapshot) MarkReporting()

+ func (dataset *DatasetSnapshot) MarkSkewColumns()

+ func (dataset *DatasetSnapshot) MarkSnapshotFailed(reason string, msg string)

+ func (dataset *DatasetSnapshot) MarkSnapshotSuccess()

+ func (dataset *DatasetSnapshot) MarkTakingSnapshot()

+ func (dataset *DatasetSnapshot) MarkUnitTestFailed(reason string, msg string)

+ func (dataset *DatasetSnapshot) MarkUnitTested()

+ func (dataset *DatasetSnapshot) MarkUnitTesting()

+ func (dataset *DatasetSnapshot) Paused() bool

+ func (dataset *DatasetSnapshot) Prepared() bool

+ func (dataset *DatasetSnapshot) ProfileURI() string

+ func (dataset *DatasetSnapshot) Profiled() bool

+ func (dataset *DatasetSnapshot) ReachedMaxTime() bool

+ func (dataset *DatasetSnapshot) Ready() bool

+ func (dataset *DatasetSnapshot) RefreshProgress()

+ func (dataset *DatasetSnapshot) RemoveFinalizer()

+ func (dataset *DatasetSnapshot) ReportName() string

+ func (dataset *DatasetSnapshot) ReportURI() string

+ func (dataset *DatasetSnapshot) Reported() bool

+ func (dataset *DatasetSnapshot) RootURI() string

+ func (dataset *DatasetSnapshot) SetObservedGeneration(generation int64)

+ func (dataset *DatasetSnapshot) SetStatus(status interface{})

+ func (dataset *DatasetSnapshot) SetUpdatedAt(time *metav1.Time)

+ func (dataset *DatasetSnapshot) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (dataset *DatasetSnapshot) Snapshotted() bool

+ func (dataset *DatasetSnapshot) TaskIndexFileKey(task string) string

+ func (dataset *DatasetSnapshot) ToRunReference() catalog.RunReference

+ func (dataset *DatasetSnapshot) UnitTested() bool

+ func (dataset *DatasetSnapshot) ValidateCreate() error

+ func (dataset *DatasetSnapshot) ValidateDelete() error

+ func (dataset *DatasetSnapshot) ValidateUpdate(old runtime.Object) error

+ func (dataset *DatasetSnapshot) WorkerIndexFileKey(workerIndex int, task string) string

+ func (in *DatasetSnapshot) DeepCopy() *DatasetSnapshot

+ func (in *DatasetSnapshot) DeepCopyInto(out *DatasetSnapshot)

+ func (in *DatasetSnapshot) DeepCopyObject() runtime.Object

+ func (m *DatasetSnapshot) Marshal() (dAtA []byte, err error)

+ func (m *DatasetSnapshot) MarshalTo(dAtA []byte) (int, error)

+ func (m *DatasetSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DatasetSnapshot) Reset()

+ func (m *DatasetSnapshot) Size() (n int)

+ func (m *DatasetSnapshot) Unmarshal(dAtA []byte) error

+ func (m *DatasetSnapshot) XXX_DiscardUnknown()

+ func (m *DatasetSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DatasetSnapshot) XXX_Merge(src proto.Message)

+ func (m *DatasetSnapshot) XXX_Size() int

+ func (m *DatasetSnapshot) XXX_Unmarshal(b []byte) error

+ func (this *DatasetSnapshot) String() string

+ type DatasetSnapshotConditionType string

+ const DatasetSnapshotAborted

+ const DatasetSnapshotExternalStatusUpdated

+ const DatasetSnapshotGenerated

+ const DatasetSnapshotGrouped

+ const DatasetSnapshotIngested

+ const DatasetSnapshotPaused

+ const DatasetSnapshotPrepared

+ const DatasetSnapshotProfiled

+ const DatasetSnapshotReady

+ const DatasetSnapshotReported

+ const DatasetSnapshotSnapshotted

+ const DatasetSnapshotUnitTested

+ type DatasetSnapshotList struct

+ Items []DatasetSnapshot

+ func (*DatasetSnapshotList) Descriptor() ([]byte, []int)

+ func (*DatasetSnapshotList) ProtoMessage()

+ func (in *DatasetSnapshotList) DeepCopy() *DatasetSnapshotList

+ func (in *DatasetSnapshotList) DeepCopyInto(out *DatasetSnapshotList)

+ func (in *DatasetSnapshotList) DeepCopyObject() runtime.Object

+ func (m *DatasetSnapshotList) Marshal() (dAtA []byte, err error)

+ func (m *DatasetSnapshotList) MarshalTo(dAtA []byte) (int, error)

+ func (m *DatasetSnapshotList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DatasetSnapshotList) Reset()

+ func (m *DatasetSnapshotList) Size() (n int)

+ func (m *DatasetSnapshotList) Unmarshal(dAtA []byte) error

+ func (m *DatasetSnapshotList) XXX_DiscardUnknown()

+ func (m *DatasetSnapshotList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DatasetSnapshotList) XXX_Merge(src proto.Message)

+ func (m *DatasetSnapshotList) XXX_Size() int

+ func (m *DatasetSnapshotList) XXX_Unmarshal(b []byte) error

+ func (this *DatasetSnapshotList) String() string

+ type DatasetSnapshotPhase string

+ const DatasetSnapshotPhaseAborted

+ const DatasetSnapshotPhaseFailed

+ const DatasetSnapshotPhaseGenerateSuccess

+ const DatasetSnapshotPhaseGenerating

+ const DatasetSnapshotPhaseGrouped

+ const DatasetSnapshotPhaseGrouping

+ const DatasetSnapshotPhaseIngestRunning

+ const DatasetSnapshotPhaseIngestSuccess

+ const DatasetSnapshotPhasePending

+ const DatasetSnapshotPhasePrepared

+ const DatasetSnapshotPhasePreparing

+ const DatasetSnapshotPhaseProfileRunning

+ const DatasetSnapshotPhaseProfileSuccess

+ const DatasetSnapshotPhaseReady

+ const DatasetSnapshotPhaseReportRunning

+ const DatasetSnapshotPhaseReportSuccess

+ const DatasetSnapshotPhaseSnapshotRunning

+ const DatasetSnapshotPhaseSnapshotSuccess

+ const DatasetSnapshotPhaseUnitTesting

+ type DatasetSnapshotSpec struct

+ Abort *bool

+ DatasetName string

+ ModelClassRunName *string

+ Owner *string

+ Pause *bool

+ Timeout *int64

+ func (*DatasetSnapshotSpec) Descriptor() ([]byte, []int)

+ func (*DatasetSnapshotSpec) ProtoMessage()

+ func (in *DatasetSnapshotSpec) DeepCopy() *DatasetSnapshotSpec

+ func (in *DatasetSnapshotSpec) DeepCopyInto(out *DatasetSnapshotSpec)

+ func (m *DatasetSnapshotSpec) Marshal() (dAtA []byte, err error)

+ func (m *DatasetSnapshotSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *DatasetSnapshotSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DatasetSnapshotSpec) Reset()

+ func (m *DatasetSnapshotSpec) Size() (n int)

+ func (m *DatasetSnapshotSpec) Unmarshal(dAtA []byte) error

+ func (m *DatasetSnapshotSpec) XXX_DiscardUnknown()

+ func (m *DatasetSnapshotSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DatasetSnapshotSpec) XXX_Merge(src proto.Message)

+ func (m *DatasetSnapshotSpec) XXX_Size() int

+ func (m *DatasetSnapshotSpec) XXX_Unmarshal(b []byte) error

+ func (this *DatasetSnapshotSpec) String() string

+ type DatasetSnapshotStatus struct

+ AnomaliesLocation catalog.FileLocation

+ CompletedAt *metav1.Time

+ Conditions []metav1.Condition

+ DataLocation catalog.FileLocation

+ DataSourceManifestLocation catalog.ManifestLocation

+ DatasetManifestLocation catalog.ManifestLocation

+ FailureMessage *string

+ FeatureHistogramRef v1.ObjectReference

+ GroupBy DatasetGroupByStatus

+ Hash string

+ Images catalog.Images

+ Imbalanced bool

+ LastStudyAt *metav1.Time

+ Logs catalog.Logs

+ ObservedGeneration int64

+ Phase DatasetSnapshotPhase

+ ProfileLocation catalog.FileLocation

+ Progress int32

+ ReportLocation catalog.FileLocation

+ ReportName string

+ SnapshotVersion catalog.Version

+ Statistics DatasetStatistics

+ UnitTestResults catalog.TestSuiteResult

+ UpdatedAt *metav1.Time

+ func (*DatasetSnapshotStatus) Descriptor() ([]byte, []int)

+ func (*DatasetSnapshotStatus) ProtoMessage()

+ func (in *DatasetSnapshotStatus) DeepCopy() *DatasetSnapshotStatus

+ func (in *DatasetSnapshotStatus) DeepCopyInto(out *DatasetSnapshotStatus)

+ func (m *DatasetSnapshotStatus) Marshal() (dAtA []byte, err error)

+ func (m *DatasetSnapshotStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *DatasetSnapshotStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DatasetSnapshotStatus) Reset()

+ func (m *DatasetSnapshotStatus) Size() (n int)

+ func (m *DatasetSnapshotStatus) Unmarshal(dAtA []byte) error

+ func (m *DatasetSnapshotStatus) XXX_DiscardUnknown()

+ func (m *DatasetSnapshotStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DatasetSnapshotStatus) XXX_Merge(src proto.Message)

+ func (m *DatasetSnapshotStatus) XXX_Size() int

+ func (m *DatasetSnapshotStatus) XXX_Unmarshal(b []byte) error

+ func (this *DatasetSnapshotStatus) String() string

type DatasetSpec

+ ArtifactBucketName *string

+ Report *bool

+ Run catalog.RunSpec

+ Schedule catalog.RunSchedule

+ UnitTest *bool

type DatasetStatistics

+ Features []FeatureStatistics

+ SizeInBytes int32

type DatasetStatus

+ Active catalog.RunReferenceList

+ AvailableSnapshotVersions catalog.VersionList

+ LastFailureMessage *string

+ LastSnapshotAt *metav1.Time

+ LastSnapshotVersion catalog.Version

+ Schedule catalog.RunScheduleStatus

+ Version catalog.Version

+ type DecisionType string

type Entity

+ func (entity *Entity) SetStatus(status interface{})

+ func (entity Entity) GetObservedGeneration() int64

+ func (entity Entity) GetStatus() proto.Message

+ func (entity Entity) SetObservedGeneration(generation int64)

+ func (entity Entity) SetUpdatedAt(time *metav1.Time)

type FeatureGroup

+ func (featuregroup *FeatureGroup) SetObservedGeneration(generation int64)

+ func (featuregroup *FeatureGroup) SetStatus(status interface{})

+ func (featuregroup *FeatureGroup) SetUpdatedAt(time *metav1.Time)

+ func (featuregroup FeatureGroup) GetObservedGeneration() int64

+ func (featuregroup FeatureGroup) GetStatus() proto.Message

type FeatureGroupSpec

+ ArtifactBucketName *string

+ LabRef *v1.ObjectReference

type FeatureHistogram

+ func (featurehistogram *FeatureHistogram) SetObservedGeneration(generation int64)

+ func (featurehistogram *FeatureHistogram) SetStatus(status interface{})

+ func (featurehistogram *FeatureHistogram) SetUpdatedAt(time *metav1.Time)

+ func (featurehistogram FeatureHistogram) GetObservedGeneration() int64

+ func (featurehistogram FeatureHistogram) GetStatus() proto.Message

+ type FeatureStatistics struct

+ Completeness float64

+ Constant bool

+ CorrToTarget float64

+ Count float64

+ DataType catalog.DataType

+ Distinct int32

+ DistinctValueCount float64

+ Duplicate bool

+ HighCardinality bool

+ HighCorrWithOtherFeatures bool

+ HighMissingPct bool

+ Histogram catalog.HistogramData

+ IQR float64

+ Ignore bool

+ Importance float64

+ Index int32

+ Invalid int32

+ Kurtosis float64

+ LowCorrWithTarget bool

+ Mad float64

+ Max float64

+ Mean float64

+ Min float64

+ Missing int32

+ Mode string

+ MostFreqValuesRatio float64

+ Name string

+ Nullable bool

+ Outliers OutlierStatistics

+ P25 float64

+ P50 float64

+ P75 float64

+ PercentMissing float64

+ Reserved bool

+ Skewed bool

+ Skewness float64

+ StdDev float64

+ Sum int64

+ Target bool

+ Values []string

+ Variance float64

+ Zeros float64

+ func (*FeatureStatistics) Descriptor() ([]byte, []int)

+ func (*FeatureStatistics) ProtoMessage()

+ func (feature FeatureStatistics) BigBoolTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (feature FeatureStatistics) BigCatTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (feature FeatureStatistics) BigNumericTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (feature FeatureStatistics) GenDriftTestCase(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (feature FeatureStatistics) SmallBoolTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (feature FeatureStatistics) SmallCatTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (feature FeatureStatistics) SmallNumericTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (in *FeatureStatistics) DeepCopy() *FeatureStatistics

+ func (in *FeatureStatistics) DeepCopyInto(out *FeatureStatistics)

+ func (m *FeatureStatistics) Marshal() (dAtA []byte, err error)

+ func (m *FeatureStatistics) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureStatistics) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureStatistics) Reset()

+ func (m *FeatureStatistics) Size() (n int)

+ func (m *FeatureStatistics) Unmarshal(dAtA []byte) error

+ func (m *FeatureStatistics) XXX_DiscardUnknown()

+ func (m *FeatureStatistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureStatistics) XXX_Merge(src proto.Message)

+ func (m *FeatureStatistics) XXX_Size() int

+ func (m *FeatureStatistics) XXX_Unmarshal(b []byte) error

+ func (this *FeatureStatistics) String() string

type GroupBySpec

+ Aggregate catalog.Aggregate

+ Frequency *catalog.Frequency

+ type GroupDatasetLocationStatus struct

+ GroupDataFolder *string

+ GroupDataIndex *string

+ GroupFeaturesFile *string

+ GroupProfileFolder *string

+ GroupReportIndex *string

+ GroupRoot *string

+ GroupsRoot *string

+ func (*GroupDatasetLocationStatus) Descriptor() ([]byte, []int)

+ func (*GroupDatasetLocationStatus) ProtoMessage()

+ func (in *GroupDatasetLocationStatus) DeepCopy() *GroupDatasetLocationStatus

+ func (in *GroupDatasetLocationStatus) DeepCopyInto(out *GroupDatasetLocationStatus)

+ func (m *GroupDatasetLocationStatus) Marshal() (dAtA []byte, err error)

+ func (m *GroupDatasetLocationStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *GroupDatasetLocationStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GroupDatasetLocationStatus) Reset()

+ func (m *GroupDatasetLocationStatus) Size() (n int)

+ func (m *GroupDatasetLocationStatus) Unmarshal(dAtA []byte) error

+ func (m *GroupDatasetLocationStatus) XXX_DiscardUnknown()

+ func (m *GroupDatasetLocationStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GroupDatasetLocationStatus) XXX_Merge(src proto.Message)

+ func (m *GroupDatasetLocationStatus) XXX_Size() int

+ func (m *GroupDatasetLocationStatus) XXX_Unmarshal(b []byte) error

+ func (this *GroupDatasetLocationStatus) String() string

+ type OutlierStatistics struct

+ Lower int32

+ Percent float32

+ Upper int32

+ func (*OutlierStatistics) Descriptor() ([]byte, []int)

+ func (*OutlierStatistics) ProtoMessage()

+ func (in *OutlierStatistics) DeepCopy() *OutlierStatistics

+ func (in *OutlierStatistics) DeepCopyInto(out *OutlierStatistics)

+ func (m *OutlierStatistics) Marshal() (dAtA []byte, err error)

+ func (m *OutlierStatistics) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutlierStatistics) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutlierStatistics) Reset()

+ func (m *OutlierStatistics) Size() (n int)

+ func (m *OutlierStatistics) Unmarshal(dAtA []byte) error

+ func (m *OutlierStatistics) XXX_DiscardUnknown()

+ func (m *OutlierStatistics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OutlierStatistics) XXX_Merge(src proto.Message)

+ func (m *OutlierStatistics) XXX_Size() int

+ func (m *OutlierStatistics) XXX_Unmarshal(b []byte) error

+ func (this *OutlierStatistics) String() string

type Recipe

+ func (recipe *Recipe) SetObservedGeneration(generation int64)

+ func (recipe *Recipe) SetStatus(status interface{})

+ func (recipe *Recipe) SetUpdatedAt(time *metav1.Time)

+ func (recipe Recipe) GetObservedGeneration() int64

+ func (recipe Recipe) GetStatus() proto.Message

type RecipeRun

+ func (reciperun *RecipeRun) SetObservedGeneration(generation int64)

+ func (reciperun *RecipeRun) SetStatus(status interface{})

+ func (reciperun *RecipeRun) SetUpdatedAt(time *metav1.Time)

+ func (reciperun RecipeRun) GetObservedGeneration() int64

+ func (reciperun RecipeRun) GetStatus() proto.Message

type SampleSpec

+ Percent *int32

Feb 27, 2023

Changes in this version

type DataInputSpec

+ PreSQL []string

Dec 22, 2022

Changes in this version

type DataInputSpec

+ PreSql []string

type DataOutputSpec

+ PostSQL []string

Dec 13, 2022

Changes in this version

type DataLocation

+ func (loc DataLocation) Validate(field string) ([]metav1.StatusCause, bool)

type GroupBySpec

+ func (gb GroupBySpec) Validate(field string) ([]metav1.StatusCause, bool)

Dec 5, 2022

Changes in this version

type DataPipelineRunStatus

+ CompletedAt *metav1.Time

+ UpdatedAt *metav1.Time

type DataProductStatus

+ ModelClassesCount int32

type DataSourceStatus

+ LastDatasetCreatedAt *metav1.Time

type DatasetSpec

+ Timeout *int64

type FeatureGroupStatus

+ FailureMessage *string

+ FailureReason *catalog.StatusError

Dec 4, 2022

Changes in this version

type DataPipelineStatus

+ LastRunName string

+ RunsCount int32

+ Schedule catalog.RunScheduleStatus

type FeatureGroupSpec

+ Tests catalog.TestSuite

type RecipeRunStatus

+ CompletedAt *metav1.Time

+ UpdatedAt *metav1.Time

type RecipeSpec

+ Timeout *int64

Dec 4, 2022

Changes in this version

type DataPipeline

+ func (wr DataPipeline) ManifestURI() string

+ func (wr DataPipeline) RootURI() string

type DataPipelineRun

+ func (run DataPipelineRun) ManifestURI() string

+ func (run DataPipelineRun) RootURI() string

type DataProduct

+ func (product DataProduct) PrefixArchiveURI(uri string) string

+ func (product DataProduct) PrefixDepotURI(uri string) string

+ func (product DataProduct) PrefixLiveURI(uri string) string

+ func (product DataProduct) YamlURI() string

type DataProductVersion

+ func (version DataProductVersion) MessageURI() string

+ func (version DataProductVersion) YamlURI() string

type DataSource

+ func (datasource DataSource) ManifestURI() string

+ func (datasource DataSource) RootURI() string

type Dataset

+ func (dataset Dataset) ManifestURI() string

+ func (dataset Dataset) ProfileURI() string

+ func (dataset Dataset) ReportURI() string

+ func (dataset Dataset) RootURI() string

type FeatureGroup

+ func (fg *FeatureGroup) PrefixLiveURI(path string) string

type RecipeRun

+ func (reciperun RecipeRun) ManifestURI() string

+ func (reciperun RecipeRun) RootURI() string

Dec 4, 2022

Changes in this version

type DataPipelineRunStatus

+ ComplatedAt *metav1.Time

+ StartedAt *metav1.Time

type DataPipelineStatus

+ UpdatedAt *metav1.Time

type DataProductStatus

+ DataAppsCount int32

+ DataPipelineRunsCount int32

+ DataPipelinesCount int32

+ DatasetsCount int32

+ DatasourcesCount int32

+ ErrorsAlertsCount int32

+ InfoAlertsCount int32

+ ModelsCount int32

+ PredictionsCount int32

+ PredictorsCount int32

+ StudiesCount int32

+ UpdatedAt *metav1.Time

type DataProductVersionStatus

+ UpdatedAt *metav1.Time

type DataSourceStatus

+ UpdatedAt *metav1.Time

type DatasetStatus

+ AnomaliesURI string

+ CompletedAt *metav1.Time

+ LastStudyAt *metav1.Time

+ ProfileURI string

+ ReportURI string

+ UpdatedAt *metav1.Time

type EntityStatus

+ UpdatedAt *metav1.Time

type FeatureGroupStatus

+ UpdatedAt *metav1.Time

type FeatureHistogramStatus

+ UpdatedAt *metav1.Time

type GovernanceReviewStatus

+ ApprovedAt *metav1.Time

type RecipeStatus

+ UpdatedAt *metav1.Time

Nov 25, 2022

Changes in this version

type DatasetSpec

+ FeatureGroups []v1.ObjectReference

Nov 25, 2022

Changes in this version

type DataPipelineRunSpec

+ ModelClassName *string

+ ModelClassRunName *string

type DatasetSpec

+ ModelClassRunName *string

type RecipeRunSpec

+ ModelClassName *string

+ ModelClassRunName *string

Nov 23, 2022

Changes in this version

type DatasetSpec

+ ModelClassVersion *int32

Nov 17, 2022

Changes in this version

type DataInputSpec

+ Observation *DataLocation

Nov 14, 2022

Changes in this version

type FeatureGroup

+ func (fg *FeatureGroup) PrefixLiveUri(path string) string

Nov 14, 2022

Changes in this version

type FeatureGroupSpec

+ FlatFile *FlatFileFormatSpec

Nov 14, 2022

Changes in this version

type Dataset

+ func (dataset Dataset) IsFeatureGroup() bool

Nov 13, 2022

Changes in this version

type FeatureGroup

+ func (fg FeatureGroup) TenantName() string

Nov 13, 2022

Changes in this version

type FeatureGroupStatus

+ IngestDatasetName string

Nov 11, 2022

Changes in this version

type FeatureGroup

+ func (fg *FeatureGroup) IsIngesting() bool

+ func (fg *FeatureGroup) IsSynching() bool

Nov 11, 2022

Changes in this version

type FeatureGroupSpec

+ KeyColumn *string

Nov 9, 2022

Changes in this version

type MaterializationSpec

+ Schedule catalog.RunSchedule

Nov 9, 2022

Changes in this version

type FeatureGroupSpec

+ TenantRef *v1.ObjectReference

Nov 9, 2022

Changes in this version

type EntitySpec

+ TenantRef *v1.ObjectReference

+ Version *string

type FeatureGroupSpec

+ Version *string

Nov 8, 2022

Changes in this version

type FeatureGroupPhase

+ const FeatureGroupPhaseReady

Nov 5, 2022

Changes in this version

type FeatureGroupSpec

+ TimeColumnFormat *string

type MaterializationSpec

+ OfflineTTL *int32

+ OnlineTTL *int32

Nov 3, 2022

Changes in this version

type DataProductSpec

+ Location DataLocation

type FeatureGroupSpec

+ Location DataLocation

type RecipeRunSpec

+ Location DataLocation

Nov 3, 2022

Changes in this version

type EntitySpec

+ JoinKey string

Oct 30, 2022

Changes in this version

type RecommendationSchema

+ ItemIDColumn *string

+ RatingColumn *string

+ UserIDColumn *string

Oct 28, 2022

Changes in this version

type FeatureGroup

+ func (fg *FeatureGroup) MarkIngestFailed(msg string)

+ func (fg *FeatureGroup) MarkIngested()

+ func (fg *FeatureGroup) MarkIngesting()

type FeatureGroupConditionType

+ const FeatureGroupIngested

type FeatureGroupPhase

+ const FeatureGroupPhaseIngested

+ const FeatureGroupPhaseIngesting

Oct 28, 2022

Changes in this version

type DataProductSpec

+ Tags []string

type DatasetSpec

+ MaxEventTime *metav1.Time

+ MinEventTime *metav1.Time

+ Tags []string

type EntitySpec

+ Tags []string

type FeatureGroupSpec

+ Tags []string

Oct 27, 2022

Changes in this version

type FeatureGroup

+ func (fg *FeatureGroup) HasOnlineTable() bool

+ func (fg *FeatureGroup) IsSynced() bool

+ func (fg *FeatureGroup) MarkSyncing()

+ func (fg FeatureGroup) IsDeleted() bool

+ func (fg FeatureGroup) IsIngestTime() bool

type FeatureGroupStatus

+ OnlineTable DataLocation

+ OnlineTableCreated *metav1.Time

Oct 26, 2022

Changes in this version

type FeatureGroup

+ func (fh *FeatureGroup) ErrorAlert(tenantRef *v1.ObjectReference, notifierName *string, err error) *infra.Alert

Oct 26, 2022

Changes in this version

type FeatureGroup

+ func (fg *FeatureGroup) MarkGeneratedOnlineDatasetFailed(msg string)

+ func (fg *FeatureGroup) MarkSyncFailed(msg string)

+ func (fg *FeatureGroup) OnlineDatasetGenerated() bool

+ func (fg *FeatureGroup) Synced() bool

type FeatureGroupPhase

+ const FeatureGroupPhaseFailed

Oct 26, 2022

Changes in this version

type FeatureGroup

+ func (fg *FeatureGroup) MarkSynching()

+ func (mclass *FeatureGroup) MarkGeneratedOnlineDataset()

+ func (mclass *FeatureGroup) MarkGeneratingOnlineDataset()

+ func (mclass *FeatureGroup) MarkSynced()

type FeatureGroupConditionType

+ const FeatureGroupSynced

+ type FeatureGroupPhase string

+ const FeatureGroupPhaseGeneratingOnlineDataset

+ const FeatureGroupPhaseOnlineDatasetGenerated

+ const FeatureGroupPhaseSynced

+ const FeatureGroupPhaseSyncing

type FeatureGroupSpec

+ IngestSchedule catalog.RunSchedule

+ SyncSchedule catalog.RunSchedule

type FeatureGroupStatus

+ IngestSchedule catalog.RunScheduleStatus

+ Phase FeatureGroupPhase

+ SyncSchedule catalog.RunScheduleStatus

Oct 24, 2022

Changes in this version

type Column

+ Aggr *catalog.Aggregate

+ DriftThreshold *float64

+ SkewThreshold *float64

+ Window *int32

type DatasetRole

+ const DatasetRoleFeatureGroup

type DatasetSpec

+ FeatureGroupName *string

type FeatureGroupSpec

+ Materialization MaterializationSpec

+ Schema Schema

Oct 22, 2022

Changes in this version

type EntitySpec

+ DataSourceName *string

type FeatureGroupSpec

+ Data DataLocation

+ Features []string

type FeatureGroupStatus

+ LastProfile catalog.LastRunStatus

+ Rows int32

Oct 21, 2022

Changes in this version

type FeatureGroupSpec

+ DatasourceName *string

+ EntityName string

+ TimeColumn *string

Oct 21, 2022

Changes in this version

type EntitySpec

+ DatasourceName *string

+ type FeatureGroup struct

+ Spec FeatureGroupSpec

+ Status FeatureGroupStatus

+ func ParseFeatureGroupYaml(content []byte) (*FeatureGroup, error)

+ func (*FeatureGroup) Descriptor() ([]byte, []int)

+ func (*FeatureGroup) ProtoMessage()

+ func (feature *FeatureGroup) AddConfiditions()

+ func (feature *FeatureGroup) AddFinalizer()

+ func (feature *FeatureGroup) Age() string

+ func (feature *FeatureGroup) CreateOrUpdateCond(cond FeatureGroupCondition)

+ func (feature *FeatureGroup) Default()

+ func (feature *FeatureGroup) GetCond(t FeatureGroupConditionType) FeatureGroupCondition

+ func (feature *FeatureGroup) GetCondIdx(t FeatureGroupConditionType) int

+ func (feature *FeatureGroup) HasFinalizer() bool

+ func (feature *FeatureGroup) IsGitObj() bool

+ func (feature *FeatureGroup) IsReady() bool

+ func (feature *FeatureGroup) Key() string

+ func (feature *FeatureGroup) LabelWithCommit(commit string, uname string, branch string)

+ func (feature *FeatureGroup) RemoveFinalizer()

+ func (feature *FeatureGroup) RepEntry() (string, error)

+ func (feature *FeatureGroup) RepPath(root string) (string, error)

+ func (feature *FeatureGroup) SetChanged()

+ func (feature *FeatureGroup) ValidateCreate() error

+ func (feature *FeatureGroup) ValidateUpdate(old runtime.Object) error

+ func (in *FeatureGroup) DeepCopy() *FeatureGroup

+ func (in *FeatureGroup) DeepCopyInto(out *FeatureGroup)

+ func (in *FeatureGroup) DeepCopyObject() runtime.Object

+ func (in *FeatureGroup) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (m *FeatureGroup) Marshal() (dAtA []byte, err error)

+ func (m *FeatureGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureGroup) Reset()

+ func (m *FeatureGroup) Size() (n int)

+ func (m *FeatureGroup) Unmarshal(dAtA []byte) error

+ func (m *FeatureGroup) XXX_DiscardUnknown()

+ func (m *FeatureGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureGroup) XXX_Merge(src proto.Message)

+ func (m *FeatureGroup) XXX_Size() int

+ func (m *FeatureGroup) XXX_Unmarshal(b []byte) error

+ func (pipeline *FeatureGroup) Archived() bool

+ func (pipeline *FeatureGroup) MarkArchived()

+ func (pipeline *FeatureGroup) MarkReady()

+ func (r *FeatureGroup) ValidateDelete() error

+ func (this *FeatureGroup) String() string

+ type FeatureGroupCondition struct

+ LastTransitionTime *metav1.Time

+ Message string

+ Reason string

+ Status v1.ConditionStatus

+ Type FeatureGroupConditionType

+ func (*FeatureGroupCondition) Descriptor() ([]byte, []int)

+ func (*FeatureGroupCondition) ProtoMessage()

+ func (in *FeatureGroupCondition) DeepCopy() *FeatureGroupCondition

+ func (in *FeatureGroupCondition) DeepCopyInto(out *FeatureGroupCondition)

+ func (m *FeatureGroupCondition) Marshal() (dAtA []byte, err error)

+ func (m *FeatureGroupCondition) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureGroupCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureGroupCondition) Reset()

+ func (m *FeatureGroupCondition) Size() (n int)

+ func (m *FeatureGroupCondition) Unmarshal(dAtA []byte) error

+ func (m *FeatureGroupCondition) XXX_DiscardUnknown()

+ func (m *FeatureGroupCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureGroupCondition) XXX_Merge(src proto.Message)

+ func (m *FeatureGroupCondition) XXX_Size() int

+ func (m *FeatureGroupCondition) XXX_Unmarshal(b []byte) error

+ func (this *FeatureGroupCondition) String() string

+ type FeatureGroupConditionType string

+ const FeatureGroupReady

+ const FeatureGroupSaved

+ type FeatureGroupList struct

+ Items []FeatureGroup

+ func (*FeatureGroupList) Descriptor() ([]byte, []int)

+ func (*FeatureGroupList) ProtoMessage()

+ func (in *FeatureGroupList) DeepCopy() *FeatureGroupList

+ func (in *FeatureGroupList) DeepCopyInto(out *FeatureGroupList)

+ func (in *FeatureGroupList) DeepCopyObject() runtime.Object

+ func (m *FeatureGroupList) Marshal() (dAtA []byte, err error)

+ func (m *FeatureGroupList) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureGroupList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureGroupList) Reset()

+ func (m *FeatureGroupList) Size() (n int)

+ func (m *FeatureGroupList) Unmarshal(dAtA []byte) error

+ func (m *FeatureGroupList) XXX_DiscardUnknown()

+ func (m *FeatureGroupList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureGroupList) XXX_Merge(src proto.Message)

+ func (m *FeatureGroupList) XXX_Size() int

+ func (m *FeatureGroupList) XXX_Unmarshal(b []byte) error

+ func (this *FeatureGroupList) String() string

+ type FeatureGroupSpec struct

+ ActiveDeadlineSeconds *int64

+ Description string

+ Entities []string

+ Exclude []string

+ Include []string

+ IngestType *catalog.FeatureStoreIngestType

+ Offline *bool

+ Online *bool

+ Owner *string

+ Paused *bool

+ Resources catalog.ResourceSpec

+ Schedule catalog.RunSchedule

+ UnitTests catalog.TestSuite

+ VersionName *string

+ func (*FeatureGroupSpec) Descriptor() ([]byte, []int)

+ func (*FeatureGroupSpec) ProtoMessage()

+ func (in *FeatureGroupSpec) DeepCopy() *FeatureGroupSpec

+ func (in *FeatureGroupSpec) DeepCopyInto(out *FeatureGroupSpec)

+ func (m *FeatureGroupSpec) Marshal() (dAtA []byte, err error)

+ func (m *FeatureGroupSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureGroupSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureGroupSpec) Reset()

+ func (m *FeatureGroupSpec) Size() (n int)

+ func (m *FeatureGroupSpec) Unmarshal(dAtA []byte) error

+ func (m *FeatureGroupSpec) XXX_DiscardUnknown()

+ func (m *FeatureGroupSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureGroupSpec) XXX_Merge(src proto.Message)

+ func (m *FeatureGroupSpec) XXX_Size() int

+ func (m *FeatureGroupSpec) XXX_Unmarshal(b []byte) error

+ func (this *FeatureGroupSpec) String() string

+ type FeatureGroupStatus struct

+ AverageCost float64

+ Conditions []FeatureGroupCondition

+ LastRun catalog.LastRunStatus

+ LastUpdated *metav1.Time

+ NextRun *metav1.Time

+ ObservedGeneration int64

+ func (*FeatureGroupStatus) Descriptor() ([]byte, []int)

+ func (*FeatureGroupStatus) ProtoMessage()

+ func (in *FeatureGroupStatus) DeepCopy() *FeatureGroupStatus

+ func (in *FeatureGroupStatus) DeepCopyInto(out *FeatureGroupStatus)

+ func (m *FeatureGroupStatus) Marshal() (dAtA []byte, err error)

+ func (m *FeatureGroupStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureGroupStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureGroupStatus) Reset()

+ func (m *FeatureGroupStatus) Size() (n int)

+ func (m *FeatureGroupStatus) Unmarshal(dAtA []byte) error

+ func (m *FeatureGroupStatus) XXX_DiscardUnknown()

+ func (m *FeatureGroupStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureGroupStatus) XXX_Merge(src proto.Message)

+ func (m *FeatureGroupStatus) XXX_Size() int

+ func (m *FeatureGroupStatus) XXX_Unmarshal(b []byte) error

+ func (this *FeatureGroupStatus) String() string

Oct 20, 2022

Changes in this version

type DataSourceSpec

+ IngestMethod *catalog.FeatureStoreIngestType

type EntitySpec

+ JoinKeys []string

type FeatureViewSpec

+ Entities []string

+ IngestType *catalog.FeatureStoreIngestType

Oct 19, 2022

Changes in this version

+ type FeatureView struct

+ Spec FeatureViewSpec

+ Status FeatureViewStatus

+ func ParseFeatureViewYaml(content []byte) (*FeatureView, error)

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

+ func (*FeatureView) ProtoMessage()

+ func (feature *FeatureView) AddConfiditions()

+ func (feature *FeatureView) AddFinalizer()

+ func (feature *FeatureView) Age() string

+ func (feature *FeatureView) CreateOrUpdateCond(cond FeatureViewCondition)

+ func (feature *FeatureView) Default()

+ func (feature *FeatureView) GetCond(t FeatureViewConditionType) FeatureViewCondition

+ func (feature *FeatureView) GetCondIdx(t FeatureViewConditionType) int

+ func (feature *FeatureView) HasFinalizer() bool

+ func (feature *FeatureView) IsGitObj() bool

+ func (feature *FeatureView) IsReady() bool

+ func (feature *FeatureView) Key() string

+ func (feature *FeatureView) LabelWithCommit(commit string, uname string, branch string)

+ func (feature *FeatureView) RemoveFinalizer()

+ func (feature *FeatureView) RepEntry() (string, error)

+ func (feature *FeatureView) RepPath(root string) (string, error)

+ func (feature *FeatureView) SetChanged()

+ func (feature *FeatureView) ValidateCreate() error

+ func (feature *FeatureView) ValidateUpdate(old runtime.Object) error

+ func (in *FeatureView) DeepCopy() *FeatureView

+ func (in *FeatureView) DeepCopyInto(out *FeatureView)

+ func (in *FeatureView) DeepCopyObject() runtime.Object

+ func (in *FeatureView) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (m *FeatureView) Marshal() (dAtA []byte, err error)

+ func (m *FeatureView) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureView) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureView) Reset()

+ func (m *FeatureView) Size() (n int)

+ func (m *FeatureView) Unmarshal(dAtA []byte) error

+ func (m *FeatureView) XXX_DiscardUnknown()

+ func (m *FeatureView) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureView) XXX_Merge(src proto.Message)

+ func (m *FeatureView) XXX_Size() int

+ func (m *FeatureView) XXX_Unmarshal(b []byte) error

+ func (pipeline *FeatureView) Archived() bool

+ func (pipeline *FeatureView) MarkArchived()

+ func (pipeline *FeatureView) MarkReady()

+ func (r *FeatureView) ValidateDelete() error

+ func (this *FeatureView) String() string

+ type FeatureViewCondition struct

+ LastTransitionTime *metav1.Time

+ Message string

+ Reason string

+ Status v1.ConditionStatus

+ Type FeatureViewConditionType

+ func (*FeatureViewCondition) Descriptor() ([]byte, []int)

+ func (*FeatureViewCondition) ProtoMessage()

+ func (in *FeatureViewCondition) DeepCopy() *FeatureViewCondition

+ func (in *FeatureViewCondition) DeepCopyInto(out *FeatureViewCondition)

+ func (m *FeatureViewCondition) Marshal() (dAtA []byte, err error)

+ func (m *FeatureViewCondition) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureViewCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureViewCondition) Reset()

+ func (m *FeatureViewCondition) Size() (n int)

+ func (m *FeatureViewCondition) Unmarshal(dAtA []byte) error

+ func (m *FeatureViewCondition) XXX_DiscardUnknown()

+ func (m *FeatureViewCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureViewCondition) XXX_Merge(src proto.Message)

+ func (m *FeatureViewCondition) XXX_Size() int

+ func (m *FeatureViewCondition) XXX_Unmarshal(b []byte) error

+ func (this *FeatureViewCondition) String() string

+ type FeatureViewConditionType string

+ const FeatureViewReady

+ const FeatureViewSaved

+ type FeatureViewList struct

+ Items []FeatureView

+ func (*FeatureViewList) Descriptor() ([]byte, []int)

+ func (*FeatureViewList) ProtoMessage()

+ func (in *FeatureViewList) DeepCopy() *FeatureViewList

+ func (in *FeatureViewList) DeepCopyInto(out *FeatureViewList)

+ func (in *FeatureViewList) DeepCopyObject() runtime.Object

+ func (m *FeatureViewList) Marshal() (dAtA []byte, err error)

+ func (m *FeatureViewList) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureViewList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureViewList) Reset()

+ func (m *FeatureViewList) Size() (n int)

+ func (m *FeatureViewList) Unmarshal(dAtA []byte) error

+ func (m *FeatureViewList) XXX_DiscardUnknown()

+ func (m *FeatureViewList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureViewList) XXX_Merge(src proto.Message)

+ func (m *FeatureViewList) XXX_Size() int

+ func (m *FeatureViewList) XXX_Unmarshal(b []byte) error

+ func (this *FeatureViewList) String() string

+ type FeatureViewSpec struct

+ ActiveDeadlineSeconds *int64

+ Aggregation *AggregationSpec

+ DatasetSelector map[string]string

+ Description string

+ Exclude []string

+ FeatureSetRef v1.ObjectReference

+ Include []string

+ Materialization *MaterializationSpec

+ Offline *bool

+ Online *bool

+ Owner *string

+ Paused *bool

+ Resources catalog.ResourceSpec

+ Schedule catalog.RunSchedule

+ UnitTests catalog.TestSuite

+ VersionName *string

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

+ func (*FeatureViewSpec) ProtoMessage()

+ func (in *FeatureViewSpec) DeepCopy() *FeatureViewSpec

+ func (in *FeatureViewSpec) DeepCopyInto(out *FeatureViewSpec)

+ func (m *FeatureViewSpec) Marshal() (dAtA []byte, err error)

+ func (m *FeatureViewSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureViewSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureViewSpec) Reset()

+ func (m *FeatureViewSpec) Size() (n int)

+ func (m *FeatureViewSpec) Unmarshal(dAtA []byte) error

+ func (m *FeatureViewSpec) XXX_DiscardUnknown()

+ func (m *FeatureViewSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureViewSpec) XXX_Merge(src proto.Message)

+ func (m *FeatureViewSpec) XXX_Size() int

+ func (m *FeatureViewSpec) XXX_Unmarshal(b []byte) error

+ func (this *FeatureViewSpec) String() string

+ type FeatureViewStatus struct

+ AverageCost float64

+ Conditions []FeatureViewCondition

+ LastRun catalog.LastRunStatus

+ LastUpdated *metav1.Time

+ NextRun *metav1.Time

+ ObservedGeneration int64

+ func (*FeatureViewStatus) Descriptor() ([]byte, []int)

+ func (*FeatureViewStatus) ProtoMessage()

+ func (in *FeatureViewStatus) DeepCopy() *FeatureViewStatus

+ func (in *FeatureViewStatus) DeepCopyInto(out *FeatureViewStatus)

+ func (m *FeatureViewStatus) Marshal() (dAtA []byte, err error)

+ func (m *FeatureViewStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureViewStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureViewStatus) Reset()

+ func (m *FeatureViewStatus) Size() (n int)

+ func (m *FeatureViewStatus) Unmarshal(dAtA []byte) error

+ func (m *FeatureViewStatus) XXX_DiscardUnknown()

+ func (m *FeatureViewStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureViewStatus) XXX_Merge(src proto.Message)

+ func (m *FeatureViewStatus) XXX_Size() int

+ func (m *FeatureViewStatus) XXX_Unmarshal(b []byte) error

+ func (this *FeatureViewStatus) String() string

Oct 17, 2022

Changes in this version

type Featureset

+ func (run *Featureset) AddConfiditions()

+ func (run *Featureset) IsCompleted() bool

+ func (run *Featureset) IsFailed() bool

+ func (run *Featureset) IsRunning() bool

+ func (run *Featureset) MarkComplete()

+ func (run *Featureset) MarkFailed(err error)

+ func (run *Featureset) MarkRunning()

+ func (run *Featureset) RunStatus() *catalog.LastRunStatus

+ type FeaturesetClass struct

+ Spec FeaturesetClassSpec

+ Status FeaturesetClassStatus

+ func ParseFeaturesetClassYaml(content []byte) (*FeaturesetClass, error)

+ func (*FeaturesetClass) Descriptor() ([]byte, []int)

+ func (*FeaturesetClass) ProtoMessage()

+ func (feature *FeaturesetClass) AddConfiditions()

+ func (feature *FeaturesetClass) AddFinalizer()

+ func (feature *FeaturesetClass) Age() string

+ func (feature *FeaturesetClass) CreateOrUpdateCond(cond FeaturesetClassCondition)

+ func (feature *FeaturesetClass) Default()

+ func (feature *FeaturesetClass) GetCond(t FeaturesetClassConditionType) FeaturesetClassCondition

+ func (feature *FeaturesetClass) GetCondIdx(t FeaturesetClassConditionType) int

+ func (feature *FeaturesetClass) HasFinalizer() bool

+ func (feature *FeaturesetClass) IsGitObj() bool

+ func (feature *FeaturesetClass) IsReady() bool

+ func (feature *FeaturesetClass) Key() string

+ func (feature *FeaturesetClass) LabelWithCommit(commit string, uname string, branch string)

+ func (feature *FeaturesetClass) RemoveFinalizer()

+ func (feature *FeaturesetClass) RepEntry() (string, error)

+ func (feature *FeaturesetClass) RepPath(root string) (string, error)

+ func (feature *FeaturesetClass) SetChanged()

+ func (feature *FeaturesetClass) ValidateCreate() error

+ func (feature *FeaturesetClass) ValidateUpdate(old runtime.Object) error

+ func (in *FeaturesetClass) DeepCopy() *FeaturesetClass

+ func (in *FeaturesetClass) DeepCopyInto(out *FeaturesetClass)

+ func (in *FeaturesetClass) DeepCopyObject() runtime.Object

+ func (in *FeaturesetClass) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (m *FeaturesetClass) Marshal() (dAtA []byte, err error)

+ func (m *FeaturesetClass) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeaturesetClass) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeaturesetClass) Reset()

+ func (m *FeaturesetClass) Size() (n int)

+ func (m *FeaturesetClass) Unmarshal(dAtA []byte) error

+ func (m *FeaturesetClass) XXX_DiscardUnknown()

+ func (m *FeaturesetClass) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeaturesetClass) XXX_Merge(src proto.Message)

+ func (m *FeaturesetClass) XXX_Size() int

+ func (m *FeaturesetClass) XXX_Unmarshal(b []byte) error

+ func (pipeline *FeaturesetClass) Archived() bool

+ func (pipeline *FeaturesetClass) MarkArchived()

+ func (pipeline *FeaturesetClass) MarkReady()

+ func (r *FeaturesetClass) ValidateDelete() error

+ func (this *FeaturesetClass) String() string

+ type FeaturesetClassCondition struct

+ LastTransitionTime *metav1.Time

+ Message string

+ Reason string

+ Status v1.ConditionStatus

+ Type FeaturesetClassConditionType

+ func (*FeaturesetClassCondition) Descriptor() ([]byte, []int)

+ func (*FeaturesetClassCondition) ProtoMessage()

+ func (in *FeaturesetClassCondition) DeepCopy() *FeaturesetClassCondition

+ func (in *FeaturesetClassCondition) DeepCopyInto(out *FeaturesetClassCondition)

+ func (m *FeaturesetClassCondition) Marshal() (dAtA []byte, err error)

+ func (m *FeaturesetClassCondition) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeaturesetClassCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeaturesetClassCondition) Reset()

+ func (m *FeaturesetClassCondition) Size() (n int)

+ func (m *FeaturesetClassCondition) Unmarshal(dAtA []byte) error

+ func (m *FeaturesetClassCondition) XXX_DiscardUnknown()

+ func (m *FeaturesetClassCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeaturesetClassCondition) XXX_Merge(src proto.Message)

+ func (m *FeaturesetClassCondition) XXX_Size() int

+ func (m *FeaturesetClassCondition) XXX_Unmarshal(b []byte) error

+ func (this *FeaturesetClassCondition) String() string

+ type FeaturesetClassConditionType string

+ const FeaturesetClassReady

+ const FeaturesetClassSaved

+ type FeaturesetClassList struct

+ Items []FeaturesetClass

+ func (*FeaturesetClassList) Descriptor() ([]byte, []int)

+ func (*FeaturesetClassList) ProtoMessage()

+ func (in *FeaturesetClassList) DeepCopy() *FeaturesetClassList

+ func (in *FeaturesetClassList) DeepCopyInto(out *FeaturesetClassList)

+ func (in *FeaturesetClassList) DeepCopyObject() runtime.Object

+ func (m *FeaturesetClassList) Marshal() (dAtA []byte, err error)

+ func (m *FeaturesetClassList) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeaturesetClassList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeaturesetClassList) Reset()

+ func (m *FeaturesetClassList) Size() (n int)

+ func (m *FeaturesetClassList) Unmarshal(dAtA []byte) error

+ func (m *FeaturesetClassList) XXX_DiscardUnknown()

+ func (m *FeaturesetClassList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeaturesetClassList) XXX_Merge(src proto.Message)

+ func (m *FeaturesetClassList) XXX_Size() int

+ func (m *FeaturesetClassList) XXX_Unmarshal(b []byte) error

+ func (this *FeaturesetClassList) String() string

+ type FeaturesetClassSpec struct

+ ActiveDeadlineSeconds *int64

+ Aggregation *AggregationSpec

+ DatasetSelector map[string]string

+ Description string

+ Exclude []string

+ FeatureSetRef v1.ObjectReference

+ Include []string

+ Materialization *MaterializationSpec

+ Offline *bool

+ Online *bool

+ Owner *string

+ Paused *bool

+ Resources catalog.ResourceSpec

+ Schedule catalog.RunSchedule

+ UnitTests catalog.TestSuite

+ VersionName *string

+ func (*FeaturesetClassSpec) Descriptor() ([]byte, []int)

+ func (*FeaturesetClassSpec) ProtoMessage()

+ func (in *FeaturesetClassSpec) DeepCopy() *FeaturesetClassSpec

+ func (in *FeaturesetClassSpec) DeepCopyInto(out *FeaturesetClassSpec)

+ func (m *FeaturesetClassSpec) Marshal() (dAtA []byte, err error)

+ func (m *FeaturesetClassSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeaturesetClassSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeaturesetClassSpec) Reset()

+ func (m *FeaturesetClassSpec) Size() (n int)

+ func (m *FeaturesetClassSpec) Unmarshal(dAtA []byte) error

+ func (m *FeaturesetClassSpec) XXX_DiscardUnknown()

+ func (m *FeaturesetClassSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeaturesetClassSpec) XXX_Merge(src proto.Message)

+ func (m *FeaturesetClassSpec) XXX_Size() int

+ func (m *FeaturesetClassSpec) XXX_Unmarshal(b []byte) error

+ func (this *FeaturesetClassSpec) String() string

+ type FeaturesetClassStatus struct

+ AverageCost float64

+ Conditions []FeaturesetClassCondition

+ LastRun catalog.LastRunStatus

+ LastUpdated *metav1.Time

+ NextRun *metav1.Time

+ ObservedGeneration int64

+ func (*FeaturesetClassStatus) Descriptor() ([]byte, []int)

+ func (*FeaturesetClassStatus) ProtoMessage()

+ func (in *FeaturesetClassStatus) DeepCopy() *FeaturesetClassStatus

+ func (in *FeaturesetClassStatus) DeepCopyInto(out *FeaturesetClassStatus)

+ func (m *FeaturesetClassStatus) Marshal() (dAtA []byte, err error)

+ func (m *FeaturesetClassStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeaturesetClassStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeaturesetClassStatus) Reset()

+ func (m *FeaturesetClassStatus) Size() (n int)

+ func (m *FeaturesetClassStatus) Unmarshal(dAtA []byte) error

+ func (m *FeaturesetClassStatus) XXX_DiscardUnknown()

+ func (m *FeaturesetClassStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeaturesetClassStatus) XXX_Merge(src proto.Message)

+ func (m *FeaturesetClassStatus) XXX_Size() int

+ func (m *FeaturesetClassStatus) XXX_Unmarshal(b []byte) error

+ func (this *FeaturesetClassStatus) String() string

type FeaturesetConditionType

+ const FeaturesetCompleted

+ type FeaturesetPhase string

+ const FeaturesetPhaseAborted

+ const FeaturesetPhaseCompleted

+ const FeaturesetPhaseFailed

+ const FeaturesetPhasePending

+ const FeaturesetPhaseRunning

type FeaturesetSpec

+ ClassName *string

+ TTL *int32

type FeaturesetStatus

+ EndTime *metav1.Time

+ FailureMessage *string

+ FailureReason *catalog.StatusError

+ Logs catalog.Logs

+ Phase FeaturesetPhase

+ StartTime *metav1.Time

+ TriggeredBy catalog.TriggerType

Oct 17, 2022

Changes in this version

type FeatureSourceSpec

+ EntityName *string

Oct 17, 2022

Changes in this version

type DataPipelineSpec

+ ModelClassName *string

type DatasetSpec

+ ModelClassName *string

Oct 16, 2022

Changes in this version

type FeaturePipeline

+ func ParseFeatureSourceYaml(content []byte) (*FeaturePipeline, error)

+ type FeatureSource struct

+ Spec FeatureSourceSpec

+ Status FeatureSourceStatus

+ func (*FeatureSource) Descriptor() ([]byte, []int)

+ func (*FeatureSource) ProtoMessage()

+ func (entity *FeatureSource) AddFinalizer()

+ func (entity *FeatureSource) Age() string

+ func (entity *FeatureSource) CreateOrUpdateCond(cond FeatureSourceCondition)

+ func (entity *FeatureSource) GetCond(t FeatureSourceConditionType) FeatureSourceCondition

+ func (entity *FeatureSource) GetCondIdx(t FeatureSourceConditionType) int

+ func (entity *FeatureSource) HasFinalizer() bool

+ func (entity *FeatureSource) IsGitObj() bool

+ func (entity *FeatureSource) IsReady() bool

+ func (entity *FeatureSource) Key() string

+ func (entity *FeatureSource) LabelWithCommit(commit string, uname string, branch string)

+ func (entity *FeatureSource) RemoveFinalizer()

+ func (entity *FeatureSource) RepEntry() (string, error)

+ func (entity *FeatureSource) RepPath(root string) (string, error)

+ func (entity *FeatureSource) SetChanged()

+ func (feature *FeatureSource) Default()

+ func (feature *FeatureSource) ValidateCreate() error

+ func (feature *FeatureSource) ValidateUpdate(old runtime.Object) error

+ func (fset *FeatureSource) MarkArchived()

+ func (fset *FeatureSource) MarkReady()

+ func (in *FeatureSource) DeepCopy() *FeatureSource

+ func (in *FeatureSource) DeepCopyInto(out *FeatureSource)

+ func (in *FeatureSource) DeepCopyObject() runtime.Object

+ func (in *FeatureSource) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (m *FeatureSource) Marshal() (dAtA []byte, err error)

+ func (m *FeatureSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureSource) Reset()

+ func (m *FeatureSource) Size() (n int)

+ func (m *FeatureSource) Unmarshal(dAtA []byte) error

+ func (m *FeatureSource) XXX_DiscardUnknown()

+ func (m *FeatureSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureSource) XXX_Merge(src proto.Message)

+ func (m *FeatureSource) XXX_Size() int

+ func (m *FeatureSource) XXX_Unmarshal(b []byte) error

+ func (pipeline *FeatureSource) Archived() bool

+ func (r *FeatureSource) ValidateDelete() error

+ func (this *FeatureSource) String() string

+ type FeatureSourceCondition struct

+ LastTransitionTime *metav1.Time

+ Message string

+ Reason string

+ Status v1.ConditionStatus

+ Type FeatureSourceConditionType

+ func (*FeatureSourceCondition) Descriptor() ([]byte, []int)

+ func (*FeatureSourceCondition) ProtoMessage()

+ func (in *FeatureSourceCondition) DeepCopy() *FeatureSourceCondition

+ func (in *FeatureSourceCondition) DeepCopyInto(out *FeatureSourceCondition)

+ func (m *FeatureSourceCondition) Marshal() (dAtA []byte, err error)

+ func (m *FeatureSourceCondition) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureSourceCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureSourceCondition) Reset()

+ func (m *FeatureSourceCondition) Size() (n int)

+ func (m *FeatureSourceCondition) Unmarshal(dAtA []byte) error

+ func (m *FeatureSourceCondition) XXX_DiscardUnknown()

+ func (m *FeatureSourceCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureSourceCondition) XXX_Merge(src proto.Message)

+ func (m *FeatureSourceCondition) XXX_Size() int

+ func (m *FeatureSourceCondition) XXX_Unmarshal(b []byte) error

+ func (this *FeatureSourceCondition) String() string

+ type FeatureSourceConditionType string

+ const FeatureSourceReady

+ const FeatureSourceSaved

+ type FeatureSourceList struct

+ Items []FeatureSource

+ func (*FeatureSourceList) Descriptor() ([]byte, []int)

+ func (*FeatureSourceList) ProtoMessage()

+ func (in *FeatureSourceList) DeepCopy() *FeatureSourceList

+ func (in *FeatureSourceList) DeepCopyInto(out *FeatureSourceList)

+ func (in *FeatureSourceList) DeepCopyObject() runtime.Object

+ func (m *FeatureSourceList) Marshal() (dAtA []byte, err error)

+ func (m *FeatureSourceList) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureSourceList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureSourceList) Reset()

+ func (m *FeatureSourceList) Size() (n int)

+ func (m *FeatureSourceList) Unmarshal(dAtA []byte) error

+ func (m *FeatureSourceList) XXX_DiscardUnknown()

+ func (m *FeatureSourceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureSourceList) XXX_Merge(src proto.Message)

+ func (m *FeatureSourceList) XXX_Size() int

+ func (m *FeatureSourceList) XXX_Unmarshal(b []byte) error

+ func (this *FeatureSourceList) String() string

+ type FeatureSourceSpec struct

+ DatasourceRef v1.ObjectReference

+ Description *string

+ EntityRef v1.LocalObjectReference

+ Exclude []string

+ Include []string

+ Owner *string

+ VersionName *string

+ func (*FeatureSourceSpec) Descriptor() ([]byte, []int)

+ func (*FeatureSourceSpec) ProtoMessage()

+ func (in *FeatureSourceSpec) DeepCopy() *FeatureSourceSpec

+ func (in *FeatureSourceSpec) DeepCopyInto(out *FeatureSourceSpec)

+ func (m *FeatureSourceSpec) Marshal() (dAtA []byte, err error)

+ func (m *FeatureSourceSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureSourceSpec) Reset()

+ func (m *FeatureSourceSpec) Size() (n int)

+ func (m *FeatureSourceSpec) Unmarshal(dAtA []byte) error

+ func (m *FeatureSourceSpec) XXX_DiscardUnknown()

+ func (m *FeatureSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureSourceSpec) XXX_Merge(src proto.Message)

+ func (m *FeatureSourceSpec) XXX_Size() int

+ func (m *FeatureSourceSpec) XXX_Unmarshal(b []byte) error

+ func (this *FeatureSourceSpec) String() string

+ type FeatureSourceStatus struct

+ Conditions []FeatureSourceCondition

+ LastUpdated *metav1.Time

+ ObservedGeneration int64

+ func (*FeatureSourceStatus) Descriptor() ([]byte, []int)

+ func (*FeatureSourceStatus) ProtoMessage()

+ func (in *FeatureSourceStatus) DeepCopy() *FeatureSourceStatus

+ func (in *FeatureSourceStatus) DeepCopyInto(out *FeatureSourceStatus)

+ func (m *FeatureSourceStatus) Marshal() (dAtA []byte, err error)

+ func (m *FeatureSourceStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *FeatureSourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FeatureSourceStatus) Reset()

+ func (m *FeatureSourceStatus) Size() (n int)

+ func (m *FeatureSourceStatus) Unmarshal(dAtA []byte) error

+ func (m *FeatureSourceStatus) XXX_DiscardUnknown()

+ func (m *FeatureSourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FeatureSourceStatus) XXX_Merge(src proto.Message)

+ func (m *FeatureSourceStatus) XXX_Size() int

+ func (m *FeatureSourceStatus) XXX_Unmarshal(b []byte) error

+ func (this *FeatureSourceStatus) String() string

Oct 16, 2022

Changes in this version

type GroupDatasetLocationsSpec

+ func (in *GroupDatasetLocationsSpec) DeepCopy() *GroupDatasetLocationsSpec

+ func (in *GroupDatasetLocationsSpec) DeepCopyInto(out *GroupDatasetLocationsSpec)

Oct 16, 2022

Changes in this version

type FeaturePipelineSpec

+ FeatureSetRef v1.ObjectReference

type FeaturesetSpec

+ DatasourceRef v1.ObjectReference

+ EntityRef v1.LocalObjectReference

+ Exclude []string

+ Include []string

Oct 4, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) GroupsFolder() string

Oct 4, 2022

Changes in this version

type GroupDatasetLocationsSpec

+ GroupsRoot *string

Oct 4, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) GroupDataFile() string

+ func (dataset *Dataset) GroupForecastFile() string

+ func (dataset *Dataset) GroupReportFile() string

Oct 4, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) GroupForecast() string

+ func (dataset *Dataset) GroupProfileFolder() string

+ func (dataset *Dataset) GroupReport() string

Oct 4, 2022

Changes in this version

type DatasetSpec

+ GroupLocations GroupDatasetLocationsSpec

+ type GroupDatasetLocationsSpec struct

+ GroupDataFile *string

+ GroupDataFolder *string

+ GroupFeaturesFile *string

+ GroupProfileFolder *string

+ GroupReportFile *string

+ GroupRoot *string

+ func (*GroupDatasetLocationsSpec) Descriptor() ([]byte, []int)

+ func (*GroupDatasetLocationsSpec) ProtoMessage()

+ func (m *GroupDatasetLocationsSpec) Marshal() (dAtA []byte, err error)

+ func (m *GroupDatasetLocationsSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *GroupDatasetLocationsSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GroupDatasetLocationsSpec) Reset()

+ func (m *GroupDatasetLocationsSpec) Size() (n int)

+ func (m *GroupDatasetLocationsSpec) Unmarshal(dAtA []byte) error

+ func (m *GroupDatasetLocationsSpec) XXX_DiscardUnknown()

+ func (m *GroupDatasetLocationsSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GroupDatasetLocationsSpec) XXX_Merge(src proto.Message)

+ func (m *GroupDatasetLocationsSpec) XXX_Size() int

+ func (m *GroupDatasetLocationsSpec) XXX_Unmarshal(b []byte) error

+ func (this *GroupDatasetLocationsSpec) String() string

Oct 4, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) GroupDataFolder() string

+ func (dataset *Dataset) GroupDataPath() string

+ func (dataset *Dataset) GroupFolder() string

+ func (dataset *Dataset) GroupModelForecast() string

+ func (dataset *Dataset) GroupModelProfileFolder() string

+ func (dataset *Dataset) GroupModelReport() string

Oct 1, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) TaskIndexFileKey(task string) string

Oct 1, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) WorkerIndexFileKey(workerIndex int, task string) string

Oct 1, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) IndexFileKey() string

Sep 26, 2022

Changes in this version

type DatasetGroupByStatus

+ WorkerResults map[int32]string

Sep 22, 2022

Changes in this version

+ type SyntheticSpec struct

+ Enabled *bool

+ Rows *int32

+ func (*SyntheticSpec) Descriptor() ([]byte, []int)

+ func (*SyntheticSpec) ProtoMessage()

+ func (in *SyntheticSpec) DeepCopy() *SyntheticSpec

+ func (in *SyntheticSpec) DeepCopyInto(out *SyntheticSpec)

+ func (m *SyntheticSpec) Marshal() (dAtA []byte, err error)

+ func (m *SyntheticSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyntheticSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SyntheticSpec) Reset()

+ func (m *SyntheticSpec) Size() (n int)

+ func (m *SyntheticSpec) Unmarshal(dAtA []byte) error

+ func (m *SyntheticSpec) XXX_DiscardUnknown()

+ func (m *SyntheticSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyntheticSpec) XXX_Merge(src proto.Message)

+ func (m *SyntheticSpec) XXX_Size() int

+ func (m *SyntheticSpec) XXX_Unmarshal(b []byte) error

+ func (this *SyntheticSpec) String() string

Sep 22, 2022

Changes in this version

type GroupBySpec

+ Enabled *bool

Sep 22, 2022

Changes in this version

type GroupBySpec

+ GroupBy []string

Sep 22, 2022

Changes in this version

type DatasetSpec

+ GroupBy GroupBySpec

+ type GroupBySpec struct

+ Aggr catalog.Aggregate

+ Freq *catalog.Freq

+ Interval *int32

+ Key []string

+ func (*GroupBySpec) Descriptor() ([]byte, []int)

+ func (*GroupBySpec) ProtoMessage()

+ func (in *GroupBySpec) DeepCopy() *GroupBySpec

+ func (in *GroupBySpec) DeepCopyInto(out *GroupBySpec)

+ func (m *GroupBySpec) Marshal() (dAtA []byte, err error)

+ func (m *GroupBySpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *GroupBySpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GroupBySpec) Reset()

+ func (m *GroupBySpec) Size() (n int)

+ func (m *GroupBySpec) Unmarshal(dAtA []byte) error

+ func (m *GroupBySpec) XXX_DiscardUnknown()

+ func (m *GroupBySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GroupBySpec) XXX_Merge(src proto.Message)

+ func (m *GroupBySpec) XXX_Size() int

+ func (m *GroupBySpec) XXX_Unmarshal(b []byte) error

+ func (this *GroupBySpec) String() string

Sep 20, 2022

Changes in this version

type DatasetGroupByStatus

+ func (in *DatasetGroupByStatus) DeepCopy() *DatasetGroupByStatus

+ func (in *DatasetGroupByStatus) DeepCopyInto(out *DatasetGroupByStatus)

Sep 20, 2022

Changes in this version

+ type DatasetGroupByStatus struct

+ DatasetsURI string

+ FeaturesURI string

+ ProfilesURI string

+ ReportsURI string

+ UnitTestsURI string

+ func (*DatasetGroupByStatus) Descriptor() ([]byte, []int)

+ func (*DatasetGroupByStatus) ProtoMessage()

+ func (m *DatasetGroupByStatus) Marshal() (dAtA []byte, err error)

+ func (m *DatasetGroupByStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *DatasetGroupByStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DatasetGroupByStatus) Reset()

+ func (m *DatasetGroupByStatus) Size() (n int)

+ func (m *DatasetGroupByStatus) Unmarshal(dAtA []byte) error

+ func (m *DatasetGroupByStatus) XXX_DiscardUnknown()

+ func (m *DatasetGroupByStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DatasetGroupByStatus) XXX_Merge(src proto.Message)

+ func (m *DatasetGroupByStatus) XXX_Size() int

+ func (m *DatasetGroupByStatus) XXX_Unmarshal(b []byte) error

+ func (this *DatasetGroupByStatus) String() string

type DatasetSpec

+ Featurized *bool

type DatasetStatus

+ GroupBy DatasetGroupByStatus

type TimeSeriesSchema

+ Aggr catalog.Aggregate

Sep 19, 2022

Changes in this version

type GroupBy

+ func (in *GroupBy) DeepCopy() *GroupBy

+ func (in *GroupBy) DeepCopyInto(out *GroupBy)

Sep 19, 2022

Changes in this version

type Schema

+ Key []string

Sep 18, 2022

Changes in this version

+ type GroupBy struct

+ Aggr catalog.Aggregate

+ Columns []string

+ Freq *catalog.Freq

+ Leaf *bool

+ Name *string

+ func (*GroupBy) Descriptor() ([]byte, []int)

+ func (*GroupBy) ProtoMessage()

+ func (m *GroupBy) Marshal() (dAtA []byte, err error)

+ func (m *GroupBy) MarshalTo(dAtA []byte) (int, error)

+ func (m *GroupBy) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GroupBy) Reset()

+ func (m *GroupBy) Size() (n int)

+ func (m *GroupBy) Unmarshal(dAtA []byte) error

+ func (m *GroupBy) XXX_DiscardUnknown()

+ func (m *GroupBy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GroupBy) XXX_Merge(src proto.Message)

+ func (m *GroupBy) XXX_Size() int

+ func (m *GroupBy) XXX_Unmarshal(b []byte) error

+ func (this *GroupBy) String() string

type TimeSeriesSchema

+ Groups []GroupBy

Sep 18, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) Grouped() bool

Sep 17, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) MarkGrouping()

Sep 17, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) MarkGroupFailed(msg string)

+ func (dataset *Dataset) MarkGroupSnapshot()

+ func (dataset *Dataset) MarkGroupSuccess()

type DatasetConditionType

+ const DatasetGrouped

type DatasetPhase

+ const DatasetPhaseGrouped

+ const DatasetPhaseGrouping

Sep 16, 2022

Changes in this version

type DatasetSpec

+ Key []string

Sep 16, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) IsGroup() bool

Sep 16, 2022

Changes in this version

type DatasetStatus

+ DatasetGroupIndexUri string

Sep 7, 2022

Changes in this version

type Column

+ LaggedRegressor *bool

+ Regressor *bool

Sep 1, 2022

Changes in this version

type Column

+ TimeIndex *bool

Aug 29, 2022

Changes in this version

type Column

+ Loc int32

type Schema

+ Index []string

Aug 27, 2022

Changes in this version

type TimeSeriesSchema

+ Type catalog.TimeSeriesType

Aug 27, 2022

Changes in this version

type Column

+ DateTimeFormat *string

+ Exogenous *bool

+ Key *bool

+ TimeSeries *bool

Aug 24, 2022

Changes in this version

type GovernanceSpec

+ Members []string

Aug 19, 2022

Changes in this version

type FeatureHistogramSpec

+ FeatureFilter catalog.FeatureFilterType

+ ReferenceType catalog.ReferenceDataType

Aug 17, 2022

Changes in this version

type TimeSeriesSchema

+ Keys []string

+ TimeColumn string

Aug 9, 2022

Changes in this version

type DatasetRole

+ const DatasetRolePrediction

Aug 8, 2022

Changes in this version

type TimeSeriesSchema

+ Interval *int32

+ Levels map[string]int32

Aug 7, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) ShouldExpire(maxPredictions int32) bool

Aug 7, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) ConstuctFeatureHistogram() (*FeatureHistogram, error)

Aug 7, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) ContructFeatureHistogram() (*FeatureHistogram, error)

Aug 6, 2022

Changes in this version

type FeatureHistogram

+ func (feature *FeatureHistogram) Drifted() bool

+ func (feature *FeatureHistogram) MarkDrift()

+ func (feature *FeatureHistogram) MarkExpired()

+ func (feature *FeatureHistogram) MarkGenTest()

+ func (feature *FeatureHistogram) MarkLive()

+ func (feature *FeatureHistogram) MarkReadyToTest()

+ func (feature FeatureHistogram) Live() bool

+ func (fh *FeatureHistogram) Expired() bool

type FeatureHistogramPhase

+ const FeatureHistogramPhaseDrift

+ const FeatureHistogramPhaseExpired

+ const FeatureHistogramPhaseGenTest

+ const FeatureHistogramPhaseLive

+ const FeatureHistogramPhaseReadyToTest

type FeatureHistogramSpec

+ BaseRef v1.ObjectReference

Aug 5, 2022

Changes in this version

+ const ModelDriftJSDivergenceLessThan

type ColumnStatistics

+ func (col *ColumnStatistics) BigBoolTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (col *ColumnStatistics) BigCatTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (col *ColumnStatistics) BigNumericTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (col *ColumnStatistics) GenDriftTestCase(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (col *ColumnStatistics) SmallBoolTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (col *ColumnStatistics) SmallCatTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

+ func (col *ColumnStatistics) SmallNumericTest(thresholds []DriftThreshold, rowCount int32) *catalog.DataTestCase

Aug 4, 2022

Changes in this version

type FeatureHistogramStatus

+ Errors int32

+ Total int32

Aug 4, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) ShouldClose(maxPredictions int32) bool

Aug 2, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) DefaultDriftThreshold(metric catalog.Metric) float64

+ func (fh *FeatureHistogram) ShouldDetectDriftForColumn(column string) bool

Aug 1, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) ShouldGenerateUnitTest() bool

type FeatureHistogramSpec

+ GenUnitTests *bool

Jul 30, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) ShouldUnitTest() bool

Jul 29, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) MarkUnitTestFailed(msg string, stop bool)

+ func (fh *FeatureHistogram) MarkUnitTested()

+ func (fh *FeatureHistogram) MarkUnitTesting()

+ func (fh *FeatureHistogram) UnitTested() bool

type FeatureHistogramConditionType

+ const FeatureHistogramUnitTested

type FeatureHistogramPhase

+ const FeatureHistogramPhaseUnitTested

+ const FeatureHistogramPhaseUnitTesting

Jul 27, 2022

Changes in this version

+ const ModelDriftChiSquaredLessThan

+ const ModelDriftJSDistanceLessThan

+ const ModelDriftKLDivergenceLessThan

+ const ModelDriftPSILessThan

+ const ModelDriftProportionDiffTestLessThan

+ const ModelDriftTwoSampleKSTestLessThan

+ const ModelDriftWassersteinDistanceLessThan

Jul 26, 2022

Changes in this version

+ const ColumnExist

+ const DatasetEmpty

type Dataset

+ func (dataset *Dataset) MarkUnitTesting()

type DatasetSpec

+ ServingDatasetRef v1.ObjectReference

+ UnitTested *bool

Jul 24, 2022

Changes in this version

+ const ColumnValueAscii

+ const ColumnValueBase64

+ const ColumnValueCreditCard

+ const ColumnValueEmail

+ const ColumnValueHasEntropy

+ const ColumnValueHostName

+ const ColumnValueIsbn10

+ const ColumnValueIsbn13

+ const ColumnValueLatitude

+ const ColumnValueLongitude

+ const ColumnValueMaxLength

+ const ColumnValueMinLength

+ const ColumnValueNameMatchPattern

+ const ColumnValueNonNegative

+ const ColumnValuePhoneNumber

+ const ColumnValuePositive

+ const ColumnValueSSN

+ const ColumnValueUUID3

+ const ColumnValueUUID4

+ const ColumnValueUUID5

+ const MultiColumnLessThan

+ const MultiColumnLessThanOrEqualTo

+ const MultiColumnUnique

+ const MultiColumnUniqueValueRatio

Jul 23, 2022

Changes in this version

+ const SqlQueryRunPhaseUnitTesting

type DataSourceSpec

+ UnitTestsTemplate catalog.TestSuite

type Dataset

+ func (dataset *Dataset) MarkUnitTestFailed(msg string)

+ func (dataset *Dataset) MarkUnitTested()

+ func (dataset *Dataset) UnitTested() bool

type DatasetConditionType

+ const DatasetUnitTested

type DatasetPhase

+ const DatasetPhaseUnitTesting

type DatasetSpec

+ UnitTests catalog.TestSuite

type DatasetStatus

+ UnitTestResult catalog.TestSuiteResult

+ UnitTestResults catalog.TestSuiteResult

type FeatureHistogramSpec

+ UnitTests catalog.TestSuite

type FeatureHistogramStatus

+ UnitTestsResult catalog.TestSuiteResult

type RecipeConditionType

+ const RecipeRunUnitTested

type RecipeRunPhase

+ const RecipeRunPhaseUnitTesting

type RecipeRunStatus

+ UnitTestsResult catalog.TestSuiteResult

type RecipeSpec

+ UnitTestsTemplate catalog.TestSuite

type SqlQueryRunConditionType

+ const SqlQueryRunUnitTested

type SqlQueryRunSpec

+ UnitTests catalog.TestSuite

type SqlQueryRunStatus

+ UnitTestsResult catalog.TestSuiteResult

type WebRequestRunSpec

+ UnitTests catalog.TestSuite

type WebRequestRunStatus

+ UnitTestsResult catalog.TestSuiteResult

Jul 22, 2022

Changes in this version

type DataSourceSpec

+ TestsTemplate catalog.TestSuite

type DatasetSpec

+ Tests catalog.TestSuite

type DatasetStatus

+ TestResult catalog.TestSuiteResult

Jul 22, 2022

Changes in this version

type FeatureHistogramSpec

+ Tests catalog.TestSuite

type FeatureHistogramStatus

+ TestsResult catalog.TestSuiteResult

Jul 18, 2022

Changes in this version

type FeatureHistogram

+ func (feature *FeatureHistogram) IsArchived() bool

Jul 18, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) AssignColumnTrainingHistogram(col string, histogram catalog.HistogramData)

+ func (fh *FeatureHistogram) AssignTrainingHistogramFrom(other *FeatureHistogram)

Jul 18, 2022

Changes in this version

type FeatureHistogramSpec

+ DriftThresholds []DriftThreshold

Jul 18, 2022

Changes in this version

type ColumnHistogram

+ Drift *bool

+ Histogram catalog.HistogramData

+ Metrics []catalog.Measurement

+ Training catalog.HistogramData

+ type DriftThreshold struct

+ Metric *catalog.Metric

+ Value *float64

+ func (*DriftThreshold) Descriptor() ([]byte, []int)

+ func (*DriftThreshold) ProtoMessage()

+ func (in *DriftThreshold) DeepCopy() *DriftThreshold

+ func (in *DriftThreshold) DeepCopyInto(out *DriftThreshold)

+ func (m *DriftThreshold) Marshal() (dAtA []byte, err error)

+ func (m *DriftThreshold) MarshalTo(dAtA []byte) (int, error)

+ func (m *DriftThreshold) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DriftThreshold) Reset()

+ func (m *DriftThreshold) Size() (n int)

+ func (m *DriftThreshold) Unmarshal(dAtA []byte) error

+ func (m *DriftThreshold) XXX_DiscardUnknown()

+ func (m *DriftThreshold) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DriftThreshold) XXX_Merge(src proto.Message)

+ func (m *DriftThreshold) XXX_Size() int

+ func (m *DriftThreshold) XXX_Unmarshal(b []byte) error

+ func (this *DriftThreshold) String() string

type DriftTresholdsSpec

+ Thresholds []DriftThreshold

type FeatureHistogramStatus

+ Columns []ColumnHistogram

Jul 13, 2022

Changes in this version

type DatasetRole

+ const DatasetRoleFeedback

+ const DatasetRoleServing

Jul 12, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) ShouldComputeDrift() bool

Jul 12, 2022

Changes in this version

type DriftTreshold

+ func (in *DriftTreshold) DeepCopy() *DriftTreshold

+ func (in *DriftTreshold) DeepCopyInto(out *DriftTreshold)

type DriftTresholdsSpec

+ func (in *DriftTresholdsSpec) DeepCopy() *DriftTresholdsSpec

+ func (in *DriftTresholdsSpec) DeepCopyInto(out *DriftTresholdsSpec)

Jul 12, 2022

Changes in this version

type FeatureHistogramSpec

+ Live *bool

+ SyncIntervalSec *int32

+ Thresholds DriftTresholdsSpec

Jul 11, 2022

Changes in this version

+ type DriftTreshold struct

+ Metric *catalog.Metric

+ Value *float64

+ func (*DriftTreshold) Descriptor() ([]byte, []int)

+ func (*DriftTreshold) ProtoMessage()

+ func (m *DriftTreshold) Marshal() (dAtA []byte, err error)

+ func (m *DriftTreshold) MarshalTo(dAtA []byte) (int, error)

+ func (m *DriftTreshold) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DriftTreshold) Reset()

+ func (m *DriftTreshold) Size() (n int)

+ func (m *DriftTreshold) Unmarshal(dAtA []byte) error

+ func (m *DriftTreshold) XXX_DiscardUnknown()

+ func (m *DriftTreshold) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DriftTreshold) XXX_Merge(src proto.Message)

+ func (m *DriftTreshold) XXX_Size() int

+ func (m *DriftTreshold) XXX_Unmarshal(b []byte) error

+ func (this *DriftTreshold) String() string

+ type DriftTresholdsSpec struct

+ Tresholds []DriftTreshold

+ func (*DriftTresholdsSpec) Descriptor() ([]byte, []int)

+ func (*DriftTresholdsSpec) ProtoMessage()

+ func (m *DriftTresholdsSpec) Marshal() (dAtA []byte, err error)

+ func (m *DriftTresholdsSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *DriftTresholdsSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DriftTresholdsSpec) Reset()

+ func (m *DriftTresholdsSpec) Size() (n int)

+ func (m *DriftTresholdsSpec) Unmarshal(dAtA []byte) error

+ func (m *DriftTresholdsSpec) XXX_DiscardUnknown()

+ func (m *DriftTresholdsSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DriftTresholdsSpec) XXX_Merge(src proto.Message)

+ func (m *DriftTresholdsSpec) XXX_Size() int

+ func (m *DriftTresholdsSpec) XXX_Unmarshal(b []byte) error

+ func (this *DriftTresholdsSpec) String() string

type FeatureHistogramSpec

+ Tresholds DriftTresholdsSpec

Jul 11, 2022

Changes in this version

type FeatureHistogram

+ func (fh *FeatureHistogram) DriftAlert(tenantRef *v1.ObjectReference, notifierName *string, err error) *infra.Alert

+ func (fh *FeatureHistogram) ErrorAlert(tenantRef *v1.ObjectReference, notifierName *string, err error) *infra.Alert

Jul 11, 2022

Changes in this version

type ColumnDrift

+ Drift *bool

type FeatureHistogram

+ func (feature *FeatureHistogram) MarkFailed(msg string)

type FeatureHistogramConditionType

+ const FeatureHistogramDriftDetected

+ type FeatureHistogramPhase string

+ const FeatureHistogramPhaseDetectingDrift

+ const FeatureHistogramPhaseDrifted

+ const FeatureHistogramPhaseFailed

+ const FeatureHistogramPhasePending

+ const FeatureHistogramPhaseReady

type FeatureHistogramStatus

+ FailureMessage *string

+ FailureReason *catalog.StatusError

+ Logs catalog.Logs

+ Phase FeatureHistogramPhase

Jul 10, 2022

Changes in this version

type Dataset

+ func (dataset *Dataset) DriftColumnNames() []string

+ func (dataset *Dataset) GetColumn(name string) (*ColumnStatistics, error)

Jul 10, 2022

Changes in this version

type DatasetSpec

+ GenerateFeatureHistogram *bool

type DatasetStatus

+ FeatureHistogramRef v1.ObjectReference

Jul 7, 2022

Changes in this version

type DatasetTestSuiteResult

+ func (in *DatasetTestSuiteResult) DeepCopy() *DatasetTestSuiteResult

+ func (in *DatasetTestSuiteResult) DeepCopyInto(out *DatasetTestSuiteResult)

Jul 7, 2022

Changes in this version

+ type DatasetTestSuiteResult struct

+ ColumnSuite catalog.TestSuiteResult

+ DatasetSuite catalog.TestSuiteResult

+ FileSuite catalog.TestSuiteResult

+ MultiColumnSuite catalog.TestSuiteResult

+ MultiDatasetSuite catalog.TestSuiteResult

+ func (*DatasetTestSuiteResult) Descriptor() ([]byte, []int)

+ func (*DatasetTestSuiteResult) ProtoMessage()

+ func (m *DatasetTestSuiteResult) Marshal() (dAtA []byte, err error)

+ func (m *DatasetTestSuiteResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *DatasetTestSuiteResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DatasetTestSuiteResult) Reset()

+ func (m *DatasetTestSuiteResult) Size() (n int)

+ func (m *DatasetTestSuiteResult) Unmarshal(dAtA []byte) error

+ func (m *DatasetTestSuiteResult) XXX_DiscardUnknown()

+ func (m *DatasetTestSuiteResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DatasetTestSuiteResult) XXX_Merge(src proto.Message)

+ func (m *DatasetTestSuiteResult) XXX_Size() int

+ func (m *DatasetTestSuiteResult) XXX_Unmarshal(b []byte) error

+ func (this *DatasetTestSuiteResult) String() string

Jul 6, 2022

Changes in this version

+ type DatasetTestSuite struct

+ ColumnSuite catalog.TestSuite

+ DatasetSuite catalog.TestSuite

+ FileSuite catalog.TestSuite

+ MultiColumnSuite catalog.TestSuite

+ MultiDatasetSuite catalog.TestSuite

+ func (*DatasetTestSuite) Descriptor() ([]byte, []int)

+ func (*DatasetTestSuite) ProtoMessage()

+ func (in *DatasetTestSuite) DeepCopy() *DatasetTestSuite

+ func (in *DatasetTestSuite) DeepCopyInto(out *DatasetTestSuite)

+ func (m *DatasetTestSuite) Marshal() (dAtA []byte, err error)

+ func (m *DatasetTestSuite) MarshalTo(dAtA []byte) (int, error)

+ func (m *DatasetTestSuite) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DatasetTestSuite) Reset()

+ func (m *DatasetTestSuite) Size() (n int)

+ func (m *DatasetTestSuite) Unmarshal(dAtA []byte) error

+ func (m *DatasetTestSuite) XXX_DiscardUnknown()

+ func (m *DatasetTestSuite) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DatasetTestSuite) XXX_Merge(src proto.Message)

+ func (m *DatasetTestSuite) XXX_Size() int

+ func (m *DatasetTestSuite) XXX_Unmarshal(b []byte) error

+ func (this *DatasetTestSuite) String() string

type Schema

+ TestTemplate DatasetTestSuite

Jul 6, 2022

Changes in this version

type TestSpec

+ ColumnSuite catalog.TestSuite

+ DatasetSuite catalog.TestSuite

+ FileSuite catalog.TestSuite

+ MultiColumnSuite catalog.TestSuite

+ MultiDatasetSuite catalog.TestSuite

Jul 5, 2022

Changes in this version

+ const ColumnHasNoNull

+ const ColumnHasNoValue

+ const ColumnHaveNulls

+ const ColumnHaveValues

+ const ColumnMismatchValueBetween

+ const ColumnOfType

+ const ColumnOutlierValueUniqueBetween

+ const ColumnUniqueValueCountBetween

+ const ColumnValidValueUniqueBetween

+ const ColumnValueAvgBetween

+ const ColumnValueChiSquarePValueBetween

+ const ColumnValueInDomain

+ const ColumnValueIsDate

+ const ColumnValueIsJson

+ const ColumnValueLengthBetween

+ const ColumnValueLowerQuartileBetween

+ const ColumnValueMaxBetween

+ const ColumnValueMedianBetween

+ const ColumnValueMinBetween

+ const ColumnValueNameMatchRegex

+ const ColumnValuePairCramersBetween

+ const ColumnValueStddevBetween

+ const ColumnValueUpperQuartileBetween

+ const ColumnValuesInSet

+ const ColumnValuesIncreasing

+ const ColumnsValuesDecreasing

+ const DatasetColumnsCountEqual

+ const DatasetColumnsInOrderedList

+ const DatasetColumnsNameInSet

+ const DatasetNotEmpty

+ const DatasetRowCountBetween

+ const MultiDatasetInnerJoinEmpty

+ const MultiDatasetInnerJoinNotEmpty

+ const MultiDatasetLeftJoinEmpty

+ const MultiDatasetLeftJoinNotEmpty

+ const MultiDatasetOuterJoinEmpty

+ const MultiDatasetOuterJoinNotEmpty

+ const MultiDatasetRightJoinEmpty

+ const MultiDatasetRightJoinNotEmpty

+ const MultiDatasetSameNumberOfRows

type DatasetStatus

+ TestResults catalog.TestSuiteResult

Jul 5, 2022

Changes in this version

type ColumnTestName

+ const ColumnTestNameChiSquarePValueBetween

+ const ColumnTestNamePairCramersBetween

+ const ColumnTestNameStddevBetween

+ type DataTestResult struct

+ Column string

+ Error string

+ Passed bool

+ Type string

+ func (*DataTestResult) Descriptor() ([]byte, []int)

+ func (*DataTestResult) ProtoMessage()

+ func (in *DataTestResult) DeepCopy() *DataTestResult

+ func (in *DataTestResult) DeepCopyInto(out *DataTestResult)

+ func (m *DataTestResult) Marshal() (dAtA []byte, err error)

+ func (m *DataTestResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *DataTestResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DataTestResult) Reset()

+ func (m *DataTestResult) Size() (n int)

+ func (m *DataTestResult) Unmarshal(dAtA []byte) error

+ func (m *DataTestResult) XXX_DiscardUnknown()

+ func (m *DataTestResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DataTestResult) XXX_Merge(src proto.Message)

+ func (m *DataTestResult) XXX_Size() int

+ func (m *DataTestResult) XXX_Unmarshal(b []byte) error

+ func (this *DataTestResult) String() string

Jul 4, 2022

Changes in this version

type DatasetSpec

+ PredictorRef v1.ObjectReference

Jul 3, 2022

Changes in this version

type ColumnDrift

+ func (in *ColumnDrift) DeepCopy() *ColumnDrift

+ func (in *ColumnDrift) DeepCopyInto(out *ColumnDrift)

type ColumnHistogram

+ func (in *ColumnHistogram) DeepCopy() *ColumnHistogram

+ func (in *ColumnHistogram) DeepCopyInto(out *ColumnHistogram)

Jul 3, 2022

Changes in this version

+ type ColumnDrift struct

+ Metrics []catalog.Measurement

+ Name string

+ func (*ColumnDrift) Descriptor() ([]byte, []int)

+ func (*ColumnDrift) ProtoMessage()

+ func (m *ColumnDrift) Marshal() (dAtA []byte, err error)

+ func (m *ColumnDrift) MarshalTo(dAtA []byte) (int, error)

+ func (m *ColumnDrift) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ColumnDrift) Reset()

+ func (m *ColumnDrift) Size() (n int)

+ func (m *ColumnDrift) Unmarshal(dAtA []byte) error

+ func (m *ColumnDrift) XXX_DiscardUnknown()

+ func (m *ColumnDrift) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ColumnDrift) XXX_Merge(src proto.Message)

+ func (m *ColumnDrift) XXX_Size() int

+ func (m *ColumnDrift) XXX_Unmarshal(b []byte) error

+ func (this *ColumnDrift) String() string

+ type ColumnHistogram struct

+ Historgram catalog.HistogramData

+ Name string

+ func (*ColumnHistogram) Descriptor() ([]byte, []int)

+ func (*ColumnHistogram) ProtoMessage()

+ func (m *ColumnHistogram) Marshal() (dAtA []byte, err error)

+ func (m *ColumnHistogram) MarshalTo(dAtA []byte) (int, error)

+ func (m *ColumnHistogram) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ColumnHistogram) Reset()

+ func (m *ColumnHistogram) Size() (n int)

+ func (m *ColumnHistogram) Unmarshal(dAtA []byte) error

+ func (m *ColumnHistogram) XXX_DiscardUnknown()

+ func (m *ColumnHistogram) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ColumnHistogram) XXX_Merge(src proto.Message)

+ func (m *ColumnHistogram) XXX_Size() int

+ func (m *ColumnHistogram) XXX_Unmarshal(b []byte) error

+ func (this *ColumnHistogram) String() string

type DatasetRole

+ const DatasetRoleUnlabeled

type FeatureHistogramSpec

+ Columns []string

+ SourceRef *v1.ObjectReference

Jul 3, 2022

Changes in this version

type DataSourceSpec

+ Labeled *bool

type DatasetSpec

+ PredictionDatasetRef v1.ObjectReference

Jul 3, 2022

Changes in this version

type FeatureHistogramSpec

+ Active *bool

+ End *metav1.Time

+ Start *metav1.Time

+ Target *bool

+ Training *bool

Jul 3, 2022

Changes in this version

type SyntacticSpec

+ func (in *SyntacticSpec) DeepCopy() *SyntacticSpec

+ func (in *SyntacticSpec) DeepCopyInto(out *SyntacticSpec)

Jul 3, 2022

Changes in this version

type DataLocationType

+ const DatasetRoleGroundTruth

+ const DatasetRolePredictions

+ const DatasetRoleTraining

+ const DatasetRoleUnlabled

+ type DatasetRole string

type DatasetSpec

+ Role *DatasetRole

+ type SyntacticSpec struct

+ Enabled *bool

+ Rows *int32

+ func (*SyntacticSpec) Descriptor() ([]byte, []int)

+ func (*SyntacticSpec) ProtoMessage()

+ func (m *SyntacticSpec) Marshal() (dAtA []byte, err error)

+ func (m *SyntacticSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *SyntacticSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SyntacticSpec) Reset()

+ func (m *SyntacticSpec) Size() (n int)

+ func (m *SyntacticSpec) Unmarshal(dAtA []byte) error

+ func (m *SyntacticSpec) XXX_DiscardUnknown()

+ func (m *SyntacticSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SyntacticSpec) XXX_Merge(src proto.Message)

+ func (m *SyntacticSpec) XXX_Size() int

+ func (m *SyntacticSpec) XXX_Unmarshal(b []byte) error

+ func (this *SyntacticSpec) String() string

Jul 1, 2022

Changes in this version

+ type MultiColumnTest struct

+ Columns []string

+ Generated *bool

+ Max *float64

+ Min *float64

+ StrictMax *bool

+ StrictMin *bool

+ Type *MultiColumnTestName

+ Value *float64

+ ValueSet []string

+ func (*MultiColumnTest) Descriptor() ([]byte, []int)

+ func (*MultiColumnTest) ProtoMessage()

+ func (in *MultiColumnTest) DeepCopy() *MultiColumnTest

+ func (in *MultiColumnTest) DeepCopyInto(out *MultiColumnTest)

+ func (m *MultiColumnTest) Marshal() (dAtA []byte, err error)

+ func (m *MultiColumnTest) MarshalTo(dAtA []byte) (int, error)

+ func (m *MultiColumnTest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MultiColumnTest) Reset()

+ func (m *MultiColumnTest) Size() (n int)

+ func (m *MultiColumnTest) Unmarshal(dAtA []byte) error

+ func (m *MultiColumnTest) XXX_DiscardUnknown()

+ func (m *MultiColumnTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MultiColumnTest) XXX_Merge(src proto.Message)

+ func (m *MultiColumnTest) XXX_Size() int

+ func (m *MultiColumnTest) XXX_Unmarshal(b []byte) error

+ func (this *MultiColumnTest) String() string

type Schema

+ Tests TestSpec

+ type TestSpec struct

+ ColumnTests []ColumnTest

+ DatasetTests []DatasetTest

+ FileTests []FileTest

+ MultiColumnTests []MultiColumnTest

+ MultiDatasetTests []MultiDatasetTest

+ func (*TestSpec) Descriptor() ([]byte, []int)

+ func (*TestSpec) ProtoMessage()

+ func (in *TestSpec) DeepCopy() *TestSpec

+ func (in *TestSpec) DeepCopyInto(out *TestSpec)

+ func (m *TestSpec) Marshal() (dAtA []byte, err error)

+ func (m *TestSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *TestSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TestSpec) Reset()

+ func (m *TestSpec) Size() (n int)

+ func (m *TestSpec) Unmarshal(dAtA []byte) error

+ func (m *TestSpec) XXX_DiscardUnknown()

+ func (m *TestSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TestSpec) XXX_Merge(src proto.Message)

+ func (m *TestSpec) XXX_Size() int

+ func (m *TestSpec) XXX_Unmarshal(b []byte) error

+ func (this *TestSpec) String() string

Jun 30, 2022

Changes in this version

+ type ColumnTest struct

+ Column *string

+ Generated *bool

+ Max *float64

+ Min *float64

+ StrictMax *bool

+ StrictMin *bool

+ Type *ColumnTestName

+ Value *float64

+ ValueSet []string

+ func (*ColumnTest) Descriptor() ([]byte, []int)

+ func (*ColumnTest) ProtoMessage()

+ func (in *ColumnTest) DeepCopy() *ColumnTest

+ func (in *ColumnTest) DeepCopyInto(out *ColumnTest)

+ func (m *ColumnTest) Marshal() (dAtA []byte, err error)

+ func (m *ColumnTest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ColumnTest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ColumnTest) Reset()

+ func (m *ColumnTest) Size() (n int)

+ func (m *ColumnTest) Unmarshal(dAtA []byte) error

+ func (m *ColumnTest) XXX_DiscardUnknown()

+ func (m *ColumnTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ColumnTest) XXX_Merge(src proto.Message)

+ func (m *ColumnTest) XXX_Size() int

+ func (m *ColumnTest) XXX_Unmarshal(b []byte) error

+ func (this *ColumnTest) String() string

+ type ColumnTestName string

+ const ColumnTestChiSquarePValueBetween

+ const ColumnTestInDomain

+ const ColumnTestNameAvgBetween

+ const ColumnTestNameColumnExist

+ const ColumnTestNameColumnHasNoNull

+ const ColumnTestNameColumnHasNoValue

+ const ColumnTestNameColumnHaveNulls

+ const ColumnTestNameColumnHaveValues

+ const ColumnTestNameColumnOfType

+ const ColumnTestNameDecreasing

+ const ColumnTestNameInSet

+ const ColumnTestNameIncreasing

+ const ColumnTestNameIsDate

+ const ColumnTestNameIsJson

+ const ColumnTestNameLengthBetween

+ const ColumnTestNameLowerQuartileBetween

+ const ColumnTestNameMatchRegex

+ const ColumnTestNameMaxBetween

+ const ColumnTestNameMedianBetween

+ const ColumnTestNameMinBetween

+ const ColumnTestNameMismatchValueBetween

+ const ColumnTestNameOutlierValueUniqueBetween

+ const ColumnTestNameUniqueValueCountBetween

+ const ColumnTestNameUpperQuartileBetween

+ const ColumnTestNameValidValueUniqueBetween

+ const ColumnTestPairCramersBetween

+ const ColumnTestStddevBetween

+ type DatasetTest struct

+ Generated *bool

+ Max *float64

+ Min *float64

+ StrictMax *bool

+ StrictMin *bool

+ Type *DatasetTestName

+ Value *float64

+ ValueSet []string

+ func (*DatasetTest) Descriptor() ([]byte, []int)

+ func (*DatasetTest) ProtoMessage()

+ func (in *DatasetTest) DeepCopy() *DatasetTest

+ func (in *DatasetTest) DeepCopyInto(out *DatasetTest)

+ func (m *DatasetTest) Marshal() (dAtA []byte, err error)

+ func (m *DatasetTest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DatasetTest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *DatasetTest) Reset()

+ func (m *DatasetTest) Size() (n int)

+ func (m *DatasetTest) Unmarshal(dAtA []byte) error

+ func (m *DatasetTest) XXX_DiscardUnknown()

+ func (m *DatasetTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DatasetTest) XXX_Merge(src proto.Message)

+ func (m *DatasetTest) XXX_Size() int

+ func (m *DatasetTest) XXX_Unmarshal(b []byte) error

+ func (this *DatasetTest) String() string

+ type DatasetTestName string

+ const DatasetTestNameColumnsCountEqual

+ const DatasetTestNameColumnsInOrderedList

+ const DatasetTestNameColumnsNameInSet

+ const DatasetTestNameNameEmpty

+ const DatasetTestNameNameNotEmpty

+ const DatasetTestNameRowCountBetween

+ type FileTest struct

+ BucketName *string

+ Generated *bool

+ Max *float64

+ Min *float64

+ Path *string

+ StrictMax *bool

+ StrictMin *bool

+ Type *FileTestName

+ Value *float64

+ ValueSet []string

+ func (*FileTest) Descriptor() ([]byte, []int)

+ func (*FileTest) ProtoMessage()

+ func (in *FileTest) DeepCopy() *FileTest

+ func (in *FileTest) DeepCopyInto(out *FileTest)

+ func (m *FileTest) Marshal() (dAtA []byte, err error)

+ func (m *FileTest) MarshalTo(dAtA []byte) (int, error)

+ func (m *FileTest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FileTest) Reset()

+ func (m *FileTest) Size() (n int)

+ func (m *FileTest) Unmarshal(dAtA []byte) error

+ func (m *FileTest) XXX_DiscardUnknown()

+ func (m *FileTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FileTest) XXX_Merge(src proto.Message)

+ func (m *FileTest) XXX_Size() int

+ func (m *FileTest) XXX_Unmarshal(b []byte) error

+ func (this *FileTest) String() string

+ type FileTestName string

+ type MultiColumnTestName string

+ type MultiDatasetTest struct

+ Datasets []string

+ Generated *bool

+ Type *MultiDatasetTestName

+ func (*MultiDatasetTest) Descriptor() ([]byte, []int)

+ func (*MultiDatasetTest) ProtoMessage()

+ func (in *MultiDatasetTest) DeepCopy() *MultiDatasetTest

+ func (in *MultiDatasetTest) DeepCopyInto(out *MultiDatasetTest)

+ func (m *MultiDatasetTest) Marshal() (dAtA []byte, err error)

+ func (m *MultiDatasetTest) MarshalTo(dAtA []byte) (int, error)

+ func (m *MultiDatasetTest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MultiDatasetTest) Reset()

+ func (m *MultiDatasetTest) Size() (n int)

+ func (m *MultiDatasetTest) Unmarshal(dAtA []byte) error

+ func (m *MultiDatasetTest) XXX_DiscardUnknown()

+ func (m *MultiDatasetTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MultiDatasetTest) XXX_Merge(src proto.Message)

+ func (m *MultiDatasetTest) XXX_Size() int

+ func (m *MultiDatasetTest) XXX_Unmarshal(b []byte) error

+ func (this *MultiDatasetTest) String() string

+ type MultiDatasetTestName string

+ const MultiDatasetTestNameInnerJoinEmpty

+ const MultiDatasetTestNameInnerJoinNotEmpty

+ const MultiDatasetTestNameLeftJoinEmpty

+ const MultiDatasetTestNameLeftJoinNotEmpty

+ const MultiDatasetTestNameOuterJoinEmpty

+ const MultiDatasetTestNameOuterJoinNotEmpty

+ const MultiDatasetTestNameRightJoinEmpty

+ const MultiDatasetTestNameRightJoinNotEmpty

+ const MultiDatasetTestNameSameNumberOfRows

Jun 26, 2022

Changes in this version

type FeatureHistogramSpec

+ BaseFeatureHistogram v1.ObjectReference

type FeatureHistogramStatus

+ Drift []catalog.Measurement

Jun 15, 2022

Changes in this version

type FlatFileType

+ const FlatFileTypeParquet

Jun 15, 2022

Changes in this version

+ type FlatFileFormatSpec struct

+ Csv CsvFileSpec

+ Excel ExcelNotebookSpec

+ FileType *FlatFileType

+ Parquet ParquetFileSpec

+ func (*FlatFileFormatSpec) Descriptor() ([]byte, []int)

+ func (*FlatFileFormatSpec) ProtoMessage()

+ func (in *FlatFileFormatSpec) DeepCopy() *FlatFileFormatSpec

+ func (in *FlatFileFormatSpec) DeepCopyInto(out *FlatFileFormatSpec)

+ func (m *FlatFileFormatSpec) Marshal() (dAtA []byte, err error)

+ func (m *FlatFileFormatSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *FlatFileFormatSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FlatFileFormatSpec) Reset()

+ func (m *FlatFileFormatSpec) Size() (n int)

+ func (m *FlatFileFormatSpec) Unmarshal(dAtA []byte) error

+ func (m *FlatFileFormatSpec) XXX_DiscardUnknown()

+ func (m *FlatFileFormatSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FlatFileFormatSpec) XXX_Merge(src proto.Message)

+ func (m *FlatFileFormatSpec) XXX_Size() int

+ func (m *FlatFileFormatSpec) XXX_Unmarshal(b []byte) error

+ func (this *FlatFileFormatSpec) String() string

+ type ParquetFileSpec struct

+ Engine *string

+ func (*ParquetFileSpec) Descriptor() ([]byte, []int)

+ func (*ParquetFileSpec) ProtoMessage()

+ func (in *ParquetFileSpec) DeepCopy() *ParquetFileSpec

+ func (in *ParquetFileSpec) DeepCopyInto(out *ParquetFileSpec)

+ func (m *ParquetFileSpec) Marshal() (dAtA []byte, err error)

+ func (m *ParquetFileSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *ParquetFileSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ParquetFileSpec) Reset()

+ func (m *ParquetFileSpec) Size() (n int)

+ func (m *ParquetFileSpec) Unmarshal(dAtA []byte) error

+ func (m *ParquetFileSpec) XXX_DiscardUnknown()

+ func (m *ParquetFileSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ParquetFileSpec) XXX_Merge(src proto.Message)

+ func (m *ParquetFileSpec) XXX_Size() int

+ func (m *ParquetFileSpec) XXX_Unmarshal(b []byte) error

+ func (this *ParquetFileSpec) String() string

Jun 15, 2022

Changes in this version

+ type OutlierStat struct

+ Lower int32

+ Percent float32

+ Upper int32

+ func (*OutlierStat) Descriptor() ([]byte, []int)

+ func (*OutlierStat) ProtoMessage()

+ func (in *OutlierStat) DeepCopy() *OutlierStat

+ func (in *OutlierStat) DeepCopyInto(out *OutlierStat)

+ func (m *OutlierStat) Marshal() (dAtA []byte, err error)

+ func (m *OutlierStat) MarshalTo(dAtA []byte) (int, error)

+ func (m *OutlierStat) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OutlierStat) Reset()

+ func (m *OutlierStat) Size() (n int)

+ func (m *OutlierStat) Unmarshal(dAtA []byte) error

+ func (m *OutlierStat) XXX_DiscardUnknown()

+ func (m *OutlierStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OutlierStat) XXX_Merge(src proto.Message)

+ func (m *OutlierStat) XXX_Size() int

+ func (m *OutlierStat) XXX_Unmarshal(b []byte) error

+ func (this *OutlierStat) String() string

Jun 14, 2022

Changes in this version

type DatasetStatus

+ AnomaliesUri string

Jun 11, 2022

Changes in this version

type DataProductSpec

+ SubTask *catalog.MLSubtaskTaskSpec

type DataSourceSpec

+ SubTask *catalog.MLTask

type DatasetSpec

+ SubTask *catalog.MLSubtaskTaskSpec