phSSKJrJr SSKJr SSKJr SSKrSr"SS\5r "SS \5r "S S \ 5r "S S \R5r "SS\ 5rg))ABCabstractmethod)Enum)CallableN<c \rSrSrSrSrSrSrg)State closedopenz half-openN)__name__ __module__ __qualname____firstlineno__CLOSEDOPEN HALF_OPEN__static_attributes__r O/home/james-whalen/.local/lib/python3.13/site-packages/redis/multidb/circuit.pyr r s F DIrr c4\rSrSr\\S\4Sj55r\R\S\4Sj55r\\S\ 4Sj55r \ R\S\ 4Sj55r \\S 55r \ R\S 55r \S \ S\ \ /S 44S j5r Srg )CircuitBreakerreturncg)z@The grace period in seconds when the circle should be kept open.Nr selfs r grace_periodCircuitBreaker.grace_period rrcg)z Set the grace period in seconds.Nr rrs rrr srcg)z!The current state of the circuit.Nr rs rstateCircuitBreaker.stater!rr%cg)z!Set current state of the circuit.Nr rr%s rr%r&"r!rcg)z&Database associated with this circuit.Nr rs rdatabaseCircuitBreaker.database(r!rcg)z*Set database associated with this circuit.Nr rr*s rr*r+.r!rcbNcgz6Callback called when the state of the circuit changes.Nr rr.s ron_state_changedCircuitBreaker.on_state_changed4 rr )rrrrpropertyrfloatrsetterr r%r*rr2rr rrrrs  e  /// u   \\ 5    __   8-=ue,Ld,R#S  rrc\rSrSrSrS\R 4Sjr\S\ 4Sj5r \ RS\ 4Sj5r \S\ 4S j5r \ RS \ 4S j5r \S 5r\RS 5r\S\S\ \ /S44Sj5rSrg)BaseCircuitBreaker:z3 Base implementation of Circuit Breaker interface. r.cXl[RURR[RURR [R URR0UlSUl gN) _cbr rcloserr r half_open_state_pb_mapper _databaser1s r__init__BaseCircuitBreaker.__init__?sO LL$((.. JJ OOTXX//!  rrc.URR$r<r= reset_timeoutrs rrBaseCircuitBreaker.grace_periodHsxx%%%rrc$XRlgr<rEr#s rrrGLs !-rcP[URRRS9$N)value)r r=r%namers rr%BaseCircuitBreaker.statePs488>>..//rr%c,URU"5 gr<)r@r(s rr%rMTs e$&rcUR$r<rArs rr*BaseCircuitBreaker.databaseXs ~~rcXlgr<rPr-s rr*rQ\s!rrNcgr0r r1s rr2#BaseCircuitBreaker.on_state_changed`r4r)r=rAr@)rrrr__doc__ pybreakerrrBr5r6rr7r r%r*rrr2rr rrr9r9:s933&e&&...0u00 \\'5''__"" 8-=ue,Ld,R#S  rr9c<\rSrSrSrS\\\\/S44SjrSr Sr g) PBListenerfzDWrapper for callback to be compatible with pybreaker implementation.r.NcXlX lg)z Initialize a PBListener instance. Args: cb: Callback function that will be called when the circuit breaker state changes. database: Database instance associated with this circuit breaker. Nr=rA)rr.r*s rrBPBListener.__init__is!rc[U5nURUl[URS9n[URS9nUR XU5 grJ)PBCircuitBreakerAdapterrAr*r rLr=)rr. old_state new_states r state_changePBListener.state_changeysA $R (nn  /  /   *rr[) rrrrrUrrr rBrarr rrrXrXfs(N" neU3T9 :" +rrXcb^\rSrSrS\R 4U4SjjrS\S\\/S44Sjr Sr U=r $)r^r.c$>[TU]U5 g)z Initialize a PBCircuitBreakerAdapter instance. This adapter wraps pybreaker's CircuitBreaker implementation to make it compatible with our CircuitBreaker interface. Args: cb: A pybreaker CircuitBreaker instance to be adapted. N)superrB)rr. __class__s rrB PBCircuitBreakerAdapter.__init__s rrNcd[XR5nURRU5 gr<)rXr*r= add_listener)rr.listeners rr2(PBCircuitBreakerAdapter.on_state_changeds"b--0 h'rr ) rrrrrVrrBrr r2r __classcell__)rgs@rr^r^s8 933 (8-=ue,Ld,R#S((rr^)abcrrenumrtypingrrVDEFAULT_GRACE_PERIODr rr9CircuitBreakerListenerrXr^r rrrss\#D ' S' T) ) X+11+6(0(r