Method ExpireDecisions

pkg/database/decisions.go:328–346

ExpireDecisions sets the expiration of a list of decisions to now(), in multiple operations if len(decisions) > decisionDeleteBulkSize. It returns the number of impacted decisions for the CAPI/PAPI, even in case of error.

(ctx context.Context, decisions []*ent.Decision)

// in multiple operations if len(decisions) > decisionDeleteBulkSize.
// It returns the number of impacted decisions for the CAPI/PAPI, even in case of error.
func (c *Client) ExpireDecisions(ctx context.Context, decisions []*ent.Decision) (int, error) {
	if len(decisions) == 0 {
		return 0, nil
	}

	now := time.Now().UTC()

	total := 0
	err := slicetools.Batch(ctx, decisions, decisionDeleteBulkSize, func(ctx context.Context, batch []*ent.Decision) error {
		rows, err := c.expireDecisionBatch(ctx, batch, now)
		if err != nil {
			return err
		}
		total += rows
		return nil
	})

	return total, err
}

// deleteDecisionBatch removes the decisions as a single operation.
func (c *Client) deleteDecisionBatch(ctx context.Context, batch []*ent.Decision) (int, error) {