taskerror

type TaskError struct {

	// FactId is the per-row event id; distinct from TaskId (the
	// subject of the failure).
	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 names the task that failed.
	TaskId string `lw:"taskId,stringArray"`

	// Reason is a short human-readable rationale (often the
	// underlying error's .Error() short form). Empty when the
	// producer didn't supply one.
	Reason string `lw:"reason,textArray"`

	// ErrorText is the FormatErrorWithStackS rendering of the
	// captured error chain. Empty when the producer surfaced a
	// reason-only failure with no Go error attached.
	ErrorText string `lw:"errorText,textArray"`
	// contains filtered or unexported fields
}

type TaskErrorCodec struct{}

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

	TaskId    []string
	Reason    []string
	ErrorText []string
}

type TaskErrorEntityI[
	StringArrayAttr TaskErrorStringArrayAttrI,
	StringArraySec TaskErrorStringArraySecI[StringArrayAttr, Ent],
	TextArrayAttr TaskErrorTextArrayAttrI,
	TextArraySec TaskErrorTextArraySecI[TextArrayAttr, Ent],
	Ent any,
] interface {
	BeginEntity() Ent
	SetId(id uint64, naturalKey []byte) Ent
	SetTimestamp(ts time.Time) Ent
	GetSectionStringArray() StringArraySec
	GetSectionTextArray() TextArraySec
	CommitEntity() (err error)
}

type TaskErrorStringArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

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

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

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

type TaskErrorTextArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

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

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

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