Package buildbot :: Package status :: Module status_push :: Class StatusPush
[frames] | no frames]

Class StatusPush

source code

                 base.StatusReceiverBase --+    
                                           |    
 twisted.application.service.Service --+   |    
                                       |   |    
twisted.application.service.MultiService --+    
                                           |    
                    util.ComparableMixin --+    
                                           |    
             base.StatusReceiverMultiService --+
                                               |
                                              StatusPush
Known Subclasses:

Event streamer to a abstract channel.

It uses IQueue to batch push requests and queue the data when the receiver is down. When a PersistentQueue object is used, the items are saved to disk on master shutdown so they can be pushed back when the master is restarted.

Instance Methods
 
__init__(self, serverPushCb, queue=None, path=None, filter=True, bufferDelay=1, retryDelay=5, blackList=None) source code
 
startService(self)
Starting up.
source code
 
wasLastPushSuccessful(self)
Returns if the "virtual pointer" in the queue advanced.
source code
 
queueNextServerPush(self)
Queue the next push or call it immediately.
source code
 
stopService(self)
Shutting down.
source code
 
push(self, event, **objs)
Push a new event.
source code
 
initialPush(self) source code
 
finalPush(self) source code
 
requestSubmitted(self, request) source code
 
requestCancelled(self, builder, request) source code
 
buildsetSubmitted(self, buildset) source code
 
builderAdded(self, builderName, builder) source code
 
builderChangedState(self, builderName, state) source code
 
buildStarted(self, builderName, build) source code
 
buildETAUpdate(self, build, ETA) source code
 
stepStarted(self, build, step) source code
 
stepTextChanged(self, build, step, text) source code
 
stepText2Changed(self, build, step, text2) source code
 
stepETAUpdate(self, build, step, ETA, expectations) source code
 
logStarted(self, build, step, log) source code
 
logFinished(self, build, step, log) source code
 
stepFinished(self, build, step, results) source code
 
buildFinished(self, builderName, build, results) source code
 
builderRemoved(self, builderName) source code
 
changeAdded(self, change) source code
 
slaveConnected(self, slavename) source code
 
slaveDisconnected(self, slavename) source code

Inherited from base.StatusReceiverMultiService: __provides__

Inherited from base.StatusReceiverBase: __providedBy__, checkConfig, logChunk

Inherited from twisted.application.service.MultiService: __iter__, addService, getServiceNamed, privilegedStartService, removeService

Inherited from twisted.application.service.Service: __getstate__, disownServiceParent, setName, setServiceParent

Inherited from util.ComparableMixin: __cmp__, __hash__

Class Variables

Inherited from base.StatusReceiverMultiService: __implemented__

Inherited from twisted.application.service.Service: name, parent, running

Inherited from util.ComparableMixin: compare_attrs

Method Details

__init__(self, serverPushCb, queue=None, path=None, filter=True, bufferDelay=1, retryDelay=5, blackList=None)
(Constructor)

source code 
Overrides: twisted.application.service.MultiService.__init__

startService(self)

source code 

Starting up.

Overrides: twisted.application.service.Service.startService

queueNextServerPush(self)

source code 

Queue the next push or call it immediately.

Called to signal new items are available to be sent or on shutdown. A timer should be queued to trigger a network request or the callback should be called immediately. If a status push is already queued, ignore the current call.

stopService(self)

source code 

Shutting down.

Overrides: twisted.application.service.Service.stopService

push(self, event, **objs)

source code 
Push a new event.

The new event will be either:
- Queued in memory to reduce network usage
- Queued to disk when the sink server is down
- Pushed (along the other queued items) to the server

requestSubmitted(self, request)

source code 
Overrides: base.StatusReceiverBase.requestSubmitted

requestCancelled(self, builder, request)

source code 
Overrides: base.StatusReceiverBase.requestCancelled

buildsetSubmitted(self, buildset)

source code 
Overrides: base.StatusReceiverBase.buildsetSubmitted

builderAdded(self, builderName, builder)

source code 
Overrides: base.StatusReceiverBase.builderAdded

builderChangedState(self, builderName, state)

source code 
Overrides: base.StatusReceiverBase.builderChangedState

buildStarted(self, builderName, build)

source code 
Overrides: base.StatusReceiverBase.buildStarted

buildETAUpdate(self, build, ETA)

source code 
Overrides: base.StatusReceiverBase.buildETAUpdate

stepStarted(self, build, step)

source code 
Overrides: base.StatusReceiverBase.stepStarted

stepTextChanged(self, build, step, text)

source code 
Overrides: base.StatusReceiverBase.stepTextChanged

stepText2Changed(self, build, step, text2)

source code 
Overrides: base.StatusReceiverBase.stepText2Changed

stepETAUpdate(self, build, step, ETA, expectations)

source code 
Overrides: base.StatusReceiverBase.stepETAUpdate

logStarted(self, build, step, log)

source code 
Overrides: base.StatusReceiverBase.logStarted

logFinished(self, build, step, log)

source code 
Overrides: base.StatusReceiverBase.logFinished

stepFinished(self, build, step, results)

source code 
Overrides: base.StatusReceiverBase.stepFinished

buildFinished(self, builderName, build, results)

source code 
Overrides: base.StatusReceiverBase.buildFinished

builderRemoved(self, builderName)

source code 
Overrides: base.StatusReceiverBase.builderRemoved

changeAdded(self, change)

source code 
Overrides: base.StatusReceiverBase.changeAdded

slaveConnected(self, slavename)

source code 
Overrides: base.StatusReceiverBase.slaveConnected

slaveDisconnected(self, slavename)

source code 
Overrides: base.StatusReceiverBase.slaveDisconnected