qualitymonitorv2

package
v0.95.0 Latest Latest
Warning

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

Go to latest
Published: Dec 17, 2025 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Overview

Manage data quality of UC objects (currently support `schema`)

Index

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

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

Type always returns AnomalyDetectionRunStatus to satisfy [pflag.Value] interface

func (*AnomalyDetectionRunStatus) Values

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 DeleteQualityMonitorRequest

type DeleteQualityMonitorRequest 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:"-"`
}

type GetQualityMonitorRequest

type GetQualityMonitorRequest 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:"-"`
}

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL