lineage

type BaseFacet struct {
	Producer  string `json:"_producer"`
	SchemaURL string `json:"_schemaURL"`
}

type CaesiumDAGFacet struct {
	BaseFacet
	TotalTasks    int    `json:"totalTasks"`
	TriggerType   string `json:"triggerType,omitempty"`
	TriggerAlias  string `json:"triggerAlias,omitempty"`
	FailurePolicy string `json:"failurePolicy,omitempty"`
	ExecutionMode string `json:"executionMode,omitempty"`
}

type CaesiumDatasetFacet struct {
	BaseFacet
	// StepName is the task/step name that produced or consumed this dataset.
	StepName string `json:"stepName,omitempty"`
	// Direction is "input" or "output" from the step's perspective.
	Direction string `json:"direction"`
	// OutputKeys lists the structured-output keys (from ##caesium::output) whose
	// values contributed to this dataset's identity.  Empty when the dataset
	// was derived from a declared schema rather than structured output.
	OutputKeys []string `json:"outputKeys,omitempty"`
}

type CaesiumExecutionFacet struct {
	BaseFacet
	Engine    string   `json:"engine"`
	Image     string   `json:"image"`
	Command   []string `json:"command,omitempty"`
	RuntimeID string   `json:"runtimeId,omitempty"`
	ClaimedBy string   `json:"claimedBy,omitempty"`
}

type CaesiumProvenanceFacet struct {
	BaseFacet
	SourceID string `json:"sourceId,omitempty"`
	Repo     string `json:"repo,omitempty"`
	Ref      string `json:"ref,omitempty"`
	Commit   string `json:"commit,omitempty"`
	Path     string `json:"path,omitempty"`
}

type CaesiumSchemaFacet struct {
	BaseFacet
	// Schema is the raw JSON Schema object (map form) as declared in the job
	// manifest's outputSchema / inputSchema field for this step.
	Schema map[string]any `json:"schema,omitempty"`
}

type Config struct {
	Enabled       bool
	Transport     string
	URL           string
	Namespace     string
	Headers       string
	FilePath      string
	Timeout       time.Duration
	RetryAttempts uint
}

type Dataset struct {
	Namespace string         `json:"namespace"`
	Name      string         `json:"name"`
	Facets    map[string]any `json:"facets,omitempty"`
}

type ErrorMessageFacet struct {
	BaseFacet
	Message             string `json:"message"`
	ProgrammingLanguage string `json:"programmingLanguage,omitempty"`
	StackTrace          string `json:"stackTrace,omitempty"`
}

type EventType string

type HTTPTransportConfig struct {
	URL     string
	Headers map[string]string
	Timeout time.Duration
}

type ImpactNode struct {
	// DatasetNamespace and DatasetName are the OpenLineage identity of the
	// downstream dataset.
	DatasetNamespace string `json:"dataset_namespace"`
	DatasetName      string `json:"dataset_name"`
	// Direction is always "output" for nodes returned by Impact — each node
	// is a dataset produced by a downstream step.
	Direction string `json:"direction"`

	// ProducingStep is the task name that emits this dataset, sourced from
	// FacetSummary.caesium_dataset.step_name when available.
	ProducingStep string `json:"producing_step,omitempty"`

	// JobID and JobAlias identify the job that contains the producing step.
	// Populated via a join from task_runs → job_runs → jobs.
	JobID    uuid.UUID `json:"job_id"`
	JobAlias string    `json:"job_alias"`

	// ProvenanceCommit and ProvenanceRepo carry git provenance from the job
	// at the time the dataset row was last written.
	ProvenanceCommit string `json:"provenance_commit,omitempty"`
	ProvenanceRepo   string `json:"provenance_repo,omitempty"`

	// LastSeen is the created_at timestamp of the lineage_dataset row — a
	// proxy for "when was this dependency last observed."
	LastSeen time.Time `json:"last_seen"`

	// Depth is the transitive hop count from the root dataset (0 = direct
	// consumer, 1 = consumer of a consumer, …).
	Depth int `json:"depth"`
}

type ImpactResult struct {
	// RootNamespace and RootName are the input dataset whose downstream
	// impact is being reported.
	RootNamespace string `json:"root_namespace"`
	RootName      string `json:"root_name"`

	// Downstream lists every transitively reachable output dataset, ordered
	// breadth-first (shallowest nodes first within each depth level).
	// When the same (namespace, name) is produced by multiple distinct
	// task runs / jobs, each (namespace+name+job_id) triple appears as a
	// separate node; BFS frontier expansion is keyed only on dataset identity
	// so the graph traversal still terminates.
	Downstream []ImpactNode `json:"downstream"`
}

type Job struct {
	Namespace string         `json:"namespace"`
	Name      string         `json:"name"`
	Facets    map[string]any `json:"facets,omitempty"`
}

type JobTypeFacet struct {
	BaseFacet
	ProcessingType string `json:"processingType"`
	Integration    string `json:"integration"`
	JobType        string `json:"jobType"`
}

type NominalTimeFacet struct {
	BaseFacet
	NominalStartTime string `json:"nominalStartTime"`
	NominalEndTime   string `json:"nominalEndTime,omitempty"`
}

type ParentJobRef struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
}

type ParentRunFacet struct {
	BaseFacet
	Run ParentRunRef `json:"run"`
	Job ParentJobRef `json:"job"`
}

type ParentRunRef struct {
	RunID uuid.UUID `json:"runId"`
}

type Run struct {
	RunID  uuid.UUID      `json:"runId"`
	Facets map[string]any `json:"facets,omitempty"`
}

type RunEvent struct {
	EventTime time.Time `json:"eventTime"`
	EventType EventType `json:"eventType"`
	Producer  string    `json:"producer"`
	SchemaURL string    `json:"schemaURL"`
	Run       Run       `json:"run"`
	Job       Job       `json:"job"`
	Inputs    []Dataset `json:"inputs"`
	Outputs   []Dataset `json:"outputs"`
}

type SourceCodeLocationFacet struct {
	BaseFacet
	Type    string `json:"type"`
	URL     string `json:"url"`
	RepoURL string `json:"repoUrl,omitempty"`
	Path    string `json:"path,omitempty"`
	Version string `json:"version,omitempty"`
	Tag     string `json:"tag,omitempty"`
	Branch  string `json:"branch,omitempty"`
}

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

type Transport interface {
	Emit(ctx context.Context, event RunEvent) error

	Close() error
}