telemetry

type Event struct {
	Version   string    `json:"v"`
	Timestamp time.Time `json:"ts"`

	RunID string `json:"run_id,omitempty"`

	Type    EventType `json:"type"`
	Payload Payload   `json:"payload"`
}

type EventScope string

type EventType string

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

type LogPayload struct {
	OpID   string `json:"op_id"`
	Data   string `json:"data"`
	Stream int    `json:"stream"`
}

type OpPayload struct {
	OpID     string        `json:"op_id"`
	OpName   string        `json:"op_name"`
	Pipeline pipeline.Path `json:"pipeline"`
	Internal bool          `json:"internal"`
	Inputs   []string      `json:"inputs"`

	Started   *time.Time `json:"started"`
	Completed *time.Time `json:"completed"`
	Cached    bool       `json:"cached"`
	Error     string     `json:"error"`
}

type Payload interface {
	Type() EventType
	Scope() EventScope
}

type PipelinedVertex struct {
	*progrock.Vertex

	// Groups stores the group IDs that this vertex is a member of. Each entry
	// has a corresponding entry in Pipelines.
	Groups []string

	// Pipelines stores the pipeline paths computed from Progrock groups.
	Pipelines []pipeline.Path
}

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

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