client

Apr 7, 2026

Changes in this version

+ func NewGlueClient(ctx context.Context, region string) (*glue.Client, error)

type AdminOption

+ func WithInsecureSkipVerify() AdminOption

+ func WithSASLPlainAuthNoTLS(username, password string) AdminOption

Mar 30, 2026

Changes in this version

+ func NewKafkaClient(brokerAddresses []string, region string, opts ...AdminOption) (sarama.Client, error)

type AdminOption

+ func AdminOptionForAuth(authType types.AuthType, clusterAuth types.ClusterAuth) AdminOption

+ func WithSASLPlainAuth(username, password string) AdminOption

Jan 8, 2026

Changes in this version

+ type RateLimitedMSKClient struct

+ func (c *RateLimitedMSKClient) DescribeTopic(ctx context.Context, params *kafka.DescribeTopicInput, ...) (*kafka.DescribeTopicOutput, error)

+ func (c *RateLimitedMSKClient) Wait(ctx context.Context) error

Oct 28, 2025

Changes in this version

+ func NewSchemaRegistryClient(url string, opts ...SchemaRegistryOption) (schemaregistry.Client, error)

type KafkaAdmin

+ GetAllMessagesWithKeyFilter func(topicName string, keyPrefix string) (map[string]string, error)

+ GetConnectorStatusMessages func(topicName string) (map[string]string, error)

type KafkaAdminClient

+ func (k *KafkaAdminClient) GetAllMessagesWithKeyFilter(topicName string, keyPrefix string) (map[string]string, error)

+ func (k *KafkaAdminClient) GetConnectorStatusMessages(topicName string) (map[string]string, error)

+ type SchemaRegistryConfig struct

+ type SchemaRegistryOption func(*SchemaRegistryConfig)

+ func WithBasicAuth(username, password string) SchemaRegistryOption

+ func WithUnauthenticated() SchemaRegistryOption

Oct 9, 2025

Changes in this version

+ func NewMSKConnectClient(region string) (*kafkaconnect.Client, error)

type AdminOption

+ func WithUnauthenticatedPlaintextAuth() AdminOption

+ func WithUnauthenticatedTlsAuth() AdminOption

Sep 16, 2025

Changes in this version

type KafkaAdmin

+ ListTopicsWithConfigs func() (map[string]sarama.TopicDetail, error)

type KafkaAdminClient

+ func (k *KafkaAdminClient) ListTopicsWithConfigs() (map[string]sarama.TopicDetail, error)

Aug 19, 2025

Changes in this version

+ func NewEC2Client(region string) (*ec2.Client, error)

+ func NewS3Client(region string) (*s3.Client, error)

Aug 13, 2025

Changes in this version

+ func NewIAMClient() (*iam.Client, error)

Jul 25, 2025

Changes in this version

type KafkaAdmin

+ ListAcls func() ([]sarama.ResourceAcls, error)

type KafkaAdminClient

+ func (k *KafkaAdminClient) ListAcls() ([]sarama.ResourceAcls, error)

Jul 23, 2025

Changes in this version

+ var SHA256 scram.HashGeneratorFcn = sha256.New

+ var SHA512 scram.HashGeneratorFcn = sha512.New

+ func NewCloudWatchClient(region string) (*cloudwatch.Client, error)

+ func NewCostExplorerClient(region string) (*costexplorer.Client, error)

+ func NewMSKClient(region string) (*kafka.Client, error)

+ type AdminConfig struct

+ type AdminOption func(*AdminConfig)

+ func WithIAMAuth() AdminOption

+ func WithSASLSCRAMAuth(username, password string) AdminOption

+ func WithTLSAuth(caCertFile string, clientCertFile string, clientKeyFile string) AdminOption

+ func WithUnauthenticatedAuth() AdminOption

+ type ClusterKafkaMetadata struct

+ Brokers []*sarama.Broker

+ ClusterID string

+ ControllerID int32

+ type KafkaAdmin interface

+ Close func() error

+ DescribeConfig func() ([]sarama.ConfigEntry, error)

+ GetClusterKafkaMetadata func() (*ClusterKafkaMetadata, error)

+ ListTopics func() (map[string]sarama.TopicDetail, error)

+ func NewKafkaAdmin(brokerAddresses []string, ...) (KafkaAdmin, error)

+ type KafkaAdminClient struct

+ func (k *KafkaAdminClient) Close() error

+ func (k *KafkaAdminClient) DescribeConfig() ([]sarama.ConfigEntry, error)

+ func (k *KafkaAdminClient) GetClusterKafkaMetadata() (*ClusterKafkaMetadata, error)

+ func (k *KafkaAdminClient) ListTopics() (map[string]sarama.TopicDetail, error)

+ type MSKAccessTokenProvider struct

+ func (m *MSKAccessTokenProvider) Token() (*sarama.AccessToken, error)

+ type XDGSCRAMClient struct

+ func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)

+ func (x *XDGSCRAMClient) Done() bool

+ func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)