Class: AWSCDK::StepFunctionsTasks::HttpInvoke
- Inherits:
-
AWSCDK::StepFunctions::TaskStateBase
- Object
- AWSCDK::StepFunctions::TaskStateBase
- AWSCDK::StepFunctionsTasks::HttpInvoke
- Defined in:
- step_functions_tasks/http_invoke.rb
Overview
A Step Functions Task to call a public third-party API.
Class Method Summary collapse
- .jsii_overridable_methods ⇒ Object
-
.json_path(scope, id, props) ⇒ AWSCDK::StepFunctionsTasks::HttpInvoke
A Step Functions Task to call a public third-party API using JSONPath.
-
.jsonata(scope, id, props) ⇒ AWSCDK::StepFunctionsTasks::HttpInvoke
A Step Functions Task to call a public third-party API using JSONata.
Instance Method Summary collapse
-
#_next(_next) ⇒ AWSCDK::StepFunctions::Chain
Continue normal execution with the given state.
-
#add_branch(branch) ⇒ void
Add a parallel branch to this state.
-
#add_catch(handler, props = nil) ⇒ AWSCDK::StepFunctions::TaskStateBase
Add a recovery handler for this state.
-
#add_choice(condition, _next, options = nil) ⇒ void
Add a choice branch to this state.
-
#add_item_processor(processor, config = nil) ⇒ void
Add a item processor to this state.
-
#add_iterator(iteration) ⇒ void
Add a map iterator to this state.
-
#add_prefix(x) ⇒ void
Add a prefix to the stateId of this state.
-
#add_retry(props = nil) ⇒ AWSCDK::StepFunctions::TaskStateBase
Add retry configuration for this state.
- #arguments ⇒ Hash?
- #assign ⇒ Hash?
-
#bind_to_graph(graph) ⇒ void
Register this state as part of the given graph.
- #branches ⇒ Array<AWSCDK::StepFunctions::StateGraph>
- #build_task_policy_statements ⇒ Array<AWSCDK::IAM::PolicyStatement>
- #comment ⇒ String?
- #default_choice ⇒ AWSCDK::StepFunctions::State?
- #default_choice=(value) ⇒ Object
-
#end_states ⇒ Array<AWSCDK::StepFunctions::INextable>
Continuable states of this Chainable.
-
#id ⇒ String
Descriptive identifier for this chainable.
-
#initialize(scope, id, props) ⇒ HttpInvoke
constructor
A new instance of HttpInvoke.
- #input_path ⇒ String?
- #iteration ⇒ AWSCDK::StepFunctions::StateGraph?
- #iteration=(value) ⇒ Object
-
#make_default(_def) ⇒ void
Make the indicated state the default choice transition of this state.
-
#make_next(_next) ⇒ void
Make the indicated state the default transition of this state.
-
#metric(metric_name, props = nil) ⇒ AWSCDK::CloudWatch::Metric
Return the given named metric for this Task.
-
#metric_failed(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity fails.
-
#metric_heartbeat_timed_out(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times the heartbeat times out for this activity.
-
#metric_run_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
The interval, in milliseconds, between the time the Task starts and the time it closes.
-
#metric_schedule_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
The interval, in milliseconds, for which the activity stays in the schedule state.
-
#metric_scheduled(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity is scheduled.
-
#metric_started(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity is started.
-
#metric_succeeded(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity succeeds.
-
#metric_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
The interval, in milliseconds, between the time the activity is scheduled and the time it closes.
-
#metric_timed_out(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Metric for the number of times this activity times out.
-
#node ⇒ Constructs::Node
The tree node.
- #output_path ⇒ String?
- #outputs ⇒ Hash?
- #parameters ⇒ Hash?
- #processor ⇒ AWSCDK::StepFunctions::StateGraph?
- #processor=(value) ⇒ Object
- #processor_config ⇒ AWSCDK::StepFunctions::ProcessorConfig?
- #processor_config=(value) ⇒ Object
- #processor_mode ⇒ AWSCDK::StepFunctions::ProcessorMode?
- #processor_mode=(value) ⇒ Object
- #query_language ⇒ AWSCDK::StepFunctions::QueryLanguage?
-
#render_assign(top_level_query_language = nil) ⇒ Object
Render the assign in ASL JSON format.
-
#render_branches ⇒ Object
Render parallel branches in ASL JSON format.
-
#render_choices(top_level_query_language = nil) ⇒ Object
Render the choices in ASL JSON format.
-
#render_input_output ⇒ Object
Render InputPath/Parameters/OutputPath/Arguments/Output in ASL JSON format.
-
#render_item_processor ⇒ Object
Render ItemProcessor in ASL JSON format.
-
#render_iterator ⇒ Object
Render map iterator in ASL JSON format.
-
#render_next_end ⇒ Object
Render the default next state in ASL JSON format.
-
#render_query_language(top_level_query_language = nil) ⇒ Object
Render QueryLanguage in ASL JSON format if needed.
-
#render_result_selector ⇒ Object
Render ResultSelector in ASL JSON format.
-
#render_retry_catch(top_level_query_language = nil) ⇒ Object
Render error recovery options in ASL JSON format.
- #result_path ⇒ String?
- #result_selector ⇒ Hash?
-
#start_state ⇒ AWSCDK::StepFunctions::State
First state of this Chainable.
-
#state_id ⇒ String
Tokenized string that evaluates to the state's ID.
- #state_name ⇒ String?
- #task_metrics ⇒ AWSCDK::StepFunctions::TaskMetricsConfig?
- #task_policies ⇒ Array<AWSCDK::IAM::PolicyStatement>?
-
#to_state_json(top_level_query_language = nil) ⇒ Hash
Return the Amazon States Language object for this state.
-
#to_string ⇒ String
Returns a string representation of this construct.
-
#validate_state ⇒ Array<String>
Allows the state to validate itself.
-
#when_bound_to_graph(graph) ⇒ void
Called whenever this state is bound to a graph.
-
#with(*mixins) ⇒ Constructs::IConstruct
Applies one or more mixins to this construct.
Constructor Details
#initialize(scope, id, props) ⇒ HttpInvoke
Returns a new instance of HttpInvoke.
11 12 13 14 15 16 17 |
# File 'step_functions_tasks/http_invoke.rb', line 11 def initialize(scope, id, props) props = props.is_a?(Hash) ? ::AWSCDK::StepFunctionsTasks::HttpInvokeProps.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(scope, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJjb25zdHJ1Y3RzLkNvbnN0cnVjdCJ9")), "scope") Jsii::Type.check_type(id, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "id") Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9uc190YXNrcy5IdHRwSW52b2tlUHJvcHMifQ==")), "props") Jsii::Object.instance_method(:initialize).bind(self).call(scope, id, props) end |
Class Method Details
.jsii_overridable_methods ⇒ Object
19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 |
# File 'step_functions_tasks/http_invoke.rb', line 19 def self.jsii_overridable_methods { :node => { kind: :property, name: "node", is_optional: false }, :branches => { kind: :property, name: "branches", is_optional: false }, :end_states => { kind: :property, name: "endStates", is_optional: false }, :id => { kind: :property, name: "id", is_optional: false }, :start_state => { kind: :property, name: "startState", is_optional: false }, :state_id => { kind: :property, name: "stateId", is_optional: false }, :arguments => { kind: :property, name: "arguments", is_optional: true }, :assign => { kind: :property, name: "assign", is_optional: true }, :comment => { kind: :property, name: "comment", is_optional: true }, :input_path => { kind: :property, name: "inputPath", is_optional: true }, :output_path => { kind: :property, name: "outputPath", is_optional: true }, :outputs => { kind: :property, name: "outputs", is_optional: true }, :parameters => { kind: :property, name: "parameters", is_optional: true }, :query_language => { kind: :property, name: "queryLanguage", is_optional: true }, :result_path => { kind: :property, name: "resultPath", is_optional: true }, :result_selector => { kind: :property, name: "resultSelector", is_optional: true }, :state_name => { kind: :property, name: "stateName", is_optional: true }, :default_choice => { kind: :property, name: "defaultChoice", is_optional: true }, :iteration => { kind: :property, name: "iteration", is_optional: true }, :processor => { kind: :property, name: "processor", is_optional: true }, :processor_config => { kind: :property, name: "processorConfig", is_optional: true }, :processor_mode => { kind: :property, name: "processorMode", is_optional: true }, :task_metrics => { kind: :property, name: "taskMetrics", is_optional: true }, :task_policies => { kind: :property, name: "taskPolicies", is_optional: true }, :to_string => { kind: :method, name: "toString", is_optional: false }, :with => { kind: :method, name: "with", is_optional: false }, :add_branch => { kind: :method, name: "addBranch", is_optional: false }, :add_choice => { kind: :method, name: "addChoice", is_optional: false }, :add_item_processor => { kind: :method, name: "addItemProcessor", is_optional: false }, :add_iterator => { kind: :method, name: "addIterator", is_optional: false }, :add_prefix => { kind: :method, name: "addPrefix", is_optional: false }, :bind_to_graph => { kind: :method, name: "bindToGraph", is_optional: false }, :make_default => { kind: :method, name: "makeDefault", is_optional: false }, :make_next => { kind: :method, name: "makeNext", is_optional: false }, :render_assign => { kind: :method, name: "renderAssign", is_optional: false }, :render_branches => { kind: :method, name: "renderBranches", is_optional: false }, :render_choices => { kind: :method, name: "renderChoices", is_optional: false }, :render_input_output => { kind: :method, name: "renderInputOutput", is_optional: false }, :render_item_processor => { kind: :method, name: "renderItemProcessor", is_optional: false }, :render_iterator => { kind: :method, name: "renderIterator", is_optional: false }, :render_next_end => { kind: :method, name: "renderNextEnd", is_optional: false }, :render_query_language => { kind: :method, name: "renderQueryLanguage", is_optional: false }, :render_result_selector => { kind: :method, name: "renderResultSelector", is_optional: false }, :render_retry_catch => { kind: :method, name: "renderRetryCatch", is_optional: false }, :to_state_json => { kind: :method, name: "toStateJson", is_optional: false }, :validate_state => { kind: :method, name: "validateState", is_optional: false }, :when_bound_to_graph => { kind: :method, name: "whenBoundToGraph", is_optional: false }, :add_catch => { kind: :method, name: "addCatch", is_optional: false }, :add_retry => { kind: :method, name: "addRetry", is_optional: false }, :metric => { kind: :method, name: "metric", is_optional: false }, :metric_failed => { kind: :method, name: "metricFailed", is_optional: false }, :metric_heartbeat_timed_out => { kind: :method, name: "metricHeartbeatTimedOut", is_optional: false }, :metric_run_time => { kind: :method, name: "metricRunTime", is_optional: false }, :metric_scheduled => { kind: :method, name: "metricScheduled", is_optional: false }, :metric_schedule_time => { kind: :method, name: "metricScheduleTime", is_optional: false }, :metric_started => { kind: :method, name: "metricStarted", is_optional: false }, :metric_succeeded => { kind: :method, name: "metricSucceeded", is_optional: false }, :metric_time => { kind: :method, name: "metricTime", is_optional: false }, :metric_timed_out => { kind: :method, name: "metricTimedOut", is_optional: false }, :_next => { kind: :method, name: "next", is_optional: false }, :build_task_policy_statements => { kind: :method, name: "buildTaskPolicyStatements", is_optional: false }, } end |
.json_path(scope, id, props) ⇒ AWSCDK::StepFunctionsTasks::HttpInvoke
A Step Functions Task to call a public third-party API using JSONPath.
105 106 107 108 109 110 111 |
# File 'step_functions_tasks/http_invoke.rb', line 105 def self.json_path(scope, id, props) Jsii::Type.check_type(scope, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJjb25zdHJ1Y3RzLkNvbnN0cnVjdCJ9")), "scope") Jsii::Type.check_type(id, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "id") props = props.is_a?(Hash) ? ::AWSCDK::StepFunctionsTasks::HttpInvokeJsonPathProps.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9uc190YXNrcy5IdHRwSW52b2tlSnNvblBhdGhQcm9wcyJ9")), "props") Jsii::Kernel.instance.call_static("aws-cdk-lib.aws_stepfunctions_tasks.HttpInvoke", "jsonPath", [scope, id, props]) end |
.jsonata(scope, id, props) ⇒ AWSCDK::StepFunctionsTasks::HttpInvoke
A Step Functions Task to call a public third-party API using JSONata.
91 92 93 94 95 96 97 |
# File 'step_functions_tasks/http_invoke.rb', line 91 def self.jsonata(scope, id, props) Jsii::Type.check_type(scope, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJjb25zdHJ1Y3RzLkNvbnN0cnVjdCJ9")), "scope") Jsii::Type.check_type(id, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "id") props = props.is_a?(Hash) ? ::AWSCDK::StepFunctionsTasks::HttpInvokeJsonataProps.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9uc190YXNrcy5IdHRwSW52b2tlSnNvbmF0YVByb3BzIn0=")), "props") Jsii::Kernel.instance.call_static("aws-cdk-lib.aws_stepfunctions_tasks.HttpInvoke", "jsonata", [scope, id, props]) end |
Instance Method Details
#_next(_next) ⇒ AWSCDK::StepFunctions::Chain
Continue normal execution with the given state.
624 625 626 627 |
# File 'step_functions_tasks/http_invoke.rb', line 624 def _next(_next) Jsii::Type.check_type(_next, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5JQ2hhaW5hYmxlIn0=")), "next") jsii_call_method("next", [_next]) end |
#add_branch(branch) ⇒ void
This method returns an undefined value.
Add a parallel branch to this state.
296 297 298 299 |
# File 'step_functions_tasks/http_invoke.rb', line 296 def add_branch(branch) Jsii::Type.check_type(branch, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "branch") jsii_call_method("addBranch", [branch]) end |
#add_catch(handler, props = nil) ⇒ AWSCDK::StepFunctions::TaskStateBase
Add a recovery handler for this state.
When a particular error occurs, execution will continue at the error handler instead of failing the state machine execution.
488 489 490 491 492 493 |
# File 'step_functions_tasks/http_invoke.rb', line 488 def add_catch(handler, props = nil) Jsii::Type.check_type(handler, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5JQ2hhaW5hYmxlIn0=")), "handler") props = props.is_a?(Hash) ? ::AWSCDK::StepFunctions::CatchProps.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5DYXRjaFByb3BzIn0=")), "props") unless props.nil? jsii_call_method("addCatch", [handler, props]) end |
#add_choice(condition, _next, options = nil) ⇒ void
This method returns an undefined value.
Add a choice branch to this state.
307 308 309 310 311 312 313 |
# File 'step_functions_tasks/http_invoke.rb', line 307 def add_choice(condition, _next, = nil) Jsii::Type.check_type(condition, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5Db25kaXRpb24ifQ==")), "condition") Jsii::Type.check_type(_next, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZSJ9")), "next") = .is_a?(Hash) ? ::AWSCDK::StepFunctions::ChoiceTransitionOptions.new(**.transform_keys(&:to_sym)) : Jsii::Type.check_type(, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5DaG9pY2VUcmFuc2l0aW9uT3B0aW9ucyJ9")), "options") unless .nil? jsii_call_method("addChoice", [condition, _next, ]) end |
#add_item_processor(processor, config = nil) ⇒ void
This method returns an undefined value.
Add a item processor to this state.
320 321 322 323 324 325 |
# File 'step_functions_tasks/http_invoke.rb', line 320 def add_item_processor(processor, config = nil) Jsii::Type.check_type(processor, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "processor") config = config.is_a?(Hash) ? ::AWSCDK::StepFunctions::ProcessorConfig.new(**config.transform_keys(&:to_sym)) : config Jsii::Type.check_type(config, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5Qcm9jZXNzb3JDb25maWcifQ==")), "config") unless config.nil? jsii_call_method("addItemProcessor", [processor, config]) end |
#add_iterator(iteration) ⇒ void
This method returns an undefined value.
Add a map iterator to this state.
331 332 333 334 |
# File 'step_functions_tasks/http_invoke.rb', line 331 def add_iterator(iteration) Jsii::Type.check_type(iteration, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "iteration") jsii_call_method("addIterator", [iteration]) end |
#add_prefix(x) ⇒ void
This method returns an undefined value.
Add a prefix to the stateId of this state.
340 341 342 343 |
# File 'step_functions_tasks/http_invoke.rb', line 340 def add_prefix(x) Jsii::Type.check_type(x, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "x") jsii_call_method("addPrefix", [x]) end |
#add_retry(props = nil) ⇒ AWSCDK::StepFunctions::TaskStateBase
Add retry configuration for this state.
This controls if and how the execution will be retried if a particular error occurs.
502 503 504 505 506 |
# File 'step_functions_tasks/http_invoke.rb', line 502 def add_retry(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::StepFunctions::RetryProps.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5SZXRyeVByb3BzIn0=")), "props") unless props.nil? jsii_call_method("addRetry", [props]) end |
#arguments ⇒ Hash?
154 155 156 |
# File 'step_functions_tasks/http_invoke.rb', line 154 def arguments() jsii_get_property("arguments") end |
#assign ⇒ Hash?
159 160 161 |
# File 'step_functions_tasks/http_invoke.rb', line 159 def assign() jsii_get_property("assign") end |
#bind_to_graph(graph) ⇒ void
This method returns an undefined value.
Register this state as part of the given graph.
Don't call this. It will be called automatically when you work with states normally.
352 353 354 355 |
# File 'step_functions_tasks/http_invoke.rb', line 352 def bind_to_graph(graph) Jsii::Type.check_type(graph, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "graph") jsii_call_method("bindToGraph", [graph]) end |
#branches ⇒ Array<AWSCDK::StepFunctions::StateGraph>
121 122 123 |
# File 'step_functions_tasks/http_invoke.rb', line 121 def branches() jsii_get_property("branches") end |
#build_task_policy_statements ⇒ Array<AWSCDK::IAM::PolicyStatement>
630 631 632 |
# File 'step_functions_tasks/http_invoke.rb', line 630 def build_task_policy_statements() jsii_call_method("buildTaskPolicyStatements", []) end |
#comment ⇒ String?
164 165 166 |
# File 'step_functions_tasks/http_invoke.rb', line 164 def comment() jsii_get_property("comment") end |
#default_choice ⇒ AWSCDK::StepFunctions::State?
209 210 211 |
# File 'step_functions_tasks/http_invoke.rb', line 209 def default_choice() jsii_get_property("defaultChoice") end |
#default_choice=(value) ⇒ Object
213 214 215 216 |
# File 'step_functions_tasks/http_invoke.rb', line 213 def default_choice=(value) Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZSJ9")), "defaultChoice") unless value.nil? jsii_set_property("defaultChoice", value) end |
#end_states ⇒ Array<AWSCDK::StepFunctions::INextable>
Continuable states of this Chainable.
128 129 130 |
# File 'step_functions_tasks/http_invoke.rb', line 128 def end_states() jsii_get_property("endStates") end |
#id ⇒ String
Descriptive identifier for this chainable.
135 136 137 |
# File 'step_functions_tasks/http_invoke.rb', line 135 def id() jsii_get_property("id") end |
#input_path ⇒ String?
169 170 171 |
# File 'step_functions_tasks/http_invoke.rb', line 169 def input_path() jsii_get_property("inputPath") end |
#iteration ⇒ AWSCDK::StepFunctions::StateGraph?
219 220 221 |
# File 'step_functions_tasks/http_invoke.rb', line 219 def iteration() jsii_get_property("iteration") end |
#iteration=(value) ⇒ Object
223 224 225 226 |
# File 'step_functions_tasks/http_invoke.rb', line 223 def iteration=(value) Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "iteration") unless value.nil? jsii_set_property("iteration", value) end |
#make_default(_def) ⇒ void
This method returns an undefined value.
Make the indicated state the default choice transition of this state.
361 362 363 364 |
# File 'step_functions_tasks/http_invoke.rb', line 361 def make_default(_def) Jsii::Type.check_type(_def, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZSJ9")), "def") jsii_call_method("makeDefault", [_def]) end |
#make_next(_next) ⇒ void
This method returns an undefined value.
Make the indicated state the default transition of this state.
370 371 372 373 |
# File 'step_functions_tasks/http_invoke.rb', line 370 def make_next(_next) Jsii::Type.check_type(_next, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZSJ9")), "next") jsii_call_method("makeNext", [_next]) end |
#metric(metric_name, props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Return the given named metric for this Task.
514 515 516 517 518 519 |
# File 'step_functions_tasks/http_invoke.rb', line 514 def metric(metric_name, props = nil) Jsii::Type.check_type(metric_name, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "metricName") props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metric", [metric_name, props]) end |
#metric_failed(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity fails.
526 527 528 529 530 |
# File 'step_functions_tasks/http_invoke.rb', line 526 def metric_failed(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricFailed", [props]) end |
#metric_heartbeat_timed_out(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times the heartbeat times out for this activity.
537 538 539 540 541 |
# File 'step_functions_tasks/http_invoke.rb', line 537 def metric_heartbeat_timed_out(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricHeartbeatTimedOut", [props]) end |
#metric_run_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - average over 5 minutes
The interval, in milliseconds, between the time the Task starts and the time it closes.
548 549 550 551 552 |
# File 'step_functions_tasks/http_invoke.rb', line 548 def metric_run_time(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricRunTime", [props]) end |
#metric_schedule_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - average over 5 minutes
The interval, in milliseconds, for which the activity stays in the schedule state.
570 571 572 573 574 |
# File 'step_functions_tasks/http_invoke.rb', line 570 def metric_schedule_time(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricScheduleTime", [props]) end |
#metric_scheduled(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity is scheduled.
559 560 561 562 563 |
# File 'step_functions_tasks/http_invoke.rb', line 559 def metric_scheduled(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricScheduled", [props]) end |
#metric_started(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity is started.
581 582 583 584 585 |
# File 'step_functions_tasks/http_invoke.rb', line 581 def metric_started(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricStarted", [props]) end |
#metric_succeeded(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity succeeds.
592 593 594 595 596 |
# File 'step_functions_tasks/http_invoke.rb', line 592 def metric_succeeded(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricSucceeded", [props]) end |
#metric_time(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - average over 5 minutes
The interval, in milliseconds, between the time the activity is scheduled and the time it closes.
603 604 605 606 607 |
# File 'step_functions_tasks/http_invoke.rb', line 603 def metric_time(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricTime", [props]) end |
#metric_timed_out(props = nil) ⇒ AWSCDK::CloudWatch::Metric
Default: - sum over 5 minutes
Metric for the number of times this activity times out.
614 615 616 617 618 |
# File 'step_functions_tasks/http_invoke.rb', line 614 def metric_timed_out(props = nil) props = props.is_a?(Hash) ? ::AWSCDK::CloudWatch::MetricOptions.new(**props.transform_keys(&:to_sym)) : props Jsii::Type.check_type(props, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3NfY2xvdWR3YXRjaC5NZXRyaWNPcHRpb25zIn0=")), "props") unless props.nil? jsii_call_method("metricTimedOut", [props]) end |
#node ⇒ Constructs::Node
The tree node.
116 117 118 |
# File 'step_functions_tasks/http_invoke.rb', line 116 def node() jsii_get_property("node") end |
#output_path ⇒ String?
174 175 176 |
# File 'step_functions_tasks/http_invoke.rb', line 174 def output_path() jsii_get_property("outputPath") end |
#outputs ⇒ Hash?
179 180 181 |
# File 'step_functions_tasks/http_invoke.rb', line 179 def outputs() jsii_get_property("outputs") end |
#parameters ⇒ Hash?
184 185 186 |
# File 'step_functions_tasks/http_invoke.rb', line 184 def parameters() jsii_get_property("parameters") end |
#processor ⇒ AWSCDK::StepFunctions::StateGraph?
229 230 231 |
# File 'step_functions_tasks/http_invoke.rb', line 229 def processor() jsii_get_property("processor") end |
#processor=(value) ⇒ Object
233 234 235 236 |
# File 'step_functions_tasks/http_invoke.rb', line 233 def processor=(value) Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "processor") unless value.nil? jsii_set_property("processor", value) end |
#processor_config ⇒ AWSCDK::StepFunctions::ProcessorConfig?
239 240 241 |
# File 'step_functions_tasks/http_invoke.rb', line 239 def processor_config() jsii_get_property("processorConfig") end |
#processor_config=(value) ⇒ Object
243 244 245 246 247 |
# File 'step_functions_tasks/http_invoke.rb', line 243 def processor_config=(value) value = value.is_a?(Hash) ? ::AWSCDK::StepFunctions::ProcessorConfig.new(**value.transform_keys(&:to_sym)) : value Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5Qcm9jZXNzb3JDb25maWcifQ==")), "processorConfig") unless value.nil? jsii_set_property("processorConfig", value) end |
#processor_mode ⇒ AWSCDK::StepFunctions::ProcessorMode?
250 251 252 |
# File 'step_functions_tasks/http_invoke.rb', line 250 def processor_mode() jsii_get_property("processorMode") end |
#processor_mode=(value) ⇒ Object
254 255 256 257 |
# File 'step_functions_tasks/http_invoke.rb', line 254 def processor_mode=(value) Jsii::Type.check_type(value, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5Qcm9jZXNzb3JNb2RlIn0=")), "processorMode") unless value.nil? jsii_set_property("processorMode", value) end |
#query_language ⇒ AWSCDK::StepFunctions::QueryLanguage?
189 190 191 |
# File 'step_functions_tasks/http_invoke.rb', line 189 def query_language() jsii_get_property("queryLanguage") end |
#render_assign(top_level_query_language = nil) ⇒ Object
Render the assign in ASL JSON format.
379 380 381 382 |
# File 'step_functions_tasks/http_invoke.rb', line 379 def render_assign(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("renderAssign", [top_level_query_language]) end |
#render_branches ⇒ Object
Render parallel branches in ASL JSON format.
387 388 389 |
# File 'step_functions_tasks/http_invoke.rb', line 387 def render_branches() jsii_call_method("renderBranches", []) end |
#render_choices(top_level_query_language = nil) ⇒ Object
Render the choices in ASL JSON format.
395 396 397 398 |
# File 'step_functions_tasks/http_invoke.rb', line 395 def render_choices(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("renderChoices", [top_level_query_language]) end |
#render_input_output ⇒ Object
Render InputPath/Parameters/OutputPath/Arguments/Output in ASL JSON format.
403 404 405 |
# File 'step_functions_tasks/http_invoke.rb', line 403 def render_input_output() jsii_call_method("renderInputOutput", []) end |
#render_item_processor ⇒ Object
Render ItemProcessor in ASL JSON format.
410 411 412 |
# File 'step_functions_tasks/http_invoke.rb', line 410 def render_item_processor() jsii_call_method("renderItemProcessor", []) end |
#render_iterator ⇒ Object
Render map iterator in ASL JSON format.
417 418 419 |
# File 'step_functions_tasks/http_invoke.rb', line 417 def render_iterator() jsii_call_method("renderIterator", []) end |
#render_next_end ⇒ Object
Render the default next state in ASL JSON format.
424 425 426 |
# File 'step_functions_tasks/http_invoke.rb', line 424 def render_next_end() jsii_call_method("renderNextEnd", []) end |
#render_query_language(top_level_query_language = nil) ⇒ Object
Render QueryLanguage in ASL JSON format if needed.
432 433 434 435 |
# File 'step_functions_tasks/http_invoke.rb', line 432 def render_query_language(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("renderQueryLanguage", [top_level_query_language]) end |
#render_result_selector ⇒ Object
Render ResultSelector in ASL JSON format.
440 441 442 |
# File 'step_functions_tasks/http_invoke.rb', line 440 def render_result_selector() jsii_call_method("renderResultSelector", []) end |
#render_retry_catch(top_level_query_language = nil) ⇒ Object
Render error recovery options in ASL JSON format.
448 449 450 451 |
# File 'step_functions_tasks/http_invoke.rb', line 448 def render_retry_catch(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("renderRetryCatch", [top_level_query_language]) end |
#result_path ⇒ String?
194 195 196 |
# File 'step_functions_tasks/http_invoke.rb', line 194 def result_path() jsii_get_property("resultPath") end |
#result_selector ⇒ Hash?
199 200 201 |
# File 'step_functions_tasks/http_invoke.rb', line 199 def result_selector() jsii_get_property("resultSelector") end |
#start_state ⇒ AWSCDK::StepFunctions::State
First state of this Chainable.
142 143 144 |
# File 'step_functions_tasks/http_invoke.rb', line 142 def start_state() jsii_get_property("startState") end |
#state_id ⇒ String
Tokenized string that evaluates to the state's ID.
149 150 151 |
# File 'step_functions_tasks/http_invoke.rb', line 149 def state_id() jsii_get_property("stateId") end |
#state_name ⇒ String?
204 205 206 |
# File 'step_functions_tasks/http_invoke.rb', line 204 def state_name() jsii_get_property("stateName") end |
#task_metrics ⇒ AWSCDK::StepFunctions::TaskMetricsConfig?
260 261 262 |
# File 'step_functions_tasks/http_invoke.rb', line 260 def task_metrics() jsii_get_property("taskMetrics") end |
#task_policies ⇒ Array<AWSCDK::IAM::PolicyStatement>?
265 266 267 |
# File 'step_functions_tasks/http_invoke.rb', line 265 def task_policies() jsii_get_property("taskPolicies") end |
#to_state_json(top_level_query_language = nil) ⇒ Hash
Return the Amazon States Language object for this state.
457 458 459 460 |
# File 'step_functions_tasks/http_invoke.rb', line 457 def to_state_json(top_level_query_language = nil) Jsii::Type.check_type(top_level_query_language, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5RdWVyeUxhbmd1YWdlIn0=")), "topLevelQueryLanguage") unless top_level_query_language.nil? jsii_call_method("toStateJson", [top_level_query_language]) end |
#to_string ⇒ String
Returns a string representation of this construct.
272 273 274 |
# File 'step_functions_tasks/http_invoke.rb', line 272 def to_string() jsii_call_method("toString", []) end |
#validate_state ⇒ Array<String>
Allows the state to validate itself.
465 466 467 |
# File 'step_functions_tasks/http_invoke.rb', line 465 def validate_state() jsii_call_method("validateState", []) end |
#when_bound_to_graph(graph) ⇒ void
This method returns an undefined value.
Called whenever this state is bound to a graph.
Can be overridden by subclasses.
475 476 477 478 |
# File 'step_functions_tasks/http_invoke.rb', line 475 def when_bound_to_graph(graph) Jsii::Type.check_type(graph, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5hd3Nfc3RlcGZ1bmN0aW9ucy5TdGF0ZUdyYXBoIn0=")), "graph") jsii_call_method("whenBoundToGraph", [graph]) end |
#with(*mixins) ⇒ Constructs::IConstruct
Applies one or more mixins to this construct.
Mixins are applied in order. The list of constructs is captured at the
start of the call, so constructs added by a mixin will not be visited.
Use multiple with() calls if subsequent mixins should apply to added
constructs.
285 286 287 288 289 290 |
# File 'step_functions_tasks/http_invoke.rb', line 285 def with(*mixins) mixins.each_with_index do |item, index| Jsii::Type.check_type(item, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJjb25zdHJ1Y3RzLklNaXhpbiJ9")), "mixins[#{index}]") end jsii_call_method("with", [*mixins]) end |