Documentation
¶
Index ¶
Constants ¶
View Source
const ( // PEMCertificateBlock has to match PEM certificate PEMCertificateBlock = `-----BEGIN CERTIFICATE-----(.*)-----END CERTIFICATE-----` // PEMPrivKeyBlock has to match PEM Key PEMPrivKeyBlock = `-----BEGIN PRIVATE KEY-----(.*)-----END PRIVATE KEY-----` // ReplacePattern to be replacing in Regexps, as strings.Replace is faster than regexp ReplacePattern = `(.*)` )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterClient ¶
type ClusterClient struct {
// contains filtered or unexported fields
}
ClusterClient will abstract work with Kafka clusters
func (*ClusterClient) Close ¶
func (c *ClusterClient) Close()
Close will close kafka connection to cleanup resources
func (*ClusterClient) InsertTopic ¶
func (c *ClusterClient) InsertTopic(topic *api.KafkaTopicSpec) error
type ClusterConfig ¶
type ClusterConfig struct {
// contains filtered or unexported fields
}
ClusterConfig will configure settings for Kafka cluster and it will get a new ClusterCient
func NewClusterConfig ¶
func NewClusterConfig(options ...Option) (*ClusterConfig, error)
NewClusterConfig would return ClusterClient or would return error if error occured
func (*ClusterConfig) GetClient ¶
func (c *ClusterConfig) GetClient() (*ClusterClient, error)
GetClient will make a new Kafka clients
type Option ¶
type Option func(*ClusterConfig) error
Option is a type of options for ClusterConfig
func MaxPartsPerTopic ¶
MaxPartsPerTopic is option function to set Maximum Partitions per Topic
func TLSEnabled ¶
TLSEnabled is option function to set if we need TLS or not
func TLSSkipVerify ¶
TLSSkipVerify is option function to set if we need to verify clusters cert
Source Files
Click to show internal directories.
Click to hide internal directories.