Module Import alias Import alias Import alias ImportFrom alias ImportFrom alias alias ImportFrom alias alias ImportFrom alias alias ImportFrom alias alias alias alias Assign NameStore Call AttributeLoad NameLoad attr Str ClassDef bases NameLoad body Expr Str ClassDef bases NameLoad body Assign NameStore Str Assign NameStore Dict Str Str NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore SubscriptLoad NameLoad Index AttributeLoad NameLoad attr Assign NameStore SubscriptLoad NameLoad Index AttributeLoad NameLoad attr Assign NameStore BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr BinOpMod Str TupleLoad NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Call NameLoad keyword NameLoad keyword NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body If CompareIs AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr Num Expr Call AttributeLoad NameLoad attr Call NameLoad keyword Call NameLoad orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Raise Call NameLoad Str decorator_list FunctionDef arguments args NameParam NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign TupleStore NameStore AttributeStore NameLoad attr TupleLoad AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Return Assign NameStore AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str While NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr Assign TupleStore NameStore NameStore TupleLoad BinOpSub NameLoad NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad Call AttributeLoad NameLoad attr attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Str Return handlers ExceptHandler type NameLoad body Return ExceptHandler body Expr Call AttributeLoad NameLoad attr AugAssignPow NameStore AttributeLoad NameLoad attr Assign NameStore Call NameLoad NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr Return Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr keyword NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body If AttributeLoad NameLoad attr body Return AttributeLoad NameLoad attr orelse If UnaryOpNot AttributeLoad NameLoad attr body Return AttributeLoad NameLoad attr orelse Return AttributeLoad AttributeLoad NameLoad attr attr decorator_list NameLoad decorator_list Assign AttributeStore NameLoad attr Call NameLoad NameLoad keyword Num keyword Num keyword Num
N/A N/A logging N/A time N/A gevent gevent GreenletExit constants ChannelState SinkProperties message FailedFastError MethodReturnMessage sink ClientMessageSink SinkProvider varz AggregateTimer Counter Source VarzBase N/A ROOT_LOG N/A N/A logging getLogger scales.Resurrector ResurrectorSink N/A ClientMessageSink N/A N/A The resurrector sink monitors its underlying sink for faults, and begins
   attempting to resurrect it.

   Additionally, it will fail any incoming requests immediately while the
   underlying sink is failed.
    Varz N/A VarzBase N/A N/A _VARZ_BASE_NAME scales.Resurrector N/A _VARZ N/A time_failed reconnect_attempts AggregateTimer Counter N/A __init__ N/A N/A self next_factory sink_properties global_properties N/A N/A N/A endpoint N/A global_properties N/A N/A SinkProperties Endpoint N/A service N/A global_properties N/A N/A SinkProperties Label N/A endpoint_source N/A %s:%d N/A N/A endpoint host N/A endpoint port N/A N/A self endpoint endpoint_source N/A N/A self _log N/A N/A ROOT_LOG getChild N/A [%s.%s] N/A service endpoint_source N/A N/A self _properties global_properties N/A N/A self _next_factory next_factory N/A N/A self _resurrector None N/A N/A self _down_on None N/A N/A self _initial_wait_interval N/A sink_properties initial_wait_interval N/A N/A self _max_wait_interval N/A sink_properties max_wait_interval N/A N/A self _backoff_exponent N/A sink_properties backoff_exponent N/A N/A self _varz N/A N/A self Varz N/A Source service service endpoint endpoint_source N/A N/A N/A N/A super ResurrectorSink self __init__ N/A AsyncProcessRequest N/A N/A self sink_stack msg stream headers N/A N/A N/A N/A N/A self next_sink None N/A N/A N/A N/A gevent sleep 0 N/A N/A N/A sink_stack AsyncProcessResponseMessage N/A MethodReturnMessage error N/A FailedFastError N/A N/A N/A N/A N/A self next_sink AsyncProcessRequest sink_stack msg stream headers N/A AsyncProcessResponse N/A N/A self sink_stack context stream msg N/A N/A N/A N/A NotImplementedError This should never be called N/A _OnSinkFaulted N/A N/A self val N/A N/A N/A N/A N/A self _down_on N/A N/A N/A self _down_on N/A N/A time time N/A N/A sink N/A self next_sink N/A N/A self next_sink None N/A N/A N/A sink Close N/A N/A N/A N/A sink on_faulted Unsubscribe N/A self _OnSinkFaulted N/A N/A self _resurrector N/A N/A gevent spawn N/A self _TryResurrect N/A N/A N/A N/A self on_faulted Set val N/A _TryResurrect N/A N/A self N/A N/A N/A N/A N/A self _down_on N/A N/A N/A last_attempt N/A self _down_on N/A wait_interval N/A self _initial_wait_interval N/A N/A N/A N/A self _log info Attempting to reopen faulted channel N/A True N/A N/A N/A N/A gevent sleep wait_interval N/A now N/A N/A time time N/A N/A down_time last_attempt N/A N/A now last_attempt now N/A N/A N/A N/A self _varz time_failed down_time N/A sink N/A N/A N/A self _next_factory CreateSink N/A self _properties N/A N/A N/A N/A N/A N/A self _varz reconnect_attempts N/A N/A N/A N/A N/A sink Open get N/A N/A N/A N/A sink on_faulted Subscribe N/A self _OnSinkFaulted N/A N/A self next_sink sink N/A N/A self _down_on None N/A N/A N/A N/A self _log info Reopened channel. N/A N/A N/A N/A GreenletExit N/A N/A N/A N/A N/A N/A N/A sink Close N/A wait_interval N/A self _backoff_exponent N/A wait_interval N/A min wait_interval N/A self _max_wait_interval N/A Open N/A N/A self N/A N/A N/A N/A N/A self next_sink N/A N/A N/A self next_sink N/A N/A N/A self _next_factory CreateSink N/A self _properties N/A N/A N/A N/A N/A self next_sink on_faulted Subscribe N/A self _OnSinkFaulted N/A N/A N/A N/A self next_sink Open N/A Close N/A N/A self N/A N/A N/A N/A self _resurrector N/A N/A N/A N/A N/A self _resurrector kill block False N/A N/A self _resurrector None N/A N/A self _down_on None N/A N/A self next_sink N/A N/A N/A N/A N/A N/A self next_sink on_faulted Unsubscribe N/A self _OnSinkFaulted N/A N/A N/A N/A self next_sink Close N/A state N/A N/A self N/A N/A N/A N/A self _down_on N/A N/A N/A ChannelState Closed N/A N/A N/A N/A self next_sink N/A N/A N/A ChannelState Idle N/A N/A N/A N/A self next_sink state N/A property N/A N/A N/A ResurrectorSink Builder N/A SinkProvider ResurrectorSink initial_wait_interval 5 max_wait_interval 60 backoff_exponent 1.2