Class: Simplerubysteps::Callback

Inherits:
State
  • Object
show all
Defined in:
lib/simplerubysteps/model.rb

Instance Attribute Summary collapse

Attributes inherited from State

#name, #state_machine

Instance Method Summary collapse

Methods inherited from State

#[]=, #error_catch, #error_retry, #next=, #render, #task_timeout

Constructor Details

#initialize(name) ⇒ Callback

Returns a new instance of Callback.



238
239
240
241
242
243
244
245
246
247
248
249
250
 
# File 'lib/simplerubysteps/model.rb', line 238

def initialize(name)
  super
  @dict[:Type] = "Task"
  @dict[:Resource] = "arn:aws:states:::lambda:invoke.waitForTaskToken"
  @dict[:Parameters] = {
    :FunctionName => pop_function_name,
    :Payload => {
      :Task => name,
      "Input.$" => "$",
      "Token.$" => "$$.Task.Token",
    },
  }
end

Instance Attribute Details

#iam_permissions ⇒ Object

Returns the value of attribute iam_permissions.



235
236
237
 
# File 'lib/simplerubysteps/model.rb', line 235

def iam_permissions
  @iam_permissions
end

#queue ⇒ Object

Returns the value of attribute queue.



236
237
238
 
# File 'lib/simplerubysteps/model.rb', line 236

def queue
  @queue
end

Instance Method Details

#action(&action_block) ⇒ Object 



252
253
254
 
# File 'lib/simplerubysteps/model.rb', line 252

def action(&action_block)
  @action_block = action_block
end

#perform_action(input, token) ⇒ Object 



256
257
258
 
# File 'lib/simplerubysteps/model.rb', line 256

def perform_action(input, token)
  @action_block.call(input, token) if @action_block
end

#perform_queue_action(input, token, queue_client) ⇒ Object 



260
261
262
 
# File 'lib/simplerubysteps/model.rb', line 260

def perform_queue_action(input, token, queue_client)
  @action_block.call(input, token, queue_client) if @action_block
end