hddlmZmZddlmZddlmZddlZdZGddeZ Gdd eZ Gd d e Z Gd d ej Z Gdde ZdS))ABCabstractmethod)Enum)CallableN<ceZdZdZdZdZdS)Stateclosedopenz half-openN)__name__ __module__ __qualname__CLOSEDOPEN HALF_OPENU/var/www/html/auto_sub_bot/venv/lib/python3.11/site-packages/redis/multidb/circuit.pyr r s F DIIIrr cZeZdZeedefdZejedefdZeedefdZ e jedefdZ eedZ e jed Z ed e deegd ffd Z d S) CircuitBreakerreturncdS)z@The grace period in seconds when the circle should be kept open.Nrselfs r grace_periodzCircuitBreaker.grace_period  rrcdS)z Set the grace period in seconds.Nrrrs rrzCircuitBreaker.grace_periodsrcdS)z!The current state of the circuit.Nrrs rstatezCircuitBreaker.staterrr cdS)z!Set current state of the circuit.Nrrr s rr zCircuitBreaker.state"rrcdS)z&Database associated with this circuit.Nrrs rdatabasezCircuitBreaker.database(rrcdS)z*Set database associated with this circuit.Nrrr$s rr$zCircuitBreaker.database.rrcbNcdSz6Callback called when the state of the circuit changes.Nrrr's ron_state_changedzCircuitBreaker.on_state_changed4  r) r r rpropertyrfloatrsetterr r r$rr+rrrrrsa  e   ^X ////^/ u   ^X  \ 5   ^\   ^X _  ^_  8-=ue,Ld,R#S   ^   rrceZdZdZdejfdZedefdZ e j defdZ ede fdZ e j d e fd Z ed Z e j d Z eded e e gdffdZdS)BaseCircuitBreakerz; Base implementation of Circuit Breaker interface. r'c||_tj|jjtj|jjtj|jji|_d|_ dSN) _cbr rcloserr r half_open_state_pb_mapper _databaser*s r__init__zBaseCircuitBreaker.__init__?sB L$(. J OTX/!  rrc|jjSr3r4 reset_timeoutrs rrzBaseCircuitBreaker.grace_periodHs x%%rrc||j_dSr3r;rs rrzBaseCircuitBreaker.grace_periodLs!-rc@t|jjjSN)value)r r4r namers rr zBaseCircuitBreaker.statePs48>.////rr c0|j|dSr3)r7r"s rr zBaseCircuitBreaker.stateTs$e$&&&&&rc|jSr3r8rs rr$zBaseCircuitBreaker.databaseXs ~rc||_dSr3rDr&s rr$zBaseCircuitBreaker.database\s !rrNcdSr)rr*s rr+z#BaseCircuitBreaker.on_state_changed`r,r)r r r__doc__ pybreakerrr9r-r.rr/r r r$rrr+rrrr1r1:sO93&e&&&X&.....0u000X0 \'5'''\'X_""_" 8-=ue,Ld,R#S   ^   rr1c:eZdZdZdeeeegdffdZdZdS) PBListenerzDWrapper for callback to be compatible with pybreaker implementation.r'Nc"||_||_dS)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. N)r4r8)rr'r$s rr9zPBListener.__init__is!rct|}|j|_t|j}t|j}||||dSr?)PBCircuitBreakerAdapterr8r$r rAr4)rr' old_state new_states r state_changezPBListener.state_changeysX $R ( (n  ///  ///  Y *****r) r r rrGrrr r9rPrrrrJrJfsVNN" neU3T9 :"""" +++++rrJcPeZdZdejffd ZdedeegdffdZxZ S)rMr'cJt|dS)a 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)superr9)rr' __class__s rr9z PBCircuitBreakerAdapter.__init__s# rrNcdt||j}|j|dSr3)rJr$r4 add_listener)rr'listeners rr+z(PBCircuitBreakerAdapter.on_state_changeds/b$-00 h'''''r) r r rrHrr9rr r+ __classcell__)rTs@rrMrMst 93      (8-=ue,Ld,R#S((((((((rrM)abcrrenumrtypingrrHDEFAULT_GRACE_PERIODr rr1CircuitBreakerListenerrJrMrrrr^s5########D ' ' ' ' ' S' ' ' T) ) ) ) ) ) ) ) X+++++1+++6(((((0(((((r