Function DeduplicateProtos

pkg/redis/redis.go:727–749

DeduplicateProtos deduplicates protos using key k. It stores a lock at LockKey(k) and the list of collected protos at ListKey(k). If the number of protos exceeds limit, the messages are trimmed from the start of the list.

(
	ctx context.Context, r redis.Scripter, k string, window time.Duration, limit int, msgs ...proto.Message,
)

// and the list of collected protos at ListKey(k).
// If the number of protos exceeds limit, the messages are trimmed from the start of the list.
func DeduplicateProtos(
	ctx context.Context, r redis.Scripter, k string, window time.Duration, limit int, msgs ...proto.Message,
) (bool, error) {
	args := make([]any, 0, 2+len(msgs))
	args = append(args, milliseconds(window))
	args = append(args, limit)
	if n := len(msgs) - limit; n > 0 {
		msgs = msgs[n:]
	}

	for _, msg := range msgs {
		s, err := MarshalProto(msg)
		if err != nil {
			return false, err
		}
		args = append(args, s)
	}
	res, err := deduplicateProtosScript.Run(ctx, r, []string{LockKey(k), ListKey(k)}, args...).Int64()
	if err != nil {
		return false, ConvertError(err)
	}
	return res == 1, nil
}

// NOTE: Time stops in lua scripts and expired keys stay available.