Pulsar.Reader.Callback (Pulsar v2.11.0)

Internal callback module for Pulsar.Reader.

This module handles messages from the consumer and forwards them to the reader's stream process. It implements the Pulsar.Consumer.Callback behaviour.

Summary

Functions

became_active(state)

Callback implementation for Pulsar.Consumer.Callback.became_active/1.

became_passive(state)

Callback implementation for Pulsar.Consumer.Callback.became_passive/1.

handle_call(request, from, state)

Callback implementation for Pulsar.Consumer.Callback.handle_call/3.

handle_cast(request, state)

Callback implementation for Pulsar.Consumer.Callback.handle_cast/2.

handle_info(message, state)

Callback implementation for Pulsar.Consumer.Callback.handle_info/2.

terminate(reason, state)

Callback implementation for Pulsar.Consumer.Callback.terminate/2.

Functions

became_active(state)

Callback implementation for Pulsar.Consumer.Callback.became_active/1.

became_passive(state)

Callback implementation for Pulsar.Consumer.Callback.became_passive/1.

handle_call(request, from, state)

Callback implementation for Pulsar.Consumer.Callback.handle_call/3.

handle_cast(request, state)

Callback implementation for Pulsar.Consumer.Callback.handle_cast/2.

handle_info(message, state)

Callback implementation for Pulsar.Consumer.Callback.handle_info/2.

terminate(reason, state)

Callback implementation for Pulsar.Consumer.Callback.terminate/2.