func ConnectorState_Values() []string
ConnectorState_Values returns all elements of the ConnectorState enum
func CustomPluginContentType_Values() []string
CustomPluginContentType_Values returns all elements of the CustomPluginContentType enum
func CustomPluginState_Values() []string
CustomPluginState_Values returns all elements of the CustomPluginState enum
func KafkaClusterClientAuthenticationType_Values() []string
KafkaClusterClientAuthenticationType_Values returns all elements of the KafkaClusterClientAuthenticationType enum
func KafkaClusterEncryptionInTransitType_Values() []string
KafkaClusterEncryptionInTransitType_Values returns all elements of the KafkaClusterEncryptionInTransitType enum
func WorkerConfigurationState_Values() []string
WorkerConfigurationState_Values returns all elements of the WorkerConfigurationState enum
type ApacheKafkaCluster struct {
// The bootstrap servers of the cluster.
//
// BootstrapServers is a required field
BootstrapServers *string `locationName:"bootstrapServers" type:"string" required:"true"`
// Details of an Amazon VPC which has network connectivity to the Apache Kafka
// cluster.
//
// Vpc is a required field
Vpc *Vpc `locationName:"vpc" type:"structure" required:"true"`
// contains filtered or unexported fields
}
The details of the Apache Kafka cluster to which the connector is connected.
func (s ApacheKafkaCluster) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ApacheKafkaCluster) SetBootstrapServers(v string) *ApacheKafkaCluster
SetBootstrapServers sets the BootstrapServers field's value.
func (s *ApacheKafkaCluster) SetVpc(v *Vpc) *ApacheKafkaCluster
SetVpc sets the Vpc field's value.
func (s ApacheKafkaCluster) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ApacheKafkaCluster) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ApacheKafkaClusterDescription struct {
// The bootstrap servers of the cluster.
BootstrapServers *string `locationName:"bootstrapServers" type:"string"`
// Details of an Amazon VPC which has network connectivity to the Apache Kafka
// cluster.
Vpc *VpcDescription `locationName:"vpc" type:"structure"`
// contains filtered or unexported fields
}
The description of the Apache Kafka cluster to which the connector is connected.
func (s ApacheKafkaClusterDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ApacheKafkaClusterDescription) SetBootstrapServers(v string) *ApacheKafkaClusterDescription
SetBootstrapServers sets the BootstrapServers field's value.
func (s *ApacheKafkaClusterDescription) SetVpc(v *VpcDescription) *ApacheKafkaClusterDescription
SetVpc sets the Vpc field's value.
func (s ApacheKafkaClusterDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type AutoScaling struct {
// The maximum number of workers allocated to the connector.
//
// MaxWorkerCount is a required field
MaxWorkerCount *int64 `locationName:"maxWorkerCount" min:"1" type:"integer" required:"true"`
// The number of microcontroller units (MCUs) allocated to each connector worker.
// The valid values are 1,2,4,8.
//
// McuCount is a required field
McuCount *int64 `locationName:"mcuCount" min:"1" type:"integer" required:"true"`
// The minimum number of workers allocated to the connector.
//
// MinWorkerCount is a required field
MinWorkerCount *int64 `locationName:"minWorkerCount" min:"1" type:"integer" required:"true"`
// The sacle-in policy for the connector.
ScaleInPolicy *ScaleInPolicy `locationName:"scaleInPolicy" type:"structure"`
// The sacle-out policy for the connector.
ScaleOutPolicy *ScaleOutPolicy `locationName:"scaleOutPolicy" type:"structure"`
// contains filtered or unexported fields
}
Specifies how the connector scales.
func (s AutoScaling) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *AutoScaling) SetMaxWorkerCount(v int64) *AutoScaling
SetMaxWorkerCount sets the MaxWorkerCount field's value.
func (s *AutoScaling) SetMcuCount(v int64) *AutoScaling
SetMcuCount sets the McuCount field's value.
func (s *AutoScaling) SetMinWorkerCount(v int64) *AutoScaling
SetMinWorkerCount sets the MinWorkerCount field's value.
func (s *AutoScaling) SetScaleInPolicy(v *ScaleInPolicy) *AutoScaling
SetScaleInPolicy sets the ScaleInPolicy field's value.
func (s *AutoScaling) SetScaleOutPolicy(v *ScaleOutPolicy) *AutoScaling
SetScaleOutPolicy sets the ScaleOutPolicy field's value.
func (s AutoScaling) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *AutoScaling) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type AutoScalingDescription struct {
// The maximum number of workers allocated to the connector.
MaxWorkerCount *int64 `locationName:"maxWorkerCount" type:"integer"`
// The number of microcontroller units (MCUs) allocated to each connector worker.
// The valid values are 1,2,4,8.
McuCount *int64 `locationName:"mcuCount" type:"integer"`
// The minimum number of workers allocated to the connector.
MinWorkerCount *int64 `locationName:"minWorkerCount" type:"integer"`
// The sacle-in policy for the connector.
ScaleInPolicy *ScaleInPolicyDescription `locationName:"scaleInPolicy" type:"structure"`
// The sacle-out policy for the connector.>
ScaleOutPolicy *ScaleOutPolicyDescription `locationName:"scaleOutPolicy" type:"structure"`
// contains filtered or unexported fields
}
Information about the auto scaling parameters for the connector.
func (s AutoScalingDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *AutoScalingDescription) SetMaxWorkerCount(v int64) *AutoScalingDescription
SetMaxWorkerCount sets the MaxWorkerCount field's value.
func (s *AutoScalingDescription) SetMcuCount(v int64) *AutoScalingDescription
SetMcuCount sets the McuCount field's value.
func (s *AutoScalingDescription) SetMinWorkerCount(v int64) *AutoScalingDescription
SetMinWorkerCount sets the MinWorkerCount field's value.
func (s *AutoScalingDescription) SetScaleInPolicy(v *ScaleInPolicyDescription) *AutoScalingDescription
SetScaleInPolicy sets the ScaleInPolicy field's value.
func (s *AutoScalingDescription) SetScaleOutPolicy(v *ScaleOutPolicyDescription) *AutoScalingDescription
SetScaleOutPolicy sets the ScaleOutPolicy field's value.
func (s AutoScalingDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type AutoScalingUpdate struct {
// The target maximum number of workers allocated to the connector.
//
// MaxWorkerCount is a required field
MaxWorkerCount *int64 `locationName:"maxWorkerCount" min:"1" type:"integer" required:"true"`
// The target number of microcontroller units (MCUs) allocated to each connector
// worker. The valid values are 1,2,4,8.
//
// McuCount is a required field
McuCount *int64 `locationName:"mcuCount" min:"1" type:"integer" required:"true"`
// The target minimum number of workers allocated to the connector.
//
// MinWorkerCount is a required field
MinWorkerCount *int64 `locationName:"minWorkerCount" min:"1" type:"integer" required:"true"`
// The target sacle-in policy for the connector.
//
// ScaleInPolicy is a required field
ScaleInPolicy *ScaleInPolicyUpdate `locationName:"scaleInPolicy" type:"structure" required:"true"`
// The target sacle-out policy for the connector.
//
// ScaleOutPolicy is a required field
ScaleOutPolicy *ScaleOutPolicyUpdate `locationName:"scaleOutPolicy" type:"structure" required:"true"`
// contains filtered or unexported fields
}
The updates to the auto scaling parameters for the connector.
func (s AutoScalingUpdate) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *AutoScalingUpdate) SetMaxWorkerCount(v int64) *AutoScalingUpdate
SetMaxWorkerCount sets the MaxWorkerCount field's value.
func (s *AutoScalingUpdate) SetMcuCount(v int64) *AutoScalingUpdate
SetMcuCount sets the McuCount field's value.
func (s *AutoScalingUpdate) SetMinWorkerCount(v int64) *AutoScalingUpdate
SetMinWorkerCount sets the MinWorkerCount field's value.
func (s *AutoScalingUpdate) SetScaleInPolicy(v *ScaleInPolicyUpdate) *AutoScalingUpdate
SetScaleInPolicy sets the ScaleInPolicy field's value.
func (s *AutoScalingUpdate) SetScaleOutPolicy(v *ScaleOutPolicyUpdate) *AutoScalingUpdate
SetScaleOutPolicy sets the ScaleOutPolicy field's value.
func (s AutoScalingUpdate) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *AutoScalingUpdate) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type BadRequestException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
func (s *BadRequestException) Code() string
Code returns the exception type name.
func (s *BadRequestException) Error() string
func (s BadRequestException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *BadRequestException) Message() string
Message returns the exception's message.
func (s *BadRequestException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *BadRequestException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *BadRequestException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s BadRequestException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type Capacity struct {
// Information about the auto scaling parameters for the connector.
AutoScaling *AutoScaling `locationName:"autoScaling" type:"structure"`
// Details about a fixed capacity allocated to a connector.
ProvisionedCapacity *ProvisionedCapacity `locationName:"provisionedCapacity" type:"structure"`
// contains filtered or unexported fields
}
Information about the capacity of the connector, whether it is auto scaled or provisioned.
func (s Capacity) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Capacity) SetAutoScaling(v *AutoScaling) *Capacity
SetAutoScaling sets the AutoScaling field's value.
func (s *Capacity) SetProvisionedCapacity(v *ProvisionedCapacity) *Capacity
SetProvisionedCapacity sets the ProvisionedCapacity field's value.
func (s Capacity) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Capacity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CapacityDescription struct {
// Describes the connector's auto scaling capacity.
AutoScaling *AutoScalingDescription `locationName:"autoScaling" type:"structure"`
// Describes a connector's provisioned capacity.
ProvisionedCapacity *ProvisionedCapacityDescription `locationName:"provisionedCapacity" type:"structure"`
// contains filtered or unexported fields
}
A description of the connector's capacity.
func (s CapacityDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CapacityDescription) SetAutoScaling(v *AutoScalingDescription) *CapacityDescription
SetAutoScaling sets the AutoScaling field's value.
func (s *CapacityDescription) SetProvisionedCapacity(v *ProvisionedCapacityDescription) *CapacityDescription
SetProvisionedCapacity sets the ProvisionedCapacity field's value.
func (s CapacityDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CapacityUpdate struct {
// The target auto scaling setting.
AutoScaling *AutoScalingUpdate `locationName:"autoScaling" type:"structure"`
// The target settings for provisioned capacity.
ProvisionedCapacity *ProvisionedCapacityUpdate `locationName:"provisionedCapacity" type:"structure"`
// contains filtered or unexported fields
}
The target capacity for the connector. The capacity can be auto scaled or provisioned.
func (s CapacityUpdate) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CapacityUpdate) SetAutoScaling(v *AutoScalingUpdate) *CapacityUpdate
SetAutoScaling sets the AutoScaling field's value.
func (s *CapacityUpdate) SetProvisionedCapacity(v *ProvisionedCapacityUpdate) *CapacityUpdate
SetProvisionedCapacity sets the ProvisionedCapacity field's value.
func (s CapacityUpdate) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CapacityUpdate) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CloudWatchLogsLogDelivery struct {
// Whether log delivery to Amazon CloudWatch Logs is enabled.
//
// Enabled is a required field
Enabled *bool `locationName:"enabled" type:"boolean" required:"true"`
// The name of the CloudWatch log group that is the destination for log delivery.
LogGroup *string `locationName:"logGroup" type:"string"`
// contains filtered or unexported fields
}
The settings for delivering connector logs to Amazon CloudWatch Logs.
func (s CloudWatchLogsLogDelivery) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CloudWatchLogsLogDelivery) SetEnabled(v bool) *CloudWatchLogsLogDelivery
SetEnabled sets the Enabled field's value.
func (s *CloudWatchLogsLogDelivery) SetLogGroup(v string) *CloudWatchLogsLogDelivery
SetLogGroup sets the LogGroup field's value.
func (s CloudWatchLogsLogDelivery) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CloudWatchLogsLogDelivery) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CloudWatchLogsLogDeliveryDescription struct {
// Whether log delivery to Amazon CloudWatch Logs is enabled.
Enabled *bool `locationName:"enabled" type:"boolean"`
// The name of the CloudWatch log group that is the destination for log delivery.
LogGroup *string `locationName:"logGroup" type:"string"`
// contains filtered or unexported fields
}
A description of the log delivery settings.
func (s CloudWatchLogsLogDeliveryDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CloudWatchLogsLogDeliveryDescription) SetEnabled(v bool) *CloudWatchLogsLogDeliveryDescription
SetEnabled sets the Enabled field's value.
func (s *CloudWatchLogsLogDeliveryDescription) SetLogGroup(v string) *CloudWatchLogsLogDeliveryDescription
SetLogGroup sets the LogGroup field's value.
func (s CloudWatchLogsLogDeliveryDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ConflictException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"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 (s *ConflictException) Code() string
Code returns the exception type name.
func (s *ConflictException) Error() string
func (s ConflictException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ConflictException) Message() string
Message returns the exception's message.
func (s *ConflictException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ConflictException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ConflictException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ConflictException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ConnectorSummary struct {
// The connector's compute capacity settings.
Capacity *CapacityDescription `locationName:"capacity" type:"structure"`
// The Amazon Resource Name (ARN) of the connector.
ConnectorArn *string `locationName:"connectorArn" type:"string"`
// The description of the connector.
ConnectorDescription *string `locationName:"connectorDescription" type:"string"`
// The name of the connector.
ConnectorName *string `locationName:"connectorName" type:"string"`
// The state of the connector.
ConnectorState *string `locationName:"connectorState" type:"string" enum:"ConnectorState"`
// The time that the connector was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The current version of the connector.
CurrentVersion *string `locationName:"currentVersion" type:"string"`
// The details of the Apache Kafka cluster to which the connector is connected.
KafkaCluster *KafkaClusterDescription `locationName:"kafkaCluster" type:"structure"`
// 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 `locationName:"kafkaClusterClientAuthentication" type:"structure"`
// Details of encryption in transit to the Apache Kafka cluster.
KafkaClusterEncryptionInTransit *KafkaClusterEncryptionInTransitDescription `locationName:"kafkaClusterEncryptionInTransit" type:"structure"`
// The version of Kafka Connect. It has to be compatible with both the Apache
// Kafka cluster's version and the plugins.
KafkaConnectVersion *string `locationName:"kafkaConnectVersion" type:"string"`
// The settings for delivering connector logs to Amazon CloudWatch Logs.
LogDelivery *LogDeliveryDescription `locationName:"logDelivery" type:"structure"`
// Specifies which plugins were used for this connector.
Plugins []*PluginDescription `locationName:"plugins" type:"list"`
// The Amazon Resource Name (ARN) of the IAM role used by the connector to access
// Amazon Web Services resources.
ServiceExecutionRoleArn *string `locationName:"serviceExecutionRoleArn" type:"string"`
// The worker configurations that are in use with the connector.
WorkerConfiguration *WorkerConfigurationDescription `locationName:"workerConfiguration" type:"structure"`
// contains filtered or unexported fields
}
Summary of a connector.
func (s ConnectorSummary) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ConnectorSummary) SetCapacity(v *CapacityDescription) *ConnectorSummary
SetCapacity sets the Capacity field's value.
func (s *ConnectorSummary) SetConnectorArn(v string) *ConnectorSummary
SetConnectorArn sets the ConnectorArn field's value.
func (s *ConnectorSummary) SetConnectorDescription(v string) *ConnectorSummary
SetConnectorDescription sets the ConnectorDescription field's value.
func (s *ConnectorSummary) SetConnectorName(v string) *ConnectorSummary
SetConnectorName sets the ConnectorName field's value.
func (s *ConnectorSummary) SetConnectorState(v string) *ConnectorSummary
SetConnectorState sets the ConnectorState field's value.
func (s *ConnectorSummary) SetCreationTime(v time.Time) *ConnectorSummary
SetCreationTime sets the CreationTime field's value.
func (s *ConnectorSummary) SetCurrentVersion(v string) *ConnectorSummary
SetCurrentVersion sets the CurrentVersion field's value.
func (s *ConnectorSummary) SetKafkaCluster(v *KafkaClusterDescription) *ConnectorSummary
SetKafkaCluster sets the KafkaCluster field's value.
func (s *ConnectorSummary) SetKafkaClusterClientAuthentication(v *KafkaClusterClientAuthenticationDescription) *ConnectorSummary
SetKafkaClusterClientAuthentication sets the KafkaClusterClientAuthentication field's value.
func (s *ConnectorSummary) SetKafkaClusterEncryptionInTransit(v *KafkaClusterEncryptionInTransitDescription) *ConnectorSummary
SetKafkaClusterEncryptionInTransit sets the KafkaClusterEncryptionInTransit field's value.
func (s *ConnectorSummary) SetKafkaConnectVersion(v string) *ConnectorSummary
SetKafkaConnectVersion sets the KafkaConnectVersion field's value.
func (s *ConnectorSummary) SetLogDelivery(v *LogDeliveryDescription) *ConnectorSummary
SetLogDelivery sets the LogDelivery field's value.
func (s *ConnectorSummary) SetPlugins(v []*PluginDescription) *ConnectorSummary
SetPlugins sets the Plugins field's value.
func (s *ConnectorSummary) SetServiceExecutionRoleArn(v string) *ConnectorSummary
SetServiceExecutionRoleArn sets the ServiceExecutionRoleArn field's value.
func (s *ConnectorSummary) SetWorkerConfiguration(v *WorkerConfigurationDescription) *ConnectorSummary
SetWorkerConfiguration sets the WorkerConfiguration field's value.
func (s ConnectorSummary) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CreateConnectorInput struct {
// Information about the capacity allocated to the connector. Exactly one of
// the two properties must be specified.
//
// Capacity is a required field
Capacity *Capacity `locationName:"capacity" type:"structure" required:"true"`
// A map of keys to values that represent the configuration for the connector.
//
// ConnectorConfiguration is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by CreateConnectorInput's
// String and GoString methods.
//
// ConnectorConfiguration is a required field
ConnectorConfiguration map[string]*string `locationName:"connectorConfiguration" type:"map" required:"true" sensitive:"true"`
// A summary description of the connector.
ConnectorDescription *string `locationName:"connectorDescription" type:"string"`
// The name of the connector.
//
// ConnectorName is a required field
ConnectorName *string `locationName:"connectorName" min:"1" type:"string" required:"true"`
// Specifies which Apache Kafka cluster to connect to.
//
// KafkaCluster is a required field
KafkaCluster *KafkaCluster `locationName:"kafkaCluster" type:"structure" required:"true"`
// Details of the client authentication used by the Apache Kafka cluster.
//
// KafkaClusterClientAuthentication is a required field
KafkaClusterClientAuthentication *KafkaClusterClientAuthentication `locationName:"kafkaClusterClientAuthentication" type:"structure" required:"true"`
// Details of encryption in transit to the Apache Kafka cluster.
//
// KafkaClusterEncryptionInTransit is a required field
KafkaClusterEncryptionInTransit *KafkaClusterEncryptionInTransit `locationName:"kafkaClusterEncryptionInTransit" type:"structure" required:"true"`
// The version of Kafka Connect. It has to be compatible with both the Apache
// Kafka cluster's version and the plugins.
//
// KafkaConnectVersion is a required field
KafkaConnectVersion *string `locationName:"kafkaConnectVersion" type:"string" required:"true"`
// Details about log delivery.
LogDelivery *LogDelivery `locationName:"logDelivery" type:"structure"`
//
// Amazon MSK Connect does not currently support specifying multiple plugins
// as a list. To use more than one plugin for your connector, you can create
// a single custom plugin using a ZIP file that bundles multiple plugins together.
//
// Specifies which plugin to use for the connector. You must specify a single-element
// list containing one customPlugin object.
//
// Plugins is a required field
Plugins []*Plugin `locationName:"plugins" type:"list" required:"true"`
// The Amazon Resource Name (ARN) of the IAM role used by the connector to access
// the Amazon Web Services resources that it needs. The types of resources depends
// on the logic of the connector. For example, a connector that has Amazon S3
// as a destination must have permissions that allow it to write to the S3 destination
// bucket.
//
// ServiceExecutionRoleArn is a required field
ServiceExecutionRoleArn *string `locationName:"serviceExecutionRoleArn" type:"string" required:"true"`
// The tags you want to attach to the connector.
Tags map[string]*string `locationName:"tags" type:"map"`
// Specifies which worker configuration to use with the connector.
WorkerConfiguration *WorkerConfiguration `locationName:"workerConfiguration" type:"structure"`
// contains filtered or unexported fields
}
func (s CreateConnectorInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateConnectorInput) SetCapacity(v *Capacity) *CreateConnectorInput
SetCapacity sets the Capacity field's value.
func (s *CreateConnectorInput) SetConnectorConfiguration(v map[string]*string) *CreateConnectorInput
SetConnectorConfiguration sets the ConnectorConfiguration field's value.
func (s *CreateConnectorInput) SetConnectorDescription(v string) *CreateConnectorInput
SetConnectorDescription sets the ConnectorDescription field's value.
func (s *CreateConnectorInput) SetConnectorName(v string) *CreateConnectorInput
SetConnectorName sets the ConnectorName field's value.
func (s *CreateConnectorInput) SetKafkaCluster(v *KafkaCluster) *CreateConnectorInput
SetKafkaCluster sets the KafkaCluster field's value.
func (s *CreateConnectorInput) SetKafkaClusterClientAuthentication(v *KafkaClusterClientAuthentication) *CreateConnectorInput
SetKafkaClusterClientAuthentication sets the KafkaClusterClientAuthentication field's value.
func (s *CreateConnectorInput) SetKafkaClusterEncryptionInTransit(v *KafkaClusterEncryptionInTransit) *CreateConnectorInput
SetKafkaClusterEncryptionInTransit sets the KafkaClusterEncryptionInTransit field's value.
func (s *CreateConnectorInput) SetKafkaConnectVersion(v string) *CreateConnectorInput
SetKafkaConnectVersion sets the KafkaConnectVersion field's value.
func (s *CreateConnectorInput) SetLogDelivery(v *LogDelivery) *CreateConnectorInput
SetLogDelivery sets the LogDelivery field's value.
func (s *CreateConnectorInput) SetPlugins(v []*Plugin) *CreateConnectorInput
SetPlugins sets the Plugins field's value.
func (s *CreateConnectorInput) SetServiceExecutionRoleArn(v string) *CreateConnectorInput
SetServiceExecutionRoleArn sets the ServiceExecutionRoleArn field's value.
func (s *CreateConnectorInput) SetTags(v map[string]*string) *CreateConnectorInput
SetTags sets the Tags field's value.
func (s *CreateConnectorInput) SetWorkerConfiguration(v *WorkerConfiguration) *CreateConnectorInput
SetWorkerConfiguration sets the WorkerConfiguration field's value.
func (s CreateConnectorInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateConnectorInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateConnectorOutput struct {
// The Amazon Resource Name (ARN) that Amazon assigned to the connector.
ConnectorArn *string `locationName:"connectorArn" type:"string"`
// The name of the connector.
ConnectorName *string `locationName:"connectorName" type:"string"`
// The state of the connector.
ConnectorState *string `locationName:"connectorState" type:"string" enum:"ConnectorState"`
// contains filtered or unexported fields
}
func (s CreateConnectorOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateConnectorOutput) SetConnectorArn(v string) *CreateConnectorOutput
SetConnectorArn sets the ConnectorArn field's value.
func (s *CreateConnectorOutput) SetConnectorName(v string) *CreateConnectorOutput
SetConnectorName sets the ConnectorName field's value.
func (s *CreateConnectorOutput) SetConnectorState(v string) *CreateConnectorOutput
SetConnectorState sets the ConnectorState field's value.
func (s CreateConnectorOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CreateCustomPluginInput struct {
// The type of the plugin file.
//
// ContentType is a required field
ContentType *string `locationName:"contentType" type:"string" required:"true" enum:"CustomPluginContentType"`
// A summary description of the custom plugin.
Description *string `locationName:"description" type:"string"`
// Information about the location of a custom plugin.
//
// Location is a required field
Location *CustomPluginLocation `locationName:"location" type:"structure" required:"true"`
// The name of the custom plugin.
//
// Name is a required field
Name *string `locationName:"name" min:"1" type:"string" required:"true"`
// The tags you want to attach to the custom plugin.
Tags map[string]*string `locationName:"tags" type:"map"`
// contains filtered or unexported fields
}
func (s CreateCustomPluginInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateCustomPluginInput) SetContentType(v string) *CreateCustomPluginInput
SetContentType sets the ContentType field's value.
func (s *CreateCustomPluginInput) SetDescription(v string) *CreateCustomPluginInput
SetDescription sets the Description field's value.
func (s *CreateCustomPluginInput) SetLocation(v *CustomPluginLocation) *CreateCustomPluginInput
SetLocation sets the Location field's value.
func (s *CreateCustomPluginInput) SetName(v string) *CreateCustomPluginInput
SetName sets the Name field's value.
func (s *CreateCustomPluginInput) SetTags(v map[string]*string) *CreateCustomPluginInput
SetTags sets the Tags field's value.
func (s CreateCustomPluginInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateCustomPluginInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateCustomPluginOutput struct {
// The Amazon Resource Name (ARN) that Amazon assigned to the custom plugin.
CustomPluginArn *string `locationName:"customPluginArn" type:"string"`
// The state of the custom plugin.
CustomPluginState *string `locationName:"customPluginState" type:"string" enum:"CustomPluginState"`
// The name of the custom plugin.
Name *string `locationName:"name" type:"string"`
// The revision of the custom plugin.
Revision *int64 `locationName:"revision" type:"long"`
// contains filtered or unexported fields
}
func (s CreateCustomPluginOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateCustomPluginOutput) SetCustomPluginArn(v string) *CreateCustomPluginOutput
SetCustomPluginArn sets the CustomPluginArn field's value.
func (s *CreateCustomPluginOutput) SetCustomPluginState(v string) *CreateCustomPluginOutput
SetCustomPluginState sets the CustomPluginState field's value.
func (s *CreateCustomPluginOutput) SetName(v string) *CreateCustomPluginOutput
SetName sets the Name field's value.
func (s *CreateCustomPluginOutput) SetRevision(v int64) *CreateCustomPluginOutput
SetRevision sets the Revision field's value.
func (s CreateCustomPluginOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CreateWorkerConfigurationInput struct {
// A summary description of the worker configuration.
Description *string `locationName:"description" type:"string"`
// The name of the worker configuration.
//
// Name is a required field
Name *string `locationName:"name" min:"1" type:"string" required:"true"`
// Base64 encoded contents of connect-distributed.properties file.
//
// PropertiesFileContent is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by CreateWorkerConfigurationInput's
// String and GoString methods.
//
// PropertiesFileContent is a required field
PropertiesFileContent *string `locationName:"propertiesFileContent" type:"string" required:"true" sensitive:"true"`
// The tags you want to attach to the worker configuration.
Tags map[string]*string `locationName:"tags" type:"map"`
// contains filtered or unexported fields
}
func (s CreateWorkerConfigurationInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateWorkerConfigurationInput) SetDescription(v string) *CreateWorkerConfigurationInput
SetDescription sets the Description field's value.
func (s *CreateWorkerConfigurationInput) SetName(v string) *CreateWorkerConfigurationInput
SetName sets the Name field's value.
func (s *CreateWorkerConfigurationInput) SetPropertiesFileContent(v string) *CreateWorkerConfigurationInput
SetPropertiesFileContent sets the PropertiesFileContent field's value.
func (s *CreateWorkerConfigurationInput) SetTags(v map[string]*string) *CreateWorkerConfigurationInput
SetTags sets the Tags field's value.
func (s CreateWorkerConfigurationInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateWorkerConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateWorkerConfigurationOutput struct {
// The time that the worker configuration was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The latest revision of the worker configuration.
LatestRevision *WorkerConfigurationRevisionSummary `locationName:"latestRevision" type:"structure"`
// The name of the worker configuration.
Name *string `locationName:"name" type:"string"`
// The Amazon Resource Name (ARN) that Amazon assigned to the worker configuration.
WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
// The state of the worker configuration.
WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"`
// contains filtered or unexported fields
}
func (s CreateWorkerConfigurationOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateWorkerConfigurationOutput) SetCreationTime(v time.Time) *CreateWorkerConfigurationOutput
SetCreationTime sets the CreationTime field's value.
func (s *CreateWorkerConfigurationOutput) SetLatestRevision(v *WorkerConfigurationRevisionSummary) *CreateWorkerConfigurationOutput
SetLatestRevision sets the LatestRevision field's value.
func (s *CreateWorkerConfigurationOutput) SetName(v string) *CreateWorkerConfigurationOutput
SetName sets the Name field's value.
func (s *CreateWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *CreateWorkerConfigurationOutput
SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
func (s *CreateWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *CreateWorkerConfigurationOutput
SetWorkerConfigurationState sets the WorkerConfigurationState field's value.
func (s CreateWorkerConfigurationOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CustomPlugin struct {
// The Amazon Resource Name (ARN) of the custom plugin.
//
// CustomPluginArn is a required field
CustomPluginArn *string `locationName:"customPluginArn" type:"string" required:"true"`
// The revision of the custom plugin.
//
// Revision is a required field
Revision *int64 `locationName:"revision" min:"1" type:"long" required:"true"`
// contains filtered or unexported fields
}
A plugin is an Amazon Web Services resource that contains the code that defines a connector's logic.
func (s CustomPlugin) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPlugin) SetCustomPluginArn(v string) *CustomPlugin
SetCustomPluginArn sets the CustomPluginArn field's value.
func (s *CustomPlugin) SetRevision(v int64) *CustomPlugin
SetRevision sets the Revision field's value.
func (s CustomPlugin) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPlugin) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CustomPluginDescription struct {
// The Amazon Resource Name (ARN) of the custom plugin.
CustomPluginArn *string `locationName:"customPluginArn" type:"string"`
// The revision of the custom plugin.
Revision *int64 `locationName:"revision" type:"long"`
// contains filtered or unexported fields
}
Details about a custom plugin.
func (s CustomPluginDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPluginDescription) SetCustomPluginArn(v string) *CustomPluginDescription
SetCustomPluginArn sets the CustomPluginArn field's value.
func (s *CustomPluginDescription) SetRevision(v int64) *CustomPluginDescription
SetRevision sets the Revision field's value.
func (s CustomPluginDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CustomPluginFileDescription struct {
// The hex-encoded MD5 checksum of the custom plugin file. You can use it to
// validate the file.
FileMd5 *string `locationName:"fileMd5" type:"string"`
// The size in bytes of the custom plugin file. You can use it to validate the
// file.
FileSize *int64 `locationName:"fileSize" type:"long"`
// contains filtered or unexported fields
}
Details about a custom plugin file.
func (s CustomPluginFileDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPluginFileDescription) SetFileMd5(v string) *CustomPluginFileDescription
SetFileMd5 sets the FileMd5 field's value.
func (s *CustomPluginFileDescription) SetFileSize(v int64) *CustomPluginFileDescription
SetFileSize sets the FileSize field's value.
func (s CustomPluginFileDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CustomPluginLocation struct {
// The S3 bucket Amazon Resource Name (ARN), file key, and object version of
// the plugin file stored in Amazon S3.
//
// S3Location is a required field
S3Location *S3Location `locationName:"s3Location" type:"structure" required:"true"`
// contains filtered or unexported fields
}
Information about the location of a custom plugin.
func (s CustomPluginLocation) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPluginLocation) SetS3Location(v *S3Location) *CustomPluginLocation
SetS3Location sets the S3Location field's value.
func (s CustomPluginLocation) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPluginLocation) Validate() error
Validate inspects the fields of the type to determine if they are valid.
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 `locationName:"s3Location" type:"structure"`
// contains filtered or unexported fields
}
Information about the location of a custom plugin.
func (s CustomPluginLocationDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPluginLocationDescription) SetS3Location(v *S3LocationDescription) *CustomPluginLocationDescription
SetS3Location sets the S3Location field's value.
func (s CustomPluginLocationDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CustomPluginRevisionSummary struct {
// The format of the plugin file.
ContentType *string `locationName:"contentType" type:"string" enum:"CustomPluginContentType"`
// The time that the custom plugin was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The description of the custom plugin.
Description *string `locationName:"description" type:"string"`
// Details about the custom plugin file.
FileDescription *CustomPluginFileDescription `locationName:"fileDescription" type:"structure"`
// Information about the location of the custom plugin.
Location *CustomPluginLocationDescription `locationName:"location" type:"structure"`
// The revision of the custom plugin.
Revision *int64 `locationName:"revision" type:"long"`
// contains filtered or unexported fields
}
Details about the revision of a custom plugin.
func (s CustomPluginRevisionSummary) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPluginRevisionSummary) SetContentType(v string) *CustomPluginRevisionSummary
SetContentType sets the ContentType field's value.
func (s *CustomPluginRevisionSummary) SetCreationTime(v time.Time) *CustomPluginRevisionSummary
SetCreationTime sets the CreationTime field's value.
func (s *CustomPluginRevisionSummary) SetDescription(v string) *CustomPluginRevisionSummary
SetDescription sets the Description field's value.
func (s *CustomPluginRevisionSummary) SetFileDescription(v *CustomPluginFileDescription) *CustomPluginRevisionSummary
SetFileDescription sets the FileDescription field's value.
func (s *CustomPluginRevisionSummary) SetLocation(v *CustomPluginLocationDescription) *CustomPluginRevisionSummary
SetLocation sets the Location field's value.
func (s *CustomPluginRevisionSummary) SetRevision(v int64) *CustomPluginRevisionSummary
SetRevision sets the Revision field's value.
func (s CustomPluginRevisionSummary) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CustomPluginSummary struct {
// The time that the custom plugin was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The Amazon Resource Name (ARN) of the custom plugin.
CustomPluginArn *string `locationName:"customPluginArn" type:"string"`
// The state of the custom plugin.
CustomPluginState *string `locationName:"customPluginState" type:"string" enum:"CustomPluginState"`
// A description of the custom plugin.
Description *string `locationName:"description" type:"string"`
// The latest revision of the custom plugin.
LatestRevision *CustomPluginRevisionSummary `locationName:"latestRevision" type:"structure"`
// The name of the custom plugin.
Name *string `locationName:"name" type:"string"`
// contains filtered or unexported fields
}
A summary of the custom plugin.
func (s CustomPluginSummary) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CustomPluginSummary) SetCreationTime(v time.Time) *CustomPluginSummary
SetCreationTime sets the CreationTime field's value.
func (s *CustomPluginSummary) SetCustomPluginArn(v string) *CustomPluginSummary
SetCustomPluginArn sets the CustomPluginArn field's value.
func (s *CustomPluginSummary) SetCustomPluginState(v string) *CustomPluginSummary
SetCustomPluginState sets the CustomPluginState field's value.
func (s *CustomPluginSummary) SetDescription(v string) *CustomPluginSummary
SetDescription sets the Description field's value.
func (s *CustomPluginSummary) SetLatestRevision(v *CustomPluginRevisionSummary) *CustomPluginSummary
SetLatestRevision sets the LatestRevision field's value.
func (s *CustomPluginSummary) SetName(v string) *CustomPluginSummary
SetName sets the Name field's value.
func (s CustomPluginSummary) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DeleteConnectorInput struct {
// The Amazon Resource Name (ARN) of the connector that you want to delete.
//
// ConnectorArn is a required field
ConnectorArn *string `location:"uri" locationName:"connectorArn" type:"string" required:"true"`
// The current version of the connector that you want to delete.
CurrentVersion *string `location:"querystring" locationName:"currentVersion" type:"string"`
// contains filtered or unexported fields
}
func (s DeleteConnectorInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteConnectorInput) SetConnectorArn(v string) *DeleteConnectorInput
SetConnectorArn sets the ConnectorArn field's value.
func (s *DeleteConnectorInput) SetCurrentVersion(v string) *DeleteConnectorInput
SetCurrentVersion sets the CurrentVersion field's value.
func (s DeleteConnectorInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteConnectorInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteConnectorOutput struct {
// The Amazon Resource Name (ARN) of the connector that you requested to delete.
ConnectorArn *string `locationName:"connectorArn" type:"string"`
// The state of the connector that you requested to delete.
ConnectorState *string `locationName:"connectorState" type:"string" enum:"ConnectorState"`
// contains filtered or unexported fields
}
func (s DeleteConnectorOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteConnectorOutput) SetConnectorArn(v string) *DeleteConnectorOutput
SetConnectorArn sets the ConnectorArn field's value.
func (s *DeleteConnectorOutput) SetConnectorState(v string) *DeleteConnectorOutput
SetConnectorState sets the ConnectorState field's value.
func (s DeleteConnectorOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DeleteCustomPluginInput struct {
// The Amazon Resource Name (ARN) of the custom plugin that you want to delete.
//
// CustomPluginArn is a required field
CustomPluginArn *string `location:"uri" locationName:"customPluginArn" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s DeleteCustomPluginInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteCustomPluginInput) SetCustomPluginArn(v string) *DeleteCustomPluginInput
SetCustomPluginArn sets the CustomPluginArn field's value.
func (s DeleteCustomPluginInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteCustomPluginInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteCustomPluginOutput struct {
// The Amazon Resource Name (ARN) of the custom plugin that you requested to
// delete.
CustomPluginArn *string `locationName:"customPluginArn" type:"string"`
// The state of the custom plugin.
CustomPluginState *string `locationName:"customPluginState" type:"string" enum:"CustomPluginState"`
// contains filtered or unexported fields
}
func (s DeleteCustomPluginOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteCustomPluginOutput) SetCustomPluginArn(v string) *DeleteCustomPluginOutput
SetCustomPluginArn sets the CustomPluginArn field's value.
func (s *DeleteCustomPluginOutput) SetCustomPluginState(v string) *DeleteCustomPluginOutput
SetCustomPluginState sets the CustomPluginState field's value.
func (s DeleteCustomPluginOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DeleteWorkerConfigurationInput struct {
// The Amazon Resource Name (ARN) of the worker configuration that you want
// to delete.
//
// WorkerConfigurationArn is a required field
WorkerConfigurationArn *string `location:"uri" locationName:"workerConfigurationArn" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s DeleteWorkerConfigurationInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteWorkerConfigurationInput) SetWorkerConfigurationArn(v string) *DeleteWorkerConfigurationInput
SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
func (s DeleteWorkerConfigurationInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteWorkerConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteWorkerConfigurationOutput struct {
// The Amazon Resource Name (ARN) of the worker configuration that you requested
// to delete.
WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
// The state of the worker configuration.
WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"`
// contains filtered or unexported fields
}
func (s DeleteWorkerConfigurationOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *DeleteWorkerConfigurationOutput
SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
func (s *DeleteWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *DeleteWorkerConfigurationOutput
SetWorkerConfigurationState sets the WorkerConfigurationState field's value.
func (s DeleteWorkerConfigurationOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DescribeConnectorInput struct {
// The Amazon Resource Name (ARN) of the connector that you want to describe.
//
// ConnectorArn is a required field
ConnectorArn *string `location:"uri" locationName:"connectorArn" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s DescribeConnectorInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeConnectorInput) SetConnectorArn(v string) *DescribeConnectorInput
SetConnectorArn sets the ConnectorArn field's value.
func (s DescribeConnectorInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeConnectorInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeConnectorOutput struct {
// Information about the capacity of the connector, whether it is auto scaled
// or provisioned.
Capacity *CapacityDescription `locationName:"capacity" type:"structure"`
// The Amazon Resource Name (ARN) of the connector.
ConnectorArn *string `locationName:"connectorArn" type:"string"`
// A map of keys to values that represent the configuration for the connector.
//
// ConnectorConfiguration is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by DescribeConnectorOutput's
// String and GoString methods.
ConnectorConfiguration map[string]*string `locationName:"connectorConfiguration" type:"map" sensitive:"true"`
// A summary description of the connector.
ConnectorDescription *string `locationName:"connectorDescription" type:"string"`
// The name of the connector.
ConnectorName *string `locationName:"connectorName" type:"string"`
// The state of the connector.
ConnectorState *string `locationName:"connectorState" type:"string" enum:"ConnectorState"`
// The time the connector was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The current version of the connector.
CurrentVersion *string `locationName:"currentVersion" type:"string"`
// The Apache Kafka cluster that the connector is connected to.
KafkaCluster *KafkaClusterDescription `locationName:"kafkaCluster" type:"structure"`
// 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 `locationName:"kafkaClusterClientAuthentication" type:"structure"`
// Details of encryption in transit to the Apache Kafka cluster.
KafkaClusterEncryptionInTransit *KafkaClusterEncryptionInTransitDescription `locationName:"kafkaClusterEncryptionInTransit" type:"structure"`
// The version of Kafka Connect. It has to be compatible with both the Apache
// Kafka cluster's version and the plugins.
KafkaConnectVersion *string `locationName:"kafkaConnectVersion" type:"string"`
// Details about delivering logs to Amazon CloudWatch Logs.
LogDelivery *LogDeliveryDescription `locationName:"logDelivery" type:"structure"`
// Specifies which plugins were used for this connector.
Plugins []*PluginDescription `locationName:"plugins" type:"list"`
// The Amazon Resource Name (ARN) of the IAM role used by the connector to access
// Amazon Web Services resources.
ServiceExecutionRoleArn *string `locationName:"serviceExecutionRoleArn" type:"string"`
// Details about the state of a connector.
StateDescription *StateDescription `locationName:"stateDescription" type:"structure"`
// Specifies which worker configuration was used for the connector.
WorkerConfiguration *WorkerConfigurationDescription `locationName:"workerConfiguration" type:"structure"`
// contains filtered or unexported fields
}
func (s DescribeConnectorOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeConnectorOutput) SetCapacity(v *CapacityDescription) *DescribeConnectorOutput
SetCapacity sets the Capacity field's value.
func (s *DescribeConnectorOutput) SetConnectorArn(v string) *DescribeConnectorOutput
SetConnectorArn sets the ConnectorArn field's value.
func (s *DescribeConnectorOutput) SetConnectorConfiguration(v map[string]*string) *DescribeConnectorOutput
SetConnectorConfiguration sets the ConnectorConfiguration field's value.
func (s *DescribeConnectorOutput) SetConnectorDescription(v string) *DescribeConnectorOutput
SetConnectorDescription sets the ConnectorDescription field's value.
func (s *DescribeConnectorOutput) SetConnectorName(v string) *DescribeConnectorOutput
SetConnectorName sets the ConnectorName field's value.
func (s *DescribeConnectorOutput) SetConnectorState(v string) *DescribeConnectorOutput
SetConnectorState sets the ConnectorState field's value.
func (s *DescribeConnectorOutput) SetCreationTime(v time.Time) *DescribeConnectorOutput
SetCreationTime sets the CreationTime field's value.
func (s *DescribeConnectorOutput) SetCurrentVersion(v string) *DescribeConnectorOutput
SetCurrentVersion sets the CurrentVersion field's value.
func (s *DescribeConnectorOutput) SetKafkaCluster(v *KafkaClusterDescription) *DescribeConnectorOutput
SetKafkaCluster sets the KafkaCluster field's value.
func (s *DescribeConnectorOutput) SetKafkaClusterClientAuthentication(v *KafkaClusterClientAuthenticationDescription) *DescribeConnectorOutput
SetKafkaClusterClientAuthentication sets the KafkaClusterClientAuthentication field's value.
func (s *DescribeConnectorOutput) SetKafkaClusterEncryptionInTransit(v *KafkaClusterEncryptionInTransitDescription) *DescribeConnectorOutput
SetKafkaClusterEncryptionInTransit sets the KafkaClusterEncryptionInTransit field's value.
func (s *DescribeConnectorOutput) SetKafkaConnectVersion(v string) *DescribeConnectorOutput
SetKafkaConnectVersion sets the KafkaConnectVersion field's value.
func (s *DescribeConnectorOutput) SetLogDelivery(v *LogDeliveryDescription) *DescribeConnectorOutput
SetLogDelivery sets the LogDelivery field's value.
func (s *DescribeConnectorOutput) SetPlugins(v []*PluginDescription) *DescribeConnectorOutput
SetPlugins sets the Plugins field's value.
func (s *DescribeConnectorOutput) SetServiceExecutionRoleArn(v string) *DescribeConnectorOutput
SetServiceExecutionRoleArn sets the ServiceExecutionRoleArn field's value.
func (s *DescribeConnectorOutput) SetStateDescription(v *StateDescription) *DescribeConnectorOutput
SetStateDescription sets the StateDescription field's value.
func (s *DescribeConnectorOutput) SetWorkerConfiguration(v *WorkerConfigurationDescription) *DescribeConnectorOutput
SetWorkerConfiguration sets the WorkerConfiguration field's value.
func (s DescribeConnectorOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DescribeCustomPluginInput struct {
// Returns information about a custom plugin.
//
// CustomPluginArn is a required field
CustomPluginArn *string `location:"uri" locationName:"customPluginArn" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s DescribeCustomPluginInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeCustomPluginInput) SetCustomPluginArn(v string) *DescribeCustomPluginInput
SetCustomPluginArn sets the CustomPluginArn field's value.
func (s DescribeCustomPluginInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeCustomPluginInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeCustomPluginOutput struct {
// The time that the custom plugin was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The Amazon Resource Name (ARN) of the custom plugin.
CustomPluginArn *string `locationName:"customPluginArn" type:"string"`
// The state of the custom plugin.
CustomPluginState *string `locationName:"customPluginState" type:"string" enum:"CustomPluginState"`
// The description of the custom plugin.
Description *string `locationName:"description" type:"string"`
// The latest successfully created revision of the custom plugin. If there are
// no successfully created revisions, this field will be absent.
LatestRevision *CustomPluginRevisionSummary `locationName:"latestRevision" type:"structure"`
// The name of the custom plugin.
Name *string `locationName:"name" type:"string"`
// Details about the state of a custom plugin.
StateDescription *StateDescription `locationName:"stateDescription" type:"structure"`
// contains filtered or unexported fields
}
func (s DescribeCustomPluginOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeCustomPluginOutput) SetCreationTime(v time.Time) *DescribeCustomPluginOutput
SetCreationTime sets the CreationTime field's value.
func (s *DescribeCustomPluginOutput) SetCustomPluginArn(v string) *DescribeCustomPluginOutput
SetCustomPluginArn sets the CustomPluginArn field's value.
func (s *DescribeCustomPluginOutput) SetCustomPluginState(v string) *DescribeCustomPluginOutput
SetCustomPluginState sets the CustomPluginState field's value.
func (s *DescribeCustomPluginOutput) SetDescription(v string) *DescribeCustomPluginOutput
SetDescription sets the Description field's value.
func (s *DescribeCustomPluginOutput) SetLatestRevision(v *CustomPluginRevisionSummary) *DescribeCustomPluginOutput
SetLatestRevision sets the LatestRevision field's value.
func (s *DescribeCustomPluginOutput) SetName(v string) *DescribeCustomPluginOutput
SetName sets the Name field's value.
func (s *DescribeCustomPluginOutput) SetStateDescription(v *StateDescription) *DescribeCustomPluginOutput
SetStateDescription sets the StateDescription field's value.
func (s DescribeCustomPluginOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DescribeWorkerConfigurationInput struct {
// The Amazon Resource Name (ARN) of the worker configuration that you want
// to get information about.
//
// WorkerConfigurationArn is a required field
WorkerConfigurationArn *string `location:"uri" locationName:"workerConfigurationArn" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s DescribeWorkerConfigurationInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeWorkerConfigurationInput) SetWorkerConfigurationArn(v string) *DescribeWorkerConfigurationInput
SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
func (s DescribeWorkerConfigurationInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeWorkerConfigurationInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeWorkerConfigurationOutput struct {
// The time that the worker configuration was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The description of the worker configuration.
Description *string `locationName:"description" type:"string"`
// The latest revision of the custom configuration.
LatestRevision *WorkerConfigurationRevisionDescription `locationName:"latestRevision" type:"structure"`
// The name of the worker configuration.
Name *string `locationName:"name" type:"string"`
// The Amazon Resource Name (ARN) of the custom configuration.
WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
// The state of the worker configuration.
WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"`
// contains filtered or unexported fields
}
func (s DescribeWorkerConfigurationOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeWorkerConfigurationOutput) SetCreationTime(v time.Time) *DescribeWorkerConfigurationOutput
SetCreationTime sets the CreationTime field's value.
func (s *DescribeWorkerConfigurationOutput) SetDescription(v string) *DescribeWorkerConfigurationOutput
SetDescription sets the Description field's value.
func (s *DescribeWorkerConfigurationOutput) SetLatestRevision(v *WorkerConfigurationRevisionDescription) *DescribeWorkerConfigurationOutput
SetLatestRevision sets the LatestRevision field's value.
func (s *DescribeWorkerConfigurationOutput) SetName(v string) *DescribeWorkerConfigurationOutput
SetName sets the Name field's value.
func (s *DescribeWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *DescribeWorkerConfigurationOutput
SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
func (s *DescribeWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *DescribeWorkerConfigurationOutput
SetWorkerConfigurationState sets the WorkerConfigurationState field's value.
func (s DescribeWorkerConfigurationOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type FirehoseLogDelivery struct {
// The name of the Kinesis Data Firehose delivery stream that is the destination
// for log delivery.
DeliveryStream *string `locationName:"deliveryStream" type:"string"`
// Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
//
// Enabled is a required field
Enabled *bool `locationName:"enabled" type:"boolean" required:"true"`
// contains filtered or unexported fields
}
The settings for delivering logs to Amazon Kinesis Data Firehose.
func (s FirehoseLogDelivery) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *FirehoseLogDelivery) SetDeliveryStream(v string) *FirehoseLogDelivery
SetDeliveryStream sets the DeliveryStream field's value.
func (s *FirehoseLogDelivery) SetEnabled(v bool) *FirehoseLogDelivery
SetEnabled sets the Enabled field's value.
func (s FirehoseLogDelivery) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *FirehoseLogDelivery) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type FirehoseLogDeliveryDescription struct {
// The name of the Kinesis Data Firehose delivery stream that is the destination
// for log delivery.
DeliveryStream *string `locationName:"deliveryStream" type:"string"`
// Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
Enabled *bool `locationName:"enabled" type:"boolean"`
// contains filtered or unexported fields
}
A description of the settings for delivering logs to Amazon Kinesis Data Firehose.
func (s FirehoseLogDeliveryDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *FirehoseLogDeliveryDescription) SetDeliveryStream(v string) *FirehoseLogDeliveryDescription
SetDeliveryStream sets the DeliveryStream field's value.
func (s *FirehoseLogDeliveryDescription) SetEnabled(v bool) *FirehoseLogDeliveryDescription
SetEnabled sets the Enabled field's value.
func (s FirehoseLogDeliveryDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ForbiddenException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
func (s *ForbiddenException) Code() string
Code returns the exception type name.
func (s *ForbiddenException) Error() string
func (s ForbiddenException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ForbiddenException) Message() string
Message returns the exception's message.
func (s *ForbiddenException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ForbiddenException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ForbiddenException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ForbiddenException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type InternalServerErrorException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
func (s *InternalServerErrorException) Code() string
Code returns the exception type name.
func (s *InternalServerErrorException) Error() string
func (s InternalServerErrorException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *InternalServerErrorException) Message() string
Message returns the exception's message.
func (s *InternalServerErrorException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *InternalServerErrorException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *InternalServerErrorException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s InternalServerErrorException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type KafkaCluster struct {
// The Apache Kafka cluster to which the connector is connected.
//
// ApacheKafkaCluster is a required field
ApacheKafkaCluster *ApacheKafkaCluster `locationName:"apacheKafkaCluster" type:"structure" required:"true"`
// contains filtered or unexported fields
}
The details of the Apache Kafka cluster to which the connector is connected.
func (s KafkaCluster) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaCluster) SetApacheKafkaCluster(v *ApacheKafkaCluster) *KafkaCluster
SetApacheKafkaCluster sets the ApacheKafkaCluster field's value.
func (s KafkaCluster) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaCluster) Validate() error
Validate inspects the fields of the type to determine if they are valid.
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.
//
// AuthenticationType is a required field
AuthenticationType *string `locationName:"authenticationType" type:"string" required:"true" enum:"KafkaClusterClientAuthenticationType"`
// contains filtered or unexported fields
}
The client authentication information used in order to authenticate with the Apache Kafka cluster.
func (s KafkaClusterClientAuthentication) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaClusterClientAuthentication) SetAuthenticationType(v string) *KafkaClusterClientAuthentication
SetAuthenticationType sets the AuthenticationType field's value.
func (s KafkaClusterClientAuthentication) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaClusterClientAuthentication) Validate() error
Validate inspects the fields of the type to determine if they are valid.
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 *string `locationName:"authenticationType" type:"string" enum:"KafkaClusterClientAuthenticationType"`
// contains filtered or unexported fields
}
The client authentication information used in order to authenticate with the Apache Kafka cluster.
func (s KafkaClusterClientAuthenticationDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaClusterClientAuthenticationDescription) SetAuthenticationType(v string) *KafkaClusterClientAuthenticationDescription
SetAuthenticationType sets the AuthenticationType field's value.
func (s KafkaClusterClientAuthenticationDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type KafkaClusterDescription struct {
// The Apache Kafka cluster to which the connector is connected.
ApacheKafkaCluster *ApacheKafkaClusterDescription `locationName:"apacheKafkaCluster" type:"structure"`
// contains filtered or unexported fields
}
Details of how to connect to the Apache Kafka cluster.
func (s KafkaClusterDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaClusterDescription) SetApacheKafkaCluster(v *ApacheKafkaClusterDescription) *KafkaClusterDescription
SetApacheKafkaCluster sets the ApacheKafkaCluster field's value.
func (s KafkaClusterDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type KafkaClusterEncryptionInTransit struct {
// The type of encryption in transit to the Apache Kafka cluster.
//
// EncryptionType is a required field
EncryptionType *string `locationName:"encryptionType" type:"string" required:"true" enum:"KafkaClusterEncryptionInTransitType"`
// contains filtered or unexported fields
}
Details of encryption in transit to the Apache Kafka cluster.
func (s KafkaClusterEncryptionInTransit) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaClusterEncryptionInTransit) SetEncryptionType(v string) *KafkaClusterEncryptionInTransit
SetEncryptionType sets the EncryptionType field's value.
func (s KafkaClusterEncryptionInTransit) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaClusterEncryptionInTransit) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type KafkaClusterEncryptionInTransitDescription struct {
// The type of encryption in transit to the Apache Kafka cluster.
EncryptionType *string `locationName:"encryptionType" type:"string" enum:"KafkaClusterEncryptionInTransitType"`
// contains filtered or unexported fields
}
The description of the encryption in transit to the Apache Kafka cluster.
func (s KafkaClusterEncryptionInTransitDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *KafkaClusterEncryptionInTransitDescription) SetEncryptionType(v string) *KafkaClusterEncryptionInTransitDescription
SetEncryptionType sets the EncryptionType field's value.
func (s KafkaClusterEncryptionInTransitDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type KafkaConnect struct {
*client.Client
}
KafkaConnect provides the API operation methods for making requests to Managed Streaming for Kafka Connect. See this package's package overview docs for details on the service.
KafkaConnect methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.
func New(p client.ConfigProvider, cfgs ...*aws.Config) *KafkaConnect
New creates a new instance of the KafkaConnect client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.
Example:
mySession := session.Must(session.NewSession())
// Create a KafkaConnect client from just a session.
svc := kafkaconnect.New(mySession)
// Create a KafkaConnect client with additional configuration
svc := kafkaconnect.New(mySession, aws.NewConfig().WithRegion("us-west-2"))
func (c *KafkaConnect) CreateConnector(input *CreateConnectorInput) (*CreateConnectorOutput, error)
CreateConnector API operation for Managed Streaming for Kafka Connect.
Creates a connector using the specified properties.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation CreateConnector for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
ConflictException HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateConnector
func (c *KafkaConnect) CreateConnectorRequest(input *CreateConnectorInput) (req *request.Request, output *CreateConnectorOutput)
CreateConnectorRequest generates a "aws/request.Request" representing the client's request for the CreateConnector operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateConnector for more information on using the CreateConnector API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateConnectorRequest method.
req, resp := client.CreateConnectorRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateConnector
func (c *KafkaConnect) CreateConnectorWithContext(ctx aws.Context, input *CreateConnectorInput, opts ...request.Option) (*CreateConnectorOutput, error)
CreateConnectorWithContext is the same as CreateConnector with the addition of the ability to pass a context and additional request options.
See CreateConnector for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) CreateCustomPlugin(input *CreateCustomPluginInput) (*CreateCustomPluginOutput, error)
CreateCustomPlugin API operation for Managed Streaming for Kafka Connect.
Creates a custom plugin using the specified properties.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation CreateCustomPlugin for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
ConflictException HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateCustomPlugin
func (c *KafkaConnect) CreateCustomPluginRequest(input *CreateCustomPluginInput) (req *request.Request, output *CreateCustomPluginOutput)
CreateCustomPluginRequest generates a "aws/request.Request" representing the client's request for the CreateCustomPlugin operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateCustomPlugin for more information on using the CreateCustomPlugin API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateCustomPluginRequest method.
req, resp := client.CreateCustomPluginRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateCustomPlugin
func (c *KafkaConnect) CreateCustomPluginWithContext(ctx aws.Context, input *CreateCustomPluginInput, opts ...request.Option) (*CreateCustomPluginOutput, error)
CreateCustomPluginWithContext is the same as CreateCustomPlugin with the addition of the ability to pass a context and additional request options.
See CreateCustomPlugin for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) CreateWorkerConfiguration(input *CreateWorkerConfigurationInput) (*CreateWorkerConfigurationOutput, error)
CreateWorkerConfiguration API operation for Managed Streaming for Kafka Connect.
Creates a worker configuration using the specified properties.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation CreateWorkerConfiguration for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
ConflictException HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateWorkerConfiguration
func (c *KafkaConnect) CreateWorkerConfigurationRequest(input *CreateWorkerConfigurationInput) (req *request.Request, output *CreateWorkerConfigurationOutput)
CreateWorkerConfigurationRequest generates a "aws/request.Request" representing the client's request for the CreateWorkerConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateWorkerConfiguration for more information on using the CreateWorkerConfiguration API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateWorkerConfigurationRequest method.
req, resp := client.CreateWorkerConfigurationRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/CreateWorkerConfiguration
func (c *KafkaConnect) CreateWorkerConfigurationWithContext(ctx aws.Context, input *CreateWorkerConfigurationInput, opts ...request.Option) (*CreateWorkerConfigurationOutput, error)
CreateWorkerConfigurationWithContext is the same as CreateWorkerConfiguration with the addition of the ability to pass a context and additional request options.
See CreateWorkerConfiguration for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) DeleteConnector(input *DeleteConnectorInput) (*DeleteConnectorOutput, error)
DeleteConnector API operation for Managed Streaming for Kafka Connect.
Deletes the specified connector.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation DeleteConnector for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteConnector
func (c *KafkaConnect) DeleteConnectorRequest(input *DeleteConnectorInput) (req *request.Request, output *DeleteConnectorOutput)
DeleteConnectorRequest generates a "aws/request.Request" representing the client's request for the DeleteConnector operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DeleteConnector for more information on using the DeleteConnector API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DeleteConnectorRequest method.
req, resp := client.DeleteConnectorRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteConnector
func (c *KafkaConnect) DeleteConnectorWithContext(ctx aws.Context, input *DeleteConnectorInput, opts ...request.Option) (*DeleteConnectorOutput, error)
DeleteConnectorWithContext is the same as DeleteConnector with the addition of the ability to pass a context and additional request options.
See DeleteConnector for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) DeleteCustomPlugin(input *DeleteCustomPluginInput) (*DeleteCustomPluginOutput, error)
DeleteCustomPlugin API operation for Managed Streaming for Kafka Connect.
Deletes a custom plugin.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation DeleteCustomPlugin for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteCustomPlugin
func (c *KafkaConnect) DeleteCustomPluginRequest(input *DeleteCustomPluginInput) (req *request.Request, output *DeleteCustomPluginOutput)
DeleteCustomPluginRequest generates a "aws/request.Request" representing the client's request for the DeleteCustomPlugin operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DeleteCustomPlugin for more information on using the DeleteCustomPlugin API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DeleteCustomPluginRequest method.
req, resp := client.DeleteCustomPluginRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteCustomPlugin
func (c *KafkaConnect) DeleteCustomPluginWithContext(ctx aws.Context, input *DeleteCustomPluginInput, opts ...request.Option) (*DeleteCustomPluginOutput, error)
DeleteCustomPluginWithContext is the same as DeleteCustomPlugin with the addition of the ability to pass a context and additional request options.
See DeleteCustomPlugin for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) DeleteWorkerConfiguration(input *DeleteWorkerConfigurationInput) (*DeleteWorkerConfigurationOutput, error)
DeleteWorkerConfiguration API operation for Managed Streaming for Kafka Connect.
Deletes the specified worker configuration.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation DeleteWorkerConfiguration for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfiguration
func (c *KafkaConnect) DeleteWorkerConfigurationRequest(input *DeleteWorkerConfigurationInput) (req *request.Request, output *DeleteWorkerConfigurationOutput)
DeleteWorkerConfigurationRequest generates a "aws/request.Request" representing the client's request for the DeleteWorkerConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DeleteWorkerConfiguration for more information on using the DeleteWorkerConfiguration API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DeleteWorkerConfigurationRequest method.
req, resp := client.DeleteWorkerConfigurationRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfiguration
func (c *KafkaConnect) DeleteWorkerConfigurationWithContext(ctx aws.Context, input *DeleteWorkerConfigurationInput, opts ...request.Option) (*DeleteWorkerConfigurationOutput, error)
DeleteWorkerConfigurationWithContext is the same as DeleteWorkerConfiguration with the addition of the ability to pass a context and additional request options.
See DeleteWorkerConfiguration for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) DescribeConnector(input *DescribeConnectorInput) (*DescribeConnectorOutput, error)
DescribeConnector API operation for Managed Streaming for Kafka Connect.
Returns summary information about the connector.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation DescribeConnector for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DescribeConnector
func (c *KafkaConnect) DescribeConnectorRequest(input *DescribeConnectorInput) (req *request.Request, output *DescribeConnectorOutput)
DescribeConnectorRequest generates a "aws/request.Request" representing the client's request for the DescribeConnector operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeConnector for more information on using the DescribeConnector API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeConnectorRequest method.
req, resp := client.DescribeConnectorRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DescribeConnector
func (c *KafkaConnect) DescribeConnectorWithContext(ctx aws.Context, input *DescribeConnectorInput, opts ...request.Option) (*DescribeConnectorOutput, error)
DescribeConnectorWithContext is the same as DescribeConnector with the addition of the ability to pass a context and additional request options.
See DescribeConnector for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) DescribeCustomPlugin(input *DescribeCustomPluginInput) (*DescribeCustomPluginOutput, error)
DescribeCustomPlugin API operation for Managed Streaming for Kafka Connect.
A summary description of the custom plugin.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation DescribeCustomPlugin for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DescribeCustomPlugin
func (c *KafkaConnect) DescribeCustomPluginRequest(input *DescribeCustomPluginInput) (req *request.Request, output *DescribeCustomPluginOutput)
DescribeCustomPluginRequest generates a "aws/request.Request" representing the client's request for the DescribeCustomPlugin operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeCustomPlugin for more information on using the DescribeCustomPlugin API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeCustomPluginRequest method.
req, resp := client.DescribeCustomPluginRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DescribeCustomPlugin
func (c *KafkaConnect) DescribeCustomPluginWithContext(ctx aws.Context, input *DescribeCustomPluginInput, opts ...request.Option) (*DescribeCustomPluginOutput, error)
DescribeCustomPluginWithContext is the same as DescribeCustomPlugin with the addition of the ability to pass a context and additional request options.
See DescribeCustomPlugin for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) DescribeWorkerConfiguration(input *DescribeWorkerConfigurationInput) (*DescribeWorkerConfigurationOutput, error)
DescribeWorkerConfiguration API operation for Managed Streaming for Kafka Connect.
Returns information about a worker configuration.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation DescribeWorkerConfiguration for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DescribeWorkerConfiguration
func (c *KafkaConnect) DescribeWorkerConfigurationRequest(input *DescribeWorkerConfigurationInput) (req *request.Request, output *DescribeWorkerConfigurationOutput)
DescribeWorkerConfigurationRequest generates a "aws/request.Request" representing the client's request for the DescribeWorkerConfiguration operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeWorkerConfiguration for more information on using the DescribeWorkerConfiguration API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeWorkerConfigurationRequest method.
req, resp := client.DescribeWorkerConfigurationRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DescribeWorkerConfiguration
func (c *KafkaConnect) DescribeWorkerConfigurationWithContext(ctx aws.Context, input *DescribeWorkerConfigurationInput, opts ...request.Option) (*DescribeWorkerConfigurationOutput, error)
DescribeWorkerConfigurationWithContext is the same as DescribeWorkerConfiguration with the addition of the ability to pass a context and additional request options.
See DescribeWorkerConfiguration for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) ListConnectors(input *ListConnectorsInput) (*ListConnectorsOutput, error)
ListConnectors API operation for Managed Streaming for Kafka Connect.
Returns a list of all the connectors in this account and Region. The list is limited to connectors whose name starts with the specified prefix. The response also includes a description of each of the listed connectors.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation ListConnectors for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListConnectors
func (c *KafkaConnect) ListConnectorsPages(input *ListConnectorsInput, fn func(*ListConnectorsOutput, bool) bool) error
ListConnectorsPages iterates over the pages of a ListConnectors operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListConnectors method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListConnectors operation.
pageNum := 0
err := client.ListConnectorsPages(params,
func(page *kafkaconnect.ListConnectorsOutput, lastPage bool) bool {
pageNum++
fmt.Println(page)
return pageNum <= 3
})
func (c *KafkaConnect) ListConnectorsPagesWithContext(ctx aws.Context, input *ListConnectorsInput, fn func(*ListConnectorsOutput, bool) bool, opts ...request.Option) error
ListConnectorsPagesWithContext same as ListConnectorsPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) ListConnectorsRequest(input *ListConnectorsInput) (req *request.Request, output *ListConnectorsOutput)
ListConnectorsRequest generates a "aws/request.Request" representing the client's request for the ListConnectors operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListConnectors for more information on using the ListConnectors API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListConnectorsRequest method.
req, resp := client.ListConnectorsRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListConnectors
func (c *KafkaConnect) ListConnectorsWithContext(ctx aws.Context, input *ListConnectorsInput, opts ...request.Option) (*ListConnectorsOutput, error)
ListConnectorsWithContext is the same as ListConnectors with the addition of the ability to pass a context and additional request options.
See ListConnectors for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) ListCustomPlugins(input *ListCustomPluginsInput) (*ListCustomPluginsOutput, error)
ListCustomPlugins API operation for Managed Streaming for Kafka Connect.
Returns a list of all of the custom plugins in this account and Region.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation ListCustomPlugins for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListCustomPlugins
func (c *KafkaConnect) ListCustomPluginsPages(input *ListCustomPluginsInput, fn func(*ListCustomPluginsOutput, bool) bool) error
ListCustomPluginsPages iterates over the pages of a ListCustomPlugins operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListCustomPlugins method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListCustomPlugins operation.
pageNum := 0
err := client.ListCustomPluginsPages(params,
func(page *kafkaconnect.ListCustomPluginsOutput, lastPage bool) bool {
pageNum++
fmt.Println(page)
return pageNum <= 3
})
func (c *KafkaConnect) ListCustomPluginsPagesWithContext(ctx aws.Context, input *ListCustomPluginsInput, fn func(*ListCustomPluginsOutput, bool) bool, opts ...request.Option) error
ListCustomPluginsPagesWithContext same as ListCustomPluginsPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) ListCustomPluginsRequest(input *ListCustomPluginsInput) (req *request.Request, output *ListCustomPluginsOutput)
ListCustomPluginsRequest generates a "aws/request.Request" representing the client's request for the ListCustomPlugins operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListCustomPlugins for more information on using the ListCustomPlugins API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListCustomPluginsRequest method.
req, resp := client.ListCustomPluginsRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListCustomPlugins
func (c *KafkaConnect) ListCustomPluginsWithContext(ctx aws.Context, input *ListCustomPluginsInput, opts ...request.Option) (*ListCustomPluginsOutput, error)
ListCustomPluginsWithContext is the same as ListCustomPlugins with the addition of the ability to pass a context and additional request options.
See ListCustomPlugins for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
ListTagsForResource API operation for Managed Streaming for Kafka Connect.
Lists all the tags attached to the specified resource.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation ListTagsForResource for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResource
func (c *KafkaConnect) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListTagsForResourceRequest method.
req, resp := client.ListTagsForResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResource
func (c *KafkaConnect) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.
See ListTagsForResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) ListWorkerConfigurations(input *ListWorkerConfigurationsInput) (*ListWorkerConfigurationsOutput, error)
ListWorkerConfigurations API operation for Managed Streaming for Kafka Connect.
Returns a list of all of the worker configurations in this account and Region.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation ListWorkerConfigurations for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListWorkerConfigurations
func (c *KafkaConnect) ListWorkerConfigurationsPages(input *ListWorkerConfigurationsInput, fn func(*ListWorkerConfigurationsOutput, bool) bool) error
ListWorkerConfigurationsPages iterates over the pages of a ListWorkerConfigurations operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListWorkerConfigurations method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListWorkerConfigurations operation.
pageNum := 0
err := client.ListWorkerConfigurationsPages(params,
func(page *kafkaconnect.ListWorkerConfigurationsOutput, lastPage bool) bool {
pageNum++
fmt.Println(page)
return pageNum <= 3
})
func (c *KafkaConnect) ListWorkerConfigurationsPagesWithContext(ctx aws.Context, input *ListWorkerConfigurationsInput, fn func(*ListWorkerConfigurationsOutput, bool) bool, opts ...request.Option) error
ListWorkerConfigurationsPagesWithContext same as ListWorkerConfigurationsPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) ListWorkerConfigurationsRequest(input *ListWorkerConfigurationsInput) (req *request.Request, output *ListWorkerConfigurationsOutput)
ListWorkerConfigurationsRequest generates a "aws/request.Request" representing the client's request for the ListWorkerConfigurations operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListWorkerConfigurations for more information on using the ListWorkerConfigurations API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListWorkerConfigurationsRequest method.
req, resp := client.ListWorkerConfigurationsRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListWorkerConfigurations
func (c *KafkaConnect) ListWorkerConfigurationsWithContext(ctx aws.Context, input *ListWorkerConfigurationsInput, opts ...request.Option) (*ListWorkerConfigurationsOutput, error)
ListWorkerConfigurationsWithContext is the same as ListWorkerConfigurations with the addition of the ability to pass a context and additional request options.
See ListWorkerConfigurations for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
TagResource API operation for Managed Streaming for Kafka Connect.
Attaches tags to the specified resource.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation TagResource for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
ConflictException HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResource
func (c *KafkaConnect) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See TagResource for more information on using the TagResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the TagResourceRequest method.
req, resp := client.TagResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResource
func (c *KafkaConnect) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.
See TagResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
UntagResource API operation for Managed Streaming for Kafka Connect.
Removes tags from the specified resource.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation UntagResource for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResource
func (c *KafkaConnect) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UntagResource for more information on using the UntagResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UntagResourceRequest method.
req, resp := client.UntagResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResource
func (c *KafkaConnect) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.
See UntagResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *KafkaConnect) UpdateConnector(input *UpdateConnectorInput) (*UpdateConnectorOutput, error)
UpdateConnector API operation for Managed Streaming for Kafka Connect.
Updates the specified connector.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Managed Streaming for Kafka Connect's API operation UpdateConnector for usage and error information.
Returned Error Types:
NotFoundException HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.
BadRequestException HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.
ForbiddenException HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.
ServiceUnavailableException HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
TooManyRequestsException HTTP Status Code 429: Limit exceeded. Resource limit reached.
UnauthorizedException HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
InternalServerErrorException HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UpdateConnector
func (c *KafkaConnect) UpdateConnectorRequest(input *UpdateConnectorInput) (req *request.Request, output *UpdateConnectorOutput)
UpdateConnectorRequest generates a "aws/request.Request" representing the client's request for the UpdateConnector operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UpdateConnector for more information on using the UpdateConnector API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UpdateConnectorRequest method.
req, resp := client.UpdateConnectorRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UpdateConnector
func (c *KafkaConnect) UpdateConnectorWithContext(ctx aws.Context, input *UpdateConnectorInput, opts ...request.Option) (*UpdateConnectorOutput, error)
UpdateConnectorWithContext is the same as UpdateConnector with the addition of the ability to pass a context and additional request options.
See UpdateConnector for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
type ListConnectorsInput struct {
// The name prefix that you want to use to search for and list connectors.
ConnectorNamePrefix *string `location:"querystring" locationName:"connectorNamePrefix" type:"string"`
// The maximum number of connectors to list in one response.
MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`
// If the response of a ListConnectors operation is truncated, it will include
// a NextToken. Send this NextToken in a subsequent request to continue listing
// from where the previous operation left off.
NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
// contains filtered or unexported fields
}
func (s ListConnectorsInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListConnectorsInput) SetConnectorNamePrefix(v string) *ListConnectorsInput
SetConnectorNamePrefix sets the ConnectorNamePrefix field's value.
func (s *ListConnectorsInput) SetMaxResults(v int64) *ListConnectorsInput
SetMaxResults sets the MaxResults field's value.
func (s *ListConnectorsInput) SetNextToken(v string) *ListConnectorsInput
SetNextToken sets the NextToken field's value.
func (s ListConnectorsInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListConnectorsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListConnectorsOutput struct {
// An array of connector descriptions.
Connectors []*ConnectorSummary `locationName:"connectors" type:"list"`
// If the response of a ListConnectors operation is truncated, it will include
// a NextToken. Send this NextToken in a subsequent request to continue listing
// from where it left off.
NextToken *string `locationName:"nextToken" type:"string"`
// contains filtered or unexported fields
}
func (s ListConnectorsOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListConnectorsOutput) SetConnectors(v []*ConnectorSummary) *ListConnectorsOutput
SetConnectors sets the Connectors field's value.
func (s *ListConnectorsOutput) SetNextToken(v string) *ListConnectorsOutput
SetNextToken sets the NextToken field's value.
func (s ListConnectorsOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListCustomPluginsInput struct {
// The maximum number of custom plugins to list in one response.
MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`
// Lists custom plugin names that start with the specified text string.
NamePrefix *string `location:"querystring" locationName:"namePrefix" type:"string"`
// If the response of a ListCustomPlugins operation is truncated, it will include
// a NextToken. Send this NextToken in a subsequent request to continue listing
// from where the previous operation left off.
NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
// contains filtered or unexported fields
}
func (s ListCustomPluginsInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListCustomPluginsInput) SetMaxResults(v int64) *ListCustomPluginsInput
SetMaxResults sets the MaxResults field's value.
func (s *ListCustomPluginsInput) SetNamePrefix(v string) *ListCustomPluginsInput
SetNamePrefix sets the NamePrefix field's value.
func (s *ListCustomPluginsInput) SetNextToken(v string) *ListCustomPluginsInput
SetNextToken sets the NextToken field's value.
func (s ListCustomPluginsInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListCustomPluginsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListCustomPluginsOutput struct {
// An array of custom plugin descriptions.
CustomPlugins []*CustomPluginSummary `locationName:"customPlugins" type:"list"`
// If the response of a ListCustomPlugins operation is truncated, it will include
// a NextToken. Send this NextToken in a subsequent request to continue listing
// from where the previous operation left off.
NextToken *string `locationName:"nextToken" type:"string"`
// contains filtered or unexported fields
}
func (s ListCustomPluginsOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListCustomPluginsOutput) SetCustomPlugins(v []*CustomPluginSummary) *ListCustomPluginsOutput
SetCustomPlugins sets the CustomPlugins field's value.
func (s *ListCustomPluginsOutput) SetNextToken(v string) *ListCustomPluginsOutput
SetNextToken sets the NextToken field's value.
func (s ListCustomPluginsOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListTagsForResourceInput struct {
// The Amazon Resource Name (ARN) of the resource for which you want to list
// all attached tags.
//
// ResourceArn is a required field
ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s ListTagsForResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput
SetResourceArn sets the ResourceArn field's value.
func (s ListTagsForResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListTagsForResourceOutput struct {
// Lists the tags attached to the specified resource in the corresponding request.
Tags map[string]*string `locationName:"tags" type:"map"`
// contains filtered or unexported fields
}
func (s ListTagsForResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput
SetTags sets the Tags field's value.
func (s ListTagsForResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListWorkerConfigurationsInput struct {
// The maximum number of worker configurations to list in one response.
MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`
// Lists worker configuration names that start with the specified text string.
NamePrefix *string `location:"querystring" locationName:"namePrefix" type:"string"`
// If the response of a ListWorkerConfigurations operation is truncated, it
// will include a NextToken. Send this NextToken in a subsequent request to
// continue listing from where the previous operation left off.
NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
// contains filtered or unexported fields
}
func (s ListWorkerConfigurationsInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListWorkerConfigurationsInput) SetMaxResults(v int64) *ListWorkerConfigurationsInput
SetMaxResults sets the MaxResults field's value.
func (s *ListWorkerConfigurationsInput) SetNamePrefix(v string) *ListWorkerConfigurationsInput
SetNamePrefix sets the NamePrefix field's value.
func (s *ListWorkerConfigurationsInput) SetNextToken(v string) *ListWorkerConfigurationsInput
SetNextToken sets the NextToken field's value.
func (s ListWorkerConfigurationsInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListWorkerConfigurationsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListWorkerConfigurationsOutput struct {
// If the response of a ListWorkerConfigurations operation is truncated, it
// will include a NextToken. Send this NextToken in a subsequent request to
// continue listing from where the previous operation left off.
NextToken *string `locationName:"nextToken" type:"string"`
// An array of worker configuration descriptions.
WorkerConfigurations []*WorkerConfigurationSummary `locationName:"workerConfigurations" type:"list"`
// contains filtered or unexported fields
}
func (s ListWorkerConfigurationsOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListWorkerConfigurationsOutput) SetNextToken(v string) *ListWorkerConfigurationsOutput
SetNextToken sets the NextToken field's value.
func (s *ListWorkerConfigurationsOutput) SetWorkerConfigurations(v []*WorkerConfigurationSummary) *ListWorkerConfigurationsOutput
SetWorkerConfigurations sets the WorkerConfigurations field's value.
func (s ListWorkerConfigurationsOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type LogDelivery struct {
// The workers can send worker logs to different destination types. This configuration
// specifies the details of these destinations.
//
// WorkerLogDelivery is a required field
WorkerLogDelivery *WorkerLogDelivery `locationName:"workerLogDelivery" type:"structure" required:"true"`
// contains filtered or unexported fields
}
Details about log delivery.
func (s LogDelivery) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *LogDelivery) SetWorkerLogDelivery(v *WorkerLogDelivery) *LogDelivery
SetWorkerLogDelivery sets the WorkerLogDelivery field's value.
func (s LogDelivery) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *LogDelivery) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type LogDeliveryDescription struct {
// The workers can send worker logs to different destination types. This configuration
// specifies the details of these destinations.
WorkerLogDelivery *WorkerLogDeliveryDescription `locationName:"workerLogDelivery" type:"structure"`
// contains filtered or unexported fields
}
The description of the log delivery settings.
func (s LogDeliveryDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *LogDeliveryDescription) SetWorkerLogDelivery(v *WorkerLogDeliveryDescription) *LogDeliveryDescription
SetWorkerLogDelivery sets the WorkerLogDelivery field's value.
func (s LogDeliveryDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type NotFoundException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"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 (s *NotFoundException) Code() string
Code returns the exception type name.
func (s *NotFoundException) Error() string
func (s NotFoundException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *NotFoundException) Message() string
Message returns the exception's message.
func (s *NotFoundException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *NotFoundException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *NotFoundException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s NotFoundException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type Plugin struct {
// Details about a custom plugin.
//
// CustomPlugin is a required field
CustomPlugin *CustomPlugin `locationName:"customPlugin" type:"structure" required:"true"`
// contains filtered or unexported fields
}
A plugin is an Amazon Web Services resource that contains the code that defines your connector logic.
func (s Plugin) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Plugin) SetCustomPlugin(v *CustomPlugin) *Plugin
SetCustomPlugin sets the CustomPlugin field's value.
func (s Plugin) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Plugin) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type PluginDescription struct {
// Details about a custom plugin.
CustomPlugin *CustomPluginDescription `locationName:"customPlugin" type:"structure"`
// contains filtered or unexported fields
}
The description of the plugin.
func (s PluginDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *PluginDescription) SetCustomPlugin(v *CustomPluginDescription) *PluginDescription
SetCustomPlugin sets the CustomPlugin field's value.
func (s PluginDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ProvisionedCapacity struct {
// The number of microcontroller units (MCUs) allocated to each connector worker.
// The valid values are 1,2,4,8.
//
// McuCount is a required field
McuCount *int64 `locationName:"mcuCount" min:"1" type:"integer" required:"true"`
// The number of workers that are allocated to the connector.
//
// WorkerCount is a required field
WorkerCount *int64 `locationName:"workerCount" min:"1" type:"integer" required:"true"`
// contains filtered or unexported fields
}
Details about a connector's provisioned capacity.
func (s ProvisionedCapacity) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ProvisionedCapacity) SetMcuCount(v int64) *ProvisionedCapacity
SetMcuCount sets the McuCount field's value.
func (s *ProvisionedCapacity) SetWorkerCount(v int64) *ProvisionedCapacity
SetWorkerCount sets the WorkerCount field's value.
func (s ProvisionedCapacity) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ProvisionedCapacity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ProvisionedCapacityDescription struct {
// The number of microcontroller units (MCUs) allocated to each connector worker.
// The valid values are 1,2,4,8.
McuCount *int64 `locationName:"mcuCount" type:"integer"`
// The number of workers that are allocated to the connector.
WorkerCount *int64 `locationName:"workerCount" type:"integer"`
// contains filtered or unexported fields
}
The description of a connector's provisioned capacity.
func (s ProvisionedCapacityDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ProvisionedCapacityDescription) SetMcuCount(v int64) *ProvisionedCapacityDescription
SetMcuCount sets the McuCount field's value.
func (s *ProvisionedCapacityDescription) SetWorkerCount(v int64) *ProvisionedCapacityDescription
SetWorkerCount sets the WorkerCount field's value.
func (s ProvisionedCapacityDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ProvisionedCapacityUpdate struct {
// The number of microcontroller units (MCUs) allocated to each connector worker.
// The valid values are 1,2,4,8.
//
// McuCount is a required field
McuCount *int64 `locationName:"mcuCount" min:"1" type:"integer" required:"true"`
// The number of workers that are allocated to the connector.
//
// WorkerCount is a required field
WorkerCount *int64 `locationName:"workerCount" min:"1" type:"integer" required:"true"`
// contains filtered or unexported fields
}
An update to a connector's fixed capacity.
func (s ProvisionedCapacityUpdate) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ProvisionedCapacityUpdate) SetMcuCount(v int64) *ProvisionedCapacityUpdate
SetMcuCount sets the McuCount field's value.
func (s *ProvisionedCapacityUpdate) SetWorkerCount(v int64) *ProvisionedCapacityUpdate
SetWorkerCount sets the WorkerCount field's value.
func (s ProvisionedCapacityUpdate) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ProvisionedCapacityUpdate) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type S3Location struct {
// The Amazon Resource Name (ARN) of an S3 bucket.
//
// BucketArn is a required field
BucketArn *string `locationName:"bucketArn" type:"string" required:"true"`
// The file key for an object in an S3 bucket.
//
// FileKey is a required field
FileKey *string `locationName:"fileKey" type:"string" required:"true"`
// The version of an object in an S3 bucket.
ObjectVersion *string `locationName:"objectVersion" type:"string"`
// contains filtered or unexported fields
}
The location of an object in Amazon S3.
func (s S3Location) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3Location) SetBucketArn(v string) *S3Location
SetBucketArn sets the BucketArn field's value.
func (s *S3Location) SetFileKey(v string) *S3Location
SetFileKey sets the FileKey field's value.
func (s *S3Location) SetObjectVersion(v string) *S3Location
SetObjectVersion sets the ObjectVersion field's value.
func (s S3Location) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3Location) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type S3LocationDescription struct {
// The Amazon Resource Name (ARN) of an S3 bucket.
BucketArn *string `locationName:"bucketArn" type:"string"`
// The file key for an object in an S3 bucket.
FileKey *string `locationName:"fileKey" type:"string"`
// The version of an object in an S3 bucket.
ObjectVersion *string `locationName:"objectVersion" type:"string"`
// contains filtered or unexported fields
}
The description of the location of an object in Amazon S3.
func (s S3LocationDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3LocationDescription) SetBucketArn(v string) *S3LocationDescription
SetBucketArn sets the BucketArn field's value.
func (s *S3LocationDescription) SetFileKey(v string) *S3LocationDescription
SetFileKey sets the FileKey field's value.
func (s *S3LocationDescription) SetObjectVersion(v string) *S3LocationDescription
SetObjectVersion sets the ObjectVersion field's value.
func (s S3LocationDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type S3LogDelivery struct {
// The name of the S3 bucket that is the destination for log delivery.
Bucket *string `locationName:"bucket" type:"string"`
// Specifies whether connector logs get sent to the specified Amazon S3 destination.
//
// Enabled is a required field
Enabled *bool `locationName:"enabled" type:"boolean" required:"true"`
// The S3 prefix that is the destination for log delivery.
Prefix *string `locationName:"prefix" type:"string"`
// contains filtered or unexported fields
}
Details about delivering logs to Amazon S3.
func (s S3LogDelivery) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3LogDelivery) SetBucket(v string) *S3LogDelivery
SetBucket sets the Bucket field's value.
func (s *S3LogDelivery) SetEnabled(v bool) *S3LogDelivery
SetEnabled sets the Enabled field's value.
func (s *S3LogDelivery) SetPrefix(v string) *S3LogDelivery
SetPrefix sets the Prefix field's value.
func (s S3LogDelivery) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3LogDelivery) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type S3LogDeliveryDescription struct {
// The name of the S3 bucket that is the destination for log delivery.
Bucket *string `locationName:"bucket" type:"string"`
// Specifies whether connector logs get sent to the specified Amazon S3 destination.
Enabled *bool `locationName:"enabled" type:"boolean"`
// The S3 prefix that is the destination for log delivery.
Prefix *string `locationName:"prefix" type:"string"`
// contains filtered or unexported fields
}
The description of the details about delivering logs to Amazon S3.
func (s S3LogDeliveryDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3LogDeliveryDescription) SetBucket(v string) *S3LogDeliveryDescription
SetBucket sets the Bucket field's value.
func (s *S3LogDeliveryDescription) SetEnabled(v bool) *S3LogDeliveryDescription
SetEnabled sets the Enabled field's value.
func (s *S3LogDeliveryDescription) SetPrefix(v string) *S3LogDeliveryDescription
SetPrefix sets the Prefix field's value.
func (s S3LogDeliveryDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ScaleInPolicy struct {
// Specifies the CPU utilization percentage threshold at which you want connector
// scale in to be triggered.
//
// CpuUtilizationPercentage is a required field
CpuUtilizationPercentage *int64 `locationName:"cpuUtilizationPercentage" min:"1" type:"integer" required:"true"`
// contains filtered or unexported fields
}
The scale-in policy for the connector.
func (s ScaleInPolicy) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleInPolicy) SetCpuUtilizationPercentage(v int64) *ScaleInPolicy
SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.
func (s ScaleInPolicy) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleInPolicy) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ScaleInPolicyDescription struct {
// Specifies the CPU utilization percentage threshold at which you want connector
// scale in to be triggered.
CpuUtilizationPercentage *int64 `locationName:"cpuUtilizationPercentage" type:"integer"`
// contains filtered or unexported fields
}
The description of the scale-in policy for the connector.
func (s ScaleInPolicyDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleInPolicyDescription) SetCpuUtilizationPercentage(v int64) *ScaleInPolicyDescription
SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.
func (s ScaleInPolicyDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ScaleInPolicyUpdate struct {
// The target CPU utilization percentage threshold at which you want connector
// scale in to be triggered.
//
// CpuUtilizationPercentage is a required field
CpuUtilizationPercentage *int64 `locationName:"cpuUtilizationPercentage" min:"1" type:"integer" required:"true"`
// contains filtered or unexported fields
}
An update to the connector's scale-in policy.
func (s ScaleInPolicyUpdate) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleInPolicyUpdate) SetCpuUtilizationPercentage(v int64) *ScaleInPolicyUpdate
SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.
func (s ScaleInPolicyUpdate) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleInPolicyUpdate) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ScaleOutPolicy struct {
// The CPU utilization percentage threshold at which you want connector scale
// out to be triggered.
//
// CpuUtilizationPercentage is a required field
CpuUtilizationPercentage *int64 `locationName:"cpuUtilizationPercentage" min:"1" type:"integer" required:"true"`
// contains filtered or unexported fields
}
The scale-out policy for the connector.
func (s ScaleOutPolicy) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleOutPolicy) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicy
SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.
func (s ScaleOutPolicy) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleOutPolicy) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ScaleOutPolicyDescription struct {
// The CPU utilization percentage threshold at which you want connector scale
// out to be triggered.
CpuUtilizationPercentage *int64 `locationName:"cpuUtilizationPercentage" type:"integer"`
// contains filtered or unexported fields
}
The description of the scale-out policy for the connector.
func (s ScaleOutPolicyDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleOutPolicyDescription) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicyDescription
SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.
func (s ScaleOutPolicyDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ScaleOutPolicyUpdate struct {
// The target CPU utilization percentage threshold at which you want connector
// scale out to be triggered.
//
// CpuUtilizationPercentage is a required field
CpuUtilizationPercentage *int64 `locationName:"cpuUtilizationPercentage" min:"1" type:"integer" required:"true"`
// contains filtered or unexported fields
}
An update to the connector's scale-out policy.
func (s ScaleOutPolicyUpdate) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleOutPolicyUpdate) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicyUpdate
SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.
func (s ScaleOutPolicyUpdate) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScaleOutPolicyUpdate) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ServiceUnavailableException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.
func (s *ServiceUnavailableException) Code() string
Code returns the exception type name.
func (s *ServiceUnavailableException) Error() string
func (s ServiceUnavailableException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ServiceUnavailableException) Message() string
Message returns the exception's message.
func (s *ServiceUnavailableException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ServiceUnavailableException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ServiceUnavailableException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ServiceUnavailableException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type StateDescription struct {
// A code that describes the state of a resource.
Code *string `locationName:"code" type:"string"`
// A message that describes the state of a resource.
Message *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
Details about the state of a resource.
func (s StateDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *StateDescription) SetCode(v string) *StateDescription
SetCode sets the Code field's value.
func (s *StateDescription) SetMessage(v string) *StateDescription
SetMessage sets the Message field's value.
func (s StateDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type TagResourceInput struct {
// The Amazon Resource Name (ARN) of the resource to which you want to attach
// tags.
//
// ResourceArn is a required field
ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
// The tags that you want to attach to the resource.
//
// Tags is a required field
Tags map[string]*string `locationName:"tags" type:"map" required:"true"`
// contains filtered or unexported fields
}
func (s TagResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput
SetResourceArn sets the ResourceArn field's value.
func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput
SetTags sets the Tags field's value.
func (s TagResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TagResourceOutput struct {
// contains filtered or unexported fields
}
func (s TagResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s TagResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type TooManyRequestsException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
HTTP Status Code 429: Limit exceeded. Resource limit reached.
func (s *TooManyRequestsException) Code() string
Code returns the exception type name.
func (s *TooManyRequestsException) Error() string
func (s TooManyRequestsException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TooManyRequestsException) Message() string
Message returns the exception's message.
func (s *TooManyRequestsException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *TooManyRequestsException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *TooManyRequestsException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s TooManyRequestsException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UnauthorizedException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"message" type:"string"`
// contains filtered or unexported fields
}
HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.
func (s *UnauthorizedException) Code() string
Code returns the exception type name.
func (s *UnauthorizedException) Error() string
func (s UnauthorizedException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UnauthorizedException) Message() string
Message returns the exception's message.
func (s *UnauthorizedException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *UnauthorizedException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *UnauthorizedException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s UnauthorizedException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UntagResourceInput struct {
// The Amazon Resource Name (ARN) of the resource from which you want to remove
// tags.
//
// ResourceArn is a required field
ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
// The keys of the tags that you want to remove from the resource.
//
// TagKeys is a required field
TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
// contains filtered or unexported fields
}
func (s UntagResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput
SetResourceArn sets the ResourceArn field's value.
func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput
SetTagKeys sets the TagKeys field's value.
func (s UntagResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UntagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UntagResourceOutput struct {
// contains filtered or unexported fields
}
func (s UntagResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s UntagResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UpdateConnectorInput struct {
// The target capacity.
//
// Capacity is a required field
Capacity *CapacityUpdate `locationName:"capacity" type:"structure" required:"true"`
// The Amazon Resource Name (ARN) of the connector that you want to update.
//
// ConnectorArn is a required field
ConnectorArn *string `location:"uri" locationName:"connectorArn" type:"string" required:"true"`
// The current version of the connector that you want to update.
//
// CurrentVersion is a required field
CurrentVersion *string `location:"querystring" locationName:"currentVersion" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s UpdateConnectorInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateConnectorInput) SetCapacity(v *CapacityUpdate) *UpdateConnectorInput
SetCapacity sets the Capacity field's value.
func (s *UpdateConnectorInput) SetConnectorArn(v string) *UpdateConnectorInput
SetConnectorArn sets the ConnectorArn field's value.
func (s *UpdateConnectorInput) SetCurrentVersion(v string) *UpdateConnectorInput
SetCurrentVersion sets the CurrentVersion field's value.
func (s UpdateConnectorInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateConnectorInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateConnectorOutput struct {
// The Amazon Resource Name (ARN) of the connector.
ConnectorArn *string `locationName:"connectorArn" type:"string"`
// The state of the connector.
ConnectorState *string `locationName:"connectorState" type:"string" enum:"ConnectorState"`
// contains filtered or unexported fields
}
func (s UpdateConnectorOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateConnectorOutput) SetConnectorArn(v string) *UpdateConnectorOutput
SetConnectorArn sets the ConnectorArn field's value.
func (s *UpdateConnectorOutput) SetConnectorState(v string) *UpdateConnectorOutput
SetConnectorState sets the ConnectorState field's value.
func (s UpdateConnectorOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type Vpc struct {
// The security groups for the connector.
SecurityGroups []*string `locationName:"securityGroups" type:"list"`
// The subnets for the connector.
//
// Subnets is a required field
Subnets []*string `locationName:"subnets" type:"list" required:"true"`
// contains filtered or unexported fields
}
Information about the VPC in which the connector resides.
func (s Vpc) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Vpc) SetSecurityGroups(v []*string) *Vpc
SetSecurityGroups sets the SecurityGroups field's value.
func (s *Vpc) SetSubnets(v []*string) *Vpc
SetSubnets sets the Subnets field's value.
func (s Vpc) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Vpc) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type VpcDescription struct {
// The security groups for the connector.
SecurityGroups []*string `locationName:"securityGroups" type:"list"`
// The subnets for the connector.
Subnets []*string `locationName:"subnets" type:"list"`
// contains filtered or unexported fields
}
The description of the VPC in which the connector resides.
func (s VpcDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *VpcDescription) SetSecurityGroups(v []*string) *VpcDescription
SetSecurityGroups sets the SecurityGroups field's value.
func (s *VpcDescription) SetSubnets(v []*string) *VpcDescription
SetSubnets sets the Subnets field's value.
func (s VpcDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type WorkerConfiguration struct {
// The revision of the worker configuration.
//
// Revision is a required field
Revision *int64 `locationName:"revision" min:"1" type:"long" required:"true"`
// The Amazon Resource Name (ARN) of the worker configuration.
//
// WorkerConfigurationArn is a required field
WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string" required:"true"`
// contains filtered or unexported fields
}
The configuration of the workers, which are the processes that run the connector logic.
func (s WorkerConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerConfiguration) SetRevision(v int64) *WorkerConfiguration
SetRevision sets the Revision field's value.
func (s *WorkerConfiguration) SetWorkerConfigurationArn(v string) *WorkerConfiguration
SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
func (s WorkerConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type WorkerConfigurationDescription struct {
// The revision of the worker configuration.
Revision *int64 `locationName:"revision" type:"long"`
// The Amazon Resource Name (ARN) of the worker configuration.
WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
// contains filtered or unexported fields
}
The description of the worker configuration.
func (s WorkerConfigurationDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerConfigurationDescription) SetRevision(v int64) *WorkerConfigurationDescription
SetRevision sets the Revision field's value.
func (s *WorkerConfigurationDescription) SetWorkerConfigurationArn(v string) *WorkerConfigurationDescription
SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
func (s WorkerConfigurationDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type WorkerConfigurationRevisionDescription struct {
// The time that the worker configuration was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The description of the worker configuration revision.
Description *string `locationName:"description" type:"string"`
// Base64 encoded contents of the connect-distributed.properties file.
//
// PropertiesFileContent is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by WorkerConfigurationRevisionDescription's
// String and GoString methods.
PropertiesFileContent *string `locationName:"propertiesFileContent" type:"string" sensitive:"true"`
// The description of a revision of the worker configuration.
Revision *int64 `locationName:"revision" type:"long"`
// contains filtered or unexported fields
}
The description of the worker configuration revision.
func (s WorkerConfigurationRevisionDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerConfigurationRevisionDescription) SetCreationTime(v time.Time) *WorkerConfigurationRevisionDescription
SetCreationTime sets the CreationTime field's value.
func (s *WorkerConfigurationRevisionDescription) SetDescription(v string) *WorkerConfigurationRevisionDescription
SetDescription sets the Description field's value.
func (s *WorkerConfigurationRevisionDescription) SetPropertiesFileContent(v string) *WorkerConfigurationRevisionDescription
SetPropertiesFileContent sets the PropertiesFileContent field's value.
func (s *WorkerConfigurationRevisionDescription) SetRevision(v int64) *WorkerConfigurationRevisionDescription
SetRevision sets the Revision field's value.
func (s WorkerConfigurationRevisionDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type WorkerConfigurationRevisionSummary struct {
// The time that a worker configuration revision was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The description of a worker configuration revision.
Description *string `locationName:"description" type:"string"`
// The revision of a worker configuration.
Revision *int64 `locationName:"revision" type:"long"`
// contains filtered or unexported fields
}
The summary of a worker configuration revision.
func (s WorkerConfigurationRevisionSummary) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerConfigurationRevisionSummary) SetCreationTime(v time.Time) *WorkerConfigurationRevisionSummary
SetCreationTime sets the CreationTime field's value.
func (s *WorkerConfigurationRevisionSummary) SetDescription(v string) *WorkerConfigurationRevisionSummary
SetDescription sets the Description field's value.
func (s *WorkerConfigurationRevisionSummary) SetRevision(v int64) *WorkerConfigurationRevisionSummary
SetRevision sets the Revision field's value.
func (s WorkerConfigurationRevisionSummary) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type WorkerConfigurationSummary struct {
// The time that a worker configuration was created.
CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"iso8601"`
// The description of a worker configuration.
Description *string `locationName:"description" type:"string"`
// The latest revision of a worker configuration.
LatestRevision *WorkerConfigurationRevisionSummary `locationName:"latestRevision" type:"structure"`
// The name of the worker configuration.
Name *string `locationName:"name" type:"string"`
// The Amazon Resource Name (ARN) of the worker configuration.
WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
// The state of the worker configuration.
WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"`
// contains filtered or unexported fields
}
The summary of a worker configuration.
func (s WorkerConfigurationSummary) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerConfigurationSummary) SetCreationTime(v time.Time) *WorkerConfigurationSummary
SetCreationTime sets the CreationTime field's value.
func (s *WorkerConfigurationSummary) SetDescription(v string) *WorkerConfigurationSummary
SetDescription sets the Description field's value.
func (s *WorkerConfigurationSummary) SetLatestRevision(v *WorkerConfigurationRevisionSummary) *WorkerConfigurationSummary
SetLatestRevision sets the LatestRevision field's value.
func (s *WorkerConfigurationSummary) SetName(v string) *WorkerConfigurationSummary
SetName sets the Name field's value.
func (s *WorkerConfigurationSummary) SetWorkerConfigurationArn(v string) *WorkerConfigurationSummary
SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
func (s *WorkerConfigurationSummary) SetWorkerConfigurationState(v string) *WorkerConfigurationSummary
SetWorkerConfigurationState sets the WorkerConfigurationState field's value.
func (s WorkerConfigurationSummary) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type WorkerLogDelivery struct {
// Details about delivering logs to Amazon CloudWatch Logs.
CloudWatchLogs *CloudWatchLogsLogDelivery `locationName:"cloudWatchLogs" type:"structure"`
// Details about delivering logs to Amazon Kinesis Data Firehose.
Firehose *FirehoseLogDelivery `locationName:"firehose" type:"structure"`
// Details about delivering logs to Amazon S3.
S3 *S3LogDelivery `locationName:"s3" type:"structure"`
// contains filtered or unexported fields
}
Workers can send worker logs to different destination types. This configuration specifies the details of these destinations.
func (s WorkerLogDelivery) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerLogDelivery) SetCloudWatchLogs(v *CloudWatchLogsLogDelivery) *WorkerLogDelivery
SetCloudWatchLogs sets the CloudWatchLogs field's value.
func (s *WorkerLogDelivery) SetFirehose(v *FirehoseLogDelivery) *WorkerLogDelivery
SetFirehose sets the Firehose field's value.
func (s *WorkerLogDelivery) SetS3(v *S3LogDelivery) *WorkerLogDelivery
SetS3 sets the S3 field's value.
func (s WorkerLogDelivery) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerLogDelivery) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type WorkerLogDeliveryDescription struct {
// Details about delivering logs to Amazon CloudWatch Logs.
CloudWatchLogs *CloudWatchLogsLogDeliveryDescription `locationName:"cloudWatchLogs" type:"structure"`
// Details about delivering logs to Amazon Kinesis Data Firehose.
Firehose *FirehoseLogDeliveryDescription `locationName:"firehose" type:"structure"`
// Details about delivering logs to Amazon S3.
S3 *S3LogDeliveryDescription `locationName:"s3" type:"structure"`
// contains filtered or unexported fields
}
Workers can send worker logs to different destination types. This configuration specifies the details of these destinations.
func (s WorkerLogDeliveryDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *WorkerLogDeliveryDescription) SetCloudWatchLogs(v *CloudWatchLogsLogDeliveryDescription) *WorkerLogDeliveryDescription
SetCloudWatchLogs sets the CloudWatchLogs field's value.
func (s *WorkerLogDeliveryDescription) SetFirehose(v *FirehoseLogDeliveryDescription) *WorkerLogDeliveryDescription
SetFirehose sets the Firehose field's value.
func (s *WorkerLogDeliveryDescription) SetS3(v *S3LogDeliveryDescription) *WorkerLogDeliveryDescription
SetS3 sets the S3 field's value.
func (s WorkerLogDeliveryDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".