Method MarkOutboxCompleted

database/lineage.go:352–362

MarkOutboxCompleted marks an outbox entry as completed.

(ctx context.Context, id int64)

// MarkOutboxCompleted marks an outbox entry as completed.
func (d Datasource) MarkOutboxCompleted(ctx context.Context, id int64) error {
	_, err := d.Conn.ExecContext(ctx, `
		UPDATE ledgerforge.lineage_outbox
		SET status = $1, processed_at = NOW(), locked_until = NULL
		WHERE id = $2
	`, model.OutboxStatusCompleted, id)
	if err != nil {
		return apierror.NewAPIError(apierror.ErrInternalServer, "Failed to mark outbox entry as completed", err)
	}
	return nil
}

// MarkOutboxFailed marks an outbox entry as failed and increments the attempt counter.
// If attempts exceed max_attempts, the status becomes 'failed', otherwise it returns to 'pending' for retry.