Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaBrokers ¶
type KafkaBrokers []TCPAddr
KafkaBrokers represents list of kafka broker tcp addresses.
func (*KafkaBrokers) AddFromString ¶
func (k *KafkaBrokers) AddFromString(brokers string)
AddFromString populates KafkaBrokers from comma-separated string.
func (KafkaBrokers) String ¶
func (k KafkaBrokers) String() string
func (KafkaBrokers) ToStringSlice ¶
func (k KafkaBrokers) ToStringSlice() []string
ToStringSlice converts KafkaBrokers to a slice of strings.
func (KafkaBrokers) Valid ¶
func (k KafkaBrokers) Valid() bool
Valid checks if all TCPAddr elements in KafkaBrokers are valid.
type KafkaTopicIdentifier ¶
type KafkaTopicIdentifier string
KafkaTopicIdentifier represents custom type for kafka topic names.
const ( DefaultKafkaBrokers = "127.0.0.1:9094" KafkaTopicIdentifierGitHub KafkaTopicIdentifier = "github" KafkaTopicIdentifierGitLab KafkaTopicIdentifier = "gitlab" KafkaTopicIdentifierBitBucket KafkaTopicIdentifier = "bitbucket" )
defaults.
func (KafkaTopicIdentifier) String ¶
func (s KafkaTopicIdentifier) String() string
func (KafkaTopicIdentifier) Valid ¶
func (s KafkaTopicIdentifier) Valid() bool
Valid checks and validates kafka topic name.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.