Versions in this module Expand all Collapse all v1 v1.0.1 Jul 4, 2024 v1.0.0 Jul 4, 2024 Changes in this version + const ConnectorStateCreating + const ConnectorStateDeleting + const ConnectorStateFailed + const ConnectorStateRunning + const ConnectorStateUpdating + const CustomPluginContentTypeJar + const CustomPluginContentTypeZip + const CustomPluginStateActive + const CustomPluginStateCreateFailed + const CustomPluginStateCreating + const CustomPluginStateDeleting + const CustomPluginStateUpdateFailed + const CustomPluginStateUpdating + const EndpointsID + const ErrCodeBadRequestException + const ErrCodeConflictException + const ErrCodeForbiddenException + const ErrCodeInternalServerErrorException + const ErrCodeNotFoundException + const ErrCodeServiceUnavailableException + const ErrCodeTooManyRequestsException + const ErrCodeUnauthorizedException + const KafkaClusterClientAuthenticationTypeIam + const KafkaClusterClientAuthenticationTypeNone + const KafkaClusterEncryptionInTransitTypePlaintext + const KafkaClusterEncryptionInTransitTypeTls + const ServiceID + const ServiceName + func ConnectorState_Values() []string + func CustomPluginContentType_Values() []string + func CustomPluginState_Values() []string + func KafkaClusterClientAuthenticationType_Values() []string + func KafkaClusterEncryptionInTransitType_Values() []string + type ApacheKafkaCluster struct + BootstrapServers *string + Vpc *Vpc + func (s *ApacheKafkaCluster) SetBootstrapServers(v string) *ApacheKafkaCluster + func (s *ApacheKafkaCluster) SetVpc(v *Vpc) *ApacheKafkaCluster + func (s *ApacheKafkaCluster) Validate() error + func (s ApacheKafkaCluster) GoString() string + func (s ApacheKafkaCluster) String() string + type ApacheKafkaClusterDescription struct + BootstrapServers *string + Vpc *VpcDescription + func (s *ApacheKafkaClusterDescription) SetBootstrapServers(v string) *ApacheKafkaClusterDescription + func (s *ApacheKafkaClusterDescription) SetVpc(v *VpcDescription) *ApacheKafkaClusterDescription + func (s ApacheKafkaClusterDescription) GoString() string + func (s ApacheKafkaClusterDescription) String() string + type AutoScaling struct + MaxWorkerCount *int64 + McuCount *int64 + MinWorkerCount *int64 + ScaleInPolicy *ScaleInPolicy + ScaleOutPolicy *ScaleOutPolicy + func (s *AutoScaling) SetMaxWorkerCount(v int64) *AutoScaling + func (s *AutoScaling) SetMcuCount(v int64) *AutoScaling + func (s *AutoScaling) SetMinWorkerCount(v int64) *AutoScaling + func (s *AutoScaling) SetScaleInPolicy(v *ScaleInPolicy) *AutoScaling + func (s *AutoScaling) SetScaleOutPolicy(v *ScaleOutPolicy) *AutoScaling + func (s *AutoScaling) Validate() error + func (s AutoScaling) GoString() string + func (s AutoScaling) String() string + type AutoScalingDescription struct + MaxWorkerCount *int64 + McuCount *int64 + MinWorkerCount *int64 + ScaleInPolicy *ScaleInPolicyDescription + ScaleOutPolicy *ScaleOutPolicyDescription + func (s *AutoScalingDescription) SetMaxWorkerCount(v int64) *AutoScalingDescription + func (s *AutoScalingDescription) SetMcuCount(v int64) *AutoScalingDescription + func (s *AutoScalingDescription) SetMinWorkerCount(v int64) *AutoScalingDescription + func (s *AutoScalingDescription) SetScaleInPolicy(v *ScaleInPolicyDescription) *AutoScalingDescription + func (s *AutoScalingDescription) SetScaleOutPolicy(v *ScaleOutPolicyDescription) *AutoScalingDescription + func (s AutoScalingDescription) GoString() string + func (s AutoScalingDescription) String() string + type AutoScalingUpdate struct + MaxWorkerCount *int64 + McuCount *int64 + MinWorkerCount *int64 + ScaleInPolicy *ScaleInPolicyUpdate + ScaleOutPolicy *ScaleOutPolicyUpdate + func (s *AutoScalingUpdate) SetMaxWorkerCount(v int64) *AutoScalingUpdate + func (s *AutoScalingUpdate) SetMcuCount(v int64) *AutoScalingUpdate + func (s *AutoScalingUpdate) SetMinWorkerCount(v int64) *AutoScalingUpdate + func (s *AutoScalingUpdate) SetScaleInPolicy(v *ScaleInPolicyUpdate) *AutoScalingUpdate + func (s *AutoScalingUpdate) SetScaleOutPolicy(v *ScaleOutPolicyUpdate) *AutoScalingUpdate + func (s *AutoScalingUpdate) Validate() error + func (s AutoScalingUpdate) GoString() string + func (s AutoScalingUpdate) String() string + type BadRequestException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *BadRequestException) Code() string + func (s *BadRequestException) Error() string + func (s *BadRequestException) Message() string + func (s *BadRequestException) OrigErr() error + func (s *BadRequestException) RequestID() string + func (s *BadRequestException) StatusCode() int + func (s BadRequestException) GoString() string + func (s BadRequestException) String() string + type Capacity struct + AutoScaling *AutoScaling + ProvisionedCapacity *ProvisionedCapacity + func (s *Capacity) SetAutoScaling(v *AutoScaling) *Capacity + func (s *Capacity) SetProvisionedCapacity(v *ProvisionedCapacity) *Capacity + func (s *Capacity) Validate() error + func (s Capacity) GoString() string + func (s Capacity) String() string + type CapacityDescription struct + AutoScaling *AutoScalingDescription + ProvisionedCapacity *ProvisionedCapacityDescription + func (s *CapacityDescription) SetAutoScaling(v *AutoScalingDescription) *CapacityDescription + func (s *CapacityDescription) SetProvisionedCapacity(v *ProvisionedCapacityDescription) *CapacityDescription + func (s CapacityDescription) GoString() string + func (s CapacityDescription) String() string + type CapacityUpdate struct + AutoScaling *AutoScalingUpdate + ProvisionedCapacity *ProvisionedCapacityUpdate + func (s *CapacityUpdate) SetAutoScaling(v *AutoScalingUpdate) *CapacityUpdate + func (s *CapacityUpdate) SetProvisionedCapacity(v *ProvisionedCapacityUpdate) *CapacityUpdate + func (s *CapacityUpdate) Validate() error + func (s CapacityUpdate) GoString() string + func (s CapacityUpdate) String() string + type CloudWatchLogsLogDelivery struct + Enabled *bool + LogGroup *string + func (s *CloudWatchLogsLogDelivery) SetEnabled(v bool) *CloudWatchLogsLogDelivery + func (s *CloudWatchLogsLogDelivery) SetLogGroup(v string) *CloudWatchLogsLogDelivery + func (s *CloudWatchLogsLogDelivery) Validate() error + func (s CloudWatchLogsLogDelivery) GoString() string + func (s CloudWatchLogsLogDelivery) String() string + type CloudWatchLogsLogDeliveryDescription struct + Enabled *bool + LogGroup *string + func (s *CloudWatchLogsLogDeliveryDescription) SetEnabled(v bool) *CloudWatchLogsLogDeliveryDescription + func (s *CloudWatchLogsLogDeliveryDescription) SetLogGroup(v string) *CloudWatchLogsLogDeliveryDescription + func (s CloudWatchLogsLogDeliveryDescription) GoString() string + func (s CloudWatchLogsLogDeliveryDescription) String() string + type ConflictException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ConflictException) Code() string + func (s *ConflictException) Error() string + func (s *ConflictException) Message() string + func (s *ConflictException) OrigErr() error + func (s *ConflictException) RequestID() string + func (s *ConflictException) StatusCode() int + func (s ConflictException) GoString() string + func (s ConflictException) String() string + type ConnectorSummary struct + Capacity *CapacityDescription + ConnectorArn *string + ConnectorDescription *string + ConnectorName *string + ConnectorState *string + CreationTime *time.Time + CurrentVersion *string + KafkaCluster *KafkaClusterDescription + KafkaClusterClientAuthentication *KafkaClusterClientAuthenticationDescription + KafkaClusterEncryptionInTransit *KafkaClusterEncryptionInTransitDescription + KafkaConnectVersion *string + LogDelivery *LogDeliveryDescription + Plugins []*PluginDescription + ServiceExecutionRoleArn *string + WorkerConfiguration *WorkerConfigurationDescription + func (s *ConnectorSummary) SetCapacity(v *CapacityDescription) *ConnectorSummary + func (s *ConnectorSummary) SetConnectorArn(v string) *ConnectorSummary + func (s *ConnectorSummary) SetConnectorDescription(v string) *ConnectorSummary + func (s *ConnectorSummary) SetConnectorName(v string) *ConnectorSummary + func (s *ConnectorSummary) SetConnectorState(v string) *ConnectorSummary + func (s *ConnectorSummary) SetCreationTime(v time.Time) *ConnectorSummary + func (s *ConnectorSummary) SetCurrentVersion(v string) *ConnectorSummary + func (s *ConnectorSummary) SetKafkaCluster(v *KafkaClusterDescription) *ConnectorSummary + func (s *ConnectorSummary) SetKafkaClusterClientAuthentication(v *KafkaClusterClientAuthenticationDescription) *ConnectorSummary + func (s *ConnectorSummary) SetKafkaClusterEncryptionInTransit(v *KafkaClusterEncryptionInTransitDescription) *ConnectorSummary + func (s *ConnectorSummary) SetKafkaConnectVersion(v string) *ConnectorSummary + func (s *ConnectorSummary) SetLogDelivery(v *LogDeliveryDescription) *ConnectorSummary + func (s *ConnectorSummary) SetPlugins(v []*PluginDescription) *ConnectorSummary + func (s *ConnectorSummary) SetServiceExecutionRoleArn(v string) *ConnectorSummary + func (s *ConnectorSummary) SetWorkerConfiguration(v *WorkerConfigurationDescription) *ConnectorSummary + func (s ConnectorSummary) GoString() string + func (s ConnectorSummary) String() string + type CreateConnectorInput struct + Capacity *Capacity + ConnectorConfiguration map[string]*string + ConnectorDescription *string + ConnectorName *string + KafkaCluster *KafkaCluster + KafkaClusterClientAuthentication *KafkaClusterClientAuthentication + KafkaClusterEncryptionInTransit *KafkaClusterEncryptionInTransit + KafkaConnectVersion *string + LogDelivery *LogDelivery + Plugins []*Plugin + ServiceExecutionRoleArn *string + WorkerConfiguration *WorkerConfiguration + func (s *CreateConnectorInput) SetCapacity(v *Capacity) *CreateConnectorInput + func (s *CreateConnectorInput) SetConnectorConfiguration(v map[string]*string) *CreateConnectorInput + func (s *CreateConnectorInput) SetConnectorDescription(v string) *CreateConnectorInput + func (s *CreateConnectorInput) SetConnectorName(v string) *CreateConnectorInput + func (s *CreateConnectorInput) SetKafkaCluster(v *KafkaCluster) *CreateConnectorInput + func (s *CreateConnectorInput) SetKafkaClusterClientAuthentication(v *KafkaClusterClientAuthentication) *CreateConnectorInput + func (s *CreateConnectorInput) SetKafkaClusterEncryptionInTransit(v *KafkaClusterEncryptionInTransit) *CreateConnectorInput + func (s *CreateConnectorInput) SetKafkaConnectVersion(v string) *CreateConnectorInput + func (s *CreateConnectorInput) SetLogDelivery(v *LogDelivery) *CreateConnectorInput + func (s *CreateConnectorInput) SetPlugins(v []*Plugin) *CreateConnectorInput + func (s *CreateConnectorInput) SetServiceExecutionRoleArn(v string) *CreateConnectorInput + func (s *CreateConnectorInput) SetWorkerConfiguration(v *WorkerConfiguration) *CreateConnectorInput + func (s *CreateConnectorInput) Validate() error + func (s CreateConnectorInput) GoString() string + func (s CreateConnectorInput) String() string + type CreateConnectorOutput struct + ConnectorArn *string + ConnectorName *string + ConnectorState *string + func (s *CreateConnectorOutput) SetConnectorArn(v string) *CreateConnectorOutput + func (s *CreateConnectorOutput) SetConnectorName(v string) *CreateConnectorOutput + func (s *CreateConnectorOutput) SetConnectorState(v string) *CreateConnectorOutput + func (s CreateConnectorOutput) GoString() string + func (s CreateConnectorOutput) String() string + type CreateCustomPluginInput struct + ContentType *string + Description *string + Location *CustomPluginLocation + Name *string + func (s *CreateCustomPluginInput) SetContentType(v string) *CreateCustomPluginInput + func (s *CreateCustomPluginInput) SetDescription(v string) *CreateCustomPluginInput + func (s *CreateCustomPluginInput) SetLocation(v *CustomPluginLocation) *CreateCustomPluginInput + func (s *CreateCustomPluginInput) SetName(v string) *CreateCustomPluginInput + func (s *CreateCustomPluginInput) Validate() error + func (s CreateCustomPluginInput) GoString() string + func (s CreateCustomPluginInput) String() string + type CreateCustomPluginOutput struct + CustomPluginArn *string + CustomPluginState *string + Name *string + Revision *int64 + func (s *CreateCustomPluginOutput) SetCustomPluginArn(v string) *CreateCustomPluginOutput + func (s *CreateCustomPluginOutput) SetCustomPluginState(v string) *CreateCustomPluginOutput + func (s *CreateCustomPluginOutput) SetName(v string) *CreateCustomPluginOutput + func (s *CreateCustomPluginOutput) SetRevision(v int64) *CreateCustomPluginOutput + func (s CreateCustomPluginOutput) GoString() string + func (s CreateCustomPluginOutput) String() string + type CreateWorkerConfigurationInput struct + Description *string + Name *string + PropertiesFileContent *string + func (s *CreateWorkerConfigurationInput) SetDescription(v string) *CreateWorkerConfigurationInput + func (s *CreateWorkerConfigurationInput) SetName(v string) *CreateWorkerConfigurationInput + func (s *CreateWorkerConfigurationInput) SetPropertiesFileContent(v string) *CreateWorkerConfigurationInput + func (s *CreateWorkerConfigurationInput) Validate() error + func (s CreateWorkerConfigurationInput) GoString() string + func (s CreateWorkerConfigurationInput) String() string + type CreateWorkerConfigurationOutput struct + CreationTime *time.Time + LatestRevision *WorkerConfigurationRevisionSummary + Name *string + WorkerConfigurationArn *string + func (s *CreateWorkerConfigurationOutput) SetCreationTime(v time.Time) *CreateWorkerConfigurationOutput + func (s *CreateWorkerConfigurationOutput) SetLatestRevision(v *WorkerConfigurationRevisionSummary) *CreateWorkerConfigurationOutput + func (s *CreateWorkerConfigurationOutput) SetName(v string) *CreateWorkerConfigurationOutput + func (s *CreateWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *CreateWorkerConfigurationOutput + func (s CreateWorkerConfigurationOutput) GoString() string + func (s CreateWorkerConfigurationOutput) String() string + type CustomPlugin struct + CustomPluginArn *string + Revision *int64 + func (s *CustomPlugin) SetCustomPluginArn(v string) *CustomPlugin + func (s *CustomPlugin) SetRevision(v int64) *CustomPlugin + func (s *CustomPlugin) Validate() error + func (s CustomPlugin) GoString() string + func (s CustomPlugin) String() string + type CustomPluginDescription struct + CustomPluginArn *string + Revision *int64 + func (s *CustomPluginDescription) SetCustomPluginArn(v string) *CustomPluginDescription + func (s *CustomPluginDescription) SetRevision(v int64) *CustomPluginDescription + func (s CustomPluginDescription) GoString() string + func (s CustomPluginDescription) String() string + type CustomPluginFileDescription struct + FileMd5 *string + FileSize *int64 + func (s *CustomPluginFileDescription) SetFileMd5(v string) *CustomPluginFileDescription + func (s *CustomPluginFileDescription) SetFileSize(v int64) *CustomPluginFileDescription + func (s CustomPluginFileDescription) GoString() string + func (s CustomPluginFileDescription) String() string + type CustomPluginLocation struct + S3Location *S3Location + func (s *CustomPluginLocation) SetS3Location(v *S3Location) *CustomPluginLocation + func (s *CustomPluginLocation) Validate() error + func (s CustomPluginLocation) GoString() string + func (s CustomPluginLocation) String() string + type CustomPluginLocationDescription struct + S3Location *S3LocationDescription + func (s *CustomPluginLocationDescription) SetS3Location(v *S3LocationDescription) *CustomPluginLocationDescription + func (s CustomPluginLocationDescription) GoString() string + func (s CustomPluginLocationDescription) String() string + type CustomPluginRevisionSummary struct + ContentType *string + CreationTime *time.Time + Description *string + FileDescription *CustomPluginFileDescription + Location *CustomPluginLocationDescription + Revision *int64 + func (s *CustomPluginRevisionSummary) SetContentType(v string) *CustomPluginRevisionSummary + func (s *CustomPluginRevisionSummary) SetCreationTime(v time.Time) *CustomPluginRevisionSummary + func (s *CustomPluginRevisionSummary) SetDescription(v string) *CustomPluginRevisionSummary + func (s *CustomPluginRevisionSummary) SetFileDescription(v *CustomPluginFileDescription) *CustomPluginRevisionSummary + func (s *CustomPluginRevisionSummary) SetLocation(v *CustomPluginLocationDescription) *CustomPluginRevisionSummary + func (s *CustomPluginRevisionSummary) SetRevision(v int64) *CustomPluginRevisionSummary + func (s CustomPluginRevisionSummary) GoString() string + func (s CustomPluginRevisionSummary) String() string + type CustomPluginSummary struct + CreationTime *time.Time + CustomPluginArn *string + CustomPluginState *string + Description *string + LatestRevision *CustomPluginRevisionSummary + Name *string + func (s *CustomPluginSummary) SetCreationTime(v time.Time) *CustomPluginSummary + func (s *CustomPluginSummary) SetCustomPluginArn(v string) *CustomPluginSummary + func (s *CustomPluginSummary) SetCustomPluginState(v string) *CustomPluginSummary + func (s *CustomPluginSummary) SetDescription(v string) *CustomPluginSummary + func (s *CustomPluginSummary) SetLatestRevision(v *CustomPluginRevisionSummary) *CustomPluginSummary + func (s *CustomPluginSummary) SetName(v string) *CustomPluginSummary + func (s CustomPluginSummary) GoString() string + func (s CustomPluginSummary) String() string + type DeleteConnectorInput struct + ConnectorArn *string + CurrentVersion *string + func (s *DeleteConnectorInput) SetConnectorArn(v string) *DeleteConnectorInput + func (s *DeleteConnectorInput) SetCurrentVersion(v string) *DeleteConnectorInput + func (s *DeleteConnectorInput) Validate() error + func (s DeleteConnectorInput) GoString() string + func (s DeleteConnectorInput) String() string + type DeleteConnectorOutput struct + ConnectorArn *string + ConnectorState *string + func (s *DeleteConnectorOutput) SetConnectorArn(v string) *DeleteConnectorOutput + func (s *DeleteConnectorOutput) SetConnectorState(v string) *DeleteConnectorOutput + func (s DeleteConnectorOutput) GoString() string + func (s DeleteConnectorOutput) String() string + type DeleteCustomPluginInput struct + CustomPluginArn *string + func (s *DeleteCustomPluginInput) SetCustomPluginArn(v string) *DeleteCustomPluginInput + func (s *DeleteCustomPluginInput) Validate() error + func (s DeleteCustomPluginInput) GoString() string + func (s DeleteCustomPluginInput) String() string + type DeleteCustomPluginOutput struct + CustomPluginArn *string + CustomPluginState *string + func (s *DeleteCustomPluginOutput) SetCustomPluginArn(v string) *DeleteCustomPluginOutput + func (s *DeleteCustomPluginOutput) SetCustomPluginState(v string) *DeleteCustomPluginOutput + func (s DeleteCustomPluginOutput) GoString() string + func (s DeleteCustomPluginOutput) String() string + type DescribeConnectorInput struct + ConnectorArn *string + func (s *DescribeConnectorInput) SetConnectorArn(v string) *DescribeConnectorInput + func (s *DescribeConnectorInput) Validate() error + func (s DescribeConnectorInput) GoString() string + func (s DescribeConnectorInput) String() string + type DescribeConnectorOutput struct + Capacity *CapacityDescription + ConnectorArn *string + ConnectorConfiguration map[string]*string + ConnectorDescription *string + ConnectorName *string + ConnectorState *string + CreationTime *time.Time + CurrentVersion *string + KafkaCluster *KafkaClusterDescription + KafkaClusterClientAuthentication *KafkaClusterClientAuthenticationDescription + KafkaClusterEncryptionInTransit *KafkaClusterEncryptionInTransitDescription + KafkaConnectVersion *string + LogDelivery *LogDeliveryDescription + Plugins []*PluginDescription + ServiceExecutionRoleArn *string + StateDescription *StateDescription + WorkerConfiguration *WorkerConfigurationDescription + func (s *DescribeConnectorOutput) SetCapacity(v *CapacityDescription) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetConnectorArn(v string) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetConnectorConfiguration(v map[string]*string) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetConnectorDescription(v string) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetConnectorName(v string) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetConnectorState(v string) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetCreationTime(v time.Time) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetCurrentVersion(v string) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetKafkaCluster(v *KafkaClusterDescription) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetKafkaClusterClientAuthentication(v *KafkaClusterClientAuthenticationDescription) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetKafkaClusterEncryptionInTransit(v *KafkaClusterEncryptionInTransitDescription) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetKafkaConnectVersion(v string) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetLogDelivery(v *LogDeliveryDescription) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetPlugins(v []*PluginDescription) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetServiceExecutionRoleArn(v string) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetStateDescription(v *StateDescription) *DescribeConnectorOutput + func (s *DescribeConnectorOutput) SetWorkerConfiguration(v *WorkerConfigurationDescription) *DescribeConnectorOutput + func (s DescribeConnectorOutput) GoString() string + func (s DescribeConnectorOutput) String() string + type DescribeCustomPluginInput struct + CustomPluginArn *string + func (s *DescribeCustomPluginInput) SetCustomPluginArn(v string) *DescribeCustomPluginInput + func (s *DescribeCustomPluginInput) Validate() error + func (s DescribeCustomPluginInput) GoString() string + func (s DescribeCustomPluginInput) String() string + type DescribeCustomPluginOutput struct + CreationTime *time.Time + CustomPluginArn *string + CustomPluginState *string + Description *string + LatestRevision *CustomPluginRevisionSummary + Name *string + StateDescription *StateDescription + func (s *DescribeCustomPluginOutput) SetCreationTime(v time.Time) *DescribeCustomPluginOutput + func (s *DescribeCustomPluginOutput) SetCustomPluginArn(v string) *DescribeCustomPluginOutput + func (s *DescribeCustomPluginOutput) SetCustomPluginState(v string) *DescribeCustomPluginOutput + func (s *DescribeCustomPluginOutput) SetDescription(v string) *DescribeCustomPluginOutput + func (s *DescribeCustomPluginOutput) SetLatestRevision(v *CustomPluginRevisionSummary) *DescribeCustomPluginOutput + func (s *DescribeCustomPluginOutput) SetName(v string) *DescribeCustomPluginOutput + func (s *DescribeCustomPluginOutput) SetStateDescription(v *StateDescription) *DescribeCustomPluginOutput + func (s DescribeCustomPluginOutput) GoString() string + func (s DescribeCustomPluginOutput) String() string + type DescribeWorkerConfigurationInput struct + WorkerConfigurationArn *string + func (s *DescribeWorkerConfigurationInput) SetWorkerConfigurationArn(v string) *DescribeWorkerConfigurationInput + func (s *DescribeWorkerConfigurationInput) Validate() error + func (s DescribeWorkerConfigurationInput) GoString() string + func (s DescribeWorkerConfigurationInput) String() string + type DescribeWorkerConfigurationOutput struct + CreationTime *time.Time + Description *string + LatestRevision *WorkerConfigurationRevisionDescription + Name *string + WorkerConfigurationArn *string + func (s *DescribeWorkerConfigurationOutput) SetCreationTime(v time.Time) *DescribeWorkerConfigurationOutput + func (s *DescribeWorkerConfigurationOutput) SetDescription(v string) *DescribeWorkerConfigurationOutput + func (s *DescribeWorkerConfigurationOutput) SetLatestRevision(v *WorkerConfigurationRevisionDescription) *DescribeWorkerConfigurationOutput + func (s *DescribeWorkerConfigurationOutput) SetName(v string) *DescribeWorkerConfigurationOutput + func (s *DescribeWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *DescribeWorkerConfigurationOutput + func (s DescribeWorkerConfigurationOutput) GoString() string + func (s DescribeWorkerConfigurationOutput) String() string + type FirehoseLogDelivery struct + DeliveryStream *string + Enabled *bool + func (s *FirehoseLogDelivery) SetDeliveryStream(v string) *FirehoseLogDelivery + func (s *FirehoseLogDelivery) SetEnabled(v bool) *FirehoseLogDelivery + func (s *FirehoseLogDelivery) Validate() error + func (s FirehoseLogDelivery) GoString() string + func (s FirehoseLogDelivery) String() string + type FirehoseLogDeliveryDescription struct + DeliveryStream *string + Enabled *bool + func (s *FirehoseLogDeliveryDescription) SetDeliveryStream(v string) *FirehoseLogDeliveryDescription + func (s *FirehoseLogDeliveryDescription) SetEnabled(v bool) *FirehoseLogDeliveryDescription + func (s FirehoseLogDeliveryDescription) GoString() string + func (s FirehoseLogDeliveryDescription) String() string + type ForbiddenException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ForbiddenException) Code() string + func (s *ForbiddenException) Error() string + func (s *ForbiddenException) Message() string + func (s *ForbiddenException) OrigErr() error + func (s *ForbiddenException) RequestID() string + func (s *ForbiddenException) StatusCode() int + func (s ForbiddenException) GoString() string + func (s ForbiddenException) String() string + type InternalServerErrorException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *InternalServerErrorException) Code() string + func (s *InternalServerErrorException) Error() string + func (s *InternalServerErrorException) Message() string + func (s *InternalServerErrorException) OrigErr() error + func (s *InternalServerErrorException) RequestID() string + func (s *InternalServerErrorException) StatusCode() int + func (s InternalServerErrorException) GoString() string + func (s InternalServerErrorException) String() string + type KafkaCluster struct + ApacheKafkaCluster *ApacheKafkaCluster + func (s *KafkaCluster) SetApacheKafkaCluster(v *ApacheKafkaCluster) *KafkaCluster + func (s *KafkaCluster) Validate() error + func (s KafkaCluster) GoString() string + func (s KafkaCluster) String() string + type KafkaClusterClientAuthentication struct + AuthenticationType *string + func (s *KafkaClusterClientAuthentication) SetAuthenticationType(v string) *KafkaClusterClientAuthentication + func (s *KafkaClusterClientAuthentication) Validate() error + func (s KafkaClusterClientAuthentication) GoString() string + func (s KafkaClusterClientAuthentication) String() string + type KafkaClusterClientAuthenticationDescription struct + AuthenticationType *string + func (s *KafkaClusterClientAuthenticationDescription) SetAuthenticationType(v string) *KafkaClusterClientAuthenticationDescription + func (s KafkaClusterClientAuthenticationDescription) GoString() string + func (s KafkaClusterClientAuthenticationDescription) String() string + type KafkaClusterDescription struct + ApacheKafkaCluster *ApacheKafkaClusterDescription + func (s *KafkaClusterDescription) SetApacheKafkaCluster(v *ApacheKafkaClusterDescription) *KafkaClusterDescription + func (s KafkaClusterDescription) GoString() string + func (s KafkaClusterDescription) String() string + type KafkaClusterEncryptionInTransit struct + EncryptionType *string + func (s *KafkaClusterEncryptionInTransit) SetEncryptionType(v string) *KafkaClusterEncryptionInTransit + func (s *KafkaClusterEncryptionInTransit) Validate() error + func (s KafkaClusterEncryptionInTransit) GoString() string + func (s KafkaClusterEncryptionInTransit) String() string + type KafkaClusterEncryptionInTransitDescription struct + EncryptionType *string + func (s *KafkaClusterEncryptionInTransitDescription) SetEncryptionType(v string) *KafkaClusterEncryptionInTransitDescription + func (s KafkaClusterEncryptionInTransitDescription) GoString() string + func (s KafkaClusterEncryptionInTransitDescription) String() string + type KafkaConnect struct + func New(p client.ConfigProvider, cfgs ...*aws.Config) *KafkaConnect + func (c *KafkaConnect) CreateConnector(input *CreateConnectorInput) (*CreateConnectorOutput, error) + func (c *KafkaConnect) CreateConnectorRequest(input *CreateConnectorInput) (req *request.Request, output *CreateConnectorOutput) + func (c *KafkaConnect) CreateConnectorWithContext(ctx aws.Context, input *CreateConnectorInput, opts ...request.Option) (*CreateConnectorOutput, error) + func (c *KafkaConnect) CreateCustomPlugin(input *CreateCustomPluginInput) (*CreateCustomPluginOutput, error) + func (c *KafkaConnect) CreateCustomPluginRequest(input *CreateCustomPluginInput) (req *request.Request, output *CreateCustomPluginOutput) + func (c *KafkaConnect) CreateCustomPluginWithContext(ctx aws.Context, input *CreateCustomPluginInput, opts ...request.Option) (*CreateCustomPluginOutput, error) + func (c *KafkaConnect) CreateWorkerConfiguration(input *CreateWorkerConfigurationInput) (*CreateWorkerConfigurationOutput, error) + func (c *KafkaConnect) CreateWorkerConfigurationRequest(input *CreateWorkerConfigurationInput) (req *request.Request, output *CreateWorkerConfigurationOutput) + func (c *KafkaConnect) CreateWorkerConfigurationWithContext(ctx aws.Context, input *CreateWorkerConfigurationInput, opts ...request.Option) (*CreateWorkerConfigurationOutput, error) + func (c *KafkaConnect) DeleteConnector(input *DeleteConnectorInput) (*DeleteConnectorOutput, error) + func (c *KafkaConnect) DeleteConnectorRequest(input *DeleteConnectorInput) (req *request.Request, output *DeleteConnectorOutput) + func (c *KafkaConnect) DeleteConnectorWithContext(ctx aws.Context, input *DeleteConnectorInput, opts ...request.Option) (*DeleteConnectorOutput, error) + func (c *KafkaConnect) DeleteCustomPlugin(input *DeleteCustomPluginInput) (*DeleteCustomPluginOutput, error) + func (c *KafkaConnect) DeleteCustomPluginRequest(input *DeleteCustomPluginInput) (req *request.Request, output *DeleteCustomPluginOutput) + func (c *KafkaConnect) DeleteCustomPluginWithContext(ctx aws.Context, input *DeleteCustomPluginInput, opts ...request.Option) (*DeleteCustomPluginOutput, error) + func (c *KafkaConnect) DescribeConnector(input *DescribeConnectorInput) (*DescribeConnectorOutput, error) + func (c *KafkaConnect) DescribeConnectorRequest(input *DescribeConnectorInput) (req *request.Request, output *DescribeConnectorOutput) + func (c *KafkaConnect) DescribeConnectorWithContext(ctx aws.Context, input *DescribeConnectorInput, opts ...request.Option) (*DescribeConnectorOutput, error) + func (c *KafkaConnect) DescribeCustomPlugin(input *DescribeCustomPluginInput) (*DescribeCustomPluginOutput, error) + func (c *KafkaConnect) DescribeCustomPluginRequest(input *DescribeCustomPluginInput) (req *request.Request, output *DescribeCustomPluginOutput) + func (c *KafkaConnect) DescribeCustomPluginWithContext(ctx aws.Context, input *DescribeCustomPluginInput, opts ...request.Option) (*DescribeCustomPluginOutput, error) + func (c *KafkaConnect) DescribeWorkerConfiguration(input *DescribeWorkerConfigurationInput) (*DescribeWorkerConfigurationOutput, error) + func (c *KafkaConnect) DescribeWorkerConfigurationRequest(input *DescribeWorkerConfigurationInput) (req *request.Request, output *DescribeWorkerConfigurationOutput) + func (c *KafkaConnect) DescribeWorkerConfigurationWithContext(ctx aws.Context, input *DescribeWorkerConfigurationInput, ...) (*DescribeWorkerConfigurationOutput, error) + func (c *KafkaConnect) ListConnectors(input *ListConnectorsInput) (*ListConnectorsOutput, error) + func (c *KafkaConnect) ListConnectorsPages(input *ListConnectorsInput, fn func(*ListConnectorsOutput, bool) bool) error + func (c *KafkaConnect) ListConnectorsPagesWithContext(ctx aws.Context, input *ListConnectorsInput, ...) error + func (c *KafkaConnect) ListConnectorsRequest(input *ListConnectorsInput) (req *request.Request, output *ListConnectorsOutput) + func (c *KafkaConnect) ListConnectorsWithContext(ctx aws.Context, input *ListConnectorsInput, opts ...request.Option) (*ListConnectorsOutput, error) + func (c *KafkaConnect) ListCustomPlugins(input *ListCustomPluginsInput) (*ListCustomPluginsOutput, error) + func (c *KafkaConnect) ListCustomPluginsPages(input *ListCustomPluginsInput, fn func(*ListCustomPluginsOutput, bool) bool) error + func (c *KafkaConnect) ListCustomPluginsPagesWithContext(ctx aws.Context, input *ListCustomPluginsInput, ...) error + func (c *KafkaConnect) ListCustomPluginsRequest(input *ListCustomPluginsInput) (req *request.Request, output *ListCustomPluginsOutput) + func (c *KafkaConnect) ListCustomPluginsWithContext(ctx aws.Context, input *ListCustomPluginsInput, opts ...request.Option) (*ListCustomPluginsOutput, error) + func (c *KafkaConnect) ListWorkerConfigurations(input *ListWorkerConfigurationsInput) (*ListWorkerConfigurationsOutput, error) + func (c *KafkaConnect) ListWorkerConfigurationsPages(input *ListWorkerConfigurationsInput, ...) error + func (c *KafkaConnect) ListWorkerConfigurationsPagesWithContext(ctx aws.Context, input *ListWorkerConfigurationsInput, ...) error + func (c *KafkaConnect) ListWorkerConfigurationsRequest(input *ListWorkerConfigurationsInput) (req *request.Request, output *ListWorkerConfigurationsOutput) + func (c *KafkaConnect) ListWorkerConfigurationsWithContext(ctx aws.Context, input *ListWorkerConfigurationsInput, opts ...request.Option) (*ListWorkerConfigurationsOutput, error) + func (c *KafkaConnect) UpdateConnector(input *UpdateConnectorInput) (*UpdateConnectorOutput, error) + func (c *KafkaConnect) UpdateConnectorRequest(input *UpdateConnectorInput) (req *request.Request, output *UpdateConnectorOutput) + func (c *KafkaConnect) UpdateConnectorWithContext(ctx aws.Context, input *UpdateConnectorInput, opts ...request.Option) (*UpdateConnectorOutput, error) + type ListConnectorsInput struct + ConnectorNamePrefix *string + MaxResults *int64 + NextToken *string + func (s *ListConnectorsInput) SetConnectorNamePrefix(v string) *ListConnectorsInput + func (s *ListConnectorsInput) SetMaxResults(v int64) *ListConnectorsInput + func (s *ListConnectorsInput) SetNextToken(v string) *ListConnectorsInput + func (s *ListConnectorsInput) Validate() error + func (s ListConnectorsInput) GoString() string + func (s ListConnectorsInput) String() string + type ListConnectorsOutput struct + Connectors []*ConnectorSummary + NextToken *string + func (s *ListConnectorsOutput) SetConnectors(v []*ConnectorSummary) *ListConnectorsOutput + func (s *ListConnectorsOutput) SetNextToken(v string) *ListConnectorsOutput + func (s ListConnectorsOutput) GoString() string + func (s ListConnectorsOutput) String() string + type ListCustomPluginsInput struct + MaxResults *int64 + NextToken *string + func (s *ListCustomPluginsInput) SetMaxResults(v int64) *ListCustomPluginsInput + func (s *ListCustomPluginsInput) SetNextToken(v string) *ListCustomPluginsInput + func (s *ListCustomPluginsInput) Validate() error + func (s ListCustomPluginsInput) GoString() string + func (s ListCustomPluginsInput) String() string + type ListCustomPluginsOutput struct + CustomPlugins []*CustomPluginSummary + NextToken *string + func (s *ListCustomPluginsOutput) SetCustomPlugins(v []*CustomPluginSummary) *ListCustomPluginsOutput + func (s *ListCustomPluginsOutput) SetNextToken(v string) *ListCustomPluginsOutput + func (s ListCustomPluginsOutput) GoString() string + func (s ListCustomPluginsOutput) String() string + type ListWorkerConfigurationsInput struct + MaxResults *int64 + NextToken *string + func (s *ListWorkerConfigurationsInput) SetMaxResults(v int64) *ListWorkerConfigurationsInput + func (s *ListWorkerConfigurationsInput) SetNextToken(v string) *ListWorkerConfigurationsInput + func (s *ListWorkerConfigurationsInput) Validate() error + func (s ListWorkerConfigurationsInput) GoString() string + func (s ListWorkerConfigurationsInput) String() string + type ListWorkerConfigurationsOutput struct + NextToken *string + WorkerConfigurations []*WorkerConfigurationSummary + func (s *ListWorkerConfigurationsOutput) SetNextToken(v string) *ListWorkerConfigurationsOutput + func (s *ListWorkerConfigurationsOutput) SetWorkerConfigurations(v []*WorkerConfigurationSummary) *ListWorkerConfigurationsOutput + func (s ListWorkerConfigurationsOutput) GoString() string + func (s ListWorkerConfigurationsOutput) String() string + type LogDelivery struct + WorkerLogDelivery *WorkerLogDelivery + func (s *LogDelivery) SetWorkerLogDelivery(v *WorkerLogDelivery) *LogDelivery + func (s *LogDelivery) Validate() error + func (s LogDelivery) GoString() string + func (s LogDelivery) String() string + type LogDeliveryDescription struct + WorkerLogDelivery *WorkerLogDeliveryDescription + func (s *LogDeliveryDescription) SetWorkerLogDelivery(v *WorkerLogDeliveryDescription) *LogDeliveryDescription + func (s LogDeliveryDescription) GoString() string + func (s LogDeliveryDescription) String() string + type NotFoundException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *NotFoundException) Code() string + func (s *NotFoundException) Error() string + func (s *NotFoundException) Message() string + func (s *NotFoundException) OrigErr() error + func (s *NotFoundException) RequestID() string + func (s *NotFoundException) StatusCode() int + func (s NotFoundException) GoString() string + func (s NotFoundException) String() string + type Plugin struct + CustomPlugin *CustomPlugin + func (s *Plugin) SetCustomPlugin(v *CustomPlugin) *Plugin + func (s *Plugin) Validate() error + func (s Plugin) GoString() string + func (s Plugin) String() string + type PluginDescription struct + CustomPlugin *CustomPluginDescription + func (s *PluginDescription) SetCustomPlugin(v *CustomPluginDescription) *PluginDescription + func (s PluginDescription) GoString() string + func (s PluginDescription) String() string + type ProvisionedCapacity struct + McuCount *int64 + WorkerCount *int64 + func (s *ProvisionedCapacity) SetMcuCount(v int64) *ProvisionedCapacity + func (s *ProvisionedCapacity) SetWorkerCount(v int64) *ProvisionedCapacity + func (s *ProvisionedCapacity) Validate() error + func (s ProvisionedCapacity) GoString() string + func (s ProvisionedCapacity) String() string + type ProvisionedCapacityDescription struct + McuCount *int64 + WorkerCount *int64 + func (s *ProvisionedCapacityDescription) SetMcuCount(v int64) *ProvisionedCapacityDescription + func (s *ProvisionedCapacityDescription) SetWorkerCount(v int64) *ProvisionedCapacityDescription + func (s ProvisionedCapacityDescription) GoString() string + func (s ProvisionedCapacityDescription) String() string + type ProvisionedCapacityUpdate struct + McuCount *int64 + WorkerCount *int64 + func (s *ProvisionedCapacityUpdate) SetMcuCount(v int64) *ProvisionedCapacityUpdate + func (s *ProvisionedCapacityUpdate) SetWorkerCount(v int64) *ProvisionedCapacityUpdate + func (s *ProvisionedCapacityUpdate) Validate() error + func (s ProvisionedCapacityUpdate) GoString() string + func (s ProvisionedCapacityUpdate) String() string + type S3Location struct + BucketArn *string + FileKey *string + ObjectVersion *string + func (s *S3Location) SetBucketArn(v string) *S3Location + func (s *S3Location) SetFileKey(v string) *S3Location + func (s *S3Location) SetObjectVersion(v string) *S3Location + func (s *S3Location) Validate() error + func (s S3Location) GoString() string + func (s S3Location) String() string + type S3LocationDescription struct + BucketArn *string + FileKey *string + ObjectVersion *string + func (s *S3LocationDescription) SetBucketArn(v string) *S3LocationDescription + func (s *S3LocationDescription) SetFileKey(v string) *S3LocationDescription + func (s *S3LocationDescription) SetObjectVersion(v string) *S3LocationDescription + func (s S3LocationDescription) GoString() string + func (s S3LocationDescription) String() string + type S3LogDelivery struct + Bucket *string + Enabled *bool + Prefix *string + func (s *S3LogDelivery) SetBucket(v string) *S3LogDelivery + func (s *S3LogDelivery) SetEnabled(v bool) *S3LogDelivery + func (s *S3LogDelivery) SetPrefix(v string) *S3LogDelivery + func (s *S3LogDelivery) Validate() error + func (s S3LogDelivery) GoString() string + func (s S3LogDelivery) String() string + type S3LogDeliveryDescription struct + Bucket *string + Enabled *bool + Prefix *string + func (s *S3LogDeliveryDescription) SetBucket(v string) *S3LogDeliveryDescription + func (s *S3LogDeliveryDescription) SetEnabled(v bool) *S3LogDeliveryDescription + func (s *S3LogDeliveryDescription) SetPrefix(v string) *S3LogDeliveryDescription + func (s S3LogDeliveryDescription) GoString() string + func (s S3LogDeliveryDescription) String() string + type ScaleInPolicy struct + CpuUtilizationPercentage *int64 + func (s *ScaleInPolicy) SetCpuUtilizationPercentage(v int64) *ScaleInPolicy + func (s *ScaleInPolicy) Validate() error + func (s ScaleInPolicy) GoString() string + func (s ScaleInPolicy) String() string + type ScaleInPolicyDescription struct + CpuUtilizationPercentage *int64 + func (s *ScaleInPolicyDescription) SetCpuUtilizationPercentage(v int64) *ScaleInPolicyDescription + func (s ScaleInPolicyDescription) GoString() string + func (s ScaleInPolicyDescription) String() string + type ScaleInPolicyUpdate struct + CpuUtilizationPercentage *int64 + func (s *ScaleInPolicyUpdate) SetCpuUtilizationPercentage(v int64) *ScaleInPolicyUpdate + func (s *ScaleInPolicyUpdate) Validate() error + func (s ScaleInPolicyUpdate) GoString() string + func (s ScaleInPolicyUpdate) String() string + type ScaleOutPolicy struct + CpuUtilizationPercentage *int64 + func (s *ScaleOutPolicy) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicy + func (s *ScaleOutPolicy) Validate() error + func (s ScaleOutPolicy) GoString() string + func (s ScaleOutPolicy) String() string + type ScaleOutPolicyDescription struct + CpuUtilizationPercentage *int64 + func (s *ScaleOutPolicyDescription) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicyDescription + func (s ScaleOutPolicyDescription) GoString() string + func (s ScaleOutPolicyDescription) String() string + type ScaleOutPolicyUpdate struct + CpuUtilizationPercentage *int64 + func (s *ScaleOutPolicyUpdate) SetCpuUtilizationPercentage(v int64) *ScaleOutPolicyUpdate + func (s *ScaleOutPolicyUpdate) Validate() error + func (s ScaleOutPolicyUpdate) GoString() string + func (s ScaleOutPolicyUpdate) String() string + type ServiceUnavailableException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *ServiceUnavailableException) Code() string + func (s *ServiceUnavailableException) Error() string + func (s *ServiceUnavailableException) Message() string + func (s *ServiceUnavailableException) OrigErr() error + func (s *ServiceUnavailableException) RequestID() string + func (s *ServiceUnavailableException) StatusCode() int + func (s ServiceUnavailableException) GoString() string + func (s ServiceUnavailableException) String() string + type StateDescription struct + Code *string + Message *string + func (s *StateDescription) SetCode(v string) *StateDescription + func (s *StateDescription) SetMessage(v string) *StateDescription + func (s StateDescription) GoString() string + func (s StateDescription) String() string + type TooManyRequestsException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *TooManyRequestsException) Code() string + func (s *TooManyRequestsException) Error() string + func (s *TooManyRequestsException) Message() string + func (s *TooManyRequestsException) OrigErr() error + func (s *TooManyRequestsException) RequestID() string + func (s *TooManyRequestsException) StatusCode() int + func (s TooManyRequestsException) GoString() string + func (s TooManyRequestsException) String() string + type UnauthorizedException struct + Message_ *string + RespMetadata protocol.ResponseMetadata + func (s *UnauthorizedException) Code() string + func (s *UnauthorizedException) Error() string + func (s *UnauthorizedException) Message() string + func (s *UnauthorizedException) OrigErr() error + func (s *UnauthorizedException) RequestID() string + func (s *UnauthorizedException) StatusCode() int + func (s UnauthorizedException) GoString() string + func (s UnauthorizedException) String() string + type UpdateConnectorInput struct + Capacity *CapacityUpdate + ConnectorArn *string + CurrentVersion *string + func (s *UpdateConnectorInput) SetCapacity(v *CapacityUpdate) *UpdateConnectorInput + func (s *UpdateConnectorInput) SetConnectorArn(v string) *UpdateConnectorInput + func (s *UpdateConnectorInput) SetCurrentVersion(v string) *UpdateConnectorInput + func (s *UpdateConnectorInput) Validate() error + func (s UpdateConnectorInput) GoString() string + func (s UpdateConnectorInput) String() string + type UpdateConnectorOutput struct + ConnectorArn *string + ConnectorState *string + func (s *UpdateConnectorOutput) SetConnectorArn(v string) *UpdateConnectorOutput + func (s *UpdateConnectorOutput) SetConnectorState(v string) *UpdateConnectorOutput + func (s UpdateConnectorOutput) GoString() string + func (s UpdateConnectorOutput) String() string + type Vpc struct + SecurityGroups []*string + Subnets []*string + func (s *Vpc) SetSecurityGroups(v []*string) *Vpc + func (s *Vpc) SetSubnets(v []*string) *Vpc + func (s *Vpc) Validate() error + func (s Vpc) GoString() string + func (s Vpc) String() string + type VpcDescription struct + SecurityGroups []*string + Subnets []*string + func (s *VpcDescription) SetSecurityGroups(v []*string) *VpcDescription + func (s *VpcDescription) SetSubnets(v []*string) *VpcDescription + func (s VpcDescription) GoString() string + func (s VpcDescription) String() string + type WorkerConfiguration struct + Revision *int64 + WorkerConfigurationArn *string + func (s *WorkerConfiguration) SetRevision(v int64) *WorkerConfiguration + func (s *WorkerConfiguration) SetWorkerConfigurationArn(v string) *WorkerConfiguration + func (s *WorkerConfiguration) Validate() error + func (s WorkerConfiguration) GoString() string + func (s WorkerConfiguration) String() string + type WorkerConfigurationDescription struct + Revision *int64 + WorkerConfigurationArn *string + func (s *WorkerConfigurationDescription) SetRevision(v int64) *WorkerConfigurationDescription + func (s *WorkerConfigurationDescription) SetWorkerConfigurationArn(v string) *WorkerConfigurationDescription + func (s WorkerConfigurationDescription) GoString() string + func (s WorkerConfigurationDescription) String() string + type WorkerConfigurationRevisionDescription struct + CreationTime *time.Time + Description *string + PropertiesFileContent *string + Revision *int64 + func (s *WorkerConfigurationRevisionDescription) SetCreationTime(v time.Time) *WorkerConfigurationRevisionDescription + func (s *WorkerConfigurationRevisionDescription) SetDescription(v string) *WorkerConfigurationRevisionDescription + func (s *WorkerConfigurationRevisionDescription) SetPropertiesFileContent(v string) *WorkerConfigurationRevisionDescription + func (s *WorkerConfigurationRevisionDescription) SetRevision(v int64) *WorkerConfigurationRevisionDescription + func (s WorkerConfigurationRevisionDescription) GoString() string + func (s WorkerConfigurationRevisionDescription) String() string + type WorkerConfigurationRevisionSummary struct + CreationTime *time.Time + Description *string + Revision *int64 + func (s *WorkerConfigurationRevisionSummary) SetCreationTime(v time.Time) *WorkerConfigurationRevisionSummary + func (s *WorkerConfigurationRevisionSummary) SetDescription(v string) *WorkerConfigurationRevisionSummary + func (s *WorkerConfigurationRevisionSummary) SetRevision(v int64) *WorkerConfigurationRevisionSummary + func (s WorkerConfigurationRevisionSummary) GoString() string + func (s WorkerConfigurationRevisionSummary) String() string + type WorkerConfigurationSummary struct + CreationTime *time.Time + Description *string + LatestRevision *WorkerConfigurationRevisionSummary + Name *string + WorkerConfigurationArn *string + func (s *WorkerConfigurationSummary) SetCreationTime(v time.Time) *WorkerConfigurationSummary + func (s *WorkerConfigurationSummary) SetDescription(v string) *WorkerConfigurationSummary + func (s *WorkerConfigurationSummary) SetLatestRevision(v *WorkerConfigurationRevisionSummary) *WorkerConfigurationSummary + func (s *WorkerConfigurationSummary) SetName(v string) *WorkerConfigurationSummary + func (s *WorkerConfigurationSummary) SetWorkerConfigurationArn(v string) *WorkerConfigurationSummary + func (s WorkerConfigurationSummary) GoString() string + func (s WorkerConfigurationSummary) String() string + type WorkerLogDelivery struct + CloudWatchLogs *CloudWatchLogsLogDelivery + Firehose *FirehoseLogDelivery + S3 *S3LogDelivery + func (s *WorkerLogDelivery) SetCloudWatchLogs(v *CloudWatchLogsLogDelivery) *WorkerLogDelivery + func (s *WorkerLogDelivery) SetFirehose(v *FirehoseLogDelivery) *WorkerLogDelivery + func (s *WorkerLogDelivery) SetS3(v *S3LogDelivery) *WorkerLogDelivery + func (s *WorkerLogDelivery) Validate() error + func (s WorkerLogDelivery) GoString() string + func (s WorkerLogDelivery) String() string + type WorkerLogDeliveryDescription struct + CloudWatchLogs *CloudWatchLogsLogDeliveryDescription + Firehose *FirehoseLogDeliveryDescription + S3 *S3LogDeliveryDescription + func (s *WorkerLogDeliveryDescription) SetCloudWatchLogs(v *CloudWatchLogsLogDeliveryDescription) *WorkerLogDeliveryDescription + func (s *WorkerLogDeliveryDescription) SetFirehose(v *FirehoseLogDeliveryDescription) *WorkerLogDeliveryDescription + func (s *WorkerLogDeliveryDescription) SetS3(v *S3LogDeliveryDescription) *WorkerLogDeliveryDescription + func (s WorkerLogDeliveryDescription) GoString() string + func (s WorkerLogDeliveryDescription) String() string
Go to main page