pipes

package
v5.43.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2023 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 Pipe 

type Pipe struct {
	pulumi.CustomResourceState

	// ARN of this pipe.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// A description of the pipe. At most 512 characters.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// The state the pipe should be in. One of: `RUNNING`, `STOPPED`.
	DesiredState pulumi.StringPtrOutput `pulumi:"desiredState"`
	// Enrichment resource of the pipe (typically an ARN). Read more about enrichment in the [User Guide](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html#pipes-enrichment).
	Enrichment pulumi.StringPtrOutput `pulumi:"enrichment"`
	// Name of the pipe. If omitted, the provider will assign a random, unique name. Conflicts with `namePrefix`.
	Name pulumi.StringOutput `pulumi:"name"`
	// Creates a unique name beginning with the specified prefix. Conflicts with `name`.
	NamePrefix pulumi.StringOutput `pulumi:"namePrefix"`
	// ARN of the role that allows the pipe to send data to the target.
	RoleArn pulumi.StringOutput `pulumi:"roleArn"`
	// Source resource of the pipe (typically an ARN).
	Source pulumi.StringOutput `pulumi:"source"`
	// Parameters required to set up a source for the pipe. Detailed below.
	SourceParameters PipeSourceParametersOutput `pulumi:"sourceParameters"`
	// Key-value mapping of resource tags. 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"`
	// Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
	// Target resource of the pipe (typically an ARN).
	Target pulumi.StringOutput `pulumi:"target"`
	// Parameters required to set up a target for your pipe. Detailed below.
	//
	// The following arguments are optional:
	TargetParameters PipeTargetParametersOutput `pulumi:"targetParameters"`
}

Resource for managing an AWS EventBridge Pipes Pipe.

You can find out more about EventBridge Pipes in the [User Guide](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html).

> **Note:** EventBridge was formerly known as CloudWatch Events. The functionality is identical.

## Example Usage ### Basic Usage

```go package main

import ( 

"encoding/json"

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/iam"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/pipes"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/sqs"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		main, err := aws.GetCallerIdentity(ctx, nil, nil)
		if err != nil {
			return err
		}
		tmpJSON0, err := json.Marshal(map[string]interface{}{
			"Version": "2012-10-17",
			"Statement": map[string]interface{}{
				"Effect": "Allow",
				"Action": "sts:AssumeRole",
				"Principal": map[string]interface{}{
					"Service": "pipes.amazonaws.com",
				},
				"Condition": map[string]interface{}{
					"StringEquals": map[string]interface{}{
						"aws:SourceAccount": main.AccountId,
					},
				},
			},
		})
		if err != nil {
			return err
		}
		json0 := string(tmpJSON0)
		test, err := iam.NewRole(ctx, "test", &iam.RoleArgs{
			AssumeRolePolicy: pulumi.String(json0),
		})
		if err != nil {
			return err
		}
		sourceQueue, err := sqs.NewQueue(ctx, "sourceQueue", nil)
		if err != nil {
			return err
		}
		sourceRolePolicy, err := iam.NewRolePolicy(ctx, "sourceRolePolicy", &iam.RolePolicyArgs{
			Role: test.ID(),
			Policy: sourceQueue.Arn.ApplyT(func(arn string) (pulumi.String, error) {
				var _zero pulumi.String
				tmpJSON1, err := json.Marshal(map[string]interface{}{
					"Version": "2012-10-17",
					"Statement": []map[string]interface{}{
						map[string]interface{}{
							"Effect": "Allow",
							"Action": []string{
								"sqs:DeleteMessage",
								"sqs:GetQueueAttributes",
								"sqs:ReceiveMessage",
							},
							"Resource": []string{
								arn,
							},
						},
					},
				})
				if err != nil {
					return _zero, err
				}
				json1 := string(tmpJSON1)
				return pulumi.String(json1), nil
			}).(pulumi.StringOutput),
		})
		if err != nil {
			return err
		}
		targetQueue, err := sqs.NewQueue(ctx, "targetQueue", nil)
		if err != nil {
			return err
		}
		targetRolePolicy, err := iam.NewRolePolicy(ctx, "targetRolePolicy", &iam.RolePolicyArgs{
			Role: test.ID(),
			Policy: targetQueue.Arn.ApplyT(func(arn string) (pulumi.String, error) {
				var _zero pulumi.String
				tmpJSON2, err := json.Marshal(map[string]interface{}{
					"Version": "2012-10-17",
					"Statement": []map[string]interface{}{
						map[string]interface{}{
							"Effect": "Allow",
							"Action": []string{
								"sqs:SendMessage",
							},
							"Resource": []string{
								arn,
							},
						},
					},
				})
				if err != nil {
					return _zero, err
				}
				json2 := string(tmpJSON2)
				return pulumi.String(json2), nil
			}).(pulumi.StringOutput),
		})
		if err != nil {
			return err
		}
		_, err = pipes.NewPipe(ctx, "example", &pipes.PipeArgs{
			RoleArn:          pulumi.Any(aws_iam_role.Example.Arn),
			Source:           sourceQueue.Arn,
			Target:           targetQueue.Arn,
			SourceParameters: nil,
			TargetParameters: nil,
		}, pulumi.DependsOn([]pulumi.Resource{
			sourceRolePolicy,
			targetRolePolicy,
		}))
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Pipes can be imported using the `name`. For example

```sh 

$ pulumi import aws:pipes/pipe:Pipe example my-pipe

```

func GetPipe 

func GetPipe(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *PipeState, opts ...pulumi.ResourceOption) (*Pipe, error)

GetPipe gets an existing Pipe 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 NewPipe 

func NewPipe(ctx *pulumi.Context,
	name string, args *PipeArgs, opts ...pulumi.ResourceOption) (*Pipe, error)

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

func (*Pipe) ElementType 

func (*Pipe) ElementType() reflect.Type

func (*Pipe) ToPipeOutput 

func (i *Pipe) ToPipeOutput() PipeOutput

func (*Pipe) ToPipeOutputWithContext 

func (i *Pipe) ToPipeOutputWithContext(ctx context.Context) PipeOutput

type PipeArgs 

type PipeArgs struct {
	// A description of the pipe. At most 512 characters.
	Description pulumi.StringPtrInput
	// The state the pipe should be in. One of: `RUNNING`, `STOPPED`.
	DesiredState pulumi.StringPtrInput
	// Enrichment resource of the pipe (typically an ARN). Read more about enrichment in the [User Guide](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html#pipes-enrichment).
	Enrichment pulumi.StringPtrInput
	// Name of the pipe. If omitted, the provider will assign a random, unique name. Conflicts with `namePrefix`.
	Name pulumi.StringPtrInput
	// Creates a unique name beginning with the specified prefix. Conflicts with `name`.
	NamePrefix pulumi.StringPtrInput
	// ARN of the role that allows the pipe to send data to the target.
	RoleArn pulumi.StringInput
	// Source resource of the pipe (typically an ARN).
	Source pulumi.StringInput
	// Parameters required to set up a source for the pipe. Detailed below.
	SourceParameters PipeSourceParametersInput
	// Key-value mapping of resource tags. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// Target resource of the pipe (typically an ARN).
	Target pulumi.StringInput
	// Parameters required to set up a target for your pipe. Detailed below.
	//
	// The following arguments are optional:
	TargetParameters PipeTargetParametersInput
}

The set of arguments for constructing a Pipe resource.

func (PipeArgs) ElementType 

func (PipeArgs) ElementType() reflect.Type

type PipeArray 

type PipeArray []PipeInput

func (PipeArray) ElementType 

func (PipeArray) ElementType() reflect.Type

func (PipeArray) ToPipeArrayOutput 

func (i PipeArray) ToPipeArrayOutput() PipeArrayOutput

func (PipeArray) ToPipeArrayOutputWithContext 

func (i PipeArray) ToPipeArrayOutputWithContext(ctx context.Context) PipeArrayOutput

type PipeArrayInput 

type PipeArrayInput interface {
	pulumi.Input

	ToPipeArrayOutput() PipeArrayOutput
	ToPipeArrayOutputWithContext(context.Context) PipeArrayOutput
}

PipeArrayInput is an input type that accepts PipeArray and PipeArrayOutput values. You can construct a concrete instance of `PipeArrayInput` via: 

PipeArray{ PipeArgs{...} }

type PipeArrayOutput 

type PipeArrayOutput struct{ *pulumi.OutputState }

func (PipeArrayOutput) ElementType 

func (PipeArrayOutput) ElementType() reflect.Type

func (PipeArrayOutput) Index 

func (o PipeArrayOutput) Index(i pulumi.IntInput) PipeOutput

func (PipeArrayOutput) ToPipeArrayOutput 

func (o PipeArrayOutput) ToPipeArrayOutput() PipeArrayOutput

func (PipeArrayOutput) ToPipeArrayOutputWithContext 

func (o PipeArrayOutput) ToPipeArrayOutputWithContext(ctx context.Context) PipeArrayOutput

type PipeInput 

type PipeInput interface {
	pulumi.Input

	ToPipeOutput() PipeOutput
	ToPipeOutputWithContext(ctx context.Context) PipeOutput
}

type PipeMap 

type PipeMap map[string]PipeInput

func (PipeMap) ElementType 

func (PipeMap) ElementType() reflect.Type

func (PipeMap) ToPipeMapOutput 

func (i PipeMap) ToPipeMapOutput() PipeMapOutput

func (PipeMap) ToPipeMapOutputWithContext 

func (i PipeMap) ToPipeMapOutputWithContext(ctx context.Context) PipeMapOutput

type PipeMapInput 

type PipeMapInput interface {
	pulumi.Input

	ToPipeMapOutput() PipeMapOutput
	ToPipeMapOutputWithContext(context.Context) PipeMapOutput
}

PipeMapInput is an input type that accepts PipeMap and PipeMapOutput values. You can construct a concrete instance of `PipeMapInput` via: 

PipeMap{ "key": PipeArgs{...} }

type PipeMapOutput 

type PipeMapOutput struct{ *pulumi.OutputState }

func (PipeMapOutput) ElementType 

func (PipeMapOutput) ElementType() reflect.Type

func (PipeMapOutput) MapIndex 

func (o PipeMapOutput) MapIndex(k pulumi.StringInput) PipeOutput

func (PipeMapOutput) ToPipeMapOutput 

func (o PipeMapOutput) ToPipeMapOutput() PipeMapOutput

func (PipeMapOutput) ToPipeMapOutputWithContext 

func (o PipeMapOutput) ToPipeMapOutputWithContext(ctx context.Context) PipeMapOutput

type PipeOutput 

type PipeOutput struct{ *pulumi.OutputState }

func (PipeOutput) Arn 

func (o PipeOutput) Arn() pulumi.StringOutput

ARN of this pipe.

func (PipeOutput) Description 

func (o PipeOutput) Description() pulumi.StringPtrOutput

A description of the pipe. At most 512 characters.

func (PipeOutput) DesiredState 

func (o PipeOutput) DesiredState() pulumi.StringPtrOutput

The state the pipe should be in. One of: `RUNNING`, `STOPPED`.

func (PipeOutput) ElementType 

func (PipeOutput) ElementType() reflect.Type

func (PipeOutput) Enrichment 

func (o PipeOutput) Enrichment() pulumi.StringPtrOutput

Enrichment resource of the pipe (typically an ARN). Read more about enrichment in the [User Guide](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html#pipes-enrichment).

func (PipeOutput) Name 

func (o PipeOutput) Name() pulumi.StringOutput

Name of the pipe. If omitted, the provider will assign a random, unique name. Conflicts with `namePrefix`.

func (PipeOutput) NamePrefix 

func (o PipeOutput) NamePrefix() pulumi.StringOutput

Creates a unique name beginning with the specified prefix. Conflicts with `name`.

func (PipeOutput) RoleArn 

func (o PipeOutput) RoleArn() pulumi.StringOutput

ARN of the role that allows the pipe to send data to the target.

func (PipeOutput) Source 

func (o PipeOutput) Source() pulumi.StringOutput

Source resource of the pipe (typically an ARN).

func (PipeOutput) SourceParameters 

func (o PipeOutput) SourceParameters() PipeSourceParametersOutput

Parameters required to set up a source for the pipe. Detailed below.

func (PipeOutput) Tags 

func (o PipeOutput) Tags() pulumi.StringMapOutput

Key-value mapping of resource tags. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (PipeOutput) TagsAll 

func (o PipeOutput) TagsAll() pulumi.StringMapOutput

Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (PipeOutput) Target 

func (o PipeOutput) Target() pulumi.StringOutput

Target resource of the pipe (typically an ARN).

func (PipeOutput) TargetParameters 

func (o PipeOutput) TargetParameters() PipeTargetParametersOutput

Parameters required to set up a target for your pipe. Detailed below.

The following arguments are optional:

func (PipeOutput) ToPipeOutput 

func (o PipeOutput) ToPipeOutput() PipeOutput

func (PipeOutput) ToPipeOutputWithContext 

func (o PipeOutput) ToPipeOutputWithContext(ctx context.Context) PipeOutput

type PipeSourceParameters 

type PipeSourceParameters struct {
	// The collection of event patterns used to filter events. Detailed below.
	FilterCriteria *PipeSourceParametersFilterCriteria `pulumi:"filterCriteria"`
}

type PipeSourceParametersArgs 

type PipeSourceParametersArgs struct {
	// The collection of event patterns used to filter events. Detailed below.
	FilterCriteria PipeSourceParametersFilterCriteriaPtrInput `pulumi:"filterCriteria"`
}

func (PipeSourceParametersArgs) ElementType 

func (PipeSourceParametersArgs) ElementType() reflect.Type

func (PipeSourceParametersArgs) ToPipeSourceParametersOutput 

func (i PipeSourceParametersArgs) ToPipeSourceParametersOutput() PipeSourceParametersOutput

func (PipeSourceParametersArgs) ToPipeSourceParametersOutputWithContext 

func (i PipeSourceParametersArgs) ToPipeSourceParametersOutputWithContext(ctx context.Context) PipeSourceParametersOutput

func (PipeSourceParametersArgs) ToPipeSourceParametersPtrOutput 

func (i PipeSourceParametersArgs) ToPipeSourceParametersPtrOutput() PipeSourceParametersPtrOutput

func (PipeSourceParametersArgs) ToPipeSourceParametersPtrOutputWithContext 

func (i PipeSourceParametersArgs) ToPipeSourceParametersPtrOutputWithContext(ctx context.Context) PipeSourceParametersPtrOutput

type PipeSourceParametersFilterCriteria 

type PipeSourceParametersFilterCriteria struct {
	// An array of up to 5 event patterns. Detailed below.
	Filters []PipeSourceParametersFilterCriteriaFilter `pulumi:"filters"`
}

type PipeSourceParametersFilterCriteriaArgs 

type PipeSourceParametersFilterCriteriaArgs struct {
	// An array of up to 5 event patterns. Detailed below.
	Filters PipeSourceParametersFilterCriteriaFilterArrayInput `pulumi:"filters"`
}

func (PipeSourceParametersFilterCriteriaArgs) ElementType 

func (PipeSourceParametersFilterCriteriaArgs) ElementType() reflect.Type

func (PipeSourceParametersFilterCriteriaArgs) ToPipeSourceParametersFilterCriteriaOutput 

func (i PipeSourceParametersFilterCriteriaArgs) ToPipeSourceParametersFilterCriteriaOutput() PipeSourceParametersFilterCriteriaOutput

func (PipeSourceParametersFilterCriteriaArgs) ToPipeSourceParametersFilterCriteriaOutputWithContext 

func (i PipeSourceParametersFilterCriteriaArgs) ToPipeSourceParametersFilterCriteriaOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaOutput

func (PipeSourceParametersFilterCriteriaArgs) ToPipeSourceParametersFilterCriteriaPtrOutput 

func (i PipeSourceParametersFilterCriteriaArgs) ToPipeSourceParametersFilterCriteriaPtrOutput() PipeSourceParametersFilterCriteriaPtrOutput

func (PipeSourceParametersFilterCriteriaArgs) ToPipeSourceParametersFilterCriteriaPtrOutputWithContext 

func (i PipeSourceParametersFilterCriteriaArgs) ToPipeSourceParametersFilterCriteriaPtrOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaPtrOutput

type PipeSourceParametersFilterCriteriaFilter 

type PipeSourceParametersFilterCriteriaFilter struct {
	// The event pattern. At most 4096 characters.
	Pattern string `pulumi:"pattern"`
}

type PipeSourceParametersFilterCriteriaFilterArgs 

type PipeSourceParametersFilterCriteriaFilterArgs struct {
	// The event pattern. At most 4096 characters.
	Pattern pulumi.StringInput `pulumi:"pattern"`
}

func (PipeSourceParametersFilterCriteriaFilterArgs) ElementType 

func (PipeSourceParametersFilterCriteriaFilterArgs) ElementType() reflect.Type

func (PipeSourceParametersFilterCriteriaFilterArgs) ToPipeSourceParametersFilterCriteriaFilterOutput 

func (i PipeSourceParametersFilterCriteriaFilterArgs) ToPipeSourceParametersFilterCriteriaFilterOutput() PipeSourceParametersFilterCriteriaFilterOutput

func (PipeSourceParametersFilterCriteriaFilterArgs) ToPipeSourceParametersFilterCriteriaFilterOutputWithContext 

func (i PipeSourceParametersFilterCriteriaFilterArgs) ToPipeSourceParametersFilterCriteriaFilterOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaFilterOutput

type PipeSourceParametersFilterCriteriaFilterArray 

type PipeSourceParametersFilterCriteriaFilterArray []PipeSourceParametersFilterCriteriaFilterInput

func (PipeSourceParametersFilterCriteriaFilterArray) ElementType 

func (PipeSourceParametersFilterCriteriaFilterArray) ElementType() reflect.Type

func (PipeSourceParametersFilterCriteriaFilterArray) ToPipeSourceParametersFilterCriteriaFilterArrayOutput 

func (i PipeSourceParametersFilterCriteriaFilterArray) ToPipeSourceParametersFilterCriteriaFilterArrayOutput() PipeSourceParametersFilterCriteriaFilterArrayOutput

func (PipeSourceParametersFilterCriteriaFilterArray) ToPipeSourceParametersFilterCriteriaFilterArrayOutputWithContext 

func (i PipeSourceParametersFilterCriteriaFilterArray) ToPipeSourceParametersFilterCriteriaFilterArrayOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaFilterArrayOutput

type PipeSourceParametersFilterCriteriaFilterArrayInput 

type PipeSourceParametersFilterCriteriaFilterArrayInput interface {
	pulumi.Input

	ToPipeSourceParametersFilterCriteriaFilterArrayOutput() PipeSourceParametersFilterCriteriaFilterArrayOutput
	ToPipeSourceParametersFilterCriteriaFilterArrayOutputWithContext(context.Context) PipeSourceParametersFilterCriteriaFilterArrayOutput
}

PipeSourceParametersFilterCriteriaFilterArrayInput is an input type that accepts PipeSourceParametersFilterCriteriaFilterArray and PipeSourceParametersFilterCriteriaFilterArrayOutput values. You can construct a concrete instance of `PipeSourceParametersFilterCriteriaFilterArrayInput` via: 

PipeSourceParametersFilterCriteriaFilterArray{ PipeSourceParametersFilterCriteriaFilterArgs{...} }

type PipeSourceParametersFilterCriteriaFilterArrayOutput 

type PipeSourceParametersFilterCriteriaFilterArrayOutput struct{ *pulumi.OutputState }

func (PipeSourceParametersFilterCriteriaFilterArrayOutput) ElementType 

func (PipeSourceParametersFilterCriteriaFilterArrayOutput) ElementType() reflect.Type

func (PipeSourceParametersFilterCriteriaFilterArrayOutput) Index 

func (o PipeSourceParametersFilterCriteriaFilterArrayOutput) Index(i pulumi.IntInput) PipeSourceParametersFilterCriteriaFilterOutput

func (PipeSourceParametersFilterCriteriaFilterArrayOutput) ToPipeSourceParametersFilterCriteriaFilterArrayOutput 

func (o PipeSourceParametersFilterCriteriaFilterArrayOutput) ToPipeSourceParametersFilterCriteriaFilterArrayOutput() PipeSourceParametersFilterCriteriaFilterArrayOutput

func (PipeSourceParametersFilterCriteriaFilterArrayOutput) ToPipeSourceParametersFilterCriteriaFilterArrayOutputWithContext 

func (o PipeSourceParametersFilterCriteriaFilterArrayOutput) ToPipeSourceParametersFilterCriteriaFilterArrayOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaFilterArrayOutput

type PipeSourceParametersFilterCriteriaFilterInput 

type PipeSourceParametersFilterCriteriaFilterInput interface {
	pulumi.Input

	ToPipeSourceParametersFilterCriteriaFilterOutput() PipeSourceParametersFilterCriteriaFilterOutput
	ToPipeSourceParametersFilterCriteriaFilterOutputWithContext(context.Context) PipeSourceParametersFilterCriteriaFilterOutput
}

PipeSourceParametersFilterCriteriaFilterInput is an input type that accepts PipeSourceParametersFilterCriteriaFilterArgs and PipeSourceParametersFilterCriteriaFilterOutput values. You can construct a concrete instance of `PipeSourceParametersFilterCriteriaFilterInput` via: 

PipeSourceParametersFilterCriteriaFilterArgs{...}

type PipeSourceParametersFilterCriteriaFilterOutput 

type PipeSourceParametersFilterCriteriaFilterOutput struct{ *pulumi.OutputState }

func (PipeSourceParametersFilterCriteriaFilterOutput) ElementType 

func (PipeSourceParametersFilterCriteriaFilterOutput) ElementType() reflect.Type

func (PipeSourceParametersFilterCriteriaFilterOutput) Pattern 

func (o PipeSourceParametersFilterCriteriaFilterOutput) Pattern() pulumi.StringOutput

The event pattern. At most 4096 characters.

func (PipeSourceParametersFilterCriteriaFilterOutput) ToPipeSourceParametersFilterCriteriaFilterOutput 

func (o PipeSourceParametersFilterCriteriaFilterOutput) ToPipeSourceParametersFilterCriteriaFilterOutput() PipeSourceParametersFilterCriteriaFilterOutput

func (PipeSourceParametersFilterCriteriaFilterOutput) ToPipeSourceParametersFilterCriteriaFilterOutputWithContext 

func (o PipeSourceParametersFilterCriteriaFilterOutput) ToPipeSourceParametersFilterCriteriaFilterOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaFilterOutput

type PipeSourceParametersFilterCriteriaInput 

type PipeSourceParametersFilterCriteriaInput interface {
	pulumi.Input

	ToPipeSourceParametersFilterCriteriaOutput() PipeSourceParametersFilterCriteriaOutput
	ToPipeSourceParametersFilterCriteriaOutputWithContext(context.Context) PipeSourceParametersFilterCriteriaOutput
}

PipeSourceParametersFilterCriteriaInput is an input type that accepts PipeSourceParametersFilterCriteriaArgs and PipeSourceParametersFilterCriteriaOutput values. You can construct a concrete instance of `PipeSourceParametersFilterCriteriaInput` via: 

PipeSourceParametersFilterCriteriaArgs{...}

type PipeSourceParametersFilterCriteriaOutput 

type PipeSourceParametersFilterCriteriaOutput struct{ *pulumi.OutputState }

func (PipeSourceParametersFilterCriteriaOutput) ElementType 

func (PipeSourceParametersFilterCriteriaOutput) ElementType() reflect.Type

func (PipeSourceParametersFilterCriteriaOutput) Filters 

func (o PipeSourceParametersFilterCriteriaOutput) Filters() PipeSourceParametersFilterCriteriaFilterArrayOutput

An array of up to 5 event patterns. Detailed below.

func (PipeSourceParametersFilterCriteriaOutput) ToPipeSourceParametersFilterCriteriaOutput 

func (o PipeSourceParametersFilterCriteriaOutput) ToPipeSourceParametersFilterCriteriaOutput() PipeSourceParametersFilterCriteriaOutput

func (PipeSourceParametersFilterCriteriaOutput) ToPipeSourceParametersFilterCriteriaOutputWithContext 

func (o PipeSourceParametersFilterCriteriaOutput) ToPipeSourceParametersFilterCriteriaOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaOutput

func (PipeSourceParametersFilterCriteriaOutput) ToPipeSourceParametersFilterCriteriaPtrOutput 

func (o PipeSourceParametersFilterCriteriaOutput) ToPipeSourceParametersFilterCriteriaPtrOutput() PipeSourceParametersFilterCriteriaPtrOutput

func (PipeSourceParametersFilterCriteriaOutput) ToPipeSourceParametersFilterCriteriaPtrOutputWithContext 

func (o PipeSourceParametersFilterCriteriaOutput) ToPipeSourceParametersFilterCriteriaPtrOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaPtrOutput

type PipeSourceParametersFilterCriteriaPtrInput 

type PipeSourceParametersFilterCriteriaPtrInput interface {
	pulumi.Input

	ToPipeSourceParametersFilterCriteriaPtrOutput() PipeSourceParametersFilterCriteriaPtrOutput
	ToPipeSourceParametersFilterCriteriaPtrOutputWithContext(context.Context) PipeSourceParametersFilterCriteriaPtrOutput
}

PipeSourceParametersFilterCriteriaPtrInput is an input type that accepts PipeSourceParametersFilterCriteriaArgs, PipeSourceParametersFilterCriteriaPtr and PipeSourceParametersFilterCriteriaPtrOutput values. You can construct a concrete instance of `PipeSourceParametersFilterCriteriaPtrInput` via: 

        PipeSourceParametersFilterCriteriaArgs{...}

or:

        nil

func PipeSourceParametersFilterCriteriaPtr 

func PipeSourceParametersFilterCriteriaPtr(v *PipeSourceParametersFilterCriteriaArgs) PipeSourceParametersFilterCriteriaPtrInput

type PipeSourceParametersFilterCriteriaPtrOutput 

type PipeSourceParametersFilterCriteriaPtrOutput struct{ *pulumi.OutputState }

func (PipeSourceParametersFilterCriteriaPtrOutput) Elem 

func (o PipeSourceParametersFilterCriteriaPtrOutput) Elem() PipeSourceParametersFilterCriteriaOutput

func (PipeSourceParametersFilterCriteriaPtrOutput) ElementType 

func (PipeSourceParametersFilterCriteriaPtrOutput) ElementType() reflect.Type

func (PipeSourceParametersFilterCriteriaPtrOutput) Filters 

func (o PipeSourceParametersFilterCriteriaPtrOutput) Filters() PipeSourceParametersFilterCriteriaFilterArrayOutput

An array of up to 5 event patterns. Detailed below.

func (PipeSourceParametersFilterCriteriaPtrOutput) ToPipeSourceParametersFilterCriteriaPtrOutput 

func (o PipeSourceParametersFilterCriteriaPtrOutput) ToPipeSourceParametersFilterCriteriaPtrOutput() PipeSourceParametersFilterCriteriaPtrOutput

func (PipeSourceParametersFilterCriteriaPtrOutput) ToPipeSourceParametersFilterCriteriaPtrOutputWithContext 

func (o PipeSourceParametersFilterCriteriaPtrOutput) ToPipeSourceParametersFilterCriteriaPtrOutputWithContext(ctx context.Context) PipeSourceParametersFilterCriteriaPtrOutput

type PipeSourceParametersInput 

type PipeSourceParametersInput interface {
	pulumi.Input

	ToPipeSourceParametersOutput() PipeSourceParametersOutput
	ToPipeSourceParametersOutputWithContext(context.Context) PipeSourceParametersOutput
}

PipeSourceParametersInput is an input type that accepts PipeSourceParametersArgs and PipeSourceParametersOutput values. You can construct a concrete instance of `PipeSourceParametersInput` via: 

PipeSourceParametersArgs{...}

type PipeSourceParametersOutput 

type PipeSourceParametersOutput struct{ *pulumi.OutputState }

func (PipeSourceParametersOutput) ElementType 

func (PipeSourceParametersOutput) ElementType() reflect.Type

func (PipeSourceParametersOutput) FilterCriteria 

func (o PipeSourceParametersOutput) FilterCriteria() PipeSourceParametersFilterCriteriaPtrOutput

The collection of event patterns used to filter events. Detailed below.

func (PipeSourceParametersOutput) ToPipeSourceParametersOutput 

func (o PipeSourceParametersOutput) ToPipeSourceParametersOutput() PipeSourceParametersOutput

func (PipeSourceParametersOutput) ToPipeSourceParametersOutputWithContext 

func (o PipeSourceParametersOutput) ToPipeSourceParametersOutputWithContext(ctx context.Context) PipeSourceParametersOutput

func (PipeSourceParametersOutput) ToPipeSourceParametersPtrOutput 

func (o PipeSourceParametersOutput) ToPipeSourceParametersPtrOutput() PipeSourceParametersPtrOutput

func (PipeSourceParametersOutput) ToPipeSourceParametersPtrOutputWithContext 

func (o PipeSourceParametersOutput) ToPipeSourceParametersPtrOutputWithContext(ctx context.Context) PipeSourceParametersPtrOutput

type PipeSourceParametersPtrInput 

type PipeSourceParametersPtrInput interface {
	pulumi.Input

	ToPipeSourceParametersPtrOutput() PipeSourceParametersPtrOutput
	ToPipeSourceParametersPtrOutputWithContext(context.Context) PipeSourceParametersPtrOutput
}

PipeSourceParametersPtrInput is an input type that accepts PipeSourceParametersArgs, PipeSourceParametersPtr and PipeSourceParametersPtrOutput values. You can construct a concrete instance of `PipeSourceParametersPtrInput` via: 

        PipeSourceParametersArgs{...}

or:

        nil

func PipeSourceParametersPtr 

func PipeSourceParametersPtr(v *PipeSourceParametersArgs) PipeSourceParametersPtrInput

type PipeSourceParametersPtrOutput 

type PipeSourceParametersPtrOutput struct{ *pulumi.OutputState }

func (PipeSourceParametersPtrOutput) Elem 

func (o PipeSourceParametersPtrOutput) Elem() PipeSourceParametersOutput

func (PipeSourceParametersPtrOutput) ElementType 

func (PipeSourceParametersPtrOutput) ElementType() reflect.Type

func (PipeSourceParametersPtrOutput) FilterCriteria 

func (o PipeSourceParametersPtrOutput) FilterCriteria() PipeSourceParametersFilterCriteriaPtrOutput

The collection of event patterns used to filter events. Detailed below.

func (PipeSourceParametersPtrOutput) ToPipeSourceParametersPtrOutput 

func (o PipeSourceParametersPtrOutput) ToPipeSourceParametersPtrOutput() PipeSourceParametersPtrOutput

func (PipeSourceParametersPtrOutput) ToPipeSourceParametersPtrOutputWithContext 

func (o PipeSourceParametersPtrOutput) ToPipeSourceParametersPtrOutputWithContext(ctx context.Context) PipeSourceParametersPtrOutput

type PipeState 

type PipeState struct {
	// ARN of this pipe.
	Arn pulumi.StringPtrInput
	// A description of the pipe. At most 512 characters.
	Description pulumi.StringPtrInput
	// The state the pipe should be in. One of: `RUNNING`, `STOPPED`.
	DesiredState pulumi.StringPtrInput
	// Enrichment resource of the pipe (typically an ARN). Read more about enrichment in the [User Guide](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html#pipes-enrichment).
	Enrichment pulumi.StringPtrInput
	// Name of the pipe. If omitted, the provider will assign a random, unique name. Conflicts with `namePrefix`.
	Name pulumi.StringPtrInput
	// Creates a unique name beginning with the specified prefix. Conflicts with `name`.
	NamePrefix pulumi.StringPtrInput
	// ARN of the role that allows the pipe to send data to the target.
	RoleArn pulumi.StringPtrInput
	// Source resource of the pipe (typically an ARN).
	Source pulumi.StringPtrInput
	// Parameters required to set up a source for the pipe. Detailed below.
	SourceParameters PipeSourceParametersPtrInput
	// Key-value mapping of resource tags. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
	// Target resource of the pipe (typically an ARN).
	Target pulumi.StringPtrInput
	// Parameters required to set up a target for your pipe. Detailed below.
	//
	// The following arguments are optional:
	TargetParameters PipeTargetParametersPtrInput
}

func (PipeState) ElementType 

func (PipeState) ElementType() reflect.Type

type PipeTargetParameters 

type PipeTargetParameters struct {
	// Valid JSON text passed to the target. In this case, nothing from the event itself is passed to the target.
	InputTemplate *string `pulumi:"inputTemplate"`
}

type PipeTargetParametersArgs 

type PipeTargetParametersArgs struct {
	// Valid JSON text passed to the target. In this case, nothing from the event itself is passed to the target.
	InputTemplate pulumi.StringPtrInput `pulumi:"inputTemplate"`
}

func (PipeTargetParametersArgs) ElementType 

func (PipeTargetParametersArgs) ElementType() reflect.Type

func (PipeTargetParametersArgs) ToPipeTargetParametersOutput 

func (i PipeTargetParametersArgs) ToPipeTargetParametersOutput() PipeTargetParametersOutput

func (PipeTargetParametersArgs) ToPipeTargetParametersOutputWithContext 

func (i PipeTargetParametersArgs) ToPipeTargetParametersOutputWithContext(ctx context.Context) PipeTargetParametersOutput

func (PipeTargetParametersArgs) ToPipeTargetParametersPtrOutput 

func (i PipeTargetParametersArgs) ToPipeTargetParametersPtrOutput() PipeTargetParametersPtrOutput

func (PipeTargetParametersArgs) ToPipeTargetParametersPtrOutputWithContext 

func (i PipeTargetParametersArgs) ToPipeTargetParametersPtrOutputWithContext(ctx context.Context) PipeTargetParametersPtrOutput

type PipeTargetParametersInput 

type PipeTargetParametersInput interface {
	pulumi.Input

	ToPipeTargetParametersOutput() PipeTargetParametersOutput
	ToPipeTargetParametersOutputWithContext(context.Context) PipeTargetParametersOutput
}

PipeTargetParametersInput is an input type that accepts PipeTargetParametersArgs and PipeTargetParametersOutput values. You can construct a concrete instance of `PipeTargetParametersInput` via: 

PipeTargetParametersArgs{...}

type PipeTargetParametersOutput 

type PipeTargetParametersOutput struct{ *pulumi.OutputState }

func (PipeTargetParametersOutput) ElementType 

func (PipeTargetParametersOutput) ElementType() reflect.Type

func (PipeTargetParametersOutput) InputTemplate 

func (o PipeTargetParametersOutput) InputTemplate() pulumi.StringPtrOutput

Valid JSON text passed to the target. In this case, nothing from the event itself is passed to the target.

func (PipeTargetParametersOutput) ToPipeTargetParametersOutput 

func (o PipeTargetParametersOutput) ToPipeTargetParametersOutput() PipeTargetParametersOutput

func (PipeTargetParametersOutput) ToPipeTargetParametersOutputWithContext 

func (o PipeTargetParametersOutput) ToPipeTargetParametersOutputWithContext(ctx context.Context) PipeTargetParametersOutput

func (PipeTargetParametersOutput) ToPipeTargetParametersPtrOutput 

func (o PipeTargetParametersOutput) ToPipeTargetParametersPtrOutput() PipeTargetParametersPtrOutput

func (PipeTargetParametersOutput) ToPipeTargetParametersPtrOutputWithContext 

func (o PipeTargetParametersOutput) ToPipeTargetParametersPtrOutputWithContext(ctx context.Context) PipeTargetParametersPtrOutput

type PipeTargetParametersPtrInput 

type PipeTargetParametersPtrInput interface {
	pulumi.Input

	ToPipeTargetParametersPtrOutput() PipeTargetParametersPtrOutput
	ToPipeTargetParametersPtrOutputWithContext(context.Context) PipeTargetParametersPtrOutput
}

PipeTargetParametersPtrInput is an input type that accepts PipeTargetParametersArgs, PipeTargetParametersPtr and PipeTargetParametersPtrOutput values. You can construct a concrete instance of `PipeTargetParametersPtrInput` via: 

        PipeTargetParametersArgs{...}

or:

        nil

func PipeTargetParametersPtr 

func PipeTargetParametersPtr(v *PipeTargetParametersArgs) PipeTargetParametersPtrInput

type PipeTargetParametersPtrOutput 

type PipeTargetParametersPtrOutput struct{ *pulumi.OutputState }

func (PipeTargetParametersPtrOutput) Elem 

func (o PipeTargetParametersPtrOutput) Elem() PipeTargetParametersOutput

func (PipeTargetParametersPtrOutput) ElementType 

func (PipeTargetParametersPtrOutput) ElementType() reflect.Type

func (PipeTargetParametersPtrOutput) InputTemplate 

func (o PipeTargetParametersPtrOutput) InputTemplate() pulumi.StringPtrOutput

Valid JSON text passed to the target. In this case, nothing from the event itself is passed to the target.

func (PipeTargetParametersPtrOutput) ToPipeTargetParametersPtrOutput 

func (o PipeTargetParametersPtrOutput) ToPipeTargetParametersPtrOutput() PipeTargetParametersPtrOutput

func (PipeTargetParametersPtrOutput) ToPipeTargetParametersPtrOutputWithContext 

func (o PipeTargetParametersPtrOutput) ToPipeTargetParametersPtrOutputWithContext(ctx context.Context) PipeTargetParametersPtrOutput

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.