awskafkaconnect

package
v2.19.0 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CfnConnector_CFN_RESOURCE_TYPE_NAME 

func CfnConnector_CFN_RESOURCE_TYPE_NAME() *string

func CfnConnector_IsCfnElement 

func CfnConnector_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 CfnConnector_IsCfnResource 

func CfnConnector_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource.

func CfnConnector_IsConstruct 

func CfnConnector_IsConstruct(x interface{}) *bool

Checks if `x` is a construct.

Returns: true if `x` is an object created from a class which extends `Construct`. Deprecated: use `x instanceof Construct` instead.

func NewCfnConnector_Override 

func NewCfnConnector_Override(c CfnConnector, scope constructs.Construct, id *string, props *CfnConnectorProps)

Create a new `AWS::KafkaConnect::Connector`.

Types

type CfnConnector 

type CfnConnector interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrConnectorArn() *string
	// `AWS::KafkaConnect::Connector.Capacity`.
	Capacity() interface{}
	SetCapacity(val interface{})
	// Options for this resource, such as condition, update policy etc.
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	// AWS resource type.
	CfnResourceType() *string
	// `AWS::KafkaConnect::Connector.ConnectorConfiguration`.
	ConnectorConfiguration() interface{}
	SetConnectorConfiguration(val interface{})
	// `AWS::KafkaConnect::Connector.ConnectorDescription`.
	ConnectorDescription() *string
	SetConnectorDescription(val *string)
	// `AWS::KafkaConnect::Connector.ConnectorName`.
	ConnectorName() *string
	SetConnectorName(val *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
	// `AWS::KafkaConnect::Connector.KafkaCluster`.
	KafkaCluster() interface{}
	SetKafkaCluster(val interface{})
	// `AWS::KafkaConnect::Connector.KafkaClusterClientAuthentication`.
	KafkaClusterClientAuthentication() interface{}
	SetKafkaClusterClientAuthentication(val interface{})
	// `AWS::KafkaConnect::Connector.KafkaClusterEncryptionInTransit`.
	KafkaClusterEncryptionInTransit() interface{}
	SetKafkaClusterEncryptionInTransit(val interface{})
	// `AWS::KafkaConnect::Connector.KafkaConnectVersion`.
	KafkaConnectVersion() *string
	SetKafkaConnectVersion(val *string)
	// `AWS::KafkaConnect::Connector.LogDelivery`.
	LogDelivery() interface{}
	SetLogDelivery(val interface{})
	// 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
	// The tree node.
	Node() constructs.Node
	// `AWS::KafkaConnect::Connector.Plugins`.
	Plugins() interface{}
	SetPlugins(val interface{})
	// 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
	// `AWS::KafkaConnect::Connector.ServiceExecutionRoleArn`.
	ServiceExecutionRoleArn() *string
	SetServiceExecutionRoleArn(val *string)
	// The stack in which this element is defined.
	//
	// CfnElements must be defined within a stack scope (directly or indirectly).
	Stack() awscdk.Stack
	// 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{}
	// `AWS::KafkaConnect::Connector.WorkerConfiguration`.
	WorkerConfiguration() interface{}
	SetWorkerConfiguration(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.
	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`).
	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) 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)
	// Overrides the auto-generated logical ID with a specific ID.
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	// 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::KafkaConnect::Connector`.

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
cfnConnector := kafkaconnect.NewCfnConnector(this, jsii.String("MyCfnConnector"), &cfnConnectorProps{
	capacity: &capacityProperty{
		autoScaling: &autoScalingProperty{
			maxWorkerCount: jsii.Number(123),
			mcuCount: jsii.Number(123),
			minWorkerCount: jsii.Number(123),
			scaleInPolicy: &scaleInPolicyProperty{
				cpuUtilizationPercentage: jsii.Number(123),
			},
			scaleOutPolicy: &scaleOutPolicyProperty{
				cpuUtilizationPercentage: jsii.Number(123),
			},
		},
		provisionedCapacity: &provisionedCapacityProperty{
			workerCount: jsii.Number(123),

			// the properties below are optional
			mcuCount: jsii.Number(123),
		},
	},
	connectorConfiguration: map[string]*string{
		"connectorConfigurationKey": jsii.String("connectorConfiguration"),
	},
	connectorName: jsii.String("connectorName"),
	kafkaCluster: &kafkaClusterProperty{
		apacheKafkaCluster: &apacheKafkaClusterProperty{
			bootstrapServers: jsii.String("bootstrapServers"),
			vpc: &vpcProperty{
				securityGroups: []*string{
					jsii.String("securityGroups"),
				},
				subnets: []*string{
					jsii.String("subnets"),
				},
			},
		},
	},
	kafkaClusterClientAuthentication: &kafkaClusterClientAuthenticationProperty{
		authenticationType: jsii.String("authenticationType"),
	},
	kafkaClusterEncryptionInTransit: &kafkaClusterEncryptionInTransitProperty{
		encryptionType: jsii.String("encryptionType"),
	},
	kafkaConnectVersion: jsii.String("kafkaConnectVersion"),
	plugins: []interface{}{
		&pluginProperty{
			customPlugin: &customPluginProperty{
				customPluginArn: jsii.String("customPluginArn"),
				revision: jsii.Number(123),
			},
		},
	},
	serviceExecutionRoleArn: jsii.String("serviceExecutionRoleArn"),

	// the properties below are optional
	connectorDescription: jsii.String("connectorDescription"),
	logDelivery: &logDeliveryProperty{
		workerLogDelivery: &workerLogDeliveryProperty{
			cloudWatchLogs: &cloudWatchLogsLogDeliveryProperty{
				enabled: jsii.Boolean(false),

				// the properties below are optional
				logGroup: jsii.String("logGroup"),
			},
			firehose: &firehoseLogDeliveryProperty{
				enabled: jsii.Boolean(false),

				// the properties below are optional
				deliveryStream: jsii.String("deliveryStream"),
			},
			s3: &s3LogDeliveryProperty{
				enabled: jsii.Boolean(false),

				// the properties below are optional
				bucket: jsii.String("bucket"),
				prefix: jsii.String("prefix"),
			},
		},
	},
	workerConfiguration: &workerConfigurationProperty{
		revision: jsii.Number(123),
		workerConfigurationArn: jsii.String("workerConfigurationArn"),
	},
})

func NewCfnConnector 

func NewCfnConnector(scope constructs.Construct, id *string, props *CfnConnectorProps) CfnConnector

Create a new `AWS::KafkaConnect::Connector`.

type CfnConnectorProps 

type CfnConnectorProps struct {
	// `AWS::KafkaConnect::Connector.Capacity`.
	Capacity interface{} `json:"capacity" yaml:"capacity"`
	// `AWS::KafkaConnect::Connector.ConnectorConfiguration`.
	ConnectorConfiguration interface{} `json:"connectorConfiguration" yaml:"connectorConfiguration"`
	// `AWS::KafkaConnect::Connector.ConnectorName`.
	ConnectorName *string `json:"connectorName" yaml:"connectorName"`
	// `AWS::KafkaConnect::Connector.KafkaCluster`.
	KafkaCluster interface{} `json:"kafkaCluster" yaml:"kafkaCluster"`
	// `AWS::KafkaConnect::Connector.KafkaClusterClientAuthentication`.
	KafkaClusterClientAuthentication interface{} `json:"kafkaClusterClientAuthentication" yaml:"kafkaClusterClientAuthentication"`
	// `AWS::KafkaConnect::Connector.KafkaClusterEncryptionInTransit`.
	KafkaClusterEncryptionInTransit interface{} `json:"kafkaClusterEncryptionInTransit" yaml:"kafkaClusterEncryptionInTransit"`
	// `AWS::KafkaConnect::Connector.KafkaConnectVersion`.
	KafkaConnectVersion *string `json:"kafkaConnectVersion" yaml:"kafkaConnectVersion"`
	// `AWS::KafkaConnect::Connector.Plugins`.
	Plugins interface{} `json:"plugins" yaml:"plugins"`
	// `AWS::KafkaConnect::Connector.ServiceExecutionRoleArn`.
	ServiceExecutionRoleArn *string `json:"serviceExecutionRoleArn" yaml:"serviceExecutionRoleArn"`
	// `AWS::KafkaConnect::Connector.ConnectorDescription`.
	ConnectorDescription *string `json:"connectorDescription" yaml:"connectorDescription"`
	// `AWS::KafkaConnect::Connector.LogDelivery`.
	LogDelivery interface{} `json:"logDelivery" yaml:"logDelivery"`
	// `AWS::KafkaConnect::Connector.WorkerConfiguration`.
	WorkerConfiguration interface{} `json:"workerConfiguration" yaml:"workerConfiguration"`
}

Properties for defining a `CfnConnector`.

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
cfnConnectorProps := &cfnConnectorProps{
	capacity: &capacityProperty{
		autoScaling: &autoScalingProperty{
			maxWorkerCount: jsii.Number(123),
			mcuCount: jsii.Number(123),
			minWorkerCount: jsii.Number(123),
			scaleInPolicy: &scaleInPolicyProperty{
				cpuUtilizationPercentage: jsii.Number(123),
			},
			scaleOutPolicy: &scaleOutPolicyProperty{
				cpuUtilizationPercentage: jsii.Number(123),
			},
		},
		provisionedCapacity: &provisionedCapacityProperty{
			workerCount: jsii.Number(123),

			// the properties below are optional
			mcuCount: jsii.Number(123),
		},
	},
	connectorConfiguration: map[string]*string{
		"connectorConfigurationKey": jsii.String("connectorConfiguration"),
	},
	connectorName: jsii.String("connectorName"),
	kafkaCluster: &kafkaClusterProperty{
		apacheKafkaCluster: &apacheKafkaClusterProperty{
			bootstrapServers: jsii.String("bootstrapServers"),
			vpc: &vpcProperty{
				securityGroups: []*string{
					jsii.String("securityGroups"),
				},
				subnets: []*string{
					jsii.String("subnets"),
				},
			},
		},
	},
	kafkaClusterClientAuthentication: &kafkaClusterClientAuthenticationProperty{
		authenticationType: jsii.String("authenticationType"),
	},
	kafkaClusterEncryptionInTransit: &kafkaClusterEncryptionInTransitProperty{
		encryptionType: jsii.String("encryptionType"),
	},
	kafkaConnectVersion: jsii.String("kafkaConnectVersion"),
	plugins: []interface{}{
		&pluginProperty{
			customPlugin: &customPluginProperty{
				customPluginArn: jsii.String("customPluginArn"),
				revision: jsii.Number(123),
			},
		},
	},
	serviceExecutionRoleArn: jsii.String("serviceExecutionRoleArn"),

	// the properties below are optional
	connectorDescription: jsii.String("connectorDescription"),
	logDelivery: &logDeliveryProperty{
		workerLogDelivery: &workerLogDeliveryProperty{
			cloudWatchLogs: &cloudWatchLogsLogDeliveryProperty{
				enabled: jsii.Boolean(false),

				// the properties below are optional
				logGroup: jsii.String("logGroup"),
			},
			firehose: &firehoseLogDeliveryProperty{
				enabled: jsii.Boolean(false),

				// the properties below are optional
				deliveryStream: jsii.String("deliveryStream"),
			},
			s3: &s3LogDeliveryProperty{
				enabled: jsii.Boolean(false),

				// the properties below are optional
				bucket: jsii.String("bucket"),
				prefix: jsii.String("prefix"),
			},
		},
	},
	workerConfiguration: &workerConfigurationProperty{
		revision: jsii.Number(123),
		workerConfigurationArn: jsii.String("workerConfigurationArn"),
	},
}

type CfnConnector_ApacheKafkaClusterProperty 

type CfnConnector_ApacheKafkaClusterProperty struct {
	// `CfnConnector.ApacheKafkaClusterProperty.BootstrapServers`.
	BootstrapServers *string `json:"bootstrapServers" yaml:"bootstrapServers"`
	// `CfnConnector.ApacheKafkaClusterProperty.Vpc`.
	Vpc interface{} `json:"vpc" yaml:"vpc"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
apacheKafkaClusterProperty := &apacheKafkaClusterProperty{
	bootstrapServers: jsii.String("bootstrapServers"),
	vpc: &vpcProperty{
		securityGroups: []*string{
			jsii.String("securityGroups"),
		},
		subnets: []*string{
			jsii.String("subnets"),
		},
	},
}

type CfnConnector_AutoScalingProperty 

type CfnConnector_AutoScalingProperty struct {
	// `CfnConnector.AutoScalingProperty.MaxWorkerCount`.
	MaxWorkerCount *float64 `json:"maxWorkerCount" yaml:"maxWorkerCount"`
	// `CfnConnector.AutoScalingProperty.McuCount`.
	McuCount *float64 `json:"mcuCount" yaml:"mcuCount"`
	// `CfnConnector.AutoScalingProperty.MinWorkerCount`.
	MinWorkerCount *float64 `json:"minWorkerCount" yaml:"minWorkerCount"`
	// `CfnConnector.AutoScalingProperty.ScaleInPolicy`.
	ScaleInPolicy interface{} `json:"scaleInPolicy" yaml:"scaleInPolicy"`
	// `CfnConnector.AutoScalingProperty.ScaleOutPolicy`.
	ScaleOutPolicy interface{} `json:"scaleOutPolicy" yaml:"scaleOutPolicy"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
autoScalingProperty := &autoScalingProperty{
	maxWorkerCount: jsii.Number(123),
	mcuCount: jsii.Number(123),
	minWorkerCount: jsii.Number(123),
	scaleInPolicy: &scaleInPolicyProperty{
		cpuUtilizationPercentage: jsii.Number(123),
	},
	scaleOutPolicy: &scaleOutPolicyProperty{
		cpuUtilizationPercentage: jsii.Number(123),
	},
}

type CfnConnector_CapacityProperty 

type CfnConnector_CapacityProperty struct {
	// `CfnConnector.CapacityProperty.AutoScaling`.
	AutoScaling interface{} `json:"autoScaling" yaml:"autoScaling"`
	// `CfnConnector.CapacityProperty.ProvisionedCapacity`.
	ProvisionedCapacity interface{} `json:"provisionedCapacity" yaml:"provisionedCapacity"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
capacityProperty := &capacityProperty{
	autoScaling: &autoScalingProperty{
		maxWorkerCount: jsii.Number(123),
		mcuCount: jsii.Number(123),
		minWorkerCount: jsii.Number(123),
		scaleInPolicy: &scaleInPolicyProperty{
			cpuUtilizationPercentage: jsii.Number(123),
		},
		scaleOutPolicy: &scaleOutPolicyProperty{
			cpuUtilizationPercentage: jsii.Number(123),
		},
	},
	provisionedCapacity: &provisionedCapacityProperty{
		workerCount: jsii.Number(123),

		// the properties below are optional
		mcuCount: jsii.Number(123),
	},
}

type CfnConnector_CloudWatchLogsLogDeliveryProperty 

type CfnConnector_CloudWatchLogsLogDeliveryProperty struct {
	// `CfnConnector.CloudWatchLogsLogDeliveryProperty.Enabled`.
	Enabled interface{} `json:"enabled" yaml:"enabled"`
	// `CfnConnector.CloudWatchLogsLogDeliveryProperty.LogGroup`.
	LogGroup *string `json:"logGroup" yaml:"logGroup"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
cloudWatchLogsLogDeliveryProperty := &cloudWatchLogsLogDeliveryProperty{
	enabled: jsii.Boolean(false),

	// the properties below are optional
	logGroup: jsii.String("logGroup"),
}

type CfnConnector_CustomPluginProperty 

type CfnConnector_CustomPluginProperty struct {
	// `CfnConnector.CustomPluginProperty.CustomPluginArn`.
	CustomPluginArn *string `json:"customPluginArn" yaml:"customPluginArn"`
	// `CfnConnector.CustomPluginProperty.Revision`.
	Revision *float64 `json:"revision" yaml:"revision"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
customPluginProperty := &customPluginProperty{
	customPluginArn: jsii.String("customPluginArn"),
	revision: jsii.Number(123),
}

type CfnConnector_FirehoseLogDeliveryProperty 

type CfnConnector_FirehoseLogDeliveryProperty struct {
	// `CfnConnector.FirehoseLogDeliveryProperty.Enabled`.
	Enabled interface{} `json:"enabled" yaml:"enabled"`
	// `CfnConnector.FirehoseLogDeliveryProperty.DeliveryStream`.
	DeliveryStream *string `json:"deliveryStream" yaml:"deliveryStream"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
firehoseLogDeliveryProperty := &firehoseLogDeliveryProperty{
	enabled: jsii.Boolean(false),

	// the properties below are optional
	deliveryStream: jsii.String("deliveryStream"),
}

type CfnConnector_KafkaClusterClientAuthenticationProperty 

type CfnConnector_KafkaClusterClientAuthenticationProperty struct {
	// `CfnConnector.KafkaClusterClientAuthenticationProperty.AuthenticationType`.
	AuthenticationType *string `json:"authenticationType" yaml:"authenticationType"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
kafkaClusterClientAuthenticationProperty := &kafkaClusterClientAuthenticationProperty{
	authenticationType: jsii.String("authenticationType"),
}

type CfnConnector_KafkaClusterEncryptionInTransitProperty 

type CfnConnector_KafkaClusterEncryptionInTransitProperty struct {
	// `CfnConnector.KafkaClusterEncryptionInTransitProperty.EncryptionType`.
	EncryptionType *string `json:"encryptionType" yaml:"encryptionType"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
kafkaClusterEncryptionInTransitProperty := &kafkaClusterEncryptionInTransitProperty{
	encryptionType: jsii.String("encryptionType"),
}

type CfnConnector_KafkaClusterProperty 

type CfnConnector_KafkaClusterProperty struct {
	// `CfnConnector.KafkaClusterProperty.ApacheKafkaCluster`.
	ApacheKafkaCluster interface{} `json:"apacheKafkaCluster" yaml:"apacheKafkaCluster"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
kafkaClusterProperty := &kafkaClusterProperty{
	apacheKafkaCluster: &apacheKafkaClusterProperty{
		bootstrapServers: jsii.String("bootstrapServers"),
		vpc: &vpcProperty{
			securityGroups: []*string{
				jsii.String("securityGroups"),
			},
			subnets: []*string{
				jsii.String("subnets"),
			},
		},
	},
}

type CfnConnector_LogDeliveryProperty 

type CfnConnector_LogDeliveryProperty struct {
	// `CfnConnector.LogDeliveryProperty.WorkerLogDelivery`.
	WorkerLogDelivery interface{} `json:"workerLogDelivery" yaml:"workerLogDelivery"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
logDeliveryProperty := &logDeliveryProperty{
	workerLogDelivery: &workerLogDeliveryProperty{
		cloudWatchLogs: &cloudWatchLogsLogDeliveryProperty{
			enabled: jsii.Boolean(false),

			// the properties below are optional
			logGroup: jsii.String("logGroup"),
		},
		firehose: &firehoseLogDeliveryProperty{
			enabled: jsii.Boolean(false),

			// the properties below are optional
			deliveryStream: jsii.String("deliveryStream"),
		},
		s3: &s3LogDeliveryProperty{
			enabled: jsii.Boolean(false),

			// the properties below are optional
			bucket: jsii.String("bucket"),
			prefix: jsii.String("prefix"),
		},
	},
}

type CfnConnector_PluginProperty 

type CfnConnector_PluginProperty struct {
	// `CfnConnector.PluginProperty.CustomPlugin`.
	CustomPlugin interface{} `json:"customPlugin" yaml:"customPlugin"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
pluginProperty := &pluginProperty{
	customPlugin: &customPluginProperty{
		customPluginArn: jsii.String("customPluginArn"),
		revision: jsii.Number(123),
	},
}

type CfnConnector_ProvisionedCapacityProperty 

type CfnConnector_ProvisionedCapacityProperty struct {
	// `CfnConnector.ProvisionedCapacityProperty.WorkerCount`.
	WorkerCount *float64 `json:"workerCount" yaml:"workerCount"`
	// `CfnConnector.ProvisionedCapacityProperty.McuCount`.
	McuCount *float64 `json:"mcuCount" yaml:"mcuCount"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
provisionedCapacityProperty := &provisionedCapacityProperty{
	workerCount: jsii.Number(123),

	// the properties below are optional
	mcuCount: jsii.Number(123),
}

type CfnConnector_S3LogDeliveryProperty 

type CfnConnector_S3LogDeliveryProperty struct {
	// `CfnConnector.S3LogDeliveryProperty.Enabled`.
	Enabled interface{} `json:"enabled" yaml:"enabled"`
	// `CfnConnector.S3LogDeliveryProperty.Bucket`.
	Bucket *string `json:"bucket" yaml:"bucket"`
	// `CfnConnector.S3LogDeliveryProperty.Prefix`.
	Prefix *string `json:"prefix" yaml:"prefix"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
s3LogDeliveryProperty := &s3LogDeliveryProperty{
	enabled: jsii.Boolean(false),

	// the properties below are optional
	bucket: jsii.String("bucket"),
	prefix: jsii.String("prefix"),
}

type CfnConnector_ScaleInPolicyProperty 

type CfnConnector_ScaleInPolicyProperty struct {
	// `CfnConnector.ScaleInPolicyProperty.CpuUtilizationPercentage`.
	CpuUtilizationPercentage *float64 `json:"cpuUtilizationPercentage" yaml:"cpuUtilizationPercentage"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
scaleInPolicyProperty := &scaleInPolicyProperty{
	cpuUtilizationPercentage: jsii.Number(123),
}

type CfnConnector_ScaleOutPolicyProperty 

type CfnConnector_ScaleOutPolicyProperty struct {
	// `CfnConnector.ScaleOutPolicyProperty.CpuUtilizationPercentage`.
	CpuUtilizationPercentage *float64 `json:"cpuUtilizationPercentage" yaml:"cpuUtilizationPercentage"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
scaleOutPolicyProperty := &scaleOutPolicyProperty{
	cpuUtilizationPercentage: jsii.Number(123),
}

type CfnConnector_VpcProperty 

type CfnConnector_VpcProperty struct {
	// `CfnConnector.VpcProperty.SecurityGroups`.
	SecurityGroups *[]*string `json:"securityGroups" yaml:"securityGroups"`
	// `CfnConnector.VpcProperty.Subnets`.
	Subnets *[]*string `json:"subnets" yaml:"subnets"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
vpcProperty := &vpcProperty{
	securityGroups: []*string{
		jsii.String("securityGroups"),
	},
	subnets: []*string{
		jsii.String("subnets"),
	},
}

type CfnConnector_WorkerConfigurationProperty 

type CfnConnector_WorkerConfigurationProperty struct {
	// `CfnConnector.WorkerConfigurationProperty.Revision`.
	Revision *float64 `json:"revision" yaml:"revision"`
	// `CfnConnector.WorkerConfigurationProperty.WorkerConfigurationArn`.
	WorkerConfigurationArn *string `json:"workerConfigurationArn" yaml:"workerConfigurationArn"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
workerConfigurationProperty := &workerConfigurationProperty{
	revision: jsii.Number(123),
	workerConfigurationArn: jsii.String("workerConfigurationArn"),
}

type CfnConnector_WorkerLogDeliveryProperty 

type CfnConnector_WorkerLogDeliveryProperty struct {
	// `CfnConnector.WorkerLogDeliveryProperty.CloudWatchLogs`.
	CloudWatchLogs interface{} `json:"cloudWatchLogs" yaml:"cloudWatchLogs"`
	// `CfnConnector.WorkerLogDeliveryProperty.Firehose`.
	Firehose interface{} `json:"firehose" yaml:"firehose"`
	// `CfnConnector.WorkerLogDeliveryProperty.S3`.
	S3 interface{} `json:"s3" yaml:"s3"`
}

Example: 

import awscdk "github.com/aws/aws-cdk-go/awscdk"import kafkaconnect "github.com/aws/aws-cdk-go/awscdk/aws_kafkaconnect"
workerLogDeliveryProperty := &workerLogDeliveryProperty{
	cloudWatchLogs: &cloudWatchLogsLogDeliveryProperty{
		enabled: jsii.Boolean(false),

		// the properties below are optional
		logGroup: jsii.String("logGroup"),
	},
	firehose: &firehoseLogDeliveryProperty{
		enabled: jsii.Boolean(false),

		// the properties below are optional
		deliveryStream: jsii.String("deliveryStream"),
	},
	s3: &s3LogDeliveryProperty{
		enabled: jsii.Boolean(false),

		// the properties below are optional
		bucket: jsii.String("bucket"),
		prefix: jsii.String("prefix"),
	},
}

Source Files

View all Source files

Directories

Path Synopsis

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.