kafkaconnect

package
v1.48.2 Latest Latest
Warning

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

Go to latest
Published: Nov 21, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Package kafkaconnect provides the client and types for making API requests to Managed Streaming for Kafka Connect.

See https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14 for more information on this service.

See kafkaconnect package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/kafkaconnect/

Using the Client

To contact Managed Streaming for Kafka Connect with the SDK use the New function to create a new service client. With that client you can make API requests to the service. These clients are safe to use concurrently.

See the SDK's documentation for more information on how to use the SDK. https://docs.aws.amazon.com/sdk-for-go/api/

See aws.Config documentation for more information on configuring SDK clients. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config

See the Managed Streaming for Kafka Connect client KafkaConnect for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/kafkaconnect/#New

Index

Constants

View Source
const (
	// ConnectorStateRunning is a ConnectorState enum value
	ConnectorStateRunning = "RUNNING"

	// ConnectorStateCreating is a ConnectorState enum value
	ConnectorStateCreating = "CREATING"

	// ConnectorStateUpdating is a ConnectorState enum value
	ConnectorStateUpdating = "UPDATING"

	// ConnectorStateDeleting is a ConnectorState enum value
	ConnectorStateDeleting = "DELETING"

	// ConnectorStateFailed is a ConnectorState enum value
	ConnectorStateFailed = "FAILED"
)
View Source
const (
	// CustomPluginContentTypeJar is a CustomPluginContentType enum value
	CustomPluginContentTypeJar = "JAR"

	// CustomPluginContentTypeZip is a CustomPluginContentType enum value
	CustomPluginContentTypeZip = "ZIP"
)
View Source
const (
	// CustomPluginStateCreating is a CustomPluginState enum value
	CustomPluginStateCreating = "CREATING"

	// CustomPluginStateCreateFailed is a CustomPluginState enum value
	CustomPluginStateCreateFailed = "CREATE_FAILED"

	// CustomPluginStateActive is a CustomPluginState enum value
	CustomPluginStateActive = "ACTIVE"

	// CustomPluginStateUpdating is a CustomPluginState enum value
	CustomPluginStateUpdating = "UPDATING"

	// CustomPluginStateUpdateFailed is a CustomPluginState enum value
	CustomPluginStateUpdateFailed = "UPDATE_FAILED"

	// CustomPluginStateDeleting is a CustomPluginState enum value
	CustomPluginStateDeleting = "DELETING"
)
View Source
const (
	// KafkaClusterClientAuthenticationTypeNone is a KafkaClusterClientAuthenticationType enum value
	KafkaClusterClientAuthenticationTypeNone = "NONE"

	// KafkaClusterClientAuthenticationTypeIam is a KafkaClusterClientAuthenticationType enum value
	KafkaClusterClientAuthenticationTypeIam = "IAM"
)
View Source
const (
	// KafkaClusterEncryptionInTransitTypePlaintext is a KafkaClusterEncryptionInTransitType enum value
	KafkaClusterEncryptionInTransitTypePlaintext = "PLAINTEXT"

	// KafkaClusterEncryptionInTransitTypeTls is a KafkaClusterEncryptionInTransitType enum value
	KafkaClusterEncryptionInTransitTypeTls = "TLS"
)
View Source
const (

	// ErrCodeBadRequestException for service response error code
	// "BadRequestException".
	//
	// HTTP Status Code 400: Bad request due to incorrect input. Correct your request
	// and then retry it.
	ErrCodeBadRequestException = "BadRequestException"

	// ErrCodeConflictException for service response error code
	// "ConflictException".
	//
	// HTTP Status Code 409: Conflict. A resource with this name already exists.
	// Retry your request with another name.
	ErrCodeConflictException = "ConflictException"

	// ErrCodeForbiddenException for service response error code
	// "ForbiddenException".
	//
	// HTTP Status Code 403: Access forbidden. Correct your credentials and then
	// retry your request.
	ErrCodeForbiddenException = "ForbiddenException"

	// ErrCodeInternalServerErrorException for service response error code
	// "InternalServerErrorException".
	//
	// HTTP Status Code 500: Unexpected internal server error. Retrying your request
	// might resolve the issue.
	ErrCodeInternalServerErrorException = "InternalServerErrorException"

	// ErrCodeNotFoundException for service response error code
	// "NotFoundException".
	//
	// HTTP Status Code 404: Resource not found due to incorrect input. Correct
	// your request and then retry it.
	ErrCodeNotFoundException = "NotFoundException"

	// ErrCodeServiceUnavailableException for service response error code
	// "ServiceUnavailableException".
	//
	// HTTP Status Code 503: Service Unavailable. Retrying your request in some
	// time might resolve the issue.
	ErrCodeServiceUnavailableException = "ServiceUnavailableException"

	// ErrCodeTooManyRequestsException for service response error code
	// "TooManyRequestsException".
	//
	// HTTP Status Code 429: Limit exceeded. Resource limit reached.
	ErrCodeTooManyRequestsException = "TooManyRequestsException"

	// ErrCodeUnauthorizedException for service response error code
	// "UnauthorizedException".
	//
	// HTTP Status Code 401: Unauthorized request. The provided credentials couldn't
	// be validated.
	ErrCodeUnauthorizedException = "UnauthorizedException"
)
View Source
const (
	ServiceName = "KafkaConnect" // Name of service.
	EndpointsID = "kafkaconnect" // ID to lookup a service endpoint with.
	ServiceID   = "KafkaConnect" // ServiceID is a unique identifier of a specific service.
)

Service information constants

Variables

This section is empty.

Functions

func ConnectorState_Values

func ConnectorState_Values() []string

ConnectorState_Values returns all elements of the ConnectorState enum

func CustomPluginContentType_Values

func CustomPluginContentType_Values() []string

CustomPluginContentType_Values returns all elements of the CustomPluginContentType enum

func CustomPluginState_Values

func CustomPluginState_Values() []string

CustomPluginState_Values returns all elements of the CustomPluginState enum

func KafkaClusterClientAuthenticationType_Values

func KafkaClusterClientAuthenticationType_Values() []string

KafkaClusterClientAuthenticationType_Values returns all elements of the KafkaClusterClientAuthenticationType enum

func KafkaClusterEncryptionInTransitType_Values

func KafkaClusterEncryptionInTransitType_Values() []string

KafkaClusterEncryptionInTransitType_Values returns all elements of the KafkaClusterEncryptionInTransitType enum

Types

type ApacheKafkaCluster

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 (ApacheKafkaCluster) GoString

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 (*ApacheKafkaCluster) SetBootstrapServers

func (s *ApacheKafkaCluster) SetBootstrapServers(v string) *ApacheKafkaCluster

SetBootstrapServers sets the BootstrapServers field's value.

func (*ApacheKafkaCluster) SetVpc

func (s *ApacheKafkaCluster) SetVpc(v *Vpc) *ApacheKafkaCluster

SetVpc sets the Vpc field's value.

func (ApacheKafkaCluster) String

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 (*ApacheKafkaCluster) Validate

func (s *ApacheKafkaCluster) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ApacheKafkaClusterDescription

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 (ApacheKafkaClusterDescription) GoString

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 (*ApacheKafkaClusterDescription) SetBootstrapServers

SetBootstrapServers sets the BootstrapServers field's value.

func (*ApacheKafkaClusterDescription) SetVpc

SetVpc sets the Vpc field's value.

func (ApacheKafkaClusterDescription) 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

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 (AutoScaling) GoString

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 (*AutoScaling) SetMaxWorkerCount

func (s *AutoScaling) SetMaxWorkerCount(v int64) *AutoScaling

SetMaxWorkerCount sets the MaxWorkerCount field's value.

func (*AutoScaling) SetMcuCount

func (s *AutoScaling) SetMcuCount(v int64) *AutoScaling

SetMcuCount sets the McuCount field's value.

func (*AutoScaling) SetMinWorkerCount

func (s *AutoScaling) SetMinWorkerCount(v int64) *AutoScaling

SetMinWorkerCount sets the MinWorkerCount field's value.

func (*AutoScaling) SetScaleInPolicy

func (s *AutoScaling) SetScaleInPolicy(v *ScaleInPolicy) *AutoScaling

SetScaleInPolicy sets the ScaleInPolicy field's value.

func (*AutoScaling) SetScaleOutPolicy

func (s *AutoScaling) SetScaleOutPolicy(v *ScaleOutPolicy) *AutoScaling

SetScaleOutPolicy sets the ScaleOutPolicy field's value.

func (AutoScaling) String

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 (*AutoScaling) Validate

func (s *AutoScaling) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type AutoScalingDescription

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 (AutoScalingDescription) GoString

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 (*AutoScalingDescription) SetMaxWorkerCount

func (s *AutoScalingDescription) SetMaxWorkerCount(v int64) *AutoScalingDescription

SetMaxWorkerCount sets the MaxWorkerCount field's value.

func (*AutoScalingDescription) SetMcuCount

SetMcuCount sets the McuCount field's value.

func (*AutoScalingDescription) SetMinWorkerCount

func (s *AutoScalingDescription) SetMinWorkerCount(v int64) *AutoScalingDescription

SetMinWorkerCount sets the MinWorkerCount field's value.

func (*AutoScalingDescription) SetScaleInPolicy

SetScaleInPolicy sets the ScaleInPolicy field's value.

func (*AutoScalingDescription) SetScaleOutPolicy

SetScaleOutPolicy sets the ScaleOutPolicy field's value.

func (AutoScalingDescription) String

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

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 (AutoScalingUpdate) GoString

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 (*AutoScalingUpdate) SetMaxWorkerCount

func (s *AutoScalingUpdate) SetMaxWorkerCount(v int64) *AutoScalingUpdate

SetMaxWorkerCount sets the MaxWorkerCount field's value.

func (*AutoScalingUpdate) SetMcuCount

func (s *AutoScalingUpdate) SetMcuCount(v int64) *AutoScalingUpdate

SetMcuCount sets the McuCount field's value.

func (*AutoScalingUpdate) SetMinWorkerCount

func (s *AutoScalingUpdate) SetMinWorkerCount(v int64) *AutoScalingUpdate

SetMinWorkerCount sets the MinWorkerCount field's value.

func (*AutoScalingUpdate) SetScaleInPolicy

func (s *AutoScalingUpdate) SetScaleInPolicy(v *ScaleInPolicyUpdate) *AutoScalingUpdate

SetScaleInPolicy sets the ScaleInPolicy field's value.

func (*AutoScalingUpdate) SetScaleOutPolicy

func (s *AutoScalingUpdate) SetScaleOutPolicy(v *ScaleOutPolicyUpdate) *AutoScalingUpdate

SetScaleOutPolicy sets the ScaleOutPolicy field's value.

func (AutoScalingUpdate) String

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 (*AutoScalingUpdate) Validate

func (s *AutoScalingUpdate) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type BadRequestException

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 (*BadRequestException) Code

func (s *BadRequestException) Code() string

Code returns the exception type name.

func (*BadRequestException) Error

func (s *BadRequestException) Error() string

func (BadRequestException) GoString

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 (*BadRequestException) Message

func (s *BadRequestException) Message() string

Message returns the exception's message.

func (*BadRequestException) OrigErr

func (s *BadRequestException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*BadRequestException) RequestID

func (s *BadRequestException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*BadRequestException) StatusCode

func (s *BadRequestException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (BadRequestException) String

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

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 (Capacity) GoString

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 (*Capacity) SetAutoScaling

func (s *Capacity) SetAutoScaling(v *AutoScaling) *Capacity

SetAutoScaling sets the AutoScaling field's value.

func (*Capacity) SetProvisionedCapacity

func (s *Capacity) SetProvisionedCapacity(v *ProvisionedCapacity) *Capacity

SetProvisionedCapacity sets the ProvisionedCapacity field's value.

func (Capacity) String

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 (*Capacity) Validate

func (s *Capacity) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CapacityDescription

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 (CapacityDescription) GoString

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 (*CapacityDescription) SetAutoScaling

SetAutoScaling sets the AutoScaling field's value.

func (*CapacityDescription) SetProvisionedCapacity

SetProvisionedCapacity sets the ProvisionedCapacity field's value.

func (CapacityDescription) String

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

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 (CapacityUpdate) GoString

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 (*CapacityUpdate) SetAutoScaling

func (s *CapacityUpdate) SetAutoScaling(v *AutoScalingUpdate) *CapacityUpdate

SetAutoScaling sets the AutoScaling field's value.

func (*CapacityUpdate) SetProvisionedCapacity

func (s *CapacityUpdate) SetProvisionedCapacity(v *ProvisionedCapacityUpdate) *CapacityUpdate

SetProvisionedCapacity sets the ProvisionedCapacity field's value.

func (CapacityUpdate) String

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 (*CapacityUpdate) Validate

func (s *CapacityUpdate) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CloudWatchLogsLogDelivery

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 (CloudWatchLogsLogDelivery) GoString

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 (*CloudWatchLogsLogDelivery) SetEnabled

SetEnabled sets the Enabled field's value.

func (*CloudWatchLogsLogDelivery) SetLogGroup

SetLogGroup sets the LogGroup field's value.

func (CloudWatchLogsLogDelivery) String

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 (*CloudWatchLogsLogDelivery) Validate

func (s *CloudWatchLogsLogDelivery) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CloudWatchLogsLogDeliveryDescription

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 (CloudWatchLogsLogDeliveryDescription) GoString

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 (*CloudWatchLogsLogDeliveryDescription) SetEnabled

SetEnabled sets the Enabled field's value.

func (*CloudWatchLogsLogDeliveryDescription) SetLogGroup

SetLogGroup sets the LogGroup field's value.

func (CloudWatchLogsLogDeliveryDescription) 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

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 (*ConflictException) Code

func (s *ConflictException) Code() string

Code returns the exception type name.

func (*ConflictException) Error

func (s *ConflictException) Error() string

func (ConflictException) GoString

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 (*ConflictException) Message

func (s *ConflictException) Message() string

Message returns the exception's message.

func (*ConflictException) OrigErr

func (s *ConflictException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ConflictException) RequestID

func (s *ConflictException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ConflictException) StatusCode

func (s *ConflictException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ConflictException) String

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

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 (ConnectorSummary) GoString

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 (*ConnectorSummary) SetCapacity

SetCapacity sets the Capacity field's value.

func (*ConnectorSummary) SetConnectorArn

func (s *ConnectorSummary) SetConnectorArn(v string) *ConnectorSummary

SetConnectorArn sets the ConnectorArn field's value.

func (*ConnectorSummary) SetConnectorDescription

func (s *ConnectorSummary) SetConnectorDescription(v string) *ConnectorSummary

SetConnectorDescription sets the ConnectorDescription field's value.

func (*ConnectorSummary) SetConnectorName

func (s *ConnectorSummary) SetConnectorName(v string) *ConnectorSummary

SetConnectorName sets the ConnectorName field's value.

func (*ConnectorSummary) SetConnectorState

func (s *ConnectorSummary) SetConnectorState(v string) *ConnectorSummary

SetConnectorState sets the ConnectorState field's value.

func (*ConnectorSummary) SetCreationTime

func (s *ConnectorSummary) SetCreationTime(v time.Time) *ConnectorSummary

SetCreationTime sets the CreationTime field's value.

func (*ConnectorSummary) SetCurrentVersion

func (s *ConnectorSummary) SetCurrentVersion(v string) *ConnectorSummary

SetCurrentVersion sets the CurrentVersion field's value.

func (*ConnectorSummary) SetKafkaCluster

SetKafkaCluster sets the KafkaCluster field's value.

func (*ConnectorSummary) SetKafkaClusterClientAuthentication

func (s *ConnectorSummary) SetKafkaClusterClientAuthentication(v *KafkaClusterClientAuthenticationDescription) *ConnectorSummary

SetKafkaClusterClientAuthentication sets the KafkaClusterClientAuthentication field's value.

func (*ConnectorSummary) SetKafkaClusterEncryptionInTransit

func (s *ConnectorSummary) SetKafkaClusterEncryptionInTransit(v *KafkaClusterEncryptionInTransitDescription) *ConnectorSummary

SetKafkaClusterEncryptionInTransit sets the KafkaClusterEncryptionInTransit field's value.

func (*ConnectorSummary) SetKafkaConnectVersion

func (s *ConnectorSummary) SetKafkaConnectVersion(v string) *ConnectorSummary

SetKafkaConnectVersion sets the KafkaConnectVersion field's value.

func (*ConnectorSummary) SetLogDelivery

SetLogDelivery sets the LogDelivery field's value.

func (*ConnectorSummary) SetPlugins

SetPlugins sets the Plugins field's value.

func (*ConnectorSummary) SetServiceExecutionRoleArn

func (s *ConnectorSummary) SetServiceExecutionRoleArn(v string) *ConnectorSummary

SetServiceExecutionRoleArn sets the ServiceExecutionRoleArn field's value.

func (*ConnectorSummary) SetWorkerConfiguration

func (s *ConnectorSummary) SetWorkerConfiguration(v *WorkerConfigurationDescription) *ConnectorSummary

SetWorkerConfiguration sets the WorkerConfiguration field's value.

func (ConnectorSummary) String

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

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

	// Specifies which plugins to use for the connector.
	//
	// 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"`

	// Specifies which worker configuration to use with the connector.
	WorkerConfiguration *WorkerConfiguration `locationName:"workerConfiguration" type:"structure"`
	// contains filtered or unexported fields
}

func (CreateConnectorInput) GoString

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 (*CreateConnectorInput) SetCapacity

SetCapacity sets the Capacity field's value.

func (*CreateConnectorInput) SetConnectorConfiguration

func (s *CreateConnectorInput) SetConnectorConfiguration(v map[string]*string) *CreateConnectorInput

SetConnectorConfiguration sets the ConnectorConfiguration field's value.

func (*CreateConnectorInput) SetConnectorDescription

func (s *CreateConnectorInput) SetConnectorDescription(v string) *CreateConnectorInput

SetConnectorDescription sets the ConnectorDescription field's value.

func (*CreateConnectorInput) SetConnectorName

func (s *CreateConnectorInput) SetConnectorName(v string) *CreateConnectorInput

SetConnectorName sets the ConnectorName field's value.

func (*CreateConnectorInput) SetKafkaCluster

func (s *CreateConnectorInput) SetKafkaCluster(v *KafkaCluster) *CreateConnectorInput

SetKafkaCluster sets the KafkaCluster field's value.

func (*CreateConnectorInput) SetKafkaClusterClientAuthentication

func (s *CreateConnectorInput) SetKafkaClusterClientAuthentication(v *KafkaClusterClientAuthentication) *CreateConnectorInput

SetKafkaClusterClientAuthentication sets the KafkaClusterClientAuthentication field's value.

func (*CreateConnectorInput) SetKafkaClusterEncryptionInTransit

func (s *CreateConnectorInput) SetKafkaClusterEncryptionInTransit(v *KafkaClusterEncryptionInTransit) *CreateConnectorInput

SetKafkaClusterEncryptionInTransit sets the KafkaClusterEncryptionInTransit field's value.

func (*CreateConnectorInput) SetKafkaConnectVersion

func (s *CreateConnectorInput) SetKafkaConnectVersion(v string) *CreateConnectorInput

SetKafkaConnectVersion sets the KafkaConnectVersion field's value.

func (*CreateConnectorInput) SetLogDelivery

func (s *CreateConnectorInput) SetLogDelivery(v *LogDelivery) *CreateConnectorInput

SetLogDelivery sets the LogDelivery field's value.

func (*CreateConnectorInput) SetPlugins

func (s *CreateConnectorInput) SetPlugins(v []*Plugin) *CreateConnectorInput

SetPlugins sets the Plugins field's value.

func (*CreateConnectorInput) SetServiceExecutionRoleArn

func (s *CreateConnectorInput) SetServiceExecutionRoleArn(v string) *CreateConnectorInput

SetServiceExecutionRoleArn sets the ServiceExecutionRoleArn field's value.

func (*CreateConnectorInput) SetWorkerConfiguration

func (s *CreateConnectorInput) SetWorkerConfiguration(v *WorkerConfiguration) *CreateConnectorInput

SetWorkerConfiguration sets the WorkerConfiguration field's value.

func (CreateConnectorInput) String

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 (*CreateConnectorInput) Validate

func (s *CreateConnectorInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateConnectorOutput

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 (CreateConnectorOutput) GoString

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 (*CreateConnectorOutput) SetConnectorArn

func (s *CreateConnectorOutput) SetConnectorArn(v string) *CreateConnectorOutput

SetConnectorArn sets the ConnectorArn field's value.

func (*CreateConnectorOutput) SetConnectorName

func (s *CreateConnectorOutput) SetConnectorName(v string) *CreateConnectorOutput

SetConnectorName sets the ConnectorName field's value.

func (*CreateConnectorOutput) SetConnectorState

func (s *CreateConnectorOutput) SetConnectorState(v string) *CreateConnectorOutput

SetConnectorState sets the ConnectorState field's value.

func (CreateConnectorOutput) String

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

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"`
	// contains filtered or unexported fields
}

func (CreateCustomPluginInput) GoString

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 (*CreateCustomPluginInput) SetContentType

SetContentType sets the ContentType field's value.

func (*CreateCustomPluginInput) SetDescription

SetDescription sets the Description field's value.

func (*CreateCustomPluginInput) SetLocation

SetLocation sets the Location field's value.

func (*CreateCustomPluginInput) SetName

SetName sets the Name field's value.

func (CreateCustomPluginInput) String

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 (*CreateCustomPluginInput) Validate

func (s *CreateCustomPluginInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateCustomPluginOutput

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 (CreateCustomPluginOutput) GoString

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 (*CreateCustomPluginOutput) SetCustomPluginArn

func (s *CreateCustomPluginOutput) SetCustomPluginArn(v string) *CreateCustomPluginOutput

SetCustomPluginArn sets the CustomPluginArn field's value.

func (*CreateCustomPluginOutput) SetCustomPluginState

func (s *CreateCustomPluginOutput) SetCustomPluginState(v string) *CreateCustomPluginOutput

SetCustomPluginState sets the CustomPluginState field's value.

func (*CreateCustomPluginOutput) SetName

SetName sets the Name field's value.

func (*CreateCustomPluginOutput) SetRevision

SetRevision sets the Revision field's value.

func (CreateCustomPluginOutput) String

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

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"`
	// contains filtered or unexported fields
}

func (CreateWorkerConfigurationInput) GoString

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 (*CreateWorkerConfigurationInput) SetDescription

SetDescription sets the Description field's value.

func (*CreateWorkerConfigurationInput) SetName

SetName sets the Name field's value.

func (*CreateWorkerConfigurationInput) SetPropertiesFileContent

SetPropertiesFileContent sets the PropertiesFileContent field's value.

func (CreateWorkerConfigurationInput) 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 (*CreateWorkerConfigurationInput) Validate

func (s *CreateWorkerConfigurationInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CreateWorkerConfigurationOutput

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"`
	// contains filtered or unexported fields
}

func (CreateWorkerConfigurationOutput) GoString

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 (*CreateWorkerConfigurationOutput) SetCreationTime

SetCreationTime sets the CreationTime field's value.

func (*CreateWorkerConfigurationOutput) SetLatestRevision

SetLatestRevision sets the LatestRevision field's value.

func (*CreateWorkerConfigurationOutput) SetName

SetName sets the Name field's value.

func (*CreateWorkerConfigurationOutput) SetWorkerConfigurationArn

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (CreateWorkerConfigurationOutput) 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

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 AWS resource that contains the code that defines a connector's logic.

func (CustomPlugin) GoString

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 (*CustomPlugin) SetCustomPluginArn

func (s *CustomPlugin) SetCustomPluginArn(v string) *CustomPlugin

SetCustomPluginArn sets the CustomPluginArn field's value.

func (*CustomPlugin) SetRevision

func (s *CustomPlugin) SetRevision(v int64) *CustomPlugin

SetRevision sets the Revision field's value.

func (CustomPlugin) String

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 (*CustomPlugin) Validate

func (s *CustomPlugin) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CustomPluginDescription

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 (CustomPluginDescription) GoString

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 (*CustomPluginDescription) SetCustomPluginArn

func (s *CustomPluginDescription) SetCustomPluginArn(v string) *CustomPluginDescription

SetCustomPluginArn sets the CustomPluginArn field's value.

func (*CustomPluginDescription) SetRevision

SetRevision sets the Revision field's value.

func (CustomPluginDescription) String

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

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 (CustomPluginFileDescription) GoString

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 (*CustomPluginFileDescription) SetFileMd5

SetFileMd5 sets the FileMd5 field's value.

func (*CustomPluginFileDescription) SetFileSize

SetFileSize sets the FileSize field's value.

func (CustomPluginFileDescription) 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

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 (CustomPluginLocation) GoString

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 (*CustomPluginLocation) SetS3Location

SetS3Location sets the S3Location field's value.

func (CustomPluginLocation) String

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 (*CustomPluginLocation) Validate

func (s *CustomPluginLocation) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type CustomPluginLocationDescription

type CustomPluginLocationDescription struct {

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

Information about the location of a custom plugin.

func (CustomPluginLocationDescription) GoString

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 (*CustomPluginLocationDescription) SetS3Location

SetS3Location sets the S3Location field's value.

func (CustomPluginLocationDescription) 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

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 (CustomPluginRevisionSummary) GoString

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 (*CustomPluginRevisionSummary) SetContentType

SetContentType sets the ContentType field's value.

func (*CustomPluginRevisionSummary) SetCreationTime

SetCreationTime sets the CreationTime field's value.

func (*CustomPluginRevisionSummary) SetDescription

SetDescription sets the Description field's value.

func (*CustomPluginRevisionSummary) SetFileDescription

SetFileDescription sets the FileDescription field's value.

func (*CustomPluginRevisionSummary) SetLocation

SetLocation sets the Location field's value.

func (*CustomPluginRevisionSummary) SetRevision

SetRevision sets the Revision field's value.

func (CustomPluginRevisionSummary) 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

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 (CustomPluginSummary) GoString

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 (*CustomPluginSummary) SetCreationTime

func (s *CustomPluginSummary) SetCreationTime(v time.Time) *CustomPluginSummary

SetCreationTime sets the CreationTime field's value.

func (*CustomPluginSummary) SetCustomPluginArn

func (s *CustomPluginSummary) SetCustomPluginArn(v string) *CustomPluginSummary

SetCustomPluginArn sets the CustomPluginArn field's value.

func (*CustomPluginSummary) SetCustomPluginState

func (s *CustomPluginSummary) SetCustomPluginState(v string) *CustomPluginSummary

SetCustomPluginState sets the CustomPluginState field's value.

func (*CustomPluginSummary) SetDescription

func (s *CustomPluginSummary) SetDescription(v string) *CustomPluginSummary

SetDescription sets the Description field's value.

func (*CustomPluginSummary) SetLatestRevision

SetLatestRevision sets the LatestRevision field's value.

func (*CustomPluginSummary) SetName

SetName sets the Name field's value.

func (CustomPluginSummary) String

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

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 (DeleteConnectorInput) GoString

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 (*DeleteConnectorInput) SetConnectorArn

func (s *DeleteConnectorInput) SetConnectorArn(v string) *DeleteConnectorInput

SetConnectorArn sets the ConnectorArn field's value.

func (*DeleteConnectorInput) SetCurrentVersion

func (s *DeleteConnectorInput) SetCurrentVersion(v string) *DeleteConnectorInput

SetCurrentVersion sets the CurrentVersion field's value.

func (DeleteConnectorInput) String

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 (*DeleteConnectorInput) Validate

func (s *DeleteConnectorInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteConnectorOutput

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 (DeleteConnectorOutput) GoString

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 (*DeleteConnectorOutput) SetConnectorArn

func (s *DeleteConnectorOutput) SetConnectorArn(v string) *DeleteConnectorOutput

SetConnectorArn sets the ConnectorArn field's value.

func (*DeleteConnectorOutput) SetConnectorState

func (s *DeleteConnectorOutput) SetConnectorState(v string) *DeleteConnectorOutput

SetConnectorState sets the ConnectorState field's value.

func (DeleteConnectorOutput) String

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

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 (DeleteCustomPluginInput) GoString

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 (*DeleteCustomPluginInput) SetCustomPluginArn

func (s *DeleteCustomPluginInput) SetCustomPluginArn(v string) *DeleteCustomPluginInput

SetCustomPluginArn sets the CustomPluginArn field's value.

func (DeleteCustomPluginInput) String

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 (*DeleteCustomPluginInput) Validate

func (s *DeleteCustomPluginInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DeleteCustomPluginOutput

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 (DeleteCustomPluginOutput) GoString

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 (*DeleteCustomPluginOutput) SetCustomPluginArn

func (s *DeleteCustomPluginOutput) SetCustomPluginArn(v string) *DeleteCustomPluginOutput

SetCustomPluginArn sets the CustomPluginArn field's value.

func (*DeleteCustomPluginOutput) SetCustomPluginState

func (s *DeleteCustomPluginOutput) SetCustomPluginState(v string) *DeleteCustomPluginOutput

SetCustomPluginState sets the CustomPluginState field's value.

func (DeleteCustomPluginOutput) String

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 DescribeConnectorInput

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 (DescribeConnectorInput) GoString

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 (*DescribeConnectorInput) SetConnectorArn

func (s *DescribeConnectorInput) SetConnectorArn(v string) *DescribeConnectorInput

SetConnectorArn sets the ConnectorArn field's value.

func (DescribeConnectorInput) String

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 (*DescribeConnectorInput) Validate

func (s *DescribeConnectorInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeConnectorOutput

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 (DescribeConnectorOutput) GoString

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 (*DescribeConnectorOutput) SetCapacity

SetCapacity sets the Capacity field's value.

func (*DescribeConnectorOutput) SetConnectorArn

SetConnectorArn sets the ConnectorArn field's value.

func (*DescribeConnectorOutput) SetConnectorConfiguration

func (s *DescribeConnectorOutput) SetConnectorConfiguration(v map[string]*string) *DescribeConnectorOutput

SetConnectorConfiguration sets the ConnectorConfiguration field's value.

func (*DescribeConnectorOutput) SetConnectorDescription

func (s *DescribeConnectorOutput) SetConnectorDescription(v string) *DescribeConnectorOutput

SetConnectorDescription sets the ConnectorDescription field's value.

func (*DescribeConnectorOutput) SetConnectorName

func (s *DescribeConnectorOutput) SetConnectorName(v string) *DescribeConnectorOutput

SetConnectorName sets the ConnectorName field's value.

func (*DescribeConnectorOutput) SetConnectorState

func (s *DescribeConnectorOutput) SetConnectorState(v string) *DescribeConnectorOutput

SetConnectorState sets the ConnectorState field's value.

func (*DescribeConnectorOutput) SetCreationTime

SetCreationTime sets the CreationTime field's value.

func (*DescribeConnectorOutput) SetCurrentVersion

func (s *DescribeConnectorOutput) SetCurrentVersion(v string) *DescribeConnectorOutput

SetCurrentVersion sets the CurrentVersion field's value.

func (*DescribeConnectorOutput) SetKafkaCluster

SetKafkaCluster sets the KafkaCluster field's value.

func (*DescribeConnectorOutput) SetKafkaClusterClientAuthentication

SetKafkaClusterClientAuthentication sets the KafkaClusterClientAuthentication field's value.

func (*DescribeConnectorOutput) SetKafkaClusterEncryptionInTransit

SetKafkaClusterEncryptionInTransit sets the KafkaClusterEncryptionInTransit field's value.

func (*DescribeConnectorOutput) SetKafkaConnectVersion

func (s *DescribeConnectorOutput) SetKafkaConnectVersion(v string) *DescribeConnectorOutput

SetKafkaConnectVersion sets the KafkaConnectVersion field's value.

func (*DescribeConnectorOutput) SetLogDelivery

SetLogDelivery sets the LogDelivery field's value.

func (*DescribeConnectorOutput) SetPlugins

SetPlugins sets the Plugins field's value.

func (*DescribeConnectorOutput) SetServiceExecutionRoleArn

func (s *DescribeConnectorOutput) SetServiceExecutionRoleArn(v string) *DescribeConnectorOutput

SetServiceExecutionRoleArn sets the ServiceExecutionRoleArn field's value.

func (*DescribeConnectorOutput) SetStateDescription

SetStateDescription sets the StateDescription field's value.

func (*DescribeConnectorOutput) SetWorkerConfiguration

SetWorkerConfiguration sets the WorkerConfiguration field's value.

func (DescribeConnectorOutput) String

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

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 (DescribeCustomPluginInput) GoString

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 (*DescribeCustomPluginInput) SetCustomPluginArn

SetCustomPluginArn sets the CustomPluginArn field's value.

func (DescribeCustomPluginInput) String

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 (*DescribeCustomPluginInput) Validate

func (s *DescribeCustomPluginInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeCustomPluginOutput

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 (DescribeCustomPluginOutput) GoString

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 (*DescribeCustomPluginOutput) SetCreationTime

SetCreationTime sets the CreationTime field's value.

func (*DescribeCustomPluginOutput) SetCustomPluginArn

SetCustomPluginArn sets the CustomPluginArn field's value.

func (*DescribeCustomPluginOutput) SetCustomPluginState

func (s *DescribeCustomPluginOutput) SetCustomPluginState(v string) *DescribeCustomPluginOutput

SetCustomPluginState sets the CustomPluginState field's value.

func (*DescribeCustomPluginOutput) SetDescription

SetDescription sets the Description field's value.

func (*DescribeCustomPluginOutput) SetLatestRevision

SetLatestRevision sets the LatestRevision field's value.

func (*DescribeCustomPluginOutput) SetName

SetName sets the Name field's value.

func (*DescribeCustomPluginOutput) SetStateDescription

SetStateDescription sets the StateDescription field's value.

func (DescribeCustomPluginOutput) 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

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 (DescribeWorkerConfigurationInput) GoString

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 (*DescribeWorkerConfigurationInput) SetWorkerConfigurationArn

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (DescribeWorkerConfigurationInput) 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 (*DescribeWorkerConfigurationInput) Validate

Validate inspects the fields of the type to determine if they are valid.

type DescribeWorkerConfigurationOutput

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"`
	// contains filtered or unexported fields
}

func (DescribeWorkerConfigurationOutput) GoString

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 (*DescribeWorkerConfigurationOutput) SetCreationTime

SetCreationTime sets the CreationTime field's value.

func (*DescribeWorkerConfigurationOutput) SetDescription

SetDescription sets the Description field's value.

func (*DescribeWorkerConfigurationOutput) SetLatestRevision

SetLatestRevision sets the LatestRevision field's value.

func (*DescribeWorkerConfigurationOutput) SetName

SetName sets the Name field's value.

func (*DescribeWorkerConfigurationOutput) SetWorkerConfigurationArn

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (DescribeWorkerConfigurationOutput) 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

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 (FirehoseLogDelivery) GoString

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 (*FirehoseLogDelivery) SetDeliveryStream

func (s *FirehoseLogDelivery) SetDeliveryStream(v string) *FirehoseLogDelivery

SetDeliveryStream sets the DeliveryStream field's value.

func (*FirehoseLogDelivery) SetEnabled

func (s *FirehoseLogDelivery) SetEnabled(v bool) *FirehoseLogDelivery

SetEnabled sets the Enabled field's value.

func (FirehoseLogDelivery) String

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 (*FirehoseLogDelivery) Validate

func (s *FirehoseLogDelivery) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type FirehoseLogDeliveryDescription

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 (FirehoseLogDeliveryDescription) GoString

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 (*FirehoseLogDeliveryDescription) SetDeliveryStream

SetDeliveryStream sets the DeliveryStream field's value.

func (*FirehoseLogDeliveryDescription) SetEnabled

SetEnabled sets the Enabled field's value.

func (FirehoseLogDeliveryDescription) 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

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 (*ForbiddenException) Code

func (s *ForbiddenException) Code() string

Code returns the exception type name.

func (*ForbiddenException) Error

func (s *ForbiddenException) Error() string

func (ForbiddenException) GoString

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 (*ForbiddenException) Message

func (s *ForbiddenException) Message() string

Message returns the exception's message.

func (*ForbiddenException) OrigErr

func (s *ForbiddenException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ForbiddenException) RequestID

func (s *ForbiddenException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ForbiddenException) StatusCode

func (s *ForbiddenException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ForbiddenException) String

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

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 (*InternalServerErrorException) Code

Code returns the exception type name.

func (*InternalServerErrorException) Error

func (InternalServerErrorException) GoString

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 (*InternalServerErrorException) Message

func (s *InternalServerErrorException) Message() string

Message returns the exception's message.

func (*InternalServerErrorException) OrigErr

func (s *InternalServerErrorException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*InternalServerErrorException) RequestID

func (s *InternalServerErrorException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*InternalServerErrorException) StatusCode

func (s *InternalServerErrorException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (InternalServerErrorException) 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

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 (KafkaCluster) GoString

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 (*KafkaCluster) SetApacheKafkaCluster

func (s *KafkaCluster) SetApacheKafkaCluster(v *ApacheKafkaCluster) *KafkaCluster

SetApacheKafkaCluster sets the ApacheKafkaCluster field's value.

func (KafkaCluster) String

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 (*KafkaCluster) Validate

func (s *KafkaCluster) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type KafkaClusterClientAuthentication

type KafkaClusterClientAuthentication struct {

	// The type of client authentication used to connect to the Apache Kafka cluster.
	// Value NONE means that no client authentication is used.
	//
	// 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 (KafkaClusterClientAuthentication) GoString

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 (*KafkaClusterClientAuthentication) SetAuthenticationType

SetAuthenticationType sets the AuthenticationType field's value.

func (KafkaClusterClientAuthentication) 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 (*KafkaClusterClientAuthentication) Validate

Validate inspects the fields of the type to determine if they are valid.

type KafkaClusterClientAuthenticationDescription

type KafkaClusterClientAuthenticationDescription struct {

	// The type of client authentication used to connect to the Apache Kafka cluster.
	// Value NONE means that no client authentication is used.
	AuthenticationType *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 (KafkaClusterClientAuthenticationDescription) GoString

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 (*KafkaClusterClientAuthenticationDescription) SetAuthenticationType

SetAuthenticationType sets the AuthenticationType field's value.

func (KafkaClusterClientAuthenticationDescription) 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

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 (KafkaClusterDescription) GoString

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 (*KafkaClusterDescription) SetApacheKafkaCluster

SetApacheKafkaCluster sets the ApacheKafkaCluster field's value.

func (KafkaClusterDescription) String

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

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 (KafkaClusterEncryptionInTransit) GoString

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 (*KafkaClusterEncryptionInTransit) SetEncryptionType

SetEncryptionType sets the EncryptionType field's value.

func (KafkaClusterEncryptionInTransit) 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 (*KafkaClusterEncryptionInTransit) Validate

func (s *KafkaClusterEncryptionInTransit) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type KafkaClusterEncryptionInTransitDescription

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 (KafkaClusterEncryptionInTransitDescription) GoString

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 (*KafkaClusterEncryptionInTransitDescription) SetEncryptionType

SetEncryptionType sets the EncryptionType field's value.

func (KafkaClusterEncryptionInTransitDescription) 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

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

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 (*KafkaConnect) CreateConnector

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 (*KafkaConnect) CreateConnectorRequest

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 (*KafkaConnect) CreateConnectorWithContext

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 (*KafkaConnect) CreateCustomPlugin

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 (*KafkaConnect) CreateCustomPluginRequest

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 (*KafkaConnect) CreateCustomPluginWithContext

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 (*KafkaConnect) CreateWorkerConfiguration

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 (*KafkaConnect) CreateWorkerConfigurationRequest

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 (*KafkaConnect) CreateWorkerConfigurationWithContext

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 (*KafkaConnect) DeleteConnector

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 (*KafkaConnect) DeleteConnectorRequest

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 (*KafkaConnect) DeleteConnectorWithContext

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 (*KafkaConnect) DeleteCustomPlugin

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 (*KafkaConnect) DeleteCustomPluginRequest

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 (*KafkaConnect) DeleteCustomPluginWithContext

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 (*KafkaConnect) DescribeConnector

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 (*KafkaConnect) DescribeConnectorRequest

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 (*KafkaConnect) DescribeConnectorWithContext

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 (*KafkaConnect) DescribeCustomPlugin

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 (*KafkaConnect) DescribeCustomPluginRequest

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 (*KafkaConnect) DescribeCustomPluginWithContext

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 (*KafkaConnect) DescribeWorkerConfiguration

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 (*KafkaConnect) DescribeWorkerConfigurationRequest

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 (*KafkaConnect) DescribeWorkerConfigurationWithContext

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 (*KafkaConnect) ListConnectors

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 (*KafkaConnect) ListConnectorsPages

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 (*KafkaConnect) ListConnectorsPagesWithContext

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 (*KafkaConnect) ListConnectorsRequest

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 (*KafkaConnect) ListConnectorsWithContext

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 (*KafkaConnect) ListCustomPlugins

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 (*KafkaConnect) ListCustomPluginsPages

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 (*KafkaConnect) ListCustomPluginsPagesWithContext

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 (*KafkaConnect) ListCustomPluginsRequest

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 (*KafkaConnect) ListCustomPluginsWithContext

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 (*KafkaConnect) ListWorkerConfigurations

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 (*KafkaConnect) ListWorkerConfigurationsPages

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 (*KafkaConnect) ListWorkerConfigurationsPagesWithContext

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 (*KafkaConnect) ListWorkerConfigurationsRequest

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 (*KafkaConnect) ListWorkerConfigurationsWithContext

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 (*KafkaConnect) UpdateConnector

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 (*KafkaConnect) UpdateConnectorRequest

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 (*KafkaConnect) UpdateConnectorWithContext

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

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 (ListConnectorsInput) GoString

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 (*ListConnectorsInput) SetConnectorNamePrefix

func (s *ListConnectorsInput) SetConnectorNamePrefix(v string) *ListConnectorsInput

SetConnectorNamePrefix sets the ConnectorNamePrefix field's value.

func (*ListConnectorsInput) SetMaxResults

func (s *ListConnectorsInput) SetMaxResults(v int64) *ListConnectorsInput

SetMaxResults sets the MaxResults field's value.

func (*ListConnectorsInput) SetNextToken

func (s *ListConnectorsInput) SetNextToken(v string) *ListConnectorsInput

SetNextToken sets the NextToken field's value.

func (ListConnectorsInput) String

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 (*ListConnectorsInput) Validate

func (s *ListConnectorsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListConnectorsOutput

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 (ListConnectorsOutput) GoString

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 (*ListConnectorsOutput) SetConnectors

SetConnectors sets the Connectors field's value.

func (*ListConnectorsOutput) SetNextToken

func (s *ListConnectorsOutput) SetNextToken(v string) *ListConnectorsOutput

SetNextToken sets the NextToken field's value.

func (ListConnectorsOutput) String

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

type ListCustomPluginsInput struct {

	// The maximum number of custom plugins to list in one response.
	MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

	// 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 (ListCustomPluginsInput) GoString

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 (*ListCustomPluginsInput) SetMaxResults

SetMaxResults sets the MaxResults field's value.

func (*ListCustomPluginsInput) SetNextToken

SetNextToken sets the NextToken field's value.

func (ListCustomPluginsInput) String

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 (*ListCustomPluginsInput) Validate

func (s *ListCustomPluginsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListCustomPluginsOutput

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 (ListCustomPluginsOutput) GoString

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 (*ListCustomPluginsOutput) SetCustomPlugins

SetCustomPlugins sets the CustomPlugins field's value.

func (*ListCustomPluginsOutput) SetNextToken

SetNextToken sets the NextToken field's value.

func (ListCustomPluginsOutput) String

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 ListWorkerConfigurationsInput

type ListWorkerConfigurationsInput struct {

	// The maximum number of worker configurations to list in one response.
	MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

	// 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 (ListWorkerConfigurationsInput) GoString

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 (*ListWorkerConfigurationsInput) SetMaxResults

SetMaxResults sets the MaxResults field's value.

func (*ListWorkerConfigurationsInput) SetNextToken

SetNextToken sets the NextToken field's value.

func (ListWorkerConfigurationsInput) 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 (*ListWorkerConfigurationsInput) Validate

func (s *ListWorkerConfigurationsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ListWorkerConfigurationsOutput

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 (ListWorkerConfigurationsOutput) GoString

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 (*ListWorkerConfigurationsOutput) SetNextToken

SetNextToken sets the NextToken field's value.

func (*ListWorkerConfigurationsOutput) SetWorkerConfigurations

SetWorkerConfigurations sets the WorkerConfigurations field's value.

func (ListWorkerConfigurationsOutput) 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

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 (LogDelivery) GoString

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 (*LogDelivery) SetWorkerLogDelivery

func (s *LogDelivery) SetWorkerLogDelivery(v *WorkerLogDelivery) *LogDelivery

SetWorkerLogDelivery sets the WorkerLogDelivery field's value.

func (LogDelivery) String

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 (*LogDelivery) Validate

func (s *LogDelivery) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type LogDeliveryDescription

type LogDeliveryDescription struct {

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

The description of the log delivery settings.

func (LogDeliveryDescription) GoString

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 (*LogDeliveryDescription) SetWorkerLogDelivery

SetWorkerLogDelivery sets the WorkerLogDelivery field's value.

func (LogDeliveryDescription) String

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

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 (*NotFoundException) Code

func (s *NotFoundException) Code() string

Code returns the exception type name.

func (*NotFoundException) Error

func (s *NotFoundException) Error() string

func (NotFoundException) GoString

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 (*NotFoundException) Message

func (s *NotFoundException) Message() string

Message returns the exception's message.

func (*NotFoundException) OrigErr

func (s *NotFoundException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*NotFoundException) RequestID

func (s *NotFoundException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*NotFoundException) StatusCode

func (s *NotFoundException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (NotFoundException) String

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

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 AWS resource that contains the code that defines your connector logic.

func (Plugin) GoString

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 (*Plugin) SetCustomPlugin

func (s *Plugin) SetCustomPlugin(v *CustomPlugin) *Plugin

SetCustomPlugin sets the CustomPlugin field's value.

func (Plugin) String

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 (*Plugin) Validate

func (s *Plugin) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type PluginDescription

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 (PluginDescription) GoString

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 (*PluginDescription) SetCustomPlugin

SetCustomPlugin sets the CustomPlugin field's value.

func (PluginDescription) String

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

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 (ProvisionedCapacity) GoString

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 (*ProvisionedCapacity) SetMcuCount

func (s *ProvisionedCapacity) SetMcuCount(v int64) *ProvisionedCapacity

SetMcuCount sets the McuCount field's value.

func (*ProvisionedCapacity) SetWorkerCount

func (s *ProvisionedCapacity) SetWorkerCount(v int64) *ProvisionedCapacity

SetWorkerCount sets the WorkerCount field's value.

func (ProvisionedCapacity) String

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 (*ProvisionedCapacity) Validate

func (s *ProvisionedCapacity) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ProvisionedCapacityDescription

type ProvisionedCapacityDescription struct {

	// The number of microcontroller units (MCUs) allocated to each connector worker.
	// The valid values are 1,2,4,8.
	McuCount *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 (ProvisionedCapacityDescription) GoString

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 (*ProvisionedCapacityDescription) SetMcuCount

SetMcuCount sets the McuCount field's value.

func (*ProvisionedCapacityDescription) SetWorkerCount

SetWorkerCount sets the WorkerCount field's value.

func (ProvisionedCapacityDescription) 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

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 (ProvisionedCapacityUpdate) GoString

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 (*ProvisionedCapacityUpdate) SetMcuCount

SetMcuCount sets the McuCount field's value.

func (*ProvisionedCapacityUpdate) SetWorkerCount

SetWorkerCount sets the WorkerCount field's value.

func (ProvisionedCapacityUpdate) String

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 (*ProvisionedCapacityUpdate) Validate

func (s *ProvisionedCapacityUpdate) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type S3Location

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 (S3Location) GoString

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 (*S3Location) SetBucketArn

func (s *S3Location) SetBucketArn(v string) *S3Location

SetBucketArn sets the BucketArn field's value.

func (*S3Location) SetFileKey

func (s *S3Location) SetFileKey(v string) *S3Location

SetFileKey sets the FileKey field's value.

func (*S3Location) SetObjectVersion

func (s *S3Location) SetObjectVersion(v string) *S3Location

SetObjectVersion sets the ObjectVersion field's value.

func (S3Location) String

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 (*S3Location) Validate

func (s *S3Location) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type S3LocationDescription

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 (S3LocationDescription) GoString

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 (*S3LocationDescription) SetBucketArn

SetBucketArn sets the BucketArn field's value.

func (*S3LocationDescription) SetFileKey

SetFileKey sets the FileKey field's value.

func (*S3LocationDescription) SetObjectVersion

func (s *S3LocationDescription) SetObjectVersion(v string) *S3LocationDescription

SetObjectVersion sets the ObjectVersion field's value.

func (S3LocationDescription) String

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

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 (S3LogDelivery) GoString

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 (*S3LogDelivery) SetBucket

func (s *S3LogDelivery) SetBucket(v string) *S3LogDelivery

SetBucket sets the Bucket field's value.

func (*S3LogDelivery) SetEnabled

func (s *S3LogDelivery) SetEnabled(v bool) *S3LogDelivery

SetEnabled sets the Enabled field's value.

func (*S3LogDelivery) SetPrefix

func (s *S3LogDelivery) SetPrefix(v string) *S3LogDelivery

SetPrefix sets the Prefix field's value.

func (S3LogDelivery) String

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 (*S3LogDelivery) Validate

func (s *S3LogDelivery) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type S3LogDeliveryDescription

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 (S3LogDeliveryDescription) GoString

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 (*S3LogDeliveryDescription) SetBucket

SetBucket sets the Bucket field's value.

func (*S3LogDeliveryDescription) SetEnabled

SetEnabled sets the Enabled field's value.

func (*S3LogDeliveryDescription) SetPrefix

SetPrefix sets the Prefix field's value.

func (S3LogDeliveryDescription) String

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

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 (ScaleInPolicy) GoString

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 (*ScaleInPolicy) SetCpuUtilizationPercentage

func (s *ScaleInPolicy) SetCpuUtilizationPercentage(v int64) *ScaleInPolicy

SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.

func (ScaleInPolicy) String

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 (*ScaleInPolicy) Validate

func (s *ScaleInPolicy) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ScaleInPolicyDescription

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 (ScaleInPolicyDescription) GoString

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 (*ScaleInPolicyDescription) SetCpuUtilizationPercentage

func (s *ScaleInPolicyDescription) SetCpuUtilizationPercentage(v int64) *ScaleInPolicyDescription

SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.

func (ScaleInPolicyDescription) String

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

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 (ScaleInPolicyUpdate) GoString

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 (*ScaleInPolicyUpdate) SetCpuUtilizationPercentage

func (s *ScaleInPolicyUpdate) SetCpuUtilizationPercentage(v int64) *ScaleInPolicyUpdate

SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.

func (ScaleInPolicyUpdate) String

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 (*ScaleInPolicyUpdate) Validate

func (s *ScaleInPolicyUpdate) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ScaleOutPolicy

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 (ScaleOutPolicy) GoString

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 (*ScaleOutPolicy) SetCpuUtilizationPercentage

func (s *ScaleOutPolicy) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicy

SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.

func (ScaleOutPolicy) String

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 (*ScaleOutPolicy) Validate

func (s *ScaleOutPolicy) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ScaleOutPolicyDescription

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 (ScaleOutPolicyDescription) GoString

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 (*ScaleOutPolicyDescription) SetCpuUtilizationPercentage

func (s *ScaleOutPolicyDescription) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicyDescription

SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.

func (ScaleOutPolicyDescription) String

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

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 (ScaleOutPolicyUpdate) GoString

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 (*ScaleOutPolicyUpdate) SetCpuUtilizationPercentage

func (s *ScaleOutPolicyUpdate) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicyUpdate

SetCpuUtilizationPercentage sets the CpuUtilizationPercentage field's value.

func (ScaleOutPolicyUpdate) String

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 (*ScaleOutPolicyUpdate) Validate

func (s *ScaleOutPolicyUpdate) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type ServiceUnavailableException

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 (*ServiceUnavailableException) Code

Code returns the exception type name.

func (*ServiceUnavailableException) Error

func (ServiceUnavailableException) GoString

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 (*ServiceUnavailableException) Message

func (s *ServiceUnavailableException) Message() string

Message returns the exception's message.

func (*ServiceUnavailableException) OrigErr

func (s *ServiceUnavailableException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*ServiceUnavailableException) RequestID

func (s *ServiceUnavailableException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*ServiceUnavailableException) StatusCode

func (s *ServiceUnavailableException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (ServiceUnavailableException) 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

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 (StateDescription) GoString

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 (*StateDescription) SetCode

func (s *StateDescription) SetCode(v string) *StateDescription

SetCode sets the Code field's value.

func (*StateDescription) SetMessage

func (s *StateDescription) SetMessage(v string) *StateDescription

SetMessage sets the Message field's value.

func (StateDescription) String

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 TooManyRequestsException

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 (*TooManyRequestsException) Code

func (s *TooManyRequestsException) Code() string

Code returns the exception type name.

func (*TooManyRequestsException) Error

func (s *TooManyRequestsException) Error() string

func (TooManyRequestsException) GoString

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 (*TooManyRequestsException) Message

func (s *TooManyRequestsException) Message() string

Message returns the exception's message.

func (*TooManyRequestsException) OrigErr

func (s *TooManyRequestsException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*TooManyRequestsException) RequestID

func (s *TooManyRequestsException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*TooManyRequestsException) StatusCode

func (s *TooManyRequestsException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (TooManyRequestsException) String

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

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 (*UnauthorizedException) Code

func (s *UnauthorizedException) Code() string

Code returns the exception type name.

func (*UnauthorizedException) Error

func (s *UnauthorizedException) Error() string

func (UnauthorizedException) GoString

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 (*UnauthorizedException) Message

func (s *UnauthorizedException) Message() string

Message returns the exception's message.

func (*UnauthorizedException) OrigErr

func (s *UnauthorizedException) OrigErr() error

OrigErr always returns nil, satisfies awserr.Error interface.

func (*UnauthorizedException) RequestID

func (s *UnauthorizedException) RequestID() string

RequestID returns the service's response RequestID for request.

func (*UnauthorizedException) StatusCode

func (s *UnauthorizedException) StatusCode() int

Status code returns the HTTP status code for the request's response error.

func (UnauthorizedException) String

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 UpdateConnectorInput

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 (UpdateConnectorInput) GoString

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 (*UpdateConnectorInput) SetCapacity

SetCapacity sets the Capacity field's value.

func (*UpdateConnectorInput) SetConnectorArn

func (s *UpdateConnectorInput) SetConnectorArn(v string) *UpdateConnectorInput

SetConnectorArn sets the ConnectorArn field's value.

func (*UpdateConnectorInput) SetCurrentVersion

func (s *UpdateConnectorInput) SetCurrentVersion(v string) *UpdateConnectorInput

SetCurrentVersion sets the CurrentVersion field's value.

func (UpdateConnectorInput) String

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 (*UpdateConnectorInput) Validate

func (s *UpdateConnectorInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdateConnectorOutput

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 (UpdateConnectorOutput) GoString

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 (*UpdateConnectorOutput) SetConnectorArn

func (s *UpdateConnectorOutput) SetConnectorArn(v string) *UpdateConnectorOutput

SetConnectorArn sets the ConnectorArn field's value.

func (*UpdateConnectorOutput) SetConnectorState

func (s *UpdateConnectorOutput) SetConnectorState(v string) *UpdateConnectorOutput

SetConnectorState sets the ConnectorState field's value.

func (UpdateConnectorOutput) String

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

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 (Vpc) GoString

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 (*Vpc) SetSecurityGroups

func (s *Vpc) SetSecurityGroups(v []*string) *Vpc

SetSecurityGroups sets the SecurityGroups field's value.

func (*Vpc) SetSubnets

func (s *Vpc) SetSubnets(v []*string) *Vpc

SetSubnets sets the Subnets field's value.

func (Vpc) String

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 (*Vpc) Validate

func (s *Vpc) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type VpcDescription

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 (VpcDescription) GoString

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 (*VpcDescription) SetSecurityGroups

func (s *VpcDescription) SetSecurityGroups(v []*string) *VpcDescription

SetSecurityGroups sets the SecurityGroups field's value.

func (*VpcDescription) SetSubnets

func (s *VpcDescription) SetSubnets(v []*string) *VpcDescription

SetSubnets sets the Subnets field's value.

func (VpcDescription) String

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

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 (WorkerConfiguration) GoString

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 (*WorkerConfiguration) SetRevision

func (s *WorkerConfiguration) SetRevision(v int64) *WorkerConfiguration

SetRevision sets the Revision field's value.

func (*WorkerConfiguration) SetWorkerConfigurationArn

func (s *WorkerConfiguration) SetWorkerConfigurationArn(v string) *WorkerConfiguration

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (WorkerConfiguration) String

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 (*WorkerConfiguration) Validate

func (s *WorkerConfiguration) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type WorkerConfigurationDescription

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 (WorkerConfigurationDescription) GoString

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 (*WorkerConfigurationDescription) SetRevision

SetRevision sets the Revision field's value.

func (*WorkerConfigurationDescription) SetWorkerConfigurationArn

func (s *WorkerConfigurationDescription) SetWorkerConfigurationArn(v string) *WorkerConfigurationDescription

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (WorkerConfigurationDescription) 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

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 (WorkerConfigurationRevisionDescription) GoString

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 (*WorkerConfigurationRevisionDescription) SetCreationTime

SetCreationTime sets the CreationTime field's value.

func (*WorkerConfigurationRevisionDescription) SetDescription

SetDescription sets the Description field's value.

func (*WorkerConfigurationRevisionDescription) SetPropertiesFileContent

SetPropertiesFileContent sets the PropertiesFileContent field's value.

func (*WorkerConfigurationRevisionDescription) SetRevision

SetRevision sets the Revision field's value.

func (WorkerConfigurationRevisionDescription) 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

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 (WorkerConfigurationRevisionSummary) GoString

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 (*WorkerConfigurationRevisionSummary) SetCreationTime

SetCreationTime sets the CreationTime field's value.

func (*WorkerConfigurationRevisionSummary) SetDescription

SetDescription sets the Description field's value.

func (*WorkerConfigurationRevisionSummary) SetRevision

SetRevision sets the Revision field's value.

func (WorkerConfigurationRevisionSummary) 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

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"`
	// contains filtered or unexported fields
}

The summary of a worker configuration.

func (WorkerConfigurationSummary) GoString

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 (*WorkerConfigurationSummary) SetCreationTime

SetCreationTime sets the CreationTime field's value.

func (*WorkerConfigurationSummary) SetDescription

SetDescription sets the Description field's value.

func (*WorkerConfigurationSummary) SetLatestRevision

SetLatestRevision sets the LatestRevision field's value.

func (*WorkerConfigurationSummary) SetName

SetName sets the Name field's value.

func (*WorkerConfigurationSummary) SetWorkerConfigurationArn

func (s *WorkerConfigurationSummary) SetWorkerConfigurationArn(v string) *WorkerConfigurationSummary

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (WorkerConfigurationSummary) 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

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 (WorkerLogDelivery) GoString

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 (*WorkerLogDelivery) SetCloudWatchLogs

SetCloudWatchLogs sets the CloudWatchLogs field's value.

func (*WorkerLogDelivery) SetFirehose

SetFirehose sets the Firehose field's value.

func (*WorkerLogDelivery) SetS3

SetS3 sets the S3 field's value.

func (WorkerLogDelivery) String

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 (*WorkerLogDelivery) Validate

func (s *WorkerLogDelivery) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type WorkerLogDeliveryDescription

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 (WorkerLogDeliveryDescription) GoString

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 (*WorkerLogDeliveryDescription) SetCloudWatchLogs

SetCloudWatchLogs sets the CloudWatchLogs field's value.

func (*WorkerLogDeliveryDescription) SetFirehose

SetFirehose sets the Firehose field's value.

func (*WorkerLogDeliveryDescription) SetS3

SetS3 sets the S3 field's value.

func (WorkerLogDeliveryDescription) 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".

Directories

Path Synopsis
Package kafkaconnectiface provides an interface to enable mocking the Managed Streaming for Kafka Connect service client for testing your code.
Package kafkaconnectiface provides an interface to enable mocking the Managed Streaming for Kafka Connect service client for testing your code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL