Method QueueInflightCommit

queue.go:339–344

QueueInflightCommit schedules an automatic commit for an inflight transaction at the specified date. Parameters: - ctx context.Context: The context for the operation. - transaction *model.Transaction: The transaction to be committed automatically. Returns: - error: An error if the task could not b

(ctx context.Context, transaction *model.Transaction)

// Returns:
// - error: An error if the task could not be enqueued.
func (q *Queue) QueueInflightCommit(ctx context.Context, transaction *model.Transaction) error {
	if !transaction.InflightCommitDate.IsZero() {
		return q.queueInflightCommit(transaction.TransactionID, transaction.InflightCommitDate)
	}
	return nil
}