R/datapipeline_interfaces.R

In paws.analytics: 'Amazon Web Services' Analytics Services

# This file is generated by make.paws. Please do not edit here.
#' @importFrom paws.common populate
#' @include datapipeline_service.R
NULL

.datapipeline$activate_pipeline_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), parameterValues = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), startTimestamp = structure(logical(0), tags = list(type = "timestamp"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$activate_pipeline_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$add_tags_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), tags = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), value = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$add_tags_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$create_pipeline_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(name = structure(logical(0), tags = list(type = "string")), uniqueId = structure(logical(0), tags = list(type = "string")), description = structure(logical(0), tags = list(type = "string")), tags = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), value = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$create_pipeline_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$deactivate_pipeline_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), cancelActive = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$deactivate_pipeline_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$delete_pipeline_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$delete_pipeline_output <- function(...) {
  list()
}

.datapipeline$describe_objects_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), objectIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), evaluateExpressions = structure(logical(0), tags = list(type = "boolean")), marker = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$describe_objects_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineObjects = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string")), fields = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string")), refValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), marker = structure(logical(0), tags = list(type = "string")), hasMoreResults = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$describe_pipelines_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$describe_pipelines_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineDescriptionList = structure(list(structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string")), fields = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string")), refValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), description = structure(logical(0), tags = list(type = "string")), tags = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), value = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$evaluate_expression_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), objectId = structure(logical(0), tags = list(type = "string")), expression = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$evaluate_expression_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(evaluatedExpression = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$get_pipeline_definition_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), version = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$get_pipeline_definition_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineObjects = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string")), fields = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string")), refValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), parameterObjects = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), attributes = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), parameterValues = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$list_pipelines_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(marker = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$list_pipelines_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineIdList = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), marker = structure(logical(0), tags = list(type = "string")), hasMoreResults = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$poll_for_task_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(workerGroup = structure(logical(0), tags = list(type = "string")), hostname = structure(logical(0), tags = list(type = "string")), instanceIdentity = structure(list(document = structure(logical(0), tags = list(type = "string")), signature = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$poll_for_task_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(taskObject = structure(list(taskId = structure(logical(0), tags = list(type = "string")), pipelineId = structure(logical(0), tags = list(type = "string")), attemptId = structure(logical(0), tags = list(type = "string")), objects = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string")), fields = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string")), refValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "map"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$put_pipeline_definition_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), pipelineObjects = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string")), fields = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string")), refValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), parameterObjects = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), attributes = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), parameterValues = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$put_pipeline_definition_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(validationErrors = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), errors = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), validationWarnings = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), warnings = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), errored = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$query_objects_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), query = structure(list(selectors = structure(list(structure(list(fieldName = structure(logical(0), tags = list(type = "string")), operator = structure(list(type = structure(logical(0), tags = list(type = "string")), values = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure")), sphere = structure(logical(0), tags = list(type = "string")), marker = structure(logical(0), tags = list(type = "string")), limit = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$query_objects_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(ids = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), marker = structure(logical(0), tags = list(type = "string")), hasMoreResults = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$remove_tags_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), tagKeys = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$remove_tags_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$report_task_progress_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(taskId = structure(logical(0), tags = list(type = "string")), fields = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string")), refValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$report_task_progress_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(canceled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$report_task_runner_heartbeat_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(taskrunnerId = structure(logical(0), tags = list(type = "string")), workerGroup = structure(logical(0), tags = list(type = "string")), hostname = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$report_task_runner_heartbeat_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(terminate = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$set_status_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), objectIds = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), status = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$set_status_output <- function(...) {
  list()
}

.datapipeline$set_task_status_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(taskId = structure(logical(0), tags = list(type = "string")), taskStatus = structure(logical(0), tags = list(type = "string")), errorId = structure(logical(0), tags = list(type = "string")), errorMessage = structure(logical(0), tags = list(type = "string")), errorStackTrace = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$set_task_status_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$validate_pipeline_definition_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(pipelineId = structure(logical(0), tags = list(type = "string")), pipelineObjects = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string")), fields = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string")), refValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), parameterObjects = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), attributes = structure(list(structure(list(key = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), parameterValues = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), stringValue = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.datapipeline$validate_pipeline_definition_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(validationErrors = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), errors = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), validationWarnings = structure(list(structure(list(id = structure(logical(0), tags = list(type = "string")), warnings = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "list")), errored = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure"))
  return(populate(args, shape))
}