Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Fetching contributors…

Cannot retrieve contributors at this time

31 lines (24 sloc) 1.072 kb
%% State in eredis_sub_client
-record(state, {
host :: string() | undefined,
port :: integer() | undefined,
password :: binary() | undefined,
reconnect_sleep :: integer() | undefined | no_reconnect,
socket :: port() | undefined,
parser_state :: #pstate{} | undefined,
%% Channels we should subscribe to
channels = [] :: [channel()],
% The process we send pubsub and connection state messages to.
controlling_process :: undefined | {reference(), pid()},
% This is the queue of messages to send to the controlling
% process.
msg_queue :: queue(),
%% When the queue reaches this size, either drop all
%% messages or exit.
max_queue_size :: integer() | inifinity,
queue_behaviour :: drop | exit,
% The msg_state keeps track of whether we are waiting
% for the controlling process to acknowledge the last
% message.
msg_state = need_ack :: ready | need_ack
}).
Jump to Line
Something went wrong with that request. Please try again.