kafka

Mar 14, 2024

Changes in this version

type Config

+ KafkaVersion string

Mar 13, 2024

Changes in this version

type Config

+ SASLAWSCredsDebug bool

+ SASLAWSProfile string

+ SASLAWSRoleArn string

+ SASLTokenUrl string

+ func (c *Config) Token() (*sarama.AccessToken, error)

+ type OAuth2Config interface

+ Token func(ctx context.Context) (*oauth2.Token, error)

Jan 28, 2024

Changes in this version

type Config

+ SASLAWSRegion string

+ type MSKAccessTokenProvider struct

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

Apr 1, 2023

Changes in this version

type Client

+ func (c *Client) DeleteUserScramCredential(userScramCredential UserScramCredential) error

+ func (c *Client) DescribeUserScramCredential(username string, mechanism string) (*UserScramCredential, error)

+ func (c *Client) UpsertUserScramCredential(userScramCredential UserScramCredential) error

type LazyClient

+ func (c *LazyClient) DeleteUserScramCredential(userScramCredential UserScramCredential) error

+ func (c *LazyClient) DescribeUserScramCredential(username string, mechanism string) (*UserScramCredential, error)

+ func (c *LazyClient) UpsertUserScramCredential(userScramCredential UserScramCredential) error

+ type UserScramCredential struct

+ Iterations int32

+ Mechanism sarama.ScramMechanismType

+ Name string

+ Password []byte

+ func (usc UserScramCredential) ID() string

+ func (usc UserScramCredential) String() string

+ type UserScramCredentialMissingError struct

+ func (e UserScramCredentialMissingError) Error() string

Jan 5, 2022

Changes in this version

type Client

+ func (c *Client) AlterQuota(quota Quota, validateOnly bool) error

+ func (c *Client) DescribeQuota(entityType string, entityName string) (*Quota, error)

type LazyClient

+ func (c *LazyClient) AlterQuota(q Quota) error

+ func (c *LazyClient) DescribeQuota(entityType string, entityName string) (*Quota, error)

+ type Quota struct

+ EntityName string

+ EntityType string

+ Ops []QuotaOp

+ func (a Quota) ID() string

+ func (a Quota) String() string

+ type QuotaMissingError struct

+ func (e QuotaMissingError) Error() string

+ type QuotaOp struct

+ Key string

+ Remove bool

+ Value float64

Feb 13, 2021

Changes in this version

type Client

+ func (c *Client) AlterReplicationFactor(t Topic) error

+ func (c *Client) CanAlterReplicationFactor() bool

+ func (c *Client) IsReplicationFactorUpdating(topic string) (bool, error)

type LazyClient

+ func (c *LazyClient) AlterReplicationFactor(t Topic) error

+ func (c *LazyClient) CanAlterReplicationFactor() (bool, error)

+ func (c *LazyClient) IsReplicationFactorUpdating(topic string) (bool, error)

Jan 19, 2021

Changes in this version

+ func ImportACL(d *schema.ResourceData, m interface{}) ([]*schema.ResourceData, error)

Jun 14, 2020

Changes in this version

type Config

+ ClientCertKeyPassphrase string

May 1, 2020

Changes in this version

+ func ACLOperationToString(in sarama.AclOperation) string

+ func ACLPermissionTypeToString(in sarama.AclPermissionType) string

+ func ACLResourceToString(in sarama.AclResourceType) string

type Client

+ func (c *Client) DescribeACLs(s StringlyTypedACL) ([]*sarama.ResourceAcls, error)

Mar 2, 2020

Changes in this version

+ type LazyClient struct

+ Config *Config

+ func (c *LazyClient) AddPartitions(t Topic) error

+ func (c *LazyClient) CreateACL(s StringlyTypedACL) error

+ func (c *LazyClient) CreateTopic(t Topic) error

+ func (c *LazyClient) DeleteACL(s StringlyTypedACL) error

+ func (c *LazyClient) DeleteTopic(t string) error

+ func (c *LazyClient) ListACLs() ([]*sarama.ResourceAcls, error)

+ func (c *LazyClient) ReadTopic(name string) (Topic, error)

+ func (c *LazyClient) UpdateTopic(t Topic) error

Dec 30, 2019

Changes in this version

+ func NewTLSConfig(clientCert, clientKey, caCert string) (*tls.Config, error)

type Client

+ func (c *Client) SaramaClient() sarama.Client

type Config

+ CACert string

+ ClientCert string

+ type StringlyTypedACL struct

+ ACL ACL

+ func (a StringlyTypedACL) String() string

May 22, 2019

Changes in this version

+ var SHA256 scram.HashGeneratorFcn = func() hash.Hash

+ var SHA512 scram.HashGeneratorFcn = func() hash.Hash

type Config

+ SASLMechanism string

type Resource

+ PatternTypeFilter string

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

Oct 3, 2018

Changes in this version

+ func MapEq(result, expected map[string]*string) error

+ func Provider() terraform.ResourceProvider

+ func ReplicaCount(c sarama.Client, topic string, partitions []int32) (int, error)

+ type ACL struct

+ Host string

+ Operation string

+ PermissionType string

+ Principal string

+ type Client struct

+ func NewClient(config *Config) (*Client, error)

+ func (c *Client) AddPartitions(t Topic) error

+ func (c *Client) CreateACL(s stringlyTypedACL) error

+ func (c *Client) CreateTopic(t Topic) error

+ func (c *Client) DeleteACL(s stringlyTypedACL) error

+ func (c *Client) DeleteTopic(t string) error

+ func (c *Client) ListACLs() ([]*sarama.ResourceAcls, error)

+ func (c *Client) UpdateTopic(topic Topic) error

+ func (client *Client) ReadTopic(name string) (Topic, error)

+ type Config struct

+ BootstrapServers *[]string

+ CACertFile string

+ ClientCertFile string

+ ClientCertKey string

+ SASLPassword string

+ SASLUsername string

+ SkipTLSVerify bool

+ TLSEnabled bool

+ Timeout int

+ func (c *Config) SASLEnabled() bool

+ type Resource struct

+ Name string

+ Type string

+ type Topic struct

+ Config map[string]*string

+ Name string

+ Partitions int32

+ ReplicationFactor int16

+ func (t *Topic) Equal(other Topic) bool

+ type TopicMissingError struct

+ func (e TopicMissingError) Error() string