emrcontainersjobtemplate

package
v0.0.0-...-964ba77 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2024 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApplicationConfiguration

type ApplicationConfiguration struct {
	// Classification: string, required
	Classification terra.StringValue `hcl:"classification,attr" validate:"required"`
	// Properties: map of string, optional
	Properties terra.MapValue[terra.StringValue] `hcl:"properties,attr"`
	// Configurations: min=0,max=100
	Configurations []Configurations `hcl:"configurations,block" validate:"min=0,max=100"`
}

type ApplicationConfigurationAttributes

type ApplicationConfigurationAttributes struct {
	// contains filtered or unexported fields
}

func (ApplicationConfigurationAttributes) Classification

func (ApplicationConfigurationAttributes) Configurations

func (ApplicationConfigurationAttributes) InternalRef

func (ApplicationConfigurationAttributes) InternalTokens

func (ApplicationConfigurationAttributes) InternalWithRef

func (ApplicationConfigurationAttributes) Properties

type ApplicationConfigurationState

type ApplicationConfigurationState struct {
	Classification string                `json:"classification"`
	Properties     map[string]string     `json:"properties"`
	Configurations []ConfigurationsState `json:"configurations"`
}

type CloudWatchMonitoringConfiguration

type CloudWatchMonitoringConfiguration struct {
	// LogGroupName: string, required
	LogGroupName terra.StringValue `hcl:"log_group_name,attr" validate:"required"`
	// LogStreamNamePrefix: string, optional
	LogStreamNamePrefix terra.StringValue `hcl:"log_stream_name_prefix,attr"`
}

type CloudWatchMonitoringConfigurationAttributes

type CloudWatchMonitoringConfigurationAttributes struct {
	// contains filtered or unexported fields
}

func (CloudWatchMonitoringConfigurationAttributes) InternalRef

func (CloudWatchMonitoringConfigurationAttributes) InternalTokens

func (CloudWatchMonitoringConfigurationAttributes) InternalWithRef

func (CloudWatchMonitoringConfigurationAttributes) LogGroupName

func (CloudWatchMonitoringConfigurationAttributes) LogStreamNamePrefix

type CloudWatchMonitoringConfigurationState

type CloudWatchMonitoringConfigurationState struct {
	LogGroupName        string `json:"log_group_name"`
	LogStreamNamePrefix string `json:"log_stream_name_prefix"`
}

type ConfigurationOverrides

type ConfigurationOverrides struct {
	// ApplicationConfiguration: min=0,max=100
	ApplicationConfiguration []ApplicationConfiguration `hcl:"application_configuration,block" validate:"min=0,max=100"`
	// MonitoringConfiguration: optional
	MonitoringConfiguration *MonitoringConfiguration `hcl:"monitoring_configuration,block"`
}

type ConfigurationOverridesAttributes

type ConfigurationOverridesAttributes struct {
	// contains filtered or unexported fields
}

func (ConfigurationOverridesAttributes) ApplicationConfiguration

func (ConfigurationOverridesAttributes) InternalRef

func (ConfigurationOverridesAttributes) InternalTokens

func (co ConfigurationOverridesAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ConfigurationOverridesAttributes) InternalWithRef

func (ConfigurationOverridesAttributes) MonitoringConfiguration

type ConfigurationOverridesState

type ConfigurationOverridesState struct {
	ApplicationConfiguration []ApplicationConfigurationState `json:"application_configuration"`
	MonitoringConfiguration  []MonitoringConfigurationState  `json:"monitoring_configuration"`
}

type Configurations

type Configurations struct {
	// Classification: string, optional
	Classification terra.StringValue `hcl:"classification,attr"`
	// Properties: map of string, optional
	Properties terra.MapValue[terra.StringValue] `hcl:"properties,attr"`
}

type ConfigurationsAttributes

type ConfigurationsAttributes struct {
	// contains filtered or unexported fields
}

func (ConfigurationsAttributes) Classification

func (c ConfigurationsAttributes) Classification() terra.StringValue

func (ConfigurationsAttributes) InternalRef

func (c ConfigurationsAttributes) InternalRef() (terra.Reference, error)

func (ConfigurationsAttributes) InternalTokens

func (c ConfigurationsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ConfigurationsAttributes) InternalWithRef

func (ConfigurationsAttributes) Properties

type ConfigurationsState

type ConfigurationsState struct {
	Classification string            `json:"classification"`
	Properties     map[string]string `json:"properties"`
}

type JobDriver

type JobDriver struct {
	// SparkSqlJobDriver: optional
	SparkSqlJobDriver *SparkSqlJobDriver `hcl:"spark_sql_job_driver,block"`
	// SparkSubmitJobDriver: optional
	SparkSubmitJobDriver *SparkSubmitJobDriver `hcl:"spark_submit_job_driver,block"`
}

type JobDriverAttributes

type JobDriverAttributes struct {
	// contains filtered or unexported fields
}

func (JobDriverAttributes) InternalRef

func (jd JobDriverAttributes) InternalRef() (terra.Reference, error)

func (JobDriverAttributes) InternalTokens

func (jd JobDriverAttributes) InternalTokens() (hclwrite.Tokens, error)

func (JobDriverAttributes) InternalWithRef

func (jd JobDriverAttributes) InternalWithRef(ref terra.Reference) JobDriverAttributes

func (JobDriverAttributes) SparkSqlJobDriver

func (JobDriverAttributes) SparkSubmitJobDriver

type JobDriverState

type JobDriverState struct {
	SparkSqlJobDriver    []SparkSqlJobDriverState    `json:"spark_sql_job_driver"`
	SparkSubmitJobDriver []SparkSubmitJobDriverState `json:"spark_submit_job_driver"`
}

type JobTemplateData

type JobTemplateData struct {
	// ExecutionRoleArn: string, required
	ExecutionRoleArn terra.StringValue `hcl:"execution_role_arn,attr" validate:"required"`
	// JobTags: map of string, optional
	JobTags terra.MapValue[terra.StringValue] `hcl:"job_tags,attr"`
	// ReleaseLabel: string, required
	ReleaseLabel terra.StringValue `hcl:"release_label,attr" validate:"required"`
	// ConfigurationOverrides: optional
	ConfigurationOverrides *ConfigurationOverrides `hcl:"configuration_overrides,block"`
	// JobDriver: required
	JobDriver *JobDriver `hcl:"job_driver,block" validate:"required"`
}

type JobTemplateDataAttributes

type JobTemplateDataAttributes struct {
	// contains filtered or unexported fields
}

func (JobTemplateDataAttributes) ConfigurationOverrides

func (JobTemplateDataAttributes) ExecutionRoleArn

func (jtd JobTemplateDataAttributes) ExecutionRoleArn() terra.StringValue

func (JobTemplateDataAttributes) InternalRef

func (jtd JobTemplateDataAttributes) InternalRef() (terra.Reference, error)

func (JobTemplateDataAttributes) InternalTokens

func (jtd JobTemplateDataAttributes) InternalTokens() (hclwrite.Tokens, error)

func (JobTemplateDataAttributes) InternalWithRef

func (JobTemplateDataAttributes) JobDriver

func (JobTemplateDataAttributes) JobTags

func (JobTemplateDataAttributes) ReleaseLabel

func (jtd JobTemplateDataAttributes) ReleaseLabel() terra.StringValue

type JobTemplateDataState

type JobTemplateDataState struct {
	ExecutionRoleArn       string                        `json:"execution_role_arn"`
	JobTags                map[string]string             `json:"job_tags"`
	ReleaseLabel           string                        `json:"release_label"`
	ConfigurationOverrides []ConfigurationOverridesState `json:"configuration_overrides"`
	JobDriver              []JobDriverState              `json:"job_driver"`
}

type MonitoringConfiguration

type MonitoringConfiguration struct {
	// PersistentAppUi: string, optional
	PersistentAppUi terra.StringValue `hcl:"persistent_app_ui,attr"`
	// CloudWatchMonitoringConfiguration: optional
	CloudWatchMonitoringConfiguration *CloudWatchMonitoringConfiguration `hcl:"cloud_watch_monitoring_configuration,block"`
	// S3MonitoringConfiguration: optional
	S3MonitoringConfiguration *S3MonitoringConfiguration `hcl:"s3_monitoring_configuration,block"`
}

type MonitoringConfigurationAttributes

type MonitoringConfigurationAttributes struct {
	// contains filtered or unexported fields
}

func (MonitoringConfigurationAttributes) CloudWatchMonitoringConfiguration

func (MonitoringConfigurationAttributes) InternalRef

func (MonitoringConfigurationAttributes) InternalTokens

func (mc MonitoringConfigurationAttributes) InternalTokens() (hclwrite.Tokens, error)

func (MonitoringConfigurationAttributes) InternalWithRef

func (MonitoringConfigurationAttributes) PersistentAppUi

func (MonitoringConfigurationAttributes) S3MonitoringConfiguration

type MonitoringConfigurationState

type MonitoringConfigurationState struct {
	PersistentAppUi                   string                                   `json:"persistent_app_ui"`
	CloudWatchMonitoringConfiguration []CloudWatchMonitoringConfigurationState `json:"cloud_watch_monitoring_configuration"`
	S3MonitoringConfiguration         []S3MonitoringConfigurationState         `json:"s3_monitoring_configuration"`
}

type S3MonitoringConfiguration

type S3MonitoringConfiguration struct {
	// LogUri: string, required
	LogUri terra.StringValue `hcl:"log_uri,attr" validate:"required"`
}

type S3MonitoringConfigurationAttributes

type S3MonitoringConfigurationAttributes struct {
	// contains filtered or unexported fields
}

func (S3MonitoringConfigurationAttributes) InternalRef

func (S3MonitoringConfigurationAttributes) InternalTokens

func (smc S3MonitoringConfigurationAttributes) InternalTokens() (hclwrite.Tokens, error)

func (S3MonitoringConfigurationAttributes) InternalWithRef

func (S3MonitoringConfigurationAttributes) LogUri

type S3MonitoringConfigurationState

type S3MonitoringConfigurationState struct {
	LogUri string `json:"log_uri"`
}

type SparkSqlJobDriver

type SparkSqlJobDriver struct {
	// EntryPoint: string, optional
	EntryPoint terra.StringValue `hcl:"entry_point,attr"`
	// SparkSqlParameters: string, optional
	SparkSqlParameters terra.StringValue `hcl:"spark_sql_parameters,attr"`
}

type SparkSqlJobDriverAttributes

type SparkSqlJobDriverAttributes struct {
	// contains filtered or unexported fields
}

func (SparkSqlJobDriverAttributes) EntryPoint

func (ssjd SparkSqlJobDriverAttributes) EntryPoint() terra.StringValue

func (SparkSqlJobDriverAttributes) InternalRef

func (ssjd SparkSqlJobDriverAttributes) InternalRef() (terra.Reference, error)

func (SparkSqlJobDriverAttributes) InternalTokens

func (ssjd SparkSqlJobDriverAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SparkSqlJobDriverAttributes) InternalWithRef

func (SparkSqlJobDriverAttributes) SparkSqlParameters

func (ssjd SparkSqlJobDriverAttributes) SparkSqlParameters() terra.StringValue

type SparkSqlJobDriverState

type SparkSqlJobDriverState struct {
	EntryPoint         string `json:"entry_point"`
	SparkSqlParameters string `json:"spark_sql_parameters"`
}

type SparkSubmitJobDriver

type SparkSubmitJobDriver struct {
	// EntryPoint: string, required
	EntryPoint terra.StringValue `hcl:"entry_point,attr" validate:"required"`
	// EntryPointArguments: set of string, optional
	EntryPointArguments terra.SetValue[terra.StringValue] `hcl:"entry_point_arguments,attr"`
	// SparkSubmitParameters: string, optional
	SparkSubmitParameters terra.StringValue `hcl:"spark_submit_parameters,attr"`
}

type SparkSubmitJobDriverAttributes

type SparkSubmitJobDriverAttributes struct {
	// contains filtered or unexported fields
}

func (SparkSubmitJobDriverAttributes) EntryPoint

func (SparkSubmitJobDriverAttributes) EntryPointArguments

func (ssjd SparkSubmitJobDriverAttributes) EntryPointArguments() terra.SetValue[terra.StringValue]

func (SparkSubmitJobDriverAttributes) InternalRef

func (ssjd SparkSubmitJobDriverAttributes) InternalRef() (terra.Reference, error)

func (SparkSubmitJobDriverAttributes) InternalTokens

func (ssjd SparkSubmitJobDriverAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SparkSubmitJobDriverAttributes) InternalWithRef

func (SparkSubmitJobDriverAttributes) SparkSubmitParameters

func (ssjd SparkSubmitJobDriverAttributes) SparkSubmitParameters() terra.StringValue

type SparkSubmitJobDriverState

type SparkSubmitJobDriverState struct {
	EntryPoint            string   `json:"entry_point"`
	EntryPointArguments   []string `json:"entry_point_arguments"`
	SparkSubmitParameters string   `json:"spark_submit_parameters"`
}

type Timeouts

type Timeouts struct {
	// Delete: string, optional
	Delete terra.StringValue `hcl:"delete,attr"`
}

type TimeoutsAttributes

type TimeoutsAttributes struct {
	// contains filtered or unexported fields
}

func (TimeoutsAttributes) Delete

func (TimeoutsAttributes) InternalRef

func (t TimeoutsAttributes) InternalRef() (terra.Reference, error)

func (TimeoutsAttributes) InternalTokens

func (t TimeoutsAttributes) InternalTokens() (hclwrite.Tokens, error)

func (TimeoutsAttributes) InternalWithRef

func (t TimeoutsAttributes) InternalWithRef(ref terra.Reference) TimeoutsAttributes

type TimeoutsState

type TimeoutsState struct {
	Delete string `json:"delete"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL