spark

package
v3.76.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Ocean

type Ocean struct {
	pulumi.CustomResourceState

	Compute       OceanComputeOutput       `pulumi:"compute"`
	Ingress       OceanIngressOutput       `pulumi:"ingress"`
	LogCollection OceanLogCollectionOutput `pulumi:"logCollection"`
	// - The ID of the Ocean cluster that Ocean for Apache Spark should be installed on.
	OceanClusterId pulumi.StringOutput `pulumi:"oceanClusterId"`
	Spark          OceanSparkOutput    `pulumi:"spark"`
	Webhook        OceanWebhookOutput  `pulumi:"webhook"`
}

Manages a Spotinst Ocean Spark resource on AWS or GCP.

## Prerequisites

An existing Ocean cluster is required by this resource. See e.g. the `aws.Ocean` resource.

## Example Usage

```go package main

import (

"github.com/pulumi/pulumi-spotinst/sdk/v3/go/spotinst/spark"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := spark.NewOcean(ctx, "example", &spark.OceanArgs{
			OceanClusterId: pulumi.String("ocean-cluster-id"),
			Ingress: &spark.OceanIngressArgs{
				Controller: &spark.OceanIngressControllerArgs{
					Managed: pulumi.Bool(true),
				},
				LoadBalancer: &spark.OceanIngressLoadBalancerArgs{
					Managed:        pulumi.Bool(true),
					TargetGroupArn: pulumi.String("arn:aws:elasticloadbalancing:eu-north-1:XXXXXXXXXXXX:targetgroup/my-spark-cluster-nlb-tg/a38c2b83XXXXXXXX"),
					ServiceAnnotations: pulumi.StringMap{
						"service.beta.kubernetes.io/aws-load-balancer-security-groups": pulumi.String("sg-XXXXXXXXXXXXXXXXX"),
						"some-service-annotation-2":                                    pulumi.String("some-service-annotation-value-2"),
					},
				},
				CustomEndpoint: &spark.OceanIngressCustomEndpointArgs{
					Enabled: pulumi.Bool(false),
					Address: pulumi.String("my-spark-cluster-nlb-8cbb8da7XXXXXXXX.elb.us-east-1.amazonaws.com"),
				},
				PrivateLink: &spark.OceanIngressPrivateLinkArgs{
					Enabled:            pulumi.Bool(false),
					VpcEndpointService: pulumi.String("com.amazonaws.vpce.eu-north-1.vpce-svc-XXXXXXXXXXXXXXXXX"),
				},
			},
			Compute: &spark.OceanComputeArgs{
				CreateVngs: pulumi.Bool(true),
				UseTaints:  pulumi.Bool(true),
			},
			LogCollection: &spark.OceanLogCollectionArgs{
				CollectAppLogs: pulumi.Bool(true),
			},
			Webhook: &spark.OceanWebhookArgs{
				UseHostNetwork: pulumi.Bool(false),
				HostNetworkPorts: pulumi.IntArray{
					pulumi.Int(25554),
				},
			},
			Spark: &spark.OceanSparkArgs{
				AdditionalAppNamespaces: pulumi.StringArray{
					pulumi.String("extra-spark-app-ns-1"),
					pulumi.String("extra-spark-app-ns-2"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetOcean

func GetOcean(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OceanState, opts ...pulumi.ResourceOption) (*Ocean, error)

GetOcean gets an existing Ocean resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewOcean

func NewOcean(ctx *pulumi.Context,
	name string, args *OceanArgs, opts ...pulumi.ResourceOption) (*Ocean, error)

NewOcean registers a new resource with the given unique name, arguments, and options.

func (*Ocean) ElementType

func (*Ocean) ElementType() reflect.Type

func (*Ocean) ToOceanOutput

func (i *Ocean) ToOceanOutput() OceanOutput

func (*Ocean) ToOceanOutputWithContext

func (i *Ocean) ToOceanOutputWithContext(ctx context.Context) OceanOutput

type OceanArgs

type OceanArgs struct {
	Compute       OceanComputePtrInput
	Ingress       OceanIngressPtrInput
	LogCollection OceanLogCollectionPtrInput
	// - The ID of the Ocean cluster that Ocean for Apache Spark should be installed on.
	OceanClusterId pulumi.StringInput
	Spark          OceanSparkPtrInput
	Webhook        OceanWebhookPtrInput
}

The set of arguments for constructing a Ocean resource.

func (OceanArgs) ElementType

func (OceanArgs) ElementType() reflect.Type

type OceanArray

type OceanArray []OceanInput

func (OceanArray) ElementType

func (OceanArray) ElementType() reflect.Type

func (OceanArray) ToOceanArrayOutput

func (i OceanArray) ToOceanArrayOutput() OceanArrayOutput

func (OceanArray) ToOceanArrayOutputWithContext

func (i OceanArray) ToOceanArrayOutputWithContext(ctx context.Context) OceanArrayOutput

type OceanArrayInput

type OceanArrayInput interface {
	pulumi.Input

	ToOceanArrayOutput() OceanArrayOutput
	ToOceanArrayOutputWithContext(context.Context) OceanArrayOutput
}

OceanArrayInput is an input type that accepts OceanArray and OceanArrayOutput values. You can construct a concrete instance of `OceanArrayInput` via:

OceanArray{ OceanArgs{...} }

type OceanArrayOutput

type OceanArrayOutput struct{ *pulumi.OutputState }

func (OceanArrayOutput) ElementType

func (OceanArrayOutput) ElementType() reflect.Type

func (OceanArrayOutput) Index

func (OceanArrayOutput) ToOceanArrayOutput

func (o OceanArrayOutput) ToOceanArrayOutput() OceanArrayOutput

func (OceanArrayOutput) ToOceanArrayOutputWithContext

func (o OceanArrayOutput) ToOceanArrayOutputWithContext(ctx context.Context) OceanArrayOutput

type OceanCompute

type OceanCompute struct {
	// - Enable/disable the creation of Ocean Spark VNGs during cluster creation.
	CreateVngs *bool `pulumi:"createVngs"`
	// - Enable/disable Ocean Spark taints on the Ocean Spark VNGs. By default, Ocean Spark uses taints to prevent non-Spark workloads from running on Ocean Spark VNGs.
	UseTaints *bool `pulumi:"useTaints"`
}

type OceanComputeArgs

type OceanComputeArgs struct {
	// - Enable/disable the creation of Ocean Spark VNGs during cluster creation.
	CreateVngs pulumi.BoolPtrInput `pulumi:"createVngs"`
	// - Enable/disable Ocean Spark taints on the Ocean Spark VNGs. By default, Ocean Spark uses taints to prevent non-Spark workloads from running on Ocean Spark VNGs.
	UseTaints pulumi.BoolPtrInput `pulumi:"useTaints"`
}

func (OceanComputeArgs) ElementType

func (OceanComputeArgs) ElementType() reflect.Type

func (OceanComputeArgs) ToOceanComputeOutput

func (i OceanComputeArgs) ToOceanComputeOutput() OceanComputeOutput

func (OceanComputeArgs) ToOceanComputeOutputWithContext

func (i OceanComputeArgs) ToOceanComputeOutputWithContext(ctx context.Context) OceanComputeOutput

func (OceanComputeArgs) ToOceanComputePtrOutput

func (i OceanComputeArgs) ToOceanComputePtrOutput() OceanComputePtrOutput

func (OceanComputeArgs) ToOceanComputePtrOutputWithContext

func (i OceanComputeArgs) ToOceanComputePtrOutputWithContext(ctx context.Context) OceanComputePtrOutput

type OceanComputeInput

type OceanComputeInput interface {
	pulumi.Input

	ToOceanComputeOutput() OceanComputeOutput
	ToOceanComputeOutputWithContext(context.Context) OceanComputeOutput
}

OceanComputeInput is an input type that accepts OceanComputeArgs and OceanComputeOutput values. You can construct a concrete instance of `OceanComputeInput` via:

OceanComputeArgs{...}

type OceanComputeOutput

type OceanComputeOutput struct{ *pulumi.OutputState }

func (OceanComputeOutput) CreateVngs

func (o OceanComputeOutput) CreateVngs() pulumi.BoolPtrOutput

- Enable/disable the creation of Ocean Spark VNGs during cluster creation.

func (OceanComputeOutput) ElementType

func (OceanComputeOutput) ElementType() reflect.Type

func (OceanComputeOutput) ToOceanComputeOutput

func (o OceanComputeOutput) ToOceanComputeOutput() OceanComputeOutput

func (OceanComputeOutput) ToOceanComputeOutputWithContext

func (o OceanComputeOutput) ToOceanComputeOutputWithContext(ctx context.Context) OceanComputeOutput

func (OceanComputeOutput) ToOceanComputePtrOutput

func (o OceanComputeOutput) ToOceanComputePtrOutput() OceanComputePtrOutput

func (OceanComputeOutput) ToOceanComputePtrOutputWithContext

func (o OceanComputeOutput) ToOceanComputePtrOutputWithContext(ctx context.Context) OceanComputePtrOutput

func (OceanComputeOutput) UseTaints

func (o OceanComputeOutput) UseTaints() pulumi.BoolPtrOutput

- Enable/disable Ocean Spark taints on the Ocean Spark VNGs. By default, Ocean Spark uses taints to prevent non-Spark workloads from running on Ocean Spark VNGs.

type OceanComputePtrInput

type OceanComputePtrInput interface {
	pulumi.Input

	ToOceanComputePtrOutput() OceanComputePtrOutput
	ToOceanComputePtrOutputWithContext(context.Context) OceanComputePtrOutput
}

OceanComputePtrInput is an input type that accepts OceanComputeArgs, OceanComputePtr and OceanComputePtrOutput values. You can construct a concrete instance of `OceanComputePtrInput` via:

        OceanComputeArgs{...}

or:

        nil

type OceanComputePtrOutput

type OceanComputePtrOutput struct{ *pulumi.OutputState }

func (OceanComputePtrOutput) CreateVngs

- Enable/disable the creation of Ocean Spark VNGs during cluster creation.

func (OceanComputePtrOutput) Elem

func (OceanComputePtrOutput) ElementType

func (OceanComputePtrOutput) ElementType() reflect.Type

func (OceanComputePtrOutput) ToOceanComputePtrOutput

func (o OceanComputePtrOutput) ToOceanComputePtrOutput() OceanComputePtrOutput

func (OceanComputePtrOutput) ToOceanComputePtrOutputWithContext

func (o OceanComputePtrOutput) ToOceanComputePtrOutputWithContext(ctx context.Context) OceanComputePtrOutput

func (OceanComputePtrOutput) UseTaints

- Enable/disable Ocean Spark taints on the Ocean Spark VNGs. By default, Ocean Spark uses taints to prevent non-Spark workloads from running on Ocean Spark VNGs.

type OceanIngress

type OceanIngress struct {
	Controller     *OceanIngressController     `pulumi:"controller"`
	CustomEndpoint *OceanIngressCustomEndpoint `pulumi:"customEndpoint"`
	LoadBalancer   *OceanIngressLoadBalancer   `pulumi:"loadBalancer"`
	PrivateLink    *OceanIngressPrivateLink    `pulumi:"privateLink"`
	// - **DEPRECATED**: Use `load_balancer.service_annotations` instead.
	ServiceAnnotations map[string]string `pulumi:"serviceAnnotations"`
}

type OceanIngressArgs

type OceanIngressArgs struct {
	Controller     OceanIngressControllerPtrInput     `pulumi:"controller"`
	CustomEndpoint OceanIngressCustomEndpointPtrInput `pulumi:"customEndpoint"`
	LoadBalancer   OceanIngressLoadBalancerPtrInput   `pulumi:"loadBalancer"`
	PrivateLink    OceanIngressPrivateLinkPtrInput    `pulumi:"privateLink"`
	// - **DEPRECATED**: Use `load_balancer.service_annotations` instead.
	ServiceAnnotations pulumi.StringMapInput `pulumi:"serviceAnnotations"`
}

func (OceanIngressArgs) ElementType

func (OceanIngressArgs) ElementType() reflect.Type

func (OceanIngressArgs) ToOceanIngressOutput

func (i OceanIngressArgs) ToOceanIngressOutput() OceanIngressOutput

func (OceanIngressArgs) ToOceanIngressOutputWithContext

func (i OceanIngressArgs) ToOceanIngressOutputWithContext(ctx context.Context) OceanIngressOutput

func (OceanIngressArgs) ToOceanIngressPtrOutput

func (i OceanIngressArgs) ToOceanIngressPtrOutput() OceanIngressPtrOutput

func (OceanIngressArgs) ToOceanIngressPtrOutputWithContext

func (i OceanIngressArgs) ToOceanIngressPtrOutputWithContext(ctx context.Context) OceanIngressPtrOutput

type OceanIngressController

type OceanIngressController struct {
	// - Should an ingress controller managed by Ocean for Apache Spark be installed on the cluster.
	Managed *bool `pulumi:"managed"`
}

type OceanIngressControllerArgs

type OceanIngressControllerArgs struct {
	// - Should an ingress controller managed by Ocean for Apache Spark be installed on the cluster.
	Managed pulumi.BoolPtrInput `pulumi:"managed"`
}

func (OceanIngressControllerArgs) ElementType

func (OceanIngressControllerArgs) ElementType() reflect.Type

func (OceanIngressControllerArgs) ToOceanIngressControllerOutput

func (i OceanIngressControllerArgs) ToOceanIngressControllerOutput() OceanIngressControllerOutput

func (OceanIngressControllerArgs) ToOceanIngressControllerOutputWithContext

func (i OceanIngressControllerArgs) ToOceanIngressControllerOutputWithContext(ctx context.Context) OceanIngressControllerOutput

func (OceanIngressControllerArgs) ToOceanIngressControllerPtrOutput

func (i OceanIngressControllerArgs) ToOceanIngressControllerPtrOutput() OceanIngressControllerPtrOutput

func (OceanIngressControllerArgs) ToOceanIngressControllerPtrOutputWithContext

func (i OceanIngressControllerArgs) ToOceanIngressControllerPtrOutputWithContext(ctx context.Context) OceanIngressControllerPtrOutput

type OceanIngressControllerInput

type OceanIngressControllerInput interface {
	pulumi.Input

	ToOceanIngressControllerOutput() OceanIngressControllerOutput
	ToOceanIngressControllerOutputWithContext(context.Context) OceanIngressControllerOutput
}

OceanIngressControllerInput is an input type that accepts OceanIngressControllerArgs and OceanIngressControllerOutput values. You can construct a concrete instance of `OceanIngressControllerInput` via:

OceanIngressControllerArgs{...}

type OceanIngressControllerOutput

type OceanIngressControllerOutput struct{ *pulumi.OutputState }

func (OceanIngressControllerOutput) ElementType

func (OceanIngressControllerOutput) Managed

- Should an ingress controller managed by Ocean for Apache Spark be installed on the cluster.

func (OceanIngressControllerOutput) ToOceanIngressControllerOutput

func (o OceanIngressControllerOutput) ToOceanIngressControllerOutput() OceanIngressControllerOutput

func (OceanIngressControllerOutput) ToOceanIngressControllerOutputWithContext

func (o OceanIngressControllerOutput) ToOceanIngressControllerOutputWithContext(ctx context.Context) OceanIngressControllerOutput

func (OceanIngressControllerOutput) ToOceanIngressControllerPtrOutput

func (o OceanIngressControllerOutput) ToOceanIngressControllerPtrOutput() OceanIngressControllerPtrOutput

func (OceanIngressControllerOutput) ToOceanIngressControllerPtrOutputWithContext

func (o OceanIngressControllerOutput) ToOceanIngressControllerPtrOutputWithContext(ctx context.Context) OceanIngressControllerPtrOutput

type OceanIngressControllerPtrInput

type OceanIngressControllerPtrInput interface {
	pulumi.Input

	ToOceanIngressControllerPtrOutput() OceanIngressControllerPtrOutput
	ToOceanIngressControllerPtrOutputWithContext(context.Context) OceanIngressControllerPtrOutput
}

OceanIngressControllerPtrInput is an input type that accepts OceanIngressControllerArgs, OceanIngressControllerPtr and OceanIngressControllerPtrOutput values. You can construct a concrete instance of `OceanIngressControllerPtrInput` via:

        OceanIngressControllerArgs{...}

or:

        nil

type OceanIngressControllerPtrOutput

type OceanIngressControllerPtrOutput struct{ *pulumi.OutputState }

func (OceanIngressControllerPtrOutput) Elem

func (OceanIngressControllerPtrOutput) ElementType

func (OceanIngressControllerPtrOutput) Managed

- Should an ingress controller managed by Ocean for Apache Spark be installed on the cluster.

func (OceanIngressControllerPtrOutput) ToOceanIngressControllerPtrOutput

func (o OceanIngressControllerPtrOutput) ToOceanIngressControllerPtrOutput() OceanIngressControllerPtrOutput

func (OceanIngressControllerPtrOutput) ToOceanIngressControllerPtrOutputWithContext

func (o OceanIngressControllerPtrOutput) ToOceanIngressControllerPtrOutputWithContext(ctx context.Context) OceanIngressControllerPtrOutput

type OceanIngressCustomEndpoint

type OceanIngressCustomEndpoint struct {
	// - The address the Ocean for Apache Spark control plane will use when addressing the cluster.
	Address *string `pulumi:"address"`
	// - Should the Ocean for Apache Spark control plane address the cluster using a custom endpoint. Use this to specify the DNS address of an externally provisioned (unmanaged) load balancer.
	Enabled *bool `pulumi:"enabled"`
}

type OceanIngressCustomEndpointArgs

type OceanIngressCustomEndpointArgs struct {
	// - The address the Ocean for Apache Spark control plane will use when addressing the cluster.
	Address pulumi.StringPtrInput `pulumi:"address"`
	// - Should the Ocean for Apache Spark control plane address the cluster using a custom endpoint. Use this to specify the DNS address of an externally provisioned (unmanaged) load balancer.
	Enabled pulumi.BoolPtrInput `pulumi:"enabled"`
}

func (OceanIngressCustomEndpointArgs) ElementType

func (OceanIngressCustomEndpointArgs) ToOceanIngressCustomEndpointOutput

func (i OceanIngressCustomEndpointArgs) ToOceanIngressCustomEndpointOutput() OceanIngressCustomEndpointOutput

func (OceanIngressCustomEndpointArgs) ToOceanIngressCustomEndpointOutputWithContext

func (i OceanIngressCustomEndpointArgs) ToOceanIngressCustomEndpointOutputWithContext(ctx context.Context) OceanIngressCustomEndpointOutput

func (OceanIngressCustomEndpointArgs) ToOceanIngressCustomEndpointPtrOutput

func (i OceanIngressCustomEndpointArgs) ToOceanIngressCustomEndpointPtrOutput() OceanIngressCustomEndpointPtrOutput

func (OceanIngressCustomEndpointArgs) ToOceanIngressCustomEndpointPtrOutputWithContext

func (i OceanIngressCustomEndpointArgs) ToOceanIngressCustomEndpointPtrOutputWithContext(ctx context.Context) OceanIngressCustomEndpointPtrOutput

type OceanIngressCustomEndpointInput

type OceanIngressCustomEndpointInput interface {
	pulumi.Input

	ToOceanIngressCustomEndpointOutput() OceanIngressCustomEndpointOutput
	ToOceanIngressCustomEndpointOutputWithContext(context.Context) OceanIngressCustomEndpointOutput
}

OceanIngressCustomEndpointInput is an input type that accepts OceanIngressCustomEndpointArgs and OceanIngressCustomEndpointOutput values. You can construct a concrete instance of `OceanIngressCustomEndpointInput` via:

OceanIngressCustomEndpointArgs{...}

type OceanIngressCustomEndpointOutput

type OceanIngressCustomEndpointOutput struct{ *pulumi.OutputState }

func (OceanIngressCustomEndpointOutput) Address

- The address the Ocean for Apache Spark control plane will use when addressing the cluster.

func (OceanIngressCustomEndpointOutput) ElementType

func (OceanIngressCustomEndpointOutput) Enabled

- Should the Ocean for Apache Spark control plane address the cluster using a custom endpoint. Use this to specify the DNS address of an externally provisioned (unmanaged) load balancer.

func (OceanIngressCustomEndpointOutput) ToOceanIngressCustomEndpointOutput

func (o OceanIngressCustomEndpointOutput) ToOceanIngressCustomEndpointOutput() OceanIngressCustomEndpointOutput

func (OceanIngressCustomEndpointOutput) ToOceanIngressCustomEndpointOutputWithContext

func (o OceanIngressCustomEndpointOutput) ToOceanIngressCustomEndpointOutputWithContext(ctx context.Context) OceanIngressCustomEndpointOutput

func (OceanIngressCustomEndpointOutput) ToOceanIngressCustomEndpointPtrOutput

func (o OceanIngressCustomEndpointOutput) ToOceanIngressCustomEndpointPtrOutput() OceanIngressCustomEndpointPtrOutput

func (OceanIngressCustomEndpointOutput) ToOceanIngressCustomEndpointPtrOutputWithContext

func (o OceanIngressCustomEndpointOutput) ToOceanIngressCustomEndpointPtrOutputWithContext(ctx context.Context) OceanIngressCustomEndpointPtrOutput

type OceanIngressCustomEndpointPtrInput

type OceanIngressCustomEndpointPtrInput interface {
	pulumi.Input

	ToOceanIngressCustomEndpointPtrOutput() OceanIngressCustomEndpointPtrOutput
	ToOceanIngressCustomEndpointPtrOutputWithContext(context.Context) OceanIngressCustomEndpointPtrOutput
}

OceanIngressCustomEndpointPtrInput is an input type that accepts OceanIngressCustomEndpointArgs, OceanIngressCustomEndpointPtr and OceanIngressCustomEndpointPtrOutput values. You can construct a concrete instance of `OceanIngressCustomEndpointPtrInput` via:

        OceanIngressCustomEndpointArgs{...}

or:

        nil

type OceanIngressCustomEndpointPtrOutput

type OceanIngressCustomEndpointPtrOutput struct{ *pulumi.OutputState }

func (OceanIngressCustomEndpointPtrOutput) Address

- The address the Ocean for Apache Spark control plane will use when addressing the cluster.

func (OceanIngressCustomEndpointPtrOutput) Elem

func (OceanIngressCustomEndpointPtrOutput) ElementType

func (OceanIngressCustomEndpointPtrOutput) Enabled

- Should the Ocean for Apache Spark control plane address the cluster using a custom endpoint. Use this to specify the DNS address of an externally provisioned (unmanaged) load balancer.

func (OceanIngressCustomEndpointPtrOutput) ToOceanIngressCustomEndpointPtrOutput

func (o OceanIngressCustomEndpointPtrOutput) ToOceanIngressCustomEndpointPtrOutput() OceanIngressCustomEndpointPtrOutput

func (OceanIngressCustomEndpointPtrOutput) ToOceanIngressCustomEndpointPtrOutputWithContext

func (o OceanIngressCustomEndpointPtrOutput) ToOceanIngressCustomEndpointPtrOutputWithContext(ctx context.Context) OceanIngressCustomEndpointPtrOutput

type OceanIngressInput

type OceanIngressInput interface {
	pulumi.Input

	ToOceanIngressOutput() OceanIngressOutput
	ToOceanIngressOutputWithContext(context.Context) OceanIngressOutput
}

OceanIngressInput is an input type that accepts OceanIngressArgs and OceanIngressOutput values. You can construct a concrete instance of `OceanIngressInput` via:

OceanIngressArgs{...}

type OceanIngressLoadBalancer

type OceanIngressLoadBalancer struct {
	// - Should a load balancer managed by Ocean for Apache Spark be provisioned for the cluster. Set this to false if you want to use an existing load balancer (only available on AWS).
	Managed *bool `pulumi:"managed"`
	// - Annotations to add to the ingress controller load balancer service. This is useful to configure properties of the managed load balancer, like the nature of the load balancer (e.g. ELB, NLB, ALB on AWS), the security groups, or various timeouts.
	ServiceAnnotations map[string]string `pulumi:"serviceAnnotations"`
	// - The ARN of a target group that the Ocean for Apache Spark ingress controller will be bound to. Set this to use an existing load balancer with Ocean for Apache Spark. Has no effect if using a managed load balancer. Only available on AWS.
	TargetGroupArn *string `pulumi:"targetGroupArn"`
}

type OceanIngressLoadBalancerArgs

type OceanIngressLoadBalancerArgs struct {
	// - Should a load balancer managed by Ocean for Apache Spark be provisioned for the cluster. Set this to false if you want to use an existing load balancer (only available on AWS).
	Managed pulumi.BoolPtrInput `pulumi:"managed"`
	// - Annotations to add to the ingress controller load balancer service. This is useful to configure properties of the managed load balancer, like the nature of the load balancer (e.g. ELB, NLB, ALB on AWS), the security groups, or various timeouts.
	ServiceAnnotations pulumi.StringMapInput `pulumi:"serviceAnnotations"`
	// - The ARN of a target group that the Ocean for Apache Spark ingress controller will be bound to. Set this to use an existing load balancer with Ocean for Apache Spark. Has no effect if using a managed load balancer. Only available on AWS.
	TargetGroupArn pulumi.StringPtrInput `pulumi:"targetGroupArn"`
}

func (OceanIngressLoadBalancerArgs) ElementType

func (OceanIngressLoadBalancerArgs) ToOceanIngressLoadBalancerOutput

func (i OceanIngressLoadBalancerArgs) ToOceanIngressLoadBalancerOutput() OceanIngressLoadBalancerOutput

func (OceanIngressLoadBalancerArgs) ToOceanIngressLoadBalancerOutputWithContext

func (i OceanIngressLoadBalancerArgs) ToOceanIngressLoadBalancerOutputWithContext(ctx context.Context) OceanIngressLoadBalancerOutput

func (OceanIngressLoadBalancerArgs) ToOceanIngressLoadBalancerPtrOutput

func (i OceanIngressLoadBalancerArgs) ToOceanIngressLoadBalancerPtrOutput() OceanIngressLoadBalancerPtrOutput

func (OceanIngressLoadBalancerArgs) ToOceanIngressLoadBalancerPtrOutputWithContext

func (i OceanIngressLoadBalancerArgs) ToOceanIngressLoadBalancerPtrOutputWithContext(ctx context.Context) OceanIngressLoadBalancerPtrOutput

type OceanIngressLoadBalancerInput

type OceanIngressLoadBalancerInput interface {
	pulumi.Input

	ToOceanIngressLoadBalancerOutput() OceanIngressLoadBalancerOutput
	ToOceanIngressLoadBalancerOutputWithContext(context.Context) OceanIngressLoadBalancerOutput
}

OceanIngressLoadBalancerInput is an input type that accepts OceanIngressLoadBalancerArgs and OceanIngressLoadBalancerOutput values. You can construct a concrete instance of `OceanIngressLoadBalancerInput` via:

OceanIngressLoadBalancerArgs{...}

type OceanIngressLoadBalancerOutput

type OceanIngressLoadBalancerOutput struct{ *pulumi.OutputState }

func (OceanIngressLoadBalancerOutput) ElementType

func (OceanIngressLoadBalancerOutput) Managed

- Should a load balancer managed by Ocean for Apache Spark be provisioned for the cluster. Set this to false if you want to use an existing load balancer (only available on AWS).

func (OceanIngressLoadBalancerOutput) ServiceAnnotations

func (o OceanIngressLoadBalancerOutput) ServiceAnnotations() pulumi.StringMapOutput

- Annotations to add to the ingress controller load balancer service. This is useful to configure properties of the managed load balancer, like the nature of the load balancer (e.g. ELB, NLB, ALB on AWS), the security groups, or various timeouts.

func (OceanIngressLoadBalancerOutput) TargetGroupArn

- The ARN of a target group that the Ocean for Apache Spark ingress controller will be bound to. Set this to use an existing load balancer with Ocean for Apache Spark. Has no effect if using a managed load balancer. Only available on AWS.

func (OceanIngressLoadBalancerOutput) ToOceanIngressLoadBalancerOutput

func (o OceanIngressLoadBalancerOutput) ToOceanIngressLoadBalancerOutput() OceanIngressLoadBalancerOutput

func (OceanIngressLoadBalancerOutput) ToOceanIngressLoadBalancerOutputWithContext

func (o OceanIngressLoadBalancerOutput) ToOceanIngressLoadBalancerOutputWithContext(ctx context.Context) OceanIngressLoadBalancerOutput

func (OceanIngressLoadBalancerOutput) ToOceanIngressLoadBalancerPtrOutput

func (o OceanIngressLoadBalancerOutput) ToOceanIngressLoadBalancerPtrOutput() OceanIngressLoadBalancerPtrOutput

func (OceanIngressLoadBalancerOutput) ToOceanIngressLoadBalancerPtrOutputWithContext

func (o OceanIngressLoadBalancerOutput) ToOceanIngressLoadBalancerPtrOutputWithContext(ctx context.Context) OceanIngressLoadBalancerPtrOutput

type OceanIngressLoadBalancerPtrInput

type OceanIngressLoadBalancerPtrInput interface {
	pulumi.Input

	ToOceanIngressLoadBalancerPtrOutput() OceanIngressLoadBalancerPtrOutput
	ToOceanIngressLoadBalancerPtrOutputWithContext(context.Context) OceanIngressLoadBalancerPtrOutput
}

OceanIngressLoadBalancerPtrInput is an input type that accepts OceanIngressLoadBalancerArgs, OceanIngressLoadBalancerPtr and OceanIngressLoadBalancerPtrOutput values. You can construct a concrete instance of `OceanIngressLoadBalancerPtrInput` via:

        OceanIngressLoadBalancerArgs{...}

or:

        nil

type OceanIngressLoadBalancerPtrOutput

type OceanIngressLoadBalancerPtrOutput struct{ *pulumi.OutputState }

func (OceanIngressLoadBalancerPtrOutput) Elem

func (OceanIngressLoadBalancerPtrOutput) ElementType

func (OceanIngressLoadBalancerPtrOutput) Managed

- Should a load balancer managed by Ocean for Apache Spark be provisioned for the cluster. Set this to false if you want to use an existing load balancer (only available on AWS).

func (OceanIngressLoadBalancerPtrOutput) ServiceAnnotations

- Annotations to add to the ingress controller load balancer service. This is useful to configure properties of the managed load balancer, like the nature of the load balancer (e.g. ELB, NLB, ALB on AWS), the security groups, or various timeouts.

func (OceanIngressLoadBalancerPtrOutput) TargetGroupArn

- The ARN of a target group that the Ocean for Apache Spark ingress controller will be bound to. Set this to use an existing load balancer with Ocean for Apache Spark. Has no effect if using a managed load balancer. Only available on AWS.

func (OceanIngressLoadBalancerPtrOutput) ToOceanIngressLoadBalancerPtrOutput

func (o OceanIngressLoadBalancerPtrOutput) ToOceanIngressLoadBalancerPtrOutput() OceanIngressLoadBalancerPtrOutput

func (OceanIngressLoadBalancerPtrOutput) ToOceanIngressLoadBalancerPtrOutputWithContext

func (o OceanIngressLoadBalancerPtrOutput) ToOceanIngressLoadBalancerPtrOutputWithContext(ctx context.Context) OceanIngressLoadBalancerPtrOutput

type OceanIngressOutput

type OceanIngressOutput struct{ *pulumi.OutputState }

func (OceanIngressOutput) Controller

func (OceanIngressOutput) CustomEndpoint

func (OceanIngressOutput) ElementType

func (OceanIngressOutput) ElementType() reflect.Type

func (OceanIngressOutput) LoadBalancer

func (OceanIngressOutput) ServiceAnnotations

func (o OceanIngressOutput) ServiceAnnotations() pulumi.StringMapOutput

- **DEPRECATED**: Use `load_balancer.service_annotations` instead.

func (OceanIngressOutput) ToOceanIngressOutput

func (o OceanIngressOutput) ToOceanIngressOutput() OceanIngressOutput

func (OceanIngressOutput) ToOceanIngressOutputWithContext

func (o OceanIngressOutput) ToOceanIngressOutputWithContext(ctx context.Context) OceanIngressOutput

func (OceanIngressOutput) ToOceanIngressPtrOutput

func (o OceanIngressOutput) ToOceanIngressPtrOutput() OceanIngressPtrOutput

func (OceanIngressOutput) ToOceanIngressPtrOutputWithContext

func (o OceanIngressOutput) ToOceanIngressPtrOutputWithContext(ctx context.Context) OceanIngressPtrOutput
type OceanIngressPrivateLink struct {
	// - Should the Ocean for Apache Spark control plane address the cluster via an AWS Private Link. Only available on AWS.
	Enabled *bool `pulumi:"enabled"`
	// - The name of the VPC Endpoint Service the Ocean for Apache Spark control plane should bind to.
	VpcEndpointService *string `pulumi:"vpcEndpointService"`
}

type OceanIngressPrivateLinkArgs

type OceanIngressPrivateLinkArgs struct {
	// - Should the Ocean for Apache Spark control plane address the cluster via an AWS Private Link. Only available on AWS.
	Enabled pulumi.BoolPtrInput `pulumi:"enabled"`
	// - The name of the VPC Endpoint Service the Ocean for Apache Spark control plane should bind to.
	VpcEndpointService pulumi.StringPtrInput `pulumi:"vpcEndpointService"`
}

func (OceanIngressPrivateLinkArgs) ElementType

func (OceanIngressPrivateLinkArgs) ToOceanIngressPrivateLinkOutput

func (i OceanIngressPrivateLinkArgs) ToOceanIngressPrivateLinkOutput() OceanIngressPrivateLinkOutput

func (OceanIngressPrivateLinkArgs) ToOceanIngressPrivateLinkOutputWithContext

func (i OceanIngressPrivateLinkArgs) ToOceanIngressPrivateLinkOutputWithContext(ctx context.Context) OceanIngressPrivateLinkOutput

func (OceanIngressPrivateLinkArgs) ToOceanIngressPrivateLinkPtrOutput

func (i OceanIngressPrivateLinkArgs) ToOceanIngressPrivateLinkPtrOutput() OceanIngressPrivateLinkPtrOutput

func (OceanIngressPrivateLinkArgs) ToOceanIngressPrivateLinkPtrOutputWithContext

func (i OceanIngressPrivateLinkArgs) ToOceanIngressPrivateLinkPtrOutputWithContext(ctx context.Context) OceanIngressPrivateLinkPtrOutput

type OceanIngressPrivateLinkInput

type OceanIngressPrivateLinkInput interface {
	pulumi.Input

	ToOceanIngressPrivateLinkOutput() OceanIngressPrivateLinkOutput
	ToOceanIngressPrivateLinkOutputWithContext(context.Context) OceanIngressPrivateLinkOutput
}

OceanIngressPrivateLinkInput is an input type that accepts OceanIngressPrivateLinkArgs and OceanIngressPrivateLinkOutput values. You can construct a concrete instance of `OceanIngressPrivateLinkInput` via:

OceanIngressPrivateLinkArgs{...}

type OceanIngressPrivateLinkOutput

type OceanIngressPrivateLinkOutput struct{ *pulumi.OutputState }

func (OceanIngressPrivateLinkOutput) ElementType

func (OceanIngressPrivateLinkOutput) Enabled

- Should the Ocean for Apache Spark control plane address the cluster via an AWS Private Link. Only available on AWS.

func (OceanIngressPrivateLinkOutput) ToOceanIngressPrivateLinkOutput

func (o OceanIngressPrivateLinkOutput) ToOceanIngressPrivateLinkOutput() OceanIngressPrivateLinkOutput

func (OceanIngressPrivateLinkOutput) ToOceanIngressPrivateLinkOutputWithContext

func (o OceanIngressPrivateLinkOutput) ToOceanIngressPrivateLinkOutputWithContext(ctx context.Context) OceanIngressPrivateLinkOutput

func (OceanIngressPrivateLinkOutput) ToOceanIngressPrivateLinkPtrOutput

func (o OceanIngressPrivateLinkOutput) ToOceanIngressPrivateLinkPtrOutput() OceanIngressPrivateLinkPtrOutput

func (OceanIngressPrivateLinkOutput) ToOceanIngressPrivateLinkPtrOutputWithContext

func (o OceanIngressPrivateLinkOutput) ToOceanIngressPrivateLinkPtrOutputWithContext(ctx context.Context) OceanIngressPrivateLinkPtrOutput

func (OceanIngressPrivateLinkOutput) VpcEndpointService

func (o OceanIngressPrivateLinkOutput) VpcEndpointService() pulumi.StringPtrOutput

- The name of the VPC Endpoint Service the Ocean for Apache Spark control plane should bind to.

type OceanIngressPrivateLinkPtrInput

type OceanIngressPrivateLinkPtrInput interface {
	pulumi.Input

	ToOceanIngressPrivateLinkPtrOutput() OceanIngressPrivateLinkPtrOutput
	ToOceanIngressPrivateLinkPtrOutputWithContext(context.Context) OceanIngressPrivateLinkPtrOutput
}

OceanIngressPrivateLinkPtrInput is an input type that accepts OceanIngressPrivateLinkArgs, OceanIngressPrivateLinkPtr and OceanIngressPrivateLinkPtrOutput values. You can construct a concrete instance of `OceanIngressPrivateLinkPtrInput` via:

        OceanIngressPrivateLinkArgs{...}

or:

        nil

type OceanIngressPrivateLinkPtrOutput

type OceanIngressPrivateLinkPtrOutput struct{ *pulumi.OutputState }

func (OceanIngressPrivateLinkPtrOutput) Elem

func (OceanIngressPrivateLinkPtrOutput) ElementType

func (OceanIngressPrivateLinkPtrOutput) Enabled

- Should the Ocean for Apache Spark control plane address the cluster via an AWS Private Link. Only available on AWS.

func (OceanIngressPrivateLinkPtrOutput) ToOceanIngressPrivateLinkPtrOutput

func (o OceanIngressPrivateLinkPtrOutput) ToOceanIngressPrivateLinkPtrOutput() OceanIngressPrivateLinkPtrOutput

func (OceanIngressPrivateLinkPtrOutput) ToOceanIngressPrivateLinkPtrOutputWithContext

func (o OceanIngressPrivateLinkPtrOutput) ToOceanIngressPrivateLinkPtrOutputWithContext(ctx context.Context) OceanIngressPrivateLinkPtrOutput

func (OceanIngressPrivateLinkPtrOutput) VpcEndpointService

- The name of the VPC Endpoint Service the Ocean for Apache Spark control plane should bind to.

type OceanIngressPtrInput

type OceanIngressPtrInput interface {
	pulumi.Input

	ToOceanIngressPtrOutput() OceanIngressPtrOutput
	ToOceanIngressPtrOutputWithContext(context.Context) OceanIngressPtrOutput
}

OceanIngressPtrInput is an input type that accepts OceanIngressArgs, OceanIngressPtr and OceanIngressPtrOutput values. You can construct a concrete instance of `OceanIngressPtrInput` via:

        OceanIngressArgs{...}

or:

        nil

type OceanIngressPtrOutput

type OceanIngressPtrOutput struct{ *pulumi.OutputState }

func (OceanIngressPtrOutput) Controller

func (OceanIngressPtrOutput) CustomEndpoint

func (OceanIngressPtrOutput) Elem

func (OceanIngressPtrOutput) ElementType

func (OceanIngressPtrOutput) ElementType() reflect.Type

func (OceanIngressPtrOutput) LoadBalancer

func (OceanIngressPtrOutput) ServiceAnnotations

func (o OceanIngressPtrOutput) ServiceAnnotations() pulumi.StringMapOutput

- **DEPRECATED**: Use `load_balancer.service_annotations` instead.

func (OceanIngressPtrOutput) ToOceanIngressPtrOutput

func (o OceanIngressPtrOutput) ToOceanIngressPtrOutput() OceanIngressPtrOutput

func (OceanIngressPtrOutput) ToOceanIngressPtrOutputWithContext

func (o OceanIngressPtrOutput) ToOceanIngressPtrOutputWithContext(ctx context.Context) OceanIngressPtrOutput

type OceanInput

type OceanInput interface {
	pulumi.Input

	ToOceanOutput() OceanOutput
	ToOceanOutputWithContext(ctx context.Context) OceanOutput
}

type OceanLogCollection

type OceanLogCollection struct {
	// - Enable/Disable collecting driver and executor logs. When enabled, logs are stored by NetApp and can be downloaded from the Spot console web interface. The logs are deleted after 30 days.
	CollectAppLogs *bool `pulumi:"collectAppLogs"`
}

type OceanLogCollectionArgs

type OceanLogCollectionArgs struct {
	// - Enable/Disable collecting driver and executor logs. When enabled, logs are stored by NetApp and can be downloaded from the Spot console web interface. The logs are deleted after 30 days.
	CollectAppLogs pulumi.BoolPtrInput `pulumi:"collectAppLogs"`
}

func (OceanLogCollectionArgs) ElementType

func (OceanLogCollectionArgs) ElementType() reflect.Type

func (OceanLogCollectionArgs) ToOceanLogCollectionOutput

func (i OceanLogCollectionArgs) ToOceanLogCollectionOutput() OceanLogCollectionOutput

func (OceanLogCollectionArgs) ToOceanLogCollectionOutputWithContext

func (i OceanLogCollectionArgs) ToOceanLogCollectionOutputWithContext(ctx context.Context) OceanLogCollectionOutput

func (OceanLogCollectionArgs) ToOceanLogCollectionPtrOutput

func (i OceanLogCollectionArgs) ToOceanLogCollectionPtrOutput() OceanLogCollectionPtrOutput

func (OceanLogCollectionArgs) ToOceanLogCollectionPtrOutputWithContext

func (i OceanLogCollectionArgs) ToOceanLogCollectionPtrOutputWithContext(ctx context.Context) OceanLogCollectionPtrOutput

type OceanLogCollectionInput

type OceanLogCollectionInput interface {
	pulumi.Input

	ToOceanLogCollectionOutput() OceanLogCollectionOutput
	ToOceanLogCollectionOutputWithContext(context.Context) OceanLogCollectionOutput
}

OceanLogCollectionInput is an input type that accepts OceanLogCollectionArgs and OceanLogCollectionOutput values. You can construct a concrete instance of `OceanLogCollectionInput` via:

OceanLogCollectionArgs{...}

type OceanLogCollectionOutput

type OceanLogCollectionOutput struct{ *pulumi.OutputState }

func (OceanLogCollectionOutput) CollectAppLogs added in v3.32.0

func (o OceanLogCollectionOutput) CollectAppLogs() pulumi.BoolPtrOutput

- Enable/Disable collecting driver and executor logs. When enabled, logs are stored by NetApp and can be downloaded from the Spot console web interface. The logs are deleted after 30 days.

func (OceanLogCollectionOutput) ElementType

func (OceanLogCollectionOutput) ElementType() reflect.Type

func (OceanLogCollectionOutput) ToOceanLogCollectionOutput

func (o OceanLogCollectionOutput) ToOceanLogCollectionOutput() OceanLogCollectionOutput

func (OceanLogCollectionOutput) ToOceanLogCollectionOutputWithContext

func (o OceanLogCollectionOutput) ToOceanLogCollectionOutputWithContext(ctx context.Context) OceanLogCollectionOutput

func (OceanLogCollectionOutput) ToOceanLogCollectionPtrOutput

func (o OceanLogCollectionOutput) ToOceanLogCollectionPtrOutput() OceanLogCollectionPtrOutput

func (OceanLogCollectionOutput) ToOceanLogCollectionPtrOutputWithContext

func (o OceanLogCollectionOutput) ToOceanLogCollectionPtrOutputWithContext(ctx context.Context) OceanLogCollectionPtrOutput

type OceanLogCollectionPtrInput

type OceanLogCollectionPtrInput interface {
	pulumi.Input

	ToOceanLogCollectionPtrOutput() OceanLogCollectionPtrOutput
	ToOceanLogCollectionPtrOutputWithContext(context.Context) OceanLogCollectionPtrOutput
}

OceanLogCollectionPtrInput is an input type that accepts OceanLogCollectionArgs, OceanLogCollectionPtr and OceanLogCollectionPtrOutput values. You can construct a concrete instance of `OceanLogCollectionPtrInput` via:

        OceanLogCollectionArgs{...}

or:

        nil

type OceanLogCollectionPtrOutput

type OceanLogCollectionPtrOutput struct{ *pulumi.OutputState }

func (OceanLogCollectionPtrOutput) CollectAppLogs added in v3.32.0

- Enable/Disable collecting driver and executor logs. When enabled, logs are stored by NetApp and can be downloaded from the Spot console web interface. The logs are deleted after 30 days.

func (OceanLogCollectionPtrOutput) Elem

func (OceanLogCollectionPtrOutput) ElementType

func (OceanLogCollectionPtrOutput) ToOceanLogCollectionPtrOutput

func (o OceanLogCollectionPtrOutput) ToOceanLogCollectionPtrOutput() OceanLogCollectionPtrOutput

func (OceanLogCollectionPtrOutput) ToOceanLogCollectionPtrOutputWithContext

func (o OceanLogCollectionPtrOutput) ToOceanLogCollectionPtrOutputWithContext(ctx context.Context) OceanLogCollectionPtrOutput

type OceanMap

type OceanMap map[string]OceanInput

func (OceanMap) ElementType

func (OceanMap) ElementType() reflect.Type

func (OceanMap) ToOceanMapOutput

func (i OceanMap) ToOceanMapOutput() OceanMapOutput

func (OceanMap) ToOceanMapOutputWithContext

func (i OceanMap) ToOceanMapOutputWithContext(ctx context.Context) OceanMapOutput

type OceanMapInput

type OceanMapInput interface {
	pulumi.Input

	ToOceanMapOutput() OceanMapOutput
	ToOceanMapOutputWithContext(context.Context) OceanMapOutput
}

OceanMapInput is an input type that accepts OceanMap and OceanMapOutput values. You can construct a concrete instance of `OceanMapInput` via:

OceanMap{ "key": OceanArgs{...} }

type OceanMapOutput

type OceanMapOutput struct{ *pulumi.OutputState }

func (OceanMapOutput) ElementType

func (OceanMapOutput) ElementType() reflect.Type

func (OceanMapOutput) MapIndex

func (OceanMapOutput) ToOceanMapOutput

func (o OceanMapOutput) ToOceanMapOutput() OceanMapOutput

func (OceanMapOutput) ToOceanMapOutputWithContext

func (o OceanMapOutput) ToOceanMapOutputWithContext(ctx context.Context) OceanMapOutput

type OceanOutput

type OceanOutput struct{ *pulumi.OutputState }

func (OceanOutput) Compute

func (o OceanOutput) Compute() OceanComputeOutput

func (OceanOutput) ElementType

func (OceanOutput) ElementType() reflect.Type

func (OceanOutput) Ingress

func (o OceanOutput) Ingress() OceanIngressOutput

func (OceanOutput) LogCollection

func (o OceanOutput) LogCollection() OceanLogCollectionOutput

func (OceanOutput) OceanClusterId

func (o OceanOutput) OceanClusterId() pulumi.StringOutput

- The ID of the Ocean cluster that Ocean for Apache Spark should be installed on.

func (OceanOutput) Spark added in v3.26.0

func (o OceanOutput) Spark() OceanSparkOutput

func (OceanOutput) ToOceanOutput

func (o OceanOutput) ToOceanOutput() OceanOutput

func (OceanOutput) ToOceanOutputWithContext

func (o OceanOutput) ToOceanOutputWithContext(ctx context.Context) OceanOutput

func (OceanOutput) Webhook

func (o OceanOutput) Webhook() OceanWebhookOutput

type OceanSpark added in v3.26.0

type OceanSpark struct {
	// - List of Kubernetes namespaces that should be configured to run Spark applications, in addition to the default Spark application namespace `spark-apps`.
	AdditionalAppNamespaces []string `pulumi:"additionalAppNamespaces"`
}

type OceanSparkArgs added in v3.26.0

type OceanSparkArgs struct {
	// - List of Kubernetes namespaces that should be configured to run Spark applications, in addition to the default Spark application namespace `spark-apps`.
	AdditionalAppNamespaces pulumi.StringArrayInput `pulumi:"additionalAppNamespaces"`
}

func (OceanSparkArgs) ElementType added in v3.26.0

func (OceanSparkArgs) ElementType() reflect.Type

func (OceanSparkArgs) ToOceanSparkOutput added in v3.26.0

func (i OceanSparkArgs) ToOceanSparkOutput() OceanSparkOutput

func (OceanSparkArgs) ToOceanSparkOutputWithContext added in v3.26.0

func (i OceanSparkArgs) ToOceanSparkOutputWithContext(ctx context.Context) OceanSparkOutput

func (OceanSparkArgs) ToOceanSparkPtrOutput added in v3.26.0

func (i OceanSparkArgs) ToOceanSparkPtrOutput() OceanSparkPtrOutput

func (OceanSparkArgs) ToOceanSparkPtrOutputWithContext added in v3.26.0

func (i OceanSparkArgs) ToOceanSparkPtrOutputWithContext(ctx context.Context) OceanSparkPtrOutput

type OceanSparkInput added in v3.26.0

type OceanSparkInput interface {
	pulumi.Input

	ToOceanSparkOutput() OceanSparkOutput
	ToOceanSparkOutputWithContext(context.Context) OceanSparkOutput
}

OceanSparkInput is an input type that accepts OceanSparkArgs and OceanSparkOutput values. You can construct a concrete instance of `OceanSparkInput` via:

OceanSparkArgs{...}

type OceanSparkOutput added in v3.26.0

type OceanSparkOutput struct{ *pulumi.OutputState }

func (OceanSparkOutput) AdditionalAppNamespaces added in v3.26.0

func (o OceanSparkOutput) AdditionalAppNamespaces() pulumi.StringArrayOutput

- List of Kubernetes namespaces that should be configured to run Spark applications, in addition to the default Spark application namespace `spark-apps`.

func (OceanSparkOutput) ElementType added in v3.26.0

func (OceanSparkOutput) ElementType() reflect.Type

func (OceanSparkOutput) ToOceanSparkOutput added in v3.26.0

func (o OceanSparkOutput) ToOceanSparkOutput() OceanSparkOutput

func (OceanSparkOutput) ToOceanSparkOutputWithContext added in v3.26.0

func (o OceanSparkOutput) ToOceanSparkOutputWithContext(ctx context.Context) OceanSparkOutput

func (OceanSparkOutput) ToOceanSparkPtrOutput added in v3.26.0

func (o OceanSparkOutput) ToOceanSparkPtrOutput() OceanSparkPtrOutput

func (OceanSparkOutput) ToOceanSparkPtrOutputWithContext added in v3.26.0

func (o OceanSparkOutput) ToOceanSparkPtrOutputWithContext(ctx context.Context) OceanSparkPtrOutput

type OceanSparkPtrInput added in v3.26.0

type OceanSparkPtrInput interface {
	pulumi.Input

	ToOceanSparkPtrOutput() OceanSparkPtrOutput
	ToOceanSparkPtrOutputWithContext(context.Context) OceanSparkPtrOutput
}

OceanSparkPtrInput is an input type that accepts OceanSparkArgs, OceanSparkPtr and OceanSparkPtrOutput values. You can construct a concrete instance of `OceanSparkPtrInput` via:

        OceanSparkArgs{...}

or:

        nil

func OceanSparkPtr added in v3.26.0

func OceanSparkPtr(v *OceanSparkArgs) OceanSparkPtrInput

type OceanSparkPtrOutput added in v3.26.0

type OceanSparkPtrOutput struct{ *pulumi.OutputState }

func (OceanSparkPtrOutput) AdditionalAppNamespaces added in v3.26.0

func (o OceanSparkPtrOutput) AdditionalAppNamespaces() pulumi.StringArrayOutput

- List of Kubernetes namespaces that should be configured to run Spark applications, in addition to the default Spark application namespace `spark-apps`.

func (OceanSparkPtrOutput) Elem added in v3.26.0

func (OceanSparkPtrOutput) ElementType added in v3.26.0

func (OceanSparkPtrOutput) ElementType() reflect.Type

func (OceanSparkPtrOutput) ToOceanSparkPtrOutput added in v3.26.0

func (o OceanSparkPtrOutput) ToOceanSparkPtrOutput() OceanSparkPtrOutput

func (OceanSparkPtrOutput) ToOceanSparkPtrOutputWithContext added in v3.26.0

func (o OceanSparkPtrOutput) ToOceanSparkPtrOutputWithContext(ctx context.Context) OceanSparkPtrOutput

type OceanState

type OceanState struct {
	Compute       OceanComputePtrInput
	Ingress       OceanIngressPtrInput
	LogCollection OceanLogCollectionPtrInput
	// - The ID of the Ocean cluster that Ocean for Apache Spark should be installed on.
	OceanClusterId pulumi.StringPtrInput
	Spark          OceanSparkPtrInput
	Webhook        OceanWebhookPtrInput
}

func (OceanState) ElementType

func (OceanState) ElementType() reflect.Type

type OceanVirtualNodeGroup added in v3.26.0

type OceanVirtualNodeGroup struct {
	pulumi.CustomResourceState

	OceanSparkClusterId pulumi.StringOutput `pulumi:"oceanSparkClusterId"`
	VirtualNodeGroupId  pulumi.StringOutput `pulumi:"virtualNodeGroupId"`
}

Manage a dedicated Spotinst Ocean Spark Virtual Node Group resource

## Prerequisites

An existing Ocean cluster and Ocean VNG is required by this resource

## Example Usage

```go package main

import (

"github.com/pulumi/pulumi-spotinst/sdk/v3/go/spotinst/spark"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := spark.NewOceanVirtualNodeGroup(ctx, "example", &spark.OceanVirtualNodeGroupArgs{
			VirtualNodeGroupId:  pulumi.String("vng_id"),
			OceanSparkClusterId: pulumi.String("cluster_id"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

func GetOceanVirtualNodeGroup added in v3.26.0

func GetOceanVirtualNodeGroup(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OceanVirtualNodeGroupState, opts ...pulumi.ResourceOption) (*OceanVirtualNodeGroup, error)

GetOceanVirtualNodeGroup gets an existing OceanVirtualNodeGroup resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewOceanVirtualNodeGroup added in v3.26.0

func NewOceanVirtualNodeGroup(ctx *pulumi.Context,
	name string, args *OceanVirtualNodeGroupArgs, opts ...pulumi.ResourceOption) (*OceanVirtualNodeGroup, error)

NewOceanVirtualNodeGroup registers a new resource with the given unique name, arguments, and options.

func (*OceanVirtualNodeGroup) ElementType added in v3.26.0

func (*OceanVirtualNodeGroup) ElementType() reflect.Type

func (*OceanVirtualNodeGroup) ToOceanVirtualNodeGroupOutput added in v3.26.0

func (i *OceanVirtualNodeGroup) ToOceanVirtualNodeGroupOutput() OceanVirtualNodeGroupOutput

func (*OceanVirtualNodeGroup) ToOceanVirtualNodeGroupOutputWithContext added in v3.26.0

func (i *OceanVirtualNodeGroup) ToOceanVirtualNodeGroupOutputWithContext(ctx context.Context) OceanVirtualNodeGroupOutput

type OceanVirtualNodeGroupArgs added in v3.26.0

type OceanVirtualNodeGroupArgs struct {
	OceanSparkClusterId pulumi.StringInput
	VirtualNodeGroupId  pulumi.StringInput
}

The set of arguments for constructing a OceanVirtualNodeGroup resource.

func (OceanVirtualNodeGroupArgs) ElementType added in v3.26.0

func (OceanVirtualNodeGroupArgs) ElementType() reflect.Type

type OceanVirtualNodeGroupArray added in v3.26.0

type OceanVirtualNodeGroupArray []OceanVirtualNodeGroupInput

func (OceanVirtualNodeGroupArray) ElementType added in v3.26.0

func (OceanVirtualNodeGroupArray) ElementType() reflect.Type

func (OceanVirtualNodeGroupArray) ToOceanVirtualNodeGroupArrayOutput added in v3.26.0

func (i OceanVirtualNodeGroupArray) ToOceanVirtualNodeGroupArrayOutput() OceanVirtualNodeGroupArrayOutput

func (OceanVirtualNodeGroupArray) ToOceanVirtualNodeGroupArrayOutputWithContext added in v3.26.0

func (i OceanVirtualNodeGroupArray) ToOceanVirtualNodeGroupArrayOutputWithContext(ctx context.Context) OceanVirtualNodeGroupArrayOutput

type OceanVirtualNodeGroupArrayInput added in v3.26.0

type OceanVirtualNodeGroupArrayInput interface {
	pulumi.Input

	ToOceanVirtualNodeGroupArrayOutput() OceanVirtualNodeGroupArrayOutput
	ToOceanVirtualNodeGroupArrayOutputWithContext(context.Context) OceanVirtualNodeGroupArrayOutput
}

OceanVirtualNodeGroupArrayInput is an input type that accepts OceanVirtualNodeGroupArray and OceanVirtualNodeGroupArrayOutput values. You can construct a concrete instance of `OceanVirtualNodeGroupArrayInput` via:

OceanVirtualNodeGroupArray{ OceanVirtualNodeGroupArgs{...} }

type OceanVirtualNodeGroupArrayOutput added in v3.26.0

type OceanVirtualNodeGroupArrayOutput struct{ *pulumi.OutputState }

func (OceanVirtualNodeGroupArrayOutput) ElementType added in v3.26.0

func (OceanVirtualNodeGroupArrayOutput) Index added in v3.26.0

func (OceanVirtualNodeGroupArrayOutput) ToOceanVirtualNodeGroupArrayOutput added in v3.26.0

func (o OceanVirtualNodeGroupArrayOutput) ToOceanVirtualNodeGroupArrayOutput() OceanVirtualNodeGroupArrayOutput

func (OceanVirtualNodeGroupArrayOutput) ToOceanVirtualNodeGroupArrayOutputWithContext added in v3.26.0

func (o OceanVirtualNodeGroupArrayOutput) ToOceanVirtualNodeGroupArrayOutputWithContext(ctx context.Context) OceanVirtualNodeGroupArrayOutput

type OceanVirtualNodeGroupInput added in v3.26.0

type OceanVirtualNodeGroupInput interface {
	pulumi.Input

	ToOceanVirtualNodeGroupOutput() OceanVirtualNodeGroupOutput
	ToOceanVirtualNodeGroupOutputWithContext(ctx context.Context) OceanVirtualNodeGroupOutput
}

type OceanVirtualNodeGroupMap added in v3.26.0

type OceanVirtualNodeGroupMap map[string]OceanVirtualNodeGroupInput

func (OceanVirtualNodeGroupMap) ElementType added in v3.26.0

func (OceanVirtualNodeGroupMap) ElementType() reflect.Type

func (OceanVirtualNodeGroupMap) ToOceanVirtualNodeGroupMapOutput added in v3.26.0

func (i OceanVirtualNodeGroupMap) ToOceanVirtualNodeGroupMapOutput() OceanVirtualNodeGroupMapOutput

func (OceanVirtualNodeGroupMap) ToOceanVirtualNodeGroupMapOutputWithContext added in v3.26.0

func (i OceanVirtualNodeGroupMap) ToOceanVirtualNodeGroupMapOutputWithContext(ctx context.Context) OceanVirtualNodeGroupMapOutput

type OceanVirtualNodeGroupMapInput added in v3.26.0

type OceanVirtualNodeGroupMapInput interface {
	pulumi.Input

	ToOceanVirtualNodeGroupMapOutput() OceanVirtualNodeGroupMapOutput
	ToOceanVirtualNodeGroupMapOutputWithContext(context.Context) OceanVirtualNodeGroupMapOutput
}

OceanVirtualNodeGroupMapInput is an input type that accepts OceanVirtualNodeGroupMap and OceanVirtualNodeGroupMapOutput values. You can construct a concrete instance of `OceanVirtualNodeGroupMapInput` via:

OceanVirtualNodeGroupMap{ "key": OceanVirtualNodeGroupArgs{...} }

type OceanVirtualNodeGroupMapOutput added in v3.26.0

type OceanVirtualNodeGroupMapOutput struct{ *pulumi.OutputState }

func (OceanVirtualNodeGroupMapOutput) ElementType added in v3.26.0

func (OceanVirtualNodeGroupMapOutput) MapIndex added in v3.26.0

func (OceanVirtualNodeGroupMapOutput) ToOceanVirtualNodeGroupMapOutput added in v3.26.0

func (o OceanVirtualNodeGroupMapOutput) ToOceanVirtualNodeGroupMapOutput() OceanVirtualNodeGroupMapOutput

func (OceanVirtualNodeGroupMapOutput) ToOceanVirtualNodeGroupMapOutputWithContext added in v3.26.0

func (o OceanVirtualNodeGroupMapOutput) ToOceanVirtualNodeGroupMapOutputWithContext(ctx context.Context) OceanVirtualNodeGroupMapOutput

type OceanVirtualNodeGroupOutput added in v3.26.0

type OceanVirtualNodeGroupOutput struct{ *pulumi.OutputState }

func (OceanVirtualNodeGroupOutput) ElementType added in v3.26.0

func (OceanVirtualNodeGroupOutput) OceanSparkClusterId added in v3.26.0

func (o OceanVirtualNodeGroupOutput) OceanSparkClusterId() pulumi.StringOutput

func (OceanVirtualNodeGroupOutput) ToOceanVirtualNodeGroupOutput added in v3.26.0

func (o OceanVirtualNodeGroupOutput) ToOceanVirtualNodeGroupOutput() OceanVirtualNodeGroupOutput

func (OceanVirtualNodeGroupOutput) ToOceanVirtualNodeGroupOutputWithContext added in v3.26.0

func (o OceanVirtualNodeGroupOutput) ToOceanVirtualNodeGroupOutputWithContext(ctx context.Context) OceanVirtualNodeGroupOutput

func (OceanVirtualNodeGroupOutput) VirtualNodeGroupId added in v3.26.0

func (o OceanVirtualNodeGroupOutput) VirtualNodeGroupId() pulumi.StringOutput

type OceanVirtualNodeGroupState added in v3.26.0

type OceanVirtualNodeGroupState struct {
	OceanSparkClusterId pulumi.StringPtrInput
	VirtualNodeGroupId  pulumi.StringPtrInput
}

func (OceanVirtualNodeGroupState) ElementType added in v3.26.0

func (OceanVirtualNodeGroupState) ElementType() reflect.Type

type OceanWebhook

type OceanWebhook struct {
	// - List of ports allowed to use on the host network - if empty default is `25554`.
	HostNetworkPorts []int `pulumi:"hostNetworkPorts"`
	// - Enable/disable host networking for the Spark Operator. Host networking can be useful when using custom CNI plugins like Calico on EKS.
	UseHostNetwork *bool `pulumi:"useHostNetwork"`
}

type OceanWebhookArgs

type OceanWebhookArgs struct {
	// - List of ports allowed to use on the host network - if empty default is `25554`.
	HostNetworkPorts pulumi.IntArrayInput `pulumi:"hostNetworkPorts"`
	// - Enable/disable host networking for the Spark Operator. Host networking can be useful when using custom CNI plugins like Calico on EKS.
	UseHostNetwork pulumi.BoolPtrInput `pulumi:"useHostNetwork"`
}

func (OceanWebhookArgs) ElementType

func (OceanWebhookArgs) ElementType() reflect.Type

func (OceanWebhookArgs) ToOceanWebhookOutput

func (i OceanWebhookArgs) ToOceanWebhookOutput() OceanWebhookOutput

func (OceanWebhookArgs) ToOceanWebhookOutputWithContext

func (i OceanWebhookArgs) ToOceanWebhookOutputWithContext(ctx context.Context) OceanWebhookOutput

func (OceanWebhookArgs) ToOceanWebhookPtrOutput

func (i OceanWebhookArgs) ToOceanWebhookPtrOutput() OceanWebhookPtrOutput

func (OceanWebhookArgs) ToOceanWebhookPtrOutputWithContext

func (i OceanWebhookArgs) ToOceanWebhookPtrOutputWithContext(ctx context.Context) OceanWebhookPtrOutput

type OceanWebhookInput

type OceanWebhookInput interface {
	pulumi.Input

	ToOceanWebhookOutput() OceanWebhookOutput
	ToOceanWebhookOutputWithContext(context.Context) OceanWebhookOutput
}

OceanWebhookInput is an input type that accepts OceanWebhookArgs and OceanWebhookOutput values. You can construct a concrete instance of `OceanWebhookInput` via:

OceanWebhookArgs{...}

type OceanWebhookOutput

type OceanWebhookOutput struct{ *pulumi.OutputState }

func (OceanWebhookOutput) ElementType

func (OceanWebhookOutput) ElementType() reflect.Type

func (OceanWebhookOutput) HostNetworkPorts

func (o OceanWebhookOutput) HostNetworkPorts() pulumi.IntArrayOutput

- List of ports allowed to use on the host network - if empty default is `25554`.

func (OceanWebhookOutput) ToOceanWebhookOutput

func (o OceanWebhookOutput) ToOceanWebhookOutput() OceanWebhookOutput

func (OceanWebhookOutput) ToOceanWebhookOutputWithContext

func (o OceanWebhookOutput) ToOceanWebhookOutputWithContext(ctx context.Context) OceanWebhookOutput

func (OceanWebhookOutput) ToOceanWebhookPtrOutput

func (o OceanWebhookOutput) ToOceanWebhookPtrOutput() OceanWebhookPtrOutput

func (OceanWebhookOutput) ToOceanWebhookPtrOutputWithContext

func (o OceanWebhookOutput) ToOceanWebhookPtrOutputWithContext(ctx context.Context) OceanWebhookPtrOutput

func (OceanWebhookOutput) UseHostNetwork

func (o OceanWebhookOutput) UseHostNetwork() pulumi.BoolPtrOutput

- Enable/disable host networking for the Spark Operator. Host networking can be useful when using custom CNI plugins like Calico on EKS.

type OceanWebhookPtrInput

type OceanWebhookPtrInput interface {
	pulumi.Input

	ToOceanWebhookPtrOutput() OceanWebhookPtrOutput
	ToOceanWebhookPtrOutputWithContext(context.Context) OceanWebhookPtrOutput
}

OceanWebhookPtrInput is an input type that accepts OceanWebhookArgs, OceanWebhookPtr and OceanWebhookPtrOutput values. You can construct a concrete instance of `OceanWebhookPtrInput` via:

        OceanWebhookArgs{...}

or:

        nil

type OceanWebhookPtrOutput

type OceanWebhookPtrOutput struct{ *pulumi.OutputState }

func (OceanWebhookPtrOutput) Elem

func (OceanWebhookPtrOutput) ElementType

func (OceanWebhookPtrOutput) ElementType() reflect.Type

func (OceanWebhookPtrOutput) HostNetworkPorts

func (o OceanWebhookPtrOutput) HostNetworkPorts() pulumi.IntArrayOutput

- List of ports allowed to use on the host network - if empty default is `25554`.

func (OceanWebhookPtrOutput) ToOceanWebhookPtrOutput

func (o OceanWebhookPtrOutput) ToOceanWebhookPtrOutput() OceanWebhookPtrOutput

func (OceanWebhookPtrOutput) ToOceanWebhookPtrOutputWithContext

func (o OceanWebhookPtrOutput) ToOceanWebhookPtrOutputWithContext(ctx context.Context) OceanWebhookPtrOutput

func (OceanWebhookPtrOutput) UseHostNetwork

func (o OceanWebhookPtrOutput) UseHostNetwork() pulumi.BoolPtrOutput

- Enable/disable host networking for the Spark Operator. Host networking can be useful when using custom CNI plugins like Calico on EKS.

Jump to

Keyboard shortcuts

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