kafka

Documentation

Index

• Variables
• func MapEq(result, expected map[string]*string) error
• func NewTLSConfig(clientCert, clientKey, caCert string) (*tls.Config, error)
• func Provider() terraform.ResourceProvider
• func ReplicaCount(c sarama.Client, topic string, partitions []int32) (int, error)
• type ACL
• type Client
  • 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 (client *Client) ReadTopic(name string) (Topic, error)
  • func (c *Client) SaramaClient() sarama.Client
  • func (c *Client) UpdateTopic(topic Topic) error
• type Config
• type LazyClient
  • 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
• type Resource
• type StringlyTypedACL
  • func (a StringlyTypedACL) String() string
• type Topic
  • func (t *Topic) Equal(other Topic) bool
• type TopicMissingError
  • func (e TopicMissingError) Error() string
• type XDGSCRAMClient
  • 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)

Variables

var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }

var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }

Functions

func MapEq

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

MapEq compares two maps, and checks that the keys and values are the same

func NewTLSConfig

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

func Provider

func Provider() terraform.ResourceProvider

func ReplicaCount

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

ReplicaCount returns the replication_factor for a partition Returns an error if it cannot determine the count, or if the number of replicas is different across partitions

Types

type ACL

type ACL struct {
	Principal      string `json:"principal"`
	Host           string `json:"host"`
	Operation      string `json:"operation"`
	PermissionType string `json:"permission_type"`
}

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

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

func (*Client) AddPartitions

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

func (*Client) CreateACL

func (c *Client) CreateACL(s StringlyTypedACL) error

func (*Client) CreateTopic

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

func (*Client) DeleteACL

func (c *Client) DeleteACL(s StringlyTypedACL) error

func (*Client) DeleteTopic

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

func (*Client) ListACLs

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

func (*Client) ReadTopic

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

func (*Client) SaramaClient

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

func (*Client) UpdateTopic

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

type Config

type Config struct {
	BootstrapServers *[]string
	Timeout          int
	CACert           string
	ClientCert       string
	ClientCertKey    string
	TLSEnabled       bool
	SkipTLSVerify    bool
	SASLUsername     string
	SASLPassword     string
	SASLMechanism    string
}

type LazyClient

type LazyClient struct {
	Config *Config
	// contains filtered or unexported fields
}

func (*LazyClient) AddPartitions

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

func (*LazyClient) CreateACL

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

func (*LazyClient) CreateTopic

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

func (*LazyClient) DeleteACL

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

func (*LazyClient) DeleteTopic

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

func (*LazyClient) ListACLs

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

func (*LazyClient) ReadTopic

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

func (*LazyClient) UpdateTopic

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

type Resource

type Resource struct {
	Type              string `json:"type"`
	Name              string `json:"name"`
	PatternTypeFilter string `json:"pattern_type_filter"`
}

type StringlyTypedACL

type StringlyTypedACL struct {
	ACL      ACL `json:"acl"`
	Resource `json:"resource"`
}

func (StringlyTypedACL) String

func (a StringlyTypedACL) String() string

type Topic

type Topic struct {
	Name              string
	Partitions        int32
	ReplicationFactor int16
	Config            map[string]*string
}

func (*Topic) Equal

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

type TopicMissingError

type TopicMissingError struct {
	// contains filtered or unexported fields
}

func (TopicMissingError) Error

func (e TopicMissingError) Error() string

type XDGSCRAMClient

type XDGSCRAMClient struct {
	*scram.Client
	*scram.ClientConversation
	scram.HashGeneratorFcn
}

func (*XDGSCRAMClient) Begin

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

func (*XDGSCRAMClient) Done

func (x *XDGSCRAMClient) Done() bool

func (*XDGSCRAMClient) Step

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