Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(10)  |  Call(10)  |  Derive(0)  |  Import(0)
Load a bucket from its list representation.

The list representation includes several different record types,
representing a base bucket, an update to a bucket, and a
summarize-in-progress record.  This class will not only load a
bucket from that list representation, it will also accumulate all
auxiliary information needed for the algorithms below.

This is implemented as a class due to the complexity of the
information that the algorithm needs to return.  The return(more...)

src/t/u/turnstile-HEAD/turnstile/compactor.py   turnstile(Download)
    # Suck in the bucket records and generate our bucket
    records = db.lrange(str(buck_key), 0, -1)
    loader = limits.BucketLoader(limit.bucket_class, db, limit,
                                 str(buck_key), records, stop_summarize=True)
 

src/t/u/turnstile-0.7.0b2/turnstile/compactor.py   turnstile(Download)
    # Suck in the bucket records and generate our bucket
    records = db.lrange(str(buck_key), 0, -1)
    loader = limits.BucketLoader(limit.bucket_class, db, limit,
                                 str(buck_key), records, stop_summarize=True)
 

src/t/u/turnstile-HEAD/tests/unit/test_limits.py   turnstile(Download)
    def test_read_no_bucket_records(self, mock_loads):
        bucket_class = mock.Mock(return_value='bucket')
        records = []
 
        loader = limits.BucketLoader(bucket_class, 'db', 'limit', 'key',
        ]
 
        loader = limits.BucketLoader(bucket_class, 'db', 'limit', 'key',
                                     records)
 
        ]
 
        loader = limits.BucketLoader(bucket_class, 'db', 'limit', 'key',
                                     records)
 
        ]
 
        loader = limits.BucketLoader(bucket_class, 'db', 'limit', 'key',
                                     records, stop_uuid='stop')
 
        ]
 
        loader = limits.BucketLoader(bucket_class, 'db', 'limit', 'key',
                                     records, stop_uuid='stop')