Documentation ¶
Index ¶
- Variables
- 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
- type Client
- 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) UpdateTopic(topic Topic) error
- type Config
- type Resource
- type Topic
- type TopicMissingError
- type XDGSCRAMClient
Constants ¶
This section is empty.
Variables ¶
View Source
var SHA256 scram.HashGeneratorFcn = func() hash.Hash { return sha256.New() }
View Source
var SHA512 scram.HashGeneratorFcn = func() hash.Hash { return sha512.New() }
Functions ¶
func Provider ¶
func Provider() terraform.ResourceProvider
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) AddPartitions ¶
func (*Client) CreateTopic ¶
func (*Client) DeleteTopic ¶
func (*Client) UpdateTopic ¶
type Topic ¶
type TopicMissingError ¶
type TopicMissingError struct {
// contains filtered or unexported fields
}
func (TopicMissingError) Error ¶
func (e TopicMissingError) Error() string
type XDGSCRAMClient ¶ added in v0.2.0
type XDGSCRAMClient struct { *scram.Client *scram.ClientConversation scram.HashGeneratorFcn }
func (*XDGSCRAMClient) Begin ¶ added in v0.2.0
func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error)
func (*XDGSCRAMClient) Done ¶ added in v0.2.0
func (x *XDGSCRAMClient) Done() bool
Click to show internal directories.
Click to hide internal directories.