Documentation ¶
Index ¶
- Variables
- func ACLOperationToString(in sarama.AclOperation) string
- func ACLPermissionTypeToString(in sarama.AclPermissionType) string
- func ACLResourceToString(in sarama.AclResourceType) string
- func MapEq(result, expected map[string]*string) error
- func NewTLSConfig(clientCert, clientKey, caCert, clientKeyPassphrase string) (*tls.Config, error)
- func Provider() *schema.Provider
- 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) AlterQuota(quota Quota, validateOnly bool) error
- func (c *Client) AlterReplicationFactor(t Topic) error
- func (c *Client) CanAlterReplicationFactor() bool
- 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) DescribeACLs(s StringlyTypedACL) ([]*sarama.ResourceAcls, error)
- func (c *Client) DescribeQuota(entityType string, entityName string) (*Quota, error)
- func (c *Client) IsReplicationFactorUpdating(topic string) (bool, error)
- func (c *Client) ListACLs() ([]*sarama.ResourceAcls, error)
- func (client *Client) ReadTopic(name string, refreshMetadata bool) (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) AlterQuota(q Quota) error
- func (c *LazyClient) AlterReplicationFactor(t Topic) error
- func (c *LazyClient) CanAlterReplicationFactor() (bool, 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) DescribeQuota(entityType string, entityName string) (*Quota, error)
- func (c *LazyClient) IsReplicationFactorUpdating(topic string) (bool, error)
- func (c *LazyClient) ListACLs() ([]*sarama.ResourceAcls, error)
- func (c *LazyClient) ReadTopic(name string, refresh_metadata bool) (Topic, error)
- func (c *LazyClient) UpdateTopic(t Topic) error
- type Quota
- type QuotaMissingError
- type QuotaOp
- type Resource
- type StringlyTypedACL
- 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 ACLOperationToString ¶ added in v0.2.5
func ACLOperationToString(in sarama.AclOperation) string
ACLOperationToString converts sarama.AclOperations to a String representation
func ACLPermissionTypeToString ¶ added in v0.2.5
func ACLPermissionTypeToString(in sarama.AclPermissionType) string
ACLPermissionTypeToString converts sarama.AclPermissionTypes to Strings
func ACLResourceToString ¶ added in v0.2.5
func ACLResourceToString(in sarama.AclResourceType) string
func NewTLSConfig ¶ added in v0.2.3
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) AddPartitions ¶
func (*Client) AlterQuota ¶ added in v0.4.2
func (*Client) AlterReplicationFactor ¶ added in v0.3.0
func (*Client) CanAlterReplicationFactor ¶ added in v0.3.0
func (*Client) CreateACL ¶
func (c *Client) CreateACL(s StringlyTypedACL) error
func (*Client) CreateTopic ¶
func (*Client) DeleteACL ¶
func (c *Client) DeleteACL(s StringlyTypedACL) error
func (*Client) DeleteTopic ¶
func (*Client) DescribeACLs ¶ added in v0.2.5
func (c *Client) DescribeACLs(s StringlyTypedACL) ([]*sarama.ResourceAcls, error)
DescribeACLs get ResourceAcls for a specific resource
func (*Client) DescribeQuota ¶ added in v0.4.2
func (*Client) IsReplicationFactorUpdating ¶ added in v0.3.0
func (*Client) SaramaClient ¶ added in v0.2.3
func (*Client) UpdateTopic ¶
type LazyClient ¶ added in v0.2.4
type LazyClient struct { Config *Config // contains filtered or unexported fields }
func (*LazyClient) AddPartitions ¶ added in v0.2.4
func (c *LazyClient) AddPartitions(t Topic) error
func (*LazyClient) AlterQuota ¶ added in v0.4.2
func (c *LazyClient) AlterQuota(q Quota) error
func (*LazyClient) AlterReplicationFactor ¶ added in v0.3.0
func (c *LazyClient) AlterReplicationFactor(t Topic) error
func (*LazyClient) CanAlterReplicationFactor ¶ added in v0.3.0
func (c *LazyClient) CanAlterReplicationFactor() (bool, error)
func (*LazyClient) CreateACL ¶ added in v0.2.4
func (c *LazyClient) CreateACL(s StringlyTypedACL) error
func (*LazyClient) CreateTopic ¶ added in v0.2.4
func (c *LazyClient) CreateTopic(t Topic) error
func (*LazyClient) DeleteACL ¶ added in v0.2.4
func (c *LazyClient) DeleteACL(s StringlyTypedACL) error
func (*LazyClient) DeleteTopic ¶ added in v0.2.4
func (c *LazyClient) DeleteTopic(t string) error
func (*LazyClient) DescribeQuota ¶ added in v0.4.2
func (c *LazyClient) DescribeQuota(entityType string, entityName string) (*Quota, error)
func (*LazyClient) IsReplicationFactorUpdating ¶ added in v0.3.0
func (c *LazyClient) IsReplicationFactorUpdating(topic string) (bool, error)
func (*LazyClient) ListACLs ¶ added in v0.2.4
func (c *LazyClient) ListACLs() ([]*sarama.ResourceAcls, error)
func (*LazyClient) ReadTopic ¶ added in v0.2.4
func (c *LazyClient) ReadTopic(name string, refresh_metadata bool) (Topic, error)
func (*LazyClient) UpdateTopic ¶ added in v0.2.4
func (c *LazyClient) UpdateTopic(t Topic) error
type QuotaMissingError ¶ added in v0.4.2
type QuotaMissingError struct {
// contains filtered or unexported fields
}
func (QuotaMissingError) Error ¶ added in v0.4.2
func (e QuotaMissingError) Error() string
type StringlyTypedACL ¶ added in v0.2.3
func (StringlyTypedACL) String ¶ added in v0.2.3
func (a StringlyTypedACL) String() string
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.