google_dataplex_task

package
v0.0.0-...-4deecce Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Args 

type Args struct {
	// Description: string, optional
	Description terra.StringValue `hcl:"description,attr"`
	// DisplayName: string, optional
	DisplayName terra.StringValue `hcl:"display_name,attr"`
	// Id: string, optional
	Id terra.StringValue `hcl:"id,attr"`
	// Labels: map of string, optional
	Labels terra.MapValue[terra.StringValue] `hcl:"labels,attr"`
	// Lake: string, optional
	Lake terra.StringValue `hcl:"lake,attr"`
	// Location: string, optional
	Location terra.StringValue `hcl:"location,attr"`
	// Project: string, optional
	Project terra.StringValue `hcl:"project,attr"`
	// TaskId: string, optional
	TaskId terra.StringValue `hcl:"task_id,attr"`
	// ExecutionSpec: required
	ExecutionSpec *ExecutionSpec `hcl:"execution_spec,block" validate:"required"`
	// Notebook: optional
	Notebook *Notebook `hcl:"notebook,block"`
	// Spark: optional
	Spark *Spark `hcl:"spark,block"`
	// Timeouts: optional
	Timeouts *Timeouts `hcl:"timeouts,block"`
	// TriggerSpec: required
	TriggerSpec *TriggerSpec `hcl:"trigger_spec,block" validate:"required"`
}

Args contains the configurations for google_dataplex_task.

type ExecutionSpec 

type ExecutionSpec struct {
	// Args: map of string, optional
	Args terra.MapValue[terra.StringValue] `hcl:"args,attr"`
	// KmsKey: string, optional
	KmsKey terra.StringValue `hcl:"kms_key,attr"`
	// MaxJobExecutionLifetime: string, optional
	MaxJobExecutionLifetime terra.StringValue `hcl:"max_job_execution_lifetime,attr"`
	// Project: string, optional
	Project terra.StringValue `hcl:"project,attr"`
	// ServiceAccount: string, required
	ServiceAccount terra.StringValue `hcl:"service_account,attr" validate:"required"`
}

type ExecutionSpecAttributes 

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

func (ExecutionSpecAttributes) Args 

func (es ExecutionSpecAttributes) Args() terra.MapValue[terra.StringValue]

func (ExecutionSpecAttributes) InternalRef 

func (es ExecutionSpecAttributes) InternalRef() (terra.Reference, error)

func (ExecutionSpecAttributes) InternalTokens 

func (es ExecutionSpecAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ExecutionSpecAttributes) InternalWithRef 

func (es ExecutionSpecAttributes) InternalWithRef(ref terra.Reference) ExecutionSpecAttributes

func (ExecutionSpecAttributes) KmsKey 

func (es ExecutionSpecAttributes) KmsKey() terra.StringValue

func (ExecutionSpecAttributes) MaxJobExecutionLifetime 

func (es ExecutionSpecAttributes) MaxJobExecutionLifetime() terra.StringValue

func (ExecutionSpecAttributes) Project 

func (es ExecutionSpecAttributes) Project() terra.StringValue

func (ExecutionSpecAttributes) ServiceAccount 

func (es ExecutionSpecAttributes) ServiceAccount() terra.StringValue

type ExecutionSpecState 

type ExecutionSpecState struct {
	Args                    map[string]string `json:"args"`
	KmsKey                  string            `json:"kms_key"`
	MaxJobExecutionLifetime string            `json:"max_job_execution_lifetime"`
	Project                 string            `json:"project"`
	ServiceAccount          string            `json:"service_account"`
}

type ExecutionStatusAttributes 

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

func (ExecutionStatusAttributes) InternalRef 

func (es ExecutionStatusAttributes) InternalRef() (terra.Reference, error)

func (ExecutionStatusAttributes) InternalTokens 

func (es ExecutionStatusAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ExecutionStatusAttributes) InternalWithRef 

func (es ExecutionStatusAttributes) InternalWithRef(ref terra.Reference) ExecutionStatusAttributes

func (ExecutionStatusAttributes) LatestJob 

func (es ExecutionStatusAttributes) LatestJob() terra.ListValue[ExecutionStatusLatestJobAttributes]

func (ExecutionStatusAttributes) UpdateTime 

func (es ExecutionStatusAttributes) UpdateTime() terra.StringValue

type ExecutionStatusLatestJobAttributes 

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

func (ExecutionStatusLatestJobAttributes) EndTime 

func (lj ExecutionStatusLatestJobAttributes) EndTime() terra.StringValue

func (ExecutionStatusLatestJobAttributes) InternalRef 

func (lj ExecutionStatusLatestJobAttributes) InternalRef() (terra.Reference, error)

func (ExecutionStatusLatestJobAttributes) InternalTokens 

func (lj ExecutionStatusLatestJobAttributes) InternalTokens() (hclwrite.Tokens, error)

func (ExecutionStatusLatestJobAttributes) InternalWithRef 

func (lj ExecutionStatusLatestJobAttributes) InternalWithRef(ref terra.Reference) ExecutionStatusLatestJobAttributes

func (ExecutionStatusLatestJobAttributes) Message 

func (lj ExecutionStatusLatestJobAttributes) Message() terra.StringValue

func (ExecutionStatusLatestJobAttributes) Name 

func (lj ExecutionStatusLatestJobAttributes) Name() terra.StringValue

func (ExecutionStatusLatestJobAttributes) RetryCount 

func (lj ExecutionStatusLatestJobAttributes) RetryCount() terra.NumberValue

func (ExecutionStatusLatestJobAttributes) Service 

func (lj ExecutionStatusLatestJobAttributes) Service() terra.StringValue

func (ExecutionStatusLatestJobAttributes) ServiceJob 

func (lj ExecutionStatusLatestJobAttributes) ServiceJob() terra.StringValue

func (ExecutionStatusLatestJobAttributes) StartTime 

func (lj ExecutionStatusLatestJobAttributes) StartTime() terra.StringValue

func (ExecutionStatusLatestJobAttributes) State 

func (lj ExecutionStatusLatestJobAttributes) State() terra.StringValue

func (ExecutionStatusLatestJobAttributes) Uid 

func (lj ExecutionStatusLatestJobAttributes) Uid() terra.StringValue

type ExecutionStatusLatestJobState 

type ExecutionStatusLatestJobState struct {
	EndTime    string  `json:"end_time"`
	Message    string  `json:"message"`
	Name       string  `json:"name"`
	RetryCount float64 `json:"retry_count"`
	Service    string  `json:"service"`
	ServiceJob string  `json:"service_job"`
	StartTime  string  `json:"start_time"`
	State      string  `json:"state"`
	Uid        string  `json:"uid"`
}

type ExecutionStatusState 

type ExecutionStatusState struct {
	UpdateTime string                          `json:"update_time"`
	LatestJob  []ExecutionStatusLatestJobState `json:"latest_job"`
}

type Notebook 

type Notebook struct {
	// ArchiveUris: list of string, optional
	ArchiveUris terra.ListValue[terra.StringValue] `hcl:"archive_uris,attr"`
	// FileUris: list of string, optional
	FileUris terra.ListValue[terra.StringValue] `hcl:"file_uris,attr"`
	// Notebook: string, required
	Notebook terra.StringValue `hcl:"notebook,attr" validate:"required"`
	// NotebookInfrastructureSpec: optional
	InfrastructureSpec *NotebookInfrastructureSpec `hcl:"infrastructure_spec,block"`
}

type NotebookAttributes 

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

func (NotebookAttributes) ArchiveUris 

func (n NotebookAttributes) ArchiveUris() terra.ListValue[terra.StringValue]

func (NotebookAttributes) FileUris 

func (n NotebookAttributes) FileUris() terra.ListValue[terra.StringValue]

func (NotebookAttributes) InfrastructureSpec 

func (n NotebookAttributes) InfrastructureSpec() terra.ListValue[NotebookInfrastructureSpecAttributes]

func (NotebookAttributes) InternalRef 

func (n NotebookAttributes) InternalRef() (terra.Reference, error)

func (NotebookAttributes) InternalTokens 

func (n NotebookAttributes) InternalTokens() (hclwrite.Tokens, error)

func (NotebookAttributes) InternalWithRef 

func (n NotebookAttributes) InternalWithRef(ref terra.Reference) NotebookAttributes

func (NotebookAttributes) Notebook 

func (n NotebookAttributes) Notebook() terra.StringValue

type NotebookInfrastructureSpec 

type NotebookInfrastructureSpec struct {
	// NotebookInfrastructureSpecBatch: optional
	Batch *NotebookInfrastructureSpecBatch `hcl:"batch,block"`
	// NotebookInfrastructureSpecContainerImage: optional
	ContainerImage *NotebookInfrastructureSpecContainerImage `hcl:"container_image,block"`
	// NotebookInfrastructureSpecVpcNetwork: optional
	VpcNetwork *NotebookInfrastructureSpecVpcNetwork `hcl:"vpc_network,block"`
}

type NotebookInfrastructureSpecAttributes 

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

func (NotebookInfrastructureSpecAttributes) Batch 

func (is NotebookInfrastructureSpecAttributes) Batch() terra.ListValue[NotebookInfrastructureSpecBatchAttributes]

func (NotebookInfrastructureSpecAttributes) ContainerImage 

func (is NotebookInfrastructureSpecAttributes) ContainerImage() terra.ListValue[NotebookInfrastructureSpecContainerImageAttributes]

func (NotebookInfrastructureSpecAttributes) InternalRef 

func (is NotebookInfrastructureSpecAttributes) InternalRef() (terra.Reference, error)

func (NotebookInfrastructureSpecAttributes) InternalTokens 

func (is NotebookInfrastructureSpecAttributes) InternalTokens() (hclwrite.Tokens, error)

func (NotebookInfrastructureSpecAttributes) InternalWithRef 

func (is NotebookInfrastructureSpecAttributes) InternalWithRef(ref terra.Reference) NotebookInfrastructureSpecAttributes

func (NotebookInfrastructureSpecAttributes) VpcNetwork 

func (is NotebookInfrastructureSpecAttributes) VpcNetwork() terra.ListValue[NotebookInfrastructureSpecVpcNetworkAttributes]

type NotebookInfrastructureSpecBatch 

type NotebookInfrastructureSpecBatch struct {
	// ExecutorsCount: number, optional
	ExecutorsCount terra.NumberValue `hcl:"executors_count,attr"`
	// MaxExecutorsCount: number, optional
	MaxExecutorsCount terra.NumberValue `hcl:"max_executors_count,attr"`
}

type NotebookInfrastructureSpecBatchAttributes 

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

func (NotebookInfrastructureSpecBatchAttributes) ExecutorsCount 

func (b NotebookInfrastructureSpecBatchAttributes) ExecutorsCount() terra.NumberValue

func (NotebookInfrastructureSpecBatchAttributes) InternalRef 

func (b NotebookInfrastructureSpecBatchAttributes) InternalRef() (terra.Reference, error)

func (NotebookInfrastructureSpecBatchAttributes) InternalTokens 

func (b NotebookInfrastructureSpecBatchAttributes) InternalTokens() (hclwrite.Tokens, error)

func (NotebookInfrastructureSpecBatchAttributes) InternalWithRef 

func (b NotebookInfrastructureSpecBatchAttributes) InternalWithRef(ref terra.Reference) NotebookInfrastructureSpecBatchAttributes

func (NotebookInfrastructureSpecBatchAttributes) MaxExecutorsCount 

func (b NotebookInfrastructureSpecBatchAttributes) MaxExecutorsCount() terra.NumberValue

type NotebookInfrastructureSpecBatchState 

type NotebookInfrastructureSpecBatchState struct {
	ExecutorsCount    float64 `json:"executors_count"`
	MaxExecutorsCount float64 `json:"max_executors_count"`
}

type NotebookInfrastructureSpecContainerImage 

type NotebookInfrastructureSpecContainerImage struct {
	// Image: string, optional
	Image terra.StringValue `hcl:"image,attr"`
	// JavaJars: list of string, optional
	JavaJars terra.ListValue[terra.StringValue] `hcl:"java_jars,attr"`
	// Properties: map of string, optional
	Properties terra.MapValue[terra.StringValue] `hcl:"properties,attr"`
	// PythonPackages: list of string, optional
	PythonPackages terra.ListValue[terra.StringValue] `hcl:"python_packages,attr"`
}

type NotebookInfrastructureSpecContainerImageAttributes 

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

func (NotebookInfrastructureSpecContainerImageAttributes) Image 

func (ci NotebookInfrastructureSpecContainerImageAttributes) Image() terra.StringValue

func (NotebookInfrastructureSpecContainerImageAttributes) InternalRef 

func (ci NotebookInfrastructureSpecContainerImageAttributes) InternalRef() (terra.Reference, error)

func (NotebookInfrastructureSpecContainerImageAttributes) InternalTokens 

func (ci NotebookInfrastructureSpecContainerImageAttributes) InternalTokens() (hclwrite.Tokens, error)

func (NotebookInfrastructureSpecContainerImageAttributes) InternalWithRef 

func (ci NotebookInfrastructureSpecContainerImageAttributes) InternalWithRef(ref terra.Reference) NotebookInfrastructureSpecContainerImageAttributes

func (NotebookInfrastructureSpecContainerImageAttributes) JavaJars 

func (ci NotebookInfrastructureSpecContainerImageAttributes) JavaJars() terra.ListValue[terra.StringValue]

func (NotebookInfrastructureSpecContainerImageAttributes) Properties 

func (ci NotebookInfrastructureSpecContainerImageAttributes) Properties() terra.MapValue[terra.StringValue]

func (NotebookInfrastructureSpecContainerImageAttributes) PythonPackages 

func (ci NotebookInfrastructureSpecContainerImageAttributes) PythonPackages() terra.ListValue[terra.StringValue]

type NotebookInfrastructureSpecContainerImageState 

type NotebookInfrastructureSpecContainerImageState struct {
	Image          string            `json:"image"`
	JavaJars       []string          `json:"java_jars"`
	Properties     map[string]string `json:"properties"`
	PythonPackages []string          `json:"python_packages"`
}

type NotebookInfrastructureSpecState 

type NotebookInfrastructureSpecState struct {
	Batch          []NotebookInfrastructureSpecBatchState          `json:"batch"`
	ContainerImage []NotebookInfrastructureSpecContainerImageState `json:"container_image"`
	VpcNetwork     []NotebookInfrastructureSpecVpcNetworkState     `json:"vpc_network"`
}

type NotebookInfrastructureSpecVpcNetwork 

type NotebookInfrastructureSpecVpcNetwork struct {
	// Network: string, optional
	Network terra.StringValue `hcl:"network,attr"`
	// NetworkTags: list of string, optional
	NetworkTags terra.ListValue[terra.StringValue] `hcl:"network_tags,attr"`
	// SubNetwork: string, optional
	SubNetwork terra.StringValue `hcl:"sub_network,attr"`
}

type NotebookInfrastructureSpecVpcNetworkAttributes 

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

func (NotebookInfrastructureSpecVpcNetworkAttributes) InternalRef 

func (vn NotebookInfrastructureSpecVpcNetworkAttributes) InternalRef() (terra.Reference, error)

func (NotebookInfrastructureSpecVpcNetworkAttributes) InternalTokens 

func (vn NotebookInfrastructureSpecVpcNetworkAttributes) InternalTokens() (hclwrite.Tokens, error)

func (NotebookInfrastructureSpecVpcNetworkAttributes) InternalWithRef 

func (vn NotebookInfrastructureSpecVpcNetworkAttributes) InternalWithRef(ref terra.Reference) NotebookInfrastructureSpecVpcNetworkAttributes

func (NotebookInfrastructureSpecVpcNetworkAttributes) Network 

func (vn NotebookInfrastructureSpecVpcNetworkAttributes) Network() terra.StringValue

func (NotebookInfrastructureSpecVpcNetworkAttributes) NetworkTags 

func (vn NotebookInfrastructureSpecVpcNetworkAttributes) NetworkTags() terra.ListValue[terra.StringValue]

func (NotebookInfrastructureSpecVpcNetworkAttributes) SubNetwork 

func (vn NotebookInfrastructureSpecVpcNetworkAttributes) SubNetwork() terra.StringValue

type NotebookInfrastructureSpecVpcNetworkState 

type NotebookInfrastructureSpecVpcNetworkState struct {
	Network     string   `json:"network"`
	NetworkTags []string `json:"network_tags"`
	SubNetwork  string   `json:"sub_network"`
}

type NotebookState 

type NotebookState struct {
	ArchiveUris        []string                          `json:"archive_uris"`
	FileUris           []string                          `json:"file_uris"`
	Notebook           string                            `json:"notebook"`
	InfrastructureSpec []NotebookInfrastructureSpecState `json:"infrastructure_spec"`
}

type Resource 

type Resource struct {
	Name string
	Args Args

	DependsOn terra.Dependencies
	Lifecycle *terra.Lifecycle
	// contains filtered or unexported fields
}

Resource represents the Terraform resource google_dataplex_task.

func New 

func New(name string, args Args) *Resource

New creates a new instance of Resource.

func (*Resource) Attributes 

func (gdt *Resource) Attributes() googleDataplexTaskAttributes

Attributes returns the attributes for Resource.

func (*Resource) Configuration 

func (gdt *Resource) Configuration() interface{}

Configuration returns the configuration (args) for Resource.

func (*Resource) DependOn 

func (gdt *Resource) DependOn() terra.Reference

DependOn is used for other resources to depend on Resource.

func (*Resource) Dependencies 

func (gdt *Resource) Dependencies() terra.Dependencies

Dependencies returns the list of resources Resource depends_on.

func (*Resource) ImportState 

func (gdt *Resource) ImportState(state io.Reader) error

ImportState imports the given attribute values into Resource's state.

func (*Resource) LifecycleManagement 

func (gdt *Resource) LifecycleManagement() *terra.Lifecycle

LifecycleManagement returns the lifecycle block for Resource.

func (*Resource) LocalName 

func (gdt *Resource) LocalName() string

LocalName returns the local name for Resource.

func (*Resource) State 

func (gdt *Resource) State() (*googleDataplexTaskState, bool)

State returns the state and a bool indicating if Resource has state.

func (*Resource) StateMust 

func (gdt *Resource) StateMust() *googleDataplexTaskState

StateMust returns the state for Resource. Panics if the state is nil.

func (*Resource) Type 

func (gdt *Resource) Type() string

Type returns the Terraform object type for Resource.

type Spark 

type Spark struct {
	// ArchiveUris: list of string, optional
	ArchiveUris terra.ListValue[terra.StringValue] `hcl:"archive_uris,attr"`
	// FileUris: list of string, optional
	FileUris terra.ListValue[terra.StringValue] `hcl:"file_uris,attr"`
	// MainClass: string, optional
	MainClass terra.StringValue `hcl:"main_class,attr"`
	// MainJarFileUri: string, optional
	MainJarFileUri terra.StringValue `hcl:"main_jar_file_uri,attr"`
	// PythonScriptFile: string, optional
	PythonScriptFile terra.StringValue `hcl:"python_script_file,attr"`
	// SqlScript: string, optional
	SqlScript terra.StringValue `hcl:"sql_script,attr"`
	// SqlScriptFile: string, optional
	SqlScriptFile terra.StringValue `hcl:"sql_script_file,attr"`
	// SparkInfrastructureSpec: optional
	InfrastructureSpec *SparkInfrastructureSpec `hcl:"infrastructure_spec,block"`
}

type SparkAttributes 

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

func (SparkAttributes) ArchiveUris 

func (s SparkAttributes) ArchiveUris() terra.ListValue[terra.StringValue]

func (SparkAttributes) FileUris 

func (s SparkAttributes) FileUris() terra.ListValue[terra.StringValue]

func (SparkAttributes) InfrastructureSpec 

func (s SparkAttributes) InfrastructureSpec() terra.ListValue[SparkInfrastructureSpecAttributes]

func (SparkAttributes) InternalRef 

func (s SparkAttributes) InternalRef() (terra.Reference, error)

func (SparkAttributes) InternalTokens 

func (s SparkAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SparkAttributes) InternalWithRef 

func (s SparkAttributes) InternalWithRef(ref terra.Reference) SparkAttributes

func (SparkAttributes) MainClass 

func (s SparkAttributes) MainClass() terra.StringValue

func (SparkAttributes) MainJarFileUri 

func (s SparkAttributes) MainJarFileUri() terra.StringValue

func (SparkAttributes) PythonScriptFile 

func (s SparkAttributes) PythonScriptFile() terra.StringValue

func (SparkAttributes) SqlScript 

func (s SparkAttributes) SqlScript() terra.StringValue

func (SparkAttributes) SqlScriptFile 

func (s SparkAttributes) SqlScriptFile() terra.StringValue

type SparkInfrastructureSpec 

type SparkInfrastructureSpec struct {
	// SparkInfrastructureSpecBatch: optional
	Batch *SparkInfrastructureSpecBatch `hcl:"batch,block"`
	// SparkInfrastructureSpecContainerImage: optional
	ContainerImage *SparkInfrastructureSpecContainerImage `hcl:"container_image,block"`
	// SparkInfrastructureSpecVpcNetwork: optional
	VpcNetwork *SparkInfrastructureSpecVpcNetwork `hcl:"vpc_network,block"`
}

type SparkInfrastructureSpecAttributes 

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

func (SparkInfrastructureSpecAttributes) Batch 

func (is SparkInfrastructureSpecAttributes) Batch() terra.ListValue[SparkInfrastructureSpecBatchAttributes]

func (SparkInfrastructureSpecAttributes) ContainerImage 

func (is SparkInfrastructureSpecAttributes) ContainerImage() terra.ListValue[SparkInfrastructureSpecContainerImageAttributes]

func (SparkInfrastructureSpecAttributes) InternalRef 

func (is SparkInfrastructureSpecAttributes) InternalRef() (terra.Reference, error)

func (SparkInfrastructureSpecAttributes) InternalTokens 

func (is SparkInfrastructureSpecAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SparkInfrastructureSpecAttributes) InternalWithRef 

func (is SparkInfrastructureSpecAttributes) InternalWithRef(ref terra.Reference) SparkInfrastructureSpecAttributes

func (SparkInfrastructureSpecAttributes) VpcNetwork 

func (is SparkInfrastructureSpecAttributes) VpcNetwork() terra.ListValue[SparkInfrastructureSpecVpcNetworkAttributes]

type SparkInfrastructureSpecBatch 

type SparkInfrastructureSpecBatch struct {
	// ExecutorsCount: number, optional
	ExecutorsCount terra.NumberValue `hcl:"executors_count,attr"`
	// MaxExecutorsCount: number, optional
	MaxExecutorsCount terra.NumberValue `hcl:"max_executors_count,attr"`
}

type SparkInfrastructureSpecBatchAttributes 

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

func (SparkInfrastructureSpecBatchAttributes) ExecutorsCount 

func (b SparkInfrastructureSpecBatchAttributes) ExecutorsCount() terra.NumberValue

func (SparkInfrastructureSpecBatchAttributes) InternalRef 

func (b SparkInfrastructureSpecBatchAttributes) InternalRef() (terra.Reference, error)

func (SparkInfrastructureSpecBatchAttributes) InternalTokens 

func (b SparkInfrastructureSpecBatchAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SparkInfrastructureSpecBatchAttributes) InternalWithRef 

func (b SparkInfrastructureSpecBatchAttributes) InternalWithRef(ref terra.Reference) SparkInfrastructureSpecBatchAttributes

func (SparkInfrastructureSpecBatchAttributes) MaxExecutorsCount 

func (b SparkInfrastructureSpecBatchAttributes) MaxExecutorsCount() terra.NumberValue

type SparkInfrastructureSpecBatchState 

type SparkInfrastructureSpecBatchState struct {
	ExecutorsCount    float64 `json:"executors_count"`
	MaxExecutorsCount float64 `json:"max_executors_count"`
}

type SparkInfrastructureSpecContainerImage 

type SparkInfrastructureSpecContainerImage struct {
	// Image: string, optional
	Image terra.StringValue `hcl:"image,attr"`
	// JavaJars: list of string, optional
	JavaJars terra.ListValue[terra.StringValue] `hcl:"java_jars,attr"`
	// Properties: map of string, optional
	Properties terra.MapValue[terra.StringValue] `hcl:"properties,attr"`
	// PythonPackages: list of string, optional
	PythonPackages terra.ListValue[terra.StringValue] `hcl:"python_packages,attr"`
}

type SparkInfrastructureSpecContainerImageAttributes 

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

func (SparkInfrastructureSpecContainerImageAttributes) Image 

func (ci SparkInfrastructureSpecContainerImageAttributes) Image() terra.StringValue

func (SparkInfrastructureSpecContainerImageAttributes) InternalRef 

func (ci SparkInfrastructureSpecContainerImageAttributes) InternalRef() (terra.Reference, error)

func (SparkInfrastructureSpecContainerImageAttributes) InternalTokens 

func (ci SparkInfrastructureSpecContainerImageAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SparkInfrastructureSpecContainerImageAttributes) InternalWithRef 

func (ci SparkInfrastructureSpecContainerImageAttributes) InternalWithRef(ref terra.Reference) SparkInfrastructureSpecContainerImageAttributes

func (SparkInfrastructureSpecContainerImageAttributes) JavaJars 

func (ci SparkInfrastructureSpecContainerImageAttributes) JavaJars() terra.ListValue[terra.StringValue]

func (SparkInfrastructureSpecContainerImageAttributes) Properties 

func (ci SparkInfrastructureSpecContainerImageAttributes) Properties() terra.MapValue[terra.StringValue]

func (SparkInfrastructureSpecContainerImageAttributes) PythonPackages 

func (ci SparkInfrastructureSpecContainerImageAttributes) PythonPackages() terra.ListValue[terra.StringValue]

type SparkInfrastructureSpecContainerImageState 

type SparkInfrastructureSpecContainerImageState struct {
	Image          string            `json:"image"`
	JavaJars       []string          `json:"java_jars"`
	Properties     map[string]string `json:"properties"`
	PythonPackages []string          `json:"python_packages"`
}

type SparkInfrastructureSpecState 

type SparkInfrastructureSpecState struct {
	Batch          []SparkInfrastructureSpecBatchState          `json:"batch"`
	ContainerImage []SparkInfrastructureSpecContainerImageState `json:"container_image"`
	VpcNetwork     []SparkInfrastructureSpecVpcNetworkState     `json:"vpc_network"`
}

type SparkInfrastructureSpecVpcNetwork 

type SparkInfrastructureSpecVpcNetwork struct {
	// Network: string, optional
	Network terra.StringValue `hcl:"network,attr"`
	// NetworkTags: list of string, optional
	NetworkTags terra.ListValue[terra.StringValue] `hcl:"network_tags,attr"`
	// SubNetwork: string, optional
	SubNetwork terra.StringValue `hcl:"sub_network,attr"`
}

type SparkInfrastructureSpecVpcNetworkAttributes 

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

func (SparkInfrastructureSpecVpcNetworkAttributes) InternalRef 

func (vn SparkInfrastructureSpecVpcNetworkAttributes) InternalRef() (terra.Reference, error)

func (SparkInfrastructureSpecVpcNetworkAttributes) InternalTokens 

func (vn SparkInfrastructureSpecVpcNetworkAttributes) InternalTokens() (hclwrite.Tokens, error)

func (SparkInfrastructureSpecVpcNetworkAttributes) InternalWithRef 

func (vn SparkInfrastructureSpecVpcNetworkAttributes) InternalWithRef(ref terra.Reference) SparkInfrastructureSpecVpcNetworkAttributes

func (SparkInfrastructureSpecVpcNetworkAttributes) Network 

func (vn SparkInfrastructureSpecVpcNetworkAttributes) Network() terra.StringValue

func (SparkInfrastructureSpecVpcNetworkAttributes) NetworkTags 

func (vn SparkInfrastructureSpecVpcNetworkAttributes) NetworkTags() terra.ListValue[terra.StringValue]

func (SparkInfrastructureSpecVpcNetworkAttributes) SubNetwork 

func (vn SparkInfrastructureSpecVpcNetworkAttributes) SubNetwork() terra.StringValue

type SparkInfrastructureSpecVpcNetworkState 

type SparkInfrastructureSpecVpcNetworkState struct {
	Network     string   `json:"network"`
	NetworkTags []string `json:"network_tags"`
	SubNetwork  string   `json:"sub_network"`
}

type SparkState 

type SparkState struct {
	ArchiveUris        []string                       `json:"archive_uris"`
	FileUris           []string                       `json:"file_uris"`
	MainClass          string                         `json:"main_class"`
	MainJarFileUri     string                         `json:"main_jar_file_uri"`
	PythonScriptFile   string                         `json:"python_script_file"`
	SqlScript          string                         `json:"sql_script"`
	SqlScriptFile      string                         `json:"sql_script_file"`
	InfrastructureSpec []SparkInfrastructureSpecState `json:"infrastructure_spec"`
}

type Timeouts 

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

type TimeoutsAttributes 

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

func (TimeoutsAttributes) Create 

func (t TimeoutsAttributes) Create() terra.StringValue

func (TimeoutsAttributes) Delete 

func (t TimeoutsAttributes) Delete() terra.StringValue

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

func (TimeoutsAttributes) Update 

func (t TimeoutsAttributes) Update() terra.StringValue

type TimeoutsState 

type TimeoutsState struct {
	Create string `json:"create"`
	Delete string `json:"delete"`
	Update string `json:"update"`
}

type TriggerSpec 

type TriggerSpec struct {
	// Disabled: bool, optional
	Disabled terra.BoolValue `hcl:"disabled,attr"`
	// MaxRetries: number, optional
	MaxRetries terra.NumberValue `hcl:"max_retries,attr"`
	// Schedule: string, optional
	Schedule terra.StringValue `hcl:"schedule,attr"`
	// StartTime: string, optional
	StartTime terra.StringValue `hcl:"start_time,attr"`
	// Type: string, required
	Type terra.StringValue `hcl:"type,attr" validate:"required"`
}

type TriggerSpecAttributes 

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

func (TriggerSpecAttributes) Disabled 

func (ts TriggerSpecAttributes) Disabled() terra.BoolValue

func (TriggerSpecAttributes) InternalRef 

func (ts TriggerSpecAttributes) InternalRef() (terra.Reference, error)

func (TriggerSpecAttributes) InternalTokens 

func (ts TriggerSpecAttributes) InternalTokens() (hclwrite.Tokens, error)

func (TriggerSpecAttributes) InternalWithRef 

func (ts TriggerSpecAttributes) InternalWithRef(ref terra.Reference) TriggerSpecAttributes

func (TriggerSpecAttributes) MaxRetries 

func (ts TriggerSpecAttributes) MaxRetries() terra.NumberValue

func (TriggerSpecAttributes) Schedule 

func (ts TriggerSpecAttributes) Schedule() terra.StringValue

func (TriggerSpecAttributes) StartTime 

func (ts TriggerSpecAttributes) StartTime() terra.StringValue

func (TriggerSpecAttributes) Type 

func (ts TriggerSpecAttributes) Type() terra.StringValue

type TriggerSpecState 

type TriggerSpecState struct {
	Disabled   bool    `json:"disabled"`
	MaxRetries float64 `json:"max_retries"`
	Schedule   string  `json:"schedule"`
	StartTime  string  `json:"start_time"`
	Type       string  `json:"type"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.