types

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Jan 14, 2022 License: Apache-2.0 Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApacheKafkaCluster 

type ApacheKafkaCluster struct {

	// The bootstrap servers of the cluster.
	//
	// This member is required.
	BootstrapServers *string

	// Details of an Amazon VPC which has network connectivity to the Apache Kafka
	// cluster.
	//
	// This member is required.
	Vpc *Vpc
	// contains filtered or unexported fields
}

The details of the Apache Kafka cluster to which the connector is connected.

type ApacheKafkaClusterDescription 

type ApacheKafkaClusterDescription struct {

	// The bootstrap servers of the cluster.
	BootstrapServers *string

	// Details of an Amazon VPC which has network connectivity to the Apache Kafka
	// cluster.
	Vpc *VpcDescription
	// contains filtered or unexported fields
}

The description of the Apache Kafka cluster to which the connector is connected.

type AutoScaling 

type AutoScaling struct {

	// The maximum number of workers allocated to the connector.
	//
	// This member is required.
	MaxWorkerCount int32

	// The number of microcontroller units (MCUs) allocated to each connector worker.
	// The valid values are 1,2,4,8.
	//
	// This member is required.
	McuCount int32

	// The minimum number of workers allocated to the connector.
	//
	// This member is required.
	MinWorkerCount int32

	// The sacle-in policy for the connector.
	ScaleInPolicy *ScaleInPolicy

	// The sacle-out policy for the connector.
	ScaleOutPolicy *ScaleOutPolicy
	// contains filtered or unexported fields
}

Specifies how the connector scales.

type AutoScalingDescription 

type AutoScalingDescription struct {

	// The maximum number of workers allocated to the connector.
	MaxWorkerCount int32

	// The number of microcontroller units (MCUs) allocated to each connector worker.
	// The valid values are 1,2,4,8.
	McuCount int32

	// The minimum number of workers allocated to the connector.
	MinWorkerCount int32

	// The sacle-in policy for the connector.
	ScaleInPolicy *ScaleInPolicyDescription

	// The sacle-out policy for the connector.>
	ScaleOutPolicy *ScaleOutPolicyDescription
	// contains filtered or unexported fields
}

Information about the auto scaling parameters for the connector.

type AutoScalingUpdate 

type AutoScalingUpdate struct {

	// The target maximum number of workers allocated to the connector.
	//
	// This member is required.
	MaxWorkerCount int32

	// The target number of microcontroller units (MCUs) allocated to each connector
	// worker. The valid values are 1,2,4,8.
	//
	// This member is required.
	McuCount int32

	// The target minimum number of workers allocated to the connector.
	//
	// This member is required.
	MinWorkerCount int32

	// The target sacle-in policy for the connector.
	//
	// This member is required.
	ScaleInPolicy *ScaleInPolicyUpdate

	// The target sacle-out policy for the connector.
	//
	// This member is required.
	ScaleOutPolicy *ScaleOutPolicyUpdate
	// contains filtered or unexported fields
}

The updates to the auto scaling parameters for the connector.

type BadRequestException 

type BadRequestException struct {
	Message *string
	// contains filtered or unexported fields
}

HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.

func (*BadRequestException) Error 

func (e *BadRequestException) Error() string

func (*BadRequestException) ErrorCode 

func (e *BadRequestException) ErrorCode() string

func (*BadRequestException) ErrorFault 

func (e *BadRequestException) ErrorFault() smithy.ErrorFault

func (*BadRequestException) ErrorMessage 

func (e *BadRequestException) ErrorMessage() string

type Capacity 

type Capacity struct {

	// Information about the auto scaling parameters for the connector.
	AutoScaling *AutoScaling

	// Details about a fixed capacity allocated to a connector.
	ProvisionedCapacity *ProvisionedCapacity
	// contains filtered or unexported fields
}

Information about the capacity of the connector, whether it is auto scaled or provisioned.

type CapacityDescription 

type CapacityDescription struct {

	// Describes the connector's auto scaling capacity.
	AutoScaling *AutoScalingDescription

	// Describes a connector's provisioned capacity.
	ProvisionedCapacity *ProvisionedCapacityDescription
	// contains filtered or unexported fields
}

A description of the connector's capacity.

type CapacityUpdate 

type CapacityUpdate struct {

	// The target auto scaling setting.
	AutoScaling *AutoScalingUpdate

	// The target settings for provisioned capacity.
	ProvisionedCapacity *ProvisionedCapacityUpdate
	// contains filtered or unexported fields
}

The target capacity for the connector. The capacity can be auto scaled or provisioned.

type CloudWatchLogsLogDelivery 

type CloudWatchLogsLogDelivery struct {

	// Whether log delivery to Amazon CloudWatch Logs is enabled.
	//
	// This member is required.
	Enabled bool

	// The name of the CloudWatch log group that is the destination for log delivery.
	LogGroup *string
	// contains filtered or unexported fields
}

The settings for delivering connector logs to Amazon CloudWatch Logs.

type CloudWatchLogsLogDeliveryDescription 

type CloudWatchLogsLogDeliveryDescription struct {

	// Whether log delivery to Amazon CloudWatch Logs is enabled.
	Enabled bool

	// The name of the CloudWatch log group that is the destination for log delivery.
	LogGroup *string
	// contains filtered or unexported fields
}

A description of the log delivery settings.

type ConflictException 

type ConflictException struct {
	Message *string
	// contains filtered or unexported fields
}

HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.

func (*ConflictException) Error 

func (e *ConflictException) Error() string

func (*ConflictException) ErrorCode 

func (e *ConflictException) ErrorCode() string

func (*ConflictException) ErrorFault 

func (e *ConflictException) ErrorFault() smithy.ErrorFault

func (*ConflictException) ErrorMessage 

func (e *ConflictException) ErrorMessage() string

type ConnectorState 

type ConnectorState string
const (
	ConnectorStateRunning  ConnectorState = "RUNNING"
	ConnectorStateCreating ConnectorState = "CREATING"
	ConnectorStateUpdating ConnectorState = "UPDATING"
	ConnectorStateDeleting ConnectorState = "DELETING"
	ConnectorStateFailed   ConnectorState = "FAILED"
)

Enum values for ConnectorState

func (ConnectorState) Values 

func (ConnectorState) Values() []ConnectorState

Values returns all known values for ConnectorState. Note that this can be expanded in the future, and so it is only as up to date as the client. The ordering of this slice is not guaranteed to be stable across updates.

type ConnectorSummary 

type ConnectorSummary struct {

	// The connector's compute capacity settings.
	Capacity *CapacityDescription

	// The Amazon Resource Name (ARN) of the connector.
	ConnectorArn *string

	// The description of the connector.
	ConnectorDescription *string

	// The name of the connector.
	ConnectorName *string

	// The state of the connector.
	ConnectorState ConnectorState

	// The time that the connector was created.
	CreationTime *time.Time

	// The current version of the connector.
	CurrentVersion *string

	// The details of the Apache Kafka cluster to which the connector is connected.
	KafkaCluster *KafkaClusterDescription

	// The type of client authentication used to connect to the Apache Kafka cluster.
	// The value is NONE when no client authentication is used.
	KafkaClusterClientAuthentication *KafkaClusterClientAuthenticationDescription

	// Details of encryption in transit to the Apache Kafka cluster.
	KafkaClusterEncryptionInTransit *KafkaClusterEncryptionInTransitDescription

	// The version of Kafka Connect. It has to be compatible with both the Apache Kafka
	// cluster's version and the plugins.
	KafkaConnectVersion *string

	// The settings for delivering connector logs to Amazon CloudWatch Logs.
	LogDelivery *LogDeliveryDescription

	// Specifies which plugins were used for this connector.
	Plugins []PluginDescription

	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access
	// Amazon Web Services resources.
	ServiceExecutionRoleArn *string

	// The worker configurations that are in use with the connector.
	WorkerConfiguration *WorkerConfigurationDescription
	// contains filtered or unexported fields
}

Summary of a connector.

type CustomPlugin 

type CustomPlugin struct {

	// The Amazon Resource Name (ARN) of the custom plugin.
	//
	// This member is required.
	CustomPluginArn *string

	// The revision of the custom plugin.
	//
	// This member is required.
	Revision int64
	// contains filtered or unexported fields
}

A plugin is an AWS resource that contains the code that defines a connector's logic.

type CustomPluginContentType 

type CustomPluginContentType string
const (
	CustomPluginContentTypeJar CustomPluginContentType = "JAR"
	CustomPluginContentTypeZip CustomPluginContentType = "ZIP"
)

Enum values for CustomPluginContentType

func (CustomPluginContentType) Values 

func (CustomPluginContentType) Values() []CustomPluginContentType

Values returns all known values for CustomPluginContentType. Note that this can be expanded in the future, and so it is only as up to date as the client. The ordering of this slice is not guaranteed to be stable across updates.

type CustomPluginDescription 

type CustomPluginDescription struct {

	// The Amazon Resource Name (ARN) of the custom plugin.
	CustomPluginArn *string

	// The revision of the custom plugin.
	Revision int64
	// contains filtered or unexported fields
}

Details about a custom plugin.

type CustomPluginFileDescription 

type CustomPluginFileDescription struct {

	// The hex-encoded MD5 checksum of the custom plugin file. You can use it to
	// validate the file.
	FileMd5 *string

	// The size in bytes of the custom plugin file. You can use it to validate the
	// file.
	FileSize int64
	// contains filtered or unexported fields
}

Details about a custom plugin file.

type CustomPluginLocation 

type CustomPluginLocation struct {

	// The S3 bucket Amazon Resource Name (ARN), file key, and object version of the
	// plugin file stored in Amazon S3.
	//
	// This member is required.
	S3Location *S3Location
	// contains filtered or unexported fields
}

Information about the location of a custom plugin.

type CustomPluginLocationDescription 

type CustomPluginLocationDescription struct {

	// The S3 bucket Amazon Resource Name (ARN), file key, and object version of the
	// plugin file stored in Amazon S3.
	S3Location *S3LocationDescription
	// contains filtered or unexported fields
}

Information about the location of a custom plugin.

type CustomPluginRevisionSummary 

type CustomPluginRevisionSummary struct {

	// The format of the plugin file.
	ContentType CustomPluginContentType

	// The time that the custom plugin was created.
	CreationTime *time.Time

	// The description of the custom plugin.
	Description *string

	// Details about the custom plugin file.
	FileDescription *CustomPluginFileDescription

	// Information about the location of the custom plugin.
	Location *CustomPluginLocationDescription

	// The revision of the custom plugin.
	Revision int64
	// contains filtered or unexported fields
}

Details about the revision of a custom plugin.

type CustomPluginState 

type CustomPluginState string
const (
	CustomPluginStateCreating     CustomPluginState = "CREATING"
	CustomPluginStateCreateFailed CustomPluginState = "CREATE_FAILED"
	CustomPluginStateActive       CustomPluginState = "ACTIVE"
	CustomPluginStateUpdating     CustomPluginState = "UPDATING"
	CustomPluginStateUpdateFailed CustomPluginState = "UPDATE_FAILED"
	CustomPluginStateDeleting     CustomPluginState = "DELETING"
)

Enum values for CustomPluginState

func (CustomPluginState) Values 

func (CustomPluginState) Values() []CustomPluginState

Values returns all known values for CustomPluginState. Note that this can be expanded in the future, and so it is only as up to date as the client. The ordering of this slice is not guaranteed to be stable across updates.

type CustomPluginSummary 

type CustomPluginSummary struct {

	// The time that the custom plugin was created.
	CreationTime *time.Time

	// The Amazon Resource Name (ARN) of the custom plugin.
	CustomPluginArn *string

	// The state of the custom plugin.
	CustomPluginState CustomPluginState

	// A description of the custom plugin.
	Description *string

	// The latest revision of the custom plugin.
	LatestRevision *CustomPluginRevisionSummary

	// The name of the custom plugin.
	Name *string
	// contains filtered or unexported fields
}

A summary of the custom plugin.

type FirehoseLogDelivery 

type FirehoseLogDelivery struct {

	// Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
	//
	// This member is required.
	Enabled bool

	// The name of the Kinesis Data Firehose delivery stream that is the destination
	// for log delivery.
	DeliveryStream *string
	// contains filtered or unexported fields
}

The settings for delivering logs to Amazon Kinesis Data Firehose.

type FirehoseLogDeliveryDescription 

type FirehoseLogDeliveryDescription struct {

	// The name of the Kinesis Data Firehose delivery stream that is the destination
	// for log delivery.
	DeliveryStream *string

	// Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
	Enabled bool
	// contains filtered or unexported fields
}

A description of the settings for delivering logs to Amazon Kinesis Data Firehose.

type ForbiddenException 

type ForbiddenException struct {
	Message *string
	// contains filtered or unexported fields
}

HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.

func (*ForbiddenException) Error 

func (e *ForbiddenException) Error() string

func (*ForbiddenException) ErrorCode 

func (e *ForbiddenException) ErrorCode() string

func (*ForbiddenException) ErrorFault 

func (e *ForbiddenException) ErrorFault() smithy.ErrorFault

func (*ForbiddenException) ErrorMessage 

func (e *ForbiddenException) ErrorMessage() string

type InternalServerErrorException 

type InternalServerErrorException struct {
	Message *string
	// contains filtered or unexported fields
}

HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.

func (*InternalServerErrorException) Error 

func (e *InternalServerErrorException) Error() string

func (*InternalServerErrorException) ErrorCode 

func (e *InternalServerErrorException) ErrorCode() string

func (*InternalServerErrorException) ErrorFault 

func (e *InternalServerErrorException) ErrorFault() smithy.ErrorFault

func (*InternalServerErrorException) ErrorMessage 

func (e *InternalServerErrorException) ErrorMessage() string

type KafkaCluster 

type KafkaCluster struct {

	// The Apache Kafka cluster to which the connector is connected.
	//
	// This member is required.
	ApacheKafkaCluster *ApacheKafkaCluster
	// contains filtered or unexported fields
}

The details of the Apache Kafka cluster to which the connector is connected.

type KafkaClusterClientAuthentication 

type KafkaClusterClientAuthentication struct {

	// The type of client authentication used to connect to the Apache Kafka cluster.
	// Value NONE means that no client authentication is used.
	//
	// This member is required.
	AuthenticationType KafkaClusterClientAuthenticationType
	// contains filtered or unexported fields
}

The client authentication information used in order to authenticate with the Apache Kafka cluster.

type KafkaClusterClientAuthenticationDescription 

type KafkaClusterClientAuthenticationDescription struct {

	// The type of client authentication used to connect to the Apache Kafka cluster.
	// Value NONE means that no client authentication is used.
	AuthenticationType KafkaClusterClientAuthenticationType
	// contains filtered or unexported fields
}

The client authentication information used in order to authenticate with the Apache Kafka cluster.

type KafkaClusterClientAuthenticationType 

type KafkaClusterClientAuthenticationType string
const (
	KafkaClusterClientAuthenticationTypeNone KafkaClusterClientAuthenticationType = "NONE"
	KafkaClusterClientAuthenticationTypeIam  KafkaClusterClientAuthenticationType = "IAM"
)

Enum values for KafkaClusterClientAuthenticationType

func (KafkaClusterClientAuthenticationType) Values 

func (KafkaClusterClientAuthenticationType) Values() []KafkaClusterClientAuthenticationType

Values returns all known values for KafkaClusterClientAuthenticationType. Note that this can be expanded in the future, and so it is only as up to date as the client. The ordering of this slice is not guaranteed to be stable across updates.

type KafkaClusterDescription 

type KafkaClusterDescription struct {

	// The Apache Kafka cluster to which the connector is connected.
	ApacheKafkaCluster *ApacheKafkaClusterDescription
	// contains filtered or unexported fields
}

Details of how to connect to the Apache Kafka cluster.

type KafkaClusterEncryptionInTransit 

type KafkaClusterEncryptionInTransit struct {

	// The type of encryption in transit to the Apache Kafka cluster.
	//
	// This member is required.
	EncryptionType KafkaClusterEncryptionInTransitType
	// contains filtered or unexported fields
}

Details of encryption in transit to the Apache Kafka cluster.

type KafkaClusterEncryptionInTransitDescription 

type KafkaClusterEncryptionInTransitDescription struct {

	// The type of encryption in transit to the Apache Kafka cluster.
	EncryptionType KafkaClusterEncryptionInTransitType
	// contains filtered or unexported fields
}

The description of the encryption in transit to the Apache Kafka cluster.

type KafkaClusterEncryptionInTransitType 

type KafkaClusterEncryptionInTransitType string
const (
	KafkaClusterEncryptionInTransitTypePlaintext KafkaClusterEncryptionInTransitType = "PLAINTEXT"
	KafkaClusterEncryptionInTransitTypeTls       KafkaClusterEncryptionInTransitType = "TLS"
)

Enum values for KafkaClusterEncryptionInTransitType

func (KafkaClusterEncryptionInTransitType) Values 

func (KafkaClusterEncryptionInTransitType) Values() []KafkaClusterEncryptionInTransitType

Values returns all known values for KafkaClusterEncryptionInTransitType. Note that this can be expanded in the future, and so it is only as up to date as the client. The ordering of this slice is not guaranteed to be stable across updates.

type LogDelivery 

type LogDelivery struct {

	// The workers can send worker logs to different destination types. This
	// configuration specifies the details of these destinations.
	//
	// This member is required.
	WorkerLogDelivery *WorkerLogDelivery
	// contains filtered or unexported fields
}

Details about log delivery.

type LogDeliveryDescription 

type LogDeliveryDescription struct {

	// The workers can send worker logs to different destination types. This
	// configuration specifies the details of these destinations.
	WorkerLogDelivery *WorkerLogDeliveryDescription
	// contains filtered or unexported fields
}

The description of the log delivery settings.

type NotFoundException 

type NotFoundException struct {
	Message *string
	// contains filtered or unexported fields
}

HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.

func (*NotFoundException) Error 

func (e *NotFoundException) Error() string

func (*NotFoundException) ErrorCode 

func (e *NotFoundException) ErrorCode() string

func (*NotFoundException) ErrorFault 

func (e *NotFoundException) ErrorFault() smithy.ErrorFault

func (*NotFoundException) ErrorMessage 

func (e *NotFoundException) ErrorMessage() string

type Plugin 

type Plugin struct {

	// Details about a custom plugin.
	//
	// This member is required.
	CustomPlugin *CustomPlugin
	// contains filtered or unexported fields
}

A plugin is an AWS resource that contains the code that defines your connector logic.

type PluginDescription 

type PluginDescription struct {

	// Details about a custom plugin.
	CustomPlugin *CustomPluginDescription
	// contains filtered or unexported fields
}

The description of the plugin.

type ProvisionedCapacity 

type ProvisionedCapacity struct {

	// The number of microcontroller units (MCUs) allocated to each connector worker.
	// The valid values are 1,2,4,8.
	//
	// This member is required.
	McuCount int32

	// The number of workers that are allocated to the connector.
	//
	// This member is required.
	WorkerCount int32
	// contains filtered or unexported fields
}

Details about a connector's provisioned capacity.

type ProvisionedCapacityDescription 

type ProvisionedCapacityDescription struct {

	// The number of microcontroller units (MCUs) allocated to each connector worker.
	// The valid values are 1,2,4,8.
	McuCount int32

	// The number of workers that are allocated to the connector.
	WorkerCount int32
	// contains filtered or unexported fields
}

The description of a connector's provisioned capacity.

type ProvisionedCapacityUpdate 

type ProvisionedCapacityUpdate struct {

	// The number of microcontroller units (MCUs) allocated to each connector worker.
	// The valid values are 1,2,4,8.
	//
	// This member is required.
	McuCount int32

	// The number of workers that are allocated to the connector.
	//
	// This member is required.
	WorkerCount int32
	// contains filtered or unexported fields
}

An update to a connector's fixed capacity.

type S3Location 

type S3Location struct {

	// The Amazon Resource Name (ARN) of an S3 bucket.
	//
	// This member is required.
	BucketArn *string

	// The file key for an object in an S3 bucket.
	//
	// This member is required.
	FileKey *string

	// The version of an object in an S3 bucket.
	ObjectVersion *string
	// contains filtered or unexported fields
}

The location of an object in Amazon S3.

type S3LocationDescription 

type S3LocationDescription struct {

	// The Amazon Resource Name (ARN) of an S3 bucket.
	BucketArn *string

	// The file key for an object in an S3 bucket.
	FileKey *string

	// The version of an object in an S3 bucket.
	ObjectVersion *string
	// contains filtered or unexported fields
}

The description of the location of an object in Amazon S3.

type S3LogDelivery 

type S3LogDelivery struct {

	// Specifies whether connector logs get sent to the specified Amazon S3
	// destination.
	//
	// This member is required.
	Enabled bool

	// The name of the S3 bucket that is the destination for log delivery.
	Bucket *string

	// The S3 prefix that is the destination for log delivery.
	Prefix *string
	// contains filtered or unexported fields
}

Details about delivering logs to Amazon S3.

type S3LogDeliveryDescription 

type S3LogDeliveryDescription struct {

	// The name of the S3 bucket that is the destination for log delivery.
	Bucket *string

	// Specifies whether connector logs get sent to the specified Amazon S3
	// destination.
	Enabled bool

	// The S3 prefix that is the destination for log delivery.
	Prefix *string
	// contains filtered or unexported fields
}

The description of the details about delivering logs to Amazon S3.

type ScaleInPolicy 

type ScaleInPolicy struct {

	// Specifies the CPU utilization percentage threshold at which you want connector
	// scale in to be triggered.
	//
	// This member is required.
	CpuUtilizationPercentage int32
	// contains filtered or unexported fields
}

The scale-in policy for the connector.

type ScaleInPolicyDescription 

type ScaleInPolicyDescription struct {

	// Specifies the CPU utilization percentage threshold at which you want connector
	// scale in to be triggered.
	CpuUtilizationPercentage int32
	// contains filtered or unexported fields
}

The description of the scale-in policy for the connector.

type ScaleInPolicyUpdate 

type ScaleInPolicyUpdate struct {

	// The target CPU utilization percentage threshold at which you want connector
	// scale in to be triggered.
	//
	// This member is required.
	CpuUtilizationPercentage int32
	// contains filtered or unexported fields
}

An update to the connector's scale-in policy.

type ScaleOutPolicy 

type ScaleOutPolicy struct {

	// The CPU utilization percentage threshold at which you want connector scale out
	// to be triggered.
	//
	// This member is required.
	CpuUtilizationPercentage int32
	// contains filtered or unexported fields
}

The scale-out policy for the connector.

type ScaleOutPolicyDescription 

type ScaleOutPolicyDescription struct {

	// The CPU utilization percentage threshold at which you want connector scale out
	// to be triggered.
	CpuUtilizationPercentage int32
	// contains filtered or unexported fields
}

The description of the scale-out policy for the connector.

type ScaleOutPolicyUpdate 

type ScaleOutPolicyUpdate struct {

	// The target CPU utilization percentage threshold at which you want connector
	// scale out to be triggered.
	//
	// This member is required.
	CpuUtilizationPercentage int32
	// contains filtered or unexported fields
}

An update to the connector's scale-out policy.

type ServiceUnavailableException 

type ServiceUnavailableException struct {
	Message *string
	// contains filtered or unexported fields
}

HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.

func (*ServiceUnavailableException) Error 

func (e *ServiceUnavailableException) Error() string

func (*ServiceUnavailableException) ErrorCode 

func (e *ServiceUnavailableException) ErrorCode() string

func (*ServiceUnavailableException) ErrorFault 

func (e *ServiceUnavailableException) ErrorFault() smithy.ErrorFault

func (*ServiceUnavailableException) ErrorMessage 

func (e *ServiceUnavailableException) ErrorMessage() string

type TooManyRequestsException 

type TooManyRequestsException struct {
	Message *string
	// contains filtered or unexported fields
}

HTTP Status Code 429: Limit exceeded. Resource limit reached.

func (*TooManyRequestsException) Error 

func (e *TooManyRequestsException) Error() string

func (*TooManyRequestsException) ErrorCode 

func (e *TooManyRequestsException) ErrorCode() string

func (*TooManyRequestsException) ErrorFault 

func (e *TooManyRequestsException) ErrorFault() smithy.ErrorFault

func (*TooManyRequestsException) ErrorMessage 

func (e *TooManyRequestsException) ErrorMessage() string

type UnauthorizedException 

type UnauthorizedException struct {
	Message *string
	// contains filtered or unexported fields
}

HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.

func (*UnauthorizedException) Error 

func (e *UnauthorizedException) Error() string

func (*UnauthorizedException) ErrorCode 

func (e *UnauthorizedException) ErrorCode() string

func (*UnauthorizedException) ErrorFault 

func (e *UnauthorizedException) ErrorFault() smithy.ErrorFault

func (*UnauthorizedException) ErrorMessage 

func (e *UnauthorizedException) ErrorMessage() string

type Vpc 

type Vpc struct {

	// The subnets for the connector.
	//
	// This member is required.
	Subnets []string

	// The security groups for the connector.
	SecurityGroups []string
	// contains filtered or unexported fields
}

Information about the VPC in which the connector resides.

type VpcDescription 

type VpcDescription struct {

	// The security groups for the connector.
	SecurityGroups []string

	// The subnets for the connector.
	Subnets []string
	// contains filtered or unexported fields
}

The description of the VPC in which the connector resides.

type WorkerConfiguration 

type WorkerConfiguration struct {

	// The revision of the worker configuration.
	//
	// This member is required.
	Revision int64

	// The Amazon Resource Name (ARN) of the worker configuration.
	//
	// This member is required.
	WorkerConfigurationArn *string
	// contains filtered or unexported fields
}

The configuration of the workers, which are the processes that run the connector logic.

type WorkerConfigurationDescription 

type WorkerConfigurationDescription struct {

	// The revision of the worker configuration.
	Revision int64

	// The Amazon Resource Name (ARN) of the worker configuration.
	WorkerConfigurationArn *string
	// contains filtered or unexported fields
}

The description of the worker configuration.

type WorkerConfigurationRevisionDescription 

type WorkerConfigurationRevisionDescription struct {

	// The time that the worker configuration was created.
	CreationTime *time.Time

	// The description of the worker configuration revision.
	Description *string

	// Base64 encoded contents of the connect-distributed.properties file.
	PropertiesFileContent *string

	// The description of a revision of the worker configuration.
	Revision int64
	// contains filtered or unexported fields
}

The description of the worker configuration revision.

type WorkerConfigurationRevisionSummary 

type WorkerConfigurationRevisionSummary struct {

	// The time that a worker configuration revision was created.
	CreationTime *time.Time

	// The description of a worker configuration revision.
	Description *string

	// The revision of a worker configuration.
	Revision int64
	// contains filtered or unexported fields
}

The summary of a worker configuration revision.

type WorkerConfigurationSummary 

type WorkerConfigurationSummary struct {

	// The time that a worker configuration was created.
	CreationTime *time.Time

	// The description of a worker configuration.
	Description *string

	// The latest revision of a worker configuration.
	LatestRevision *WorkerConfigurationRevisionSummary

	// The name of the worker configuration.
	Name *string

	// The Amazon Resource Name (ARN) of the worker configuration.
	WorkerConfigurationArn *string
	// contains filtered or unexported fields
}

The summary of a worker configuration.

type WorkerLogDelivery 

type WorkerLogDelivery struct {

	// Details about delivering logs to Amazon CloudWatch Logs.
	CloudWatchLogs *CloudWatchLogsLogDelivery

	// Details about delivering logs to Amazon Kinesis Data Firehose.
	Firehose *FirehoseLogDelivery

	// Details about delivering logs to Amazon S3.
	S3 *S3LogDelivery
	// contains filtered or unexported fields
}

Workers can send worker logs to different destination types. This configuration specifies the details of these destinations.

type WorkerLogDeliveryDescription 

type WorkerLogDeliveryDescription struct {

	// Details about delivering logs to Amazon CloudWatch Logs.
	CloudWatchLogs *CloudWatchLogsLogDeliveryDescription

	// Details about delivering logs to Amazon Kinesis Data Firehose.
	Firehose *FirehoseLogDeliveryDescription

	// Details about delivering logs to Amazon S3.
	S3 *S3LogDeliveryDescription
	// contains filtered or unexported fields
}

Workers can send worker logs to different destination types. This configuration specifies the details of these destinations.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.