Method Add

pkg/execution/concurrency/concurrency.go:26–26

Add inserts a new item into the concurrency service. This will count towards concurrency limits until the specified timeout or until the key is removed via a call to Done(). Add must return an ErrAtConcurrencyLimit if there is no capacity for the given function ID/key.

(ctx context.Context, functionID uuid.UUID, qi queue.Item)

	// Add must return an ErrAtConcurrencyLimit if there is no capacity for the given
	// function ID/key.
	Add(ctx context.Context, functionID uuid.UUID, qi queue.Item) error

	// Done removes the given key from concurrency limits for a function.
	//