opensearchingest

package
v6.32.0 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 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 Pipeline 

type Pipeline struct {
	pulumi.CustomResourceState

	// Key-value pairs to configure persistent buffering for the pipeline. See `bufferOptions` below.
	BufferOptions PipelineBufferOptionsPtrOutput `pulumi:"bufferOptions"`
	// Key-value pairs to configure encryption for data that is written to a persistent buffer. See `encryptionAtRestOptions` below.
	EncryptionAtRestOptions PipelineEncryptionAtRestOptionsPtrOutput `pulumi:"encryptionAtRestOptions"`
	// The list of ingestion endpoints for the pipeline, which you can send data to.
	IngestEndpointUrls pulumi.StringArrayOutput `pulumi:"ingestEndpointUrls"`
	// Key-value pairs to configure log publishing. See `logPublishingOptions` below.
	LogPublishingOptions PipelineLogPublishingOptionsPtrOutput `pulumi:"logPublishingOptions"`
	// The maximum pipeline capacity, in Ingestion Compute Units (ICUs).
	MaxUnits pulumi.IntOutput `pulumi:"maxUnits"`
	// The minimum pipeline capacity, in Ingestion Compute Units (ICUs).
	MinUnits pulumi.IntOutput `pulumi:"minUnits"`
	// Amazon Resource Name (ARN) of the pipeline.
	PipelineArn pulumi.StringOutput `pulumi:"pipelineArn"`
	// The pipeline configuration in YAML format. This argument accepts the pipeline configuration as a string or within a .yaml file. If you provide the configuration as a string, each new line must be escaped with \n.
	PipelineConfigurationBody pulumi.StringOutput `pulumi:"pipelineConfigurationBody"`
	// The name of the OpenSearch Ingestion pipeline to create. Pipeline names are unique across the pipelines owned by an account within an AWS Region.
	//
	// The following arguments are optional:
	PipelineName pulumi.StringOutput `pulumi:"pipelineName"`
	// A map of tags to assign to the pipeline. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// Deprecated: Please use `tags` instead.
	TagsAll  pulumi.StringMapOutput    `pulumi:"tagsAll"`
	Timeouts PipelineTimeoutsPtrOutput `pulumi:"timeouts"`
	// Container for the values required to configure VPC access for the pipeline. If you don't specify these values, OpenSearch Ingestion creates the pipeline with a public endpoint. See `vpcOptions` below.
	VpcOptions PipelineVpcOptionsPtrOutput `pulumi:"vpcOptions"`
}

Resource for managing an AWS OpenSearch Ingestion Pipeline.

## Example Usage

### Basic Usage

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"encoding/json"
"fmt"

"github.com/pulumi/pulumi-aws/sdk/v6/go/aws"
"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/iam"
"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/opensearchingest"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		current, err := aws.GetRegion(ctx, nil, nil)
		if err != nil {
			return err
		}
		tmpJSON0, err := json.Marshal(map[string]interface{}{
			"Version": "2012-10-17",
			"Statement": []map[string]interface{}{
				map[string]interface{}{
					"Action": "sts:AssumeRole",
					"Effect": "Allow",
					"Sid":    "",
					"Principal": map[string]interface{}{
						"Service": "osis-pipelines.amazonaws.com",
					},
				},
			},
		})
		if err != nil {
			return err
		}
		json0 := string(tmpJSON0)
		example, err := iam.NewRole(ctx, "example", &iam.RoleArgs{
			AssumeRolePolicy: pulumi.String(json0),
		})
		if err != nil {
			return err
		}
		_, err = opensearchingest.NewPipeline(ctx, "example", &opensearchingest.PipelineArgs{
			PipelineName: pulumi.String("example"),
			PipelineConfigurationBody: example.Arn.ApplyT(func(arn string) (string, error) {
				return fmt.Sprintf(`version: "2"

example-pipeline: 

source:
  http:
    path: "/example"
sink:
  - s3:
      aws:
        sts_role_arn: "%v"
        region: "%v"
      bucket: "example"
      threshold:
        event_collect_timeout: "60s"
      codec:
        ndjson:

`, arn, current.Name), nil 

			}).(pulumi.StringOutput),
			MaxUnits: pulumi.Int(1),
			MinUnits: pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` <!--End PulumiCodeChooser -->

### Using file function

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/opensearchingest"
"github.com/pulumi/pulumi-std/sdk/go/std"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		invokeFile, err := std.File(ctx, &std.FileArgs{
			Input: "example.yaml",
		}, nil)
		if err != nil {
			return err
		}
		_, err = opensearchingest.NewPipeline(ctx, "example", &opensearchingest.PipelineArgs{
			PipelineName:              pulumi.String("example"),
			PipelineConfigurationBody: invokeFile.Result,
			MaxUnits:                  pulumi.Int(1),
			MinUnits:                  pulumi.Int(1),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` <!--End PulumiCodeChooser -->

## Import

Using `pulumi import`, import OpenSearch Ingestion Pipeline using the `id`. For example:

```sh $ pulumi import aws:opensearchingest/pipeline:Pipeline example example ```

func GetPipeline 

func GetPipeline(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *PipelineState, opts ...pulumi.ResourceOption) (*Pipeline, error)

GetPipeline gets an existing Pipeline 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 NewPipeline 

func NewPipeline(ctx *pulumi.Context,
	name string, args *PipelineArgs, opts ...pulumi.ResourceOption) (*Pipeline, error)

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

func (*Pipeline) ElementType 

func (*Pipeline) ElementType() reflect.Type

func (*Pipeline) ToPipelineOutput 

func (i *Pipeline) ToPipelineOutput() PipelineOutput

func (*Pipeline) ToPipelineOutputWithContext 

func (i *Pipeline) ToPipelineOutputWithContext(ctx context.Context) PipelineOutput

type PipelineArgs 

type PipelineArgs struct {
	// Key-value pairs to configure persistent buffering for the pipeline. See `bufferOptions` below.
	BufferOptions PipelineBufferOptionsPtrInput
	// Key-value pairs to configure encryption for data that is written to a persistent buffer. See `encryptionAtRestOptions` below.
	EncryptionAtRestOptions PipelineEncryptionAtRestOptionsPtrInput
	// Key-value pairs to configure log publishing. See `logPublishingOptions` below.
	LogPublishingOptions PipelineLogPublishingOptionsPtrInput
	// The maximum pipeline capacity, in Ingestion Compute Units (ICUs).
	MaxUnits pulumi.IntInput
	// The minimum pipeline capacity, in Ingestion Compute Units (ICUs).
	MinUnits pulumi.IntInput
	// The pipeline configuration in YAML format. This argument accepts the pipeline configuration as a string or within a .yaml file. If you provide the configuration as a string, each new line must be escaped with \n.
	PipelineConfigurationBody pulumi.StringInput
	// The name of the OpenSearch Ingestion pipeline to create. Pipeline names are unique across the pipelines owned by an account within an AWS Region.
	//
	// The following arguments are optional:
	PipelineName pulumi.StringInput
	// A map of tags to assign to the pipeline. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags     pulumi.StringMapInput
	Timeouts PipelineTimeoutsPtrInput
	// Container for the values required to configure VPC access for the pipeline. If you don't specify these values, OpenSearch Ingestion creates the pipeline with a public endpoint. See `vpcOptions` below.
	VpcOptions PipelineVpcOptionsPtrInput
}

The set of arguments for constructing a Pipeline resource.

func (PipelineArgs) ElementType 

func (PipelineArgs) ElementType() reflect.Type

type PipelineArray 

type PipelineArray []PipelineInput

func (PipelineArray) ElementType 

func (PipelineArray) ElementType() reflect.Type

func (PipelineArray) ToPipelineArrayOutput 

func (i PipelineArray) ToPipelineArrayOutput() PipelineArrayOutput

func (PipelineArray) ToPipelineArrayOutputWithContext 

func (i PipelineArray) ToPipelineArrayOutputWithContext(ctx context.Context) PipelineArrayOutput

type PipelineArrayInput 

type PipelineArrayInput interface {
	pulumi.Input

	ToPipelineArrayOutput() PipelineArrayOutput
	ToPipelineArrayOutputWithContext(context.Context) PipelineArrayOutput
}

PipelineArrayInput is an input type that accepts PipelineArray and PipelineArrayOutput values. You can construct a concrete instance of `PipelineArrayInput` via: 

PipelineArray{ PipelineArgs{...} }

type PipelineArrayOutput 

type PipelineArrayOutput struct{ *pulumi.OutputState }

func (PipelineArrayOutput) ElementType 

func (PipelineArrayOutput) ElementType() reflect.Type

func (PipelineArrayOutput) Index 

func (o PipelineArrayOutput) Index(i pulumi.IntInput) PipelineOutput

func (PipelineArrayOutput) ToPipelineArrayOutput 

func (o PipelineArrayOutput) ToPipelineArrayOutput() PipelineArrayOutput

func (PipelineArrayOutput) ToPipelineArrayOutputWithContext 

func (o PipelineArrayOutput) ToPipelineArrayOutputWithContext(ctx context.Context) PipelineArrayOutput

type PipelineBufferOptions 

type PipelineBufferOptions struct {
	// Whether persistent buffering should be enabled.
	PersistentBufferEnabled bool `pulumi:"persistentBufferEnabled"`
}

type PipelineBufferOptionsArgs 

type PipelineBufferOptionsArgs struct {
	// Whether persistent buffering should be enabled.
	PersistentBufferEnabled pulumi.BoolInput `pulumi:"persistentBufferEnabled"`
}

func (PipelineBufferOptionsArgs) ElementType 

func (PipelineBufferOptionsArgs) ElementType() reflect.Type

func (PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutput 

func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutput() PipelineBufferOptionsOutput

func (PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutputWithContext 

func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutputWithContext(ctx context.Context) PipelineBufferOptionsOutput

func (PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutput 

func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput

func (PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutputWithContext 

func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutputWithContext(ctx context.Context) PipelineBufferOptionsPtrOutput

type PipelineBufferOptionsInput 

type PipelineBufferOptionsInput interface {
	pulumi.Input

	ToPipelineBufferOptionsOutput() PipelineBufferOptionsOutput
	ToPipelineBufferOptionsOutputWithContext(context.Context) PipelineBufferOptionsOutput
}

PipelineBufferOptionsInput is an input type that accepts PipelineBufferOptionsArgs and PipelineBufferOptionsOutput values. You can construct a concrete instance of `PipelineBufferOptionsInput` via: 

PipelineBufferOptionsArgs{...}

type PipelineBufferOptionsOutput 

type PipelineBufferOptionsOutput struct{ *pulumi.OutputState }

func (PipelineBufferOptionsOutput) ElementType 

func (PipelineBufferOptionsOutput) ElementType() reflect.Type

func (PipelineBufferOptionsOutput) PersistentBufferEnabled 

func (o PipelineBufferOptionsOutput) PersistentBufferEnabled() pulumi.BoolOutput

Whether persistent buffering should be enabled.

func (PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutput 

func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutput() PipelineBufferOptionsOutput

func (PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutputWithContext 

func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutputWithContext(ctx context.Context) PipelineBufferOptionsOutput

func (PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutput 

func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput

func (PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutputWithContext 

func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutputWithContext(ctx context.Context) PipelineBufferOptionsPtrOutput

type PipelineBufferOptionsPtrInput 

type PipelineBufferOptionsPtrInput interface {
	pulumi.Input

	ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput
	ToPipelineBufferOptionsPtrOutputWithContext(context.Context) PipelineBufferOptionsPtrOutput
}

PipelineBufferOptionsPtrInput is an input type that accepts PipelineBufferOptionsArgs, PipelineBufferOptionsPtr and PipelineBufferOptionsPtrOutput values. You can construct a concrete instance of `PipelineBufferOptionsPtrInput` via: 

        PipelineBufferOptionsArgs{...}

or:

        nil

func PipelineBufferOptionsPtr 

func PipelineBufferOptionsPtr(v *PipelineBufferOptionsArgs) PipelineBufferOptionsPtrInput

type PipelineBufferOptionsPtrOutput 

type PipelineBufferOptionsPtrOutput struct{ *pulumi.OutputState }

func (PipelineBufferOptionsPtrOutput) Elem 

func (o PipelineBufferOptionsPtrOutput) Elem() PipelineBufferOptionsOutput

func (PipelineBufferOptionsPtrOutput) ElementType 

func (PipelineBufferOptionsPtrOutput) ElementType() reflect.Type

func (PipelineBufferOptionsPtrOutput) PersistentBufferEnabled 

func (o PipelineBufferOptionsPtrOutput) PersistentBufferEnabled() pulumi.BoolPtrOutput

Whether persistent buffering should be enabled.

func (PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutput 

func (o PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput

func (PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutputWithContext 

func (o PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutputWithContext(ctx context.Context) PipelineBufferOptionsPtrOutput

type PipelineEncryptionAtRestOptions 

type PipelineEncryptionAtRestOptions struct {
	// The ARN of the KMS key used to encrypt data-at-rest in OpenSearch Ingestion. By default, data is encrypted using an AWS owned key.
	KmsKeyArn string `pulumi:"kmsKeyArn"`
}

type PipelineEncryptionAtRestOptionsArgs 

type PipelineEncryptionAtRestOptionsArgs struct {
	// The ARN of the KMS key used to encrypt data-at-rest in OpenSearch Ingestion. By default, data is encrypted using an AWS owned key.
	KmsKeyArn pulumi.StringInput `pulumi:"kmsKeyArn"`
}

func (PipelineEncryptionAtRestOptionsArgs) ElementType 

func (PipelineEncryptionAtRestOptionsArgs) ElementType() reflect.Type

func (PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutput 

func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutput() PipelineEncryptionAtRestOptionsOutput

func (PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutputWithContext 

func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsOutput

func (PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutput 

func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput

func (PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext 

func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsPtrOutput

type PipelineEncryptionAtRestOptionsInput 

type PipelineEncryptionAtRestOptionsInput interface {
	pulumi.Input

	ToPipelineEncryptionAtRestOptionsOutput() PipelineEncryptionAtRestOptionsOutput
	ToPipelineEncryptionAtRestOptionsOutputWithContext(context.Context) PipelineEncryptionAtRestOptionsOutput
}

PipelineEncryptionAtRestOptionsInput is an input type that accepts PipelineEncryptionAtRestOptionsArgs and PipelineEncryptionAtRestOptionsOutput values. You can construct a concrete instance of `PipelineEncryptionAtRestOptionsInput` via: 

PipelineEncryptionAtRestOptionsArgs{...}

type PipelineEncryptionAtRestOptionsOutput 

type PipelineEncryptionAtRestOptionsOutput struct{ *pulumi.OutputState }

func (PipelineEncryptionAtRestOptionsOutput) ElementType 

func (PipelineEncryptionAtRestOptionsOutput) ElementType() reflect.Type

func (PipelineEncryptionAtRestOptionsOutput) KmsKeyArn 

func (o PipelineEncryptionAtRestOptionsOutput) KmsKeyArn() pulumi.StringOutput

The ARN of the KMS key used to encrypt data-at-rest in OpenSearch Ingestion. By default, data is encrypted using an AWS owned key.

func (PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutput 

func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutput() PipelineEncryptionAtRestOptionsOutput

func (PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutputWithContext 

func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsOutput

func (PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutput 

func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput

func (PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext 

func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsPtrOutput

type PipelineEncryptionAtRestOptionsPtrInput 

type PipelineEncryptionAtRestOptionsPtrInput interface {
	pulumi.Input

	ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput
	ToPipelineEncryptionAtRestOptionsPtrOutputWithContext(context.Context) PipelineEncryptionAtRestOptionsPtrOutput
}

PipelineEncryptionAtRestOptionsPtrInput is an input type that accepts PipelineEncryptionAtRestOptionsArgs, PipelineEncryptionAtRestOptionsPtr and PipelineEncryptionAtRestOptionsPtrOutput values. You can construct a concrete instance of `PipelineEncryptionAtRestOptionsPtrInput` via: 

        PipelineEncryptionAtRestOptionsArgs{...}

or:

        nil

func PipelineEncryptionAtRestOptionsPtr 

func PipelineEncryptionAtRestOptionsPtr(v *PipelineEncryptionAtRestOptionsArgs) PipelineEncryptionAtRestOptionsPtrInput

type PipelineEncryptionAtRestOptionsPtrOutput 

type PipelineEncryptionAtRestOptionsPtrOutput struct{ *pulumi.OutputState }

func (PipelineEncryptionAtRestOptionsPtrOutput) Elem 

func (o PipelineEncryptionAtRestOptionsPtrOutput) Elem() PipelineEncryptionAtRestOptionsOutput

func (PipelineEncryptionAtRestOptionsPtrOutput) ElementType 

func (PipelineEncryptionAtRestOptionsPtrOutput) ElementType() reflect.Type

func (PipelineEncryptionAtRestOptionsPtrOutput) KmsKeyArn 

func (o PipelineEncryptionAtRestOptionsPtrOutput) KmsKeyArn() pulumi.StringPtrOutput

The ARN of the KMS key used to encrypt data-at-rest in OpenSearch Ingestion. By default, data is encrypted using an AWS owned key.

func (PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutput 

func (o PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput

func (PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext 

func (o PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsPtrOutput

type PipelineInput 

type PipelineInput interface {
	pulumi.Input

	ToPipelineOutput() PipelineOutput
	ToPipelineOutputWithContext(ctx context.Context) PipelineOutput
}

type PipelineLogPublishingOptions 

type PipelineLogPublishingOptions struct {
	// The destination for OpenSearch Ingestion logs sent to Amazon CloudWatch Logs. This parameter is required if IsLoggingEnabled is set to true. See `cloudwatchLogDestination` below.
	CloudwatchLogDestination *PipelineLogPublishingOptionsCloudwatchLogDestination `pulumi:"cloudwatchLogDestination"`
	// Whether logs should be published.
	IsLoggingEnabled *bool `pulumi:"isLoggingEnabled"`
}

type PipelineLogPublishingOptionsArgs 

type PipelineLogPublishingOptionsArgs struct {
	// The destination for OpenSearch Ingestion logs sent to Amazon CloudWatch Logs. This parameter is required if IsLoggingEnabled is set to true. See `cloudwatchLogDestination` below.
	CloudwatchLogDestination PipelineLogPublishingOptionsCloudwatchLogDestinationPtrInput `pulumi:"cloudwatchLogDestination"`
	// Whether logs should be published.
	IsLoggingEnabled pulumi.BoolPtrInput `pulumi:"isLoggingEnabled"`
}

func (PipelineLogPublishingOptionsArgs) ElementType 

func (PipelineLogPublishingOptionsArgs) ElementType() reflect.Type

func (PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutput 

func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutput() PipelineLogPublishingOptionsOutput

func (PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutputWithContext 

func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsOutput

func (PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutput 

func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput

func (PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutputWithContext 

func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsPtrOutput

type PipelineLogPublishingOptionsCloudwatchLogDestination 

type PipelineLogPublishingOptionsCloudwatchLogDestination struct {
	// The name of the CloudWatch Logs group to send pipeline logs to. You can specify an existing log group or create a new one. For example, /aws/OpenSearchService/IngestionService/my-pipeline.
	LogGroup string `pulumi:"logGroup"`
}

type PipelineLogPublishingOptionsCloudwatchLogDestinationArgs 

type PipelineLogPublishingOptionsCloudwatchLogDestinationArgs struct {
	// The name of the CloudWatch Logs group to send pipeline logs to. You can specify an existing log group or create a new one. For example, /aws/OpenSearchService/IngestionService/my-pipeline.
	LogGroup pulumi.StringInput `pulumi:"logGroup"`
}

func (PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ElementType 

func (PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ElementType() reflect.Type

func (PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutput 

func (i PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutput() PipelineLogPublishingOptionsCloudwatchLogDestinationOutput

func (PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutputWithContext 

func (i PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudwatchLogDestinationOutput

func (PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput 

func (i PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput() PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput

func (PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutputWithContext 

func (i PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput

type PipelineLogPublishingOptionsCloudwatchLogDestinationInput 

type PipelineLogPublishingOptionsCloudwatchLogDestinationInput interface {
	pulumi.Input

	ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutput() PipelineLogPublishingOptionsCloudwatchLogDestinationOutput
	ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutputWithContext(context.Context) PipelineLogPublishingOptionsCloudwatchLogDestinationOutput
}

PipelineLogPublishingOptionsCloudwatchLogDestinationInput is an input type that accepts PipelineLogPublishingOptionsCloudwatchLogDestinationArgs and PipelineLogPublishingOptionsCloudwatchLogDestinationOutput values. You can construct a concrete instance of `PipelineLogPublishingOptionsCloudwatchLogDestinationInput` via: 

PipelineLogPublishingOptionsCloudwatchLogDestinationArgs{...}

type PipelineLogPublishingOptionsCloudwatchLogDestinationOutput 

type PipelineLogPublishingOptionsCloudwatchLogDestinationOutput struct{ *pulumi.OutputState }

func (PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ElementType 

func (PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ElementType() reflect.Type

func (PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) LogGroup 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) LogGroup() pulumi.StringOutput

The name of the CloudWatch Logs group to send pipeline logs to. You can specify an existing log group or create a new one. For example, /aws/OpenSearchService/IngestionService/my-pipeline.

func (PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutput 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutput() PipelineLogPublishingOptionsCloudwatchLogDestinationOutput

func (PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutputWithContext 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudwatchLogDestinationOutput

func (PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput() PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput

func (PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutputWithContext 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput

type PipelineLogPublishingOptionsCloudwatchLogDestinationPtrInput 

type PipelineLogPublishingOptionsCloudwatchLogDestinationPtrInput interface {
	pulumi.Input

	ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput() PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput
	ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutputWithContext(context.Context) PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput
}

PipelineLogPublishingOptionsCloudwatchLogDestinationPtrInput is an input type that accepts PipelineLogPublishingOptionsCloudwatchLogDestinationArgs, PipelineLogPublishingOptionsCloudwatchLogDestinationPtr and PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput values. You can construct a concrete instance of `PipelineLogPublishingOptionsCloudwatchLogDestinationPtrInput` via: 

        PipelineLogPublishingOptionsCloudwatchLogDestinationArgs{...}

or:

        nil

func PipelineLogPublishingOptionsCloudwatchLogDestinationPtr 

func PipelineLogPublishingOptionsCloudwatchLogDestinationPtr(v *PipelineLogPublishingOptionsCloudwatchLogDestinationArgs) PipelineLogPublishingOptionsCloudwatchLogDestinationPtrInput

type PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput 

type PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput struct{ *pulumi.OutputState }

func (PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) Elem 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) Elem() PipelineLogPublishingOptionsCloudwatchLogDestinationOutput

func (PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) ElementType 

func (PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) ElementType() reflect.Type

func (PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) LogGroup 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) LogGroup() pulumi.StringPtrOutput

The name of the CloudWatch Logs group to send pipeline logs to. You can specify an existing log group or create a new one. For example, /aws/OpenSearchService/IngestionService/my-pipeline.

func (PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput() PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput

func (PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutputWithContext 

func (o PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput) ToPipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput

type PipelineLogPublishingOptionsInput 

type PipelineLogPublishingOptionsInput interface {
	pulumi.Input

	ToPipelineLogPublishingOptionsOutput() PipelineLogPublishingOptionsOutput
	ToPipelineLogPublishingOptionsOutputWithContext(context.Context) PipelineLogPublishingOptionsOutput
}

PipelineLogPublishingOptionsInput is an input type that accepts PipelineLogPublishingOptionsArgs and PipelineLogPublishingOptionsOutput values. You can construct a concrete instance of `PipelineLogPublishingOptionsInput` via: 

PipelineLogPublishingOptionsArgs{...}

type PipelineLogPublishingOptionsOutput 

type PipelineLogPublishingOptionsOutput struct{ *pulumi.OutputState }

func (PipelineLogPublishingOptionsOutput) CloudwatchLogDestination 

func (o PipelineLogPublishingOptionsOutput) CloudwatchLogDestination() PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput

The destination for OpenSearch Ingestion logs sent to Amazon CloudWatch Logs. This parameter is required if IsLoggingEnabled is set to true. See `cloudwatchLogDestination` below.

func (PipelineLogPublishingOptionsOutput) ElementType 

func (PipelineLogPublishingOptionsOutput) ElementType() reflect.Type

func (PipelineLogPublishingOptionsOutput) IsLoggingEnabled 

func (o PipelineLogPublishingOptionsOutput) IsLoggingEnabled() pulumi.BoolPtrOutput

Whether logs should be published.

func (PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsOutput 

func (o PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsOutput() PipelineLogPublishingOptionsOutput

func (PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsOutputWithContext 

func (o PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsOutput

func (PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsPtrOutput 

func (o PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput

func (PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsPtrOutputWithContext 

func (o PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsPtrOutput

type PipelineLogPublishingOptionsPtrInput 

type PipelineLogPublishingOptionsPtrInput interface {
	pulumi.Input

	ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput
	ToPipelineLogPublishingOptionsPtrOutputWithContext(context.Context) PipelineLogPublishingOptionsPtrOutput
}

PipelineLogPublishingOptionsPtrInput is an input type that accepts PipelineLogPublishingOptionsArgs, PipelineLogPublishingOptionsPtr and PipelineLogPublishingOptionsPtrOutput values. You can construct a concrete instance of `PipelineLogPublishingOptionsPtrInput` via: 

        PipelineLogPublishingOptionsArgs{...}

or:

        nil

func PipelineLogPublishingOptionsPtr 

func PipelineLogPublishingOptionsPtr(v *PipelineLogPublishingOptionsArgs) PipelineLogPublishingOptionsPtrInput

type PipelineLogPublishingOptionsPtrOutput 

type PipelineLogPublishingOptionsPtrOutput struct{ *pulumi.OutputState }

func (PipelineLogPublishingOptionsPtrOutput) CloudwatchLogDestination 

func (o PipelineLogPublishingOptionsPtrOutput) CloudwatchLogDestination() PipelineLogPublishingOptionsCloudwatchLogDestinationPtrOutput

The destination for OpenSearch Ingestion logs sent to Amazon CloudWatch Logs. This parameter is required if IsLoggingEnabled is set to true. See `cloudwatchLogDestination` below.

func (PipelineLogPublishingOptionsPtrOutput) Elem 

func (o PipelineLogPublishingOptionsPtrOutput) Elem() PipelineLogPublishingOptionsOutput

func (PipelineLogPublishingOptionsPtrOutput) ElementType 

func (PipelineLogPublishingOptionsPtrOutput) ElementType() reflect.Type

func (PipelineLogPublishingOptionsPtrOutput) IsLoggingEnabled 

func (o PipelineLogPublishingOptionsPtrOutput) IsLoggingEnabled() pulumi.BoolPtrOutput

Whether logs should be published.

func (PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutput 

func (o PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput

func (PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutputWithContext 

func (o PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsPtrOutput

type PipelineMap 

type PipelineMap map[string]PipelineInput

func (PipelineMap) ElementType 

func (PipelineMap) ElementType() reflect.Type

func (PipelineMap) ToPipelineMapOutput 

func (i PipelineMap) ToPipelineMapOutput() PipelineMapOutput

func (PipelineMap) ToPipelineMapOutputWithContext 

func (i PipelineMap) ToPipelineMapOutputWithContext(ctx context.Context) PipelineMapOutput

type PipelineMapInput 

type PipelineMapInput interface {
	pulumi.Input

	ToPipelineMapOutput() PipelineMapOutput
	ToPipelineMapOutputWithContext(context.Context) PipelineMapOutput
}

PipelineMapInput is an input type that accepts PipelineMap and PipelineMapOutput values. You can construct a concrete instance of `PipelineMapInput` via: 

PipelineMap{ "key": PipelineArgs{...} }

type PipelineMapOutput 

type PipelineMapOutput struct{ *pulumi.OutputState }

func (PipelineMapOutput) ElementType 

func (PipelineMapOutput) ElementType() reflect.Type

func (PipelineMapOutput) MapIndex 

func (o PipelineMapOutput) MapIndex(k pulumi.StringInput) PipelineOutput

func (PipelineMapOutput) ToPipelineMapOutput 

func (o PipelineMapOutput) ToPipelineMapOutput() PipelineMapOutput

func (PipelineMapOutput) ToPipelineMapOutputWithContext 

func (o PipelineMapOutput) ToPipelineMapOutputWithContext(ctx context.Context) PipelineMapOutput

type PipelineOutput 

type PipelineOutput struct{ *pulumi.OutputState }

func (PipelineOutput) BufferOptions 

func (o PipelineOutput) BufferOptions() PipelineBufferOptionsPtrOutput

Key-value pairs to configure persistent buffering for the pipeline. See `bufferOptions` below.

func (PipelineOutput) ElementType 

func (PipelineOutput) ElementType() reflect.Type

func (PipelineOutput) EncryptionAtRestOptions 

func (o PipelineOutput) EncryptionAtRestOptions() PipelineEncryptionAtRestOptionsPtrOutput

Key-value pairs to configure encryption for data that is written to a persistent buffer. See `encryptionAtRestOptions` below.

func (PipelineOutput) IngestEndpointUrls 

func (o PipelineOutput) IngestEndpointUrls() pulumi.StringArrayOutput

The list of ingestion endpoints for the pipeline, which you can send data to.

func (PipelineOutput) LogPublishingOptions 

func (o PipelineOutput) LogPublishingOptions() PipelineLogPublishingOptionsPtrOutput

Key-value pairs to configure log publishing. See `logPublishingOptions` below.

func (PipelineOutput) MaxUnits 

func (o PipelineOutput) MaxUnits() pulumi.IntOutput

The maximum pipeline capacity, in Ingestion Compute Units (ICUs).

func (PipelineOutput) MinUnits 

func (o PipelineOutput) MinUnits() pulumi.IntOutput

The minimum pipeline capacity, in Ingestion Compute Units (ICUs).

func (PipelineOutput) PipelineArn 

func (o PipelineOutput) PipelineArn() pulumi.StringOutput

Amazon Resource Name (ARN) of the pipeline.

func (PipelineOutput) PipelineConfigurationBody 

func (o PipelineOutput) PipelineConfigurationBody() pulumi.StringOutput

The pipeline configuration in YAML format. This argument accepts the pipeline configuration as a string or within a .yaml file. If you provide the configuration as a string, each new line must be escaped with \n.

func (PipelineOutput) PipelineName 

func (o PipelineOutput) PipelineName() pulumi.StringOutput

The name of the OpenSearch Ingestion pipeline to create. Pipeline names are unique across the pipelines owned by an account within an AWS Region.

The following arguments are optional:

func (PipelineOutput) Tags 

func (o PipelineOutput) Tags() pulumi.StringMapOutput

A map of tags to assign to the pipeline. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (PipelineOutput) TagsAll deprecated 

func (o PipelineOutput) TagsAll() pulumi.StringMapOutput

Deprecated: Please use `tags` instead.

func (PipelineOutput) Timeouts 

func (o PipelineOutput) Timeouts() PipelineTimeoutsPtrOutput

func (PipelineOutput) ToPipelineOutput 

func (o PipelineOutput) ToPipelineOutput() PipelineOutput

func (PipelineOutput) ToPipelineOutputWithContext 

func (o PipelineOutput) ToPipelineOutputWithContext(ctx context.Context) PipelineOutput

func (PipelineOutput) VpcOptions 

func (o PipelineOutput) VpcOptions() PipelineVpcOptionsPtrOutput

Container for the values required to configure VPC access for the pipeline. If you don't specify these values, OpenSearch Ingestion creates the pipeline with a public endpoint. See `vpcOptions` below.

type PipelineState 

type PipelineState struct {
	// Key-value pairs to configure persistent buffering for the pipeline. See `bufferOptions` below.
	BufferOptions PipelineBufferOptionsPtrInput
	// Key-value pairs to configure encryption for data that is written to a persistent buffer. See `encryptionAtRestOptions` below.
	EncryptionAtRestOptions PipelineEncryptionAtRestOptionsPtrInput
	// The list of ingestion endpoints for the pipeline, which you can send data to.
	IngestEndpointUrls pulumi.StringArrayInput
	// Key-value pairs to configure log publishing. See `logPublishingOptions` below.
	LogPublishingOptions PipelineLogPublishingOptionsPtrInput
	// The maximum pipeline capacity, in Ingestion Compute Units (ICUs).
	MaxUnits pulumi.IntPtrInput
	// The minimum pipeline capacity, in Ingestion Compute Units (ICUs).
	MinUnits pulumi.IntPtrInput
	// Amazon Resource Name (ARN) of the pipeline.
	PipelineArn pulumi.StringPtrInput
	// The pipeline configuration in YAML format. This argument accepts the pipeline configuration as a string or within a .yaml file. If you provide the configuration as a string, each new line must be escaped with \n.
	PipelineConfigurationBody pulumi.StringPtrInput
	// The name of the OpenSearch Ingestion pipeline to create. Pipeline names are unique across the pipelines owned by an account within an AWS Region.
	//
	// The following arguments are optional:
	PipelineName pulumi.StringPtrInput
	// A map of tags to assign to the pipeline. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// Deprecated: Please use `tags` instead.
	TagsAll  pulumi.StringMapInput
	Timeouts PipelineTimeoutsPtrInput
	// Container for the values required to configure VPC access for the pipeline. If you don't specify these values, OpenSearch Ingestion creates the pipeline with a public endpoint. See `vpcOptions` below.
	VpcOptions PipelineVpcOptionsPtrInput
}

func (PipelineState) ElementType 

func (PipelineState) ElementType() reflect.Type

type PipelineTimeouts 

type PipelineTimeouts struct {
	// A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
	Create *string `pulumi:"create"`
	// A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
	Delete *string `pulumi:"delete"`
	// A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
	Update *string `pulumi:"update"`
}

type PipelineTimeoutsArgs 

type PipelineTimeoutsArgs struct {
	// A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
	Create pulumi.StringPtrInput `pulumi:"create"`
	// A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.
	Delete pulumi.StringPtrInput `pulumi:"delete"`
	// A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).
	Update pulumi.StringPtrInput `pulumi:"update"`
}

func (PipelineTimeoutsArgs) ElementType 

func (PipelineTimeoutsArgs) ElementType() reflect.Type

func (PipelineTimeoutsArgs) ToPipelineTimeoutsOutput 

func (i PipelineTimeoutsArgs) ToPipelineTimeoutsOutput() PipelineTimeoutsOutput

func (PipelineTimeoutsArgs) ToPipelineTimeoutsOutputWithContext 

func (i PipelineTimeoutsArgs) ToPipelineTimeoutsOutputWithContext(ctx context.Context) PipelineTimeoutsOutput

func (PipelineTimeoutsArgs) ToPipelineTimeoutsPtrOutput 

func (i PipelineTimeoutsArgs) ToPipelineTimeoutsPtrOutput() PipelineTimeoutsPtrOutput

func (PipelineTimeoutsArgs) ToPipelineTimeoutsPtrOutputWithContext 

func (i PipelineTimeoutsArgs) ToPipelineTimeoutsPtrOutputWithContext(ctx context.Context) PipelineTimeoutsPtrOutput

type PipelineTimeoutsInput 

type PipelineTimeoutsInput interface {
	pulumi.Input

	ToPipelineTimeoutsOutput() PipelineTimeoutsOutput
	ToPipelineTimeoutsOutputWithContext(context.Context) PipelineTimeoutsOutput
}

PipelineTimeoutsInput is an input type that accepts PipelineTimeoutsArgs and PipelineTimeoutsOutput values. You can construct a concrete instance of `PipelineTimeoutsInput` via: 

PipelineTimeoutsArgs{...}

type PipelineTimeoutsOutput 

type PipelineTimeoutsOutput struct{ *pulumi.OutputState }

func (PipelineTimeoutsOutput) Create 

func (o PipelineTimeoutsOutput) Create() pulumi.StringPtrOutput

A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).

func (PipelineTimeoutsOutput) Delete 

func (o PipelineTimeoutsOutput) Delete() pulumi.StringPtrOutput

A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.

func (PipelineTimeoutsOutput) ElementType 

func (PipelineTimeoutsOutput) ElementType() reflect.Type

func (PipelineTimeoutsOutput) ToPipelineTimeoutsOutput 

func (o PipelineTimeoutsOutput) ToPipelineTimeoutsOutput() PipelineTimeoutsOutput

func (PipelineTimeoutsOutput) ToPipelineTimeoutsOutputWithContext 

func (o PipelineTimeoutsOutput) ToPipelineTimeoutsOutputWithContext(ctx context.Context) PipelineTimeoutsOutput

func (PipelineTimeoutsOutput) ToPipelineTimeoutsPtrOutput 

func (o PipelineTimeoutsOutput) ToPipelineTimeoutsPtrOutput() PipelineTimeoutsPtrOutput

func (PipelineTimeoutsOutput) ToPipelineTimeoutsPtrOutputWithContext 

func (o PipelineTimeoutsOutput) ToPipelineTimeoutsPtrOutputWithContext(ctx context.Context) PipelineTimeoutsPtrOutput

func (PipelineTimeoutsOutput) Update 

func (o PipelineTimeoutsOutput) Update() pulumi.StringPtrOutput

A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).

type PipelineTimeoutsPtrInput 

type PipelineTimeoutsPtrInput interface {
	pulumi.Input

	ToPipelineTimeoutsPtrOutput() PipelineTimeoutsPtrOutput
	ToPipelineTimeoutsPtrOutputWithContext(context.Context) PipelineTimeoutsPtrOutput
}

PipelineTimeoutsPtrInput is an input type that accepts PipelineTimeoutsArgs, PipelineTimeoutsPtr and PipelineTimeoutsPtrOutput values. You can construct a concrete instance of `PipelineTimeoutsPtrInput` via: 

        PipelineTimeoutsArgs{...}

or:

        nil

func PipelineTimeoutsPtr 

func PipelineTimeoutsPtr(v *PipelineTimeoutsArgs) PipelineTimeoutsPtrInput

type PipelineTimeoutsPtrOutput 

type PipelineTimeoutsPtrOutput struct{ *pulumi.OutputState }

func (PipelineTimeoutsPtrOutput) Create 

func (o PipelineTimeoutsPtrOutput) Create() pulumi.StringPtrOutput

A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).

func (PipelineTimeoutsPtrOutput) Delete 

func (o PipelineTimeoutsPtrOutput) Delete() pulumi.StringPtrOutput

A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours). Setting a timeout for a Delete operation is only applicable if changes are saved into state before the destroy operation occurs.

func (PipelineTimeoutsPtrOutput) Elem 

func (o PipelineTimeoutsPtrOutput) Elem() PipelineTimeoutsOutput

func (PipelineTimeoutsPtrOutput) ElementType 

func (PipelineTimeoutsPtrOutput) ElementType() reflect.Type

func (PipelineTimeoutsPtrOutput) ToPipelineTimeoutsPtrOutput 

func (o PipelineTimeoutsPtrOutput) ToPipelineTimeoutsPtrOutput() PipelineTimeoutsPtrOutput

func (PipelineTimeoutsPtrOutput) ToPipelineTimeoutsPtrOutputWithContext 

func (o PipelineTimeoutsPtrOutput) ToPipelineTimeoutsPtrOutputWithContext(ctx context.Context) PipelineTimeoutsPtrOutput

func (PipelineTimeoutsPtrOutput) Update 

func (o PipelineTimeoutsPtrOutput) Update() pulumi.StringPtrOutput

A string that can be [parsed as a duration](https://pkg.go.dev/time#ParseDuration) consisting of numbers and unit suffixes, such as "30s" or "2h45m". Valid time units are "s" (seconds), "m" (minutes), "h" (hours).

type PipelineVpcOptions 

type PipelineVpcOptions struct {
	// A list of security groups associated with the VPC endpoint.
	SecurityGroupIds []string `pulumi:"securityGroupIds"`
	// A list of subnet IDs associated with the VPC endpoint.
	SubnetIds []string `pulumi:"subnetIds"`
}

type PipelineVpcOptionsArgs 

type PipelineVpcOptionsArgs struct {
	// A list of security groups associated with the VPC endpoint.
	SecurityGroupIds pulumi.StringArrayInput `pulumi:"securityGroupIds"`
	// A list of subnet IDs associated with the VPC endpoint.
	SubnetIds pulumi.StringArrayInput `pulumi:"subnetIds"`
}

func (PipelineVpcOptionsArgs) ElementType 

func (PipelineVpcOptionsArgs) ElementType() reflect.Type

func (PipelineVpcOptionsArgs) ToPipelineVpcOptionsOutput 

func (i PipelineVpcOptionsArgs) ToPipelineVpcOptionsOutput() PipelineVpcOptionsOutput

func (PipelineVpcOptionsArgs) ToPipelineVpcOptionsOutputWithContext 

func (i PipelineVpcOptionsArgs) ToPipelineVpcOptionsOutputWithContext(ctx context.Context) PipelineVpcOptionsOutput

func (PipelineVpcOptionsArgs) ToPipelineVpcOptionsPtrOutput 

func (i PipelineVpcOptionsArgs) ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput

func (PipelineVpcOptionsArgs) ToPipelineVpcOptionsPtrOutputWithContext 

func (i PipelineVpcOptionsArgs) ToPipelineVpcOptionsPtrOutputWithContext(ctx context.Context) PipelineVpcOptionsPtrOutput

type PipelineVpcOptionsInput 

type PipelineVpcOptionsInput interface {
	pulumi.Input

	ToPipelineVpcOptionsOutput() PipelineVpcOptionsOutput
	ToPipelineVpcOptionsOutputWithContext(context.Context) PipelineVpcOptionsOutput
}

PipelineVpcOptionsInput is an input type that accepts PipelineVpcOptionsArgs and PipelineVpcOptionsOutput values. You can construct a concrete instance of `PipelineVpcOptionsInput` via: 

PipelineVpcOptionsArgs{...}

type PipelineVpcOptionsOutput 

type PipelineVpcOptionsOutput struct{ *pulumi.OutputState }

func (PipelineVpcOptionsOutput) ElementType 

func (PipelineVpcOptionsOutput) ElementType() reflect.Type

func (PipelineVpcOptionsOutput) SecurityGroupIds 

func (o PipelineVpcOptionsOutput) SecurityGroupIds() pulumi.StringArrayOutput

A list of security groups associated with the VPC endpoint.

func (PipelineVpcOptionsOutput) SubnetIds 

func (o PipelineVpcOptionsOutput) SubnetIds() pulumi.StringArrayOutput

A list of subnet IDs associated with the VPC endpoint.

func (PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutput 

func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutput() PipelineVpcOptionsOutput

func (PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutputWithContext 

func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutputWithContext(ctx context.Context) PipelineVpcOptionsOutput

func (PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutput 

func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput

func (PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutputWithContext 

func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutputWithContext(ctx context.Context) PipelineVpcOptionsPtrOutput

type PipelineVpcOptionsPtrInput 

type PipelineVpcOptionsPtrInput interface {
	pulumi.Input

	ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput
	ToPipelineVpcOptionsPtrOutputWithContext(context.Context) PipelineVpcOptionsPtrOutput
}

PipelineVpcOptionsPtrInput is an input type that accepts PipelineVpcOptionsArgs, PipelineVpcOptionsPtr and PipelineVpcOptionsPtrOutput values. You can construct a concrete instance of `PipelineVpcOptionsPtrInput` via: 

        PipelineVpcOptionsArgs{...}

or:

        nil

func PipelineVpcOptionsPtr 

func PipelineVpcOptionsPtr(v *PipelineVpcOptionsArgs) PipelineVpcOptionsPtrInput

type PipelineVpcOptionsPtrOutput 

type PipelineVpcOptionsPtrOutput struct{ *pulumi.OutputState }

func (PipelineVpcOptionsPtrOutput) Elem 

func (o PipelineVpcOptionsPtrOutput) Elem() PipelineVpcOptionsOutput

func (PipelineVpcOptionsPtrOutput) ElementType 

func (PipelineVpcOptionsPtrOutput) ElementType() reflect.Type

func (PipelineVpcOptionsPtrOutput) SecurityGroupIds 

func (o PipelineVpcOptionsPtrOutput) SecurityGroupIds() pulumi.StringArrayOutput

A list of security groups associated with the VPC endpoint.

func (PipelineVpcOptionsPtrOutput) SubnetIds 

func (o PipelineVpcOptionsPtrOutput) SubnetIds() pulumi.StringArrayOutput

A list of subnet IDs associated with the VPC endpoint.

func (PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutput 

func (o PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput

func (PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutputWithContext 

func (o PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutputWithContext(ctx context.Context) PipelineVpcOptionsPtrOutput

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.