bigquery

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

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

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

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

type Config struct {
	ProjectID           string `envconfig:"BIGQUERY_PROJECT"`
	CredentialsFilePath string `envconfig:"BIGQUERY_CREDENTIALS_FILE"`
	CredentialsJSON     string
	Credentials         *google.Credentials
	Location            string `envconfig:"BIGQUERY_LOCATION"`
}

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

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

type DB interface {
	Querier
	Selector
	MetadataUpdater
}

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

type MetadataUpdater interface {
	UpdateTableMetadataIfNotExist(ctx context.Context, asset *pipeline.Asset) error
}

type NoMetadataUpdatedError struct{}

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

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

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

type Querier interface {
	RunQueryWithoutResult(ctx context.Context, query *query.Query) error
}

type Selector interface {
	Select(ctx context.Context, query *query.Query) ([][]interface{}, error)
}

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