Documentation
¶
Index ¶
- type LookupPipelineArgs
- type LookupPipelineOutputArgs
- type LookupPipelineResult
- type LookupPipelineResultOutput
- func (o LookupPipelineResultOutput) BufferOptions() PipelineBufferOptionsPtrOutput
- func (LookupPipelineResultOutput) ElementType() reflect.Type
- func (o LookupPipelineResultOutput) EncryptionAtRestOptions() PipelineEncryptionAtRestOptionsPtrOutput
- func (o LookupPipelineResultOutput) IngestEndpointUrls() pulumi.StringArrayOutput
- func (o LookupPipelineResultOutput) LogPublishingOptions() PipelineLogPublishingOptionsPtrOutput
- func (o LookupPipelineResultOutput) MaxUnits() pulumi.IntPtrOutput
- func (o LookupPipelineResultOutput) MinUnits() pulumi.IntPtrOutput
- func (o LookupPipelineResultOutput) PipelineArn() pulumi.StringPtrOutput
- func (o LookupPipelineResultOutput) PipelineConfigurationBody() pulumi.StringPtrOutput
- func (o LookupPipelineResultOutput) Tags() aws.TagArrayOutput
- func (o LookupPipelineResultOutput) ToLookupPipelineResultOutput() LookupPipelineResultOutput
- func (o LookupPipelineResultOutput) ToLookupPipelineResultOutputWithContext(ctx context.Context) LookupPipelineResultOutput
- func (o LookupPipelineResultOutput) VpcEndpoints() PipelineVpcEndpointArrayOutput
- type Pipeline
- type PipelineArgs
- type PipelineBufferOptions
- type PipelineBufferOptionsArgs
- func (PipelineBufferOptionsArgs) ElementType() reflect.Type
- func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutput() PipelineBufferOptionsOutput
- func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsOutputWithContext(ctx context.Context) PipelineBufferOptionsOutput
- func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput
- func (i PipelineBufferOptionsArgs) ToPipelineBufferOptionsPtrOutputWithContext(ctx context.Context) PipelineBufferOptionsPtrOutput
- type PipelineBufferOptionsInput
- type PipelineBufferOptionsOutput
- func (PipelineBufferOptionsOutput) ElementType() reflect.Type
- func (o PipelineBufferOptionsOutput) PersistentBufferEnabled() pulumi.BoolOutput
- func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutput() PipelineBufferOptionsOutput
- func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsOutputWithContext(ctx context.Context) PipelineBufferOptionsOutput
- func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput
- func (o PipelineBufferOptionsOutput) ToPipelineBufferOptionsPtrOutputWithContext(ctx context.Context) PipelineBufferOptionsPtrOutput
- type PipelineBufferOptionsPtrInput
- type PipelineBufferOptionsPtrOutput
- func (o PipelineBufferOptionsPtrOutput) Elem() PipelineBufferOptionsOutput
- func (PipelineBufferOptionsPtrOutput) ElementType() reflect.Type
- func (o PipelineBufferOptionsPtrOutput) PersistentBufferEnabled() pulumi.BoolPtrOutput
- func (o PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutput() PipelineBufferOptionsPtrOutput
- func (o PipelineBufferOptionsPtrOutput) ToPipelineBufferOptionsPtrOutputWithContext(ctx context.Context) PipelineBufferOptionsPtrOutput
- type PipelineEncryptionAtRestOptions
- type PipelineEncryptionAtRestOptionsArgs
- func (PipelineEncryptionAtRestOptionsArgs) ElementType() reflect.Type
- func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutput() PipelineEncryptionAtRestOptionsOutput
- func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsOutput
- func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput
- func (i PipelineEncryptionAtRestOptionsArgs) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsPtrOutput
- type PipelineEncryptionAtRestOptionsInput
- type PipelineEncryptionAtRestOptionsOutput
- func (PipelineEncryptionAtRestOptionsOutput) ElementType() reflect.Type
- func (o PipelineEncryptionAtRestOptionsOutput) KmsKeyArn() pulumi.StringOutput
- func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutput() PipelineEncryptionAtRestOptionsOutput
- func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsOutput
- func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput
- func (o PipelineEncryptionAtRestOptionsOutput) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsPtrOutput
- type PipelineEncryptionAtRestOptionsPtrInput
- type PipelineEncryptionAtRestOptionsPtrOutput
- func (o PipelineEncryptionAtRestOptionsPtrOutput) Elem() PipelineEncryptionAtRestOptionsOutput
- func (PipelineEncryptionAtRestOptionsPtrOutput) ElementType() reflect.Type
- func (o PipelineEncryptionAtRestOptionsPtrOutput) KmsKeyArn() pulumi.StringPtrOutput
- func (o PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutput() PipelineEncryptionAtRestOptionsPtrOutput
- func (o PipelineEncryptionAtRestOptionsPtrOutput) ToPipelineEncryptionAtRestOptionsPtrOutputWithContext(ctx context.Context) PipelineEncryptionAtRestOptionsPtrOutput
- type PipelineInput
- type PipelineLogPublishingOptions
- type PipelineLogPublishingOptionsArgs
- func (PipelineLogPublishingOptionsArgs) ElementType() reflect.Type
- func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutput() PipelineLogPublishingOptionsOutput
- func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsOutput
- func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput
- func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsPtrOutput
- type PipelineLogPublishingOptionsCloudWatchLogDestinationProperties
- type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs
- func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ElementType() reflect.Type
- func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput
- func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput
- func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- func (i PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesArgs) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesInput
- type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput
- func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ElementType() reflect.Type
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) LogGroup() pulumi.StringOutput
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrInput
- type PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) Elem() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesOutput
- func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ElementType() reflect.Type
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) LogGroup() pulumi.StringPtrOutput
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- func (o PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ToPipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- type PipelineLogPublishingOptionsInput
- type PipelineLogPublishingOptionsOutput
- func (o PipelineLogPublishingOptionsOutput) CloudWatchLogDestination() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- func (PipelineLogPublishingOptionsOutput) ElementType() reflect.Type
- func (o PipelineLogPublishingOptionsOutput) IsLoggingEnabled() pulumi.BoolPtrOutput
- func (o PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsOutput() PipelineLogPublishingOptionsOutput
- func (o PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsOutput
- func (o PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput
- func (o PipelineLogPublishingOptionsOutput) ToPipelineLogPublishingOptionsPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsPtrOutput
- type PipelineLogPublishingOptionsPtrInput
- type PipelineLogPublishingOptionsPtrOutput
- func (o PipelineLogPublishingOptionsPtrOutput) CloudWatchLogDestination() PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput
- func (o PipelineLogPublishingOptionsPtrOutput) Elem() PipelineLogPublishingOptionsOutput
- func (PipelineLogPublishingOptionsPtrOutput) ElementType() reflect.Type
- func (o PipelineLogPublishingOptionsPtrOutput) IsLoggingEnabled() pulumi.BoolPtrOutput
- func (o PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput
- func (o PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsPtrOutput
- type PipelineOutput
- func (o PipelineOutput) BufferOptions() PipelineBufferOptionsPtrOutput
- func (PipelineOutput) ElementType() reflect.Type
- func (o PipelineOutput) EncryptionAtRestOptions() PipelineEncryptionAtRestOptionsPtrOutput
- func (o PipelineOutput) IngestEndpointUrls() pulumi.StringArrayOutput
- func (o PipelineOutput) LogPublishingOptions() PipelineLogPublishingOptionsPtrOutput
- func (o PipelineOutput) MaxUnits() pulumi.IntOutput
- func (o PipelineOutput) MinUnits() pulumi.IntOutput
- func (o PipelineOutput) PipelineArn() pulumi.StringOutput
- func (o PipelineOutput) PipelineConfigurationBody() pulumi.StringOutput
- func (o PipelineOutput) PipelineName() pulumi.StringOutput
- func (o PipelineOutput) Tags() aws.TagArrayOutput
- func (o PipelineOutput) ToPipelineOutput() PipelineOutput
- func (o PipelineOutput) ToPipelineOutputWithContext(ctx context.Context) PipelineOutput
- func (o PipelineOutput) VpcEndpoints() PipelineVpcEndpointArrayOutput
- func (o PipelineOutput) VpcOptions() PipelineVpcOptionsPtrOutput
- type PipelineState
- type PipelineTag
- type PipelineVpcEndpoint
- type PipelineVpcEndpointArrayOutput
- func (PipelineVpcEndpointArrayOutput) ElementType() reflect.Type
- func (o PipelineVpcEndpointArrayOutput) Index(i pulumi.IntInput) PipelineVpcEndpointOutput
- func (o PipelineVpcEndpointArrayOutput) ToPipelineVpcEndpointArrayOutput() PipelineVpcEndpointArrayOutput
- func (o PipelineVpcEndpointArrayOutput) ToPipelineVpcEndpointArrayOutputWithContext(ctx context.Context) PipelineVpcEndpointArrayOutput
- type PipelineVpcEndpointOutput
- func (PipelineVpcEndpointOutput) ElementType() reflect.Type
- func (o PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutput() PipelineVpcEndpointOutput
- func (o PipelineVpcEndpointOutput) ToPipelineVpcEndpointOutputWithContext(ctx context.Context) PipelineVpcEndpointOutput
- func (o PipelineVpcEndpointOutput) VpcEndpointId() pulumi.StringPtrOutput
- func (o PipelineVpcEndpointOutput) VpcId() pulumi.StringPtrOutput
- func (o PipelineVpcEndpointOutput) VpcOptions() PipelineVpcOptionsPtrOutput
- type PipelineVpcOptions
- type PipelineVpcOptionsArgs
- func (PipelineVpcOptionsArgs) ElementType() reflect.Type
- func (i PipelineVpcOptionsArgs) ToPipelineVpcOptionsOutput() PipelineVpcOptionsOutput
- func (i PipelineVpcOptionsArgs) ToPipelineVpcOptionsOutputWithContext(ctx context.Context) PipelineVpcOptionsOutput
- func (i PipelineVpcOptionsArgs) ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput
- func (i PipelineVpcOptionsArgs) ToPipelineVpcOptionsPtrOutputWithContext(ctx context.Context) PipelineVpcOptionsPtrOutput
- type PipelineVpcOptionsInput
- type PipelineVpcOptionsOutput
- func (PipelineVpcOptionsOutput) ElementType() reflect.Type
- func (o PipelineVpcOptionsOutput) SecurityGroupIds() pulumi.StringArrayOutput
- func (o PipelineVpcOptionsOutput) SubnetIds() pulumi.StringArrayOutput
- func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutput() PipelineVpcOptionsOutput
- func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutputWithContext(ctx context.Context) PipelineVpcOptionsOutput
- func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput
- func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutputWithContext(ctx context.Context) PipelineVpcOptionsPtrOutput
- type PipelineVpcOptionsPtrInput
- type PipelineVpcOptionsPtrOutput
- func (o PipelineVpcOptionsPtrOutput) Elem() PipelineVpcOptionsOutput
- func (PipelineVpcOptionsPtrOutput) ElementType() reflect.Type
- func (o PipelineVpcOptionsPtrOutput) SecurityGroupIds() pulumi.StringArrayOutput
- func (o PipelineVpcOptionsPtrOutput) SubnetIds() pulumi.StringArrayOutput
- func (o PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput
- func (o PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutputWithContext(ctx context.Context) PipelineVpcOptionsPtrOutput
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 { // Options that specify the configuration of a persistent buffer. To configure how OpenSearch Ingestion encrypts this data, set the `EncryptionAtRestOptions` . For more information, see [Persistent buffering](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/osis-features-overview.html#persistent-buffering) . BufferOptions *PipelineBufferOptions `pulumi:"bufferOptions"` // Options to control how OpenSearch encrypts buffer data. EncryptionAtRestOptions *PipelineEncryptionAtRestOptions `pulumi:"encryptionAtRestOptions"` // A list of endpoints that can be used for ingesting data into a pipeline IngestEndpointUrls []string `pulumi:"ingestEndpointUrls"` // Key-value pairs that represent log publishing settings. 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 LookupPipelineOutput ¶
func LookupPipelineOutput(ctx *pulumi.Context, args LookupPipelineOutputArgs, opts ...pulumi.InvokeOption) LookupPipelineResultOutput
func (LookupPipelineResultOutput) BufferOptions ¶ added in v0.91.0
func (o LookupPipelineResultOutput) BufferOptions() PipelineBufferOptionsPtrOutput
Options that specify the configuration of a persistent buffer. To configure how OpenSearch Ingestion encrypts this data, set the `EncryptionAtRestOptions` . For more information, see [Persistent buffering](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/osis-features-overview.html#persistent-buffering) .
func (LookupPipelineResultOutput) ElementType ¶
func (LookupPipelineResultOutput) ElementType() reflect.Type
func (LookupPipelineResultOutput) EncryptionAtRestOptions ¶ added in v0.91.0
func (o LookupPipelineResultOutput) EncryptionAtRestOptions() PipelineEncryptionAtRestOptionsPtrOutput
Options to control how OpenSearch encrypts buffer data.
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
Key-value pairs that represent log publishing settings.
func (LookupPipelineResultOutput) MaxUnits ¶
func (o LookupPipelineResultOutput) MaxUnits() pulumi.IntPtrOutput
The maximum pipeline capacity, in Ingestion OpenSearch Compute Units (OCUs).
func (LookupPipelineResultOutput) MinUnits ¶
func (o LookupPipelineResultOutput) MinUnits() pulumi.IntPtrOutput
The minimum pipeline capacity, in Ingestion OpenSearch Compute Units (OCUs).
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.
func (LookupPipelineResultOutput) Tags ¶
func (o LookupPipelineResultOutput) Tags() aws.TagArrayOutput
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 ¶
func (o LookupPipelineResultOutput) VpcEndpoints() PipelineVpcEndpointArrayOutput
The VPC interface endpoints that have access to the pipeline.
type Pipeline ¶
type Pipeline struct { pulumi.CustomResourceState // Options that specify the configuration of a persistent buffer. To configure how OpenSearch Ingestion encrypts this data, set the `EncryptionAtRestOptions` . For more information, see [Persistent buffering](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/osis-features-overview.html#persistent-buffering) . BufferOptions PipelineBufferOptionsPtrOutput `pulumi:"bufferOptions"` // Options to control how OpenSearch encrypts buffer data. EncryptionAtRestOptions PipelineEncryptionAtRestOptionsPtrOutput `pulumi:"encryptionAtRestOptions"` // A list of endpoints that can be used for ingesting data into a pipeline IngestEndpointUrls pulumi.StringArrayOutput `pulumi:"ingestEndpointUrls"` // Key-value pairs that represent log publishing settings. 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"` // Options that specify the subnets and security groups for an OpenSearch Ingestion VPC endpoint. 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) ToPipelineOutput ¶
func (i *Pipeline) ToPipelineOutput() PipelineOutput
func (*Pipeline) ToPipelineOutputWithContext ¶
func (i *Pipeline) ToPipelineOutputWithContext(ctx context.Context) PipelineOutput
type PipelineArgs ¶
type PipelineArgs struct { // Options that specify the configuration of a persistent buffer. To configure how OpenSearch Ingestion encrypts this data, set the `EncryptionAtRestOptions` . For more information, see [Persistent buffering](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/osis-features-overview.html#persistent-buffering) . BufferOptions PipelineBufferOptionsPtrInput // Options to control how OpenSearch encrypts buffer data. EncryptionAtRestOptions PipelineEncryptionAtRestOptionsPtrInput // Key-value pairs that represent log publishing settings. 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 // Options that specify the subnets and security groups for an OpenSearch Ingestion VPC endpoint. 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) ElementType() reflect.Type
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 (o PipelineBufferOptionsPtrOutput) Elem() PipelineBufferOptionsOutput
func (PipelineBufferOptionsPtrOutput) ElementType ¶ added in v0.91.0
func (PipelineBufferOptionsPtrOutput) ElementType() reflect.Type
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) ElementType() reflect.Type
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) ElementType() reflect.Type
func (PipelineEncryptionAtRestOptionsOutput) KmsKeyArn ¶ added in v0.91.0
func (o PipelineEncryptionAtRestOptionsOutput) KmsKeyArn() pulumi.StringOutput
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
func PipelineEncryptionAtRestOptionsPtr ¶ added in v0.91.0
func PipelineEncryptionAtRestOptionsPtr(v *PipelineEncryptionAtRestOptionsArgs) PipelineEncryptionAtRestOptionsPtrInput
type PipelineEncryptionAtRestOptionsPtrOutput ¶ added in v0.91.0
type PipelineEncryptionAtRestOptionsPtrOutput struct{ *pulumi.OutputState }
func (PipelineEncryptionAtRestOptionsPtrOutput) ElementType ¶ added in v0.91.0
func (PipelineEncryptionAtRestOptionsPtrOutput) ElementType() reflect.Type
func (PipelineEncryptionAtRestOptionsPtrOutput) KmsKeyArn ¶ added in v0.91.0
func (o PipelineEncryptionAtRestOptionsPtrOutput) KmsKeyArn() pulumi.StringPtrOutput
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) ElementType() reflect.Type
func (PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutput ¶
func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutput() PipelineLogPublishingOptionsOutput
func (PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutputWithContext ¶
func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsOutput
func (PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutput ¶
func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput
func (PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutputWithContext ¶
func (i PipelineLogPublishingOptionsArgs) ToPipelineLogPublishingOptionsPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsPtrOutput
type 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) ElementType() reflect.Type
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.StringOutput
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) ElementType ¶
func (PipelineLogPublishingOptionsCloudWatchLogDestinationPropertiesPtrOutput) ElementType() reflect.Type
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) 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) ElementType ¶
func (PipelineLogPublishingOptionsPtrOutput) ElementType() reflect.Type
func (PipelineLogPublishingOptionsPtrOutput) IsLoggingEnabled ¶
func (o PipelineLogPublishingOptionsPtrOutput) IsLoggingEnabled() pulumi.BoolPtrOutput
Whether logs should be published.
func (PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutput ¶
func (o PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutput() PipelineLogPublishingOptionsPtrOutput
func (PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutputWithContext ¶
func (o PipelineLogPublishingOptionsPtrOutput) ToPipelineLogPublishingOptionsPtrOutputWithContext(ctx context.Context) PipelineLogPublishingOptionsPtrOutput
type PipelineOutput ¶
type PipelineOutput struct{ *pulumi.OutputState }
func (PipelineOutput) BufferOptions ¶ added in v0.91.0
func (o PipelineOutput) BufferOptions() PipelineBufferOptionsPtrOutput
Options that specify the configuration of a persistent buffer. To configure how OpenSearch Ingestion encrypts this data, set the `EncryptionAtRestOptions` . For more information, see [Persistent buffering](https://docs.aws.amazon.com/opensearch-service/latest/developerguide/osis-features-overview.html#persistent-buffering) .
func (PipelineOutput) ElementType ¶
func (PipelineOutput) ElementType() reflect.Type
func (PipelineOutput) EncryptionAtRestOptions ¶ added in v0.91.0
func (o PipelineOutput) EncryptionAtRestOptions() PipelineEncryptionAtRestOptionsPtrOutput
Options to control how OpenSearch encrypts buffer data.
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
Key-value pairs that represent log publishing settings.
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 ¶
func (o PipelineOutput) Tags() aws.TagArrayOutput
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 ¶
func (o PipelineOutput) VpcEndpoints() PipelineVpcEndpointArrayOutput
The VPC interface endpoints that have access to the pipeline.
func (PipelineOutput) VpcOptions ¶
func (o PipelineOutput) VpcOptions() PipelineVpcOptionsPtrOutput
Options that specify the subnets and security groups for an OpenSearch Ingestion VPC endpoint.
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"` // Information about the VPC, including associated subnets and security groups. 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) 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 ¶
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
Information about the VPC, including associated subnets and security groups.
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 ¶
func (o PipelineVpcOptionsOutput) SubnetIds() pulumi.StringArrayOutput
A list of subnet IDs associated with the VPC endpoint.
func (PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutput ¶
func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutput() PipelineVpcOptionsOutput
func (PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutputWithContext ¶
func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsOutputWithContext(ctx context.Context) PipelineVpcOptionsOutput
func (PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutput ¶
func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput
func (PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutputWithContext ¶
func (o PipelineVpcOptionsOutput) ToPipelineVpcOptionsPtrOutputWithContext(ctx context.Context) PipelineVpcOptionsPtrOutput
type PipelineVpcOptionsPtrInput ¶
type PipelineVpcOptionsPtrInput interface { pulumi.Input ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput ToPipelineVpcOptionsPtrOutputWithContext(context.Context) PipelineVpcOptionsPtrOutput }
PipelineVpcOptionsPtrInput is an input type that accepts PipelineVpcOptionsArgs, PipelineVpcOptionsPtr and PipelineVpcOptionsPtrOutput values. You can construct a concrete instance of `PipelineVpcOptionsPtrInput` via:
PipelineVpcOptionsArgs{...} or: nil
func PipelineVpcOptionsPtr ¶
func PipelineVpcOptionsPtr(v *PipelineVpcOptionsArgs) PipelineVpcOptionsPtrInput
type PipelineVpcOptionsPtrOutput ¶
type PipelineVpcOptionsPtrOutput struct{ *pulumi.OutputState }
func (PipelineVpcOptionsPtrOutput) Elem ¶
func (o PipelineVpcOptionsPtrOutput) Elem() PipelineVpcOptionsOutput
func (PipelineVpcOptionsPtrOutput) ElementType ¶
func (PipelineVpcOptionsPtrOutput) ElementType() reflect.Type
func (PipelineVpcOptionsPtrOutput) SecurityGroupIds ¶
func (o PipelineVpcOptionsPtrOutput) SecurityGroupIds() pulumi.StringArrayOutput
A list of security groups associated with the VPC endpoint.
func (PipelineVpcOptionsPtrOutput) SubnetIds ¶
func (o PipelineVpcOptionsPtrOutput) SubnetIds() pulumi.StringArrayOutput
A list of subnet IDs associated with the VPC endpoint.
func (PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutput ¶
func (o PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutput() PipelineVpcOptionsPtrOutput
func (PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutputWithContext ¶
func (o PipelineVpcOptionsPtrOutput) ToPipelineVpcOptionsPtrOutputWithContext(ctx context.Context) PipelineVpcOptionsPtrOutput