kafka

Documentation

Index

• func MapEq(result, expected map[string]*string) error
• func Provider() terraform.ResourceProvider
• func ReplicaCount(c sarama.Client, topic string, partitions []int32) (int, error)
• type Client
  • func NewClient(config *Config) (*Client, error)
  • func (c *Client) AddPartitions(t Topic) error
  • func (c *Client) CreateTopic(t Topic) error
  • func (c *Client) DeleteTopic(t string) error
  • func (client *Client) ReadTopic(name string) (Topic, error)
  • func (c *Client) UpdateTopic(topic Topic) error
• type Config
• type Topic
  • func (t *Topic) Equal(other Topic) bool
• type TopicMissingError
  • func (e TopicMissingError) Error() string

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 Provider

func Provider() terraform.ResourceProvider

Provider returns a 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 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) CreateTopic

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

func (*Client) DeleteTopic

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

func (*Client) ReadTopic

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

func (*Client) UpdateTopic

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

type Config

type Config struct {
	BootstrapServers *[]string
	Timeout          int
}

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