cmd

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

type ColumnSummary struct {
	Name           string      `json:"name"`
	Type           string      `json:"type"`
	NormalizedType string      `json:"normalized_type"`
	Nullable       bool        `json:"nullable"`
	PrimaryKey     bool        `json:"primary_key"`
	Unique         bool        `json:"unique"`
	Stats          interface{} `json:"stats,omitempty"`
}

type ConnectionsCommand struct{}

type EnvironmentCloneCommand struct{}

type EnvironmentDeleteCommand struct{}

type EnvironmentListCommand struct{}

type EnvironmentUpdateCommand struct{}

type ErrorResponse struct {
	Error string `json:"error"`
}

type ErrorResponses struct {
	Error []string `json:"error"`
}

type ExecutionSummary struct {
	TotalTasks      int
	SuccessfulTasks int
	FailedTasks     int
	SkippedTasks    int

	Assets       TaskTypeStats
	ColumnChecks TaskTypeStats
	CustomChecks TaskTypeStats
	MetadataPush TaskTypeStats

	Duration time.Duration
}

type Filter struct {
	IncludeTag        string   // Tag to include assets (from `--tag`)
	OnlyTaskTypes     []string // Task types to include (from `--only`)
	IncludeDownstream bool     // Whether to include downstream tasks (from `--downstream`)
	PushMetaData      bool
	SingleTask        *pipeline.Asset   // Single asset (from running asset file directly)
	SelectedAssets    []*pipeline.Asset // Multiple assets specified as positional arguments
	ExcludeTag        string
	// contains filtered or unexported fields
}

type FilterMutator func(ctx context.Context, f *Filter, s *scheduler.Scheduler, p *pipeline.Pipeline) error

type JSONColumnDiff struct {
	Name        string       `json:"name"`
	Type        JSONPropDiff `json:"type"`
	Nullable    JSONPropDiff `json:"nullable"`
	Constraints JSONPropDiff `json:"constraints"`
	Status      string       `json:"status"` // "added", "removed", "modified", "unchanged"
}

type JSONColumnStats struct {
	ColumnName string          `json:"columnName"`
	DataType   string          `json:"dataType"`
	Statistics []JSONStatistic `json:"statistics"`
}

type JSONCountDiff struct {
	Source int64 `json:"source"`
	Target int64 `json:"target"`
	Diff   int64 `json:"diff"`
}

type JSONDiffOutput struct {
	Summary          JSONSummary       `json:"summary"`
	SchemaDiffs      []JSONColumnDiff  `json:"schemaDiffs"`
	ColumnStatistics []JSONColumnStats `json:"columnStatistics"`
	SourceTable      string            `json:"sourceTable"`
	TargetTable      string            `json:"targetTable"`
	HasDifferences   bool              `json:"hasDifferences"`
	AlterStatements  string            `json:"alterStatements"`
}

type JSONPropDiff struct {
	Source      string `json:"source"`
	Target      string `json:"target"`
	IsDifferent bool   `json:"isDifferent"`
}

type JSONStatistic struct {
	Name        string `json:"name"`
	Source      string `json:"source"`
	Target      string `json:"target"`
	Diff        string `json:"diff"`
	DiffPercent string `json:"diffPercent,omitempty"`
}

type JSONSummary struct {
	RowCount    JSONCountDiff `json:"rowCount"`
	ColumnCount JSONCountDiff `json:"columnCount"`
}

type Limiter interface {
	Limit(query string, limit int64) string
}

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

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

type LockDependenciesResult struct {
	RequirementsPath string
	PythonVersion    string
	InputPath        string
	DependencyType   python.DependencyType
	ProjectRoot      string
}

type ModifierInfo struct {
	StartDate      time.Time
	EndDate        time.Time
	ApplyModifiers bool
}

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

type PipelineInfo struct {
	Pipeline           *pipeline.Pipeline
	RunningForAnAsset  bool
	RunDownstreamTasks bool
}

type QueryLog struct {
	Query       string          `json:"query"`
	Timestamp   time.Time       `json:"timestamp"`
	Connection  string          `json:"connection"`
	Success     bool            `json:"success"`
	Columns     []string        `json:"columns,omitempty"`
	Rows        [][]interface{} `json:"rows,omitempty"`
	Error       string          `json:"error,omitempty"`
	Asset       string          `json:"asset,omitempty"`
	Environment string          `json:"environment,omitempty"`
	Limit       int64           `json:"limit,omitempty"`
	Timeout     int             `json:"timeout,omitempty"`
}

type QueryLogOptions struct {
	Asset       string
	Environment string
	Limit       int64
	Timeout     int
}

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

type ScheduledQuery struct {
	Name        string
	DisplayName string
	Query       string
	Schedule    string
	Dataset     string
	Config      *datatransferpb.TransferConfig
}

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

type SuccessResponse struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}

type SummaryStats struct {
	TotalSchemas int `json:"total_schemas"`
	TotalTables  int `json:"total_tables"`
}

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

type TableComparer interface {
	CompareTables(ctx context.Context, table1, table2 string) (*diff.SchemaComparisonResult, error)
}

type TableSummary struct {
	TableName    string                   `json:"table_name"`
	Connection   string                   `json:"connection"`
	RowCount     int64                    `json:"row_count"`
	Columns      []ColumnSummary          `json:"columns"`
	SampleValues map[string][]interface{} `json:"sample_values,omitempty"`
	Error        string                   `json:"error,omitempty"`
}

type TableauDashboard struct {
	ViewID       string
	ViewName     string
	WorkbookID   string
	WorkbookName string
	WorkbookURL  string // Added for workbook URL in meta
	ProjectID    string // Added for project hierarchy
	ProjectName  string
	ProjectPath  []string // Added for full project hierarchy path
	OwnerName    string
	ContentURL   string
	ViewURL      string
	UpdatedAt    string
	Tags         []string
	DataSources  []tableau.DataSourceInfo     // Added for data source dependencies
	Connections  []tableau.WorkbookConnection // Added for connection tracking
}

type TaskTypeStats struct {
	Total             int
	Succeeded         int
	Failed            int // Failed in main execution
	FailedDueToChecks int // Failed only due to checks (main execution succeeded)
	Skipped           int
}

type VersionInfo struct {
	Version string `json:"version"`
	Commit  string `json:"commit"`
	Latest  string `json:"latest"`
}

type WarningResponse struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}