View Source AshGraphql.Subscription.Batcher (ash_graphql v1.4.0)

If started as a GenServer, this module will batch notifications and send them in bulk. Otherwise, it will send them immediately.

Summary

Functions

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

handle_continue(arg, state)

View Source

Callback implementation for GenServer.handle_continue/2.

Config options

async_limit (default 100): if there are more than async_limit notifications, we will start to backpressure

send_immediately_threshold (default 50): if there are less then send_immediately_threshold notifications, we will send them immediately

subscription_batch_interval (default 1000): the interval in milliseconds the batcher waits for new notifications before sending them

Link to this function

publish(topic, notification, pubsub, key_strategy, doc)

View Source