Documentation ¶
Index ¶
- func CfnPipeline_CFN_RESOURCE_TYPE_NAME() *string
- func CfnPipeline_IsCfnElement(x interface{}) *bool
- func CfnPipeline_IsCfnResource(construct constructs.IConstruct) *bool
- func CfnPipeline_IsConstruct(x interface{}) *bool
- func NewCfnPipeline_Override(c CfnPipeline, scope constructs.Construct, id *string, props *CfnPipelineProps)
- type CfnPipeline
- type CfnPipelineProps
- type CfnPipeline_CloudWatchLogDestinationProperty
- type CfnPipeline_LogPublishingOptionsProperty
- type CfnPipeline_VpcEndpointProperty
- type CfnPipeline_VpcOptionsProperty
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CfnPipeline_CFN_RESOURCE_TYPE_NAME ¶
func CfnPipeline_CFN_RESOURCE_TYPE_NAME() *string
func CfnPipeline_IsCfnElement ¶
func CfnPipeline_IsCfnElement(x interface{}) *bool
Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).
Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.
Returns: The construct as a stack element or undefined if it is not a stack element.
func CfnPipeline_IsCfnResource ¶
func CfnPipeline_IsCfnResource(construct constructs.IConstruct) *bool
Check whether the given construct is a CfnResource.
func CfnPipeline_IsConstruct ¶
func CfnPipeline_IsConstruct(x interface{}) *bool
Checks if `x` is a construct.
Use this method instead of `instanceof` to properly detect `Construct` instances, even when the construct library is symlinked.
Explanation: in JavaScript, multiple copies of the `constructs` library on disk are seen as independent, completely different libraries. As a consequence, the class `Construct` in each copy of the `constructs` library is seen as a different class, and an instance of one class will not test as `instanceof` the other class. `npm install` will not create installations like this, but users may manually symlink construct libraries together or use a monorepo tool: in those cases, multiple copies of the `constructs` library can be accidentally installed, and `instanceof` will behave unpredictably. It is safest to avoid using `instanceof`, and using this type-testing method instead.
Returns: true if `x` is an object created from a class which extends `Construct`.
func NewCfnPipeline_Override ¶
func NewCfnPipeline_Override(c CfnPipeline, scope constructs.Construct, id *string, props *CfnPipelineProps)
Create a new `AWS::OSIS::Pipeline`.
Types ¶
type CfnPipeline ¶
type CfnPipeline interface { awscdk.CfnResource awscdk.IInspectable // A list of the ingestion endpoints for the pipeline that you can send data to. // // Currently, only a single ingestion endpoint is supported for a pipeline. For example, `my-pipeline-123456789012.us-east-1.osis.amazonaws.com` . AttrIngestEndpointUrls() *[]*string // The Amazon Resource Name (ARN) of the pipeline. AttrPipelineArn() *string // The VPC interface endpoints that have access to the pipeline. AttrVpcEndpoints() awscdk.IResolvable // Options for this resource, such as condition, update policy etc. CfnOptions() awscdk.ICfnResourceOptions CfnProperties() *map[string]interface{} // AWS resource type. CfnResourceType() *string // Returns: the stack trace of the point where this Resource was created from, sourced // from the +metadata+ entry typed +aws:cdk:logicalId+, and with the bottom-most // node +internal+ entries filtered. CreationStack() *[]*string // The logical ID for this CloudFormation stack element. // // The logical ID of the element // is calculated from the path of the resource node in the construct tree. // // To override this value, use `overrideLogicalId(newLogicalId)`. // // Returns: the logical ID as a stringified token. This value will only get // resolved during synthesis. LogicalId() *string // Key-value pairs that represent log publishing settings. LogPublishingOptions() interface{} SetLogPublishingOptions(val interface{}) // The maximum pipeline capacity, in Ingestion Compute Units (ICUs). MaxUnits() *float64 SetMaxUnits(val *float64) // The minimum pipeline capacity, in Ingestion Compute Units (ICUs). MinUnits() *float64 SetMinUnits(val *float64) // The tree node. Node() constructs.Node // The Data Prepper pipeline configuration in YAML format. PipelineConfigurationBody() *string SetPipelineConfigurationBody(val *string) // The name of the pipeline. PipelineName() *string SetPipelineName(val *string) // Return a string that will be resolved to a CloudFormation `{ Ref }` for this element. // // If, by any chance, the intrinsic reference of a resource is not a string, you could // coerce it to an IResolvable through `Lazy.any({ produce: resource.ref })`. Ref() *string // The stack in which this element is defined. // // CfnElements must be defined within a stack scope (directly or indirectly). Stack() awscdk.Stack // List of tags to add to the pipeline upon creation. Tags() awscdk.TagManager // Deprecated. // Deprecated: use `updatedProperties` // // Return properties modified after initiation // // Resources that expose mutable properties should override this function to // collect and return the properties object for this resource. UpdatedProperites() *map[string]interface{} // Return properties modified after initiation. // // Resources that expose mutable properties should override this function to // collect and return the properties object for this resource. UpdatedProperties() *map[string]interface{} // Options that specify the subnets and security groups for an OpenSearch Ingestion VPC endpoint. VpcOptions() interface{} SetVpcOptions(val interface{}) // Syntactic sugar for `addOverride(path, undefined)`. AddDeletionOverride(path *string) // Indicates that this resource depends on another resource and cannot be provisioned unless the other resource has been successfully provisioned. // // This can be used for resources across stacks (or nested stack) boundaries // and the dependency will automatically be transferred to the relevant scope. AddDependency(target awscdk.CfnResource) // Indicates that this resource depends on another resource and cannot be provisioned unless the other resource has been successfully provisioned. // Deprecated: use addDependency. AddDependsOn(target awscdk.CfnResource) // Add a value to the CloudFormation Resource Metadata. // See: https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/metadata-section-structure.html // // Note that this is a different set of metadata from CDK node metadata; this // metadata ends up in the stack template under the resource, whereas CDK // node metadata ends up in the Cloud Assembly. // AddMetadata(key *string, value interface{}) // Adds an override to the synthesized CloudFormation resource. // // To add a // property override, either use `addPropertyOverride` or prefix `path` with // "Properties." (i.e. `Properties.TopicName`). // // If the override is nested, separate each nested level using a dot (.) in the path parameter. // If there is an array as part of the nesting, specify the index in the path. // // To include a literal `.` in the property name, prefix with a `\`. In most // programming languages you will need to write this as `"\\."` because the // `\` itself will need to be escaped. // // For example, // “`typescript // cfnResource.addOverride('Properties.GlobalSecondaryIndexes.0.Projection.NonKeyAttributes', ['myattribute']); // cfnResource.addOverride('Properties.GlobalSecondaryIndexes.1.ProjectionType', 'INCLUDE'); // “` // would add the overrides // “`json // "Properties": { // "GlobalSecondaryIndexes": [ // { // "Projection": { // "NonKeyAttributes": [ "myattribute" ] // ... // } // ... // }, // { // "ProjectionType": "INCLUDE" // ... // }, // ] // ... // } // “` // // The `value` argument to `addOverride` will not be processed or translated // in any way. Pass raw JSON values in here with the correct capitalization // for CloudFormation. If you pass CDK classes or structs, they will be // rendered with lowercased key names, and CloudFormation will reject the // template. AddOverride(path *string, value interface{}) // Adds an override that deletes the value of a property from the resource definition. AddPropertyDeletionOverride(propertyPath *string) // Adds an override to a resource property. // // Syntactic sugar for `addOverride("Properties.<...>", value)`. AddPropertyOverride(propertyPath *string, value interface{}) // Sets the deletion policy of the resource based on the removal policy specified. // // The Removal Policy controls what happens to this resource when it stops // being managed by CloudFormation, either because you've removed it from the // CDK application or because you've made a change that requires the resource // to be replaced. // // The resource can be deleted (`RemovalPolicy.DESTROY`), or left in your AWS // account for data recovery and cleanup later (`RemovalPolicy.RETAIN`). In some // cases, a snapshot can be taken of the resource prior to deletion // (`RemovalPolicy.SNAPSHOT`). A list of resources that support this policy // can be found in the following link:. // See: https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-attribute-deletionpolicy.html#aws-attribute-deletionpolicy-options // ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions) // Returns a token for an runtime attribute of this resource. // // Ideally, use generated attribute accessors (e.g. `resource.arn`), but this can be used for future compatibility // in case there is no generated attribute. GetAtt(attributeName *string, typeHint awscdk.ResolutionTypeHint) awscdk.Reference // Retrieve a value value from the CloudFormation Resource Metadata. // See: https://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/metadata-section-structure.html // // Note that this is a different set of metadata from CDK node metadata; this // metadata ends up in the stack template under the resource, whereas CDK // node metadata ends up in the Cloud Assembly. // GetMetadata(key *string) interface{} // Examines the CloudFormation resource and discloses attributes. Inspect(inspector awscdk.TreeInspector) // Retrieves an array of resources this resource depends on. // // This assembles dependencies on resources across stacks (including nested stacks) // automatically. ObtainDependencies() *[]interface{} // Get a shallow copy of dependencies between this resource and other resources in the same stack. ObtainResourceDependencies() *[]awscdk.CfnResource // Overrides the auto-generated logical ID with a specific ID. OverrideLogicalId(newLogicalId *string) // Indicates that this resource no longer depends on another resource. // // This can be used for resources across stacks (including nested stacks) // and the dependency will automatically be removed from the relevant scope. RemoveDependency(target awscdk.CfnResource) RenderProperties(props *map[string]interface{}) *map[string]interface{} // Replaces one dependency with another. ReplaceDependency(target awscdk.CfnResource, newTarget awscdk.CfnResource) // Can be overridden by subclasses to determine if this resource will be rendered into the cloudformation template. // // Returns: `true` if the resource should be included or `false` is the resource // should be omitted. ShouldSynthesize() *bool // Returns a string representation of this construct. // // Returns: a string representation of this resource. ToString() *string ValidateProperties(_properties interface{}) }
A CloudFormation `AWS::OSIS::Pipeline`.
The AWS::OSIS::Pipeline resource creates an Amazon OpenSearch Ingestion pipeline.
Example:
// The code below shows an example of how to instantiate this type. // The values are placeholders you should change. import "github.com/aws/aws-cdk-go/awscdk" cfnPipeline := awscdk.Aws_osis.NewCfnPipeline(this, jsii.String("MyCfnPipeline"), &CfnPipelineProps{ MaxUnits: jsii.Number(123), MinUnits: jsii.Number(123), PipelineConfigurationBody: jsii.String("pipelineConfigurationBody"), PipelineName: jsii.String("pipelineName"), // the properties below are optional LogPublishingOptions: &LogPublishingOptionsProperty{ CloudWatchLogDestination: &CloudWatchLogDestinationProperty{ LogGroup: jsii.String("logGroup"), }, IsLoggingEnabled: jsii.Boolean(false), }, Tags: []cfnTag{ &cfnTag{ Key: jsii.String("key"), Value: jsii.String("value"), }, }, VpcOptions: &VpcOptionsProperty{ SecurityGroupIds: []*string{ jsii.String("securityGroupIds"), }, SubnetIds: []*string{ jsii.String("subnetIds"), }, }, })
func NewCfnPipeline ¶
func NewCfnPipeline(scope constructs.Construct, id *string, props *CfnPipelineProps) CfnPipeline
Create a new `AWS::OSIS::Pipeline`.
type CfnPipelineProps ¶
type CfnPipelineProps struct { // The maximum pipeline capacity, in Ingestion Compute Units (ICUs). MaxUnits *float64 `field:"required" json:"maxUnits" yaml:"maxUnits"` // The minimum pipeline capacity, in Ingestion Compute Units (ICUs). MinUnits *float64 `field:"required" json:"minUnits" yaml:"minUnits"` // The Data Prepper pipeline configuration in YAML format. PipelineConfigurationBody *string `field:"required" json:"pipelineConfigurationBody" yaml:"pipelineConfigurationBody"` // The name of the pipeline. PipelineName *string `field:"required" json:"pipelineName" yaml:"pipelineName"` // Key-value pairs that represent log publishing settings. LogPublishingOptions interface{} `field:"optional" json:"logPublishingOptions" yaml:"logPublishingOptions"` // List of tags to add to the pipeline upon creation. Tags *[]*awscdk.CfnTag `field:"optional" json:"tags" yaml:"tags"` // Options that specify the subnets and security groups for an OpenSearch Ingestion VPC endpoint. VpcOptions interface{} `field:"optional" json:"vpcOptions" yaml:"vpcOptions"` }
Properties for defining a `CfnPipeline`.
Example:
// The code below shows an example of how to instantiate this type. // The values are placeholders you should change. import "github.com/aws/aws-cdk-go/awscdk" cfnPipelineProps := &CfnPipelineProps{ MaxUnits: jsii.Number(123), MinUnits: jsii.Number(123), PipelineConfigurationBody: jsii.String("pipelineConfigurationBody"), PipelineName: jsii.String("pipelineName"), // the properties below are optional LogPublishingOptions: &LogPublishingOptionsProperty{ CloudWatchLogDestination: &CloudWatchLogDestinationProperty{ LogGroup: jsii.String("logGroup"), }, IsLoggingEnabled: jsii.Boolean(false), }, Tags: []cfnTag{ &cfnTag{ Key: jsii.String("key"), Value: jsii.String("value"), }, }, VpcOptions: &VpcOptionsProperty{ SecurityGroupIds: []*string{ jsii.String("securityGroupIds"), }, SubnetIds: []*string{ jsii.String("subnetIds"), }, }, }
type CfnPipeline_CloudWatchLogDestinationProperty ¶
type CfnPipeline_CloudWatchLogDestinationProperty struct { // `CfnPipeline.CloudWatchLogDestinationProperty.LogGroup`. LogGroup *string `field:"optional" json:"logGroup" yaml:"logGroup"` }
Example:
// The code below shows an example of how to instantiate this type. // The values are placeholders you should change. import "github.com/aws/aws-cdk-go/awscdk" cloudWatchLogDestinationProperty := &CloudWatchLogDestinationProperty{ LogGroup: jsii.String("logGroup"), }
type CfnPipeline_LogPublishingOptionsProperty ¶
type CfnPipeline_LogPublishingOptionsProperty struct { // The destination for OpenSearch Ingestion logs sent to Amazon CloudWatch Logs. // // This parameter is required if `IsLoggingEnabled` is set to `true` . CloudWatchLogDestination interface{} `field:"optional" json:"cloudWatchLogDestination" yaml:"cloudWatchLogDestination"` // Whether logs should be published. IsLoggingEnabled interface{} `field:"optional" json:"isLoggingEnabled" yaml:"isLoggingEnabled"` }
Container for the values required to configure logging for the pipeline.
If you don't specify these values, OpenSearch Ingestion will not publish logs from your application to CloudWatch Logs.
Example:
// The code below shows an example of how to instantiate this type. // The values are placeholders you should change. import "github.com/aws/aws-cdk-go/awscdk" logPublishingOptionsProperty := &LogPublishingOptionsProperty{ CloudWatchLogDestination: &CloudWatchLogDestinationProperty{ LogGroup: jsii.String("logGroup"), }, IsLoggingEnabled: jsii.Boolean(false), }
type CfnPipeline_VpcEndpointProperty ¶
type CfnPipeline_VpcEndpointProperty struct { // The unique identifier of the endpoint. VpcEndpointId *string `field:"optional" json:"vpcEndpointId" yaml:"vpcEndpointId"` // The ID for your VPC. // // AWS PrivateLink generates this value when you create a VPC. VpcId *string `field:"optional" json:"vpcId" yaml:"vpcId"` // Information about the VPC, including associated subnets and security groups. VpcOptions interface{} `field:"optional" json:"vpcOptions" yaml:"vpcOptions"` }
An OpenSearch Ingestion-managed VPC endpoint that will access one or more pipelines.
Example:
// The code below shows an example of how to instantiate this type. // The values are placeholders you should change. import "github.com/aws/aws-cdk-go/awscdk" vpcEndpointProperty := &VpcEndpointProperty{ VpcEndpointId: jsii.String("vpcEndpointId"), VpcId: jsii.String("vpcId"), VpcOptions: &VpcOptionsProperty{ SecurityGroupIds: []*string{ jsii.String("securityGroupIds"), }, SubnetIds: []*string{ jsii.String("subnetIds"), }, }, }
type CfnPipeline_VpcOptionsProperty ¶
type CfnPipeline_VpcOptionsProperty struct { // A list of security groups associated with the VPC endpoint. SecurityGroupIds *[]*string `field:"optional" json:"securityGroupIds" yaml:"securityGroupIds"` // A list of subnet IDs associated with the VPC endpoint. SubnetIds *[]*string `field:"optional" json:"subnetIds" yaml:"subnetIds"` }
Options that specify the subnets and security groups for an OpenSearch Ingestion VPC endpoint.
Example:
// The code below shows an example of how to instantiate this type. // The values are placeholders you should change. import "github.com/aws/aws-cdk-go/awscdk" vpcOptionsProperty := &VpcOptionsProperty{ SecurityGroupIds: []*string{ jsii.String("securityGroupIds"), }, SubnetIds: []*string{ jsii.String("subnetIds"), }, }