osis

package
v0.84.0 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2023 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 {
	// 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 Compute Units (ICUs).
	MaxUnits *int `pulumi:"maxUnits"`
	// The minimum pipeline capacity, in Ingestion Compute Units (ICUs).
	MinUnits *int `pulumi:"minUnits"`
	// The Amazon Resource Name (ARN) of the pipeline.
	PipelineArn *string `pulumi:"pipelineArn"`
	// The Data Prepper pipeline configuration in YAML format.
	PipelineConfigurationBody *string `pulumi:"pipelineConfigurationBody"`
	// An array of key-value pairs to apply to this resource.
	Tags []PipelineTag `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 LookupPipelineOutput 

func LookupPipelineOutput(ctx *pulumi.Context, args LookupPipelineOutputArgs, opts ...pulumi.InvokeOption) LookupPipelineResultOutput

func (LookupPipelineResultOutput) ElementType 

func (LookupPipelineResultOutput) ElementType() reflect.Type

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 (o LookupPipelineResultOutput) LogPublishingOptions() PipelineLogPublishingOptionsPtrOutput

func (LookupPipelineResultOutput) MaxUnits 

func (o LookupPipelineResultOutput) MaxUnits() pulumi.IntPtrOutput

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

func (LookupPipelineResultOutput) MinUnits 

func (o LookupPipelineResultOutput) MinUnits() pulumi.IntPtrOutput

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

func (LookupPipelineResultOutput) PipelineArn 

func (o LookupPipelineResultOutput) PipelineArn() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) of the pipeline.

func (LookupPipelineResultOutput) PipelineConfigurationBody 

func (o LookupPipelineResultOutput) PipelineConfigurationBody() pulumi.StringPtrOutput

The Data Prepper pipeline configuration in YAML format.

func (LookupPipelineResultOutput) Tags 

func (o LookupPipelineResultOutput) Tags() PipelineTagArrayOutput

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) ToOutput added in v0.76.0 

func (o LookupPipelineResultOutput) ToOutput(ctx context.Context) pulumix.Output[LookupPipelineResult]

func (LookupPipelineResultOutput) VpcEndpoints 

func (o LookupPipelineResultOutput) VpcEndpoints() PipelineVpcEndpointArrayOutput

The VPC interface endpoints that have access to the pipeline.

type Pipeline 

type Pipeline struct {
	pulumi.CustomResourceState

	// 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 Compute Units (ICUs).
	MaxUnits pulumi.IntOutput `pulumi:"maxUnits"`
	// The minimum pipeline capacity, in Ingestion Compute Units (ICUs).
	MinUnits pulumi.IntOutput `pulumi:"minUnits"`
	// The Amazon Resource Name (ARN) of the pipeline.
	PipelineArn pulumi.StringOutput `pulumi:"pipelineArn"`
	// The Data Prepper pipeline configuration in YAML format.
	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 PipelineTagArrayOutput `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) ToOutput added in v0.76.0 

func (i *Pipeline) ToOutput(ctx context.Context) pulumix.Output[*Pipeline]

func (*Pipeline) ToPipelineOutput 

func (i *Pipeline) ToPipelineOutput() PipelineOutput

func (*Pipeline) ToPipelineOutputWithContext 

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

type PipelineArgs 

type PipelineArgs struct {
	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 Data Prepper pipeline configuration in YAML format.
	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       PipelineTagArrayInput
	VpcOptions PipelineVpcOptionsPtrInput
}

The set of arguments for constructing a Pipeline resource.

func (PipelineArgs) ElementType 

func (PipelineArgs) ElementType() reflect.Type

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) ElementType() reflect.Type

func (PipelineLogPublishingOptionsArgs) ToOutput added in v0.76.0 

func (i PipelineLogPublishingOptionsArgs) ToOutput(ctx context.Context) pulumix.Output[PipelineLogPublishingOptions]

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.StringPtrInput `pulumi:"logGroup"`
}

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

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ElementType 

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ElementType() reflect.Type

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToOutput added in v0.76.0 

func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToOutput(ctx context.Context) pulumix.Output[PipelineLogPublishingOptionsCloudWatchLogDestinationProperties]

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput 

func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext 

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

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput 

func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

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) ElementType() reflect.Type

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) LogGroup 

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) LogGroup() pulumi.StringPtrOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToOutput added in v0.76.0 

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToOutput(ctx context.Context) pulumix.Output[PipelineLogPublishingOptionsCloudWatchLogDestinationProperties]

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput 

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext 

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

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput 

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

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

func PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtr 

func PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtr(v *PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrInput

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput 

type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput struct{ *pulumi.OutputState }

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) Elem 

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) Elem() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ElementType 

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ElementType() reflect.Type

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) LogGroup 

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) LogGroup() pulumi.StringPtrOutput

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToOutput added in v0.76.0 

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*PipelineLogPublishingOptionsCloudWatchLogDestinationProperties]

func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput 

func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

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 

func (o PipelineLogPublishingOptionsOutput) CloudWatchLogDestination() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

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

func (PipelineLogPublishingOptionsOutput) ElementType 

func (PipelineLogPublishingOptionsOutput) ElementType() reflect.Type

func (PipelineLogPublishingOptionsOutput) IsLoggingEnabled 

func (o PipelineLogPublishingOptionsOutput) IsLoggingEnabled() pulumi.BoolPtrOutput

Whether logs should be published.

func (PipelineLogPublishingOptionsOutput) ToOutput added in v0.76.0 

func (o PipelineLogPublishingOptionsOutput) ToOutput(ctx context.Context) pulumix.Output[PipelineLogPublishingOptions]

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() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput

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

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) ToOutput added in v0.76.0 

func (o PipelineLogPublishingOptionsPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*PipelineLogPublishingOptions]

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) ElementType 

func (PipelineOutput) ElementType() reflect.Type

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 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

The Amazon Resource Name (ARN) of the pipeline.

func (PipelineOutput) PipelineConfigurationBody 

func (o PipelineOutput) PipelineConfigurationBody() pulumi.StringOutput

The Data Prepper pipeline configuration in YAML format.

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 

func (o PipelineOutput) Tags() PipelineTagArrayOutput

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

func (PipelineOutput) ToOutput added in v0.76.0 

func (o PipelineOutput) ToOutput(ctx context.Context) pulumix.Output[*Pipeline]

func (PipelineOutput) ToPipelineOutput 

func (o PipelineOutput) ToPipelineOutput() PipelineOutput

func (PipelineOutput) ToPipelineOutputWithContext 

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

func (PipelineOutput) VpcEndpoints 

func (o PipelineOutput) VpcEndpoints() PipelineVpcEndpointArrayOutput

The VPC interface endpoints that have access to the pipeline.

func (PipelineOutput) VpcOptions 

func (o PipelineOutput) VpcOptions() PipelineVpcOptionsPtrOutput

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 PipelineTagArgs 

type PipelineTagArgs 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 pulumi.StringInput `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 pulumi.StringInput `pulumi:"value"`
}

A key-value pair to associate with a resource.

func (PipelineTagArgs) ElementType 

func (PipelineTagArgs) ElementType() reflect.Type

func (PipelineTagArgs) ToOutput added in v0.76.0 

func (i PipelineTagArgs) ToOutput(ctx context.Context) pulumix.Output[PipelineTag]

func (PipelineTagArgs) ToPipelineTagOutput 

func (i PipelineTagArgs) ToPipelineTagOutput() PipelineTagOutput

func (PipelineTagArgs) ToPipelineTagOutputWithContext 

func (i PipelineTagArgs) ToPipelineTagOutputWithContext(ctx context.Context) PipelineTagOutput

type PipelineTagArray 

type PipelineTagArray []PipelineTagInput

func (PipelineTagArray) ElementType 

func (PipelineTagArray) ElementType() reflect.Type

func (PipelineTagArray) ToOutput added in v0.76.0 

func (i PipelineTagArray) ToOutput(ctx context.Context) pulumix.Output[[]PipelineTag]

func (PipelineTagArray) ToPipelineTagArrayOutput 

func (i PipelineTagArray) ToPipelineTagArrayOutput() PipelineTagArrayOutput

func (PipelineTagArray) ToPipelineTagArrayOutputWithContext 

func (i PipelineTagArray) ToPipelineTagArrayOutputWithContext(ctx context.Context) PipelineTagArrayOutput

type PipelineTagArrayInput 

type PipelineTagArrayInput interface {
	pulumi.Input

	ToPipelineTagArrayOutput() PipelineTagArrayOutput
	ToPipelineTagArrayOutputWithContext(context.Context) PipelineTagArrayOutput
}

PipelineTagArrayInput is an input type that accepts PipelineTagArray and PipelineTagArrayOutput values. You can construct a concrete instance of `PipelineTagArrayInput` via: 

PipelineTagArray{ PipelineTagArgs{...} }

type PipelineTagArrayOutput 

type PipelineTagArrayOutput struct{ *pulumi.OutputState }

func (PipelineTagArrayOutput) ElementType 

func (PipelineTagArrayOutput) ElementType() reflect.Type

func (PipelineTagArrayOutput) Index 

func (o PipelineTagArrayOutput) Index(i pulumi.IntInput) PipelineTagOutput

func (PipelineTagArrayOutput) ToOutput added in v0.76.0 

func (o PipelineTagArrayOutput) ToOutput(ctx context.Context) pulumix.Output[[]PipelineTag]

func (PipelineTagArrayOutput) ToPipelineTagArrayOutput 

func (o PipelineTagArrayOutput) ToPipelineTagArrayOutput() PipelineTagArrayOutput

func (PipelineTagArrayOutput) ToPipelineTagArrayOutputWithContext 

func (o PipelineTagArrayOutput) ToPipelineTagArrayOutputWithContext(ctx context.Context) PipelineTagArrayOutput

type PipelineTagInput 

type PipelineTagInput interface {
	pulumi.Input

	ToPipelineTagOutput() PipelineTagOutput
	ToPipelineTagOutputWithContext(context.Context) PipelineTagOutput
}

PipelineTagInput is an input type that accepts PipelineTagArgs and PipelineTagOutput values. You can construct a concrete instance of `PipelineTagInput` via: 

PipelineTagArgs{...}

type PipelineTagOutput 

type PipelineTagOutput struct{ *pulumi.OutputState }

A key-value pair to associate with a resource.

func (PipelineTagOutput) ElementType 

func (PipelineTagOutput) ElementType() reflect.Type

func (PipelineTagOutput) Key 

func (o PipelineTagOutput) Key() pulumi.StringOutput

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 -.

func (PipelineTagOutput) ToOutput added in v0.76.0 

func (o PipelineTagOutput) ToOutput(ctx context.Context) pulumix.Output[PipelineTag]

func (PipelineTagOutput) ToPipelineTagOutput 

func (o PipelineTagOutput) ToPipelineTagOutput() PipelineTagOutput

func (PipelineTagOutput) ToPipelineTagOutputWithContext 

func (o PipelineTagOutput) ToPipelineTagOutputWithContext(ctx context.Context) PipelineTagOutput

func (PipelineTagOutput) Value 

func (o PipelineTagOutput) Value() pulumi.StringOutput

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 -.

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) ElementType() reflect.Type

func (PipelineVpcEndpointArrayOutput) Index 

func (o PipelineVpcEndpointArrayOutput) Index(i pulumi.IntInput) PipelineVpcEndpointOutput

func (PipelineVpcEndpointArrayOutput) ToOutput added in v0.76.0 

func (o PipelineVpcEndpointArrayOutput) ToOutput(ctx context.Context) pulumix.Output[[]PipelineVpcEndpoint]

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) ToOutput added in v0.76.0 

func (o PipelineVpcEndpointOutput) ToOutput(ctx context.Context) pulumix.Output[PipelineVpcEndpoint]

func (PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutput 

func (o PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutput() PipelineVpcEndpointOutput

func (PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutputWithContext 

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

func (PipelineVpcEndpointOutput) VpcEndpointId 

func (o PipelineVpcEndpointOutput) VpcEndpointId() pulumi.StringPtrOutput

The unique identifier of the endpoint.

func (PipelineVpcEndpointOutput) VpcId 

func (o PipelineVpcEndpointOutput) VpcId() pulumi.StringPtrOutput

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

func (PipelineVpcEndpointOutput) VpcOptions 

func (o PipelineVpcEndpointOutput) VpcOptions() PipelineVpcOptionsPtrOutput

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) ToOutput added in v0.76.0 

func (i PipelineVpcOptionsArgs) ToOutput(ctx context.Context) pulumix.Output[PipelineVpcOptions]

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 

func (o PipelineVpcOptionsOutput) SubnetIds() pulumi.StringArrayOutput

A list of subnet IDs associated with the VPC endpoint.

func (PipelineVpcOptionsOutput) ToOutput added in v0.76.0 

func (o PipelineVpcOptionsOutput) ToOutput(ctx context.Context) pulumix.Output[PipelineVpcOptions]

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) ToOutput added in v0.76.0 

func (o PipelineVpcOptionsPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*PipelineVpcOptions]

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.