twisted.spread.pb.Broker(banana.Banana) class documentation

Part of twisted.spread.pb View Source (View In Hierarchy)

Known subclasses: twisted.mail.pb.MaildirBroker, twisted.mail.pb.MaildirClient

I am a broker for objects.

Method __init__ Undocumented
Method resumeProducing Called when the consumer attached to me runs out of buffer.
Method pauseProducing Undocumented
Method stopProducing Undocumented
Method registerPageProducer Undocumented
Method expressionReceived Evaluate an expression as it's received.
Method proto_version Protocol message: (version version-number)
Method sendCall Utility method to send an expression to the other side of the connection.
Method proto_didNotUnderstand Respond to stock 'didNotUnderstand' message.
Method connectionReady Initialize. Called after Banana negotiation is done.
Method connectionFailed Undocumented
Method connectionLost The connection was lost.
Method notifyOnDisconnect Call the given callback when the Broker disconnects.
Method notifyOnFail Call the given callback if the Broker fails to connect.
Method notifyOnConnect Call the given callback when the Broker connects.
Method dontNotifyOnDisconnect Remove a callback from list of disconnect callbacks.
Method localObjectForID Get a local object for a locally unique ID.
Method registerReference Get an ID for a local object.
Method setNameForLocal Store a special (string) ID for this object.
Method remoteForName Returns an object from the remote name mapping.
Method cachedRemotelyAs Returns an ID that says what this instance is cached as remotely, or None if it's not.
Method remotelyCachedForLUID Returns an instance which is cached remotely, with this LUID.
Method cacheRemotely XXX
Method cacheLocally (internal)
Method cachedLocallyAs Undocumented
Method serialize Jelly an object according to the remote security rules for this broker.
Method unserialize Unjelly an sexp according to the local security rules for this broker.
Method newLocalID Generate a new LUID.
Method newRequestID Generate a new request ID.
Method proto_message Undocumented
Method proto_cachemessage Undocumented
Method proto_answer (internal) Got an answer to a previously sent message.
Method proto_error (internal) Deal with an error.
Method sendDecRef (internal) Send a DECREF directive.
Method proto_decref (internal) Decrement the reference count of an object.
Method decCacheRef (internal) Send a DECACHE directive.
Method proto_decache (internal) Decrement the reference count of a cached object.
Method proto_uncache (internal) Tell the client it is now OK to uncache an object.
Method _sendMessage Undocumented
Method _recvMessage Received a message-send.
Method _sendAnswer (internal) Send an answer to a previously sent message.
Method _sendFailureOrError Call _sendError or _sendFailure, depending on whether fail represents an Error subclass or not.
Method _sendFailure Log error and then send it.
Method _sendError (internal) Send an error for a previously sent message.

Inherited from Ephemeral (via Banana):

Method __reduce__ Serialize any subclass of Ephemeral in a way which replaces it with Ephemeral itself.
Method __getstate__ Undocumented
Method __setstate__ Undocumented

Inherited from Ephemeral (via Banana):

Method __reduce__ Serialize any subclass of Ephemeral in a way which replaces it with Ephemeral itself.
Method __getstate__ Undocumented
Method __setstate__ Undocumented

Inherited from Ephemeral (via Banana):

Method __reduce__ Serialize any subclass of Ephemeral in a way which replaces it with Ephemeral itself.
Method __getstate__ Undocumented
Method __setstate__ Undocumented

Inherited from Ephemeral (via Banana):

Method __reduce__ Serialize any subclass of Ephemeral in a way which replaces it with Ephemeral itself.
Method __getstate__ Undocumented
Method __setstate__ Undocumented
def __init__(self, isClient=1, security=globalSecurity): (source)
overrides twisted.spread.banana.Banana.__init__
Undocumented
def resumeProducing(self): (source)

Called when the consumer attached to me runs out of buffer.

def pauseProducing(self): (source)
Undocumented
def stopProducing(self): (source)
Undocumented
def registerPageProducer(self, pager): (source)
Undocumented
def expressionReceived(self, sexp): (source)
overrides twisted.spread.banana.Banana.expressionReceived

Evaluate an expression as it's received.

def proto_version(self, vnum): (source)

Protocol message: (version version-number)

Check to make sure that both ends of the protocol are speaking the same version dialect.

def sendCall(self, *exp): (source)

Utility method to send an expression to the other side of the connection.

def proto_didNotUnderstand(self, command): (source)

Respond to stock 'didNotUnderstand' message.

Log the command that was not understood and continue. (Note: this will probably be changed to close the connection or raise an exception in the future.)

def connectionReady(self): (source)
overrides twisted.spread.banana.Banana.connectionReady

Initialize. Called after Banana negotiation is done.

def connectionFailed(self): (source)
Undocumented
def connectionLost(self, reason): (source)
from twisted.internet.interfaces.IProtocol
overrides twisted.internet.protocol.Protocol.connectionLost

The connection was lost.

def notifyOnDisconnect(self, notifier): (source)

Call the given callback when the Broker disconnects.

def notifyOnFail(self, notifier): (source)

Call the given callback if the Broker fails to connect.

def notifyOnConnect(self, notifier): (source)

Call the given callback when the Broker connects.

def dontNotifyOnDisconnect(self, notifier): (source)

Remove a callback from list of disconnect callbacks.

def localObjectForID(self, luid): (source)

Get a local object for a locally unique ID.

ReturnsAn object previously stored with registerReference or None if there is no object which corresponds to the given identifier.
def registerReference(self, object): (source)

Get an ID for a local object.

Store a persistent reference to a local object and map its id() to a generated, session-unique ID and return that ID.

def setNameForLocal(self, name, object): (source)

Store a special (string) ID for this object.

This is how you specify a 'base' set of objects that the remote protocol can connect to.

def remoteForName(self, name): (source)

Returns an object from the remote name mapping.

Note that this does not check the validity of the name, only creates a translucent reference for it.

def cachedRemotelyAs(self, instance, incref=0): (source)

Returns an ID that says what this instance is cached as remotely, or None if it's not.

def remotelyCachedForLUID(self, luid): (source)

Returns an instance which is cached remotely, with this LUID.

def cacheRemotely(self, instance): (source)

XXX

def cacheLocally(self, cid, instance): (source)

(internal)

Store a non-filled-out cached instance locally.

def cachedLocallyAs(self, cid): (source)
Undocumented
def serialize(self, object, perspective=None, method=None, args=None, kw=None): (source)

Jelly an object according to the remote security rules for this broker.

def unserialize(self, sexp, perspective=None): (source)

Unjelly an sexp according to the local security rules for this broker.

def newLocalID(self): (source)

Generate a new LUID.

def newRequestID(self): (source)

Generate a new request ID.

def _sendMessage(self, prefix, perspective, objectID, message, args, kw): (source)
Undocumented
def proto_message(self, requestID, objectID, message, answerRequired, netArgs, netKw): (source)
Undocumented
def proto_cachemessage(self, requestID, objectID, message, answerRequired, netArgs, netKw): (source)
Undocumented
def _recvMessage(self, findObjMethod, requestID, objectID, message, answerRequired, netArgs, netKw): (source)

Received a message-send.

Look up message based on object, unserialize the arguments, and invoke it with args, and send an 'answer' or 'error' response.

def _sendAnswer(self, netResult, requestID): (source)

(internal) Send an answer to a previously sent message.

def proto_answer(self, requestID, netResult): (source)

(internal) Got an answer to a previously sent message.

Look up the appropriate callback and call it.

def _sendFailureOrError(self, fail, requestID): (source)

Call _sendError or _sendFailure, depending on whether fail represents an Error subclass or not.

def _sendFailure(self, fail, requestID): (source)

Log error and then send it.

def _sendError(self, fail, requestID): (source)

(internal) Send an error for a previously sent message.

def proto_error(self, requestID, fail): (source)

(internal) Deal with an error.

def sendDecRef(self, objectID): (source)

(internal) Send a DECREF directive.

def proto_decref(self, objectID): (source)

(internal) Decrement the reference count of an object.

If the reference count is zero, it will free the reference to this object.

def decCacheRef(self, objectID): (source)

(internal) Send a DECACHE directive.

def proto_decache(self, objectID): (source)

(internal) Decrement the reference count of a cached object.

If the reference count is zero, free the reference, then send an 'uncached' directive.

def proto_uncache(self, objectID): (source)

(internal) Tell the client it is now OK to uncache an object.

API Documentation for Twisted, generated by pydoctor at 2016-04-11 10:39:53.