taskprogress

type TaskProgress struct {

	// FactId is the per-row event id (sequence number assigned by the
	// producer). It is the leeway-fact identifier, distinct from
	// TaskId (which names the *subject* of the fact).
	FactId uint64 `lw:",id"`

	// NaturalKey is the entity natural key; the facts SetId is 2-arg.
	// These bus DTOs carry no separate key, so it stays the nil default.
	NaturalKey []byte `lw:",naturalKey"`

	// At is the event timestamp. time.Time matches the facts
	// SetTimestamp signature directly (strict 1:1); the leeway wire
	// truncates to u32 seconds, while the bus preserves full nanos.
	At time.Time `lw:",ts"`

	// TaskId is the per-task identifier (a nanoid by default; see
	// task.TaskIdT). Carried as a string-section column so future
	// task.* DTOs can share the membership and join on this column.
	TaskId string `lw:"taskId,stringArray"`

	// Current is the work-units-completed counter at the At timestamp.
	Current uint64 `lw:"progressCurrent,u64Array"`

	// Total is the work-units denominator. Zero marks an
	// indeterminate task (count visible, end unknown).
	Total uint64 `lw:"progressTotal,u64Array"`

	// Unit is the canonical magnitude name ("items", "bytes",
	// "steps", or "unspecified") matching task.UnitE.String().
	// Encoded as a leeway symbol so the on-disk column is a
	// LowCardinality(String) dictionary.
	Unit string `lw:"progressUnit,symbol"`

	// ThroughputPerSec is the producer-side derived rate (Current per
	// second) over the estimator's sliding window. Zero means
	// not-yet-computed (early-frame reports).
	ThroughputPerSec float64 `lw:"progressThroughputPerSec,f64Array"`

	// EtaMs is the producer-side derived ETA-to-completion in
	// milliseconds. Zero means not-yet-computed; meaningless when
	// Total is zero.
	EtaMs int64 `lw:"progressEtaMs,i64Array"`

	// Note is a short free-text annotation appended to the humanized
	// rendering. Empty string means no annotation.
	Note string `lw:"note,textArray"`
	// contains filtered or unexported fields
}

type TaskProgressCodec struct{}

type TaskProgressColumns struct {
	FactId     []uint64
	NaturalKey [][]byte
	At         []time.Time

	TaskId           []string
	Current          []uint64
	Total            []uint64
	Unit             []string
	ThroughputPerSec []float64
	EtaMs            []int64
	Note             []string
}

type TaskProgressEntityI[
	StringArrayAttr TaskProgressStringArrayAttrI,
	StringArraySec TaskProgressStringArraySecI[StringArrayAttr, Ent],
	U64ArrayAttr TaskProgressU64ArrayAttrI,
	U64ArraySec TaskProgressU64ArraySecI[U64ArrayAttr, Ent],
	SymbolAttr TaskProgressSymbolAttrI,
	SymbolSec TaskProgressSymbolSecI[SymbolAttr, Ent],
	F64ArrayAttr TaskProgressF64ArrayAttrI,
	F64ArraySec TaskProgressF64ArraySecI[F64ArrayAttr, Ent],
	I64ArrayAttr TaskProgressI64ArrayAttrI,
	I64ArraySec TaskProgressI64ArraySecI[I64ArrayAttr, Ent],
	TextArrayAttr TaskProgressTextArrayAttrI,
	TextArraySec TaskProgressTextArraySecI[TextArrayAttr, Ent],
	Ent any,
] interface {
	BeginEntity() Ent
	SetId(id uint64, naturalKey []byte) Ent
	SetTimestamp(ts time.Time) Ent
	GetSectionStringArray() StringArraySec
	GetSectionU64Array() U64ArraySec
	GetSectionSymbol() SymbolSec
	GetSectionF64Array() F64ArraySec
	GetSectionI64Array() I64ArraySec
	GetSectionTextArray() TextArraySec
	CommitEntity() (err error)
}

type TaskProgressF64ArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

type TaskProgressF64ArrayAttrsReadI interface {
	GetAttrValueSingleOrDefault(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) float64
	GetNumberOfAttributes(entityIdx raruntime.EntityIdx) int64
}

type TaskProgressF64ArrayMembsReadI interface {
	GetMembValueLowCardRef(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) iter.Seq[uint64]
}

type TaskProgressF64ArraySecI[Attr any, Ent any] interface {
	BeginAttributeSingle(value float64) Attr
	EndSection() Ent
}

type TaskProgressI64ArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

type TaskProgressI64ArrayAttrsReadI interface {
	GetAttrValueSingleOrDefault(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) int64
	GetNumberOfAttributes(entityIdx raruntime.EntityIdx) int64
}

type TaskProgressI64ArrayMembsReadI interface {
	GetMembValueLowCardRef(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) iter.Seq[uint64]
}

type TaskProgressI64ArraySecI[Attr any, Ent any] interface {
	BeginAttributeSingle(value int64) Attr
	EndSection() Ent
}

type TaskProgressStringArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

type TaskProgressStringArrayAttrsReadI interface {
	GetAttrValueSingleOrDefault(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) string
	GetNumberOfAttributes(entityIdx raruntime.EntityIdx) int64
}

type TaskProgressStringArrayMembsReadI interface {
	GetMembValueLowCardRef(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) iter.Seq[uint64]
}

type TaskProgressStringArraySecI[Attr any, Ent any] interface {
	BeginAttributeSingle(value string) Attr
	EndSection() Ent
}

type TaskProgressSymbolAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

type TaskProgressSymbolAttrsReadI interface {
	GetAttrValueValue(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) string
	GetNumberOfAttributes(entityIdx raruntime.EntityIdx) int64
}

type TaskProgressSymbolMembsReadI interface {
	GetMembValueLowCardRef(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) iter.Seq[uint64]
}

type TaskProgressSymbolSecI[Attr any, Ent any] interface {
	BeginAttribute(value string) Attr
	EndSection() Ent
}

type TaskProgressTextArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

type TaskProgressTextArrayAttrsReadI interface {
	GetAttrValueSingleOrDefault(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) string
	GetNumberOfAttributes(entityIdx raruntime.EntityIdx) int64
}

type TaskProgressTextArrayMembsReadI interface {
	GetMembValueLowCardRef(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) iter.Seq[uint64]
}

type TaskProgressTextArraySecI[Attr any, Ent any] interface {
	BeginAttributeSingle(value string) Attr
	EndSection() Ent
}

type TaskProgressU64ArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

type TaskProgressU64ArrayAttrsReadI interface {
	GetAttrValueSingleOrDefault(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) uint64
	GetNumberOfAttributes(entityIdx raruntime.EntityIdx) int64
}

type TaskProgressU64ArrayMembsReadI interface {
	GetMembValueLowCardRef(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) iter.Seq[uint64]
}

type TaskProgressU64ArraySecI[Attr any, Ent any] interface {
	BeginAttributeSingle(value uint64) Attr
	EndSection() Ent
}