Documentation
¶
Overview ¶
Manage data quality of UC objects (currently support `schema`)
Index ¶
- type AnomalyDetectionConfig
- type AnomalyDetectionRunStatus
- type CreateQualityMonitorRequest
- type DeleteQualityMonitorRequest
- type GetQualityMonitorRequest
- type ListQualityMonitorRequest
- type ListQualityMonitorResponse
- type QualityMonitor
- type QualityMonitorV2API
- func (a *QualityMonitorV2API) CreateQualityMonitor(ctx context.Context, request CreateQualityMonitorRequest) (*QualityMonitor, error)
- func (a *QualityMonitorV2API) DeleteQualityMonitor(ctx context.Context, request DeleteQualityMonitorRequest) error
- func (a *QualityMonitorV2API) DeleteQualityMonitorByObjectTypeAndObjectId(ctx context.Context, objectType string, objectId string) error
- func (a *QualityMonitorV2API) GetQualityMonitor(ctx context.Context, request GetQualityMonitorRequest) (*QualityMonitor, error)
- func (a *QualityMonitorV2API) GetQualityMonitorByObjectTypeAndObjectId(ctx context.Context, objectType string, objectId string) (*QualityMonitor, error)
- func (a *QualityMonitorV2API) ListQualityMonitor(ctx context.Context, request ListQualityMonitorRequest) listing.Iterator[QualityMonitor]
- func (a *QualityMonitorV2API) ListQualityMonitorAll(ctx context.Context, request ListQualityMonitorRequest) ([]QualityMonitor, error)
- func (a *QualityMonitorV2API) UpdateQualityMonitor(ctx context.Context, request UpdateQualityMonitorRequest) (*QualityMonitor, error)
- type QualityMonitorV2Interface
- type QualityMonitorV2Servicedeprecated
- type UpdateQualityMonitorRequest
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AnomalyDetectionConfig ¶
type AnomalyDetectionConfig struct {
// Run id of the last run of the workflow
LastRunId string `json:"last_run_id,omitempty"`
// The status of the last run of the workflow.
LatestRunStatus AnomalyDetectionRunStatus `json:"latest_run_status,omitempty"`
ForceSendFields []string `json:"-" url:"-"`
}
func (AnomalyDetectionConfig) MarshalJSON ¶
func (s AnomalyDetectionConfig) MarshalJSON() ([]byte, error)
func (*AnomalyDetectionConfig) UnmarshalJSON ¶
func (s *AnomalyDetectionConfig) UnmarshalJSON(b []byte) error
type AnomalyDetectionRunStatus ¶
type AnomalyDetectionRunStatus string
Status of Anomaly Detection Job Run
const AnomalyDetectionRunStatusAnomalyDetectionRunStatusCanceled AnomalyDetectionRunStatus = `ANOMALY_DETECTION_RUN_STATUS_CANCELED`
const AnomalyDetectionRunStatusAnomalyDetectionRunStatusFailed AnomalyDetectionRunStatus = `ANOMALY_DETECTION_RUN_STATUS_FAILED`
const AnomalyDetectionRunStatusAnomalyDetectionRunStatusJobDeleted AnomalyDetectionRunStatus = `ANOMALY_DETECTION_RUN_STATUS_JOB_DELETED`
const AnomalyDetectionRunStatusAnomalyDetectionRunStatusPending AnomalyDetectionRunStatus = `ANOMALY_DETECTION_RUN_STATUS_PENDING`
const AnomalyDetectionRunStatusAnomalyDetectionRunStatusRunning AnomalyDetectionRunStatus = `ANOMALY_DETECTION_RUN_STATUS_RUNNING`
const AnomalyDetectionRunStatusAnomalyDetectionRunStatusSuccess AnomalyDetectionRunStatus = `ANOMALY_DETECTION_RUN_STATUS_SUCCESS`
const AnomalyDetectionRunStatusAnomalyDetectionRunStatusUnknown AnomalyDetectionRunStatus = `ANOMALY_DETECTION_RUN_STATUS_UNKNOWN`
const AnomalyDetectionRunStatusAnomalyDetectionRunStatusWorkspaceMismatchError AnomalyDetectionRunStatus = `ANOMALY_DETECTION_RUN_STATUS_WORKSPACE_MISMATCH_ERROR`
func (*AnomalyDetectionRunStatus) Set ¶
func (f *AnomalyDetectionRunStatus) Set(v string) error
Set raw string value and validate it against allowed values
func (*AnomalyDetectionRunStatus) String ¶
func (f *AnomalyDetectionRunStatus) String() string
String representation for fmt.Print
func (*AnomalyDetectionRunStatus) Type ¶
func (f *AnomalyDetectionRunStatus) Type() string
Type always returns AnomalyDetectionRunStatus to satisfy [pflag.Value] interface
func (*AnomalyDetectionRunStatus) Values ¶
func (f *AnomalyDetectionRunStatus) Values() []AnomalyDetectionRunStatus
Values returns all possible values for AnomalyDetectionRunStatus.
There is no guarantee on the order of the values in the slice.
type CreateQualityMonitorRequest ¶
type CreateQualityMonitorRequest struct {
QualityMonitor QualityMonitor `json:"quality_monitor"`
}
type ListQualityMonitorRequest ¶
type ListQualityMonitorRequest struct {
PageSize int `json:"-" url:"page_size,omitempty"`
PageToken string `json:"-" url:"page_token,omitempty"`
ForceSendFields []string `json:"-" url:"-"`
}
func (ListQualityMonitorRequest) MarshalJSON ¶
func (s ListQualityMonitorRequest) MarshalJSON() ([]byte, error)
func (*ListQualityMonitorRequest) UnmarshalJSON ¶
func (s *ListQualityMonitorRequest) UnmarshalJSON(b []byte) error
type ListQualityMonitorResponse ¶
type ListQualityMonitorResponse struct {
NextPageToken string `json:"next_page_token,omitempty"`
QualityMonitors []QualityMonitor `json:"quality_monitors,omitempty"`
ForceSendFields []string `json:"-" url:"-"`
}
func (ListQualityMonitorResponse) MarshalJSON ¶
func (s ListQualityMonitorResponse) MarshalJSON() ([]byte, error)
func (*ListQualityMonitorResponse) UnmarshalJSON ¶
func (s *ListQualityMonitorResponse) UnmarshalJSON(b []byte) error
type QualityMonitor ¶
type QualityMonitor struct {
AnomalyDetectionConfig *AnomalyDetectionConfig `json:"anomaly_detection_config,omitempty"`
// The uuid of the request object. For example, schema id.
ObjectId string `json:"object_id"`
// The type of the monitored object. Can be one of the following: schema.
ObjectType string `json:"object_type"`
}
type QualityMonitorV2API ¶
type QualityMonitorV2API struct {
// contains filtered or unexported fields
}
Manage data quality of UC objects (currently support `schema`)
func NewQualityMonitorV2 ¶
func NewQualityMonitorV2(client *client.DatabricksClient) *QualityMonitorV2API
func (*QualityMonitorV2API) CreateQualityMonitor ¶
func (a *QualityMonitorV2API) CreateQualityMonitor(ctx context.Context, request CreateQualityMonitorRequest) (*QualityMonitor, error)
func (*QualityMonitorV2API) DeleteQualityMonitor ¶
func (a *QualityMonitorV2API) DeleteQualityMonitor(ctx context.Context, request DeleteQualityMonitorRequest) error
func (*QualityMonitorV2API) DeleteQualityMonitorByObjectTypeAndObjectId ¶
func (a *QualityMonitorV2API) DeleteQualityMonitorByObjectTypeAndObjectId(ctx context.Context, objectType string, objectId string) error
Delete a quality monitor on UC object
func (*QualityMonitorV2API) GetQualityMonitor ¶
func (a *QualityMonitorV2API) GetQualityMonitor(ctx context.Context, request GetQualityMonitorRequest) (*QualityMonitor, error)
func (*QualityMonitorV2API) GetQualityMonitorByObjectTypeAndObjectId ¶
func (a *QualityMonitorV2API) GetQualityMonitorByObjectTypeAndObjectId(ctx context.Context, objectType string, objectId string) (*QualityMonitor, error)
Read a quality monitor on UC object
func (*QualityMonitorV2API) ListQualityMonitor ¶
func (a *QualityMonitorV2API) ListQualityMonitor(ctx context.Context, request ListQualityMonitorRequest) listing.Iterator[QualityMonitor]
(Unimplemented) List quality monitors
func (*QualityMonitorV2API) ListQualityMonitorAll ¶
func (a *QualityMonitorV2API) ListQualityMonitorAll(ctx context.Context, request ListQualityMonitorRequest) ([]QualityMonitor, error)
(Unimplemented) List quality monitors
func (*QualityMonitorV2API) UpdateQualityMonitor ¶
func (a *QualityMonitorV2API) UpdateQualityMonitor(ctx context.Context, request UpdateQualityMonitorRequest) (*QualityMonitor, error)
type QualityMonitorV2Interface ¶
type QualityMonitorV2Interface interface {
// Create a quality monitor on UC object
CreateQualityMonitor(ctx context.Context, request CreateQualityMonitorRequest) (*QualityMonitor, error)
// Delete a quality monitor on UC object
DeleteQualityMonitor(ctx context.Context, request DeleteQualityMonitorRequest) error
// Delete a quality monitor on UC object
DeleteQualityMonitorByObjectTypeAndObjectId(ctx context.Context, objectType string, objectId string) error
// Read a quality monitor on UC object
GetQualityMonitor(ctx context.Context, request GetQualityMonitorRequest) (*QualityMonitor, error)
// Read a quality monitor on UC object
GetQualityMonitorByObjectTypeAndObjectId(ctx context.Context, objectType string, objectId string) (*QualityMonitor, error)
// (Unimplemented) List quality monitors
//
// This method is generated by Databricks SDK Code Generator.
ListQualityMonitor(ctx context.Context, request ListQualityMonitorRequest) listing.Iterator[QualityMonitor]
// (Unimplemented) List quality monitors
//
// This method is generated by Databricks SDK Code Generator.
ListQualityMonitorAll(ctx context.Context, request ListQualityMonitorRequest) ([]QualityMonitor, error)
// (Unimplemented) Update a quality monitor on UC object
UpdateQualityMonitor(ctx context.Context, request UpdateQualityMonitorRequest) (*QualityMonitor, error)
}
type QualityMonitorV2Service
deprecated
type QualityMonitorV2Service interface {
// Create a quality monitor on UC object
CreateQualityMonitor(ctx context.Context, request CreateQualityMonitorRequest) (*QualityMonitor, error)
// Delete a quality monitor on UC object
DeleteQualityMonitor(ctx context.Context, request DeleteQualityMonitorRequest) error
// Read a quality monitor on UC object
GetQualityMonitor(ctx context.Context, request GetQualityMonitorRequest) (*QualityMonitor, error)
// (Unimplemented) List quality monitors
ListQualityMonitor(ctx context.Context, request ListQualityMonitorRequest) (*ListQualityMonitorResponse, error)
// (Unimplemented) Update a quality monitor on UC object
UpdateQualityMonitor(ctx context.Context, request UpdateQualityMonitorRequest) (*QualityMonitor, error)
}
Manage data quality of UC objects (currently support `schema`)
Deprecated: Do not use this interface, it will be removed in a future version of the SDK.
type UpdateQualityMonitorRequest ¶
type UpdateQualityMonitorRequest struct {
// The uuid of the request object. For example, schema id.
ObjectId string `json:"-" url:"-"`
// The type of the monitored object. Can be one of the following: schema.
ObjectType string `json:"-" url:"-"`
QualityMonitor QualityMonitor `json:"quality_monitor"`
}