runs

type BatchAssetResult struct {
	Name     string      `json:"name"`
	Type     string      `json:"type"`
	Provider string      `json:"provider"`
	MRN      string      `json:"mrn"`
	Asset    interface{} `json:"asset"`
	Status   string      `json:"status"`
	Error    string      `json:"error,omitempty"`
}

type BatchCreateRequest struct {
	Assets        []CreateAssetRequest   `json:"assets" validate:"required,min=1"`
	Lineage       []CreateLineageRequest `json:"lineage"`
	Documentation []CreateDocRequest     `json:"documentation"`
	Config        plugin.RawPluginConfig `json:"config"`
	PipelineName  string                 `json:"pipeline_name" validate:"required"`
	SourceName    string                 `json:"source_name" validate:"required"`
	RunID         string                 `json:"run_id" validate:"required"`
}

type BatchCreateResponse struct {
	Assets               []BatchAssetResult    `json:"assets"`
	StaleEntitiesRemoved []string              `json:"stale_entities_removed,omitempty"`
	Lineage              []LineageResult       `json:"lineage,omitempty"`
	Documentation        []DocumentationResult `json:"documentation,omitempty"`
}

type CompleteRunRequest struct {
	RunID   string             `json:"run_id" validate:"required"`
	Status  plugin.RunStatus   `json:"status" validate:"required"`
	Summary *plugin.RunSummary `json:"summary"`
	Error   string             `json:"error,omitempty"`
}

type CreateAssetRequest struct {
	Name          string                 `json:"name"`
	Type          string                 `json:"type"`
	Providers     []string               `json:"providers"`
	Description   *string                `json:"description"`
	Metadata      map[string]interface{} `json:"metadata"`
	Schema        map[string]interface{} `json:"schema"`
	Tags          []string               `json:"tags"`
	Sources       []string               `json:"sources"`
	ExternalLinks []map[string]string    `json:"external_links"`
}

type CreateDocRequest struct {
	AssetMRN string `json:"asset_mrn"`
	Content  string `json:"content"`
	Type     string `json:"type"`
}

type CreateLineageRequest struct {
	Source string `json:"source"`
	Target string `json:"target"`
	Type   string `json:"type"`
}

type DestroyRunResponse struct {
	AssetsDeleted        int      `json:"assets_deleted"`
	LineageDeleted       int      `json:"lineage_deleted"`
	DocumentationDeleted int      `json:"documentation_deleted"`
	DeletedEntityMRNs    []string `json:"deleted_entity_mrns"`
}

type DocumentationResult struct {
	AssetMRN string `json:"asset_mrn"`
	Type     string `json:"type"`
	Status   string `json:"status"`
	Error    string `json:"error,omitempty"`
}

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

type LineageResult struct {
	Source string `json:"source"`
	Target string `json:"target"`
	Type   string `json:"type"`
	Status string `json:"status"`
	Error  string `json:"error,omitempty"`
}

type RunEntitiesResponse struct {
	Entities []*runs.RunEntity `json:"entities"`
	Total    int               `json:"total"`
	Limit    int               `json:"limit"`
	Offset   int               `json:"offset"`
}

type StartRunRequest struct {
	PipelineName string                 `json:"pipeline_name" validate:"required"`
	SourceName   string                 `json:"source_name" validate:"required"`
	Config       plugin.RawPluginConfig `json:"config"`
}