ExAirtable.RateLimiter (ExAirtable v0.2.9) View Source

The RateLimiter ensures that no requests go to Airtable fast enough to trigger API rate-limiting.

Requests will be handled immediately until more than 5 happen, at which point they go onto a queue which flushes every second. This ensures that no more than 5 requests per second will ever be sent to Airtable.

There is one ExAirtable.RateLimiter.BaseQueue per base to track requests, since Airtable does rate-limiting per-base.

Link to this section Summary

Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

request(table_module, request)

Add a request to the request buffer for a given table.

start_link(table_modules)

Pass a list of valid module names where the given modules have implemented the ExAirtable.Table behaviour.

Link to this section Functions

child_spec(init_arg)

Returns a specification to start this module under a supervisor.

See Supervisor.

request(table_module, request)

Add a request to the request buffer for a given table.

Note that the request buffer is a MapSet - meaning that (exact) duplicate requests will be ignored.

start_link(table_modules)

Pass a list of valid module names where the given modules have implemented the ExAirtable.Table behaviour.

Internal state is a map of %BaseQueue{} structs where the key is the base ID.