View Source PipelineRunServer.Worker (Datapio OpenCore v0.1.0)

Consume PipelineRunRequest from queues.

Link to this section Summary

child_spec(opts)

Return a specification to run the consumer under a supervisor

shutdown(id)

Shutdown the consumer

start_link(options)

Start a consumer linked to the current process

child_spec(Datapio.MQ.Consumer.consumer_options()) :: Supervisor.child_spec()

Return a specification to run the consumer under a supervisor

shutdown(Datapio.MQ.Consumer.consumer_id()) :: :ok

Shutdown the consumer

start_link(Datapio.MQ.Consumer.consumer_options()) :: GenServer.on_start()

Start a consumer linked to the current process