Package buildbot :: Package status :: Module status_push :: Class StatusPush

Class StatusPush

                     base.StatusReceiver --+    
                                           |    
 twisted.application.service.Service --+   |    
                                       |   |    
twisted.application.service.MultiService --+    
                                           |    
                    util.ComparableMixin --+    
                                           |    
             base.StatusReceiverMultiService --+
                                               |
                                              StatusPush

Known Subclasses:

HttpStatusPush

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.StatusReceiver: __providedBy__, 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

Class StatusPush

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

startService(self)

queueNextServerPush(self)

stopService(self)

push(self, event, **objs)

requestSubmitted(self, request)

requestCancelled(self, builder, request)

buildsetSubmitted(self, buildset)

builderAdded(self, builderName, builder)

builderChangedState(self, builderName, state)

buildStarted(self, builderName, build)

buildETAUpdate(self, build, ETA)

stepStarted(self, build, step)

stepTextChanged(self, build, step, text)

stepText2Changed(self, build, step, text2)

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

logStarted(self, build, step, log)

logFinished(self, build, step, log)

stepFinished(self, build, step, results)

buildFinished(self, builderName, build, results)

builderRemoved(self, builderName)

changeAdded(self, change)

slaveConnected(self, slavename)

slaveDisconnected(self, slavename)

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