Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
doctorondemand
doctorondemand / supervisor python
Repository URL to install this package:
|
Version:
4.2.1 ▾
|
U
VƧ\C ã @ s4 d dl mZ d dlmZ g Zdd Zdd Zdd Zd d
ZG d d d Z G d
d de Z
G dd de
Z G dd de
Z G dd de Z
G dd de
ZG dd de
ZG dd de ZG dd d e ZG d d d eZG d d d eZG d!d" d"ZG d#d$ d$e ZG d%d& d&eZG d'd( d(eZG d)d* d*eZG d+d, d,eZG d-d. d.eZG d/d0 d0eZG d1d2 d2eZ G d3d4 d4eZ G d5d6 d6eZ G d7d8 d8e Z G d9d: d:e Z G d;d< d<e Z!G d=d> d>e Z"G d?d@ d@e"Z#G dAdB dBe"Z$G dCdD dDe"Z%e#e$e%gZ&G dEdF dFZ'dGdH Z(dIdJ Z)dKS )Lé )ÚgetProcessStateDescription)Ú as_stringc C s t | |f¡ d S ©N)Ú callbacksÚappend©ÚtypeÚcallback© r
ú ./build/lib/supervisor/events.pyÚ subscribe s r c C s t | |f¡ d S r )r Úremover r
r
r Ú unsubscribe s r c C s$ t D ]\}}t| |r|| qd S r )r Ú
isinstance)Úeventr r r
r
r Únotify s
r c C s g t d d
< d S r )r r
r
r
r Úclear s r c @ s e Zd ZdZdS )ÚEventz Abstract event type N)Ú__name__Ú
__module__Ú __qualname__Ú__doc__r
r
r
r r s r c @ s$ e Zd ZdZdZdd Zdd ZdS )ÚProcessLogEventú
Abstract Nc C s || _ || _|| _d S r ©ÚprocessÚpidÚdata©Úselfr r r r
r
r Ú__init__ s zProcessLogEvent.__init__c C s~ d}| j jd k r | j jjj}zt| j}W n tk
rH d| j }Y nX td}|t| j jjt|| jt| j|f }|S )NÚ úUndecodable: %rz0processname:%s groupname:%s pid:%s channel:%s
%s) r ÚgroupÚconfigÚnamer r ÚUnicodeDecodeErrorr Úchannel)r Ú groupnamer ZfmtÚresultr
r
r Úpayload s þzProcessLogEvent.payload)r r r r r' r r* r
r
r
r r s r c @ s e Zd ZdZdS )ÚProcessLogStdoutEventÚstdoutN©r r r r' r
r
r
r r+ 1 s r+ c @ s e Zd ZdZdS )ÚProcessLogStderrEventÚstderrNr- r
r
r
r r. 4 s r. c @ s( e Zd ZdZdZdZdd Zdd ZdS ) ÚProcessCommunicationEventr s <!--XSUPERVISOR:BEGIN-->s <!--XSUPERVISOR:END-->c C s || _ || _|| _d S r r r r
r
r r = s z"ProcessCommunicationEvent.__init__c C sb d}| j jd k r | j jjj}zt| j}W n tk
rH d| j }Y nX d| j jj|| j|f S )Nr! r" z%processname:%s groupname:%s pid:%s
%s)r r# r$ r% r r r& r )r r( r r
r
r r* B s üz!ProcessCommunicationEvent.payloadN)r r r r Z BEGIN_TOKENZ END_TOKENr r* r
r
r
r r0 7 s
r0 c @ s e Zd ZdZdS )Ú ProcessCommunicationStdoutEventr, Nr- r
r
r
r r1 P s r1 c @ s e Zd ZdZdS )Ú ProcessCommunicationStderrEventr/ Nr- r
r
r
r r2 S s r2 c @ s e Zd Zdd Zdd ZdS )ÚRemoteCommunicationEventc C s || _ || _d S r ©r r )r r r r
r
r r W s z!RemoteCommunicationEvent.__init__c C s d| j | jf S )Nz
type:%s
%sr4 ©r r
r
r r* [ s z RemoteCommunicationEvent.payloadN©r r r r r* r
r
r
r r3 V s r3 c @ s e Zd ZdZdd ZdS )ÚSupervisorStateChangeEventz Abstract class c C s dS )Nr! r
r5 r
r
r r* ` s z"SupervisorStateChangeEvent.payloadN)r r r r r* r
r
r
r r7 ^ s r7 c @ s e Zd ZdS )ÚSupervisorRunningEventN©r r r r
r
r
r r8 c s r8 c @ s e Zd ZdS )ÚSupervisorStoppingEventNr9 r
r
r
r r: f s r: c @ s e Zd Zdd ZdS )ÚEventRejectedEventc C s || _ || _d S r )r r )r r r r
r
r r j s zEventRejectedEvent.__init__N)r r r r r
r
r
r r; i s r; c @ s2 e Zd ZdZdZdZd
ddZdd Zdd ZdS ) ÚProcessStateEventz' Abstract class, never raised directly NTc C s || _ || _|| _| ¡ | _d S r )r Ú
from_stateÚexpectedÚget_extra_valuesÚ extra_values)r r r= r> r
r
r r r s zProcessStateEvent.__init__c C sb d}| j jd k r | j jjj}d| j jjfd|fdt| jfg}| | j¡ d dd |D ¡}|S )Nr! Z processnamer( r= ú c S s g | ]\}}d ||f qS )z%s:%sr
)Ú.0r% Úvalr
r
r Ú
<listcomp> s z-ProcessStateEvent.payload.<locals>.<listcomp>) r r# r$ r% r r= Úextendr@ Újoin)r r( ÚLÚsr
r
r r* z s ÿ zProcessStateEvent.payloadc C s g S r r
r5 r
r
r r? s z"ProcessStateEvent.get_extra_values)T) r r r r ZfrmÚtor r* r? r
r
r
r r< n s
r< c @ s e Zd ZdS )ÚProcessStateFatalEventNr9 r
r
r
r rJ s rJ c @ s e Zd ZdS )ÚProcessStateUnknownEventNr9 r
r
r
r rK s rK c @ s e Zd Zdd ZdS )Ú"ProcessStateStartingOrBackoffEventc C s dt | jjfgS )NZtries)Úintr Zbackoffr5 r
r
r r? s z3ProcessStateStartingOrBackoffEvent.get_extra_valuesN©r r r r? r
r
r
r rL s rL c @ s e Zd ZdS )ÚProcessStateBackoffEventNr9 r
r
r
r rO s rO c @ s e Zd ZdS )ÚProcessStateStartingEventNr9 r
r
r
r rP s rP c @ s e Zd Zdd ZdS )ÚProcessStateExitedEventc C s dt | jfd| jjfgS )Nr> r )rM r> r r r5 r
r
r r? s z(ProcessStateExitedEvent.get_extra_valuesNrN r
r
r
r rQ s rQ c @ s e Zd Zdd ZdS )ÚProcessStateRunningEventc C s d| j jfgS ©Nr ©r r r5 r
r
r r? s z)ProcessStateRunningEvent.get_extra_valuesNrN r
r
r
r rR s rR c @ s e Zd Zdd ZdS )ÚProcessStateStoppingEventc C s d| j jfgS rS rT r5 r
r
r r? s z*ProcessStateStoppingEvent.get_extra_valuesNrN r
r
r
r rU s rU c @ s e Zd Zdd ZdS )ÚProcessStateStoppedEventc C s d| j jfgS rS rT r5 r
r
r r? ¤ s z)ProcessStateStoppedEvent.get_extra_valuesNrN r
r
r
r rV £ s rV c @ s e Zd Zdd Zdd ZdS )ÚProcessGroupEventc C s
|| _ d S r ©r# )r r# r
r
r r ¨ s zProcessGroupEvent.__init__c C s
d| j S )Nz
groupname:%s
rX r5 r
r
r r* « s zProcessGroupEvent.payloadNr6 r
r
r
r rW § s rW c @ s e Zd ZdS )ÚProcessGroupAddedEventNr9 r
r
r
r rY ® s rY c @ s e Zd ZdS )ÚProcessGroupRemovedEventNr9 r
r
r
r rZ ± s rZ c @ s e Zd ZdZdd Zdd ZdS )Ú TickEventr c C s || _ || _d S r )ÚwhenÚ supervisord)r r\ r] r
r
r r ¶ s zTickEvent.__init__c C s
d| j S )Nzwhen:%s)r\ r5 r
r
r r* º s zTickEvent.payloadN)r r r r r r* r
r
r
r r[ ´ s r[ c @ s e Zd ZdZdS )Ú
Tick5Eventé N©r r r Zperiodr
r
r
r r^ ½ s r^ c @ s e Zd ZdZdS )Ú Tick60Eventé< Nr` r
r
r
r ra À s ra c @ s e Zd ZdZdS )Ú
Tick3600Eventi Nr` r
r
r
r rc às rc c @ sx e Zd ZeZeZeZe Z
e Z e
ZeZeZeZeZeZeZeZ e Z e Z e!Z"e#Z$e%Z&e'Z(e)Z*e+Z,e-Z.e/Z0e1Z2e3Z4e5Z6e7Z8dS )Ú
EventTypesN)9r r r r ZEVENTr< Z
PROCESS_STATErV ZPROCESS_STATE_STOPPEDrQ ZPROCESS_STATE_EXITEDrP ZPROCESS_STATE_STARTINGrU ZPROCESS_STATE_STOPPINGrO ZPROCESS_STATE_BACKOFFrJ ZPROCESS_STATE_FATALrR ZPROCESS_STATE_RUNNINGrK ZPROCESS_STATE_UNKNOWNr0 ZPROCESS_COMMUNICATIONr1 Z PROCESS_COMMUNICATION_STDOUTr2 Z PROCESS_COMMUNICATION_STDERRr Z PROCESS_LOGr+ ZPROCESS_LOG_STDOUTr. ZPROCESS_LOG_STDERRr3 ZREMOTE_COMMUNICATIONr7 ZSUPERVISOR_STATE_CHANGEr8 Z SUPERVISOR_STATE_CHANGE_RUNNINGr: Z SUPERVISOR_STATE_CHANGE_STOPPINGr[ ZTICKr^ ZTICK_5ra ZTICK_60rc Z TICK_3600rW Z
PROCESS_GROUPrY ZPROCESS_GROUP_ADDEDrZ ZPROCESS_GROUP_REMOVEDr
r
r
r rd È s6 rd c C s( t j ¡ D ]\}}|| kr
| S q
d S r )rd Ú__dict__Úitems)Z requestedr% Útypr
r
r ÚgetEventNameByTypeå s rh c C s t t| | d S r )Úsetattrrd )r% r r
r
r Úregisterê s rj N)*Zsupervisor.statesr Zsupervisor.compatr r r r r r r r r+ r. r0 r1 r2 r3 r7 r8 r: r; r< rJ rK rL rO rP rQ rR rU rV rW rY rZ r[ r^ ra rc Z TICK_EVENTSrd rh rj r
r
r
r Ú<module> sN