RPKI Engine 1.0
|
Public Member Functions | |
def | __init__ |
def | __repr__ |
def | detach |
def | request |
def | restart |
def | return_result |
def | send_request |
Public Attributes | |
client | |
hostport | |
queue | |
Static Public Attributes | |
log = log_method |
Queue of pending HTTP requests for a single destination. This class is very tightly coupled to http_client; http_client handles the HTTP stream itself, this class provides a slightly higher-level API.
def rpki.http.http_queue.detach | ( | self, | |
client_ | |||
) |
def rpki.http.http_queue.request | ( | self, | |
requests | |||
) |
def rpki.http.http_queue.restart | ( | self | ) |
Send next request for this queue, if we can. This may involve starting a new http_client stream, reusing an existing idle stream, or just ignoring this request if there's an active client stream already; in the last case, handling of the response (or exception, or timeout) for the query currently in progress will call this method when it's time to kick out the next query.
def rpki.http.http_queue.return_result | ( | self, | |
client, | |||
result, | |||
detach = False |
|||
) |
def rpki.http.http_queue.send_request | ( | self | ) |
rpki.http.http_queue.log = log_method [static] |