import * as core from "@terrascript/core";

export interface S3Args extends core.SchemaArgs {
  bucketArn: string | core.StringOut;

  fileKey: string | core.StringOut;

  roleArn: string | core.StringOut;
}

export class S3 extends core.Schema<S3Args> {
  @core.attr(String)
  public bucketArn!: string | core.StringOut;

  @core.attr(String)
  public fileKey!: string | core.StringOut;

  @core.attr(String)
  public roleArn!: string | core.StringOut;
}

export interface CsvArgs extends core.SchemaArgs {
  recordColumnDelimiter: string | core.StringOut;

  recordRowDelimiter: string | core.StringOut;
}

export class Csv extends core.Schema<CsvArgs> {
  @core.attr(String)
  public recordColumnDelimiter!: string | core.StringOut;

  @core.attr(String)
  public recordRowDelimiter!: string | core.StringOut;
}

export interface JsonArgs extends core.SchemaArgs {
  recordRowPath: string | core.StringOut;
}

export class Json extends core.Schema<JsonArgs> {
  @core.attr(String)
  public recordRowPath!: string | core.StringOut;
}

export interface MappingParametersArgs extends core.SchemaArgs {
  csv?: Csv;

  json?: Json;
}

export class MappingParameters extends core.Schema<MappingParametersArgs> {
  @core.attr(Csv)
  public csv?: Csv;

  @core.attr(Json)
  public json?: Json;
}

export interface RecordFormatArgs extends core.SchemaArgs {
  mappingParameters?: MappingParameters;

  recordFormatType: string | core.StringOut;
}

export class RecordFormat extends core.Schema<RecordFormatArgs> {
  @core.attr(MappingParameters)
  public mappingParameters?: MappingParameters;

  @core.attr(String, { computed: true })
  public recordFormatType!: string | core.StringOut;
}

export interface RecordColumnsArgs extends core.SchemaArgs {
  mapping?: string | core.StringOut;

  name: string | core.StringOut;

  sqlType: string | core.StringOut;
}

export class RecordColumns extends core.Schema<RecordColumnsArgs> {
  @core.attr(String)
  public mapping?: string | core.StringOut;

  @core.attr(String)
  public name!: string | core.StringOut;

  @core.attr(String)
  public sqlType!: string | core.StringOut;
}

export interface ReferenceDataSourcesSchemaArgs extends core.SchemaArgs {
  recordColumns: core.Array<RecordColumns> | core.ArrayOut<RecordColumns>;

  recordEncoding?: string | core.StringOut;

  recordFormat: RecordFormat;
}

export class ReferenceDataSourcesSchema extends core.Schema<ReferenceDataSourcesSchemaArgs> {
  @core.attr(RecordColumns, { kind: "array" })
  public recordColumns!:
    | core.Array<RecordColumns>
    | core.ArrayOut<RecordColumns>;

  @core.attr(String)
  public recordEncoding?: string | core.StringOut;

  @core.attr(RecordFormat)
  public recordFormat!: RecordFormat;
}

export interface ReferenceDataSourcesArgs extends core.SchemaArgs {
  id: string | core.StringOut;

  s3: S3;

  schema: ReferenceDataSourcesSchema;

  tableName: string | core.StringOut;
}

export class ReferenceDataSources extends core.Schema<ReferenceDataSourcesArgs> {
  @core.attr(String, { computed: true })
  public id!: string | core.StringOut;

  @core.attr(S3)
  public s3!: S3;

  @core.attr(ReferenceDataSourcesSchema)
  public schema!: ReferenceDataSourcesSchema;

  @core.attr(String)
  public tableName!: string | core.StringOut;
}

export interface CloudwatchLoggingOptionsArgs extends core.SchemaArgs {
  id: string | core.StringOut;

  logStreamArn: string | core.StringOut;

  roleArn: string | core.StringOut;
}

export class CloudwatchLoggingOptions extends core.Schema<CloudwatchLoggingOptionsArgs> {
  @core.attr(String, { computed: true })
  public id!: string | core.StringOut;

  @core.attr(String)
  public logStreamArn!: string | core.StringOut;

  @core.attr(String)
  public roleArn!: string | core.StringOut;
}

export interface KinesisFirehoseArgs extends core.SchemaArgs {
  resourceArn: string | core.StringOut;

  roleArn: string | core.StringOut;
}

export class KinesisFirehose extends core.Schema<KinesisFirehoseArgs> {
  @core.attr(String)
  public resourceArn!: string | core.StringOut;

  @core.attr(String)
  public roleArn!: string | core.StringOut;
}

export interface KinesisStreamArgs extends core.SchemaArgs {
  resourceArn: string | core.StringOut;

  roleArn: string | core.StringOut;
}

export class KinesisStream extends core.Schema<KinesisStreamArgs> {
  @core.attr(String)
  public resourceArn!: string | core.StringOut;

  @core.attr(String)
  public roleArn!: string | core.StringOut;
}

export interface LambdaArgs extends core.SchemaArgs {
  resourceArn: string | core.StringOut;

  roleArn: string | core.StringOut;
}

export class Lambda extends core.Schema<LambdaArgs> {
  @core.attr(String)
  public resourceArn!: string | core.StringOut;

  @core.attr(String)
  public roleArn!: string | core.StringOut;
}

export interface OutputsSchemaArgs extends core.SchemaArgs {
  recordFormatType: string | core.StringOut;
}

export class OutputsSchema extends core.Schema<OutputsSchemaArgs> {
  @core.attr(String)
  public recordFormatType!: string | core.StringOut;
}

export interface OutputsArgs extends core.SchemaArgs {
  id: string | core.StringOut;

  kinesisFirehose?: KinesisFirehose;

  kinesisStream?: KinesisStream;

  lambda?: Lambda;

  name: string | core.StringOut;

  schema: OutputsSchema;
}

export class Outputs extends core.Schema<OutputsArgs> {
  @core.attr(String, { computed: true })
  public id!: string | core.StringOut;

  @core.attr(KinesisFirehose)
  public kinesisFirehose?: KinesisFirehose;

  @core.attr(KinesisStream)
  public kinesisStream?: KinesisStream;

  @core.attr(Lambda)
  public lambda?: Lambda;

  @core.attr(String)
  public name!: string | core.StringOut;

  @core.attr(OutputsSchema)
  public schema!: OutputsSchema;
}

export interface StartingPositionConfigurationArgs extends core.SchemaArgs {
  startingPosition?: string | core.StringOut;
}

export class StartingPositionConfiguration extends core.Schema<StartingPositionConfigurationArgs> {
  @core.attr(String, { computed: true })
  public startingPosition?: string | core.StringOut;
}

export interface ParallelismArgs extends core.SchemaArgs {
  count?: number | core.NumberOut;
}

export class Parallelism extends core.Schema<ParallelismArgs> {
  @core.attr(Number, { computed: true })
  public count?: number | core.NumberOut;
}

export interface ProcessingConfigurationArgs extends core.SchemaArgs {
  lambda: Lambda;
}

export class ProcessingConfiguration extends core.Schema<ProcessingConfigurationArgs> {
  @core.attr(Lambda)
  public lambda!: Lambda;
}

export interface InputsArgs extends core.SchemaArgs {
  id: string | core.StringOut;

  kinesisFirehose?: KinesisFirehose;

  kinesisStream?: KinesisStream;

  namePrefix: string | core.StringOut;

  parallelism?: Parallelism;

  processingConfiguration?: ProcessingConfiguration;

  schema: ReferenceDataSourcesSchema;

  startingPositionConfiguration?:
    | core.Array<StartingPositionConfiguration>
    | core.ArrayOut<StartingPositionConfiguration>;

  streamNames: core.Array<string> | core.ArrayOut<core.StringOut>;
}

export class Inputs extends core.Schema<InputsArgs> {
  @core.attr(String, { computed: true })
  public id!: string | core.StringOut;

  @core.attr(KinesisFirehose)
  public kinesisFirehose?: KinesisFirehose;

  @core.attr(KinesisStream)
  public kinesisStream?: KinesisStream;

  @core.attr(String)
  public namePrefix!: string | core.StringOut;

  @core.attr(Parallelism, { computed: true })
  public parallelism?: Parallelism;

  @core.attr(ProcessingConfiguration)
  public processingConfiguration?: ProcessingConfiguration;

  @core.attr(ReferenceDataSourcesSchema)
  public schema!: ReferenceDataSourcesSchema;

  @core.attr(StartingPositionConfiguration, { computed: true, kind: "array" })
  public startingPositionConfiguration?:
    | core.Array<StartingPositionConfiguration>
    | core.ArrayOut<StartingPositionConfiguration>;

  @core.attr(String, { computed: true, kind: "array" })
  public streamNames!: core.Array<string> | core.ArrayOut<core.StringOut>;
}

export interface ApplicationArgs extends core.ResourceArgs {
  /**
   * (Optional) The CloudWatch log stream options to monitor application errors.
   */
  cloudwatchLoggingOptions?: CloudwatchLoggingOptions;

  /**
   * (Optional) SQL Code to transform input data, and generate output.
   */
  code?: string | core.StringOut;

  /**
   * (Optional) Description of the application.
   */
  description?: string | core.StringOut;

  /**
   * (Optional) Input configuration of the application. See [Inputs](#inputs) below for more details.
   */
  inputs?: Inputs;

  /**
   * (Required) Name of the Kinesis Analytics Application.
   */
  name: string | core.StringOut;

  /**
   * (Optional) Output destination configuration of the application. See [Outputs](#outputs) below for mo
   * re details.
   */
  outputs?: core.Array<Outputs> | core.ArrayOut<Outputs>;

  /**
   * (Optional) An S3 Reference Data Source for the application.
   */
  referenceDataSources?: ReferenceDataSources;

  /**
   * (Optional) Whether to start or stop the Kinesis Analytics Application. To start an application, an i
   * nput with a defined `starting_position` must be configured.
   */
  startApplication?: boolean | core.BooleanOut;

  /**
   * Key-value map of tags for the Kinesis Analytics Application. If configured with a provider [`default
   * _tags` configuration block](https://registry.terraform.io/providers/hashicorp/aws/latest/docs#defaul
   * t_tags-configuration-block) present, tags with matching keys will overwrite those defined at the pro
   * vider-level.
   */
  tags?: core.Map<string, string> | core.MapOut<core.StringOut>;

  /**
   * A map of tags assigned to the resource, including those inherited from the provider [`default_tags`
   * configuration block](https://registry.terraform.io/providers/hashicorp/aws/latest/docs#default_tags-
   * configuration-block).
   */
  tagsAll?: core.Map<string, string> | core.MapOut<core.StringOut>;
}

export class Application extends core.Resource<ApplicationArgs> {
  /**
   * The ARN of the Kinesis Analytics Appliation.
   */
  @core.attr(String, { computed: true })
  public arn!: string | core.StringOut;

  /**
   * (Optional) The CloudWatch log stream options to monitor application errors.
   */
  @core.attr(CloudwatchLoggingOptions)
  public cloudwatchLoggingOptions?: CloudwatchLoggingOptions;

  /**
   * (Optional) SQL Code to transform input data, and generate output.
   */
  @core.attr(String)
  public code?: string | core.StringOut;

  /**
   * The Timestamp when the application version was created.
   */
  @core.attr(String, { computed: true })
  public createTimestamp!: string | core.StringOut;

  /**
   * (Optional) Description of the application.
   */
  @core.attr(String)
  public description?: string | core.StringOut;

  /**
   * The ARN of the Kinesis Analytics Application.
   */
  @core.attr(String, { computed: true })
  public id!: string | core.StringOut;

  /**
   * (Optional) Input configuration of the application. See [Inputs](#inputs) below for more details.
   */
  @core.attr(Inputs)
  public inputs?: Inputs;

  /**
   * The Timestamp when the application was last updated.
   */
  @core.attr(String, { computed: true })
  public lastUpdateTimestamp!: string | core.StringOut;

  /**
   * (Required) Name of the Kinesis Analytics Application.
   */
  @core.attr(String)
  public name!: string | core.StringOut;

  /**
   * (Optional) Output destination configuration of the application. See [Outputs](#outputs) below for mo
   * re details.
   */
  @core.attr(Outputs, { kind: "array" })
  public outputs?: core.Array<Outputs> | core.ArrayOut<Outputs>;

  /**
   * (Optional) An S3 Reference Data Source for the application.
   */
  @core.attr(ReferenceDataSources)
  public referenceDataSources?: ReferenceDataSources;

  /**
   * (Optional) Whether to start or stop the Kinesis Analytics Application. To start an application, an i
   * nput with a defined `starting_position` must be configured.
   */
  @core.attr(Boolean)
  public startApplication?: boolean | core.BooleanOut;

  /**
   * The Status of the application.
   */
  @core.attr(String, { computed: true })
  public status!: string | core.StringOut;

  /**
   * Key-value map of tags for the Kinesis Analytics Application. If configured with a provider [`default
   * _tags` configuration block](https://registry.terraform.io/providers/hashicorp/aws/latest/docs#defaul
   * t_tags-configuration-block) present, tags with matching keys will overwrite those defined at the pro
   * vider-level.
   */
  @core.attr(String, { kind: "map" })
  public tags?: core.Map<string, string> | core.MapOut<core.StringOut>;

  /**
   * A map of tags assigned to the resource, including those inherited from the provider [`default_tags`
   * configuration block](https://registry.terraform.io/providers/hashicorp/aws/latest/docs#default_tags-
   * configuration-block).
   */
  @core.attr(String, { computed: true, kind: "map" })
  public tagsAll?: core.Map<string, string> | core.MapOut<core.StringOut>;

  /**
   * The Version of the application.
   */
  @core.attr(Number, { computed: true })
  public version!: number | core.NumberOut;

  constructor(name: string, args?: ApplicationArgs) {
    super(name, "aws_kinesis_analytics_application", args);
  }

  public override getNamespace(): string {
    return "aws_kinesis_analytics";
  }
}