R/kafkaconnect_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 kafkaconnect_service.R
NULL

.kafkaconnect$create_connector_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(capacity = structure(list(autoScaling = structure(list(maxWorkerCount = structure(logical(0), tags = list(type = "integer")), mcuCount = structure(logical(0), tags = list(type = "integer")), minWorkerCount = structure(logical(0), tags = list(type = "integer")), scaleInPolicy = structure(list(cpuUtilizationPercentage = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), scaleOutPolicy = structure(list(cpuUtilizationPercentage = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure")), provisionedCapacity = structure(list(mcuCount = structure(logical(0), tags = list(type = "integer")), workerCount = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure")), connectorConfiguration = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map", sensitive = TRUE)), connectorDescription = structure(logical(0), tags = list(type = "string")), connectorName = structure(logical(0), tags = list(type = "string")), kafkaCluster = structure(list(apacheKafkaCluster = structure(list(bootstrapServers = structure(logical(0), tags = list(type = "string")), vpc = structure(list(securityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), subnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), kafkaClusterClientAuthentication = structure(list(authenticationType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), kafkaClusterEncryptionInTransit = structure(list(encryptionType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), kafkaConnectVersion = structure(logical(0), tags = list(type = "string")), logDelivery = structure(list(workerLogDelivery = structure(list(cloudWatchLogs = structure(list(enabled = structure(logical(0), tags = list(type = "boolean")), logGroup = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), firehose = structure(list(deliveryStream = structure(logical(0), tags = list(type = "string")), enabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), s3 = structure(list(bucket = structure(logical(0), tags = list(type = "string")), enabled = structure(logical(0), tags = list(type = "boolean")), prefix = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), plugins = structure(list(structure(list(customPlugin = structure(list(customPluginArn = structure(logical(0), tags = list(type = "string")), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), serviceExecutionRoleArn = structure(logical(0), tags = list(type = "string")), workerConfiguration = structure(list(revision = structure(logical(0), tags = list(type = "long")), workerConfigurationArn = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$create_connector_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(connectorArn = structure(logical(0), tags = list(type = "string")), connectorName = structure(logical(0), tags = list(type = "string")), connectorState = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$create_custom_plugin_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(contentType = structure(logical(0), tags = list(type = "string")), description = structure(logical(0), tags = list(type = "string")), location = structure(list(s3Location = structure(list(bucketArn = structure(logical(0), tags = list(type = "string")), fileKey = structure(logical(0), tags = list(type = "string")), objectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), name = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$create_custom_plugin_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(customPluginArn = structure(logical(0), tags = list(type = "string")), customPluginState = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string")), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$create_worker_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(description = structure(logical(0), tags = list(type = "string")), name = structure(logical(0), tags = list(type = "string")), propertiesFileContent = structure(logical(0), tags = list(type = "string", sensitive = TRUE))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$create_worker_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), latestRevision = structure(list(creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), description = structure(logical(0), tags = list(type = "string")), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), name = structure(logical(0), tags = list(type = "string")), workerConfigurationArn = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$delete_connector_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(connectorArn = structure(logical(0), tags = list(location = "uri", locationName = "connectorArn", type = "string")), currentVersion = structure(logical(0), tags = list(location = "querystring", locationName = "currentVersion", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$delete_connector_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(connectorArn = structure(logical(0), tags = list(type = "string")), connectorState = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$delete_custom_plugin_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(customPluginArn = structure(logical(0), tags = list(location = "uri", locationName = "customPluginArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$delete_custom_plugin_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(customPluginArn = structure(logical(0), tags = list(type = "string")), customPluginState = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$describe_connector_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(connectorArn = structure(logical(0), tags = list(location = "uri", locationName = "connectorArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$describe_connector_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(capacity = structure(list(autoScaling = structure(list(maxWorkerCount = structure(logical(0), tags = list(type = "integer")), mcuCount = structure(logical(0), tags = list(type = "integer")), minWorkerCount = structure(logical(0), tags = list(type = "integer")), scaleInPolicy = structure(list(cpuUtilizationPercentage = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), scaleOutPolicy = structure(list(cpuUtilizationPercentage = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure")), provisionedCapacity = structure(list(mcuCount = structure(logical(0), tags = list(type = "integer")), workerCount = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure")), connectorArn = structure(logical(0), tags = list(type = "string")), connectorConfiguration = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "map", sensitive = TRUE)), connectorDescription = structure(logical(0), tags = list(type = "string")), connectorName = structure(logical(0), tags = list(type = "string")), connectorState = structure(logical(0), tags = list(type = "string")), creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), currentVersion = structure(logical(0), tags = list(type = "string")), kafkaCluster = structure(list(apacheKafkaCluster = structure(list(bootstrapServers = structure(logical(0), tags = list(type = "string")), vpc = structure(list(securityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), subnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), kafkaClusterClientAuthentication = structure(list(authenticationType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), kafkaClusterEncryptionInTransit = structure(list(encryptionType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), kafkaConnectVersion = structure(logical(0), tags = list(type = "string")), logDelivery = structure(list(workerLogDelivery = structure(list(cloudWatchLogs = structure(list(enabled = structure(logical(0), tags = list(type = "boolean")), logGroup = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), firehose = structure(list(deliveryStream = structure(logical(0), tags = list(type = "string")), enabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), s3 = structure(list(bucket = structure(logical(0), tags = list(type = "string")), enabled = structure(logical(0), tags = list(type = "boolean")), prefix = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), plugins = structure(list(structure(list(customPlugin = structure(list(customPluginArn = structure(logical(0), tags = list(type = "string")), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), serviceExecutionRoleArn = structure(logical(0), tags = list(type = "string")), stateDescription = structure(list(code = structure(logical(0), tags = list(type = "string")), message = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), workerConfiguration = structure(list(revision = structure(logical(0), tags = list(type = "long")), workerConfigurationArn = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$describe_custom_plugin_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(customPluginArn = structure(logical(0), tags = list(location = "uri", locationName = "customPluginArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$describe_custom_plugin_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), customPluginArn = structure(logical(0), tags = list(type = "string")), customPluginState = structure(logical(0), tags = list(type = "string")), description = structure(logical(0), tags = list(type = "string")), latestRevision = structure(list(contentType = structure(logical(0), tags = list(type = "string")), creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), description = structure(logical(0), tags = list(type = "string")), fileDescription = structure(list(fileMd5 = structure(logical(0), tags = list(type = "string")), fileSize = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), location = structure(list(s3Location = structure(list(bucketArn = structure(logical(0), tags = list(type = "string")), fileKey = structure(logical(0), tags = list(type = "string")), objectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), name = structure(logical(0), tags = list(type = "string")), stateDescription = structure(list(code = structure(logical(0), tags = list(type = "string")), message = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$describe_worker_configuration_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(workerConfigurationArn = structure(logical(0), tags = list(location = "uri", locationName = "workerConfigurationArn", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$describe_worker_configuration_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), description = structure(logical(0), tags = list(type = "string")), latestRevision = structure(list(creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), description = structure(logical(0), tags = list(type = "string")), propertiesFileContent = structure(logical(0), tags = list(type = "string", sensitive = TRUE)), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), name = structure(logical(0), tags = list(type = "string")), workerConfigurationArn = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$list_connectors_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(connectorNamePrefix = structure(logical(0), tags = list(location = "querystring", locationName = "connectorNamePrefix", type = "string")), maxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), nextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$list_connectors_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(connectors = structure(list(structure(list(capacity = structure(list(autoScaling = structure(list(maxWorkerCount = structure(logical(0), tags = list(type = "integer")), mcuCount = structure(logical(0), tags = list(type = "integer")), minWorkerCount = structure(logical(0), tags = list(type = "integer")), scaleInPolicy = structure(list(cpuUtilizationPercentage = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), scaleOutPolicy = structure(list(cpuUtilizationPercentage = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure")), provisionedCapacity = structure(list(mcuCount = structure(logical(0), tags = list(type = "integer")), workerCount = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure")), connectorArn = structure(logical(0), tags = list(type = "string")), connectorDescription = structure(logical(0), tags = list(type = "string")), connectorName = structure(logical(0), tags = list(type = "string")), connectorState = structure(logical(0), tags = list(type = "string")), creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), currentVersion = structure(logical(0), tags = list(type = "string")), kafkaCluster = structure(list(apacheKafkaCluster = structure(list(bootstrapServers = structure(logical(0), tags = list(type = "string")), vpc = structure(list(securityGroups = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list")), subnets = structure(list(structure(logical(0), tags = list(type = "string"))), tags = list(type = "list"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), kafkaClusterClientAuthentication = structure(list(authenticationType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), kafkaClusterEncryptionInTransit = structure(list(encryptionType = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), kafkaConnectVersion = structure(logical(0), tags = list(type = "string")), logDelivery = structure(list(workerLogDelivery = structure(list(cloudWatchLogs = structure(list(enabled = structure(logical(0), tags = list(type = "boolean")), logGroup = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure")), firehose = structure(list(deliveryStream = structure(logical(0), tags = list(type = "string")), enabled = structure(logical(0), tags = list(type = "boolean"))), tags = list(type = "structure")), s3 = structure(list(bucket = structure(logical(0), tags = list(type = "string")), enabled = structure(logical(0), tags = list(type = "boolean")), prefix = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "structure")), plugins = structure(list(structure(list(customPlugin = structure(list(customPluginArn = structure(logical(0), tags = list(type = "string")), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), serviceExecutionRoleArn = structure(logical(0), tags = list(type = "string")), workerConfiguration = structure(list(revision = structure(logical(0), tags = list(type = "long")), workerConfigurationArn = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure"))), tags = list(type = "list")), nextToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$list_custom_plugins_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(maxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), nextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$list_custom_plugins_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(customPlugins = structure(list(structure(list(creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), customPluginArn = structure(logical(0), tags = list(type = "string")), customPluginState = structure(logical(0), tags = list(type = "string")), description = structure(logical(0), tags = list(type = "string")), latestRevision = structure(list(contentType = structure(logical(0), tags = list(type = "string")), creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), description = structure(logical(0), tags = list(type = "string")), fileDescription = structure(list(fileMd5 = structure(logical(0), tags = list(type = "string")), fileSize = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), location = structure(list(s3Location = structure(list(bucketArn = structure(logical(0), tags = list(type = "string")), fileKey = structure(logical(0), tags = list(type = "string")), objectVersion = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "structure")), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), name = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list")), nextToken = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$list_worker_configurations_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(maxResults = structure(logical(0), tags = list(location = "querystring", locationName = "maxResults", type = "integer")), nextToken = structure(logical(0), tags = list(location = "querystring", locationName = "nextToken", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$list_worker_configurations_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(nextToken = structure(logical(0), tags = list(type = "string")), workerConfigurations = structure(list(structure(list(creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), description = structure(logical(0), tags = list(type = "string")), latestRevision = structure(list(creationTime = structure(logical(0), tags = list(type = "timestamp", timestampFormat = "iso8601")), description = structure(logical(0), tags = list(type = "string")), revision = structure(logical(0), tags = list(type = "long"))), tags = list(type = "structure")), name = structure(logical(0), tags = list(type = "string")), workerConfigurationArn = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))), tags = list(type = "list"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$update_connector_input <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(capacity = structure(list(autoScaling = structure(list(maxWorkerCount = structure(logical(0), tags = list(type = "integer")), mcuCount = structure(logical(0), tags = list(type = "integer")), minWorkerCount = structure(logical(0), tags = list(type = "integer")), scaleInPolicy = structure(list(cpuUtilizationPercentage = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure")), scaleOutPolicy = structure(list(cpuUtilizationPercentage = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure")), provisionedCapacity = structure(list(mcuCount = structure(logical(0), tags = list(type = "integer")), workerCount = structure(logical(0), tags = list(type = "integer"))), tags = list(type = "structure"))), tags = list(type = "structure")), connectorArn = structure(logical(0), tags = list(location = "uri", locationName = "connectorArn", type = "string")), currentVersion = structure(logical(0), tags = list(location = "querystring", locationName = "currentVersion", type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}

.kafkaconnect$update_connector_output <- function(...) {
  args <- c(as.list(environment()), list(...))
  shape <- structure(list(connectorArn = structure(logical(0), tags = list(type = "string")), connectorState = structure(logical(0), tags = list(type = "string"))), tags = list(type = "structure"))
  return(populate(args, shape))
}