awskafkaconnect

Documentation

Index

• func CfnConnector_CFN_RESOURCE_TYPE_NAME() *string
• func CfnConnector_IsCfnElement(x interface{}) *bool
• func CfnConnector_IsCfnResource(construct constructs.IConstruct) *bool
• func CfnConnector_IsConstruct(x interface{}) *bool
• func NewCfnConnector_Override(c CfnConnector, scope constructs.Construct, id *string, ...)
• type CfnConnector
  • func NewCfnConnector(scope constructs.Construct, id *string, props *CfnConnectorProps) CfnConnector
• type CfnConnectorProps
• type CfnConnector_ApacheKafkaClusterProperty
• type CfnConnector_AutoScalingProperty
• type CfnConnector_CapacityProperty
• type CfnConnector_CloudWatchLogsLogDeliveryProperty
• type CfnConnector_CustomPluginProperty
• type CfnConnector_FirehoseLogDeliveryProperty
• type CfnConnector_KafkaClusterClientAuthenticationProperty
• type CfnConnector_KafkaClusterEncryptionInTransitProperty
• type CfnConnector_KafkaClusterProperty
• type CfnConnector_LogDeliveryProperty
• type CfnConnector_PluginProperty
• type CfnConnector_ProvisionedCapacityProperty
• type CfnConnector_S3LogDeliveryProperty
• type CfnConnector_ScaleInPolicyProperty
• type CfnConnector_ScaleOutPolicyProperty
• type CfnConnector_VpcProperty
• type CfnConnector_WorkerConfigurationProperty
• type CfnConnector_WorkerLogDeliveryProperty

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
	Capacity() interface{}
	SetCapacity(val interface{})
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	ConnectorConfiguration() interface{}
	SetConnectorConfiguration(val interface{})
	ConnectorDescription() *string
	SetConnectorDescription(val *string)
	ConnectorName() *string
	SetConnectorName(val *string)
	CreationStack() *[]*string
	KafkaCluster() interface{}
	SetKafkaCluster(val interface{})
	KafkaClusterClientAuthentication() interface{}
	SetKafkaClusterClientAuthentication(val interface{})
	KafkaClusterEncryptionInTransit() interface{}
	SetKafkaClusterEncryptionInTransit(val interface{})
	KafkaConnectVersion() *string
	SetKafkaConnectVersion(val *string)
	LogDelivery() interface{}
	SetLogDelivery(val interface{})
	LogicalId() *string
	Node() constructs.Node
	Plugins() interface{}
	SetPlugins(val interface{})
	Ref() *string
	ServiceExecutionRoleArn() *string
	SetServiceExecutionRoleArn(val *string)
	Stack() awscdk.Stack
	UpdatedProperites() *map[string]interface{}
	WorkerConfiguration() interface{}
	SetWorkerConfiguration(val interface{})
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OverrideLogicalId(newLogicalId *string)
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	ToString() *string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KafkaConnect::Connector`.

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE

type CfnConnector_KafkaClusterClientAuthenticationProperty

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

TODO: EXAMPLE

type CfnConnector_KafkaClusterEncryptionInTransitProperty

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

TODO: EXAMPLE

type CfnConnector_KafkaClusterProperty

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

TODO: EXAMPLE

type CfnConnector_LogDeliveryProperty

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

TODO: EXAMPLE

type CfnConnector_PluginProperty

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

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE

type CfnConnector_ScaleInPolicyProperty

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

TODO: EXAMPLE

type CfnConnector_ScaleOutPolicyProperty

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

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE

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

TODO: EXAMPLE