osis

package
v0.104.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LookupPipelineArgs

type LookupPipelineArgs struct {
	// The Amazon Resource Name (ARN) of the pipeline.
	PipelineArn string `pulumi:"pipelineArn"`
}

type LookupPipelineOutputArgs

type LookupPipelineOutputArgs struct {
	// The Amazon Resource Name (ARN) of the pipeline.
	PipelineArn pulumi.StringInput `pulumi:"pipelineArn"`
}

func (LookupPipelineOutputArgs) ElementType

func (LookupPipelineOutputArgs) ElementType() reflect.Type

type LookupPipelineResult

type LookupPipelineResult struct {
	BufferOptions           *PipelineBufferOptions           `pulumi:"bufferOptions"`
	EncryptionAtRestOptions *PipelineEncryptionAtRestOptions `pulumi:"encryptionAtRestOptions"`
	// A list of endpoints that can be used for ingesting data into a pipeline
	IngestEndpointUrls   []string                      `pulumi:"ingestEndpointUrls"`
	LogPublishingOptions *PipelineLogPublishingOptions `pulumi:"logPublishingOptions"`
	// The maximum pipeline capacity, in Ingestion OpenSearch Compute Units (OCUs).
	MaxUnits *int `pulumi:"maxUnits"`
	// The minimum pipeline capacity, in Ingestion OpenSearch Compute Units (OCUs).
	MinUnits *int `pulumi:"minUnits"`
	// The Amazon Resource Name (ARN) of the pipeline.
	PipelineArn *string `pulumi:"pipelineArn"`
	// The Data Prepper pipeline configuration.
	PipelineConfigurationBody *string `pulumi:"pipelineConfigurationBody"`
	// An array of key-value pairs to apply to this resource.
	Tags []aws.Tag `pulumi:"tags"`
	// The VPC interface endpoints that have access to the pipeline.
	VpcEndpoints []PipelineVpcEndpoint `pulumi:"vpcEndpoints"`
}

func LookupPipeline

func LookupPipeline(ctx *pulumi.Context, args *LookupPipelineArgs, opts ...pulumi.InvokeOption) (*LookupPipelineResult, error)

An OpenSearch Ingestion Service Data Prepper pipeline running Data Prepper.

type LookupPipelineResultOutput

type LookupPipelineResultOutput struct{ *pulumi.OutputState }

func (LookupPipelineResultOutput) BufferOptions added in v0.91.0

func (LookupPipelineResultOutput) ElementType

func (LookupPipelineResultOutput) ElementType() reflect.Type

func (LookupPipelineResultOutput) EncryptionAtRestOptions added in v0.91.0

func (LookupPipelineResultOutput) IngestEndpointUrls

func (o LookupPipelineResultOutput) IngestEndpointUrls() pulumi.StringArrayOutput

A list of endpoints that can be used for ingesting data into a pipeline

func (LookupPipelineResultOutput) LogPublishingOptions

func (LookupPipelineResultOutput) MaxUnits

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

func (LookupPipelineResultOutput) MinUnits

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

func (LookupPipelineResultOutput) PipelineArn

The Amazon Resource Name (ARN) of the pipeline.

func (LookupPipelineResultOutput) PipelineConfigurationBody

func (o LookupPipelineResultOutput) PipelineConfigurationBody() pulumi.StringPtrOutput

The Data Prepper pipeline configuration.

func (LookupPipelineResultOutput) Tags

An array of key-value pairs to apply to this resource.

func (LookupPipelineResultOutput) ToLookupPipelineResultOutput

func (o LookupPipelineResultOutput) ToLookupPipelineResultOutput() LookupPipelineResultOutput

func (LookupPipelineResultOutput) ToLookupPipelineResultOutputWithContext

func (o LookupPipelineResultOutput) ToLookupPipelineResultOutputWithContext(ctx context.Context) LookupPipelineResultOutput

func (LookupPipelineResultOutput) VpcEndpoints

The VPC interface endpoints that have access to the pipeline.

type Pipeline

type Pipeline struct {
	pulumi.CustomResourceState

	BufferOptions           PipelineBufferOptionsPtrOutput           `pulumi:"bufferOptions"`
	EncryptionAtRestOptions PipelineEncryptionAtRestOptionsPtrOutput `pulumi:"encryptionAtRestOptions"`
	// A list of endpoints that can be used for ingesting data into a pipeline
	IngestEndpointUrls   pulumi.StringArrayOutput              `pulumi:"ingestEndpointUrls"`
	LogPublishingOptions PipelineLogPublishingOptionsPtrOutput `pulumi:"logPublishingOptions"`
	// The maximum pipeline capacity, in Ingestion OpenSearch Compute Units (OCUs).
	MaxUnits pulumi.IntOutput `pulumi:"maxUnits"`
	// The minimum pipeline capacity, in Ingestion OpenSearch Compute Units (OCUs).
	MinUnits pulumi.IntOutput `pulumi:"minUnits"`
	// The Amazon Resource Name (ARN) of the pipeline.
	PipelineArn pulumi.StringOutput `pulumi:"pipelineArn"`
	// The Data Prepper pipeline configuration.
	PipelineConfigurationBody pulumi.StringOutput `pulumi:"pipelineConfigurationBody"`
	// Name of the OpenSearch Ingestion Service pipeline to create. Pipeline names are unique across the pipelines owned by an account within an AWS Region.
	PipelineName pulumi.StringOutput `pulumi:"pipelineName"`
	// An array of key-value pairs to apply to this resource.
	Tags aws.TagArrayOutput `pulumi:"tags"`
	// The VPC interface endpoints that have access to the pipeline.
	VpcEndpoints PipelineVpcEndpointArrayOutput `pulumi:"vpcEndpoints"`
	VpcOptions   PipelineVpcOptionsPtrOutput    `pulumi:"vpcOptions"`
}

An OpenSearch Ingestion Service Data Prepper pipeline running Data Prepper.

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 {
	BufferOptions           PipelineBufferOptionsPtrInput
	EncryptionAtRestOptions PipelineEncryptionAtRestOptionsPtrInput
	LogPublishingOptions    PipelineLogPublishingOptionsPtrInput
	// The maximum pipeline capacity, in Ingestion OpenSearch Compute Units (OCUs).
	MaxUnits pulumi.IntInput
	// The minimum pipeline capacity, in Ingestion OpenSearch Compute Units (OCUs).
	MinUnits pulumi.IntInput
	// The Data Prepper pipeline configuration.
	PipelineConfigurationBody pulumi.StringInput
	// Name of the OpenSearch Ingestion Service pipeline to create. Pipeline names are unique across the pipelines owned by an account within an AWS Region.
	PipelineName pulumi.StringPtrInput
	// An array of key-value pairs to apply to this resource.
	Tags       aws.TagArrayInput
	VpcOptions PipelineVpcOptionsPtrInput
}

The set of arguments for constructing a Pipeline resource.

func (PipelineArgs) ElementType

func (PipelineArgs) ElementType() reflect.Type

type PipelineBufferOptions added in v0.91.0

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

Key-value pairs to configure buffering.

type PipelineBufferOptionsArgs added in v0.91.0

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

Key-value pairs to configure buffering.

func (PipelineBufferOptionsArgs) ElementType added in v0.91.0

func (PipelineBufferOptionsArgs) ElementType() reflect.Type

func (PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutput added in v0.91.0

func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutput() PipelineBufferOptionsOutput

func (PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutputWithContext added in v0.91.0

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

func (PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutput added in v0.91.0

func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput

func (PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutputWithContext added in v0.91.0

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

type PipelineBufferOptionsInput added in v0.91.0

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 added in v0.91.0

type PipelineBufferOptionsOutput struct{ *pulumi.OutputState }

Key-value pairs to configure buffering.

func (PipelineBufferOptionsOutput) ElementType added in v0.91.0

func (PipelineBufferOptionsOutput) PersistentBufferEnabled added in v0.91.0

func (o PipelineBufferOptionsOutput) PersistentBufferEnabled() pulumi.BoolOutput

Whether persistent buffering should be enabled.

func (PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutput added in v0.91.0

func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutput() PipelineBufferOptionsOutput

func (PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutputWithContext added in v0.91.0

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

func (PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutput added in v0.91.0

func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput

func (PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutputWithContext added in v0.91.0

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

type PipelineBufferOptionsPtrInput added in v0.91.0

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 added in v0.91.0

func PipelineBufferOptionsPtr(v *PipelineBufferOptionsArgs) PipelineBufferOptionsPtrInput

type PipelineBufferOptionsPtrOutput added in v0.91.0

type PipelineBufferOptionsPtrOutput struct{ *pulumi.OutputState }

func (PipelineBufferOptionsPtrOutput) Elem added in v0.91.0

func (PipelineBufferOptionsPtrOutput) ElementType added in v0.91.0

func (PipelineBufferOptionsPtrOutput) PersistentBufferEnabled added in v0.91.0

func (o PipelineBufferOptionsPtrOutput) PersistentBufferEnabled() pulumi.BoolPtrOutput

Whether persistent buffering should be enabled.

func (PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutput added in v0.91.0

func (o PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput

func (PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutputWithContext added in v0.91.0

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

type PipelineEncryptionAtRestOptions added in v0.91.0

type PipelineEncryptionAtRestOptions struct {
	// The KMS key to use for encrypting data. By default an AWS owned key is used
	KmsKeyArn string `pulumi:"kmsKeyArn"`
}

Key-value pairs to configure encryption at rest.

type PipelineEncryptionAtRestOptionsArgs added in v0.91.0

type PipelineEncryptionAtRestOptionsArgs struct {
	// The KMS key to use for encrypting data. By default an AWS owned key is used
	KmsKeyArn pulumi.StringInput `pulumi:"kmsKeyArn"`
}

Key-value pairs to configure encryption at rest.

func (PipelineEncryptionAtRestOptionsArgs) ElementType added in v0.91.0

func (PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutput added in v0.91.0

func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutput() PipelineEncryptionAtRestOptionsOutput

func (PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutputWithContext added in v0.91.0

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

func (PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutput added in v0.91.0

func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput

func (PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext added in v0.91.0

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

type PipelineEncryptionAtRestOptionsInput added in v0.91.0

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 added in v0.91.0

type PipelineEncryptionAtRestOptionsOutput struct{ *pulumi.OutputState }

Key-value pairs to configure encryption at rest.

func (PipelineEncryptionAtRestOptionsOutput) ElementType added in v0.91.0

func (PipelineEncryptionAtRestOptionsOutput) KmsKeyArn added in v0.91.0

The KMS key to use for encrypting data. By default an AWS owned key is used

func (PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutput added in v0.91.0

func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutput() PipelineEncryptionAtRestOptionsOutput

func (PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutputWithContext added in v0.91.0

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

func (PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutput added in v0.91.0

func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput

func (PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext added in v0.91.0

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

type PipelineEncryptionAtRestOptionsPtrInput added in v0.91.0

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

type PipelineEncryptionAtRestOptionsPtrOutput added in v0.91.0

type PipelineEncryptionAtRestOptionsPtrOutput struct{ *pulumi.OutputState }

func (PipelineEncryptionAtRestOptionsPtrOutput) Elem added in v0.91.0

func (PipelineEncryptionAtRestOptionsPtrOutput) ElementType added in v0.91.0

func (PipelineEncryptionAtRestOptionsPtrOutput) KmsKeyArn added in v0.91.0

The KMS key to use for encrypting data. By default an AWS owned key is used

func (PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutput added in v0.91.0

func (o PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput

func (PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext added in v0.91.0

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 Service logs sent to Amazon CloudWatch.
	CloudWatchLogDestination *PipelineLogPublishingOptionsCloudWatchLogDestinationProperties `pulumi:"cloudWatchLogDestination"`
	// Whether logs should be published.
	IsLoggingEnabled *bool `pulumi:"isLoggingEnabled"`
}

Key-value pairs to configure log publishing.

type PipelineLogPublishingOptionsArgs

type PipelineLogPublishingOptionsArgs struct {
	// The destination for OpenSearch Ingestion Service logs sent to Amazon CloudWatch.
	CloudWatchLogDestination PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrInput `pulumi:"cloudWatchLogDestination"`
	// Whether logs should be published.
	IsLoggingEnabled pulumi.BoolPtrInput `pulumi:"isLoggingEnabled"`
}

Key-value pairs to configure log publishing.

func (PipelineLogPublishingOptionsArgs) ElementType

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 PipelineLogPublishingOptionsCloudWatchLogDestinationProperties

type PipelineLogPublishingOptionsCloudWatchLogDestinationProperties struct {
	LogGroup string `pulumi:"logGroup"`
}

The destination for OpenSearch Ingestion Service logs sent to Amazon CloudWatch.

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs struct {
	LogGroup pulumi.StringInput `pulumi:"logGroup"`
}

The destination for OpenSearch Ingestion Service logs sent to Amazon CloudWatch.

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ElementType

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext

func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext

func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesInput

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesInput interface {
	pulumi.Input

	ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput
	ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext(context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput
}

PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesInput is an input type that accepts PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs and PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput values. You can construct a concrete instance of `PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesInput` via:

PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs{...}

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput struct{ *pulumi.OutputState }

The destination for OpenSearch Ingestion Service logs sent to Amazon CloudWatch.

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ElementType

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) LogGroup

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrInput

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrInput interface {
	pulumi.Input

	ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
	ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext(context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
}

PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrInput is an input type that accepts PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs, PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtr and PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput values. You can construct a concrete instance of `PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrInput` via:

        PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs{...}

or:

        nil

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput struct{ *pulumi.OutputState }

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) Elem

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ElementType

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) LogGroup

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

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 }

Key-value pairs to configure log publishing.

func (PipelineLogPublishingOptionsOutput) CloudWatchLogDestination

The destination for OpenSearch Ingestion Service logs sent to Amazon CloudWatch.

func (PipelineLogPublishingOptionsOutput) ElementType

func (PipelineLogPublishingOptionsOutput) IsLoggingEnabled

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

type PipelineLogPublishingOptionsPtrOutput

type PipelineLogPublishingOptionsPtrOutput struct{ *pulumi.OutputState }

func (PipelineLogPublishingOptionsPtrOutput) CloudWatchLogDestination

The destination for OpenSearch Ingestion Service logs sent to Amazon CloudWatch.

func (PipelineLogPublishingOptionsPtrOutput) Elem

func (PipelineLogPublishingOptionsPtrOutput) ElementType

func (PipelineLogPublishingOptionsPtrOutput) IsLoggingEnabled

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 PipelineOutput

type PipelineOutput struct{ *pulumi.OutputState }

func (PipelineOutput) BufferOptions added in v0.91.0

func (PipelineOutput) ElementType

func (PipelineOutput) ElementType() reflect.Type

func (PipelineOutput) EncryptionAtRestOptions added in v0.91.0

func (o PipelineOutput) EncryptionAtRestOptions() PipelineEncryptionAtRestOptionsPtrOutput

func (PipelineOutput) IngestEndpointUrls

func (o PipelineOutput) IngestEndpointUrls() pulumi.StringArrayOutput

A list of endpoints that can be used for ingesting data into a pipeline

func (PipelineOutput) LogPublishingOptions

func (o PipelineOutput) LogPublishingOptions() PipelineLogPublishingOptionsPtrOutput

func (PipelineOutput) MaxUnits

func (o PipelineOutput) MaxUnits() pulumi.IntOutput

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

func (PipelineOutput) MinUnits

func (o PipelineOutput) MinUnits() pulumi.IntOutput

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

func (PipelineOutput) PipelineArn

func (o PipelineOutput) PipelineArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the pipeline.

func (PipelineOutput) PipelineConfigurationBody

func (o PipelineOutput) PipelineConfigurationBody() pulumi.StringOutput

The Data Prepper pipeline configuration.

func (PipelineOutput) PipelineName

func (o PipelineOutput) PipelineName() pulumi.StringOutput

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

func (PipelineOutput) Tags

An array of key-value pairs to apply to this resource.

func (PipelineOutput) ToPipelineOutput

func (o PipelineOutput) ToPipelineOutput() PipelineOutput

func (PipelineOutput) ToPipelineOutputWithContext

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

func (PipelineOutput) VpcEndpoints

The VPC interface endpoints that have access to the pipeline.

func (PipelineOutput) VpcOptions

type PipelineState

type PipelineState struct {
}

func (PipelineState) ElementType

func (PipelineState) ElementType() reflect.Type

type PipelineTag

type PipelineTag struct {
	// The key name of the tag. You can specify a value that is 1 to 128 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.
	Key string `pulumi:"key"`
	// The value for the tag. You can specify a value that is 0 to 256 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.
	Value string `pulumi:"value"`
}

A key-value pair to associate with a resource.

type PipelineVpcEndpoint

type PipelineVpcEndpoint struct {
	// The unique identifier of the endpoint.
	VpcEndpointId *string `pulumi:"vpcEndpointId"`
	// The ID for your VPC. AWS Privatelink generates this value when you create a VPC.
	VpcId      *string             `pulumi:"vpcId"`
	VpcOptions *PipelineVpcOptions `pulumi:"vpcOptions"`
}

An OpenSearch Ingestion Service-managed VPC endpoint that will access one or more pipelines.

type PipelineVpcEndpointArrayOutput

type PipelineVpcEndpointArrayOutput struct{ *pulumi.OutputState }

func (PipelineVpcEndpointArrayOutput) ElementType

func (PipelineVpcEndpointArrayOutput) Index

func (PipelineVpcEndpointArrayOutput) ToPipelineVpcEndpointArrayOutput

func (o PipelineVpcEndpointArrayOutput) ToPipelineVpcEndpointArrayOutput() PipelineVpcEndpointArrayOutput

func (PipelineVpcEndpointArrayOutput) ToPipelineVpcEndpointArrayOutputWithContext

func (o PipelineVpcEndpointArrayOutput) ToPipelineVpcEndpointArrayOutputWithContext(ctx context.Context) PipelineVpcEndpointArrayOutput

type PipelineVpcEndpointOutput

type PipelineVpcEndpointOutput struct{ *pulumi.OutputState }

An OpenSearch Ingestion Service-managed VPC endpoint that will access one or more pipelines.

func (PipelineVpcEndpointOutput) ElementType

func (PipelineVpcEndpointOutput) ElementType() reflect.Type

func (PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutput

func (o PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutput() PipelineVpcEndpointOutput

func (PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutputWithContext

func (o PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutputWithContext(ctx context.Context) PipelineVpcEndpointOutput

func (PipelineVpcEndpointOutput) VpcEndpointId

The unique identifier of the endpoint.

func (PipelineVpcEndpointOutput) VpcId

The ID for your VPC. AWS Privatelink generates this value when you create a VPC.

func (PipelineVpcEndpointOutput) VpcOptions

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"`
}

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

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"`
}

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

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 }

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

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

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

type PipelineVpcOptionsPtrOutput

type PipelineVpcOptionsPtrOutput struct{ *pulumi.OutputState }

func (PipelineVpcOptionsPtrOutput) Elem

func (PipelineVpcOptionsPtrOutput) ElementType

func (PipelineVpcOptionsPtrOutput) SecurityGroupIds

A list of security groups associated with the VPC endpoint.

func (PipelineVpcOptionsPtrOutput) SubnetIds

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

Jump to

Keyboard shortcuts

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