Did I find the right examples for you? yes no

All Samples(19)  |  Call(11)  |  Derive(3)  |  Import(5)

src/t/x/txAWS-0.2.3/txaws/ec2/client.py   txAWS(Download)
 
from txaws import version
from txaws.client.base import BaseClient, BaseQuery, error_wrapper
from txaws.ec2 import model
from txaws.ec2.exception import EC2Error
class Query(BaseQuery):
    """A query that may be submitted to EC2."""
 
    timeout = 30
 

src/t/x/txAWS-0.2.3/txaws/s3/client.py   txAWS(Download)
from dateutil.parser import parse as parseTime
 
from txaws.client.base import BaseClient, BaseQuery, error_wrapper
from txaws.s3.acls import AccessControlPolicy
from txaws.s3.model import (
class Query(BaseQuery):
    """A query for submission to the S3 service."""
 
    def __init__(self, bucket=None, object_name=None, data="",
                 content_type=None, metadata={}, amz_headers={}, *args,

src/l/e/leastauthority.com-HEAD/content/static/patches/txaws/s3/client.py   leastauthority.com(Download)
from epsilon.extime import Time
 
from txaws.client.base import BaseClient, BaseQuery, error_wrapper
from txaws.s3.acls import AccessControlPolicy
from txaws.s3.model import (
class Query(BaseQuery):
    """A query for submission to the S3 service."""
 
    def __init__(self, bucket=None, object_name=None, data="",
                 content_type=None, metadata={}, amz_headers={}, *args,

src/t/x/txAWS-0.2.3/txaws/client/tests/test_base.py   txAWS(Download)
 
from txaws.client import ssl
from txaws.client.base import BaseClient, BaseQuery, error_wrapper
from txaws.service import AWSServiceEndpoint
from txaws.testing.base import TXAWSTestCase
    def test_creation(self):
        query = BaseQuery("an action", "creds", "http://endpoint")
        self.assertEquals(query.factory, HTTPClientFactory)
        self.assertEquals(query.action, "an action")
        self.assertEquals(query.creds, "creds")
    def test_get_page(self):
        query = BaseQuery("an action", "creds", "http://endpoint")
        d = query.get_page(self._get_url("file"))
        d.addCallback(self.assertEquals, "0123456789")
        return d
 
    def test_get_request_headers_no_client(self):
 
        query = BaseQuery("an action", "creds", "http://endpoint")
            self.assertEquals(results.values(), [])
 
        query = BaseQuery("an action", "creds", "http://endpoint")
        d = query.get_page(self._get_url("file"))
        d.addCallback(query.get_request_headers)

src/t/x/txAWS-0.2.3/txaws/client/tests/test_ssl.py   txAWS(Download)
from txaws import exception
from txaws.client import ssl
from txaws.client.base import BaseQuery
from txaws.service import AWSServiceEndpoint
from txaws.testing.base import TXAWSTestCase
 
        endpoint = AWSServiceEndpoint(ssl_hostname_verification=True)
        query = BaseQuery("an action", "creds", endpoint)
        d = query.get_page(self._get_url("file"))
        return d.addCallback(self.assertEquals, "0123456789")
 
        endpoint = AWSServiceEndpoint(ssl_hostname_verification=True)
        query = BaseQuery("an action", "creds", endpoint)
        d = query.get_page(self._get_url("file"))
        return self.assertFailure(d, SSLError)
 
        endpoint = AWSServiceEndpoint(ssl_hostname_verification=False)
        query = BaseQuery("an action", "creds", endpoint)
        d = query.get_page(self._get_url("file"))
        return d.addCallback(self.assertEquals, "0123456789")
 
        endpoint = AWSServiceEndpoint(ssl_hostname_verification=True)
        query = BaseQuery("an action", "creds", endpoint)
        d = query.get_page("https://127.0.0.1:%d/file" % (self.portno,))
        return d.addCallback(self.assertEquals, "0123456789")