taskdone

type TaskDone struct {

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

	// Result is the application-defined success payload. Opaque to
	// the codec; observers decode by TaskCreated.Kind. Empty (nil or
	// len=0) when the task signals success without a payload.
	Result []byte `lw:"taskResult,blobArray"`
	// contains filtered or unexported fields
}

type TaskDoneBlobArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

type TaskDoneBlobArrayAttrsReadI interface {
	GetAttrValueSingleOrDefault(entityIdx raruntime.EntityIdx, attrIdx raruntime.AttributeIdx) []byte
	GetNumberOfAttributes(entityIdx raruntime.EntityIdx) int64
}

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

type TaskDoneBlobArraySecI[Attr any, Ent any] interface {
	BeginAttributeSingle(value []byte) Attr
	EndSection() Ent
}

type TaskDoneCodec struct{}

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

	TaskId []string
	Result [][]byte
}

type TaskDoneEntityI[
	StringArrayAttr TaskDoneStringArrayAttrI,
	StringArraySec TaskDoneStringArraySecI[StringArrayAttr, Ent],
	BlobArrayAttr TaskDoneBlobArrayAttrI,
	BlobArraySec TaskDoneBlobArraySecI[BlobArrayAttr, Ent],
	Ent any,
] interface {
	BeginEntity() Ent
	SetId(id uint64, naturalKey []byte) Ent
	SetTimestamp(ts time.Time) Ent
	GetSectionStringArray() StringArraySec
	GetSectionBlobArray() BlobArraySec
	CommitEntity() (err error)
}

type TaskDoneStringArrayAttrI interface {
	dmlruntime.InAttributeMembershipLowCardRefPI
	EndAttributeP()
}

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

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

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