mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
support pagination of results in AWS Data Pipeline query_objects
This commit is contained in:
parent
2821afa750
commit
b67d9af4c0
1 changed files with 4 additions and 2 deletions
|
@ -10,14 +10,16 @@ module Fog
|
|||
# * PipelineId <~String> - The ID of the pipeline
|
||||
# * Sphere <~String> - Specifies whether the query applies to components or instances.
|
||||
# Allowable values: COMPONENT, INSTANCE, ATTEMPT.
|
||||
# * Marker <~String> - The starting point for the results to be returned.
|
||||
# ==== Returns
|
||||
# * response<~Excon::Response>:
|
||||
# * body<~Hash>:
|
||||
def query_objects(id, sphere)
|
||||
def query_objects(id, sphere, options={})
|
||||
params = {
|
||||
'pipelineId' => id,
|
||||
'sphere' => sphere,
|
||||
}
|
||||
params['marker'] = options[:marker] if options[:marker]
|
||||
|
||||
response = request({
|
||||
:body => Fog::JSON.encode(params),
|
||||
|
@ -30,7 +32,7 @@ module Fog
|
|||
end
|
||||
|
||||
class Mock
|
||||
def query_objects(id, objects)
|
||||
def query_objects(id, sphere, options={})
|
||||
Fog::Mock.not_implemented
|
||||
end
|
||||
end
|
||||
|
|
Loading…
Reference in a new issue