kafkaconnect

package
v1.42.45 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2022 License: Apache-2.0 Imports: 10 Imported by: 16

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 

func (s ApacheKafkaClusterDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ApacheKafkaClusterDescription) SetBootstrapServers 

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

SetBootstrapServers sets the BootstrapServers field's value.

func (*ApacheKafkaClusterDescription) SetVpc 

func (s *ApacheKafkaClusterDescription) SetVpc(v *VpcDescription) *ApacheKafkaClusterDescription

SetVpc sets the Vpc field's value.

func (ApacheKafkaClusterDescription) String 

func (s ApacheKafkaClusterDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type AutoScaling 

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 

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

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 

func (s *AutoScalingDescription) SetScaleInPolicy(v *ScaleInPolicyDescription) *AutoScalingDescription

SetScaleInPolicy sets the ScaleInPolicy field's value.

func (*AutoScalingDescription) SetScaleOutPolicy 

func (s *AutoScalingDescription) SetScaleOutPolicy(v *ScaleOutPolicyDescription) *AutoScalingDescription

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 

func (s *CapacityDescription) SetAutoScaling(v *AutoScalingDescription) *CapacityDescription

SetAutoScaling sets the AutoScaling field's value.

func (*CapacityDescription) SetProvisionedCapacity 

func (s *CapacityDescription) SetProvisionedCapacity(v *ProvisionedCapacityDescription) *CapacityDescription

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 

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

SetEnabled sets the Enabled field's value.

func (*CloudWatchLogsLogDelivery) SetLogGroup 

func (s *CloudWatchLogsLogDelivery) SetLogGroup(v string) *CloudWatchLogsLogDelivery

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 

func (s CloudWatchLogsLogDeliveryDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CloudWatchLogsLogDeliveryDescription) SetEnabled 

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

SetEnabled sets the Enabled field's value.

func (*CloudWatchLogsLogDeliveryDescription) SetLogGroup 

func (s *CloudWatchLogsLogDeliveryDescription) SetLogGroup(v string) *CloudWatchLogsLogDeliveryDescription

SetLogGroup sets the LogGroup field's value.

func (CloudWatchLogsLogDeliveryDescription) String 

func (s CloudWatchLogsLogDeliveryDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ConflictException 

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 

func (s *ConnectorSummary) SetCapacity(v *CapacityDescription) *ConnectorSummary

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 

func (s *ConnectorSummary) SetKafkaCluster(v *KafkaClusterDescription) *ConnectorSummary

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 

func (s *ConnectorSummary) SetLogDelivery(v *LogDeliveryDescription) *ConnectorSummary

SetLogDelivery sets the LogDelivery field's value.

func (*ConnectorSummary) SetPlugins 

func (s *ConnectorSummary) SetPlugins(v []*PluginDescription) *ConnectorSummary

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 required field
	ConnectorConfiguration map[string]*string `locationName:"connectorConfiguration" type:"map" required:"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 

func (s *CreateConnectorInput) SetCapacity(v *Capacity) *CreateConnectorInput

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 

func (s *CreateCustomPluginInput) SetContentType(v string) *CreateCustomPluginInput

SetContentType sets the ContentType field's value.

func (*CreateCustomPluginInput) SetDescription 

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

SetDescription sets the Description field's value.

func (*CreateCustomPluginInput) SetLocation 

func (s *CreateCustomPluginInput) SetLocation(v *CustomPluginLocation) *CreateCustomPluginInput

SetLocation sets the Location field's value.

func (*CreateCustomPluginInput) SetName 

func (s *CreateCustomPluginInput) SetName(v string) *CreateCustomPluginInput

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 

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

SetName sets the Name field's value.

func (*CreateCustomPluginOutput) SetRevision 

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

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 required field
	PropertiesFileContent *string `locationName:"propertiesFileContent" type:"string" required:"true"`
	// contains filtered or unexported fields
}

func (CreateWorkerConfigurationInput) GoString 

func (s CreateWorkerConfigurationInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateWorkerConfigurationInput) SetDescription 

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

SetDescription sets the Description field's value.

func (*CreateWorkerConfigurationInput) SetName 

func (s *CreateWorkerConfigurationInput) SetName(v string) *CreateWorkerConfigurationInput

SetName sets the Name field's value.

func (*CreateWorkerConfigurationInput) SetPropertiesFileContent 

func (s *CreateWorkerConfigurationInput) SetPropertiesFileContent(v string) *CreateWorkerConfigurationInput

SetPropertiesFileContent sets the PropertiesFileContent field's value.

func (CreateWorkerConfigurationInput) String 

func (s CreateWorkerConfigurationInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*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 

func (s CreateWorkerConfigurationOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CreateWorkerConfigurationOutput) SetCreationTime 

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

SetCreationTime sets the CreationTime field's value.

func (*CreateWorkerConfigurationOutput) SetLatestRevision 

func (s *CreateWorkerConfigurationOutput) SetLatestRevision(v *WorkerConfigurationRevisionSummary) *CreateWorkerConfigurationOutput

SetLatestRevision sets the LatestRevision field's value.

func (*CreateWorkerConfigurationOutput) SetName 

func (s *CreateWorkerConfigurationOutput) SetName(v string) *CreateWorkerConfigurationOutput

SetName sets the Name field's value.

func (*CreateWorkerConfigurationOutput) SetWorkerConfigurationArn 

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

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (CreateWorkerConfigurationOutput) String 

func (s CreateWorkerConfigurationOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type CustomPlugin 

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 

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

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 

func (s *CustomPluginFileDescription) SetFileMd5(v string) *CustomPluginFileDescription

SetFileMd5 sets the FileMd5 field's value.

func (*CustomPluginFileDescription) SetFileSize 

func (s *CustomPluginFileDescription) SetFileSize(v int64) *CustomPluginFileDescription

SetFileSize sets the FileSize field's value.

func (CustomPluginFileDescription) String 

func (s CustomPluginFileDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type CustomPluginLocation 

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 

func (s *CustomPluginLocation) SetS3Location(v *S3Location) *CustomPluginLocation

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 

func (s CustomPluginLocationDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*CustomPluginLocationDescription) SetS3Location 

func (s *CustomPluginLocationDescription) SetS3Location(v *S3LocationDescription) *CustomPluginLocationDescription

SetS3Location sets the S3Location field's value.

func (CustomPluginLocationDescription) String 

func (s CustomPluginLocationDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type CustomPluginRevisionSummary 

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 

func (s *CustomPluginRevisionSummary) SetContentType(v string) *CustomPluginRevisionSummary

SetContentType sets the ContentType field's value.

func (*CustomPluginRevisionSummary) SetCreationTime 

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

SetCreationTime sets the CreationTime field's value.

func (*CustomPluginRevisionSummary) SetDescription 

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

SetDescription sets the Description field's value.

func (*CustomPluginRevisionSummary) SetFileDescription 

func (s *CustomPluginRevisionSummary) SetFileDescription(v *CustomPluginFileDescription) *CustomPluginRevisionSummary

SetFileDescription sets the FileDescription field's value.

func (*CustomPluginRevisionSummary) SetLocation 

func (s *CustomPluginRevisionSummary) SetLocation(v *CustomPluginLocationDescription) *CustomPluginRevisionSummary

SetLocation sets the Location field's value.

func (*CustomPluginRevisionSummary) SetRevision 

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

SetRevision sets the Revision field's value.

func (CustomPluginRevisionSummary) String 

func (s CustomPluginRevisionSummary) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type CustomPluginSummary 

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 

func (s *CustomPluginSummary) SetLatestRevision(v *CustomPluginRevisionSummary) *CustomPluginSummary

SetLatestRevision sets the LatestRevision field's value.

func (*CustomPluginSummary) SetName 

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

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 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 map[string]*string `locationName:"connectorConfiguration" type:"map"`

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

	// 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 

func (s *DescribeConnectorOutput) SetCapacity(v *CapacityDescription) *DescribeConnectorOutput

SetCapacity sets the Capacity field's value.

func (*DescribeConnectorOutput) SetConnectorArn 

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

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 

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

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 

func (s *DescribeConnectorOutput) SetKafkaCluster(v *KafkaClusterDescription) *DescribeConnectorOutput

SetKafkaCluster sets the KafkaCluster field's value.

func (*DescribeConnectorOutput) SetKafkaClusterClientAuthentication 

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

SetKafkaClusterClientAuthentication sets the KafkaClusterClientAuthentication field's value.

func (*DescribeConnectorOutput) SetKafkaClusterEncryptionInTransit 

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

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 

func (s *DescribeConnectorOutput) SetLogDelivery(v *LogDeliveryDescription) *DescribeConnectorOutput

SetLogDelivery sets the LogDelivery field's value.

func (*DescribeConnectorOutput) SetPlugins 

func (s *DescribeConnectorOutput) SetPlugins(v []*PluginDescription) *DescribeConnectorOutput

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) SetWorkerConfiguration 

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

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 

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

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

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

SetCreationTime sets the CreationTime field's value.

func (*DescribeCustomPluginOutput) SetCustomPluginArn 

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

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 

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

SetDescription sets the Description field's value.

func (*DescribeCustomPluginOutput) SetLatestRevision 

func (s *DescribeCustomPluginOutput) SetLatestRevision(v *CustomPluginRevisionSummary) *DescribeCustomPluginOutput

SetLatestRevision sets the LatestRevision field's value.

func (*DescribeCustomPluginOutput) SetName 

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

SetName sets the Name field's value.

func (DescribeCustomPluginOutput) String 

func (s DescribeCustomPluginOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type DescribeWorkerConfigurationInput 

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 

func (s DescribeWorkerConfigurationInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeWorkerConfigurationInput) SetWorkerConfigurationArn 

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

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (DescribeWorkerConfigurationInput) String 

func (s DescribeWorkerConfigurationInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeWorkerConfigurationInput) Validate 

func (s *DescribeWorkerConfigurationInput) Validate() error

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 

func (s DescribeWorkerConfigurationOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*DescribeWorkerConfigurationOutput) SetCreationTime 

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

SetCreationTime sets the CreationTime field's value.

func (*DescribeWorkerConfigurationOutput) SetDescription 

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

SetDescription sets the Description field's value.

func (*DescribeWorkerConfigurationOutput) SetLatestRevision 

func (s *DescribeWorkerConfigurationOutput) SetLatestRevision(v *WorkerConfigurationRevisionDescription) *DescribeWorkerConfigurationOutput

SetLatestRevision sets the LatestRevision field's value.

func (*DescribeWorkerConfigurationOutput) SetName 

func (s *DescribeWorkerConfigurationOutput) SetName(v string) *DescribeWorkerConfigurationOutput

SetName sets the Name field's value.

func (*DescribeWorkerConfigurationOutput) SetWorkerConfigurationArn 

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

SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.

func (DescribeWorkerConfigurationOutput) String 

func (s DescribeWorkerConfigurationOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type FirehoseLogDelivery 

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 

func (s FirehoseLogDeliveryDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*FirehoseLogDeliveryDescription) SetDeliveryStream 

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

SetDeliveryStream sets the DeliveryStream field's value.

func (*FirehoseLogDeliveryDescription) SetEnabled 

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

SetEnabled sets the Enabled field's value.

func (FirehoseLogDeliveryDescription) String 

func (s FirehoseLogDeliveryDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ForbiddenException 

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 

func (s *InternalServerErrorException) Code() string

Code returns the exception type name.

func (*InternalServerErrorException) Error 

func (s *InternalServerErrorException) Error() string

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 

func (s InternalServerErrorException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type KafkaCluster 

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 

func (s KafkaClusterClientAuthentication) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*KafkaClusterClientAuthentication) SetAuthenticationType 

func (s *KafkaClusterClientAuthentication) SetAuthenticationType(v string) *KafkaClusterClientAuthentication

SetAuthenticationType sets the AuthenticationType field's value.

func (KafkaClusterClientAuthentication) String 

func (s KafkaClusterClientAuthentication) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*KafkaClusterClientAuthentication) Validate 

func (s *KafkaClusterClientAuthentication) Validate() error

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 

func (s KafkaClusterClientAuthenticationDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*KafkaClusterClientAuthenticationDescription) SetAuthenticationType 

func (s *KafkaClusterClientAuthenticationDescription) SetAuthenticationType(v string) *KafkaClusterClientAuthenticationDescription

SetAuthenticationType sets the AuthenticationType field's value.

func (KafkaClusterClientAuthenticationDescription) String 

func (s KafkaClusterClientAuthenticationDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type KafkaClusterDescription 

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 

func (s *KafkaClusterDescription) SetApacheKafkaCluster(v *ApacheKafkaClusterDescription) *KafkaClusterDescription

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 

func (s KafkaClusterEncryptionInTransit) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*KafkaClusterEncryptionInTransit) SetEncryptionType 

func (s *KafkaClusterEncryptionInTransit) SetEncryptionType(v string) *KafkaClusterEncryptionInTransit

SetEncryptionType sets the EncryptionType field's value.

func (KafkaClusterEncryptionInTransit) String 

func (s KafkaClusterEncryptionInTransit) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*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 

func (s KafkaClusterEncryptionInTransitDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*KafkaClusterEncryptionInTransitDescription) SetEncryptionType 

func (s *KafkaClusterEncryptionInTransitDescription) SetEncryptionType(v string) *KafkaClusterEncryptionInTransitDescription

SetEncryptionType sets the EncryptionType field's value.

func (KafkaClusterEncryptionInTransitDescription) String 

func (s KafkaClusterEncryptionInTransitDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type KafkaConnect 

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) 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 

func (s *ListConnectorsOutput) SetConnectors(v []*ConnectorSummary) *ListConnectorsOutput

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 

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

SetMaxResults sets the MaxResults field's value.

func (*ListCustomPluginsInput) SetNextToken 

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

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 

func (s *ListCustomPluginsOutput) SetCustomPlugins(v []*CustomPluginSummary) *ListCustomPluginsOutput

SetCustomPlugins sets the CustomPlugins field's value.

func (*ListCustomPluginsOutput) SetNextToken 

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

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 

func (s ListWorkerConfigurationsInput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListWorkerConfigurationsInput) SetMaxResults 

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

SetMaxResults sets the MaxResults field's value.

func (*ListWorkerConfigurationsInput) SetNextToken 

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

SetNextToken sets the NextToken field's value.

func (ListWorkerConfigurationsInput) String 

func (s ListWorkerConfigurationsInput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*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 

func (s ListWorkerConfigurationsOutput) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ListWorkerConfigurationsOutput) SetNextToken 

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

SetNextToken sets the NextToken field's value.

func (*ListWorkerConfigurationsOutput) SetWorkerConfigurations 

func (s *ListWorkerConfigurationsOutput) SetWorkerConfigurations(v []*WorkerConfigurationSummary) *ListWorkerConfigurationsOutput

SetWorkerConfigurations sets the WorkerConfigurations field's value.

func (ListWorkerConfigurationsOutput) String 

func (s ListWorkerConfigurationsOutput) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type LogDelivery 

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 

func (s *LogDeliveryDescription) SetWorkerLogDelivery(v *WorkerLogDeliveryDescription) *LogDeliveryDescription

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 

func (s *PluginDescription) SetCustomPlugin(v *CustomPluginDescription) *PluginDescription

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 

func (s ProvisionedCapacityDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*ProvisionedCapacityDescription) SetMcuCount 

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

SetMcuCount sets the McuCount field's value.

func (*ProvisionedCapacityDescription) SetWorkerCount 

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

SetWorkerCount sets the WorkerCount field's value.

func (ProvisionedCapacityDescription) String 

func (s ProvisionedCapacityDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type ProvisionedCapacityUpdate 

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 

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

SetMcuCount sets the McuCount field's value.

func (*ProvisionedCapacityUpdate) SetWorkerCount 

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

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 

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

SetBucketArn sets the BucketArn field's value.

func (*S3LocationDescription) SetFileKey 

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

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 

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

SetBucket sets the Bucket field's value.

func (*S3LogDeliveryDescription) SetEnabled 

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

SetEnabled sets the Enabled field's value.

func (*S3LogDeliveryDescription) SetPrefix 

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

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 

func (s *ServiceUnavailableException) Code() string

Code returns the exception type name.

func (*ServiceUnavailableException) Error 

func (s *ServiceUnavailableException) Error() string

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 

func (s ServiceUnavailableException) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type 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 

func (s *UpdateConnectorInput) SetCapacity(v *CapacityUpdate) *UpdateConnectorInput

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 

func (s WorkerConfigurationDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*WorkerConfigurationDescription) SetRevision 

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

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 

func (s WorkerConfigurationDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type WorkerConfigurationRevisionDescription 

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 *string `locationName:"propertiesFileContent" type:"string"`

	// 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 

func (s WorkerConfigurationRevisionDescription) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*WorkerConfigurationRevisionDescription) SetCreationTime 

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

SetCreationTime sets the CreationTime field's value.

func (*WorkerConfigurationRevisionDescription) SetDescription 

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

SetDescription sets the Description field's value.

func (*WorkerConfigurationRevisionDescription) SetPropertiesFileContent 

func (s *WorkerConfigurationRevisionDescription) SetPropertiesFileContent(v string) *WorkerConfigurationRevisionDescription

SetPropertiesFileContent sets the PropertiesFileContent field's value.

func (*WorkerConfigurationRevisionDescription) SetRevision 

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

SetRevision sets the Revision field's value.

func (WorkerConfigurationRevisionDescription) String 

func (s WorkerConfigurationRevisionDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type WorkerConfigurationRevisionSummary 

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 

func (s WorkerConfigurationRevisionSummary) GoString() string

GoString returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

func (*WorkerConfigurationRevisionSummary) SetCreationTime 

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

SetCreationTime sets the CreationTime field's value.

func (*WorkerConfigurationRevisionSummary) SetDescription 

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

SetDescription sets the Description field's value.

func (*WorkerConfigurationRevisionSummary) SetRevision 

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

SetRevision sets the Revision field's value.

func (WorkerConfigurationRevisionSummary) String 

func (s WorkerConfigurationRevisionSummary) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type WorkerConfigurationSummary 

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 

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

SetCreationTime sets the CreationTime field's value.

func (*WorkerConfigurationSummary) SetDescription 

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

SetDescription sets the Description field's value.

func (*WorkerConfigurationSummary) SetLatestRevision 

func (s *WorkerConfigurationSummary) SetLatestRevision(v *WorkerConfigurationRevisionSummary) *WorkerConfigurationSummary

SetLatestRevision sets the LatestRevision field's value.

func (*WorkerConfigurationSummary) SetName 

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

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 

func (s WorkerConfigurationSummary) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

type WorkerLogDelivery 

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 

func (s *WorkerLogDelivery) SetCloudWatchLogs(v *CloudWatchLogsLogDelivery) *WorkerLogDelivery

SetCloudWatchLogs sets the CloudWatchLogs field's value.

func (*WorkerLogDelivery) SetFirehose 

func (s *WorkerLogDelivery) SetFirehose(v *FirehoseLogDelivery) *WorkerLogDelivery

SetFirehose sets the Firehose field's value.

func (*WorkerLogDelivery) SetS3 

func (s *WorkerLogDelivery) SetS3(v *S3LogDelivery) *WorkerLogDelivery

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 

func (s *WorkerLogDeliveryDescription) SetCloudWatchLogs(v *CloudWatchLogsLogDeliveryDescription) *WorkerLogDeliveryDescription

SetCloudWatchLogs sets the CloudWatchLogs field's value.

func (*WorkerLogDeliveryDescription) SetFirehose 

func (s *WorkerLogDeliveryDescription) SetFirehose(v *FirehoseLogDeliveryDescription) *WorkerLogDeliveryDescription

SetFirehose sets the Firehose field's value.

func (*WorkerLogDeliveryDescription) SetS3 

func (s *WorkerLogDeliveryDescription) SetS3(v *S3LogDeliveryDescription) *WorkerLogDeliveryDescription

SetS3 sets the S3 field's value.

func (WorkerLogDeliveryDescription) String 

func (s WorkerLogDeliveryDescription) String() string

String returns the string representation.

API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".

Source Files

View all Source files

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
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.