kafkaconnect

Sep 20, 2024

Changes in this version

type Options

+ MeterProvider metrics.MeterProvider

+ TracerProvider tracing.TracerProvider

Jun 17, 2024

Changes in this version

type Options

+ AccountIDEndpointMode aws.AccountIDEndpointMode

Feb 26, 2024

Changes in this version

type Client

+ func (c *Client) DeleteWorkerConfiguration(ctx context.Context, params *DeleteWorkerConfigurationInput, ...) (*DeleteWorkerConfigurationOutput, error)

+ func (c *Client) ListTagsForResource(ctx context.Context, params *ListTagsForResourceInput, ...) (*ListTagsForResourceOutput, error)

+ func (c *Client) TagResource(ctx context.Context, params *TagResourceInput, optFns ...func(*Options)) (*TagResourceOutput, error)

+ func (c *Client) UntagResource(ctx context.Context, params *UntagResourceInput, optFns ...func(*Options)) (*UntagResourceOutput, error)

type CreateConnectorInput

+ Tags map[string]string

type CreateCustomPluginInput

+ Tags map[string]string

type CreateWorkerConfigurationInput

+ Tags map[string]string

type CreateWorkerConfigurationOutput

+ WorkerConfigurationState types.WorkerConfigurationState

+ type DeleteWorkerConfigurationInput struct

+ WorkerConfigurationArn *string

+ type DeleteWorkerConfigurationOutput struct

+ ResultMetadata middleware.Metadata

+ WorkerConfigurationArn *string

+ WorkerConfigurationState types.WorkerConfigurationState

type DescribeWorkerConfigurationOutput

+ WorkerConfigurationState types.WorkerConfigurationState

type ListCustomPluginsInput

+ NamePrefix *string

+ type ListTagsForResourceInput struct

+ ResourceArn *string

+ type ListTagsForResourceOutput struct

+ ResultMetadata middleware.Metadata

+ Tags map[string]string

type ListWorkerConfigurationsInput

+ NamePrefix *string

+ type TagResourceInput struct

+ ResourceArn *string

+ Tags map[string]string

+ type TagResourceOutput struct

+ ResultMetadata middleware.Metadata

+ type UntagResourceInput struct

+ ResourceArn *string

+ TagKeys []string

+ type UntagResourceOutput struct

+ ResultMetadata middleware.Metadata

Nov 29, 2023

Changes in this version

type Client

+ func (c *Client) Options() Options

Nov 15, 2023

Changes in this version

+ func WithSigV4SigningName(name string) func(*Options)

+ func WithSigV4SigningRegion(region string) func(*Options)

+ type AuthResolverParameters struct

+ Operation string

+ Region string

+ type AuthSchemeResolver interface

+ ResolveAuthSchemes func(context.Context, *AuthResolverParameters) ([]*smithyauth.Option, error)

type Options

+ AuthSchemeResolver AuthSchemeResolver

+ AuthSchemes []smithyhttp.AuthScheme

+ func (o Options) GetIdentityResolver(schemeID string) smithyauth.IdentityResolver

Jul 31, 2023

Changes in this version

+ func WithEndpointResolverV2(v EndpointResolverV2) func(*Options)

+ type EndpointParameters struct

+ Endpoint *string

+ Region *string

+ UseDualStack *bool

+ UseFIPS *bool

+ func (p EndpointParameters) ValidateRequired() error

+ func (p EndpointParameters) WithDefaults() EndpointParameters

+ type EndpointResolverV2 interface

+ ResolveEndpoint func(ctx context.Context, params EndpointParameters) (smithyendpoints.Endpoint, error)

+ func NewDefaultEndpointResolverV2() EndpointResolverV2

type Options

+ BaseEndpoint *string

+ EndpointResolverV2 EndpointResolverV2

Jul 13, 2023

Changes in this version

type Options

+ AppID string

Mar 8, 2022

Changes in this version

type Client

+ func (c *Client) DeleteCustomPlugin(ctx context.Context, params *DeleteCustomPluginInput, optFns ...func(*Options)) (*DeleteCustomPluginOutput, error)

+ type DeleteCustomPluginInput struct

+ CustomPluginArn *string

+ type DeleteCustomPluginOutput struct

+ CustomPluginArn *string

+ CustomPluginState types.CustomPluginState

+ ResultMetadata middleware.Metadata

type DescribeConnectorOutput

+ StateDescription *types.StateDescription

type DescribeCustomPluginOutput

+ StateDescription *types.StateDescription

Feb 24, 2022

Changes in this version

type Options

+ RetryMaxAttempts int

+ RetryMode aws.RetryMode

Jan 14, 2022

Changes in this version

type Options

+ DefaultsMode aws.DefaultsMode

+ RuntimeEnvironment aws.RuntimeEnvironment

Sep 17, 2021

Changes in this version

+ const ServiceAPIVersion

+ const ServiceID

+ func NewDefaultEndpointResolver() *internalendpoints.Resolver

+ func WithAPIOptions(optFns ...func(*middleware.Stack) error) func(*Options)

+ func WithEndpointResolver(v EndpointResolver) func(*Options)

+ type Client struct

+ func New(options Options, optFns ...func(*Options)) *Client

+ func NewFromConfig(cfg aws.Config, optFns ...func(*Options)) *Client

+ func (c *Client) CreateConnector(ctx context.Context, params *CreateConnectorInput, optFns ...func(*Options)) (*CreateConnectorOutput, error)

+ func (c *Client) CreateCustomPlugin(ctx context.Context, params *CreateCustomPluginInput, optFns ...func(*Options)) (*CreateCustomPluginOutput, error)

+ func (c *Client) CreateWorkerConfiguration(ctx context.Context, params *CreateWorkerConfigurationInput, ...) (*CreateWorkerConfigurationOutput, error)

+ func (c *Client) DeleteConnector(ctx context.Context, params *DeleteConnectorInput, optFns ...func(*Options)) (*DeleteConnectorOutput, error)

+ func (c *Client) DescribeConnector(ctx context.Context, params *DescribeConnectorInput, optFns ...func(*Options)) (*DescribeConnectorOutput, error)

+ func (c *Client) DescribeCustomPlugin(ctx context.Context, params *DescribeCustomPluginInput, ...) (*DescribeCustomPluginOutput, error)

+ func (c *Client) DescribeWorkerConfiguration(ctx context.Context, params *DescribeWorkerConfigurationInput, ...) (*DescribeWorkerConfigurationOutput, error)

+ func (c *Client) ListConnectors(ctx context.Context, params *ListConnectorsInput, optFns ...func(*Options)) (*ListConnectorsOutput, error)

+ func (c *Client) ListCustomPlugins(ctx context.Context, params *ListCustomPluginsInput, optFns ...func(*Options)) (*ListCustomPluginsOutput, error)

+ func (c *Client) ListWorkerConfigurations(ctx context.Context, params *ListWorkerConfigurationsInput, ...) (*ListWorkerConfigurationsOutput, error)

+ func (c *Client) UpdateConnector(ctx context.Context, params *UpdateConnectorInput, optFns ...func(*Options)) (*UpdateConnectorOutput, error)

+ type CreateConnectorInput struct

+ Capacity *types.Capacity

+ ConnectorConfiguration map[string]string

+ ConnectorDescription *string

+ ConnectorName *string

+ KafkaCluster *types.KafkaCluster

+ KafkaClusterClientAuthentication *types.KafkaClusterClientAuthentication

+ KafkaClusterEncryptionInTransit *types.KafkaClusterEncryptionInTransit

+ KafkaConnectVersion *string

+ LogDelivery *types.LogDelivery

+ Plugins []types.Plugin

+ ServiceExecutionRoleArn *string

+ WorkerConfiguration *types.WorkerConfiguration

+ type CreateConnectorOutput struct

+ ConnectorArn *string

+ ConnectorName *string

+ ConnectorState types.ConnectorState

+ ResultMetadata middleware.Metadata

+ type CreateCustomPluginInput struct

+ ContentType types.CustomPluginContentType

+ Description *string

+ Location *types.CustomPluginLocation

+ Name *string

+ type CreateCustomPluginOutput struct

+ CustomPluginArn *string

+ CustomPluginState types.CustomPluginState

+ Name *string

+ ResultMetadata middleware.Metadata

+ Revision int64

+ type CreateWorkerConfigurationInput struct

+ Description *string

+ Name *string

+ PropertiesFileContent *string

+ type CreateWorkerConfigurationOutput struct

+ CreationTime *time.Time

+ LatestRevision *types.WorkerConfigurationRevisionSummary

+ Name *string

+ ResultMetadata middleware.Metadata

+ WorkerConfigurationArn *string

+ type DeleteConnectorInput struct

+ ConnectorArn *string

+ CurrentVersion *string

+ type DeleteConnectorOutput struct

+ ConnectorArn *string

+ ConnectorState types.ConnectorState

+ ResultMetadata middleware.Metadata

+ type DescribeConnectorInput struct

+ ConnectorArn *string

+ type DescribeConnectorOutput struct

+ Capacity *types.CapacityDescription

+ ConnectorArn *string

+ ConnectorConfiguration map[string]string

+ ConnectorDescription *string

+ ConnectorName *string

+ ConnectorState types.ConnectorState

+ CreationTime *time.Time

+ CurrentVersion *string

+ KafkaCluster *types.KafkaClusterDescription

+ KafkaClusterClientAuthentication *types.KafkaClusterClientAuthenticationDescription

+ KafkaClusterEncryptionInTransit *types.KafkaClusterEncryptionInTransitDescription

+ KafkaConnectVersion *string

+ LogDelivery *types.LogDeliveryDescription

+ Plugins []types.PluginDescription

+ ResultMetadata middleware.Metadata

+ ServiceExecutionRoleArn *string

+ WorkerConfiguration *types.WorkerConfigurationDescription

+ type DescribeCustomPluginInput struct

+ CustomPluginArn *string

+ type DescribeCustomPluginOutput struct

+ CreationTime *time.Time

+ CustomPluginArn *string

+ CustomPluginState types.CustomPluginState

+ Description *string

+ LatestRevision *types.CustomPluginRevisionSummary

+ Name *string

+ ResultMetadata middleware.Metadata

+ type DescribeWorkerConfigurationInput struct

+ WorkerConfigurationArn *string

+ type DescribeWorkerConfigurationOutput struct

+ CreationTime *time.Time

+ Description *string

+ LatestRevision *types.WorkerConfigurationRevisionDescription

+ Name *string

+ ResultMetadata middleware.Metadata

+ WorkerConfigurationArn *string

+ type EndpointResolver interface

+ ResolveEndpoint func(region string, options EndpointResolverOptions) (aws.Endpoint, error)

+ func EndpointResolverFromURL(url string, optFns ...func(*aws.Endpoint)) EndpointResolver

+ type EndpointResolverFunc func(region string, options EndpointResolverOptions) (aws.Endpoint, error)

+ func (fn EndpointResolverFunc) ResolveEndpoint(region string, options EndpointResolverOptions) (endpoint aws.Endpoint, err error)

+ type EndpointResolverOptions = internalendpoints.Options

+ type HTTPClient interface

+ Do func(*http.Request) (*http.Response, error)

+ type HTTPSignerV4 interface

+ SignHTTP func(ctx context.Context, credentials aws.Credentials, r *http.Request, ...) error

+ type ListConnectorsAPIClient interface

+ ListConnectors func(context.Context, *ListConnectorsInput, ...func(*Options)) (*ListConnectorsOutput, error)

+ type ListConnectorsInput struct

+ ConnectorNamePrefix *string

+ MaxResults int32

+ NextToken *string

+ type ListConnectorsOutput struct

+ Connectors []types.ConnectorSummary

+ NextToken *string

+ ResultMetadata middleware.Metadata

+ type ListConnectorsPaginator struct

+ func NewListConnectorsPaginator(client ListConnectorsAPIClient, params *ListConnectorsInput, ...) *ListConnectorsPaginator

+ func (p *ListConnectorsPaginator) HasMorePages() bool

+ func (p *ListConnectorsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListConnectorsOutput, error)

+ type ListConnectorsPaginatorOptions struct

+ Limit int32

+ StopOnDuplicateToken bool

+ type ListCustomPluginsAPIClient interface

+ ListCustomPlugins func(context.Context, *ListCustomPluginsInput, ...func(*Options)) (*ListCustomPluginsOutput, error)

+ type ListCustomPluginsInput struct

+ MaxResults int32

+ NextToken *string

+ type ListCustomPluginsOutput struct

+ CustomPlugins []types.CustomPluginSummary

+ NextToken *string

+ ResultMetadata middleware.Metadata

+ type ListCustomPluginsPaginator struct

+ func NewListCustomPluginsPaginator(client ListCustomPluginsAPIClient, params *ListCustomPluginsInput, ...) *ListCustomPluginsPaginator

+ func (p *ListCustomPluginsPaginator) HasMorePages() bool

+ func (p *ListCustomPluginsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListCustomPluginsOutput, error)

+ type ListCustomPluginsPaginatorOptions struct

+ Limit int32

+ StopOnDuplicateToken bool

+ type ListWorkerConfigurationsAPIClient interface

+ ListWorkerConfigurations func(context.Context, *ListWorkerConfigurationsInput, ...func(*Options)) (*ListWorkerConfigurationsOutput, error)

+ type ListWorkerConfigurationsInput struct

+ MaxResults int32

+ NextToken *string

+ type ListWorkerConfigurationsOutput struct

+ NextToken *string

+ ResultMetadata middleware.Metadata

+ WorkerConfigurations []types.WorkerConfigurationSummary

+ type ListWorkerConfigurationsPaginator struct

+ func NewListWorkerConfigurationsPaginator(client ListWorkerConfigurationsAPIClient, ...) *ListWorkerConfigurationsPaginator

+ func (p *ListWorkerConfigurationsPaginator) HasMorePages() bool

+ func (p *ListWorkerConfigurationsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListWorkerConfigurationsOutput, error)

+ type ListWorkerConfigurationsPaginatorOptions struct

+ Limit int32

+ StopOnDuplicateToken bool

+ type Options struct

+ APIOptions []func(*middleware.Stack) error

+ ClientLogMode aws.ClientLogMode

+ Credentials aws.CredentialsProvider

+ EndpointOptions EndpointResolverOptions

+ EndpointResolver EndpointResolver

+ HTTPClient HTTPClient

+ HTTPSignerV4 HTTPSignerV4

+ Logger logging.Logger

+ Region string

+ Retryer aws.Retryer

+ func (o Options) Copy() Options

+ type ResolveEndpoint struct

+ Options EndpointResolverOptions

+ Resolver EndpointResolver

+ func (*ResolveEndpoint) ID() string

+ func (m *ResolveEndpoint) HandleSerialize(ctx context.Context, in middleware.SerializeInput, ...) (out middleware.SerializeOutput, metadata middleware.Metadata, err error)

+ type UpdateConnectorInput struct

+ Capacity *types.CapacityUpdate

+ ConnectorArn *string

+ CurrentVersion *string

+ type UpdateConnectorOutput struct

+ ConnectorArn *string

+ ConnectorState types.ConnectorState

+ ResultMetadata middleware.Metadata